+ xui^Rt^RIHt^RIt^RIt^RIHtRtRt] R8Xd ]!4R#R#)a! Merge duplicate parts where one record has part_number like PK- and another record has blank part_number for the same name. Keeps the blank-part-number row as canonical (usually has correct unit like 'pcs'), moves images from PK row, copies source_partkeepr_id, then deletes PK row. ) annotationsN) DictCursorc>\P!RR7pVPRRR7VPR\RR7VPRR R 7VPR RR7VPR RR7VPR RR7VP 4#)z2Reconcile PK-* duplicate parts in parts_inventory.) descriptionz--hostT)requiredz--porti )typedefaultz --databaseparts_inventory)rz--userz --passwordz --dry-run store_true)action)argparseArgumentParser add_argumentint parse_args)parsers @C:\Users\Bill\Software\Server\scripts\reconcile_pk_duplicates.pyrrs  $ $1e fF 40 sD9  .?@ 40  t4  L9    c \4p\P!VPVPVP VP VP\RR7p^p^pVP4;_uu_4pVPR4VP4pVEFpVR,pVR,pVPRWx34W4P, pVR,R9d VR,MVR,p VR ,'d VR ,MVR ,;'gR p VR ,e VR ,MVR ,p V eIVPRV34VPRWV34VP4p V 'd VR ,p VPRWW34VPRV34V^, pEK" RRR4VP'dVP4MVP!4\#RV RV RVP 24TP'4R# +'giLt;i \$dTP4hi;i TP'4i;i)F)hostportuserpassworddatabase cursorclass autocommitaU SELECT blank.id AS keep_id, blank.name, blank.part_number AS keep_part_number, blank.quantity AS keep_quantity, blank.unit AS keep_unit, blank.source_partkeepr_id AS keep_source_id, pk.id AS drop_id, pk.part_number AS drop_part_number, pk.quantity AS drop_quantity, pk.unit AS drop_unit, pk.source_partkeepr_id AS drop_source_id FROM parts blank JOIN parts pk ON pk.name = blank.name WHERE (blank.part_number IS NULL OR blank.part_number = '') AND pk.part_number LIKE 'PK-%' AND blank.id <> pk.id ORDER BY blank.id, pk.id keep_iddrop_idz6UPDATE part_images SET part_id = %s WHERE part_id = %s keep_quantityN drop_quantity keep_unit drop_unitkeep_source_iddrop_source_idz9UPDATE parts SET source_partkeepr_id = NULL WHERE id = %sz SELECT id FROM parts WHERE source_partkeepr_id = %s AND id NOT IN (%s, %s) LIMIT 1 a  UPDATE parts SET quantity = %s, unit = %s, source_partkeepr_id = %s, updated_at = CURRENT_TIMESTAMP WHERE id = %s zDELETE FROM parts WHERE id = %szReconcile complete: merged=z moved_images=z dry_run=)N)rpymysqlconnectrrrrrrcursorexecutefetchallrowcountfetchonedry_runrollbackcommitprint Exceptionclose) argsconnmerged moved_imagescurpairspairrrmerged_quantity merged_unit merged_source collisions rmainr>s. ?O:P:\%5 6bfgwbx !,KK [^e]ghKK '9!$ I (,-=(>  %=J  =zJ! Y3N <<< MMO KKM +F8>,yY]YeYeXfgh a]X    sD#I;B H/ H/"B!H/I?I/ H? :III""I4__main__) __doc__ __future__rr r&pymysql.cursorsrrr>__name__rrrEs8#&^B zFr