领券更新缓存

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

@@ -328,18 +328,22 @@ public class SweetIntegralActivityDrawServiceImpl extends ServiceImpl<SweetInteg
             LocalDateTime nowTime = LocalDateTime.now();
             LinkedList<String> sqls = CollectionUtil.linkedListString();
             LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
-            LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
             sqls.add(SqlMapping.get("sweet_integral_activity_draw.get_coupon"));
-            sqls.add(SqlMapping.get("sweet_integral_activity_draw.updateStatus"));
             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));
+            // 更改发放状态
+            LinkedList<String> sqlsB = CollectionUtil.linkedListString();
+            LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
+            sqlsB.add(SqlMapping.get("sweet_integral_activity_draw.updateStatus"));
             sqlsDataB.add(new Object[]{
                     2, nowTime, drawId
             });
-            queueUtils.sendMsgByRedis(MQConst.StoneQueue.STONE_ORDER_COUPON.getKey(),
-                    SqlMapping.gets(sqls, sqlsDataA, sqlsDataB));
+            queueUtils.sendMsgByRedis(MQConst.SweetQueue.SWEET_INTEGRAL_ACTIVITY_DRAW.getKey(),
+                    SqlMapping.gets(sqlsB, sqlsDataB));
             // 更新缓存
             redisDataUtils.delIntegralActivityDrawList(drawVo.getIntegralActivityId(), uid);