report.go 48 KB

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