|
@@ -3,6 +3,7 @@ package com.winhc.bigdata.task.jobs;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.alibaba.fastjson.serializer.SerializerFeature;
|
|
|
import com.mongodb.client.MongoCollection;
|
|
|
import com.winhc.bigdata.task.service.DingTalkService;
|
|
|
import com.winhc.bigdata.task.util.DateUtils;
|
|
@@ -241,11 +242,6 @@ public class DynamicPersonIdUpdateJob {
|
|
|
log.error(e.getMessage(), e);
|
|
|
}
|
|
|
|
|
|
- int i = new Random().nextInt(3);
|
|
|
- if (i == 0) {
|
|
|
- log.info("riewqujir:\n{} : {}\n{}", keyno, validId, JSON.toJSONString(data));
|
|
|
- }
|
|
|
-
|
|
|
if (StringUtils.isEmpty(id)) {
|
|
|
return;
|
|
|
}
|
|
@@ -275,14 +271,14 @@ public class DynamicPersonIdUpdateJob {
|
|
|
if (collect.isEmpty()) {
|
|
|
Map<String, Object> map = new HashMap<>();
|
|
|
map.put("deleted", "9");
|
|
|
- map.put("update_time",date);
|
|
|
+ map.put("update_time", date);
|
|
|
ClientOptions clientOptions = new ClientOptions();
|
|
|
clientOptions.setId(id);
|
|
|
processor.updateData(index, "dynamic", map, clientOptions);
|
|
|
} else {
|
|
|
jsonObject.put("content", collect);
|
|
|
- jData.put("update_time",date);
|
|
|
- jData.put("dynamic_info", jsonObject.toJSONString());
|
|
|
+ jData.put("update_time", date);
|
|
|
+ jData.put("dynamic_info", JSON.toJSONString(jsonObject, SerializerFeature.WriteMapNullValue));
|
|
|
ClientOptions clientOptions = new ClientOptions();
|
|
|
clientOptions.setId(id);
|
|
|
processor.insertData(index, "dynamic", jData, clientOptions);
|
|
@@ -358,4 +354,5 @@ public class DynamicPersonIdUpdateJob {
|
|
|
return update.containsKey("old_human_pid") && update.containsKey("new_human_pid");
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
}
|