增减积分用队列

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGoblinBizIntegralReceiver.java

@@ -22,12 +22,12 @@ public class ConsumerGoblinBizIntegralReceiver extends AbstractBizRedisReceiver
 
     @Override
     protected String getRedisStreamKey() {
-        return MQConst.GoblinQueue.BIZ_ARTWORK_UPL.getKey();
+        return MQConst.GoblinQueue.BIZ_INTEGRAL.getKey();
     }
 
     @Override
     protected String getRedisStreamGroup() {
-        return MQConst.GoblinQueue.BIZ_ARTWORK_UPL.getGroup();
+        return MQConst.GoblinQueue.BIZ_INTEGRAL.getGroup();
     }
 
     @Override

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/GoblinNftOrderServiceImpl.java

@@ -673,7 +673,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
                 // 增加销量
                 goblinRedisUtils.incrSkuSaleCount(orderVo.getSpuId(), orderVo.getSkuId(), orderVo.getNum());
                 // 加积分
-                goblinOrderUtils.integral(uid, orderVo.getPriceActual(), "藏品购买", 1);
+                goblinOrderUtils.integral(uid, orderVo.getPriceActual(), "购买数字藏品", 1);
             }
             // 写入用户订单列表 因取消的订单不展示 所以放在这里
             nftOrderUtils.addNftOrderList(uid, orderVo.getOrderId());
@@ -739,7 +739,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
             queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_NFT_ORDER.getKey(),
                     SqlMapping.gets(sqls, sqlsOrder, sqlsBackOrder));
             //减积分
-            goblinOrderUtils.integral(nftOrder.getUserId(), nftOrderRefundVo.getPrice(), "藏品退款", 2);
+            goblinOrderUtils.integral(nftOrder.getUserId(), nftOrderRefundVo.getPrice(), "数字藏品退款", 2);
         } else if (0 == status) {
             log.info("NftRefundCallback: 支付平台返回状态为失败，编号{}", refundCallbackParam.getOrderRefundCode());
             return "fail";