_probe_s3_seed.py 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738
  1. #!/usr/bin/env python3
  2. import json, pymysql
  3. T=797403760988229
  4. conn=pymysql.connect(host='123.60.180.165',port=3306,user='aidopremote',password='1234567890aiDOP#',database='aidopdev',charset='utf8mb4',cursorclass=pymysql.cursors.DictCursor)
  5. out={}
  6. with conn.cursor() as c:
  7. c.execute("SELECT COUNT(*) c FROM srm_purchase WHERE tenant_id=%s AND IFNULL(IsDeleted,0)=0", (T,))
  8. out['srm_purchase']=c.fetchone()['c']
  9. c.execute("SELECT number,supplier_number,quota_rate,is_active FROM srm_purchase WHERE tenant_id=%s LIMIT 5", (T,))
  10. out['purchase_sample']=c.fetchall()
  11. c.execute("""
  12. SELECT d.ItemNum, m.PurOrd, m.Buyer, m.USAGE,
  13. IFNULL(d.QtyOrded,0)-IFNULL(d.RctQty,0) open_qty
  14. FROM PurOrdDetail d
  15. JOIN PurOrdMaster m ON m.RecID=d.PurOrdRecID
  16. WHERE m.tenant_id=%s AND IFNULL(m.Status,'')<>'C'
  17. AND (IFNULL(d.QtyOrded,0)-IFNULL(d.RctQty,0))>0
  18. LIMIT 8""", (T,))
  19. out['po_lines']=c.fetchall()
  20. c.execute("SELECT ItemNum, PurMfg FROM ItemMaster WHERE tenant_id=%s AND PurMfg='P' LIMIT 5", (T,))
  21. out['pur_items']=c.fetchall()
  22. for it in ['3152C0064','112AB6752','1A00D33','PO-UAT-20260604-01']:
  23. c.execute('SELECT number,quota_rate,is_active,supplier_number FROM srm_purchase WHERE tenant_id=%s AND number=%s LIMIT 2',(T,it))
  24. out[f'sp_{it}']=c.fetchall()
  25. c.execute('SELECT ItemNum,PurMfg FROM ItemMaster WHERE ItemNum=%s LIMIT 1',(it,))
  26. out[f'im_{it}']=c.fetchone()
  27. c.execute("""
  28. SELECT sp.number AS itemnum, COUNT(*) po_cnt
  29. FROM srm_purchase sp
  30. INNER JOIN PurOrdDetail d ON d.ItemNum = sp.number
  31. INNER JOIN PurOrdMaster m ON m.RecID=d.PurOrdRecID AND m.tenant_id=%s
  32. WHERE sp.tenant_id=%s AND IFNULL(sp.quota_rate,0)>0 AND IFNULL(sp.IsDeleted,0)=0
  33. AND IFNULL(m.Status,'')<>'C' AND (IFNULL(d.QtyOrded,0)-IFNULL(d.RctQty,0))>0
  34. GROUP BY sp.number ORDER BY po_cnt DESC LIMIT 10
  35. """, (T,T))
  36. out['intersection']=c.fetchall()
  37. conn.close()
  38. print(json.dumps(out, ensure_ascii=False, indent=2, default=str))