会员标签4.0

src/main/java/com/gic/spark/entity/TagGroupInfo.java

@@ -10,12 +10,12 @@ import java.io.Serializable;
 public class TagGroupInfo implements Serializable{
 
     private static final long serialVersionUID = -8710695590658340671L;
-    private Integer mcu_id;
+    private Long id;
     private Integer enterprise_id;
     private String tag_group_info;
 
-    public TagGroupInfo(Integer mcu_id, Integer enterprise_id, String tag_group_info) {
-        this.mcu_id = mcu_id;
+    public TagGroupInfo(Long id, Integer enterprise_id, String tag_group_info) {
+        this.id = id;
         this.enterprise_id = enterprise_id;
         this.tag_group_info = tag_group_info;
     }

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

@@ -256,8 +256,8 @@ public class TagProcessManager {
                                                 while(data.hasNext()){
                                                     Tuple2<Long,String>tp2=data.next();
                                                     JSONObject json = JSONObject.parseObject(tp2._2());
-                                                    if(StringUtils.isNotEmpty(json.getString("tagGroup"))){
-                                                        tagGroupInfoList.add(new TagGroupInfo(json.getInteger("mcuId"),enterpriseId,json.getString("tagGroup")));
+                                                    if(StringUtils.isNotEmpty(json.getString("sceneTags_b"))){
+                                                        tagGroupInfoList.add(new TagGroupInfo(json.getLong("id"),enterpriseId,json.getString("sceneTags_b")));
                                                     }
                                                 }
                                                 return tagGroupInfoList.iterator();