dashboard_service.go 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290
  1. package backend
  2. import (
  3. "context"
  4. "encoding/json"
  5. "fmt"
  6. "kpt-tmr-group/model"
  7. "kpt-tmr-group/pkg/logger/zaplog"
  8. "kpt-tmr-group/pkg/tool"
  9. "kpt-tmr-group/pkg/xerr"
  10. operationPb "kpt-tmr-group/proto/go/backend/operation"
  11. "net/http"
  12. "sort"
  13. "sync"
  14. "go.uber.org/multierr"
  15. "go.uber.org/zap"
  16. )
  17. func (s *StoreEntry) SearchPrefAnalysisData(ctx context.Context, req *operationPb.SearchAnalysisAccuracyRequest) (map[int64]*model.PastureAnalysisAccuracyData, error) {
  18. groupPastureList, err := s.FindGroupPastureListByIds(ctx, req.PastureIds)
  19. if err != nil {
  20. return nil, xerr.WithStack(err)
  21. }
  22. res := make(map[int64]*model.PastureAnalysisAccuracyData, 0)
  23. wg := sync.WaitGroup{}
  24. wg.Add(len(groupPastureList))
  25. var muError error
  26. for _, pasture := range groupPastureList {
  27. go func(p *model.GroupPasture) {
  28. response := &model.PastureAnalysisAccuracyResponse{}
  29. body := &model.DashboardAccuracyRequest{
  30. PastureId: int32(p.Id),
  31. FeedFormulaId: req.FeedFormulaId,
  32. CattleParentCategoryId: int32(req.CattleParentCategoryId),
  33. StartDate: req.StartDate,
  34. EndDate: req.EndDate,
  35. }
  36. if err = s.PastureHttpClient(ctx, DashboardAccuracyUrl, p.Id, body, response); err != nil {
  37. muError = multierr.Append(muError, err)
  38. zaplog.Error("DistributeFeedFormula",
  39. zap.String("url", DashboardAccuracyUrl),
  40. zap.Any("pasture", p), zap.Any("body", body),
  41. zap.Any("err", err), zap.Any("response", response))
  42. b, _ := json.Marshal(body)
  43. resB, _ := json.Marshal(response)
  44. pastureDataLog := model.NewPastureDataLog(p.Id, PastureDataLogType["FeedFormula_Distribute"], FeedFormulaDistributeUrl, string(b), string(resB))
  45. s.DB.Create(pastureDataLog)
  46. }
  47. if response.Code != http.StatusOK {
  48. muError = multierr.Append(muError, xerr.Custom(response.Msg))
  49. }
  50. res[p.Id] = response.Data
  51. wg.Done()
  52. }(pasture)
  53. }
  54. wg.Wait()
  55. return res, nil
  56. }
  57. func (s *StoreEntry) SearchAnalysisAccuracy(ctx context.Context, req *operationPb.SearchAnalysisAccuracyRequest) (*model.SearchAnalysisAccuracyResponse, error) {
  58. res := &model.SearchAnalysisAccuracyResponse{
  59. Code: http.StatusOK,
  60. Msg: "ok",
  61. Data: &model.AnalysisAccuracyData{
  62. Chart: &model.Chart{},
  63. Table: &model.Table{
  64. TitleList: make([]*model.TableList, 0),
  65. DataList: &model.DataList{},
  66. },
  67. },
  68. }
  69. res.Data.Table.TitleList = append(res.Data.Table.TitleList, &model.TableList{
  70. Name: "title",
  71. Value: "牧场",
  72. })
  73. pastureAnalysisAccuracy, err := s.SearchPrefAnalysisData(ctx, req)
  74. if err != nil {
  75. return nil, xerr.WithStack(err)
  76. }
  77. mixedFodderAccurateRatio, mixedFodderCorrectRatio, sprinkleFodderAccurateRatio, sprinkleFodderCorrectRatio :=
  78. &model.CommonValueRatio{}, &model.CommonValueRatio{}, &model.CommonValueRatio{}, &model.CommonValueRatio{}
  79. maTitleValueList, mcTitleValueList, saTitleValueList, scTitleValueList := make([]float64, 0), make([]float64, 0), make([]float64, 0), make([]float64, 0)
  80. mTopOneName := ""
  81. for pastureId, data := range pastureAnalysisAccuracy {
  82. b, _ := json.Marshal(data)
  83. zaplog.Info("pastureAnalysisAccuracy", zap.String("body", string(b)))
  84. groupPasture, err := s.GetGroupPastureListById(ctx, pastureId)
  85. if err != nil {
  86. zaplog.Error("SearchAnalysisAccuracy GetGroupPastureListById",
  87. zap.Any("pastureId", pastureId), zap.Any("error", err))
  88. continue
  89. }
  90. mixedFodderAccurateRatioDataList := make([]string, 0)
  91. for _, v := range data.MixedFodderAccurateRatio {
  92. mixedFodderAccurateRatioDataList = append(mixedFodderAccurateRatioDataList, fmt.Sprintf("%.2f", v.Ratio))
  93. mixedFodderAccurateRatio.DateDay = append(mixedFodderAccurateRatio.DateDay, v.DayTime)
  94. maTitleValueList = append(maTitleValueList, v.Ratio)
  95. }
  96. mixedFodderAccurateRatio.DataList = append(mixedFodderAccurateRatio.DataList, mixedFodderAccurateRatioDataList)
  97. mixedFodderAccurateRatio.PastureIds = append(mixedFodderAccurateRatio.PastureIds, int32(pastureId))
  98. mixedFodderAccurateRatio.PastureName = append(mixedFodderAccurateRatio.PastureName, groupPasture.Name)
  99. mixedFodderCorrectRatioDataList := make([]string, 0)
  100. for _, v := range data.MixedFodderCorrectRatio {
  101. mixedFodderCorrectRatioDataList = append(mixedFodderCorrectRatioDataList, fmt.Sprintf("%.2f", v.Ratio))
  102. mixedFodderCorrectRatio.DateDay = append(mixedFodderCorrectRatio.DateDay, v.DayTime)
  103. mcTitleValueList = append(mcTitleValueList, v.Ratio)
  104. }
  105. mixedFodderCorrectRatio.DataList = append(mixedFodderCorrectRatio.DataList, mixedFodderCorrectRatioDataList)
  106. mixedFodderCorrectRatio.PastureIds = append(mixedFodderCorrectRatio.PastureIds, int32(pastureId))
  107. mixedFodderCorrectRatio.PastureName = append(mixedFodderCorrectRatio.PastureName, groupPasture.Name)
  108. sprinkleFodderRatioDataList := make([]string, 0)
  109. for _, v := range data.SprinkleFodderAccurateRatio {
  110. sprinkleFodderRatioDataList = append(sprinkleFodderRatioDataList, fmt.Sprintf("%.2f", v.Ratio))
  111. sprinkleFodderAccurateRatio.DateDay = append(sprinkleFodderAccurateRatio.DateDay, v.DayTime)
  112. saTitleValueList = append(saTitleValueList, v.Ratio)
  113. }
  114. sprinkleFodderAccurateRatio.DataList = append(sprinkleFodderAccurateRatio.DataList, sprinkleFodderRatioDataList)
  115. sprinkleFodderAccurateRatio.PastureIds = append(sprinkleFodderAccurateRatio.PastureIds, int32(pastureId))
  116. sprinkleFodderAccurateRatio.PastureName = append(sprinkleFodderAccurateRatio.PastureName, groupPasture.Name)
  117. sprinkleFodderCorrectRatioDataList := make([]string, 0)
  118. for _, v := range data.SprinkleFodderCorrectRatio {
  119. sprinkleFodderCorrectRatioDataList = append(sprinkleFodderCorrectRatioDataList, fmt.Sprintf("%.2f", v.Ratio))
  120. sprinkleFodderCorrectRatio.DateDay = append(sprinkleFodderCorrectRatio.DateDay, v.DayTime)
  121. scTitleValueList = append(scTitleValueList, v.Ratio)
  122. }
  123. sprinkleFodderCorrectRatio.DataList = append(sprinkleFodderCorrectRatio.DataList, sprinkleFodderCorrectRatioDataList)
  124. sprinkleFodderCorrectRatio.PastureIds = append(sprinkleFodderCorrectRatio.PastureIds, int32(pastureId))
  125. sprinkleFodderCorrectRatio.PastureName = append(sprinkleFodderCorrectRatio.PastureName, groupPasture.Name)
  126. }
  127. sort.Float64s(maTitleValueList)
  128. mixedFodderAccurateRatio.MaxValue = fmt.Sprintf("%.2f", maTitleValueList[len(maTitleValueList)-1])
  129. mixedFodderAccurateRatio.MinValue = fmt.Sprintf("%.2f", maTitleValueList[0])
  130. mixedFodderAccurateRatio.MiddleValue = fmt.Sprintf("%.2f", tool.Median(maTitleValueList))
  131. mixedFodderAccurateRatio.TopOneName = mTopOneName
  132. sort.Float64s(mcTitleValueList)
  133. mixedFodderCorrectRatio.MaxValue = fmt.Sprintf("%.2f", mcTitleValueList[len(mcTitleValueList)-1])
  134. mixedFodderCorrectRatio.MinValue = fmt.Sprintf("%.2f", mcTitleValueList[0])
  135. mixedFodderCorrectRatio.MiddleValue = fmt.Sprintf("%.2f", tool.Median(mcTitleValueList))
  136. mixedFodderCorrectRatio.TopOneName = mTopOneName
  137. sort.Float64s(saTitleValueList)
  138. sprinkleFodderAccurateRatio.MaxValue = fmt.Sprintf("%.2f", saTitleValueList[len(saTitleValueList)-1])
  139. sprinkleFodderAccurateRatio.MinValue = fmt.Sprintf("%.2f", saTitleValueList[0])
  140. sprinkleFodderAccurateRatio.MiddleValue = fmt.Sprintf("%.2f", tool.Median(saTitleValueList))
  141. sprinkleFodderAccurateRatio.TopOneName = mTopOneName
  142. sort.Float64s(scTitleValueList)
  143. sprinkleFodderCorrectRatio.MaxValue = fmt.Sprintf("%.2f", scTitleValueList[len(scTitleValueList)-1])
  144. sprinkleFodderCorrectRatio.MinValue = fmt.Sprintf("%.2f", scTitleValueList[0])
  145. sprinkleFodderCorrectRatio.MiddleValue = fmt.Sprintf("%.2f", tool.Median(scTitleValueList))
  146. sprinkleFodderCorrectRatio.TopOneName = mTopOneName
  147. chart := &model.Chart{
  148. MixedFodderAccurateRatio: mixedFodderAccurateRatio,
  149. MixedFodderCorrectRatio: mixedFodderCorrectRatio,
  150. SprinkleFodderAccurateRatio: sprinkleFodderAccurateRatio,
  151. SprinkleFodderCorrectRatio: sprinkleFodderCorrectRatio,
  152. }
  153. res.Data.Chart = chart
  154. res.Data.Table = s.TitleList(ctx, pastureAnalysisAccuracy)
  155. return res, nil
  156. }
  157. // TopPasture 牧场排名
  158. func (s *StoreEntry) TopPasture(ctx context.Context, req *operationPb.SearchAnalysisAccuracyRequest) (*model.GetPastureTopResponse, error) {
  159. res := &model.GetPastureTopResponse{
  160. Code: http.StatusOK,
  161. Msg: "ok",
  162. Data: &model.PastureTop{
  163. MixedFodderAccurateRatio: make([]*model.PastureTopData, 0),
  164. MixedFodderCorrectRatio: make([]*model.PastureTopData, 0),
  165. SprinkleFodderAccurateRatio: make([]*model.PastureTopData, 0),
  166. SprinkleFodderCorrectRatio: make([]*model.PastureTopData, 0),
  167. },
  168. }
  169. analysisAccuracy, err := s.SearchPrefAnalysisData(ctx, req)
  170. if err != nil {
  171. return nil, xerr.WithStack(err)
  172. }
  173. fmt.Println("========analysisAccuracy=========", analysisAccuracy)
  174. /*time1, _ := time.ParseInLocation(model.LayoutDateFormat, req.StartDate, time.Local)
  175. time2, _ := time.ParseInLocation(model.LayoutDateFormat, req.EndDate, time.Local)
  176. timeLen := time2.Sub(time1).Hours() / 24
  177. mapPastureList := make(map[string][]*model.OptionsAnalysisAccuracy, 0)
  178. for _, v := range analysisAccuracy {
  179. mapPastureList[v.PastureName] = append(mapPastureList[v.PastureName], v)
  180. }*/
  181. mixedFodderAccurateRatio := make([]*model.PastureTopData, 0)
  182. /*for pastureName, data := range mapPastureList {
  183. var allValueRatio float64
  184. for _, v := range data {
  185. allValueRatio += float64(v.AllIweight/v.AllLweight) / 100.0
  186. }
  187. average := allValueRatio / timeLen
  188. mixedFodderAccurateRatio = append(mixedFodderAccurateRatio, &model.PastureTopData{
  189. PastureName: pastureName,
  190. Ratio: average,
  191. })
  192. }*/
  193. sort.Slice(mixedFodderAccurateRatio, func(i, j int) bool {
  194. return mixedFodderAccurateRatio[i].Ratio > mixedFodderAccurateRatio[j].Ratio
  195. })
  196. res.Data.MixedFodderAccurateRatio = mixedFodderAccurateRatio
  197. return res, nil
  198. }
  199. func (s *StoreEntry) TitleList(ctx context.Context, pastureAnalysisList map[int64]*model.PastureAnalysisAccuracyData) *model.Table {
  200. res := &model.Table{
  201. TitleList: make([]*model.TableList, 0),
  202. DataList: &model.DataList{
  203. MixedFodderAccurateRatio: make([]map[string]string, 0),
  204. MixedFodderCorrectRatio: make([]map[string]string, 0),
  205. SprinkleFodderAccurateRatio: make([]map[string]string, 0),
  206. SprinkleFodderCorrectRatio: make([]map[string]string, 0),
  207. },
  208. }
  209. for pastureId, data := range pastureAnalysisList {
  210. groupPasture, err := s.GetGroupPastureListById(ctx, pastureId)
  211. if err != nil {
  212. zaplog.Info("TitleList", zap.Any("GetGroupPastureListById", pastureId), zap.Any("err", err))
  213. continue
  214. }
  215. if len(res.TitleList) <= len(data.MixedFodderAccurateRatio) {
  216. res.TitleList = append(res.TitleList, &model.TableList{
  217. Name: "title",
  218. Value: "牧场",
  219. })
  220. }
  221. maMap := map[string]string{
  222. "title": groupPasture.Name,
  223. }
  224. for i, v := range data.MixedFodderCorrectRatio {
  225. maMap[fmt.Sprintf("data%d", i+1)] = fmt.Sprintf("%.2f", v.Ratio)
  226. if len(res.TitleList) <= len(data.MixedFodderAccurateRatio) {
  227. res.TitleList = append(res.TitleList, &model.TableList{
  228. Name: fmt.Sprintf("data%d", i+1),
  229. Value: v.DayTime,
  230. })
  231. }
  232. }
  233. res.DataList.MixedFodderAccurateRatio = append(res.DataList.MixedFodderAccurateRatio, maMap)
  234. mcMap := map[string]string{
  235. "title": groupPasture.Name,
  236. }
  237. for i, v := range data.MixedFodderCorrectRatio {
  238. mcMap[fmt.Sprintf("data%d", i+1)] = fmt.Sprintf("%.2f", v.Ratio)
  239. }
  240. res.DataList.MixedFodderCorrectRatio = append(res.DataList.MixedFodderCorrectRatio, mcMap)
  241. saMap := map[string]string{
  242. "title": groupPasture.Name,
  243. }
  244. for i, v := range data.SprinkleFodderAccurateRatio {
  245. saMap[fmt.Sprintf("data%d", i+1)] = fmt.Sprintf("%.2f", v.Ratio)
  246. }
  247. res.DataList.SprinkleFodderAccurateRatio = append(res.DataList.SprinkleFodderAccurateRatio, saMap)
  248. scMap := map[string]string{
  249. "title": groupPasture.Name,
  250. }
  251. for i, v := range data.SprinkleFodderCorrectRatio {
  252. scMap[fmt.Sprintf("data%d", i+1)] = fmt.Sprintf("%.2f", v.Ratio)
  253. }
  254. res.DataList.SprinkleFodderCorrectRatio = append(res.DataList.SprinkleFodderCorrectRatio, scMap)
  255. }
  256. return res
  257. }