org.springframework.boot
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/business/IBizBusinessOrderInfoService.java b/casic-metering-service/src/main/java/com/casic/missiles/service/business/IBizBusinessOrderInfoService.java
index 596ab06..761223f 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/business/IBizBusinessOrderInfoService.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/business/IBizBusinessOrderInfoService.java
@@ -8,6 +8,8 @@
import com.casic.missiles.dto.business.OrderListResponse;
import com.casic.missiles.model.business.BizBusinessOrderInfo;
+import java.util.List;
+
/**
*
* 计量检定业务-任务单 服务类
@@ -30,5 +32,7 @@
String checkOrder(BizBusinessOrderInfo businessOrder);
+ String checkSamples(List sampleIds, Long orderId);
+
}
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/impl/board/NoticeBoardServiceImpl.java b/casic-metering-service/src/main/java/com/casic/missiles/service/impl/board/NoticeBoardServiceImpl.java
index 158cc4e..223c875 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/impl/board/NoticeBoardServiceImpl.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/impl/board/NoticeBoardServiceImpl.java
@@ -229,8 +229,8 @@
// 待检设备态势(未检定、检定中、已检完)
List statistic = new ArrayList<>();
- statistic.add(new EquipmentCommonAggr("已超期", (int) list.stream().filter(i->i.getCertificateValid().before(new Date())).count()));
- statistic.add(new EquipmentCommonAggr("未超期", (int) list.stream().filter(i->i.getCertificateValid().after(new Date())).count()));
+ statistic.add(new EquipmentCommonAggr("已超期", (int) list.stream().filter(i->ObjectUtil.isNotEmpty(i.getCertificateValid()) && i.getCertificateValid().before(new Date())).count()));
+ statistic.add(new EquipmentCommonAggr("未超期", (int) list.stream().filter(i->ObjectUtil.isNotEmpty(i.getCertificateValid()) && i.getCertificateValid().after(new Date())).count()));
res.setStatistic(statistic);
//受检单位/负责人排行榜;单位/部门列表
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/impl/business/BizBusinessOrderInfoServiceImpl.java b/casic-metering-service/src/main/java/com/casic/missiles/service/impl/business/BizBusinessOrderInfoServiceImpl.java
index fed732a..edd9d5b 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/impl/business/BizBusinessOrderInfoServiceImpl.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/impl/business/BizBusinessOrderInfoServiceImpl.java
@@ -23,14 +23,18 @@
import com.casic.missiles.mapper.business.BusinessOrderListResponseMapper;
import com.casic.missiles.model.business.BizBusinessOrderInfo;
import com.casic.missiles.model.business.BizBusinessOrderSampleRelation;
+import com.casic.missiles.modular.system.model.Dept;
import com.casic.missiles.service.business.IBizBusinessOrderInfoService;
import com.casic.missiles.service.business.IBizBusinessOrderSampleRelationService;
+import com.casic.missiles.service.system.ISystemDeptService;
import com.casic.missiles.utils.DictCodeUtils;
import com.casic.missiles.utils.NumberGeneratorUtil;
import lombok.AllArgsConstructor;
import org.apache.commons.lang3.StringUtils;
+import org.jetbrains.annotations.Nullable;
import org.springframework.stereotype.Service;
+import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
@@ -50,15 +54,30 @@
private final IBizBusinessOrderSampleRelationService sampleRelationService;
private final BizBusinessOrderSampleRelationMapper sampleRelationMapper;
private final AbstractPermissionContext permissionContext;
+ private final ISystemDeptService systemDeptService;
@Override
public Page orderListPage(Page page, OrderListRequest request) throws Exception {
QueryWrapper wrapper = listParamWrapperBuilder(request);
// 查找本单位提交的
- Long deptId = permissionContext.getAuthService().getLoginUser().getDeptId();
- List parentDeptIds = permissionContext.getDeptService().getParentListById(deptId);
- wrapper.and(i->i.eq("customer_id",deptId).or().in(CollUtil.isNotEmpty(parentDeptIds),"customer_id",parentDeptIds));
+// Long deptId = permissionContext.getAuthService().getLoginUser().getDeptId();
+// List parentDeptIds = permissionContext.getDeptService().getParentListById(deptId);
+// wrapper.and(i->i.eq("customer_id",deptId).or().in(CollUtil.isNotEmpty(parentDeptIds),"customer_id",parentDeptIds));
+
+ // 如果当前用户所在组织机构 的级别是受检单位,查本单位下所有部门的;否则查当前用户所在部门的
+ List userDeptList = systemDeptService.getUserDeptList(null);
+ List userDeptIds = new ArrayList<>();
+ if(ObjectUtil.isNotEmpty(userDeptList)) {
+ userDeptIds.add(permissionContext.getAuthService().getLoginUser().getDeptId());
+ userDeptIds = userDeptList.stream().map(Dept::getId).collect(Collectors.toList());
+ }
+ if(ObjectUtil.isNotEmpty(userDeptIds)){
+ wrapper.in("dept_id",userDeptIds);
+ }else {
+ // userDeptIds为空 查询结果应为空
+ return page;
+ }
List list = orderListResponseMapper.listPage(page, wrapper);
page.setRecords(list);
@@ -75,7 +94,8 @@
DictCodeUtils.convertDictCodeToName(orderInfo);
// todo 交接单编号列表,另需补充根据交接单编号打印pdf的接口
QueryWrapper wrapper = new QueryWrapper<>();
- wrapper.select("*","(select manufacturer from eqpt_equipment_info e where e.id = sample_id) as sampleManufacturer");
+ wrapper.select("*","(select manufacturer from eqpt_equipment_info e where e.id = sample_id) as sampleManufacturer"
+ ,"(select manufacture_no from eqpt_equipment_info e where e.id = sample_id) as sampleManufactureNo");
wrapper.eq("order_id", orderInfo.getId());
List orderSampleList = sampleRelationMapper.selectList(wrapper);
for (BizBusinessOrderSampleRelation bizBusinessOrderSampleRelation : orderSampleList) {
@@ -179,18 +199,25 @@
List sampleRelations = businessOrder.getCustomerSampleInfoList();
if(CollUtil.isNotEmpty(sampleRelations)){
List sampleIds = sampleRelations.stream().map(BizBusinessOrderSampleRelation::getSampleId).distinct().collect(Collectors.toList());
- List checkRes = this.baseMapper.checkSamples(sampleIds,businessOrder.getId());
- if(CollUtil.isNotEmpty(checkRes)){
- Map> map = checkRes.stream().collect(Collectors.groupingBy(OrderCheckDTO::getManufactureNo));
- StringBuilder stringBuilder = new StringBuilder();
- for (String manufactureNo : map.keySet()) {
- List subRes = map.get(manufactureNo);
- String orderNos = StrUtil.join(",",subRes.stream().map(OrderCheckDTO::getOrderNo).distinct().collect(Collectors.toList()));
- stringBuilder.append(String.format("编号为%s的%s设备已在任务单%s中,",manufactureNo,subRes.get(0).getEquipmentName(),orderNos));
- }
- stringBuilder.append("请确认是否继续提交");
- return stringBuilder.toString();
+ return checkSamples(sampleIds,businessOrder.getId());
+ }
+
+ return null;
+ }
+
+ @Override
+ public String checkSamples(List sampleIds, Long orderId) {
+ List checkRes = this.baseMapper.checkSamples(sampleIds, orderId);
+ if(CollUtil.isNotEmpty(checkRes)){
+ Map> map = checkRes.stream().collect(Collectors.groupingBy(OrderCheckDTO::getManufactureNo));
+ StringBuilder stringBuilder = new StringBuilder();
+ for (String manufactureNo : map.keySet()) {
+ List subRes = map.get(manufactureNo);
+ String orderNos = StrUtil.join(",",subRes.stream().map(OrderCheckDTO::getOrderNo).distinct().collect(Collectors.toList()));
+ stringBuilder.append(String.format("编号为%s的%s设备已在任务单%s中,",manufactureNo,subRes.get(0).getEquipmentName(),orderNos));
}
+ stringBuilder.append("请确认是否继续提交");
+ return stringBuilder.toString();
}
return null;
}
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/impl/equipment/EquipmentInfoServiceImpl.java b/casic-metering-service/src/main/java/com/casic/missiles/service/impl/equipment/EquipmentInfoServiceImpl.java
index c587261..f16c7b3 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/impl/equipment/EquipmentInfoServiceImpl.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/impl/equipment/EquipmentInfoServiceImpl.java
@@ -54,6 +54,7 @@
import liquibase.pro.packaged.S;
import lombok.RequiredArgsConstructor;
import org.apache.commons.lang3.StringUtils;
+import org.docx4j.wml.P;
import org.jetbrains.annotations.NotNull;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
@@ -132,9 +133,7 @@
@Override
public Page listPage(Page page, EquipmentQueryForm queryForm) {
QueryWrapper queryWrapper = commonQuery(queryForm);
- DataScope dataScope = permissionContext.getAuthService().getLoginUserDataScope();
- dataScope.setScopeName("dept_id");
- List list = this.baseMapper.selectListPage(page, dataScope, queryWrapper);
+ List list = this.baseMapper.selectListPage(page, null, queryWrapper);
list.forEach(this::warpEquipmentInfo);
page.setRecords(list);
return page;
@@ -163,26 +162,14 @@
@Override
public List list(EquipmentQueryForm queryForm) {
QueryWrapper queryWrapper = commonQuery(queryForm);
- DataScope dataScope = permissionContext.getAuthService().getLoginUserDataScope();
- dataScope.setScopeName("dept_id");
- List list = this.baseMapper.selectList(dataScope, queryWrapper);
+ List list = this.baseMapper.selectList(null, queryWrapper);
list.forEach(this::warpEquipmentInfo);
return list;
}
@Override
public List groupByName(EquipmentQueryForm queryForm) {
- DataScope dataScope = permissionContext.getAuthService().getLoginUserDataScope();
- if (!ScopeEnums.ALL_TYPE.equals(dataScope.getScopeEnums())) {
- List dataScopeDeptIds = dataScope.getDeptIds();
- if (ObjectUtil.isNull(queryForm.getDeptIds())) {
- queryForm.setDeptIds(new ArrayList<>());
- }
- queryForm.getDeptIds().addAll(dataScopeDeptIds);
- }
-
QueryWrapper queryWrapper = commonQuery(queryForm);
-
queryWrapper.groupBy("equipment_name");
queryWrapper.select("equipment_name as 'equipmentName',count(*) as 'count'");
List