From c02703a1aef70d2bb830c63652df72c98403db39 Mon Sep 17 00:00:00 2001
From: lin <sbla5888@163.com>
Date: Mon, 25 Mar 2024 10:58:19 +0800
Subject: [PATCH] 小区用户支持栋，单元+名字查询
---
src/main/java/org/springblade/modules/discuss/service/impl/UserTopicsServiceImpl.java | 38 ++++++++++++++++++++++++++++----------
1 files changed, 28 insertions(+), 10 deletions(-)
diff --git a/src/main/java/org/springblade/modules/discuss/service/impl/UserTopicsServiceImpl.java b/src/main/java/org/springblade/modules/discuss/service/impl/UserTopicsServiceImpl.java
index 3517b07..8bbcb15 100644
--- a/src/main/java/org/springblade/modules/discuss/service/impl/UserTopicsServiceImpl.java
+++ b/src/main/java/org/springblade/modules/discuss/service/impl/UserTopicsServiceImpl.java
@@ -31,6 +31,7 @@
import org.springblade.modules.discuss.entity.PublicDiscussEntity;
import org.springblade.modules.discuss.entity.TopicsEntity;
import org.springblade.modules.discuss.entity.UserTopicsEntity;
+import org.springblade.modules.discuss.excel.UserTopicsExcel;
import org.springblade.modules.discuss.mapper.UserTopicsMapper;
import org.springblade.modules.discuss.service.IPublicDiscussService;
import org.springblade.modules.discuss.service.ITopicsService;
@@ -77,7 +78,7 @@
@Override
@Transactional(rollbackFor = Exception.class)
- public Boolean batchSave(List<TopicsVO> topics) throws Exception {
+ public String batchSave(List<TopicsVO> topics) throws Exception {
// 判断是否一户一票 还是一人一票
IPublicDiscussService bean = SpringUtil.getBean(IPublicDiscussService.class);
PublicDiscussEntity one = bean.getOne(Wrappers.<PublicDiscussEntity>lambdaQuery().eq(PublicDiscussEntity::getArticleId, topics.get(0).getArticleId()));
@@ -85,22 +86,22 @@
if (one.getVoteRestrictions().equals(CommonConstant.NUMBER_ONE)) {
long count = count(Wrappers.<UserTopicsEntity>lambdaQuery()
.eq(UserTopicsEntity::getHouseCode, topics.get(0).getHouseCode())
- .eq(UserTopicsEntity::getArticleId,topics.get(0).getArticleId()));
- if (count > 1) {
- throw new Exception("您的房屋已投票，不能重复投票！");
+ .eq(UserTopicsEntity::getArticleId, topics.get(0).getArticleId()));
+ if (count > 0) {
+ return "您的房屋已投票，不能重复投票！";
}
} else {
//
long count = count(Wrappers.<UserTopicsEntity>lambdaQuery()
.eq(UserTopicsEntity::getUserId, AuthUtil.getUserId())
- .eq(UserTopicsEntity::getArticleId,topics.get(0).getArticleId()));
- if (count > 1) {
- throw new Exception("您的已投票，不能重复投票！");
+ .eq(UserTopicsEntity::getArticleId, topics.get(0).getArticleId()));
+ if (count > 0) {
+ return "您已投票，不能重复投票！";
}
}
Boolean userTopics = getaBoolean(topics);
- if (userTopics != null) return userTopics;
- return false;
+ if (userTopics) return "200";
+ return "操作失败！";
}
@Nullable
@@ -156,7 +157,7 @@
return saveBatch(objectsTwo);
}
}
- return null;
+ return false;
}
@@ -167,4 +168,21 @@
.groupBy(UserTopicsEntity::getUserId));
return list.size();
}
+
+ @Override
+ public List<UserTopicsExcel> exportUser(UserTopicsVO userTopics) {
+ if (StringUtils.isNotBlank(userTopics.getDistrictId())) {
+ List<String> longs = JSON.parseArray(userTopics.getDistrictId()).toJavaList(String.class);
+ IDistrictService bean = SpringUtils.getBean(IDistrictService.class);
+ List<DistrictEntity> list = bean.list(Wrappers.<DistrictEntity>lambdaQuery().in(DistrictEntity::getId, longs));
+ List<String> collect = list.stream().map(item ->
+ item.getAoiCode()
+ ).collect(Collectors.toList());
+ if (collect != null) {
+ userTopics.setAoiCodeList(collect);
+ }
+ }
+ List<UserTopicsExcel> userTopicsExcels = baseMapper.exportUser(userTopics);
+ return userTopicsExcels;
+ }
}
--
Gitblit v1.9.3