import sys,json,collections,copy
|
from pathlib import Path
|
from decimal import Decimal as D
|
sys.stdout.reconfigure(encoding='utf-8')
|
P=Path(__file__).parent;db=json.loads((P/'audit.json').read_text(encoding='utf8'));plan=json.loads((P/'plan.json').read_text(encoding='utf8'))
|
def active(t):return [x for x in db[t]['rows'] if x.get('deleted') not in (1,"b'\\x01'")]
|
inds={x['id']:x for x in plan['indicators']};details=collections.defaultdict(list)
|
for x in plan['details']:details[x['result_id']].append(x)
|
versions={(x['template_id'],x['version']):json.loads(x['schema_json']) for x in active('qc_report_template_version')}
|
new_schema=json.loads(json.dumps(versions[(14,'v1.1')],ensure_ascii=False).replace('item.standardValue','item.requirement').replace('标准值','标准要求'))
|
# Keep inspection names readable and reserve sufficient width for long SOP requirements on A4.
|
new_schema['grapes']['styles'].extend([
|
{'selectors':['#ipnmhk'],'style':{'table-layout':'fixed','width':'100%'}},
|
*[{'selectors':['#'+iid],'style':{'width':width}} for iid,width in zip(['iea1ya','iy2rxi','iqwrcq','itsffd','iwpsmz','i0sop1'],['6%','19%','40%','13%','11%','11%'])]
|
])
|
versions[(14,'v1.2')]=new_schema
|
(P/'report-template-upgrade.json').write_text(json.dumps({'template_id':14,'version':'v1.2','schema':new_schema,'source_version':'v1.1'},ensure_ascii=False,indent=2),encoding='utf8')
|
users=json.loads(Path('scripts/qc-complete-20261014/audit.json').read_text(encoding='utf8'))['users'];usernames={x['id']:x['nickname'].strip() for x in users}
|
unitnames={x['id']:x['name'] for x in active('mes_md_unit_measure')}
|
heads={k:{x['id']:x for x in active('mes_qc_'+k)} for k in ['iqc','ipqc','oqc','rqc']}
|
def plain(v):return format(D(v).normalize(),'f') if v is not None else ''
|
def requirement(line):
|
low,high=line.get('min_threshold'),line.get('max_threshold')
|
unit=line.get('_unit_name') or unitnames.get(line.get('unit_measure_id')) or inds[line['indicator_id']].get('unit_text') or ''
|
if low is not None and high is not None:text='='+plain(low) if D(low)==D(high) else plain(low)+'～'+plain(high)
|
elif low is not None:text='≥'+plain(low)
|
elif high is not None:text='≤'+plain(high)
|
else:
|
m=line.get('check_method') or '';remark=line.get('remark') or ''
|
return m[3:].split('；方法：')[0] if m.startswith('要求：') else remark if not remark.startswith('10月8日至14日业务链') else ''
|
return text+(' '+unit if unit else '')
|
jobs=[];preserved=[]
|
for instance in active('qc_report_instance'):
|
kind=instance['business_type'].replace('mes_qc_','');qid=int(instance['business_id']);head=heads[kind].get(qid)
|
if not head:
|
preserved.append({'id':instance['id'],'report_no':instance['report_no'],'reason':'来源单据已删除，保留原冻结报告，避免改写历史依据'});continue
|
qc_type={'iqc':1,'ipqc':2,'oqc':3,'rqc':4}[kind]
|
samples=[x for x in active('mes_qc_indicator_result') if x['qc_type']==qc_type and x['qc_id']==qid]
|
lines=[x for x in plan['line_state'][kind] if x[kind+'_id']==qid]
|
child=collections.defaultdict(list);own=collections.defaultdict(list)
|
for line in lines:
|
ind=inds[line['indicator_id']];parent=inds.get(ind['parent_id'])
|
if parent and parent['item_type']==2:child[parent['id']].append(line)
|
else:own[ind['id']].append(line)
|
entries=[]
|
for iid,ll in child.items():entries.append((inds[iid],own.pop(iid,[]),sorted(ll,key=lambda x:inds[x['indicator_id']]['sort_order'] or 999999)))
|
for iid,ll in own.items():entries.append((inds[iid],ll,[]))
|
entries.sort(key=lambda x:(x[0].get('sort_order') or 999999,x[0]['id']))
|
items=[]
|
def expand(ind,line):
|
values=[d for sample in samples for d in details[sample['id']] if d['indicator_id']==ind['id']]
|
if not values:values=[{'value':None,'remark':None}]
|
output=[]
|
for value in values:
|
unit='' if ind['item_type']==2 else line.get('_unit_name') or unitnames.get(line.get('unit_measure_id')) or ind.get('unit_text') or ''
|
remark='；'.join(x for x in [line.get('remark'),value.get('remark')] if x)
|
output.append({'index':0,'itemCode':ind['code'],'itemName':ind['name'],'standardValue':plain(line.get('standard_value')),'actualValue':value['value'] or '','unit':unit,'requirement':requirement(line),'checkMethod':line.get('check_method') or '', 'group':{'childName':'','span':1,'hidden':''},'upperLimit':float(line['max_threshold']) if line.get('max_threshold') is not None else None,'lowerLimit':float(line['min_threshold']) if line.get('min_threshold') is not None else None,'result':'','resultText':'待判定','remark':remark})
|
return output
|
for ind,ownlines,children in entries:
|
entry=[]
|
for line in ownlines:entry.extend(expand(ind,line))
|
if children and not entry:entry=expand(ind,{'indicator_id':ind['id']})
|
anchors=len(entry)
|
for line in children:
|
leaf=inds[line['indicator_id']];rr=expand(leaf,line)
|
for row in rr:row['group']['childName']=leaf['name']
|
entry.extend(rr)
|
for index,row in enumerate(entry):
|
row['index']=len(items)+1;row['group']['span']=len(entry) if children and index==0 else 1;row['group']['hidden']='hidden' if children and index>0 else ''
|
if index<anchors and ind.get('formula_text'):row['requirement']=ind['formula_text']
|
items.append(row)
|
snapshot=json.loads(instance['data_snapshot']);report=copy.deepcopy(snapshot['report']);report.update(reportNo=instance['report_no'],inspectDate=head['inspect_date'],inspector=usernames.get(head['inspector_user_id'],report.get('inspector','')),qcResult=str(head['check_result']),result='',resultText='待判定',conclusion='待判定',passRate='',total=len(items),passCount=0,failCount=0)
|
version='v1.2' if instance['template_id']==14 and instance['template_version']=='v1.1' else instance['template_version']
|
jobs.append({'id':instance['id'],'report_no':instance['report_no'],'template_version':version,'schema':versions[(instance['template_id'],version)],'snapshot':{'report':report,'inspectionItems':items}})
|
(P/'report-input.json').write_text(json.dumps(jobs,ensure_ascii=False,indent=2),encoding='utf8')
|
(P/'preserved-reports.json').write_text(json.dumps(preserved,ensure_ascii=False,indent=2),encoding='utf8')
|
print(json.dumps({'reports':len(jobs),'report_items':sum(len(x['snapshot']['inspectionItems']) for x in jobs)},ensure_ascii=False))
|
