优化同步WorkOrder：先全部删除，再进行同步

zhanghl

2025-05-15 728621ba2f24bb9f41c7f2cd1c6cdc990247928c

 aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java

@@ -1,9 +1,9 @@
package com.aps.job.service.impl;

import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.aps.common.core.utils.DateUtils;
import com.aps.common.core.utils.uuid.Sequence;
import com.aps.job.domain.ApsWorkOrderJob;
import com.aps.job.domain.ApsWorkOrderJobLog;
import com.aps.job.mapper.ApsWorkOrderJobLogMapper;
@@ -52,9 +52,6 @@

    @Autowired
    private ApsWorkOrderJobLogMapper jobLogMapper;

    @Autowired
    private Sequence sequence;

    /**
     * 查询工单同步
@@ -182,6 +179,7 @@
        jobLog.setCreateTime(DateUtils.getNowDate());
        jobLog.setBizType("work_order");
        jobLogMapper.insertApsWorkOrderJobLog(jobLog);
        log.info("work_order_request：{}", JSONObject.toJSONString(jobLog));
        return requestOnePage(jobLog);
    }
    /**
@@ -296,7 +294,7 @@
                }

                ApsWorkOrderJob order = result.getObject(i, ApsWorkOrderJob.class);
                order.setId(sequence.nextId());
                order.setId(IdUtil.getSnowflakeNextId());
                order.setOrderId(jsonObject.getString("ID"));
                order.setCreateTime(DateUtils.getNowDate());
                order.setPageIndex(i);
@@ -305,17 +303,16 @@
                order.setProcessStatus("0");
                order.setOpStatus(jsonObject.getString("OpStatus"));
                order.setNextOpName(jsonObject.getString("NextOpName"));
                order.setLowOrderCode(jsonObject.getString("LowLevelCode"));
                order.setOrderCreateTime(jsonObject.getDate("CreatedOn"));
                order.setApproveOn(jsonObject.getDate("ApproveOn"));
                order.setStartWorkDate(jsonObject.getDate("StartDatetime"));
                jobs.add(order);
                orderIds.add(order.getOrderId());
            } catch (Exception e) {
                log.error("Error processing result at index {}: {}", i, e.getMessage(), e);
                // 继续处理其他数据
            }
        }

        if (!orderIds.isEmpty()) {
            // 删除旧数据
            apsWorkOrderJobMapper.deleteWorkOrderJobByOrderIds(orderIds);
        }

        // 批量插入新数据
@@ -360,4 +357,9 @@
        apsWorkOrderJobMapper.batchInsertGasPiping();
    }

    @Override
    public void deleteAllWorkOrderJob(){
         apsWorkOrderJobMapper.deleteAllWorkOrderJob();
    }

}