no message

src/biz/member/cost.ts

@@ -2,20 +2,77 @@
  * 收费
  */
 
-import { PAYMENTTYPE } from "../../config/enum";
+import { ORDERSTATE, PAYMENTTYPE } from "../../config/enum";
 import { TABLEENUM } from "../../data/models/model";
 import { findOnce } from "../../data/select";
 import { eccEnumValue } from "../../util/verificationEnum";
 import { update } from "../portal/fenZhiJiGou/jiGouGuanLi";
+import * as path from "path";
 const WxPay = require('wechatpay-node-v3');
 import * as fs from 'fs';
+import { BizError } from "../../util/bizError";
+import { ERRORENUM } from "../../config/errorEnum";
+import { generateWXOrderId } from "../../tools/system";
+import { updateOneData } from "../../data/update";
+import moment = require("moment");
 
+const AppId = 'wx96c0cf11b3babcf6';
+const MchId = '1614605859';
 const pay = new WxPay({
-    appid: 'wx96c0cf11b3babcf6',
-    mchid: '1614605859',
-    publicKey: fs.readFileSync('./apiclient_cert.pem'), // 公钥
-    privateKey: fs.readFileSync('./apiclient_key.pem'), // 秘钥
-  });
+    appid: AppId,
+    mchid: MchId,
+    publicKey: fs.readFileSync( path.join(__dirname.substring(0,__dirname.indexOf("out")), "keys", 'apiclient_cert.pem'  ) ), // 公钥
+    privateKey: fs.readFileSync(  path.join(__dirname.substring(0,__dirname.indexOf("out")), "keys", 'apiclient_key.pem'  ) ), // 秘钥
+});
+
+
+/**
+ * native下单接口【前端调用】
+ * @param param0 {id订单列表的id}
+ * @returns 
+ */
+export async function placeAnOrder({id}) {
+    let orderInfo = await findOnce(TABLEENUM.订单表, {id}, ["id", "loginId", "userId", "memberCategory", "money", "orderCycleStart", "orderCycleEnd"]);
+    if (!orderInfo || !orderInfo.id) throw new BizError(ERRORENUM.订单不存在);
+    if (orderInfo.state != ORDERSTATE.已支付) throw new BizError(ERRORENUM.该订单已支付);
+
+    /**生成 out_trade_no */
+    let out_trade_no = generateWXOrderId(orderInfo.memberCategory, orderInfo.userId);
+    let desc = `${orderInfo.loginId}_${moment(orderInfo.orderCycleStart).format("YYYY-MM-DD")}至${moment(orderInfo.orderCycleEnd).format("YYYY-MM-DD")}`;
+
+    await updateOneData(TABLEENUM.订单表, {id}, {weChartPR:out_trade_no, paymentMethod:PAYMENTTYPE.微信支付});
+    /**请求参数 */
+    const Param = {
+        appid: AppId,
+        mchid: MchId,
+        description:desc,
+        out_trade_no,//订单号
+        amount:{//金额
+            total:orderInfo.money
+        },
+        notify_url:'',//测试时先设置白名单地址
+    };
+    const result = await pay.transactions_native(Param);
+    if (result.status != 200) throw new BizError(ERRORENUM.调起微信支付失败);
+    return {code_url:result.code_url};
+}
+
+
+/**
+ * 订单查询状态【前端调用】
+ */
+export async function orderState({orderId}) {
+    const result = await pay.query({out_trade_no: '1609914303237'});
+}
+
+
+/**
+ * 关闭订单【前端调用】
+ */
+export async function orderClose() {
+
+}
+
 
 // var initConfig = {
 // partnerKey: "<partnerkey>",

src/config/errorEnum.ts

@@ -35,7 +35,9 @@ export enum ERRORENUM {
     用户已注册成功,
     不具备审批条件,
     该用户已在宽限期内,
-    该订单已支付
+    该订单已支付,
+    调起微信支付失败,
+    订单不存在
 }
 
 export enum ERRORCODEENUM {

src/tools/system.ts

@@ -77,8 +77,14 @@ export function generateOrderId(userId:string) {
  * 获取今天开始时刻的时间戳  0时0分
  * @returns 
  */
- export function getTodayMs() {
+export function getTodayMs() {
     return new Date(`${ moment().format("YYYY-MM-DD")} 00:00:00`).valueOf();
 }
 
 
+
+export function generateWXOrderId(memberType, userId) {
+    let thisDate = new Date();
+    return `${memberType}_${thisDate.getFullYear()}_${md5(`${userId}${Math.random() * 100}${thisDate.valueOf()}${Math.floor(Math.random() * 1000)}`)}`
+}
+