From ad2ec97fe0c60eee4bb7c8cdacff7c876f280ea7 Mon Sep 17 00:00:00 2001
From: linwei <872216696@qq.com>
Date: Mon, 08 Jan 2024 11:30:18 +0800
Subject: [PATCH] 公安安全监管

---
 src/main/java/org/springblade/modules/discuss/controller/UserTopicsController.java |   58 +++++++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 49 insertions(+), 9 deletions(-)

diff --git a/src/main/java/org/springblade/modules/discuss/controller/UserTopicsController.java b/src/main/java/org/springblade/modules/discuss/controller/UserTopicsController.java
index 11162c2..9cc4d3a 100644
--- a/src/main/java/org/springblade/modules/discuss/controller/UserTopicsController.java
+++ b/src/main/java/org/springblade/modules/discuss/controller/UserTopicsController.java
@@ -16,25 +16,32 @@
  */
 package org.springblade.modules.discuss.controller;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
-import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import lombok.AllArgsConstructor;
-import javax.validation.Valid;
-
-import org.springblade.core.secure.BladeUser;
+import org.springblade.common.constant.CommonConstant;
+import org.springblade.core.boot.ctrl.BladeController;
 import org.springblade.core.mp.support.Condition;
 import org.springblade.core.mp.support.Query;
+import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.Func;
-import org.springframework.web.bind.annotation.*;
-import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.springblade.core.tool.utils.SpringUtil;
+import org.springblade.modules.discuss.entity.PublicDiscussEntity;
 import org.springblade.modules.discuss.entity.UserTopicsEntity;
+import org.springblade.modules.discuss.service.IPublicDiscussService;
+import org.springblade.modules.discuss.service.IUserTopicsService;
+import org.springblade.modules.discuss.vo.TopicsVO;
 import org.springblade.modules.discuss.vo.UserTopicsVO;
 import org.springblade.modules.discuss.wrapper.UserTopicsWrapper;
-import org.springblade.modules.discuss.service.IUserTopicsService;
-import org.springblade.core.boot.ctrl.BladeController;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+import java.util.List;
 
 /**
  * 用户议题报表 控制器
@@ -109,7 +116,29 @@
 	@ApiOperationSupport(order = 6)
 	@ApiOperation(value = "新增或修改", notes = "传入userTopics")
 	public R submit(@Valid @RequestBody UserTopicsEntity userTopics) {
-		return R.status(userTopicsService.saveOrUpdate(userTopics));
+		userTopics.setUserId(AuthUtil.getUserId());
+		// 判断是否一户一票 还是一人一票
+		IPublicDiscussService bean = SpringUtil.getBean(IPublicDiscussService.class);
+		PublicDiscussEntity one = bean.getOne(Wrappers.<PublicDiscussEntity>lambdaQuery().eq(PublicDiscussEntity::getId, userTopics.getPublicDiscussId()));
+		// 一户一票
+		if (one.getVoteRestrictions().equals(CommonConstant.NUMBER_ONE)) {
+			long count = userTopicsService.count(Wrappers.<UserTopicsEntity>lambdaQuery()
+				.eq(UserTopicsEntity::getPublicDiscussId, userTopics.getPublicDiscussId())
+				.eq(UserTopicsEntity::getUserId, userTopics.getUserId())
+				.eq(UserTopicsEntity::getHouseCode, userTopics.getHouseCode()));
+			if (count > 0) {
+				return R.fail("您房屋已经投票,不能重复投票!");
+			}
+			// 一人一票
+		} else {
+			long count = userTopicsService.count(Wrappers.<UserTopicsEntity>lambdaQuery()
+				.eq(UserTopicsEntity::getPublicDiscussId, userTopics.getPublicDiscussId())
+				.eq(UserTopicsEntity::getUserId, userTopics.getUserId()));
+			if (count > 0) {
+				return R.fail("您已投票,不能重复投票!");
+			}
+		}
+		return R.status(userTopicsService.save(userTopics));
 	}
 
 	/**
@@ -122,5 +151,16 @@
 		return R.status(userTopicsService.removeByIds(Func.toLongList(ids)));
 	}
 
+	/**
+	 * 议题表 修改
+	 */
+	@PostMapping("/updateBath")
+	@ApiOperationSupport(order = 5)
+	@ApiOperation(value = "批量更新", notes = "传入topics")
+	public R updateBath(@Valid @RequestBody List<TopicsVO> topics) throws Exception {
+		Boolean result = userTopicsService.batchSave(topics);
+		return R.status(result);
+	}
+
 
 }

--
Gitblit v1.9.3