payment-platform/logs/_lsy-round3.py

# -*- coding: utf-8 -*-
"""第三轮：① 平安(50)渠道的退款解锁重试；② 关单腿铺开；③ 若干收尾读数。

第二轮遗留：
  * supply-ch50 建单成功（200001070J1226092816253210006）但**查询超时** —— 量具失效，
    不是负读数，必须重跑。
  * /v3/cancelorder 对真实被扫失败单回「暂不支持撤销！」（sign 有效）—— 待确认是不是
    只对这一笔/这一个渠道成立。
"""
import io
import json
import os
import re
import time
import uuid
import urllib.error
import urllib.request
from hashlib import md5

YML = "java/src/main/resources/application.yml"
VAR = re.compile(r"^\$\{([A-Za-z0-9_]+):(.*)\}$")
OUTDIR = "logs/_lsy-lc3"
OUT = "logs/_lsy-round3.txt"
buf = []
rows = []


def say(s=""):
    buf.append(s)
    print(s.encode("ascii", "replace").decode())


def read_block(path, top):
    lines = io.open(path, encoding="utf-8", errors="replace").read().split("\n")
    start = None
    for i, ln in enumerate(lines):
        if re.match(r"^%s:\s*$" % re.escape(top), ln):
            start = i
            break
    if start is None:
        raise SystemExit("找不到顶层段 %s:" % top)
    out = {}
    for j in range(start + 1, len(lines)):
        ln = lines[j]
        if ln.strip() == "" or ln.lstrip().startswith("#"):
            continue
        if not ln.startswith((" ", "\t")):
            break
        m = re.match(r"^\s+([A-Za-z0-9_.\-]+):\s*(.*)$", ln)
        if m:
            out[m.group(1)] = re.split(r"\s+#", m.group(2), maxsplit=1)[0].strip().strip("'\"")
    return out


def resolve(raw):
    m = VAR.match(raw)
    if not m:
        return raw
    return os.environ.get(m.group(1)) or m.group(2)


cfg = read_block(YML, "leshouying")
BASE = resolve(cfg["base-url"]).rstrip("/")
INST = resolve(cfg["inst-no"])
KEY = resolve(cfg["key"])
MCH = "Y52211090004"
if not os.path.isdir(OUTDIR):
    os.makedirs(OUTDIR)


def call(path, params, tag, envelope="v3", timeout=60):
    p = dict(params)
    p.setdefault("inst_no", INST)
    p.setdefault("mch_no", MCH)
    A = "&".join("%s=%s" % (k, p[k]) for k in sorted(p) if p[k] is not None)
    p["sign"] = md5((A + "&key=" + KEY).encode("utf-8")).hexdigest().lower()
    body = json.dumps(p, ensure_ascii=False).encode("utf-8")
    req = urllib.request.Request(BASE + path, data=body,
                                 headers={"Content-Type": "application/json;charset=utf-8"},
                                 method="POST")
    try:
        with urllib.request.urlopen(req, timeout=timeout) as r:
            code, raw = r.status, r.read()
    except urllib.error.HTTPError as e:
        code, raw = e.code, e.read()
    except Exception as e:  # noqa: BLE001
        say("  !! 未完成 %s: %r  ← 量具失效，不是上游回答" % (tag, e))
        rows.append((tag, path, "TRANSPORT_ERR", "量具失效"))
        return None
    io.open("%s/%s.bin" % (OUTDIR, tag), "wb").write(raw)
    try:
        resp = json.loads(raw.decode("utf-8"))
    except Exception:  # noqa: BLE001
        rows.append((tag, path, "NON_JSON", "%d B" % len(raw)))
        return None
    usign = resp.get("sign")
    vs = "sign=null"
    if usign:
        nn = {k: v for k, v in resp.items() if k != "sign" and v is not None}
        A2 = "&".join("%s=%s" % (k, nn[k]) for k in sorted(nn))
        vs = ("验签OK(%d)" % len(nn)
              if md5((A2 + "&key=" + KEY).encode("utf-8")).hexdigest().lower() == usign
              else "验签FAIL(%d)" % len(nn))
    elif "sign" not in resp:
        vs = "无sign键"
    rc, ec = resp.get("return_code"), resp.get("result_code")
    if envelope == "legacy":
        rc, ec = resp.get("code"), resp.get("data")
    say("  POST %-22s -> %4d B  rc=%s ec=%s  %s" % (path, len(raw), rc, ec, vs))
    say("       msg = %s" % (resp.get("return_msg") or resp.get("message")))
    rows.append((tag, path, "%s/%s" % (rc, ec),
                 "%s; %s" % (str(resp.get("return_msg") or resp.get("message"))[:44], vs)))
    return resp


def stamp():
    return time.strftime("%Y%m%d%H%M%S")


def uid(p):
    return "%s%s%s" % (p, time.strftime("%H%M%S"), uuid.uuid4().hex[:6])


# 从第二轮原始字节里读句柄，不手抄
ch50 = json.loads(io.open("logs/_lsy-lc2/supply-ch50.bin", "rb").read().decode("utf-8"))
CH50_NO = ch50["data"]
ch37_no = "200001070J1226092816241610001"
BARCODE = "200001070X3126092816241710003"
H5_CLOSED = "200001070X4326092816241610002"

