添加MES库存同步功能及配置

zhangc

2025-01-03 2fc477de92ef724cd37a79a3679c7d605adb94ab

 src/main/java/com/zy/asrs/task/AutoMoveScheduler.java

@@ -44,21 +44,21 @@

    // 调拨出库
//    @Scheduled(cron = "0/2 * * * * ? ")
    private void execute(){
        List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(
                new EntityWrapper<AgvLocMast>()
                        .isNotNull("loc_type")
                        .ne("loc_type", "")
                        .eq("floor", 1)
                        .eq("loc_sts","F"));
        if (agvLocMasts.isEmpty()) {
            return;
        }
        for (AgvLocMast agvLocMast : agvLocMasts) {
            ReturnT<String> returnT = autoMoveHandler.start(agvLocMast);
        }

    }
//    private void execute(){
//        List<AgvLocMast> agvLocMasts = agvLocMastService.selectList(
//                new EntityWrapper<AgvLocMast>()
//                        .isNotNull("loc_type")
//                        .ne("loc_type", "")
//                        .eq("floor", 1)
//                        .eq("loc_sts","F"));
//        if (agvLocMasts.isEmpty()) {
//            return;
//        }
//        for (AgvLocMast agvLocMast : agvLocMasts) {
//            ReturnT<String> returnT = autoMoveHandler.start(agvLocMast);
//        }
//
//    }

    /**
     * 自动调拨任务，从1楼调拨到2楼，3楼
@@ -66,7 +66,7 @@
     * ioType 108.自动调拨
     * crnNo :2目标楼层
     */
    @Scheduled(cron = "0/3 * * * * ? ")
    @Scheduled(cron = "0/1 * * * * ? ")
    private synchronized void execute2(){
        List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
                .eq("wrk_sts", 22)
@@ -344,7 +344,7 @@

            if (time3 > 0 && time3 < (1000* 60 * 10)) {

                List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().like("loc_no", "02F1").like("source_loc_no", "F1"));
                List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().like("loc_no", "02F1").like("source_loc_no", "F1").eq("io_type",12));
                if (maxTansk <= agvWrkMasts.size()){
                    return;
                }
@@ -362,7 +362,7 @@
                    try{
                        autoMoveHandler.autoTransfers(agvLocMast,maxTansk);
                    } catch (Exception e){
                        log.error("库位号"+agvLocMast.getLocNo()+"空板自动回库 库位-接驳点  库位-吸塑车间,处理失败：===》异常原因："+e.getMessage());
                        log.error("库位号"+agvLocMast.getLocNo()+"定时移库任务 吸塑一楼 --> 吸塑二楼,处理失败：===》异常原因："+e.getMessage());
                    }
                }
            }