Data.go 36 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186
  1. package controllers
  2. import (
  3. "Cold_Api/Nats/NatsServer"
  4. "Cold_Api/conf"
  5. "Cold_Api/controllers/lib"
  6. "Cold_Api/models/Admin"
  7. "Cold_Api/models/Device"
  8. "Cold_Api/models/System"
  9. "fmt"
  10. beego "github.com/beego/beego/v2/server/web"
  11. "github.com/signintech/gopdf"
  12. "github.com/xuri/excelize/v2"
  13. "math"
  14. "os"
  15. "strconv"
  16. "strings"
  17. "time"
  18. )
  19. type DataController struct {
  20. beego.Controller
  21. }
  22. // 列表 -
  23. func (c *DataController) DataPlane() {
  24. // 验证登录
  25. b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  26. if !b_ {
  27. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  28. c.ServeJSON()
  29. return
  30. }
  31. c.TplName = "Data/DataPlane.html"
  32. } // 列表 -
  33. func (c *DataController) DataReal_html() {
  34. // 验证登录
  35. b_, R_u := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  36. if !b_ {
  37. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  38. c.ServeJSON()
  39. return
  40. }
  41. Name := c.GetString("Name")
  42. c.Data["Class_List"] = Device.Read_DeviceClass_ALL_T_uuid_1(R_u.Admin_uuid)
  43. c.Data["Name"] = Name
  44. c.TplName = "Data/DataReal.html"
  45. }
  46. // 列表 -
  47. func (c *DataController) DataRealCalss_html() {
  48. // 验证登录
  49. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  50. if !b_ {
  51. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  52. c.ServeJSON()
  53. return
  54. }
  55. c.Data["Admin_r"] = admin_r
  56. Name := c.GetString("Name")
  57. c.Data["Class_List"] = Device.Read_DeviceClass_ALL_T_uuid_1(admin_r.Admin_uuid)
  58. c.Data["Name"] = Name
  59. c.TplName = "Data/DataRealCalss.html"
  60. }
  61. // 列表 -
  62. func (c *DataController) DataList_html() {
  63. // 验证登录
  64. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  65. if !b_ {
  66. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  67. c.ServeJSON()
  68. return
  69. }
  70. c.Data["Admin_r"] = admin_r
  71. Name := c.GetString("Name")
  72. c.Data["Class_List"] = Device.Read_DeviceClass_ALL_T_uuid_1(admin_r.Admin_uuid)
  73. c.Data["Name"] = Name
  74. c.TplName = "Data/DataList.html"
  75. }
  76. // 列表 -
  77. func (c *DataController) DataLine_html() {
  78. // 验证登录
  79. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  80. if !b_ {
  81. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  82. c.ServeJSON()
  83. return
  84. }
  85. c.Data["Admin_r"] = admin_r
  86. Name := c.GetString("Name")
  87. c.Data["Class_List"] = Device.Read_DeviceClass_ALL_T_uuid_1(admin_r.Admin_uuid)
  88. c.Data["Name"] = Name
  89. c.TplName = "Data/DataLine.html"
  90. }
  91. // 列表 -
  92. func (c *DataController) DataMap_html() {
  93. // 验证登录
  94. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  95. if !b_ {
  96. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  97. c.ServeJSON()
  98. return
  99. }
  100. c.Data["Admin_r"] = admin_r
  101. Name := c.GetString("Name")
  102. c.Data["Class_List"] = Device.Read_DeviceClass_ALL_T_uuid_1(admin_r.Admin_uuid)
  103. c.Data["Name"] = Name
  104. c.TplName = "Data/DataMap.html"
  105. }
  106. func (c *DataController) Device_Sensor() {
  107. // 验证登录
  108. b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  109. if !b_ {
  110. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  111. c.ServeJSON()
  112. return
  113. }
  114. T_sn := c.GetString("T_sn")
  115. T_id, _ := c.GetInt("T_id")
  116. //c.Data["Class_List"] = Device.Read_Class_All_1()
  117. DeviceSensor_r, err := Device.Read_DeviceSensor_ByTsn_Tid(T_sn, T_id)
  118. if err != nil {
  119. c.Data["json"] = lib.JSONS{Code: 201, Msg: "err!"}
  120. c.ServeJSON()
  121. return
  122. }
  123. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Device.DeviceSensorToDeviceSensor_R(DeviceSensor_r)}
  124. c.ServeJSON()
  125. return
  126. }
  127. func (c *DataController) Device_Sensor_List() {
  128. // 验证登录
  129. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  130. if !b_ {
  131. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  132. c.ServeJSON()
  133. return
  134. }
  135. type R_JSONS struct {
  136. //必须的大写开头
  137. DeviceSensor_lite []Device.DeviceSensor_R
  138. Num int
  139. Page int
  140. Page_size int
  141. Pages []lib.Page_T
  142. }
  143. var r_jsons R_JSONS
  144. page, _ := c.GetInt("page")
  145. println(page)
  146. if page < 1 {
  147. page = 1
  148. }
  149. page_z, _ := c.GetInt("page_z")
  150. println(page_z)
  151. if page_z == 0 {
  152. page_z = conf.Page_size
  153. }
  154. T_sn := c.GetString("T_sn")
  155. T_Calss_id, _ := c.GetInt("T_class_id")
  156. T_name := c.GetString("T_name")
  157. SN_type := c.GetString("SN_type")
  158. //c.Data["Class_List"] = Device.Read_Class_All_1()
  159. var cnt int64
  160. r_jsons.DeviceSensor_lite, cnt = Device.Read_DeviceSensor_class_ALL_1(admin_r, T_Calss_id, page, page_z, T_sn, T_name, SN_type)
  161. page_size := math.Ceil(float64(cnt) / float64(page_z))
  162. r_jsons.Page = int(page)
  163. r_jsons.Page_size = int(page_size)
  164. r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
  165. r_jsons.Num = int(cnt)
  166. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  167. c.ServeJSON()
  168. return
  169. }
  170. // 列表 - 接口
  171. func (c *DataController) Device_Sensor_Data() {
  172. page, _ := c.GetInt("page")
  173. page_z, _ := c.GetInt("page_z")
  174. println(page)
  175. if page < 1 {
  176. page = 1
  177. }
  178. if page_z < 1 {
  179. page_z = 10
  180. }
  181. T_id, _ := c.GetInt("T_id")
  182. SN := c.GetString("T_sn")
  183. Time_start := c.GetString("Time_start")
  184. Time_end := c.GetString("Time_end")
  185. type R_JSONS struct {
  186. //必须的大写开头
  187. DeviceSensor_data []Device.DeviceData_
  188. Num int
  189. Page int
  190. Page_size int
  191. Pages []lib.Page_T
  192. }
  193. var r_jsons R_JSONS
  194. var cnt int
  195. r_jsons.DeviceSensor_data, cnt = Device.Read_DeviceSensorData_ById_List(SN, T_id, Time_start, Time_end, page, page_z)
  196. page_size := math.Ceil(float64(cnt) / float64(page_z))
  197. r_jsons.Page = int(page)
  198. r_jsons.Page_size = int(page_size)
  199. r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
  200. r_jsons.Num = int(cnt)
  201. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  202. c.ServeJSON()
  203. return
  204. }
  205. // 列表 - 接口
  206. func (c *DataController) Device_Sensor_Data_More() {
  207. page, _ := c.GetInt("page")
  208. page_z, _ := c.GetInt("page_z")
  209. println(page)
  210. if page < 1 {
  211. page = 1
  212. }
  213. if page_z < 1 {
  214. page_z = 10
  215. }
  216. T_snid := c.GetString("T_snid")
  217. Time_start := c.GetString("Time_start")
  218. Time_end := c.GetString("Time_end")
  219. if len(T_snid) < 10 {
  220. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  221. c.ServeJSON()
  222. return
  223. }
  224. type R_JSONS struct {
  225. //必须的大写开头
  226. DeviceSensor_data []Device.DeviceData_
  227. Num int
  228. Page int
  229. Page_size int
  230. Pages []lib.Page_T
  231. }
  232. var r_jsons R_JSONS
  233. var cnt int
  234. r_jsons.DeviceSensor_data, cnt = Device.Read_DeviceSensorData_By_T_snid_List(T_snid, Time_start, Time_end, page, page_z)
  235. page_size := math.Ceil(float64(cnt) / float64(page_z))
  236. r_jsons.Page = int(page)
  237. r_jsons.Page_size = int(page_size)
  238. r_jsons.Pages = lib.Func_page(int64(page), int64(page_size))
  239. r_jsons.Num = int(cnt)
  240. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  241. c.ServeJSON()
  242. return
  243. }
  244. // 列表 - 接口
  245. func (c *DataController) Device_Sensor_Data_Excel() {
  246. // 验证登录
  247. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  248. if !b_ {
  249. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  250. c.ServeJSON()
  251. return
  252. }
  253. T_snid := c.GetString("T_snid")
  254. Time_start := c.GetString("Time_start")
  255. Time_end := c.GetString("Time_end")
  256. if len(T_snid) < 10 {
  257. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  258. c.ServeJSON()
  259. return
  260. }
  261. var DeviceSensor_data []Device.DeviceData_
  262. DeviceSensor_data, _ = Device.Read_DeviceSensorData_By_T_snid_List(T_snid, Time_start, Time_end, 0, 9999)
  263. f := excelize.NewFile() // 设置单元格的值
  264. // 这里设置表头
  265. f.SetCellValue("Sheet1", "A1", "编号")
  266. f.SetCellValue("Sheet1", "B1", "传感器名称")
  267. f.SetCellValue("Sheet1", "C1", "温度℃")
  268. f.SetCellValue("Sheet1", "D1", "湿度%")
  269. f.SetCellValue("Sheet1", "E1", "温度范围 ℃")
  270. f.SetCellValue("Sheet1", "F1", "湿度范围 %")
  271. f.SetCellValue("Sheet1", "G1", "记录时间")
  272. // 设置列宽
  273. f.SetColWidth("Sheet1", "A", "A", 10)
  274. f.SetColWidth("Sheet1", "B", "B", 15)
  275. f.SetColWidth("Sheet1", "C", "D", 10)
  276. f.SetColWidth("Sheet1", "E", "F", 15)
  277. f.SetColWidth("Sheet1", "G", "G", 22)
  278. line := 1
  279. headStyleLower, _ := f.NewStyle(`{
  280. "font":{
  281. "color":"#ff8585",
  282. "size":11,
  283. "family":"arial"
  284. }
  285. }`)
  286. headStyleUpper, _ := f.NewStyle(`{
  287. "font":{
  288. "color":"#ff8585",
  289. "size":11,
  290. "family":"arial"
  291. }
  292. }`)
  293. // 循环写入数据
  294. for _, v := range DeviceSensor_data {
  295. line++
  296. f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), line-1)
  297. f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), v.T_name+"["+strconv.Itoa(v.T_id)+"]")
  298. f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), v.T_t)
  299. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  300. f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), v.T_rh)
  301. }
  302. f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), strconv.FormatFloat(float64(v.T_Tlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_Tupper), 'f', 2, 64))
  303. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  304. f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), strconv.FormatFloat(float64(v.T_RHlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_RHupper), 'f', 2, 64))
  305. }
  306. f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), v.T_time)
  307. if v.T_t < v.T_Tlower || v.T_t > v.T_Tupper {
  308. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleLower)
  309. }
  310. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  311. if v.T_rh < v.T_RHlower || v.T_rh > v.T_RHupper {
  312. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleUpper)
  313. }
  314. }
  315. }
  316. timeStr := time.Now().Format("20060102150405")
  317. // 保存文件
  318. if err := f.SaveAs("ofile/" + timeStr + ".xlsx"); err != nil {
  319. fmt.Println(err)
  320. }
  321. // 上传 OSS
  322. url, is := NatsServer.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+timeStr+".xlsx", "ofile/"+timeStr+".xlsx")
  323. if !is {
  324. c.Data["json"] = lib.JSONS{Code: 203, Msg: "oss!"}
  325. c.ServeJSON()
  326. return
  327. }
  328. //删除目录
  329. err := os.Remove("ofile/" + timeStr + ".xlsx")
  330. if err != nil {
  331. fmt.Println(err)
  332. }
  333. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url}
  334. c.ServeJSON()
  335. return
  336. }
  337. // 列表 - 接口
  338. func (c *DataController) Device_Sensor_Data_Excel_m() {
  339. // 验证登录
  340. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  341. if !b_ {
  342. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  343. c.ServeJSON()
  344. return
  345. }
  346. T_snid := c.GetString("T_snid")
  347. Time_start := c.GetString("Time_start")
  348. Time_end := c.GetString("Time_end")
  349. if len(T_snid) < 10 {
  350. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  351. c.ServeJSON()
  352. return
  353. }
  354. var DeviceSensor_data []Device.DeviceData_
  355. DeviceSensor_data, _ = Device.Read_DeviceSensorData_By_T_snid_List(T_snid, Time_start, Time_end, 0, 9999)
  356. f := excelize.NewFile() // 设置单元格的值
  357. // 这里设置表头
  358. f.SetCellValue("Sheet1", "A1", "编号")
  359. f.SetCellValue("Sheet1", "B1", "传感器名称")
  360. f.SetCellValue("Sheet1", "C1", "温度℃")
  361. f.SetCellValue("Sheet1", "D1", "湿度%")
  362. f.SetCellValue("Sheet1", "E1", "温度范围 ℃")
  363. f.SetCellValue("Sheet1", "F1", "湿度范围 %")
  364. f.SetCellValue("Sheet1", "G1", "记录时间")
  365. // 设置列宽
  366. f.SetColWidth("Sheet1", "A", "A", 10)
  367. f.SetColWidth("Sheet1", "B", "B", 15)
  368. f.SetColWidth("Sheet1", "C", "D", 10)
  369. f.SetColWidth("Sheet1", "E", "F", 15)
  370. f.SetColWidth("Sheet1", "G", "G", 22)
  371. line := 1
  372. headStyleLower, _ := f.NewStyle(`{
  373. "font":{
  374. "color":"#a8f7ff",
  375. "size":11,
  376. "family":"arial"
  377. }
  378. }`)
  379. headStyleUpper, _ := f.NewStyle(`{
  380. "font":{
  381. "color":"#ff8585",
  382. "size":11,
  383. "family":"arial"
  384. }
  385. }`)
  386. atime, _ := time.ParseDuration("-1m") // Valid time units are "ns", "us" (or "µs"), "ms", "s", "m", "h".
  387. // 循环写入数据
  388. for v_i, v := range DeviceSensor_data {
  389. line++
  390. f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), line-1)
  391. f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), v.T_name+"["+strconv.Itoa(v.T_id)+"]")
  392. f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), v.T_t)
  393. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  394. f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), v.T_rh)
  395. }
  396. f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), strconv.FormatFloat(float64(v.T_Tlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_Tupper), 'f', 2, 64))
  397. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  398. f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), strconv.FormatFloat(float64(v.T_RHlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_RHupper), 'f', 2, 64))
  399. }
  400. f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), v.T_time)
  401. if v.T_t < v.T_Tlower || v.T_rh < v.T_RHlower {
  402. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleLower)
  403. }
  404. if v.T_t > v.T_Tupper || v.T_rh > v.T_RHupper {
  405. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleUpper)
  406. }
  407. if len(DeviceSensor_data)-1 == v_i {
  408. break
  409. }
  410. cha_v := ((DeviceSensor_data[v_i+1].T_t - v.T_t) / 3)
  411. //println("cha_v:",cha_v)
  412. // -------
  413. v.T_t = float32(lib.Decimal(float64(v.T_t + cha_v)))
  414. //println("v.T_t:",v.T_t)
  415. fTime, _ := time.Parse("2006-1-2 15:04:05", v.T_time)
  416. fTime = fTime.Add(atime)
  417. v.T_time = fTime.Format("2006-1-2 15:04:05")
  418. line++
  419. f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), line-1)
  420. f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), v.T_name+"["+strconv.Itoa(v.T_id)+"]")
  421. f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), v.T_t)
  422. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  423. f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), v.T_rh)
  424. }
  425. f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), strconv.FormatFloat(float64(v.T_Tlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_Tupper), 'f', 2, 64))
  426. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  427. f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), strconv.FormatFloat(float64(v.T_RHlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_RHupper), 'f', 2, 64))
  428. }
  429. f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), v.T_time)
  430. if v.T_t < v.T_Tlower || v.T_t > v.T_Tupper {
  431. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleLower)
  432. }
  433. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  434. if v.T_rh < v.T_RHlower || v.T_rh > v.T_RHupper {
  435. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleUpper)
  436. }
  437. }
  438. // -------
  439. v.T_t = float32(lib.Decimal(float64(v.T_t + cha_v)))
  440. //println("v.T_t:",v.T_t)
  441. fTime, _ = time.Parse("2006-1-2 15:04:05", v.T_time)
  442. fTime = fTime.Add(atime)
  443. v.T_time = fTime.Format("2006-1-2 15:04:05")
  444. line++
  445. f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), line-1)
  446. f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), v.T_name+"["+strconv.Itoa(v.T_id)+"]")
  447. f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), v.T_t)
  448. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  449. f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), v.T_rh)
  450. }
  451. f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), strconv.FormatFloat(float64(v.T_Tlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_Tupper), 'f', 2, 64))
  452. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  453. f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), strconv.FormatFloat(float64(v.T_RHlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_RHupper), 'f', 2, 64))
  454. }
  455. f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), v.T_time)
  456. if v.T_t < v.T_Tlower || v.T_rh < v.T_RHlower {
  457. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleLower)
  458. }
  459. if v.T_t > v.T_Tupper || v.T_rh > v.T_RHupper {
  460. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleUpper)
  461. }
  462. // -------
  463. v.T_t = float32(lib.Decimal(float64(v.T_t + cha_v)))
  464. //println("v.T_t:",v.T_t)
  465. fTime, _ = time.Parse("2006-1-2 15:04:05", v.T_time)
  466. fTime = fTime.Add(atime)
  467. v.T_time = fTime.Format("2006-1-2 15:04:05")
  468. line++
  469. f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), line-1)
  470. f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), v.T_name+"["+strconv.Itoa(v.T_id)+"]")
  471. f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), v.T_t)
  472. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  473. f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), v.T_rh)
  474. }
  475. f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), strconv.FormatFloat(float64(v.T_Tlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_Tupper), 'f', 2, 64))
  476. if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  477. f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), strconv.FormatFloat(float64(v.T_RHlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_RHupper), 'f', 2, 64))
  478. }
  479. f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), v.T_time)
  480. if v.T_t < v.T_Tlower || v.T_rh < v.T_RHlower {
  481. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleLower)
  482. }
  483. if v.T_t > v.T_Tupper || v.T_rh > v.T_RHupper {
  484. f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleUpper)
  485. }
  486. //
  487. //// -------
  488. //v.T_t = float32(lib.Decimal(float64(v.T_t+cha_v)))
  489. //println("v.T_t:",v.T_t)
  490. //
  491. //fTime,_ = time.Parse("2006-1-2 15:04:05", v.T_time)
  492. //fTime = fTime.Add(atime)
  493. //v.T_time = fTime.Format("2006-1-2 15:04:05")
  494. //
  495. //line++
  496. //f.SetCellValue("Sheet1", fmt.Sprintf("A%d", line), line-1)
  497. //f.SetCellValue("Sheet1", fmt.Sprintf("B%d", line), v.T_name+"["+strconv.Itoa(v.T_id)+"]")
  498. //f.SetCellValue("Sheet1", fmt.Sprintf("C%d", line), v.T_t)
  499. //if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  500. // f.SetCellValue("Sheet1", fmt.Sprintf("D%d", line), v.T_rh)
  501. //}
  502. //
  503. //f.SetCellValue("Sheet1", fmt.Sprintf("E%d", line), strconv.FormatFloat(float64(v.T_Tlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_Tupper), 'f', 2, 64))
  504. //if !(admin_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD")) {
  505. // f.SetCellValue("Sheet1", fmt.Sprintf("F%d", line), strconv.FormatFloat(float64(v.T_RHlower), 'f', 2, 64)+"~"+strconv.FormatFloat(float64(v.T_RHupper), 'f', 2, 64))
  506. //}
  507. //f.SetCellValue("Sheet1", fmt.Sprintf("G%d", line), v.T_time)
  508. //
  509. //if v.T_t < v.T_Tlower || v.T_rh < v.T_RHlower {
  510. // f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleLower)
  511. //}
  512. //if v.T_t > v.T_Tupper || v.T_rh > v.T_RHupper {
  513. // f.SetCellStyle("Sheet1", fmt.Sprintf("A%d", line), fmt.Sprintf("G%d", line), headStyleUpper)
  514. //}
  515. // -------
  516. v.T_t = float32(lib.Decimal(float64(v.T_t + cha_v)))
  517. //println("v.T_t:",v.T_t)
  518. fTime, _ = time.Parse("2006-1-2 15:04:05", v.T_time)
  519. fTime = fTime.Add(atime)
  520. v.T_time = fTime.Format("2006-1-2 15:04:05")
  521. }
  522. timeStr := time.Now().Format("20060102150405")
  523. // 保存文件
  524. if err := f.SaveAs("ofile/" + timeStr + ".xlsx"); err != nil {
  525. fmt.Println(err)
  526. }
  527. // 上传 OSS
  528. url, is := NatsServer.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/ofile/"+timeStr+".xlsx", "ofile/"+timeStr+".xlsx")
  529. if !is {
  530. c.Data["json"] = lib.JSONS{Code: 203, Msg: "oss!"}
  531. c.ServeJSON()
  532. return
  533. }
  534. //删除目录
  535. //err := os.Remove("ofile/" + timeStr + ".xlsx")
  536. //if err != nil {
  537. // fmt.Println(err)
  538. //}
  539. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url}
  540. c.ServeJSON()
  541. return
  542. }
  543. // 大数据平台
  544. func (c *DataController) DataScreen() {
  545. // 验证登录
  546. b_, _ := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  547. if !b_ {
  548. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  549. c.ServeJSON()
  550. return
  551. }
  552. c.TplName = "Data/DataScreen.html"
  553. }
  554. // 大数据 数据
  555. func (c *DataController) DataScreen_Data() {
  556. // 验证登录
  557. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  558. if !b_ {
  559. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  560. c.ServeJSON()
  561. return
  562. }
  563. Device_YD_1_Count_use := 0
  564. Device_YD_2_Count_use := 0
  565. Data := make(map[string]interface{})
  566. if admin_r.Admin_power == 10 {
  567. admin_r.Id = admin_r.Admin_master
  568. }
  569. // ----------------- 左上角 -----------------
  570. //仓库端总数
  571. Data["KF_Count"] = Device.Read_Device_ALL_T_Bind_Count(admin_r, "KF", 0)
  572. //运输端总数
  573. Data["YD_Count"] = Device.Read_Device_ALL_T_Bind_Count(admin_r, "YD", 0)
  574. // 仓库报备数
  575. Data["KF_Warning_Count"] = Device.Read_Warning_ALL_T_Bind_TIME_1d_Count(admin_r, "KF")
  576. // 运输报警数
  577. Data["YD_Warning_Count"] = Device.Read_Warning_ALL_T_Bind_TIME_1d_Count(admin_r, "YD")
  578. // 仓库端分公司数据统计 分公司名 终端总数 报警设备数 设备报警率
  579. var KF_list []map[string]interface{}
  580. Admin_maps := Admin.Read_Admin_List_Admin_master_ALL(admin_r.Id)
  581. for _, v := range Admin_maps {
  582. Data_KF := make(map[string]interface{})
  583. Data_KF["Name"] = v.Admin_name
  584. Device_Count := Device.Read_Device_ALL_T_Bind_Count(v, "KF", 0)
  585. Data_KF["Device_Count"] = Device_Count
  586. Warning_Count := Device.Read_Warning_ALL_T_Bind_TIME_1d_Count(v, "KF")
  587. Data_KF["Warning_Count"] = Warning_Count
  588. // 强制 报警数 不超过 设备数量
  589. if Warning_Count > Device_Count {
  590. Warning_Count = Device_Count
  591. }
  592. //fmt.Println("Device_Count:",Device_Count,"Warning_Count:",Warning_Count)
  593. if Warning_Count == 0 || Device_Count == 0 {
  594. Data_KF["Ratio"] = 0
  595. } else {
  596. Data_KF["Ratio"] = int((float32(Warning_Count) / float32(Device_Count)) * 100)
  597. }
  598. KF_list = append(KF_list, Data_KF)
  599. }
  600. // 运输报警数
  601. Data["KF_list"] = KF_list
  602. // 运输端分公司数据统计 分公司名 终端总数 报警设备数 设备报警率
  603. var YD_list []map[string]interface{}
  604. Admin_maps = Admin.Read_Admin_List_Admin_master_ALL(admin_r.Id)
  605. for _, v := range Admin_maps {
  606. Data_YD := make(map[string]interface{})
  607. Data_YD["Name"] = v.Admin_name
  608. Device_Count := Device.Read_Device_ALL_T_Bind_Count(v, "YD", 0)
  609. Data_YD["Device_Count"] = Device_Count
  610. Warning_Count := Device.Read_Warning_ALL_T_Bind_TIME_1d_Count(v, "YD")
  611. Data_YD["Warning_Count"] = Warning_Count
  612. //fmt.Println("Device_Count:",Device_Count,"Warning_Count:",Warning_Count)
  613. if Warning_Count == 0 || Device_Count == 0 {
  614. Data_YD["Ratio"] = 0
  615. } else {
  616. Data_YD["Ratio"] = int((float32(Warning_Count) / float32(Device_Count)) * 100)
  617. }
  618. YD_list = append(YD_list, Data_YD)
  619. }
  620. // 运输报警数
  621. Data["YD_list"] = YD_list
  622. // 分公司名 终端总数 报警设备数 设备报警率
  623. var KF_YD_list []map[string]interface{}
  624. Admin_maps = Admin.Read_Admin_List_Admin_master_ALL(admin_r.Id)
  625. for _, v := range Admin_maps {
  626. Data_KF_YD := make(map[string]interface{})
  627. Data_KF_YD["Name"] = v.Admin_name
  628. Device_Count := Device.Read_Device_ALL_T_Bind_Count(v, "", 0)
  629. Data_KF_YD["Device_Count"] = Device_Count
  630. Warning_Count := Device.Read_Warning_ALL_T_Bind_TIME_1d_Count(v, "")
  631. Data_KF_YD["Warning_Count"] = Warning_Count
  632. //fmt.Println("Device_Count:",Device_Count,"Warning_Count:",Warning_Count)
  633. if Warning_Count == 0 || Device_Count == 0 {
  634. Data_KF_YD["Ratio"] = 0
  635. } else {
  636. Data_KF_YD["Ratio"] = int((float32(Warning_Count) / float32(Device_Count)) * 100)
  637. }
  638. KF_YD_list = append(KF_YD_list, Data_KF_YD)
  639. }
  640. // 报警率排名
  641. Data["Warning_KF_YD_list"] = KF_YD_list
  642. //每个时间段使用数量走势(物流曲线/药店曲线)
  643. // 年
  644. Device_list := Device.Read_Device_ALL_bind(admin_r)
  645. var Sales_Year_z_list_1 [12]int
  646. var Sales_Year_z_list_2 [12]int
  647. for _, D_v := range Device_list {
  648. for _, v := range Device.Read_DeviceData_ById_Year_List(D_v.T_sn) {
  649. switch D_v.T_l_p {
  650. case 1:
  651. Sales_Year_z_list_1[lib.To_int(v[0])-1] += 1
  652. break
  653. case 2:
  654. Sales_Year_z_list_2[lib.To_int(v[0])-1] += 1
  655. break
  656. }
  657. }
  658. }
  659. Data["Sales_Year_z_list_1"] = Sales_Year_z_list_1
  660. Data["Sales_Year_z_list_2"] = Sales_Year_z_list_2
  661. // 月
  662. currentTime := time.Now()
  663. Month_z := lib.GetYearMonthToDay(currentTime.Year(), int(currentTime.Month()))
  664. var Sales_Month_z_list_1 = make([]int, Month_z)
  665. var Sales_Month_z_list_2 = make([]int, Month_z)
  666. for _, D_v := range Device_list {
  667. for _, v := range Device.Read_DeviceData_ById_Month_List(D_v.T_sn) {
  668. switch D_v.T_l_p {
  669. case 1:
  670. Sales_Month_z_list_1[lib.To_int(v[0])-1] += 1
  671. break
  672. case 2:
  673. Sales_Month_z_list_2[lib.To_int(v[0])-1] += 1
  674. break
  675. }
  676. }
  677. }
  678. Data["Sales_Month_z_list_1"] = Sales_Month_z_list_1
  679. Data["Sales_Month_z_list_2"] = Sales_Month_z_list_2
  680. // 日
  681. var Sales_Day_z_list_1 [24]int
  682. var Sales_Day_z_list_2 [24]int
  683. for _, D_v := range Device_list {
  684. for _, v := range Device.Read_DeviceSensorData_ById_Day_List(D_v.T_sn) {
  685. switch D_v.T_l_p {
  686. case 1:
  687. Sales_Day_z_list_1[lib.To_int(v[0])] += 1
  688. break
  689. case 2:
  690. Sales_Day_z_list_2[lib.To_int(v[0])] += 1
  691. break
  692. }
  693. }
  694. }
  695. Data["Sales_Day_z_list_1"] = Sales_Day_z_list_1
  696. Data["Sales_Day_z_list_2"] = Sales_Day_z_list_2
  697. // 物流端使用占比
  698. var DY_pie_1 []map[string]interface{}
  699. Admin_maps = Admin.Read_Admin_List_Admin_master_ALL(admin_r.Id)
  700. for _, Admin_maps_v := range Admin_maps {
  701. Day_x := 0
  702. Device_l := Device.Read_Device_ALL_bind_T_l_p(Admin_maps_v, 1)
  703. if len(Device_l) == 0 {
  704. continue
  705. }
  706. for _, Device_list_v := range Device_l {
  707. // 今天 次数(每小时一次)
  708. if len(Device.Read_DeviceSensorData_ById_Day_List(Device_list_v.T_sn)) > 0 {
  709. Day_x += 1
  710. }
  711. }
  712. Data_YD := make(map[string]interface{})
  713. Data_YD["Name"] = Admin_maps_v.Admin_name
  714. Data_YD["Ratio"] = Day_x
  715. Device_YD_1_Count_use += Day_x // 统计 使用次数
  716. DY_pie_1 = append(DY_pie_1, Data_YD)
  717. }
  718. Data["YD_pie_1"] = DY_pie_1
  719. // 药店端使用占比
  720. var DY_pie_2 []map[string]interface{}
  721. Admin_maps = Admin.Read_Admin_List_Admin_master_ALL(admin_r.Id)
  722. for _, Admin_maps_v := range Admin_maps {
  723. Day_x := 0
  724. Device_l := Device.Read_Device_ALL_bind_T_l_p(Admin_maps_v, 2)
  725. if len(Device_l) == 0 {
  726. continue
  727. }
  728. for _, Device_list_v := range Device_l {
  729. // 今天 次数(每小时一次)
  730. if len(Device.Read_DeviceSensorData_ById_Day_List(Device_list_v.T_sn)) > 0 {
  731. Day_x += 1
  732. }
  733. }
  734. Data_YD := make(map[string]interface{})
  735. Data_YD["Name"] = Admin_maps_v.Admin_name
  736. Data_YD["Ratio"] = Day_x
  737. Device_YD_1_Count_use += Day_x // 统计 使用次数
  738. DY_pie_2 = append(DY_pie_2, Data_YD)
  739. }
  740. Data["YD_pie_2"] = DY_pie_2
  741. // 运输端数据统计
  742. var YD_1_2 = make(map[string]interface{})
  743. Device_YD_1_Count := Device.Read_Device_ALL_T_Bind_Count(admin_r, "YD", 1)
  744. YD_1_2["Device_YD_1_Count"] = Device_YD_1_Count
  745. Device_YD_2_Count := Device.Read_Device_ALL_T_Bind_Count(admin_r, "YD", 2)
  746. YD_1_2["Device_YD_2_Count"] = Device_YD_2_Count
  747. YD_1_2["Device_YD_1_Count_use"] = Device_YD_1_Count_use
  748. YD_1_2["Device_YD_2_Count_use"] = Device_YD_2_Count_use
  749. Data["YD_1_2"] = YD_1_2
  750. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Data}
  751. c.ServeJSON()
  752. return
  753. }
  754. // 大数据平台
  755. func (c *DataController) DataScreen_Map() {
  756. // 验证登录
  757. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  758. if !b_ {
  759. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  760. c.ServeJSON()
  761. return
  762. }
  763. if admin_r.Admin_power == 10 {
  764. admin_r.Id = admin_r.Admin_master
  765. }
  766. data := Device.Read_DeviceSensor_Map_ALL_1(admin_r, 0, "", "", "YD")
  767. for i, v := range data {
  768. DeviceSensorData, is := Device.Read_DeviceSensorData_ById_New(v.T_sn, v.T_id)
  769. if !is {
  770. continue
  771. }
  772. data[i].T_t = DeviceSensorData.T_t
  773. data[i].T_rh = DeviceSensorData.T_rh
  774. data[i].T_Site = DeviceSensorData.T_Site
  775. data[i].T_Dattery = DeviceSensorData.T_Dattery
  776. data[i].T_time = DeviceSensorData.T_time
  777. }
  778. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: data}
  779. c.ServeJSON()
  780. return
  781. }
  782. // 列表 - 接口
  783. func (c *DataController) DeviceSensor_Data_Print() {
  784. SN := c.GetString("T_sn")
  785. Time_start := c.GetString("Time_start")
  786. Time_end := c.GetString("Time_end")
  787. type R_JSONS struct {
  788. //必须的大写开头
  789. T_time string
  790. T1 interface{}
  791. T2 interface{}
  792. T3 interface{}
  793. T4 interface{}
  794. }
  795. r_jsons := make(map[string]R_JSONS)
  796. GROUP_BY_t_time := Device.Read_DeviceSensorData_List_GROUP_BY_t_time(SN, Time_start, Time_end)
  797. // 时间 MAP
  798. for _, vt := range GROUP_BY_t_time {
  799. tt := lib.To_string(vt[0])
  800. r_jsons[tt] = R_JSONS{T_time: tt, T1: nil, T2: nil, T3: nil, T4: nil}
  801. }
  802. // 记录传感器
  803. maps, num := Device.Read_DeviceSensorData_ById_List(SN, 1, Time_start, Time_end, 1, 9999)
  804. if num > 0 {
  805. for _, v_map := range maps {
  806. ws, ok := r_jsons[v_map.T_time] /*如果确定是真实的,则存在,否则不存在 */
  807. if ok {
  808. ws.T1 = v_map
  809. r_jsons[v_map.T_time] = ws
  810. }
  811. }
  812. }
  813. maps, num = Device.Read_DeviceSensorData_ById_List(SN, 2, Time_start, Time_end, 1, 9999)
  814. if num > 0 {
  815. for _, v_map := range maps {
  816. ws, ok := r_jsons[v_map.T_time] /*如果确定是真实的,则存在,否则不存在 */
  817. if ok {
  818. ws.T2 = v_map
  819. r_jsons[v_map.T_time] = ws
  820. }
  821. }
  822. }
  823. maps, num = Device.Read_DeviceSensorData_ById_List(SN, 3, Time_start, Time_end, 1, 9999)
  824. if num > 0 {
  825. for _, v_map := range maps {
  826. ws, ok := r_jsons[v_map.T_time] /*如果确定是真实的,则存在,否则不存在 */
  827. if ok {
  828. ws.T3 = v_map
  829. r_jsons[v_map.T_time] = ws
  830. }
  831. }
  832. }
  833. maps, num = Device.Read_DeviceSensorData_ById_List(SN, 4, Time_start, Time_end, 1, 9999)
  834. if num > 0 {
  835. for _, v_map := range maps {
  836. ws, ok := r_jsons[v_map.T_time] /*如果确定是真实的,则存在,否则不存在 */
  837. if ok {
  838. ws.T4 = v_map
  839. r_jsons[v_map.T_time] = ws
  840. }
  841. }
  842. }
  843. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: r_jsons}
  844. c.ServeJSON()
  845. return
  846. }
  847. // 列表 - 接口
  848. func (c *DataController) Device_Sensor_Data_PDF() {
  849. // 验证登录
  850. b_, user_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  851. if !b_ {
  852. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  853. c.ServeJSON()
  854. return
  855. }
  856. T_snid := c.GetString("T_snid")
  857. Time_start := c.GetString("Time_start")
  858. Time_end := c.GetString("Time_end")
  859. if len(T_snid) < 10 {
  860. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!"}
  861. c.ServeJSON()
  862. return
  863. }
  864. var DeviceSensor_data []Device.DeviceData_
  865. DeviceSensor_data, _ = Device.Read_DeviceSensorData_By_T_snid_List(T_snid, Time_start, Time_end, 0, 9999)
  866. var err error
  867. pdf := &gopdf.GoPdf{}
  868. pdf.Start(gopdf.Config{PageSize: gopdf.Rect{W: 595.28, H: 841.89}}) //595.28, 841.89 = A4
  869. //err = GetFont(pdf, "LiberationSerif-Regular.ttf")
  870. //if err != nil {
  871. // log.Fatalln(err)
  872. //}
  873. //err = pdf.SetFont("Ubuntu-L", "", 14)
  874. //if err != nil {
  875. // log.Fatalln(err)
  876. //}
  877. err = pdf.AddTTFFont("simsun", "static/fonts/三极行楷简体-粗.ttf")
  878. if err != nil {
  879. c.Data["json"] = lib.JSONS{Code: 204, Msg: "ok!", Data: err}
  880. c.ServeJSON()
  881. return
  882. }
  883. err = pdf.SetFont("simsun", "", 24)
  884. if err != nil {
  885. c.Data["json"] = lib.JSONS{Code: 205, Msg: "ok!", Data: err}
  886. c.ServeJSON()
  887. return
  888. }
  889. pdf.SetGrayFill(0.5)
  890. pdf.SetMargins(0, 20, 0, 20)
  891. pdf.AddPage()
  892. //use path
  893. //pdf.Image("logo.png", 100, 50, &gopdf.Rect{W: 50, H: 50})
  894. textw, _ := pdf.MeasureTextWidth(user_r.Admin_name)
  895. pdf.SetX((595 / 2) - (textw / 2))
  896. pdf.SetY(40)
  897. pdf.Text(user_r.Admin_name)
  898. // 线
  899. pdf.SetLineWidth(2)
  900. pdf.SetLineType("dashed")
  901. pdf.Line(10, 60, 585, 60)
  902. err = pdf.AddTTFFont("wts", "static/fonts/MiSans-Medium.ttf")
  903. if err != nil {
  904. c.Data["json"] = lib.JSONS{Code: 206, Msg: "ok!", Data: err}
  905. c.ServeJSON()
  906. return
  907. }
  908. err = pdf.SetFont("wts", "", 12)
  909. if err != nil {
  910. c.Data["json"] = lib.JSONS{Code: 207, Msg: "ok!", Data: err}
  911. c.ServeJSON()
  912. return
  913. }
  914. //fmt.Sprintf(" %.1f ", v.T_t)
  915. lib.RectFillColor(pdf, "历史数据["+Time_start+" / "+Time_end+"]", 14, 22, 80, 550, 40, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  916. lib.RectFillColor(pdf, "序号", 12, 22, 120, 30, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  917. lib.RectFillColor(pdf, "传感器名称", 12, 52, 120, 100, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  918. lib.RectFillColor(pdf, "温度℃", 12, 152, 120, 60, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  919. lib.RectFillColor(pdf, "湿度%", 12, 212, 120, 60, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  920. lib.RectFillColor(pdf, "温度范围", 12, 272, 120, 100, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  921. lib.RectFillColor(pdf, "湿度范围", 12, 362, 120, 100, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  922. lib.RectFillColor(pdf, "记录时间", 12, 452, 120, 120, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  923. var y float64 = 140
  924. err = pdf.SetFont("wts", "", 10)
  925. if err != nil {
  926. c.Data["json"] = lib.JSONS{Code: 207, Msg: "ok!", Data: err}
  927. c.ServeJSON()
  928. return
  929. }
  930. for i, v := range DeviceSensor_data {
  931. text := fmt.Sprintf(" %d ", i+1)
  932. var textH float64 = 25 // if text height is 25px.
  933. pdf.SetNewY(y, textH)
  934. y = pdf.GetY()
  935. //pdf.SetX(x) // must after pdf.SetNewY() called.
  936. //err = pdf.Text(text)
  937. //if err != nil {
  938. // log.Fatalln(err)
  939. //}
  940. T_t := fmt.Sprintf(" %.1f ", v.T_t)
  941. T_rh := fmt.Sprintf(" %.1f ", v.T_rh)
  942. T_Tlu := fmt.Sprintf(" %.1f ~ %.1f ", v.T_Tlower, v.T_Tupper)
  943. T_Rlu := fmt.Sprintf(" %.1f ~ %.1f ", v.T_RHlower, v.T_RHupper)
  944. T_time := fmt.Sprintf("%s", v.T_time)
  945. if user_r.Admin_rh == 0 && strings.Contains(v.T_sn, "YD") {
  946. T_rh = "-"
  947. T_Rlu = "-"
  948. }
  949. lib.RectFillColor(pdf, text, 10, 22, y, 30, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  950. lib.RectFillColor(pdf, v.T_name, 10, 52, y, 100, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  951. lib.RectFillColor(pdf, T_t, 10, 152, y, 60, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  952. lib.RectFillColor(pdf, T_rh, 10, 212, y, 60, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  953. lib.RectFillColor(pdf, T_Tlu, 10, 272, y, 90, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  954. lib.RectFillColor(pdf, T_Rlu, 10, 362, y, 90, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  955. lib.RectFillColor(pdf, T_time, 10, 452, y, 120, 20, 255, 255, 255, lib.AlignCenter, lib.ValignMiddle)
  956. y += 20
  957. }
  958. timeStr := "ofile/" + time.Now().Format("20060102150405") + ".pdf"
  959. err = pdf.WritePdf(timeStr)
  960. if err != nil {
  961. c.Data["json"] = lib.JSONS{Code: 207, Msg: "ok!", Data: err}
  962. c.ServeJSON()
  963. return
  964. }
  965. // 上传 OSS
  966. url, is := NatsServer.Qiniu_UploadFile(lib.GetCurrentDirectory()+"/"+timeStr, timeStr)
  967. if !is {
  968. c.Data["json"] = lib.JSONS{Code: 203, Msg: "oss!"}
  969. c.ServeJSON()
  970. return
  971. }
  972. //删除目录
  973. err = os.Remove(timeStr)
  974. if err != nil {
  975. fmt.Println(err)
  976. }
  977. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: url}
  978. c.ServeJSON()
  979. return
  980. }
  981. // 大数据平台
  982. func (c *DataController) Raw() {
  983. // 验证登录
  984. b_, admin_r := lib.Verification(c.Ctx.GetCookie("User_tokey"), c.GetString("User_tokey"))
  985. if !b_ {
  986. c.Data["json"] = lib.JSONS{Code: 201, Msg: "User_tokey Err!"}
  987. c.ServeJSON()
  988. return
  989. }
  990. T_SQL := c.GetString("T_SQL")
  991. T_SQL_ := strings.ToLower(T_SQL)
  992. if strings.Contains(T_SQL_, ";") ||
  993. //strings.Contains(T_SQL, "Admin")||
  994. //strings.Contains(T_SQL, "Device ")||
  995. //strings.Contains(T_SQL, "DeviceParameter")||
  996. //strings.Contains(T_SQL, "DeviceSensor")||
  997. //strings.Contains(T_SQL, "DeviceSnOld")||
  998. //strings.Contains(T_SQL, "DeviceTask")||
  999. //strings.Contains(T_SQL, "DeviceWarning")||
  1000. strings.Contains(T_SQL, "Logs") ||
  1001. strings.Contains(T_SQL, "SqlLogs") ||
  1002. strings.Contains(T_SQL, "Tokey") ||
  1003. strings.Contains(T_SQL, "UserLogs") ||
  1004. strings.Contains(T_SQL_, "show") ||
  1005. strings.Contains(T_SQL_, "create") ||
  1006. strings.Contains(T_SQL_, "drop") ||
  1007. strings.Contains(T_SQL_, "desc") ||
  1008. strings.Contains(T_SQL_, "alter") ||
  1009. strings.Contains(T_SQL_, "insert") ||
  1010. strings.Contains(T_SQL_, "update") ||
  1011. strings.Contains(T_SQL_, "delete") {
  1012. System.Add_SqlLogs(admin_r.Admin_uuid, "Err:"+admin_r.Admin_user, T_SQL)
  1013. c.Data["json"] = lib.JSONS{Code: 201, Msg: "Err SQL!", Data: admin_r.Admin_name + " :你的行为 也被记录"}
  1014. c.ServeJSON()
  1015. return
  1016. }
  1017. if //!strings.Contains(T_SQL, "Z_DeviceData_") ||
  1018. !strings.Contains(T_SQL_, "select") {
  1019. System.Add_SqlLogs(admin_r.Admin_uuid, "Err:"+admin_r.Admin_user, T_SQL)
  1020. c.Data["json"] = lib.JSONS{Code: 201, Msg: "Err SQL!", Data: admin_r.Admin_name + " :你的行为 也被记录"}
  1021. c.ServeJSON()
  1022. return
  1023. }
  1024. System.Add_SqlLogs(admin_r.Admin_uuid, "ok", T_SQL)
  1025. c.Data["json"] = lib.JSONS{Code: 200, Msg: "ok!", Data: Device.Read_SqlRaw(T_SQL)}
  1026. c.ServeJSON()
  1027. return
  1028. }