sfd
2025-05-26 2a64b537e8e3bce9ce030585a3da17d48379c0ad
aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWeldSeamStandardJobServiceImpl.java
@@ -1,5 +1,6 @@
package com.aps.job.service.impl;
import cn.hutool.core.collection.ListUtil;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
@@ -95,6 +96,7 @@
    public boolean syncWeldSeamStandardData()
    {
        try {
            log.info("开始同步物料标准焊缝数据");
            // 使用POST方法调用接口
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.APPLICATION_JSON);
@@ -174,23 +176,32 @@
            if (jobList.isEmpty()) {
                return false;
            }
            log.info("清空旧数据 deleteAllApsWeldSeamStandardJob");
            // 清空旧数据
            deleteAllApsWeldSeamStandardJob();
            
            // 批量插入新数据
            batchInsertApsWeldSeamStandardJob(jobList);
            List<List<ApsWeldSeamStandardJob>> dataGroup = ListUtil.split(jobList, 1000);
            for (List<ApsWeldSeamStandardJob> data : dataGroup) {
                batchInsertApsWeldSeamStandardJob(data);
            }
            // 删除业务表数据(全量覆盖)
            deleteAllApsWeldSeamStandard();
            // 同步数据到业务表
            syncToBizTable(jobList);
            for (List<ApsWeldSeamStandardJob> data : dataGroup) {
                syncToBizTable(data);
            }
            return true;
        } catch (Exception e) {
            log.error("同步物料标准焊缝数据异常", e);
            throw e;
        }
    }
    private void deleteAllApsWeldSeamStandard() {
        apsWeldSeamStandardMapper.deleteAllApsWeldSeamStandard();
    }
    /**
     * 同步数据到业务表
     * 
@@ -198,9 +209,6 @@
     */
    private void syncToBizTable(List<ApsWeldSeamStandardJob> jobList) {
        try {
            // 删除业务表数据(全量覆盖)
            apsWeldSeamStandardMapper.deleteAllApsWeldSeamStandard();
            if (jobList == null || jobList.isEmpty()) {
                return;
            }