V3MqttHandle.go 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835
  1. package MqttServer
  2. import (
  3. "Cold_mqtt/MqttServer/WarningNotice"
  4. "Cold_mqtt/Nats/NatsServer"
  5. "Cold_mqtt/lib"
  6. "Cold_mqtt/logs"
  7. "Cold_mqtt/models/Device"
  8. "Cold_mqtt/models/Product"
  9. "Cold_mqtt/models/Warning"
  10. "encoding/json"
  11. "fmt"
  12. "io/ioutil"
  13. "math"
  14. "net/http"
  15. "strconv"
  16. "strings"
  17. "time"
  18. )
  19. func AsyncFuncV3(r_Device *Device.Device, Ms_project Ms2m_Project, msg []byte) {
  20. ms2_Return := Ms2_Return{
  21. Type: Ms_project.Type,
  22. Msid: Ms_project.Msid,
  23. Status: 1,
  24. }
  25. switch Ms_project.Type {
  26. case 0: // 0:实时数据
  27. var ms2_Project_list Ms2_Project_list
  28. err := json.Unmarshal(msg, &ms2_Project_list)
  29. if err != nil {
  30. logs.Println("MqttServer", "JSON反序列化失败[Ms_project_0]", string(msg))
  31. logs.Println("JSON反序列化失败[Ms_project_0],err=", err)
  32. return
  33. }
  34. for _, v := range ms2_Project_list.Data {
  35. // 是否存在传感器 不存在 跳过
  36. DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r_Device.T_sn, lib.To_int(v["id"]))
  37. if !is {
  38. logs.Println("MqttServer", "实时数据 传感器不存在 跳过处理", r_Device.T_sn+lib.To_string(v["id"]))
  39. continue
  40. }
  41. // lost 字段为传感器离线状态(1代表离线,在线不传此字段),如果离线 温湿度时间数据为空
  42. if _, lost_is := v["lost"]; lost_is {
  43. DeviceSensor_r.T_link = 0
  44. Device.Update_DeviceSensor(DeviceSensor_r, "T_link")
  45. Warning.Add_DeviceLogs(103, *r_Device, fmt.Sprintf("[%d]%s: 传感器异常断开!", DeviceSensor_r.T_id, DeviceSensor_r.T_name))
  46. // 发现 lost 此字段 代表 传感器异常!!!!!
  47. continue
  48. }
  49. int64_, _ := strconv.ParseInt(lib.To_string(v["ut"]), 10, 64)
  50. UT := time.Unix(int64_, 0)
  51. logs.Println(UT.Format("2006-01-02 15:04:05"))
  52. DeviceSensorParameter_r, is := Device.Read_DeviceSensorParameter(r_Device.T_sn, DeviceSensor_r.T_id)
  53. if !is {
  54. logs.Println("MqttServer", "记录数据 传感器参数不存在 跳过处理", r_Device.T_sn+lib.To_string(v["id"]))
  55. continue
  56. }
  57. //// 更新记录 - 缓存
  58. DeviceData_t := Device.DeviceData_R{
  59. T_t: float32(math.Ceil(float64(lib.To_float32(v["t"])*10)) / 10),
  60. T_rh: float32(math.Ceil(float64(lib.To_float32(v["h"])*10)) / 10),
  61. T_Site: lib.To_string(v["s"]),
  62. T_time: UT,
  63. T_sp: DeviceSensorParameter_r.Id,
  64. }
  65. Device.RedisDeviceData_Set(r_Device.T_sn, DeviceSensor_r.T_id, DeviceData_t)
  66. r_Device.T_Site = DeviceData_t.T_Site
  67. // 传感器属于 连接状态
  68. if DeviceSensor_r.T_link != 1 {
  69. DeviceSensor_r.T_link = 1
  70. Device.Update_DeviceSensor(DeviceSensor_r, "T_link")
  71. }
  72. }
  73. Device.Update_Device_new(*r_Device, "T_Site")
  74. // 反馈透传
  75. NatsServer.Mqtt_DeviceReal(r_Device.T_sn, msg)
  76. return
  77. case 1: // 1:记录数据
  78. var ms2_Project_list Ms2_Project_list
  79. err := json.Unmarshal(msg, &ms2_Project_list)
  80. if err != nil {
  81. logs.Println("MqttServer", "JSON反序列化失败[Ms_project_1]", string(msg))
  82. logs.Println("JSON反序列化失败[Ms_project_1],err=", err)
  83. return
  84. }
  85. // 回复
  86. ms2_Return.Status = 1
  87. for _, v := range ms2_Project_list.Data {
  88. int64_, _ := strconv.ParseInt(lib.To_string(v["ut"]), 10, 64)
  89. UT := time.Unix(int64_, 0)
  90. //时间异常 大于10s,直接丢掉数据
  91. if (UT.Unix() - time.Now().Unix()) > 10 {
  92. ms2_Return.Status = 3
  93. continue
  94. }
  95. // 是否存在传感器 不存在 跳过
  96. DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r_Device.T_sn, lib.To_int(v["id"]))
  97. if !is {
  98. logs.Println("MqttServer", "记录数据 传感器不存在 跳过处理", r_Device.T_sn+lib.To_string(v["id"]))
  99. continue
  100. }
  101. // 获取传感器参数
  102. DeviceSensorParameter_r, is := Device.Read_DeviceSensorParameter(r_Device.T_sn, DeviceSensor_r.T_id)
  103. if !is {
  104. logs.Println("MqttServer", "记录数据 传感器参数不存在 跳过处理", r_Device.T_sn+lib.To_string(v["id"]))
  105. continue
  106. }
  107. //// 更新记录 - 缓存
  108. DeviceData_t := Device.DeviceData_R{
  109. T_t: float32(math.Ceil(float64(lib.To_float32(v["t"])*10)) / 10),
  110. T_rh: float32(math.Ceil(float64(lib.To_float32(v["h"])*10)) / 10),
  111. T_Site: lib.To_string(v["s"]),
  112. T_time: UT,
  113. T_sp: DeviceSensorParameter_r.Id,
  114. }
  115. if r_, DeviceData_old_r := Device.Add_DeviceData(r_Device.T_sn, DeviceSensor_r.T_id, DeviceData_t); r_ {
  116. // 被替换
  117. Device.Add_DeviceDataOld(Device.DeviceDataOld{
  118. T_sn: r_Device.T_sn,
  119. T_id: DeviceSensor_r.T_id,
  120. T_t: DeviceData_old_r.T_t,
  121. T_rh: DeviceData_old_r.T_rh,
  122. T_Site: DeviceData_old_r.T_site,
  123. T_time: UT,
  124. T_operation: 2,
  125. T_uuid: "",
  126. })
  127. }
  128. r_Device.T_Site = DeviceData_t.T_Site // GPS
  129. // 监控状态 数据有效
  130. if (time.Now().Unix() - UT.Unix()) < 30 {
  131. r_Device.T_monitor = 1
  132. }
  133. }
  134. Device.Update_Device_new(*r_Device, "T_monitor", "T_Site")
  135. NatsServer.Mqtt_DeviceReal(r_Device.T_sn, msg)
  136. break
  137. case 2: // 2:设备报警
  138. var ms2_Project Ms2_Project_list
  139. err := json.Unmarshal(msg, &ms2_Project)
  140. if err != nil {
  141. logs.PrintlnError("MqttServer", "设备报警", string(msg))
  142. break
  143. }
  144. // 缓存报警ID,防止重复发送
  145. if Warning.Redis_Warning_Repeat_T_sn_Msid(r_Device.T_sn + "|" + strconv.FormatInt(ms2_Project.Msid, 10)) {
  146. logs.Println("MqttServer", " 存在报警 跳过:", string(msg))
  147. break
  148. }
  149. for _, v := range ms2_Project.Data {
  150. var Warning_r Warning.Warning
  151. Warning_r.T_pid = r_Device.T_pid
  152. Warning_r.T_tp = lib.To_int(v["tp"]) // 报警类型
  153. Warning_r.T_sn = r_Device.T_sn
  154. Warning_r.T_id = lib.To_int(v["id"])
  155. Warning_r.T_Msid = Ms_project.Msid
  156. Warning_r.T_D_name = r_Device.T_devName
  157. Warning_r.T_State = 1
  158. // 获取 传感器 参数
  159. DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r_Device.T_sn, Warning_r.T_id)
  160. if !is {
  161. logs.Println("MqttServer", " 传感器ID 不存在", string(msg))
  162. break
  163. }
  164. Warning_r.T_DS_name = DeviceSensor_r.T_name
  165. // 获取 传感器 配置参数
  166. DeviceSensorParameter_r, is := Device.Read_DeviceSensorParameter(Warning_r.T_sn, Warning_r.T_id)
  167. if !is {
  168. logs.Println("MqttServer", " 传感器ID 配置参数不存在", string(msg))
  169. break
  170. }
  171. // 温度湿度 封装
  172. T := float32(math.Ceil(float64(lib.To_float32(v["t"])*10)) / 10)
  173. RH := float32(math.Ceil(float64(lib.To_float32(v["h"])*10)) / 10)
  174. // 持续时间计算
  175. time_int64_, _ := strconv.ParseInt(lib.To_string(v["ut"]), 10, 64)
  176. time_int64_f, _ := strconv.ParseInt(lib.To_string(v["fut"]), 10, 64)
  177. if time_int64_f == 0 {
  178. time_int64_f = time_int64_
  179. }
  180. Warning_r.T_fUt = time.Unix(time_int64_f, 0)
  181. time_int64_f_x := (int(time_int64_) - int(time_int64_f))
  182. logs.Println(strconv.FormatInt(Warning_r.T_Msid, 10)+"持续时间:", time_int64_f_x)
  183. Warning_r.T_Ut = time.Unix(time_int64_, 0)
  184. // 如果记录时间大于当前时间
  185. //if time.Now().Unix() < time_int64_ {
  186. // Warning_r.T_Ut = time.Now()
  187. // Warning_r.T_Remark += "设备时间异常!"
  188. // // 推送同步 时间
  189. // go func() {
  190. // time.Sleep(time.Second * 3)
  191. // logs.Println(fmt.Sprintf("%s 时间相差:%d", r_Device.T_sn, int(math.Abs(float64(time_int64_-time.Now().Unix())))))
  192. // Warning.Add_DeviceLogs(103, *r_Device, fmt.Sprintf("时间相差:%d", int(math.Abs(float64(time_int64_-time.Now().Unix())))))
  193. // RTC_TimeStr(r_Device.T_sn, time.Now().Unix(), 99)
  194. // }()
  195. //}
  196. //时间异常 大于10s,直接丢掉数据
  197. if (time_int64_ - time.Now().Unix()) > 10 {
  198. ms2_Return.Status = 3
  199. continue
  200. }
  201. // 查看 sn 是否有归属
  202. if Warning_r.T_pid == 0 { // 寻找报警归属
  203. if len(Warning_r.T_sn) > 10 {
  204. r_Device, err := Device.Read_Device_ByT_sn(Warning_r.T_sn)
  205. if err != nil {
  206. logs.Println("MessageDisconnected 没有该设备:", Warning_r.T_sn)
  207. }
  208. Warning_r.T_pid = r_Device.T_pid
  209. }
  210. }
  211. //tp 报警类型
  212. // 1 温度超上限报警
  213. // 2 温度超下限报警
  214. // 3 温度恢复正常
  215. // 4 湿度超上限报警
  216. // 5 湿度超下限报警
  217. // 6 湿度恢复正常
  218. // 7 温度超上限预警
  219. // 8 温度超下限预警
  220. // 9 温度预警恢复正常
  221. // 10 湿度超上限预警
  222. // 11 湿度超下限预警
  223. // 12 湿度预警恢复正常
  224. //当期湿度:88.0%(↓23.0~↑73.0),已持续1小时33秒
  225. if time_int64_f_x > 0 {
  226. Warning_r.T_Remark += "已持续 " + lib.MinuteToDataTime(time_int64_f_x)
  227. }
  228. //// 报警处理
  229. WarningNotice.WarningCompanyNotice(&Warning_r, T, RH)
  230. //封装具体信息
  231. switch {
  232. case Warning_r.T_tp == 1, Warning_r.T_tp == 2, Warning_r.T_tp == 3:
  233. Warning_r.T_Remark = "当前温度:" + strconv.FormatFloat(float64(T), 'f', -1, 32) + " (↓" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_Tlower), 'f', -1, 32) + "~↑" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_Tupper), 'f', -1, 32) + ")," + Warning_r.T_Remark
  234. break
  235. case Warning_r.T_tp == 4, Warning_r.T_tp == 5, Warning_r.T_tp == 6:
  236. Warning_r.T_Remark = "当前湿度:" + strconv.FormatFloat(float64(RH), 'f', -1, 32) + " (↓" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_RHlower), 'f', -1, 32) + "~↑" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_RHupper), 'f', -1, 32) + ")," + Warning_r.T_Remark
  237. break
  238. case Warning_r.T_tp == 7, Warning_r.T_tp == 8, Warning_r.T_tp == 9:
  239. Warning_r.T_Remark = "当前温度:" + strconv.FormatFloat(float64(T), 'f', -1, 32) + " (↓" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_tprel), 'f', -1, 32) + "~↑" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_tpreu), 'f', -1, 32) + ")," + Warning_r.T_Remark
  240. break
  241. case Warning_r.T_tp == 10, Warning_r.T_tp == 11, Warning_r.T_tp == 12:
  242. Warning_r.T_Remark = "当前湿度:" + strconv.FormatFloat(float64(RH), 'f', -1, 32) + " (↓" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_hprel), 'f', -1, 32) + "~↑" + strconv.FormatFloat(float64(DeviceSensorParameter_r.T_hpreu), 'f', -1, 32) + ")," + Warning_r.T_Remark
  243. break
  244. }
  245. // 添加报警
  246. _, err = Warning.Add_Warning(Warning_r)
  247. //// 不能 同时增加 记录数据,因为缺失GPS数据
  248. }
  249. NatsServer.Mqtt_DeviceReal(r_Device.T_sn, msg)
  250. break
  251. case 3: // 3:读取主机参数
  252. var ms2_Project Ms2_Project
  253. err := json.Unmarshal(msg, &ms2_Project)
  254. if err != nil {
  255. logs.PrintlnError("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg))
  256. return
  257. }
  258. T_name := lib.To_string(ms2_Project.Data["name"])
  259. if len(T_name) == 0 {
  260. return
  261. }
  262. if T_name == "*" {
  263. T_name = r_Device.T_devName
  264. }
  265. if r_Device.T_devName == "未知类型" {
  266. T_name = Product.Read_ProductType_Get(r_Device.T_model)
  267. }
  268. if T_name == r_Device.T_sn {
  269. T_name = Product.Read_ProductType_Get(r_Device.T_model)
  270. }
  271. r_Device.T_devName = T_name
  272. Deviceparameter := Device.DeviceParameter{
  273. T_sn: r_Device.T_sn,
  274. T_name: T_name,
  275. T_saveT: lib.To_int(ms2_Project.Data["saveT"]), //数据保存间隔 (s)*最小值60
  276. T_overA: lib.To_int(ms2_Project.Data["overA"]), //超限报警触发间隔 (s)*最小值60
  277. T_outA: lib.To_int(ms2_Project.Data["outA"]), //断电报警触发间隔 (s)*最小值60
  278. T_lostA: lib.To_int(ms2_Project.Data["lostA"]), //传感器掉线报警触发间隔 (s)*最小值60
  279. T_warnD: lib.To_int(ms2_Project.Data["warnD"]), // 超限预警延时 (s)*
  280. T_scan: lib.To_int(ms2_Project.Data["scan"]), // 显示轮播间隔 s(1~240) 默认:5 *
  281. T_warn: lib.To_int(ms2_Project.Data["warn"]), // 超限预警触发间隔 (s)*为0时预警只触发一次 *最小值60
  282. T_bat: lib.To_int(ms2_Project.Data["bat"]), //电池电量下限 (%)*
  283. T_dormancy: lib.To_int(ms2_Project.Data["dormancy"]), //是否进入休眠 0:关闭 1:开启 默认:0
  284. T_snum: lib.To_int(ms2_Project.Data["snum"]), // 【管理主机】 - 传感器数量 (范围0~255)
  285. T_btname: lib.To_string(ms2_Project.Data["btname"]), //--蓝牙打印机名称 用于移动端连接蓝牙打印机
  286. T_btsid: lib.To_int(ms2_Project.Data["btsid"]), //--打印机服务号 用于移动端连接蓝牙打印机
  287. T_btchar: lib.To_int(ms2_Project.Data["btchar"]), //--蓝牙特征码 用于移动端连接蓝牙打印机
  288. //T_speed: lib.To_int(ms2_Project.Data["speed"]), //--蓝牙特征码 用于移动端连接蓝牙打印机
  289. T_State: 1,
  290. T_SendState: 1,
  291. }
  292. if Device.Add_DeviceParameter_fun(Deviceparameter) {
  293. Warning.Add_DeviceLogs(102, *r_Device, "修改主机参数")
  294. }
  295. Device.Update_Device_new(*r_Device, "T_devName")
  296. // 获取所有传感器
  297. //Read_DeviceSensorParameter(r_Device.T_sn)
  298. // 不用反馈
  299. return
  300. case 4: // 4:设置主机参数 - 反馈
  301. var ms2_Return_r Ms2_Return
  302. err := json.Unmarshal(msg, &ms2_Return_r)
  303. if err != nil {
  304. logs.PrintlnError("MqttServer", "JSON反序列化失败[4:设置主机参数]", string(msg), err.Error())
  305. return
  306. }
  307. DeviceParameter_r, err := Device.Read_DeviceParameter_SN_Msid(r_Device.T_sn, ms2_Return_r.Msid)
  308. if err != nil {
  309. logs.PrintlnError("MqttServer", " SN_Msid Err![4:设置主机参数]", string(msg), err.Error())
  310. return
  311. }
  312. DeviceParameter_r.T_SendState = 2
  313. // 判断参数 //1设置成功,0设置失败
  314. if ms2_Return_r.Status == 1 {
  315. DeviceParameter_r.T_SendState = 1
  316. r_Device.T_devName = DeviceParameter_r.T_name
  317. Device.Update_Device_new(*r_Device, "T_devName")
  318. }
  319. // 状态更新
  320. Device.Update_DeviceParameter_(DeviceParameter_r)
  321. // 同步参数
  322. DeviceParameter_r.T_State = 1
  323. Device.Add_DeviceParameter_fun(DeviceParameter_r)
  324. Warning.Add_DeviceLogs(102, *r_Device, "修改主机参数-反馈成功")
  325. // 取消掉 其他参数
  326. Device.UPDATE_DeviceParameter_SN_T_SendState_2_sql(r_Device.T_sn)
  327. return
  328. case 5: // 读取传感器参数
  329. var ms2_Project Ms2_Project_list
  330. err := json.Unmarshal(msg, &ms2_Project)
  331. if err != nil {
  332. logs.Println("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg))
  333. logs.Println("JSON反序列化失败[Ms_Parameter],err=", err)
  334. return
  335. }
  336. for _, v := range ms2_Project.Data {
  337. DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r_Device.T_sn, lib.To_int(v["id"]))
  338. T_name := lib.To_string(v["name"])
  339. if len(T_name) == 0 {
  340. continue
  341. }
  342. if T_name == "*" {
  343. T_name = r_Device.T_sn + "-" + lib.To_string(v["id"])
  344. if is {
  345. T_name = DeviceSensor_r.T_name
  346. }
  347. }
  348. // 不存在
  349. if !is {
  350. DeviceSensor_r.T_sn = r_Device.T_sn
  351. DeviceSensor_r.T_pid = r_Device.T_pid
  352. DeviceSensor_r.T_id = lib.To_int(v["id"])
  353. DeviceSensor_r.T_name = T_name
  354. DeviceSensor_r.T_datashow = 1
  355. DeviceSensor_r.T_sort = 1
  356. DeviceSensor_r.T_monitor = r_Device.T_monitor
  357. // 设备同步参数
  358. DeviceSensor_r.T_Dattery = r_Device.T_Dattery
  359. DeviceSensor_r.T_Site = r_Device.T_Site
  360. DeviceSensor_r.T_State = r_Device.T_State
  361. DeviceSensor_r.T_online = r_Device.T_online
  362. DeviceSensor_r.Id = Device.Add_DeviceSensor(*r_Device, DeviceSensor_r)
  363. }
  364. // 记录传感器
  365. Devicesensorparameter := Device.DeviceSensorParameter{
  366. T_sn: r_Device.T_sn,
  367. T_id: lib.To_int(v["id"]),
  368. T_name: T_name,
  369. // 报警
  370. T_Tlower: lib.To_float32(v["tl"]),
  371. T_Tupper: lib.To_float32(v["tu"]),
  372. T_RHlower: lib.To_float32(v["hl"]),
  373. T_RHupper: lib.To_float32(v["hu"]),
  374. // 预警
  375. T_enprel: lib.To_int(v["enprel"]),
  376. T_tprel: lib.To_float32(v["tprel"]),
  377. T_tpreu: lib.To_float32(v["tpreu"]),
  378. T_hprel: lib.To_float32(v["hprel"]),
  379. T_hpreu: lib.To_float32(v["hpreu"]),
  380. T_enprelnote: lib.To_int(v["enprelnote"]),
  381. //T_speed: lib.To_int(v["speed"]),
  382. //T_sense: lib.To_int(v["sense"]),
  383. T_en: lib.To_int(v["en"]),
  384. T_free: lib.To_int(v["free"]),
  385. T_Msid: ms2_Project.Msid, // 消息识别ID
  386. T_SendState: 1, // 发送状态 0 待发送 1 发送成功 2 失败 3 覆盖
  387. T_State: 1, // 1 系统获取 2 用户提交
  388. }
  389. // 过滤参数 相同
  390. id := Device.Add_DeviceSensorParameter_fun(Devicesensorparameter)
  391. Warning.Add_DeviceLogs(102, *r_Device, "修改设备参数")
  392. logs.Println("DeviceSensorParameter ID:", id)
  393. // 对 传感器 的状态更新
  394. DeviceSensor_r.T_name = T_name
  395. DeviceSensor_r.T_sp = id
  396. Device.Update_DeviceSensor(DeviceSensor_r, "T_name", "T_sp")
  397. }
  398. go func() {
  399. time.Sleep(time.Second * 3)
  400. Get_Device_Realtime(r_Device.T_sn)
  401. }()
  402. // 不用反馈
  403. return
  404. case 6: // 设置传感器参数
  405. var ms2_Return_r Ms2_Return
  406. err := json.Unmarshal(msg, &ms2_Return_r)
  407. if err != nil {
  408. logs.Println("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg))
  409. logs.Println("JSON反序列化失败[Ms_Parameter],err=", err)
  410. return
  411. }
  412. r, is := Device.Read_DeviceSensorParameter_SN_T_id_Msid(r_Device.T_sn, ms2_Return_r.Msid)
  413. if !is {
  414. logs.Println("设备配置", "设置设备参数 SN_Msid Err! [Ms_Parameter_r]", string(msg))
  415. return
  416. }
  417. r.T_SendState = 2
  418. // 判断参数 //1设置成功,0设置失败
  419. if ms2_Return_r.Status == 1 {
  420. r.T_SendState = 1
  421. DeviceSensor_r, is := Device.Read_DeviceSensor_ByT_sn(r.T_sn, r.T_id)
  422. if !is {
  423. logs.Println("设备配置", "设置传感器参数 r_DeviceSensor Err! [Ms_Parameter_r]", r.T_sn+"|"+strconv.Itoa(r.T_id))
  424. logs.Println("设置传感器参数 r_DeviceSensor Err![Ms_Parameter_r],err=", r.T_sn+"|"+strconv.Itoa(r.T_id))
  425. logs.Println("MqttServer", r_Device.T_sn+"["+lib.To_string(r.T_id)+"] 没有找到传感器:", string(msg))
  426. break
  427. }
  428. // 添加一份最新的
  429. r.T_State = 0
  430. id := Device.Add_DeviceSensorParameter_fun(r)
  431. Warning.Add_DeviceLogs(102, *r_Device, "修改设备参数")
  432. logs.Println("DeviceSensorParameter ID:", id)
  433. // 对 传感器 的状态更新
  434. DeviceSensor_r.T_name = r.T_name
  435. DeviceSensor_r.T_sp = id
  436. Device.Update_DeviceSensor(DeviceSensor_r, "T_name", "T_sp")
  437. }
  438. // 状态更新
  439. Device.Update_DeviceSensorParameter(r, "T_SendState")
  440. // 取消掉 其他参数
  441. Device.UPDATE_DeviceSensorParamete_SN_T_SendState_2_sql(r_Device.T_sn, strconv.Itoa(r.T_id))
  442. //// 更新主机参数
  443. //go func() {
  444. // time.Sleep(time.Second * 1)
  445. // Read_DeviceSensorParameter3(r_Device.T_sn)
  446. //}()
  447. return
  448. case 12:
  449. var ms2_Project Ms2_Project_list
  450. err := json.Unmarshal(msg, &ms2_Project)
  451. if err != nil {
  452. logs.PrintlnError("MqttServer", "JSON反序列化失败[Ms_project_2]", string(msg), err.Error())
  453. break
  454. }
  455. // 缓存报警ID,防止重复发送
  456. if Warning.Redis_Warning_Repeat_T_sn_Msid(r_Device.T_sn + "|" + strconv.FormatInt(ms2_Project.Msid, 10)) {
  457. logs.Println("MqttServer", " 存在报警 跳过:", string(msg))
  458. break
  459. }
  460. // {
  461. // "sn": "YD0123456789",
  462. // "type": 12,
  463. // "msid": 125456001,
  464. // "data": [
  465. // {
  466. // "tp":7, // 对照 报警类型对应表
  467. // "msg": "报警信息或故障信息", //如:1号传感器故障 (非必填,但是 要带字段)
  468. // "ut": 1626857518 //产生时间
  469. // },
  470. // ..........
  471. //]
  472. //}
  473. for _, v := range ms2_Project.Data {
  474. var Warning_r Warning.Warning
  475. Warning_r.T_tp = lib.To_int(v["tp"]) + 100 // 报警类型
  476. Warning_r.T_sn = r_Device.T_sn
  477. Warning_r.T_id = -1
  478. Warning_r.T_Msid = Ms_project.Msid
  479. Warning_r.T_D_name = r_Device.T_devName
  480. Warning_r.T_DS_name = r_Device.T_devName
  481. time_int64_, _ := strconv.ParseInt(lib.To_string(v["ut"]), 10, 64)
  482. Warning_r.T_Ut = time.Unix(time_int64_, 0)
  483. Warning_r.T_Remark = lib.To_string(v["msg"])
  484. Warning_r.T_State = 1
  485. //时间异常 大于10s,直接丢掉数据
  486. if (time_int64_ - time.Now().Unix()) > 10 {
  487. ms2_Return.Status = 3
  488. continue
  489. }
  490. // 持续时间计算
  491. time_int64_f, _ := strconv.ParseInt(lib.To_string(v["fut"]), 10, 64)
  492. if time_int64_f == 0 {
  493. time_int64_f = time_int64_
  494. }
  495. Warning_r.T_fUt = time.Unix(time_int64_f, 0)
  496. time_int64_f_x := (int(time_int64_) - int(time_int64_f))
  497. logs.Println(strconv.FormatInt(Warning_r.T_Msid, 10)+"持续时间:", time_int64_f_x)
  498. if time_int64_f_x > 0 {
  499. Warning_r.T_Remark += " 已持续" + lib.MinuteToDataTime(time_int64_f_x)
  500. }
  501. // 查看 sn 是否有归属
  502. if Warning_r.T_pid == 0 { // 寻找报警归属
  503. if len(Warning_r.T_sn) > 10 {
  504. r_Device, err := Device.Read_Device_ByT_sn(Warning_r.T_sn)
  505. if err != nil {
  506. logs.Println("MessageDisconnected 没有该设备:", Warning_r.T_sn)
  507. }
  508. Warning_r.T_pid = r_Device.T_pid
  509. }
  510. }
  511. switch Warning_r.T_tp {
  512. case 101: // 主机报警
  513. Warning_r.T_State = 3
  514. WarningNotice.WarningToAdminId(&Warning_r, []int{}) // 发送给 绑定公司管理员
  515. break
  516. case 115:
  517. Warning_r.T_Remark = "开始监测任务"
  518. // 1 start:开始监测任务,
  519. // 防止没有结束命令
  520. DeviceTask_r, ok := Device.Read_DeviceTask_All_Limit_1(r_Device.T_sn)
  521. logs.Println("DeviceTask_r.id:", DeviceTask_r.Id)
  522. if ok {
  523. if DeviceTask_r.T_Ut_end.IsZero() {
  524. logs.Println("没有结束 强制 更新上一条")
  525. DeviceTask_r.T_Ut_end = Warning_r.T_Ut
  526. Device.Update_DeviceTask(DeviceTask_r)
  527. }
  528. }
  529. logs.Println("插入新任务")
  530. // 插入开始 任务
  531. dt := Device.DeviceTask{
  532. T_sn: r_Device.T_sn,
  533. T_Ut_start: Warning_r.T_Ut,
  534. T_Ut: Warning_r.T_Ut,
  535. T_State: 1,
  536. }
  537. Device.Add_DeviceTask(dt)
  538. r_Device.T_monitor = 1
  539. break
  540. case 116:
  541. Warning_r.T_Remark = "中途打印任务"
  542. DeviceTask_r, ok := Device.Read_DeviceTask_All_Limit_1(r_Device.T_sn)
  543. if ok {
  544. if DeviceTask_r.T_Ut_end.IsZero() {
  545. DeviceTask_r.T_Ut_end = Warning_r.T_Ut
  546. DeviceTask_r.T_State = 3
  547. Device.Update_DeviceTask(DeviceTask_r)
  548. // 插入开始 任务
  549. dt := Device.DeviceTask{
  550. T_sn: r_Device.T_sn,
  551. T_Ut_start: DeviceTask_r.T_Ut_start,
  552. T_Ut: Warning_r.T_Ut,
  553. T_State: 1,
  554. }
  555. logs.Println("插入新任务")
  556. Device.Add_DeviceTask(dt)
  557. }
  558. }
  559. r_Device.T_monitor = 1
  560. break
  561. case 117:
  562. Warning_r.T_Remark = "结束监测任务"
  563. // 防止没有结束命令
  564. DeviceTask_r, ok := Device.Read_DeviceTask_All_Limit_1(r_Device.T_sn)
  565. if ok {
  566. if DeviceTask_r.T_Ut_end.IsZero() {
  567. DeviceTask_r.T_Ut_end = Warning_r.T_Ut
  568. DeviceTask_r.T_State = 2
  569. Device.Update_DeviceTask(DeviceTask_r)
  570. }
  571. }
  572. r_Device.T_monitor = 0
  573. break
  574. }
  575. //// 推送运维信息
  576. WarningNotice.WarningCompanyNotice(&Warning_r, 0, 0)
  577. // 添加报警
  578. _, err = Warning.Add_Warning(Warning_r)
  579. }
  580. Device.Update_Device_new(*r_Device, "T_monitor")
  581. break
  582. case 13: // 上电推送信息
  583. var ms2_Project Ms2_Project
  584. err := json.Unmarshal(msg, &ms2_Project)
  585. if err != nil {
  586. logs.Println("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg))
  587. logs.Println("JSON反序列化失败[Ms_Parameter],err=", err)
  588. return
  589. }
  590. var Warning_r Warning.Warning
  591. Warning_r.T_tp = 106 // 报警类型
  592. Warning_r.T_sn = r_Device.T_sn
  593. Warning_r.T_D_name = r_Device.T_devName
  594. Warning_r.T_id = 0
  595. Warning_r.T_DS_name = ""
  596. Warning_r.T_Msid = Ms_project.Msid
  597. r_Device.T_model = lib.To_string(ms2_Project.Data["model"])
  598. r_Device.T_sver = lib.To_string(ms2_Project.Data["sver"])
  599. r_Device.T_hver = lib.To_string(ms2_Project.Data["hver"])
  600. r_Device.T_imei = lib.To_string(ms2_Project.Data["imei"])
  601. r_Device.T_iccid = lib.To_string(ms2_Project.Data["iccid"])
  602. Device.Update_Device(*r_Device, "T_model", "T_sver", "T_hver", "T_imei", "T_iccid")
  603. // 加入日志
  604. // "rtc" : 1671173184,//设备时间
  605. // "rtl" : 3,//设备开机累计运行秒数
  606. // "st" : 1671173177,//设备开机时间
  607. // "lst" : 0//设备上次关机时间
  608. UT_rtc := time.Unix(int64(lib.To_int64(ms2_Project.Data["rtc"])), 0).Format("2006-01-02 15:04:05")
  609. UT_st := time.Unix(int64(lib.To_int64(ms2_Project.Data["st"])), 0).Format("2006-01-02 15:04:05")
  610. UT_lst := time.Unix(int64(lib.To_int64(ms2_Project.Data["lst"])), 0).Format("2006-01-02 15:04:05")
  611. UT_rtl := lib.To_string(ms2_Project.Data["rtl"])
  612. str := "----- 设备信息 -----\n"
  613. str += "设备型号:" + r_Device.T_model + " |\n"
  614. str += "软件版本:" + r_Device.T_sver + " |\n"
  615. str += "硬件版本:" + r_Device.T_hver + " |\n"
  616. str += "模组imei:" + r_Device.T_imei + " |\n"
  617. str += "sim卡号:" + r_Device.T_iccid + " |\n"
  618. str += "设备时间:" + UT_rtc + " |\n"
  619. str += "设备开机时间:" + UT_st + " |\n"
  620. str += "设备上次关机时间:" + UT_lst + " |\n"
  621. str += "设备开机累计运行秒数:" + UT_rtl + " |\n"
  622. Warning_r.T_Remark = str
  623. Warning_r.T_Ut = time.Now()
  624. Warning_r.T_State = 1
  625. // 添加报警
  626. _, err = Warning.Add_Warning(Warning_r)
  627. return
  628. case 15: // 网络延时测试
  629. Rt_Project_Data_r := Ms2_Project{
  630. Type: Ms_project.Type,
  631. Msid: Ms_project.Msid,
  632. }
  633. var Data map[string]interface{}
  634. Data = make(map[string]interface{})
  635. Data["ut"] = Ms_project.Dut
  636. Rt_Project_Data_r.Data = Data
  637. // 回复
  638. jsonStu, err := json.Marshal(Rt_Project_Data_r)
  639. if err != nil {
  640. return
  641. }
  642. Mqtt_publish(r_Device.T_sn, string(jsonStu))
  643. return
  644. case 88: // 临时授权
  645. var ms2_Project Ms2_Project
  646. err := json.Unmarshal(msg, &ms2_Project)
  647. if err != nil {
  648. logs.PrintlnError("MqttServer", "JSON反序列化失败[Ms_Parameter]", string(msg))
  649. return
  650. }
  651. url := "192.168.0.33:3991/CreateAuth"
  652. method := "POST"
  653. payload := strings.NewReader("model=" + lib.To_string(ms2_Project.Data["model"]) + "&sver=" + lib.To_string(ms2_Project.Data["sver"]) + "&hver=" + lib.To_string(ms2_Project.Data["hver"]) + "&imei=" + lib.To_string(ms2_Project.Data["imei"]) + "&iccid=" + lib.To_string(ms2_Project.Data["iccid"]) + "&sn=" + lib.To_string(ms2_Project.Data["sn"]))
  654. client := &http.Client{}
  655. req, err := http.NewRequest(method, url, payload)
  656. if err != nil {
  657. fmt.Println(err)
  658. return
  659. }
  660. req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
  661. res, err := client.Do(req)
  662. if err != nil {
  663. fmt.Println(err)
  664. return
  665. }
  666. defer res.Body.Close()
  667. body, err := ioutil.ReadAll(res.Body)
  668. if err != nil {
  669. fmt.Println(err)
  670. return
  671. }
  672. fmt.Println(string(body))
  673. // 实体类
  674. type Ms2_Projectccc struct {
  675. Pass string `json:"psaa"`
  676. Status string `json:"status"`
  677. }
  678. var ms2_Projectccc Ms2_Projectccc
  679. err = json.Unmarshal(body, &ms2_Projectccc)
  680. if err != nil {
  681. logs.PrintlnError("MqttServer", "JSON反序列化失败[Ms2_Projectccc]", string(msg))
  682. return
  683. }
  684. Rt_Project_Data_r := Ms2_Project{
  685. Type: Ms_project.Type,
  686. Msid: Ms_project.Msid,
  687. }
  688. var Data map[string]interface{}
  689. Data = make(map[string]interface{})
  690. Data["Pass"] = ms2_Projectccc.Pass
  691. Data["Status"] = ms2_Projectccc.Status
  692. Rt_Project_Data_r.Data = Data
  693. // 回复
  694. jsonStu, err := json.Marshal(Rt_Project_Data_r)
  695. if err != nil {
  696. return
  697. }
  698. Mqtt_publish(r_Device.T_sn, string(jsonStu))
  699. return
  700. case 98: // 时间同步
  701. RTC_TimeStr(r_Device.T_sn, Ms_project.Msid, 98)
  702. return
  703. case 100: // 设备实时状态推送
  704. var ms2_Project Ms2_Project
  705. err := json.Unmarshal(msg, &ms2_Project)
  706. if err != nil {
  707. logs.Println("MqttServer", "JSON反序列化失败[Ms_project_]", string(msg))
  708. logs.Println("JSON反序列化失败[Ms_project],err=", err)
  709. return
  710. }
  711. r_Device.T_Dattery = lib.To_int(ms2_Project.Data["power"]) //#设备剩余电量百分比
  712. r_Device.T_rssi = lib.To_string(ms2_Project.Data["rssi"]) //#信号强度
  713. Device.Update_Device(*r_Device, "T_Dattery", "T_rssi")
  714. // 反馈透传
  715. NatsServer.Mqtt_DeviceReal(r_Device.T_sn, msg)
  716. Device.Update_Device_new(*r_Device, "T_Dattery")
  717. return
  718. default:
  719. return
  720. }
  721. // 回复
  722. jsonStu, err := json.Marshal(ms2_Return)
  723. if err != nil {
  724. logs.PrintlnError("MqttServer", "json.Marshal ", string(msg))
  725. logs.Println("回复失败 [Ms_project_0],err=", err)
  726. return
  727. }
  728. Mqtt_publish(r_Device.T_sn, string(jsonStu))
  729. }