Quellcode durchsuchen

fix: update_time

JimZhang vor 3 Jahren
Ursprung
Commit
c86e3ba1ef

+ 3 - 0
src/main/java/com/winhc/bigdata/task/jobs/DynamicPersonIdUpdateJob.java

@@ -269,14 +269,17 @@ public class DynamicPersonIdUpdateJob {
                     return true;
                 }
             }).collect(Collectors.toList());
+            Date date = new Date();
             if (collect.isEmpty()) {
                 Map<String, Object> map = new HashMap<>();
                 map.put("deleted", "9");
+                map.put("update_time",date);
                 ClientOptions clientOptions = new ClientOptions();
                 clientOptions.setId(id);
                 processor.updateData(index, "dynamic", map, clientOptions);
             } else {
                 jsonObject.put("content", collect);
+                jsonObject.put("update_time",date);
                 ClientOptions clientOptions = new ClientOptions();
                 clientOptions.setId(id);
                 processor.insertData(index, "dynamic", jsonObject, clientOptions);