Paozhu 重构了webpay模块 公网测试了支付宝支付 微信v2, v3版支付，小程序支付。网站使用 微信native支付 无需年费，应用于低频次支付场景。

Paozhu 已经是金丹修为的框架，提供了完善了web开发，而无需依赖第三方。

配置参考 conf/webpay.conf 配置文件

# 演示数据，需要你填入你真正的数据

# 微信支付 V2（jscode2session / access_token / JSAPI / Native XML 接口）

[wxpayv2]

appid = wx21222334444

mch_id = 11145678901

apikey = zI8wF8cI3k78uB8uZ2oB6lZ9gB2bL5bO

secret = 379c869abc23a35849663ea9d5bc7b69

cert_file = conf/apiclient_cert.pem

key_file = conf/apiclient_key.pem

notifyurl = https://www.xxx.net/ordernotify

# 微信支付 V3（Native / JSAPI 等 v3 接口）

# ⚠️ 换商户时 cert_file / key_file / v3_serial_no 三项必须全部替换

[wxpayv3]

appid = wx21222334444

mch_id = 11145678901

api_v3_key = 1122334455_need32char

cert_file = conf/apiclient_cert.pem

key_file = conf/apiclient_key.pem

notifyurl = https://www.xxx.net/ordernotify

v3_serial_no = 6F245450E065994D48A99A6987BE9B54286F2D1A

platform_cert_file =

填上自己的财付通信息

[sitea.alipay]

appid = xxx-sitea-alipay-appid

key_file = conf/sitea应用私钥RSA2048.txt

public_key_file = conf/sitea支付宝公钥RSA2.txt

notifyurl = https://www.site-a.com/alipaynotify

returnurl = https://www.site-a.com/alipayreturn

sandbox = 0

阿里支付宝支付配置信息，支持跳转阿里支付控制台或者本页扫描支付，微信只有本页扫描支付。

// 电脑网站支付的「前置模式」：告诉网关"这一版页面我要嵌在自己页里"，让它吐二维码区而不是

// 整页收银台。模式编号语义官方文档页取不到 ⇒ 以网关行为为准，mode 原样透传不校验，

// 并把实际出网的串回显在页面上——"发没发这个键"不该靠翻代码确认。

// /testalipayfront 默认档（mode=4 & width 由网关自己定）

// /testalipayfront?mode=0|1|3|4 四档对照

// /testalipayfront?mode=4&width=300 模式 4 的宽度

// /testalipayfront?mode=none 对照档：一个键都不发

//@urlpath(null,testalipayfront)

asio::awaitable<std::string> test_alipay_front(std::shared_ptr<httppeer> peer)

{

httppeer &client = peer->get_peer();

client.type("text/html; charset=UTF-8");

#ifdef ENABLE_WEBPAY

std::string mode = client.get["mode"].to_string();

std::string width = client.get["width"].to_string();

if (mode.empty()) mode = "4";

const bool front = (mode != "none");

if (!front) width.clear();

std::string out_trade_no = get_date("%Y%m%d%H%M%S") + rand_string(4, 4);

pay::alipay apay;

std::string cfgmsg;

if (!webpay::alipay_fill(apay, kPayTag, cfgmsg))

{

client.output = cfgmsg;

co_return "";

}

apay.setOutTradeNo(out_trade_no);

apay.setSubject("测试商品");

apay.setBody("测试商品描述");

apay.setTotalAmount("0.01");

if (front)

{

apay.setQrPayMode(mode);

if (!width.empty()) apay.setQrcodeWidth(width);

}

std::string pay_url = apay.createTradePage();

// buildRequest() 把出网那一串（值已 percent 编码）留在 last_request_body_ 里；

// qr_pay_mode 这类键名本身是 ASCII，编码前后长得一样，所以直接按字面找就是"发没发"的读数。

const std::string sent = apay.lastRequestBody();

const bool sent_mode = (sent.find("qr_pay_mode") != std::string::npos);

const bool sent_width = (sent.find("qrcode_width") != std::string::npos);

std::string sent_note = "前置模式档 " + html_encode(mode)

+ " qrcode_width " + html_encode(width.empty() ? "(不发)" : width)

+ "<br>出网串里含 <b>qr_pay_mode</b>：" + (sent_mode ? "是" : "<b>否</b>")

+ " 含 <b>qrcode_width</b>：" + (sent_width ? "是" : "否")

+ " 串长 " + std::to_string(sent.size()) + " 字节"

+ "<details><summary>出网那一串原文（gateway.do? 之后，含 sign）</summary><pre>"

+ html_encode(sent) + "</pre></details>";

std::string insrep;

unsigned int oid = co_await tal_order_insert_async(out_trade_no, "0.01", "测试商品", "测试商品描述", client.client_ip, &insrep);

// 高度按档给：前置模式那一版只有二维码区，780px 会剩一大片空白，看着像"没渲染出来"；

// none 档装的是整页收银台，得留够高度。

std::string frame_style = "width:100%;height:" + std::string(front ? "520px" : "780px")

+ ";border:1px solid #bbb";

if (oid == 0)

{

// 闸门：库里没这一行 ⇒ 不内嵌收银台（那一格里钱付出去就没账可对）。

// 出网串读数照打：它是本地签名的结果，跟库连不连得上无关。

client.output = "<!DOCTYPE html><html><head><meta charset=\"utf-8\">"

"<title>支付宝前置模式：未下单</title></head><body>"

"<p><b>存根写入失败</b>：订单没写进 cms.orderlist，这一页没有内嵌收银台。</p>"

"<p style=\"font-size:13px\">" + sent_note + "</p>"

"<p style=\"font-size:12px\">" + insrep + "</p></body></html>";

co_return "";

}

client.output = tal_paypage_embed(pay_url, out_trade_no, oid, insrep, sent_note, frame_style);

#else

client.output = "{\"code\":\"-1\",\"msg\":\"ENABLE_WEBPAY not enabled\"}";

#endif

co_return "";

}

