z+jDBddlmZddlmZmZmZddlmZddlmZm Z ddl m Z ddl m Z ddlmZdd lmZdd lmZmZmZmZmZmZmZmZd9dZd:dZd;dZddddddddd*Z dd'd?d,Z!dd'd@d.Z"dd'dAd0Z#dd'dBd2Z$dd'dCd4Z%dd'dDd6Z&dd'dEd8Z'dS)F) annotations)datedatetimetimezone)Decimal)AnyMapping)UUID)sql)Jsonb)connect)PartyIn ProductIn SourceFileInPurchaseOrderInStockMovementInShipmentSignoffInValidationIssueInReconciliationRunInprefixstrreturncn|dtjtjdS)N-z%Y%m%d%H%M%S%f)rnowrutcstrftime)rs app/write_service.py _now_coder s1 N Nx|HL11::;KLL N NNvaluerct|trt|St|trt|St|tt fr|St|trd|DSt|tr d|DS|S)Nc4i|]\}}|t|S _to_jsonable.0kvs r z _to_jsonable..s$===tq!<??===r!c,g|]}t|Sr%r&)r)r+s r z _to_jsonable.. s///A Q///r!) isinstancer rrrr isoformatdictitemslist)r"s rr'r's%5zz%!!5zz%(D)**!   %>==u{{}}====%0////// Lr!tabledataMapping[str, Any]cd|D}|stdd|D}g}|D]d}t|tst|t r#|t|O||etj d tj |tj d |tj d d|D}| ||t|dS) Nci|] \}}||| SNr%r(s rr,z_insert..%s < < .(s" - - -!CN1   - - -r!zAINSERT INTO {table} ({cols}) VALUES ({placeholders}) RETURNING id, c3<K|]}tjVdSr9r Placeholderr)_s r z_insert..2s*'H'Ha(9(9'H'H'H'H'H'Hr!)r4cols placeholdersid)r2 ValueErrorvaluesr/r1r3appendr r SQLformatr<joinexecuterfetchone)curr4r5cleanrEvalsr+qs r_insertrT$sW < .Is @ @ @da!-Q---r!zDINSERT INTO api_write_requests ({cols}) VALUES ({vals}) RETURNING idr>c3>K|]}tj|VdSr9r;r=s rrDz_audit..Ks,AAaq 1 1AAAAAAr!c3<K|]}tjVdSr9r@rBs rrDz_audit..Ls*AAa 1 1AAAAAAr!)rErRrGz INSERT INTO agent_write_audit(agent_profile, tool_name, operation, target_table, target_id, request_payload, result_status, result_message) VALUES (%s, %s, %s, %s, %s, %s, %s, %s) >createimportupdatecomputedelete_requestrksuccess needs_review)r r r'rrrrr2r rKrLrMrNr3rIrrO)rPr[r\r]r^rUrVrWrXrYrZreq_datarQrSreq_ids r_auditrt8s"$&* gm!D, E,D0 0E3D0 4EE  E rct5}|5}t||}|rddi|cdddcdddS|dd}|ddt |d|}t |d|t d |d |d |d |d |d|d|d|dd t||dddd||| | d|icdddcdddS#1swxYwY ddddS#1swxYwYdS)Nr{Tr|r}extraction_statusr source_files file_receiptsFRsource_platformuploader received_atsource_cache_pathoriginal_source_pathreceived_status file_existsnotes) source_file_id receipt_coder sender_namerrrreceive_statusrrregister_source_filerkrcrrG) rrrxrrrTr rrtrrs rrrs %d [[]] %c)#??H 8$d7h7 % % % % % % %%%%%%%%% %%4h%GGD OO/ ; ; ;^T::I C"+ )$#'88,=#>#>#xx 33#xx 66%)XX.A%B%B(,1G(H(H"&((+<"="=#xx 66'** + +    3m?Uair{KYenx|N] ^ ^ ^ ^ KKMMM)$+ % % % % % % %%%%%%%%% % % % % % % % % %%%%%%%%%%%%%%%%%%%s@F5F F5D.F F5F F5#F $F55F9<F9rc|jstdt5}|5}t ||}|rddi|cdddcdddS|dhdd}t d|d<|d @|d r+|d r|d d |d |d <t|d |}g}g} t|jdD]U\} } | dhdd} | || dd| d | d| d<t|d| } | | | j D]}|dd}| |d<|d|dd|d<|dJt|ddt|ddz|d<| t|d|АWt||dddd ||d !t|t| d"|# |||| d$cdddcdddS#1swxYwY ddddS#1swxYwYdS)%Nz)purchase order requires at least one liner{Tlinesr|excluder~rPO order_codeexpected_arrival_textexpected_arrival_startexpected_arrival_end~purchase_ordersr startchannel_allocationsr)order_idline_nordelivery_quantityquantity order_linesr} order_line_idplanned_quantityoriginal_quantityrconfirmed_quantityadjustment_quantitycreate_purchase_orderrkrcjsonr) line_countallocation_count r[r\r]r^rUrVrWrXrZ)rGline_idsallocation_ids)rrHrrrxrr rrT enumeratermrJrfloatrtlenr)rWr[rZrrPr order_datarrridxline line_dataline_idalloc alloc_datas rrrs =FDEEE \d [[]] \c)#??H 8$d7h7 \ \ \ \ \ \ \\\\\\\\\ !++WIDW_+``J'0J| $~~566>>>":;;I Oe@f@fI=GH`=a;I;IdnpFeG;I;IJ67s$5zBBH"$H(*N&w}A>>> [ [ T OO5J4KZ^emOnn   h3_h!i!ijjj==!455=5>z5JI12!#}i@@(((!5[[E!&!1!1t(!1!S!SJ29J/!~~&899A9CH[]^9_9_ #56!~~&:;;C;@PcefAgAg;h;hkpq{qqAVXYrZrZl[l[<[ #78"))'#7Lj*Y*YZZZZ[ 3m?Vbjs|L]iq{B{M{MSY{M{Z{ZvyzBvCvCY\]kYlYlgmgmN O O O O KKMMM"N[[; \ \ \ \ \ \ \\\\\\\\\ \ \ \ \ \ \ \ \ \\\\\\\\\\\\\\\\\\\sALK) L+I%K) L)K- -L0K- 1LL Lrc|dd}td|d<|d|d<t5}|5}t ||}|rddi|cdddcdddS|dd kr|d |d f|}|r|d nd }|||dkrt|dddd|d dd|d|ddd} t||dddd| |d t|id| | d| dcdddcdddSt|d|} t||dddd| || | d | icdddcdddS#1swxYwY ddddS#1swxYwYdS)!NTr|r}MV movement_code movement_nor{ directionoutzCSELECT current_quantity FROM v_current_stock WHERE stock_item_id=%s stock_item_idcurrent_quantityrrvalidation_issuesnegative_stockerror stock_itemsu库存不足：当前 u，申请出库 open) issue_typeseverity related_table related_id field_namemessager^add_stock_movementrkrejectedu 库存不足) r[r\r]r^rUrVrWrXrYrZ)rvalidation_issue_idstock_movementsrcrrG) rr rrrxrNrOrTrtrr) rWr[rZr5rrPrrwcurrentissue_idrVs rrrs   4h  ? ?D%dOOD/D %d [[]] %c)#??H 8$d7h7 % % % % % % %%%%%%%%% K E)) adhixdyc{|||llnn58?#011a&7T*5E+E+E&s,?&6G^k&*?&;:#gG#g#gUYZdUe#g#gsyBB  H 3mG[goyCReqyCGUgilmtiuiuTvFTfuvvvvKKMMM(,XNN! % % % % % % %%%%%%%%%$ %6==I 3m?S_gpyIZfoy}O^ _ _ _ _ KKMMM)$) % % % % % % %%%%%%%%% % % % % % % % % %%%%%%%%%%%%%%%%%%%sPGF>0 G CF> G%AF>% G>G GG GGGrct5}|5}t||}|rddi|cdddcdddS|dhdd}t d|d<t |d|}g}t |jd D]\} } | dd } | || d | d  | d| d <| d&| ddkr| dnd| d<| t |d| t||dddd||ddt|i| | ||dcdddcdddS#1swxYwY ddddS#1swxYwYdS)Nr{Trr|rSO signoff_codeshipment_signoffsr rr}) signoff_idrshipped_quantityrsigned_quantity sign_statussignedrshipment_signoff_linescreate_shipment_signoffrkrcrrrr)rGr)rrrxrr rTrrrmrrJrtrr) rWr[rZrrPrr5rrrrrs rrrs: >> S S T OOHOMM   s!K!KLLL==!344<4=j4II01==!233;LUMMZgLhLhltLtLt9Z3H3Hz{I/0-Ey Q QRRRR 3m?Xdlu~NamwAHASASY_ASA`A`nz|@H|I|ImJ\k l l l l KKMMM$(;;% < < < < < < <<<<<<<<< < < < < < < < < <<<<<<<<<<<<<<<<<< 0 THEN 'shortage' WHEN difference_supplier_minus_demand > 0 THEN 'surplus' ELSE 'balanced' END, jsonb_build_object( 'project_id', project_id, 'product_name', product_name, 'generated_from', 'v_supplier_vs_upstream_reconciliation_live' ) FROM v_supplier_vs_upstream_reconciliation_live z run_reconciliationrnrcrr)rGr) rrrrrxr rrTrNrowcountrtr) rWr[rZr5rrrPrrun_datar paramsproject_filterrs rr r s   4h  ? ?D,''J 2rs""""""----------$$$$$$ OOOO    %%%%(pt#'$tx'+4      F&&&&Y] % % % % % %]a%%%%%%,fj%%%%%%4jn!\!\!\!\!\!\Hgk%%%%%%8nr<<<<<<.nr % % % % % %ko6<6<6<6<6<6<6<6