report_view.go 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267
  1. package services
  2. import (
  3. "fmt"
  4. "github.com/tealeg/xlsx"
  5. "hongze/hongze_task/models"
  6. "hongze/hongze_task/utils"
  7. "os"
  8. "time"
  9. )
  10. //报告历史访问次数
  11. func ReportViewTimes() (err error) {
  12. defer func() {
  13. if err != nil {
  14. fmt.Println("crete ReportViewTimes err:", err.Error())
  15. utils.FileLog.Info("crete ReportViewTimes err: %s", err.Error())
  16. }
  17. }()
  18. //创建excel
  19. file := xlsx.NewFile()
  20. sheet, err := file.AddSheet("用户访问次数")
  21. if err != nil {
  22. return err
  23. }
  24. //标头
  25. rowTitle := sheet.AddRow()
  26. cellA := rowTitle.AddCell()
  27. cellA.Value = "用户名称"
  28. cellB := rowTitle.AddCell()
  29. cellB.Value = "公司名称"
  30. cellC := rowTitle.AddCell()
  31. cellC.Value = "历史访问次数"
  32. cellD := rowTitle.AddCell()
  33. cellD.Value = "最近一次访问日期"
  34. rddpItems,err:=models.GetRddpHistoryViewTimes()
  35. items, err := models.GetHistoryViewTimes()
  36. if err != nil {
  37. return err
  38. }
  39. for _, item := range items {
  40. row := sheet.AddRow()
  41. cellA := row.AddCell()
  42. cellA.Value = item.RealName
  43. cellB := row.AddCell()
  44. cellB.Value = item.CompanyName
  45. cellC := row.AddCell()
  46. cellC.SetInt(item.ViewCount)
  47. cellD := row.AddCell()
  48. cellD.Value = item.CreateTime
  49. }
  50. for _, item := range rddpItems {
  51. row := sheet.AddRow()
  52. cellA := row.AddCell()
  53. cellA.Value = item.RealName
  54. cellB := row.AddCell()
  55. cellB.Value = item.CompanyName
  56. cellC := row.AddCell()
  57. cellC.SetInt(item.ViewCount)
  58. cellD := row.AddCell()
  59. cellD.Value = item.CreateTime
  60. }
  61. title := "用户访问次数"
  62. savePath := "report_view_times" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  63. err = file.Save("./" + savePath)
  64. if err != nil {
  65. return
  66. }
  67. //发送邮件
  68. content := "你好,上周用户访问次数见附件。"
  69. fmt.Println("start send email")
  70. sendResult := utils.SendEmailByHongze(title, content, utils.EmailSendToHzUsers, savePath,title+".xlsx")
  71. //sendResult:=utils.SendEmailByHongze(title,content,utils.EmailSendToMe,savePath)
  72. if sendResult {
  73. os.Remove(savePath)
  74. }
  75. fmt.Println("send result:", sendResult)
  76. fmt.Println("end send email")
  77. return nil
  78. }
  79. //报告访问详情
  80. func ReportViewDetail() (err error) {
  81. defer func() {
  82. if err != nil {
  83. fmt.Println("crete ReportViewDetail err:", err.Error())
  84. utils.FileLog.Info("crete ReportViewDetail err: %s", err.Error())
  85. }
  86. }()
  87. typeList := make([]*models.ReportType, 0)
  88. day := new(models.ReportType)
  89. day.TypeName = "晨报"
  90. day.TypeValue = "day"
  91. typeList = append(typeList, day)
  92. advisory := new(models.ReportType)
  93. advisory.TypeName = "每日商品聚焦"
  94. advisory.TypeValue = "advisory"
  95. typeList = append(typeList, advisory)
  96. week := new(models.ReportType)
  97. week.TypeName = "周报"
  98. week.TypeValue = "week"
  99. typeList = append(typeList, week)
  100. two_week := new(models.ReportType)
  101. two_week.TypeName = "双周报"
  102. two_week.TypeValue = "two_week"
  103. typeList = append(typeList, two_week)
  104. month := new(models.ReportType)
  105. month.TypeName = "月报"
  106. month.TypeValue = "month"
  107. typeList = append(typeList, month)
  108. other := new(models.ReportType)
  109. other.TypeName = "数据点评"
  110. other.TypeValue = "other"
  111. typeList = append(typeList, other)
  112. rddp := new(models.ReportType)
  113. rddp.TypeName = "日度点评"
  114. rddp.TypeValue = "rddp"
  115. typeList = append(typeList, rddp)
  116. startTime := time.Now().AddDate(0, 0, -7).Format(utils.FormatDateTime)
  117. endTime := time.Now().Format(utils.FormatDateTime)
  118. //创建excel
  119. file := xlsx.NewFile()
  120. for _, v := range typeList {
  121. fmt.Println(v.TypeName, v.TypeValue)
  122. if v.TypeValue == "rddp" {
  123. sheet, err := file.AddSheet(v.TypeName + "阅读统计")
  124. if err != nil {
  125. return err
  126. }
  127. //标头
  128. rowTitle := sheet.AddRow()
  129. cellA := rowTitle.AddCell()
  130. cellA.Value = "用户名称"
  131. cellB := rowTitle.AddCell()
  132. cellB.Value = "公司名称"
  133. cellC := rowTitle.AddCell()
  134. cellC.Value = "访问时间"
  135. cellD := rowTitle.AddCell()
  136. cellD.Value = "访问标题"
  137. cellF := rowTitle.AddCell()
  138. cellF.Value = "报告类型"
  139. items, err := models.GetRddpReportViewersDetail(startTime, endTime)
  140. if err != nil {
  141. return err
  142. }
  143. for _, item := range items {
  144. row := sheet.AddRow()
  145. cellA := row.AddCell()
  146. cellA.Value = item.RealName
  147. cellB := row.AddCell()
  148. cellB.Value = item.CompanyName
  149. cellC := row.AddCell()
  150. cellC.Value = item.CreatedTime
  151. cellD := row.AddCell()
  152. cellD.Value = item.ResearchReportName + "(" + item.ReportCreateDate + ")"
  153. cellE := row.AddCell()
  154. cellE.Value = v.TypeName
  155. }
  156. } else if v.TypeValue == "advisory" {
  157. sheet, err := file.AddSheet(v.TypeName + "研报阅读统计")
  158. if err != nil {
  159. return err
  160. }
  161. //标头
  162. rowTitle := sheet.AddRow()
  163. cellA := rowTitle.AddCell()
  164. cellA.Value = "用户名称"
  165. cellB := rowTitle.AddCell()
  166. cellB.Value = "公司名称"
  167. cellC := rowTitle.AddCell()
  168. cellC.Value = "访问时间"
  169. cellD := rowTitle.AddCell()
  170. cellD.Value = "访问标题"
  171. cellE := rowTitle.AddCell()
  172. cellE.Value = "报告类型"
  173. items, err := models.GetAdvisoryViewersDetail(startTime, endTime)
  174. if err != nil {
  175. return err
  176. }
  177. for _, item := range items {
  178. row := sheet.AddRow()
  179. cellA := row.AddCell()
  180. cellA.Value = item.RealName
  181. cellB := row.AddCell()
  182. cellB.Value = item.CompanyName
  183. cellC := row.AddCell()
  184. cellC.Value = item.CreatedTime
  185. cellD := row.AddCell()
  186. cellD.Value = item.ResearchReportName
  187. cellE := row.AddCell()
  188. cellE.Value = v.TypeName
  189. }
  190. } else {
  191. sheet, err := file.AddSheet(v.TypeName + "研报阅读统计")
  192. if err != nil {
  193. return err
  194. }
  195. //标头
  196. rowTitle := sheet.AddRow()
  197. cellA := rowTitle.AddCell()
  198. cellA.Value = "用户名称"
  199. cellB := rowTitle.AddCell()
  200. cellB.Value = "公司名称"
  201. cellC := rowTitle.AddCell()
  202. cellC.Value = "访问时间"
  203. cellD := rowTitle.AddCell()
  204. cellD.Value = "访问标题"
  205. cellE := rowTitle.AddCell()
  206. cellE.Value = "访问页面"
  207. cellF := rowTitle.AddCell()
  208. cellF.Value = "报告类型"
  209. items, err := models.GetResearchReportViewersDetail(startTime, endTime, v.TypeValue)
  210. if err != nil {
  211. return err
  212. }
  213. for _, item := range items {
  214. row := sheet.AddRow()
  215. cellA := row.AddCell()
  216. cellA.Value = item.RealName
  217. cellB := row.AddCell()
  218. cellB.Value = item.CompanyName
  219. cellC := row.AddCell()
  220. cellC.Value = item.CreatedTime
  221. cellD := row.AddCell()
  222. cellD.Value = item.ResearchReportName
  223. cellE := row.AddCell()
  224. cellE.Value = item.ReportVariety
  225. cellF := row.AddCell()
  226. cellF.Value = v.TypeName
  227. }
  228. }
  229. }
  230. title := "研报阅读统计报表"
  231. savePath := "report_view_detail"+ time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  232. err = file.Save("./" + savePath)
  233. fmt.Println(err)
  234. if err != nil {
  235. return
  236. }
  237. //发送邮件
  238. fmt.Println("start send email")
  239. sendResult := utils.SendEmailByHongze(title, "你好,上周研报阅读统计见附件。", utils.EmailSendToHzUsers, savePath,title+".xlsx")
  240. //sendResult:=utils.SendEmailByHongze(title,"你好,上周研报阅读统计见附件。",utils.EmailSendToMe,savePath)
  241. if sendResult {
  242. os.Remove(savePath)
  243. }
  244. //fmt.Println("send result:", sendResult)
  245. //fmt.Println("end send email")
  246. return nil
  247. }