From 7e2f3abca2f5bb83459f809b8e7195b361e0a372 Mon Sep 17 00:00:00 2001
From: cjl <276999030@qq.com>
Date: Sat, 07 Oct 2023 12:00:30 +0800
Subject: [PATCH] ci:补充提交
---
screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java | 211 +++++++++++++---------------------------------------
1 files changed, 52 insertions(+), 159 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java
index d72e2ec..7a8b8f9 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java
@@ -68,6 +68,7 @@
@Slf4j
public class AllocationServiceImpl extends ServiceImpl<AllocationMapper, Allocation> implements AllocationService {
+ private final Integer NEW_BUILT = 10;
@Autowired
private SysDictTypeMapper sysDictTypeMapper;
@Autowired
@@ -138,63 +139,32 @@
allocation.setEscalationType(AllocationEscalationTypeEnum.SELF.getValue());
String dateString = DateUtils.dateToDateString(new Date(), DateUtils.yyyyMMdd_EN);
Object o = redisTemplate.opsForValue().get(RedisConstants.JBD_DATA);
- int i;
- if (ObjectUtils.isEmpty(o)){
- i = 1;
- }else {
- i = Integer.parseInt(o.toString()) + 1;
- }
+ int i = ObjectUtils.isEmpty(o)?1:Integer.parseInt(o.toString()) + 1;
//������
String allocationNum = "JBD-" + dateString + String.format("%04d", i);
allocation.setAllocationNum(allocationNum);
if(Objects.nonNull(allocationCond.getEscalationUnitId())&&allocationCond.getEscalationUnitId().toString().length()==6) {
allocation.setEscalationType(AllocationEscalationTypeEnum.CHECK.getValue());
}
- if(AllocationApproveEnum.NEW_BUILT.value.equals(allocationCond.getState())) {
+ if(NEW_BUILT.equals(allocationCond.getState())) {
allocation.setState(AllocationApproveEnum.UNDER_RECTIFICATION.value);
}
//������������������
allocationMapper.insert(allocation);
redisTemplate.opsForValue().set(RedisConstants.JBD_DATA,i);
- if(AllocationApproveEnum.NEW_BUILT.value.equals(allocationCond.getState())) {
+ if(NEW_BUILT.equals(allocationCond.getState())) {
//������������������
ApproveTable approveTable = new ApproveTable();
approveTable.setRelationId(allocation.getAllocationId());
- approveTable.setState(AllocationApproveEnum.NEW_BUILT.value);
+ approveTable.setState(NEW_BUILT);
approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value);
- approveTable.setStateName(AllocationApproveEnum.NEW_BUILT.name);
+ approveTable.setStateName("������");
approveTableService.saveResult(approveTable);
}
fileTableService.upDateResult(allocationCond.getFileBaseList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value);
return allocation.getAllocationId();
}
- /**
- * ������������
- * @param id
- * @return
- */
- @Override
- public AllocationUnitDto check(Integer id) {
- AllocationUnitDto allocationUnitDto = new AllocationUnitDto();
- Allocation allocation = allocationMapper.selectById(id);
- BeanUtils.copyProperties(allocation,allocationUnitDto);
- ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(allocation.getUnitId());
- allocationUnitDto.setUnitName(responsibilityUnit.getUnitName());
- allocationUnitDto.setEscalationUnitName(responsibilityUnit.getUnitName());
- Map<String, List<SysDictData>> map = (Map<String, List<SysDictData>>) redisTemplate.opsForValue().get(RedisConstants.DICT_DATA_KEY);
- List<SysDictData> contaminate = map.get("contaminate");
- for (SysDictData sysDictData : contaminate) {
- if (sysDictData.getDataKey().equals(allocation.getPolluteType().toString())){
- allocationUnitDto.setPolluteTypeName(sysDictData.getDataValue());
- break;
- }
- }
- allocationUnitDto.setChangeTypeName(allocation.getChangeType()==0?"������������":"������������");
- allocationUnitDto.setInvestigationTypeName(allocation.getChangeType()==0?"������":"���������");
- //������������
- return allocationUnitDto;
- }
/**
* ���������������
@@ -212,16 +182,16 @@
if(Objects.nonNull(allocationUpdateCond.getEscalationUnitId())&&allocationUpdateCond.getEscalationUnitId().toString().length()==6) {
allocation.setEscalationType(AllocationEscalationTypeEnum.CHECK.getValue());
}
- if(AllocationApproveEnum.NEW_BUILT.value.equals(allocationUpdateCond.getState())) {
+ if(NEW_BUILT.equals(allocationUpdateCond.getState())) {
//������������������
ApproveTable approveTable = new ApproveTable();
approveTable.setRelationId(allocation.getAllocationId());
- approveTable.setState(AllocationApproveEnum.NEW_BUILT.value);
+ approveTable.setState(NEW_BUILT);
approveTable.setApproveModule(FileTableEnum.ALLOCATION_FOUNDATION.value);
- approveTable.setStateName(AllocationApproveEnum.NEW_BUILT.name);
+ approveTable.setStateName("������");
approveTableService.saveResult(approveTable);
}
- if(AllocationApproveEnum.NEW_BUILT.value.equals(allocationUpdateCond.getState())) {
+ if(NEW_BUILT.equals(allocationUpdateCond.getState())) {
allocation.setState(AllocationApproveEnum.UNDER_RECTIFICATION.value);
}
fileTableService.upDateResult(allocationUpdateCond.getFileBaseList(),allocation.getAllocationId(), FileTableEnum.ALLOCATION_FOUNDATION.value);
@@ -229,67 +199,7 @@
}
- /**
- * ������������������
- * @param map
- * @return
- */
- @Override
- public List<Allocation> selectAll(Map<String, Object> map) {
- Object unitId = map.get("unitId");
- Object state = map.get("state");
- Object polluteType = map.get("polluteType");
- Object investigationType = map.get("investigationType");
- Object changeType = map.get("changeType");
- Object escalationTime = map.get("escalationTime");
- Object isInvalid = map.get("isInvalid");
-// int page = Integer.parseInt(map.get("page").toString());
-// int size = Integer.parseInt(map.get("size").toString());
- QueryWrapper<Allocation> wrapper = new QueryWrapper<>();
-
- //������������
- if (!ObjectUtils.isEmpty(unitId)){
- wrapper.eq("unit_id",Integer.parseInt(unitId.toString()));
- }
- //������������
- if (!ObjectUtils.isEmpty(state)){
- wrapper.eq("state",Integer.parseInt(state.toString()));
- }
- //������������
- if (!ObjectUtils.isEmpty(polluteType)){
- wrapper.eq("pollute_type",Integer.parseInt(polluteType.toString()));
- }
- //������������
- if (!ObjectUtils.isEmpty(investigationType)){
- wrapper.eq("investigation_type",Integer.parseInt(investigationType.toString()));
- }
- //������������
- if (!ObjectUtils.isEmpty(changeType)){
- wrapper.eq("change_type",Integer.parseInt(changeType.toString()));
- }
- //������������
- if (!ObjectUtils.isEmpty(isInvalid)){
- wrapper.eq("is_invalid",Integer.parseInt(isInvalid.toString()));
- }
- if (!ObjectUtils.isEmpty(escalationTime)){
-// wrapper.eq("is_invalid",Integer.parseInt(isInvalid.toString()));
- }
- List<Allocation> allocations = allocationMapper.selectList(wrapper);
- ArrayList<AllocationUnitDto> rsList = new ArrayList<>();
- for (Allocation allocation : allocations) {
- AllocationUnitDto allocationUnitDto = new AllocationUnitDto();
- BeanUtils.copyProperties(allocation,allocationUnitDto);
- allocation.getEscalationTime();
- Date dateOfDay = DateUtils.getDateOfDay(allocation.getEscalationTime(), allocation.getChangeDay());
- Date date = new Date();
- //���������������������������
- int days = DateUtils.getDays(dateOfDay, date);
- allocationUnitDto.setChangeDay(days);
- rsList.add(allocationUnitDto);
- }
- return null;
- }
/**
@@ -309,6 +219,9 @@
wrapper.in("unit_id",map.get("unitId").toString());
}else {
if (orgId!=24){
+ if (ObjectUtils.isEmpty(unitId)){
+ return null;
+ }
ResponsibilityUnit responsibilityUnit1 = responsibilityUnitMapper.selectById(Integer.parseInt(unitId.toString()));
Integer areaCode = responsibilityUnit1.getAreaCode();
List<ResponsibilityUnit> responsibilityUnits = responsibilityUnitService.selectUnit(areaCode);
@@ -322,21 +235,12 @@
List<Integer> collect1 = collect.keySet().stream().collect(Collectors.toList());
wrapper.in("unit_id",collect1);
}
- }else if(orgId==24) {
-
- }else {
- if (ObjectUtils.isEmpty(unitId)){
- return null;
- }
}
}
HashMap<String, Object> rsMap = new HashMap<>();
-// HashMap<String, Object> polluteMap = new HashMap<>();
ArrayList<Map<String, Object>> polluteArrayList = new ArrayList<>();
ArrayList<Map<String, Object>> escalationTypeList = new ArrayList<>();
-
-
ArrayList<AllocationUnitViewDto> allocationUnitViewDtos = new ArrayList<>();
Object number1 = map.get("number");
@@ -349,26 +253,9 @@
}
if (!ObjectUtils.isEmpty(number1)){
String s = "-"+number1;
- //���������������
+ //������������������
endTime = DateUtils.getCurDateTime();
- if (s.equals("-1")){
- //���������������
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
- if (s.equals("-2")){
- //���������������
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
- if (s.equals("-3")){
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
- if (s.equals("-6")){
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
- if (s.equals("-12")){
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
-
+ startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
}
wrapper.between("escalation_time",startTime,endTime);
@@ -384,7 +271,7 @@
String state = allocation.getState()+"";
if (state.equals("40")||state.equals("50")){
complete++;
- }else if(state.equals("10")||state.equals("20") ||state.equals("30")) {
+ }else {
unComplete++;
}
}
@@ -407,7 +294,6 @@
Map<Integer, List<Allocation>> polluteTypeMap = allocations.stream().collect(Collectors.groupingBy(o -> o.getPolluteType()));
Set<Integer> polluteTypes = polluteTypeMap.keySet();
for (Integer polluteType : polluteTypes) {
-
HashMap<String, Object> typeMap = new HashMap<>();
List<Allocation> allocations1 = polluteTypeMap.get(polluteType);
QueryWrapper<SysDictData> sysDictDataQueryWrapper = new QueryWrapper<>();
@@ -416,7 +302,6 @@
SysDictData sysDictData = sysDictDataMapper.selectOne(sysDictDataQueryWrapper);
typeMap.put("name",sysDictData.getDataValue());
typeMap.put("value",allocations1.size());
-// polluteMap.put("polluteType",typeMap);
polluteArrayList.add(typeMap);
}
//������������������������
@@ -427,9 +312,7 @@
for (Integer integer : unitList) {
//������������
ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(integer);
-
SysArea areaByCode = sysAreaService.getAreaByCode(responsibilityUnit.getAreaCode());
-
AllocationUnitViewDto allocationUnitViewDto = new AllocationUnitViewDto();
List<Allocation> allocations1 = unitMap.get(integer);
//������
@@ -445,7 +328,7 @@
Date dateOfDay = DateUtils.getDateOfDay(allocation.getEscalationTime(), allocation.getChangeDay());
Date date = new Date();
boolean timeBefor = DateUtils.isTimeBefor(date, dateOfDay);
- if (timeBefor && !state.equals("40") && !state.equals("50")){
+ if (timeBefor && !state.equals("40") && !state.equals("50") && !state.equals("9")){
//������������
overdue++;
}
@@ -474,9 +357,9 @@
rsMap.put("unitView",allocationUnitViewDtos);
//������
rsMap.put("total",allocations.size());
- //���������
+ //���������
rsMap.put("complete",complete);
- //������������
+ //���������
rsMap.put("unComplete",unComplete);
//������
rsMap.put("overdue",overdue);
@@ -532,26 +415,9 @@
}
if (!ObjectUtils.isEmpty(number1)){
String s = "-"+number1;
- //���������������
+ //������������������
endTime = DateUtils.getCurDateTime();
- if (s.equals("-1")){
- //���������������
-
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
- if (s.equals("-2")){
- //���������������
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
- if (s.equals("-3")){
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
- if (s.equals("-6")){
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
- if (s.equals("-12")){
- startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
- }
+ startTime = DateUtils.getDateStringOfMon(Integer.parseInt(s), DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
}
wrapper.between("escalation_time",startTime,endTime);
@@ -569,11 +435,8 @@
LinkedHashMap<String, Object> map1 = new LinkedHashMap<>();
//������������
ResponsibilityUnit responsibilityUnit = responsibilityUnitMapper.selectById(integer);
-
SysArea areaByCode = sysAreaService.getAreaByCode(responsibilityUnit.getAreaCode());
-
List<Allocation> allocations1 = unitMap.get(integer);
-
//������
int marks=0;
//������
@@ -609,8 +472,19 @@
@Override
public Page<AllocationPageExt> extPage(AllocationPageCond allocationPageCond) {
List<Integer> unitList = unitResult();
+ Integer codeId = unitAreaCode();
allocationPageCond.setUnitList(unitList);
- return this.baseMapper.extPage(allocationPageCond.getPage().convertPage(), allocationPageCond);
+ Page<AllocationPageExt> page = this.baseMapper.extPage(allocationPageCond.getPage().convertPage(), allocationPageCond);
+ if(CollectionUtils.isNotEmpty(page.getRecords())){
+ page.getRecords().forEach(it->{
+ if((CollectionUtils.isEmpty(unitList)&&codeId.equals(1))||codeId.equals(2)){
+ it.setIsApprove(1);
+ }else {
+ it.setIsApprove(0);
+ }
+ });
+ }
+ return page;
}
@Override
@@ -728,6 +602,7 @@
}
AllocationExtension allocationExtension = allocationExtensionAddCond.convert();
allocationExtension.setState(AllocationExtensionApproveEnum.APPLYING.value);
+ allocationExtension.setExtensionOldNum(allocationExt.getChangeDay());
allocationExtensionService.save(allocationExtension);
fileTableService.upDateResult(allocationExtensionAddCond.getFileList(),allocationExtension.getId(), FileTableEnum.ALLOCATION_EXTENSION.value);
return true;
@@ -747,4 +622,22 @@
}
return Arrays.asList(0);
}
+
+ @Override
+ public Integer unitAreaCode() {
+ QxUser user = UserHelper.getCurrentUser();
+ List<Integer> userList = responsibilityUnitMapper.selectCodeList("JBD",user.getUserId());
+ if(CollectionUtils.isNotEmpty(userList)){
+ return 1;
+ }
+ if(Objects.nonNull(user.getUnitId())){
+ String code = responsibilityUnitMapper.selectAreaCode(user.getUnitId());
+ if(code.length()>6){
+ return 0;
+ }else {
+ return 2;
+ }
+ }
+ return 1;
+ }
}
--
Gitblit v1.8.0