四个演示和简单订单管理再controller/src目录，订单管理文件在libs/webpay目录

controller/src/test_alipay.cpp

controller/src/test_wxpay.cpp

自己写业务代码时候可以按需剪裁移植。

这次狂添加了　MQTT 模块

方便物联网场景使用，其它也可以使用MQTT。

mqtt目录上服务器端程序 ，客户端在 controller/src目录 test_mqtt_client.cpp 文件

//@urlpath(null, test_mqtt_client)

asio::awaitable<std::string> test_mqtt_client(std::shared_ptr<httppeer> peer)

{

httppeer &cp = peer->get_peer();

mqtt_client_config_t cfg1;

cfg1.client_id = "mydevice@@@group-device";

cfg1.clean_start = true;

cfg1.keepalive = 60;

cfg1.receive_maximum = 65535;

auto r1 = co_await run_one_case("Case1_B4_no_local", cfg1);

mqtt_client_config_t cfg2 = cfg1;

cfg2.client_id = "mydevice@@@"; // reg_key=mydevice group=empty device=empty

auto r2 = co_await run_one_case("Case2_parse_client_id_reg_only", cfg2);

mqtt_client_config_t cfg3 = cfg1;

cfg3.client_id = "mydevice@@@rm-client";

cfg3.receive_maximum = 8; // less than server policy 16 → server still advertises its own policy 16 (no longer min with client value)

auto r3 = co_await run_one_case("Case3_S1_rm8", cfg3);

auto dump = [](const case_result &r) -> std::string

{

std::string s = std::string("=== ") + r.name + " ===\n";

s += " connected_=" + std::to_string((int)r.connected_) +

" rc=" + std::to_string(static_cast<int>(r.connack_rc)) +

" err=" + std::to_string((int)r.iserror);

if (!r.error_msg.empty())

s += " (" + r.error_msg + ")";

s += "\n session_present=" + std::to_string((int)r.session_present);

s += " server_receive_maximum=" + std::to_string(r.server_receive_maximum);

s += "\n run_loop_fun=" + std::to_string(r.recv.size());

if (!r.recv.empty())

for (auto &p : r.recv) s += " [" + p.topic + "]";

s += "\n received_window_empty=" + std::to_string((int)r.received_window_empty) +

" (hook installed, should be 1)";

s += "\n";

return s;

};

std::string summary = dump(r1) + dump(r2) + dump(r3);

summary += "\n=== Verification Summary ===\n";

summary += "B3 empty Client ID: " + std::string((int)r2.connack_rc == 0 ? "PASS" : "FAIL") +

" (rc=" + std::to_string(static_cast<int>(r2.connack_rc)) + ")\n";

summary += "S1 receive_max: " + std::string(r3.server_receive_maximum == 16 ? "PASS (server advertises its own policy 16)" : "FAIL") +

" (server_rm=" + std::to_string(r3.server_receive_maximum) + ", expect 16)\n";

summary += "B4 No Local: " + std::string(r1.recv.empty() ? "PASS" : "FAIL (loopbacks received)") +

" (" + std::to_string(r1.recv.size()) + " loopbacks)\n";

// All three cases install run_loop_fun and the "no message should land"

// semantics of no_local makes the empty window check toothless here.

// For real evidence see /test_mqtt_tick_push, which installs the same hook

// but actually receives 5 messages and checks received in the callback.

summary += "hook installed, no window writes: — (this group produces zero delivered messages, reading is meaningless; see /test_mqtt_tick_push)\n";

cp.output = make_html("MQTT 5 Client Test — B3 + S1 + B4", summary);

co_return "";

}

目前MQTT支持V5版本

http2流量控制目前已经是第四次重构了

ORM添加原生rawsql语句查询支持。

其它可以参考官方地址

https://github.com/hggq/paozhu/