|
|
@@ -1677,7 +1677,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
|
product_attrs_original = json.loads(json.dumps(_extract.get("product_attrs",{})))
|
|
|
except Exception as e:
|
|
|
pass
|
|
|
- if len(list_new_product)>0:
|
|
|
+ if len(list_new_product)>0 and len(list_new_product)>product_attrs_original.get("data",[])//3:
|
|
|
set_product = set(_product)
|
|
|
product_attrs_new = {"data":[]}
|
|
|
for product_i in range(len(list_new_product)):
|
luojiehua