数据迁移

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinOrderTicketsMapper.java

@@ -45,5 +45,5 @@ public interface KylinOrderTicketsMapper extends BaseMapper<KylinOrderTickets> {
      * @param uid
      * @return
      */
-    BigDecimal getOrderScore(@Param("uid") String uid);
+    Integer getOrderScore(@Param("uid") String uid);
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java

 package com.liquidnet.service.platform.service.impl.kylin;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.fasterxml.jackson.annotation.JsonAutoDetect;
@@ -7,6 +8,7 @@ import com.fasterxml.jackson.annotation.PropertyAccessor;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.SerializationFeature;
 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import com.google.gson.JsonObject;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.*;
 import com.liquidnet.service.adam.constant.AdamRedisConst;
@@ -84,7 +86,7 @@ public class DataImpl {
                     .select(AdamUser::getUid).last("limit " + ((page - 1) * size) + "," + ((page) * size)));
             for (AdamUser item : adamUserList) {
                 //获取用户相关信息
-                String uid=item.getUid();
+                String uid = item.getUid();
                 String mobile = item.getMobile();
                 AdamUserInfoVo userInfoVo = (AdamUserInfoVo) redisUtil.get(AdamRedisConst.INFO_USER.concat(uid));
                 if (userInfoVo == null) {
@@ -107,12 +109,14 @@ public class DataImpl {
                     userCreate(userTaskVo);
                 }
                 //获取演出每日任务积分
-                BigDecimal performancePrice = orderTicketsMapper.getOrderScore(uid);
+                Integer performancePrice = orderTicketsMapper.getOrderScore(uid);
                 score += performancePrice.intValue() * 5;
                 //获取商品每日任务积分
-
+                String resultData = HttpUtil.get("http://devmall.zhengzai.tv/admin/sumUserCost?user_id=" + 1, null);
+                int goodsPrice = (int) JSONObject.parseObject(resultData).get("cost");
+                score += goodsPrice * 5;
                 //获取 关注摩登天空服务号
-                if(getUnionIdByPhone(mobile)!=null){
+                if (getUnionIdByPhone(mobile) != null) {
                     MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
                     params.add("uid", uid);
                     params.add("taskId", 4 + "");
@@ -180,11 +184,15 @@ public class DataImpl {
                 userCreate(userTaskVo);
             }
             //获取演出每日任务积分
-            BigDecimal performancePrice = orderTicketsMapper.getOrderScore(uid);
+            Integer performancePrice = orderTicketsMapper.getOrderScore(uid);
             score += performancePrice.intValue() * 5;
             //获取商品每日任务积分
+            String resultData = HttpUtil.get("http://devmall.zhengzai.tv/admin/sumUserCost?user_id=" + 1, null);
+            int goodsPrice = (int) JSONObject.parseObject(resultData).get("cost");
+            score += goodsPrice * 5;
+
             //获取 关注摩登天空服务号
-            if(getUnionIdByPhone(mobile)!=null){
+            if (getUnionIdByPhone(mobile) != null) {
                 MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
                 params.add("uid", uid);
                 params.add("taskId", 4 + "");
@@ -241,10 +249,10 @@ public class DataImpl {
     public String getUnionIdByPhone(String phone) {
         String redisKey = SweetConstant.REDIS_KEY_SWEET_WECHAT_USER_UNIONID_PHONE.concat(phone);
         Object obj = redisUtil.get(redisKey);
-        if(obj==null){
+        if (obj == null) {
             return null;
-        }else{
-            return (String)obj;
+        } else {
+            return (String) obj;
         }
     }
 }