redis 队列 消费

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

@@ -101,4 +101,33 @@ public class MQConst {
             return desc;
         }
     }
+
+    public enum CandyQueue {
+        COUPON_USE("candy:stream:rk.coupon.use", "group.coupon.use", "券-使用"),
+        COUPON_BACK("candy:stream:rk.coupon.back", "group.coupon.back", "券-回退"),
+        COUPON_RECEIVE("candy:stream:rk.coupon.receive", "group.coupon.receive", "券-领取"),
+        ;
+
+        private final String key;
+        private final String group;
+        private final String desc;
+
+        CandyQueue(String key, String group, String desc) {
+            this.key = key;
+            this.group = group;
+            this.desc = desc;
+        }
+
+        public String getKey() {
+            return key;
+        }
+
+        public String getGroup() {
+            return group;
+        }
+
+        public String getDesc() {
+            return desc;
+        }
+    }
 }

liquidnet-bus-service/liquidnet-service-candy/liquidnet-service-candy-impl/src/main/java/com/liquidnet/service/candy/service/impl/CandyCouponServiceImpl.java

@@ -187,7 +187,7 @@ public class CandyCouponServiceImpl extends ServiceImpl<CandyCouponMapper, Candy
     public CandyUseResultVo useCoupon(String uCouponId, String content) {
         String uid = CurrentUtil.getCurrentUid();
         CandyUseResultVo vo = CandyUseResultVo.getNew();
-        List<CandyUserCouponBasicDto> dtoList = CouponBaseUtil.useCoupon(redisDataUtils.getCouponByUid(uid), uCouponId,content);
+        List<CandyUserCouponBasicDto> dtoList = CouponBaseUtil.useCoupon(redisDataUtils.getCouponByUid(uid), uCouponId, content);
         if (dtoList == null) {
             return null;
         } else {
@@ -213,8 +213,9 @@ public class CandyCouponServiceImpl extends ServiceImpl<CandyCouponMapper, Candy
             redisDataUtils.setCouponByUid(uid, dtoList);
             //入库
             queueUtils.sendMsgByRedis(
-                    MQConst.AdamQueue.SQL_UCENTER.getKey(),
-                    SqlMapping.get("candy_coupon.use", 1
+                    MQConst.CandyQueue.COUPON_USE.getKey(),
+                    SqlMapping.get("candy_coupon.use",
+                            uid,uCouponId
                     )
             );
         }
@@ -231,8 +232,9 @@ public class CandyCouponServiceImpl extends ServiceImpl<CandyCouponMapper, Candy
             redisDataUtils.setCouponByUid(uid, dtoList);
             //入库
             queueUtils.sendMsgByRedis(
-                    MQConst.AdamQueue.SQL_UCENTER.getKey(),
-                    SqlMapping.get("candy_coupon.back", 1
+                    MQConst.CandyQueue.COUPON_BACK.getKey(),
+                    SqlMapping.get("candy_coupon.back",
+                            uid,uCouponId
                     )
             );
         }
@@ -254,8 +256,9 @@ public class CandyCouponServiceImpl extends ServiceImpl<CandyCouponMapper, Candy
             redisDataUtils.addCouponByUid(uid, baseDto);
             //入库
             queueUtils.sendMsgByRedis(
-                    MQConst.AdamQueue.SQL_UCENTER.getKey(),
-                    SqlMapping.get("candy_coupon.receive", 1
+                    MQConst.CandyQueue.COUPON_RECEIVE.getKey(),
+                    SqlMapping.get("candy_coupon.receive",
+                            uCouponId, uid, 1, infoDto.getCouponId(), ccode, LocalDateTime.now()
                     )
             );
         } else {

liquidnet-bus-service/liquidnet-service-candy/liquidnet-service-candy-impl/src/main/resources/sqlmap.properties

 #  --  使用券  --
-candy_coupon.use=INSERT INTO sweet_remind (remind_id,openId,unionId,performancesId) VALUES (?,?,?,?)
-
+candy_coupon.use=UPDATE candy_user_coupon SET state = 3 WHERE uid = ? AND ucoupon_id = ?
 #  --  回退券  --
-candy_coupon.back=INSERT INTO sweet_remind (remind_id,openId,unionId,performancesId) VALUES (?,?,?,?)
-
+candy_coupon.back=UPDATE candy_user_coupon SET state = 1 WHERE uid = ? AND ucoupon_id = ?
 #  --  领取券  --
-candy_coupon.receive=INSERT INTO sweet_remind (remind_id,openId,unionId,performancesId) VALUES (?,?,?,?)
\ No newline at end of file
+candy_coupon.receive=INSERT INTO candy_user_coupon (ucoupon_id , uid , state , coupon_id , ccdoe , bind_at ) VALUE ( ? , ? , ? , ? , ? , ? )