renyupeng 6 ヶ月 前
コミット
e16f275a2b
2 ファイル変更1 行追加1 行削除
  1. 1 0
      JST/KwaixiaodianJstPurchaseItemsRange_append.py
  2. 0 1
      utils/mysql_helper.py

+ 1 - 0
JST/KwaixiaodianJstPurchaseItemsRange_append.py

@@ -86,6 +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')
 
 

+ 0 - 1
utils/mysql_helper.py

@@ -103,7 +103,6 @@ def batch_insertPro_jst(item_list, table_name):
     con = pymysql.connect(host='139.186.27.96', user='data', passwd='hcst@2021', charset='utf8', port=3390)
     # 对数据库进行插入操作,并不需要commit,twisted会自动commit
     insert_sql = "REPLACE INTO ruixuan.{table_name}(poi_id, po_id,sku_id,qty, price,po_date,start_qty,end_qty,sku_num) VALUES ( %s,%s, %s, %s, %s, %s, %s, %s, %s )".format(table_name=table_name)
-    print(insert_sql)
     cur = con.cursor()
     try:
         cur.executemany(insert_sql, item_list)