小程序修改

2026-07-12 19:44:36 +08:00
parent 3b4833b51a
commit e2dfb08de3
45 changed files with 2028 additions and 347 deletions
@@ -0,0 +1,79 @@
+import type { ClientRuntimeConfig, WechatJsapiPrepayParams, WechatLoginResult, WechatPayOrderResult } from '@dukang/shared-types';
+import { WECHAT_AUTH_REQUIRED, isWxAuthorizeEnabled } from '@dukang/shared-types';
+import { invokeWechatPay } from '@dukang/weixin-sdk';
+import Taro from '@tarojs/taro';
+import { request, type UserProfile } from './api';
+import { syncMiniWechatProfile } from './mini-wechat-profile';
+
+export function isMiniWechatEnv(): boolean {
+  return process.env.TARO_ENV === 'weapp';
+}
+
+export function isWechatAuthRequiredError(err: unknown): boolean {
+  return err instanceof Error && err.message === WECHAT_AUTH_REQUIRED;
+}
+
+export async function fetchClientConfig(): Promise<ClientRuntimeConfig> {
+  return request<ClientRuntimeConfig>('/common/client-config');
+}
+
+export async function fetchUserProfile(): Promise<UserProfile> {
+  return request<UserProfile>('/auth/me');
+}
+
+/** 真实微信支付且未绑定微信时需要授权 */
+export function needsWechatAuthForPay(
+  config: ClientRuntimeConfig,
+  profile: UserProfile | null,
+): boolean {
+  if (!isWxAuthorizeEnabled(config)) return false;
+  return !config.mockPay && config.wechatPayEnabled && isMiniWechatEnv() && !profile?.hasWechat;
+}
+
+function sleep(ms: number) {
+  return new Promise((resolve) => setTimeout(resolve, ms));
+}
+
+export async function waitOrderPaid(orderId: string, maxAttempts = 15): Promise<boolean> {
+  for (let i = 0; i < maxAttempts; i += 1) {
+    const order = await request<{ payStatus?: string }>(`/trade/orders/${orderId}`);
+    if (order.payStatus === 'PAID') return true;
+    await sleep(2000);
+  }
+  return false;
+}
+
+export async function payOrder(orderId: string): Promise<'paid' | 'pending'> {
+  const result = await request<WechatPayOrderResult>(`/trade/orders/${orderId}/pay`, {
+    method: 'POST',
+  });
+
+  if (result.mode === 'jsapi' && result.prepay) {
+    await invokeWechatPay(result.prepay as WechatJsapiPrepayParams);
+    const paid = await waitOrderPaid(orderId);
+    return paid ? 'paid' : 'pending';
+  }
+
+  return 'paid';
+}
+
+export type WechatBindResult =
+  | { ok: true; profile?: UserProfile }
+  | { ok: false; needBindPhone: true; wxSessionKey: string };
+
+export async function bindWechatForUser(): Promise<WechatBindResult> {
+  const res = await Taro.login();
+  if (!res.code) {
+    throw new Error(res.errMsg || '微信授权失败');
+  }
+  const data = await request<WechatLoginResult>('/auth/wechat/bind', {
+    method: 'POST',
+    data: { code: res.code, platform: 'mini' },
+  });
+  if (data.needBindPhone && data.wxSessionKey) {
+    return { ok: false, needBindPhone: true, wxSessionKey: data.wxSessionKey };
+  }
+  await syncMiniWechatProfile();
+  const profile = await fetchUserProfile();
+  return { ok: true, profile };
+}