NotAuth.go 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
  1. package controllers
  2. import (
  3. "Cold_GoodsOrder/Nats/NatsServer"
  4. "Cold_GoodsOrder/lib"
  5. "Cold_GoodsOrder/models/Device"
  6. "Cold_GoodsOrder/models/Function"
  7. "log"
  8. "net/url"
  9. "strconv"
  10. "time"
  11. beego "github.com/beego/beego/v2/server/web"
  12. )
  13. type NotAuthController struct {
  14. beego.Controller
  15. }
  16. func (c *NotAuthController) GetDeviceData() {
  17. s, _ := beego.AppConfig.String("orderUrl")
  18. addr := s + url.QueryEscape(lib.AesEncryptCBC("202502191739933974", lib.AesKey))
  19. log.Println(addr)
  20. var err error
  21. order := c.GetString("order")
  22. if len(order) == 0 {
  23. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  24. c.ServeJSON()
  25. return
  26. }
  27. Order_r := Function.Read_Order_ByOderid(order)
  28. if Order_r.Id == 0 {
  29. c.Data["json"] = lib.JSONS{Code: 207, Msg: "Id Err!"}
  30. c.ServeJSON()
  31. return
  32. }
  33. _, err = NatsServer.ReadDeviceByT_sn(Order_r.T_sn)
  34. if err != nil {
  35. c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_sn Err!"}
  36. c.ServeJSON()
  37. return
  38. }
  39. DeviceSensor_r := NatsServer.ReadDeviceSensorALLByT_sn(Order_r.T_sn)
  40. if len(DeviceSensor_r) == 0 {
  41. c.Data["json"] = lib.JSONS{Code: 202, Msg: Order_r.T_sn + "设备没有数据!"}
  42. c.ServeJSON()
  43. return
  44. }
  45. var DeviceSensor_data []Device.DeviceData_R
  46. if Order_r.T_start_Ut.IsZero() {
  47. c.Data["json"] = lib.JSONS{Code: 202, Msg: Order_r.T_sn + "未开启配送"}
  48. c.ServeJSON()
  49. return
  50. }
  51. if Order_r.T_end_Ut.IsZero() {
  52. Order_r.T_end_Ut = time.Now()
  53. }
  54. DeviceSensor_data, _ = NatsServer.ReadDeviceDataListBy_T_snid(Order_r.T_sn+","+strconv.Itoa(DeviceSensor_r[0].T_id), Order_r.T_start_Ut.Format("2006-01-02 15:04:05"), Order_r.T_end_Ut.Format("2006-01-02 15:04:05"), 0, 9999)
  55. if len(DeviceSensor_data) == 0 {
  56. c.Data["json"] = lib.JSONS{Code: 202, Msg: Order_r.T_sn + "设备没有数据!"}
  57. c.ServeJSON()
  58. return
  59. }
  60. lastValidTsite := ""
  61. for i, sensor := range DeviceSensor_data {
  62. if len(sensor.T_site) <= 0 || sensor.T_site == "0,0" {
  63. DeviceSensor_data[i].T_site = lastValidTsite
  64. } else {
  65. lastValidTsite = sensor.T_site
  66. }
  67. }
  68. c.Data["json"] = lib.JSONS{Code: 200, Msg: "成功", Data: DeviceSensor_data}
  69. c.ServeJSON()
  70. }
  71. func (c *NotAuthController) Test() {
  72. time.Sleep(5 * time.Second)
  73. c.Data["json"] = lib.JSONS{Code: 200, Msg: "成功", Data: nil}
  74. c.ServeJSON()
  75. }