morning_meeting.go 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. package services
  2. import (
  3. "fmt"
  4. "hongze/hongze_cygx/models"
  5. "hongze/hongze_cygx/utils"
  6. "strconv"
  7. "strings"
  8. "time"
  9. )
  10. func init12321() {
  11. for i := 180; i > 0; i-- {
  12. init12(i)
  13. }
  14. }
  15. func init12(day int) (err error) {
  16. defer func() {
  17. if err != nil {
  18. fmt.Println(err)
  19. go utils.SendAlarmMsg("定时生成晨会精华汇总失败,err:"+err.Error(), 2)
  20. }
  21. }()
  22. hourstr := " 10:30:00 "
  23. DayTime := time.Now().AddDate(0, 0, -day)
  24. startSize := 0
  25. pageSize := 100
  26. var condition string
  27. var pars []interface{}
  28. startDate := DayTime.AddDate(0, 0, -1).Format(utils.FormatDate) + hourstr
  29. endDate := DayTime.Format(utils.FormatDate) + hourstr
  30. condition = ` AND publish_time = ? `
  31. pars = append(pars, endDate)
  32. total, err := models.GetCygxMorningMeetingGatherCount(condition, pars)
  33. if err != nil {
  34. return
  35. }
  36. if total > 0 {
  37. return
  38. }
  39. pars = make([]interface{}, 0)
  40. condition = ` AND publish_time BETWEEN ? AND ? `
  41. pars = append(pars, startDate, endDate)
  42. list, err := models.GetCygxMorningMeetingReviewsList(condition, pars, startSize, pageSize)
  43. if err != nil {
  44. return
  45. }
  46. if len(list) == 0 {
  47. return
  48. }
  49. item := new(models.CygxMorningMeetingGather)
  50. for _, v := range list {
  51. item.MeetingIds += strconv.Itoa(v.Id) + ","
  52. }
  53. item.MeetingIds = strings.TrimRight(item.MeetingIds, ",")
  54. item.Title = utils.GetTimeDateHourAndDay(DayTime) + "(" + utils.StrDateTimeToWeek(DayTime.Format(utils.FormatDateTime)) + ")" + "|晨会精华"
  55. item.CreateTime = time.Now()
  56. item.ModifyTime = time.Now()
  57. item.PublishTime = endDate
  58. item.Status = 1
  59. err = models.AddCygxMorningMeetingGather(item)
  60. return
  61. }