优化任务状态更新逻辑

zhangc

2024-11-26 30730084c35b2cc09268e6b630324c7964a4d2fc

优化任务状态更新逻辑

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

@@ -8,7 +8,7 @@

public interface AgvWrkMastService extends IService<AgvWrkMast> {

    public void updateWrkStsByWrkNo(int wrkNo, long wrkSts);
    public Boolean updateWrkStsByWrkNo(int wrkNo, long wrkSts);

    public void updateWrkStsByWrkNo(int wrkNo, long wrkSts,String manuType,long userId);


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

@@ -63,13 +63,13 @@
    private AgvWrkMastService agvWrkMastService;


    public void updateWrkStsByWrkNo(int wrkNo, long wrkSts) {
    public Boolean updateWrkStsByWrkNo(int wrkNo, long wrkSts) {
        AgvWrkMast agvWrkMast = this.selectById(wrkNo);
        //判断要修改的工作档状态是否合理，如果不合理则抛出异常
        checkWrkSts(agvWrkMast, wrkSts);
        agvWrkMast.setWrkSts(wrkSts);
        agvWrkMast.setModiTime(new Date());
        this.updateById(agvWrkMast);
        return this.updateById(agvWrkMast);
    }

    public void updateWrkStsByWrkNo(int wrkNo, long wrkSts, String manuType, long userId) {
@@ -284,7 +284,7 @@
                    .doPost();
            JSONObject jsonObject = JSON.parseObject(response);

             code = Integer.parseInt(jsonObject.get("code").toString());
            code = Integer.parseInt(jsonObject.get("code").toString());
            if (code != 0) {
                if (code == 6) {
                    log.info("AGV任务单号已上报:{}", response);
@@ -304,7 +304,7 @@
            throw new CoolException("调用AGV响应错误");
            //return 1;
        } finally {
            if(code !=6){
            if (code != 6) {
                apiLogService.save(
                        namespace,
                        url + path,

 src/main/java/com/zy/asrs/task/handler/AgvWrkMastHandler.java

@@ -531,13 +531,14 @@
                throw new CoolException("任务下发失败");
            }

            agvWrkMast.setWrkSts(202L);
            agvWrkMast.setModiTime(new Date());
            boolean b = agvWrkMastService.updateById(agvWrkMast);
            //agvWrkMast.setWrkSts(202L);
            //agvWrkMast.setModiTime(new Date());
            //boolean b = agvWrkMastService.updateById(agvWrkMast);
            boolean b = agvWrkMastService.updateWrkStsByWrkNo(Math.abs(agvWrkMast.getWrkNo()), 202L);
            if (!b) {
                log.info("更新任务状态失败,{}", agvWrkMast.getWrkNo());
                throw new CoolException("更新任务状态失败");
            }else {
            } else {
                log.info("更新任务状态成功,{}", agvWrkMast.getWrkNo());
            }
            if (agvWrkMast.getIoType() == 1) {