修改过滤user_id为空值

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

@@ -149,7 +149,7 @@ public class WechatFollowServiceImpl implements IWechatFollowService {
                         String openIdStrs = String.join("\',\'", openIds);
                         openIdStrs = "\'" + openIdStrs + "\'";
                         // 添加公众号数据
-                        String sql = String.format("INSERT INTO wechat_info_relation(`user_id`, `open_id`, `union_id`, `type`, `task_period`)  SELECT `user_id`, `open_id`, `union_id`, '%s', %s from wechat_userinfo where app_name='%s' and `open_id` IN (%s)", WECHAT_ACCOUNT, period, WECHAT_XYQB, openIdStrs);
+                        String sql = String.format("INSERT INTO wechat_info_relation(`user_id`, `open_id`, `union_id`, `type`, `task_period`)  SELECT `user_id`, `open_id`, `union_id`, '%s', %s from wechat_userinfo where app_name='%s' and user_id is not null and `open_id` IN (%s)", WECHAT_ACCOUNT, period, WECHAT_XYQB, openIdStrs);
                         jdbcTemplate.update(sql);
                     }
                     if (nextOpenId != "") {
@@ -231,7 +231,7 @@ public class WechatFollowServiceImpl implements IWechatFollowService {
                 String unionIdStrs = String.join("\',\'", unionIds);
                 unionIdStrs = "\'" + unionIdStrs + "\'";
 //                String sql = String.format("INSERT INTO wechat_enterprise(`unionid`) values ('%s')", String.join(",", unionIdAll));
-                String sql = String.format("INSERT INTO wechat_info_relation(`user_id`, `open_id`, `union_id`, `type`, `task_period`)  SELECT `user_id`, `open_id`, `union_id`, '%s', %s from wechat_userinfo where `union_id` IN (%s)", ENTERPRISE_WECHAT, period, unionIdStrs);
+                String sql = String.format("INSERT INTO wechat_info_relation(`user_id`, `open_id`, `union_id`, `type`, `task_period`)  SELECT `user_id`, `open_id`, `union_id`, '%s', %s from wechat_userinfo where  user_id is no null and `union_id` IN (%s)", ENTERPRISE_WECHAT, period, unionIdStrs);
                 jdbcTemplate.update(sql);
             }