task.go 26 KB

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