| | |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | log.info("下发输送线任务：taskWrk:"+JSON.toJSONString(taskWrk)); |
|---|
| | | R r = siteController.siteDetlUpdate(Integer.valueOf(taskWrk.getTargetPoint()), taskWrk.getWrkNo().shortValue(), (short) 0, "Y", false, false); |
|---|
| | | JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(r)); |
|---|
| | | if (jsonObject.getInteger("code").equals(200)){ |
|---|
| | | // R r = siteController.siteDetlUpdate(Integer.valueOf(taskWrk.getTargetPoint()), taskWrk.getWrkNo().shortValue(), (short) 0, "Y", false, false); |
|---|
| | | staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue()); |
|---|
| | | staProtocol.setStaNo(staDesc.getCrnStn().shortValue()); |
|---|
| | | boolean offer = false; |
|---|
| | | try{ |
|---|
| | | offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol)); |
|---|
| | | }catch (Exception e){ |
|---|
| | | log.error("下发输送线任务失败：异常:"+e); |
|---|
| | | log.error("下发输送线任务失败：异常:offer:"+offer); |
|---|
| | | } |
|---|
| | | // JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(r)); |
|---|
| | | if (offer){ |
|---|
| | | log.info("下发输送线任务成功：taskWrk:"+JSON.toJSONString(taskWrk)); |
|---|
| | | taskWrk.setStatus(5); |
|---|
| | | taskWrk.setWrkSts(14); |
|---|
| | | taskWrkService.updateById(taskWrk); |
|---|
| | | }else { |
|---|
| | | log.error("下发输送线任务失败：taskWrk:"+JSON.toJSONString(taskWrk)); |
|---|
| | | log.error("下发输送线任务失败：异常信息:"+JSON.toJSONString(r)); |
|---|
| | | // log.error("下发输送线任务失败：异常信息:"+JSON.toJSONString(r)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
