增减积分用队列 orderBind、演出购票

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinAppZhengzaiServiceImpl.java

@@ -27,6 +27,8 @@ public class GoblinAppZhengzaiServiceImpl implements IGoblinAppZhengzaiService {
     @Autowired
     GoblinRedisUtils redisUtils;
     @Autowired
+    GoblinOrderUtils goblinOrderUtils;
+    @Autowired
     GoblinMongoUtils mongoUtils;
     @Autowired
     QueueUtils queueUtils;
@@ -205,7 +207,7 @@ public class GoblinAppZhengzaiServiceImpl implements IGoblinAppZhengzaiService {
                                 uid, now, storeOrderVo.getOrderId(), now, now));
             }
             if (priceActual.compareTo(BigDecimal.ZERO) != 0) {
-                orderUtils.doTask(uid, priceActual);
+                goblinOrderUtils.integral(uid, priceActual, "购买商品", 1);
             }
         }
         return ResponseDto.success();

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/util/GoblinOrderUtils.java

@@ -7,8 +7,10 @@ import com.liquidnet.commons.lang.util.CurrentUtil;
 import com.liquidnet.commons.lang.util.HttpUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.candy.param.BackCouponParam;
 import com.liquidnet.service.candy.vo.CandyCouponVo;
+import com.liquidnet.service.goblin.dto.GoblinQueueBizIntegralDto;
 import com.liquidnet.service.goblin.dto.vo.GoblinGoodsSkuInfoVo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -27,10 +29,10 @@ public class GoblinOrderUtils {
 
     @Value("${liquidnet.service.candy.url}")
     private String candyUrl;
-    @Value("${liquidnet.service.stone.url}")
-    private String stoneUrl;
     @Autowired
     GoblinRedisUtils redisUtils;
+    @Autowired
+    QueueUtils queueUtils;
 
     public void backCoupon(String uCouponId, String uid) {
         try {
@@ -76,18 +78,14 @@ public class GoblinOrderUtils {
         }
     }
 
-    public void doTask(String uid, BigDecimal price) {
-        try {
-            MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
-            header.add("Accept", "application/json;charset=UTF-8");
-            MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
-            params.add("score", price.intValue() + "");
-            params.add("content", "购买商品:");
-            params.add("uid", uid);
-            String resultData = HttpUtil.post(stoneUrl + "/user/logs/in2111", params, header);
-        } catch (Exception e) {
-            log.error("添加积分失败,e:{}", e);
-            e.printStackTrace();
+    public void integral(String uid, BigDecimal price, String content, int type) {
+        if (price.intValue() > 0) {
+            GoblinQueueBizIntegralDto goblinQueueBizIntegralDto = GoblinQueueBizIntegralDto.getNew();
+            goblinQueueBizIntegralDto.setUid(uid);
+            goblinQueueBizIntegralDto.setScore(price);
+            goblinQueueBizIntegralDto.setContent(content);
+            goblinQueueBizIntegralDto.setType(type);
+            queueUtils.sendMsgByRedis(MQConst.GoblinQueue.BIZ_INTEGRAL.getKey(), goblinQueueBizIntegralDto.toJson());
         }
     }
 

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

@@ -68,6 +68,8 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
     @Autowired
     private OrderUtils orderUtils;
     @Autowired
+    GoblinOrderUtils goblinOrderUtils;
+    @Autowired
     private MongoTemplate mongoTemplate;
     @Autowired
     private MongoConverter mongoConverter;
@@ -1032,7 +1034,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
 //                    log.info("下单消息模版错误",e);
 //                }
                 //加分
-                orderUtils.doTask(orderTicketData.getUserId(), orderTicketData.getPerformanceTitle(), orderTicketData.getPriceActual());
+                goblinOrderUtils.integral(orderTicketData.getUserId(), orderTicketData.getPriceActual(), "购买演出:".concat(orderTicketData.getPerformanceTitle()), 1);
                 //
 //                innerService.reportO(orderTicketData, "摩登天空");
                 //大麦回调

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

@@ -152,21 +152,6 @@ public class OrderUtils {
         return surplusGeneral;
     }
 
-    public void doTask(String uid, String title, BigDecimal price) {
-        try {
-            MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
-            header.add("Accept", "application/json;charset=UTF-8");
-            MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
-            params.add("score", price.intValue() + "");
-            params.add("content", "购买演出:" + title);
-            params.add("uid", uid);
-            String resultData = HttpUtil.post(stoneUrl + "/user/logs/in2111", params, header);
-        } catch (Exception e) {
-            log.error("添加积分失败,e:{}", e);
-            e.printStackTrace();
-        }
-    }
-
     public AdamRscPolymer01Vo adamAddressEnterMember(String uid, String enterIds, String addressId) {
         try {
             MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();