task.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788
  1. package services
  2. import (
  3. "context"
  4. "errors"
  5. "fmt"
  6. "github.com/beego/beego/v2/task"
  7. "hongze/hongze_task/models"
  8. "hongze/hongze_task/services/company"
  9. "hongze/hongze_task/services/company_contract"
  10. "hongze/hongze_task/services/data"
  11. "hongze/hongze_task/services/roadshow"
  12. "hongze/hongze_task/utils"
  13. "strconv"
  14. "strings"
  15. "sync"
  16. "time"
  17. )
  18. func Task() {
  19. fmt.Println("task start")
  20. //如果是生产环境,才需要走这些任务
  21. if utils.RunMode == "release" {
  22. releaseTask()
  23. }
  24. //每日定时合同处理
  25. handleCompanyContract := task.NewTask("handleCompanyContract", "0 1 2 * * *", company_contract.HandleCompanyContract)
  26. task.AddTask("每日定时合同处理", handleCompanyContract)
  27. //正式->试用
  28. companyTryOut := task.NewTask("companyTryOut", "0 5 2 * * *", CompanyTryOut)
  29. task.AddTask("正式->试用", companyTryOut)
  30. //试用->冻结
  31. companyFreeze := task.NewTask("companyFreeze", "0 10 2 * * *", CompanyFreeze)
  32. task.AddTask("试用->冻结", companyFreeze)
  33. //冻结->流失
  34. companyLoss := task.NewTask("companyLoss", "0 20 2 * * *", CompanyLoss)
  35. task.AddTask("冻结->流失", companyLoss)
  36. //用户产品权限正式-->试用
  37. companyReportPermissionTryOut := task.NewTask("companyReportPermissionTryOut", "0 30 2 * * *", CompanyReportPermissionTryOut)
  38. task.AddTask("用户产品权限正式-->试用", companyReportPermissionTryOut)
  39. //用户产品权限试用-->关闭
  40. companyReportPermissionClose := task.NewTask("companyReportPermissionClose", "0 35 2 * * *", CompanyReportPermissionClose)
  41. task.AddTask("用户产品权限试用-->关闭", companyReportPermissionClose)
  42. // 存量客户数据统计
  43. stackCompanyStatistic := task.NewTask("stackCompanyStatistic", "0 35 2 * * *", StackCompanyStatistic)
  44. task.AddTask("存量客户数据统计", stackCompanyStatistic)
  45. // 定时往同花顺推送报告
  46. sendWaitReport := task.NewTask("sendWaitReport", "0 */1 * * * * ", SendWaitReport)
  47. task.AddTask("定时往同花顺推送报告", sendWaitReport)
  48. // 研报电话会提醒
  49. ybTelRemind := task.NewTask("YbTelRemind", "0 */1 * * * * ", YbTelRemind)
  50. task.AddTask("研报电话会提醒", ybTelRemind)
  51. // 研报沙龙提醒
  52. ybSalonRemind := task.NewTask("ybSalonRemind", "0 */1 * * * * ", YbSalonRemind)
  53. task.AddTask("研报沙龙提醒", ybSalonRemind)
  54. // 定时新增手工指标数据提醒
  55. addEdbTask := task.NewTask("sendWaitReport", "1 0 2 * * * ", AddEdbTask)
  56. task.AddTask("定时新增手工指标数据提醒", addEdbTask)
  57. //每次服务启动都需要执行一次的
  58. _ = AddEdbTask(nil)
  59. //每日用户阅读数据统计
  60. statisticsUserView := task.NewTask("statisticsUserView", "0 5 2 * * *", StatisticsUserView)
  61. task.AddTask("每日用户阅读数据统计", statisticsUserView)
  62. //路演-活动状态修改
  63. modifyRsCalendarStatus := task.NewTask("modifyRsCalendarStatus", "0 */1 * * * * ", roadshow.ModifyRsCalendarResearcherStatus)
  64. task.AddTask("modifyRsCalendarStatus", modifyRsCalendarStatus)
  65. addReportRecord := task.NewTask("addReportRecord", "0 0 */1 * * *", roadshow.AddReportRecord)
  66. task.AddTask("addReportRecord", addReportRecord)
  67. //存量客户数据统计
  68. addCompanyReportRecord := task.NewTask("addCompanyReportRecord", "0 0 */1 * * *", company.AddCompanyReportRecord)
  69. task.AddTask("addCompanyReportRecord", addCompanyReportRecord)
  70. //CRM 6.3 客户列表路演次数统计
  71. roadShowTotal := task.NewTask("roadShowTotal", "0 */30 * * * *", roadshow.RoadShow)
  72. task.AddTask("roadShowTotal", roadShowTotal)
  73. //每半个小时用户阅读数据统计
  74. statisticsUserView1Hour := task.NewTask("statisticsUserView1Hour", "0 */30 * * * *", StatisticsUserView1Hour)
  75. task.AddTask("每半个小时用户阅读数据统计", statisticsUserView1Hour)
  76. //路演公开会议合并
  77. setPublicMeetingUnionCode := task.NewTask("setPublicMeetingUnionCode", "0 */10 * * * *", roadshow.SetPublicMeetingUnionCode)
  78. task.AddTask("setPublicMeetingUnionCode", setPublicMeetingUnionCode)
  79. //同步进门会议参会人员数据
  80. syncComeinMeeting := task.NewTask("SyncComeinMeeting", "0 1 */1 * * * ", SyncComeinMeeting)
  81. task.AddTask("SyncComeinMeeting", syncComeinMeeting)
  82. //同步user_record中的关注状态
  83. syncSubStatus := task.NewTask("syncSubStatus", "0 0 2 * * *", SyncSubStatus)
  84. task.AddTask("syncSubStatus", syncSubStatus)
  85. //删除日志 report_save_log,ppt_v2_save_log,保留一个月的
  86. deleteLog := task.NewTask("syncSubStatus", "0 0 2 1 * *", DeleteLog)
  87. task.AddTask("deleteLog", deleteLog)
  88. task.StartTask()
  89. fmt.Println("task end")
  90. }
  91. //func Task() {
  92. // fmt.Println("start")
  93. // cont := new(context.Context)
  94. // roadshow.SetPublicMeetingUnionCode(*cont)
  95. // fmt.Println("end")
  96. //}
  97. //生产环境需要走的任务
  98. func releaseTask() {
  99. //隆众调研指标获取
  100. getLzSurveyProduct := task.NewTask("getLzSurveyProduct", "0 5 08-19/1 * * * ", GetLzSurveyProduct)
  101. task.AddTask("getLzSurveyProduct", getLzSurveyProduct)
  102. //隆众调研指标数据获取
  103. getLzSurveyProductData := task.NewTask("getLzSurveyProductData", "0 10 08-20/1 * * * ", GetLzSurveyProductData)
  104. task.AddTask("getLzSurveyProductData", getLzSurveyProductData)
  105. //发送邮件
  106. sendEmail := task.NewTask("sendEmail", "0 0 12 * * 0 ", SendEmail)
  107. task.AddTask("sendEmail", sendEmail)
  108. // 正式/试用 用户到期提醒
  109. companyRemind := task.NewTask("companyRemind", "0 30 08 * * *", CompanyRemind)
  110. task.AddTask("companyRemind", companyRemind)
  111. //潜在客户
  112. freeViewerDetail := task.NewTask("freeViewerDetail", "0 0 9 * * 1 ", FreeViewerDetail)
  113. task.AddTask("潜在客户", freeViewerDetail)
  114. //上周增量客户列表
  115. incrementCompany := task.NewTask("incrementCompany", "0 0 9 * * 1 ", IncrementCompany)
  116. task.AddTask("上周增量客户列表", incrementCompany)
  117. //刷新指标数据
  118. refreshData := task.NewTask("refreshData", "0 1 0,19 * * *", RefreshData)
  119. task.AddTask("refreshData", refreshData)
  120. //刷新交易所指标数据
  121. refreshTradeData := task.NewTask("refreshData", "0 1 4 * * *", RefreshTradeData)
  122. task.AddTask("refreshTradeData", refreshTradeData)
  123. //刷新欧洲天然气指标数据
  124. refreshEicData := task.NewTask("refreshData", "0 1 3,7 * * *", RefreshEicData)
  125. task.AddTask("refreshEicData", refreshEicData)
  126. //刷新指标基础数据
  127. refreshBaseData := task.NewTask("refreshBaseData", "0 */30 * * * * ", RefreshBaseData)
  128. task.AddTask("refreshBaseData", refreshBaseData)
  129. //同步弘则数据库中来自,钢联,隆众,有色,人工等基础数据--每隔五分钟,同步一次最新数据
  130. syncBaseData := task.NewTask("syncBaseData", "0 */5 * * * * ", SyncBaseData)
  131. task.AddTask("syncBaseData", syncBaseData)
  132. syncBaseDataExt := task.NewTask("syncBaseDataExt", "0 */30 * * * * ", SyncBaseDataExt)
  133. task.AddTask("syncBaseDataExt", syncBaseDataExt)
  134. // 定时往同花顺同步微信群的截止日期(凌晨4点)
  135. syncThsWxGroupEveryDay := task.NewTask("syncThsWxGroupEveryDay", "0 1 4 * * * ", SyncWxGroupEveryDay)
  136. task.AddTask("定时往同花顺同步微信群的截止日期", syncThsWxGroupEveryDay)
  137. //检测数据服务器
  138. checkDataServer := task.NewTask("checkDataServer", "0 */2 * * * * ", checkDataServer)
  139. task.AddTask("checkDataServer", checkDataServer)
  140. //初始化指标更新状态
  141. resetEdbInfoIsUpdate := task.NewTask("resetEdbInfoIsUpdate", "0 0 0 * * *", data.ResetEdbInfoIsUpdate)
  142. task.AddTask("resetEdbInfoIsUpdate", resetEdbInfoIsUpdate)
  143. // 定时检测同花顺客群推送消息状态
  144. checkThsReportList := task.NewTask("checkThsReportList", "0 */2 * * * * ", CheckThsReportList)
  145. task.AddTask("checkThsReportList", checkThsReportList)
  146. }
  147. func TaskTest() {
  148. fmt.Println("The task is start")
  149. //companyReportPermissionClose := task.NewTask("companyTryOut", "0 5 0 * * *", CompanyReportPermissionClose)
  150. companyReportPermissionClose := task.NewTask("companyReportPermissionClose", "0/30 * * * * *", CompanyReportPermissionClose)
  151. task.AddTask("用户产品权限试用-->关闭", companyReportPermissionClose)
  152. task.StartTask()
  153. fmt.Println("The task is end")
  154. }
  155. func SendEmail(cont context.Context) (err error) {
  156. //报告历史访问次数
  157. go ReportViewTimes()
  158. //报告访问详情
  159. go ReportViewDetail()
  160. //用户权限统计
  161. go HongzeUsers()
  162. return
  163. }
  164. func OneMinute(cont context.Context) (err error) {
  165. //日度
  166. //FrequencyByDay()
  167. //周度
  168. FrequencyByWeek()
  169. //月度
  170. FrequencyByMonth()
  171. return
  172. }
  173. func RefreshData(cont context.Context) (err error) {
  174. wg := sync.WaitGroup{}
  175. wg.Add(11)
  176. //hour := time.Now().Hour()
  177. //if hour != 0 {
  178. //}
  179. go data.RefreshDataFromWind(&wg)
  180. //同花顺
  181. go data.RefreshDataFromThs(&wg)
  182. //彭博
  183. go data.RefreshDataFromPb(&wg)
  184. //彭博财务
  185. go data.RefreshDataFromPbFinance(&wg)
  186. //手工数据
  187. go data.RefreshDataFromManual(&wg)
  188. //隆众数据
  189. go data.RefreshDataFromLz(&wg)
  190. //有色
  191. go data.RefreshDataFromYs(&wg)
  192. //钢联
  193. go data.RefreshDataFromGl(&wg)
  194. //路透
  195. go data.RefreshDataFromLt(&wg)
  196. //煤炭
  197. go data.RefreshDataFromCoal(&wg)
  198. //谷歌出行数据
  199. go data.RefreshDataFromGoogleTravel(&wg)
  200. wg.Wait()
  201. ////计算指标
  202. data.RefreshDataFromCalculateAll()
  203. time.Sleep(5 * time.Second)
  204. data.RefreshNotice()
  205. fmt.Println("Refresh End")
  206. return
  207. }
  208. // RefreshTradeData 刷新交易所数据
  209. func RefreshTradeData(cont context.Context) (err error) {
  210. wg := sync.WaitGroup{}
  211. wg.Add(5)
  212. //郑商所
  213. go data.RefreshDataFromZz(&wg)
  214. //上期所
  215. go data.RefreshDataFromSh(&wg)
  216. //上期能源
  217. go data.RefreshDataFromShfe(&wg)
  218. //中金所
  219. go data.RefreshDataFromCffex(&wg)
  220. //大商所
  221. go data.RefreshDataFromDl(&wg)
  222. wg.Wait()
  223. //计算指标
  224. data.RefreshDataFromCalculateAll()
  225. return
  226. }
  227. // RefreshEicData 刷新欧洲天然气数据
  228. func RefreshEicData(cont context.Context) (err error) {
  229. wg := sync.WaitGroup{}
  230. wg.Add(1)
  231. //欧洲天然气
  232. go data.RefreshDataFromEic(&wg)
  233. wg.Wait()
  234. //计算指标
  235. data.RefreshDataFromCalculateAll()
  236. return
  237. }
  238. //刷新基础数据
  239. func RefreshBaseData(cont context.Context) (err error) {
  240. now := time.Now()
  241. if now.Hour() == 0 || now.Hour() == 19 {
  242. return nil
  243. }
  244. //同步有色基础指标数据
  245. go data.SyncSmmIndexDataBase()
  246. return
  247. }
  248. //刷新基础数据
  249. func SyncBaseData(cont context.Context) (err error) {
  250. now := time.Now()
  251. if now.Hour() == 0 || now.Hour() == 19 {
  252. return nil
  253. }
  254. //同步钢联基础数据
  255. go data.SyncGlDataBase()
  256. return
  257. }
  258. //刷新基础数据
  259. func SyncBaseDataExt(cont context.Context) (err error) {
  260. now := time.Now()
  261. if now.Hour() == 0 || now.Hour() == 19 {
  262. return nil
  263. }
  264. //同步隆众基础数据
  265. go data.SyncLzDataBase()
  266. //同步手工数据
  267. go data.SyncManualDataBase()
  268. //同步有色基础数据
  269. go data.SyncSmmDataBase()
  270. //刷新图表中,指标的最新日期
  271. go data.SetChartEdbEndDate()
  272. return
  273. }
  274. // EdbTaskNameMap 手工指标定时任务名称map集合
  275. var EdbTaskNameMap map[string]map[string]bool
  276. // EdbTaskNameChannel 手工指标定时任务名称channel
  277. var EdbTaskNameChannel chan string
  278. // EdbTaskStopChannel 手工指标定时任务停止channel
  279. var EdbTaskStopChannel chan string
  280. // EdbTaskRunNum 手工指标定时任务开始次数
  281. var EdbTaskRunNum int
  282. // AddEdbTask 新增手工指标数据录入提醒
  283. func AddEdbTask(cont context.Context) (err error) {
  284. //失败列表
  285. failList := make([]string, 0)
  286. defer func() {
  287. if len(failList) > 0 {
  288. fmt.Println("提醒失败:")
  289. for _, v := range failList {
  290. fmt.Println(v)
  291. }
  292. }
  293. }()
  294. list, err := models.GetEdbInfoByFrequencyNotDay()
  295. if err != nil {
  296. fmt.Println("查询获取频度非日度 且 提醒时间不为空 的指标数据失败,Err:", err.Error())
  297. }
  298. //如果还没有初始化map,那么先初始
  299. if EdbTaskNameMap == nil {
  300. EdbTaskNameMap = make(map[string]map[string]bool)
  301. }
  302. tmpEdbTaskNameMap := make(map[string]bool)
  303. // 今天的日期字符串(格式:2021-10-25)
  304. todayStr := time.Now().Format(utils.FormatDate)
  305. //当前周的周一与周日
  306. nowWeekFirstDay := utils.GetNowWeekMonday()
  307. nowWeekLastDay := utils.GetNowWeekLastDay()
  308. //当前月的一号与最后一天
  309. nowMonthFirstDay := utils.GetNowMonthFirstDay()
  310. nowMonthLastDay := utils.GetNowMonthLastDay()
  311. //当前季度的第一天与最后一天
  312. nowQuarterFirstDay := utils.GetNowQuarterFirstDay()
  313. nowQuarterLastDay := utils.GetNowQuarterLastDay()
  314. //当前半年的第一天与最后一天
  315. nowHalfYearFirstDay := utils.GetNowHalfYearFirstDay()
  316. nowHalfYearLastDay := utils.GetNowHalfYearLastDay()
  317. // 当前年的第一天与最后一天
  318. nowYearFirstDay := utils.GetNowYearFirstDay()
  319. nowYearLastDay := utils.GetNowYearLastDay()
  320. debugNoticeUserId := 0 //测试环境,需要发送消息的用户
  321. //测试环境也不发了
  322. //if utils.RunMode == "debug" {
  323. // tmpWxUser, tmpErr := models.GetWxUserByMobile("17634786714")
  324. // if tmpErr == nil && tmpWxUser != nil {
  325. // //debugNoticeUserId = 44078 //测试环境的话,发送邮箱给颜鹏
  326. // debugNoticeUserId = int(tmpWxUser.UserId) //测试环境的话,发送邮箱给嘉豪
  327. // }
  328. //}
  329. //task.globalTaskManager.adminTaskList
  330. for _, edb := range list {
  331. if edb.UserId <= 0 {
  332. continue //没有配置user_id的话,那么不需要提醒
  333. }
  334. tmpEdb := edb //指标信息
  335. isNotice := false //是否需要提醒
  336. noticeTime := "12:00:00" //提醒时间
  337. var dataDtTime time.Time
  338. edbData, tmpErr := models.GetLastEdbdataInfo(tmpEdb.TradeCode)
  339. if tmpErr != nil {
  340. if tmpErr.Error() != utils.ErrNoRow() {
  341. failList = append(failList, fmt.Sprint(tmpEdb.TradeCode, "失败,Err:", tmpErr.Error()))
  342. continue
  343. }
  344. }
  345. //如果确实是有数据的
  346. if edbData != nil {
  347. tmpDataDtTime, _ := time.ParseInLocation(utils.FormatDate, edbData.Dt, time.Now().Location())
  348. dataDtTime = tmpDataDtTime
  349. }
  350. switch tmpEdb.Frequency {
  351. case "周度":
  352. modifyDate := nowWeekLastDay //下次更新日期
  353. if tmpEdb.NoticeTime != "" {
  354. addDay := 7
  355. noticeArr := strings.Split(tmpEdb.NoticeTime, " ")
  356. if len(noticeArr) >= 2 {
  357. noticeTime = noticeArr[1]
  358. }
  359. noticeWeek := noticeArr[0]
  360. switch noticeWeek {
  361. case "周一":
  362. addDay = 1
  363. case "周二":
  364. addDay = 2
  365. case "周三":
  366. addDay = 3
  367. case "周四":
  368. addDay = 4
  369. case "周五":
  370. addDay = 5
  371. case "周六":
  372. addDay = 6
  373. case "周日":
  374. addDay = 7
  375. }
  376. modifyDate = modifyDate.AddDate(0, 0, addDay-7)
  377. }
  378. //如果正好是提醒日,同时本周没有过记录,那么需要提醒
  379. if todayStr == modifyDate.Format(utils.FormatDate) && !nowWeekFirstDay.Before(dataDtTime) {
  380. isNotice = true
  381. }
  382. case "月度":
  383. addDay := 0
  384. modifyDate := nowMonthLastDay //下次更新日期
  385. if tmpEdb.NoticeTime != "" {
  386. strArr := strings.Split(tmpEdb.NoticeTime, "日")
  387. if len(strArr) >= 2 {
  388. noticeTime = strArr[1]
  389. }
  390. tmpAddDay, tmpErr := strconv.Atoi(strArr[0])
  391. if tmpErr != nil {
  392. continue
  393. }
  394. addDay = tmpAddDay - 1
  395. modifyDate = nowMonthFirstDay.AddDate(0, 0, addDay)
  396. }
  397. //如果正好是提醒日,同时本月没有过记录,那么需要提醒
  398. if todayStr == modifyDate.Format(utils.FormatDate) && !nowMonthFirstDay.Before(dataDtTime) {
  399. isNotice = true
  400. }
  401. case "季度":
  402. //提醒时间
  403. if tmpEdb.NoticeTime != "" {
  404. noticeArr := strings.Split(tmpEdb.NoticeTime, " ")
  405. if len(noticeArr) >= 2 {
  406. noticeTime = noticeArr[1]
  407. }
  408. }
  409. //每季度更新数据时间
  410. //如果正好是提醒日(每季度最后一天),同时本季度没有过记录,那么需要提醒
  411. if todayStr == nowQuarterLastDay.Format(utils.FormatDate) && !nowQuarterFirstDay.Before(dataDtTime) {
  412. isNotice = true
  413. }
  414. case "半年度":
  415. //提醒时间
  416. if tmpEdb.NoticeTime != "" {
  417. noticeArr := strings.Split(tmpEdb.NoticeTime, " ")
  418. if len(noticeArr) >= 2 {
  419. noticeTime = noticeArr[1]
  420. }
  421. }
  422. //每半年度更新数据时间
  423. //如果正好是提醒日(每半年度最后一天),同时本半年度没有过记录,那么需要提醒
  424. if todayStr == nowHalfYearLastDay.Format(utils.FormatDate) && !nowHalfYearFirstDay.Before(dataDtTime) {
  425. isNotice = true
  426. }
  427. case "年度":
  428. //提醒时间
  429. if tmpEdb.NoticeTime != "" {
  430. noticeArr := strings.Split(tmpEdb.NoticeTime, " ")
  431. if len(noticeArr) >= 2 {
  432. noticeTime = noticeArr[1]
  433. }
  434. }
  435. //每年度更新数据时间
  436. //如果正好是提醒日(每年度最后一天),同时半年度没有过记录,那么需要提醒
  437. if todayStr == nowYearLastDay.Format(utils.FormatDate) && !nowYearFirstDay.Before(dataDtTime) {
  438. isNotice = true
  439. }
  440. }
  441. if isNotice {
  442. taskName := "edb_task_" + todayStr + ":" + fmt.Sprint(tmpEdb.TradeCode)
  443. //fmt.Println(taskName, ";", tmpEdb.SecName)
  444. //定时任务
  445. tmpTaskFunc := func(ctx context.Context) (funcErr error) {
  446. //方法执行结束后,移除定时任务
  447. defer func() {
  448. EdbTaskNameChannel <- taskName
  449. }()
  450. // 匿名方法内判断是否发送提醒,因为可能时间到的时候,发现
  451. funcIsNotice := false
  452. // 再次获取指标数据详情
  453. edbData, tmpErr := models.GetLastEdbdataInfo(tmpEdb.TradeCode)
  454. if tmpErr != nil {
  455. if tmpErr.Error() != utils.ErrNoRow() {
  456. funcErr = tmpErr
  457. return
  458. }
  459. }
  460. if utils.RunMode == "debug" && debugNoticeUserId > 0 {
  461. tmpEdb.UserId = debugNoticeUserId //测试环境的话,发送邮箱给嘉豪
  462. }
  463. //数据过期时间
  464. var funcDataDtTime time.Time
  465. //如果确实是有数据的
  466. if edbData != nil {
  467. tmpDataDtTime, _ := time.ParseInLocation(utils.FormatDate, edbData.Dt, time.Now().Location())
  468. funcDataDtTime = tmpDataDtTime
  469. }
  470. //提示频度文案
  471. notifyFrequency := "每日"
  472. switch tmpEdb.Frequency {
  473. case "周度":
  474. notifyFrequency = "每周"
  475. modifyDate := nowWeekLastDay //下次更新日期
  476. if tmpEdb.NoticeTime != "" {
  477. addDay := 7
  478. noticeArr := strings.Split(tmpEdb.NoticeTime, " ")
  479. if len(noticeArr) >= 2 {
  480. noticeTime = noticeArr[1]
  481. }
  482. noticeWeek := noticeArr[0]
  483. switch noticeWeek {
  484. case "周一":
  485. addDay = 1
  486. case "周二":
  487. addDay = 2
  488. case "周三":
  489. addDay = 3
  490. case "周四":
  491. addDay = 4
  492. case "周五":
  493. addDay = 5
  494. case "周六":
  495. addDay = 6
  496. case "周日":
  497. addDay = 7
  498. }
  499. modifyDate = modifyDate.AddDate(0, 0, addDay-7)
  500. }
  501. //如果正好是提醒日,同时本周没有过记录,那么需要提醒
  502. if todayStr == modifyDate.Format(utils.FormatDate) && !nowWeekFirstDay.Before(funcDataDtTime) {
  503. funcIsNotice = true
  504. }
  505. case "月度":
  506. notifyFrequency = "每月"
  507. addDay := 0
  508. modifyDate := nowMonthLastDay //下次更新日期
  509. if tmpEdb.NoticeTime != "" {
  510. strArr := strings.Split(tmpEdb.NoticeTime, "日")
  511. if len(strArr) >= 2 {
  512. noticeTime = strArr[1]
  513. }
  514. tmpAddDay, tmpErr := strconv.Atoi(strArr[0])
  515. if tmpErr != nil {
  516. funcErr = tmpErr
  517. }
  518. addDay = tmpAddDay - 1
  519. modifyDate = nowMonthFirstDay.AddDate(0, 0, addDay)
  520. }
  521. //如果正好是提醒日,同时本月没有过记录,那么需要提醒
  522. if todayStr == modifyDate.Format(utils.FormatDate) && !nowMonthFirstDay.Before(funcDataDtTime) {
  523. funcIsNotice = true
  524. }
  525. case "季度":
  526. notifyFrequency = "每季度"
  527. //提醒时间
  528. if tmpEdb.NoticeTime != "" {
  529. noticeArr := strings.Split(tmpEdb.NoticeTime, " ")
  530. if len(noticeArr) >= 2 {
  531. noticeTime = noticeArr[1]
  532. }
  533. }
  534. //每季度更新数据时间
  535. //如果正好是提醒日(每季度最后一天),同时本季度没有过记录,那么需要提醒
  536. if todayStr == nowQuarterLastDay.Format(utils.FormatDate) && !nowQuarterFirstDay.Before(funcDataDtTime) {
  537. funcIsNotice = true
  538. }
  539. case "半年度":
  540. notifyFrequency = "每半年度"
  541. //提醒时间
  542. if tmpEdb.NoticeTime != "" {
  543. noticeArr := strings.Split(tmpEdb.NoticeTime, " ")
  544. if len(noticeArr) >= 2 {
  545. noticeTime = noticeArr[1]
  546. }
  547. }
  548. //每半年度更新数据时间
  549. //如果正好是提醒日(每半年度最后一天),同时本半年度没有过记录,那么需要提醒
  550. if todayStr == nowHalfYearLastDay.Format(utils.FormatDate) && !nowHalfYearFirstDay.Before(funcDataDtTime) {
  551. funcIsNotice = true
  552. }
  553. case "年度":
  554. notifyFrequency = "每年"
  555. //提醒时间
  556. if tmpEdb.NoticeTime != "" {
  557. noticeArr := strings.Split(tmpEdb.NoticeTime, " ")
  558. if len(noticeArr) >= 2 {
  559. noticeTime = noticeArr[1]
  560. }
  561. }
  562. //每年度更新数据时间
  563. //如果正好是提醒日(每年度最后一天),同时半年度没有过记录,那么需要提醒
  564. if todayStr == nowYearLastDay.Format(utils.FormatDate) && !nowYearFirstDay.Before(funcDataDtTime) {
  565. funcIsNotice = true
  566. }
  567. }
  568. //fmt.Println(tmpEdb.TradeCode, " funcIsNotice:", funcIsNotice)
  569. //如果还是要提醒
  570. if funcIsNotice {
  571. //用户微信openid列表数据
  572. openIdList := make([]*models.OpenIdList, 0)
  573. //获取用户信息
  574. isAdmin := true
  575. admin, err := models.GetAdminByAdminId(tmpEdb.UserId)
  576. if err != nil {
  577. if err.Error() == utils.ErrNoRow() {
  578. isAdmin = false
  579. } else {
  580. return err
  581. }
  582. }
  583. if admin == nil {
  584. isAdmin = false
  585. }
  586. if isAdmin {
  587. if admin.Mobile == "" {
  588. } else {
  589. wxUser, err := models.GetWxUserByMobile(admin.Mobile)
  590. if err != nil {
  591. return err
  592. }
  593. if wxUser == nil {
  594. funcErr = errors.New("用户信息不存在:mobile:" + admin.Mobile)
  595. return err
  596. }
  597. tmpOpenidList, err := models.GetUserOpenidListByUserId(int(wxUser.UserId))
  598. if err != nil {
  599. return err
  600. }
  601. openIdList = tmpOpenidList
  602. }
  603. } else {
  604. tmpOpenidList, err := models.GetUserOpenidListByUserId(tmpEdb.UserId)
  605. if err != nil {
  606. return err
  607. }
  608. openIdList = tmpOpenidList
  609. }
  610. //发送消息
  611. if len(openIdList) <= 0 {
  612. funcErr = errors.New("openId 列表为空" + strconv.Itoa(tmpEdb.UserId))
  613. return
  614. }
  615. first := "数据录入提醒"
  616. keyword1 := tmpEdb.SecName
  617. keyword2 := notifyFrequency + " " + tmpEdb.NoticeTime
  618. remark := tmpEdb.SecName + "该更新了"
  619. err = SendWxMsgWithFrequency(first, keyword1, keyword2, remark, openIdList)
  620. if err != nil {
  621. return err
  622. }
  623. //发送成功,记录发送日志
  624. {
  625. sendRecord := new(models.EdbinfoSendMsgRecord)
  626. sendRecord.UserId = tmpEdb.UserId
  627. sendRecord.TradeCode = tmpEdb.TradeCode
  628. sendRecord.CreateTime = time.Now()
  629. err = models.AddEdbinfoSendMsgRecord(sendRecord)
  630. if err != nil {
  631. return err
  632. }
  633. }
  634. }
  635. return
  636. }
  637. //添加定时任务(没有设置通知时间就不进行定时任务通知了)
  638. spec := ``
  639. if noticeTime != "" {
  640. noticeArr := strings.Split(noticeTime, ":")
  641. if len(noticeArr) == 3 {
  642. //spec = ` */20 * * * * * `
  643. spec = fmt.Sprintf(` %s %s %s * * * `, noticeArr[2], noticeArr[1], noticeArr[0])
  644. //定时任务开始的时间
  645. tmpTask := task.NewTask(taskName, spec, tmpTaskFunc)
  646. task.AddTask(taskName, tmpTask)
  647. tmpEdbTaskNameMap[taskName] = true
  648. }
  649. }
  650. }
  651. }
  652. //将当天的手工指标加入到手工指标池去
  653. EdbTaskNameMap[todayStr] = tmpEdbTaskNameMap
  654. //开启协程,用来清除定时任务
  655. go deleteTask()
  656. //如果当前定时任务执行次数大于0次,那么需要往手工指标定时任务停止channel写入数据,用来关闭昨天没有执行的的定时任务
  657. if EdbTaskRunNum > 0 {
  658. //清除昨天的数据
  659. EdbTaskStopChannel <- time.Now().AddDate(0, 0, -1).Format(utils.FormatDate)
  660. }
  661. //手工指标定时任务开始次数累加
  662. EdbTaskRunNum++
  663. return
  664. //fmt.Println(task.NewMapSorter())
  665. }
  666. // deleteTask 清除已通知的任务
  667. func deleteTask() {
  668. for {
  669. select {
  670. case taskName := <-EdbTaskNameChannel:
  671. task.DeleteTask(taskName)
  672. delete(EdbTaskNameMap, taskName)
  673. case dayStr := <-EdbTaskStopChannel: //收到停止信号,先清除掉那一天的定时任务,
  674. for taskName := range EdbTaskNameMap[dayStr] {
  675. task.DeleteTask(taskName)
  676. delete(EdbTaskNameMap, taskName)
  677. }
  678. break
  679. }
  680. }
  681. }
  682. //检测数据服务
  683. func checkDataServer(cont context.Context) (err error) {
  684. //检测wind新服务器
  685. go data.CheckWindDataInterface(cont)
  686. //检测同花顺数据服务器
  687. go data.CheckThsDataInterface(cont)
  688. //检测路透数据服务器
  689. go data.CheckLtDataInterface(cont)
  690. //检测彭博
  691. go data.CheckPbDataInterface(cont)
  692. return
  693. }