import sys,json
|
from pathlib import Path
|
from read_links import P,connect,encode
|
result=json.loads((P/'result.json').read_text(encoding='utf8'))
|
before=json.loads(Path(result['backup']).read_text(encoding='utf8'))
|
plan=json.loads((P/'plan.json').read_text(encoding='utf8'))
|
expected={t:{r['id']:dict(r) for r in rows} for t,rows in before.items()}
|
for r in plan['changes']:expected[r['table']][r['id']][r['field']]=r['after']
|
c=connect(sys.stdin.readline().strip())
|
try:
|
with c.cursor() as q:
|
q.execute("SET time_zone='+08:00'");q.execute('SELECT NOW() now');now=q.fetchone()['now']
|
after={}
|
for t in before:
|
q.execute('SELECT * FROM `'+t+'` WHERE deleted=0 ORDER BY id');after[t]={r['id']:r for r in q.fetchall()}
|
assert encode(after[t])==encode(expected[t]),'Unexpected source or unrelated field change: '+t
|
customers=after['crm_customer'];missing={}
|
for t in ('mes_pro_mps','mes_pro_work_order','mes_pro_task'):
|
bad=[r['id'] for r in after[t].values() if r['client_id'] not in customers]
|
assert not bad,(t,bad);missing[t]=len(bad)
|
for task in after['mes_pro_task'].values():
|
wo=after['mes_pro_work_order'].get(task['work_order_id'])
|
assert wo and task['client_id']==wo['client_id'],'Task/work order mismatch'
|
for mps in after['mes_pro_mps'].values():
|
order=after['erp_sale_order'].get(mps['sale_order_id'])
|
if order:assert mps['client_id']==order['customer_id']
|
wo=after['mes_pro_work_order'].get(mps['work_order_id'])
|
if wo:assert mps['client_id']==wo['client_id']
|
for batch in after['mes_wm_batch'].values():
|
if batch['work_order_id'] in after['mes_pro_work_order']:
|
assert batch['client_id']==after['mes_pro_work_order'][batch['work_order_id']]['client_id'],'Batch/work order mismatch'
|
passed={'passed':True,'verified_at':str(now),'updated':len(plan['changes']),
|
'production_customer_missing':missing,'order_mps_workorder_task_batch_consistent':True,
|
'only_client_id_changed':True,'customer_rows_not_added_or_modified':True,
|
'unresolved_oqc':len(plan['unresolved']),'unallocated_stock_batches':len(plan['unallocated_stock_batches'])}
|
(P/'verification.json').write_text(encode(passed),encoding='utf8');print(encode(passed))
|
finally:c.close()
|
