| | |
| | | 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 com.nanometer.smartlab.util.ExcelUtils; |
| | | 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; |
| | | import org.springframework.stereotype.Repository; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Propagation; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | |
| | | private OpeUseFlowDao opeUseFlowDao; |
| | | @Resource |
| | | private OpeWarehouseReserveDao opeWarehouseReserveDao; |
| | | @Resource |
| | | private BaseRoleService baseRoleService; |
| | | |
| | | @Resource(name="baseMetaDao") |
| | | BaseMetaDao baseMetaDao; |
| | |
| | | |
| | | @Transactional(propagation = Propagation.REQUIRED) |
| | | public List<OpeReagentStatus> getOpeReagentStatusListForLab(String name, String articleNumber, Integer status, |
| | | String reagentCode, String userId, Integer first, Integer pageSize) { |
| | | String reagentCode, String userId,String labName, Integer first, Integer pageSize) { |
| | | try { |
| | | Map<String, Object> params = new HashMap<String, Object>(); |
| | | |
| | | params.put("name", "%" + name + "%"); |
| | | params.put("articleNumber", articleNumber); |
| | | params.put("status", status); |
| | | addParamByUserId(userId, params); |
| | | params.put("labName", labName); |
| | | // addParamByUserId(userId, params); |
| | | if (StringUtils.isNotBlank(userId)) { |
| | | SysUser sysUser = sysUserService.getSysUser(userId); |
| | | BaseRole baseRole = baseRoleService.getBaseRole(sysUser.getRoleId()); |
| | | //不是系统管理员 根据用户的课题组判断可视(用户所在课题组是否 在实验室的课题组下) |
| | | if (!"系统管理员".equals(baseRole.getName())) { |
| | | if (StringUtils.isBlank(sysUser.getProject())) { |
| | | return null; |
| | | } |
| | | params.put("project", sysUser.getProject()); |
| | | } |
| | | } |
| | | if (StringUtils.isNotBlank(reagentCode)) { |
| | | params.put("reagentCode", "%" + reagentCode + "%"); |
| | | } |
| | |
| | | |
| | | @Transactional(propagation = Propagation.REQUIRED) |
| | | public int getOpeReagentStatusTotalCountForLab(String name, String articleNumber, Integer status, String reagentCode, |
| | | String userId) { |
| | | String userId,String labName) { |
| | | try { |
| | | Map<String, Object> params = new HashMap<String, Object>(); |
| | | params.put("name", "%" + name + "%"); |
| | | |
| | | addParamByUserId(userId, params); |
| | | // addParamByUserId(userId, params); |
| | | params.put("articleNumber", articleNumber); |
| | | if (StringUtils.isNotBlank(userId)) { |
| | | SysUser sysUser = sysUserService.getSysUser(userId); |
| | | BaseRole baseRole = baseRoleService.getBaseRole(sysUser.getRoleId()); |
| | | //不是系统管理员 根据用户的课题组判断可视(用户所在课题组是否 在实验室的课题组下) |
| | | if (!"系统管理员".equals(baseRole.getName())) { |
| | | if (StringUtils.isBlank(sysUser.getProject())) { |
| | | return 0; |
| | | } |
| | | params.put("project", sysUser.getProject()); |
| | | } |
| | | } |
| | | if (StringUtils.isNotBlank(reagentCode)) { |
| | | params.put("reagentCode", "%" + reagentCode + "%"); |
| | | } |
| | | params.put("status", status); |
| | | params.put("labName", labName); |
| | | return this.opeReagentStatusDao.getOpeReagentStatusTotalCountForLab(params); |
| | | } catch (DataAccessException e) { |
| | | logger.error(e.getMessage(), e); |
| | |
| | | |
| | | // 不是管理员时,加入userid |
| | | //if (sysUser.getSeeFlag().getKey() == SeeFlag.MANAGE.getKey()||sysUser.getSeeFlag().getKey() == SeeFlag.LEADING.getKey()) { |
| | | if (sysUser.getSeeFlag().getKey() == SeeFlag.MANAGE.getKey()) { |
| | | if (sysUser.getSeeFlag().getKey() == SeeFlag.MANAGE.getKey() |
| | | && sysUser.getSeeFlag().getKey() != SeeFlag.LEADING.getKey()) { |
| | | |
| | | } else { |
| | | params.put("userId", userId); |
| | |
| | | } |
| | | |
| | | @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 |
| | |
| | | } |
| | | |
| | | |
| | | /** |
| | | * @Description: 导出 |
| | | * @date 2021/4/22 10:33 |
| | | */ |
| | | @Override |
| | | public List<Map> selectExportList(String name, String articleNumber, Integer status, String reagentCode, String userId,String labName) { |
| | | |
| | | Map<String, Object> params = new HashMap<>(); |
| | | params.put("name", name); |
| | | params.put("articleNumber", articleNumber); |
| | | params.put("status", status); |
| | | params.put("labName", labName); |
| | | if (StringUtils.isNotBlank(userId)) { |
| | | SysUser sysUser = sysUserService.getSysUser(userId); |
| | | BaseRole baseRole = baseRoleService.getBaseRole(sysUser.getRoleId()); |
| | | //不是系统管理员 根据用户的课题组判断可视(用户所在课题组是否 在实验室的课题组下) |
| | | if (!"系统管理员".equals(baseRole.getName())) { |
| | | if (StringUtils.isBlank(sysUser.getProject())) { |
| | | return null; |
| | | } |
| | | params.put("project", sysUser.getProject()); |
| | | } |
| | | } |
| | | params.put("reagentCode", reagentCode); |
| | | return opeReagentStatusDao.selectExportList(params); |
| | | } |
| | | |
| | | @Override |
| | | public void exportLabStock2Excel(List<Map> list) throws Exception { |
| | | Map<String, String> map = new LinkedHashMap<>(); |
| | | map.put("houseName", "实验室名称"); |
| | | map.put("containerCode", "临时存储库条码"); |
| | | map.put("reagentName", "试剂名称"); |
| | | map.put("reagentCode", "试剂条形码"); |
| | | map.put("articleNumber", "批号"); |
| | | map.put("cas", "cas"); |
| | | map.put("productHome", "厂家"); |
| | | map.put("supplierName", "供应商"); |
| | | map.put("remainder", "残存量"); |
| | | ExcelUtils.export2Excel(list,"实验室库存",map); |
| | | } |
| | | |
| | | @Override |
| | | public OpeReagentStatus getStatus(String reagentId, String reagentCode) { |
| | | |
| | | |
| | | return opeReagentStatusDao.getStatus(reagentId,reagentCode); |
| | | } |
| | | |
| | | |
| | | } |