| | |
| | | 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; |
| | |
| | | |
| | | 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; |
| | | } |
| | |
| | | } |
| | | |
| | | // 状态:等待确认 并且 任务完成位 = 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()); |
| | |
| | | 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(); |
| | | } |
| | | |
| | |
| | | if (!result) { |
| | | throw new CoolException("更新plc站点信息失败"); |
| | | } |
| | | |
| | | Date now = new Date(); |
| | | wrkMast.setModiTime(now); |
| | | wrkMastMapper.updateById(wrkMast); |
| | | wrkMastMapper.updateWrkSts(updateWrkSts, wrkMast.getWrkNo()); |
| | | rgvThread.setResetFlag1(true); |
| | | } |
| | | } |
| | | } |