diff --git a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/controller/QmsIncomingInspectionTaskController.java b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/controller/QmsIncomingInspectionTaskController.java index 51282c22..32c2ed3e 100644 --- a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/controller/QmsIncomingInspectionTaskController.java +++ b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/controller/QmsIncomingInspectionTaskController.java @@ -1,6 +1,7 @@ package com.nflg.qms.admin.controller; import com.nflg.qms.admin.service.IncomingInspectionTaskControllerService; +import com.nflg.qms.admin.service.WmsIncomingInspectionTaskCallbackService; import com.nflg.wms.common.pojo.ApiResult; import com.nflg.wms.common.pojo.PageData; import com.nflg.wms.common.pojo.qo.*; @@ -28,6 +29,9 @@ public class QmsIncomingInspectionTaskController extends BaseController { @Resource private IncomingInspectionTaskControllerService incomingInspectionTaskControllerService; + @Resource + private WmsIncomingInspectionTaskCallbackService wmsIncomingInspectionTaskCallbackService; + /** * 分页查询来料检测任务列表 */ @@ -131,5 +135,12 @@ public class QmsIncomingInspectionTaskController extends BaseController { return ApiResult.success(); } - + /** + * 回调 + */ + @PostMapping("callback") + public ApiResult callback(@RequestParam Long taskId){ + wmsIncomingInspectionTaskCallbackService.process(taskId); + return ApiResult.success(); + } } diff --git a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/WmsIncomingInspectionTaskCallbackService.java b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/WmsIncomingInspectionTaskCallbackService.java index 6dabf254..56fd3600 100644 --- a/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/WmsIncomingInspectionTaskCallbackService.java +++ b/nflg-qms-admin/src/main/java/com/nflg/qms/admin/service/WmsIncomingInspectionTaskCallbackService.java @@ -1,8 +1,12 @@ package com.nflg.qms.admin.service; +import com.nflg.wms.common.constant.STATE; +import com.nflg.wms.common.exception.NflgException; import com.nflg.wms.common.pojo.qo.WmsIncomingInspectionTaskCallbackQO; import com.nflg.wms.common.pojo.qo.WmsInventoryInspectionTaskCallbackQO; import com.nflg.wms.common.pojo.vo.QmsIncomingInspectionTaskVO; +import com.nflg.wms.common.util.VUtil; +import com.nflg.wms.repository.entity.QmsIncomingInspectionTask; import com.nflg.wms.repository.entity.QmsIncomingInspectionTaskRecord; import com.nflg.wms.repository.service.IQmsIncomingInspectionTaskRecordService; import com.nflg.wms.repository.service.IQmsIncomingInspectionTaskService; @@ -38,8 +42,7 @@ public class WmsIncomingInspectionTaskCallbackService { /** * 向WMS系统发送来料检验任务回调 */ - public void incoming(Long taskId) { - QmsIncomingInspectionTaskVO taskVO = incomingInspectionTaskService.getDetail(taskId); + private void incoming(QmsIncomingInspectionTaskVO taskVO) { WmsIncomingInspectionTaskCallbackQO qo = new WmsIncomingInspectionTaskCallbackQO() .setTaskNo(taskVO.getTaskNo()) .setInspectionType(taskVO.getInspectionType()) @@ -59,7 +62,7 @@ public class WmsIncomingInspectionTaskCallbackService { List records = incomingInspectionTaskRecordService.lambdaQuery() .select(QmsIncomingInspectionTaskRecord::getMaterialUniqueNo, QmsIncomingInspectionTaskRecord::getQualified) - .eq(QmsIncomingInspectionTaskRecord::getTaskId, taskId) + .eq(QmsIncomingInspectionTaskRecord::getTaskId, taskVO.getId()) .list(); qo.setQualifiedMaterialUniqueNo(records.stream() .filter(QmsIncomingInspectionTaskRecord::getQualified) @@ -72,14 +75,25 @@ public class WmsIncomingInspectionTaskCallbackService { .toList() ); - wmsApiService.post(incomingUrl, qo, "来料检验任务回调WMS"); + boolean callbackResult = true; + try { + wmsApiService.post(incomingUrl, qo, "来料检验任务回调WMS"); + } catch (Exception e) { + callbackResult = false; + throw new NflgException(STATE.BusinessError, "调用WMS接口失败:" + e.getMessage()); + } finally { + incomingInspectionTaskService.lambdaUpdate() + .eq(QmsIncomingInspectionTask::getId, taskVO.getId()) + .ne(QmsIncomingInspectionTask::getCallbackResult, true) + .set(QmsIncomingInspectionTask::getCallbackResult, callbackResult) + .update(); + } } /** * 向WMS系统发送库存检验任务回调 */ - public void inventory(Long taskId) { - QmsIncomingInspectionTaskVO taskVO = incomingInspectionTaskService.getDetail(taskId); + private void inventory(QmsIncomingInspectionTaskVO taskVO) { WmsInventoryInspectionTaskCallbackQO qo = new WmsInventoryInspectionTaskCallbackQO() .setTaskNo(taskVO.getTaskNo()) .setMaterialNo(taskVO.getMaterialNo()) @@ -94,7 +108,7 @@ public class WmsIncomingInspectionTaskCallbackService { List records = incomingInspectionTaskRecordService.lambdaQuery() .select(QmsIncomingInspectionTaskRecord::getMaterialUniqueNo, QmsIncomingInspectionTaskRecord::getQualified) - .eq(QmsIncomingInspectionTaskRecord::getTaskId, taskId) + .eq(QmsIncomingInspectionTaskRecord::getTaskId, taskVO.getId()) .list(); qo.setQualifiedMaterialUniqueNo(records.stream() .filter(QmsIncomingInspectionTaskRecord::getQualified) @@ -107,6 +121,33 @@ public class WmsIncomingInspectionTaskCallbackService { .toList() ); - wmsApiService.post(inventoryUrl, qo, "库存检验任务回调WMS"); + boolean callbackResult = true; + try { + wmsApiService.post(inventoryUrl, qo, "库存检验任务回调WMS"); + } catch (Exception e) { + callbackResult = false; + throw new NflgException(STATE.BusinessError, "调用WMS接口失败:" + e.getMessage()); + } finally { + incomingInspectionTaskService.lambdaUpdate() + .eq(QmsIncomingInspectionTask::getId, taskVO.getId()) + .ne(QmsIncomingInspectionTask::getCallbackResult, true) + .set(QmsIncomingInspectionTask::getCallbackResult, callbackResult) + .update(); + } + } + + public void process(Long taskId) { + QmsIncomingInspectionTaskVO taskVO = incomingInspectionTaskService.getDetail(taskId); + switch (taskVO.getInspectionType()) { + case 1: + incoming(taskVO); + break; + case 2: + inventory(taskVO); + break; + default: + VUtil.trueThrowBusinessError(true).throwMessage("无效的检验类型:" + taskVO.getInspectionType()); + break; + } } } diff --git a/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/vo/QmsIncomingInspectionTaskVO.java b/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/vo/QmsIncomingInspectionTaskVO.java index 10d7b085..1a27ed8a 100644 --- a/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/vo/QmsIncomingInspectionTaskVO.java +++ b/nflg-wms-common/src/main/java/com/nflg/wms/common/pojo/vo/QmsIncomingInspectionTaskVO.java @@ -182,6 +182,11 @@ public class QmsIncomingInspectionTaskVO { */ private String purchaseGroup; + /** + * 回调结果 + */ + private Boolean callbackResult; + /** * 最近更新人id */ diff --git a/nflg-wms-repository/src/main/java/com/nflg/wms/repository/entity/QmsIncomingInspectionTask.java b/nflg-wms-repository/src/main/java/com/nflg/wms/repository/entity/QmsIncomingInspectionTask.java index 30403472..178216c0 100644 --- a/nflg-wms-repository/src/main/java/com/nflg/wms/repository/entity/QmsIncomingInspectionTask.java +++ b/nflg-wms-repository/src/main/java/com/nflg/wms/repository/entity/QmsIncomingInspectionTask.java @@ -187,6 +187,11 @@ public class QmsIncomingInspectionTask implements Serializable { */ private String purchaseGroup; + /** + * 回调结果 + */ + private Boolean callbackResult; + /** * 最近更新人id */ diff --git a/nflg-wms-repository/src/main/resources/mapper/QmsIncomingInspectionTaskMapper.xml b/nflg-wms-repository/src/main/resources/mapper/QmsIncomingInspectionTaskMapper.xml index 06b532d6..f127cedd 100644 --- a/nflg-wms-repository/src/main/resources/mapper/QmsIncomingInspectionTaskMapper.xml +++ b/nflg-wms-repository/src/main/resources/mapper/QmsIncomingInspectionTaskMapper.xml @@ -4,40 +4,42 @@