From 2ba93435afce9b04a5247739041902861b20596c Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Tue, 24 Oct 2023 10:24:26 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/wb' into qa --- screen-api/src/main/java/com/moral/api/mapper/SysDictTypeMapper.java | 2 + screen-api/src/main/java/com/moral/api/pojo/vo/allocation/AllocationFindVo.java | 2 + screen-api/src/main/resources/mapper/SysDictTypeMapper.xml | 6 +++ screen-api/src/main/java/com/moral/api/service/SysDictTypeService.java | 2 + screen-api/src/main/java/com/moral/api/service/impl/AllocationServiceImpl.java | 67 +++++++++++++++++++-------------- screen-common/src/main/java/com/moral/util/AmendUtils.java | 3 + screen-api/src/main/java/com/moral/api/pojo/query/allocation/AllocationCheckCond.java | 2 screen-api/src/main/java/com/moral/api/service/impl/SysDictTypeServiceImpl.java | 13 ++++++ 8 files changed, 68 insertions(+), 29 deletions(-) diff --git a/screen-api/src/main/java/com/moral/api/mapper/SysDictTypeMapper.java b/screen-api/src/main/java/com/moral/api/mapper/SysDictTypeMapper.java index c62f910..d1de4f3 100644 --- a/screen-api/src/main/java/com/moral/api/mapper/SysDictTypeMapper.java +++ b/screen-api/src/main/java/com/moral/api/mapper/SysDictTypeMapper.java @@ -21,4 +21,6 @@ List<SysDictData> selectIdList(@Param("code") String code, @Param("ids") List<String> ids); + + SysDictType selectFind(@Param("name") String name); } diff --git a/screen-api/src/main/java/com/moral/api/pojo/query/allocation/AllocationCheckCond.java b/screen-api/src/main/java/com/moral/api/pojo/query/allocation/AllocationCheckCond.java index 675faa4..0a3b2c4 100644 --- a/screen-api/src/main/java/com/moral/api/pojo/query/allocation/AllocationCheckCond.java +++ b/screen-api/src/main/java/com/moral/api/pojo/query/allocation/AllocationCheckCond.java @@ -26,7 +26,7 @@ @EqualsAndHashCode(callSuper = false) @Accessors(chain = true) @ApiModel(value="Allocation - ������������������", description="Allocation - ������������������") -public class AllocationCheckCond implements Serializable { +public class AllocationCheckCond implements Serializable { @ApiModelProperty(value = "������id") @NotNull(message = "������id���������������") diff --git a/screen-api/src/main/java/com/moral/api/pojo/vo/allocation/AllocationFindVo.java b/screen-api/src/main/java/com/moral/api/pojo/vo/allocation/AllocationFindVo.java index 7e443a3..0b507d1 100644 --- a/screen-api/src/main/java/com/moral/api/pojo/vo/allocation/AllocationFindVo.java +++ b/screen-api/src/main/java/com/moral/api/pojo/vo/allocation/AllocationFindVo.java @@ -38,6 +38,8 @@ @ApiModelProperty(value = "������������id") private Integer changeType; + @ApiModelProperty(value = "������������") + private String pollutePosition; @ApiModelProperty(value = "������������") private Integer changeDay; diff --git a/screen-api/src/main/java/com/moral/api/service/SysDictTypeService.java b/screen-api/src/main/java/com/moral/api/service/SysDictTypeService.java index 932f5df..97a8530 100644 --- a/screen-api/src/main/java/com/moral/api/service/SysDictTypeService.java +++ b/screen-api/src/main/java/com/moral/api/service/SysDictTypeService.java @@ -22,4 +22,6 @@ SysDictData listOne(String code, String dataKey); List<SysDictData> listWindAll(String code, List<String> dataKey); + //������������������������ + SysDictType slectFind(String name); } 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 003041c..1dbffad 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 @@ -64,6 +64,8 @@ private AllocationExtensionService allocationExtensionService; @Autowired private ResponsibilityUnitService responsibilityUnitService; + @Autowired + private SysDictTypeService sysDictTypeService; /** * ������������������������������������ @@ -280,13 +282,14 @@ escalationTypeList.add(typeMap); } //������������������������ + SysDictType sysDictType = sysDictTypeService.slectFind(Constants.WU_RAN_LEI_XING); 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<>(); - sysDictDataQueryWrapper.eq("dict_type_id",32); + sysDictDataQueryWrapper.eq("dict_type_id",sysDictType.getId()); sysDictDataQueryWrapper.eq("dataKey",polluteType); SysDictData sysDictData = sysDictDataMapper.selectOne(sysDictDataQueryWrapper); typeMap.put("name",sysDictData.getDataValue()); @@ -617,57 +620,65 @@ //������������������ List<Integer> list = unitResult(); if (!ObjectUtils.isEmpty(list)){ - Integer integer = list.get(0); - if (integer==0){ - return null; - }else { - wrapper.in(Allocation::getUnitId,list); - } + wrapper.in(Allocation::getUnitId,list); } Integer integer = unitAreaCode(); - //��������������� ��������� - if (integer==0 || integer==1){ + // ��������� + if (integer==1){ if (state==3){ - wrapper.in(Allocation::getState,40,50); - }else if (state==2){ - wrapper.eq(Allocation::getState,30); + wrapper.in(Allocation::getState,AllocationApproveEnum.PASS.value,AllocationApproveEnum.REFUSE.value); }else if (state==1){ - wrapper.eq(Allocation::getState,20); + wrapper.in(Allocation::getState,AllocationApproveEnum.UNDER_RECTIFICATION.value,AllocationApproveEnum.DRAFT.value,AllocationApproveEnum.IN_APPROVAL.value); + }else { + wrapper.eq(Allocation::getState,0); } - //������������ - }else if (integer==2){ + }else if(integer == 0) { if (state==3){ - wrapper.in(Allocation::getState,40,50); + wrapper.in(Allocation::getState,AllocationApproveEnum.PASS.value,AllocationApproveEnum.REFUSE.value); }else if (state==2){ - wrapper.eq(Allocation::getState,20); + wrapper.eq(Allocation::getState,AllocationApproveEnum.IN_APPROVAL.value); }else if (state==1){ - wrapper.eq(Allocation::getState,30); + wrapper.in(Allocation::getState,AllocationApproveEnum.UNDER_RECTIFICATION.value,AllocationApproveEnum.DRAFT.value); + } + }else if(integer == 2){ + if (state==3){ + wrapper.in(Allocation::getState,AllocationApproveEnum.PASS.value,AllocationApproveEnum.REFUSE.value); + }else if (state==2){ + wrapper.in(Allocation::getState,AllocationApproveEnum.UNDER_RECTIFICATION.value,AllocationApproveEnum.DRAFT.value); + }else if (state==1){ + wrapper.eq(Allocation::getState,AllocationApproveEnum.IN_APPROVAL.value); } } if (!ObjectUtils.isEmpty(startTime) && !ObjectUtils.isEmpty(endTime)){ wrapper.between(Allocation::getEscalationTime,startTime,endTime); } wrapper.eq(Allocation::getIsDel,0).eq(Allocation::getIsInvalid,0); - wrapper.orderByDesc(Allocation::getEscalationTime); + wrapper.orderByDesc(Allocation::getEscalationTime,Allocation::getAllocationId); List<Allocation> allocations = allocationMapper.selectList(wrapper); for (Allocation allocation : allocations) { AllocationFindVo allocationFindVo = new AllocationFindVo(); BeanUtils.copyProperties(allocation,allocationFindVo); Integer state1 = allocationFindVo.getState(); - if (integer==0 || integer==1){ - if (state1==20){ + if ( integer==2){ + if (state1.equals(AllocationApproveEnum.DRAFT.value)||state1.equals(AllocationApproveEnum.UNDER_RECTIFICATION.value)){ + allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_COMPLETED.name); + }else if (state1.equals(AllocationApproveEnum.IN_APPROVAL.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_PROCESSED.name); - }else if (state1==30){ - allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_PROCESSED.name); - }else if (state1==40 ||state1==50){ + }else if (state1.equals(AllocationApproveEnum.PASS.value)||state1.equals(AllocationApproveEnum.REFUSE.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.COMPLETED.name); } - }else { - if (state1==20){ + }else if(integer==1){ + if (state1.equals(AllocationApproveEnum.DRAFT.value)||state1.equals(AllocationApproveEnum.UNDER_RECTIFICATION.value)||state1.equals(AllocationApproveEnum.IN_APPROVAL.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_PROCESSED.name); - }else if (state1==30){ + }else if (state1.equals(AllocationApproveEnum.PASS.value)||state1.equals(AllocationApproveEnum.REFUSE.value)){ + allocationFindVo.setStateName(AppAllocationStateEnum.COMPLETED.name); + } + }else if(integer==0) { + if (state1.equals(AllocationApproveEnum.DRAFT.value)||state1.equals(AllocationApproveEnum.UNDER_RECTIFICATION.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_PROCESSED.name); - }else if (state1==40||state1==50){ + }else if (state1.equals(AllocationApproveEnum.IN_APPROVAL.value)){ + allocationFindVo.setStateName(AppAllocationStateEnum.TO_BE_COMPLETED.name); + }else if (state1.equals(AllocationApproveEnum.PASS.value)||state1.equals(AllocationApproveEnum.REFUSE.value)){ allocationFindVo.setStateName(AppAllocationStateEnum.COMPLETED.name); } } diff --git a/screen-api/src/main/java/com/moral/api/service/impl/SysDictTypeServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/SysDictTypeServiceImpl.java index 088bc46..c1fb0e1 100644 --- a/screen-api/src/main/java/com/moral/api/service/impl/SysDictTypeServiceImpl.java +++ b/screen-api/src/main/java/com/moral/api/service/impl/SysDictTypeServiceImpl.java @@ -1,11 +1,16 @@ package com.moral.api.service.impl; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.moral.api.entity.SysDictData; import com.moral.api.entity.SysDictType; import com.moral.api.mapper.SysDictTypeMapper; import com.moral.api.service.SysDictTypeService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.moral.constant.Constants; + import org.apache.commons.collections4.CollectionUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.web.config.QuerydslWebConfiguration; import org.springframework.stereotype.Service; import java.util.List; @@ -21,6 +26,8 @@ @Service public class SysDictTypeServiceImpl extends ServiceImpl<SysDictTypeMapper, SysDictType> implements SysDictTypeService { + @Autowired + private SysDictTypeMapper sysDictTypeMapper; @Override public List<SysDictData> listAll(String code, String dataKey) { List<SysDictData> listAll = this.baseMapper.selectCodeList(code,dataKey); @@ -43,4 +50,10 @@ List<SysDictData> listAll = this.baseMapper.selectIdList(code,dataKey); return listAll; } + + @Override + public SysDictType slectFind(String name) { + SysDictType sysDictType = this.baseMapper.selectFind(name); + return sysDictType; + } } diff --git a/screen-api/src/main/resources/mapper/SysDictTypeMapper.xml b/screen-api/src/main/resources/mapper/SysDictTypeMapper.xml index e438644..29aebce 100644 --- a/screen-api/src/main/resources/mapper/SysDictTypeMapper.xml +++ b/screen-api/src/main/resources/mapper/SysDictTypeMapper.xml @@ -30,4 +30,10 @@ and t1.is_delete = 0 order by t1.create_time desc </select> + + <select id="selectFind" resultType="com.moral.api.entity.SysDictType"> + select * from sys_dict_type + where sys_dict_type.name= #{name} AND is_delete = 0 + </select> + </mapper> \ No newline at end of file diff --git a/screen-common/src/main/java/com/moral/util/AmendUtils.java b/screen-common/src/main/java/com/moral/util/AmendUtils.java index 3c726b1..ac3c4e0 100644 --- a/screen-common/src/main/java/com/moral/util/AmendUtils.java +++ b/screen-common/src/main/java/com/moral/util/AmendUtils.java @@ -57,6 +57,9 @@ List<Double> data = new ArrayList<>(); for (Map<String, Object> dataMap : list) { Map<String, Object> dataValue = JSONObject.parseObject((String) dataMap.get("value"), Map.class); + if (ObjectUtils.isEmpty(dataValue.get(Constants.SENSOR_CODE_O3))){ + continue; + } Double o3 = Double.parseDouble(dataValue.get(Constants.SENSOR_CODE_O3).toString()); //O3��������������� -- Gitblit v1.8.0