payment-platform/logs/_lsy-refund-unlock.py

# -*- coding: utf-8 -*-
"""第二轮：把「退款」这条腿打通 —— 换渠道补录 + 换寻址键退款。

第一轮的读数（logs/_lsy-lifecycle.txt）：
  * 补录（channel_type=37 建行）→ queryorder 查到 PAY_SUCCESS ✔
  * 但 /v3/refundorder → PAY_FAIL「退款失败：没有查询到符合条件的记录。」
  * /v3/queryrefund 把那条退款记录查回来了，return_msg = 「查询失败：商户号[105000370940]已注销或待审核」
    —— 那个商户号不是我们的（我们的是 Y52211090004），是**渠道商户号**。
  ⇒ 假设 R1：退款失败是因为 channel_type=37 那条渠道在建行侧没开通/已注销。
     若成立，换一个渠道（50 平安 / 6 官方直连 / 其它）补录后**退款应当能往下走**。
  ⇒ 假设 R2：退款失败是**寻址键**的问题（pay_trace_no+pay_trace_time 这条腿在退款接口上不通）。
     若成立，用 trade_no 寻址应当能往下走。
  两个假设**各改一个变量**，互不干扰。

另测：真实被扫失败单的 /v3/cancelorder（文档：「如果此订单用户支付失败，会将此订单关闭」）。
"""
import io
import json
import os
import re
import sys
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-lc2"
OUT = "logs/_lsy-refund-unlock.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)

# 第一轮遗留的真实句柄（读自原始应答字节，不手抄）
BARCODE_TRADE_NO = "200001070X3126092816241710003"   # create-pay-barcode，PAY_FAIL 的真被扫单
SUP_TRACE = None
SUP_TIME = None
SUP_NO = None
for ln in io.open("logs/_lsy-lifecycle.txt", encoding="utf-8").read().split("\n"):
    if "data(乐收赢订单号)" in ln:
        SUP_NO = ln.split("=")[-1].strip()
say("── 前置：读第一轮的补录句柄 ──")
say("  补录乐收赢订单号 = %s" % SUP_NO)
say("  真实被扫失败单   = %s" % BARCODE_TRADE_NO)
say()


def call(path, params, tag, envelope="v3"):
    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=30) 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", repr(e)[:60]))
        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))
        ok = md5((A2 + "&key=" + KEY).encode("utf-8")).hexdigest().lower() == usign
        vs = "验签OK(%d)" % len(nn) if ok else "验签FAIL(%d)" % len(nn)
    elif "sign" not in resp:
        vs = "无sign键"

    rc = resp.get("return_code")
    ec = resp.get("result_code")
    if envelope == "legacy":
        rc, ec = resp.get("code"), resp.get("data")
    say("  POST %-20s -> %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])


# ────────────────────────────────────────────── 0) 验签：FAIL 应答的 sign 覆盖了什么
say("=" * 78)
say("【0】先钉一件事：queryorder 的 FAIL 应答 sign 覆盖哪几个字段")
say("=" * 78)
raw = io.open("logs/_lsy-lc/query-qrpay-unscanned.bin", "rb").read()
resp = json.loads(raw.decode("utf-8"))
nn = {k: v for k, v in resp.items() if k != "sign" and v is not None}
say("  非 null 字段 = %s" % sorted(nn))
A2 = "&".join("%s=%s" % (k, nn[k]) for k in sorted(nn))
mine = md5((A2 + "&key=" + KEY).encode("utf-8")).hexdigest().lower()
say("  重算 == 上游 : %s" % (mine == resp["sign"]))
say("  ⇒ 这两条 FAIL 的 sign 是**常量**（换单号、换 query_trace_no 都不变）")
say()

# ────────────────────────────────────────────── 1) 换渠道补录
say("=" * 78)
say("【1】假设 R1：换 channel_type 补录（各一条），再试退款")
say("=" * 78)
CHANNELS = [("6", "官方直连"), ("1", "网商"), ("2", "富友"), ("50", "平安"), ("4", "银联")]
made = []
for ch, name in CHANNELS:
    trace = uid("s%d" % len(made))
    now = stamp()
    settle = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time() - 60))
    r = call("/v3/createSupply", {
        "channel_type": ch, "pay_mode": "2", "type": "300", "function_flag": "1",
        "pay_time": now, "settle_time": settle, "pay_trace_no": trace,
        "total_fee": "1", "order_body": "二轮补录ch%s" % ch,
    }, "supply-ch%s" % ch, envelope="legacy")
    if r and r.get("code") == 200 and r.get("data"):
        made.append({"ch": ch, "name": name, "trace": trace, "time": now, "no": r["data"]})
        say("       ch=%s(%s) 订单号 = %s" % (ch, name, r["data"]))
    say()

