src/main/java/com/zy/asrs/mapper/WrkMastMapper.java

@@ -58,6 +58,9 @@

    WrkMast selectWorking(@Param("crnNo")Integer crnNo);

    @Update("update asr_wrk_mast set wrk_sts=#{wrkSts} where wrk_no = #{wrkNo}")
    int updateWrkSts(Long wrkSts, Integer wrkNo);

    // work log -------------------------------------------------------
    @Insert("insert into asr_wrk_mast_log select * from asr_wrk_mast where wrk_no=#{workNo}")
    int saveWrkMastLog(Integer workNo);

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

@@ -13,7 +13,6 @@
import com.zy.asrs.mapper.WrkMastMapper;
import com.zy.asrs.service.*;
import com.zy.asrs.utils.Utils;
import com.zy.asrs.utils.VersionUtils;
import com.zy.common.constant.RedisConstantType;
import com.zy.common.model.LocTypeDto;
import com.zy.common.model.MatDto;
@@ -233,9 +232,14 @@
                            LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
                                    .eq("loc_no", dto.getLocNo()));

                            short staNo = dto.getStaNo().shortValue();
                            if (inSta.getStaNo() == 1002) {
                                staNo = 2002;
                            }

                            barcodeThread.setBarcode("");
                            staProtocol.setWorkNo(dto.getWorkNo().shortValue());
                            staProtocol.setStaNo(dto.getStaNo().shortValue());
                            staProtocol.setStaNo(staNo);
                            staProtocol.setPalletSize(locMast.getLocType2());
                            devpThread.setPakMk(staProtocol.getSiteId(), false);
                            boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -2199,16 +2203,16 @@

    // RGV  ===>> 执行对RGV操作
    public synchronized void rgvExecute(Integer mark) {
        ArrayList<Integer> list = new ArrayList<Integer>(){{add(1090);add(1091);}};
        ArrayList<Integer> list = new ArrayList<Integer>(){{add(2003);add(2002);}};
        for (Integer staNo : list) {
            Integer devpId = null;
            Integer rgvStaNo = null;
            if (staNo == 1090) {
            if (staNo == 2003) {
                devpId = 1;
                rgvStaNo = 1091;
                rgvStaNo = 2002;
            }else {
                devpId = 2;
                rgvStaNo = 1090;
                rgvStaNo = 2003;
            }

            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devpId);
@@ -2224,11 +2228,16 @@

            if (staProtocol.isAutoing()
                    && staProtocol.isLoading()
                    && staProtocol.isInEnable()
//                    && staProtocol.isInEnable()
                    && staProtocol.getWorkNo() > 0
            ) {
                WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>()
                        .eq("wrk_no", staProtocol.getWorkNo()));

                if (wrkMast == null) {
                    continue;
                }

                if (wrkMast.getWrkSts() == 201) {
                    continue;
                }
@@ -2269,7 +2278,7 @@
            }

            //  状态：等待确认 并且  任务完成位 = 1
            if (rgvProtocol.statusType == RgvStatusType.WAITING && rgvProtocol.getTaskNo1() != 0) {
            if (rgvProtocol.statusType1 == RgvStatusType.WAITING && rgvProtocol.getTaskNo1() != 0) {
                News.warnNoLog(""+mark+" - 0"+" - 开始执行对RGV工作档的完成操作");
                // 获取入库待确认工作档
                WrkMast wrkMast = wrkMastMapper.selectPakInStep3(rgvProtocol.getTaskNo1().intValue());
@@ -2278,25 +2287,21 @@
                    continue;
                }

                if (Cools.isEmpty(wrkMast.getMemo())) {
                    News.error(""+mark+" - 1"+" - RGV处于等待确认且任务完成状态，但工作档数据异常。RGV号={}，工作号={}", rgvSlave.getId(), rgvProtocol.getTaskNo1());
                    continue;
                }

                Integer devpId = null;
                Integer devpStaNo = null;
                String locNo = null;
                Long updateWrkSts = null;
                if (wrkMast.getIoType() < 100) {
                    //入库
                    wrkMast.setWrkSts(2L);
                    updateWrkSts = 2L;
                    devpId = 1;
                    devpStaNo = 1090;
                    devpStaNo = 2003;
                    locNo = wrkMast.getLocNo();
                }else {
                    //出库
                    wrkMast.setWrkSts(15L);
                    updateWrkSts = 15L;
                    devpId = 2;
                    devpStaNo = 1091;
                    devpStaNo = 2002;
                    locNo = wrkMast.getSourceLocNo();
                }

@@ -2323,10 +2328,8 @@
                    if (!result) {
                        throw new CoolException("更新plc站点信息失败");
                    }

                    Date now = new Date();
                    wrkMast.setModiTime(now);
                    wrkMastMapper.updateById(wrkMast);
                    wrkMastMapper.updateWrkSts(updateWrkSts, wrkMast.getWrkNo());
                    rgvThread.setResetFlag1(true);
                }
            }
        }

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

@@ -210,7 +210,7 @@
    }

    /**
     * 工位1、2同时写入数据
     * 工位1同时写入数据
     */
    private boolean write(RgvCommand command) throws InterruptedException {
        if (null == command) {
@@ -219,7 +219,7 @@
        }
//        convertRow(command);
        command.setRgvNo(slave.getId());
        short[] array = new short[11];
        short[] array = new short[5];
        array[0] = command.getAckFinish1();
        array[1] = command.getTaskNo1();
        array[2] = command.getTaskMode1();

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

@@ -55,11 +55,11 @@
        add(1064);add(1065);add(1066);add(1067);add(1068);add(1069);add(1070);add(1071);
        add(1072);add(1073);add(1074);add(1075);add(1076);add(1077);add(1078);add(1079);
        add(1080);add(1081);add(1082);add(1083);add(1084);add(1085);add(1086);add(1087);
        add(1088);add(1089);add(1090);
        add(1088);add(1089);add(1090);add(2003);
    }};

    public static final ArrayList<Integer> staNos2 = new ArrayList<Integer>() {{
        add(2001);add(2002);add(2003);add(2004);
        add(2000);add(2001);add(2002);add(1001);add(1002);
    }};



 src/main/resources/application.yml

@@ -258,6 +258,12 @@
    port: 102
    rack: 0
    slot: 0
    # 入库口1
    inSta[0]:
      staNo: 1002
      barcode: ${wcs-slave.barcode[2].id}
      backSta: 1001
      led: ${wcs-slave.led[7].id}
  # 条码扫描仪1
  barcode[0]:
    id: 1
@@ -326,4 +332,11 @@
    ip: 10.10.11.210
    port: 5005
    devpPlcId: ${wcs-slave.devp[0].id}
    staArr: 1074
    staArr: 1074
  # LED8
  led[7]:
    id: 8
    ip: 10.10.11.210
    port: 5005
    devpPlcId: ${wcs-slave.devp[1].id}
    staArr: 1001