|
@@ -24,7 +24,7 @@ group by sku_id
|
|
|
results = self.conn.QueryAll(sql=sql)
|
|
|
items_per_thread = len(results)
|
|
|
threads = []
|
|
|
- for i in range(5):
|
|
|
+ for i in range(1):
|
|
|
start = i * items_per_thread
|
|
|
end = start + items_per_thread
|
|
|
thread = threading.Thread(target=self.handlerSkuRange, args=(results[start:end],))
|
|
@@ -34,6 +34,7 @@ group by sku_id
|
|
|
thread.join()
|
|
|
|
|
|
def handlerSkuRange(self, sku_list):
|
|
|
+ sku_item_list = []
|
|
|
for sku_id in sku_list:
|
|
|
sku_id = sku_id[0].decode("utf-8")
|
|
|
sku_range_delete = """
|
|
@@ -47,7 +48,6 @@ group by sku_id
|
|
|
data_list = self.conn.QueryAll(sql=sku_sql)
|
|
|
sumqty = 0
|
|
|
end_qty = 0
|
|
|
- sku_item_list = []
|
|
|
for i, data in enumerate(data_list):
|
|
|
if i == 0:
|
|
|
start_qty = 0
|
|
@@ -86,8 +86,7 @@ group by sku_id
|
|
|
poi_id, po_id, sku_id, qty, price, po_date, start_qty, end_qty, sku_num
|
|
|
)
|
|
|
sku_item_list.append(sku_item)
|
|
|
- print(sku_item_list)
|
|
|
- batch_insertPro_jst(sku_item_list, 'kwaixiaodian_jst_purchase_items_range')
|
|
|
+ batch_insertPro_jst(sku_item_list, 'kwaixiaodian_jst_purchase_items_range')
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|