1.历史数据同步

consumers/history_data.py

@@ -208,7 +208,7 @@ class Order_dispose(object):
         if sync_log_vals_list:
             val_df = pd.DataFrame(sync_log_vals_list)
             val_df.to_sql('cc_history_package_sync_log', con=db_handle, if_exists='append', index=False)
-        origin_log_ids = [sync_log_result.id for sync_log_result in sync_log_result_arr.itertuples()]
+        origin_log_ids = sync_log_result_arr['id'].tolist()
         return origin_log_ids
 
     def history_package_goods(self, db_handle, ship_package_id, history_ship_package_id, big_id, select_bl_id):
@@ -330,22 +330,22 @@ class Order_dispose(object):
                 pd.read_sql(update_sql, con=db_handle, chunksize=100)
                 if origin_delete:
                     # print('delete data')
-                    # if delete_big_ids:  # 删除原大包
-                    #     ids = '(%s)' % str(delete_big_ids)[1:-1]
-                    #     delete_big_sql = 'delete from cc_big_package where id in %s' % ids
-                    #     pd.read_sql(delete_big_sql, con=db_handle, chunksize=100)
-                    # if delete_package_ids:  # 删除原小包
-                    #     ids = '(%s)' % str(delete_package_ids)[1:-1]
-                    #     delete_package_sql = 'delete from cc_ship_package where id in %s' % ids
-                    #     pd.read_sql(delete_package_sql, con=db_handle, chunksize=100)
-                    # if delete_good_ids:  # 删除原小包商品
-                    #     ids = '(%s)' % str(delete_good_ids)[1:-1]
-                    #     delete_goods_sql = 'delete from cc_package_good where id in %s' % ids
-                    #     pd.read_sql(delete_goods_sql, con=db_handle, chunksize=100)
-                    # if delete_log_ids:  # 删除原小包tiktok日志
-                    #     ids = '(%s)' % str(delete_log_ids)[1:-1]
-                    #     delete_log_sql = 'delete from cc_ship_package_sync_log where id in %s' % ids
-                    #     pd.read_sql(delete_log_sql, con=db_handle, chunksize=100)
+                    if delete_big_ids:  # 删除原大包
+                        ids = '(%s)' % str(delete_big_ids)[1:-1]
+                        delete_big_sql = 'delete from cc_big_package where id in %s' % ids
+                        pd.read_sql(delete_big_sql, con=db_handle, chunksize=100)
+                    if delete_package_ids:  # 删除原小包
+                        ids = '(%s)' % str(delete_package_ids)[1:-1]
+                        delete_package_sql = 'delete from cc_ship_package where id in %s' % ids
+                        pd.read_sql(delete_package_sql, con=db_handle, chunksize=100)
+                    if delete_good_ids:  # 删除原小包商品
+                        ids = '(%s)' % str(delete_good_ids)[1:-1]
+                        delete_goods_sql = 'delete from cc_package_good where id in %s' % ids
+                        pd.read_sql(delete_goods_sql, con=db_handle, chunksize=100)
+                    if delete_log_ids:  # 删除原小包tiktok日志
+                        ids = '(%s)' % str(delete_log_ids)[1:-1]
+                        delete_log_sql = 'delete from cc_ship_package_sync_log where id in %s' % ids
+                        pd.read_sql(delete_log_sql, con=db_handle, chunksize=100)
                     logging.info(f'同步提单:{select_bl_no},删除大包{len(delete_big_ids)}个,删除小包{len(delete_package_ids)}个,删除小包商品{len(delete_good_ids)}个,删除小包日志{len(delete_log_ids)}条')
         except Exception as ex:
             logging.error('create_history_data error:%s' % str(ex))