diff --git a/.idea/jijv.iml b/.idea/jijv.iml
index d0876a7..9199d9d 100644
--- a/.idea/jijv.iml
+++ b/.idea/jijv.iml
@@ -2,7 +2,7 @@
-
+
\ No newline at end of file
diff --git a/.idea/misc.xml b/.idea/misc.xml
index c1622b9..97fc4e8 100644
--- a/.idea/misc.xml
+++ b/.idea/misc.xml
@@ -3,5 +3,5 @@
-
+
\ No newline at end of file
diff --git a/machines/config.ini b/machines/config.ini
new file mode 100644
index 0000000..21fb073
--- /dev/null
+++ b/machines/config.ini
@@ -0,0 +1,16 @@
+[source_db]
+host = 192.168.1.114
+user = boot
+password = boot@123
+database = newimt
+port = 13306
+
+[target_db]
+host = 192.168.1.114
+user = boot
+password = boot@123
+database = test_jiju
+port = 13306
+
+[settings]
+rule_file = E:\workingSpace\PycharmProjects\jijv\ma_supplier_info.xlsx
diff --git a/machines/新购机具.py b/machines/新购机具.py
new file mode 100644
index 0000000..86b45e7
--- /dev/null
+++ b/machines/新购机具.py
@@ -0,0 +1,144 @@
+import configparser
+import pandas as pd
+from sqlalchemy import create_engine
+from urllib.parse import quote_plus
+# 读取配置文件
+config = configparser.ConfigParser()
+config.read(r'D:\code\Bonus-Transfer-Machines\machines\config.ini')
+
+# 获取数据库连接配置
+source_config = {
+ 'host': config.get('source_db', 'host'),
+ 'user': config.get('source_db', 'user'),
+ 'password': config.get('source_db', 'password'),
+ 'database': config.get('source_db', 'database'),
+ 'port': config.getint('source_db', 'port')
+}
+
+target_config = {
+ 'host': config.get('target_db', 'host'),
+ 'user': config.get('target_db', 'user'),
+ 'password': config.get('target_db', 'password'),
+ 'database': config.get('target_db', 'database'),
+ 'port': config.getint('target_db', 'port')
+}
+
+# 创建数据库引擎
+source_engine = create_engine(
+ f"mysql+pymysql://{source_config['user']}:{quote_plus(source_config['password'])}@{source_config['host']}:{source_config['port']}/{source_config['database']}"
+)
+target_engine = create_engine(
+ f"mysql+pymysql://{target_config['user']}:{quote_plus(target_config['password'])}@{target_config['host']}:{target_config['port']}/{target_config['database']}"
+)
+
+def process_tm_task():
+ """处理新购待验收数据"""
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bms.ID as task_id,
+ 0 as task_type,
+ 2 as task_status,
+ bms.APPLY_NUMBER as code,
+ bms.BUYER as create_by,
+ tt.CREATE_TIME as create_time
+ FROM
+ ba_ma_shop bms
+ LEFT JOIN tm_task tt on bms.ID = tt.ID
+ LEFT JOIN tm_task_status tts on tt.`STATUS` = tts.`CODE`
+ LEFT JOIN tm_task_ma_type ttmt on bms.ID = ttmt.TASK_ID
+ WHERE tt.CREATE_TIME BETWEEN '2025-01-01' and NOW() and tt.`STATUS` in (18,19)
+ GROUP BY bms.ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('tm_task', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条新购机具任务表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理新购机具任务表数据时出错: {str(e)}")
+ return False
+
+def process_purchase_check_info():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bms.ID as task_id,
+ bms.BUY_TIME as purchase_time,
+ bms.ACCEPT_TIME as arrival_time,
+ ttmt.MANUFACTURER_ID as supplier_id,
+ bms.BUYER as create_by,
+ tt.CREATE_TIME as create_time
+ FROM
+ ba_ma_shop bms
+ LEFT JOIN tm_task tt on bms.ID = tt.ID
+ LEFT JOIN tm_task_status tts on tt.`STATUS` = tts.`CODE`
+ LEFT JOIN tm_task_ma_type ttmt on bms.ID = ttmt.TASK_ID
+ WHERE tt.CREATE_TIME BETWEEN '2025-01-01' and NOW()
+ GROUP BY bms.ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('purchase_check_info', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条新购主表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理新购主表数据时出错: {str(e)}")
+ return False
+
+def process_purchase_check_details():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bms.ID as task_id,
+ ttmt.MA_TYPE_ID as type_id,
+ ttmt.PRICE as purchase_price,
+ ttmt.MACHINES_NUM as purchase_num,
+ ttmt.MACHINES_NUM as check_num,
+ ttmt.ACTUAL_NUM as bind_num,
+ ttmt.INPUT_NUM as input_num,
+ ttmt.MANUFACTURER_ID as supplier_id,
+ IF(ttmt.MACHINES_NUM - IFNULL(ttmt.INPUT_NUM,0) = 0,19,4) as status,
+ bms.BUYER as create_by,
+ tt.CREATE_TIME as create_time
+ FROM
+ ba_ma_shop bms
+ LEFT JOIN tm_task tt on bms.ID = tt.ID
+ LEFT JOIN tm_task_ma_type ttmt on bms.ID = ttmt.TASK_ID
+ WHERE tt.CREATE_TIME BETWEEN '2025-01-01' and NOW()
+ GROUP BY bms.ID,ttmt.MA_TYPE_ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('purchase_check_details', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条租赁申请主表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理租赁申请主表数据时出错: {str(e)}")
+ return False
+
+if __name__ == "__main__":
+ # 执行3个转换流程
+ success1 = process_tm_task()
+ success2 = process_purchase_check_info()
+ success3 = process_purchase_check_details()
+
+ if success1 and success2 and success3:
+ print("所有数据转换完成！")
+ else:
+ print("数据转换过程中出现错误，请检查日志")
\ No newline at end of file
diff --git a/machines/新购配件.py b/machines/新购配件.py
new file mode 100644
index 0000000..eb3baea
--- /dev/null
+++ b/machines/新购配件.py
@@ -0,0 +1,143 @@
+import configparser
+import pandas as pd
+from sqlalchemy import create_engine
+from urllib.parse import quote_plus
+# 读取配置文件
+config = configparser.ConfigParser()
+config.read(r'D:\code\Bonus-Transfer-Machines\machines\config.ini')
+
+# 获取数据库连接配置
+source_config = {
+ 'host': config.get('source_db', 'host'),
+ 'user': config.get('source_db', 'user'),
+ 'password': config.get('source_db', 'password'),
+ 'database': config.get('source_db', 'database'),
+ 'port': config.getint('source_db', 'port')
+}
+
+target_config = {
+ 'host': config.get('target_db', 'host'),
+ 'user': config.get('target_db', 'user'),
+ 'password': config.get('target_db', 'password'),
+ 'database': config.get('target_db', 'database'),
+ 'port': config.getint('target_db', 'port')
+}
+
+# 创建数据库引擎
+source_engine = create_engine(
+ f"mysql+pymysql://{source_config['user']}:{quote_plus(source_config['password'])}@{source_config['host']}:{source_config['port']}/{source_config['database']}"
+)
+target_engine = create_engine(
+ f"mysql+pymysql://{target_config['user']}:{quote_plus(target_config['password'])}@{target_config['host']}:{target_config['port']}/{target_config['database']}"
+)
+
+def process_tm_task():
+ """处理新购任务数据"""
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bps.ID as task_id,
+ 12 as task_type,
+ IF( SUM(ttmt.MACHINES_NUM) - IFNULL(SUM(ttmt.INPUT_NUM),0) =0,1,0) as task_status,
+ tt.`CODE` as code,
+ bps.BUYER as create_by,
+ tt.CREATE_TIME as create_time
+ FROM
+ ba_pa_shop bps
+ LEFT JOIN tm_task tt on bps.ID = tt.ID
+ LEFT JOIN tm_task_status tts on tt.`STATUS` = tts.`CODE`
+ LEFT JOIN tm_task_ma_type ttmt on bps.ID = ttmt.TASK_ID
+ WHERE tt.CREATE_TIME BETWEEN '2025-01-01' and NOW()
+ GROUP BY bps.ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('tm_task', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条新购配件任务表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理新购配件任务表数据时出错: {str(e)}")
+ return False
+
+def process_purchase_part_info():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bps.ID as task_id,
+ bps.BUY_TIME as purchase_time,
+ bps.ACCEPT_TIME as arrival_time,
+ ttmt.MANUFACTURER_ID as supplier_id,
+ bps.BUYER as create_by,
+ tt.CREATE_TIME as create_time
+ FROM
+ ba_pa_shop bps
+ LEFT JOIN tm_task tt on bps.ID = tt.ID
+ LEFT JOIN tm_task_status tts on tt.`STATUS` = tts.`CODE`
+ LEFT JOIN tm_task_ma_type ttmt on bps.ID = ttmt.TASK_ID
+ WHERE tt.CREATE_TIME BETWEEN '2025-01-01' and NOW()
+ GROUP BY bps.ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('purchase_part_info', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条新购配件主表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理新购配件主表数据时出错: {str(e)}")
+ return False
+
+def process_purchase_part_details():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bps.ID as task_id,
+ ttmt.MA_TYPE_ID as part_id,
+ ttmt.PRICE as purchase_price,
+ ttmt.MACHINES_NUM as purchase_num,
+ ttmt.MACHINES_NUM as check_num,
+ ttmt.INPUT_NUM as input_num,
+ ttmt.MANUFACTURER_ID as supplier_id,
+ IF(ttmt.MACHINES_NUM - IFNULL(ttmt.INPUT_NUM,0) = 0,1,0) as status,
+ bps.BUYER as create_by,
+ tt.CREATE_TIME as as create_time
+ FROM
+ ba_pa_shop bps
+ LEFT JOIN tm_task tt on bps.ID = tt.ID
+ LEFT JOIN tm_task_ma_type ttmt on bps.ID = ttmt.TASK_ID
+ WHERE tt.CREATE_TIME BETWEEN '2025-01-01' and NOW()
+ GROUP BY bps.ID,ttmt.MA_TYPE_ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('purchase_part_details', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条新购配件详情表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理新购配件详情表数据时出错: {str(e)}")
+ return False
+
+if __name__ == "__main__":
+ # 执行3个转换流程
+ success1 = process_tm_task()
+ success2 = process_purchase_part_info()
+ success3 = process_purchase_part_details()
+
+ if success1 and success2 and success3:
+ print("所有数据转换完成！")
+ else:
+ print("数据转换过程中出现错误，请检查日志")
\ No newline at end of file
diff --git a/machines/标准箱.py b/machines/标准箱.py
new file mode 100644
index 0000000..2a7bd70
--- /dev/null
+++ b/machines/标准箱.py
@@ -0,0 +1,105 @@
+import configparser
+import pandas as pd
+from sqlalchemy import create_engine
+from urllib.parse import quote_plus
+# 读取配置文件
+config = configparser.ConfigParser()
+config.read(r'D:\code\Bonus-Transfer-Machines\machines\config.ini')
+
+# 获取数据库连接配置
+source_config = {
+ 'host': config.get('source_db', 'host'),
+ 'user': config.get('source_db', 'user'),
+ 'password': config.get('source_db', 'password'),
+ 'database': config.get('source_db', 'database'),
+ 'port': config.getint('source_db', 'port')
+}
+
+target_config = {
+ 'host': config.get('target_db', 'host'),
+ 'user': config.get('target_db', 'user'),
+ 'password': config.get('target_db', 'password'),
+ 'database': config.get('target_db', 'database'),
+ 'port': config.getint('target_db', 'port')
+}
+
+# 创建数据库引擎
+source_engine = create_engine(
+ f"mysql+pymysql://{source_config['user']}:{quote_plus(source_config['password'])}@{source_config['host']}:{source_config['port']}/{source_config['database']}"
+)
+target_engine = create_engine(
+ f"mysql+pymysql://{target_config['user']}:{quote_plus(target_config['password'])}@{target_config['host']}:{target_config['port']}/{target_config['database']}"
+)
+
+def process_bm_qrcode_box():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bqm.BOX_ID as box_id,
+ bqb.BOX_QRCODE as box_code,
+ CASE
+ WHEN bqb.box_status = 1 THEN 4
+ WHEN bqb.box_status = 2 THEN 3
+ WHEN bqb.box_status = 4 THEN 6
+ ELSE 5
+ END AS box_status,
+ 132 as input_user
+ FROM
+ bm_qrcode_ma bqm
+ LEFT JOIN bm_qrcode_box bqb on bqb.ID = bqm.BOX_ID
+ WHERE bqm.TIME BETWEEN '2025-01-01' and NOW()
+ GROUP BY bqm.BOX_ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('bm_qrcode_box', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条标准箱表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理标准箱表数据时出错: {str(e)}")
+ return False
+
+def process_bm_qrcode_box_bind():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bqm.BOX_ID as box_id,
+ bqm.MA_ID as ma_id,
+ pu.`NAME` as create_by,
+ bqm.TIME as create_time
+ FROM
+ bm_qrcode_ma bqm
+ LEFT JOIN bm_qrcode_box bqb on bqb.ID = bqm.BOX_ID
+ LEFT JOIN pm_user pu on bqm.`USER` = pu.ID
+ WHERE bqm.TIME BETWEEN '2025-01-01' and NOW()
+ GROUP BY bqm.BOX_ID,bqm.MA_ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('bm_qrcode_box_bind', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条标准箱表绑定数据")
+ return True
+
+ except Exception as e:
+ print(f"处理标准箱表绑定数据时出错: {str(e)}")
+ return False
+
+
+if __name__ == "__main__":
+ # 执行2个转换流程
+ success1 = process_bm_qrcode_box()
+ success2 = process_bm_qrcode_box_bind()
+
+ if success1 and success2:
+ print("所有数据转换完成！")
+ else:
+ print("数据转换过程中出现错误，请检查日志")
\ No newline at end of file
diff --git a/machines/退料.py b/machines/退料.py
new file mode 100644
index 0000000..17b5615
--- /dev/null
+++ b/machines/退料.py
@@ -0,0 +1,224 @@
+import configparser
+import pandas as pd
+from sqlalchemy import create_engine
+from urllib.parse import quote_plus
+# 读取配置文件
+config = configparser.ConfigParser()
+config.read(r'D:\code\Bonus-Transfer-Machines\machines\config.ini')
+
+# 获取数据库连接配置
+source_config = {
+ 'host': config.get('source_db', 'host'),
+ 'user': config.get('source_db', 'user'),
+ 'password': config.get('source_db', 'password'),
+ 'database': config.get('source_db', 'database'),
+ 'port': config.getint('source_db', 'port')
+}
+
+target_config = {
+ 'host': config.get('target_db', 'host'),
+ 'user': config.get('target_db', 'user'),
+ 'password': config.get('target_db', 'password'),
+ 'database': config.get('target_db', 'database'),
+ 'port': config.getint('target_db', 'port')
+}
+
+# 创建数据库引擎
+source_engine = create_engine(
+ f"mysql+pymysql://{source_config['user']}:{quote_plus(source_config['password'])}@{source_config['host']}:{source_config['port']}/{source_config['database']}"
+)
+target_engine = create_engine(
+ f"mysql+pymysql://{target_config['user']}:{quote_plus(target_config['password'])}@{target_config['host']}:{target_config['port']}/{target_config['database']}"
+)
+
+def process_tm_task():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ tt.ID as task_id,
+ 3 AS task_type,
+ IF(tt.`STATUS` = 4,2,0) as task_status,
+ bmb.APPLY_NUMBER as code,
+ bmb.CREATOR as create_by,
+ bmb.CREATE_TIME as create_time
+ FROM
+ ba_ma_back bmb
+ LEFT JOIN tm_task tt on bmb.ID = tt.ID
+ LEFT JOIN tm_task_status ts on tt.`STATUS` = ts.`CODE`
+ WHERE bmb.company_id =1
+ GROUP BY bmb.ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('tm_task', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条退料任务表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理退料任务表数据时出错: {str(e)}")
+ return False
+
+def process_tm_task_agreement():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ tt.ID as task_id,
+ bat.AGREEMENT_ID as agreement_id
+ FROM
+ ba_ma_back bmb
+ LEFT JOIN tm_task tt on bmb.ID = tt.ID
+ LEFT JOIN ba_agreement_task bat on bmb.ID = bat.TASK_ID
+ WHERE bmb.company_id =1
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('tm_task_agreement', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条退料任务协议表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理退料任务协议表数据时出错: {str(e)}")
+ return False
+
+def process_back_apply_info():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bmb.ID as id,
+ bmb.APPLY_NUMBER as code,
+ tt.ID as task_id,
+ bmb.BACKER AS back_person,
+ bmb.PHONE as phone,
+ bmb.CREATOR as create_by,
+ bmb.CREATE_TIME as create_time,
+ IF(tt.`STATUS` = 4,1,0) as status,
+ bmb.IS_PRINT as print_status
+ FROM
+ ba_ma_back bmb
+ LEFT JOIN tm_task tt on bmb.ID = tt.ID
+ LEFT JOIN tm_task_status ts on tt.`STATUS` = ts.`CODE`
+ WHERE bmb.company_id =1
+ GROUP BY bmb.ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('back_apply_info', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条退料申请主表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理退料申请主表数据时出错: {str(e)}")
+ return False
+
+def process_back_apply_details():
+ """处理退料申请明细数据"""
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bmb.APPLY_NUMBER as code,
+ bmb.id as parent_id,
+ ttmt.MA_TYPE_ID as type_id,
+ ttmt.MACHINES_NUM as pre_num,
+ ttmt.MACHINES_NUM as audit_num ,
+ ttmt.BACK_BAD_NUM as bad_num,
+ ttmt.BACK_GOOD_NUM as good_num,
+ IF(tt.`STATUS` = 4,2,0) as status,
+ bmb.CREATOR as create_by,
+ bmb.CREATE_TIME as create_time
+ FROM
+ ba_ma_back bmb
+ LEFT JOIN tm_task tt on bmb.ID = tt.ID
+ LEFT JOIN tm_task_ma_type ttmt on bmb.ID = ttmt.TASK_ID
+ WHERE bmb.company_id =1
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('back_apply_details', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条退料申请明细数据")
+ return True
+
+ except Exception as e:
+ print(f"处理退料申请明细时出错: {str(e)}")
+ return False
+
+
+def process_back_check_details():
+ """处理退料明细数据"""
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bmb.ID as parent_id,
+ mm.TYPE as type_id,
+ mm.ID as ma_id,
+ ttm.CREATOR as create_by,
+ ttm.CREATE_TIME as create_time,
+ 1 as back_num ,
+ 1 as back_status ,
+ 1 as good_num,
+ 0 as bad_num
+ FROM
+ ba_ma_back bmb
+ LEFT JOIN tm_task_ma ttm on bmb.ID = ttm.TASK_ID
+ LEFT JOIN ma_machines mm on ttm.MA_ID = mm.ID
+ LEFT JOIN ma_type mt on mm.TYPE = mt.ID
+ WHERE mt.IS_COUNT = 0
+ UNION
+ SELECT
+ bmb.id as parent_id,
+ ttmt.MA_TYPE_ID as type_id,
+ null as ma_id,
+ pu.`NAME` as create_by,
+ bmb.CREATE_TIME as create_time,
+ ROUND(ttmt.MACHINES_NUM,3) as back_num,
+ 1 as back_status ,
+ ttmt.BACK_GOOD_NUM as ood_num,
+ ttmt.BACK_BAD_NUM as bad_num
+ FROM
+ ba_ma_back bmb
+ LEFT JOIN tm_task_ma_type ttmt on bmb.ID = ttmt.TASK_ID
+ LEFT JOIN pm_user pu on bmb.CREATOR = pu.ID
+ WHERE ttmt.IS_COUNT =1
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('back_check_details', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条退料明细数据")
+ return True
+
+ except Exception as e:
+ print(f"处理退料明细时出错: {str(e)}")
+ return False
+
+
+if __name__ == "__main__":
+ # 执行5个转换流程
+ success1 = process_tm_task()
+ success2 = process_tm_task_agreement()
+ success3 = process_back_apply_info()
+ success4 = process_back_apply_details()
+ success5 = process_back_check_details()
+
+ if success1 and success2 and success3 and success4 and success5:
+ print("所有数据转换完成！")
+ else:
+ print("数据转换过程中出现错误，请检查日志")
\ No newline at end of file
diff --git a/machines/领料.py b/machines/领料.py
new file mode 100644
index 0000000..8b8c896
--- /dev/null
+++ b/machines/领料.py
@@ -0,0 +1,217 @@
+import configparser
+import pandas as pd
+from sqlalchemy import create_engine
+from urllib.parse import quote_plus
+# 读取配置文件
+config = configparser.ConfigParser()
+config.read(r'D:\code\Bonus-Transfer-Machines\machines\config.ini')
+
+# 获取数据库连接配置
+source_config = {
+ 'host': config.get('source_db', 'host'),
+ 'user': config.get('source_db', 'user'),
+ 'password': config.get('source_db', 'password'),
+ 'database': config.get('source_db', 'database'),
+ 'port': config.getint('source_db', 'port')
+}
+
+target_config = {
+ 'host': config.get('target_db', 'host'),
+ 'user': config.get('target_db', 'user'),
+ 'password': config.get('target_db', 'password'),
+ 'database': config.get('target_db', 'database'),
+ 'port': config.getint('target_db', 'port')
+}
+
+# 创建数据库引擎
+source_engine = create_engine(
+ f"mysql+pymysql://{source_config['user']}:{quote_plus(source_config['password'])}@{source_config['host']}:{source_config['port']}/{source_config['database']}"
+)
+target_engine = create_engine(
+ f"mysql+pymysql://{target_config['user']}:{quote_plus(target_config['password'])}@{target_config['host']}:{target_config['port']}/{target_config['database']}"
+)
+
+def process_tm_task():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ tt.ID as task_id,
+ 2 as task_type,
+ IF(SUM(ttmt.MACHINES_NUM)- SUM(ttmt.ACTUAL_NUM )>0,3,4) as task_status,
+ bmc.APPLY_NUMBER as code,
+ pu.`NAME` as create_by,
+ bmc.CREATE_TIME as create_time
+ FROM
+ ba_ma_collar bmc
+ LEFT JOIN tm_task tt on bmc.ID = tt.ID
+ LEFT JOIN tm_task_ma_type ttmt on bmc.ID = ttmt.TASK_ID
+ LEFT JOIN pm_user pu on bmc.CREATOR = pu.ID
+ WHERE bmc.company_id =1
+ GROUP BY bmc.ID
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('tm_task', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条租赁任务表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理租赁任务表数据时出错: {str(e)}")
+ return False
+
+def process_tm_task_agreement():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ tt.ID as task_id,
+ bat.AGREEMENT_ID as agreement_id
+ FROM
+ ba_ma_collar bmc
+ LEFT JOIN tm_task tt on bmc.ID = tt.ID
+ LEFT JOIN ba_agreement_task bat on bmc.ID = bat.TASK_ID
+ WHERE bmc.company_id =1
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('tm_task_agreement', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条租赁任务协议表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理租赁任务协议表数据时出错: {str(e)}")
+ return False
+
+def process_lease_apply_info():
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bmc.ID as id,
+ bmc.APPLY_NUMBER as code,
+ tt.ID as task_id,
+ bmc.COLLAR_MAN as lease_person,
+ bmc.COLLAR_PHONE as phone,
+ pu.`NAME` as create_by,
+ bmc.CREATE_TIME as create_time,
+ bmc.direct_id as direct_id,
+ bma.LEASE_COMPANY as unit_id,
+ bma.PROJECT as project_id
+ FROM
+ ba_ma_collar bmc
+ LEFT JOIN tm_task tt on bmc.ID = tt.ID
+ LEFT JOIN ba_agreement_task bat on bmc.ID = bat.TASK_ID
+ LEFT JOIN ba_ma_agreement bma on bat.AGREEMENT_ID = bma.ID
+ LEFT JOIN pm_user pu on bmc.CREATOR = pu.ID
+ WHERE bmc.company_id =1
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('lease_apply_info', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条租赁申请主表数据")
+ return True
+
+ except Exception as e:
+ print(f"处理租赁申请主表数据时出错: {str(e)}")
+ return False
+
+def process_lease_apply_details():
+ """处理租赁申请明细数据"""
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bmc.ID as parent_id,
+ ttmt.MA_TYPE_ID as type_id,
+ ttmt.MACHINES_NUM as pre_num,
+ ttmt.ACTUAL_NUM as al_num,
+ IF(ttmt.MACHINES_NUM - ttmt.ACTUAL_NUM =0,2,0) AS status
+ FROM
+ ba_ma_collar bmc
+ LEFT JOIN tm_task_ma_type ttmt on bmc.ID = ttmt.TASK_ID
+ WHERE bmc.company_id =1
+ AND ttmt.MA_TYPE_ID IS NOT NULL
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('lease_apply_details', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条租赁申请明细数据")
+ return True
+
+ except Exception as e:
+ print(f"处理租赁申请明细时出错: {str(e)}")
+ return False
+
+
+def process_lease_out_details():
+ """处理租赁出库明细数据"""
+ try:
+ # 执行转换SQL
+ sql = """
+ SELECT
+ bmc.ID as parent_id,
+ mm.TYPE as type_id,
+ mm.ID as ma_id,
+ ttm.CREATOR as create_by,
+ ttm.CREATE_TIME as create_time,
+ 1 as out_num
+ FROM
+ ba_ma_collar bmc
+ LEFT JOIN tm_task_ma ttm on bmc.ID = ttm.TASK_ID
+ LEFT JOIN ma_machines mm on ttm.MA_ID = mm.ID
+ LEFT JOIN ma_type mt on mm.TYPE = mt.ID
+ WHERE bmc.company_id =1 AND mt.IS_COUNT = 0
+ UNION
+ SELECT
+ bmc.ID as parent_id,
+ ttot.MA_TYPE_ID as type_id,
+ null as ma_id,
+ pu.`NAME` as create_by,
+ ttot.CREATE_TIME as create_time,
+ ttot.NUM as out_num
+ FROM
+ ba_ma_collar bmc
+ LEFT JOIN tm_task_out_type ttot on bmc.ID = ttot.TASK_ID
+ LEFT JOIN ma_type mt on ttot.MA_TYPE_ID = mt.ID
+ LEFT JOIN pm_user pu on ttot.CREATOR = pu.ID
+ WHERE bmc.company_id =1 AND ttot.IS_COUNT =1
+ """
+ df = pd.read_sql(sql, source_engine)
+
+ # 写入目标表
+ df.to_sql('lease_out_details', target_engine,
+ if_exists='append', index=False)
+
+ print(f"成功导入 {len(df)} 条租赁出库明细数据")
+ return True
+
+ except Exception as e:
+ print(f"处理租赁出库明细时出错: {str(e)}")
+ return False
+
+
+if __name__ == "__main__":
+ # 执行5个转换流程
+ success1 = process_tm_task()
+ success2 = process_tm_task_agreement()
+ success3 = process_lease_apply_info()
+ success4 = process_lease_apply_details()
+ success5 = process_lease_out_details()
+
+ if success1 and success2 and success3 and success4 and success5:
+ print("所有数据转换完成！")
+ else:
+ print("数据转换过程中出现错误，请检查日志")
\ No newline at end of file