task.go 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569
  1. package services
  2. import (
  3. "eta/eta_api/models"
  4. "eta/eta_api/services/data"
  5. "eta/eta_api/utils"
  6. "fmt"
  7. "strings"
  8. "time"
  9. )
  10. func Task() {
  11. fmt.Println("task start")
  12. {
  13. // 修复客户试用数据
  14. //FixCompanyUpdateData()
  15. //FixCompanyTryDay()
  16. //FixCompanyTryDay()
  17. //StaticCompanyTryDay()
  18. //return
  19. }
  20. //FixPermissionStatus()
  21. //GetCompanyInfo()
  22. //ReportCount()
  23. //windSourceUrl:=`http://47.100.166.55:7002/edbInfo/wind/?EdbCode=M0001427&StartDate=2020-11-01&EndDate=2021-03-01`
  24. //data.AddAllArticle()
  25. //data.GetSmmIndex()
  26. //data.GetSmmIndexData()
  27. go AutoInsertLogToDB()
  28. //手工数据表格导入后的指标库刷新
  29. go ImportManualDataRefresh()
  30. // 加入钢联化工指标数据之后的刷新
  31. go MysteelChemicalDataAdd()
  32. //修复用户关注标识
  33. //GetWxUsersSubscribe()
  34. go AutoInsertAdminOperateRecordToDB()
  35. // 指标刷新
  36. go data.HandleEdbRefreshQueue()
  37. // 进行指标替换操作
  38. go DealReplaceEdbCache()
  39. // TODO:监听这里需要找下达梦的方案,主流程先跑起来再处理
  40. // 监听binlog
  41. if utils.MYSQL_DATA_BINLOG_URL != "" {
  42. //go binlog.ListenMysql()
  43. }
  44. //go edbmonitor.HandleEdbMonitorEdbInfo()
  45. // 监听数据源binlog写入es
  46. //go binlog.HandleDataSourceChange2Es()
  47. // TODO:数据修复
  48. //FixNewEs()
  49. fmt.Println("task end")
  50. }
  51. //// 每日发布晨报
  52. //func AutoPublishDayReport() {
  53. // defer func() {
  54. // if err := recover(); err != nil {
  55. // fmt.Println("[AutoPublishDayReport]", err)
  56. // }
  57. // }()
  58. //
  59. // // 每日8:42发布晨报
  60. // ticker := time.Tick(50 * time.Second)
  61. // for range ticker {
  62. // nowTime := time.Now()
  63. // clock := nowTime.Format("1504")
  64. // if clock == "0842" {
  65. // if err := PublishTodayDayReport(); err != nil {
  66. // go alarm_msg.SendAlarmMsg(fmt.Sprint("每日晨报自动发送 AutoPublishDayReport ERR:", err), 3)
  67. // //utils.SendEmail(utils.APPNAME+" "+utils.RunMode+" 失败提醒", fmt.Sprint("AutoPublishDayReport ERR:", err), utils.EmailSendToUsers)
  68. // }
  69. // }
  70. // }
  71. //}
  72. // ImportManualDataRefresh 导入手工数据后的刷新
  73. func ImportManualDataRefresh() {
  74. defer func() {
  75. if err := recover(); err != nil {
  76. fmt.Println("[ImportManualDataRefresh]", err)
  77. }
  78. }()
  79. for {
  80. utils.Rc.Brpop(utils.CACHE_IMPORT_MANUAL_DATA, func(b []byte) {
  81. edbCode := string(b)
  82. edbCode = strings.TrimPrefix(edbCode, `"`)
  83. edbCode = strings.TrimSuffix(edbCode, `"`)
  84. data.RefreshManualData(edbCode)
  85. })
  86. }
  87. }
  88. // MysteelChemicalDataAdd 加入钢联化工指标数据之后的刷新
  89. func MysteelChemicalDataAdd() {
  90. defer func() {
  91. if err := recover(); err != nil {
  92. fmt.Println("[ImportManualDataRefresh]", err)
  93. }
  94. }()
  95. for {
  96. utils.Rc.Brpop(utils.CACHE_MYSTEEL_CHEMICAL_ADD_DATA, func(b []byte) {
  97. edbCode := string(b)
  98. edbCode = strings.TrimPrefix(edbCode, `"`)
  99. edbCode = strings.TrimSuffix(edbCode, `"`)
  100. data.RefreshMysteelChemicalData(edbCode)
  101. })
  102. }
  103. }
  104. //func init() {
  105. // fmt.Println("start task init")
  106. // UpdateEnglishEmailLogErrMsg()
  107. // fmt.Println("end task init")
  108. //}
  109. //
  110. //// UpdateEnglishEmailLogErrMsg 更新英文邮件日志的ErrMsg(研报后台4.2上线后执行, 仅一次)
  111. //func UpdateEnglishEmailLogErrMsg() {
  112. // var cond string
  113. // var pars []interface{}
  114. // list, e := models.GetEnglishReportEmailLogList(cond, pars)
  115. // if e != nil {
  116. // fmt.Println("获取日志列表失败")
  117. // return
  118. // }
  119. // for _, v := range list {
  120. // if v.SendStatus != 0 || v.Source != 1 || v.Result == "" || v.ErrMsg != "" {
  121. // continue
  122. // }
  123. // // 取出错误信息
  124. // fmt.Printf("正在更新%d\n", v.Id)
  125. // r := new(AliyunEmailResult)
  126. // if e = json.Unmarshal([]byte(v.Result), &r); e != nil {
  127. // fmt.Println("JSON解析报错了1" + e.Error())
  128. // continue
  129. // }
  130. // rd := new(AliyunEmailResultData)
  131. // res := strings.Replace(r.Data, `\`, ``, -1)
  132. // if e = json.Unmarshal([]byte(res), &rd); e != nil {
  133. // fmt.Println("JSON解析报错了2" + e.Error())
  134. // continue
  135. // }
  136. // v.ErrMsg = rd.Message
  137. // if e = v.Update([]string{"ErrMsg"}); e != nil {
  138. // fmt.Println("更新失败了" + e.Error())
  139. // continue
  140. // }
  141. // }
  142. // fmt.Println("更新成功")
  143. //}
  144. //func FixCompanyUpdateData1() {
  145. // list, err := company.GetCompanyProductUpdateLogList()
  146. // if err != nil {
  147. // fmt.Println("获取客户变更数据失败:", err)
  148. // return
  149. // }
  150. //
  151. // nowTime := time.Now()
  152. // for _, v := range list {
  153. // //item, tmpErr := company.GetCompanyProductLogItem(v.CompanyId, v.ProductId, v.CreateTime)
  154. // //if tmpErr != nil {
  155. // // fmt.Println(v.Id, "找数据,", tmpErr)
  156. // // continue
  157. // //}
  158. //
  159. // //permissionList := make([]*company.CompanyReportPermission, 0)
  160. // //switch v.Source {
  161. // //case "add", "receive", "thaw", "delay", "apply_receive":
  162. // //
  163. // //}
  164. // permissionList, err := company.GetCompanyReportPermission(v.CompanyId, v.ProductId)
  165. // if err != nil {
  166. // fmt.Println("err:", err)
  167. // continue
  168. // }
  169. //
  170. // startDate := v.CreateTime
  171. // endDate := v.CreateTime.AddDate(0, 2, 0)
  172. // isStop := 1
  173. // realEndDate := endDate
  174. // if realEndDate.After(nowTime) {
  175. // realEndDate = nowTime
  176. // isStop = 0
  177. // }
  178. // for _, permission := range permissionList {
  179. // permission.StartDate = startDate.Format(utils.FormatDate)
  180. // permission.EndDate = v.CreateTime.Format(utils.FormatDate)
  181. // }
  182. // companyProductTryOutUpdateLogItem := &company.CompanyProductTryOutUpdateLog{
  183. // Id: 0,
  184. // CompanyId: v.CompanyId,
  185. // ProductId: v.ProductId,
  186. // SellerId: v.SellerId,
  187. // SellerName: v.SellerName,
  188. // Source: v.Source,
  189. // StartDate: startDate,
  190. // EndDate: endDate,
  191. // RealEndDate: realEndDate,
  192. // IsStop: isStop,
  193. // CreateTime: v.CreateTime,
  194. // }
  195. // err = company.AddCompanyProductTryOutUpdateLog(companyProductTryOutUpdateLogItem, permissionList)
  196. // }
  197. // //fmt.Println("结束")
  198. //}
  199. //func FixCompanyUpdateData2() {
  200. // list, err := company.GetTryOutCompanyOperationRecordList()
  201. // if err != nil {
  202. // fmt.Println("获取客户变更数据失败:", err)
  203. // return
  204. // }
  205. //
  206. // nowTime := time.Now()
  207. // for _, v := range list {
  208. // //item, tmpErr := company.GetCompanyProductLogItem(v.CompanyId, v.ProductId, v.CreateTime)
  209. // //if tmpErr != nil {
  210. // // fmt.Println(v.Id, "找数据,", tmpErr)
  211. // // continue
  212. // //}
  213. //
  214. // //permissionList := make([]*company.CompanyReportPermission, 0)
  215. // //switch v.Source {
  216. // //case "add", "receive", "thaw", "delay", "apply_receive":
  217. // //
  218. // //}
  219. // permissionList, err := company.GetCompanyReportPermission(v.CompanyId, v.ProductId)
  220. // if err != nil {
  221. // fmt.Println("err:", err)
  222. // continue
  223. // }
  224. //
  225. // startDate := v.CreateTime
  226. // endDate := v.CreateTime.AddDate(0, 2, 0)
  227. // isStop := 1
  228. // realEndDate := endDate
  229. // if realEndDate.After(nowTime) {
  230. // realEndDate = nowTime
  231. // isStop = 0
  232. // }
  233. // for _, permission := range permissionList {
  234. // permission.StartDate = startDate.Format(utils.FormatDate)
  235. // permission.EndDate = v.CreateTime.Format(utils.FormatDate)
  236. // }
  237. // sellerName := ``
  238. // {
  239. // sysUser, _ := system.GetSysAdminById(v.SellerId)
  240. // if sysUser != nil {
  241. // sellerName = sysUser.RealName
  242. // }
  243. // }
  244. // companyProductTryOutUpdateLogItem := &company.CompanyProductTryOutUpdateLog{
  245. // Id: 0,
  246. // CompanyId: v.CompanyId,
  247. // ProductId: v.ProductId,
  248. // SellerId: v.SellerId,
  249. // SellerName: sellerName,
  250. // Source: "formal_to_try_out",
  251. // StartDate: startDate,
  252. // EndDate: endDate,
  253. // RealEndDate: realEndDate,
  254. // IsStop: isStop,
  255. // CreateTime: v.CreateTime,
  256. // }
  257. // err = company.AddCompanyProductTryOutUpdateLog(companyProductTryOutUpdateLogItem, permissionList)
  258. // }
  259. // fmt.Println("结束")
  260. //}
  261. // FixCompanyTryDay 修复试用天数
  262. //func FixCompanyTryDay() {
  263. // list, err := company.GetCompanyProductTryOutUpdateGroup()
  264. // if err != nil {
  265. // fmt.Println("获取客户变更数据失败:", err)
  266. // return
  267. // }
  268. //
  269. // lenList := len(list)
  270. // for k, v := range list {
  271. // fmt.Println("剩余", lenList-k-1, "条数据修复")
  272. // companyProduct, tmpErr := company.GetCompanyProductByCompanyIdAndProductId(v.CompanyId, v.ProductId)
  273. // if tmpErr != nil {
  274. // fmt.Println("company_id:", v.CompanyId, ";product_id:", v.ProductId, ";找不到对应的客户,Err:", tmpErr)
  275. // continue
  276. // }
  277. //
  278. // logList, err := company.GetCompanyProductTryOutUpdateList(v.CompanyId, v.ProductId)
  279. // if err != nil {
  280. // fmt.Println("查找客户日志失败,err:", err)
  281. // continue
  282. // }
  283. //
  284. // //lenLog := len(logList)
  285. // var day int //实际试用天数
  286. // var endDate time.Time
  287. // for _, log := range logList {
  288. // startDate := log.StartDate
  289. // if endDate.IsZero() {
  290. // endDate = log.RealEndDate
  291. // day = utils.GetTimeSubDay(startDate, log.RealEndDate) + 1
  292. // } else {
  293. // if log.RealEndDate.After(endDate) {
  294. // if endDate.After(startDate) {
  295. // startDate = endDate
  296. // }
  297. // if startDate.Equal(log.EndDate) {
  298. // day += utils.GetTimeSubDay(startDate, log.RealEndDate)
  299. // } else {
  300. // day += utils.GetTimeSubDay(startDate, log.RealEndDate) + 1
  301. // }
  302. // endDate = log.RealEndDate
  303. // }
  304. // }
  305. // }
  306. // companyProduct.TryOutDayTotal = day
  307. // companyProduct.Update([]string{"TryOutDayTotal"})
  308. // }
  309. // fmt.Println("结束")
  310. //}
  311. // StaticCompanyTryDay 定时任务每天更新试用天数
  312. //func StaticCompanyTryDay() {
  313. // list, err := company.GetCompanyProductTryOutUpdateNoStopGroup()
  314. // if err != nil {
  315. // fmt.Println("获取客户变更数据失败:", err)
  316. // return
  317. // }
  318. //
  319. // lenList := len(list)
  320. // for k, v := range list {
  321. // isAdd := false //是否要增加一天,默认不加
  322. // fmt.Println("剩余", lenList-k-1, "条数据修复")
  323. // permissionList, tmpErr := company.GetCompanyReportPermissionByStatus(v.CompanyId, v.ProductId, "试用")
  324. // if tmpErr == nil {
  325. // fmt.Println("company_id:", v.CompanyId, ";product_id:", v.ProductId, ";寻找对应的试用品种失败,Err:", tmpErr)
  326. // continue
  327. // }
  328. // currPermissionIdList := make([]int, 0) //当前试用的品种
  329. // for _, permission := range permissionList {
  330. // currPermissionIdList = append(currPermissionIdList, permission.ChartPermissionId)
  331. // }
  332. //
  333. // //获取所有未停止的记录列表
  334. // logList, err := company.GetCompanyProductTryOutUpdateNoStopListByEndDate(v.CompanyId, v.ProductId)
  335. // if err != nil {
  336. // fmt.Println("查找客户日志失败,err:", err)
  337. // continue
  338. // }
  339. //
  340. // logPermissionIdList := make([]int, 0) //当前日志中的试用的品种
  341. // for _, log := range logList {
  342. // //获取所有未停止的品种试用记录列表
  343. // logPermissionList, tmpErr := company.GetCompanyProductTryOutPermissionUpdateNoStopListByEndDate(log.Id)
  344. // if tmpErr != nil {
  345. // fmt.Println("查找客户品种变更日志失败,err:", tmpErr)
  346. // continue
  347. // }
  348. // lenLogPermissionList := len(logPermissionList) //当前日志存在试用的品种数量
  349. // stopPermission := 0 //当前日志需要停止的品种数量
  350. //
  351. // currTime := time.Now() //当前时间
  352. // for _, logPermission := range logPermissionList {
  353. // if utils.InArrayByInt(logPermissionIdList, logPermission.ChartPermissionId) {
  354. // // 如果已经被其他记录使用了,那么就将当前记录给标记停止
  355. // logPermission.IsStop = 1
  356. //
  357. // // 如果当前时间晚于结束日期,那么实际结束日期就是今天之前一天,否则就是当天
  358. // if currTime.After(logPermission.EndDate) {
  359. // logPermission.RealEndDate = currTime.AddDate(0, 0, -1)
  360. // } else {
  361. // logPermission.RealEndDate = time.Now()
  362. // }
  363. // logPermission.Update([]string{"IsStop", "RealEndDate"})
  364. // stopPermission++
  365. // continue
  366. // } else if !utils.InArrayByInt(currPermissionIdList, logPermission.ChartPermissionId) {
  367. // // 如果该品种不在当前客户的品种里面,那么也要将当前记录给标记停止
  368. // logPermission.IsStop = 1
  369. // // 如果当前时间晚于结束日期,那么实际结束日期就是今天之前一天,否则就是当天
  370. // if currTime.After(logPermission.EndDate) {
  371. // logPermission.RealEndDate = currTime.AddDate(0, 0, -1)
  372. // } else {
  373. // logPermission.RealEndDate = time.Now()
  374. // }
  375. // logPermission.Update([]string{"IsStop", "RealEndDate"})
  376. // stopPermission++
  377. // continue
  378. // }
  379. //
  380. // // 剩下的说明还处于试用状态,需要添加1天试用期,且需要把该品种加入到当前日志中的试用的品种列表
  381. // isAdd = true
  382. // logPermissionIdList = append(logPermissionIdList, logPermission.ChartPermissionId)
  383. // }
  384. //
  385. // //如果当前日志存在试用的品种数量 == 当前日志需要停止的品种数量
  386. // // 那么当前日志也是处于停用状态
  387. // if lenLogPermissionList == stopPermission {
  388. // log.IsStop = 1
  389. // // 如果当前时间晚于结束日期,那么实际结束日期就是今天之前一天,否则就是当天
  390. // if currTime.After(log.EndDate) {
  391. // log.RealEndDate = currTime.AddDate(0, 0, -1)
  392. // } else {
  393. // log.RealEndDate = time.Now()
  394. // }
  395. // log.Update([]string{"IsStop", "RealEndDate"})
  396. // }
  397. //
  398. // }
  399. //
  400. // // 如果需要添加,那么将该客户品种添加1天
  401. // if isAdd {
  402. //
  403. // }
  404. // // 更新客户产品的试用天数
  405. // tmpErr = company.AddCompanyProductTryOutDayTotal(v.CompanyId, v.ProductId)
  406. // if tmpErr != nil {
  407. // fmt.Println("company_id:", v.CompanyId, ";product_id:", v.ProductId, ";更新客户产品的试用天数,Err:", tmpErr)
  408. // continue
  409. // }
  410. // }
  411. // fmt.Println("结束")
  412. //}
  413. //func Task2() {
  414. // fmt.Println("task start")
  415. //
  416. // //_, _ = maycur.GetPublicOfferingSaleLeader()
  417. // //_ = maycur.TestSyncCompanyProfile()
  418. // //_ = maycur.SyncCompanyProfile()
  419. // //_ = maycur.ImportExcelEmployeeId()
  420. // //_ = maycur.ApiTest()
  421. // //_ = maycur.ApiTest2()
  422. // fmt.Println("task end")
  423. //}
  424. // FixEnCompanyPermission 英文权限上线时修复英文客户拥有所有权限(一次性)
  425. func FixEnCompanyPermission() {
  426. var err error
  427. defer func() {
  428. if err != nil {
  429. fmt.Println("FixEnCompanyPermission Err: ", err.Error())
  430. }
  431. }()
  432. // 获取正式客户
  433. companies := make([]*models.EnglishCompany, 0)
  434. {
  435. cond := ` AND status = ?`
  436. pars := make([]interface{}, 0)
  437. pars = append(pars, 1)
  438. list, e := models.GetEnglishCompanyList(cond, pars, "")
  439. if e != nil {
  440. err = fmt.Errorf("GetEnglishCompanyList err: %s", e.Error())
  441. return
  442. }
  443. companies = list
  444. }
  445. // 获取所有权限
  446. permissions := make([]*models.EnPermission, 0)
  447. {
  448. cond := ` AND parent_id > ?`
  449. pars := make([]interface{}, 0)
  450. pars = append(pars, 0)
  451. ob := new(models.EnPermission)
  452. list, e := ob.GetItemsByCondition(cond, pars, []string{}, "")
  453. if e != nil {
  454. err = fmt.Errorf("GetPermissionItemsByCondition err: %s", e.Error())
  455. return
  456. }
  457. permissions = list
  458. }
  459. for _, c := range companies {
  460. ps := make([]*models.EnCompanyPermission, 0)
  461. for _, p := range permissions {
  462. ps = append(ps, &models.EnCompanyPermission{
  463. EnCompanyId: c.CompanyId,
  464. EnPermissionId: p.EnPermissionId,
  465. CreateTime: time.Now().Local(),
  466. })
  467. }
  468. if e := models.ClearAndCreateEnCompanyPermissions(c.CompanyId, ps); e != nil {
  469. err = fmt.Errorf("ClearAndCreateEnCompanyPermissions err: %s", e.Error())
  470. return
  471. }
  472. }
  473. fmt.Println("修复完成")
  474. }
  475. // ModifyEsEnglishReport 批量修改es里的英文研报信息和线上路演信息
  476. func ModifyEsEnglishReport() {
  477. fmt.Println("开始")
  478. err := ModifyAllEsEnglishReportVideo()
  479. if err != nil {
  480. err = fmt.Errorf("重置es中的英文研报信息失败:ModifyAllEnglishReportInEs err: %s", err.Error())
  481. return
  482. }
  483. fmt.Println("结束")
  484. }
  485. //func InsertBloombergIndex() {
  486. // fmt.Println("开始写入")
  487. //
  488. // start := 100000
  489. // now := time.Now()
  490. // for i := 1; i <= 100; i++ {
  491. // fmt.Printf("写入第%d个\n", i)
  492. //
  493. // start += 1
  494. // index := new(data_manage.BaseFromBloombergIndex)
  495. // index.IndexCode = fmt.Sprintf("BLID%d", start)
  496. // index.IndexName = fmt.Sprintf("模拟Bloomberg-%s", index.IndexCode)
  497. // index.Unit = "无"
  498. // index.Source = utils.DATA_SOURCE_BLOOMBERG
  499. // index.Frequency = "日度"
  500. // index.StartDate = now.AddDate(0, 0, -i)
  501. // index.EndDate = now
  502. // index.CreateTime = time.Now().Local()
  503. // index.ModifyTime = time.Now().Local()
  504. // if e := index.Create(); e != nil {
  505. // fmt.Printf("新增指标失败, IndexCode: %s, err: %s", index.IndexCode, e.Error())
  506. // return
  507. // }
  508. //
  509. // insertData := make([]*data_manage.BaseFromBloombergData, 0)
  510. // for ii := 0; ii <= 50; ii++ {
  511. // indexData := new(data_manage.BaseFromBloombergData)
  512. // indexData.BaseFromBloombergIndexId = index.BaseFromBloombergIndexId
  513. // indexData.IndexCode = index.IndexCode
  514. // indexData.DataTime = now.AddDate(0, 0, -ii)
  515. // va := GenerateRandomFloat64InRange()
  516. // va += float64(ii)
  517. // indexData.Value = va
  518. // indexData.CreateTime = time.Now().Local()
  519. // indexData.ModifyTime = time.Now().Local()
  520. // indexData.DataTimestamp = int(indexData.DataTime.UnixNano() / 1e6)
  521. // insertData = append(insertData, indexData)
  522. // }
  523. // ob := new(data_manage.BaseFromBloombergData)
  524. // if e := ob.CreateMulti(insertData); e != nil {
  525. // fmt.Printf("新增指标数据失败, IndexCode: %s, err: %s", index.IndexCode, e.Error())
  526. // return
  527. // }
  528. // }
  529. //
  530. // fmt.Println("结束写入")
  531. //}
  532. //
  533. //func GenerateRandomFloat64InRange() float64 {
  534. // var rnd = rand.New(rand.NewSource(time.Now().UnixNano())) // 设置随机数种子
  535. //
  536. // return rnd.Float64()*11000 - 1000
  537. //}