| | |
|---|
| | | TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("barcode", barcode)); |
|---|
| | | if (taskWrk1 != null) { |
|---|
| | | if (staProtocol.getWorkNo() == 9999) { |
|---|
| | | Object object = redisUtil.get(RedisKeyType.IN_TASK_LOCK.key + inSta.getStaNo()); |
|---|
| | | if(object != null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() |
|---|
| | | .eq("crn_no", taskWrk1.getCrnNo()).eq("type_no", 1).eq("stn_no", staProtocol.getSiteId())); |
|---|
| | | staProtocol.setWorkNo(taskWrk1.getWrkNo()); |
|---|
| | | staProtocol.setStaNo(staDesc.getCrnStn().shortValue()); |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | redisUtil.set(RedisKeyType.IN_TASK_LOCK.key, "lock", 10); |
|---|
| | | } |
|---|
| | | News.watchInfo(String.valueOf(staProtocol.getSiteId()), "托盘码：" + barcode + "任务档存在"); |
|---|
| | | continue; |
|---|
