#

luxiaotao1123

2022-03-14 412c5291467a5812af769156912dca6024abc8f1

#

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

@@ -1115,7 +1115,7 @@
            SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, ste.getId());
            SteProtocol steProtocol = steThread.getSteProtocol();
            if (steProtocol == null) { continue; }
            if (steProtocol.getStatusType().equals(SteStatusType.WAITING) && steProtocol.getTaskNo() != 0) {
            if (steProtocol.getWaiting() && steProtocol.getTaskNo() != 0) {
                // 查询是否有待入库的任务
                WrkMast wrkMast = wrkMastMapper.selectCarWaiting(steProtocol.getTaskNo());
                if (wrkMast == null) { continue; }

 src/main/java/com/zy/core/enums/SteStatusType.java

@@ -5,7 +5,6 @@
    IDLE(0, "空闲"),
    MOVING(1, "作业中"),
    SOS(2, "报警"),
    WAITING(3, "任务完成等待WCS确认"),
    ;

    public Integer id;

 src/main/java/com/zy/core/model/command/SteCommand.java

@@ -21,10 +21,10 @@
    private Short taskMode = 0;

    // 正在执行任务
    public Boolean execute;
    public Boolean execute = Boolean.FALSE;

    // 任务完成，等待WCS确认
    public Boolean waiting;
    // 确认任务完成
    public Boolean complete = Boolean.FALSE;

    @JSONField(serialize = false)
    private SteTaskModeType taskModeType;

 src/main/java/com/zy/core/thread/SteThread.java

@@ -15,7 +15,6 @@
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.OutputQueue;
import com.zy.core.enums.SlaveType;
import com.zy.core.enums.SteStatusType;
import com.zy.core.model.SteSlave;
import com.zy.core.model.Task;
import com.zy.core.model.command.SteCommand;
@@ -176,10 +175,10 @@
                OutputQueue.CRN.offer(MessageFormat.format("【{0}】[id:{1}] <<<<< 实时数据更新成功",DateUtils.convert(new Date()), slave.getId()));

                // 复位信号
                if (steProtocol.getStatusType().equals(SteStatusType.WAITING)) {
                if (steProtocol.getWaiting()) {
                    if (resetFlag) {
                        SteCommand steCommand = new SteCommand();
//                        steCommand.setAckFinish((short)1);
                        steCommand.setComplete(true);
                        if (write(steCommand) && confirmPos()) {
                            resetFlag = false;
                        }
@@ -221,7 +220,7 @@
        command.setSteNo(slave.getId());
        OperateResult result = null;
        // 开始任务
        if (!command.getWaiting()) {
        if (!command.getComplete()) {
            OperateResult result0 = siemensS7Net.Write("D0", command.getTaskNo());
            short[] array = new short[10];
            array[0] = command.getTaskMode();