From 03b9171a758aef6253ff10f4cd8b70067d6f0b8f Mon Sep 17 00:00:00 2001 From: zane Date: Fri, 6 Sep 2024 19:11:03 +0800 Subject: [PATCH 1/8] =?UTF-8?q?=E5=8D=95=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../glxp/api/constant/BusTypeConstant.java | 33 ++++++++++++ .../api/service/collect/DownloadFactory.java | 51 +++++++++++++++++++ .../collect/IoCollectOriginService.java | 22 ++------ .../service/collect/down/GMRKDownload.java | 15 ++++++ .../api/service/collect/down/IDownload.java | 12 +++++ .../service/collect/down/LYCKDownload.java | 40 +++++++++++++++ .../service/collect/down/LYRKDownload.java | 15 ++++++ .../service/collect/down/YPCF002Download.java | 40 +++++++++++++++ 8 files changed, 209 insertions(+), 19 deletions(-) create mode 100644 src/main/java/com/glxp/api/constant/BusTypeConstant.java create mode 100644 src/main/java/com/glxp/api/service/collect/DownloadFactory.java create mode 100644 src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java create mode 100644 src/main/java/com/glxp/api/service/collect/down/IDownload.java create mode 100644 src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java create mode 100644 src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java create mode 100644 src/main/java/com/glxp/api/service/collect/down/YPCF002Download.java diff --git a/src/main/java/com/glxp/api/constant/BusTypeConstant.java b/src/main/java/com/glxp/api/constant/BusTypeConstant.java new file mode 100644 index 000000000..a45e0f1e9 --- /dev/null +++ b/src/main/java/com/glxp/api/constant/BusTypeConstant.java @@ -0,0 +1,33 @@ +package com.glxp.api.constant; + +public enum BusTypeConstant { + YPCF002("药品处方单","YPCF002"), + CGJH001("采购计划","CGJH001"), + LYRK("领药入库","LYRK"), + GMRK("购买入库","GMRK"), + LYCK("领药出库","LYCK"), + ; + + private String name; + private String busType; + BusTypeConstant(String name, String busType) { + this.name = name; + this.busType = busType; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getBusType() { + return busType; + } + + public void setBusType(String busType) { + this.busType = busType; + } +} diff --git a/src/main/java/com/glxp/api/service/collect/DownloadFactory.java b/src/main/java/com/glxp/api/service/collect/DownloadFactory.java new file mode 100644 index 000000000..3b0060ad7 --- /dev/null +++ b/src/main/java/com/glxp/api/service/collect/DownloadFactory.java @@ -0,0 +1,51 @@ +package com.glxp.api.service.collect; + +import com.glxp.api.common.res.BaseResponse; +import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.constant.BusTypeConstant; +import com.glxp.api.req.collect.CollectOrderRequest; +import com.glxp.api.service.collect.down.*; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; + +/** + * 下载工厂 + */ +@Component +public class DownloadFactory { + + @Resource + private YPCF002Download ypcf002Download; + @Resource + private LYRKDownload lyrkDownload; + @Resource + private GMRKDownload gmrkDownload; + @Resource + private LYCKDownload lyckDownload; + + /** + * 第三方单据类型 + * @param collectOrderRequest + * @return + */ + public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest){ + String busType = collectOrderRequest.getBusType(); + if(busType == null){ + return ResultVOUtils.error("下载失败，未配置业务类型"); + } + if(busType.equals(BusTypeConstant.YPCF002.getBusType())){ + return ypcf002Download.downloadOrder(collectOrderRequest); + } else if(busType.equals(BusTypeConstant.CGJH001.getBusType())){ + return ResultVOUtils.error("下载失败，未配置业务类型"); + } else if(busType.equals(BusTypeConstant.LYRK.getBusType())){ + return lyrkDownload.downloadOrder(collectOrderRequest); + } else if(busType.equals(BusTypeConstant.GMRK.getBusType())){ + return gmrkDownload.downloadOrder(collectOrderRequest); + } else if(busType.equals(BusTypeConstant.LYCK.getBusType())){ + return lyckDownload.downloadOrder(collectOrderRequest); + } + return ResultVOUtils.error("下载失败，未配置业务类型"); + } + +} diff --git a/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java b/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java index 7005874e7..7795b7c41 100644 --- a/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java +++ b/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java @@ -2,7 +2,6 @@ package com.glxp.api.service.collect; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollUtil; -import cn.hutool.core.lang.Assert; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -17,7 +16,6 @@ import com.glxp.api.exception.JsonException; import com.glxp.api.http.ErpBasicClient; import com.glxp.api.req.basic.GetSickPrescribeRequest; import com.glxp.api.req.collect.CollectOrderRequest; -import com.glxp.api.req.inout.FilterOrderRequest; import com.glxp.api.res.PageSimpleResponse; import com.glxp.api.res.basic.BasicSkPrescribeResponse; import com.glxp.api.service.basic.*; @@ -47,6 +45,8 @@ public class IoCollectOriginService { IoCollectOrderService collectOrderService; @Resource IoCollectOrderBizService collectOrderBizService; + @Resource + private DownloadFactory downloadFactory; public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { @@ -90,23 +90,7 @@ public class IoCollectOriginService { } public BaseResponse downloadOrderV2(CollectOrderRequest collectOrderRequest) { - //拉取药品处方 - if (collectOrderRequest.getBusType().equals("YPCF002")) { - GetSickPrescribeRequest getSickPrescribeRequest = new GetSickPrescribeRequest(); - getSickPrescribeRequest.setPage(1); - getSickPrescribeRequest.setLimit(100); - getSickPrescribeRequest.setCode(collectOrderRequest.getBillNo()); - getSickPrescribeRequest.setThirdSys("thirdId"); - getSickPrescribeRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); - getSickPrescribeRequest.setFromType(collectOrderRequest.getFromType()); - BaseResponse> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest); - if (baseResponse.getCode() == 20000) { - List list = baseResponse.getData().getList(); - collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); - return ResultVOUtils.success("下载成功"); - } - } - return ResultVOUtils.error("下载失败"); + return downloadFactory.downloadOrder(collectOrderRequest); } diff --git a/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java b/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java new file mode 100644 index 000000000..47f89c9bd --- /dev/null +++ b/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java @@ -0,0 +1,15 @@ +package com.glxp.api.service.collect.down; + +import com.glxp.api.common.res.BaseResponse; +import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.req.collect.CollectOrderRequest; +import org.springframework.stereotype.Service; + +@Service +public class GMRKDownload implements IDownload{ + + @Override + public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { + return ResultVOUtils.error("下载失败"); + } +} diff --git a/src/main/java/com/glxp/api/service/collect/down/IDownload.java b/src/main/java/com/glxp/api/service/collect/down/IDownload.java new file mode 100644 index 000000000..0015890f6 --- /dev/null +++ b/src/main/java/com/glxp/api/service/collect/down/IDownload.java @@ -0,0 +1,12 @@ +package com.glxp.api.service.collect.down; + +import com.glxp.api.common.res.BaseResponse; +import com.glxp.api.req.collect.CollectOrderRequest; + +/** + * 下载接口 + */ +public interface IDownload { + BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest); + +} diff --git a/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java b/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java new file mode 100644 index 000000000..0634e6b1b --- /dev/null +++ b/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java @@ -0,0 +1,40 @@ +package com.glxp.api.service.collect.down; + +import com.glxp.api.common.res.BaseResponse; +import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.entity.collect.IoCollectOrder; +import com.glxp.api.http.ErpBasicClient; +import com.glxp.api.req.basic.GetSickPrescribeRequest; +import com.glxp.api.req.collect.CollectOrderRequest; +import com.glxp.api.res.PageSimpleResponse; +import com.glxp.api.service.collect.IoCollectOrderService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.List; + +@Service +public class LYCKDownload implements IDownload{ + @Resource + private ErpBasicClient erpBasicClient; + @Resource + private IoCollectOrderService collectOrderService; + + @Override + public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { + GetSickPrescribeRequest getSickPrescribeRequest = new GetSickPrescribeRequest(); + getSickPrescribeRequest.setPage(1); + getSickPrescribeRequest.setLimit(100); + getSickPrescribeRequest.setCode(collectOrderRequest.getBillNo()); + getSickPrescribeRequest.setThirdSys("thirdId"); + getSickPrescribeRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); + getSickPrescribeRequest.setFromType(collectOrderRequest.getFromType()); + BaseResponse> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest); + if (baseResponse.getCode() == 20000) { + List list = baseResponse.getData().getList(); + collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); + return ResultVOUtils.success("下载成功"); + } + return ResultVOUtils.error("下载失败"); + } +} diff --git a/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java b/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java new file mode 100644 index 000000000..bdf5baff4 --- /dev/null +++ b/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java @@ -0,0 +1,15 @@ +package com.glxp.api.service.collect.down; + +import com.glxp.api.common.res.BaseResponse; +import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.req.collect.CollectOrderRequest; +import org.springframework.stereotype.Service; + +@Service +public class LYRKDownload implements IDownload { + + @Override + public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { + return ResultVOUtils.error("下载失败"); + } +} diff --git a/src/main/java/com/glxp/api/service/collect/down/YPCF002Download.java b/src/main/java/com/glxp/api/service/collect/down/YPCF002Download.java new file mode 100644 index 000000000..3b5a078fb --- /dev/null +++ b/src/main/java/com/glxp/api/service/collect/down/YPCF002Download.java @@ -0,0 +1,40 @@ +package com.glxp.api.service.collect.down; + +import com.glxp.api.common.res.BaseResponse; +import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.entity.collect.IoCollectOrder; +import com.glxp.api.http.ErpBasicClient; +import com.glxp.api.req.basic.GetSickPrescribeRequest; +import com.glxp.api.req.collect.CollectOrderRequest; +import com.glxp.api.res.PageSimpleResponse; +import com.glxp.api.service.collect.IoCollectOrderService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.List; + +@Service +public class YPCF002Download implements IDownload{ + @Resource + private ErpBasicClient erpBasicClient; + @Resource + private IoCollectOrderService collectOrderService; + + @Override + public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { + GetSickPrescribeRequest getSickPrescribeRequest = new GetSickPrescribeRequest(); + getSickPrescribeRequest.setPage(1); + getSickPrescribeRequest.setLimit(100); + getSickPrescribeRequest.setCode(collectOrderRequest.getBillNo()); + getSickPrescribeRequest.setThirdSys("thirdId"); + getSickPrescribeRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); + getSickPrescribeRequest.setFromType(collectOrderRequest.getFromType()); + BaseResponse> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest); + if (baseResponse.getCode() == 20000) { + List list = baseResponse.getData().getList(); + collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); + return ResultVOUtils.success("下载成功"); + } + return ResultVOUtils.error("下载失败"); + } +} From 0ffa77d1e0cc64b531e3c55fc450253d11499598 Mon Sep 17 00:00:00 2001 From: yewj Date: Fri, 6 Sep 2024 19:41:44 +0800 Subject: [PATCH 2/8] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E5=A4=87=E4=BB=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../api/controller/inout/IoCodeTempController.java | 12 ++++++------ .../api/service/collect/IoCollectOriginService.java | 2 ++ .../glxp/api/service/inout/IoSplitCodeService.java | 9 +++++---- 3 files changed, 13 insertions(+), 10 deletions(-) diff --git a/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java b/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java index dc07e2d68..82c5e82e4 100644 --- a/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java +++ b/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java @@ -225,9 +225,9 @@ public class IoCodeTempController extends BaseController { UdiEntity udiEntity = FilterUdiUtils.getUdi(code); if (udiEntity == null) { String viewType = addEnterCodeRequest.getViewType(); - if (viewType.equals("tagCode")){ + if (viewType.equals("tagCode")) { IoCollectOrder collectOrder = collectOrderService.getByBillNo(code); - if (collectOrder == null ){ + if (collectOrder == null) { //=============================================// //本地数据库 无此单据时 触发 用billNo 到 处方下载方法 进行下载 CollectOrderRequest collectOrderRequest = new CollectOrderRequest(); @@ -235,23 +235,23 @@ public class IoCodeTempController extends BaseController { collectOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); collectOrderRequest.setBillNo(code); BaseResponse baseResponse = collectOriginService.downloadOrderV2(collectOrderRequest); - if (ResultEnum.SUCCESS.getCode() == baseResponse.getCode()){ + if (ResultEnum.SUCCESS.getCode() == baseResponse.getCode()) { collectOrder = collectOrderService.getByBillNo(code); //=============================================// BaseResponse response = ResultVOUtils.error(601, code); response.setData(collectOrder); return response; - }else { + } else { BaseResponse response = ResultVOUtils.error(501, "UDI码格式错误"); response.setData(originCode); return response; } - }else { + } else { BaseResponse response = ResultVOUtils.error(601, code); response.setData(collectOrder); return response; } - } else{ + } else { String sptmtodi = systemParamConfigService.selectValueByParamKey(Constant.SPTM_TO_DI); if (sptmtodi.equals("1")) { if (code.length() == 13) { diff --git a/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java b/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java index 7795b7c41..daf0994b8 100644 --- a/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java +++ b/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java @@ -2,6 +2,7 @@ package com.glxp.api.service.collect; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.lang.Assert; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -16,6 +17,7 @@ import com.glxp.api.exception.JsonException; import com.glxp.api.http.ErpBasicClient; import com.glxp.api.req.basic.GetSickPrescribeRequest; import com.glxp.api.req.collect.CollectOrderRequest; +import com.glxp.api.req.inout.FilterOrderRequest; import com.glxp.api.res.PageSimpleResponse; import com.glxp.api.res.basic.BasicSkPrescribeResponse; import com.glxp.api.service.basic.*; diff --git a/src/main/java/com/glxp/api/service/inout/IoSplitCodeService.java b/src/main/java/com/glxp/api/service/inout/IoSplitCodeService.java index eefb8743d..46bfe88d7 100644 --- a/src/main/java/com/glxp/api/service/inout/IoSplitCodeService.java +++ b/src/main/java/com/glxp/api/service/inout/IoSplitCodeService.java @@ -587,10 +587,11 @@ public class IoSplitCodeService extends ServiceImpl 0 ? lockCount : 0); + splitFifoInv.setReCount(IntUtil.value(splitFifoInv.getInCount()) - IntUtil.value(splitFifoInv.getOutCount())); + splitFifoInv.setAvailableCount(IntUtil.value(splitFifoInv.getInCount()) - IntUtil.value(splitFifoInv.getLockCount()) - IntUtil.value(splitFifoInv.getOutCount())); splitFifoInvService.updateById(splitFifoInv); } if (count >= needCount) { From b3a9d01651e20b05cada1e8399c29320cbf12452 Mon Sep 17 00:00:00 2001 From: yewj Date: Sat, 7 Sep 2024 15:48:55 +0800 Subject: [PATCH 3/8] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E5=A4=87=E4=BB=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../IoCollectOrderCodeManController.java | 46 ++++++-- .../inout/IoCodeTempController.java | 105 +++++++++++++++++- .../api/req/inout/AddEnterCodeRequest.java | 4 + .../api/req/inout/AddOrderCodeRequest.java | 41 +++++++ .../glxp/api/req/inout/AddTagCodeReqeust.java | 5 +- .../com/glxp/api/res/inout/AddCodeResult.java | 3 + .../api/res/inout/VailCodeResultResponse.java | 14 +++ .../api/res/inout/VailTagResultResponse.java | 13 +++ 8 files changed, 215 insertions(+), 16 deletions(-) create mode 100644 src/main/java/com/glxp/api/req/inout/AddOrderCodeRequest.java create mode 100644 src/main/java/com/glxp/api/res/inout/VailCodeResultResponse.java create mode 100644 src/main/java/com/glxp/api/res/inout/VailTagResultResponse.java diff --git a/src/main/java/com/glxp/api/controller/collect/IoCollectOrderCodeManController.java b/src/main/java/com/glxp/api/controller/collect/IoCollectOrderCodeManController.java index 99f9ad48b..673272fa5 100644 --- a/src/main/java/com/glxp/api/controller/collect/IoCollectOrderCodeManController.java +++ b/src/main/java/com/glxp/api/controller/collect/IoCollectOrderCodeManController.java @@ -1,5 +1,6 @@ package com.glxp.api.controller.collect; +import cn.hutool.core.collection.CollUtil; import com.github.pagehelper.PageInfo; import com.glxp.api.common.enums.ResultEnum; import com.glxp.api.common.res.BaseResponse; @@ -11,6 +12,8 @@ import com.glxp.api.req.inout.AddTagCodeReqeust; import com.glxp.api.req.inout.DeleteTageCodeRequest; import com.glxp.api.res.PageSimpleResponse; import com.glxp.api.res.collect.CollectOrderCodeManResponse; +import com.glxp.api.res.inout.VailCodeResultResponse; +import com.glxp.api.res.inout.VailTagResultResponse; import com.glxp.api.service.auth.SysWorkplaceService; import com.glxp.api.service.basic.UdiRelevanceService; import com.glxp.api.service.collect.IoCollectOrderBizService; @@ -18,6 +21,7 @@ import com.glxp.api.service.collect.IoCollectOrderCodeManService; import com.glxp.api.service.collect.IoCollectOrderService; import com.glxp.api.util.GennerOrderUtils; import lombok.extern.slf4j.Slf4j; +import org.json.JSONException; import org.springframework.validation.BindingResult; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; @@ -26,6 +30,7 @@ import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; import javax.validation.Valid; +import java.util.ArrayList; import java.util.List; @Slf4j @@ -37,15 +42,6 @@ public class IoCollectOrderCodeManController extends BaseController { IoCollectOrderService collectOrderService; @Resource IoCollectOrderCodeManService collectOrderCodeManService; - @Resource - IoCollectOrderBizService collectOrderBizService; - - @Resource - UdiRelevanceService udiRelevanceService; - @Resource - GennerOrderUtils gennerOrderUtils; - @Resource - SysWorkplaceService sysWorkPlaceService; /** * 器械拆零处方赋码明细 @@ -82,6 +78,38 @@ public class IoCollectOrderCodeManController extends BaseController { return ResultVOUtils.success(collectOrder); } + /** + * 器械拆零处方赋码（批量赋码) + * + * @return + */ + @PostMapping("/udiwms/ioSplit/collect/order/batchAddCode") + public BaseResponse batchAddCode(@RequestBody @Valid AddTagCodeReqeust addTagCodeReqeust, + BindingResult bindingResult) { + if (bindingResult.hasErrors()) { + return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage()); + } + IoCollectOrder collectOrder = null; + VailTagResultResponse vailTagResultResponse = new VailTagResultResponse(); + List vailCodeResultResponses = new ArrayList<>(); + if (CollUtil.isNotEmpty(addTagCodeReqeust.getCodeList())) { + for (String code : addTagCodeReqeust.getCodeList()) { + VailCodeResultResponse vailCodeResultResponse = new VailCodeResultResponse(); + addTagCodeReqeust.setCode(code); + vailCodeResultResponse.setCode(code); + try { + collectOrder = collectOrderCodeManService.prescribeTagCode(addTagCodeReqeust); + } catch (JSONException e) { + vailCodeResultResponse.setErrMsg(e.getMessage()); + vailCodeResultResponse.setStatus(2); + } + } + } + vailTagResultResponse.setCollectOrder(collectOrder); + vailTagResultResponse.setVailCodeResultResponses(vailCodeResultResponses); + return ResultVOUtils.success(vailCodeResultResponses); + } + @PostMapping("/udiwms/ioSplit/collect/code/remove") public BaseResponse removeCode(@RequestBody @Valid DeleteTageCodeRequest deleteTageCodeRequest, diff --git a/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java b/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java index 82c5e82e4..dbdb30b54 100644 --- a/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java +++ b/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java @@ -8,6 +8,7 @@ import com.glxp.api.entity.inv.InvProductDetailEntity; import com.glxp.api.exception.JsonException; import com.glxp.api.req.collect.CollectOrderRequest; import com.glxp.api.res.inout.IoOrderDetailCodeResponse; +import com.glxp.api.res.inout.VailCodeResultResponse; import com.glxp.api.service.collect.IoCollectOrderService; import com.glxp.api.service.collect.IoCollectOriginService; import com.glxp.api.service.inout.impl.IoCodeService; @@ -44,6 +45,7 @@ import com.glxp.api.util.*; import com.glxp.api.util.udi.FilterUdiUtils; import com.glxp.api.util.udi.UdiCalCountUtil; import org.apache.commons.lang3.StringUtils; +import org.springframework.transaction.annotation.Transactional; import org.springframework.validation.BindingResult; import org.springframework.web.bind.annotation.*; @@ -91,8 +93,6 @@ public class IoCodeTempController extends BaseController { @Resource IoCodeService codeService; @Resource - InvPreProductDetailService invPreProductDetailService; - @Resource IoAddInoutService ioAddInoutService; @Resource IoOrderDetailCodeService ioOrderDetailCodeService; @@ -282,7 +282,7 @@ public class IoCodeTempController extends BaseController { UdiRelevanceResponse checkUdi = udiRelevanceService.selectByNameCode(udiEntity.getUdi()); if (checkUdi == null) { - return ResultVOUtils.error(500, "耗材字典不存在此产品！"); + return ResultVOUtils.error(500, "产品字典不存在此产品！"); } boolean checkSuccess = true; String lostMsg = ""; @@ -338,6 +338,100 @@ public class IoCodeTempController extends BaseController { } + @AuthRuleAnnotation("") + @PostMapping("warehouse/inout/batchVailCode") + public BaseResponse batchVailCode(@RequestBody AddEnterCodeRequest addEnterCodeRequest) { + List codeList = addEnterCodeRequest.getCodeList(); + if (CollUtil.isEmpty(codeList)) + return ResultVOUtils.error(500, "追溯码不能为空"); + codeList = codeList.stream().distinct().collect(Collectors.toList()); + List vailCodeResultResponses = new ArrayList<>(); + for (String code : codeList) { + VailCodeResultResponse vailCodeResultResponse = new VailCodeResultResponse(); + UdiEntity udiEntity = FilterUdiUtils.getUdi(code); + vailCodeResultResponse.setCode(code); + vailCodeResultResponse.setStatus(1); + vailCodeResultResponse.setErrMsg("解析正确"); + vailCodeResultResponses.add(vailCodeResultResponse); + if (udiEntity == null) { + vailCodeResultResponse.setStatus(2); + vailCodeResultResponse.setErrMsg("追溯码格式错误"); + continue; + } + UdiRelevanceResponse checkUdi = udiRelevanceService.selectByNameCode(udiEntity.getUdi()); + if (checkUdi == null) { + vailCodeResultResponse.setStatus(2); + vailCodeResultResponse.setErrMsg("产品字典不存在此产品"); + continue; + } + } + return ResultVOUtils.success(vailCodeResultResponses); + } + + + @RepeatSubmit() + @AuthRuleAnnotation("") + @PostMapping("warehouse/inout/batchAddCode") + @CusRedissonAnnotation(cacheName = RedissonCacheKey.WEB_ADD_CODE, key = {"#addOrderCodeRequest.corpOrderId", "#addOrderCodeRequest.codeList"}, timeOutMsg = "系统正在处理，请勿重复提交") + @Log(title = "单据管理", businessType = BusinessType.INSERT) + public BaseResponse batchAddCode(@RequestBody AddOrderCodeRequest addOrderCodeRequest, BindingResult bindingResult) { + + if (bindingResult.hasErrors()) { + return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage()); + } + AddCodeResult addCodeResult = new AddCodeResult(); + List codeList = addOrderCodeRequest.getCodeList(); + if (CollUtil.isEmpty(codeList)) + return ResultVOUtils.error(500, "追溯码不能为空"); + List vailCodeResultResponses = new ArrayList<>(); + for (String code : codeList) { + AddOrderRequest addOrderRequest = new AddOrderRequest(); + BeanUtils.copyProperties(addOrderCodeRequest, addOrderRequest); + if (StringUtils.isBlank(code)) return ResultVOUtils.error(ResultEnum.DATA_ERROR); + if (code.endsWith("\u001D")) { + code = code.replace("\u001D", ""); + } + UdiEntity udiEntity = FilterUdiUtils.getUdi(code); + if (udiEntity == null) + return ResultVOUtils.error(500, "无效条码！"); + + if (StrUtil.isNotEmpty(addOrderRequest.getBatchNo())) { + udiEntity.setBatchNo(addOrderRequest.getBatchNo()); + } + if (StrUtil.isNotEmpty(addOrderRequest.getProduceDate())) { + udiEntity.setProduceDate(addOrderRequest.getProduceDate()); + } + if (StrUtil.isNotEmpty(addOrderRequest.getExpireDate())) { + udiEntity.setExpireDate(addOrderRequest.getExpireDate()); + } + if (StrUtil.isNotEmpty(addOrderRequest.getSerialNo())) { + udiEntity.setSerialNo(addOrderRequest.getSerialNo()); + } + BaseResponse baseResponse = null; + if (IntUtil.value(udiEntity.getProductType()) == 2) { + baseResponse = adddGrugOrder(addOrderRequest, udiEntity, code); + } else { + baseResponse = addMaterOrder(addOrderRequest, udiEntity, code); + } + VailCodeResultResponse vailCodeResultResponse = new VailCodeResultResponse(); + if (baseResponse.getCode() == 20000) { + vailCodeResultResponse.setCode(code); + vailCodeResultResponse.setStatus(1); + vailCodeResultResponse.setErrMsg("正确"); + AddCodeResult temp = (AddCodeResult) baseResponse.getData(); + addCodeResult.setOrderId(temp.getOrderId()); + } else { + vailCodeResultResponse.setCode(code); + vailCodeResultResponse.setStatus(2); + vailCodeResultResponse.setErrMsg(baseResponse.getMessage()); + } + vailCodeResultResponses.add(vailCodeResultResponse); + } + addCodeResult.setVailCodeResultResponses(vailCodeResultResponses); + return ResultVOUtils.success(); + } + + public String checkNewCode(UdiEntity originEnity, String newCode) { UdiEntity newEntity = FilterUdiUtils.getUdi(originEnity.getUdi() + newCode); if (newEntity == null || originEnity == null) { @@ -396,10 +490,9 @@ public class IoCodeTempController extends BaseController { } else { return addMaterOrder(addOrderRequest, udiEntity, code); } - } - + @Transactional(rollbackFor = Exception.class) public BaseResponse addMaterOrder(AddOrderRequest addOrderRequest, UdiEntity udiEntity, String code) { AddCodeResult addCodeResult = new AddCodeResult(); @@ -981,12 +1074,12 @@ public class IoCodeTempController extends BaseController { return ResultVOUtils.success(addCodeResult); } + @Transactional(rollbackFor = Exception.class) public BaseResponse adddGrugOrder(AddOrderRequest addOrderRequest, UdiEntity udiEntity, String code) { AddCodeResult addCodeResult = new AddCodeResult(); BasicBussinessTypeEntity bussinessTypeEntity = basicBussinessTypeService.findByAction(addOrderRequest.getAction()); InvWarehouseEntity invWarehouseEntity = invWarehouseService.findByInvSubByCode(addOrderRequest.getInvCode()); - //批次号校验 //判断此产品是否开启允许无批次号 UdiProductEntity udiInfoEntity = udiProductService.findByNameCode(udiEntity.getUdi()); diff --git a/src/main/java/com/glxp/api/req/inout/AddEnterCodeRequest.java b/src/main/java/com/glxp/api/req/inout/AddEnterCodeRequest.java index db6a5a7e1..6068851d5 100644 --- a/src/main/java/com/glxp/api/req/inout/AddEnterCodeRequest.java +++ b/src/main/java/com/glxp/api/req/inout/AddEnterCodeRequest.java @@ -2,10 +2,14 @@ package com.glxp.api.req.inout; import lombok.Data; +import java.util.List; + @Data public class AddEnterCodeRequest { private String originCode; private String workPlaceCode; + private String busType; private String code; + private List codeList; private String viewType; } diff --git a/src/main/java/com/glxp/api/req/inout/AddOrderCodeRequest.java b/src/main/java/com/glxp/api/req/inout/AddOrderCodeRequest.java new file mode 100644 index 000000000..515b71c91 --- /dev/null +++ b/src/main/java/com/glxp/api/req/inout/AddOrderCodeRequest.java @@ -0,0 +1,41 @@ +package com.glxp.api.req.inout; + +import lombok.Data; + +import javax.validation.constraints.NotNull; +import java.util.List; + +@Data +public class AddOrderCodeRequest { + + /** + * 工位 + */ + @NotNull(message = "工位编码不能为空") + private Long workPlaceCode; + /** + * 业务类型 + */ + @NotNull(message = "业务类型不能为空") + private String splitBusType; + /** + * 本地订单号 + */ + @NotNull(message = "本地单号不能为空") + private String corpOrderId; + /** + * 追溯码 + */ + private String code; + /** + * 追溯码列表 + */ + @NotNull(message = "溯码不能为空") + private List codeList; + /** + * 1:上货；2：退货 + */ + @NotNull(message = "上货方式不能为空") + private Integer inoutType; + +} diff --git a/src/main/java/com/glxp/api/req/inout/AddTagCodeReqeust.java b/src/main/java/com/glxp/api/req/inout/AddTagCodeReqeust.java index b479396d2..37884fb09 100644 --- a/src/main/java/com/glxp/api/req/inout/AddTagCodeReqeust.java +++ b/src/main/java/com/glxp/api/req/inout/AddTagCodeReqeust.java @@ -3,6 +3,7 @@ package com.glxp.api.req.inout; import lombok.Data; import javax.validation.constraints.NotNull; +import java.util.List; @Data public class AddTagCodeReqeust { @@ -15,9 +16,11 @@ public class AddTagCodeReqeust { /** * udi码/药品追溯码 */ - @NotNull(message = "追溯码不能为空") private String code; + + private List codeList; + private String billNo; private Long workPlaceCode; diff --git a/src/main/java/com/glxp/api/res/inout/AddCodeResult.java b/src/main/java/com/glxp/api/res/inout/AddCodeResult.java index 1cec863cb..69fd32ef6 100644 --- a/src/main/java/com/glxp/api/res/inout/AddCodeResult.java +++ b/src/main/java/com/glxp/api/res/inout/AddCodeResult.java @@ -2,8 +2,11 @@ package com.glxp.api.res.inout; import lombok.Data; +import java.util.List; + @Data public class AddCodeResult { private String orderId; private String errMsg; + List vailCodeResultResponses; } diff --git a/src/main/java/com/glxp/api/res/inout/VailCodeResultResponse.java b/src/main/java/com/glxp/api/res/inout/VailCodeResultResponse.java new file mode 100644 index 000000000..11d17fcce --- /dev/null +++ b/src/main/java/com/glxp/api/res/inout/VailCodeResultResponse.java @@ -0,0 +1,14 @@ +package com.glxp.api.res.inout; + +import lombok.Data; + +@Data +public class VailCodeResultResponse { + + private String code; + /** + * 1:正常；2：异常 + */ + private Integer status; + private String errMsg; +} diff --git a/src/main/java/com/glxp/api/res/inout/VailTagResultResponse.java b/src/main/java/com/glxp/api/res/inout/VailTagResultResponse.java new file mode 100644 index 000000000..322e1f845 --- /dev/null +++ b/src/main/java/com/glxp/api/res/inout/VailTagResultResponse.java @@ -0,0 +1,13 @@ +package com.glxp.api.res.inout; + +import com.glxp.api.entity.collect.IoCollectOrder; +import lombok.Data; + +import java.util.List; + +@Data +public class VailTagResultResponse { + IoCollectOrder collectOrder; + private List vailCodeResultResponses; + +} From 2efc35861a5e18545de771bf08fe6a379eb195ea Mon Sep 17 00:00:00 2001 From: zane Date: Sat, 7 Sep 2024 17:29:16 +0800 Subject: [PATCH 4/8] =?UTF-8?q?=E6=8B=89=E5=8F=96=E5=8D=95=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/glxp/api/http/ErpBasicClient.java | 24 +++++++++++ .../api/req/thrsys/FilterThrOrderRequest.java | 8 ++++ .../glxp/api/res/thrsys/ThrOrderResponse.java | 3 +- .../api/service/collect/DownloadFactory.java | 5 ++- .../service/collect/down/CGJH001Download.java | 41 +++++++++++++++++++ .../service/collect/down/GMRKDownload.java | 26 +++++++++++- .../service/collect/down/LYCKDownload.java | 22 +++++----- .../service/collect/down/LYRKDownload.java | 26 +++++++++++- 8 files changed, 141 insertions(+), 14 deletions(-) create mode 100644 src/main/java/com/glxp/api/service/collect/down/CGJH001Download.java diff --git a/src/main/java/com/glxp/api/http/ErpBasicClient.java b/src/main/java/com/glxp/api/http/ErpBasicClient.java index a69a2d046..be4a3b21a 100644 --- a/src/main/java/com/glxp/api/http/ErpBasicClient.java +++ b/src/main/java/com/glxp/api/http/ErpBasicClient.java @@ -12,6 +12,7 @@ import com.glxp.api.entity.basic.BasicSkProjectEntity; import com.glxp.api.entity.basic.BasicSkSickerEntity; import com.glxp.api.entity.collect.IoCollectOrder; import com.glxp.api.entity.thrsys.ThrManufacturerEntity; +import com.glxp.api.entity.thrsys.ThrOrderEntity; import com.glxp.api.entity.thrsys.ThrSystemBusApiEntity; import com.glxp.api.entity.thrsys.ThrSystemEntity; import com.glxp.api.exception.JsonException; @@ -32,6 +33,7 @@ import com.glxp.api.res.basic.BasicSkSickerResponse; import com.glxp.api.res.chs.YbHcflEntityResponse; import com.glxp.api.res.collect.IoCollectOrderResponse; import com.glxp.api.res.thrsys.ThrCorpsResponse; +import com.glxp.api.res.thrsys.ThrOrderResponse; import com.glxp.api.res.thrsys.ThrProductsResponse; import com.glxp.api.res.thrsys.UdiwmsWarehouseDetail; import com.glxp.api.service.thrsys.ThrSystemService; @@ -233,6 +235,28 @@ public class ErpBasicClient { } + /** + * 获取三方单据信息 + * @param filterThrOrderRequest + * @return + */ + public BaseResponse> getThrOrders(FilterThrOrderRequest filterThrOrderRequest) { + ThrSystemEntity basicThirdSysEntity = basicThirdSysService.selectByThirdId(filterThrOrderRequest.getThirdSys()); + String url = basicThirdSysEntity.getThridUrl() + "/udiwms/erp/getThrOrders"; + try { + String response = httpOkClient.uCloudPost(url, filterThrOrderRequest); + BaseResponse> listBaseResponse = + JSONObject.parseObject(response, new TypeReference>>() { + }); + + return listBaseResponse; + } catch (Exception e) { + log.error("获取三方单据信息", e); + return ResultVOUtils.error(500, "连接第三方系统接口服务出错"); + } + } + + /** * 获取医保单据 * diff --git a/src/main/java/com/glxp/api/req/thrsys/FilterThrOrderRequest.java b/src/main/java/com/glxp/api/req/thrsys/FilterThrOrderRequest.java index dc51f5d07..806ed380b 100644 --- a/src/main/java/com/glxp/api/req/thrsys/FilterThrOrderRequest.java +++ b/src/main/java/com/glxp/api/req/thrsys/FilterThrOrderRequest.java @@ -33,5 +33,13 @@ public class FilterThrOrderRequest extends ListPageRequest { private String thirdAction; private String thirdOrderFk; private Integer allocateStatus; + /** + * 工位编码 + */ + private Long workPlaceCode; + /** + * 来源业务 + */ + private String fromType; private List erpOrderResponses; } diff --git a/src/main/java/com/glxp/api/res/thrsys/ThrOrderResponse.java b/src/main/java/com/glxp/api/res/thrsys/ThrOrderResponse.java index ca4195a68..8d0a582ae 100644 --- a/src/main/java/com/glxp/api/res/thrsys/ThrOrderResponse.java +++ b/src/main/java/com/glxp/api/res/thrsys/ThrOrderResponse.java @@ -1,6 +1,7 @@ package com.glxp.api.res.thrsys; import com.baomidou.mybatisplus.annotation.TableField; +import com.glxp.api.entity.thrsys.ThrOrderDetailEntity; import lombok.Data; import java.math.BigDecimal; @@ -20,7 +21,7 @@ public class ThrOrderResponse { private String fromInvCode; //往来仓库 private String thirdSysFk; - + private List detailList; private List subErpOrders; //增加字段 diff --git a/src/main/java/com/glxp/api/service/collect/DownloadFactory.java b/src/main/java/com/glxp/api/service/collect/DownloadFactory.java index 3b0060ad7..2ecadb04d 100644 --- a/src/main/java/com/glxp/api/service/collect/DownloadFactory.java +++ b/src/main/java/com/glxp/api/service/collect/DownloadFactory.java @@ -17,6 +17,9 @@ public class DownloadFactory { @Resource private YPCF002Download ypcf002Download; + + @Resource + private CGJH001Download cgjh001Download; @Resource private LYRKDownload lyrkDownload; @Resource @@ -37,7 +40,7 @@ public class DownloadFactory { if(busType.equals(BusTypeConstant.YPCF002.getBusType())){ return ypcf002Download.downloadOrder(collectOrderRequest); } else if(busType.equals(BusTypeConstant.CGJH001.getBusType())){ - return ResultVOUtils.error("下载失败，未配置业务类型"); + return cgjh001Download.downloadOrder(collectOrderRequest); } else if(busType.equals(BusTypeConstant.LYRK.getBusType())){ return lyrkDownload.downloadOrder(collectOrderRequest); } else if(busType.equals(BusTypeConstant.GMRK.getBusType())){ diff --git a/src/main/java/com/glxp/api/service/collect/down/CGJH001Download.java b/src/main/java/com/glxp/api/service/collect/down/CGJH001Download.java new file mode 100644 index 000000000..ac624a0aa --- /dev/null +++ b/src/main/java/com/glxp/api/service/collect/down/CGJH001Download.java @@ -0,0 +1,41 @@ +package com.glxp.api.service.collect.down; + +import com.glxp.api.common.res.BaseResponse; +import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.http.ErpBasicClient; +import com.glxp.api.req.collect.CollectOrderRequest; +import com.glxp.api.req.thrsys.FilterThrOrderRequest; +import com.glxp.api.res.PageSimpleResponse; +import com.glxp.api.res.thrsys.ThrOrderResponse; +import com.glxp.api.service.collect.IoCollectOrderService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.List; + + +@Service +public class CGJH001Download implements IDownload{ + @Resource + private ErpBasicClient erpBasicClient; + @Resource + private IoCollectOrderService collectOrderService; + + @Override + public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { + FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest(); + filterThrOrderRequest.setPage(1); + filterThrOrderRequest.setLimit(100); + filterThrOrderRequest.setBillNo(collectOrderRequest.getBillNo()); + filterThrOrderRequest.setThirdSys("thirdId"); + filterThrOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); + filterThrOrderRequest.setFromType(collectOrderRequest.getFromType()); + BaseResponse> baseResponse = erpBasicClient.getThrOrders(filterThrOrderRequest); + if (baseResponse.getCode() == 20000) { + List list = baseResponse.getData().getList(); +// collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); + return ResultVOUtils.success("下载成功"); + } + return ResultVOUtils.error("下载失败"); + } +} diff --git a/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java b/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java index 47f89c9bd..9800cf5a3 100644 --- a/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java +++ b/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java @@ -2,14 +2,38 @@ package com.glxp.api.service.collect.down; import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.http.ErpBasicClient; import com.glxp.api.req.collect.CollectOrderRequest; +import com.glxp.api.req.thrsys.FilterThrOrderRequest; +import com.glxp.api.res.PageSimpleResponse; +import com.glxp.api.res.thrsys.ThrOrderResponse; +import com.glxp.api.service.collect.IoCollectOrderService; import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; + @Service public class GMRKDownload implements IDownload{ - + @Resource + private ErpBasicClient erpBasicClient; + @Resource + private IoCollectOrderService collectOrderService; @Override public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { + FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest(); + filterThrOrderRequest.setPage(1); + filterThrOrderRequest.setLimit(100); + filterThrOrderRequest.setBillNo(collectOrderRequest.getBillNo()); + filterThrOrderRequest.setThirdSys("thirdId"); + filterThrOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); + filterThrOrderRequest.setFromType(collectOrderRequest.getFromType()); + BaseResponse> baseResponse = erpBasicClient.getThrOrders(filterThrOrderRequest); + if (baseResponse.getCode() == 20000) { + List list = baseResponse.getData().getList(); +// collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); + return ResultVOUtils.success("下载成功"); + } return ResultVOUtils.error("下载失败"); } } diff --git a/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java b/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java index 0634e6b1b..b4e4898e8 100644 --- a/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java +++ b/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java @@ -6,7 +6,9 @@ import com.glxp.api.entity.collect.IoCollectOrder; import com.glxp.api.http.ErpBasicClient; import com.glxp.api.req.basic.GetSickPrescribeRequest; import com.glxp.api.req.collect.CollectOrderRequest; +import com.glxp.api.req.thrsys.FilterThrOrderRequest; import com.glxp.api.res.PageSimpleResponse; +import com.glxp.api.res.thrsys.ThrOrderResponse; import com.glxp.api.service.collect.IoCollectOrderService; import org.springframework.stereotype.Service; @@ -22,17 +24,17 @@ public class LYCKDownload implements IDownload{ @Override public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { - GetSickPrescribeRequest getSickPrescribeRequest = new GetSickPrescribeRequest(); - getSickPrescribeRequest.setPage(1); - getSickPrescribeRequest.setLimit(100); - getSickPrescribeRequest.setCode(collectOrderRequest.getBillNo()); - getSickPrescribeRequest.setThirdSys("thirdId"); - getSickPrescribeRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); - getSickPrescribeRequest.setFromType(collectOrderRequest.getFromType()); - BaseResponse> baseResponse = erpBasicClient.getPrescribeV2(getSickPrescribeRequest); + FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest(); + filterThrOrderRequest.setPage(1); + filterThrOrderRequest.setLimit(100); + filterThrOrderRequest.setBillNo(collectOrderRequest.getBillNo()); + filterThrOrderRequest.setThirdSys("thirdId"); + filterThrOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); + filterThrOrderRequest.setFromType(collectOrderRequest.getFromType()); + BaseResponse> baseResponse = erpBasicClient.getThrOrders(filterThrOrderRequest); if (baseResponse.getCode() == 20000) { - List list = baseResponse.getData().getList(); - collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); + List list = baseResponse.getData().getList(); +// collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); return ResultVOUtils.success("下载成功"); } return ResultVOUtils.error("下载失败"); diff --git a/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java b/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java index bdf5baff4..c10942dad 100644 --- a/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java +++ b/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java @@ -2,14 +2,38 @@ package com.glxp.api.service.collect.down; import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.http.ErpBasicClient; import com.glxp.api.req.collect.CollectOrderRequest; +import com.glxp.api.req.thrsys.FilterThrOrderRequest; +import com.glxp.api.res.PageSimpleResponse; +import com.glxp.api.res.thrsys.ThrOrderResponse; +import com.glxp.api.service.collect.IoCollectOrderService; import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; + @Service public class LYRKDownload implements IDownload { - + @Resource + private ErpBasicClient erpBasicClient; + @Resource + private IoCollectOrderService collectOrderService; @Override public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { + FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest(); + filterThrOrderRequest.setPage(1); + filterThrOrderRequest.setLimit(100); + filterThrOrderRequest.setBillNo(collectOrderRequest.getBillNo()); + filterThrOrderRequest.setThirdSys("thirdId"); + filterThrOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); + filterThrOrderRequest.setFromType(collectOrderRequest.getFromType()); + BaseResponse> baseResponse = erpBasicClient.getThrOrders(filterThrOrderRequest); + if (baseResponse.getCode() == 20000) { + List list = baseResponse.getData().getList(); +// collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); + return ResultVOUtils.success("下载成功"); + } return ResultVOUtils.error("下载失败"); } } From a168f03590783cb14a1c65ea3155dec73fa4e4da Mon Sep 17 00:00:00 2001 From: zane Date: Sat, 7 Sep 2024 18:53:26 +0800 Subject: [PATCH 5/8] =?UTF-8?q?=E6=8B=89=E5=8F=96=E5=8D=95=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../api/service/collect/DownloadFactory.java | 16 +- .../collect/IoCollectOriginService.java | 1 + .../service/collect/down/CGJH001Download.java | 41 ----- .../service/collect/down/GMRKDownload.java | 39 ----- .../service/collect/down/LYCKDownload.java | 42 ----- .../service/collect/down/LYRKDownload.java | 39 ----- .../collect/down/ThrOrderDownload.java | 147 ++++++++++++++++++ 7 files changed, 153 insertions(+), 172 deletions(-) delete mode 100644 src/main/java/com/glxp/api/service/collect/down/CGJH001Download.java delete mode 100644 src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java delete mode 100644 src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java delete mode 100644 src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java create mode 100644 src/main/java/com/glxp/api/service/collect/down/ThrOrderDownload.java diff --git a/src/main/java/com/glxp/api/service/collect/DownloadFactory.java b/src/main/java/com/glxp/api/service/collect/DownloadFactory.java index 2ecadb04d..bb920c1c4 100644 --- a/src/main/java/com/glxp/api/service/collect/DownloadFactory.java +++ b/src/main/java/com/glxp/api/service/collect/DownloadFactory.java @@ -19,13 +19,7 @@ public class DownloadFactory { private YPCF002Download ypcf002Download; @Resource - private CGJH001Download cgjh001Download; - @Resource - private LYRKDownload lyrkDownload; - @Resource - private GMRKDownload gmrkDownload; - @Resource - private LYCKDownload lyckDownload; + private ThrOrderDownload thrOrderDownload; /** * 第三方单据类型 @@ -40,13 +34,13 @@ public class DownloadFactory { if(busType.equals(BusTypeConstant.YPCF002.getBusType())){ return ypcf002Download.downloadOrder(collectOrderRequest); } else if(busType.equals(BusTypeConstant.CGJH001.getBusType())){ - return cgjh001Download.downloadOrder(collectOrderRequest); + return thrOrderDownload.downloadOrder(collectOrderRequest); } else if(busType.equals(BusTypeConstant.LYRK.getBusType())){ - return lyrkDownload.downloadOrder(collectOrderRequest); + return thrOrderDownload.downloadOrder(collectOrderRequest); } else if(busType.equals(BusTypeConstant.GMRK.getBusType())){ - return gmrkDownload.downloadOrder(collectOrderRequest); + return thrOrderDownload.downloadOrder(collectOrderRequest); } else if(busType.equals(BusTypeConstant.LYCK.getBusType())){ - return lyckDownload.downloadOrder(collectOrderRequest); + return thrOrderDownload.downloadOrder(collectOrderRequest); } return ResultVOUtils.error("下载失败，未配置业务类型"); } diff --git a/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java b/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java index daf0994b8..ec2bef7ba 100644 --- a/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java +++ b/src/main/java/com/glxp/api/service/collect/IoCollectOriginService.java @@ -92,6 +92,7 @@ public class IoCollectOriginService { } public BaseResponse downloadOrderV2(CollectOrderRequest collectOrderRequest) { + //条件 return downloadFactory.downloadOrder(collectOrderRequest); } diff --git a/src/main/java/com/glxp/api/service/collect/down/CGJH001Download.java b/src/main/java/com/glxp/api/service/collect/down/CGJH001Download.java deleted file mode 100644 index ac624a0aa..000000000 --- a/src/main/java/com/glxp/api/service/collect/down/CGJH001Download.java +++ /dev/null @@ -1,41 +0,0 @@ -package com.glxp.api.service.collect.down; - -import com.glxp.api.common.res.BaseResponse; -import com.glxp.api.common.util.ResultVOUtils; -import com.glxp.api.http.ErpBasicClient; -import com.glxp.api.req.collect.CollectOrderRequest; -import com.glxp.api.req.thrsys.FilterThrOrderRequest; -import com.glxp.api.res.PageSimpleResponse; -import com.glxp.api.res.thrsys.ThrOrderResponse; -import com.glxp.api.service.collect.IoCollectOrderService; -import org.springframework.stereotype.Service; - -import javax.annotation.Resource; -import java.util.List; - - -@Service -public class CGJH001Download implements IDownload{ - @Resource - private ErpBasicClient erpBasicClient; - @Resource - private IoCollectOrderService collectOrderService; - - @Override - public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { - FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest(); - filterThrOrderRequest.setPage(1); - filterThrOrderRequest.setLimit(100); - filterThrOrderRequest.setBillNo(collectOrderRequest.getBillNo()); - filterThrOrderRequest.setThirdSys("thirdId"); - filterThrOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); - filterThrOrderRequest.setFromType(collectOrderRequest.getFromType()); - BaseResponse> baseResponse = erpBasicClient.getThrOrders(filterThrOrderRequest); - if (baseResponse.getCode() == 20000) { - List list = baseResponse.getData().getList(); -// collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); - return ResultVOUtils.success("下载成功"); - } - return ResultVOUtils.error("下载失败"); - } -} diff --git a/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java b/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java deleted file mode 100644 index 9800cf5a3..000000000 --- a/src/main/java/com/glxp/api/service/collect/down/GMRKDownload.java +++ /dev/null @@ -1,39 +0,0 @@ -package com.glxp.api.service.collect.down; - -import com.glxp.api.common.res.BaseResponse; -import com.glxp.api.common.util.ResultVOUtils; -import com.glxp.api.http.ErpBasicClient; -import com.glxp.api.req.collect.CollectOrderRequest; -import com.glxp.api.req.thrsys.FilterThrOrderRequest; -import com.glxp.api.res.PageSimpleResponse; -import com.glxp.api.res.thrsys.ThrOrderResponse; -import com.glxp.api.service.collect.IoCollectOrderService; -import org.springframework.stereotype.Service; - -import javax.annotation.Resource; -import java.util.List; - -@Service -public class GMRKDownload implements IDownload{ - @Resource - private ErpBasicClient erpBasicClient; - @Resource - private IoCollectOrderService collectOrderService; - @Override - public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { - FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest(); - filterThrOrderRequest.setPage(1); - filterThrOrderRequest.setLimit(100); - filterThrOrderRequest.setBillNo(collectOrderRequest.getBillNo()); - filterThrOrderRequest.setThirdSys("thirdId"); - filterThrOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); - filterThrOrderRequest.setFromType(collectOrderRequest.getFromType()); - BaseResponse> baseResponse = erpBasicClient.getThrOrders(filterThrOrderRequest); - if (baseResponse.getCode() == 20000) { - List list = baseResponse.getData().getList(); -// collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); - return ResultVOUtils.success("下载成功"); - } - return ResultVOUtils.error("下载失败"); - } -} diff --git a/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java b/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java deleted file mode 100644 index b4e4898e8..000000000 --- a/src/main/java/com/glxp/api/service/collect/down/LYCKDownload.java +++ /dev/null @@ -1,42 +0,0 @@ -package com.glxp.api.service.collect.down; - -import com.glxp.api.common.res.BaseResponse; -import com.glxp.api.common.util.ResultVOUtils; -import com.glxp.api.entity.collect.IoCollectOrder; -import com.glxp.api.http.ErpBasicClient; -import com.glxp.api.req.basic.GetSickPrescribeRequest; -import com.glxp.api.req.collect.CollectOrderRequest; -import com.glxp.api.req.thrsys.FilterThrOrderRequest; -import com.glxp.api.res.PageSimpleResponse; -import com.glxp.api.res.thrsys.ThrOrderResponse; -import com.glxp.api.service.collect.IoCollectOrderService; -import org.springframework.stereotype.Service; - -import javax.annotation.Resource; -import java.util.List; - -@Service -public class LYCKDownload implements IDownload{ - @Resource - private ErpBasicClient erpBasicClient; - @Resource - private IoCollectOrderService collectOrderService; - - @Override - public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { - FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest(); - filterThrOrderRequest.setPage(1); - filterThrOrderRequest.setLimit(100); - filterThrOrderRequest.setBillNo(collectOrderRequest.getBillNo()); - filterThrOrderRequest.setThirdSys("thirdId"); - filterThrOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); - filterThrOrderRequest.setFromType(collectOrderRequest.getFromType()); - BaseResponse> baseResponse = erpBasicClient.getThrOrders(filterThrOrderRequest); - if (baseResponse.getCode() == 20000) { - List list = baseResponse.getData().getList(); -// collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); - return ResultVOUtils.success("下载成功"); - } - return ResultVOUtils.error("下载失败"); - } -} diff --git a/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java b/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java deleted file mode 100644 index c10942dad..000000000 --- a/src/main/java/com/glxp/api/service/collect/down/LYRKDownload.java +++ /dev/null @@ -1,39 +0,0 @@ -package com.glxp.api.service.collect.down; - -import com.glxp.api.common.res.BaseResponse; -import com.glxp.api.common.util.ResultVOUtils; -import com.glxp.api.http.ErpBasicClient; -import com.glxp.api.req.collect.CollectOrderRequest; -import com.glxp.api.req.thrsys.FilterThrOrderRequest; -import com.glxp.api.res.PageSimpleResponse; -import com.glxp.api.res.thrsys.ThrOrderResponse; -import com.glxp.api.service.collect.IoCollectOrderService; -import org.springframework.stereotype.Service; - -import javax.annotation.Resource; -import java.util.List; - -@Service -public class LYRKDownload implements IDownload { - @Resource - private ErpBasicClient erpBasicClient; - @Resource - private IoCollectOrderService collectOrderService; - @Override - public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { - FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest(); - filterThrOrderRequest.setPage(1); - filterThrOrderRequest.setLimit(100); - filterThrOrderRequest.setBillNo(collectOrderRequest.getBillNo()); - filterThrOrderRequest.setThirdSys("thirdId"); - filterThrOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); - filterThrOrderRequest.setFromType(collectOrderRequest.getFromType()); - BaseResponse> baseResponse = erpBasicClient.getThrOrders(filterThrOrderRequest); - if (baseResponse.getCode() == 20000) { - List list = baseResponse.getData().getList(); -// collectOrderService.importPrescribe(list,collectOrderRequest.getBusType()); - return ResultVOUtils.success("下载成功"); - } - return ResultVOUtils.error("下载失败"); - } -} diff --git a/src/main/java/com/glxp/api/service/collect/down/ThrOrderDownload.java b/src/main/java/com/glxp/api/service/collect/down/ThrOrderDownload.java new file mode 100644 index 000000000..2e04f8307 --- /dev/null +++ b/src/main/java/com/glxp/api/service/collect/down/ThrOrderDownload.java @@ -0,0 +1,147 @@ +package com.glxp.api.service.collect.down; + +import cn.hutool.core.bean.BeanUtil; +import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.StrUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.glxp.api.common.res.BaseResponse; +import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.dao.thrsys.ThrOrderDao; +import com.glxp.api.dao.thrsys.ThrOrderDetailDao; +import com.glxp.api.entity.collect.IoCollectOrder; +import com.glxp.api.entity.collect.IoCollectOrderBiz; +import com.glxp.api.entity.thrsys.ThrOrderDetailEntity; +import com.glxp.api.entity.thrsys.ThrOrderEntity; +import com.glxp.api.http.ErpBasicClient; +import com.glxp.api.req.collect.CollectOrderRequest; +import com.glxp.api.req.thrsys.FilterThrOrderRequest; +import com.glxp.api.res.PageSimpleResponse; +import com.glxp.api.res.thrsys.ThrOrderResponse; +import com.glxp.api.service.collect.IoCollectOrderService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.Date; +import java.util.List; + + +/** + * 采购计划 CGJH001 + * 出入信息 LYRK GMRK LYCK + */ +@Service +public class ThrOrderDownload implements IDownload{ + @Resource + private ErpBasicClient erpBasicClient; + @Resource + private IoCollectOrderService collectOrderService; + @Resource + private ThrOrderDao thrOrderDao; + @Resource + private ThrOrderDetailDao thrOrderDetailDao; + + @Override + public BaseResponse downloadOrder(CollectOrderRequest collectOrderRequest) { + LambdaQueryWrapper w = new LambdaQueryWrapper<>(); + w.eq(StrUtil.isNotBlank(collectOrderRequest.getBillNo()),ThrOrderEntity::getBillNo,collectOrderRequest.getBillNo()); + List thrOrderEntities = thrOrderDao.selectList(w); + if(CollUtil.isNotEmpty(thrOrderEntities)){ + return this.importThrOrder(thrOrderEntities,collectOrderRequest); + }else{ + //三方拉取 + FilterThrOrderRequest filterThrOrderRequest = new FilterThrOrderRequest(); + filterThrOrderRequest.setPage(1); + filterThrOrderRequest.setLimit(100); + filterThrOrderRequest.setBillNo(collectOrderRequest.getBillNo()); + filterThrOrderRequest.setThirdSys("thirdId"); + filterThrOrderRequest.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); + filterThrOrderRequest.setFromType(collectOrderRequest.getFromType()); + BaseResponse> baseResponse = erpBasicClient.getThrOrders(filterThrOrderRequest); + if (baseResponse.getCode() == 20000) { + List list = baseResponse.getData().getList(); + if(CollUtil.isNotEmpty(list)){ + list.forEach(item -> { + ThrOrderEntity thrOrderEntity = new ThrOrderEntity(); + BeanUtil.copyProperties(item, thrOrderEntity); + thrOrderEntity.setCreateTime(new Date()); + thrOrderEntity.setUpdateTime(new Date()); + List detailList = item.getDetailList(); + if (CollUtil.isNotEmpty(detailList)) { + thrOrderDetailDao.delete(new LambdaQueryWrapper().eq(ThrOrderDetailEntity::getOrderIdFk, item.getBillNo())); + for (ThrOrderDetailEntity detail : detailList) { + detail.setCreateTime(thrOrderEntity.getCreateTime()); + detail.setUpdateTime(thrOrderEntity.getUpdateTime()); + thrOrderDetailDao.insert(detail); + } + } + thrOrderDao.insertOrUpdate(thrOrderEntity); + }); + //再次获取 + thrOrderEntities = thrOrderDao.selectList(w); + return this.importThrOrder(thrOrderEntities,collectOrderRequest); + } + } + } + return ResultVOUtils.error("下载失败"); + } + + + /** + * 下载至单据 + * @param thrOrderEntities + * @param collectOrderRequest + */ + private BaseResponse importThrOrder(List thrOrderEntities,CollectOrderRequest collectOrderRequest){ + List ioCollectOrderList = new ArrayList<>(); + if(CollUtil.isNotEmpty(thrOrderEntities)){ + for(ThrOrderEntity thrOrder: thrOrderEntities){ + IoCollectOrder ioCollectOrder = new IoCollectOrder(); + StringBuilder errorMsg = new StringBuilder(); + ioCollectOrder.setBillNo(thrOrder.getBillNo()); + ioCollectOrder.setFromType("HIS系统"); + ioCollectOrder.setFromCorp(null); + ioCollectOrder.setWorkPlaceCode(collectOrderRequest.getWorkPlaceCode()); + ioCollectOrder.setFromCorpName(""); + ioCollectOrder.setBillTime(DateUtil.parseTime(thrOrder.getBilldate())); + ioCollectOrder.setCreateTime(new Date()); + ioCollectOrder.setCreateUser(collectOrderRequest.getCreateUser()); + ioCollectOrder.setBackupOrderRemark1(null); + ioCollectOrder.setUpdateTime(new Date()); + ioCollectOrder.setSplitStatus(0); + ioCollectOrder.setTagStatus(0); + List thrOrderDetailEntities = thrOrderDetailDao.selectList(new LambdaQueryWrapper().eq(ThrOrderDetailEntity::getOrderIdFk,thrOrder.getBillNo())); + List bizList = new ArrayList<>(); + for(ThrOrderDetailEntity entity : thrOrderDetailEntities){ + IoCollectOrderBiz collectOrderBiz = new IoCollectOrderBiz(); +// BasicUdirelEntity basicUdirelEntity = basicUdirelDao.selectOne(new LambdaQueryWrapper().eq(BasicUdirelEntity::getMainId, entity.getPHYSIC_CODE())); +// if (basicUdirelEntity != null) { +// collectOrderBiz.setRelId(basicUdirelEntity.getId()); +// } else { +// errorMsg.append(entity.getPHYSIC_NAME()).append("字典未对照").append(";"); +// } + collectOrderBiz.setThrCode(null); + collectOrderBiz.setCpmctymc(null); + collectOrderBiz.setGgxh(null); + collectOrderBiz.setBatchNo(entity.getBatchNo()); + collectOrderBiz.setOrderIdFk(ioCollectOrder.getBillNo()); + collectOrderBiz.setCount(entity.getCount()); + collectOrderBiz.setMeasureUnit(null); + collectOrderBiz.setTagStatus(1); + collectOrderBiz.setUnTagCount(0); + bizList.add(collectOrderBiz); + } + if (StrUtil.isNotBlank(errorMsg)) { + ioCollectOrder.setErrorMsg(errorMsg.toString()); + ioCollectOrder.setTagStatus(4); + } + ioCollectOrder.setBizList(bizList); + ioCollectOrderList.add(ioCollectOrder); + } + collectOrderService.importPrescribe(ioCollectOrderList,collectOrderRequest.getBusType()); + return ResultVOUtils.success("下载成功"); + } + return ResultVOUtils.error("下载失败"); + } +} From a7747416c5f07f89973fd7eefdd3b80e09b7a72d Mon Sep 17 00:00:00 2001 From: yewj Date: Sun, 8 Sep 2024 15:43:55 +0800 Subject: [PATCH 6/8] =?UTF-8?q?=E4=B8=9A=E5=8A=A1=E5=8D=95=E7=94=9F?= =?UTF-8?q?=E6=88=90=E6=89=AB=E7=A0=81=E5=8D=95=E9=97=AE=E9=A2=98=EF=BC=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../collect/IoCollectOrderCodeManService.java | 2 +- .../collect/IoCollectOrderService.java | 24 +++++++++++-------- .../collect/IoCollectOrderBizMapper.xml | 7 ++++-- src/main/resources/schemas/schema_v2.4.sql | 2 -- 4 files changed, 20 insertions(+), 15 deletions(-) diff --git a/src/main/java/com/glxp/api/service/collect/IoCollectOrderCodeManService.java b/src/main/java/com/glxp/api/service/collect/IoCollectOrderCodeManService.java index e058cb146..5a111d068 100644 --- a/src/main/java/com/glxp/api/service/collect/IoCollectOrderCodeManService.java +++ b/src/main/java/com/glxp/api/service/collect/IoCollectOrderCodeManService.java @@ -430,7 +430,7 @@ public class IoCollectOrderCodeManService extends ServiceImpl ioCollectOrderList,String addr) { + public void importPrescribe(List ioCollectOrderList, String addr) { //下载处方 - if (CollUtil.isNotEmpty(ioCollectOrderList)){ + if (CollUtil.isNotEmpty(ioCollectOrderList)) { for (IoCollectOrder collectOrder : ioCollectOrderList) { if (collectOrderMapper.exists(new LambdaQueryWrapper().eq(IoCollectOrder::getBillNo, collectOrder.getBillNo()))) { continue; } SysWorkplaceDocumentEntity sysWorkplaceDocumentEntity = sysWorkplaceDocumentService.findByBusType(addr); - if (sysWorkplaceDocumentEntity == null){ + if (sysWorkplaceDocumentEntity == null) { continue; } - if(collectOrder.getWorkPlaceCode() == null){ + if (collectOrder.getWorkPlaceCode() == null) { //自动分配工位 final Long[] defaultWorkplace = {null}; List sysWorkplaces = sysWorkplaceService.getAllByBusType(addr); @@ -499,16 +498,15 @@ public class IoCollectOrderService extends ServiceImpl bizList = collectOrder.getBizList(); - if (CollUtil.isNotEmpty(bizList)){ - for(IoCollectOrderBiz collectOrderBiz : bizList){ - if(collectOrderBiz.getRelId() != null){ + if (CollUtil.isNotEmpty(bizList)) { + for (IoCollectOrderBiz collectOrderBiz : bizList) { + if (collectOrderBiz.getRelId() != null) { UdiRelevanceResponse udiRelevanceResponse = udiRelevanceService.selectByRelId(collectOrderBiz.getRelId() + ""); if (udiRelevanceResponse != null) { collectOrderBiz.setYbbm(udiRelevanceResponse.getYbbm()); collectOrderBiz.setPayFeeCode(udiRelevanceResponse.getPayFeeCode()); collectOrderBiz.setNameCode(udiRelevanceResponse.getNameCode()); if (IntUtil.value(udiRelevanceResponse.getProductsType()) == 2) { - collectOrderBiz.setGgxh(udiRelevanceResponse.getBzgg()); collectOrderBiz.setMeasureUnit(udiRelevanceResponse.getPrepnUnit()); } } @@ -688,6 +686,9 @@ public class IoCollectOrderService extends ServiceImpl