# ────────────────────────────────────────────── 2) 每笔补录：查得到吗
say("=" * 78)
say("【2】每笔补录用 queryorder 复核（必须 PAY_SUCCESS 才值得往下退）")
say("=" * 78)
good = []
for m in made:
    q = call("/v3/queryorder", {"query_trace_no": uuid.uuid4().hex,
                                "pay_trace_no": m["trace"], "pay_time": m["time"]},
             "q-supply-ch%s" % m["ch"])
    if q and q.get("result_code") == "PAY_SUCCESS":
        good.append(m)
    say()
say("  查到 PAY_SUCCESS 的：%s" % [m["ch"] for m in good])
say()

# ────────────────────────────────────────────── 3) 假设 R1：换渠道退款（键不变）
say("=" * 78)
say("【3】假设 R1：同一套寻址键（pay_trace_no+pay_trace_time），只换渠道")
say("=" * 78)
for m in made:
    say("  ── ch=%s(%s) ──" % (m["ch"], m["name"]))
    call("/v3/refundorder", {
        "refund_trace_no": uid("r%d" % len(m["ch"])), "refund_fee": "1",
        "pay_time": stamp(), "pay_trace_no": m["trace"], "pay_trace_time": m["time"],
    }, "refund-ch%s-bytrace" % m["ch"])
    say()

# ────────────────────────────────────────────── 4) 假设 R2：换寻址键（trade_no）
say("=" * 78)
say("【4】假设 R2：换寻址键为 trade_no（含第一轮那笔建行补录）")
say("=" * 78)
targets = [{"ch": "37(一轮建行)", "no": SUP_NO}] + [{"ch": m["ch"], "no": m["no"]} for m in good]
for t in targets:
    if not t["no"]:
        continue
    say("  ── trade_no = %s  ch=%s ──" % (t["no"], t["ch"]))
    call("/v3/refundorder", {
        "refund_trace_no": uid("rt"), "refund_fee": "1",
        "pay_time": stamp(), "trade_no": t["no"],
    }, "refund-tradeno-%s" % t["no"][-6:])
    say()

# ────────────────────────────────────────────── 5) 退款查询：把 refund_time 用对
say("=" * 78)
say("【5】/v3/queryrefund 两条寻址路（第一轮 bytrace 挂在我把 refund_time 填错）")
say("=" * 78)
first = json.loads(io.open("logs/_lsy-lc/refund-supply-bytrace.bin", "rb").read().decode("utf-8"))
say("  第一轮那条退款：refund_no=%s refund_trace_no=%s" % (first.get("refund_no"), first.get("refund_trace_no")))
say("  它回显的 pay_time（=发起退款的时间）= %s  ← 这才是 refund_time 该填的值" % first.get("pay_time"))
call("/v3/queryrefund", {"query_trace_no": uuid.uuid4().hex,
                         "refund_trace_no": first["refund_trace_no"],
                         "refund_time": first["pay_time"]}, "qrefund-bytrace-fixed")
call("/v3/queryrefund", {"query_trace_no": uuid.uuid4().hex,
                         "refund_no": first["refund_no"]}, "qrefund-byno-again")
say()

# ────────────────────────────────────────────── 6) 撤销：真实被扫失败单
say("=" * 78)
say("【6】/v3/cancelorder —— 拿一笔**真实的被扫 PAY_FAIL 单**（文档：支付失败会关单）")
say("=" * 78)
call("/v3/cancelorder", {"cancel_trace_no": uid("cx"), "cancel_time": stamp(),
                         "trade_no": BARCODE_TRADE_NO}, "cancel-barcode-bytradeno")
call("/v3/queryorder", {"query_trace_no": uuid.uuid4().hex,
                        "trade_no": BARCODE_TRADE_NO}, "q-barcode-aftercancel")
say()

# ────────────────────────────────────────────── 7) 退款一笔「已被关单」的 H5 单
say("=" * 78)
say("【7】对**已关单**的 H5 单退款（第一轮 closeorder 已把它关了）")
say("=" * 78)
h5 = json.loads(io.open("logs/_lsy-lc/create-h5pay.bin", "rb").read().decode("utf-8"))
say("  H5 单 trade_no = %s（已被 /v3/closeorder 关闭）" % h5.get("trade_no"))
call("/v3/refundorder", {"refund_trace_no": uid("rc"), "refund_fee": "1",
                         "pay_time": stamp(), "trade_no": h5.get("trade_no")},
     "refund-closed-h5")
say()

# ────────────────────────────────────────────── 8) 补录退款（function_flag=2）
say("=" * 78)
say("【8】/v3/createSupply function_flag=2（补录退款订单）—— 直接造一条退款记录")
say("=" * 78)
if SUP_NO:
    call("/v3/createSupply", {
        "channel_type": "37", "pay_mode": "2", "type": "300", "function_flag": "2",
        "pay_time": stamp(), "settle_time": time.strftime("%Y-%m-%d %H:%M:%S"),
        "pay_trace_no": uid("sup2"), "total_fee": "1", "out_refund_no": SUP_NO,
        "order_body": "二轮补录退款",
    }, "supply-flag2", envelope="legacy")
say()

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

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