From 47a751cb301d05276ae5d75145d57b2d090fe4e1 Mon Sep 17 00:00:00 2001 From: kongzy <kongzy> Date: 星期一, 01 七月 2024 10:58:35 +0800 Subject: [PATCH] change --- src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java | 212 +++++++++++++++++++++++++++++++++-------------------- 1 files changed, 132 insertions(+), 80 deletions(-) diff --git a/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java b/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java index cd38618..ded8ae7 100644 --- a/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java +++ b/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java @@ -1,7 +1,6 @@ package com.nanometer.smartlab.service; -import com.nanometer.smartlab.dao.OpeApplyDao; -import com.nanometer.smartlab.dao.SysReagentDao; +import com.nanometer.smartlab.dao.*; import com.nanometer.smartlab.entity.*; import com.nanometer.smartlab.entity.enumtype.ApplyStatus; import com.nanometer.smartlab.entity.enumtype.SeeFlag; @@ -22,6 +21,8 @@ import org.apache.poi.xssf.usermodel.XSSFWorkbook; import org.primefaces.event.FileUploadEvent; import org.primefaces.model.UploadedFile; +import org.springframework.beans.BeanUtils; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Lazy; import org.springframework.dao.DataAccessException; @@ -52,6 +53,10 @@ @Resource(name = "opeApplyDao") OpeApplyDao opeApplyDao; + + @Autowired + SysProjectDao projectDao; + @Lazy @Resource OpeOrderService opeOrderService; @@ -70,13 +75,17 @@ private SysUserService sysUserService; @Resource private BaseMetaService baseMetaService; + @Resource + private OpeOrderDao opeOrderDao; + @Resource + private OpeReagentCodeDao opeReagentCodeDao; @Value("${activeEnv}") private String activeEnv; @Transactional(propagation = Propagation.REQUIRED) public List<OpeApply> getOpeApplyList(String reagentName, Timestamp startDeadline, String controlProduct,Timestamp endDeadline, Integer status, - String applyUserId, String approveUserId, String queryCas, + Long applyUserId, Long approveUserId, String queryCas, Integer first, Integer pageSize,String applyCode,String applyUserName,Byte isShow) { try { Map<String, Object> params = new HashMap<String, Object>(); @@ -89,7 +98,7 @@ params.put("isShow", isShow); params.put("controlProduct", controlProduct); - if (StringUtils.isNotBlank(applyUserId)) { + if (applyUserId!=null) { SysUser sysUser = sysUserService.getSysUser(applyUserId); // 不是管理员时,加入applyUserId if (sysUser.getSeeFlag().getKey() != SeeFlag.MANAGE.getKey() @@ -119,7 +128,7 @@ @Transactional(propagation = Propagation.REQUIRED) public List<OpeApply> getOpeApplyListForApproval(String applyUserName,String approvaUserName,String reagentName, Timestamp startDeadline, Timestamp endDeadline, Integer status, - String applyUserId, String approveUserId, String queryCas, + Long applyUserId, Long approveUserId, String queryCas, Integer first, Integer pageSize,String applyCode,String searchApproval) { try { Map<String, Object> params = new HashMap<String, Object>(); @@ -131,7 +140,7 @@ params.put("status", status); params.put("searchApproval",searchApproval); - if (StringUtils.isNotBlank(approveUserId)) { + if (approveUserId!=null) { SysUser sysUser = sysUserService.getSysUser(approveUserId); // 不是管理员时,加入applyUserId if (sysUser.getSeeFlag().getKey() != SeeFlag.MANAGE.getKey() @@ -161,7 +170,7 @@ } @Transactional(propagation = Propagation.REQUIRED) public int getOpeApplyTotalCountForApproval(String applyUserName,String approvaUserName,String reagentName, Timestamp startDeadline, Timestamp endDeadline, Integer status, - String applyUserId, String approveUserId, String queryCas,String applyCode,String searchApproval) { + Long applyUserId, Long approveUserId, String queryCas,String applyCode,String searchApproval) { try { Map<String, Object> params = new HashMap<String, Object>(); if (StringUtils.isNotBlank(reagentName)) { @@ -171,7 +180,7 @@ params.put("endDeadline", endDeadline); params.put("status", status); params.put("searchApproval",searchApproval); - if (StringUtils.isNotBlank(approveUserId)) { + if (approveUserId!=null) { SysUser sysUser = sysUserService.getSysUser(approveUserId); // 不是管理员时,加入applyUserId if (sysUser.getSeeFlag().getKey() != SeeFlag.MANAGE.getKey() @@ -200,7 +209,7 @@ @Transactional(propagation = Propagation.REQUIRED) public int getOpeApplyTotalCount(String reagentName, Timestamp startDeadline,String controlProduct, Timestamp endDeadline, Integer status, - String applyUserId, String approveUserId, String queryCas,String applyCode,String applyUserName,Byte isShow) { + Long applyUserId, Long approveUserId, String queryCas,String applyCode,String applyUserName,Byte isShow) { try { Map<String, Object> params = new HashMap<String, Object>(); if (StringUtils.isNotBlank(reagentName)) { @@ -212,7 +221,7 @@ params.put("isShow", isShow); params.put("controlProduct", controlProduct); - if (StringUtils.isNotBlank(applyUserId)) { + if (applyUserId!=null) { SysUser sysUser = sysUserService.getSysUser(applyUserId); // 不是管理员时,加入applyUserId if (sysUser.getSeeFlag().getKey() != SeeFlag.MANAGE.getKey() @@ -239,7 +248,7 @@ } @Transactional(propagation = Propagation.REQUIRED) - public OpeApply getOpeApply(String id) { + public OpeApply getOpeApply(Long id) { try { return this.opeApplyDao.getOpeApply(id); } catch (DataAccessException e) { @@ -251,7 +260,7 @@ @Transactional(propagation = Propagation.REQUIRED) public OpeApply insertOpeApply(OpeApply opeApply) { try { - opeApply.setId(IDUtils.uuid()); + // opeApply.setId(IDUtils.uuid()); this.opeApplyDao.insertOpeApply(opeApply); return opeApply; } catch (DuplicateKeyException ex) { @@ -283,7 +292,7 @@ } } - @Transactional(propagation = Propagation.REQUIRED) + public boolean updateOpeApply(OpeApply opeApply) { try { int row = this.opeApplyDao.updateOpeApply(opeApply); @@ -306,7 +315,7 @@ @Transactional(propagation = Propagation.REQUIRED) - public boolean updateFirst(String id) { + public boolean updateFirst(Long id) { try { Map<String, Object> params = new HashMap<String, Object>(); params.put("id",id); @@ -329,7 +338,7 @@ } @Transactional(propagation = Propagation.REQUIRED) - public boolean updateFirst2(String id) { + public boolean updateFirst2(Long id) { try { Map<String, Object> params = new HashMap<String, Object>(); params.put("id",id); @@ -373,14 +382,10 @@ } @Override - public boolean updateSelectedOpeApplyStatus(String memo, List<String> applyIds, String adminUserId, List<String> adminApplyIds,List<String> firstUserIds) { + public boolean updateSelectedOpeApplyStatus(String memo, List<Long> applyIds, Long adminUserId, List<Long> adminApplyIds,List<Long> firstUserIds) { boolean apply = false, adminApply = false; if (!CollectionUtils.isEmpty(applyIds)) { - if("gslab".equalsIgnoreCase(activeEnv)){ - apply = this.updateOpeApplyStatus(ApplyStatus.Price_CONFIRM, memo, applyIds); - }else{ - apply = this.updateOpeApplyStatus(ApplyStatus.APPROVED, memo, applyIds); - } + apply = this.updateOpeApplyStatus(ApplyStatus.APPROVED, memo, applyIds); } if (!CollectionUtils.isEmpty(adminApplyIds)) { adminApply = this.updateOpeApplyAdminStatus2(memo, adminApplyIds, adminUserId,firstUserIds); @@ -388,8 +393,7 @@ return apply || adminApply; } - @Transactional(propagation = Propagation.REQUIRED) - public boolean updateOpeApplyStatus(ApplyStatus status, String memo, List<String> applyIds) { + public boolean updateOpeApplyStatus(ApplyStatus status, String memo, List<Long> applyIds) { try { Map<String, Object> params = new HashMap<String, Object>(); params.put("status", status.getKey()); @@ -417,7 +421,7 @@ @Transactional(propagation = Propagation.REQUIRED) - public boolean updateOpeApplyAdminStatus2(String memo, List<String> applyIds, String adminUserId,List<String> firstUserIds) { + public boolean updateOpeApplyAdminStatus2(String memo, List<Long> applyIds, Long adminUserId,List<Long> firstUserIds) { try { for(int i=0;i<applyIds.size();i++){ Map<String, Object> params = new HashMap<String, Object>(); @@ -446,7 +450,7 @@ } @Transactional(propagation = Propagation.REQUIRED) - public boolean updateOpeApplyAdminStatus(String memo, List<String> applyIds, String adminUserId,List<String> firstUserIds) { + public boolean updateOpeApplyAdminStatus(String memo, List<Long> applyIds, Long adminUserId,List<Long> firstUserIds) { try { Map<String, Object> params = new HashMap<String, Object>(); params.put("userId", adminUserId); @@ -479,7 +483,7 @@ return false; } - List<String> ids = new ArrayList<String>(); + List<Long> ids = new ArrayList<Long>(); for (OpeApply opeApply : opeApplyList) { ids.add(opeApply.getId()); } @@ -529,7 +533,7 @@ } @Override - public OpeApply selectOpeApplyByPrimaryKey(String id) { + public OpeApply selectOpeApplyByPrimaryKey(Long id) { try { OpeApply info = this.opeApplyDao.selectOpeApplyByPrimaryKey(id); return info; @@ -546,7 +550,7 @@ } @Override - public int getOpeApplyReserveTotalCountByName(String id,String reagentName, String personName) { + public int getOpeApplyReserveTotalCountByName(Long id,String reagentName, String personName) { try { Map<String, Object> params = new HashMap<String, Object>(); params.put("reagentName", reagentName); @@ -561,12 +565,12 @@ } @Override - public int getOpeApplyReserveTotalCountByNameFor(String id,String reagentName, String personName,String productSn,String applyCode,Integer status,Integer isAllApply,boolean isExpired) { + public int getOpeApplyReserveTotalCountByNameFor(Long userId,String reagentName, String personName,String productSn,String applyCode,Integer status,Integer isAllApply,boolean isExpired) { try { Map<String, Object> params = new HashMap<String, Object>(); params.put("reagentName", reagentName); params.put("personName", personName); - params.put("userId",id); + params.put("userId",userId); params.put("productSn",productSn); params.put("applyCode",applyCode); if (isExpired) { @@ -583,7 +587,7 @@ } } @Override - public List<OpeApplyReserve> getOpeApplyReserveListByNameFor(String id,String reagentName, String personName, Integer first, + public List<OpeApplyReserve> getOpeApplyReserveListByNameFor(Long id,String reagentName, String personName, Integer first, Integer pageSize,String productSn,String applyCode,Integer status,Integer isAllApply,boolean isExpired) { try { Map<String, Object> params = new HashMap<String, Object>(); @@ -608,7 +612,7 @@ } } @Override - public List<OpeApplyReserve> getOpeApplyReserveListByName(String id,String reagentName, String personName, Integer first, + public List<OpeApplyReserve> getOpeApplyReserveListByName(Long id,String reagentName, String personName, Integer first, Integer pageSize) { try { Map<String, Object> params = new HashMap<String, Object>(); @@ -626,7 +630,7 @@ } @Transactional(propagation = Propagation.REQUIRED) - public boolean updaetOpeApplyPrice(BigDecimal applyPrice, String id){ + public boolean updaetOpeApplyPrice(BigDecimal applyPrice, Long id){ try{ Map<String, Object> params = new HashMap<String, Object>(); params.put("applyPrice", applyPrice); @@ -644,7 +648,7 @@ } @Transactional(propagation = Propagation.REQUIRED) - public boolean updaetOpeApplyStockFlag(int stockFlag, String id){ + public boolean updaetOpeApplyStockFlag(int stockFlag, Long id){ try{ Map<String, Object> params = new HashMap<String, Object>(); params.put("stockFlag", stockFlag); @@ -662,7 +666,7 @@ } @Transactional(propagation = Propagation.REQUIRED) - public boolean cancelApply(ApplyStatus status,String id){ + public boolean cancelApply(ApplyStatus status,Long id){ try{ Map<String, Object> params = new HashMap<String, Object>(); params.put("status", status.getKey()); @@ -680,12 +684,12 @@ } @Transactional(propagation = Propagation.REQUIRED) - public List<OpeApply>selectByReId(String id){ + public List<OpeApply>selectByReId(Long id){ return this.opeApplyDao.selectByReId(id); } @Transactional(propagation = Propagation.REQUIRED) - public void updateByReId(String newReId,String oldReId){ + public void updateByReId(Long newReId,Long oldReId){ Map<String, Object> params=new HashMap(); params.put("newReId",newReId); params.put("oldReId",oldReId); @@ -693,63 +697,75 @@ } @Override - public OpeApplyReserve getOpeApplyDetail(String id) { + public OpeApplyReserve getOpeApplyDetail(Long id) { return opeApplyDao.getOpeApplyDetail(id); } @Override - public void updateOpeApplyInfo(ApplyStatus storage, String consigneeId, Timestamp arrivalTime, String applyId) { + public void updateOpeApplyInfo(ApplyStatus storage, Long consigneeId, Timestamp arrivalTime, Long applyId,Integer arrivalNum) { Map<String,Object> params = new HashMap(); params.put("status", storage); params.put("consigneeId", consigneeId); params.put("arrivalTime", arrivalTime); params.put("applyId", applyId); + if(arrivalNum!=null){ + params.put("arrivalNum",arrivalNum); + } opeApplyDao.updateOpeApplyInfo(params); } @Override @Transactional - public void orderInputWarehouse(List<OpeApplyReserve> opeApplyList,String consigneeId,Timestamp arrivalTime) { + public void orderInputWarehouse(List<OpeApplyReserve> opeApplyList,Long consigneeId,Timestamp arrivalTime) { for (OpeApplyReserve opeApplyReserve:opeApplyList) { - //0.1获取该申购单的订单 - OpeOrder oo = opeOrderService.getOrder(opeApplyReserve.getId()); - if (oo == null) { - throw new BusinessException(ExceptionEnumCode.ORDER_ERROR,"订单不存在"); - } - //0.2检查条码->得到试剂条码列表 - List<String> codeList = opeReagentStatusService - .checkReagentCode(opeApplyReserve.getStartReagentCode2(), opeApplyReserve.getEndReagentCode2(), opeApplyReserve.getArrivalNum()); - //1.入库 - if (codeList == null){ - //无条码入库 不需要增加状态和流向 - //1.1库存表增加 - opeWarehouseReserveService.insertOpeWarehouseReserve2(opeApplyReserve, oo,consigneeId); - }else{ - //条码入库 - assert codeList.size() > 0; - //1.1入库(库存表增加) - opeWarehouseReserveService.insertOpeWarehouseReserve2(opeApplyReserve, oo,consigneeId); - //1.2试剂状态表增加,流向增加 - opeReagentStatusService.orderInputWarehouseReagentStatusAndUseFlow(opeApplyReserve,consigneeId,codeList,oo); - } - //2.更改申购单所属订单状态(判断子订单是否全部完成) - //2.1更改该申购单的状态,收货人和到货时间 - this.updateOpeApplyInfo(ApplyStatus.STORAGE,consigneeId,arrivalTime, opeApplyReserve.getId()); - //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.STORAGE); - opeOrderService.updateOpeOrderStatus(oo); - }else{ - oo.setStatus(ApplyStatus.UNCOMPLETED); - opeOrderService.updateOpeOrder(oo); + int existArrivalNum=this.opeApplyDao.getArrivalNumById(opeApplyReserve.getId()); + Integer applyNum = opeApplyReserve.getNum(); + Integer arrivalNum = opeApplyReserve.getArrivalNum(); + + if(arrivalNum<=existArrivalNum||arrivalNum>applyNum){ + throw new BusinessException(ExceptionEnumCode.ORDER_ERROR,"到货数量不正确"); } + ApplyStatus flag = ApplyStatus.STORAGE; + if(applyNum > arrivalNum) + { + flag = ApplyStatus.UNCOMPLETED; + } + //0.1获取该申购单的订单 + OpeOrder opeOrder = opeOrderService.getOrder(opeApplyReserve.getId()); + if (opeOrder == null) { + throw new BusinessException(ExceptionEnumCode.ORDER_ERROR,"订单不存在"); + } + + this.updateOpeApplyInfo(flag,consigneeId,arrivalTime, opeApplyReserve.getId(),arrivalNum); + + + OpeApply opeApply=new OpeApply(); + BeanUtils.copyProperties(opeApplyReserve,opeApply); + OpeReagentCode opeReagentCode=this.opeReagentCodeDao.getReagentCode(opeOrder.getId(),opeApply.getId()); + if(opeReagentCode==null){ + throw new BusinessException(ExceptionEnumCode.SYS_ERR, "申购编号:" + opeApply.getApplyCode() + "的试剂条形码未自动生成"); + } + + List<OpeReagentStatus> opeReagentStatusList=opeOrderService.generateReagentStatus(opeApply,opeReagentCode,opeOrder.getConsigneeUserId(),arrivalNum); + opeOrderService.generateOpeUseFlow(opeReagentStatusList); + opeOrderService.updateWareHouse(opeApply,arrivalNum-existArrivalNum); + this.opeReagentCodeDao.updateStatus(opeOrder.getId(),opeApply.getId(),1); + + + List<OpeApply> oas = opeOrderService.getOpeApplyListByOrder(opeOrder.getId()); + assert oas.size() > 0; + //子订单是否全部入库,是则父单为已入库,否则未完成 + boolean orderflag = oas.stream().allMatch(oa -> oa.getStatus() == ApplyStatus.STORAGE); + opeOrder.setConsigneeUserId(consigneeId); + opeOrder.setArrivalTime(arrivalTime); + if (orderflag){ + opeOrder.setStatus(ApplyStatus.STORAGE); + opeOrderService.updateOpeOrderStatus(opeOrder); + }else{ + opeOrder.setStatus(ApplyStatus.UNCOMPLETED); + opeOrderService.updateOpeOrder(opeOrder); + } } } /** @@ -862,7 +878,7 @@ if (approveUser == null) throw new BusinessException(ExceptionEnumCode.PARAM_NO_EXIST, i+"行:审批人不存在或者审批人姓名存在重复,导入失败"); OpeApply opeApply = new OpeApply(); - opeApply.setId(IDUtils.uuid()); + // opeApply.setId(IDUtils.uuid()); opeApply.setValidFlag(ValidFlag.VALID); opeApply.setStatus(ApplyStatus.PENDING_APPROVAL); opeApply.setApplyCode(sysSequenceService.getApplyCode()); @@ -880,8 +896,9 @@ opeApply.setApplyUserId(applyUser.getId()); //选择的审批人 opeApply.setApproveUserId(approveUser.getId()); + SysProject project=projectDao.getSysProjectByName(objective); //选择的课题组信息 - opeApply.setObjective(objective); + opeApply.setProjectId(project!=null?project.getId():null); adds.add(opeApply); @@ -894,7 +911,7 @@ } @Override - public OpeApplyReserve getOpeApplyReserveListByNameForRowData(String rowKey) { + public OpeApplyReserve getOpeApplyReserveListByNameForRowData(Long rowKey) { return opeApplyDao.getOpeApplyReserveListByNameForRowData(rowKey); } @@ -933,4 +950,39 @@ return this.opeApplyDao.getOpeApplySupplerRequireMngList(params); } + @Override + public int updateOpeApplyStatusById(Integer status, Long applyId) { + return this.opeApplyDao.updateOpeApplyStatusById(applyId,status); + } + + @Override + public List<OpeApply> getOpeApplyByOrderId(Long orderId) { + return this.opeApplyDao.getOpeApplyByOrderId(orderId); + } + + @Override + public SysReagent getReagentByApplyId(Long applyId) { + return this.opeApplyDao.getReagentByApplyId(applyId); + } + + @Override + public int getOpeApplyCountWithOrder(String applyCode, String orderCode, String orderName) { + Map<String, Object> params = new HashMap<>(); + params.put("applyCode", applyCode); + params.put("orderCode", orderCode); + params.put("orderName", orderName); + return this.opeApplyDao.getOpeApplyCountWithOrder(params); + } + + @Override + public List<OpeApply> getOpeApplyListWithOrder(String applyCode, String orderCode, String orderName, int first, int pageSize) { + Map<String, Object> params = new HashMap<>(); + params.put("applyCode", applyCode); + params.put("orderCode", orderCode); + params.put("orderName", orderName); + params.put("first", first); + params.put("pageSize", pageSize); + return this.opeApplyDao.getOpeApplyListWithOrder(params); + } + } -- Gitblit v1.9.2