diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/controller/PushProDataUseInfoController.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/controller/PushProDataUseInfoController.java index 8962a4ac..1310db2e 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/controller/PushProDataUseInfoController.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/controller/PushProDataUseInfoController.java @@ -174,7 +174,11 @@ public class PushProDataUseInfoController extends BaseController { } } - // 检验临期和检验超期数量 + /** + * 机具物资检验临期和检验超期数量 + * @param bean + * @return + */ @GetMapping(value = "getApproachingAndTimeout") public AjaxResult getApproachingAndTimeout(ProIdsBean bean) { try { @@ -194,40 +198,7 @@ public class PushProDataUseInfoController extends BaseController { @GetMapping(value = "getHyCheckingTimeout") public AjaxResult getHyCheckTimeout(ProIdsBean bean) { try { - StaticsNumsBean results = new StaticsNumsBean(); - Map map = new HashMap(); - map.put("projectId", bean.getProjectId()); - map.put("projectName", bean.getProjectName()); - String body = JSONObject.toJSONString(map); - // 检验临期接口路径 - String url = "http://10.138.55.101:21021/iws/hystw/backstage/machine/getHyNearWarnList"; - String data = HttpHelper.sendHttpPost(url, body); - JSONObject object = JSONObject.parseObject(data); - System.out.println(data); - String code = object.getString("res"); - if ("1".equals(code)) { - JSONObject obj = object.getJSONObject("obj"); - JSONArray dataArray = obj.getJSONArray("list"); - // 临期数量 - int num = dataArray.size(); - results.setApproachingNum(BigDecimal.valueOf(num)); - System.out.println("数组大小: " + dataArray.size()); - } - - // 检验超期接口路径 - String url1 = "http://10.138.55.101:21021/iws/hystw/backstage/machine/getHyOverWarnList"; - String overData = HttpHelper.sendHttpPost(url1, body); - JSONObject overObject = JSONObject.parseObject(overData); - System.out.println(overObject); - String overCode = overObject.getString("res"); - if ("1".equals(overCode)) { - JSONObject obj = overObject.getJSONObject("obj"); - JSONArray dataArray = obj.getJSONArray("list"); - // 超期数量 - int num = dataArray.size(); - results.setTimeoutNum(BigDecimal.valueOf(num)); - System.out.println("数组大小: " + dataArray.size()); - } + StaticsNumsBean results = service.getHyApproachingAndTimeout(bean); return AjaxResult.success(results); } catch (Exception e) { logger.error(e.toString(), e); @@ -242,138 +213,10 @@ public class PushProDataUseInfoController extends BaseController { */ @GetMapping(value = "getHyApproachingDetails") public AjaxResult getHyApproachingDetails(ProIdsBean bean) { - Integer pageIndex = Convert.toInt(ServletUtils.getParameter("pageNum"), 1); - Integer pageSize = Convert.toInt(ServletUtils.getParameter("pageSize"), 10); - List results = new ArrayList<>(); try { - Map map = new HashMap(); - map.put("projectId", bean.getProjectId()); - map.put("projectName", bean.getProjectName()); - String body = JSONObject.toJSONString(map); - if (bean.getType() == null) { - return AjaxResult.success(); - } - if (bean.getType() == 0) { - // 检验临期接口路径 - String url = "http://10.138.55.101:21021/iws/hystw/backstage/machine/getHyNearWarnList"; - String data = HttpHelper.sendHttpPost(url, body); - JSONObject object = JSONObject.parseObject(data); - String code = object.getString("res"); - if ("1".equals(code)) { - JSONObject obj = object.getJSONObject("obj"); - JSONArray dataArray = obj.getJSONArray("list"); - System.out.println("数组大小: " + dataArray.size()); - if (!dataArray.isEmpty()) { - // 有数据 - for (int i = 0; i < dataArray.size(); i++) { - JSONObject item = dataArray.getJSONObject(i); - //物资名称 - JSONObject typeObject = item.getJSONObject("type"); - String typeName = (typeObject != null) ? typeObject.getString("parentName") : null; - // 规格型号 - String typeModelName = (typeObject != null) ? typeObject.getString("name") : null; - // 计量单位 - String unitName = (typeObject != null) ? typeObject.getString("unitName") : null; - // 设备编码 - String maCode = item.getString("code"); - // 工程名称 - String projectName = item.getString("projectName"); - // 下次检验时间 - String nextCheckTime = item.getString("nextRepairTime"); - // 领用时间 - String leaseTime = item.getString("pickTime"); - // 实施单位 - String deptName = item.getString("deptName"); - // 到期天数 - Integer daysDiff = item.getInteger("days"); - MachineInfoBean rs = new MachineInfoBean(); - rs.setTypeName(typeName); - rs.setTypeModelName(typeModelName); - rs.setUnit(unitName); - rs.setMaCode(maCode); - rs.setProName(projectName); - rs.setExpireTime(nextCheckTime); - rs.setLeaseTime(leaseTime); - rs.setDeptName(deptName); - rs.setDaysDiff(daysDiff); - results.add(rs); - } - // 根据前端传入的类型或者规格型号查询相关设备 - if (StringUtils.isNotBlank(bean.getTypeName()) || StringUtils.isNotBlank(bean.getTypeModelName())) { - results = results.stream().filter(item -> { - boolean isTypeNameMatch = StringUtils.isBlank(bean.getTypeName()) - || (item.getTypeName() != null && item.getTypeName().contains(bean.getTypeName())); - - boolean isModelNameMatch = StringUtils.isBlank(bean.getTypeModelName()) - || (item.getTypeModelName() != null && item.getTypeModelName().contains(bean.getTypeModelName())); - return isTypeNameMatch && isModelNameMatch; - }).collect(Collectors.toList()); - } - } - } - } - - if (bean.getType() == 1) { - // 检验超期接口路径 - String url1 = "http://10.138.55.101:21021/iws/hystw/backstage/machine/getHyOverWarnList"; - String overData = HttpHelper.sendHttpPost(url1, body); - JSONObject overObject = JSONObject.parseObject(overData); - String overCode = overObject.getString("res"); - - if ("1".equals(overCode)) { - JSONObject obj = overObject.getJSONObject("obj"); - JSONArray dataArray = obj.getJSONArray("list"); - System.out.println("数组大小: " + dataArray.size()); - if (!dataArray.isEmpty()) { - // 有数据 - for (int i = 0; i < dataArray.size(); i++) { - JSONObject item = dataArray.getJSONObject(i); - //物资名称 - JSONObject typeObject = item.getJSONObject("type"); - String typeName = (typeObject != null) ? typeObject.getString("parentName") : null; - // 规格型号 - String typeModelName = (typeObject != null) ? typeObject.getString("name") : null; - // 计量单位 - String unitName = (typeObject != null) ? typeObject.getString("unitName") : null; - // 设备编码 - String maCode = item.getString("code"); - // 工程名称 - String projectName = item.getString("projectName"); - // 下次检验时间 - String nextCheckTime = item.getString("nextRepairTime"); - // 领用时间 - String leaseTime = item.getString("pickTime"); - // 实施单位 - String deptName = item.getString("deptName"); - // 到期天数 - Integer daysDiff = item.getInteger("days"); - MachineInfoBean rs = new MachineInfoBean(); - rs.setTypeName(typeName); - rs.setTypeModelName(typeModelName); - rs.setUnit(unitName); - rs.setMaCode(maCode); - rs.setProName(projectName); - rs.setExpireTime(nextCheckTime); - rs.setLeaseTime(leaseTime); - rs.setDeptName(deptName); - rs.setDaysDiff(daysDiff); - results.add(rs); - } - // 根据前端传入的类型或者规格型号查询相关设备 - if (StringUtils.isNotBlank(bean.getTypeName()) || StringUtils.isNotBlank(bean.getTypeModelName())) { - results = results.stream().filter(item -> { - boolean isTypeNameMatch = StringUtils.isBlank(bean.getTypeName()) - || (item.getTypeName() != null && item.getTypeName().contains(bean.getTypeName())); - - boolean isModelNameMatch = StringUtils.isBlank(bean.getTypeModelName()) - || (item.getTypeModelName() != null && item.getTypeModelName().contains(bean.getTypeModelName())); - return isTypeNameMatch && isModelNameMatch; - }).collect(Collectors.toList()); - } - } - } - } - + Integer pageIndex = Convert.toInt(ServletUtils.getParameter("pageNum"), 1); + Integer pageSize = Convert.toInt(ServletUtils.getParameter("pageSize"), 10); + List results = service.getHyApproachingDetails(bean); return AjaxResult.success(ListPagingUtil.paging(pageIndex, pageSize, results)); } catch (Exception e) { logger.error(e.toString(), e); @@ -381,7 +224,11 @@ public class PushProDataUseInfoController extends BaseController { } } - // 临期、超期设备详情 + /** + * 机具物资临期、超期设备详情 + * @param bean + * @return + */ @GetMapping(value = "getApproachingDetails") public TableDataInfo getApproachingDetails(ProIdsBean bean) { try { diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/mapper/ProDataUseInfoMapper.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/mapper/ProDataUseInfoMapper.java index 16f701e4..ab85c6ac 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/mapper/ProDataUseInfoMapper.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/mapper/ProDataUseInfoMapper.java @@ -61,4 +61,18 @@ public interface ProDataUseInfoMapper { List getDeviceNumByType(ProIdsBean bean); List getProDataDetails(ProIdsBean bean); + + /** + * 宏源物资检验临期和检验超期数量 + * @param bean + * @return + */ + StaticsNumsBean getHyApproachingAndTimeout(ProIdsBean bean); + + /** + * 宏源物资检验临期和检验超期详情 + * @param bean + * @return + */ + List getHyApproachingDetails(ProIdsBean bean); } diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/ProDataUseInfoService.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/ProDataUseInfoService.java index 3741e550..9e454f51 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/ProDataUseInfoService.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/ProDataUseInfoService.java @@ -68,4 +68,18 @@ public interface ProDataUseInfoService { * @return */ List getRetainedEquipmentList(MaterialRetainedEquipmentInfo bean); + + /** + * 宏源物资检验临期和检验超期数量 + * @param bean + * @return + */ + StaticsNumsBean getHyApproachingAndTimeout(ProIdsBean bean); + + /** + * 宏源物资检验临期和检验超期数量详情 + * @param bean + * @return + */ + List getHyApproachingDetails(ProIdsBean bean); } diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/impl/ProDataUseInfoImpl.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/impl/ProDataUseInfoImpl.java index 5e6d61d3..18056227 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/impl/ProDataUseInfoImpl.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/push/service/impl/ProDataUseInfoImpl.java @@ -236,6 +236,26 @@ public class ProDataUseInfoImpl implements ProDataUseInfoService { return usList; } + /** + * 宏源物资检验临期和检验超期数量 + * @param bean + * @return + */ + @Override + public StaticsNumsBean getHyApproachingAndTimeout(ProIdsBean bean) { + return proDataUseInfoMapper.getHyApproachingAndTimeout(bean); + } + + /** + * 宏源物资检验临期和检验超期数量详情 + * @param bean + * @return + */ + @Override + public List getHyApproachingDetails(ProIdsBean bean) { + return proDataUseInfoMapper.getHyApproachingDetails(bean); + } + /** * 模糊查询 * @param item diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/repair/service/impl/RepairAuditDetailsServiceImpl.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/repair/service/impl/RepairAuditDetailsServiceImpl.java index 5d3a06be..c1790331 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/repair/service/impl/RepairAuditDetailsServiceImpl.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/repair/service/impl/RepairAuditDetailsServiceImpl.java @@ -537,8 +537,8 @@ public class RepairAuditDetailsServiceImpl implements IRepairAuditDetailsService @Override @Transactional(rollbackFor = Exception.class) public AjaxResult outerAudit(@NotNull List repairAuditDetails) { - // 获取锁(公平锁会按线程等待请求顺序分配锁) - lock.lock(); + /*// 获取锁(公平锁会按线程等待请求顺序分配锁) + lock.lock();*/ final List taskIds = repairAuditDetails.stream() .filter(Objects::nonNull) .map(RepairAuditDetails::getTaskId) @@ -631,10 +631,10 @@ public class RepairAuditDetailsServiceImpl implements IRepairAuditDetailsService } catch (ServiceException e) { log.error("修改维修审核状态失败", e); throw new ServiceException("修饰审核失败,请联系管理员"); - } finally { + } /*finally { // 释放锁 lock.unlock(); - } + }*/ return AjaxResult.success(HttpCodeEnum.SUCCESS.getMsg()); } diff --git a/bonus-modules/bonus-material/src/main/resources/mapper/material/push/ProDataUseInfoMapper.xml b/bonus-modules/bonus-material/src/main/resources/mapper/material/push/ProDataUseInfoMapper.xml index 6e3fbc72..a4e50216 100644 --- a/bonus-modules/bonus-material/src/main/resources/mapper/material/push/ProDataUseInfoMapper.xml +++ b/bonus-modules/bonus-material/src/main/resources/mapper/material/push/ProDataUseInfoMapper.xml @@ -1347,4 +1347,106 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" GROUP BY bp.pro_name,mt.type_id,sai.ma_id + + + +