| | |
|---|
| | | staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>() |
|---|
| | | .eq("crn_no", taskWrk.getCrnNo()).eq("type_no",1).lt("stn_no", 400).ge("stn_no", 250)); |
|---|
| | | } |
|---|
| | | if (!staProtocol.isPakMk()){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue()); |
|---|
| | | staProtocol.setStaNo(staDesc.getCrnStn().shortValue()); |
|---|
| | | MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol)); |
|---|
| | | devpThread.setPakMk(staProtocol.getSiteId(), false); |
|---|
| | | Thread.sleep(500); |
|---|
| | | }else { |
|---|
| | | //TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo()); |
|---|
