report.go 37 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244
  1. package api
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "sort"
  6. "strconv"
  7. "strings"
  8. "time"
  9. "../../routers/restful"
  10. "github.com/Anderson-Lu/gofasion/gofasion"
  11. "github.com/xormplus/xorm"
  12. )
  13. //包含报表模块前端需要的各种数据格式转换
  14. func praseReportform(sqlnamestr string, parammaps *gofasion.Fasion, tx *xorm.Session, checked string, offset, count, typea int) (queryData map[string]interface{}, err error) {
  15. sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
  16. s_params := make([]interface{}, 0)
  17. if sql != "" {
  18. paramslist := strings.Split(p, ",")
  19. if len(paramslist) > 0 && p != "" {
  20. for _, value := range paramslist {
  21. s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  22. }
  23. }
  24. }
  25. queryList, err := tx.SQL(sql, s_params...).Query().List()
  26. //############
  27. sql2, p2 := restful.GetSqlByNameDBT("getFeednameSort", tx)
  28. s_params2 := make([]interface{}, 0)
  29. if sql2 != "" {
  30. paramslist2 := strings.Split(p2, ",")
  31. if len(paramslist2) > 0 && p != "" {
  32. for _, value := range paramslist2 {
  33. s_params2 = append(s_params2, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  34. }
  35. }
  36. }
  37. queryList2, err := tx.SQL(sql2, s_params2...).Query().List()
  38. var feednamesort []string
  39. if len(queryList2) > 0 {
  40. for i := 0; i < len(queryList2); i++ {
  41. feednamesort = append(feednamesort, queryList2[i]["fname"].(string))
  42. }
  43. }
  44. // #########
  45. sql3, p3 := restful.GetSqlByNameDBT("getFeednameSort2", tx)
  46. s_params3 := make([]interface{}, 0)
  47. if sql3 != "" {
  48. paramslist3 := strings.Split(p3, ",")
  49. if len(paramslist3) > 0 && p != "" {
  50. for _, value := range paramslist3 {
  51. s_params3 = append(s_params3, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  52. }
  53. }
  54. }
  55. // var queryList3 []map[string]interface{}
  56. // queryList3 = make([]map[string]interface{}, 0)
  57. var feednamesort3 []string
  58. if sql3 != "" {
  59. queryList3, err := tx.SQL(sql3, s_params3...).Query().List()
  60. // fmt.Println()
  61. if err != nil {
  62. return nil, err
  63. }
  64. if len(queryList3) > 0 {
  65. for z := 0; z < len(queryList3); z++ {
  66. feednamesort3 = append(feednamesort3, queryList3[z]["feedname"].(string))
  67. }
  68. }
  69. }
  70. if err != nil {
  71. return nil, err
  72. }
  73. // if len(queryList) == 0 {
  74. // return nil, nil
  75. // }
  76. temstr := ""
  77. //除特殊接口外,去接口名称的前10位做同一类型的转换
  78. switch sqlnamestr {
  79. case "getAccuracyAllHL", "getAccuracyAllQX", "getAccuracyAllJH", "getFeedEffMR", "getFeedEffHL", "getHomepageCB", "getAccuraa", "judgenurFTReportDetail":
  80. temstr = sqlnamestr
  81. default:
  82. temstr = sqlnamestr[:10]
  83. }
  84. // 根据名称选择不通类型的转换-(可自动扩展,不需要使用之前的)
  85. switch temstr {
  86. case "getAccurac", "getFeedEff":
  87. queryData, err = getAccuracy(queryList) // 不定参数
  88. case "getprocess":
  89. //queryData, err = getAccuracyV3v1(queryList)
  90. queryData, err = getAccuracyV3(queryList)
  91. // 统计分析 过程分析
  92. if sqlnamestr == "getprocessAnalysisTB" {
  93. quertDataList := queryData["list"]
  94. query := quertDataList.(map[string]interface{})
  95. querys, _ := GetprocessAnalysisTB(parammaps, tx, quertDataList, queryList)
  96. if len(querys) != 0 {
  97. query["data1"] = querys["WTime"]
  98. query["data2"] = querys["data2"]
  99. query["data3"] = querys["realWandT"]
  100. query["data5"] = querys["data5"]
  101. }
  102. }
  103. case "getHomepro":
  104. queryData, err = getAccuracyV3(queryList)
  105. case "getAccuracyAllHL", "getAccuracyAllQX", "getAccuracyAllJH", "getFeedEffMR", "getFeedEffHL", "getHomepageCB", "getAccuraa":
  106. queryData, err = getAccuracyV2(queryList) //固定维度 日期
  107. case "getMateria":
  108. sql1, p1 := restful.GetSqlByNameDBT(sqlnamestr+("sum"), tx)
  109. s_params1 := make([]interface{}, 0)
  110. if sql1 != "" {
  111. paramslist1 := strings.Split(p1, ",")
  112. if len(paramslist1) > 0 && p != "" {
  113. for _, value := range paramslist1 {
  114. s_params1 = append(s_params1, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  115. }
  116. }
  117. }
  118. queryListSum, _ := tx.SQL(sql1, s_params1...).Query().List()
  119. queryData, err = getAccuracyV4(queryList, queryListSum, checked, feednamesort3, typea)
  120. case "getPriceAn":
  121. queryData, err = getAccuracyV5(queryList)
  122. case "getJT1Accu":
  123. queryData, err = getAccuracyV6(queryList) //固定维度 牧场
  124. case "judgenurFT":
  125. queryData, err = getAccuracyV7(queryList)
  126. case "judgenurFTReportDetail":
  127. queryData, err = getAccuracyV8(queryList)
  128. case "downloadPl":
  129. var sql2, p2 string
  130. s_params2 := make([]interface{}, 0)
  131. if sqlnamestr == "downloadPlanSFJD" {
  132. sql2, p2 = restful.GetSqlByNameDBT("countfl", tx)
  133. //s_params1 := make([]interface{}, 0)
  134. if sql2 != "" {
  135. paramslist1 := strings.Split(p2, ",")
  136. if len(paramslist1) > 0 && p != "" {
  137. for _, value := range paramslist1 {
  138. s_params2 = append(s_params2, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  139. }
  140. }
  141. }
  142. }
  143. queryList2, _ := tx.SQL(sql2, s_params2...).Query().List()
  144. var flleight string
  145. if len(queryList2) > 0 {
  146. flleight, _ = queryList2[0]["flcount"].(string)
  147. // fmt.Println(flleight)
  148. }
  149. flleightint, _ := strconv.Atoi(flleight)
  150. queryData, err = getAccuracyV9(queryList, sqlnamestr, flleightint, feednamesort) //投料简打、累加
  151. default:
  152. queryData, err = nil, nil
  153. }
  154. return
  155. }
  156. func getAccuracyV9(queryList []map[string]interface{}, sqlnamestr string, flleightint int, feednamesort []string) (map[string]interface{}, error) {
  157. queryData := make(map[string]interface{})
  158. chartData := make(map[string]interface{})
  159. mapc3 := make(map[string]interface{})
  160. data2 := []interface{}{}
  161. data1 := []interface{}{}
  162. mapc3["label"] = "车次"
  163. mapc3["prop"] = "projname"
  164. data1 = append(data1, mapc3)
  165. mapc3 = make(map[string]interface{})
  166. mapc3["label"] = "TMR"
  167. mapc3["prop"] = "tmrtname"
  168. data1 = append(data1, mapc3)
  169. mapc3 = make(map[string]interface{})
  170. //if sqlnamestr == "downloadPlanSFJD":
  171. //mapc3["label"] = "时间"
  172. //mapc3["prop"] = "plantime"
  173. //data1 = append(data1, mapc3)
  174. //mapc3 = make(map[string]interface{})
  175. //
  176. //mapc3["label"] = "班组"
  177. //mapc3["prop"] = "times"
  178. //data1 = append(data1, mapc3)
  179. //mapc3 = make(map[string]interface{})
  180. //
  181. //mapc3["label"] = "驾驶员"
  182. //mapc3["prop"] = "driver"
  183. //data1 = append(data1, mapc3)
  184. //mapc3 = make(map[string]interface{})
  185. //
  186. //mapc3["label"] = "日系数比例"
  187. //mapc3["prop"] = "rate"
  188. //data1 = append(data1, mapc3)
  189. //mapc3 = make(map[string]interface{})
  190. //
  191. //mapc3["label"] = "牛头数"
  192. //mapc3["prop"] = "feedpcount"
  193. //data1 = append(data1, mapc3)
  194. //mapc3 = make(map[string]interface{})
  195. //
  196. //mapc3["label"] = "配方模板"
  197. //mapc3["prop"] = "templetname"
  198. //data1 = append(data1, mapc3)
  199. //mapc3 = make(map[string]interface{})
  200. //#######################################################################################
  201. mtem := make(map[interface{}]interface{})
  202. var stem, feedNames []string
  203. for _, feed := range feednamesort {
  204. feed = strings.ReplaceAll(feed, " ", "")
  205. mtem[feed] = struct{}{}
  206. // fmt.Println(feed)
  207. stem = append(stem, feed)
  208. }
  209. for i := 0; i < len(queryList); i++ { // 获取所有饲料种类
  210. // if _, ok := mtem[queryList[i]["fname"]]; ok {
  211. // continue
  212. // }
  213. // stem = append(stem, queryList[i]["fname"].(string))
  214. // mtem[queryList[i]["fname"]] = struct{}{}
  215. feedNames = append(feedNames, queryList[i]["fname"].(string))
  216. }
  217. sort.Strings(feedNames)
  218. for _, feed := range feedNames {
  219. if _, ok := mtem[feed]; ok {
  220. continue
  221. }
  222. // fmt.Println(feed)
  223. stem = append(stem, feed)
  224. mtem[feed] = struct{}{}
  225. }
  226. stemEnd := []string{}
  227. if sqlnamestr == "downloadPlanSFJD" {
  228. bb := stem[len(stem)-flleightint : len(stem) : len(stem)]
  229. //aa := stem[0 : len(stem)-flleightint : len(stem)]
  230. stemEnd = append(stemEnd, bb...)
  231. stemEnd = append(stemEnd, feednamesort...)
  232. //fmt.Println(stemEnd)
  233. } else {
  234. stemEnd = stem
  235. }
  236. //logging.Info("导出数据 ",stemEnd )
  237. for _, va := range stemEnd {
  238. mapc3["label"] = va
  239. mapc3["prop"] = va
  240. data1 = append(data1, mapc3)
  241. mapc3 = make(map[string]interface{})
  242. }
  243. if queryList[0]["sumlweight"] != nil {
  244. mapc3["label"] = "合计"
  245. mapc3["prop"] = "sumlweight"
  246. }
  247. data1 = append(data1, mapc3)
  248. mapc3 = make(map[string]interface{})
  249. var tem interface{}
  250. mapc2 := make(map[string]interface{})
  251. for i := 0; i < len(queryList); i++ { // 获取所有饲料种类
  252. if i == 0 {
  253. tem = queryList[i]["projname"]
  254. mapc2 = queryList[i]
  255. if mapc2["sumlweight"] != nil {
  256. var sumlweight float64
  257. sumlweight, _ = strconv.ParseFloat(mapc2["sumlweight"].(string), 64)
  258. mapc2["sumlweight"] = sumlweight
  259. }
  260. for key := range mtem {
  261. mapc2[xorm.String(key)] = 0
  262. }
  263. // var lweight float64
  264. if queryList[i]["lweight"] != nil {
  265. // var error errors.Error
  266. lweight, err := strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  267. if err == nil {
  268. mapc2[xorm.String(queryList[i]["fname"])] = lweight
  269. } else {
  270. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  271. }
  272. } else {
  273. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  274. }
  275. }
  276. if tem == queryList[i]["projname"] {
  277. // var lweight float64
  278. if queryList[i]["lweight"] != nil {
  279. lweight, err := strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  280. if err == nil {
  281. mapc2[xorm.String(queryList[i]["fname"])] = lweight
  282. } else {
  283. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  284. }
  285. } else {
  286. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  287. }
  288. } else {
  289. data2 = append(data2, mapc2)
  290. tem = queryList[i]["projname"]
  291. mapc2 = queryList[i]
  292. if mapc2["sumlweight"] != nil {
  293. var sumlweight float64
  294. sumlweight, _ = strconv.ParseFloat(mapc2["sumlweight"].(string), 64)
  295. mapc2["sumlweight"] = sumlweight
  296. }
  297. for key := range mtem {
  298. mapc2[xorm.String(key)] = 0
  299. }
  300. if queryList[i]["lweight"] != nil {
  301. lweight, err := strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  302. if err == nil {
  303. mapc2[xorm.String(queryList[i]["fname"])] = lweight
  304. } else {
  305. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  306. }
  307. } else {
  308. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  309. }
  310. }
  311. }
  312. data2 = append(data2, mapc2)
  313. chartData["data1"] = data1
  314. chartData["data2"] = data2
  315. queryData["list"] = chartData
  316. queryData["code"] = 0
  317. queryData["message"] = "ok"
  318. queryData["data"] = queryList
  319. return queryData, nil
  320. }
  321. func getAccuracyV8(queryList []map[string]interface{}) (map[string]interface{}, error) {
  322. queryData := make(map[string]interface{})
  323. chartData := make(map[string]interface{})
  324. //list := make(map[string]interface{})
  325. data := []interface{}{}
  326. for i := 0; i < len(queryList); i++ {
  327. dry, _ := strconv.ParseFloat(queryList[i]["dry"].(string), 64)
  328. Hrate, _ := strconv.ParseFloat(queryList[i]["Hrate"].(string), 64)
  329. Srate, _ := strconv.ParseFloat(queryList[i]["Srate"].(string), 64)
  330. trans35f, _ := strconv.ParseFloat(queryList[i]["trans35f"].(string), 64)
  331. jcrate, _ := strconv.ParseFloat(queryList[i]["jcrate"].(string), 64)
  332. uprice, _ := strconv.ParseFloat(queryList[i]["uprice"].(string), 64)
  333. kprice, _ := strconv.ParseFloat(queryList[i]["dry"].(string), 64)
  334. adf, _ := strconv.ParseFloat(queryList[i]["adf"].(string), 64)
  335. ca, _ := strconv.ParseFloat(queryList[i]["ca"].(string), 64)
  336. cdry, _ := strconv.ParseFloat(queryList[i]["cdry"].(string), 64)
  337. cad, _ := strconv.ParseFloat(queryList[i]["cad"].(string), 64)
  338. cndf, _ := strconv.ParseFloat(queryList[i]["cndf"].(string), 64)
  339. cp, _ := strconv.ParseFloat(queryList[i]["cp"].(string), 64)
  340. cpd, _ := strconv.ParseFloat(queryList[i]["cpd"].(string), 64)
  341. fat, _ := strconv.ParseFloat(queryList[i]["fat"].(string), 64)
  342. ndf, _ := strconv.ParseFloat(queryList[i]["ndf"].(string), 64)
  343. nm, _ := strconv.ParseFloat(queryList[i]["nm"].(string), 64)
  344. nmd, _ := strconv.ParseFloat(queryList[i]["nmd"].(string), 64)
  345. nuint, _ := strconv.ParseFloat(queryList[i]["nuint"].(string), 64)
  346. p, _ := strconv.ParseFloat(queryList[i]["p"].(string), 64)
  347. pd, _ := strconv.ParseFloat(queryList[i]["pd"].(string), 64)
  348. starch, _ := strconv.ParseFloat(queryList[i]["starch"].(string), 64)
  349. trans4f, _ := strconv.ParseFloat(queryList[i]["trans4f"].(string), 64)
  350. list := make(map[string]interface{})
  351. list["ft"] = dry
  352. list["index"] = "干物质(kg)"
  353. list["tmr"] = TransFloat(dry * Hrate)
  354. list["cyl"] = TransFloat(dry * Srate)
  355. data = append(data, list)
  356. list = make(map[string]interface{})
  357. list["ft"] = jcrate
  358. list["index"] = "粗精比(%)"
  359. list["tmr"] = TransFloat(jcrate * Hrate)
  360. list["cyl"] = TransFloat(jcrate * Srate)
  361. data = append(data, list)
  362. list = make(map[string]interface{})
  363. list["ft"] = uprice
  364. list["index"] = "日粮成本(元)"
  365. list["tmr"] = TransFloat(uprice * Hrate)
  366. list["cyl"] = TransFloat(uprice * Srate)
  367. data = append(data, list)
  368. list = make(map[string]interface{})
  369. list["ft"] = kprice
  370. list["index"] = "公斤奶成本"
  371. list["tmr"] = TransFloat(kprice * Hrate)
  372. list["cyl"] = TransFloat(kprice * Srate)
  373. data = append(data, list)
  374. list = make(map[string]interface{})
  375. list["ft"] = cdry
  376. list["index"] = "粗料中的干物质"
  377. list["tmr"] = TransFloat(cdry * Hrate)
  378. list["cyl"] = TransFloat(cdry * Srate)
  379. data = append(data, list)
  380. list = make(map[string]interface{})
  381. list["ft"] = nm
  382. list["index"] = " 产奶净能(MJ)"
  383. list["tmr"] = TransFloat(nm * Hrate)
  384. list["cyl"] = TransFloat(nm * Srate)
  385. data = append(data, list)
  386. list = make(map[string]interface{})
  387. list["ft"] = nuint
  388. list["index"] = "奶牛能量单位(NND)"
  389. list["tmr"] = TransFloat(nuint * Hrate)
  390. list["cyl"] = TransFloat(nuint * Srate)
  391. data = append(data, list)
  392. list = make(map[string]interface{})
  393. list["ft"] = cp
  394. list["index"] = "粗蛋白(g)"
  395. list["tmr"] = TransFloat(cp * Hrate)
  396. list["cyl"] = TransFloat(cp * Srate)
  397. data = append(data, list)
  398. list = make(map[string]interface{})
  399. list["ft"] = cpd
  400. list["index"] = "粗蛋白(%DM)"
  401. list["tmr"] = TransFloat(cpd * Hrate)
  402. list["cyl"] = TransFloat(cpd * Srate)
  403. data = append(data, list)
  404. list = make(map[string]interface{})
  405. list["ft"] = ca
  406. list["index"] = "钙(g)"
  407. list["tmr"] = TransFloat(ca * Hrate)
  408. list["cyl"] = TransFloat(ca * Srate)
  409. data = append(data, list)
  410. list = make(map[string]interface{})
  411. list["ft"] = p
  412. list["index"] = "磷(g)"
  413. list["tmr"] = TransFloat(p * Hrate)
  414. list["cyl"] = TransFloat(p * Srate)
  415. data = append(data, list)
  416. list = make(map[string]interface{})
  417. list["ft"] = nmd
  418. list["index"] = "产奶净能(Mcal/DM)"
  419. list["tmr"] = TransFloat(nmd * Hrate)
  420. list["cyl"] = TransFloat(nmd * Srate)
  421. data = append(data, list)
  422. list = make(map[string]interface{})
  423. list["ft"] = fat
  424. list["index"] = "脂肪"
  425. list["tmr"] = TransFloat(fat * Hrate)
  426. list["cyl"] = TransFloat(fat * Srate)
  427. data = append(data, list)
  428. list = make(map[string]interface{})
  429. list["ft"] = starch
  430. list["index"] = "淀粉"
  431. list["tmr"] = TransFloat(starch * Hrate)
  432. list["cyl"] = TransFloat(starch * Srate)
  433. data = append(data, list)
  434. list = make(map[string]interface{})
  435. list["ft"] = ndf
  436. list["index"] = "NDF(%DM)"
  437. list["tmr"] = TransFloat(ndf * Hrate)
  438. list["cyl"] = TransFloat(ndf * Srate)
  439. data = append(data, list)
  440. list = make(map[string]interface{})
  441. list["ft"] = cndf
  442. list["index"] = "粗料中的NDF(%DM)"
  443. list["tmr"] = TransFloat(cndf * Hrate)
  444. list["cyl"] = TransFloat(cndf * Srate)
  445. data = append(data, list)
  446. list = make(map[string]interface{})
  447. list["ft"] = adf
  448. list["index"] = " ADF(%DM)"
  449. list["tmr"] = TransFloat(adf * Hrate)
  450. list["cyl"] = TransFloat(adf * Srate)
  451. data = append(data, list)
  452. list = make(map[string]interface{})
  453. list["ft"] = cad
  454. list["index"] = "钙(%DM)"
  455. list["tmr"] = TransFloat(cad * Hrate)
  456. list["cyl"] = TransFloat(cad * Srate)
  457. data = append(data, list)
  458. list = make(map[string]interface{})
  459. list["ft"] = pd
  460. list["index"] = " 磷(%DM)"
  461. list["tmr"] = TransFloat(pd * Hrate)
  462. list["cyl"] = TransFloat(pd * Srate)
  463. data = append(data, list)
  464. list = make(map[string]interface{})
  465. list["ft"] = trans35f
  466. list["index"] = "(3.5)FCR(kg/DM)"
  467. list["tmr"] = TransFloat(trans35f * Hrate)
  468. list["cyl"] = TransFloat(trans35f * Srate)
  469. data = append(data, list)
  470. list = make(map[string]interface{})
  471. list["ft"] = trans4f
  472. list["index"] = "(4.0)FCR(kg/DM)"
  473. list["tmr"] = TransFloat(trans4f * Hrate)
  474. list["cyl"] = TransFloat(trans4f * Srate)
  475. data = append(data, list)
  476. }
  477. chartData["data"] = data
  478. queryData["list"] = chartData
  479. queryData["code"] = 0
  480. queryData["message"] = "ok"
  481. queryData["data"] = queryList
  482. return queryData, nil
  483. }
  484. func TransFloat(flo float64) float64 {
  485. hf, _ := strconv.ParseFloat(fmt.Sprintf("%.3f", float64(flo)), 64)
  486. return hf
  487. }
  488. func getAccuracyV7(queryList []map[string]interface{}) (map[string]interface{}, error) {
  489. queryData := make(map[string]interface{})
  490. chartData := make(map[string]interface{})
  491. //list := make(map[string]interface{})
  492. data := []interface{}{}
  493. for i := 0; i < len(queryList); i++ {
  494. dry, _ := strconv.ParseFloat(queryList[i]["dry"].(string), 64)
  495. Hrate, _ := strconv.ParseFloat(queryList[i]["Hrate"].(string), 64)
  496. Srate, _ := strconv.ParseFloat(queryList[i]["Srate"].(string), 64)
  497. trans35f, _ := strconv.ParseFloat(queryList[i]["trans35f"].(string), 64)
  498. jcrate, _ := strconv.ParseFloat(queryList[i]["jcrate"].(string), 64)
  499. uprice, _ := strconv.ParseFloat(queryList[i]["uprice"].(string), 64)
  500. kprice, _ := strconv.ParseFloat(queryList[i]["dry"].(string), 64)
  501. list := make(map[string]interface{})
  502. list["tname"] = queryList[i]["tname"]
  503. list["ftid"] = queryList[i]["ftid"]
  504. list["ft"] = dry
  505. list["index"] = "干物质(kg)"
  506. list["tmr"] = TransFloat(dry * Hrate)
  507. list["cyl"] = TransFloat(dry * Srate)
  508. data = append(data, list)
  509. list = make(map[string]interface{})
  510. list["tname"] = queryList[i]["tname"]
  511. list["ftid"] = queryList[i]["ftid"]
  512. list["ft"] = trans35f
  513. list["index"] = "(3.5)FCR(kg/DM)"
  514. list["tmr"] = TransFloat(trans35f * Hrate)
  515. list["cyl"] = TransFloat(trans35f * Srate)
  516. data = append(data, list)
  517. list = make(map[string]interface{})
  518. list["tname"] = queryList[i]["tname"]
  519. list["ftid"] = queryList[i]["ftid"]
  520. list["ft"] = jcrate
  521. list["index"] = "粗精比(%)"
  522. list["tmr"] = TransFloat(jcrate * Hrate)
  523. list["cyl"] = TransFloat(jcrate * Srate)
  524. data = append(data, list)
  525. list = make(map[string]interface{})
  526. list["tname"] = queryList[i]["tname"]
  527. list["ftid"] = queryList[i]["ftid"]
  528. list["ft"] = uprice
  529. list["index"] = "日粮成本(元)"
  530. list["tmr"] = TransFloat(uprice * Hrate)
  531. list["cyl"] = TransFloat(uprice * Srate)
  532. data = append(data, list)
  533. list = make(map[string]interface{})
  534. list["tname"] = queryList[i]["tname"]
  535. list["ftid"] = queryList[i]["ftid"]
  536. list["ft"] = kprice
  537. list["index"] = "公斤奶成本"
  538. list["tmr"] = TransFloat(kprice * Hrate)
  539. list["cyl"] = TransFloat(kprice * Srate)
  540. data = append(data, list)
  541. }
  542. chartData["data"] = data
  543. queryData["list"] = chartData
  544. queryData["code"] = 0
  545. queryData["message"] = "ok"
  546. queryData["data"] = queryList
  547. return queryData, nil
  548. }
  549. func getAccuracyV6(queryList []map[string]interface{}) (map[string]interface{}, error) {
  550. queryData := make(map[string]interface{})
  551. chartData := make(map[string]interface{})
  552. data := []interface{}{}
  553. data1 := []interface{}{}
  554. data2 := []interface{}{}
  555. data3 := []interface{}{}
  556. data4 := []interface{}{}
  557. for i := 0; i < len(queryList); i++ {
  558. data = append(data, queryList[i]["牧场"])
  559. data1 = append(data1, queryList[i]["field1"])
  560. data2 = append(data2, queryList[i]["field2"])
  561. data3 = append(data3, queryList[i]["field3"])
  562. data4 = append(data4, queryList[i]["field4"])
  563. }
  564. chartData["data1"] = data
  565. chartData["data2"] = data1
  566. chartData["data3"] = data2
  567. chartData["data4"] = data3
  568. chartData["data5"] = data4
  569. queryData["list"] = chartData
  570. queryData["code"] = 0
  571. queryData["message"] = "ok"
  572. queryData["data"] = queryList
  573. return queryData, nil
  574. }
  575. func getAccuracyV5(queryList []map[string]interface{}) (map[string]interface{}, error) {
  576. queryData := make(map[string]interface{})
  577. chartData := make(map[string]interface{})
  578. datamap1 := make(map[string]interface{})
  579. datamap2 := make(map[string]interface{})
  580. temsmap := make(map[interface{}]interface{})
  581. mapc2 := make(map[interface{}]interface{})
  582. data3 := []interface{}{}
  583. datamap2child := make(map[string]interface{})
  584. data2 := []interface{}{}
  585. data1 := []interface{}{}
  586. var dtem interface{}
  587. var temstr interface{}
  588. var typestr interface{}
  589. count2 := 0
  590. a := 0
  591. for i := 0; i < len(queryList); i++ {
  592. if i == 0 {
  593. temstr = queryList[i]["fname"]
  594. typestr = queryList[i]["typestr"]
  595. }
  596. if temstr == queryList[i]["fname"] {
  597. temsmap[queryList[i]["feedname"]] = 1
  598. }
  599. if _, ok := mapc2[queryList[i]["feedname"]]; !ok {
  600. mapc2[queryList[i]["feedname"]] = count2
  601. mapc2[count2] = queryList[i]["feedname"]
  602. count2++
  603. }
  604. }
  605. //for i := 0; i<count2 ; i++ {
  606. // reslist := make([]map[string]interface{},1)
  607. // res := make(map[string]interface{})
  608. // res["fname"] = "分界线"
  609. // res["feedname"] = mapc2[i]
  610. // res["饲料名称"] = mapc2[i]
  611. // reslist[0] = res
  612. // queryList = append(reslist,queryList...)
  613. //}
  614. for i := 0; i < count2; i++ { // 将所有饲料种类新增为第一行 测试
  615. if _, ok := temsmap[mapc2[i]]; !ok {
  616. reslist := make([]map[string]interface{}, 1)
  617. res := make(map[string]interface{})
  618. res["fname"] = temstr
  619. res["feedname"] = mapc2[i]
  620. res["饲料名称"] = mapc2[i]
  621. res["typestr"] = typestr
  622. reslist[0] = res
  623. queryList = append(reslist, queryList...)
  624. }
  625. }
  626. for i := 0; i < len(queryList); i++ {
  627. a = mapc2[queryList[i]["feedname"]].(int) * 2
  628. if i == 0 {
  629. datamap2["label"] = "饲料名称"
  630. switch queryList[i]["typestr"].(type) {
  631. case string:
  632. datamap2child["label"] = queryList[i]["typestr"].(string) + "/饲料参数"
  633. default:
  634. datamap2child["label"] = "/饲料参数"
  635. }
  636. datamap2child["prop"] = "A"
  637. data3 = append(data3, datamap2child)
  638. datamap2["children"] = data3
  639. data2 = append(data2, datamap2)
  640. data3 = []interface{}{}
  641. datamap2child = make(map[string]interface{})
  642. datamap2 = make(map[string]interface{})
  643. dtem = queryList[i]["fname"]
  644. }
  645. if dtem != queryList[i]["fname"] && i != 0 {
  646. data1 = append(data1, datamap1)
  647. dtem = queryList[i]["fname"]
  648. datamap1 = make(map[string]interface{})
  649. }
  650. if queryList[i]["fname"] == temstr {
  651. datamap2["label"] = queryList[i]["feedname"]
  652. datamap2child["label"] = "理论"
  653. datamap2child["prop"] = "a" + strconv.Itoa(a)
  654. data3 = append(data3, datamap2child)
  655. datamap2child = make(map[string]interface{})
  656. datamap2child["label"] = "实际"
  657. datamap2child["prop"] = "a" + strconv.Itoa(a+1)
  658. data3 = append(data3, datamap2child)
  659. datamap2child = make(map[string]interface{})
  660. datamap2["children"] = data3
  661. data2 = append(data2, datamap2)
  662. data3 = []interface{}{}
  663. datamap2 = make(map[string]interface{})
  664. datamap2child = make(map[string]interface{})
  665. }
  666. datamap1["A"] = queryList[i]["fname"]
  667. datamap1["a"+strconv.Itoa(a)] = queryList[i]["lweight"]
  668. datamap1["a"+strconv.Itoa(a+1)] = queryList[i]["actualweightminus"]
  669. datamap2["label"] = queryList[i]["饲料名称"]
  670. a = a + 2
  671. }
  672. data1 = append(data1, datamap1)
  673. chartData["data1"] = data1
  674. chartData["data2"] = data2
  675. queryData["list"] = chartData
  676. queryData["code"] = 0
  677. queryData["message"] = "ok"
  678. queryData["data"] = queryList
  679. return queryData, nil
  680. }
  681. func getAccuracyV4(queryList []map[string]interface{}, queryListSum []map[string]interface{}, checked string, feednamesort3 []string, typea int) (map[string]interface{}, error) {
  682. queryData := make(map[string]interface{})
  683. chartData := make(map[string]interface{})
  684. datamap1 := make(map[string]interface{})
  685. datamap2 := make(map[string]interface{})
  686. temsmap := make(map[interface{}]interface{})
  687. mapc2 := make(map[interface{}]interface{})
  688. mapc3 := make(map[interface{}]interface{})
  689. data3 := []interface{}{}
  690. datamap2child := make(map[string]interface{})
  691. data2 := []interface{}{}
  692. data1 := []interface{}{}
  693. a := 0
  694. //ss := 0
  695. var dtem interface{}
  696. count2 := 0
  697. var tem interface{}
  698. var temstr interface{}
  699. var typestr interface{}
  700. //var sort interface{}
  701. for i := 0; i < len(queryList); i++ { // 获取所有饲料种类
  702. if i == 0 {
  703. temstr = queryList[i]["fname"]
  704. typestr = queryList[i]["typestr"]
  705. //sort = queryList[i]["sort"]
  706. }
  707. if temstr == queryList[i]["fname"] {
  708. temsmap[queryList[i]["feedname"]] = 1
  709. }
  710. //if i == len(queryList)-1{
  711. // temstr = "合计"
  712. // typestr = queryList[i]["typestr"]
  713. //}
  714. if _, ok := mapc2[queryList[i]["feedname"]]; !ok {
  715. mapc2[queryList[i]["feedname"]] = count2 // 编号
  716. mapc2[count2] = queryList[i]["feedname"]
  717. count2++
  718. }
  719. }
  720. for i := 0; i < count2; i++ { // 将所有饲料种类新增为第一行 测试
  721. if _, ok := temsmap[mapc2[i]]; !ok {
  722. reslist := make([]map[string]interface{}, 1)
  723. res := make(map[string]interface{})
  724. res["fname"] = temstr
  725. res["feedname"] = mapc2[i]
  726. res["饲料名称"] = mapc2[i]
  727. res["typestr"] = typestr
  728. reslist[0] = res
  729. queryList = append(reslist, queryList...)
  730. }
  731. }
  732. //for i := 0; i<count2 ; i++ {
  733. // reslist := make([]map[string]interface{},1)
  734. // res := make(map[string]interface{})
  735. // res["fname"] = "分界线"
  736. // res["feedname"] = mapc2[i]
  737. // res["饲料名称"] = mapc2[i]
  738. // res["typestr"] =typestr
  739. // reslist[0] = res
  740. // queryList = append(reslist,queryList...)
  741. //}
  742. for i := 0; i < len(queryList); i++ {
  743. if i == 0 {
  744. tem = queryList[i]["fname"]
  745. }
  746. if queryList[i]["fname"] == tem {
  747. mapc3[queryList[i]["feedname"]] = i
  748. }
  749. }
  750. for i := 0; i < len(queryList); i++ {
  751. a = mapc2[queryList[i]["feedname"]].(int) * 4
  752. if i == 0 {
  753. datamap2["label"] = "饲料名称"
  754. switch queryList[i]["typestr"].(type) {
  755. case string:
  756. // datamap2child["label"] = queryList[i]["typestr"].(string) + "/饲料参数"
  757. datamap2child["label"] = queryList[i]["typestr"].(string)
  758. default:
  759. datamap2child["label"] = "/饲料参数"
  760. }
  761. datamap2child["prop"] = "A"
  762. data3 = append(data3, datamap2child)
  763. datamap2["children"] = data3
  764. data2 = append(data2, datamap2)
  765. data3 = []interface{}{}
  766. datamap2child = make(map[string]interface{})
  767. datamap2 = make(map[string]interface{})
  768. dtem = queryList[i]["fname"]
  769. }
  770. if dtem != queryList[i]["fname"] && i != 0 {
  771. data1 = append(data1, datamap1)
  772. dtem = queryList[i]["fname"]
  773. datamap1 = make(map[string]interface{})
  774. }
  775. if queryList[i]["fname"] == temstr {
  776. datamap2["label"] = queryList[i]["feedname"]
  777. if typea == 0 || typea == 1 {
  778. datamap2child["label"] = "理论"
  779. datamap2child["prop"] = "a" + strconv.Itoa(a)
  780. data3 = append(data3, datamap2child)
  781. datamap2child = make(map[string]interface{})
  782. }
  783. if typea == 0 || typea == 2 {
  784. datamap2child["label"] = "实际"
  785. datamap2child["prop"] = "a" + strconv.Itoa(a+1)
  786. data3 = append(data3, datamap2child)
  787. datamap2child = make(map[string]interface{})
  788. }
  789. if checked == "1" {
  790. datamap2child["label"] = "误差值"
  791. datamap2child["prop"] = "a" + strconv.Itoa(a+2)
  792. data3 = append(data3, datamap2child)
  793. datamap2child = make(map[string]interface{})
  794. datamap2child["label"] = "误差率"
  795. datamap2child["prop"] = "a" + strconv.Itoa(a+3)
  796. data3 = append(data3, datamap2child)
  797. datamap2child = make(map[string]interface{})
  798. }
  799. // datamap2 = make(map[string]interface{})
  800. if i != len(queryList)-1 {
  801. datamap2["children"] = data3
  802. data2 = append(data2, datamap2)
  803. datamap2 = make(map[string]interface{})
  804. data3 = []interface{}{}
  805. }
  806. }
  807. datamap1["A"] = queryList[i]["fname"]
  808. if queryList[i]["lweight"] != nil {
  809. var lweight float64
  810. lweight, _ = strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  811. datamap1["a"+strconv.Itoa(a)] = lweight
  812. } else {
  813. datamap1["a"+strconv.Itoa(a)] = queryList[i]["lweight"]
  814. }
  815. if queryList[i]["actualweightminus"] != nil {
  816. var actualweightminus float64
  817. actualweightminus, _ = strconv.ParseFloat(queryList[i]["actualweightminus"].(string), 64)
  818. datamap1["a"+strconv.Itoa(a+1)] = actualweightminus
  819. } else {
  820. datamap1["a"+strconv.Itoa(a+1)] = queryList[i]["actualweightminus"]
  821. }
  822. if checked == "1" {
  823. datamap1["a"+strconv.Itoa(a+2)] = queryList[i]["diff"]
  824. datamap1["a"+strconv.Itoa(a+3)] = queryList[i]["diffrate"]
  825. }
  826. datamap2["label"] = queryList[i]["饲料名称"]
  827. for z := 0; z < len(queryListSum); z++ {
  828. if queryListSum[z]["fname"] == queryList[i]["fname"] {
  829. if queryListSum[z]["lweight"] != nil {
  830. var lweight float64
  831. lweight, _ = strconv.ParseFloat(queryListSum[z]["lweight"].(string), 64)
  832. datamap1["B"] = lweight
  833. } else {
  834. datamap1["B"] = queryListSum[z]["lweight"]
  835. }
  836. if queryListSum[z]["actualweightminus"] != nil {
  837. var actualweightminus float64
  838. actualweightminus, _ = strconv.ParseFloat(queryListSum[z]["actualweightminus"].(string), 64)
  839. datamap1["C"] = actualweightminus
  840. } else {
  841. datamap1["B"] = queryListSum[z]["actualweightminus"]
  842. }
  843. }
  844. }
  845. if i == len(queryList)-1 {
  846. datamap2["label"] = "合计"
  847. if typea == 0 || typea == 1 {
  848. datamap2child = make(map[string]interface{})
  849. datamap2child["label"] = "理论"
  850. datamap2child["prop"] = "B"
  851. data3 = append(data3, datamap2child)
  852. }
  853. if typea == 0 || typea == 2 {
  854. datamap2child = make(map[string]interface{})
  855. datamap2child["label"] = "实际"
  856. datamap2child["prop"] = "C"
  857. data3 = append(data3, datamap2child)
  858. }
  859. // ###########################
  860. datamap2["children"] = data3
  861. data2 = append(data2, datamap2)
  862. datamap2 = make(map[string]interface{})
  863. data3 = []interface{}{}
  864. }
  865. }
  866. //var sortSum []string
  867. //for z := 0; z < len(data2); z++ {
  868. // ss := data2[z].(map[string]interface{})
  869. // bb := ss["label"].(string)
  870. // if bb != "合计" {
  871. // sortSum = append(sortSum, bb)
  872. // }
  873. //}
  874. //sort.Strings(sortSum)
  875. //fmt.Println(sortSum)
  876. theEndSort := []interface{}{}
  877. for ii := 0; ii < len(data2); ii++ {
  878. ss := data2[ii].(map[string]interface{})
  879. bb := ss["label"].(string)
  880. if "饲料名称" == bb {
  881. theEndSort = append(theEndSort, data2[ii])
  882. }
  883. }
  884. for _, v := range feednamesort3 {
  885. for ii := 0; ii < len(data2); ii++ {
  886. ss := data2[ii].(map[string]interface{})
  887. bb := ss["label"].(string)
  888. // fmt.Println(bb)
  889. if v == bb && "饲料名称" != bb {
  890. theEndSort = append(theEndSort, data2[ii])
  891. }
  892. }
  893. }
  894. for ii := 0; ii < len(data2); ii++ {
  895. ss := data2[ii].(map[string]interface{})
  896. bb := ss["label"].(string)
  897. if "合计" == bb {
  898. theEndSort = append(theEndSort, data2[ii])
  899. }
  900. }
  901. data1 = append(data1, datamap1)
  902. chartData["data1"] = data1
  903. chartData["data2"] = theEndSort
  904. queryData["list"] = chartData
  905. queryData["code"] = 0
  906. queryData["message"] = "ok"
  907. queryData["data"] = queryList
  908. return queryData, nil
  909. }
  910. func getAccuracyV3(queryList []map[string]interface{}) (map[string]interface{}, error) {
  911. queryData := make(map[string]interface{})
  912. chartData := make(map[string]interface{})
  913. data := []interface{}{}
  914. data1 := []interface{}{}
  915. data2 := []interface{}{}
  916. data3 := []interface{}{}
  917. data4 := []interface{}{}
  918. //
  919. t1 := make(map[interface{}]string, 0)
  920. for i := 0; i < len(queryList); i++ {
  921. data = append(data, queryList[i]["mtime"])
  922. data1 = append(data1, queryList[i]["lweight"])
  923. data2 = append(data2, queryList[i]["weight"])
  924. //data3 = append(data3, queryList[i]["field3"])
  925. //data4 = append(data4, queryList[i]["field4"])
  926. if _, ok := t1[queryList[i]["id"]]; !ok {
  927. datatem := []interface{}{}
  928. datatem = append(datatem, queryList[i]["startstime"], queryList[i]["lastactualweight"])
  929. data3 = append(data3, datatem)
  930. datatem2 := []interface{}{}
  931. datatem2 = append(datatem2, queryList[i]["intime"], queryList[i]["actualweight"])
  932. data4 = append(data4, datatem2)
  933. //datatem = []interface{}{}
  934. }
  935. t1[queryList[i]["id"]] = "1"
  936. }
  937. //
  938. chartData["data1"] = data
  939. chartData["data2"] = data1
  940. chartData["data3"] = data2
  941. chartData["data4"] = data3
  942. chartData["data5"] = data4
  943. queryData["list"] = chartData
  944. queryData["code"] = 0
  945. queryData["message"] = "ok"
  946. queryData["data"] = queryList
  947. return queryData, nil
  948. }
  949. func getAccuracyV2(queryList []map[string]interface{}) (map[string]interface{}, error) {
  950. queryData := make(map[string]interface{})
  951. chartData := make(map[string]interface{})
  952. data := []interface{}{}
  953. data1 := []interface{}{}
  954. data2 := []interface{}{}
  955. data3 := []interface{}{}
  956. data4 := []interface{}{}
  957. for i := 0; i < len(queryList); i++ {
  958. data = append(data, queryList[i]["日期"])
  959. data1 = append(data1, queryList[i]["field1"])
  960. data2 = append(data2, queryList[i]["field2"])
  961. data3 = append(data3, queryList[i]["field3"])
  962. data4 = append(data4, queryList[i]["field4"])
  963. }
  964. chartData["data1"] = data
  965. chartData["data2"] = data1
  966. chartData["data3"] = data2
  967. chartData["data4"] = data3
  968. chartData["data5"] = data4
  969. queryData["list"] = chartData
  970. queryData["code"] = 0
  971. queryData["message"] = "ok"
  972. queryData["data"] = queryList
  973. return queryData, nil
  974. }
  975. func getAccuracy(queryList []map[string]interface{}) (map[string]interface{}, error) {
  976. queryData := make(map[string]interface{})
  977. chartData := make(map[string]interface{})
  978. t1 := make(map[interface{}]interface{}, 0)
  979. t2 := make(map[interface{}]interface{}, 0)
  980. data := make(map[string][]interface{}, 0)
  981. t := make([]map[string][]interface{}, 0)
  982. e1 := []interface{}{}
  983. e2 := []string{}
  984. for _, value := range queryList {
  985. if _, ok := t1[value["名称"]]; !ok {
  986. e1 = append(e1, value["名称"])
  987. }
  988. if _, ok := t2[value["日期"]]; !ok {
  989. switch value["日期"].(type) {
  990. case string:
  991. e2 = append(e2, value["日期"].(string))
  992. }
  993. }
  994. t1[value["名称"]] = value["名称"]
  995. t2[value["日期"]] = value["日期"]
  996. }
  997. sort.Strings(e2)
  998. var b interface{}
  999. a := 0
  1000. for i := 0; i < len(queryList); i++ {
  1001. if i == 0 {
  1002. b = queryList[i]["名称"]
  1003. }
  1004. if b != queryList[i]["名称"] {
  1005. if a < len(e2)-1 {
  1006. for k := 0; k < len(e2)-a; k++ {
  1007. data["data"] = append(data["data"], "")
  1008. }
  1009. }
  1010. t = append(t, data)
  1011. data = make(map[string][]interface{}, 0)
  1012. b = queryList[i]["名称"]
  1013. a = 0
  1014. }
  1015. switch queryList[i]["日期"].(type) {
  1016. case string:
  1017. dates, _ := time.Parse("2006-01-02", queryList[i]["日期"].(string))
  1018. dates1 := ""
  1019. if a < len(e2)-1 {
  1020. dates1 = e2[a]
  1021. } else {
  1022. dates1 = e2[len(e2)-1]
  1023. }
  1024. if a < len(e2)-1 {
  1025. if e2[a] != queryList[i]["日期"].(string) {
  1026. if e2[a] < queryList[i]["日期"].(string) {
  1027. dates1 = queryList[i]["日期"].(string)
  1028. dates, _ = time.Parse("2006-01-02", e2[a])
  1029. for ; a < len(e2)-1; a++ {
  1030. if e2[a] >= queryList[i]["日期"].(string) {
  1031. break
  1032. }
  1033. }
  1034. }
  1035. for ; dates.Format("2006-01-02") < dates1; dates = dates.Add(24 * time.Hour) {
  1036. data["data"] = append(data["data"], "")
  1037. }
  1038. }
  1039. }
  1040. }
  1041. data["data"] = append(data["data"], queryList[i]["准确率"])
  1042. a++
  1043. }
  1044. if a < len(e2)-1 {
  1045. for k := 0; k < len(e2)-a; k++ {
  1046. data["data"] = append(data["data"], "")
  1047. }
  1048. }
  1049. t = append(t, data)
  1050. chartData["data1"] = e1
  1051. chartData["data2"] = e2
  1052. chartData["data3"] = t
  1053. queryData["list"] = chartData
  1054. queryData["code"] = 0
  1055. queryData["message"] = "ok"
  1056. queryData["data"] = queryList
  1057. return queryData, nil
  1058. }
  1059. //统计分析过程分析data值拆分
  1060. func GetprocessAnalysisTB(parammaps *gofasion.Fasion, tx *xorm.Session, quertDataList interface{}, queryList []map[string]interface{}) (query map[string]interface{}, err error) {
  1061. sql1, p1 := restful.GetSqlByNameDBT("getweightjson", tx)
  1062. query1 := make(map[string]interface{}, 0)
  1063. s_params1 := make([]interface{}, 0)
  1064. if sql1 != "" {
  1065. paramslist := strings.Split(p1, ",")
  1066. if len(paramslist) > 0 && p1 != "" {
  1067. for _, value := range paramslist {
  1068. s_params1 = append(s_params1, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  1069. }
  1070. }
  1071. }
  1072. queryList2, err := tx.SQL(sql1, s_params1...).Query().List()
  1073. if len(queryList2) == 0 {
  1074. return query1, nil
  1075. }
  1076. if err != nil {
  1077. fmt.Println("查询配料出错")
  1078. return nil, err
  1079. }
  1080. //fmt.Printf("%T\n",queryList2[0]["weightjson"])
  1081. b, _ := json.Marshal(&quertDataList)
  1082. var m map[string]interface{}
  1083. _ = json.Unmarshal(b, &m)
  1084. msg := queryList2[0]["weightjson"].(string)
  1085. weightjson := make([]map[string]string, 0)
  1086. json.Unmarshal([]byte(msg), &weightjson)
  1087. //fmt.Println(len(weightjson))
  1088. realWandT := make([]interface{}, 0)
  1089. for i := 0; i < len(weightjson); i++ {
  1090. oneSlice := make([]interface{}, 0)
  1091. oneSlice = append(oneSlice, weightjson[i]["mt"])
  1092. oneSlice = append(oneSlice, weightjson[i]["w"])
  1093. realWandT = append(realWandT, oneSlice)
  1094. }
  1095. WTime := make([]interface{}, 0)
  1096. for z := 0; z < len(weightjson); z++ {
  1097. WTime = append(WTime, weightjson[z]["mt"])
  1098. }
  1099. data2 := make([]interface{}, 0)
  1100. for i := 0; i < len(queryList); i++ {
  1101. querySlice := make([]interface{}, 0)
  1102. querySlice = append(querySlice, queryList[i]["timedate"], queryList[i]["lweight"])
  1103. data2 = append(data2, querySlice)
  1104. }
  1105. data5 := make([]interface{}, 0)
  1106. for i := 0; i < len(queryList); i++ {
  1107. querySlice := make([]interface{}, 0)
  1108. querySlice = append(querySlice, queryList[i]["intime"], queryList[i]["actualweight"], queryList[i]["allname"], queryList[i]["fname"])
  1109. data5 = append(data5, querySlice)
  1110. }
  1111. query1["WTime"] = WTime
  1112. query1["data2"] = data2
  1113. query1["data5"] = data5
  1114. query1["realWandT"] = realWandT
  1115. return query1, nil
  1116. }