[veh_scrap]
veh = INSERT INTO zqy_veh_scrap_sto (zqy_id, vin, pack_num, scrap_time, bat_is_scrap,wmi,epname,epcode,province_code,city_code,submit_time) values

def random_vin():
 """
 生成隨機vin
 :return:
 """
 return ''.join(
  random.sample(['Z', 'Y', 'X', 'W', 'V', 'U', 'T', 'S', 'R', 'Q', 'P',
      'O', 'N', 'M', 'L', 'K', 'J', 'I', 'H', 'G', 'F', 'E',
      'D', 'C', 'B', 'A', '1', '2', '3', '4', '5', '6', '7',
      '8', '9', '0'], 17))

def get_conn():
 conn = pymysql.connect(
  host=,
  port=,
  user=,
  password=,
  database=,
  charset='utf8')
 return conn


def execut_sql(sql):
 try:

  conn = get_conn()
  cur = conn.cursor()
  cur.execute(sql)
  conn.commit()
  print("數據庫執(zhí)行成功")
  cur.close()

 except Exception as e:
  print(str(e))
  print(sql)
  # 有異常就回滾
  conn.rollback()
  # 關閉連接
 cur.close()
 conn.close()

def select_one_sql(sql):
 try:
  conn = get_conn()
  cur = conn.cursor()
  cur.execute(sql)
  results = cur.fetchone()
  #print(results)
  cur.close()

  return results
 except Exception as e:
  print(str(e))
  # 關閉連接
 cur.close()
 conn.close()

import configparser

cfg_path = 'rebulid_generate_sql_git\base_data\sql_header.ini'
cfg = configparser.ConfigParser()
cfg.read(cfg_path,encoding='utf-8')

def get_config_data(section,options):
 return cfg.get(section,options)

def recycle_veh_scrap(prov, city):
 """
 報廢車輛入庫表
 :return:
 """
 prov_info = random_util.random_city_code(prov, city)
 # 獲取當地所有公司信息
 company = search_factory_info.get_company_data(prov, city)
 # 獲取vin
 vin = random_util.random_vin()
 # 生成數據容器
 insert_data = []
 # 生成隨機zqy_id,寫入列表
 insert_data.append(random_util.random_id())
 # 生成隨機vin,寫入列表
 insert_data.append(vin)
 # 生成隨機電池包數,寫入列表
 insert_data.append(random.randint(1, 10))
 # 生成報廢時間,寫入列表
 insert_data.append(random_util.random_date())
 # bat_is_scrap
 insert_data.append('1')
 # wmi
 insert_data.append(vin[0:3].upper())
 # 生成報廢企業(yè)名稱,寫入列表
 insert_data.append(company[0])
 # 生成報廢企業(yè)代碼,寫入列表
 insert_data.append(company[1])
 # 獲取省級代碼，寫入列表
 insert_data.append(prov_info[0])
 # 獲取市級代碼，寫入列表
 insert_data.append(prov_info[1])
 # 數據提交時間為當前數據生成時間，寫入列表
 insert_data.append(time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()))return insert_data

def TongJiQi(list):
 # 列表內容統(tǒng)計器，對列表內的重復項進行數量統(tǒng)計
 count_dict = dict()
 for item in list:
  if item in count_dict:
   count_dict[item] += 1
  else:
   count_dict[item] = 1
 return count_dict


def qiuhe(data_list):
 """
 對列表內的數值進行求和
 :param data_list:
 :return:
 """
 total = 0
 for ele in range(0, len(data_list)):
  total = total + data_list[ele]
 return total

def write_sql（prov, city, des_prov, des_city）
# 通過配置文件獲取sql頭
sql = config_util.get_config_data('veh_scrap', 'pack_out')
# 控制循環(huán)
i = 0
# 創(chuàng)建列表，用于收集需要統(tǒng)計計算的數據
company_num = []
des_company_num = []
while i < sql_num:
 i += 1
 # 取生成的values值
 data = _crap_out(prov, city, des_prov, des_city)
 # 收集需要統(tǒng)計的數據
 company_num.append(data[8])
 des_company_num.append(data[4])
 # 拼裝sql語句
 sql = sql + str(tuple(data)) + ','
 # 最后一組數據后的,刪除掉
right_sql = sql.strip(',')
# 拼裝上結尾的; fullsql作為返回值
full_sql = right_sql + ';'
# print(full_sql)
# 執(zhí)行寫入
pymysql_util.execut_sql(full_sql)
print('上報企業(yè)統(tǒng)計： ' + str(
 statistics_util.TongJiQi(company_num)))
print('去向企業(yè)統(tǒng)計： ' + str(
 statistics_util.TongJiQi(des_company_num)))

def main(prov, city, sql_num, sour_prov, sour_city):
 """
 啟動數據自動寫入的主方法
 :return:
 """
 features_type = input("請選擇生成數據所屬功能模塊 1.車輛報廢 2.梯次利用 3.資源再生")
 if features_type == '1':
  scrapped_main.write_sql(prov, city, sql_num, des_prov=sour_prov,
        des_city=sour_city)
 elif features_type == '2':
  echelon_use_main.write_main(prov, city, sql_num, sour_prov, sour_city)
 elif features_type == '3':
  recycle_main.write_main(sql_num, prov, city, sour_prov, sour_city)