diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/impl/CustomPolicyServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/impl/CustomPolicyServiceImpl.java index b7a8dd0..fee24c3 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/impl/CustomPolicyServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/impl/CustomPolicyServiceImpl.java @@ -2,6 +2,7 @@ package org.nl.acs.custompolicy.server.impl; import cn.hutool.core.bean.BeanUtil; +import cn.hutool.core.collection.CollectionUtil; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; @@ -44,11 +45,24 @@ public class CustomPolicyServiceImpl extends CommonServiceImpl instructionStrategys; private final CustomPolicyMapper customPolicyMapper; + private final HashMap> customPolicyPlantDTOMap; + /** + * 初始化策略 + * @throws Exception + */ @Override public void autoInitial() throws Exception { - - + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(CustomPolicy::getIs_delete,0) ; + List customPolicyList = customPolicyMapper.selectList(wrapper); + if (CollectionUtil.isNotEmpty(customPolicyList)){ + List customPolicies = customPolicyList.stream().filter(item -> item.getKey_value() != null).collect(Collectors.toList()); + customPolicies.forEach(item -> { + CustomPolicyPlantVO customPolicyPlantVO = JSON.parseObject(item.getKey_value(), CustomPolicyPlantVO.class); + customPolicyPlantDTOMap.put(item.getUnit_code(),customPolicyPlantVO.getPlans()); + }); + } } @@ -100,7 +114,14 @@ public class CustomPolicyServiceImpl extends CommonServiceImpl