增加个日期备用 增加是否投过票判断

liquidnet-bus-service/liquidnet-service-sweet/docu/db_sweetsugar_structure.sql

@@ -490,6 +490,7 @@ CREATE TABLE `sweet_city_vote`
     `unionId`    varchar(255)    NOT NULL DEFAULT '' COMMENT 'unionId',
     `city_code`  varchar(255)    NOT NULL DEFAULT '' COMMENT '城市代码',
     `city_name`  varchar(255)    NOT NULL DEFAULT '' COMMENT '城市名称',
+    `day_time`   varchar(255)    NOT NULL DEFAULT '' COMMENT '投票天',
     `created_at` datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
     `updated_at` datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
     PRIMARY KEY (`mid`),

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/constant/SweetConstant.java

@@ -26,6 +26,7 @@ public class SweetConstant {
     public final static String REDIS_KEY_SWEET_ANSWER_PHONE="sweet:answer:phone:";
     public final static String REDIS_KEY_SWEET_CITY_VOTE_STAT_LIST="sweet:cityVote:StatList";
     public final static String REDIS_KEY_SWEET_CITY_VOTE_CITY_CODE="sweet:cityVote:cityCode:";
+    public final static String REDIS_KEY_SWEET_CITY_VOTE_USER="sweet:cityVote:user:";
 
 //    public enum ManualPosition {
 //        artist("艺人","artist"),

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/SweetCityVoteController.java

@@ -37,7 +37,7 @@ public class SweetCityVoteController {
 
     @PostMapping("createVote")
     @ApiOperation("用户投票记录")
-    public ResponseDto<Boolean> createVote(@Valid @RequestBody SweetCityVoteParam param) {
+    public ResponseDto createVote(@Valid @RequestBody SweetCityVoteParam param) {
         return sweetCityVoteService.createVote(param);
     }
 

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/entity/SweetCityVote.java

@@ -51,6 +51,11 @@ public class SweetCityVote implements Serializable {
      */
     private String cityName;
 
+    /**
+     * 投票天
+     */
+    private String dayTime;
+
     /**
      * 创建时间
      */

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/ISweetCityVoteService.java

@@ -20,6 +20,6 @@ public interface ISweetCityVoteService extends IService<SweetCityVote> {
 
     ResponseDto<List<SweetCItyVoteStatVo>> getList();
 
-    ResponseDto<Boolean> createVote(SweetCityVoteParam param);
+    ResponseDto createVote(SweetCityVoteParam param);
 
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/SweetCityVoteServiceImpl.java

@@ -2,6 +2,7 @@ package com.liquidnet.service.sweet.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.commons.lang.util.CollectionUtil;
+import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
@@ -43,7 +44,11 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
     }
 
     @Override
-    public ResponseDto<Boolean> createVote(SweetCityVoteParam param) {
+    public ResponseDto createVote(SweetCityVoteParam param) {
+        Boolean userVote = redisDataUtils.getUserVote(param.getPhone(), param.getUnionId());
+        if (userVote) {
+            return ResponseDto.failure("已经投过票啦～");
+        }
         SweetCityVote aNew = SweetCityVote.getNew();
         aNew.setVoteId(IDGenerator.nextSnowId());
         aNew.setPhone(param.getPhone());
@@ -57,7 +62,7 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
         LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
         sqls.add(SqlMapping.get("sweet_city_vote.insert"));
         sqlsDataA.add(new Object[]{
-                aNew.getVoteId(), aNew.getPhone(), aNew.getUnionId(), aNew.getCityCode(), aNew.getCityName()
+                aNew.getVoteId(), aNew.getPhone(), aNew.getUnionId(), aNew.getCityCode(), aNew.getCityName(), DateUtil.format(LocalDateTime.now(), DateUtil.Formatter.yyyyMMdd)
         });
         Integer cityVoteNum = redisDataUtils.getSweetCityVote(aNew.getCityCode());
         if (cityVoteNum > 0) { // 已有 incr
@@ -76,6 +81,8 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
 
         redisDataUtils.incrSweetCityVote(aNew.getCityCode());
 
+        redisDataUtils.setUserVote(param.getPhone(), param.getUnionId());
+
         return ResponseDto.success();
     }
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/utils/RedisDataUtils.java

@@ -500,4 +500,17 @@ public class RedisDataUtils {
             return (Integer) obj;
         }
     }
+    public void setUserVote(String phone, String unionId) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_USER.concat(phone).concat("-").concat(unionId);
+        redisUtil.set(redisKey, 1);
+    }
+    public Boolean getUserVote(String phone, String unionId) {
+        String redisKey = SweetConstant.REDIS_KEY_SWEET_CITY_VOTE_USER.concat(phone).concat("-").concat(unionId);
+        Object obj = redisUtil.get(redisKey);
+        if (null == obj) {
+            return false;
+        } else {
+            return true;
+        }
+    }
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/resources/sqlmap.properties

@@ -70,6 +70,6 @@ sweet_remind.insert=INSERT INTO sweet_remind (remind_id,openId,unionId,performan
 # --------------------------小程序登录记录用户解密后信息--------------------------
 sweet_applet_user.insert=INSERT INTO sweet_applet_user (user_id,openId,unionId,getPhoneNumber,getPurePhoneNumber,getCountryCode,type) VALUES (?,?,?,?,?,?,?)
 # --------------------------用户投票记录--------------------------
-sweet_city_vote.insert=INSERT INTO sweet_city_vote (vote_id,phone,unionId,city_code,city_name) VALUES (?,?,?,?,?)
+sweet_city_vote.insert=INSERT INTO sweet_city_vote (vote_id,phone,unionId,city_code,city_name,day_time) VALUES (?,?,?,?,?,?)
 sweet_city_vote_stat.insert=INSERT INTO sweet_city_vote_stat (stat_id,city_code,city_name,vote_num) VALUES (?,?,?,?)
 sweet_city_vote_stat.update=UPDATE sweet_city_vote_stat SET vote_num = IFNULL(vote_num, 0) + 1, updated_at = ?  WHERE city_code = ?
\ No newline at end of file