| | |
|---|
| | | } else { |
|---|
| | | staProtocol = staProtocol.clone(); |
|---|
| | | } |
|---|
| | | Short workNo = staProtocol.getWorkNo(); |
|---|
| | | Short stano = staProtocol.getStaNo(); |
|---|
| | | //led |
|---|
| | | LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, inSta.getLed()); |
|---|
| | | |
|---|
| | | // 尺寸检测异常 |
|---|
| | | boolean back = false; |
|---|
| | | String errMsg = ""; |
|---|
| | | if (staProtocol.isFrontErr()) { |
|---|
| | | errMsg = "前超限"; |
|---|
| | | back = true; |
|---|
| | | } |
|---|
| | | if (!back && staProtocol.isBackErr()) { |
|---|
| | | errMsg = "后超限"; |
|---|
| | | back = true; |
|---|
| | | } |
|---|
| | | if (!back && staProtocol.isHighErr()) { |
|---|
| | | errMsg = "高超限"; |
|---|
| | | back = true; |
|---|
| | | } |
|---|
| | | if (!back && staProtocol.isLeftErr()) { |
|---|
| | | errMsg = "左超限"; |
|---|
| | | back = true; |
|---|
| | | } |
|---|
| | | if (!back && staProtocol.isRightErr()) { |
|---|
| | | errMsg = "右超限"; |
|---|
| | | back = true; |
|---|
| | | } |
|---|
| | | if (!back && staProtocol.isWeightErr()) { |
|---|
| | | errMsg = "超重"; |
|---|
| | | back = true; |
|---|
| | | } |
|---|
| | | // if (!back && staProtocol.isBarcodeErr()) { |
|---|
| | | // errMsg = "扫码失败"; |
|---|
| | | // back = true; |
|---|
| | | // } |
|---|
| | | // 判断是否满足入库条件 |
|---|
| | | if (staProtocol.isAutoing() && staProtocol.isLoading() |
|---|
| | | && staProtocol.isInEnable() |
|---|
| | | && workNo >= 9990 |
|---|
| | | && staProtocol.isPakMk()) { |
|---|
| | | if (back) { |
|---|
| | | // led 异常显示 |
|---|
| | | if (ledThread != null) { |
|---|
| | | String errorMsg = errMsg; |
|---|
| | | MessageQueue.offer(SlaveType.Led, inSta.getLed(), new Task(5, errorMsg)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isPakMk() && staProtocol.getWorkNo() == 0) { |
|---|
| | | |
|---|
| | | TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().orderBy("create_time")); |
|---|
| | | TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("wrk_sts",1).orderBy("create_time")); |
|---|
| | | if (taskWrk != null) { |
|---|
| | | HashMap<String, Object> hashMap = new HashMap<>(); |
|---|
| | | hashMap.put("TaskNo", taskWrk.getTaskNo()); |
|---|
| | | //开始上报,任务开始时，WCS回调WMS |
|---|
| | | String response = new HttpHandler.Builder() |
|---|
| | | .setUri(wmsUrl) |
|---|
| | | .setPath(taskStatusFeedbackPath) |
|---|
| | | .setJson(JSON.toJSONString(hashMap)) |
|---|
| | | .build() |
|---|
| | | .doPost(); |
|---|
| | | JSONObject jsonObject1 = JSON.parseObject(response); |
|---|
| | | Boolean bool = false; |
|---|
| | | if (jsonObject1.get("ReturnStatus").equals(0)) { |
|---|
| | | taskWrk.setStatus(2);//派发任务 |
|---|
| | | bool = true; |
|---|
| | | taskWrkService.updateById(taskWrk); |
|---|
| | | log.info("下发输送线任务：taskWrk:" + JSON.toJSONString(taskWrk)); |
|---|
| | | staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue()); |
|---|
| | | staProtocol.setStaNo(staProtocol.getSiteId().shortValue()); |
|---|
| | | boolean offer = false; |
|---|
| | | try { |
|---|
| | | offer = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol)); |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error("下发输送线任务失败：异常:" + e); |
|---|
| | | log.error("下发输送线任务失败：异常:offer:" + offer); |
|---|
| | | } |
|---|
| | | apiLogService.save("wcs开始入库任务上报wms" |
|---|
| | | , wmsUrl + TaskExecCallback |
|---|
| | | , null |
|---|
| | | , "127.0.0.1" |
|---|
| | | , JSON.toJSONString(hashMap) |
|---|
| | | , response |
|---|
| | | , bool |
|---|
| | | ); |
|---|
| | | if (offer) { |
|---|
| | | log.info("下发输送线任务成功：taskWrk:" + JSON.toJSONString(taskWrk)); |
|---|
| | | taskWrk.setStatus(1); |
|---|
| | | taskWrk.setWrkSts(2); |
|---|
| | | taskWrkService.updateById(taskWrk); |
|---|
| | | |
|---|
| | | HashMap<String, Object> hashMap = new HashMap<>(); |
|---|
| | | hashMap.put("TaskNo", taskWrk.getTaskNo()); |
|---|
| | | //开始上报,任务开始时，WCS回调WMS |
|---|
| | | String response = new HttpHandler.Builder() |
|---|
| | | .setUri(wmsUrl) |
|---|
| | | .setPath(taskStatusFeedbackPath) |
|---|
| | | .setJson(JSON.toJSONString(hashMap)) |
|---|
| | | .build() |
|---|
| | | .doPost(); |
|---|
| | | JSONObject jsonObject1 = JSON.parseObject(response); |
|---|
| | | Boolean bool = false; |
|---|
| | | if (jsonObject1.get("ReturnStatus").equals(0)) { |
|---|
| | | taskWrk.setStatus(2);//派发任务 |
|---|
| | | bool = true; |
|---|
| | | taskWrkService.updateById(taskWrk); |
|---|
| | | } |
|---|
| | | apiLogService.save("wcs开始入库任务上报wms" |
|---|
| | | , wmsUrl + TaskExecCallback |
|---|
| | | , null |
|---|
| | | , "127.0.0.1" |
|---|
| | | , JSON.toJSONString(hashMap) |
|---|
| | | , response |
|---|
| | | , bool |
|---|
| | | ); |
|---|
| | | } else { |
|---|
| | | log.error("下发输送线任务失败：taskWrk:" + JSON.toJSONString(taskWrk)); |
|---|
| | | // log.error("下发输送线任务失败：异常信息:"+JSON.toJSONString(r)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | |
|---|
| | | if (taskWrk == null) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | // log.info("下发输送线任务：taskWrk:" + JSON.toJSONString(taskWrk)); |
|---|
| | | //// R r = siteController.siteDetlUpdate(Integer.valueOf(taskWrk.getTargetPoint()), taskWrk.getWrkNo().shortValue(), (short) 0, "Y", false, false); |
|---|
| | | // staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue()); |
|---|
| | | // staProtocol.setStaNo(staDesc.getStnNo().shortValue()); |
|---|
| | | // boolean offer = false; |
|---|
| | | // try { |
|---|
| | | // offer = MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol)); |
|---|
| | | // } catch (Exception e) { |
|---|
| | | // log.error("下发输送线任务失败：异常:" + e); |
|---|
| | | // log.error("下发输送线任务失败：异常:offer:" + offer); |
|---|
| | | // } |
|---|
| | | log.info("下发输送线任务：taskWrk:" + JSON.toJSONString(taskWrk)); |
|---|
| | | // R r = siteController.siteDetlUpdate(Integer.valueOf(taskWrk.getTargetPoint()), taskWrk.getWrkNo().shortValue(), (short) 0, "Y", false, false); |
|---|
| | | staProtocol.setWorkNo(taskWrk.getWrkNo().shortValue()); |
|---|
| | | staProtocol.setStaNo(staDesc.getStnNo().shortValue()); |
|---|
| | | boolean offer = false; |
|---|
| | | try { |
|---|
| | | offer = MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), 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)); |
|---|
| | | // } |
|---|
| | | 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)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error("出库到出库站异常:异常信息：" + e); |
|---|
