update

find_source/common/databases.py

@@ -54,6 +54,16 @@ def update_one(collection: Collection, item):
 
 
 def update_one_by_domain(collection: Collection, item):
+    lst = []
+    items = collection.find_one({'domain': item['domain']})
+    if items is not None:
+        origin = items.get('origin', [])
+        if item['origin'] not in origin:
+            lst.append(item['origin'])
+        lst.extend(origin)
+    else:
+        lst.append(item['origin'])
+    item.update({'origin': lst})
     collection.update_one(
         {'domain': item['domain']},
         {'$set': item},