提交相关 关注公众号逻辑

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/constant/SweetConstant.java

@@ -25,6 +25,9 @@ public class SweetConstant {
     public final static String REDIS_KEY_SWEET_WECHAT_USER_UNIONID="sweet:wechatUser:openId:";
     public final static String REDIS_KEY_SWEET_ANSWER_PHONE="sweet:answer:phone:";
 
+    public final static String REDIS_KEY_SWEET_WECHAT_USER_UNIONID_PHONE="sweet:wechatUser:phone:";
+
+
 //    public enum ManualPosition {
 //        artist("艺人","artist"),
 //        signingTime("签售时间","signingTime"),

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/pom.xml

@@ -62,6 +62,12 @@
             <version>1.0-SNAPSHOT</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.liquidnet</groupId>
+            <artifactId>liquidnet-service-sweet-api</artifactId>
+            <version>1.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
 
 
         <dependency>

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

@@ -32,6 +32,7 @@ import com.liquidnet.service.stone.entity.StoneScoreUser;
 import com.liquidnet.service.stone.mapper.StoneScoreLogsMapper;
 import com.liquidnet.service.stone.mapper.StoneScoreUserMapper;
 import com.liquidnet.service.stone.vo.StoneUserVo;
+import com.liquidnet.service.sweet.constant.SweetConstant;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.mongodb.core.MongoTemplate;
@@ -81,9 +82,10 @@ public class DataImpl {
             //查询全部用户
             List<AdamUser> adamUserList = userMapper.selectList(Wrappers.lambdaQuery(AdamUser.class).eq(AdamUser::getState, 1)
                     .select(AdamUser::getUid).last("limit " + ((page - 1) * size) + "," + ((page) * size)));
-            List<String> uidList = adamUserList.stream().map(AdamUser::getUid).collect(Collectors.toList());
-            for (String uid : uidList) {
+            for (AdamUser item : adamUserList) {
                 //获取用户相关信息
+                String uid=item.getUid();
+                String mobile = item.getMobile();
                 AdamUserInfoVo userInfoVo = (AdamUserInfoVo) redisUtil.get(AdamRedisConst.INFO_USER.concat(uid));
                 if (userInfoVo == null) {
                     System.out.println("REDIS KEY = " + AdamRedisConst.INFO_USER.concat(uid));
@@ -99,7 +101,6 @@ public class DataImpl {
                     data.setUid(uid);
                     data.setCreatedAt(LocalDateTime.now());
                     stoneScoreUserMapper.insert(data);
-
                     StoneUserVo userTaskVo = StoneUserVo.getNew();
                     userTaskVo.getTask();
                     userTaskVo.setUid(uid);
@@ -110,7 +111,14 @@ public class DataImpl {
                 int performanceCount = orderTicketsMapper.getOrderScore(uid).size();
                 score += performanceCount * 5;
                 //获取商品每日任务积分
+
                 //获取 关注摩登天空服务号
+                if(getUnionIdByPhone(mobile)!=null){
+                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
+                    params.add("uid", uid);
+                    params.add("taskId", 4 + "");
+                    HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
+                }
                 //获取用户相关信息
                 if (null != userInfoVo.getSex()) {
                     //获取 完善个人信息
@@ -158,6 +166,7 @@ public class DataImpl {
                 System.out.println("REDIS KEY = " + AdamRedisConst.INFO_USER.concat(uid));
             }
             int score = 0;
+            String mobile = userInfoVo.getMobile();
             //创建 用户积分数据
             int isExists = stoneScoreUserMapper.selectCount(Wrappers.lambdaQuery(StoneScoreUser.class).eq(StoneScoreUser::getUid, uid));
             if (isExists <= 0) {
@@ -179,6 +188,12 @@ public class DataImpl {
             score += performanceCount * 5;
             //获取商品每日任务积分
             //获取 关注摩登天空服务号
+            if(getUnionIdByPhone(mobile)!=null){
+                MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
+                params.add("uid", uid);
+                params.add("taskId", 4 + "");
+                HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
+            }
             //获取用户相关信息
             if (null != userInfoVo.getSex()) {
                 //获取 完善个人信息
@@ -226,4 +241,14 @@ public class DataImpl {
     public Object userCreate(StoneUserVo data) {
         return mongoTemplate.insert(data, StoneUserVo.class.getSimpleName());
     }
+
+    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){
+            return null;
+        }else{
+            return (String)obj;
+        }
+    }
 }