import sys, json
from pathlib import Path
sys.stdout.reconfigure(encoding='utf-8')
sys.path.insert(0, str(Path(__file__).parent / 'iqc-import-20261012/deps'))
import pymysql
out = Path(__file__).parent / 'module-backfill-20261014'
out.mkdir(exist_ok=True)
tables = ['crm_follow_up_record', 'crm_contract', 'mes_pro_mps', 'mes_pro_workorder', 'mes_pro_feedback', 'mes_qc_iqc', 'mes_qc_ipqc', 'mes_qc_oqc', 'mes_wm_product_produce', 'mes_wm_product_recpt', 'mes_wm_item_recpt', 'mes_energy_record']
snapshot = {}
with pymysql.connect(host='36.213.150.237', port=10000, user='root', password=sys.stdin.readline().strip(), database='mom-hm', charset='utf8mb4', connect_timeout=15, read_timeout=40, cursorclass=pymysql.cursors.DictCursor) as c:
    with c.cursor() as q:
        q.execute('SELECT DATABASE() db')
        assert q.fetchone()['db'] == 'mom-hm'
        q.execute('SHOW TABLES')
        existing = {next(iter(x.values())) for x in q.fetchall()}
        for table in tables:
            if table not in existing:
                print(json.dumps({'table': table, 'exists': False})); continue
            q.execute(f'SHOW FULL COLUMNS FROM `{table}`')
            columns = q.fetchall()
            names = {x['Field'] for x in columns}
            where = 'WHERE deleted=0' if 'deleted' in names else ''
            q.execute(f'SELECT COUNT(*) n FROM `{table}` {where}')
            count = q.fetchone()['n']
            q.execute(f'SELECT * FROM `{table}` {where} ORDER BY id DESC LIMIT 4')
            rows = q.fetchall()
            snapshot[table] = {'columns': columns, 'rows': rows, 'count': count}
            print(json.dumps({'table':table, 'count':count, 'columns':sorted(names), 'latest':rows[:1]},ensure_ascii=False,default=str))
        q.execute('SELECT id, username, nickname, dept_id FROM system_users WHERE deleted=0')
        snapshot['users'] = q.fetchall()
        q.execute('SELECT id,name,parent_id FROM system_dept WHERE deleted=0')
        snapshot['departments'] = q.fetchall()
        print(json.dumps({'departments':snapshot['departments']}, ensure_ascii=False))
(out/'read-snapshot.json').write_text(json.dumps(snapshot,ensure_ascii=False,default=str,indent=2),encoding='utf-8')