#

LSH

2023-11-10 62b9fa3e8696252c931769ef742a95edfd6597c7

#

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

@@ -122,6 +122,9 @@
        }
        TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo());

        if (Cools.isEmpty(taskWrk)){
            return R.error("未查询到任务，任务号："+param.getTaskNo());
        }
        return R.ok(taskWrk.getStartPoint());
    }

@@ -137,12 +140,19 @@
        } else if (Cools.isEmpty(param.getWharfCode())){
            return R.error("码头编号为空！");
        }
        BasDevp basDevp = basDevpService.selectById(param.getWharfCode());
        if (basDevp.getAutoing().equals("Y") && basDevp.getLoading().equals("N")){
            return R.ok();
        }else {
            return R.error();

        try{
            BasDevp basDevp = basDevpService.selectById(param.getWharfCode());
            if (basDevp.getAutoing().equals("Y") && basDevp.getLoading().equals("N")){
                return R.ok();
            }else {
                return R.error();
            }
        }catch (Exception e){
            log.error("AGV请求动作接口报错:"+e);
            return R.error("程序报错，未查询到站点");
        }

    }

    //任务下发接口
@@ -219,20 +229,20 @@
        }
        boolean sign =false;
        switch (param.getTaskStatus()){
            case "1"://正常取消
            case 1://正常取消
                if (taskWrk.getWrkSts()>1){
                    return R.error("任务已开始执行");
                }
            case "2"://强制取消
            case 2://强制取消
                if (taskWrk.getWrkSts()>3){
                    return R.error("任务已执行完成");
                }
                break;
            case "3"://正常完成
            case 3://正常完成
                if (taskWrk.getWrkSts()>11){
                    return R.error("任务已开始执行");
                }
            case "4"://强制完成
            case 4://强制完成
                if (taskWrk.getWrkSts()>14){
                    return R.error("任务已执行完成");
                }

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

@@ -159,7 +159,11 @@
        Date now = new Date();
        taskWrk.setStatus(TaskStatusType.CANCEL.id);
        taskWrk.setModiTime(now);//操作时间
        taskWrk.setModiUser(getUserId());//操作员
        try{
            taskWrk.setModiUser(getUserId());//操作员
        }catch (Exception e){
            taskWrk.setModiUser(9999L);//操作员
        }
        taskWrk.setCompleteTime(now);//完结时间
        taskWrkService.updateById(taskWrk);
        return R.ok();

 src/main/java/com/zy/asrs/entity/param/WMSAndAGVInterfaceParam.java

@@ -32,7 +32,7 @@
    * 3.正常完成--只能完成未执行的任务，货物处于任务执行完成状态
    * 4.强制完成--可完成已执行未完成的任务，货物处于任务执行完成状态
    * */
    private String taskStatus;          //操作类型
    private Integer taskStatus;          //操作类型

    //AGV请求入库码头接口
//    private String containerCode;     //托盘编码

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

@@ -36,6 +36,7 @@
        taskWrk.setIoType(param.getIoType());//任务类型
        taskWrk.setIoPri(param.getTaskPriority());//优先级
        taskWrk.setBarcode(param.getBarcode());//条码
        taskWrk.setWrkSts(1);
        if (!Cools.isEmpty(param.getStartPoint())) {
            taskWrk.setStartPoint(param.getStartPoint());//起点
        }

 src/main/java/com/zy/asrs/task/core/WcsDispatcher.java

@@ -1,7 +1,5 @@
package com.zy.asrs.task.core;

import com.zy.asrs.task.handler.WorkLogHandler;
import com.zy.asrs.task.handler.WorkMastHandler;
import com.zy.system.service.ConfigService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -21,11 +19,6 @@

    private static final Logger log = LoggerFactory.getLogger(WcsDispatcher.class);
    private Thread thread;

    @Autowired
    private WorkMastHandler workMastHandler;
    @Autowired
    private WorkLogHandler workLogHandler;
    @Autowired
    private ConfigService configService;