Order.go 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753
  1. package controllers
  2. import (
  3. "Cold_GoodsOrder/Nats/NatsServer"
  4. "Cold_GoodsOrder/conf"
  5. "Cold_GoodsOrder/lib"
  6. "Cold_GoodsOrder/models/Account"
  7. "Cold_GoodsOrder/models/Device"
  8. "Cold_GoodsOrder/models/Function"
  9. "encoding/base64"
  10. "fmt"
  11. "image"
  12. "log"
  13. "math"
  14. "net/url"
  15. "os"
  16. "strconv"
  17. "strings"
  18. "time"
  19. beego "github.com/beego/beego/v2/server/web"
  20. "github.com/qiniu/go-sdk/v7/sms/bytes"
  21. "github.com/signintech/gopdf"
  22. )
  23. // Handle
  24. type OrderController struct {
  25. beego.Controller
  26. User_r Account.User // 登陆的用户
  27. T_pid int // 公司id
  28. }
  29. func (c *OrderController) Prepare() {
  30. c.User_r = *Account.User_r
  31. c.T_pid = *Account.T_pid
  32. }
  33. func (c *OrderController) Order_List() {
  34. type R_JSONS struct {
  35. //必须的大写开头
  36. Data []Function.OrderR
  37. Num int64
  38. Page int
  39. Page_size int
  40. }
  41. var r_jsons R_JSONS
  42. page, _ := c.GetInt("page")
  43. if page < 1 {
  44. page = 1
  45. }
  46. page_z, _ := c.GetInt("page_z")
  47. if page_z < 1 {
  48. page_z = conf.Page_size
  49. }
  50. t_sn := c.GetString("t_sn")
  51. orderid := c.GetString("t_orderid")
  52. startTime := c.GetString("startTime")
  53. endTime := c.GetString("endTime")
  54. c.Data["Name"] = t_sn
  55. r_jsons.Data, r_jsons.Num = Function.Read_Order_List(c.User_r.T_pid, page, page_z, orderid, t_sn, startTime, endTime)
  56. r_jsons.Page = page
  57. r_jsons.Page_size = int(math.Ceil(float64(r_jsons.Num) / float64(page_z)))
  58. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  59. c.ServeJSON()
  60. return
  61. }
  62. func (c *OrderController) CreateOrderNo() {
  63. format := time.Now().Format("20060102")
  64. unix := time.Now().Unix()
  65. OrderNo := fmt.Sprintf("%v%v", format, unix)
  66. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: OrderNo}
  67. c.ServeJSON()
  68. return
  69. }
  70. func (c *OrderController) Order_Add() {
  71. T_orderid := c.GetString("T_orderid")
  72. WaybillNo := c.GetString("WaybillNo")
  73. T_sn := c.GetString("T_sn")
  74. T_receiving := c.GetString("T_receiving")
  75. ShippingUnit := c.GetString("ShippingUnit")
  76. EstimateStartTime := c.GetString("EstimateStartTime")
  77. EstimateEndTime := c.GetString("EstimateEndTime")
  78. T_text := c.GetString("T_text")
  79. PeerList := c.GetString("PeerList")
  80. DeviceType := c.GetString("DeviceType")
  81. IsExpatriate, _ := c.GetInt("IsExpatriate")
  82. Phone := c.GetString("Phone")
  83. ChildPid := c.GetString("ChildPid")
  84. CouriesName := c.GetString("CouriesName")
  85. CouriesId := c.GetString("CouriesId")
  86. DeliveryAddress := c.GetString("DeliveryAddress")
  87. ReceivingAddress := c.GetString("ReceivingAddress")
  88. if len(EstimateStartTime) <= 0 || len(EstimateEndTime) <= 0 {
  89. c.Data["json"] = lib.JSONS{Code: 207, Msg: "时间参数异常!"}
  90. c.ServeJSON()
  91. return
  92. }
  93. start, err := time.Parse("2006-01-02", EstimateStartTime)
  94. endtime, err := time.Parse("2006-01-02", EstimateEndTime)
  95. if err != nil {
  96. c.Data["json"] = lib.JSONS{Code: 207, Msg: "时间参数异常!"}
  97. c.ServeJSON()
  98. return
  99. }
  100. if len(CouriesId) != 0 {
  101. atoi, _ := strconv.Atoi(CouriesId)
  102. r := Function.Read_Couriers_ById(atoi)
  103. CouriesName = r.Name
  104. }
  105. var_ := Function.Order{
  106. T_pid: c.User_r.T_pid,
  107. T_orderid: T_orderid,
  108. WaybillNo: WaybillNo,
  109. ShippingUnit: ShippingUnit,
  110. T_sn: T_sn,
  111. T_receiving: T_receiving,
  112. EstimateStartTime: start,
  113. EstimateEndTime: endtime,
  114. T_text: T_text,
  115. T_State: 1,
  116. PeerList: PeerList,
  117. DeviceType: DeviceType,
  118. IsExpatriate: IsExpatriate,
  119. Phone: Phone,
  120. ChildPid: ChildPid,
  121. CouriesName: CouriesName,
  122. CouriesId: CouriesId,
  123. DeliveryAddress: DeliveryAddress,
  124. ReceivingAddress: ReceivingAddress,
  125. }
  126. if var_.IsExpatriate == 2 {
  127. if len(var_.Phone) < 0 {
  128. c.Data["json"] = lib.JSONS{Code: 203, Msg: "电话号码不能为空!"}
  129. c.ServeJSON()
  130. return
  131. }
  132. var_.ExpatriateReceiving = T_receiving
  133. }
  134. defer func() {
  135. s, _ := beego.AppConfig.String("orderUrl")
  136. addr := s + url.QueryEscape(lib.AesEncryptCBC(var_.T_orderid, lib.AesKey))
  137. sprintf := fmt.Sprintf("【冷链订单配送】您的订单正在配送中点击下方链接查看%v", addr)
  138. err = lib.SendModel(Phone, sprintf)
  139. if err != nil {
  140. c.Data["json"] = lib.JSONS{Code: 203, Msg: "发送短信失败!"}
  141. c.ServeJSON()
  142. return
  143. }
  144. }()
  145. id, err := Function.Add_Order(var_)
  146. if err != nil {
  147. c.Data["json"] = lib.JSONS{Code: 301, Msg: "添加失败!"}
  148. c.ServeJSON()
  149. return
  150. }
  151. NatsServer.AddUserLogs(Account.User_r.T_uuid, "订单系统", "添加", var_)
  152. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: id}
  153. c.ServeJSON()
  154. }
  155. func (c *OrderController) Order_Get() {
  156. id, _ := c.GetInt("T_id")
  157. r := Function.Read_Order_ById(id)
  158. // 记录不存在
  159. if r.Id == 0 {
  160. c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_id Err!"}
  161. c.ServeJSON()
  162. return
  163. }
  164. if c.User_r.T_pid != r.T_pid {
  165. c.Data["json"] = lib.JSONS{Code: 205, Msg: "没有权限!"}
  166. c.ServeJSON()
  167. return
  168. }
  169. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Function.OrderToOrderR(r)}
  170. c.ServeJSON()
  171. }
  172. func (c *OrderController) Order_Edit() {
  173. id, _ := c.GetInt("T_id")
  174. r := Function.Read_Order_ById(id)
  175. if r.Id == 0 {
  176. c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_id !"}
  177. c.ServeJSON()
  178. return
  179. }
  180. if c.User_r.T_pid != r.T_pid {
  181. c.Data["json"] = lib.JSONS{Code: 205, Msg: "没有权限!"}
  182. c.ServeJSON()
  183. return
  184. }
  185. WaybillNo := c.GetString("WaybillNo")
  186. T_sn := c.GetString("T_sn")
  187. T_receiving := c.GetString("T_receiving")
  188. ShippingUnit := c.GetString("ShippingUnit")
  189. EstimateStartTime := c.GetString("EstimateStartTime")
  190. EstimateEndTime := c.GetString("EstimateEndTime")
  191. T_text := c.GetString("T_text")
  192. PeerList := c.GetString("PeerList")
  193. DeviceType := c.GetString("DeviceType")
  194. IsExpatriate, _ := c.GetInt("IsExpatriate")
  195. Phone := c.GetString("Phone")
  196. ChildPid := c.GetString("ChildPid")
  197. T_State, _ := c.GetInt("T_State")
  198. CouriesName := c.GetString("CouriesName")
  199. CouriesId := c.GetString("CouriesId")
  200. DeliveryAddress := c.GetString("DeliveryAddress")
  201. ReceivingAddress := c.GetString("ReceivingAddress")
  202. if len(EstimateStartTime) <= 0 || len(EstimateEndTime) <= 0 {
  203. c.Data["json"] = lib.JSONS{Code: 207, Msg: "时间参数异常!"}
  204. c.ServeJSON()
  205. return
  206. }
  207. start, err := time.Parse("2006-01-02", EstimateStartTime)
  208. endtime, err := time.Parse("2006-01-02", EstimateEndTime)
  209. if err != nil {
  210. c.Data["json"] = lib.JSONS{Code: 207, Msg: "时间参数异常!"}
  211. c.ServeJSON()
  212. return
  213. }
  214. if len(WaybillNo) > 0 {
  215. r.WaybillNo = WaybillNo
  216. }
  217. if len(DeliveryAddress) > 0 {
  218. r.DeliveryAddress = DeliveryAddress
  219. }
  220. if len(ReceivingAddress) > 0 {
  221. r.ReceivingAddress = ReceivingAddress
  222. }
  223. if len(T_sn) > 0 {
  224. r.T_sn = T_sn
  225. }
  226. if len(T_receiving) > 0 {
  227. r.T_receiving = T_receiving
  228. }
  229. if len(T_text) > 0 {
  230. r.T_text = T_text
  231. }
  232. if len(ShippingUnit) > 0 {
  233. r.ShippingUnit = ShippingUnit
  234. }
  235. if len(EstimateStartTime) > 0 {
  236. r.EstimateStartTime = start
  237. }
  238. if len(EstimateEndTime) > 0 {
  239. r.EstimateEndTime = endtime
  240. }
  241. if len(PeerList) > 0 {
  242. r.PeerList = PeerList
  243. }
  244. if len(DeviceType) > 0 {
  245. r.DeviceType = DeviceType
  246. }
  247. if IsExpatriate != r.IsExpatriate {
  248. r.IsExpatriate = IsExpatriate
  249. }
  250. if len(Phone) > 0 {
  251. r.Phone = Phone
  252. }
  253. if len(ChildPid) > 0 {
  254. r.ChildPid = ChildPid
  255. }
  256. if len(CouriesName) > 0 {
  257. r.CouriesName = CouriesName
  258. }
  259. if len(CouriesId) > 0 {
  260. r.CouriesId = CouriesId
  261. }
  262. if T_State != 0 {
  263. r.T_State = T_State
  264. }
  265. is := Function.Update_Order(r, "waybill_no", "t_sn", "t_receiving", "shipping_unit", "estimate_start_time", "estimate_end_time", "peer_list", "device_type", "is_expatriate", "phone", "child_pid", "t__state", "t_text", "couries_name", "couries_id")
  266. if !is {
  267. c.Data["json"] = lib.JSONS{Code: 202, Msg: "修改失败!"}
  268. c.ServeJSON()
  269. return
  270. }
  271. NatsServer.AddUserLogs(Account.User_r.T_uuid, "订单系统", "修改", r)
  272. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  273. c.ServeJSON()
  274. return
  275. }
  276. func (c *OrderController) GetDeviceData() {
  277. var err error
  278. Id, _ := c.GetInt("T_id")
  279. if Id == 0 {
  280. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  281. c.ServeJSON()
  282. return
  283. }
  284. Order_r := Function.Read_Order_ById(Id)
  285. if Order_r.Id == 0 {
  286. c.Data["json"] = lib.JSONS{Code: 207, Msg: "Id Err!"}
  287. c.ServeJSON()
  288. return
  289. }
  290. _, err = NatsServer.ReadDeviceByT_sn(Order_r.T_sn)
  291. if err != nil {
  292. c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_sn Err!"}
  293. c.ServeJSON()
  294. return
  295. }
  296. DeviceSensor_r := NatsServer.ReadDeviceSensorALLByT_sn(Order_r.T_sn)
  297. if len(DeviceSensor_r) == 0 {
  298. c.Data["json"] = lib.JSONS{Code: 202, Msg: Order_r.T_sn + "设备没有数据!"}
  299. c.ServeJSON()
  300. return
  301. }
  302. var DeviceSensor_data []Device.DeviceData_R
  303. if Order_r.T_start_Ut.IsZero() {
  304. c.Data["json"] = lib.JSONS{Code: 202, Msg: Order_r.T_sn + "未开启配送"}
  305. c.ServeJSON()
  306. return
  307. }
  308. if Order_r.T_end_Ut.IsZero() {
  309. Order_r.T_end_Ut = time.Now()
  310. }
  311. 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)
  312. if len(DeviceSensor_data) == 0 {
  313. c.Data["json"] = lib.JSONS{Code: 202, Msg: Order_r.T_sn + "设备没有数据!"}
  314. c.ServeJSON()
  315. return
  316. }
  317. lastValidTsite := ""
  318. for i, sensor := range DeviceSensor_data {
  319. if len(sensor.T_site) <= 0 || sensor.T_site == "0,0" {
  320. DeviceSensor_data[i].T_site = lastValidTsite
  321. } else {
  322. lastValidTsite = sensor.T_site
  323. }
  324. }
  325. c.Data["json"] = lib.JSONS{Code: 200, Msg: "成功", Data: DeviceSensor_data}
  326. c.ServeJSON()
  327. }
  328. func (c *OrderController) Order_Del() {
  329. Id, _ := c.GetInt("T_id")
  330. r := Function.Read_Order_ById(Id)
  331. if r.Id == 0 {
  332. c.Data["json"] = lib.JSONS{Code: 202, Msg: "T_id Err!"}
  333. c.ServeJSON()
  334. return
  335. }
  336. if c.User_r.T_pid != r.T_pid {
  337. c.Data["json"] = lib.JSONS{Code: 202, Msg: "没有权限!"}
  338. c.ServeJSON()
  339. return
  340. }
  341. if is := Function.Delete_Order(r); !is {
  342. c.Data["json"] = lib.JSONS{Code: 202, Msg: "删除失败!"}
  343. c.ServeJSON()
  344. return
  345. }
  346. NatsServer.AddUserLogs(Account.User_r.T_uuid, "订单系统", "删除", r)
  347. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  348. c.ServeJSON()
  349. return
  350. }
  351. // Order_PDF 列表 - 接口
  352. func (c *OrderController) Order_PDF() {
  353. var err error
  354. Id, _ := c.GetInt("T_id")
  355. if Id == 0 {
  356. c.Data["json"] = lib.JSONS{Code: 202, Msg: "Id Err!"}
  357. c.ServeJSON()
  358. return
  359. }
  360. Order_r := Function.Read_Order_ById(Id)
  361. if Order_r.Id == 0 {
  362. c.Data["json"] = lib.JSONS{Code: 207, Msg: "Id Err!"}
  363. c.ServeJSON()
  364. return
  365. }
  366. Device_r, err := NatsServer.ReadDeviceByT_sn(Order_r.T_sn)
  367. if err != nil {
  368. c.Data["json"] = lib.JSONS{Code: 204, Msg: "T_sn Err!"}
  369. c.ServeJSON()
  370. return
  371. }
  372. DeviceSensor_r := NatsServer.ReadDeviceSensorALLByT_sn(Order_r.T_sn)
  373. if len(DeviceSensor_r) == 0 {
  374. c.Data["json"] = lib.JSONS{Code: 202, Msg: Order_r.T_sn + "设备没有数据!"}
  375. c.ServeJSON()
  376. return
  377. }
  378. var DeviceSensor_data []Device.DeviceData_R
  379. 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)
  380. if len(DeviceSensor_data) == 0 {
  381. c.Data["json"] = lib.JSONS{Code: 202, Msg: Order_r.T_sn + "设备没有数据!"}
  382. c.ServeJSON()
  383. return
  384. }
  385. pdf := &gopdf.GoPdf{}
  386. pdf.Start(gopdf.Config{PageSize: gopdf.Rect{W: 595.28, H: 841.89}}) //595.28, 841.89 = A4
  387. err = pdf.AddTTFFont("simsun", "static/fonts/三极行楷简体-粗.ttf")
  388. if err != nil {
  389. c.Data["json"] = lib.JSONS{Code: 204, Msg: err.Error()}
  390. c.ServeJSON()
  391. return
  392. }
  393. err = pdf.SetFont("simsun", "", 24)
  394. if err != nil {
  395. c.Data["json"] = lib.JSONS{Code: 205, Msg: err.Error()}
  396. c.ServeJSON()
  397. return
  398. }
  399. pdf.SetGrayFill(0.5)
  400. pdf.SetMargins(0, 20, 0, 20)
  401. pdf.AddPage()
  402. company, _ := NatsServer.Read_Company_ById(c.T_pid)
  403. log.Println(c.T_pid, c.User_r.T_pid)
  404. textw, _ := pdf.MeasureTextWidth(company.T_name + "-货单详情")
  405. pdf.SetX((595 / 2) - (textw / 2))
  406. pdf.SetY(40)
  407. pdf.Text(company.T_name + "-货单详情")
  408. // 线
  409. pdf.SetLineWidth(2)
  410. pdf.SetLineType("dashed")
  411. pdf.Line(10, 60, 585, 60)
  412. err = pdf.AddTTFFont("wts", "static/fonts/MiSans-Medium.ttf")
  413. if err != nil {
  414. c.Data["json"] = lib.JSONS{Code: 206, Msg: err.Error()}
  415. c.ServeJSON()
  416. return
  417. }
  418. err = pdf.SetFont("wts", "", 10)
  419. if err != nil {
  420. c.Data["json"] = lib.JSONS{Code: 207, Msg: err.Error()}
  421. c.ServeJSON()
  422. return
  423. }
  424. pages := pdf.GetNumberOfPages()
  425. pagenums := fmt.Sprintf("第 %d 页", pages)
  426. pagenum, _ := pdf.MeasureTextWidth(pagenums)
  427. pdf.SetX((595 / 2) - (pagenum / 2))
  428. pdf.SetY(830) // 设置页码位置
  429. pdf.Cell(nil, pagenums)
  430. // -------------
  431. x := 22.0
  432. w1 := 80.0
  433. w2 := 195.0
  434. lib.RectFillColor(pdf, "订单号:", 12, x, 80, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  435. x += w1
  436. lib.RectFillColor(pdf, Order_r.T_orderid, 12, x, 80, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  437. x += w2
  438. lib.RectFillColor(pdf, "运单号:", 12, x, 80, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  439. x += w1
  440. lib.RectFillColor(pdf, Order_r.T_outorderid, 12, x, 80, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  441. x += w2
  442. // -------------
  443. x = 22.0
  444. w1 = 80.0
  445. w2 = 195.0
  446. lib.RectFillColor(pdf, "设备名称:", 12, x, 100, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  447. x += w1
  448. lib.RectFillColor(pdf, Device_r.T_devName, 12, x, 100, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  449. x += w2
  450. lib.RectFillColor(pdf, "设备编号:", 12, x, 100, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  451. x += w1
  452. lib.RectFillColor(pdf, Device_r.T_sn, 12, x, 100, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  453. x += w2
  454. // -------------
  455. x = 22.0
  456. w1 = 80.0
  457. w2 = 240.0
  458. T_time := fmt.Sprintf("%s", Order_r.T_start_Ut.Format("2006-01-02 15:04:05")+" - "+Order_r.T_end_Ut.Format("2006-01-02 15:04:05"))
  459. lib.RectFillColor(pdf, "送货时间:", 12, x, 120, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  460. x += w1
  461. lib.RectFillColor(pdf, T_time, 12, x, 120, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  462. x += w2
  463. T_time = fmt.Sprintf("%s", Order_r.CreateTime.Format("2006-01-02 15:04:05"))
  464. lib.RectFillColor(pdf, "订单时间:", 12, x, 120, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  465. x += w1
  466. lib.RectFillColor(pdf, T_time, 12, x, 120, 150, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  467. // -------------
  468. x = 22.0
  469. w1 = 80.0
  470. w2 = 195.0*2 + 80
  471. ShippingUnit := fmt.Sprintf("%s", Order_r.ShippingUnit)
  472. lib.RectFillColor(pdf, "发货单位:", 12, x, 140, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  473. x += w1
  474. lib.RectFillColor(pdf, ShippingUnit, 12, x, 140, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  475. x += w2
  476. x = 22.0
  477. T_text := fmt.Sprintf("%s", Order_r.T_receiving)
  478. lib.RectFillColor(pdf, "收货单位:", 12, x, 160, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  479. x += w1
  480. lib.RectFillColor(pdf, T_text, 12, x, 160, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  481. x += w2
  482. // 数据汇总--------------------------------
  483. // 最低温度
  484. var T_t_l float32 = 100.0
  485. // 最高温度
  486. var T_t_u float32 = 0.0
  487. var T_t_v float32 = 0.0
  488. for n := 0; len(DeviceSensor_data) > n; n++ {
  489. // -计算温度
  490. if DeviceSensor_data[n].T_t < T_t_l {
  491. T_t_l = DeviceSensor_data[n].T_t
  492. }
  493. if DeviceSensor_data[n].T_t > T_t_u {
  494. T_t_u = DeviceSensor_data[n].T_t
  495. }
  496. T_t_v += DeviceSensor_data[n].T_t
  497. }
  498. var y float64 = 180
  499. x = 22.0
  500. w1 = 60.0
  501. w2 = 50.0
  502. err = pdf.SetFont("wts", "", 10)
  503. if err != nil {
  504. c.Data["json"] = lib.JSONS{Code: 207, Msg: err.Error()}
  505. c.ServeJSON()
  506. return
  507. }
  508. T_t := fmt.Sprintf(" %.1f℃ ", DeviceSensor_data[len(DeviceSensor_data)-1].T_t)
  509. lib.RectFillColor(pdf, "起送温度", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  510. x += w1
  511. lib.RectFillColor(pdf, T_t, 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  512. x += w2
  513. T_t = fmt.Sprintf(" %.1f℃ ", DeviceSensor_data[0].T_t)
  514. lib.RectFillColor(pdf, "送达温度", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  515. x += w1
  516. lib.RectFillColor(pdf, T_t, 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  517. x += w2
  518. T_t = fmt.Sprintf(" %.1f℃ ", T_t_l)
  519. lib.RectFillColor(pdf, "最低温度", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  520. x += w1
  521. lib.RectFillColor(pdf, T_t, 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  522. x += w2
  523. T_t = fmt.Sprintf(" %.1f℃ ", T_t_v/float32(len(DeviceSensor_data)))
  524. lib.RectFillColor(pdf, "平均温度", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  525. x += w1
  526. lib.RectFillColor(pdf, T_t, 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  527. x += w2
  528. T_t = fmt.Sprintf(" %.1f℃ ", T_t_u)
  529. lib.RectFillColor(pdf, "最高温度", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  530. x += w1
  531. lib.RectFillColor(pdf, T_t, 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  532. x += w2
  533. var height int
  534. getString := c.GetString("images")
  535. split := strings.Split(getString, ",")
  536. if len(split) >= 2 {
  537. imageBytes, err := base64.StdEncoding.DecodeString(split[1])
  538. if err != nil {
  539. c.Data["json"] = lib.JSONS{Code: 207, Msg: "无效的图像数据"}
  540. c.ServeJSON()
  541. return
  542. }
  543. decode, _, err := image.Decode(bytes.NewReader(imageBytes))
  544. // 获取图片的高度
  545. bounds := decode.Bounds()
  546. height = bounds.Dy()
  547. if height >= 500 {
  548. height = 500
  549. }
  550. with := bounds.Dx()
  551. log.Println("图片宽高", with, height)
  552. y = 220
  553. imgH, err := gopdf.ImageHolderByBytes(imageBytes)
  554. err = pdf.ImageByHolder(imgH, 10, y, &gopdf.Rect{W: 575, H: float64(height)})
  555. if err != nil {
  556. c.Data["json"] = lib.JSONS{Code: 207, Msg: "添加图片失败"}
  557. c.ServeJSON()
  558. return
  559. }
  560. } else {
  561. c.Data["json"] = lib.JSONS{Code: 207, Msg: "无效的图像数据"}
  562. c.ServeJSON()
  563. return
  564. }
  565. // -----------
  566. textw, _ = pdf.MeasureTextWidth("历史数据")
  567. pdf.SetX(20)
  568. pdf.SetY(float64(230 + height))
  569. pdf.Text("历史数据:")
  570. // 数据展示--------------------------------
  571. //var y float64 = 220
  572. y = float64(240 + height)
  573. x = 22.0
  574. w1 = 94.0
  575. w2 = 43.0
  576. lib.RectFillColor(pdf, "记录时间", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  577. x += w1
  578. lib.RectFillColor(pdf, "温度℃", 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  579. x += w2
  580. lib.RectFillColor(pdf, "记录时间", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  581. x += w1
  582. lib.RectFillColor(pdf, "温度℃", 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  583. x += w2
  584. lib.RectFillColor(pdf, "记录时间", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  585. x += w1
  586. lib.RectFillColor(pdf, "温度℃", 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  587. x += w2
  588. lib.RectFillColor(pdf, "记录时间", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  589. x += w1
  590. lib.RectFillColor(pdf, "温度℃", 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  591. x += w2
  592. // 数据展示--------------------------------
  593. y = float64(260 + height)
  594. err = pdf.SetFont("wts", "", 8)
  595. if err != nil {
  596. c.Data["json"] = lib.JSONS{Code: 207, Msg: err.Error()}
  597. c.ServeJSON()
  598. return
  599. }
  600. nln := 0
  601. x = 22.0
  602. for n := 0; len(DeviceSensor_data) > n; n++ {
  603. var textH float64 = 25 // if text height is 25px.
  604. pdf.SetNewY(y, textH)
  605. y = pdf.GetY()
  606. nln++
  607. if nln > 4 {
  608. nln = 1
  609. x = 22.0
  610. y += 18
  611. }
  612. if y >= 794 {
  613. err = pdf.SetFont("wts", "", 10)
  614. if err != nil {
  615. c.Data["json"] = lib.JSONS{Code: 207, Msg: err.Error()}
  616. c.ServeJSON()
  617. return
  618. }
  619. pdf.AddPage()
  620. pages := pdf.GetNumberOfPages()
  621. pagenums := fmt.Sprintf("第 %d 页", pages)
  622. pagenum, _ := pdf.MeasureTextWidth(pagenums)
  623. pdf.SetX((595 / 2) - (pagenum / 2))
  624. pdf.SetY(830) // 设置页码位置
  625. pdf.Cell(nil, pagenums)
  626. x = 22.0
  627. y = 20
  628. lib.RectFillColor(pdf, "记录时间", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  629. x += w1
  630. lib.RectFillColor(pdf, "温度℃", 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  631. x += w2
  632. lib.RectFillColor(pdf, "记录时间", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  633. x += w1
  634. lib.RectFillColor(pdf, "温度℃", 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  635. x += w2
  636. lib.RectFillColor(pdf, "记录时间", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  637. x += w1
  638. lib.RectFillColor(pdf, "温度℃", 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  639. x += w2
  640. lib.RectFillColor(pdf, "记录时间", 10, x, y, w1, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  641. x += w1
  642. lib.RectFillColor(pdf, "温度℃", 10, x, y, w2, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  643. x += w2
  644. x = 22.0
  645. y += 20
  646. }
  647. err = pdf.SetFont("wts", "", 8)
  648. // ------------------
  649. T_t = fmt.Sprintf(" %.1f ", DeviceSensor_data[n].T_t)
  650. T_time = fmt.Sprintf("%s", DeviceSensor_data[n].T_time)
  651. lib.RectFillColor(pdf, T_time, 10, x, y, w1, 18, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  652. x += w1
  653. lib.RectFillColor(pdf, T_t, 10, x, y, w2, 18, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  654. x += w2
  655. }
  656. err = pdf.SetFont("wts", "", 10)
  657. if err != nil {
  658. c.Data["json"] = lib.JSONS{Code: 207, Msg: err.Error()}
  659. c.ServeJSON()
  660. return
  661. }
  662. //----------------
  663. timeStr := "ofile/" + time.Now().Format("20060102150405") + ".pdf"
  664. err = pdf.WritePdf(timeStr)
  665. if err != nil {
  666. c.Data["json"] = lib.JSONS{Code: 207, Msg: err.Error()}
  667. c.ServeJSON()
  668. return
  669. }
  670. //上传 OSS
  671. //url, is := NatsServer.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/"+timeStr, timeStr)
  672. url, is := NatsServer.Qiniu_UploadFile(timeStr, timeStr)
  673. if !is {
  674. c.Data["json"] = lib.JSONS{Code: 203, Msg: "oss!"}
  675. c.ServeJSON()
  676. return
  677. }
  678. //删除目录
  679. err = os.Remove(timeStr)
  680. if err != nil {
  681. fmt.Println(err)
  682. }
  683. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url}
  684. c.ServeJSON()
  685. return
  686. }