sweet_city_vote_stat

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/constant/MQConst.java

@@ -81,7 +81,7 @@ public class MQConst {
         SWEET_USER_INSERT_DRAW("sweet:stream:rk.sweetUserInsert", "group.sweetUserInsert", "关注服务号的用户信息"),
         SWEET_REMIND_INSERT_DRAW("sweet:stream:rk.remindInsert", "group.remindInsert", "提醒记录"),
         SWEET_APPLET_USER_INSERT_DRAW("sweet:stream:rk.sweetAppletUserInsert", "group.sweetAppletUserInsert", "小程序登录记录用户解密后信息"),
-        SWEET_CITY_VOTE_INSERT_DRAW("sweet:stream:rk.cityVoteInsert", "group.cityVoteInsert", "用户投票记录"),
+        SWEET_CITY_VOTE_DRAW("sweet:stream:rk.cityVote", "group.cityVote", "用户投票记录"),
         ;
 
         private final String key;

liquidnet-bus-service/liquidnet-service-sweet/docu/redis_queue_create.txt

@@ -23,4 +23,8 @@ XGROUP CREATE sweet:stream:rk.remindInsert group.remindInsert 0
 
 --     小程序登录记录用户解密后信息     --
 XADD sweet:stream:rk.sweetAppletUserInsert * 0 0
-XGROUP CREATE sweet:stream:rk.sweetAppletUserInsert group.sweetAppletUserInsert 0
+XGROUP CREATE sweet:stream:rk.sweetAppletUserInsert group.sweetAppletUserInsert 0
\ No newline at end of file
+
+--     用户投票记录     --
+XADD sweet:stream:rk.cityVote * 0 0
+XGROUP CREATE sweet:stream:rk.cityVote group.cityVote 0
\ No newline at end of file

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

@@ -16,6 +16,7 @@ import com.liquidnet.service.sweet.vo.SweetCItyVoteStatVo;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
 import java.util.LinkedList;
 import java.util.List;
 
@@ -53,19 +54,26 @@ public class SweetCityVoteServiceImpl extends ServiceImpl<SweetCityVoteMapper, S
 
         LinkedList<String> sqls = CollectionUtil.linkedListString();
         LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+        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()
         });
-        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_CITY_VOTE_INSERT_DRAW.getKey(),
-                SqlMapping.gets(sqls, sqlsDataA));
-
         Integer cityVoteNum = redisDataUtils.getSweetCityVote(aNew.getCityCode());
         if (cityVoteNum > 0) { // 已有 incr
-
-        } else {// insert
-
+            sqls.add(SqlMapping.get("sweet_city_vote_stat.update"));
+            sqlsDataB.add(new Object[]{
+                    LocalDateTime.now(), aNew.getCityCode()
+            });
+        } else { // insert
+            sqls.add(SqlMapping.get("sweet_city_vote_stat.insert"));
+            sqlsDataB.add(new Object[]{
+                    IDGenerator.nextSnowId(), aNew.getCityCode(), aNew.getCityName(), 1
+            });
         }
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_CITY_VOTE_DRAW.getKey(),
+                SqlMapping.gets(sqls, sqlsDataA, sqlsDataB));
+
         redisDataUtils.incrSweetCityVote(aNew.getCityCode());
 
         return ResponseDto.success();

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

@@ -70,4 +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) VALUES (?,?,?,?,?)
\ No newline at end of file
+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