image_record.go 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160
  1. package levelMonitor
  2. import (
  3. "fmt"
  4. "github.com/gin-gonic/gin"
  5. "go.uber.org/zap"
  6. "log-server/global"
  7. "log-server/model/common/response"
  8. "log-server/model/levelMonitor"
  9. "log-server/model/levelMonitor/request"
  10. "log-server/utils"
  11. "strconv"
  12. )
  13. type ImageRecordApi struct {
  14. }
  15. //创建图片记录
  16. func (a *ImageRecordApi) CreateImageRecord(c *gin.Context) {
  17. var record levelMonitor.ImageRecord
  18. _ = c.ShouldBindJSON(&record)
  19. if err := utils.Verify(record, utils.ImageRecordVerify); err != nil {
  20. response.FailWithMessage(err.Error(), c)
  21. return
  22. }
  23. if err := imageRecordService.CreateImageRecord(record); err != nil {
  24. global.GVA_LOG.Error("创建失败!"+err.Error(), zap.Error(err))
  25. response.FailWithMessage("创建失败"+err.Error(), c)
  26. } else {
  27. response.OkWithMessage("创建成功", c)
  28. }
  29. }
  30. func (a *ImageRecordApi) UpLevel(c *gin.Context) {
  31. var record request.CreateLevelRequest
  32. _ = c.ShouldBindJSON(&record)
  33. if err := utils.Verify(record, utils.ImageRecordVerify); err != nil {
  34. response.FailWithMessage(err.Error(), c)
  35. return
  36. }
  37. if err := imageRecordService.CreateLevel(record); err != nil {
  38. response.FailWithMessage("创建失败"+err.Error(), c)
  39. } else {
  40. response.OkWithMessage("创建成功", c)
  41. }
  42. }
  43. func (a *ImageRecordApi) UploadOrNot(c *gin.Context) {
  44. var record levelMonitor.ImageRecord
  45. _ = c.ShouldBindJSON(&record)
  46. if record.TaskId == 0 {
  47. response.FailWithMessage("任务id不能为空", c)
  48. }
  49. global.GVA_LOG.Info("gameId = " + strconv.Itoa(record.TaskId) + "account = " + record.Account)
  50. if err := imageRecordService.UploadOrNot(record); err != nil {
  51. response.FailWithMessage("不用上传", c)
  52. } else {
  53. response.OkWithMessage("可以上传", c)
  54. }
  55. }
  56. //删除三天前的图片记录
  57. //func (a *ImageRecordApi) DeleteExpireImageRecord (c *gin.Context) {}
  58. //查询图片记录列表
  59. func (a *ImageRecordApi) GetImageRecordList(c *gin.Context) {
  60. var paramsInfo request.SearchImageRecordParams
  61. _ = c.ShouldBindJSON(&paramsInfo)
  62. if err := utils.Verify(paramsInfo.PageInfo, utils.PageInfoVerify); err != nil {
  63. response.FailWithMessage(err.Error(), c)
  64. return
  65. }
  66. list, total, err := imageRecordService.GetImageRecordList(paramsInfo.ImageRecordRequest, paramsInfo.PageInfo, paramsInfo.OrderKey, paramsInfo.Desc)
  67. if err != nil {
  68. global.GVA_LOG.Error("获取失败!", zap.Error(err))
  69. response.FailWithMessage("获取失败", c)
  70. } else {
  71. response.OkWithDetailed(response.PageResult{
  72. List: list,
  73. Total: total,
  74. Page: paramsInfo.Page,
  75. PageSize: paramsInfo.PageSize,
  76. }, "获取成功", c)
  77. }
  78. }
  79. //获取7日数据
  80. func (a *ImageRecordApi) GetWeekImageRecordStatistics(c *gin.Context) {
  81. var weekDataRequest request.WeekImageRecordStatisticsRequest
  82. _ = c.ShouldBindJSON(&weekDataRequest)
  83. if weekDataRequest.TaskId == 0 {
  84. response.FailWithMessage("请传入task_id", c)
  85. return
  86. }
  87. if weekDataRequest.CreateDate == "" {
  88. response.FailWithMessage("请传入create_date", c)
  89. return
  90. }
  91. list, err := imageRecordService.GetWeekImageRecordStatistics(weekDataRequest.TaskId, weekDataRequest.CreateDate)
  92. if err != nil {
  93. global.GVA_LOG.Error("获取失败!", zap.Error(err))
  94. response.FailWithMessage("获取失败", c)
  95. } else {
  96. response.OkWithDetailed(list, "获取成功", c)
  97. }
  98. }
  99. //获取等级统计数据列表
  100. func (a *ImageRecordApi) GetImageRecordStatisticsList(c *gin.Context) {
  101. var paramsInfo request.SearchImageRecordStatisticsParams
  102. _ = c.ShouldBindJSON(&paramsInfo)
  103. if err := utils.Verify(paramsInfo.PageInfo, utils.PageInfoVerify); err != nil {
  104. response.FailWithMessage(err.Error(), c)
  105. return
  106. }
  107. list, total, err := imageRecordService.GetImageRecordStatisticsList(paramsInfo.ImageRecordStatisticsRequest, paramsInfo.PageInfo, paramsInfo.OrderKey, paramsInfo.Desc)
  108. if err != nil {
  109. global.GVA_LOG.Error("获取失败!", zap.Error(err))
  110. response.FailWithMessage("获取失败", c)
  111. } else {
  112. response.OkWithDetailed(response.PageResult{
  113. List: list,
  114. Total: total,
  115. Page: paramsInfo.Page,
  116. PageSize: paramsInfo.PageSize,
  117. }, "获取成功", c)
  118. }
  119. }
  120. //导出等级统计数据列表
  121. func (a *ImageRecordApi) ImageRecordStatisticsExport(c *gin.Context) {
  122. var excelInfo request.ExcelImageRecordStatistics
  123. _ = c.ShouldBindJSON(&excelInfo)
  124. fmt.Println(excelInfo)
  125. paramsInfo := excelInfo.InfoList
  126. paramsInfo.PageSize = 300
  127. paramsInfo.Page = 1
  128. if err := utils.Verify(paramsInfo.PageInfo, utils.PageInfoVerify); err != nil {
  129. response.FailWithMessage(err.Error(), c)
  130. return
  131. }
  132. list, _, err := imageRecordService.GetImageRecordStatisticsList(paramsInfo.ImageRecordStatisticsRequest, paramsInfo.PageInfo, paramsInfo.OrderKey, paramsInfo.Desc)
  133. if err != nil {
  134. global.GVA_LOG.Error("获取失败!", zap.Error(err))
  135. response.FailWithMessage("获取失败 "+err.Error(), c)
  136. }
  137. //var nowTime string = time.Now().Format("2006-01-02_15:04")
  138. //excelInfo.FileName = nowTime + "-ip.xlsx"
  139. //fmt.Println(excelInfo.FileName)
  140. filePath := global.GVA_CONFIG.Excel.Dir + excelInfo.FileName
  141. err = imageRecordService.ImageRecordStatisticsListExcel(list, filePath)
  142. if err != nil {
  143. global.GVA_LOG.Error("转换Excel失败!", zap.Error(err))
  144. response.FailWithMessage("转换Excel失败", c)
  145. return
  146. }
  147. c.Writer.Header().Add("success", "true")
  148. c.File(filePath)
  149. }