【UPDATE】1.增加同步BOM数据定时任务功能 2.将BOM数据存储到Redis中

huangjiayang

2025-05-08 fed6f56842fea1a7e17dbfec12a30cb332c566b0

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

@@ -45,9 +45,9 @@
    /**
     * 同步工单工序数据
     */
    public void syncWorkOrderProcessData()
    public void syncWorkOrderProcessData(String status, Integer pageSize)
    {
        iApsWorkOrderProcessService.syncWorkOrderProcessData();
        iApsWorkOrderProcessService.syncWorkOrderProcessData(status, pageSize);
    }

    /**
@@ -59,6 +59,21 @@
        iApsWorkOrderJobService.syncPartOrderData();
    }

    /**
     * 每日同步钣金工单数据
     * */
    public void  syncPlateOrderData ()
    {

        iApsWorkOrderJobService.syncPlateOrderData();
    }
    /**
     * 每日同步气柜管路数据
     * */
    public void  syncGasPipingData ()
    {
        iApsWorkOrderJobService.syncGasPipingData();
    }
    /**
     * 每日同步所有工单数据
     * */
@@ -75,20 +90,47 @@
        param.setDocState(Arrays.asList(0,1,2,4));
        param.setBeginDate(yesterdayMidnight.format(formatter));
        param.setEndDate(today.format(formatter));
        param.setPageSize(1000);
        param.setPageSize(500);
        while (continueFlag){
            param.setPageIndex(currentPage);
            continueFlag= iApsWorkOrderJobService.batchSaveByPager(param);
            currentPage++;
        }
    }
    /**
     * 每日同步所有工单数据
     * */
    public void syncAllWorkOrder()
    {

        boolean continueFlag = true;
        Integer currentPage = 1;
        ApsWorkOrderJobParam param=new ApsWorkOrderJobParam();
        param.setPageIndex(currentPage);
        param.setDocState(Arrays.asList(0,1,2,4));
        param.setPageSize(500);
        while (continueFlag){
            param.setPageIndex(currentPage);
            continueFlag= iApsWorkOrderJobService.batchSaveByPager(param);
            currentPage++;
        }
    }
    /**
     * 将工单工序数据同步到业务表中
     */
    public void insertIntoApsProcessRoute()
    {
        iApsWorkOrderProcessService.deleteApsProcessRoute();
        iApsWorkOrderProcessService.insertIntoApsProcessRoute();
        iApsWorkOrderProcessService.syncProcessRouteData();
    }

    /**
     * 同步零件、钣金、气柜管路的工单数据到业务表中、同步工序数据到工艺路线表中
     */
    public void syncAllTypeOrder()
    {
        iApsWorkOrderJobService.syncPartOrderData();
        iApsWorkOrderJobService.syncPlateOrderData();
        iApsWorkOrderJobService.syncGasPipingData();
        iApsWorkOrderProcessService.syncProcessRouteData();
    }
}