package MqttServer

//func MqttPolling() {
//
//	var DevicePollingMap map[string]int /*创建集合 */
//	DevicePollingMap = make(map[string]int)
//
//	for true {
//
//		for k, _ := range DevicePollingMap {
//			Dpm, ok := DevicePollingMap[k]
//			if ok {
//				r_Device, err := Device.Read_Device_ByT_sn(k)
//				if err != nil {
//					delete(DevicePollingMap, k)
//					continue
//				}
//				Read_DeviceSensorParameter(r_Device.T_sn)
//
//				DevicePollingMap[k] = Dpm - 1
//				if Dpm <= 1 {
//					delete(DevicePollingMap, k)
//				}
//
//			}
//			time.Sleep(10 * time.Millisecond)
//		}
//
//		time.Sleep(10 * time.Second)
//	}
//}