From 1afdf3622484b9a54c4cc4642e38bbf5c815884f Mon Sep 17 00:00:00 2001 From: 李宇 <986321569@qq.com> Date: 星期四, 04 二月 2021 17:48:36 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java | 25 +++++++++++++++++++------ 1 files changed, 19 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java b/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java index 08482d6..e84cdfa 100644 --- a/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java +++ b/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java @@ -15,6 +15,7 @@ import com.nanometer.smartlab.util.MessageUtil; import org.apache.commons.lang.StringUtils; import org.apache.log4j.Logger; +import org.springframework.context.annotation.Lazy; import org.springframework.dao.DataAccessException; import org.springframework.dao.DataIntegrityViolationException; import org.springframework.dao.DuplicateKeyException; @@ -41,10 +42,13 @@ @Resource(name = "opeApplyDao") OpeApplyDao opeApplyDao; + @Lazy @Resource OpeOrderService opeOrderService; + @Lazy @Resource OpeReagentStatusService opeReagentStatusService; + @Lazy @Resource OpeWarehouseReserveService opeWarehouseReserveService; @@ -526,7 +530,7 @@ } @Override - public int getOpeApplyReserveTotalCountByNameFor(String id,String reagentName, String personName,String productSn,String applyCode,Integer status) { + public int getOpeApplyReserveTotalCountByNameFor(String id,String reagentName, String personName,String productSn,String applyCode,Integer status,Integer isAllApply) { try { Map<String, Object> params = new HashMap<String, Object>(); params.put("reagentName", reagentName); @@ -535,6 +539,7 @@ params.put("productSn",productSn); params.put("applyCode",applyCode); params.put("status",status); + params.put("isAllApply",isAllApply); return this.opeApplyDao.getOpeApplyReserveTotalCountFor(params); } catch (DataAccessException e) { logger.error(e.getMessage(), e); @@ -544,7 +549,7 @@ } @Override public List<OpeApplyReserve> getOpeApplyReserveListByNameFor(String id,String reagentName, String personName, Integer first, - Integer pageSize,String productSn,String applyCode,Integer status) { + Integer pageSize,String productSn,String applyCode,Integer status,Integer isAllApply) { try { Map<String, Object> params = new HashMap<String, Object>(); params.put("reagentName", reagentName); @@ -555,6 +560,7 @@ params.put("productSn",productSn); params.put("applyCode",applyCode); params.put("status",status); + params.put("isAllApply",isAllApply); return this.opeApplyDao.getOpeApplyReserveListFor(params); } catch (DataAccessException e) { logger.error(e.getMessage(), e); @@ -678,12 +684,12 @@ if (codeList == null){ //无条码入库 不需要增加状态和流向 //1.1库存表增加 - opeWarehouseReserveService.insertOpeWarehouseReserve2(opeApplyReserve, oo); + opeWarehouseReserveService.insertOpeWarehouseReserve2(opeApplyReserve, oo,consigneeId); }else{ //条码入库 assert codeList.size() > 0; //1.1入库(库存表增加) - opeWarehouseReserveService.insertOpeWarehouseReserve2(opeApplyReserve, oo); + opeWarehouseReserveService.insertOpeWarehouseReserve2(opeApplyReserve, oo,consigneeId); //1.2试剂状态表增加,流向增加 opeReagentStatusService.orderInputWarehouseReagentStatusAndUseFlow(opeApplyReserve,consigneeId,codeList,oo); } @@ -693,12 +699,12 @@ //2.2更改订单状态 List<OpeApply> oas = opeOrderService.getOpeApplyListByOrder(oo.getId()); assert oas.size() > 0; - //子订单是否全部入库,是则父单为完成,否则未完成 + //子订单是否全部入库,是则父单为已入库,否则未完成 boolean flag = oas.stream().allMatch(oa -> oa.getStatus() == ApplyStatus.STORAGE); oo.setConsigneeUserId(consigneeId); oo.setArrivalTime(arrivalTime); if (flag){ - oo.setStatus(ApplyStatus.FINISHED); + oo.setStatus(ApplyStatus.STORAGE); opeOrderService.updateOpeOrderStatus(oo); }else{ oo.setStatus(ApplyStatus.UNCOMPLETED); @@ -707,5 +713,12 @@ } } + /** + * 补贴条码更新订单的领用数量 + */ + @Override + public void btUpdateApplyAndOrder(List<OpeApply> opeList) { + + } } -- Gitblit v1.9.2