feat: 增加服务单派发通知

wlzboy

3 天以前 8cb5d3440208a3be3e772e65f1bd0ec63031ba62

 ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/LegacySystemSyncTask.java

@@ -168,10 +168,10 @@
     * 3. 有调度单ID和服务单ID
     */
    public void syncPendingAttachments() {
        log.info("开始执行任务附件同步定时任务");
//        log.info("开始执行任务附件同步定时任务");
        try {
            int successCount = taskAttachmentSyncService.batchSyncPendingAttachments();
            log.info("任务附件同步完成，成功同步: {} 个附件", successCount);
//            log.info("任务附件同步完成，成功同步: {} 个附件", successCount);
        } catch (Exception e) {
            log.error("任务附件同步异常", e);
        }
@@ -188,10 +188,10 @@
     * cron表达式: 0 0/10 * * * ? (每10分钟执行一次)
     */
    public void syncPaymentToLegacy() {
        log.info("开始执行支付信息同步定时任务（新系统 -> 旧系统）");
//        log.info("开始执行支付信息同步定时任务（新系统 -> 旧系统）");
        try {
            int successCount = paymentSyncService.batchSyncPaymentToLegacy();
            log.info("支付信息同步完成，成功同步: {} 条记录", successCount);
//            log.info("支付信息同步完成，成功同步: {} 条记录", successCount);
        } catch (Exception e) {
            log.error("支付信息同步异常", e);
        }
@@ -208,10 +208,10 @@
     * cron表达式: 0 0/15 * * * ? (每15分钟执行一次)
     */
    public void syncPaymentFromLegacy() {
        log.info("开始执行支付信息同步定时任务（旧系统 -> 新系统）");
//        log.info("开始执行支付信息同步定时任务（旧系统 -> 新系统）");
        try {
            int successCount = paymentSyncService.batchSyncPaymentFromLegacy();
            log.info("支付信息同步完成，成功同步: {} 条记录", successCount);
//            log.info("支付信息同步完成，成功同步: {} 条记录", successCount);
        } catch (Exception e) {
            log.error("支付信息同步异常", e);
        }
@@ -228,10 +228,10 @@
     * cron表达式: 0 0/10 * * * ? (每10分钟执行一次)
     */
    public void syncAdditionalFeeToLegacy() {
        log.info("开始执行附加费用同步定时任务（新系统 -> 旧系统）");
//        log.info("开始执行新系统附加费用同步定时任务（新系统 -> 旧系统）");
        try {
            int successCount = additionalFeeSyncService.batchSyncAdditionalFeeToLegacy();
            log.info("附加费用同步完成，成功同步: {} 条记录", successCount);
//            log.info("附加费用同步完成，成功同步: {} 条记录", successCount);
        } catch (Exception e) {
            log.error("附加费用同步异常", e);
        }
@@ -248,11 +248,11 @@
     * cron表达式： 0 0/15 * * * ? (每15分钟执行一次)
     */
    public void syncAdditionalFeeFromLegacy() {
        log.info("开始执行附加费用同步定时任务（旧系统 -> 新系统）");
//        log.info("开始执行旧系统附加费用同步定时任务（旧系统 -> 新系统）");
        try {
            // 同步最近24小时内的记录
            int successCount = additionalFeeSyncService.batchSyncAdditionalFeeFromLegacy(24);
            log.info("附加费用同步完成，成功同步: {} 条记录", successCount);
            int successCount = additionalFeeSyncService.batchSyncAdditionalFeeFromLegacy(72);
//            log.info("旧系统附加费用同步完成，成功同步: {} 条记录", successCount);
        } catch (Exception e) {
            log.error("附加费用同步异常", e);
        }