init

db/20260824-调度服务迁移.sql

@@ -0,0 +1,373 @@
+CREATE TABLE quartz_job_details
+(
+    SCHED_NAME        VARCHAR(120) NOT NULL,
+    JOB_NAME          VARCHAR(190) NOT NULL,
+    JOB_GROUP         VARCHAR(190) NOT NULL,
+    DESCRIPTION       VARCHAR(250) NULL,
+    JOB_CLASS_NAME    VARCHAR(250) NOT NULL,
+    IS_DURABLE        VARCHAR(1)   NOT NULL,
+    IS_NONCONCURRENT  VARCHAR(1)   NOT NULL,
+    IS_UPDATE_DATA    VARCHAR(1)   NOT NULL,
+    REQUESTS_RECOVERY VARCHAR(1)   NOT NULL,
+    JOB_DATA          BLOB NULL,
+    PRIMARY KEY (SCHED_NAME, JOB_NAME, JOB_GROUP)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_triggers
+(
+    SCHED_NAME     VARCHAR(120) NOT NULL,
+    TRIGGER_NAME   VARCHAR(190) NOT NULL,
+    TRIGGER_GROUP  VARCHAR(190) NOT NULL,
+    JOB_NAME       VARCHAR(190) NOT NULL,
+    JOB_GROUP      VARCHAR(190) NOT NULL,
+    DESCRIPTION    VARCHAR(250) NULL,
+    NEXT_FIRE_TIME BIGINT(13) NULL,
+    PREV_FIRE_TIME BIGINT(13) NULL,
+    PRIORITY       INTEGER NULL,
+    TRIGGER_STATE  VARCHAR(16)  NOT NULL,
+    TRIGGER_TYPE   VARCHAR(8)   NOT NULL,
+    START_TIME     BIGINT(13) NOT NULL,
+    END_TIME       BIGINT(13) NULL,
+    CALENDAR_NAME  VARCHAR(190) NULL,
+    MISFIRE_INSTR  SMALLINT(2) NULL,
+    JOB_DATA       BLOB NULL,
+    PRIMARY KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
+    FOREIGN KEY (SCHED_NAME, JOB_NAME, JOB_GROUP) REFERENCES quartz_job_details (SCHED_NAME, JOB_NAME, JOB_GROUP)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_simple_triggers
+(
+    SCHED_NAME      VARCHAR(120) NOT NULL,
+    TRIGGER_NAME    VARCHAR(190) NOT NULL,
+    TRIGGER_GROUP   VARCHAR(190) NOT NULL,
+    REPEAT_COUNT    BIGINT(7) NOT NULL,
+    REPEAT_INTERVAL BIGINT(12) NOT NULL,
+    TIMES_TRIGGERED BIGINT(10) NOT NULL,
+    PRIMARY KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
+    FOREIGN KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) REFERENCES quartz_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_cron_triggers
+(
+    SCHED_NAME      VARCHAR(120) NOT NULL,
+    TRIGGER_NAME    VARCHAR(190) NOT NULL,
+    TRIGGER_GROUP   VARCHAR(190) NOT NULL,
+    CRON_EXPRESSION VARCHAR(120) NOT NULL,
+    TIME_ZONE_ID    VARCHAR(80),
+    PRIMARY KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
+    FOREIGN KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) REFERENCES quartz_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_simprop_triggers
+(
+    SCHED_NAME    VARCHAR(120) NOT NULL,
+    TRIGGER_NAME  VARCHAR(190) NOT NULL,
+    TRIGGER_GROUP VARCHAR(190) NOT NULL,
+    STR_PROP_1    VARCHAR(512) NULL,
+    STR_PROP_2    VARCHAR(512) NULL,
+    STR_PROP_3    VARCHAR(512) NULL,
+    INT_PROP_1    INT NULL,
+    INT_PROP_2    INT NULL,
+    LONG_PROP_1   BIGINT NULL,
+    LONG_PROP_2   BIGINT NULL,
+    DEC_PROP_1    NUMERIC(13, 4) NULL,
+    DEC_PROP_2    NUMERIC(13, 4) NULL,
+    BOOL_PROP_1   VARCHAR(1) NULL,
+    BOOL_PROP_2   VARCHAR(1) NULL,
+    PRIMARY KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
+    FOREIGN KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) REFERENCES quartz_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_blob_triggers
+(
+    SCHED_NAME    VARCHAR(120) NOT NULL,
+    TRIGGER_NAME  VARCHAR(190) NOT NULL,
+    TRIGGER_GROUP VARCHAR(190) NOT NULL,
+    BLOB_DATA     BLOB NULL,
+    PRIMARY KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP),
+    FOREIGN KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) REFERENCES quartz_triggers (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_calendars
+(
+    SCHED_NAME    VARCHAR(120) NOT NULL,
+    CALENDAR_NAME VARCHAR(190) NOT NULL,
+    CALENDAR      BLOB         NOT NULL,
+    PRIMARY KEY (SCHED_NAME, CALENDAR_NAME)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_paused_trigger_grps
+(
+    SCHED_NAME    VARCHAR(120) NOT NULL,
+    TRIGGER_GROUP VARCHAR(190) NOT NULL,
+    PRIMARY KEY (SCHED_NAME, TRIGGER_GROUP)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_fired_triggers
+(
+    SCHED_NAME        VARCHAR(120) NOT NULL,
+    ENTRY_ID          VARCHAR(95)  NOT NULL,
+    TRIGGER_NAME      VARCHAR(190) NOT NULL,
+    TRIGGER_GROUP     VARCHAR(190) NOT NULL,
+    INSTANCE_NAME     VARCHAR(190) NOT NULL,
+    FIRED_TIME        BIGINT(13) NOT NULL,
+    SCHED_TIME        BIGINT(13) NOT NULL,
+    PRIORITY          INTEGER      NOT NULL,
+    STATE             VARCHAR(16)  NOT NULL,
+    JOB_NAME          VARCHAR(190) NULL,
+    JOB_GROUP         VARCHAR(190) NULL,
+    IS_NONCONCURRENT  VARCHAR(1) NULL,
+    REQUESTS_RECOVERY VARCHAR(1) NULL,
+    PRIMARY KEY (SCHED_NAME, ENTRY_ID)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_scheduler_state
+(
+    SCHED_NAME        VARCHAR(120) NOT NULL,
+    INSTANCE_NAME     VARCHAR(190) NOT NULL,
+    LAST_CHECKIN_TIME BIGINT(13) NOT NULL,
+    CHECKIN_INTERVAL  BIGINT(13) NOT NULL,
+    PRIMARY KEY (SCHED_NAME, INSTANCE_NAME)
+) ENGINE=InnoDB;
+
+CREATE TABLE quartz_locks
+(
+    SCHED_NAME VARCHAR(120) NOT NULL,
+    LOCK_NAME  VARCHAR(40)  NOT NULL,
+    PRIMARY KEY (SCHED_NAME, LOCK_NAME)
+) ENGINE=InnoDB;
+
+INSERT INTO sys_job (job_name,
+                     job_group,
+                     job_order,
+                     job_type,
+                     execute_path,
+                     method_name,
+                     method_params_value,
+                     cron_expression,
+                     misfire_policy,
+                     job_tenant_type,
+                     job_status,
+                     remark,
+                     create_by,
+                     create_time)
+VALUES ('任务图片排重结果同步',
+        'image_sync_group',
+        '5',
+        '3',
+        'http://hnqz-upms-biz/schedule/common/sync-task-image-audit',
+        NULL,
+        NULL,
+        '0 */10 * * * ?',
+        '1',
+        '2',
+        '2',
+        '从 @Scheduled 迁移，图片排重结果从 vector-search 增量同步到本地库',
+        'admin',
+        NOW()),
+       ('结算平台和税源地数据同步',
+        'settlement_sync_group',
+        '5',
+        '3',
+        'http://hnqz-upms-biz/schedule/common/sync-settlement',
+        NULL,
+        NULL,
+        '0 */10 * * * ?',
+        '1',
+        '2',
+        '2',
+        '从 @Scheduled 迁移，同步结算平台、税源地、税源地发票数据',
+        'admin',
+        NOW()),
+       ('GIG签约回调处理',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/callback-sign',
+        NULL,
+        NULL,
+        '0/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        'GIG签约回调处理',
+        'admin',
+        NOW()),
+       ('GIG结算回调处理',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/callback-settle',
+        NULL,
+        NULL,
+        '1/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        'GIG结算回调处理',
+        'admin',
+        NOW()),
+       ('GIG结算步骤重试',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/settle-step-retry',
+        NULL,
+        NULL,
+        '2/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        'GIG结算步骤重试',
+        'admin',
+        NOW()),
+       ('产才易任务审核确认',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/szzgxs-task-audit-confirm',
+        NULL,
+        NULL,
+        '3/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        '产才易任务审核确认',
+        'admin',
+        NOW()),
+       ('产才易签约结果确认',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/szzgxs-sign-result-confirm',
+        NULL,
+        NULL,
+        '4/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        '产才易签约结果确认',
+        'admin',
+        NOW()),
+       ('合创优选林朗签约结果确认',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/hczylxlw-sign-result-confirm',
+        NULL,
+        NULL,
+        '5/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        '合创优选林朗签约结果确认',
+        'admin',
+        NOW()),
+       ('合创优选林朗结算结果确认',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/hczylxlw-settle-result-confirm',
+        NULL,
+        NULL,
+        '6/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        '合创优选林朗结算结果确认',
+        'admin',
+        NOW()),
+       ('BossKg签约结果确认',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/bosskgyjb-sign-result-confirm',
+        NULL,
+        NULL,
+        '7/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        'BossKg签约结果确认',
+        'admin',
+        NOW()),
+       ('芜湖金浩结算结果确认',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/wuhujinhao-settle-result-confirm',
+        NULL,
+        NULL,
+        '8/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        '芜湖金浩结算结果确认',
+        'admin',
+        NOW()),
+       ('平台申请通知',
+        'gig_group',
+        '5',
+        '3',
+        'http://gulop-gig-biz/gig/schedule/notify-platform-application',
+        NULL,
+        NULL,
+        '9/10 * * * * ?',
+        '1',
+        '2',
+        '2',
+        '平台申请通知',
+        'admin',
+        NOW());
+
+-- 2. 执行迁移：更新 job_type 为 REST(3)，设置对应的 execute_path
+UPDATE sys_job
+SET job_type     = '3',
+    execute_path = CASE method_name
+                       WHEN 'dailyGMVsStatistic'
+                           THEN 'http://hnqz-upms-biz/schedule/statistics/daily-gmvs-statistic'
+                       WHEN 'setHotArtileTask'
+                           THEN 'http://hnqz-upms-biz/schedule/article/set-hot-article'
+                       WHEN 'singleMemberSettleSameAmountInSeveralMonths'
+                           THEN 'http://hnqz-upms-biz/schedule/risk/single-member-settle-same-amount'
+                       WHEN 'singleMemberSettleAmountOverrunInSeveralMonths'
+                           THEN 'http://hnqz-upms-biz/schedule/risk/single-member-settle-amount-overrun'
+                       WHEN 'singleEnterpriseSettleSameAmountForSeveralMembersInCurrentMonth'
+                           THEN 'http://hnqz-upms-biz/schedule/risk/single-enterprise-settle-same-amount'
+                       WHEN 'singleMemberWithoutSuchTaskTypesInSeveralMonths'
+                           THEN 'http://hnqz-upms-biz/schedule/risk/single-member-without-task-types'
+                       WHEN 'sendCurrentDaySettleDataToDeptDaily'
+                           THEN 'http://hnqz-upms-biz/schedule/task/send-settle-data-to-dept'
+                       WHEN 'sendFxyApply'
+                           THEN 'http://hnqz-upms-biz/schedule/promotion/send-fxy-apply'
+                       WHEN 'sendPromotionRecord'
+                           THEN 'http://hnqz-upms-biz/schedule/promotion/send-promotion-record'
+                       WHEN 'batchUpdatePackageStatus'
+                           THEN 'http://hnqz-upms-biz/schedule/task/batch-update-package-status'
+                       WHEN 'refreshFinalReviewScoreForSettlement'
+                           THEN 'http://hnqz-upms-biz/schedule/task/refresh-final-review-score'
+                       WHEN 'asignPullFacePhoto'
+                           THEN 'http://gulop-gig-biz/gig/cert/pull-face-img'
+                       ELSE execute_path
+        END,
+    -- REST 模式不需要 className 和 methodName，清空
+    class_name   = NULL,
+    method_name  = NULL,
+    update_by    = 'admin',
+    update_time  = NOW()
+WHERE job_type = '2'
+  AND class_name = 'demo'
+  AND method_name IN (
+                      'dailyGMVsStatistic',
+                      'setHotArtileTask',
+                      'singleMemberSettleSameAmountInSeveralMonths',
+                      'singleMemberSettleAmountOverrunInSeveralMonths',
+                      'singleEnterpriseSettleSameAmountForSeveralMembersInCurrentMonth',
+                      'singleMemberWithoutSuchTaskTypesInSeveralMonths',
+                      'sendCurrentDaySettleDataToDeptDaily',
+                      'sendFxyApply',
+                      'sendPromotionRecord',
+                      'batchUpdatePackageStatus',
+                      'refreshFinalReviewScoreForSettlement',
+                      'asignPullFacePhoto'
+    );

src/main/java/net/yyc/quartz/feign/RemoteInnerSignApiService.java

@@ -1,25 +0,0 @@
-package net.yyc.quartz.feign;
-
-import net.yyc.common.core.constant.SecurityConstants;
-import net.yyc.common.core.constant.ServiceNameConstants;
-import org.springframework.cloud.openfeign.FeignClient;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RequestHeader;
-
-/**
- * 爱签内部API Feign服务
- */
-@FeignClient(contextId = "remoteInnerSignApiService", value = ServiceNameConstants.UPMS_SERVICE)
-public interface RemoteInnerSignApiService {
-
-    /**
-     * 爱签人脸截图拉取任务
-     *
-     * @param params 参数
-     * @param from 调用来源
-     * @return 执行结果
-     */
-    @GetMapping("/inner-sign-api/asign-pull-face-photo-job")
-    String asignPullFacePhotoJob(@RequestParam("params") String params, @RequestHeader(value = SecurityConstants.FROM, required = false) String from);
-}

src/main/java/net/yyc/quartz/feign/RemoteScheduleTaskService.java

@@ -1,82 +0,0 @@
-package net.yyc.quartz.feign;
-
-import net.yyc.common.core.constant.SecurityConstants;
-import net.yyc.common.core.constant.ServiceNameConstants;
-import net.yyc.common.core.util.R;
-import org.springframework.cloud.openfeign.FeignClient;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestHeader;
-import org.springframework.web.bind.annotation.RequestParam;
-
-/**
- * 调度任务 Feign 服务
- */
-@FeignClient(contextId = "remoteScheduleTaskService", value = ServiceNameConstants.UPMS_SERVICE)
-public interface RemoteScheduleTaskService {
-
-    /**
-     * 每日GMV统计
-     */
-    @PostMapping("/schedule/statistics/daily-gmvs-statistic")
-    R<String> dailyGMVsStatistic(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 设置热门文章
-     */
-    @PostMapping("/schedule/article/set-hot-article")
-    R<String> setHotArticle(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 单会员多月相同金额检测
-     */
-    @PostMapping("/schedule/risk/single-member-settle-same-amount")
-    R<String> singleMemberSettleSameAmount(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 单会员多月超限检测
-     */
-    @PostMapping("/schedule/risk/single-member-settle-amount-overrun")
-    R<String> singleMemberSettleAmountOverrun(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 企业向多人支付相同金额检测
-     */
-    @PostMapping("/schedule/risk/single-enterprise-settle-same-amount")
-    R<String> singleEnterpriseSettleSameAmount(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 单会员多月无指定任务类型检测
-     */
-    @PostMapping("/schedule/risk/single-member-without-task-types")
-    R<String> singleMemberWithoutTaskTypes(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 刷新已结算积分包的任务终审积分
-     */
-    @PostMapping("/schedule/task/refresh-final-review-score")
-    R<String> refreshFinalReviewScoreForSettlement(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 发送当日结算数据给企业邮箱
-     */
-    @PostMapping("/schedule/task/send-settle-data-to-dept")
-    R<String> sendCurrentDaySettleDataToDept(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 发送锋信易申请数据给企业邮箱
-     */
-    @PostMapping("/schedule/promotion/send-fxy-apply")
-    R<String> sendFxyApply(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 发送推广点击记录给企业邮箱
-     */
-    @PostMapping("/schedule/promotion/send-promotion-record")
-    R<String> sendPromotionRecord(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-
-    /**
-     * 批量更新过期积分包状态
-     */
-    @PostMapping("/schedule/task/batch-update-package-status")
-    R<String> batchUpdatePackageStatus(@RequestParam("params") String params, @RequestHeader(SecurityConstants.FROM) String from);
-}

src/main/java/net/yyc/quartz/task/SpringBeanTaskDemo.java

@@ -1,250 +0,0 @@
- /*
- *    Copyright (c) 2018-2025, hnqz All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the pig4cloud.com developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: hnqz
- */
-
-package net.yyc.quartz.task;
-
-
-import net.yyc.quartz.feign.RemoteInnerSignApiService;
-import net.yyc.quartz.feign.RemoteScheduleTaskService;
-import net.yyc.quartz.constants.QuartzEnum;
-import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
-import net.yyc.common.core.constant.SecurityConstants;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-
-/**
- * @author 郑健楠
- */
-@Slf4j
-@Component("demo")
-public class SpringBeanTaskDemo {
-    @Resource
-    private RemoteScheduleTaskService remoteScheduleTaskService;
-    @Resource
-    private RemoteInnerSignApiService remoteInnerSignApiService;
-
-    @Deprecated
-    @SneakyThrows
-    public String changePackageStatusTask(String para) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=changePackageStatusTask params={}", para);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @Deprecated
-    @SneakyThrows
-    public String getArtileTask(String para) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=getArtileTask params={}", para);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @Deprecated
-    @SneakyThrows
-    public String changeTaskRule(String para) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=changeTaskRule params={}", para);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @Deprecated
-    @SneakyThrows
-    public String buildTaskImg(String para) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=buildTaskImg params={}", para);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    /**
-     * 每日GMVs统计
-     *
-     * @param para
-     * @return
-     */
-    @SneakyThrows
-    public String dailyGMVsStatistic(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=dailyGMVsStatistic params={}", para);
-        remoteScheduleTaskService.dailyGMVsStatistic(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=dailyGMVsStatistic");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @SneakyThrows
-    public String setHotArtileTask(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=setHotArtileTask params={}", para);
-        remoteScheduleTaskService.setHotArticle(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=setHotArtileTask");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    /**
-     * 同一用户，连续多月结算金额相同
-     *
-     * @param para 参数（月数）
-     * @return 运行结果
-     */
-    @SneakyThrows
-    public String singleMemberSettleSameAmountInSeveralMonths(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=singleMemberSettleSameAmount params={}", para);
-        remoteScheduleTaskService.singleMemberSettleSameAmount(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=singleMemberSettleSameAmount");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    /**
-     * 同一用户 同一税地，连续多月结算金额超过限额
-     *
-     * @param para 参数（月数和限额）
-     * @return 运行结果
-     */
-    @SneakyThrows
-    public String singleMemberSettleAmountOverrunInSeveralMonths(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=singleMemberSettleAmountOverrun params={}", para);
-        remoteScheduleTaskService.singleMemberSettleAmountOverrun(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=singleMemberSettleAmountOverrun");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    /**
-     * 同一企业，当前月给多个用户支付相同金额
-     *
-     * @param para 参数（统计人数）
-     * @return 运行结果
-     */
-    @SneakyThrows
-    public String singleEnterpriseSettleSameAmountForSeveralMembersInCurrentMonth(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=singleEnterpriseSettleSameAmount params={}", para);
-        remoteScheduleTaskService.singleEnterpriseSettleSameAmount(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=singleEnterpriseSettleSameAmount");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    /**
-     * 同一用户，连续多月没有指定任务类型
-     *
-     * @param para 参数（周期和任务类型）
-     * @return 运行结果
-     */
-    @SneakyThrows
-    public String singleMemberWithoutSuchTaskTypesInSeveralMonths(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=singleMemberWithoutTaskTypes params={}", para);
-        remoteScheduleTaskService.singleMemberWithoutTaskTypes(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=singleMemberWithoutTaskTypes");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @Deprecated
-    @SneakyThrows
-    public String pushUserCertFailure(String para) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=pushUserCertFailure params={}", para);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    /**
-     * 每天发送当日结算数据给企业指定邮箱
-     */
-    @SneakyThrows
-    public String sendCurrentDaySettleDataToDeptDaily(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=sendCurrentDaySettleDataToDept params={}", para);
-        remoteScheduleTaskService.sendCurrentDaySettleDataToDept(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=sendCurrentDaySettleDataToDept");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @Deprecated
-    @SneakyThrows
-    public String batchUpdateCertStatus(String params) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=batchUpdateCertStatus params={}", params);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    /**
-     * 锋信易申请每日发布
-     */
-    @SneakyThrows
-    public String sendFxyApply(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=sendFxyApply params={}", para);
-        remoteScheduleTaskService.sendFxyApply(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=sendFxyApply");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    /**
-     * 锋信易弹窗点击记录每日发布
-     */
-    @SneakyThrows
-    public String sendPromotionRecord(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=sendPromotionRecord params={}", para);
-        remoteScheduleTaskService.sendPromotionRecord(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=sendPromotionRecord");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @SneakyThrows
-    public String batchUpdatePackageStatus(String params) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=batchUpdatePackageStatus params={}", params);
-        remoteScheduleTaskService.batchUpdatePackageStatus(params, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=batchUpdatePackageStatus");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @Deprecated
-    @SneakyThrows
-    public String bosskgyjbSignResultConfirm(String para) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=bosskgyjbSignResultConfirm params={}", para);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @Deprecated
-    @SneakyThrows
-    public String heChuangLxlwSignResultConfirm(String para) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=heChuangLxlwSignResultConfirm params={}", para);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @Deprecated
-    @SneakyThrows
-    public String heChuangLxlwSettleResultConfirm(String para) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=heChuangLxlwSettleResultConfirm params={}", para);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @Deprecated
-    @SneakyThrows
-    public String chaEPulxlwSettleResultConfirm(String para) {
-        log.warn("[QUARTZ] 废弃任务方法调用 | method=chaEPulxlwSettleResultConfirm params={}", para);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    /**
-     * 刷新已结算积分包的任务终审积分
-     */
-    @SneakyThrows
-    public String refreshFinalReviewScoreForSettlement(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=refreshFinalReviewScoreForSettlement params={}", para);
-        remoteScheduleTaskService.refreshFinalReviewScoreForSettlement(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=refreshFinalReviewScoreForSettlement");
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-    @SneakyThrows
-    public String asignPullFacePhoto(String para) {
-        log.info("[QUARTZ] SpringBean任务开始 | method=asignPullFacePhoto params={}", para);
-        String ret = remoteInnerSignApiService.asignPullFacePhotoJob(para, SecurityConstants.FROM_IN);
-        log.info("[QUARTZ] SpringBean任务完成 | method=asignPullFacePhoto result={}", ret);
-        return QuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
-    }
-
-}

src/main/resources/logback-spring.xml

@@ -25,7 +25,7 @@
 		<file>${log.path}/app.log</file>
 		<rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
 			<fileNamePattern>${log.path}/%d{yyyy-MM, aux}/app.%d{yyyy-MM-dd}.%i.log.gz</fileNamePattern>
-			<maxFileSize>500MB</maxFileSize>
+			<maxFileSize>200MB</maxFileSize>
 			<maxHistory>30</maxHistory>
 		</rollingPolicy>
 		<encoder>