添加通过unionid批量获取关联信息

src/main/java/cn/quantgroup/xyqb/controller/external/WeChatController.java

@@ -12,8 +12,10 @@ import cn.quantgroup.xyqb.model.webchat.AccessTokenResponse;
 import cn.quantgroup.xyqb.service.merchant.IMerchantService;
 import cn.quantgroup.xyqb.service.session.ISessionService;
 import cn.quantgroup.xyqb.service.user.IUserService;
+import cn.quantgroup.xyqb.service.wechat.IWechatFollowService;
 import cn.quantgroup.xyqb.service.wechat.IWechatService;
 import cn.quantgroup.xyqb.util.EmojiUtil;
+import cn.quantgroup.xyqb.util.TenantUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.TypeReference;
 import com.google.common.base.Joiner;
@@ -24,10 +26,7 @@ import org.apache.commons.lang.StringUtils;
 import org.apache.http.HttpStatus;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 import org.springframework.web.context.request.RequestContextHolder;
 import org.springframework.web.context.request.ServletRequestAttributes;
 
@@ -39,6 +38,7 @@ import java.net.MalformedURLException;
 import java.net.URL;
 import java.security.MessageDigest;
 import java.security.NoSuchAlgorithmException;
+import java.text.SimpleDateFormat;
 import java.util.*;
 
 /**
@@ -85,6 +85,9 @@ public class WeChatController implements IBaseController {
      */
     @Value("${m.https}")
     private String xjdDomain;
+
+    @Autowired
+    private IWechatFollowService wechatFollowService;
     /**
      * 开发者资质认证,有必要吗?
      *
@@ -468,4 +471,16 @@ public class WeChatController implements IBaseController {
         return JsonResult.buildSuccessResult("通过unionId查询的绑定微信相关信息", wechatUserInfoList);
     }
 
+    @PostMapping("/getByUnionIdsToUserIds")
+    public JsonResult getByUnionIdsToUserIds(@RequestBody Map<String, Object> params) {
+        log.info("根据unionIds获取企业绑定用户信息 {}", params);
+        List<String> unionIds = (List<String>) params.get("unionIds");
+        if (unionIds.size() > 500) {
+            unionIds = unionIds.subList(0,500);
+        }
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("YYYYMMdd");
+        String period = simpleDateFormat.format(new Date());
+        return JsonResult.buildSuccessResultGeneric(wechatFollowService.findByUnionIdsToUserIds(unionIds, period));
+    }
+
 }

src/main/java/cn/quantgroup/xyqb/entity/WechatInfoRelation.java

@@ -6,6 +6,7 @@ import org.springframework.beans.BeanUtils;
 
 import javax.persistence.*;
 import java.io.Serializable;
+import java.sql.Date;
 import java.sql.Timestamp;
 
 /**
@@ -23,14 +24,10 @@ public class WechatInfoRelation extends BaseEntity implements Serializable {
     private String openId;
     @Column(name = "union_id")
     private String unionId;
-    @Column(name = "is_follow_wechat")
-    private Integer isFollowWechat;
-    @Column(name = "is_follow_enterprise_wechat")
-    private Integer isFollowEnterpriseWechat;
-    @Column(name = "is_followed_wechat")
-    private Integer isFollowedWechat;
-    @Column(name = "is_followed_enterprise_wechat")
-    private Integer isFollowedEnterpriseWechat;
+    @Column(name = "type")
+    private Integer type;
+    @Column(name = "task_period")
+    private String taskPeriod;
 
 }
 

src/main/java/cn/quantgroup/xyqb/repository/IWeChatInfoRelationRepository.java

@@ -19,4 +19,6 @@ public interface IWeChatInfoRelationRepository extends JpaRepository<WechatInfoR
     @Query(value = "update wechat_info_relation as wir set wir.is_follow_wechat = 1 where wir.open_id IN (?1)", nativeQuery = true)
     void updateIsFollowWechatInOpenIdList(List<String> openIdList);
 
+    List<WechatInfoRelation> findByUnionIdInAndTaskPeriod(List<String> unionIdList, String period);
+
 }

src/main/java/cn/quantgroup/xyqb/service/wechat/IWechatFollowService.java

@@ -4,10 +4,14 @@ import cn.quantgroup.xyqb.entity.WechatUserInfo;
 import cn.quantgroup.xyqb.model.JsonResult;
 import cn.quantgroup.xyqb.model.webchat.AccessTokenResponse;
 
+import java.util.List;
+
 public interface IWechatFollowService {
     AccessTokenResponse getToken();
 
     JsonResult executeWechatFollowStatus(String nextOpenId, String period);
 
     void executeTask();
+
+    Object findByUnionIdsToUserIds(List<String> unionIds, String period);
 }

src/main/java/cn/quantgroup/xyqb/service/wechat/impl/WechatFollowServiceImpl.java

@@ -181,6 +181,11 @@ public class WechatFollowServiceImpl implements IWechatFollowService {
         executeEnterpriseFollowStatus("", period);
     }
 
+    @Override
+    public Object findByUnionIdsToUserIds(List<String> unionIds, String period) {
+        return weChatInfoRelationRepository.findByUnionIdInAndTaskPeriod(unionIds, period);
+    }
+
     private JsonResult executeEnterpriseFollowStatus(String s, String period) {
         try {