package com.nanometer.smartlab.api;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.google.common.collect.Lists;
|
import com.google.common.collect.Maps;
|
import com.nanometer.smartlab.controller.BaseController;
|
import com.nanometer.smartlab.controller.MenuController;
|
import com.nanometer.smartlab.dao.SysLaboratoryContainerDao;
|
import com.nanometer.smartlab.dao.SysWarehouseContainerDao;
|
import com.nanometer.smartlab.entity.*;
|
import com.nanometer.smartlab.entity.dto.InWarehouseInfoDto;
|
import com.nanometer.smartlab.entity.dto.SysWarehouseDto;
|
import com.nanometer.smartlab.entity.enumtype.ApiStatus;
|
import com.nanometer.smartlab.entity.enumtype.ReplaceDictType;
|
import com.nanometer.smartlab.entity.enumtype.SeeFlag;
|
import com.nanometer.smartlab.exception.ApiException;
|
import com.nanometer.smartlab.exception.BusinessException;
|
import com.nanometer.smartlab.exception.ExceptionEnumCode;
|
import com.nanometer.smartlab.model.ResponseModel;
|
import com.nanometer.smartlab.service.*;
|
import com.nanometer.smartlab.util.Constants;
|
import com.nanometer.smartlab.util.FacesUtils;
|
import com.nanometer.smartlab.util.IDUtils;
|
import com.nanometer.smartlab.util.MessageUtil;
|
|
import org.apache.commons.lang.ArrayUtils;
|
import org.apache.commons.lang.StringUtils;
|
import org.apache.log4j.Logger;
|
import org.apache.shiro.authc.UnknownAccountException;
|
import org.apache.shiro.authc.UsernamePasswordToken;
|
import org.apache.shiro.subject.Subject;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.servlet.ModelAndView;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.*;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* Created by johnny on 17/9/13.
|
*/
|
@Controller
|
@RequestMapping(value = "service")
|
public class ApiAction extends BaseAction {
|
|
private static Logger logger = Logger.getLogger(ApiAction.class);
|
|
@Resource
|
private SysUserService sysUserService;
|
@Resource
|
private OpeReagentStatusService opeReagentStatusService;
|
@Resource
|
private SysReagentService sysReagentService;
|
@Resource
|
private SysWarehouseContainerService sysWarehouseContainerService;
|
@Resource
|
private SysLaboratoryContainerService sysLaboratoryContainerService;
|
@Resource
|
private BaseMetaService baseMetaService;
|
@Resource
|
private InterfaceService interfaceService;
|
@Resource
|
private SysWarehouseService sysWarehouseService;
|
|
@Resource
|
private SysWarningService sysWarningService;
|
|
@Resource
|
private TempSensorsService tempSensorsService;
|
|
@Resource
|
private SysFileService sysFileService;
|
@Resource
|
private SysLaboratoryContainerDao sysLaboratoryContainerDao;
|
@Resource
|
private SysWarehouseContainerDao sysWarehouseContainerDao;
|
@Resource
|
private DangerousEncodeService dangerousEncodeService;
|
@Resource
|
private EncodeReplaceDictService encodeReplaceDictService;
|
@Value("${institute.url}")
|
String instituteUrl;
|
|
@ResponseBody
|
@RequestMapping(value = "/registerTestCabinet")
|
public String registerTestCabinet(HttpServletRequest request) throws IOException {
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
|
logger.info("registerTestCabinet" + data);
|
String userId = request.getHeader("userId");
|
JSONObject retJSON = new JSONObject();
|
try {
|
interfaceService.registerTestCabinet(userId, JSONObject.parseObject(data));
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
// 现在注册流程是，先在web端创建试剂柜，然后当柜子第一次会调用接口，如果货柜条码存在，则注册成功。
|
// 如果货柜类型等数据发生变更，以柜子发上来的数据为准
|
@ResponseBody
|
@RequestMapping(value = "/AutheTestCabinet")
|
public String AutheTestCabinet(HttpServletRequest request) throws IOException {
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
|
logger.info("AutheTestCabinet" + data);
|
String userId = request.getHeader("userId");
|
JSONObject retJSON = new JSONObject();
|
try {
|
interfaceService.AutheTestCabinet(userId, JSONObject.parseObject(data));
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
@ResponseBody
|
@RequestMapping(value = "/logoutTestCabinet")
|
public String logoutTestCabinet(HttpServletRequest request) throws IOException {
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
logger.info("logoutTestCabinet" + data);
|
String userId = request.getHeader("userId");
|
JSONObject retJSON = new JSONObject();
|
try {
|
interfaceService.logoutTestCabinet(userId, JSONObject.parseObject(data));
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
|
@ResponseBody
|
@RequestMapping(value = "/updateTestCabinet")
|
public String updateTestCabinet(HttpServletRequest request) throws IOException {
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
logger.info("updateTestCabinet" + data);
|
String userId = request.getHeader("userId");
|
JSONObject retJSON = new JSONObject();
|
try {
|
interfaceService.updateTestCabinet(userId, JSONObject.parseObject(data));
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
|
@ResponseBody
|
@RequestMapping(value = "/openCabinetDoor")
|
public String openCabinetDoor(HttpServletRequest request) throws IOException {
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
logger.info("openCabinetDoor" + data);
|
String userId = request.getHeader("userId");
|
JSONObject retJSON = new JSONObject();
|
try {
|
String returndata = interfaceService.openCabinetDoor(userId, JSONObject.parseObject(data));
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
retJSON.put("userLevel", returndata);
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
@ResponseBody
|
@RequestMapping(value = "/closeCabinetDoor")
|
public String closeCabinetDoor(HttpServletRequest request) throws IOException {
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
|
logger.info("closeCabinetDoor" + data);
|
String userId = request.getHeader("userId");
|
JSONObject retJSON = new JSONObject();
|
try {
|
interfaceService.closeCabinetDoor(JSONObject.parseObject(data));
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
// 报送试剂最新信息接口
|
@ResponseBody
|
@RequestMapping(value = "/synchAllCabinet")
|
public String synchAllCabinet(HttpServletRequest request) throws IOException {
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
JSONObject retJSON = new JSONObject();
|
logger.info("synchAllCabinet" + data);
|
String userId = request.getHeader("userId");
|
|
// 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.synchAllCabinet(dataJSONArray);
|
}
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
// 报警情况接口（warning）
|
@ResponseBody
|
@RequestMapping(value = "/alarm")
|
public String alarm(HttpServletRequest request) throws IOException {
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
logger.info("alarm" + data);
|
String userId = request.getHeader("userId");
|
JSONObject retJSON = new JSONObject();
|
try {
|
interfaceService.alarm(JSONObject.parseObject(data));
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
// 人员违规预警接口
|
@ResponseBody
|
@RequestMapping(value = "/alarmperson")
|
public String alarmperson(HttpServletRequest request) throws IOException {
|
logger.info("/api/service/alarmperson");
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
logger.info("alarmperson" + data);
|
String userId = request.getHeader("userId");
|
JSONObject retJSON = new JSONObject();
|
try {
|
interfaceService.alarmperson(JSONObject.parseObject(data));
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
// 出入库记录信息接口
|
@ResponseBody
|
@RequestMapping(value = "/cabinetData")
|
public String cabinetData(HttpServletRequest request) throws IOException {
|
BufferedReader br = request.getReader();
|
String str, data = "";
|
while((str = br.readLine()) != null){
|
data += str;
|
}
|
JSONObject retJSON = new JSONObject();
|
logger.info("cabinetData" + data);
|
String userId = request.getHeader("userId");
|
|
// 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);
|
}
|
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
} 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();
|
}
|
|
//http://[URL]/smartlab/api/service/containerInfo
|
@ResponseBody
|
@RequestMapping(value = "/containerInfo")
|
public Object getContainerInfo(@RequestParam String startTime, @RequestParam String endTime) {
|
logger.info("getContainerInfo start...");
|
List<SysWarehouseContainer> warehouseList = sysWarehouseContainerService.getSysWarehouseContainerInfoList(startTime, endTime);
|
List<SysLaboratoryContainer> laboratoryList = sysLaboratoryContainerService.getSysLaboratoryContainerInfoList(startTime, endTime);
|
List<Map> datalist = Lists.newArrayListWithCapacity(warehouseList.size() + laboratoryList.size());
|
for (SysWarehouseContainer container : warehouseList) {
|
Map<String, Object> map = Maps.newHashMapWithExpectedSize(3);
|
datalist.add(map);
|
map.put("containerCode", container.getContainerCode());
|
map.put("containerName", container.getName());
|
map.put("validFlag", container.getValidFlag().getKey());
|
map.put("type", this.baseMetaService.getBaseMetaKey(container.getType()));
|
map.put("place", "0");
|
map.put("left", this.baseMetaService.getBaseMetaKey(container.getCharacterLeft()));
|
map.put("right", this.baseMetaService.getBaseMetaKey(container.getCharacterRight()));
|
}
|
for (SysLaboratoryContainer container : laboratoryList) {
|
Map<String, Object> map = Maps.newHashMapWithExpectedSize(3);
|
datalist.add(map);
|
map.put("containerCode", container.getContainerCode());
|
map.put("containerName", container.getName());
|
map.put("validFlag", container.getValidFlag().getKey());
|
map.put("type", this.baseMetaService.getBaseMetaKey(container.getType()));
|
map.put("place", "1");
|
map.put("left", this.baseMetaService.getBaseMetaKey(container.getCharacterLeft()));
|
map.put("right", this.baseMetaService.getBaseMetaKey(container.getCharacterRight()));
|
}
|
logger.info("getContainerInfo end...");
|
return ResponseModel.getOkInstence(datalist);
|
}
|
|
|
@ResponseBody
|
@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;
|
|
SysLaboratoryContainer laboratoryContainer = sysLaboratoryContainerDao
|
.getSysLaboratoryContainerByContainerCode(containerCode);
|
if (Objects.isNull(laboratoryContainer)) {
|
SysWarehouseContainer warehouseContainer = sysWarehouseContainerDao
|
.getSysWarehouseContainerByContainerCode(containerCode);
|
if (Objects.isNull(warehouseContainer)) {
|
JSONObject retJSON = new JSONObject();
|
logger.error("The containerCode:" + containerCode + " has not been exists!");
|
retJSON.put("code", ApiStatus.SYS_ERR.getRetCode());
|
retJSON.put("message", ApiStatus.SYS_ERR.getRetMsg() + "--" + "The containerCode:" + containerCode + " has not been exists!");
|
return retJSON.toJSONString();
|
} else {
|
containerid = warehouseContainer.getId();
|
}
|
} else {
|
containerid = laboratoryContainer.getId();
|
}
|
|
List<OpeReagentStatus> reagetList = opeReagentStatusService.getOpeReagentStatusInfoList(startTime, endTime, containerid, status);
|
List<Map> datalist = Lists.newArrayListWithCapacity(reagetList.size());
|
for (OpeReagentStatus opeReagentStatus : reagetList) {
|
Map<String, Object> map = Maps.newHashMapWithExpectedSize(4);
|
datalist.add(map);
|
map.put("reagentCode", opeReagentStatus.getReagentCode());
|
map.put("reagentName", opeReagentStatus.getReagent().getName());
|
map.put("cas", opeReagentStatus.getReagent().getCas());
|
map.put("reagentType", opeReagentStatus.getReagent().getReagentType());
|
map.put("deadline", opeReagentStatus.getReagent().getDeadline());
|
map.put("specification", opeReagentStatus.getReagent().getReagentFormat());
|
map.put("masterMetering", opeReagentStatus.getReagent().getMainMetering());
|
map.put("itemNumber", opeReagentStatus.getReagent().getReagentType());
|
map.put("producer", opeReagentStatus.getReagent().getProductHome());
|
}
|
logger.info("getReagentInfo end...");
|
return ResponseModel.getOkInstence(datalist);
|
}
|
|
@ResponseBody
|
@RequestMapping(value = "/userInfo")
|
public Object getUserInfo(@RequestParam String startTime, @RequestParam String endTime) {
|
logger.info("getUserInfo start...");
|
|
List<SysUser> userList = sysUserService.getSysUserInfoList(startTime, endTime);
|
List<SysLaboratoryContainer> allLaboratoryContainerList = sysLaboratoryContainerService.getSysLaboratoryContainerList(null,null,null,null,null);
|
List<SysWarehouseContainer> allWarehouseContainerList = sysWarehouseContainerService.getSysWarehouseContainerList(null,null,null,null,null);
|
|
List<String> containerCodeList = new ArrayList<String>();
|
List<String> wareContainerCodeList = new ArrayList<String>();
|
for (SysLaboratoryContainer laboratoryContainer : allLaboratoryContainerList) {
|
containerCodeList.add(laboratoryContainer.getContainerCode());
|
}
|
for (SysWarehouseContainer warehouseContainer : allWarehouseContainerList) {
|
containerCodeList.add(warehouseContainer.getContainerCode());
|
wareContainerCodeList.add(warehouseContainer.getContainerCode());
|
}
|
|
List<Map> datalist = Lists.newArrayListWithCapacity(userList.size());
|
for (SysUser user : userList) {
|
Map<String, Object> map = Maps.newHashMapWithExpectedSize(5);
|
datalist.add(map);
|
map.put("name", user.getName());
|
map.put("role", user.getSeeFlag().getKey());
|
map.put("validFlag", user.getValidFlag().getKey());
|
map.put("idcard", user.getIdCard());
|
map.put("point", user.getPoint());
|
map.put("unit", user.getCompany());
|
map.put("Arp", user.getArp());
|
map.put("department", user.getDepartment());
|
if (StringUtils.isNotBlank(user.getContainerCodeList())) {
|
map.put("containerCodeList",
|
ArrayUtils.addAll(user.getContainerCodeList().split(","),
|
(String[])wareContainerCodeList.toArray(new String[0])));
|
|
}
|
if(user.getSeeFlag().ordinal() == SeeFlag.MANAGE.ordinal()){
|
map.put("containerCodeList", containerCodeList);
|
}
|
}
|
logger.info("getUserInfo end...");
|
return ResponseModel.getOkInstence(datalist);
|
}
|
|
|
|
|
|
@RequestMapping(value = "/putInLaboratory", produces = {"application/json;charset=UTF-8"}, method = RequestMethod.POST)
|
@ResponseBody
|
public String putInLaboratory(HttpServletRequest request, String reagentCode, String barCode, String containerCode) {
|
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(), "用户卡号"));
|
}
|
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)) {
|
throw new BusinessException(ExceptionEnumCode.PARAM_NULL, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NULL.getCode(), "试剂条码"));
|
}
|
|
// 检查地点条码
|
if (StringUtils.isBlank(barCode)) {
|
throw new BusinessException(ExceptionEnumCode.PARAM_NULL, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NULL.getCode(), "地点条码"));
|
}
|
|
// 检查货柜条码
|
if (StringUtils.isBlank(containerCode)) {
|
throw new BusinessException(ExceptionEnumCode.PARAM_NULL, MessageUtil.getMessageByCode(ExceptionEnumCode.PARAM_NULL.getCode(), "货柜条码"));
|
}
|
|
this.opeReagentStatusService.putReagentInLaboratory(reagentCode, barCode, containerCode, sysUser);
|
|
return this.getOkResponseString();
|
} catch (BusinessException e) {
|
logger.error("试剂放入实验室柜失败", e);
|
return this.getResponseString(e.getErrorCode().getCode(), e.getMessage());
|
} catch (Exception e) {
|
logger.error("试剂放入实验室柜失败", e);
|
return this.getSysErrResponseString();
|
} finally {
|
logger.info("PutInLaboratory end...");
|
}
|
}
|
|
//
|
//
|
// @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();
|
// }
|
|
|
// 智能柜温度，湿度，气体浓度数据接口
|
@RequestMapping(value = "/tempSensors")
|
@ResponseBody
|
public String tempSensors(HttpServletRequest request) throws ParseException, IOException, ApiException {
|
logger.info("tempSensors start...");
|
JSONObject retJSON = new JSONObject();
|
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);
|
|
if (!jsonObject.containsKey("data")) {
|
logger.error("data has not been exists!");
|
retJSON.put("code", ApiStatus.SYS_ERR.getRetCode());
|
retJSON.put("message", ApiStatus.SYS_ERR.getRetMsg() + "--" + "data has not been exists!");
|
return retJSON.toJSONString();
|
}
|
|
// 2.2 Body参数：
|
// 货柜条码 containerCode String ○
|
// 数据 data JSONArray
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String dataStr = jsonObject.getString("data");
|
String containerCode = jsonObject.getString("containerCode");
|
logger.info("dataStr:" + dataStr);
|
JSONArray dataJsonArray = null;
|
Iterator<Object> dataIt = null;
|
JSONObject dataJson = null;
|
try{
|
dataJsonArray = JSONArray.parseArray(dataStr);
|
logger.info("dataJsonArray:" + dataJsonArray.size());
|
dataIt = dataJsonArray.iterator();
|
|
} catch (Exception e){
|
e.printStackTrace();
|
}
|
int type = 0;
|
String containerId = null;
|
logger.info("The containerCode:" + containerCode + " finding!");
|
// 查找货柜条码对应货柜信息
|
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!");
|
retJSON.put("code", ApiStatus.PARAM_NO_EXIST.getRetCode());
|
retJSON.put("message", ApiStatus.PARAM_NO_EXIST.getRetMsg() + "--" + "The containerCode:" + containerCode + " has not been exists!");
|
return retJSON.toJSONString();
|
} else {
|
type = TempSensors.TYPE_WAREHOUSE_CONTAINER;
|
containerId = warehouseContainer.getId();
|
}
|
} else {
|
type = TempSensors.TYPE_LABORATORY_CONTAINER;
|
containerId = laboratoryContainer.getId();
|
}
|
|
while (dataIt.hasNext()) {
|
logger.info("dataIt.hasNext()" );
|
dataJson = JSONObject.parseObject(dataIt.next().toString());
|
logger.info("dataJson" +dataJson.toJSONString() );
|
//
|
// 2.2.1.数据JSON格式
|
// 温度值 Temp Float ○
|
// 湿度值 Humidity Float ○
|
// 气体浓度 voc1 Float ○
|
// 报警信息 Flag Integer
|
// 更新时间 updateTime String ○
|
|
if (!dataJson.containsKey("Temp") || !dataJson.containsKey("Humidity") || !dataJson.containsKey("voc1")
|
|| !dataJson.containsKey("Flag")
|
|| !dataJson.containsKey("updateTime")) {
|
retJSON.put("code", ApiStatus.PARAM_NO_EXIST.getRetCode());
|
retJSON.put("message", ApiStatus.PARAM_NO_EXIST.getRetMsg() + "--" + "data has not been exists!");
|
return retJSON.toJSONString();
|
}
|
|
Float temp = dataJson.getFloat("Temp");
|
Float humidity = dataJson.getFloat("Humidity");
|
Float voc1 = dataJson.getFloat("voc1");
|
String flag = dataJson.getString("Flag");
|
|
if (flag == null || flag.isEmpty() || flag.length() < 5) {
|
continue;
|
}
|
|
String updateTime = dataJson.getString("updateTime");
|
|
SysContainerSensors sysContainerSensors = new SysContainerSensors();
|
sysContainerSensors.setContainerId(containerCode);
|
TempSensors tempSensors = new TempSensors();
|
tempSensors.setContainerId(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.setType(type);
|
tempSensors.setContainerId(containerId);
|
|
|
try {
|
// 将温度、湿度、气体浓度保存到数据库
|
tempSensorsService.insert(tempSensors);
|
sysLaboratoryContainerService.updateInfo(temp,humidity,voc1,containerId,flag);
|
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();
|
}
|
|
|
/**
|
* 获取试剂柜试剂最新状态接口
|
*
|
* @param containerCode
|
* @return
|
*/
|
//http://[URL]/smartlab/api/service/getReagentStatusByContainerCode
|
@ResponseBody
|
@RequestMapping(value = "/getReagentStatusByContainerCode")
|
public Object getReagentStatusByContainerCode(@RequestParam String containerCode) {
|
logger.info("getReagentStatusByContainerCode start...");
|
JSONObject retJSON = new JSONObject();
|
try {
|
if (StringUtils.isBlank(containerCode)) {
|
throw new ApiException(ApiStatus.PARAM_NO_EXIST);
|
}
|
List<OpeReagentStatus> list = opeReagentStatusService.getReagentStatusByContainerCode(containerCode);
|
list.stream().forEach(info->info.setContainerCode(containerCode));
|
return ResponseModel.getOkInstence(list);
|
|
} catch (ApiException e) {
|
retJSON.put("code", e.getApiStatus().getRetCode());
|
retJSON.put("message", e.getErrorMessage());
|
}
|
return retJSON;
|
|
}
|
|
/**
|
* 获取试剂柜APP版本
|
*
|
* @param containerCode
|
* @return
|
*/
|
//http://[URL]/smartlab/api/service/getContainerVersion
|
@ResponseBody
|
@RequestMapping(value = "/getContainerVersion")
|
public Object getContainerVersion(HttpServletRequest request) {
|
logger.info("getContainerVersion start...");
|
JSONObject retJSON = new JSONObject();
|
List<BaseMeta> versionList = this.baseMetaService.getBaseMetaList("containerversion", "", 0, 1);
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
retJSON.put("version", versionList.get(0).getMetaValue());
|
|
return retJSON;
|
|
}
|
|
@ResponseBody
|
@RequestMapping(value = "/getAppVersion")
|
public Object getAppVersion(HttpServletRequest request) {
|
logger.info("getAppVersion start...");
|
JSONObject retJSON = new JSONObject();
|
try {
|
List<SysFile> list = this.sysFileService.getSysFileList(null, null, null);
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
if(list==null&&list.size()==0){
|
retJSON.put("data", null);
|
}else {
|
SysFile sysFile=list.get(0);
|
Map map=new HashMap();
|
map.put("newOrOld",sysFile.getNewOrOld());
|
map.put("version",sysFile.getVersion());
|
String urlPrefix = instituteUrl.replace("http://", "");
|
map.put("downLoadUrl",urlPrefix+"/smartlab/api/service/downloadFile?id="+sysFile.getId());
|
retJSON.put("data",map);
|
}
|
|
}catch (Exception e){
|
retJSON.put("code", ApiStatus.SYS_ERR.getRetCode());
|
retJSON.put("message", e.getMessage());
|
}
|
return retJSON;
|
}
|
|
@ResponseBody
|
@RequestMapping(value = "/getAllFile")
|
public Object getAllFile(HttpServletRequest request) {
|
logger.info("getAllFile start...");
|
JSONObject retJSON = new JSONObject();
|
try {
|
List<SysFile> list = this.sysFileService.getSysFileList(null, null, null);
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
retJSON.put("data", list);
|
}catch (Exception e){
|
retJSON.put("code", ApiStatus.SYS_ERR.getRetCode());
|
retJSON.put("message", e.getMessage());
|
}
|
return retJSON;
|
|
}
|
@ResponseBody
|
@RequestMapping(value = "/downloadFile")
|
public HttpServletResponse downloadFile(HttpServletRequest request, String id, HttpServletResponse response){
|
SysFile sysFile=this.sysFileService.getSysFileById(id);
|
try {
|
// path是指欲下载的文件的路径。
|
File file = new File(sysFile.getUrl());
|
// 取得文件名。
|
String filename = file.getName();
|
// 取得文件的后缀名。
|
String ext = filename.substring(filename.lastIndexOf(".") + 1).toUpperCase();
|
|
// 以流的形式下载文件。
|
InputStream fis = new BufferedInputStream(new FileInputStream(sysFile.getUrl()));
|
byte[] buffer = new byte[fis.available()];
|
fis.read(buffer);
|
fis.close();
|
// 清空response
|
response.reset();
|
String name=new String(filename.getBytes("UTF-8"),"ISO-8859-1");
|
// 设置response的Header
|
response.addHeader("Content-Disposition", "attachment;filename=" + name);
|
response.addHeader("Content-Length", "" + file.length());
|
OutputStream toClient = new BufferedOutputStream(response.getOutputStream());
|
response.setContentType("application/octet-stream");
|
toClient.write(buffer);
|
toClient.flush();
|
toClient.close();
|
} catch (IOException ex) {
|
ex.printStackTrace();
|
}
|
return response;
|
}
|
|
@RequestMapping(value = "/dataLogin")
|
public ModelAndView login(HttpServletRequest request){
|
UsernamePasswordToken token = new UsernamePasswordToken("admin", "123456789");
|
token.setRememberMe(true);
|
BaseController baseController=new BaseController();
|
Subject currentUser = baseController.getSubject();
|
System.out.println(1);
|
try {
|
System.out.println(2);
|
currentUser.login(token);
|
} catch (UnknownAccountException e) {
|
System.out.println("用户名不存在");
|
FacesUtils.warn("用户名不存在");
|
return null;
|
} catch (Exception e) {
|
System.out.println("登陆失败");
|
logger.error("登陆失败", e);
|
}
|
|
if (currentUser.isAuthenticated()) {//登录成功进入主页
|
System.out.println(3);
|
SysUser user = this.sysUserService.getSysUserByAccount("admin");
|
currentUser.getSession(true).setAttribute(Constants.SESSION_USER, user);
|
currentUser.getSession(true).getId();
|
MenuController menuController=new MenuController();
|
menuController.initPage();
|
System.out.println(4);
|
//return "redirect:http://192.168.1.195:8888/smartlab_war_exploded/index.xhtml";
|
return new ModelAndView("redirect:/index.xhtml");
|
} else {
|
System.out.println("用户名与密码不匹配");
|
FacesUtils.warn("用户名与密码不匹配");
|
}
|
return null;
|
/*JSONObject retJSON = new JSONObject();
|
retJSON.put("code", ApiStatus.OK.getRetCode());
|
retJSON.put("message", ApiStatus.OK.getRetMsg());
|
System.out.println(5);
|
return retJSON;*/
|
}
|
|
//从柜子的设备码根据设备的所在实验室的课题组的课题组下的所有用户，没有课题组则返回用部门搜索
|
@ResponseBody
|
@RequestMapping(value = "/userListByContainerCode")
|
public Object userListByContainerCodeNew(@RequestParam String containerCode,@RequestParam String startTime, @RequestParam String endTime) throws ApiException {
|
logger.info("userListByContainerCodeNew start...containerCode= " + containerCode
|
+ ",startTime=" + startTime
|
+ ",endTime=" + endTime);
|
|
|
//1.课题组下的用户
|
List<SysUser> userList= interfaceService.getUserListByContainerCodeNew(containerCode, startTime, endTime);
|
if (userList == null) {
|
//2.否则部门下用户
|
userList = interfaceService.getUserListByContainerCode(containerCode, startTime, endTime);
|
}
|
|
List<Map> datalist = Lists.newArrayListWithCapacity(userList.size());
|
for (SysUser user : userList) {
|
Map<String, Object> map = Maps.newHashMapWithExpectedSize(5);
|
datalist.add(map);
|
map.put("name", user.getName());
|
map.put("role", user.getSeeFlag().getKey());
|
map.put("validFlag", user.getValidFlag().getKey());
|
map.put("idcard", user.getIdCard());
|
map.put("point", user.getPoint());
|
map.put("unit", user.getCompany());
|
map.put("Arp", user.getArp());
|
map.put("departmentName", user.getDepartment());
|
map.put("project", user.getProject());
|
|
}
|
logger.info("getUserInfo end...");
|
return ResponseModel.getOkInstence(datalist);
|
}
|
|
|
//危化品编码接口
|
@ResponseBody
|
@RequestMapping(value = "/dangerousEncodeInfo")
|
public Object getDangerousEncodeInfo(@RequestParam String reagentName, @RequestParam String cas) {
|
List<DangerousEncodeVo> 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("有毒称重型");
|
}
|
}
|
}
|
}else {
|
return ResponseModel.getParamInstence("reagentName,cas");
|
}
|
|
return ResponseModel.getOkInstence(datalist);
|
}
|
|
//生成24位危化品编码
|
@ResponseBody
|
@RequestMapping(value = "/generatorCode")
|
public Object generatorCode(@RequestParam String reagentName,@RequestParam String containerName,
|
@RequestParam String factory, @RequestParam String specs,@RequestParam String pack) {
|
String code = "";
|
int count = 0;
|
DangerousEncode dangerousEncode = new DangerousEncode();
|
if (StringUtils.isNotBlank(reagentName)){
|
dangerousEncode = dangerousEncodeService.selectByName(reagentName);
|
if (null != dangerousEncode){
|
code = dangerousEncode.getCode();
|
count = dangerousEncode.getCount();
|
}else {
|
return ResponseModel.getErrInstance("无法找到该试剂");
|
}
|
}else {
|
return ResponseModel.getParamInstence("reagentName");
|
}
|
|
StringBuffer buffer = new StringBuffer(code);
|
|
if (StringUtils.isNotBlank(containerName)){
|
if (containerName.equals("普通型")){
|
buffer.replace(0, 1, "0");
|
}else if (containerName.equals("阻燃型")){
|
buffer.replace(0, 1, "1");
|
}else if (containerName.equals("抗腐蚀型")){
|
buffer.replace(0, 1, "2");
|
}else if (containerName.equals("防爆型")){
|
buffer.replace(0, 1, "3");
|
}else if (containerName.equals("有毒称重型")){
|
buffer.replace(0, 1, "4");
|
}
|
}else {
|
return ResponseModel.getParamInstence("containerName");
|
}
|
|
String regex="^[A-F0-9]+$";
|
|
if (StringUtils.isNotBlank(factory) && factory.matches(regex)){
|
buffer.replace(2, 3, factory);
|
}else {
|
return ResponseModel.getParamInstence("factory");
|
}
|
|
if (StringUtils.isNotBlank(specs) && specs.matches(regex)){
|
buffer.replace(3, 4, specs);
|
}else {
|
return ResponseModel.getParamInstence("specs");
|
}
|
|
if (StringUtils.isNotBlank(pack) && pack.matches(regex)){
|
buffer.replace(18, 19, pack);
|
}else {
|
return ResponseModel.getParamInstence("pack");
|
}
|
|
String countHex = Integer.toHexString(count).toUpperCase();
|
if (countHex.length() == 1){
|
buffer.replace(23, 24, countHex);
|
}else if (countHex.length() == 2){
|
buffer.replace(22, 24, countHex);
|
}else if (countHex.length() == 3){
|
buffer.replace(21, 24, countHex);
|
}else if (countHex.length() == 4){
|
buffer.replace(20, 24, countHex);
|
}else if (countHex.length() == 5){
|
buffer.replace(19, 24, countHex);
|
}
|
code = buffer.toString();
|
|
dangerousEncode.setCount(dangerousEncode.getCount()+1);
|
dangerousEncodeService.updateOne(dangerousEncode);
|
|
return ResponseModel.getOkInstence(code);
|
}
|
|
/**
|
* 获取替换字典
|
*
|
*/
|
@ResponseBody
|
@RequestMapping("getEncodeReplaceDict")
|
public Object getEncodeReplaceDict(@RequestParam String type) {
|
try {
|
ReplaceDictType rdType = ReplaceDictType.parse(Integer.parseInt(type));
|
EncodeReplaceDict encodeReplaceDict = new EncodeReplaceDict();
|
encodeReplaceDict.setType(rdType);
|
List<EncodeReplaceDict> data = encodeReplaceDictService.selectAll(encodeReplaceDict, null, null);
|
return ResponseModel.getOkInstence(data);
|
}catch (Exception e){
|
e.printStackTrace();
|
logger.info(e);
|
return ResponseModel.getErrInstance("系统出错");
|
}
|
|
}
|
|
/**
|
* 获取编码
|
*
|
*/
|
@ResponseBody
|
@RequestMapping("getDangerousEncode")
|
public Object getDangerousEncode(@RequestParam(required = false) String reagentName, @RequestParam(required = false) String cas) {
|
try {
|
List<DangerousEncode> data = dangerousEncodeService.selectByCodeAndName(null, reagentName, cas, null);
|
return ResponseModel.getOkInstence(data);
|
} catch (Exception e){
|
e.printStackTrace();
|
logger.info(e);
|
return ResponseModel.getErrInstance("系统出错");
|
}
|
|
}
|
/**
|
* 获取仓库信息
|
*/
|
@ResponseBody
|
@RequestMapping("getWarehouseInfo")
|
public Object getWarehouseInfo() {
|
try {
|
List<SysWarehouseDto> data = sysWarehouseService.getWarehouseList();
|
return ResponseModel.getOkInstence(data);
|
} catch (Exception e) {
|
e.printStackTrace();
|
logger.info(e);
|
return ResponseModel.getErrInstance("系统出错");
|
}
|
|
}
|
|
|
/**
|
* @Description: 获取所有人员，人员相关实验室，实验室相关试剂柜
|
* @date 2020/12/23 16:47
|
*/
|
@ResponseBody
|
@RequestMapping("getApplyPersonDetailInfo")
|
public Object getApplyPersonDetailInfo() {
|
try {
|
List data = sysUserService.getUserInfo();
|
return ResponseModel.getOkInstence(data);
|
} catch (Exception e) {
|
e.printStackTrace();
|
logger.info(e);
|
return ResponseModel.getErrInstance("系统出错");
|
}
|
|
}
|
|
|
/**
|
* @Description: 入库
|
* @date 2020/12/24 14:19
|
*/
|
@ResponseBody
|
@RequestMapping("putInStorage")
|
public Object putInWarehouse(@RequestBody InWarehouseInfoDto inWarehouseInfo) {
|
try {
|
|
if (inWarehouseInfo.getReagentCode() != null && inWarehouseInfo.getReagentCode().size() > 0) {
|
sysWarehouseService.putInWarehouse(inWarehouseInfo);
|
return ResponseModel.getOkInstence("入库成功");
|
} else {
|
return ResponseModel.getErrInstance("无试剂条码");
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
logger.info(e);
|
return ResponseModel.getErrInstance("系统出错");
|
}
|
|
}
|
|
|
}
|
