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/api/ApiAction.java | 406 ++++++++++++++++++++++++++++++---------------------------- 1 files changed, 210 insertions(+), 196 deletions(-) diff --git a/src/main/java/com/nanometer/smartlab/api/ApiAction.java b/src/main/java/com/nanometer/smartlab/api/ApiAction.java index 993fe6b..6a0e601 100644 --- a/src/main/java/com/nanometer/smartlab/api/ApiAction.java +++ b/src/main/java/com/nanometer/smartlab/api/ApiAction.java @@ -9,6 +9,7 @@ import com.nanometer.smartlab.controller.MenuController; import com.nanometer.smartlab.dao.OpeReagentStatusDao; import com.nanometer.smartlab.dao.SysLaboratoryContainerDao; +import com.nanometer.smartlab.dao.SysLaboratoryDao; import com.nanometer.smartlab.dao.SysWarehouseContainerDao; import com.nanometer.smartlab.entity.*; import com.nanometer.smartlab.entity.dto.*; @@ -80,6 +81,12 @@ @Lazy @Resource private SysLaboratoryContainerDao sysLaboratoryContainerDao; + + @Lazy + @Resource + private SysLaboratoryDao sysLaboratoryDao; + + @Lazy @Resource private SysWarehouseContainerDao sysWarehouseContainerDao; @@ -121,7 +128,7 @@ } logger.info("registerTestCabinet" + data); - String userId = request.getHeader("userId"); + Long userId = Long.valueOf(request.getHeader("userId")); JSONObject retJSON = new JSONObject(); try { interfaceService.registerTestCabinet(userId, JSONObject.parseObject(data)); @@ -158,7 +165,7 @@ } logger.info("AutheTestCabinet" + data); - String userId = request.getHeader("userId"); + Long userId = Long.valueOf(request.getHeader("userId")); JSONObject retJSON = new JSONObject(); try { interfaceService.AutheTestCabinet(userId, JSONObject.parseObject(data)); @@ -192,7 +199,7 @@ data += str; } logger.info("logoutTestCabinet" + data); - String userId = request.getHeader("userId"); + Long userId = Long.valueOf(request.getHeader("userId")); JSONObject retJSON = new JSONObject(); try { interfaceService.logoutTestCabinet(userId, JSONObject.parseObject(data)); @@ -227,7 +234,7 @@ data += str; } logger.info("updateTestCabinet" + data); - String userId = request.getHeader("userId"); + Long userId = Long.valueOf(request.getHeader("userId")); JSONObject retJSON = new JSONObject(); try { interfaceService.updateTestCabinet(userId, JSONObject.parseObject(data)); @@ -262,7 +269,7 @@ data += str; } logger.info("openCabinetDoor" + data); - String userId = request.getHeader("userId"); + Long userId = Long.valueOf(request.getHeader("userId")); JSONObject retJSON = new JSONObject(); try { String returndata = interfaceService.openCabinetDoor(userId, JSONObject.parseObject(data)); @@ -385,7 +392,7 @@ // 操作状态 10 仓库入库 @ResponseBody @RequestMapping(value = "/cabinetData") - public String cabinetData(HttpServletRequest request) throws IOException { + public String cabinetData(HttpServletRequest request) throws Exception { BufferedReader br = request.getReader(); String str, data = ""; while((str = br.readLine()) != null){ @@ -393,24 +400,22 @@ } JSONObject retJSON = new JSONObject(); logger.info("cabinetData" + data); - String userId = request.getHeader("userId"); - + Long userId = StringUtils.isNotBlank(request.getHeader("userId"))?Long.valueOf(request.getHeader("userId")):null; + if(userId==null){ + throw new ApiException(ApiStatus.SYS_ERR,"传参用户ID为空"); + } // Body参数 JSONObject bodyJSONObject = new JSONObject(); bodyJSONObject = JSONObject.parseObject(data); - // 主控条码 - String controllerCode = bodyJSONObject.getString("controllerCode"); try { // 数据 String dataStr = bodyJSONObject.getString("data"); JSONArray dataJSONArray = JSONArray.parseArray(dataStr); logger.info("dataJSONArray: " + dataJSONArray); - - if( dataJSONArray.size() !=0 ){ - interfaceService.cabinetData(dataJSONArray); + interfaceService.cabinetData(dataJSONArray,userId); } retJSON.put("code", ApiStatus.OK.getRetCode()); @@ -544,7 +549,7 @@ @RequestMapping(value = "/reagentInfo") public Object getReagentInfo(@RequestParam String startTime, @RequestParam String endTime, @RequestParam String containerCode, @RequestParam String status) { logger.info("getReagentInfo start..."); - String containerid = null; + Long containerid = null; SysLaboratoryContainer laboratoryContainer = sysLaboratoryContainerDao .getSysLaboratoryContainerByContainerCode(containerCode); @@ -595,7 +600,7 @@ logger.info("getUserInfo start..."); List<SysUser> userList = sysUserService.getSysUserInfoList(startTime, endTime); - List<SysLaboratoryContainer> allLaboratoryContainerList = sysLaboratoryContainerService.getSysLaboratoryContainerList(null,null,null,null,null,null,null); + List<SysLaboratoryContainer> allLaboratoryContainerList = sysLaboratoryContainerService.getSysLaboratoryContainerList(null,null,null,null,null,null); List<SysWarehouseContainer> allWarehouseContainerList = sysWarehouseContainerService.getSysWarehouseContainerList(null,null,null,null,null); List<String> containerCodeList = new ArrayList<String>(); @@ -636,35 +641,41 @@ } - - - + /** + * 入实验室库操作 + * @param request + * @param reagentCode + * @return + */ @RequestMapping(value = "/putInLaboratory", produces = {"application/json;charset=UTF-8"}, method = RequestMethod.POST) @ResponseBody - public String putInLaboratory(HttpServletRequest request, String reagentCode, String barCode, String containerCode) { + public String putInLaboratory(HttpServletRequest request, String reagentCode, Long labId, Long labContainerId) { try { logger.info("PutInLaboratory start..."); - logger.info("Params : reagentCode[" + reagentCode + "], barCode[" + barCode + "], containerCode[" + containerCode + "]"); // 检查用户 - String idCard = this.getIdCardFromHeader(request); - if (StringUtils.isBlank(idCard)) { - throw new BusinessException(ExceptionEnumCode.PARAM_NULL, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NULL.getCode(), "用户卡号")); + Long userId = StringUtils.isNotBlank(request.getHeader("userId"))?Long.valueOf(request.getHeader("userId")):null; + if(userId==null){ + throw new ApiException(ApiStatus.SYS_ERR,"传参用户ID为空"); } - SysUser sysUser = this.sysUserService.getSysUserByIdCard(idCard); - - if (sysUser == null) { - if(idCard.length()==20){//截取长度为8的卡号再次查询 - idCard=idCard.substring(10,18); - sysUser = this.sysUserService.getSysUserByIdCard(idCard); - if(sysUser==null){ - throw new BusinessException(ExceptionEnumCode.PARAM_NO_EXIST, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NO_EXIST.getCode(), "用户卡号", idCard)); - } - }else { - throw new BusinessException(ExceptionEnumCode.PARAM_NO_EXIST, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NO_EXIST.getCode(), "用户卡号", idCard)); - } - - } +// String idCard = this.getIdCardFromHeader(request); +// if (StringUtils.isBlank(idCard)) { +// throw new BusinessException(ExceptionEnumCode.PARAM_NULL, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NULL.getCode(), "用户卡号")); +// } +// SysUser sysUser = this.sysUserService.getSysUserByIdCard(idCard); +// +// if (sysUser == null) { +// if(idCard.length()==20){//截取长度为8的卡号再次查询 +// idCard=idCard.substring(10,18); +// sysUser = this.sysUserService.getSysUserByIdCard(idCard); +// if(sysUser==null){ +// throw new BusinessException(ExceptionEnumCode.PARAM_NO_EXIST, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NO_EXIST.getCode(), "用户卡号", idCard)); +// } +// }else { +// throw new BusinessException(ExceptionEnumCode.PARAM_NO_EXIST, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NO_EXIST.getCode(), "用户卡号", idCard)); +// } +// +// } // 检查试剂条码 if (StringUtils.isBlank(reagentCode)) { @@ -672,16 +683,16 @@ } // 检查地点条码 - if (StringUtils.isBlank(barCode)) { - throw new BusinessException(ExceptionEnumCode.PARAM_NULL, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NULL.getCode(), "地点条码")); + if (labId==null) { + throw new BusinessException(ExceptionEnumCode.PARAM_NULL, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NULL.getCode(), "地点id")); } // 检查货柜条码 - if (StringUtils.isBlank(containerCode)) { - throw new BusinessException(ExceptionEnumCode.PARAM_NULL, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NULL.getCode(), "货柜条码")); + if (labContainerId==null) { + throw new BusinessException(ExceptionEnumCode.PARAM_NULL, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NULL.getCode(), "货柜id")); } - this.opeReagentStatusService.putReagentInLaboratory(reagentCode, barCode, containerCode, sysUser); + this.opeReagentStatusService.putReagentInLaboratory(reagentCode, labId, labContainerId, userId); return this.getOkResponseString(); } catch (BusinessException e) { @@ -695,91 +706,6 @@ } } -// -// -// @RequestMapping(value = "/setWarning", produces = {"application/json;charset=UTF-8"}, method = RequestMethod.POST) -// @ResponseBody -// public String setWarning(HttpServletRequest request) throws ParseException, IOException, ApiException { -// BufferedReader reader = new BufferedReader(new InputStreamReader(request.getInputStream())); -// String str = ""; -// String inputLine; -// try { -// while ((inputLine = reader.readLine()) != null) { -// str += inputLine; -// } -// reader.close(); -// } catch (IOException e) { -// System.out.println("IOException: " + e); -// } -// JSONObject jsonObject = JSON.parseObject(str); -// SysWarning sysWarning = new SysWarning(); -// if (!jsonObject.containsKey("controllerCode") -// || ! jsonObject.containsKey("data")) { -// throw new ApiException(ApiStatus.PARAM_NO_EXIST); -// } -// -// String controllerCode = jsonObject.getString("controllerCode"); -// -// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); -// String dataStr = jsonObject.getString("data"); -// -// -// JSONObject dataJson = JSON.parseObject(dataStr); -// -// if (!dataJson.containsKey("warningId") -// || !dataJson.containsKey("userId") -// || !dataJson.containsKey("warningTime") -// || !dataJson.containsKey("warningLevel") -// || !dataJson.containsKey("containerCode") -// || !dataJson.containsKey("warningPoint")) { -// throw new ApiException(ApiStatus.PARAM_NO_EXIST); -// } -// -// String containerCode = dataJson.getString("containerCode"); -// String warningId = dataJson.getString("warningId"); -// String userId = dataJson.getString("userId"); -// String warningTimeStr = dataJson.getString("warningTime"); -// Integer warningLevelInt = dataJson.getInteger("warningLevel"); -// Integer warningPoint = dataJson.getInteger("warningPoint"); -// -// sysWarning.setUserId(userId); -// sysWarning.setWarningTime(sdf.parse(warningTimeStr)); -// sysWarning.setWarningPoint(warningPoint); -// sysWarning.setWarningLevel(warningLevelInt); -// sysWarning.setWarningId(warningId); -// sysWarning.setId(IDUtils.uuid()); -// -// -// SysLaboratoryContainer laboratoryContainer = sysLaboratoryContainerDao.getSysLaboratoryContainerByContainerCode(containerCode); -// if (Objects.isNull(laboratoryContainer)) { -// SysWarehouseContainer warehouseContainer = sysWarehouseContainerDao.getSysWarehouseContainerByContainerCode(containerCode); -// if (Objects.isNull(warehouseContainer)) { -// logger.error("The containerCode:"+containerCode+" has not been exists!"); -// } else { -// sysWarning.setContainerId(warehouseContainer.getId()); -// } -// } else { -// sysWarning.setContainerId(laboratoryContainer.getId()); -// } -// JSONObject retJSON = new JSONObject(); -// try { -// sysWarningService.insert(sysWarning); -// retJSON.put("code", ApiStatus.OK.getRetCode()); -// retJSON.put("message", ApiStatus.OK.getRetMsg()); -// } catch (Exception e) { -// retJSON.put("code", ApiStatus.SYS_ERR.getRetCode()); -// StackTraceElement[] stackTraceElements = e.getStackTrace(); -// -// StringBuilder sb = new StringBuilder(); -// sb.append(e.toString()); -// for (StackTraceElement stackTraceElement : stackTraceElements) { -// sb.append("\n"); -// sb.append(stackTraceElement.toString()); -// } -// retJSON.put("message", ApiStatus.SYS_ERR.getRetMsg() + "--" + sb.toString()); -// } -// return retJSON.toJSONString(); -// } // 智能柜温度,湿度,气体浓度数据接口 @@ -827,7 +753,7 @@ e.printStackTrace(); } int type = 0; - String containerId = null; + Long containerId = null; logger.info("The containerCode:" + containerCode + " finding!"); // 查找货柜条码对应货柜信息 SysLaboratoryContainer laboratoryContainer = sysLaboratoryContainerDao @@ -886,16 +812,16 @@ } SysContainerSensors sysContainerSensors = new SysContainerSensors(); - sysContainerSensors.setContainerId(containerCode); + sysContainerSensors.setContainerId(Long.valueOf(containerCode)); TempSensors tempSensors = new TempSensors(); - tempSensors.setContainerId(containerCode); + tempSensors.setContainerId(Long.valueOf(containerCode)); /* tempSensors.setFlag(flag); */ tempSensors.setTemp(temp); tempSensors.setHumidity(humidity); tempSensors.setVoc1(voc1); tempSensors.setFlag(flag); tempSensors.setUpdateTime(sdf.parse(updateTime)); - tempSensors.setId(IDUtils.uuid()); + //tempSensors.setId(IDUtils.uuid()); tempSensors.setType(type); tempSensors.setContainerId(containerId); @@ -1019,7 +945,7 @@ } @ResponseBody @RequestMapping(value = "/downloadFile") - public HttpServletResponse downloadFile(HttpServletRequest request, String id, HttpServletResponse response){ + public HttpServletResponse downloadFile(HttpServletRequest request, Long id, HttpServletResponse response){ SysFile sysFile=this.sysFileService.getSysFileById(id); try { // path是指欲下载的文件的路径。 @@ -1113,7 +1039,7 @@ map.put("unit", user.getCompany()); map.put("Arp", user.getArp()); map.put("departmentName", user.getDepartment()); - map.put("project", user.getProject()); + map.put("projectId", user.getProjectId()); } logger.info("getUserInfo end..."); @@ -1125,21 +1051,21 @@ @ResponseBody @RequestMapping(value = "/dangerousEncodeInfo") public Object getDangerousEncodeInfo(@RequestParam String reagentName, @RequestParam String cas) { - List<DangerousEncodeVo> datalist = new ArrayList<>(); + List<DangerousEncode> datalist = new ArrayList<>(); if (StringUtils.isNotBlank(reagentName) || StringUtils.isNotBlank(cas)){ datalist = dangerousEncodeService.selectByReagentName(reagentName,cas); - for (DangerousEncodeVo dangerousEncodeVo : datalist){ - if (StringUtils.isNotBlank(dangerousEncodeVo.getContainerNumber())){ - if (dangerousEncodeVo.getContainerNumber().startsWith("0")){ - dangerousEncodeVo.setContainerName("普通型"); - }else if (dangerousEncodeVo.getContainerNumber().startsWith("1")){ - dangerousEncodeVo.setContainerName("阻燃型"); - }else if (dangerousEncodeVo.getContainerNumber().startsWith("2")){ - dangerousEncodeVo.setContainerName("抗腐蚀型"); - }else if (dangerousEncodeVo.getContainerNumber().startsWith("3")){ - dangerousEncodeVo.setContainerName("防爆型"); - }else if (dangerousEncodeVo.getContainerNumber().startsWith("4")){ - dangerousEncodeVo.setContainerName("有毒称重型"); + for (DangerousEncode dangerousEncode : datalist){ + if (StringUtils.isNotBlank(dangerousEncode.getContainerNumber())){ + if (dangerousEncode.getContainerNumber().startsWith("0")){ + dangerousEncode.setContainerName("普通型"); + }else if (dangerousEncode.getContainerNumber().startsWith("1")){ + dangerousEncode.setContainerName("阻燃型"); + }else if (dangerousEncode.getContainerNumber().startsWith("2")){ + dangerousEncode.setContainerName("抗腐蚀型"); + }else if (dangerousEncode.getContainerNumber().startsWith("3")){ + dangerousEncode.setContainerName("防爆型"); + }else if (dangerousEncode.getContainerNumber().startsWith("4")){ + dangerousEncode.setContainerName("有毒称重型"); } } } @@ -1335,28 +1261,28 @@ return ResponseModel.getErrInstance("该试剂危化品编码已存在"); } } - - //3.如果是入智能柜,则该智能柜下需要存在对应的实验室和实验室柜子 - SysWarehouseContainer sysWarehouseContainer = sysWarehouseContainerService.getSysWarehouseContainer(inWarehouseInfo.getContainerId()); - if(this.baseMetaService.getBaseMetaKey(sysWarehouseContainer.getType()).equals("200")) { - reagentReceivingDtos.setReagentCode(inWarehouseInfo.getReagentCode()); - reagentReceivingDtos.setApplyUserId(inWarehouseInfo.getUser()); - SysLaboratoryContainer sysLaboratoryContainer = sysLaboratoryContainerService.getSysLaboratoryContainerByContainerCode(sysWarehouseContainer.getContainerCode()); - if (null != sysLaboratoryContainer){ - reagentReceivingDtos.setLabId(sysLaboratoryContainer.getLaboratoryId()); - reagentReceivingDtos.setLabContainerId(sysLaboratoryContainer.getId()); - }else { - return ResponseModel.getErrInstance("该仓库货柜为智能柜,但是未创建相同货柜条码的实验室临时存储柜"); - } - } +// +// //3.如果是入智能柜,则该智能柜下需要存在对应的实验室和实验室柜子 +// SysWarehouseContainer sysWarehouseContainer = sysWarehouseContainerService.getSysWarehouseContainer(inWarehouseInfo.getContainerId()); +// if(this.baseMetaService.getBaseMetaKey(sysWarehouseContainer.getType()).equals("200")) { +// reagentReceivingDtos.setReagentCode(inWarehouseInfo.getReagentCode()); +// reagentReceivingDtos.setApplyUserId(inWarehouseInfo.getUser()); +// SysLaboratoryContainer sysLaboratoryContainer = sysLaboratoryContainerService.getSysLaboratoryContainerByContainerCode(sysWarehouseContainer.getContainerCode()); +// if (null != sysLaboratoryContainer){ +// reagentReceivingDtos.setLabId(sysLaboratoryContainer.getLaboratoryId()); +// reagentReceivingDtos.setLabContainerId(sysLaboratoryContainer.getId()); +// }else { +// return ResponseModel.getErrInstance("该仓库货柜为智能柜,但是未创建相同货柜条码的实验室临时存储柜"); +// } +// } //4.入库 sysWarehouseService.putInWarehouse(inWarehouseInfo); //5.如果是入智能柜,则需再领用到智能柜里 - if (StringUtils.isNotBlank(reagentReceivingDtos.getLabContainerId())){ - sysWarehouseService.reagentReceiving(reagentReceivingDtos); - } +// if (reagentReceivingDtos.getLabContainerId()!=null){ +// sysWarehouseService.reagentReceiving(reagentReceivingDtos); +// } return ResponseModel.getOkInstence("入库成功"); } else { @@ -1379,23 +1305,26 @@ @RequestMapping("reagentReceiving") public Object reagentReceiving(@RequestBody ReagentReceivingDto reagentReceiving) { try { - if (reagentReceiving.getReagentCode() != null && reagentReceiving.getReagentCode().size() > 0) { - - //1.校验仓库是否有该试剂 - for (int i = 0; i < reagentReceiving.getReagentCode().size(); i++) { - String reagentCode = reagentReceiving.getReagentCode().get(i); - //去试剂状态查找 是否有此试剂条码 - OpeReagentStatus ors = opeReagentStatusService.getOpeReagentStatusByReagentCode(reagentCode); - if (ors == null || ors.getStatus() != ArrivalStatus.WAREHOUSE){ - return ResponseModel.getErrInstance("仓库无此试剂"); - } - } - //2.领用 - sysWarehouseService.reagentReceiving(reagentReceiving); - return ResponseModel.getOkInstence("领用成功"); - } else { + if (reagentReceiving.getReagentCode() == null || reagentReceiving.getReagentCode().size() == 0) { return ResponseModel.getErrInstance("无效试剂条码"); } + if(reagentReceiving.getLabId()==null||reagentReceiving.getLabContainerId()==null||reagentReceiving.getApplyUserId()==null){ + return ResponseModel.getErrInstance("传参错误"); + } + //1.校验仓库是否有该试剂 + for (int i = 0; i < reagentReceiving.getReagentCode().size(); i++) { + String reagentCode = reagentReceiving.getReagentCode().get(i); + //去试剂状态查找 是否有此试剂条码 + OpeReagentStatus ors = opeReagentStatusService.getOpeReagentStatusByReagentCode(reagentCode); + if (ors == null || ors.getStatus() != ArrivalStatus.WAREHOUSE.getKey()){ + return ResponseModel.getErrInstance("仓库无此试剂"); + } + } + + //2.领用 + sysWarehouseService.reagentReceiving(reagentReceiving); + return ResponseModel.getOkInstence("领用成功"); + } catch (Exception e) { e.printStackTrace(); logger.info(e); @@ -1417,8 +1346,8 @@ if (reagentReceiving.getReagentCode() == null || reagentReceiving.getReagentCode().size() == 0) { return ResponseModel.getErrInstance("请选择申领试剂"); } - if (StringUtils.isBlank(reagentReceiving.getApplyUserId())|| StringUtils.isBlank(reagentReceiving.getLabContainerId()) - || StringUtils.isBlank(reagentReceiving.getLabId())){ + if (reagentReceiving.getApplyUserId()!=null|| reagentReceiving.getLabContainerId()!=null + || reagentReceiving.getLabId()!=null){ FacesUtils.warn("请选择申领人、实验室、货柜"); } for (String reagentCode : reagentReceiving.getReagentCode()) { @@ -1443,7 +1372,7 @@ lr.setValidFlag(ValidFlag.VALID); opeLaboratoryReserveService.insert(lr); - opeReagentStatus.setStatus(ArrivalStatus.NOREGISTER); + opeReagentStatus.setStatus(ArrivalStatus.NOREGISTER.getKey()); opeReagentStatus.setUserId(reagentReceiving.getApplyUserId()); opeReagentStatus.setHouseId(reagentReceiving.getLabId()); opeReagentStatus.setContainerId(reagentReceiving.getLabContainerId()); @@ -1457,10 +1386,9 @@ opeUseFlow.setContainerId(opeReagentStatus.getContainerId()); opeUseFlow.setUserId(opeReagentStatus.getUserId()); opeUseFlow.setPlace(opeReagentStatus.getPlace()); - opeUseFlow.setStoreType(StoreType.DIRECTSTORE); + opeUseFlow.setStoreType(StoreType.DIRECTSTORE.getKey()); opeUseFlow.setRemainder(opeUseFlowExist.getRemainder()); - BaseMeta baseMeta = baseMetaService.getBaseMeta("operate_status",String.valueOf(OperateStatus.TRANSFER.getKey()),"转移"); - opeUseFlow.setOperateState(baseMeta.getId()); + opeUseFlow.setOperateState(OperateStatus.TRANSFER.getKey()); opeUseFlow.setReceiptNumber(number); opeUseFlowService.insertOpeUseFlow(opeUseFlow); } @@ -1489,11 +1417,12 @@ return ResponseModel.getErrInstance("账户名不存在"); }else{ if (sysUser.getPassword().equals(MD5Utils.encode(user.getPassword()))){ - if (sysUser.getAdminFlag() != 0){ - user = sysUser; - }else{ - return ResponseModel.getErrInstance("用户不属于危废处理人员"); - } +// if (sysUser.getAdminFlag() != 0){ +// user = sysUser; +// }else{ +// return ResponseModel.getErrInstance("用户不属于危废处理人员"); +// } + user = sysUser; return ResponseModel.getOkInstence(user); }else{ return ResponseModel.getErrInstance("密码错误"); @@ -1551,14 +1480,14 @@ */ @ResponseBody @RequestMapping("hazardousWaste/getLabAndUser") - public Object getLabAndUser(@RequestParam(required=true) String project){ + public Object getLabAndUser(@RequestParam(required=true) Long projectId){ try { - if (StringUtils.isBlank(project)){ - return ResponseModel.getErrInstance("课题组不能为空"); + if (projectId==null){ + return ResponseModel.getErrInstance("课题组id不能为空"); } LaboratoryVo laboratoryVo = new LaboratoryVo(); - List<LaboratoryVo.Laboratory> laboratoryList = sysLaboratoryService.getLaboratoryByProject(project); - List<LaboratoryVo.LaboratoryUser> laboratoryUserList = sysUserService.getUserByProject(project); + List<LaboratoryVo.Laboratory> laboratoryList = sysLaboratoryService.getLaboratoryByProject(projectId); + List<LaboratoryVo.LaboratoryUser> laboratoryUserList = sysUserService.getUserByProject(projectId); laboratoryVo.setLaboratoryList(laboratoryList); laboratoryVo.setLaboratoryUsers(laboratoryUserList); return ResponseModel.getOkInstence(laboratoryVo); @@ -1577,8 +1506,8 @@ @RequestMapping("hazardousWaste/putWasteInfo") public Object putWasteInfo(@RequestBody HazardousWaste hazardousWaste){ try { - if (StringUtils.isBlank(hazardousWaste.getDepartment()) || StringUtils.isBlank(hazardousWaste.getApplyPerson()) - || StringUtils.isBlank(hazardousWaste.getProject()) || StringUtils.isBlank(hazardousWaste.getCreator())){ + if (StringUtils.isBlank(hazardousWaste.getDepartment()) || hazardousWaste.getApplyPerson()!=null + || hazardousWaste.getProjectId()==null || StringUtils.isBlank(hazardousWaste.getCreator())){ return ResponseModel.getErrInstance("部门、课题组、确认者、创建者、不能为空"); } SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); @@ -1908,5 +1837,90 @@ } } + + /** + * 根据用户id查询实验室列表和实验室临时存储库列表 + * @return + */ + @ResponseBody + @RequestMapping(value = "/labAndContainerList",method = RequestMethod.GET) + public Object getLabAndContainerList(HttpServletRequest request){ + try { + Long userId = StringUtils.isNotBlank(request.getHeader("userId"))?Long.valueOf(request.getHeader("userId")):null; + if(userId==null){ + throw new ApiException(ApiStatus.SYS_ERR,"传参用户ID为空"); + } + return ResponseModel.getOkInstence(interfaceService.getLabAndContainerByUserId(userId)); + }catch (ApiException e) { + return ResponseModel.getErrInstance(e.getErrorMessage()); + }catch (Exception e){ + e.printStackTrace(); + return ResponseModel.getErrInstance("系统内部错误"); + } + } + + + /** + * 根据试剂编码查询流向 + * @return + */ + @ResponseBody + @RequestMapping(value = "/reagentUseFlowList",method = RequestMethod.GET) + public Object getReagentUseFlowList(@RequestParam(required=true) String reagentCode){ + try { + return ResponseModel.getOkInstence(interfaceService.getReagentUseFlowList(reagentCode)); + }catch (ApiException e) { + return ResponseModel.getErrInstance(e.getErrorMessage()); + }catch (Exception e){ + e.printStackTrace(); + return ResponseModel.getErrInstance("系统内部错误"); + } + } + + /** + * 根据用户id查询所属实验室信息 + * @return + */ + @ResponseBody + @RequestMapping(value = "/userLabList",method = RequestMethod.GET) + public Object getUserLabList(HttpServletRequest request){ + try { + Long userId = StringUtils.isNotBlank(request.getHeader("userId"))?Long.valueOf(request.getHeader("userId")):null; + if(userId==null){ + throw new ApiException(ApiStatus.SYS_ERR,"传参用户ID为空"); + } + return ResponseModel.getOkInstence(interfaceService.getLaboratoryByUserId(userId)); + }catch (ApiException e) { + return ResponseModel.getErrInstance(e.getErrorMessage()); + }catch (Exception e){ + e.printStackTrace(); + return ResponseModel.getErrInstance("系统内部错误"); + } + } + + /** + * 根据用户id查询试剂流向信息 + * @return + */ + @ResponseBody + @RequestMapping(value = "/personUserFlowList",method = RequestMethod.GET) + public Object getPersonUserFlowList(HttpServletRequest request,@RequestParam(required=false,defaultValue = "1") Integer pageNum,@RequestParam(required=false,defaultValue = "10") Integer pageSize,Integer operatestate,String startDate,String endDate){ + try { + Long userId = StringUtils.isNotBlank(request.getHeader("userId"))?Long.valueOf(request.getHeader("userId")):null; + if(userId==null){ + throw new ApiException(ApiStatus.SYS_ERR,"传参用户ID为空"); + } + return ResponseModel.getOkInstence(interfaceService.getOpeUseFlowByUserId(pageNum,pageSize,userId,operatestate,startDate,endDate)); + }catch (ApiException e) { + return ResponseModel.getErrInstance(e.getErrorMessage()); + }catch (Exception e){ + e.printStackTrace(); + return ResponseModel.getErrInstance("系统内部错误"); + } + } + + + + } -- Gitblit v1.9.2