| | |
| | | import com.google.common.collect.ImmutableMap; |
| | | import com.nanometer.smartlab.dao.*; |
| | | import com.nanometer.smartlab.entity.*; |
| | | import com.nanometer.smartlab.entity.dto.PersonUseDetail; |
| | | import com.nanometer.smartlab.entity.enumtype.ValidFlag; |
| | | import org.apache.commons.lang.StringUtils; |
| | | import org.apache.log4j.Logger; |
| | |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(propagation = Propagation.REQUIRED) |
| | | public boolean updateReagentStatus3(OpeReagentStatus opeReagentStatus) { |
| | | public boolean updateReagentStatus3(List<String> reagentCodes,String userId,String projectNum,String laboratoryId,String laboratoryContainerId) { |
| | | try { |
| | | //1.判断->试剂状态是否为在仓库 |
| | | if (isAllowWarehouseUse(opeReagentStatus)) { |
| | | //1.1获得 试剂的库存选择批次 |
| | | List<OpeWarehouseReserve> owrList = this.opeWarehouseReserveService |
| | | .getOpeWarehouseReserveList(opeReagentStatus.getReagent().getId(), opeReagentStatus.getArticleNumber(),opeReagentStatus.getHouseId()); |
| | | //在同一个仓库有相同批次的试剂,根据时间早的,个数少的先扣除库存 |
| | | owrList.get(0).setReserve(owrList.get(0).getReserve() - 1); |
| | | this.opeWarehouseReserveService.updateOpeWarehouseReserve(owrList.get(0)); |
| | | for (String opeReagentStatusId : reagentCodes) { |
| | | OpeReagentStatus opeReagentStatus = this.getOpeReagentStatus(opeReagentStatusId); |
| | | opeReagentStatus.setUserId(userId); |
| | | opeReagentStatus.setProjectNum(projectNum); |
| | | //1.判断->试剂状态是否为在仓库 |
| | | if (isAllowWarehouseUse(opeReagentStatus)) { |
| | | //1.1获得 试剂的库存选择批次 |
| | | List<OpeWarehouseReserve> owrList = this.opeWarehouseReserveService |
| | | .getOpeWarehouseReserveList(opeReagentStatus.getReagent().getId(), opeReagentStatus.getArticleNumber(), opeReagentStatus.getHouseId()); |
| | | //在同一个仓库有相同批次的试剂,根据时间早的,个数少的先扣除库存 |
| | | owrList.get(0).setReserve(owrList.get(0).getReserve() - 1); |
| | | this.opeWarehouseReserveService.updateOpeWarehouseReserve(owrList.get(0)); |
| | | } |
| | | //设置 试剂状态->领用待入库 |
| | | opeReagentStatus.setStatus(ArrivalStatus.NOREGISTER); |
| | | opeReagentStatus.setHouseId(laboratoryId); |
| | | opeReagentStatus.setContainerId(laboratoryContainerId); |
| | | int row = this.updateOpeReagentStatus(opeReagentStatus); |
| | | |
| | | if (row == 0) { |
| | | return false; |
| | | } |
| | | |
| | | OpeUseFlow opeUseFlow = new OpeUseFlow(); |
| | | opeUseFlow.setReagentCode(opeReagentStatus.getReagentCode()); |
| | | opeUseFlow.setStatus(opeReagentStatus.getStatus()); |
| | | opeUseFlow.setHouseId(laboratoryId); |
| | | opeUseFlow.setContainerId(laboratoryContainerId); |
| | | opeUseFlow.setUserId(opeReagentStatus.getUserId()); |
| | | opeUseFlow.setPlace(opeReagentStatus.getPlace()); |
| | | opeUseFlow.setRemainder(opeReagentStatus.getRemainder()); |
| | | |
| | | Map<String, String> metaMap = new HashMap<>(); |
| | | metaMap.put("groupId", "operate_status"); |
| | | metaMap.put("metaKey", String.valueOf(OperateStatus.WAREHOUSEOUT.getKey())); |
| | | List<BaseMeta> baseMetaList = baseMetaDao.getBaseMetaList(metaMap); |
| | | opeUseFlow.setOperateState(baseMetaList.get(0).getId()); |
| | | |
| | | this.opeUseFlowService.insertOpeUseFlow(opeUseFlow); |
| | | } |
| | | //设置 试剂状态->领用待入库 |
| | | opeReagentStatus.setStatus(ArrivalStatus.NOREGISTER); |
| | | int row = this.opeReagentStatusDao.updateOpeReagentStatusDao(opeReagentStatus); |
| | | |
| | | if (row == 0) { |
| | | return false; |
| | | } |
| | | |
| | | |
| | | |
| | | OpeUseFlow opeUseFlow = new OpeUseFlow(); |
| | | opeUseFlow.setReagentCode(opeReagentStatus.getReagentCode()); |
| | | opeUseFlow.setStatus(opeReagentStatus.getStatus()); |
| | | opeUseFlow.setHouseId(opeReagentStatus.getHouseId()); |
| | | opeUseFlow.setContainerId(opeReagentStatus.getContainerId()); |
| | | opeUseFlow.setUserId(opeReagentStatus.getUserId()); |
| | | opeUseFlow.setPlace(opeReagentStatus.getPlace()); |
| | | opeUseFlow.setRemainder(opeReagentStatus.getRemainder()); |
| | | |
| | | Map<String, String> metaMap = new HashMap<>(); |
| | | metaMap.put("groupId", "operate_status"); |
| | | metaMap.put("metaKey", String.valueOf(OperateStatus.WAREHOUSEOUT.getKey())); |
| | | List<BaseMeta> baseMetaList = baseMetaDao.getBaseMetaList(metaMap); |
| | | opeUseFlow.setOperateState(baseMetaList.get(0).getId()); |
| | | |
| | | this.opeUseFlowService.insertOpeUseFlow(opeUseFlow); |
| | | |
| | | return true; |
| | | } catch (DuplicateKeyException ex) { |
| | | logger.warn(ex.getMessage(), ex); |
| | |
| | | logger.error(ex.getMessage(), ex); |
| | | throw new BusinessException(ExceptionEnumCode.DB_ERR, |
| | | MessageUtil.getMessageByCode(ExceptionEnumCode.DB_ERR.getCode()), ex); |
| | | }catch(Exception e){ |
| | | e.printStackTrace(); |
| | | throw new RuntimeException(e); |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | @Transactional(propagation = Propagation.REQUIRED) |
| | | public OpeReagentStatus getOpeReagentStatus(String id) { |
| | | try { |
| | | return this.opeReagentStatusDao.getOpeReagentStatus(id); |
| | |
| | | } |
| | | } |
| | | |
| | | @Transactional(propagation = Propagation.REQUIRED) |
| | | public OpeReagentStatus getOpeReagentStatusByReagentCode2(OpeReagentStatus opeReagentStatus) { |
| | | try { |
| | | OpeReagentStatus status = this.opeReagentStatusDao.getOpeReagentStatusByReagentCode(opeReagentStatus.getReagentCode()); |
| | |
| | | } |
| | | } |
| | | |
| | | @Transactional(propagation = Propagation.REQUIRED) |
| | | public OpeReagentStatus getOpeReagentStatusByReagentCode(String reagentCode) { |
| | | try { |
| | | OpeReagentStatus status = this.opeReagentStatusDao.getOpeReagentStatusByReagentCode(reagentCode); |
| | |
| | | */ |
| | | @Override |
| | | @Transactional |
| | | public void batchUpdateStatusByCode(List<OpeReagentStatus> list) throws Exception { |
| | | if(list == null || list.size() <1){ |
| | | throw new Exception("没有选择试剂"); |
| | | } |
| | | public void batchUpdateStatusByCode(List<PersonUseDetail> applyList) throws Exception { |
| | | |
| | | for (OpeReagentStatus opeReagentStatus : list) { |
| | | |
| | | |
| | | for (PersonUseDetail pu : applyList) { |
| | | |
| | | //变更试剂状态为入库 |
| | | Map<String, Object> params1 = new HashMap<>(); |
| | | String reagentCode = opeReagentStatus.getReagentCode(); |
| | | String reagentCode = pu.getReagentCode(); |
| | | params1.put("code", reagentCode); |
| | | params1.put("status",ArrivalStatus.WAREHOUSE); |
| | | opeReagentStatusDao.updateStatusByCode(params1); |
| | |
| | | |
| | | //增加数据库存 |
| | | Map<String, Object> params3 = new HashMap<>(); |
| | | String reagentId = opeReagentStatus.getReagentId(); |
| | | String articleNumber = opeReagentStatus.getArticleNumber(); |
| | | String reagentId = pu.getReagentId(); |
| | | String articleNumber = pu.getArticleNumber(); |
| | | params3.put("reagentId", reagentId); |
| | | params3.put("articleNumber", articleNumber); |
| | | opeWarehouseReserveDao.updateCount(params3); |
| | |
| | | } |
| | | |
| | | @Override |
| | | public void updateOpeReagentStatus(OpeReagentStatus opeReagentStatus) { |
| | | opeReagentStatusDao.updateOpeReagentStatusDao(opeReagentStatus); |
| | | public int updateOpeReagentStatus(OpeReagentStatus opeReagentStatus) { |
| | | return opeReagentStatusDao.updateOpeReagentStatusDao(opeReagentStatus); |
| | | } |
| | | |
| | | @Override |