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

zhanghl

2025-05-15 728621ba2f24bb9f41c7f2cd1c6cdc990247928c

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

 aps-modules/aps-job/src/main/java/com/aps/job/mapper/ApsWorkOrderJobMapper.java

@@ -95,4 +95,6 @@
    int batchInsertGasPiping();

    List<ApsWorkOrderJob> selectApsWorkOrderJobListDocNoNotNull(ApsWorkOrderJob apsWorkOrderJob);

    int deleteAllWorkOrderJob();
}

 aps-modules/aps-job/src/main/java/com/aps/job/service/IApsWorkOrderJobService.java

@@ -81,4 +81,6 @@

    @Transactional
    void syncGasPipingData();

    void deleteAllWorkOrderJob();
}

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

@@ -315,11 +315,6 @@
            }
        }

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

        // 批量插入新数据
        int affectedRows = apsWorkOrderJobMapper.batchInsertApsWorkOrderJob(jobs);

@@ -362,4 +357,9 @@
        apsWorkOrderJobMapper.batchInsertGasPiping();
    }

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

}

 aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java

@@ -119,6 +119,7 @@
    public void syncAllWorkOrder()
    {

        iApsWorkOrderJobService.deleteAllWorkOrderJob();
        boolean continueFlag = true;
        Integer currentPage = 1;
        ApsWorkOrderJobParam param=new ApsWorkOrderJobParam();

 aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobMapper.xml

@@ -466,4 +466,8 @@
        where ( doc_status in (0,1,2,4) and is_hold_release='0'
            and (item_code like 'A65%' or item_code like 'W%'));
    </insert>

    <delete id="deleteAllWorkOrderJob" >
        delete from aps_work_order_job where del_flag in ('0','1')
    </delete>
</mapper>