diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueVoteStatisticalDailyController.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueVoteStatisticalDailyController.java index 7e5506354a..6ff8f2e89b 100644 --- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueVoteStatisticalDailyController.java +++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/controller/IssueVoteStatisticalDailyController.java @@ -91,4 +91,16 @@ public class IssueVoteStatisticalDailyController { ExcelUtils.exportExcelToTarget(response, null, list, IssueVoteStatisticalDailyExcel.class); } + /** + * @Description 定时任务 每天生成生成昨日的议题表决日统计数 + * @param + * @return + * @author wangc + * @date 2020.05.20 15:39 + **/ + @PostMapping(value = "dailystasticalvotejob") + public Result dailyStasticalVoteJob(){ + issueVoteStatisticalDailyService.countVotingDailyStatistic(); + return new Result(); + } } \ No newline at end of file diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteDetailDao.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteDetailDao.java index 1b0b35cd83..2fc8b4ee66 100644 --- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteDetailDao.java +++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteDetailDao.java @@ -22,6 +22,8 @@ import com.epmet.dto.form.VoteFormDTO; import com.epmet.entity.IssueVoteDetailEntity; import org.apache.ibatis.annotations.Mapper; +import java.util.Set; + /** * 议题表决记录表 * @@ -38,4 +40,12 @@ public interface IssueVoteDetailDao extends BaseDao { */ Integer checkoutVote(VoteFormDTO formDTO); + /** + * @Description getAttitudes + * @param + * @return + * @author wangc + * @date 2020.05.20 10:52 + **/ + Set getAttitudes(); } \ No newline at end of file diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDailyDao.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDailyDao.java index 7fa3df29c2..c6a6a36e1b 100644 --- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDailyDao.java +++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/dao/IssueVoteStatisticalDailyDao.java @@ -50,4 +50,31 @@ public interface IssueVoteStatisticalDailyDao extends BaseDao getIssueVotingStatisticalUpToYesterday(); + + /** + * @Description 通过议题Id和统计日期查找日统计信息 + * @param entity + * @return + * @author wangc + * @date 2020.05.20 11:14 + **/ + IssueVoteStatisticalDailyEntity getDailyStatisticalCountByIssueIdAndStatisticalDate(IssueVoteStatisticalDailyEntity entity); + + /** + * @Description 批量添加 + * @param list List + * @return + * @author wangc + * @date 2020.05.20 14:54 + **/ + void insertBatch(List list); + + /** + * @Description 批量更新 + * @param list List + * @return + * @author wangc + * @date 2020.05.20 14:54 + **/ + void updateBatch(List list); } \ No newline at end of file diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalDailyServiceImpl.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalDailyServiceImpl.java index db1b43ecc0..adea467e4e 100644 --- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalDailyServiceImpl.java +++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueVoteStatisticalDailyServiceImpl.java @@ -20,23 +20,27 @@ package com.epmet.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; +import com.epmet.commons.tools.constant.NumConstant; import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.utils.ConvertUtils; import com.epmet.commons.tools.constant.FieldConstant; +import com.epmet.dao.IssueVoteDetailDao; import com.epmet.dao.IssueVoteStatisticalDailyDao; import com.epmet.dto.IssueVoteStatisticalDailyDTO; import com.epmet.dto.result.IssuesToBeCountedResultDTO; import com.epmet.entity.IssueVoteStatisticalDailyEntity; import com.epmet.redis.IssueVoteStatisticalDailyRedis; import com.epmet.service.IssueVoteStatisticalDailyService; +import com.epmet.utils.ModuleConstants; +import oracle.sql.NUMBER; import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; -import java.util.Arrays; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.stream.Collectors; /** @@ -51,6 +55,11 @@ public class IssueVoteStatisticalDailyServiceImpl extends BaseServiceImpl page(Map params) { IPage page = baseDao.selectPage( @@ -72,7 +81,9 @@ public class IssueVoteStatisticalDailyServiceImpl extends BaseServiceImpl wrapper = new QueryWrapper<>(); wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id); - + wrapper.eq(FieldConstant.DEL_FLAG,NumConstant.ZERO_STR); + wrapper.eq(StringUtils.isNotBlank((String)params.get(ModuleConstants.FIELD_JAVA_ISSUE_ID)), ModuleConstants.FIELD_SQL_ISSUE_ID,params.get(ModuleConstants.FIELD_JAVA_ISSUE_ID)); + wrapper.eq(null == params.get(ModuleConstants.FIELD_JAVA_STATISTICAL_DATE),ModuleConstants.FIELD_SQL_STATISTICAL_DATE,params.get(ModuleConstants.FIELD_JAVA_STATISTICAL_DATE)); return wrapper; } @@ -111,24 +122,182 @@ public class IssueVoteStatisticalDailyServiceImpl extends BaseServiceImpl issueStatisticalList = baseDao.getIssueVotingStatistical(); Map> issueStatisticalMap = - issueStatisticalList.stream().collect(Collectors.groupingBy(IssuesToBeCountedResultDTO::getIssueId)); + issueStatisticalList.stream().collect(Collectors.groupingBy(IssuesToBeCountedResultDTO::getIssueId)); + //截至到昨天的统计List List issueStatisticalListUpToYes = baseDao.getIssueVotingStatisticalUpToYesterday(); - Map> issueStatisticalMapUpTpYes = + Map> issueStatisticalMapUpToYes = issueStatisticalListUpToYes.stream().collect(Collectors.groupingBy(IssuesToBeCountedResultDTO::getIssueId)); + //日统计信息会出现若统计日内无人点“同意”或者“反对”,则返回列表中只有表决的单方面数据,未被选举的数据没有,因此需要截至当日的统计列表 + //如果当日无人进行表决而昨日之前有表决,此时会返回一条议题记录,attitude为null,attitudeUpToYesterday不为null + //若昨日以及昨日之前都无人表决,此时attitude为null,attitudeUpToYesterday也为null + List dailyListToInsert = new LinkedList<>(); + List dailyListToUpdate = new LinkedList<>(); issueStatisticalMap.forEach((key,value) -> { + //key为议题Id + //当List不为空时 + if(null != value && value.size() > NumConstant.ZERO){ + IssueVoteStatisticalDailyEntity dailyStatisticalToInsert = new IssueVoteStatisticalDailyEntity(); + dailyStatisticalToInsert.setIssueId(key); + dailyStatisticalToInsert.setStatisticalDate(yesterday); + dailyStatisticalToInsert.setCreatedBy(ModuleConstants.CREATED_OR_UPDATED_BY_SYSTEM); + //此列无意义,统一存0 + dailyStatisticalToInsert.setVotableCount(NumConstant.ZERO); - }); + IssueVoteStatisticalDailyEntity dailyStatisticalToUpdate = new IssueVoteStatisticalDailyEntity(); + dailyStatisticalToUpdate.setIssueId(key); + dailyStatisticalToUpdate.setStatisticalDate(yesterday); + dailyStatisticalToUpdate.setUpdatedBy(ModuleConstants.CREATED_OR_UPDATED_BY_SYSTEM); + //判断数据库中是否有此数据 + IssueVoteStatisticalDailyEntity + existedInfo = + baseDao.getDailyStatisticalCountByIssueIdAndStatisticalDate(dailyStatisticalToUpdate); - //1.获取所有表决中的议题以及在昨日表决截至的议题,将昨日新生成的议题单独拿出来 + for(IssuesToBeCountedResultDTO o : value){ + //o的attitudeUpToYesterday有三种值:opposition 、 support 、 null + //当o的attitudeUpToYesterday为null时,List中只有一条 + //当o的attitudeUpToYesterday不为null时,List中可能存在一条或者两条 + if(null != existedInfo){ + //数据库中已有此记录 - update + dailyStatisticalToUpdate.setId(existedInfo.getId()); + if(StringUtils.isBlank(o.getAttitudeUpToYesterday())){ + //昨日无人表决,昨日之前也无人表决 + dailyStatisticalToUpdate.setOppositionCount(NumConstant.ZERO); + dailyStatisticalToUpdate.setSupportCount(NumConstant.ZERO); + dailyStatisticalToUpdate.setTotalCount(NumConstant.ZERO); + dailyStatisticalToUpdate.setOppositionIncrement(NumConstant.ZERO); + dailyStatisticalToUpdate.setSupportIncrement(NumConstant.ZERO); + dailyStatisticalToUpdate.setTodayIncrement(NumConstant.ZERO); + }else if(StringUtils.equals(o.getAttitudeUpToYesterday(),ModuleConstants.ISSUE_VOTING_ATTITUDE_SUPPORT)){ + dailyStatisticalToUpdate.setSupportCount(o.getVoteCountUpToYesterday()); + dailyStatisticalToUpdate.setSupportIncrement(o.getVoteCount()); + }else if(StringUtils.equals(o.getAttitudeUpToYesterday(),ModuleConstants.ISSUE_VOTING_ATTITUDE_OPPOSITION)){ + dailyStatisticalToUpdate.setOppositionCount(o.getVoteCountUpToYesterday()); + dailyStatisticalToUpdate.setOppositionIncrement(o.getVoteCount()); + } - //2.对每一个表决中的议题校验有没有生成过前一天的统计数据,如果生成过则跳过次议题 + }else{ + //数据库中没有此纪录 - insert + if(StringUtils.isBlank(o.getAttitudeUpToYesterday())){ + //昨日无人表决,昨日之前也无人表决 + dailyStatisticalToInsert.setOppositionCount(NumConstant.ZERO); + dailyStatisticalToInsert.setSupportCount(NumConstant.ZERO); + dailyStatisticalToInsert.setTotalCount(NumConstant.ZERO); + dailyStatisticalToInsert.setOppositionIncrement(NumConstant.ZERO); + dailyStatisticalToInsert.setSupportIncrement(NumConstant.ZERO); + dailyStatisticalToInsert.setTodayIncrement(NumConstant.ZERO); + }else if(StringUtils.equals(o.getAttitudeUpToYesterday(),ModuleConstants.ISSUE_VOTING_ATTITUDE_SUPPORT)){ + dailyStatisticalToInsert.setSupportCount(o.getVoteCountUpToYesterday()); + dailyStatisticalToInsert.setSupportIncrement(o.getVoteCount()); + }else if(StringUtils.equals(o.getAttitudeUpToYesterday(),ModuleConstants.ISSUE_VOTING_ATTITUDE_OPPOSITION)){ + dailyStatisticalToInsert.setOppositionCount(o.getVoteCountUpToYesterday()); + dailyStatisticalToInsert.setOppositionIncrement(o.getVoteCount()); + } + } + } + //遍历完List之后,检查是否有因为昨日未表决过某钟态度而漏掉昨日之前的表决信息 + if(null != existedInfo){ + if(null == dailyStatisticalToUpdate.getOppositionCount()){ + //昨日无人反对该议题 + dailyStatisticalToUpdate.setOppositionIncrement(NumConstant.ZERO); + if(null != issueStatisticalMapUpToYes.get(key)){ + Optional first = + issueStatisticalMapUpToYes.get(key).stream().filter( + obj -> ModuleConstants.ISSUE_VOTING_ATTITUDE_OPPOSITION.equals(obj.getAttitude())).findFirst(); + if(first.isPresent()){ + dailyStatisticalToUpdate.setOppositionCount(first.get().getVoteCountUpToYesterday()); + }else{ + dailyStatisticalToUpdate.setOppositionCount(NumConstant.ZERO); + } + }else{ + dailyStatisticalToUpdate.setOppositionCount(NumConstant.ZERO); + } - //3.如果没有生成过,取前一天的日统计信息与缓存中的表决数进行对比生成昨日数据(非昨日新生成议题) + }else if(null == dailyStatisticalToUpdate.getSupportCount()){ + //昨日无人赞同该议题 + dailyStatisticalToUpdate.setSupportIncrement(NumConstant.ZERO); + if(null != issueStatisticalMapUpToYes.get(key)){ + Optional first = + issueStatisticalMapUpToYes.get(key).stream().filter( + obj -> ModuleConstants.ISSUE_VOTING_ATTITUDE_SUPPORT.equals(obj.getAttitude())).findFirst(); + if(first.isPresent()){ + dailyStatisticalToUpdate.setSupportCount(first.get().getVoteCountUpToYesterday()); + }else{ + dailyStatisticalToUpdate.setSupportCount(NumConstant.ZERO); + } + }else{ + dailyStatisticalToUpdate.setSupportCount(NumConstant.ZERO); + } + + } + + //不会同时出现oppositionCount与supportCount同时为null的现象 + //因为这表示该议题从未被表决过,已经在上方逻辑进行处理 + dailyStatisticalToUpdate.setTotalCount(dailyStatisticalToUpdate.getOppositionCount() + dailyStatisticalToUpdate.getSupportCount()); + dailyStatisticalToUpdate.setTodayIncrement(dailyStatisticalToUpdate.getOppositionIncrement() + dailyStatisticalToUpdate.getSupportIncrement()); + + dailyListToUpdate.add(dailyStatisticalToUpdate); + }else{ + if(null == dailyStatisticalToInsert.getOppositionCount()){ + //昨日无人反对该议题 + dailyStatisticalToInsert.setOppositionIncrement(NumConstant.ZERO); + if(null != issueStatisticalMapUpToYes.get(key)){ + Optional first = + issueStatisticalMapUpToYes.get(key).stream().filter( + obj -> ModuleConstants.ISSUE_VOTING_ATTITUDE_OPPOSITION.equals(obj.getAttitude())).findFirst(); + if(first.isPresent()){ + dailyStatisticalToInsert.setOppositionCount(first.get().getVoteCountUpToYesterday()); + }else{ + dailyStatisticalToInsert.setOppositionCount(NumConstant.ZERO); + } + }else{ + dailyStatisticalToInsert.setOppositionCount(NumConstant.ZERO); + } + }else if(null == dailyStatisticalToInsert.getSupportCount()){ + //昨日无人赞同该议题 + dailyStatisticalToInsert.setSupportIncrement(NumConstant.ZERO); + if(null != issueStatisticalMapUpToYes.get(key)){ + Optional first = + issueStatisticalMapUpToYes.get(key).stream().filter( + obj -> ModuleConstants.ISSUE_VOTING_ATTITUDE_SUPPORT.equals(obj.getAttitude())).findFirst(); + if(first.isPresent()){ + dailyStatisticalToInsert.setSupportCount(first.get().getVoteCountUpToYesterday()); + }else{ + dailyStatisticalToInsert.setSupportCount(NumConstant.ZERO); + } + }else{ + dailyStatisticalToInsert.setSupportCount(NumConstant.ZERO); + } + } + //不会同时出现oppositionCount与supportCount同时为null的现象 + //因为这表示该议题从未被表决过,已经在上方逻辑进行处理 + + dailyStatisticalToInsert.setTotalCount(dailyStatisticalToInsert.getOppositionCount() + dailyStatisticalToInsert.getSupportCount()); + dailyStatisticalToInsert.setTodayIncrement(dailyStatisticalToInsert.getOppositionIncrement() + dailyStatisticalToInsert.getSupportIncrement()); + + dailyListToInsert.add(dailyStatisticalToInsert); + } + + }else{ + //当List为空时 + //不会出现List为空的现象 + logger.warn(String.format("遍历issueStatisticalMap时候出现List为空现象,issueId:【%s】",key)); + } + }); + if(dailyListToInsert.size() > NumConstant.ZERO){ + baseDao.insertBatch(dailyListToInsert); + } + if(dailyListToUpdate.size() > NumConstant.ZERO){ + baseDao.updateBatch(dailyListToUpdate); + } - //4.获取人员投票详情对昨日的count数(昨日新生成议题,保证数据的准确性) } } \ No newline at end of file diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/utils/ModuleConstants.java b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/utils/ModuleConstants.java index 8cf1e44e15..8a9e9f7fde 100644 --- a/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/utils/ModuleConstants.java +++ b/epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/utils/ModuleConstants.java @@ -69,4 +69,28 @@ public interface ModuleConstants { String EMPTY_STR = ""; + String FIELD_SQL_ISSUE_ID = "ISSUE_ID"; + + String FIELD_JAVA_ISSUE_ID = "issueId"; + + String FIELD_SQL_ATTITUDE = "ATTITUDE"; + + String FIELD_JAVA_ATTITUDE = "attitude"; + + String FIELD_SQL_STATISTICAL_DATE = "STATISTICAL_DATE"; + + String FIELD_JAVA_STATISTICAL_DATE = "statisticalDate"; + + /** + * 议题表决态度 赞成 + * */ + String ISSUE_VOTING_ATTITUDE_SUPPORT = "support"; + + /** + * 议题表决态度 反对 + * */ + String ISSUE_VOTING_ATTITUDE_OPPOSITION = "opposition"; + + String CREATED_OR_UPDATED_BY_SYSTEM = "system"; + } diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueDao.xml b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueDao.xml index 4546d8da07..d31d8bd7cf 100644 --- a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueDao.xml +++ b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueDao.xml @@ -270,25 +270,28 @@ totalvote.VOTE_COUNT AS VOTE_COUNT_UP_TO_YESTERDAY FROM ISSUE issue + LEFT JOIN ( SELECT ISSUE_ID , ATTITUDE, count(ATTITUDE) AS VOTE_COUNT FROM issue_vote_detail WHERE DEL_FLAG = '0' - AND TO_DAYS( NOW( ) ) - TO_DAYS( CREATED_TIME ) 1 - AND TO_DAYS( NOW( ) ) - TO_DAYS( CREATED_TIME ) ]]> 0 + AND TO_DAYS( NOW( ) ) - TO_DAYS( CREATED_TIME ) ]]> 0 GROUP BY ISSUE_ID , ATTITUDE - ) vote ON issue.ID = vote.ISSUE_ID + ) totalvote ON issue.ID = totalvote.ISSUE_ID + LEFT JOIN ( SELECT ISSUE_ID , ATTITUDE, count(ATTITUDE) AS VOTE_COUNT FROM issue_vote_detail WHERE DEL_FLAG = '0' - AND TO_DAYS( NOW( ) ) - TO_DAYS( CREATED_TIME ) ]]> 0 + AND TO_DAYS( NOW( ) ) - TO_DAYS( CREATED_TIME ) 1 + AND TO_DAYS( NOW( ) ) - TO_DAYS( CREATED_TIME ) ]]> 0 GROUP BY ISSUE_ID , ATTITUDE - ) totalvote ON issue.ID = totalvote.ISSUE_ID AND vote.ATTITUDE = totalvote.ATTITUDE + ) vote ON issue.ID = vote.ISSUE_ID AND totalvote.ATTITUDE = vote.ATTITUDE + WHERE issue.DEL_FLAG = '0' AND ( @@ -307,6 +310,7 @@ ORDER BY issue.ID + diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml index 6e6166601b..62e0ed265a 100644 --- a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml +++ b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteDetailDao.xml @@ -27,4 +27,12 @@ AND created_by = #{createdBy} + + \ No newline at end of file diff --git a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDailyDao.xml b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDailyDao.xml index 6eff9f400f..0c907f48be 100644 --- a/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDailyDao.xml +++ b/epmet-module/gov-issue/gov-issue-server/src/main/resources/mapper/IssueVoteStatisticalDailyDao.xml @@ -26,33 +26,36 @@ + + + + + + INSERT INTO issue_vote_statistical_daily + ( + id, + + issue_id, + + statistical_date, + + support_count, + + opposition_count, + + total_count, + + today_increment, + + support_increment, + + opposition_increment, + + votable_count, + + + + created_by, + + created_time, + + updated_by, + + updated_time + + ) values + + ( + (SELECT REPLACE(UUID(), '-', '') AS id), + + #{item.issueId}, + + #{item.statisticalDate}, + + #{item.supportCount}, + + #{item.oppositionCount}, + + #{item.totalCount}, + + #{item.todayIncrement}, + + #{item.supportIncrement}, + + #{item.oppositionIncrement}, + + #{item.votableCount}, + + + + #{item.createdBy}, + + now(), + + #{item.createdBy}, + + now() + ) + + + + + + UPDATE issue_vote_statistical_daily + + + + + + when id = #{item.id} then #{item.supportCount} + + + + + + + + when id = #{item.id} then #{item.oppositionCount} + + + + + + + + when id = #{item.id} then #{item.totalCount} + + + + + + + + when id = #{item.id} then #{item.todayIncrement} + + + + + + + + when id = #{item.id} then #{item.supportIncrement} + + + + + + + + when id = #{item.id} then #{item.oppositionIncrement} + + + + + + + + when id = #{item.id} then #{item.updatedBy} + + + + + + + + when id = #{item.id} then #{item.votableCount} + + + + + + + + when id = #{item.id} then #{item.delFlag} + + + + + + + + when id = #{item.id} then #{item.updatedBy} + + + + + + updated_time = now() + + WHERE id = #{id} + \ No newline at end of file diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java index d72cbeeb69..6f8ade6604 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java @@ -134,8 +134,8 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl wrapper = new QueryWrapper<>(); wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id); wrapper.eq(FieldConstant.DEL_FLAG,NumConstant.ZERO_STR); - wrapper.eq(TopicConstant.CUSTOMER_USER_ID,params.get(TopicConstant.CUSTOMER_USER_ID)); - wrapper.eq(TopicConstant.RESI_GROUP_ID,params.get(TopicConstant.RESI_GROUP_ID)); + wrapper.eq(StringUtils.isNotBlank((String)params.get(TopicConstant.CUSTOMER_USER_ID)),TopicConstant.CUSTOMER_USER_ID,params.get(TopicConstant.CUSTOMER_USER_ID)); + wrapper.eq(StringUtils.isNotBlank((String)params.get(TopicConstant.RESI_GROUP_ID)),TopicConstant.RESI_GROUP_ID,params.get(TopicConstant.RESI_GROUP_ID)); return wrapper; }