NatsServer.go 5.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275
  1. package NatsServer
  2. import (
  3. "ColdVerify_local/conf"
  4. "ColdVerify_local/lib"
  5. "ColdVerify_local/logs"
  6. "ColdVerify_local/models/Account"
  7. "ColdVerify_local/models/Device"
  8. "ColdVerify_local/models/Task"
  9. "errors"
  10. "github.com/nats-io/nats.go"
  11. "github.com/vmihailenco/msgpack/v5"
  12. "time"
  13. )
  14. func Update_Task(v Task.Task) error {
  15. logs.Debug("Nats =>", lib.FuncName(), v)
  16. b, err := msgpack.Marshal(&v)
  17. if err != nil {
  18. return err
  19. }
  20. msg, err := lib.Nats.Request("ColdVerify_Server_Update_Task", b, 3*time.Second)
  21. if err != nil {
  22. return err
  23. }
  24. type T_R struct {
  25. Code int16 `xml:"Code"`
  26. Msg string `xml:"Msg"`
  27. Data Task.Task `xml:"Data"`
  28. }
  29. var t_R T_R
  30. err = msgpack.Unmarshal(msg.Data, &t_R)
  31. if err != nil {
  32. return err
  33. }
  34. if t_R.Code != 200 {
  35. return errors.New(t_R.Msg)
  36. }
  37. return nil
  38. }
  39. func Read_Task(T_task_id string) (task Task.Task, err error) {
  40. //logs.Println("Nats =>", lib.FuncName(), T_task_id)
  41. if lib.Nats == nil || !lib.Nats.IsConnected() {
  42. lib.Nats, err = nats.Connect("nats://" + conf.NatsServer_Url)
  43. if err != nil {
  44. logs.Println("无法重新连接到 NATS:", err)
  45. } else {
  46. logs.Println("成功重新连接到 NATS...")
  47. }
  48. }
  49. msg, err := lib.Nats.Request("ColdVerify_Server_Read_Task", []byte(T_task_id), 3*time.Second)
  50. if err != nil {
  51. logs.Error(lib.FuncName(), err.Error())
  52. return task, err
  53. }
  54. type T_R struct {
  55. Code int16 `xml:"Code"`
  56. Msg string `xml:"Msg"`
  57. Data Task.Task `xml:"Data"`
  58. }
  59. var t_R T_R
  60. err = msgpack.Unmarshal(msg.Data, &t_R)
  61. if err != nil {
  62. logs.Error(lib.FuncName(), err.Error())
  63. return task, err
  64. }
  65. if t_R.Code != 200 {
  66. err = errors.New(t_R.Msg)
  67. logs.Error(lib.FuncName(), err.Error())
  68. return task, err
  69. }
  70. return t_R.Data, nil
  71. }
  72. func Read_User(T_uuid string) (user Account.User, err error) {
  73. logs.Println("Nats =>", lib.FuncName(), T_uuid)
  74. msg, err := lib.Nats.Request("ColdVerify_Server_Read_User", []byte(T_uuid), 3*time.Second)
  75. if err != nil {
  76. logs.Error(lib.FuncName(), err.Error())
  77. return user, err
  78. }
  79. type T_R struct {
  80. Code int16 `xml:"Code"`
  81. Msg string `xml:"Msg"`
  82. Data Account.User `xml:"Data"`
  83. }
  84. var t_R T_R
  85. err = msgpack.Unmarshal(msg.Data, &t_R)
  86. if err != nil {
  87. logs.Error(lib.FuncName(), err.Error())
  88. return user, err
  89. }
  90. if t_R.Code != 200 {
  91. err = errors.New(t_R.Msg)
  92. logs.Error(lib.FuncName(), err.Error())
  93. return user, err
  94. }
  95. return t_R.Data, nil
  96. }
  97. func Read_Admin(T_uuid string) (user Account.Admin, err error) {
  98. logs.Println("Nats =>", lib.FuncName(), T_uuid)
  99. msg, err := lib.Nats.Request("ColdVerify_Server_Read_Admin", []byte(T_uuid), 3*time.Second)
  100. if err != nil {
  101. logs.Error(lib.FuncName(), err.Error())
  102. return user, err
  103. }
  104. type T_R struct {
  105. Code int16 `xml:"Code"`
  106. Msg string `xml:"Msg"`
  107. Data Account.Admin `xml:"Data"`
  108. }
  109. var t_R T_R
  110. err = msgpack.Unmarshal(msg.Data, &t_R)
  111. if err != nil {
  112. logs.Error(lib.FuncName(), err.Error())
  113. return user, err
  114. }
  115. if t_R.Code != 200 {
  116. err = errors.New(t_R.Msg)
  117. logs.Error(lib.FuncName(), err.Error())
  118. return user, err
  119. }
  120. return t_R.Data, nil
  121. }
  122. func Device_Class_List(T_task_id string) (list []Device.DeviceClassList, err error) {
  123. //logs.Println("Nats =>", lib.FuncName(), T_task_id)
  124. if !lib.Nats.IsConnected() {
  125. lib.Nats, err = nats.Connect("nats://" + conf.NatsServer_Url)
  126. if err != nil {
  127. logs.Println("无法重新连接到 NATS:", err)
  128. }
  129. logs.Println("成功重新连接到 NATS...")
  130. }
  131. msg, err := lib.Nats.Request("ColdVerify_Server_Device_Class_List", []byte(T_task_id), 3*time.Second)
  132. if err != nil {
  133. logs.Error(lib.FuncName(), err.Error())
  134. return list, err
  135. }
  136. type T_R struct {
  137. Code int16 `xml:"Code"`
  138. Msg string `xml:"Msg"`
  139. Data []Device.DeviceClassList `xml:"Data"`
  140. }
  141. var t_R T_R
  142. err = msgpack.Unmarshal(msg.Data, &t_R)
  143. if err != nil {
  144. logs.Error(lib.FuncName(), err.Error())
  145. return list, err
  146. }
  147. if t_R.Code != 200 {
  148. err = errors.New(t_R.Msg)
  149. logs.Error(lib.FuncName(), err.Error())
  150. return list, err
  151. }
  152. return t_R.Data, nil
  153. }
  154. func Add_DeviceClassList(T_task_id, T_sn, T_id string) (err error) {
  155. logs.Debug("Nats =>", lib.FuncName(), T_task_id, T_sn, T_id)
  156. type T_R struct {
  157. T_task_id string `xml:"T_task_id"` // 任务主键id
  158. T_sn string `xml:"T_sn"`
  159. T_id string `xml:"T_id"`
  160. }
  161. t_R := T_R{
  162. T_task_id: T_task_id,
  163. T_sn: T_sn,
  164. T_id: T_id,
  165. }
  166. b, err := msgpack.Marshal(&t_R)
  167. if err != nil {
  168. return err
  169. }
  170. msg, err := lib.Nats.Request("ColdVerify_Server_Add_DeviceClassList", b, 3*time.Second)
  171. if err != nil {
  172. return err
  173. }
  174. type T_Res struct {
  175. Code int16 `xml:"Code"`
  176. Msg string `xml:"Msg"`
  177. }
  178. var t_Res T_Res
  179. err = msgpack.Unmarshal(msg.Data, &t_Res)
  180. if err != nil {
  181. return err
  182. }
  183. if t_Res.Code != 200 {
  184. return errors.New(t_Res.Msg)
  185. }
  186. return nil
  187. }
  188. func Edit_DeviceClassList(T_task_id, T_sn, T_id string) (err error) {
  189. logs.Debug("Nats =>", lib.FuncName(), T_task_id, T_sn, T_id)
  190. type T_R struct {
  191. T_task_id string `xml:"T_task_id"` // 任务主键id
  192. T_sn string `xml:"T_sn"`
  193. T_id string `xml:"T_id"`
  194. }
  195. t_R := T_R{
  196. T_task_id: T_task_id,
  197. T_sn: T_sn,
  198. T_id: T_id,
  199. }
  200. b, err := msgpack.Marshal(&t_R)
  201. if err != nil {
  202. return err
  203. }
  204. msg, err := lib.Nats.Request("ColdVerify_Server_Edit_DeviceClassList", b, 3*time.Second)
  205. if err != nil {
  206. return err
  207. }
  208. type T_Res struct {
  209. Code int16 `xml:"Code"`
  210. Msg string `xml:"Msg"`
  211. }
  212. var t_Res T_Res
  213. err = msgpack.Unmarshal(msg.Data, &t_Res)
  214. if err != nil {
  215. return err
  216. }
  217. if t_Res.Code != 200 {
  218. return errors.New(t_Res.Msg)
  219. }
  220. return nil
  221. }
  222. func Del_TaskData_ByT_BindDeviceDataTime(T_task_id string) {
  223. logs.Debug("Nats =>", lib.FuncName(), T_task_id)
  224. err := lib.Nats.Publish("ColdVerify_Server_Del_TaskData_ByT_BindDeviceDataTime", []byte(T_task_id))
  225. if err != nil {
  226. logs.Error("Nats =>", lib.FuncName(), err)
  227. }
  228. }