| | |
| | | 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; |
| | |
| | | public boolean syncWeldSeamStandardData() |
| | | { |
| | | try { |
| | | log.info("开始同步物料标准焊缝数据"); |
| | | // 使用POST方法调用接口 |
| | | HttpHeaders headers = new HttpHeaders(); |
| | | headers.setContentType(MediaType.APPLICATION_JSON); |
| | |
| | | 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(); |
| | | } |
| | | /** |
| | | * 同步数据到业务表 |
| | | * |
| | |
| | | */ |
| | | private void syncToBizTable(List<ApsWeldSeamStandardJob> jobList) { |
| | | try { |
| | | // 删除业务表数据(全量覆盖) |
| | | apsWeldSeamStandardMapper.deleteAllApsWeldSeamStandard(); |
| | | |
| | | if (jobList == null || jobList.isEmpty()) { |
| | | return; |
| | | } |