会员标签4.0

src/main/java/com/gic/spark/SparkTagProcessByTagGroupId.java

@@ -27,9 +27,9 @@ public class SparkTagProcessByTagGroupId {
         boolean isProd = Boolean.parseBoolean(args[0]);
         boolean extractData = Boolean.parseBoolean(args[1]);
         String[] arrs=args[2].split(",");
-        List<Integer>params=new ArrayList();
+        List<Long>params=new ArrayList();
         for(String s:arrs){
-            params.add(Integer.parseInt(s));
+            params.add(Long.parseLong(s));
         }
         ShardingConfigManager.initDefualt();
         SparkEnvManager.getInstance().init("member_tag_4.0");

src/main/java/com/gic/spark/tag/TagProcessManager.java

@@ -114,7 +114,7 @@ public class TagProcessManager {
             }
         }
     }
-    public void setTagGroupId(List<Integer>tagGroupIdList){
+    public void setTagGroupId(List<Long>tagGroupIdList){
         for(int i=sceneCrowdDTOList.size()-1;i>=0;i--){
             if(!tagGroupIdList.contains(sceneCrowdDTOList.get(i).getId())){
                 sceneCrowdDTOList.remove(i);