draw mysql

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

@@ -85,6 +85,7 @@ public class MQConst {
         SWEET_TEMPLATE_MSG("sweet:stream:rk.sweetTemplateMsg", "group.sweetTemplateMsg", "发送模版消息"),
         SWEET_CITY_VOTE_DRAW("sweet:stream:rk.cityVote", "group.cityVote", "用户投票记录"),
         SWEET_ANTIGENIC_QUESTION_DRAW("sweet:stream:rk.antigenicQuestion", "group.antigenicQuestion", "防疫答题"),
+        SWEET_INTEGRAL_ACTIVITY_DRAW("sweet:stream:rk.integralActivityDraw", "group.integralActivityDraw", "积分抽奖"),
         ;
 
         private final String key;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetIntegralActivityDrawRedisStreamConfig.java

+package com.liquidnet.service.consumer.sweet.config;
+
+import com.liquidnet.service.consumer.sweet.receiver.ConsumerIntegralActivityDrawRdsReceiver;
+import lombok.var;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.time.Duration;
+
+import static com.liquidnet.service.base.constant.MQConst.SweetQueue.SWEET_INTEGRAL_ACTIVITY_DRAW;
+
+@Configuration
+public class ConsumerSweetIntegralActivityDrawRedisStreamConfig {
+    @Autowired
+    ConsumerIntegralActivityDrawRdsReceiver consumerIntegralActivityDrawRdsReceiver;
+
+    private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
+        var options = StreamMessageListenerContainer
+                .StreamMessageListenerContainerOptions
+                .builder()
+                .pollTimeout(Duration.ofMillis(1))
+                .build();
+        return StreamMessageListenerContainer.create(factory, options);
+    }
+
+    /**
+     * 缺票登记
+     *
+     * @param listenerContainer
+     * @param t
+     * @return
+     */
+    private Subscription receiveSqlIntegralActivityDraw(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+        return listenerContainer.receiveAutoAck(
+                Consumer.from(SWEET_INTEGRAL_ACTIVITY_DRAW.getGroup(), SWEET_INTEGRAL_ACTIVITY_DRAW.name() + t),
+                StreamOffset.create(SWEET_INTEGRAL_ACTIVITY_DRAW.getKey(), ReadOffset.lastConsumed()), consumerIntegralActivityDrawRdsReceiver
+        );
+    }
+
+    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+
+    /* -------------------------------------------------------- ｜ 缺票登记 */
+
+    @Bean
+    public Subscription subscriptionSqlIntegralActivityDraw(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlIntegralActivityDraw(listenerContainer, 1);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionSqlIntegralActivityDraw2(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlIntegralActivityDraw(listenerContainer, 1);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    @Bean
+    public Subscription subscriptionSqlIntegralActivityDraw3(RedisConnectionFactory factory) {
+        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+        var subscription = receiveSqlIntegralActivityDraw(listenerContainer, 1);
+        listenerContainer.start();
+        return subscription;
+    }
+
+    /* -------------------------------------------------------- ｜  */
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/receiver/ConsumerIntegralActivityDrawRdsReceiver.java

+package com.liquidnet.service.consumer.sweet.receiver;
+
+import com.liquidnet.service.base.constant.MQConst;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerIntegralActivityDrawRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.SweetQueue.SWEET_INTEGRAL_ACTIVITY_DRAW.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.SweetQueue.SWEET_INTEGRAL_ACTIVITY_DRAW.getGroup();
+    }
+}

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

@@ -36,3 +36,7 @@ XGROUP CREATE sweet:stream:rk.cityVote group.cityVote 0
 --     防疫答题     --
 XADD sweet:stream:rk.antigenicQuestion * 0 0
 XGROUP CREATE sweet:stream:rk.antigenicQuestion group.antigenicQuestion 0
+
+--     积分抽奖     --
+XADD sweet:stream:rk.integralActivityDraw * 0 0
+XGROUP CREATE sweet:stream:rk.integralActivityDraw group.integralActivityDraw 0
\ No newline at end of file

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

 package com.liquidnet.service.sweet.service.impl;
 
-import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.CurrentUtil;
@@ -8,6 +7,8 @@ import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.base.PagedResult;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.sweet.dto.vo.IntegralActivityDrawVo;
 import com.liquidnet.service.sweet.dto.vo.IntegralActivityVo;
 import com.liquidnet.service.sweet.dto.vo.admin.SweetIntegralActivityPrizeVo;
@@ -15,6 +16,7 @@ import com.liquidnet.service.sweet.entity.SweetIntegralActivityDraw;
 import com.liquidnet.service.sweet.entity.SweetIntegralActivityPrize;
 import com.liquidnet.service.sweet.mapper.SweetIntegralActivityDrawMapper;
 import com.liquidnet.service.sweet.service.ISweetIntegralActivityDrawService;
+import com.liquidnet.service.sweet.utils.QueueUtils;
 import com.liquidnet.service.sweet.utils.RedisDataUtils;
 import com.liquidnet.service.sweet.utils.SweetNewObjectUtil;
 import org.apache.commons.lang.StringUtils;
@@ -50,6 +52,9 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
     @Autowired
     private MongoTemplate mongoTemplate;
 
+    @Autowired
+    private QueueUtils queueUtils;
+
     @Override
     public ResponseDto<SweetIntegralActivityPrizeVo> create(String integralActivityId) {
         // TODO: 2021/10/26 看情况是否加锁  一个用户整个逻辑单进程
@@ -98,8 +103,9 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
         if (activityPrizeNum < 0 || activityPrizeWinnersNum < 0) {// 库存不够了
             return ResponseDto.failure("活动太火爆了，请稍后再试");
         }
+        String drawId = IDGenerator.nextSnowId();
         IntegralActivityDrawVo integralActivityDrawVo = IntegralActivityDrawVo.getNew();
-        integralActivityDrawVo.setDrawId(IDGenerator.nextSnowId());
+        integralActivityDrawVo.setDrawId(drawId);
         integralActivityDrawVo.setIntegralActivityId(integralActivityId);
         integralActivityDrawVo.setActivityNum(integralActivity.getActivityNum());
         integralActivityDrawVo.setPrizeId(sweetIntegralActivityPrize.getPrizeId());
@@ -116,7 +122,18 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
         // mongo
         mongoTemplate.insert(integralActivityDrawVo, IntegralActivityDrawVo.class.getSimpleName());
 
-        // TODO: 2021/10/28 mysql 抽奖记录  库存？
+        // mysql 抽奖记录
+        LinkedList<String> sqls = CollectionUtil.linkedListString();
+        LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+        sqls.add(SqlMapping.get("integral_activity_draw.insert"));
+        sqlsDataA.add(new Object[]{
+                drawId, integralActivityId, integralActivity.getActivityNum(),
+                sweetIntegralActivityPrize.getPrizeId(), sweetIntegralActivityPrize.getPrizeTitle(), sweetIntegralActivityPrize.getPrizeType(),
+                sweetIntegralActivityPrize.getPrizeTypeNum(), sweetIntegralActivityPrize.getRelationId(),
+                userId, nickname
+        });
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_INTEGRAL_ACTIVITY_DRAW.getKey(),
+                SqlMapping.gets(sqls, sqlsDataA));
 
         return ResponseDto.success(sweetIntegralActivityPrizeVo);
     }
