gaoluyang
6 天以前 e40a608ef9bf51db294d8eefada6a8e2e80cebca
1
2
3
4
5
6
7
8
9
import sys,json
from pathlib import Path
sys.stdout.reconfigure(encoding='utf-8')
sys.path.insert(0,str(Path(__file__).resolve().parents[1]/'iqc-import-20261012/deps'))
import pymysql
with pymysql.connect(host='36.213.150.237',port=10000,user='root',password=sys.stdin.readline().strip(),database='mom-hm',charset='utf8mb4',connect_timeout=15,cursorclass=pymysql.cursors.DictCursor) as c:
    with c.cursor() as q:
        for sql in ['SELECT DATABASE() db', 'SELECT period_type,period_value,status,deleted,COUNT(*) count FROM crm_sales_target GROUP BY period_type,period_value,status,deleted ORDER BY period_type,period_value', "SELECT * FROM crm_sales_target WHERE deleted=0 AND period_type=1 AND period_value='2026'", 'SELECT COUNT(*) count FROM crm_sales_target WHERE deleted=0', "SELECT COUNT(*) count FROM crm_customer WHERE deleted=0 AND create_time>='2026-01-01' AND create_time<'2027-01-01'"]:
            q.execute(sql);print(json.dumps(dict(sql=sql,rows=q.fetchall()),ensure_ascii=False,default=str))