领券

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

@@ -319,20 +319,24 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
 
     @Override
     public ResponseDto collectCoupon(String couponId, String drawId) {
-        // TODO: 2021/12/6 看看是否需要判断中奖状态再发
-        // TODO: 2021/12/6 领过了要改状态 下次判断状态 
+        IntegralActivityDrawVo drawVo = redisDataUtils.getIntegralActivityDrawInfo(drawId);
         Map tokenClaims = CurrentUtil.getTokenClaims();
         String mobile = StringUtils.defaultString((String.valueOf(tokenClaims.get(CurrentUtil.TOKEN_MOBILE))), "");
-        LocalDateTime nowTime = LocalDateTime.now();
-        LinkedList<String> sqls = CollectionUtil.linkedListString();
-        LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-        sqls.add(SqlMapping.get("stone_candy_mgt_coupon.add_for_member"));
-        sqlsDataA.add(new Object[]{
-                IDGenerator.nextTimeId2(), couponId,
-                1, mobile, nowTime, "INTEGRAL_DRAW", nowTime
-        });
-        queueUtils.sendMsgByRedis(MQConst.StoneQueue.STONE_ORDER_COUPON.getKey(),
-                SqlMapping.gets(sqls, sqlsDataA));
+        String uid = StringUtils.defaultString((String.valueOf(tokenClaims.get(CurrentUtil.TOKEN_SUB))), "");
+        if (null != drawVo && drawVo.getReceivingStatus() == 2 && drawVo.getUserId().equals(uid)) {
+            // 发放券
+            LocalDateTime nowTime = LocalDateTime.now();
+            LinkedList<String> sqls = CollectionUtil.linkedListString();
+            LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
+            sqls.add(SqlMapping.get("stone_candy_mgt_coupon.add_for_member"));
+            sqlsDataA.add(new Object[]{
+                    IDGenerator.nextTimeId2(), couponId,
+                    1, mobile, nowTime, "INTEGRAL_DRAW", nowTime
+            });
+            queueUtils.sendMsgByRedis(MQConst.StoneQueue.STONE_ORDER_COUPON.getKey(),
+                    SqlMapping.gets(sqls, sqlsDataA));
+            // TODO: 2021/12/7 更改发放状态redis info list mongo 数据库写入券id 
+        }
         return ResponseDto.success();
     }