@@ -159,8 +176,6 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
 
     @Override
     public ResponseDto perfectAddress(String drawId, String receivingAddressesId, String receivingName, String receivingPhone, String receivingAddress) {
-        // todo mysql
-
         // 更新缓存
         IntegralActivityDrawVo drawVo = redisDataUtils.getIntegralActivityDrawInfo(drawId);
         drawVo.setReceivingAddressesId(receivingAddressesId);
@@ -173,14 +188,23 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
 
         mongoTemplate.getCollection(IntegralActivityDrawVo.class.getSimpleName()).updateOne(
                 Query.query(Criteria.where("drawId").is(drawId)).getQueryObject(),
-                new Document("$set", new Document("receivingStatus", 2)
-                        .append("receivingAddressesId", receivingAddressesId)
+                new Document("$set", new Document("receivingAddressesId", receivingAddressesId)
                         .append("receivingName", receivingName)
                         .append("receivingPhone", receivingPhone)
                         .append("receivingAddress", receivingAddress)
                         .append("updatedAt", DateUtil.Formatter.yyyyMMddHHmmss.format(nowTime)))
         );
 
+        // mysql
+        LinkedList<String> sqls = CollectionUtil.linkedListString();
+        LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+        sqls.add(SqlMapping.get("integral_activity_draw.update"));
+        sqlsDataA.add(new Object[]{
+                receivingAddressesId, receivingName, receivingPhone, receivingAddress, nowTime, drawId
+        });
+        queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_INTEGRAL_ACTIVITY_DRAW.getKey(),
+                SqlMapping.gets(sqls, sqlsDataA));
+
         return ResponseDto.success();
     }
 

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

@@ -48,3 +48,6 @@ sweet_city_vote_stat.insert=INSERT INTO sweet_city_vote_stat (stat_id,city_code,
 sweet_city_vote_stat.update=UPDATE sweet_city_vote_stat SET vote_num = IFNULL(vote_num, 0) + 1, updated_at = ?  WHERE city_code = ? AND type = ?
 # --------------------------防疫答题--------------------------
 sweet_antigenic_question.insert=INSERT INTO sweet_antigenic_question (question_id,type,openId,unionId,nickname,address,phone,urgent_phone,keyword1,keyword11,keyword2,keyword3,keyword4,keyword5,keyword6,keyword7) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
+# ------------------------积分抽奖----------------------------
+integral_activity_draw.insert=INSERT INTO sweet_integral_activity_draw (draw_id,integral_activity_id,activity_num,prize_id,prize_title,prize_type,prize_type_num,relation_id,user_id,nickname) VALUES (?,?,?,?,?,?,?,?,?,?)
+integral_activity_draw.update=UPDATE sweet_integral_activity_draw SET receiving_addresses_id = ?, receiving_name = ?, receiving_phone = ?, receiving_address = ?, updated_at = ? WHERE draw_id = ?
\ No newline at end of file