From 9f8f9d13c42ca8cdccbf351069082a5fdccef2e4 Mon Sep 17 00:00:00 2001
From: lin <sbla5888@163.com>
Date: Mon, 25 Mar 2024 17:30:51 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
src/main/java/org/springblade/modules/discuss/service/impl/UserTopicsServiceImpl.java | 47 +++++++++++++++++++++++++++++++++++------------
1 files changed, 35 insertions(+), 12 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 cde7f24..fcf8e67 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,31 +78,36 @@
@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()));
// 一户一票
if (one.getVoteRestrictions().equals(CommonConstant.NUMBER_ONE)) {
- long count = count(Wrappers.<UserTopicsEntity>lambdaQuery().eq(UserTopicsEntity::getHouseCode, topics.get(0).getHouseCode()));
- if (count > 1) {
- throw new Exception("您的房屋已投票，不能重复投票！");
+ long count = count(Wrappers.<UserTopicsEntity>lambdaQuery()
+ .eq(UserTopicsEntity::getHouseCode, topics.get(0).getHouseCode())
+ .eq(UserTopicsEntity::getArticleId, topics.get(0).getArticleId()));
+ if (count > 0) {
+ return "您的房屋已投票，不能重复投票！";
}
} else {
//
- long count = count(Wrappers.<UserTopicsEntity>lambdaQuery().eq(UserTopicsEntity::getUserId, AuthUtil.getUserId()));
- if (count > 1) {
- throw new Exception("您的已投票，不能重复投票！");
+ long count = count(Wrappers.<UserTopicsEntity>lambdaQuery()
+ .eq(UserTopicsEntity::getUserId, AuthUtil.getUserId())
+ .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
private Boolean getaBoolean(List<TopicsVO> topics) {
List<UserTopicsEntity> objects = new ArrayList<>();
+ Boolean result = false;
for (TopicsVO topic : topics) {
UserTopicsEntity userTopicsEntity = new UserTopicsEntity();
userTopicsEntity.setUserId(AuthUtil.getUserId());
@@ -126,7 +132,7 @@
objectUpdateWrapper.setSql("number = number + 1");
objectUpdateWrapper.eq("id", topic.getSelected());
topicsService.update(null, objectUpdateWrapper);
- return save(userTopics);
+ result = save(userTopics);
} else {
// 多选
if (StringUtils.isBlank(topic.getSelected())) {
@@ -149,10 +155,10 @@
objectUpdateWrapper.eq("id", o);
topicsService.update(null, objectUpdateWrapper);
}
- return saveBatch(objectsTwo);
+ result = saveBatch(objectsTwo);
}
}
- return null;
+ return result;
}
@@ -163,4 +169,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