Skip to content

G
gic-spark-tag-4.0
Commit c53adf7e by guos
Options

会员标签4.0

parent b9dd1c03
Showing with 3 additions and 5 deletions
src/main/java/com/gic/spark/tag/TagProcessManager.java
...@@ -129,11 +129,7 @@ public class TagProcessManager { ...@@ -129,11 +129,7 @@ public class TagProcessManager {
public void process(boolean extractData){ public void process(boolean extractData){
// if(null!=memberDatasource){ System.out.println("sceneCrowdDTOList==>"+JSONObject.toJSONString(sceneCrowdDTOList));
// System.out.println("memberDatasource==>"+memberDatasource.getHiveTableName());
// System.out.println("memberDatasource==>"+memberDatasource.getSourceKey());
// }
Map<Integer, List<TagProcessEntity>> tagGroupByEnterpriseMap = new HashMap<>(); Map<Integer, List<TagProcessEntity>> tagGroupByEnterpriseMap = new HashMap<>();
Map<Long, BaseTagFilter> tagIdToFilterMap = new HashMap(); Map<Long, BaseTagFilter> tagIdToFilterMap = new HashMap();
...@@ -174,6 +170,8 @@ public class TagProcessManager { ...@@ -174,6 +170,8 @@ public class TagProcessManager {
} }
} }
System.out.println("tagGroupByEnterpriseMap==>"+JSONObject.toJSONString(tagGroupByEnterpriseMap));
//准备标签需要的数据 //准备标签需要的数据
for (Map.Entry<Integer, List<TagProcessEntity>> enterpriseTagEntry : tagGroupByEnterpriseMap.entrySet()) { for (Map.Entry<Integer, List<TagProcessEntity>> enterpriseTagEntry : tagGroupByEnterpriseMap.entrySet()) {
for (TagProcessEntity processEntity : enterpriseTagEntry.getValue()) { for (TagProcessEntity processEntity : enterpriseTagEntry.getValue()) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment