# 订单出库同步锁

whycq

2024-05-29 683c0e046f1d4363f87633104969a91ffe275da6

# 订单出库同步锁

 src/main/java/com/zy/asrs/controller/AgvWorkController.java

@@ -57,4 +57,11 @@
        }
        return R.ok();
    }

    @RequestMapping("/hand/control/wrkMast/changeType")
    @ManagerAuth(memo = "切换调拨方式")
    public R handControlWrkMastChangeType(@RequestParam String workNo){
        workService.changeType(workNo, getUserId());
        return R.ok();
    }
}

 src/main/java/com/zy/asrs/service/AgvWorkService.java

@@ -58,4 +58,9 @@
     */
    void cancelWrkMast(String workNo, Long userId, Integer type);

    /**
     * 切换调拨类型
     */
    void changeType(String workNo, Long userId);

}

 src/main/java/com/zy/asrs/service/impl/AgvWorkServiceImpl.java

@@ -949,6 +949,27 @@
        }
    }

    @Override
    @Transactional
    public void changeType(String workNo, Long userId) {
        AgvWrkMast wrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("wrk_no", workNo));
        if (Cools.isEmpty(wrkMast)) {
            throw new CoolException("暂无\n" + workNo + "\n工作");
        }
        if (wrkMast.getWrkSts() != 22) {
            throw new CoolException("当前任务已分配目标库位，暂不支持调整");
        }
        if (wrkMast.getIoType() == 108) {
            wrkMast.setIoType(111);
            agvWrkMastService.update(wrkMast,new EntityWrapper<AgvWrkMast>().eq("wrk_no", workNo));
        } else if(wrkMast.getIoType() == 111) {
            wrkMast.setIoType(108);
            agvWrkMastService.update(wrkMast,new EntityWrapper<AgvWrkMast>().eq("wrk_no", workNo));
        }


    }

    private void addInQty(String devno){
        AgvBasDevp agvBasDevp = agvBasDevpService.selectById(devno);
        if(!Cools.isEmpty(agvBasDevp)){