annual_report.go 7.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213
  1. package services
  2. import (
  3. "fmt"
  4. "hongze/hongze_api/models"
  5. "hongze/hongze_api/utils"
  6. "time"
  7. )
  8. func CreateAnnualReport() {
  9. br := new(models.BaseResponse).Init()
  10. defer func() {
  11. }()
  12. startDate := "2020-01-01 00:00:00"
  13. endDate := time.Now().Format(utils.FormatDate)
  14. uid := 123
  15. user,err:=GetWxUserItemByUserId(uid,utils.WxPlatform)
  16. if err!=nil {
  17. }
  18. var realName, togetherDay, createDate string
  19. resp := new(models.BillDetailResp)
  20. if user.RealName == "" {
  21. realName = user.NickName
  22. } else {
  23. realName = user.RealName
  24. }
  25. if !user.CreatedTime.IsZero() {
  26. sub := time.Now().Sub(user.CreatedTime)
  27. if sub < 0 {
  28. sub = 0
  29. }
  30. expireDay := fmt.Sprintf("%v", int(sub.Hours()/24))
  31. togetherDay = expireDay
  32. createDate = user.CreatedTime.Format(utils.FormatDate)
  33. } else {
  34. sub := time.Now().Sub(user.LastUpdatedTime)
  35. if sub < 0 {
  36. sub = 0
  37. }
  38. expireDay := fmt.Sprintf("%v", int(sub.Hours()/24))
  39. togetherDay = expireDay
  40. createDate = user.LastUpdatedTime.Format(utils.FormatDate)
  41. }
  42. //uid = 41555
  43. firstReadReportType, firstReadReportTitle, err := models.GetFirstReportInfo(uid, startDate)
  44. if err != nil && err.Error() != utils.ErrNoRow() {
  45. br.Msg = "获取数据失败"
  46. br.ErrMsg = "获取数据失败GetFirstReportInfo,Err:" + err.Error()
  47. return
  48. }
  49. listenCount, listenVideoPlaySeconds, err := models.GetListenInfo(uid, startDate)
  50. if err != nil && err.Error() != utils.ErrNoRow() {
  51. br.Msg = "获取数据失败"
  52. br.ErrMsg = "获取数据失败GetListenInfo,Err:" + err.Error()
  53. return
  54. }
  55. maxReadReportCount, maxReadReportDate, err := models.GetMaxReadReportInfo(uid, startDate)
  56. if err != nil && err.Error() != utils.ErrNoRow() {
  57. br.Msg = "获取数据失败"
  58. br.ErrMsg = "获取数据失败GetMaxReadReportInfo,Err:" + err.Error()
  59. return
  60. }
  61. latestTime, latestCreateTime, err := models.GetLatestReadReportInfo(uid, startDate)
  62. if err != nil && err.Error() != utils.ErrNoRow() {
  63. br.Msg = "获取数据失败"
  64. br.ErrMsg = "获取数据失败GetLatestReadReportInfo,Err:" + err.Error()
  65. return
  66. }
  67. var lastestCreateDate string
  68. var VideoPlaySeconds float64
  69. if !latestCreateTime.IsZero() {
  70. lastestCreateDate = latestCreateTime.Format(utils.FormatDate)
  71. }
  72. if lastestCreateDate != "" {
  73. rddpReadCount, rddpVideoPlaySeconds, err := models.GetRddpReadReportCountByDate(uid, lastestCreateDate)
  74. if err != nil && err.Error() != utils.ErrNoRow() {
  75. br.Msg = "获取数据失败"
  76. br.ErrMsg = "获取数据失败GetRddpReadReportCountByDate,Err:" + err.Error()
  77. return
  78. }
  79. weekReadCount, err := models.GetWeekReadReportCountByDate(uid, lastestCreateDate)
  80. if err != nil && err.Error() != utils.ErrNoRow() {
  81. br.Msg = "获取数据失败"
  82. br.ErrMsg = "获取数据失败GetWeekReadReportCountByDate,Err:" + err.Error()
  83. return
  84. }
  85. var weekVideoPlaySeconds float64
  86. if rddpReadCount <= 0 {
  87. weekVideoPlaySeconds = float64(utils.GetRandInt(3, 300)) / float64(10.00)
  88. } else {
  89. weekVideoPlaySeconds = float64(weekReadCount) * (rddpVideoPlaySeconds / float64(rddpReadCount))
  90. }
  91. VideoPlaySeconds = utils.FixFloat(rddpVideoPlaySeconds+weekVideoPlaySeconds, 2)
  92. }
  93. maxOpenReportClassify, maxOpenReportCount, err := models.GetOpenReadReportInfo(uid, startDate)
  94. if err != nil && err.Error() != utils.ErrNoRow() {
  95. br.Msg = "获取数据失败"
  96. br.ErrMsg = "获取数据失败GetOpenReadReportInfo,Err:" + err.Error()
  97. return
  98. }
  99. rddpTotalPlaySeconds, rddpTotal, err := models.GetRddpTotalReadDuration(uid, startDate)
  100. if err != nil && err.Error() != utils.ErrNoRow() {
  101. br.Msg = "获取数据失败"
  102. br.ErrMsg = "获取数据失败GetRddpTotalReadDuration,Err:" + err.Error()
  103. return
  104. }
  105. weekTotal, err := models.GetWeekTotalRead(uid, startDate)
  106. if err != nil && err.Error() != utils.ErrNoRow() {
  107. br.Msg = "获取数据失败"
  108. br.ErrMsg = "获取数据失败GetRddpTotalReadDuration,Err:" + err.Error()
  109. return
  110. }
  111. totalReadDuration := 0.00
  112. if rddpTotal <= 0 {
  113. totalReadDuration = rddpTotalPlaySeconds + float64(weekTotal)*(float64(utils.GetRandInt(3, 300))/float64(10.00))
  114. } else {
  115. totalReadDuration = rddpTotalPlaySeconds + (rddpTotalPlaySeconds/float64(rddpTotal))*float64(weekTotal)
  116. }
  117. dayType := `day`
  118. dayTotal, err := models.GetWeekTotalReadByType(uid, dayType, startDate)
  119. if err != nil && err.Error() != utils.ErrNoRow() {
  120. br.Msg = "获取数据失败"
  121. br.ErrMsg = "获取数据失败GetWeekTotalReadByType,Err:" + err.Error() + ";report_type:" + dayType
  122. return
  123. }
  124. weekType := `week`
  125. weekReportReadTotal, err := models.GetWeekTotalReadByType(uid, weekType, startDate)
  126. if err != nil && err.Error() != utils.ErrNoRow() {
  127. br.Msg = "获取数据失败"
  128. br.ErrMsg = "获取数据失败GetWeekTotalReadByType,Err:" + err.Error() + ";report_type:" + weekType
  129. return
  130. }
  131. twoWeekType := `two_week`
  132. twoWeekTotal, err := models.GetWeekTotalReadByType(uid, twoWeekType, startDate)
  133. if err != nil && err.Error() != utils.ErrNoRow() {
  134. br.Msg = "获取数据失败"
  135. br.ErrMsg = "获取数据失败GetWeekTotalReadByType,Err:" + err.Error() + ";report_type:" + twoWeekType
  136. return
  137. }
  138. monthType := `month`
  139. monthTotal, err := models.GetWeekTotalReadByType(uid, dayType, startDate)
  140. if err != nil && err.Error() != utils.ErrNoRow() {
  141. br.Msg = "获取数据失败"
  142. br.ErrMsg = "获取数据失败GetWeekTotalReadByType,Err:" + err.Error() + ";report_type:" + monthType
  143. return
  144. }
  145. rddpReadTotal, err := models.GetRddpTotalReadByType(uid, startDate)
  146. if err != nil && err.Error() != utils.ErrNoRow() {
  147. br.Msg = "获取数据失败"
  148. br.ErrMsg = "获取数据失败GetRddpTotalReadByType,Err:" + err.Error() + ";report_type:" + monthType
  149. return
  150. }
  151. var learnDay int
  152. rddpLearnDay, err := models.GetRddpLearnDay(uid, startDate, endDate)
  153. if err != nil && err.Error() != utils.ErrNoRow() {
  154. br.Msg = "获取数据失败"
  155. br.ErrMsg = "获取数据失败GetRddpLearnDay,Err:" + err.Error() + ";report_type:" + monthType
  156. return
  157. }
  158. weekLearnDay, err := models.GetWeekpLearnDay(uid, startDate)
  159. if err != nil && err.Error() != utils.ErrNoRow() {
  160. br.Msg = "获取数据失败"
  161. br.ErrMsg = "获取数据失败GetWeekpLearnDay,Err:" + err.Error() + ";report_type:" + monthType
  162. return
  163. }
  164. if rddpLearnDay >= weekLearnDay {
  165. learnDay = rddpLearnDay
  166. } else {
  167. learnDay = weekLearnDay
  168. }
  169. if learnDay <= 0 {
  170. learnDay = 1
  171. }
  172. resp.RealName = realName
  173. resp.TogetherDay = togetherDay
  174. resp.CreateDate = createDate
  175. resp.FirstReadReportType = firstReadReportType
  176. resp.FirstReadReportTitle = firstReadReportTitle
  177. resp.ListenReportCount = listenCount
  178. resp.ListenReportDuration = utils.FixFloat((listenVideoPlaySeconds / 60.00), 2)
  179. resp.MaxReadReportCount = maxReadReportCount
  180. resp.MaxReadReportDate = maxReadReportDate.Format(utils.FormatDate)
  181. resp.LatestReadReportDate = lastestCreateDate
  182. resp.LatestReadReportTime = latestTime
  183. resp.LatestReadReportDateDuration = VideoPlaySeconds
  184. resp.MaxOpenReportClassify = maxOpenReportClassify
  185. resp.MaxOpenReportCount = maxOpenReportCount
  186. resp.TotalReadDuration = totalReadDuration
  187. resp.TotalReportDayCount = dayTotal
  188. resp.TotalReportWeekCount = weekReportReadTotal
  189. resp.TotalReportTwoWeekCount = twoWeekTotal
  190. resp.TotalReportMonthCount = monthTotal
  191. resp.TotalReportRddpCount = rddpReadTotal
  192. resp.LearnDay = learnDay
  193. resp.TotalReport = dayTotal + weekReportReadTotal + twoWeekTotal + monthTotal + rddpReadTotal
  194. br.Ret = 200
  195. br.Success = true
  196. br.Msg = "获取成功"
  197. br.Data = resp
  198. }