#

luxiaotao1123

2022-08-25 7ea7fa055306a766420d578f508a7dc358afebc1

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

@@ -2,18 +2,26 @@

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.annotations.ManagerAuth;
import com.core.common.BaseRes;
import com.core.common.Cools;
import com.core.common.R;
import com.core.exception.CoolException;
import com.zy.asrs.domain.enums.CrnStatusType;
import com.zy.asrs.domain.param.SteOperatorParam;
import com.zy.asrs.domain.vo.SteMsgTableVo;
import com.zy.asrs.domain.vo.SteStateTableVo;
import com.zy.asrs.entity.BasSte;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.service.BasSteService;
import com.zy.asrs.service.WrkMastService;
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.OutputQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.enums.SteTaskModeType;
import com.zy.core.model.SteSlave;
import com.zy.core.model.Task;
import com.zy.core.model.command.SteCommand;
import com.zy.core.model.protocol.SteProtocol;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.SteThread;
@@ -143,4 +151,49 @@
        return R.ok().add(str.toString());
    }


    /****************************************************************/
    /************************** 手动操作 ******************************/
    /****************************************************************/

    @ManagerAuth(memo = "手动操作")
    @PostMapping("/operator/ste")
    public R steOperator(SteOperatorParam param){
        if (Cools.isEmpty(param.getSteNo(), param.getSteTaskMode())) {
            return R.parse(BaseRes.PARAM);
        }

        for (SteSlave ste : slaveProperties.getSte()) {
            // 获取堆垛机信息
            if (param.getSteNo().equals(ste.getId())) {
                SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, ste.getId());
                if (steThread == null) {
                    throw new CoolException("穿梭车不在线");
                }
                SteProtocol steProtocol = steThread.getSteProtocol();
                if (steProtocol == null) {
                    throw new CoolException("穿梭车不在线");
                }
                SteTaskModeType steTaskModeType = SteTaskModeType.get(param.getSteTaskMode());
                SteCommand steCommand = new SteCommand();
                steCommand.setSteNo(ste.getId()); // 穿梭车编号
                if (param.getSteTaskMode() == 16) {
                    steCommand.setComplete(true);
                } else {
                    if (steTaskModeType == null) {
                        throw new CoolException("任务类型错误");
                    }
                    steCommand.setTaskNo(param.getTaskNo()); // 工作号
                    steCommand.setTaskMode(steTaskModeType);
                }
                if (MessageQueue.offer(SlaveType.Ste, ste.getId(), new Task(2, steCommand))) {
                    return R.ok();
                } else {
                    throw new CoolException("命令下发失败");
                }
            }
        }
        return R.error();
    }

}