report.go 48 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652
  1. package api
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "math"
  6. "sort"
  7. "strconv"
  8. "strings"
  9. "time"
  10. "tmr-watch/http/handle/restful"
  11. "github.com/Anderson-Lu/gofasion/gofasion"
  12. "github.com/xormplus/xorm"
  13. )
  14. //包含报表模块前端需要的各种数据格式转换
  15. func praseReportform(sqlnamestr string, parammaps *gofasion.Fasion, tx *xorm.Session, checked string, offset, count, typea, mode int) (queryData map[string]interface{}, err error) {
  16. sql, p := restful.GetSqlByNameDBT(sqlnamestr, tx)
  17. s_params := make([]interface{}, 0)
  18. if sql != "" {
  19. paramslist := strings.Split(p, ",")
  20. if len(paramslist) > 0 && p != "" {
  21. for _, value := range paramslist {
  22. s_params = append(s_params, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  23. }
  24. }
  25. }
  26. queryList, err := tx.SQL(sql, s_params...).Query().List()
  27. //############
  28. sql2, p2 := restful.GetSqlByNameDBT("getFeednameSort", tx)
  29. s_params2 := make([]interface{}, 0)
  30. if sql2 != "" {
  31. paramslist2 := strings.Split(p2, ",")
  32. if len(paramslist2) > 0 && p != "" {
  33. for _, value := range paramslist2 {
  34. s_params2 = append(s_params2, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  35. }
  36. }
  37. }
  38. queryList2, err := tx.SQL(sql2, s_params2...).Query().List()
  39. var feednamesort []string
  40. var feedcodelist []string
  41. if len(queryList2) > 0 {
  42. for i := 0; i < len(queryList2); i++ {
  43. feednamesort = append(feednamesort, queryList2[i]["fname"].(string))
  44. }
  45. }
  46. // #########
  47. sql3, p3 := restful.GetSqlByNameDBT("getFeednameSort2", tx)
  48. s_params3 := make([]interface{}, 0)
  49. if sql3 != "" {
  50. paramslist3 := strings.Split(p3, ",")
  51. if len(paramslist3) > 0 && p != "" {
  52. for _, value := range paramslist3 {
  53. s_params3 = append(s_params3, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  54. }
  55. }
  56. }
  57. // var queryList3 []map[string]interface{}
  58. feedDataList := make([]map[string]interface{}, 0)
  59. var feednamesort3 []string
  60. if sql3 != "" {
  61. queryList3, err := tx.SQL(sql3, s_params3...).Query().List()
  62. // fmt.Println()
  63. if err != nil {
  64. return nil, err
  65. }
  66. if len(queryList3) > 0 {
  67. for z := 0; z < len(queryList3); z++ {
  68. feednamesort3 = append(feednamesort3, queryList3[z]["feedname"].(string))
  69. feedcodelist = append(feedcodelist, queryList3[z]["feedcode"].(string))
  70. }
  71. feedDataList = append(feedDataList, queryList3...)
  72. }
  73. }
  74. if err != nil {
  75. return nil, err
  76. }
  77. // if len(queryList) == 0 {
  78. // return nil, nil
  79. // }
  80. temstr := ""
  81. //除特殊接口外,去接口名称的前10位做同一类型的转换
  82. switch sqlnamestr {
  83. case "getAccuracyAllHL", "getAccuracyAllQX", "getAccuracyAllJH", "getFeedEffMR", "getFeedEffHL", "getHomepageCB", "getAccuraa", "judgenurFTReportDetail":
  84. temstr = sqlnamestr
  85. default:
  86. temstr = sqlnamestr[:10]
  87. }
  88. // 根据名称选择不通类型的转换-(可自动扩展,不需要使用之前的)
  89. switch temstr {
  90. case "getAccurac", "getFeedEff":
  91. queryData, err = getAccuracy(queryList, "2006-01-02") // 不定参数
  92. case "getprocess":
  93. //queryData, err = getAccuracyV3v1(queryList)
  94. queryData, err = getAccuracyV3(queryList)
  95. // 统计分析 过程分析
  96. if sqlnamestr == "getprocessAnalysisTB" {
  97. quertDataList := queryData["list"]
  98. query := quertDataList.(map[string]interface{})
  99. querys, _ := GetprocessAnalysisTB(parammaps, tx, quertDataList, queryList)
  100. if len(querys) != 0 {
  101. query["data1"] = querys["WTime"]
  102. query["data2"] = querys["data2"]
  103. query["data3"] = querys["realWandT"]
  104. query["data5"] = querys["data5"]
  105. }
  106. }
  107. case "getHomepro":
  108. queryData, err = getAccuracyV3(queryList)
  109. case "getAccuracyAllHL", "getAccuracyAllQX", "getAccuracyAllJH", "getFeedEffMR", "getFeedEffHL", "getHomepageCB", "getAccuraa":
  110. queryData, err = getAccuracyV2(queryList) //固定维度 日期
  111. case "getMateria":
  112. sql1, p1 := restful.GetSqlByNameDBT(sqlnamestr+("sum"), tx)
  113. s_params1 := make([]interface{}, 0)
  114. if sql1 != "" {
  115. paramslist1 := strings.Split(p1, ",")
  116. if len(paramslist1) > 0 && p != "" {
  117. for _, value := range paramslist1 {
  118. s_params1 = append(s_params1, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  119. }
  120. }
  121. }
  122. queryListSum, _ := tx.SQL(sql1, s_params1...).Query().List()
  123. if mode == 0 {
  124. for _, a := range queryList {
  125. fmt.Println(a)
  126. }
  127. queryData, err = getAccuracyV4(queryList, queryListSum, checked, feednamesort3, typea)
  128. } else {
  129. queryData, _ = getAccuracyV41(queryList, queryListSum, checked, feednamesort3, typea, feedDataList)
  130. }
  131. queryData["feedcode"] = feedcodelist
  132. case "getPriceAn":
  133. queryData, err = getAccuracyV5(queryList, typea)
  134. case "getJT1Accu":
  135. queryData, err = getAccuracyV6(queryList) //固定维度 牧场
  136. case "judgenurFT":
  137. queryData, err = getAccuracyV7(queryList)
  138. case "judgenurFTReportDetail":
  139. queryData, err = getAccuracyV8(queryList)
  140. case "downloadPl":
  141. var sql2, p2 string
  142. s_params2 := make([]interface{}, 0)
  143. if sqlnamestr == "downloadPlanSFJD" {
  144. sql2, p2 = restful.GetSqlByNameDBT("countfl", tx)
  145. //s_params1 := make([]interface{}, 0)
  146. if sql2 != "" {
  147. paramslist1 := strings.Split(p2, ",")
  148. if len(paramslist1) > 0 && p != "" {
  149. for _, value := range paramslist1 {
  150. s_params2 = append(s_params2, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  151. }
  152. }
  153. }
  154. }
  155. queryList2, _ := tx.SQL(sql2, s_params2...).Query().List()
  156. var flleight string
  157. if len(queryList2) > 0 {
  158. flleight, _ = queryList2[0]["flcount"].(string)
  159. // fmt.Println(flleight)
  160. }
  161. flleightint, _ := strconv.Atoi(flleight)
  162. // getAccuracyV9English
  163. languageStatus := GetLanguageStatus()
  164. if languageStatus == "0" {
  165. if sqlnamestr == "downloadPlanTSLJD" {
  166. queryData, err = getAccuracyV9(queryList, sqlnamestr, flleightint, feednamesort3)
  167. } else {
  168. queryData, err = getAccuracyV9(queryList, sqlnamestr, flleightint, feednamesort) //投料简打、累加
  169. }
  170. } else {
  171. if sqlnamestr == "downloadPlanTSLJD" {
  172. queryData, err = getAccuracyV9English(queryList, sqlnamestr, flleightint, feednamesort3)
  173. } else {
  174. queryData, err = getAccuracyV9English(queryList, sqlnamestr, flleightint, feednamesort) //投料简打、累加
  175. }
  176. }
  177. default:
  178. queryData, err = nil, nil
  179. }
  180. return
  181. }
  182. func getAccuracyV9(queryList []map[string]interface{}, sqlnamestr string, flleightint int, feednamesort []string) (map[string]interface{}, error) {
  183. queryData := make(map[string]interface{})
  184. chartData := make(map[string]interface{})
  185. mapc3 := make(map[string]interface{})
  186. data2 := []interface{}{}
  187. data1 := []interface{}{}
  188. mapc3["label"] = "车次"
  189. mapc3["prop"] = "projname"
  190. data1 = append(data1, mapc3)
  191. mapc3 = make(map[string]interface{})
  192. mapc3["label"] = "TMR"
  193. mapc3["prop"] = "tmrtname"
  194. data1 = append(data1, mapc3)
  195. mapc3 = make(map[string]interface{})
  196. //if sqlnamestr == "downloadPlanSFJD":
  197. //mapc3["label"] = "时间"
  198. //mapc3["prop"] = "plantime"
  199. //data1 = append(data1, mapc3)
  200. //mapc3 = make(map[string]interface{})
  201. //
  202. //mapc3["label"] = "班组"
  203. //mapc3["prop"] = "times"
  204. //data1 = append(data1, mapc3)
  205. //mapc3 = make(map[string]interface{})
  206. //
  207. //mapc3["label"] = "驾驶员"
  208. //mapc3["prop"] = "driver"
  209. //data1 = append(data1, mapc3)
  210. //mapc3 = make(map[string]interface{})
  211. //
  212. //mapc3["label"] = "日系数比例"
  213. //mapc3["prop"] = "rate"
  214. //data1 = append(data1, mapc3)
  215. //mapc3 = make(map[string]interface{})
  216. //
  217. //mapc3["label"] = "牛头数"
  218. //mapc3["prop"] = "feedpcount"
  219. //data1 = append(data1, mapc3)
  220. //mapc3 = make(map[string]interface{})
  221. //
  222. //mapc3["label"] = "配方模板"
  223. //mapc3["prop"] = "templetname"
  224. //data1 = append(data1, mapc3)
  225. //mapc3 = make(map[string]interface{})
  226. //#######################################################################################
  227. mtem := make(map[interface{}]interface{})
  228. var stem, feedNames []string
  229. for _, feed := range feednamesort {
  230. feed = strings.ReplaceAll(feed, " ", "")
  231. mtem[feed] = struct{}{}
  232. // fmt.Println(feed)
  233. stem = append(stem, feed)
  234. }
  235. for i := 0; i < len(queryList); i++ { // 获取所有饲料种类
  236. // if _, ok := mtem[queryList[i]["fname"]]; ok {
  237. // continue
  238. // }
  239. // stem = append(stem, queryList[i]["fname"].(string))
  240. // mtem[queryList[i]["fname"]] = struct{}{}
  241. feedNames = append(feedNames, queryList[i]["fname"].(string))
  242. }
  243. sort.Strings(feedNames)
  244. for _, feed := range feedNames {
  245. if _, ok := mtem[feed]; ok {
  246. continue
  247. }
  248. // fmt.Println(feed)
  249. stem = append(stem, feed)
  250. mtem[feed] = struct{}{}
  251. }
  252. stemEnd := []string{}
  253. if sqlnamestr == "downloadPlanSFJD" {
  254. bb := stem[len(stem)-flleightint : len(stem) : len(stem)]
  255. //aa := stem[0 : len(stem)-flleightint : len(stem)]
  256. stemEnd = append(stemEnd, bb...)
  257. stemEnd = append(stemEnd, feednamesort...)
  258. //fmt.Println(stemEnd)
  259. } else {
  260. stemEnd = stem
  261. }
  262. //logging.Info("导出数据 ",stemEnd )
  263. for _, va := range stemEnd {
  264. mapc3["label"] = va
  265. mapc3["prop"] = va
  266. data1 = append(data1, mapc3)
  267. mapc3 = make(map[string]interface{})
  268. }
  269. if queryList[0]["sumlweight"] != nil {
  270. mapc3["label"] = "合计"
  271. mapc3["prop"] = "sumlweight"
  272. }
  273. data1 = append(data1, mapc3)
  274. mapc3 = make(map[string]interface{})
  275. var tem interface{}
  276. mapc2 := make(map[string]interface{})
  277. for i := 0; i < len(queryList); i++ { // 获取所有饲料种类
  278. if i == 0 {
  279. tem = queryList[i]["projname"]
  280. mapc2 = queryList[i]
  281. if mapc2["sumlweight"] != nil {
  282. var sumlweight float64
  283. sumlweight, _ = strconv.ParseFloat(mapc2["sumlweight"].(string), 64)
  284. mapc2["sumlweight"] = sumlweight
  285. }
  286. for key := range mtem {
  287. mapc2[xorm.String(key)] = 0
  288. }
  289. // var lweight float64
  290. if queryList[i]["lweight"] != nil {
  291. // var error errors.Error
  292. lweight, err := strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  293. if err == nil {
  294. mapc2[xorm.String(queryList[i]["fname"])] = lweight
  295. } else {
  296. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  297. }
  298. } else {
  299. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  300. }
  301. }
  302. if tem == queryList[i]["projname"] {
  303. // var lweight float64
  304. if queryList[i]["lweight"] != nil {
  305. lweight, err := strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  306. if err == nil {
  307. mapc2[xorm.String(queryList[i]["fname"])] = lweight
  308. } else {
  309. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  310. }
  311. } else {
  312. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  313. }
  314. } else {
  315. data2 = append(data2, mapc2)
  316. tem = queryList[i]["projname"]
  317. mapc2 = queryList[i]
  318. if mapc2["sumlweight"] != nil {
  319. var sumlweight float64
  320. sumlweight, _ = strconv.ParseFloat(mapc2["sumlweight"].(string), 64)
  321. mapc2["sumlweight"] = sumlweight
  322. }
  323. for key := range mtem {
  324. mapc2[xorm.String(key)] = 0
  325. }
  326. if queryList[i]["lweight"] != nil {
  327. lweight, err := strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  328. if err == nil {
  329. mapc2[xorm.String(queryList[i]["fname"])] = lweight
  330. } else {
  331. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  332. }
  333. } else {
  334. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  335. }
  336. }
  337. }
  338. data2 = append(data2, mapc2)
  339. chartData["data1"] = data1
  340. chartData["data2"] = data2
  341. queryData["list"] = chartData
  342. queryData["code"] = 0
  343. queryData["message"] = "ok"
  344. queryData["data"] = queryList
  345. return queryData, nil
  346. }
  347. func getAccuracyV9English(queryList []map[string]interface{}, sqlnamestr string, flleightint int, feednamesort []string) (map[string]interface{}, error) {
  348. queryData := make(map[string]interface{})
  349. chartData := make(map[string]interface{})
  350. mapc3 := make(map[string]interface{})
  351. data2 := []interface{}{}
  352. data1 := []interface{}{}
  353. mapc3["label"] = "Batch"
  354. mapc3["prop"] = "projname"
  355. data1 = append(data1, mapc3)
  356. mapc3 = make(map[string]interface{})
  357. mapc3["label"] = "TMR"
  358. mapc3["prop"] = "tmrtname"
  359. data1 = append(data1, mapc3)
  360. mapc3 = make(map[string]interface{})
  361. //if sqlnamestr == "downloadPlanSFJD":
  362. //mapc3["label"] = "时间"
  363. //mapc3["prop"] = "plantime"
  364. //data1 = append(data1, mapc3)
  365. //mapc3 = make(map[string]interface{})
  366. //
  367. //mapc3["label"] = "班组"
  368. //mapc3["prop"] = "times"
  369. //data1 = append(data1, mapc3)
  370. //mapc3 = make(map[string]interface{})
  371. //
  372. //mapc3["label"] = "驾驶员"
  373. //mapc3["prop"] = "driver"
  374. //data1 = append(data1, mapc3)
  375. //mapc3 = make(map[string]interface{})
  376. //
  377. //mapc3["label"] = "日系数比例"
  378. //mapc3["prop"] = "rate"
  379. //data1 = append(data1, mapc3)
  380. //mapc3 = make(map[string]interface{})
  381. //
  382. //mapc3["label"] = "牛头数"
  383. //mapc3["prop"] = "feedpcount"
  384. //data1 = append(data1, mapc3)
  385. //mapc3 = make(map[string]interface{})
  386. //
  387. //mapc3["label"] = "配方模板"
  388. //mapc3["prop"] = "templetname"
  389. //data1 = append(data1, mapc3)
  390. //mapc3 = make(map[string]interface{})
  391. //#######################################################################################
  392. mtem := make(map[interface{}]interface{})
  393. var stem, feedNames []string
  394. for _, feed := range feednamesort {
  395. feed = strings.ReplaceAll(feed, " ", "")
  396. mtem[feed] = struct{}{}
  397. // fmt.Println(feed)
  398. stem = append(stem, feed)
  399. }
  400. for i := 0; i < len(queryList); i++ { // 获取所有饲料种类
  401. // if _, ok := mtem[queryList[i]["fname"]]; ok {
  402. // continue
  403. // }
  404. // stem = append(stem, queryList[i]["fname"].(string))
  405. // mtem[queryList[i]["fname"]] = struct{}{}
  406. feedNames = append(feedNames, queryList[i]["fname"].(string))
  407. }
  408. sort.Strings(feedNames)
  409. for _, feed := range feedNames {
  410. if _, ok := mtem[feed]; ok {
  411. continue
  412. }
  413. // fmt.Println(feed)
  414. stem = append(stem, feed)
  415. mtem[feed] = struct{}{}
  416. }
  417. stemEnd := []string{}
  418. if sqlnamestr == "downloadPlanSFJD" {
  419. bb := stem[len(stem)-flleightint : len(stem) : len(stem)]
  420. //aa := stem[0 : len(stem)-flleightint : len(stem)]
  421. stemEnd = append(stemEnd, bb...)
  422. stemEnd = append(stemEnd, feednamesort...)
  423. //fmt.Println(stemEnd)
  424. } else {
  425. stemEnd = stem
  426. }
  427. //logging.Info("导出数据 ",stemEnd )
  428. for _, va := range stemEnd {
  429. mapc3["label"] = va
  430. mapc3["prop"] = va
  431. data1 = append(data1, mapc3)
  432. mapc3 = make(map[string]interface{})
  433. }
  434. if queryList[0]["sumlweight"] != nil {
  435. mapc3["label"] = "Sum"
  436. mapc3["prop"] = "sumlweight"
  437. }
  438. data1 = append(data1, mapc3)
  439. mapc3 = make(map[string]interface{})
  440. var tem interface{}
  441. mapc2 := make(map[string]interface{})
  442. for i := 0; i < len(queryList); i++ { // 获取所有饲料种类
  443. if i == 0 {
  444. tem = queryList[i]["projname"]
  445. mapc2 = queryList[i]
  446. if mapc2["sumlweight"] != nil {
  447. var sumlweight float64
  448. sumlweight, _ = strconv.ParseFloat(mapc2["sumlweight"].(string), 64)
  449. mapc2["sumlweight"] = sumlweight
  450. }
  451. for key := range mtem {
  452. mapc2[xorm.String(key)] = 0
  453. }
  454. // var lweight float64
  455. if queryList[i]["lweight"] != nil {
  456. // var error errors.Error
  457. lweight, err := strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  458. if err == nil {
  459. mapc2[xorm.String(queryList[i]["fname"])] = lweight
  460. } else {
  461. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  462. }
  463. } else {
  464. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  465. }
  466. }
  467. if tem == queryList[i]["projname"] {
  468. // var lweight float64
  469. if queryList[i]["lweight"] != nil {
  470. lweight, err := strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  471. if err == nil {
  472. mapc2[xorm.String(queryList[i]["fname"])] = lweight
  473. } else {
  474. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  475. }
  476. } else {
  477. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  478. }
  479. } else {
  480. data2 = append(data2, mapc2)
  481. tem = queryList[i]["projname"]
  482. mapc2 = queryList[i]
  483. if mapc2["sumlweight"] != nil {
  484. var sumlweight float64
  485. sumlweight, _ = strconv.ParseFloat(mapc2["sumlweight"].(string), 64)
  486. mapc2["sumlweight"] = sumlweight
  487. }
  488. for key := range mtem {
  489. mapc2[xorm.String(key)] = 0
  490. }
  491. if queryList[i]["lweight"] != nil {
  492. lweight, err := strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  493. if err == nil {
  494. mapc2[xorm.String(queryList[i]["fname"])] = lweight
  495. } else {
  496. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  497. }
  498. } else {
  499. mapc2[xorm.String(queryList[i]["fname"])] = queryList[i]["lweight"]
  500. }
  501. }
  502. }
  503. data2 = append(data2, mapc2)
  504. chartData["data1"] = data1
  505. chartData["data2"] = data2
  506. queryData["list"] = chartData
  507. queryData["code"] = 0
  508. queryData["message"] = "ok"
  509. queryData["data"] = queryList
  510. return queryData, nil
  511. }
  512. func getAccuracyV8(queryList []map[string]interface{}) (map[string]interface{}, error) {
  513. queryData := make(map[string]interface{})
  514. chartData := make(map[string]interface{})
  515. //list := make(map[string]interface{})
  516. data := []interface{}{}
  517. for i := 0; i < len(queryList); i++ {
  518. dry, _ := strconv.ParseFloat(queryList[i]["dry"].(string), 64)
  519. Hrate, _ := strconv.ParseFloat(queryList[i]["Hrate"].(string), 64)
  520. Srate, _ := strconv.ParseFloat(queryList[i]["Srate"].(string), 64)
  521. trans35f, _ := strconv.ParseFloat(queryList[i]["trans35f"].(string), 64)
  522. jcrate, _ := strconv.ParseFloat(queryList[i]["jcrate"].(string), 64)
  523. uprice, _ := strconv.ParseFloat(queryList[i]["uprice"].(string), 64)
  524. kprice, _ := strconv.ParseFloat(queryList[i]["dry"].(string), 64)
  525. adf, _ := strconv.ParseFloat(queryList[i]["adf"].(string), 64)
  526. ca, _ := strconv.ParseFloat(queryList[i]["ca"].(string), 64)
  527. cdry, _ := strconv.ParseFloat(queryList[i]["cdry"].(string), 64)
  528. cad, _ := strconv.ParseFloat(queryList[i]["cad"].(string), 64)
  529. cndf, _ := strconv.ParseFloat(queryList[i]["cndf"].(string), 64)
  530. cp, _ := strconv.ParseFloat(queryList[i]["cp"].(string), 64)
  531. cpd, _ := strconv.ParseFloat(queryList[i]["cpd"].(string), 64)
  532. fat, _ := strconv.ParseFloat(queryList[i]["fat"].(string), 64)
  533. ndf, _ := strconv.ParseFloat(queryList[i]["ndf"].(string), 64)
  534. nm, _ := strconv.ParseFloat(queryList[i]["nm"].(string), 64)
  535. nmd, _ := strconv.ParseFloat(queryList[i]["nmd"].(string), 64)
  536. nuint, _ := strconv.ParseFloat(queryList[i]["nuint"].(string), 64)
  537. p, _ := strconv.ParseFloat(queryList[i]["p"].(string), 64)
  538. pd, _ := strconv.ParseFloat(queryList[i]["pd"].(string), 64)
  539. starch, _ := strconv.ParseFloat(queryList[i]["starch"].(string), 64)
  540. trans4f, _ := strconv.ParseFloat(queryList[i]["trans4f"].(string), 64)
  541. list := make(map[string]interface{})
  542. list["ft"] = dry
  543. list["index"] = "干物质(kg)"
  544. list["tmr"] = TransFloat(dry * Hrate)
  545. list["cyl"] = TransFloat(dry * Srate)
  546. data = append(data, list)
  547. list = make(map[string]interface{})
  548. list["ft"] = jcrate
  549. list["index"] = "粗精比(%)"
  550. list["tmr"] = TransFloat(jcrate * Hrate)
  551. list["cyl"] = TransFloat(jcrate * Srate)
  552. data = append(data, list)
  553. list = make(map[string]interface{})
  554. list["ft"] = uprice
  555. list["index"] = "日粮成本(元)"
  556. list["tmr"] = TransFloat(uprice * Hrate)
  557. list["cyl"] = TransFloat(uprice * Srate)
  558. data = append(data, list)
  559. list = make(map[string]interface{})
  560. list["ft"] = kprice
  561. list["index"] = "公斤奶成本"
  562. list["tmr"] = TransFloat(kprice * Hrate)
  563. list["cyl"] = TransFloat(kprice * Srate)
  564. data = append(data, list)
  565. list = make(map[string]interface{})
  566. list["ft"] = cdry
  567. list["index"] = "粗料中的干物质"
  568. list["tmr"] = TransFloat(cdry * Hrate)
  569. list["cyl"] = TransFloat(cdry * Srate)
  570. data = append(data, list)
  571. list = make(map[string]interface{})
  572. list["ft"] = nm
  573. list["index"] = " 产奶净能(MJ)"
  574. list["tmr"] = TransFloat(nm * Hrate)
  575. list["cyl"] = TransFloat(nm * Srate)
  576. data = append(data, list)
  577. list = make(map[string]interface{})
  578. list["ft"] = nuint
  579. list["index"] = "奶牛能量单位(NND)"
  580. list["tmr"] = TransFloat(nuint * Hrate)
  581. list["cyl"] = TransFloat(nuint * Srate)
  582. data = append(data, list)
  583. list = make(map[string]interface{})
  584. list["ft"] = cp
  585. list["index"] = "粗蛋白(g)"
  586. list["tmr"] = TransFloat(cp * Hrate)
  587. list["cyl"] = TransFloat(cp * Srate)
  588. data = append(data, list)
  589. list = make(map[string]interface{})
  590. list["ft"] = cpd
  591. list["index"] = "粗蛋白(%DM)"
  592. list["tmr"] = TransFloat(cpd * Hrate)
  593. list["cyl"] = TransFloat(cpd * Srate)
  594. data = append(data, list)
  595. list = make(map[string]interface{})
  596. list["ft"] = ca
  597. list["index"] = "钙(g)"
  598. list["tmr"] = TransFloat(ca * Hrate)
  599. list["cyl"] = TransFloat(ca * Srate)
  600. data = append(data, list)
  601. list = make(map[string]interface{})
  602. list["ft"] = p
  603. list["index"] = "磷(g)"
  604. list["tmr"] = TransFloat(p * Hrate)
  605. list["cyl"] = TransFloat(p * Srate)
  606. data = append(data, list)
  607. list = make(map[string]interface{})
  608. list["ft"] = nmd
  609. list["index"] = "产奶净能(Mcal/DM)"
  610. list["tmr"] = TransFloat(nmd * Hrate)
  611. list["cyl"] = TransFloat(nmd * Srate)
  612. data = append(data, list)
  613. list = make(map[string]interface{})
  614. list["ft"] = fat
  615. list["index"] = "脂肪"
  616. list["tmr"] = TransFloat(fat * Hrate)
  617. list["cyl"] = TransFloat(fat * Srate)
  618. data = append(data, list)
  619. list = make(map[string]interface{})
  620. list["ft"] = starch
  621. list["index"] = "淀粉"
  622. list["tmr"] = TransFloat(starch * Hrate)
  623. list["cyl"] = TransFloat(starch * Srate)
  624. data = append(data, list)
  625. list = make(map[string]interface{})
  626. list["ft"] = ndf
  627. list["index"] = "NDF(%DM)"
  628. list["tmr"] = TransFloat(ndf * Hrate)
  629. list["cyl"] = TransFloat(ndf * Srate)
  630. data = append(data, list)
  631. list = make(map[string]interface{})
  632. list["ft"] = cndf
  633. list["index"] = "粗料中的NDF(%DM)"
  634. list["tmr"] = TransFloat(cndf * Hrate)
  635. list["cyl"] = TransFloat(cndf * Srate)
  636. data = append(data, list)
  637. list = make(map[string]interface{})
  638. list["ft"] = adf
  639. list["index"] = " ADF(%DM)"
  640. list["tmr"] = TransFloat(adf * Hrate)
  641. list["cyl"] = TransFloat(adf * Srate)
  642. data = append(data, list)
  643. list = make(map[string]interface{})
  644. list["ft"] = cad
  645. list["index"] = "钙(%DM)"
  646. list["tmr"] = TransFloat(cad * Hrate)
  647. list["cyl"] = TransFloat(cad * Srate)
  648. data = append(data, list)
  649. list = make(map[string]interface{})
  650. list["ft"] = pd
  651. list["index"] = " 磷(%DM)"
  652. list["tmr"] = TransFloat(pd * Hrate)
  653. list["cyl"] = TransFloat(pd * Srate)
  654. data = append(data, list)
  655. list = make(map[string]interface{})
  656. list["ft"] = trans35f
  657. list["index"] = "(3.5)FCR(kg/DM)"
  658. list["tmr"] = TransFloat(trans35f * Hrate)
  659. list["cyl"] = TransFloat(trans35f * Srate)
  660. data = append(data, list)
  661. list = make(map[string]interface{})
  662. list["ft"] = trans4f
  663. list["index"] = "(4.0)FCR(kg/DM)"
  664. list["tmr"] = TransFloat(trans4f * Hrate)
  665. list["cyl"] = TransFloat(trans4f * Srate)
  666. data = append(data, list)
  667. }
  668. chartData["data"] = data
  669. queryData["list"] = chartData
  670. queryData["code"] = 0
  671. queryData["message"] = "ok"
  672. queryData["data"] = queryList
  673. return queryData, nil
  674. }
  675. func TransFloat(flo float64) float64 {
  676. hf, _ := strconv.ParseFloat(fmt.Sprintf("%.3f", float64(flo)), 64)
  677. return hf
  678. }
  679. func getAccuracyV7(queryList []map[string]interface{}) (map[string]interface{}, error) {
  680. queryData := make(map[string]interface{})
  681. chartData := make(map[string]interface{})
  682. //list := make(map[string]interface{})
  683. data := []interface{}{}
  684. for i := 0; i < len(queryList); i++ {
  685. dry, _ := strconv.ParseFloat(queryList[i]["dry"].(string), 64)
  686. Hrate, _ := strconv.ParseFloat(queryList[i]["Hrate"].(string), 64)
  687. Srate, _ := strconv.ParseFloat(queryList[i]["Srate"].(string), 64)
  688. trans35f, _ := strconv.ParseFloat(queryList[i]["trans35f"].(string), 64)
  689. jcrate, _ := strconv.ParseFloat(queryList[i]["jcrate"].(string), 64)
  690. uprice, _ := strconv.ParseFloat(queryList[i]["uprice"].(string), 64)
  691. kprice, _ := strconv.ParseFloat(queryList[i]["dry"].(string), 64)
  692. list := make(map[string]interface{})
  693. list["tname"] = queryList[i]["tname"]
  694. list["ftid"] = queryList[i]["ftid"]
  695. list["ft"] = dry
  696. list["index"] = "干物质(kg)"
  697. list["tmr"] = TransFloat(dry * Hrate)
  698. list["cyl"] = TransFloat(dry * Srate)
  699. data = append(data, list)
  700. list = make(map[string]interface{})
  701. list["tname"] = queryList[i]["tname"]
  702. list["ftid"] = queryList[i]["ftid"]
  703. list["ft"] = trans35f
  704. list["index"] = "(3.5)FCR(kg/DM)"
  705. list["tmr"] = TransFloat(trans35f * Hrate)
  706. list["cyl"] = TransFloat(trans35f * Srate)
  707. data = append(data, list)
  708. list = make(map[string]interface{})
  709. list["tname"] = queryList[i]["tname"]
  710. list["ftid"] = queryList[i]["ftid"]
  711. list["ft"] = jcrate
  712. list["index"] = "粗精比(%)"
  713. list["tmr"] = TransFloat(jcrate * Hrate)
  714. list["cyl"] = TransFloat(jcrate * Srate)
  715. data = append(data, list)
  716. list = make(map[string]interface{})
  717. list["tname"] = queryList[i]["tname"]
  718. list["ftid"] = queryList[i]["ftid"]
  719. list["ft"] = uprice
  720. list["index"] = "日粮成本(元)"
  721. list["tmr"] = TransFloat(uprice * Hrate)
  722. list["cyl"] = TransFloat(uprice * Srate)
  723. data = append(data, list)
  724. list = make(map[string]interface{})
  725. list["tname"] = queryList[i]["tname"]
  726. list["ftid"] = queryList[i]["ftid"]
  727. list["ft"] = kprice
  728. list["index"] = "公斤奶成本"
  729. list["tmr"] = TransFloat(kprice * Hrate)
  730. list["cyl"] = TransFloat(kprice * Srate)
  731. data = append(data, list)
  732. }
  733. chartData["data"] = data
  734. queryData["list"] = chartData
  735. queryData["code"] = 0
  736. queryData["message"] = "ok"
  737. queryData["data"] = queryList
  738. return queryData, nil
  739. }
  740. func getAccuracyV6(queryList []map[string]interface{}) (map[string]interface{}, error) {
  741. queryData := make(map[string]interface{})
  742. chartData := make(map[string]interface{})
  743. data := []interface{}{}
  744. data1 := []interface{}{}
  745. data2 := []interface{}{}
  746. data3 := []interface{}{}
  747. data4 := []interface{}{}
  748. for i := 0; i < len(queryList); i++ {
  749. data = append(data, queryList[i]["牧场"])
  750. data1 = append(data1, queryList[i]["field1"])
  751. data2 = append(data2, queryList[i]["field2"])
  752. data3 = append(data3, queryList[i]["field3"])
  753. data4 = append(data4, queryList[i]["field4"])
  754. }
  755. chartData["data1"] = data
  756. chartData["data2"] = data1
  757. chartData["data3"] = data2
  758. chartData["data4"] = data3
  759. chartData["data5"] = data4
  760. queryData["list"] = chartData
  761. queryData["code"] = 0
  762. queryData["message"] = "ok"
  763. queryData["data"] = queryList
  764. return queryData, nil
  765. }
  766. func getAccuracyV5(queryList []map[string]interface{}, typea int) (map[string]interface{}, error) {
  767. queryData := make(map[string]interface{})
  768. chartData := make(map[string]interface{})
  769. datamap1 := make(map[string]interface{})
  770. datamap2 := make(map[string]interface{})
  771. temsmap := make(map[interface{}]interface{})
  772. mapc2 := make(map[interface{}]interface{})
  773. data3 := []interface{}{}
  774. datamap2child := make(map[string]interface{})
  775. data2 := []interface{}{}
  776. data1 := []interface{}{}
  777. var dtem interface{}
  778. var temstr interface{}
  779. var typestr interface{}
  780. count2 := 0
  781. a := 0
  782. for i := 0; i < len(queryList); i++ {
  783. if i == 0 {
  784. temstr = queryList[i]["fname"]
  785. typestr = queryList[i]["typestr"]
  786. }
  787. if temstr == queryList[i]["fname"] {
  788. temsmap[queryList[i]["feedname"]] = 1
  789. }
  790. if _, ok := mapc2[queryList[i]["feedname"]]; !ok {
  791. mapc2[queryList[i]["feedname"]] = count2
  792. mapc2[count2] = queryList[i]["feedname"]
  793. count2++
  794. }
  795. }
  796. //for i := 0; i<count2 ; i++ {
  797. // reslist := make([]map[string]interface{},1)
  798. // res := make(map[string]interface{})
  799. // res["fname"] = "分界线"
  800. // res["feedname"] = mapc2[i]
  801. // res["饲料名称"] = mapc2[i]
  802. // reslist[0] = res
  803. // queryList = append(reslist,queryList...)
  804. //}
  805. for i := 0; i < count2; i++ { // 将所有饲料种类新增为第一行 测试
  806. if _, ok := temsmap[mapc2[i]]; !ok {
  807. reslist := make([]map[string]interface{}, 1)
  808. res := make(map[string]interface{})
  809. res["fname"] = temstr
  810. res["feedname"] = mapc2[i]
  811. res["饲料名称"] = mapc2[i]
  812. res["typestr"] = typestr
  813. reslist[0] = res
  814. queryList = append(reslist, queryList...)
  815. }
  816. }
  817. for i := 0; i < len(queryList); i++ {
  818. a = mapc2[queryList[i]["feedname"]].(int) * 4
  819. if i == 0 {
  820. datamap2["label"] = "饲料名称"
  821. switch queryList[i]["typestr"].(type) {
  822. case string:
  823. datamap2child["label"] = queryList[i]["typestr"].(string) + "/饲料参数"
  824. default:
  825. datamap2child["label"] = "/饲料参数"
  826. }
  827. datamap2child["prop"] = "A"
  828. data3 = append(data3, datamap2child)
  829. datamap2["children"] = data3
  830. data2 = append(data2, datamap2)
  831. data3 = []interface{}{}
  832. datamap2child = make(map[string]interface{})
  833. datamap2 = make(map[string]interface{})
  834. dtem = queryList[i]["fname"]
  835. }
  836. if dtem != queryList[i]["fname"] && i != 0 {
  837. data1 = append(data1, datamap1)
  838. dtem = queryList[i]["fname"]
  839. datamap1 = make(map[string]interface{})
  840. }
  841. if queryList[i]["fname"] == temstr {
  842. datamap2["label"] = queryList[i]["feedname"]
  843. if typea == 0 || typea == 1 {
  844. datamap2child["label"] = "理论"
  845. datamap2child["prop"] = "a" + strconv.Itoa(a)
  846. data3 = append(data3, datamap2child)
  847. datamap2child = make(map[string]interface{})
  848. }
  849. if typea == 0 || typea == 2 {
  850. datamap2child["label"] = "实际"
  851. datamap2child["prop"] = "a" + strconv.Itoa(a+1)
  852. data3 = append(data3, datamap2child)
  853. datamap2child = make(map[string]interface{})
  854. }
  855. if typea == 0 || typea == 3 {
  856. datamap2child["label"] = "理论重量"
  857. datamap2child["prop"] = "a" + strconv.Itoa(a+2)
  858. data3 = append(data3, datamap2child)
  859. datamap2child = make(map[string]interface{})
  860. }
  861. if typea == 0 || typea == 4 {
  862. datamap2child["label"] = "实际重量"
  863. datamap2child["prop"] = "a" + strconv.Itoa(a+3)
  864. data3 = append(data3, datamap2child)
  865. datamap2child = make(map[string]interface{})
  866. }
  867. // datamap2child["label"] = "理论"
  868. // datamap2child["prop"] = "a" + strconv.Itoa(a)
  869. // data3 = append(data3, datamap2child)
  870. // datamap2child = make(map[string]interface{})
  871. // datamap2child["label"] = "实际"
  872. // datamap2child["prop"] = "a" + strconv.Itoa(a+1)
  873. // data3 = append(data3, datamap2child)
  874. // datamap2child = make(map[string]interface{})
  875. datamap2["children"] = data3
  876. data2 = append(data2, datamap2)
  877. data3 = []interface{}{}
  878. datamap2 = make(map[string]interface{})
  879. datamap2child = make(map[string]interface{})
  880. }
  881. datamap1["A"] = queryList[i]["fname"]
  882. datamap1["a"+strconv.Itoa(a)] = queryList[i]["lweight"]
  883. datamap1["a"+strconv.Itoa(a+1)] = queryList[i]["actualweightminus"]
  884. datamap1["a"+strconv.Itoa(a+2)] = queryList[i]["lweight1"]
  885. datamap1["a"+strconv.Itoa(a+3)] = queryList[i]["actualweightminus1"]
  886. datamap2["label"] = queryList[i]["饲料名称"]
  887. a = a + 4
  888. }
  889. data1 = append(data1, datamap1)
  890. chartData["data1"] = data1
  891. chartData["data2"] = data2
  892. queryData["list"] = chartData
  893. queryData["code"] = 0
  894. queryData["message"] = "ok"
  895. queryData["data"] = queryList
  896. return queryData, nil
  897. }
  898. func getAccuracyV4(queryList []map[string]interface{}, queryListSum []map[string]interface{}, checked string, feednamesort3 []string, typea int) (map[string]interface{}, error) {
  899. queryData := make(map[string]interface{})
  900. chartData := make(map[string]interface{})
  901. datamap1 := make(map[string]interface{})
  902. datamap2 := make(map[string]interface{})
  903. temsmap := make(map[interface{}]interface{})
  904. mapc2 := make(map[interface{}]interface{})
  905. mapc3 := make(map[interface{}]interface{})
  906. data3 := []interface{}{}
  907. datamap2child := make(map[string]interface{})
  908. data2 := []interface{}{}
  909. data1 := []interface{}{}
  910. a := 0
  911. //ss := 0
  912. var dtem interface{}
  913. count2 := 0
  914. var tem interface{}
  915. var temstr interface{}
  916. var typestr interface{}
  917. //var sort interface{}
  918. for i := 0; i < len(queryList); i++ { // 获取所有饲料种类
  919. if i == 0 {
  920. temstr = queryList[i]["fname"]
  921. typestr = queryList[i]["typestr"]
  922. //sort = queryList[i]["sort"]
  923. }
  924. if temstr == queryList[i]["fname"] {
  925. temsmap[queryList[i]["feedname"]] = 1
  926. }
  927. //if i == len(queryList)-1{
  928. // temstr = "合计"
  929. // typestr = queryList[i]["typestr"]
  930. //}
  931. if _, ok := mapc2[queryList[i]["feedname"]]; !ok {
  932. mapc2[queryList[i]["feedname"]] = count2 // 编号
  933. mapc2[count2] = queryList[i]["feedname"]
  934. count2++
  935. }
  936. }
  937. for i := 0; i < count2; i++ { // 将所有饲料种类新增为第一行 测试
  938. if _, ok := temsmap[mapc2[i]]; !ok {
  939. reslist := make([]map[string]interface{}, 1)
  940. res := make(map[string]interface{})
  941. res["fname"] = temstr
  942. res["feedname"] = mapc2[i]
  943. res["饲料名称"] = mapc2[i]
  944. res["typestr"] = typestr
  945. reslist[0] = res
  946. queryList = append(reslist, queryList...)
  947. }
  948. }
  949. //for i := 0; i<count2 ; i++ {
  950. // reslist := make([]map[string]interface{},1)
  951. // res := make(map[string]interface{})
  952. // res["fname"] = "分界线"
  953. // res["feedname"] = mapc2[i]
  954. // res["饲料名称"] = mapc2[i]
  955. // res["typestr"] =typestr
  956. // reslist[0] = res
  957. // queryList = append(reslist,queryList...)
  958. //}
  959. for i := 0; i < len(queryList); i++ {
  960. if i == 0 {
  961. tem = queryList[i]["fname"]
  962. }
  963. if queryList[i]["fname"] == tem {
  964. mapc3[queryList[i]["feedname"]] = i
  965. }
  966. }
  967. for i := 0; i < len(queryList); i++ {
  968. a = mapc2[queryList[i]["feedname"]].(int) * 4
  969. if i == 0 {
  970. datamap2["label"] = "饲料名称"
  971. switch queryList[i]["typestr"].(type) {
  972. case string:
  973. // datamap2child["label"] = queryList[i]["typestr"].(string) + "/饲料参数"
  974. datamap2child["label"] = queryList[i]["typestr"].(string)
  975. default:
  976. datamap2child["label"] = "/饲料参数"
  977. }
  978. datamap2child["prop"] = "A"
  979. data3 = append(data3, datamap2child)
  980. datamap2["children"] = data3
  981. data2 = append(data2, datamap2)
  982. data3 = []interface{}{}
  983. datamap2child = make(map[string]interface{})
  984. datamap2 = make(map[string]interface{})
  985. dtem = queryList[i]["fname"]
  986. }
  987. if dtem != queryList[i]["fname"] && i != 0 {
  988. data1 = append(data1, datamap1)
  989. dtem = queryList[i]["fname"]
  990. datamap1 = make(map[string]interface{})
  991. }
  992. if queryList[i]["fname"] == temstr {
  993. datamap2["label"] = queryList[i]["feedname"]
  994. if typea == 0 || typea == 1 {
  995. datamap2child["label"] = "理论"
  996. datamap2child["prop"] = "a" + strconv.Itoa(a)
  997. data3 = append(data3, datamap2child)
  998. datamap2child = make(map[string]interface{})
  999. }
  1000. if typea == 0 || typea == 2 {
  1001. datamap2child["label"] = "实际"
  1002. datamap2child["prop"] = "a" + strconv.Itoa(a+1)
  1003. data3 = append(data3, datamap2child)
  1004. datamap2child = make(map[string]interface{})
  1005. }
  1006. if checked == "1" {
  1007. datamap2child["label"] = "误差值"
  1008. datamap2child["prop"] = "a" + strconv.Itoa(a+2)
  1009. data3 = append(data3, datamap2child)
  1010. datamap2child = make(map[string]interface{})
  1011. datamap2child["label"] = "误差率"
  1012. datamap2child["prop"] = "a" + strconv.Itoa(a+3)
  1013. data3 = append(data3, datamap2child)
  1014. datamap2child = make(map[string]interface{})
  1015. }
  1016. // datamap2 = make(map[string]interface{})
  1017. if i != len(queryList)-1 {
  1018. datamap2["children"] = data3
  1019. data2 = append(data2, datamap2)
  1020. datamap2 = make(map[string]interface{})
  1021. data3 = []interface{}{}
  1022. }
  1023. }
  1024. datamap1["A"] = queryList[i]["fname"]
  1025. if queryList[i]["lweight"] != nil {
  1026. var lweight float64
  1027. lweight, _ = strconv.ParseFloat(queryList[i]["lweight"].(string), 64)
  1028. datamap1["a"+strconv.Itoa(a)] = lweight
  1029. } else {
  1030. datamap1["a"+strconv.Itoa(a)] = queryList[i]["lweight"]
  1031. }
  1032. if queryList[i]["actualweightminus"] != nil {
  1033. var actualweightminus float64
  1034. actualweightminus, _ = strconv.ParseFloat(queryList[i]["actualweightminus"].(string), 64)
  1035. datamap1["a"+strconv.Itoa(a+1)] = actualweightminus
  1036. } else {
  1037. datamap1["a"+strconv.Itoa(a+1)] = queryList[i]["actualweightminus"]
  1038. }
  1039. if checked == "1" {
  1040. datamap1["a"+strconv.Itoa(a+2)] = queryList[i]["diff"]
  1041. datamap1["a"+strconv.Itoa(a+3)] = queryList[i]["diffrate"]
  1042. }
  1043. datamap2["label"] = queryList[i]["饲料名称"]
  1044. for z := 0; z < len(queryListSum); z++ {
  1045. if queryListSum[z]["fname"] == queryList[i]["fname"] {
  1046. if queryListSum[z]["lweight"] != nil {
  1047. var lweight float64
  1048. lweight, _ = strconv.ParseFloat(queryListSum[z]["lweight"].(string), 64)
  1049. datamap1["B"] = lweight
  1050. } else {
  1051. datamap1["B"] = queryListSum[z]["lweight"]
  1052. }
  1053. if queryListSum[z]["actualweightminus"] != nil {
  1054. var actualweightminus float64
  1055. actualweightminus, _ = strconv.ParseFloat(queryListSum[z]["actualweightminus"].(string), 64)
  1056. datamap1["C"] = actualweightminus
  1057. } else {
  1058. datamap1["B"] = queryListSum[z]["actualweightminus"]
  1059. }
  1060. }
  1061. }
  1062. if queryList[i]["fname"] == "合计" {
  1063. var lweightSum, actualweightminusSum float64
  1064. for z := 0; z < len(queryListSum); z++ {
  1065. if queryListSum[z]["lweight"] != nil {
  1066. var lweight float64
  1067. lweight, _ = strconv.ParseFloat(queryListSum[z]["lweight"].(string), 64)
  1068. lweightSum += lweight
  1069. }
  1070. if queryListSum[z]["actualweightminus"] != nil {
  1071. var actualweightminus float64
  1072. actualweightminus, _ = strconv.ParseFloat(queryListSum[z]["actualweightminus"].(string), 64)
  1073. actualweightminusSum += actualweightminus
  1074. }
  1075. datamap1["B"] = lweightSum
  1076. datamap1["C"] = actualweightminusSum
  1077. }
  1078. }
  1079. if i == len(queryList)-1 {
  1080. datamap2["label"] = "合计"
  1081. if typea == 0 || typea == 1 {
  1082. datamap2child = make(map[string]interface{})
  1083. datamap2child["label"] = "理论"
  1084. datamap2child["prop"] = "B"
  1085. data3 = append(data3, datamap2child)
  1086. }
  1087. if typea == 0 || typea == 2 {
  1088. datamap2child = make(map[string]interface{})
  1089. datamap2child["label"] = "实际"
  1090. datamap2child["prop"] = "C"
  1091. data3 = append(data3, datamap2child)
  1092. }
  1093. // ###########################
  1094. datamap2["children"] = data3
  1095. data2 = append(data2, datamap2)
  1096. datamap2 = make(map[string]interface{})
  1097. data3 = []interface{}{}
  1098. }
  1099. }
  1100. //var sortSum []string
  1101. //for z := 0; z < len(data2); z++ {
  1102. // ss := data2[z].(map[string]interface{})
  1103. // bb := ss["label"].(string)
  1104. // if bb != "合计" {
  1105. // sortSum = append(sortSum, bb)
  1106. // }
  1107. //}
  1108. //sort.Strings(sortSum)
  1109. //fmt.Println(sortSum)
  1110. theEndSort := []interface{}{}
  1111. for ii := 0; ii < len(data2); ii++ {
  1112. ss := data2[ii].(map[string]interface{})
  1113. bb := ss["label"].(string)
  1114. if "饲料名称" == bb {
  1115. theEndSort = append(theEndSort, data2[ii])
  1116. }
  1117. }
  1118. for _, v := range feednamesort3 {
  1119. for ii := 0; ii < len(data2); ii++ {
  1120. ss := data2[ii].(map[string]interface{})
  1121. bb := ss["label"].(string)
  1122. if v == bb && "饲料名称" != bb {
  1123. theEndSort = append(theEndSort, data2[ii])
  1124. }
  1125. }
  1126. }
  1127. for ii := 0; ii < len(data2); ii++ {
  1128. ss := data2[ii].(map[string]interface{})
  1129. bb := ss["label"].(string)
  1130. if "合计" == bb {
  1131. theEndSort = append(theEndSort, data2[ii])
  1132. }
  1133. }
  1134. data1 = append(data1, datamap1)
  1135. chartData["data1"] = data1
  1136. chartData["data2"] = theEndSort
  1137. queryData["list"] = chartData
  1138. queryData["code"] = 0
  1139. queryData["message"] = "ok"
  1140. queryData["data"] = queryList
  1141. return queryData, nil
  1142. }
  1143. func getAccuracyV3(queryList []map[string]interface{}) (map[string]interface{}, error) {
  1144. queryData := make(map[string]interface{})
  1145. chartData := make(map[string]interface{})
  1146. data := []interface{}{}
  1147. data1 := []interface{}{}
  1148. data2 := []interface{}{}
  1149. data3 := []interface{}{}
  1150. data4 := []interface{}{}
  1151. //
  1152. t1 := make(map[interface{}]string, 0)
  1153. for i := 0; i < len(queryList); i++ {
  1154. data = append(data, queryList[i]["mtime"])
  1155. data1 = append(data1, queryList[i]["lweight"])
  1156. data2 = append(data2, queryList[i]["weight"])
  1157. //data3 = append(data3, queryList[i]["field3"])
  1158. //data4 = append(data4, queryList[i]["field4"])
  1159. if _, ok := t1[queryList[i]["id"]]; !ok {
  1160. datatem := []interface{}{}
  1161. datatem = append(datatem, queryList[i]["startstime"], queryList[i]["lastactualweight"])
  1162. data3 = append(data3, datatem)
  1163. datatem2 := []interface{}{}
  1164. datatem2 = append(datatem2, queryList[i]["intime"], queryList[i]["actualweight"])
  1165. data4 = append(data4, datatem2)
  1166. //datatem = []interface{}{}
  1167. }
  1168. t1[queryList[i]["id"]] = "1"
  1169. }
  1170. //
  1171. chartData["data1"] = data
  1172. chartData["data2"] = data1
  1173. chartData["data3"] = data2
  1174. chartData["data4"] = data3
  1175. chartData["data5"] = data4
  1176. queryData["list"] = chartData
  1177. queryData["code"] = 0
  1178. queryData["message"] = "ok"
  1179. queryData["data"] = queryList
  1180. return queryData, nil
  1181. }
  1182. func getAccuracyV2(queryList []map[string]interface{}) (map[string]interface{}, error) {
  1183. queryData := make(map[string]interface{})
  1184. chartData := make(map[string]interface{})
  1185. data := []interface{}{}
  1186. data1 := []interface{}{}
  1187. data2 := []interface{}{}
  1188. data3 := []interface{}{}
  1189. data4 := []interface{}{}
  1190. for i := 0; i < len(queryList); i++ {
  1191. data = append(data, queryList[i]["日期"])
  1192. data1 = append(data1, queryList[i]["field1"])
  1193. data2 = append(data2, queryList[i]["field2"])
  1194. data3 = append(data3, queryList[i]["field3"])
  1195. data4 = append(data4, queryList[i]["field4"])
  1196. }
  1197. chartData["data1"] = data
  1198. chartData["data2"] = data1
  1199. chartData["data3"] = data2
  1200. chartData["data4"] = data3
  1201. chartData["data5"] = data4
  1202. queryData["list"] = chartData
  1203. queryData["code"] = 0
  1204. queryData["message"] = "ok"
  1205. queryData["data"] = queryList
  1206. return queryData, nil
  1207. }
  1208. func getAccuracy(queryList []map[string]interface{}, layout string) (map[string]interface{}, error) {
  1209. queryData := make(map[string]interface{})
  1210. chartData := make(map[string]interface{})
  1211. t1 := make(map[interface{}]interface{}, 0)
  1212. t2 := make(map[interface{}]interface{}, 0)
  1213. data := make(map[string][]interface{}, 0)
  1214. t := make([]map[string][]interface{}, 0)
  1215. e1 := []interface{}{}
  1216. e2 := []string{}
  1217. for _, value := range queryList {
  1218. if _, ok := t1[value["名称"]]; !ok {
  1219. e1 = append(e1, value["名称"])
  1220. }
  1221. if _, ok := t2[value["日期"]]; !ok {
  1222. switch value["日期"].(type) {
  1223. case string:
  1224. e2 = append(e2, value["日期"].(string))
  1225. }
  1226. }
  1227. t1[value["名称"]] = value["名称"]
  1228. t2[value["日期"]] = value["日期"]
  1229. }
  1230. sort.Strings(e2)
  1231. var b interface{}
  1232. a := 0
  1233. for i := 0; i < len(queryList); i++ {
  1234. if i == 0 {
  1235. b = queryList[i]["名称"]
  1236. }
  1237. if b != queryList[i]["名称"] {
  1238. if a < len(e2)-1 {
  1239. eee := len(e2) - a
  1240. fmt.Println(eee)
  1241. for k := 0; k < len(e2)-a; k++ {
  1242. data["data"] = append(data["data"], "")
  1243. }
  1244. }
  1245. t = append(t, data)
  1246. data = make(map[string][]interface{}, 0)
  1247. b = queryList[i]["名称"]
  1248. a = 0
  1249. }
  1250. switch queryList[i]["日期"].(type) {
  1251. case string:
  1252. dates, _ := time.Parse(layout, queryList[i]["日期"].(string))
  1253. dates1 := ""
  1254. if a < len(e2)-1 {
  1255. dates1 = e2[a]
  1256. } else {
  1257. dates1 = e2[len(e2)-1]
  1258. }
  1259. if a < len(e2)-1 {
  1260. if e2[a] != queryList[i]["日期"].(string) {
  1261. if e2[a] < queryList[i]["日期"].(string) {
  1262. dates1 = queryList[i]["日期"].(string)
  1263. dates, _ = time.Parse(layout, e2[a])
  1264. for ; a < len(e2)-1; a++ {
  1265. if e2[a] >= queryList[i]["日期"].(string) {
  1266. break
  1267. }
  1268. }
  1269. }
  1270. if layout == "2006-01-02" {
  1271. for ; dates.Format(layout) < dates1; dates = dates.Add(24 * time.Hour) {
  1272. data["data"] = append(data["data"], "")
  1273. }
  1274. } else if layout == "2006-01" {
  1275. for ; dates.Format(layout) < dates1; dates = dates.AddDate(0, 1, 0) {
  1276. data["data"] = append(data["data"], "")
  1277. }
  1278. }
  1279. }
  1280. }
  1281. }
  1282. data["data"] = append(data["data"], queryList[i]["准确率"])
  1283. a++
  1284. }
  1285. if a < len(e2)-1 {
  1286. for k := 0; k < len(e2)-a; k++ {
  1287. data["data"] = append(data["data"], "")
  1288. }
  1289. }
  1290. t = append(t, data)
  1291. chartData["data1"] = e1
  1292. chartData["data2"] = e2
  1293. chartData["data3"] = t
  1294. queryData["list"] = chartData
  1295. queryData["code"] = 0
  1296. queryData["message"] = "ok"
  1297. queryData["data"] = queryList
  1298. return queryData, nil
  1299. }
  1300. //统计分析过程分析data值拆分
  1301. func GetprocessAnalysisTB(parammaps *gofasion.Fasion, tx *xorm.Session, quertDataList interface{}, queryList []map[string]interface{}) (query map[string]interface{}, err error) {
  1302. sql1, p1 := restful.GetSqlByNameDBT("getweightjson", tx)
  1303. query1 := make(map[string]interface{}, 0)
  1304. s_params1 := make([]interface{}, 0)
  1305. if sql1 != "" {
  1306. paramslist := strings.Split(p1, ",")
  1307. if len(paramslist) > 0 && p1 != "" {
  1308. for _, value := range paramslist {
  1309. s_params1 = append(s_params1, parammaps.Get(strings.Trim(value, " ")).ValueStr())
  1310. }
  1311. }
  1312. }
  1313. queryList2, err := tx.SQL(sql1, s_params1...).Query().List()
  1314. if len(queryList2) == 0 {
  1315. return query1, nil
  1316. }
  1317. if err != nil {
  1318. fmt.Println("查询配料出错")
  1319. return nil, err
  1320. }
  1321. //fmt.Printf("%T\n",queryList2[0]["weightjson"])
  1322. b, _ := json.Marshal(&quertDataList)
  1323. var m map[string]interface{}
  1324. _ = json.Unmarshal(b, &m)
  1325. msg := queryList2[0]["weightjson"].(string)
  1326. weightjson := make([]map[string]string, 0)
  1327. json.Unmarshal([]byte(msg), &weightjson)
  1328. //fmt.Println(len(weightjson))
  1329. realWandT := make([]interface{}, 0)
  1330. for i := 0; i < len(weightjson); i++ {
  1331. oneSlice := make([]interface{}, 0)
  1332. oneSlice = append(oneSlice, weightjson[i]["mt"])
  1333. oneSlice = append(oneSlice, weightjson[i]["w"])
  1334. realWandT = append(realWandT, oneSlice)
  1335. }
  1336. WTime := make([]interface{}, 0)
  1337. for z := 0; z < len(weightjson); z++ {
  1338. WTime = append(WTime, weightjson[z]["mt"])
  1339. }
  1340. data2 := make([]interface{}, 0)
  1341. for i := 0; i < len(queryList); i++ {
  1342. querySlice := make([]interface{}, 0)
  1343. querySlice = append(querySlice, queryList[i]["timedate"], queryList[i]["lweight"])
  1344. data2 = append(data2, querySlice)
  1345. }
  1346. data5 := make([]interface{}, 0)
  1347. for i := 0; i < len(queryList); i++ {
  1348. querySlice := make([]interface{}, 0)
  1349. querySlice = append(querySlice, queryList[i]["intime"], queryList[i]["actualweight"], queryList[i]["allname"], queryList[i]["fname"])
  1350. data5 = append(data5, querySlice)
  1351. }
  1352. query1["WTime"] = WTime
  1353. query1["data2"] = data2
  1354. query1["data5"] = data5
  1355. query1["realWandT"] = realWandT
  1356. return query1, nil
  1357. }
  1358. type Columns struct {
  1359. Prop string `json:"prop"`
  1360. Label string `json:"label"`
  1361. }
  1362. func getAccuracyV41(queryList []map[string]interface{}, queryListSum []map[string]interface{}, checked string, feednamesort3 []string, typea int, feednameCodes []map[string]interface{}) (map[string]interface{}, error) {
  1363. columns := make([]*Columns, 0)
  1364. columns = append(columns, &Columns{
  1365. Prop: "A",
  1366. Label: "饲料编码",
  1367. })
  1368. columns = append(columns, &Columns{
  1369. Prop: "B",
  1370. Label: "饲料名称",
  1371. })
  1372. label := "类别"
  1373. // column1 := new(Columns)
  1374. columns1 := make([]*Columns, 0)
  1375. dataList := make([]map[string]interface{}, 0)
  1376. for i := 0; i < len(queryList); i++ {
  1377. label = queryList[i]["typestr"].(string)
  1378. exist1 := false
  1379. for _, data := range dataList {
  1380. if data["B"].(string) == queryList[i]["feedname"].(string) {
  1381. exist1 = true
  1382. }
  1383. }
  1384. if !exist1 {
  1385. data1 := make(map[string]interface{}, 0)
  1386. data2 := make(map[string]interface{}, 0)
  1387. for _, v := range feednameCodes {
  1388. if v["feedname"].(string) == queryList[i]["feedname"].(string) {
  1389. data1["A"] = v["feedcode"]
  1390. data2["A"] = v["feedcode"]
  1391. break
  1392. }
  1393. }
  1394. data1["B"] = queryList[i]["feedname"]
  1395. data1["C"] = "理论"
  1396. // data1[queryList[i]["fname"].(string)] = 0
  1397. dataList = append(dataList, data1)
  1398. data2["B"] = queryList[i]["feedname"]
  1399. data2["C"] = "实际"
  1400. // data2[queryList[i]["fname"].(string)] = 0
  1401. dataList = append(dataList, data2)
  1402. }
  1403. column := new(Columns)
  1404. column.Prop = queryList[i]["fname"].(string)
  1405. column.Label = queryList[i]["fname"].(string)
  1406. exist := false
  1407. for _, c := range columns1 {
  1408. if c.Prop == queryList[i]["fname"].(string) {
  1409. exist = true
  1410. }
  1411. }
  1412. if exist {
  1413. continue
  1414. }
  1415. columns1 = append(columns1, column)
  1416. }
  1417. for _, data := range dataList {
  1418. for _, c := range columns1 {
  1419. data[c.Prop] = 0
  1420. }
  1421. }
  1422. data1 := make(map[string]interface{}, 0)
  1423. data2 := make(map[string]interface{}, 0)
  1424. data1["B"] = "合计"
  1425. data1["C"] = "理论"
  1426. data2["B"] = "合计"
  1427. data2["C"] = "实际"
  1428. for _, c := range columns1 {
  1429. if c.Prop != "合计" {
  1430. data1[c.Prop] = 0.0
  1431. data2[c.Prop] = 0.0
  1432. }
  1433. }
  1434. columns = append(columns, &Columns{
  1435. Prop: "C",
  1436. Label: label,
  1437. })
  1438. columns = append(columns, columns1...)
  1439. for _, data := range dataList {
  1440. for i := 0; i < len(queryList); i++ {
  1441. if queryList[i]["feedname"].(string) == data["B"] {
  1442. if data["C"].(string) == "理论" {
  1443. f1, _ := strconv.ParseFloat(fmt.Sprintf("%v", queryList[i]["lweight"]), 64)
  1444. data[queryList[i]["fname"].(string)] = Round(f1, 2)
  1445. } else {
  1446. if queryList[i]["actualweightminus"] == nil {
  1447. data[queryList[i]["fname"].(string)] = 0.0
  1448. } else {
  1449. f1, _ := strconv.ParseFloat(fmt.Sprintf("%v", queryList[i]["actualweightminus"]), 64)
  1450. data[queryList[i]["fname"].(string)] = Round(f1, 2)
  1451. }
  1452. }
  1453. }
  1454. }
  1455. }
  1456. for _, data := range dataList {
  1457. for _, c := range columns1 {
  1458. if c.Prop != "合计" {
  1459. if data["C"].(string) == "理论" {
  1460. f1, _ := strconv.ParseFloat(fmt.Sprintf("%v", data1[c.Prop]), 64)
  1461. f2, _ := strconv.ParseFloat(fmt.Sprintf("%v", data[c.Prop]), 64)
  1462. data1[c.Prop] = Round(f1+f2, 2)
  1463. } else {
  1464. f1, _ := strconv.ParseFloat(fmt.Sprintf("%v", data2[c.Prop]), 64)
  1465. f2, _ := strconv.ParseFloat(fmt.Sprintf("%v", data[c.Prop]), 64)
  1466. data2[c.Prop] = Round(f1+f2, 2)
  1467. }
  1468. }
  1469. }
  1470. }
  1471. dataList = append(dataList, data1)
  1472. dataList = append(dataList, data2)
  1473. respData := make(map[string]interface{})
  1474. respData["data"] = dataList
  1475. respData["columns"] = columns
  1476. return respData, nil
  1477. }
  1478. func Round(number float64, size int) float64 {
  1479. return math.Round(number*100) / 100
  1480. }