say("句柄（均读自原始应答字节）")
say("  ch50(平安) 补录单 = %s" % CH50_NO)
say("  ch37(建行) 补录单 = %s" % ch37_no)
say("  真实被扫失败单     = %s" % BARCODE)
say("  已关单的 H5        = %s" % H5_CLOSED)
say()

# ─────────────────────────────── 1) 平安渠道：查询 + 退款
say("=" * 78)
say("【1】平安(50)渠道的补录单 —— 查询（第二轮超时，重跑）")
say("=" * 78)
q = call("/v3/queryorder", {"query_trace_no": uuid.uuid4().hex, "trade_no": CH50_NO},
         "q-ch50-bytradeno")
say()
say("【1b】对它退款（先 trade_no 寻址）")
call("/v3/refundorder", {"refund_trace_no": uid("p5"), "refund_fee": "1",
                         "pay_time": stamp(), "trade_no": CH50_NO}, "refund-ch50-tradeno")
say()

# ─────────────────────────────── 2) 关单腿铺开
say("=" * 78)
say("【2】关单：/v3/closeorder 全路径（我方**未实现**这个端点）")
say("=" * 78)
t, pt = uid("h5c"), stamp()
h5 = call("/v3/h5pay", {"pay_trace_no": t, "pay_time": pt, "total_amount": "1",
                        "pay_type": "300", "order_body": "三轮-关单用H5"}, "h5-for-close")
NEW_H5 = h5.get("trade_no") if h5 else None
say("  新 H5 trade_no = %s" % NEW_H5)
say()

if NEW_H5:
    call("/v3/closeorder", {"close_trace_no": uid("k1"), "close_time": stamp(),
                            "trade_no": NEW_H5}, "co-h5-1st")
    call("/v3/closeorder", {"close_trace_no": uid("k2"), "close_time": stamp(),
                            "trade_no": NEW_H5}, "co-h5-2nd-幂等")
    call("/v3/queryorder", {"query_trace_no": uuid.uuid4().hex, "trade_no": NEW_H5},
         "q-h5-afterclose")
say()

# 关单：两个键都不发
call("/v3/closeorder", {"close_trace_no": uid("k3"), "close_time": stamp()}, "co-nokey")
# 关单：被扫单（文档说 closeorder 只用于二维码/JSAPI）
call("/v3/closeorder", {"close_trace_no": uid("k4"), "close_time": stamp(),
                        "trade_no": BARCODE}, "co-barcode")
# 关单：已关过的老 H5
call("/v3/closeorder", {"close_trace_no": uid("k5"), "close_time": stamp(),
                        "trade_no": H5_CLOSED}, "co-oldh5-again")
# 关单：不存在的单
call("/v3/closeorder", {"close_trace_no": uid("k6"), "close_time": stamp(),
                        "trade_no": "200001070X9999999999999999999"}, "co-nonexistent")
say()

# ─────────────────────────────── 3) 已关单的 H5 还能查到吗
say("=" * 78)
say("【3】已关单的 H5 在 queryorder 里是什么样")
say("=" * 78)
call("/v3/queryorder", {"query_trace_no": uuid.uuid4().hex, "trade_no": H5_CLOSED}, "q-oldh5-closed")
say()

# ─────────────────────────────── 4) 退款：真实被扫失败单 / 不存在单
say("=" * 78)
say("【4】退款错误路径补齐")
say("=" * 78)
call("/v3/refundorder", {"refund_trace_no": uid("rb"), "refund_fee": "1",
                         "pay_time": stamp(), "trade_no": BARCODE}, "refund-barcode-unpaid")
call("/v3/refundorder", {"refund_trace_no": uid("rz"), "refund_fee": "1",
                         "pay_time": stamp(), "trade_no": "200001070X9999999999999999999"},
     "refund-bogus-tradeno")
say()

# ─────────────────────────────── 5) 撤销：再试一笔，确认「暂不支持」是不是普遍
say("=" * 78)
say("【5】撤销：换一笔再试（判「暂不支持撤销」是这一笔的还是普遍的）")
say("=" * 78)
t2, p2 = uid("bc2"), stamp()
bc = call("/v3/pay", {"pay_trace_no": t2, "pay_time": p2, "total_amount": "1",
                      "auth_code": "284812345678901234", "pay_type": "300",
                      "order_body": "三轮-撤销用被扫"}, "barcode-for-cancel")
if bc and bc.get("trade_no"):
    say("  新被扫单 trade_no = %s" % bc["trade_no"])
    call("/v3/cancelorder", {"cancel_trace_no": uid("c2"), "cancel_time": stamp(),
                             "trade_no": bc["trade_no"]}, "cancel-barcode-2nd")
    call("/v3/cancelorder", {"cancel_trace_no": uid("c3"), "cancel_time": stamp(),
                             "pay_trace_no": t2, "pay_time": p2}, "cancel-barcode-bytrace")
say()

say("=" * 78)
say("汇总（%d 条）" % len(rows))
say("=" * 78)
say("%-28s %-22s %-20s %s" % ("tag", "path", "rc/ec", "note"))
for t_, p_, v, d in rows:
    say("%-28s %-22s %-20s %s" % (t_, p_, v, d))

io.open(OUT, "w", encoding="utf-8").write("\n".join(buf) + "\n")
print("report -> %s" % OUT)