diff --git a/router.go b/router.go index 569532f..669689a 100644 --- a/router.go +++ b/router.go @@ -497,13 +497,16 @@ func changeDataV2(loraNode LoraNode){ // log.Println("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@") // log.Println("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@00000:",loraNode) // log.Println("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@11111:",DEVICEDATAS.DATA[loraNode.DEVICE]) - DEVICEDATAS.RLock() - if DEVICEDATAS.DATA[loraNode.DEVICE]!=nil{ - DEVICEDATAS.DATA[loraNode.DEVICE].DATA[loraNode.LOCATION_DATA] = loraNode.CURRENT_DATA - }else{ - log.Println("changeDataV2.DEVICEDATAS not init") - } - DEVICEDATAS.RUnlock() + // DEVICEDATAS.RLock() + DEVICEDATAS.Lock() + _,ok := DEVICEDATAS.DATA[loraNode.DEVICE] + if ok { + DEVICEDATAS.DATA[loraNode.DEVICE].DATA[loraNode.LOCATION_DATA] = loraNode.CURRENT_DATA + }else{ + log.Println("changeDataV2.DEVICEDATAS load fail:",loraNode.DEVICE) + + } + DEVICEDATAS.Unlock() log.Println("yunhorndeug.push.data.change:",DEVICEDATAS.DATA[loraNode.DEVICE]) // log.Println("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@") }