fs_qw_task_sys_job_seed.sql 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. -- fs-qw-task 迁移至 fs-task 后的 sys_job_template 种子数据
  2. -- scope=TENANT(租户级任务);module_tag=QW_TASK(对应原 job_group)
  3. -- default_status=1 表示新租户默认暂停,需总后台手动开启后同步;status=0 表示模板启用
  4. -- invoke_target 须与 fs-task 模块 Spring Bean 方法一致
  5. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  6. SELECT 'qw.checkSopRuleTime', '企微-SOP规则检查', 'QW_TASK', 'qwTask.qwCheckSopRuleTime()', '0 10 1 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 10 1 * * ?'
  7. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.checkSopRuleTime');
  8. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  9. SELECT 'qw.addTag', '企微-客户打标签', 'QW_TASK', 'qwTask.addTag()', '0 0/20 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 0/20 * * * ?'
  10. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.addTag');
  11. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  12. SELECT 'qw.selectSopUserLogs', '企微-营期生成SOP日志', 'QW_TASK', 'qwTask.selectSopUserLogsListByTime()', '0 5 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 5 * * * ?'
  13. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.selectSopUserLogs');
  14. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  15. SELECT 'qw.wxSop', '企微-微信SOP处理', 'QW_TASK', 'qwTask.wxSop()', '0 5 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 5 * * * ?'
  16. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.wxSop');
  17. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  18. SELECT 'qw.sendQwApiSopLog', '企微-官方接口群发(单链)', 'QW_TASK', 'qwTask.SendQwApiSopLogTimer()', '0 20 1 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 20 1 * * ?'
  19. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.sendQwApiSopLog');
  20. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  21. SELECT 'qw.sendQwApiSopLogNew', '企微-官方接口群发(新版)', 'QW_TASK', 'qwTask.SendQwApiSopLogTimerNew()', '0 10 0,1 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 10 0,1 * * ?'
  22. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.sendQwApiSopLogNew');
  23. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  24. SELECT 'qw.getQwApiSopLogResult', '企微-获取群发结果', 'QW_TASK', 'qwTask.GetQwApiSopLogResultTimerNew()', '0 0 8 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 0 8 * * ?'
  25. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.getQwApiSopLogResult');
  26. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  27. SELECT 'qw.sendQwGroupMsg', '企微-客户群发处理', 'QW_TASK', 'qwTask.sendQwGroupMsgTask()', '0 0/10 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 0/10 * * * ?'
  28. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.sendQwGroupMsg');
  29. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  30. SELECT 'qw.sendQwBySop', '企微-发送转换消息', 'QW_TASK', 'qwTask.sendQwBySop()', '0 0 8 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 0 8 * * ?'
  31. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.sendQwBySop');
  32. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  33. SELECT 'qw.externalErrRetry', '企微-标签备注补偿', 'QW_TASK', 'qwTask.qwExternalErrRetryTimer()', '0 0/3 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 0/3 * * * ?'
  34. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.externalErrRetry');
  35. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  36. SELECT 'qw.updateSopLogsByCancel', '企微-补发过期完课消息', 'QW_TASK', 'qwTask.updateQwSopLogsByCancel()', '0 0 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 0 * * * ?'
  37. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.updateSopLogsByCancel');
  38. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  39. SELECT 'qw.batchProcessingExpired', '企微-批量处理过期消息', 'QW_TASK', 'qwTask.batchProcessingExpiredMessages()', '0 0/8 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 0/8 * * * ?'
  40. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.batchProcessingExpired');
  41. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  42. SELECT 'qw.deleteSopLogsByDate', '企微-清理历史SOP日志', 'QW_TASK', 'qwTask.deleteQwSopLogsByDate()', '0 10 0 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 10 0 * * ?'
  43. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.deleteSopLogsByDate');
  44. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  45. SELECT 'qw.processRepairSopLogs', '企微-修复营期异常数据', 'QW_TASK', 'qwTask.processRepairQwSopLogsTimer()', '0 30 0/3 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 30 0/3 * * ?'
  46. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.processRepairSopLogs');
  47. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  48. SELECT 'qw.processIsDaysNotStudy', '企微-E级未看课恢复', 'QW_TASK', 'qwTask.processSopUserLogsInfoByIsDaysNotStudy()', '0 35 2 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 35 2 * * ?'
  49. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.processIsDaysNotStudy');
  50. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  51. SELECT 'qw.externalContactRating', '企微-客户分级评级', 'QW_TASK', 'qwTask.processQwSopExternalContactRatingTimer()', '0 45 3 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 45 3 * * ?'
  52. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.externalContactRating');
  53. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  54. SELECT 'qw.ratingMoreSevenDays', '企微-超7天未看课标E级', 'QW_TASK', 'qwTask.processQwSopExternalContactRatingMoreSevenDaysTimer()', '0 30 3 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 30 3 * * ?'
  55. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.ratingMoreSevenDays');
  56. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  57. SELECT 'qw.updateSopLogsDayBefore', '企微-更新前一天待发送', 'QW_TASK', 'qwTask.updateQwSopLogsDayBefore()', '0 3 0 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 3 0 * * ?'
  58. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.updateSopLogsDayBefore');
  59. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  60. SELECT 'qw.updateExternalUnionid', '企微-同步外部联系人UnionId', 'QW_TASK', 'qwTask.updateQwExternalContactUnionid()', '0 1 0 */2 * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 1 0 */2 * ?'
  61. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.updateExternalUnionid');
  62. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  63. SELECT 'qw.autoPullGroup', '企微-自动拉人进群', 'QW_TASK', 'qwTask.autoPullGroup()', '0 0 16 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 qwTask @Scheduled 0 0 16 * * ?'
  64. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.autoPullGroup');
  65. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  66. SELECT 'course.checkWatchStatus', '看课-检查看课状态', 'QW_TASK', 'courseWatchLogScheduler.checkWatchStatus()', '0 0/1 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 fixedRate 60000,用 cron 近似每分钟'
  67. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'course.checkWatchStatus');
  68. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  69. SELECT 'course.createCourseFinishMsg', '看课-创建完课消息', 'QW_TASK', 'courseWatchLogScheduler.createCourseFinishMsg()', '0 0/5 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 fixedRate 300000,用 cron 近似每5分钟'
  70. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'course.createCourseFinishMsg');
  71. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  72. SELECT 'course.delCourseExpireLink', '看课-删除过期短链', 'QW_TASK', 'courseWatchLogScheduler.delCourseExpireLink()', '0 0 0 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 CourseWatchLogScheduler @Scheduled 0 0 0 * * ?'
  73. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'course.delCourseExpireLink');
  74. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  75. SELECT 'qw.syncQwUser', '企微-同步企微员工', 'QW_TASK', 'qwUserAsyncTask.syncQwUserAsync()', '0 0 0/3 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 QwUserAsyncTask @Scheduled 0 0 0/3 * * ?'
  76. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.syncQwUser');
  77. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  78. SELECT 'course.userCourseCount', '看课-会员看课统计', 'QW_TASK', 'userCourseWatchCountTask.userCourseCountTask()', '0 */20 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 UserCourseWatchCountTask @Scheduled 0 */20 * * * ?'
  79. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'course.userCourseCount');
  80. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  81. SELECT 'sop.refreshCourseConfig', '看课-刷新课程配置缓存', 'QW_TASK', 'sopLogsTaskServiceImpl.refreshCourseConfig()', '0 0/1 * * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 SopLogsTaskServiceImpl fixedDelay 60000'
  82. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'sop.refreshCourseConfig');
  83. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  84. SELECT 'qw.refreshRatingConfig', '企微-刷新评级配置', 'QW_TASK', 'qwExternalContactRatingServiceImpl.refreshRatingConfig()', '0 50 0/6 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 QwExternalContactRatingServiceImpl @Scheduled'
  85. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.refreshRatingConfig');
  86. INSERT INTO sys_job_template (template_code, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, scope, module_tag, default_status, status, create_by, create_time, remark)
  87. SELECT 'qw.refreshRatingMoreSeven', '企微-刷新超7天评级配置', 'QW_TASK', 'qwExternalContactRatingMoreSevenDaysServiceImpl.refreshRatingConfig()', '0 50 0/6 * * ?', '3', '1', 'TENANT', 'QW_TASK', '1', '0', 'admin', NOW(), '原 QwExternalContactRatingMoreSevenDaysServiceImpl @Scheduled'
  88. WHERE NOT EXISTS (SELECT 1 FROM sys_job_template WHERE template_code = 'qw.refreshRatingMoreSeven');
  89. -- 备注:selectChatSopUserLogsListByTime 原 @Scheduled 已注释,未写入
  90. -- 备注:checkFsUserWatchStatus(fixedRate 30s) 未迁移至 fs-task,未写入