pinyin

src/api/pinyin/pinyinController.js

@@ -0,0 +1,459 @@
+import moment from 'moment';
+import dataUpdateStatus from '../../model/dataUpdateStatus.js';
+import pinyin from '../../model/pinyin.js';
+import config from '../../config/index.js';
+import _ from 'lodash';
+import axios from 'axios';
+import { Encrypt, Decrypt } from '../../util/crypto/index.js';
+import { stringUtils } from '../../util/stringClass.js';
+import WXBizDataCrypt from '../../util/WXBizDataCrypt.js';
+import { globalCache } from '../../util/GlobalCache.js';
+
+export async function PinyinLogin(ctx) {
+    let param = ctx.request.body;
+    if (param.param) {
+        const paramStr = Decrypt(param.param, config.urlSecrets.aes_key, config.urlSecrets.aes_iv);
+        //console.log("paramStr:"+paramStr);
+        param = JSON.parse(paramStr);
+    }
+    const code = param.Code;
+    //console.log("code:"+code);
+    const url = `https://api.weixin.qq.com/sns/jscode2session?appid=${config.wx.pinyin_appid}&secret=${config.wx.pinyin_appsecret}&js_code=${code}&grant_type=authorization_code`;
+
+    let result = await axios.get(url)
+        .then(res => {
+            const json = res.data;
+            //console.log("json:"+json);
+            if (json && json.openid) {
+                param.OpenID = json.openid;
+                param.sessionKey = json.session_key;
+                if (json.unionid)
+                    param.UnionID = json.unionid;
+                return {errcode: 10000};
+            }
+            else {
+                return json;
+            }
+        })
+        .catch(err => {
+            return {errcode: 101, errStr: err};
+        });
+
+    if (result.errcode == 10000) {
+        delete param.Code;
+        if (param.sessionKey && param.iv && param.encryptedData){
+            //console.log("param.sessionKey:"+param.sessionKey);
+            const pc = new WXBizDataCrypt(config.wx.phonics_appid, param.sessionKey);
+            const dataUnionID = pc.decryptData(param.encryptedData , param.iv);
+            //console.log(dataUnionID);
+            param.UnionID = dataUnionID.unionId;
+        }
+
+        delete param.sessionKey;
+        delete param.iv;
+        delete param.encryptedData;
+
+        //todo
+        //param.OpenID="o4UHq4gaNlHfdTWxgl3fTgC1mFsI";
+
+        let userList = await pinyin.GetUsersInfo(param);
+        if (userList.length > 0) {
+            param.LastLoginTime = new Date();
+            const time1 = moment(userList[0].ProductServiceTime).format('YYYY-MM-DD HH:mm:ss');
+            const time3 = moment().format('YYYY-MM-DD HH:mm:ss');
+            if (time1 < time3)
+                param.IsMember = 0;
+
+            delete param.Introducer;
+            delete param.UserSource;
+            delete param.SourceID;
+            //console.log(param.NickName);
+            if (param.NickName == "陌生用户") {
+                delete param.NickName;
+                delete param.AvatarUrl;
+                delete param.Language;
+                delete param.Gender;
+                delete param.City;
+                delete param.Province;
+                delete param.Country;
+            }
+
+            await pinyin.UpdateUsers(param);
+            userList = await pinyin.GetUsersInfo(param);
+        }
+        else {
+            param.NickName = "陌生用户";
+            param.AvatarUrl = "../images/userface_default.png";
+            param.CreateTime = new Date();
+            param.LastLoginTime = param.CreateTime;
+            param.ProductServiceTime = param.CreateTime;
+            const inseredID = await pinyin.AddUsers(param);
+            userList = await pinyin.GetUsersInfo(param);
+        }
+
+        delete userList[0].OpenID;
+        delete userList[0].UnionID;
+
+        result = {errcode: 10000, result: userList[0]};
+    }
+
+    ctx.body = result;
+}
+
+//新增拼音记录
+export async function AddPinyinRecord(ctx) {
+    const param = ctx.request.body;
+    const inseredID = await pinyin.AddPinyinRecord(param);
+
+    ctx.body = {errcode: 10000, result: inseredID};
+}
+
+//更新拼音记录
+export async function UpdatePinyinRecord(ctx) {
+    const param = ctx.request.body;
+    await pinyin.UpdatePinyinRecord(param);
+    ctx.body = {errcode: 10000};
+}
+
+//得到用户记录
+export async function GetPinyinRecordData(ctx) {
+    const param = {
+        UserID: ctx.query.UserID || 0,
+        Version: ctx.query.Version || "1.0.0",
+    };
+    if (param.UserID === "undefined")
+        param.UserID = 0;
+
+    const result = await pinyin.GetPinyinRecordData(param);
+
+    if (param.UserID > 0 && result && result.length > 0) {
+        const userList = await pinyin.GetUsersInfoByUserID(param);
+
+        //是否是首日
+        const timeCreateTime = moment(userList[0].CreateTime).format('YYYYMMDD');
+        const timeToday = moment().format('YYYYMMDD');
+        if (timeCreateTime === timeToday)
+            result[0].IsFirstDay = true;
+        else
+            result[0].IsFirstDay = false;
+
+        const a = moment(userList[0].CreateTime);
+        const b = moment();
+        result[0].DayNumber = b.diff(a, 'days') + 1;
+
+        //得到分享新增用户数
+        let productServiceTime = moment(userList[0].ProductServiceTime).format('YYYYMMDD');
+        if (productServiceTime === "20991231") {
+            result[0].NewUserNumber = 999999;
+        }
+        else {
+            const newUserNumber = await pinyin.GetNewUserByUserID(param);
+            if (newUserNumber) {
+                result[0].NewUserNumber = newUserNumber.length;
+                //console.log("userList[0].ActivityTime:"+userList[0].ActivityTime);
+
+                productServiceTime = moment(userList[0].ProductServiceTime).format('YYYYMMDD');
+                const currentTime = moment().format('YYYYMMDD');
+
+                //如果推荐用户数超过6个，就改为增加3个月
+                if (newUserNumber.length >= 6 && !userList[0].ActivityTime && productServiceTime >= currentTime) {
+                    const obj = {
+                        ActivityTime: moment().format('YYYY-MM-DD HH:mm:ss'),
+                        ProductServiceTime: moment(userList[0].ProductServiceTime).add(1, 'months').format('YYYY-MM-DD HH:mm:ss'),
+                        OpenID: userList[0].OpenID,
+                    }
+                    await pinyin.UpdateUsers(obj);
+                    result[0].NewUserNumber = 999999;
+                }
+            }
+        }
+
+        result[0].IsMember = userList[0].IsMember;
+        if (productServiceTime < timeToday)
+            result[0].IsMember = 0;
+
+        const result2 = await pinyin.GetPinyinFinishedDataCount(param);
+
+        if (result2)
+            result[0].FinishedCount = result2[0].count;
+
+        const param2 = {
+            ProgramID: 98,
+            Version: param.Version,
+        };
+        const result3 = await dataUpdateStatus.GetProductVersionList(param2);
+        if (result3) {
+            if ((param.Version === result3[0].Version && result3[0].IsShowPay <= 0)
+                || param.Version > result3[0].Version) {
+                result[0].IsShow = result3[0].IsShowPay;
+            }
+            else {
+                result[0].IsShow = 1;
+            }
+
+            //针对iphone测试用户，永远是无支付状态
+            if (userList[0].Brand === 'iPhone' && userList[0].WXLanguage === 'en-US'
+                && userList[0].UserSource === '1001' && userList[0].IsPay === 0) {
+                result[0].IsShow = 0;
+            }
+        }
+
+        ctx.body = {"errcode": 10000, result: result[0]};
+    }
+    else
+        ctx.body = {"errcode": 10000};
+}
+
+//新增或删除拼音完成结果
+export async function UpdatePinyinFinished(ctx) {
+    const param = ctx.request.body;
+    if (param.Style === "undefined")
+        param.Style = "";
+    if (param.IsFinished) {
+        delete param.IsFinished;
+        if (param.UserID) {
+            await pinyin.AddPinyinFinished(param);
+        }
+    }
+    else {
+        delete param.IsFinished;
+        if (param.UserID) {
+            await pinyin.DeletePinyinFinished(param);
+        }
+    }
+    ctx.body = {errcode: 10000};
+}
+
+//得到用户完成记录
+export async function GetPinyinFinishedData(ctx) {
+    const param = {
+        UserID: ctx.query.UserID || 0,
+        Category: ctx.query.Category || 0,
+    };
+    if (param.UserID === "undefined")
+        param.UserID = 0;
+
+    const result = await pinyin.GetPinyinFinishedData(param);
+    if (result && result.length > 0)
+        ctx.body = {"errcode": 10000, result: result};
+    else
+        ctx.body = {"errcode": 10000};
+}
+
+//帮助用户使用兑换卡
+export async function SetPinyinUserExchange(ctx) {
+    const param = {
+        ExchangeUserID: ctx.query.UserID || 0,
+        ID: ctx.query.ProductPayInfoID || 0,
+        ExchangeTime: new Date(),
+    };
+    if (param.ID === "undefined")
+        param.ID = 0;
+
+    const ProductPayInfo = await pinyin.GetPinyinUserExchange(param);
+    if (ProductPayInfo && ProductPayInfo.length) {
+        if (ProductPayInfo[0].ExchangeUserID === 0) {
+            await pinyin.SetPinyinUserExchange(param);
+            const param2 = {};
+            param2.UserID = param.ExchangeUserID;
+            const userList = await pinyin.GetUsersInfoByUserID(param2);
+            if (userList && userList.length) {
+                const time1 = moment().format('YYYYMMDD');
+                const time2 = moment(userList[0].ProductServiceTime).format('YYYYMMDD');
+                if (time1 < time2) {
+                    param2.ProductServiceTime = moment(userList[0].ProductServiceTime).add(6, 'months').format('YYYY-MM-DD HH:mm:ss');
+                }
+                else {
+                    param2.ProductServiceTime = moment().add(6, 'months').format('YYYY-MM-DD HH:mm:ss');
+                }
+                param2.IsMember = 1;
+
+                await pinyin.UpdateUsersByUserID(param2);
+            }
+            ctx.body = {"errcode": 10000, result: true};
+        }
+        else
+            ctx.body = {"errcode": 10000, result: false};
+    }
+    else
+        ctx.body = {"errcode": 10000, result: false};
+}
+
+//得到拼音单元数据
+export async function GetPinyinUnitWords(ctx) {
+    const param = {
+        BookID: ctx.query.BookID || 44,
+        UnitID: ctx.query.UnitID || 431,
+        Word: ctx.query.Word || "b",
+        TestType: ctx.query.TestType || "read",
+    };
+
+    let result = globalCache.get("GetPinyinUnitWords?TestType=" + param.TestType + "&BookID=" + param.BookID + "&UnitID=" + param.UnitID + "&Word=" + param.Word);
+    if (result === 0) {
+        result = [];
+
+        if (param.BookID === 44) {
+            let arrExclude = [];
+            const arrPinyinBasic = constantClass.getPinyinBasic();
+            for (let k = 0; k < arrPinyinBasic.length; k++) {
+                for (let i = 0; i < arrPinyinBasic[k].List.length; i++) {
+                    if (arrPinyinBasic[k].List[i].Name === param.Word) {
+                        arrExclude = arrPinyinBasic[k].List[i].Exclude;
+                        break;
+                    }
+                }
+
+                if (arrExclude.length > 0)
+                    break;
+            }
+
+            const pinyinArr = constantClass.getPinyinArray();
+
+            const arr = [];
+            for (let i = 0; i < pinyinArr.length; i++) {
+                let word = param.Word;
+                const item = pinyinArr[i];
+                if (word === "un") {
+                    if (item[0].substr(0, 1) === "j"
+                        || item[0].substr(0, 1) === "q"
+                        || item[0].substr(0, 1) === "x"
+                        || item[0].substr(0, 1) === "y"
+                    ) {
+                        continue;
+                    }
+                }
+                if (word.indexOf("ü") >= 0) {
+                    if (item[0].substr(0, 1) === "j"
+                        || item[0].substr(0, 1) === "q"
+                        || item[0].substr(0, 1) === "x"
+                        || item[0].substr(0, 1) === "y"
+                    ) {
+                        word = word.replace("ü", "u");
+                    }
+                    else {
+                        word = word.replace("ü", "v");
+                    }
+                }
+
+                if (item[0].length > word.length &&
+                    ((item[0].indexOf(word) === 0 && item[0].indexOf("5") < 0)
+                        || item[0].lastIndexOf(word + "1") === (item[0].length - word.length - 1)
+                        || item[0].lastIndexOf(word + "2") === (item[0].length - word.length - 1)
+                        || item[0].lastIndexOf(word + "3") === (item[0].length - word.length - 1)
+                        || item[0].lastIndexOf(word + "4") === (item[0].length - word.length - 1)
+                    )
+                ) {
+                    let b = true;
+                    for (let j = 0; j < arrExclude.length; j++) {
+                        if (item[0].indexOf(arrExclude[j]) >= 0) {
+                            b = false;
+                            break;
+                        }
+                    }
+                    if (b) {
+                        if (item[0].indexOf(word) >= 0 && !(item[2].length === 1 && item[2] === "")) {
+                            arr.push(item)
+                        }
+                    }
+                }
+            }
+            //console.log(arr);
+            for (let i = 0; i < arr.length; i++) {
+                const obj = {};
+                obj.ID = i + 1;
+                let qustion, answer, tags;
+                const ReadString = "https://pinyin-1253256735.file.myqcloud.com/sounds/" + arr[i][0] + ".m4a";
+                qustion = arr[i][1];
+
+                //console.log(JSON.stringify(json.CHN));
+
+                answer = "[读 src='" + ReadString + "']" + qustion + "[/读]\n\n";
+
+                answer += arr[i][2].join(",");
+
+                tags = "拼音怎么念";
+
+                obj.Word = qustion;
+                obj.ReadString = ReadString;
+                obj.Content = [];
+                obj.Content.push({ContentType: 0, Content: tags});
+                obj.Content.push({ContentType: 1, Content: qustion});
+                obj.Content.push({ContentType: 2, Content: answer});
+                obj.Content.push({ContentType: 3, Content: ""});
+                result.push(obj);
+            }
+        }
+        else {
+            let arr = "";
+            switch (Number(param.UnitID)) {
+                case 431:
+                    arr = "b,p,m,f,d,t,n,l";
+                    break;
+                case 432:
+                    arr = "g,k,h,j,q,x";
+                    break;
+                case 433:
+                    arr = "zh,ch,sh,r,z,c,s,y,w";
+                    break;
+                case 434:
+                    arr = "a,o,e,i,u,ü";
+                    break;
+                case 435:
+                    arr = "ai,ei,ui,ao,ou,iu,ie,üe,er";
+                    break;
+                case 436:
+                    arr = "an,en,in,un,ün,ang,eng,ing,ong";
+                    break;
+                case 437:
+                    arr = "zhi,chi,shi,ri,zi,ci,si,yi,wu";
+                    break;
+                case 438:
+                    arr = "yu,ye,yue,yin,yun,yuan,ying";
+                    break;
+            }
+            arr = arr.split(",");
+            for (let i = 0; i < arr.length; i++) {
+                const obj = {};
+                obj.ID = i + 1;
+                let qustion, answer, tags;
+                let sound = arr[i];
+                sound = sound.replace("ü", "v");
+                const ReadString = "https://pinyin-1253256735.file.myqcloud.com/basic/" + sound + ".m4a";
+
+                if (param.TestType === "read") {
+                    qustion = arr[i];
+                    //console.log(JSON.stringify(json.CHN));
+                    answer = "[读 src='" + ReadString + "']" + qustion + "[/读]\n\n";
+                    tags = "拼音怎么念";
+                }
+                else {
+                    //console.log(result[i].Word);
+                    qustion = "[读 src='" + ReadString + "']拼音[/读]\n";
+
+                    answer = arr[i] + "\n\n";
+                    for (let j = 0; j < arr[i].length; j++) {
+                        let str = arr[i][j];
+                        if (str === "ü")
+                            str = "v1"
+                        answer += "[图 w='650' h='650']https://miaguo-1253256735.file.myqcloud.com/letter/s" + str + ".gif[/图]\n";
+                    }
+
+                    tags = "拼音怎么写";
+                }
+
+                obj.Word = arr[i];
+                obj.ReadString = ReadString;
+                obj.Content = [];
+                obj.Content.push({ContentType: 0, Content: tags});
+                obj.Content.push({ContentType: 1, Content: qustion});
+                obj.Content.push({ContentType: 2, Content: answer});
+                obj.Content.push({ContentType: 3, Content: ""});
+                result.push(obj);
+            }
+        }
+
+        globalCache.set("GetPinyinUnitWords?TestType=" + param.TestType + "&BookID=" + param.BookID + "&UnitID=" + param.UnitID + "&Word=" + param.Word, result, config.BufferMemoryTimeHigh);
+    }
+
+    ctx.body = {"errcode": 10000, result: result};
+}

src/api/pinyin/routes.js

@@ -0,0 +1,16 @@
+import Router from 'koa-router';
+import * as pinyin from './pinyinController.js';
+
+
+const router = new Router();
+ //拼音
+router.post('/api/PinyinLogin',pinyin.PinyinLogin);
+router.post('/api/AddPinyinRecord',pinyin.AddPinyinRecord);
+router.post('/api/UpdatePinyinRecord',pinyin.UpdatePinyinRecord);
+router.get('/api/GetPinyinRecordData',pinyin.GetPinyinRecordData);
+router.post('/api/UpdatePinyinFinished',pinyin.UpdatePinyinFinished);
+router.get('/api/GetPinyinFinishedData',pinyin.GetPinyinFinishedData);
+router.get('/api/SetPinyinUserExchange',pinyin.SetPinyinUserExchange);
+router.get('/api/GetPinyinUnitWords',pinyin.GetPinyinUnitWords);
+
+export default router;

src/app.js

@@ -4,12 +4,15 @@ import serve from 'koa-static';
 import path from 'path';
 import { fileURLToPath } from 'url';
 import config from './config/index.js';
-import mpsRouter from './api/mps/routes.js';
-import phonicsRouter from './api/phonics/routes.js';
-import commonRouter from './api/common/routes.js';
 import { decryptUrlMiddle } from './util/crypto/index.js';
 import { stringUtils } from './util/stringClass.js';
 
+
+import commonRouter from './api/common/routes.js';
+import mpsRouter from './api/mps/routes.js';
+import phonicsRouter from './api/phonics/routes.js';
+import pinyinRouter from './api/pinyin/routes.js';
+
 const __dirname = path.dirname(fileURLToPath(import.meta.url));
 
 const app = new Koa();
@@ -42,6 +45,8 @@ app.use(mpsRouter.routes());
 app.use(mpsRouter.allowedMethods());
 app.use(phonicsRouter.routes());
 app.use(phonicsRouter.allowedMethods());
+app.use(pinyinRouter.routes());
+app.use(pinyinRouter.allowedMethods());
 
 // 启动服务器
 app.listen(config.port, () => {

src/model/pinyin.js

@@ -0,0 +1,316 @@
+import { query } from '../util/db.js';
+
+/**
+ * 拼音模型类
+ */
+class Pinyin {
+    /**
+     * 获取用户信息(通过OpenID)
+     * @param {Object} obj 查询参数
+     * @param {string} obj.OpenID 用户OpenID
+     * @returns {Promise<Array>} 用户信息
+     */
+    static async GetUsersInfo(obj) {
+        try {
+            const sql = "SELECT * FROM PinyinWXUsers WHERE OpenID=?";
+            return await query(sql, [obj.OpenID]);
+        } catch (error) {
+            console.error('获取用户信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 获取用户信息(通过UserID)
+     * @param {Object} obj 查询参数
+     * @param {number} obj.UserID 用户ID
+     * @returns {Promise<Array>} 用户信息
+     */
+    static async GetUsersInfoByUserID(obj) {
+        try {
+            const sql = "SELECT * FROM PinyinWXUsers WHERE UserID=?";
+            return await query(sql, [obj.UserID]);
+        } catch (error) {
+            console.error('获取用户信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 添加用户
+     * @param {Object} obj 用户信息
+     * @returns {Promise<Object>} 插入结果
+     */
+    static async AddUsers(obj) {
+        try {
+            const sql = "INSERT INTO PinyinWXUsers SET ?";
+            return await query(sql, [obj]);
+        } catch (error) {
+            console.error('添加用户失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 更新用户信息(通过OpenID)
+     * @param {Object} obj 更新参数
+     * @param {string} obj.OpenID 用户OpenID
+     * @returns {Promise<Object>} 更新结果
+     */
+    static async UpdateUsers(obj) {
+        try {
+            const sql = "UPDATE PinyinWXUsers SET ? WHERE OpenID=?";
+            return await query(sql, [obj, obj.OpenID]);
+        } catch (error) {
+            console.error('更新用户信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 更新用户信息(通过UserID)
+     * @param {Object} obj 更新参数
+     * @param {number} obj.UserID 用户ID
+     * @returns {Promise<Object>} 更新结果
+     */
+    static async UpdateUsersByUserID(obj) {
+        try {
+            const sql = "UPDATE PinyinWXUsers SET ? WHERE UserID=?";
+            return await query(sql, [obj, obj.UserID]);
+        } catch (error) {
+            console.error('更新用户信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 添加拼音记录
+     * @param {Object} obj 记录信息
+     * @returns {Promise<Object>} 插入结果
+     */
+    static async AddPinyinRecord(obj) {
+        try {
+            const sql = "INSERT INTO PinyinRecords SET ?";
+            return await query(sql, [obj]);
+        } catch (error) {
+            console.error('添加拼音记录失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 更新拼音记录
+     * @param {Object} obj 更新参数
+     * @param {string} obj.RecordID 记录ID
+     * @returns {Promise<Object>} 更新结果
+     */
+    static async UpdatePinyinRecord(obj) {
+        try {
+            const sql = "UPDATE PinyinRecords SET ? WHERE RecordID=?";
+            return await query(sql, [obj, obj.RecordID]);
+        } catch (error) {
+            console.error('更新拼音记录失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 获取拼音记录数据
+     * @param {Object} obj 查询参数
+     * @param {number} obj.UserID 用户ID
+     * @returns {Promise<Array>} 记录数据
+     */
+    static async GetPinyinRecordData(obj) {
+        try {
+            const sql = `SELECT 
+                COUNT(DISTINCT DATE_FORMAT(CreateTime,'%Y-%m-%d')) as DayNumber,
+                SUM(PinyinNumber) as PinyinNumber 
+                FROM PinyinRecords WHERE UserID=?`;
+            return await query(sql, [obj.UserID]);
+        } catch (error) {
+            console.error('获取拼音记录数据失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 获取新用户信息(通过UserID)
+     * @param {Object} obj 查询参数
+     * @param {number} obj.UserID 用户ID
+     * @returns {Promise<Array>} 用户信息
+     */
+    static async GetNewUserByUserID(obj) {
+        try {
+            const sql = "SELECT UserID, NickName, AvatarUrl FROM PinyinWXUsers WHERE Introducer=?";
+            return await query(sql, [obj.UserID]);
+        } catch (error) {
+            console.error('获取新用户信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 获取已完成的拼音数量
+     * @param {Object} obj 查询参数
+     * @param {number} obj.UserID 用户ID
+     * @returns {Promise<Array>} 完成数量
+     */
+    static async GetPinyinFinishedDataCount(obj) {
+        try {
+            const sql = "SELECT COUNT(*) as count FROM PinyinFinished WHERE UserID=?";
+            return await query(sql, [obj.UserID]);
+        } catch (error) {
+            console.error('获取已完成的拼音数量失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 添加支付信息
+     * @param {Object} obj 支付信息
+     * @returns {Promise<Object>} 插入结果
+     */
+    static async AddPayInfo(obj) {
+        try {
+            obj.ProductID = 98;
+            const sql = "INSERT INTO ProductPayInfo SET ?";
+            return await query(sql, [obj]);
+        } catch (error) {
+            console.error('添加支付信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 更新支付信息
+     * @param {Object} obj 更新参数
+     * @param {string} obj.OpenID 用户OpenID
+     * @param {string} obj.TradeNo 交易号
+     * @returns {Promise<Object>} 更新结果
+     */
+    static async UpdatePayInfo(obj) {
+        try {
+            const sql = "UPDATE ProductPayInfo SET ? WHERE OpenID=? AND TradeNo=?";
+            return await query(sql, [obj, obj.OpenID, obj.TradeNo]);
+        } catch (error) {
+            console.error('更新支付信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 获取支付信息列表
+     * @param {Object} obj 查询参数
+     * @param {string} obj.OpenID 用户OpenID
+     * @param {string} obj.TradeNo 交易号
+     * @returns {Promise<Array>} 支付信息列表
+     */
+    static async GetPayInfoListByOpenIDAndTradeNo(obj) {
+        try {
+            const sql = "SELECT * FROM ProductPayInfo WHERE OpenID=? AND TradeNo=?";
+            return await query(sql, [obj.OpenID, obj.TradeNo]);
+        } catch (error) {
+            console.error('获取支付信息列表失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 添加拼音临时数据
+     * @param {Object} obj 临时数据
+     * @returns {Promise<Object>} 插入结果
+     */
+    static async AddPinyinTemp(obj) {
+        try {
+            const sql = "INSERT INTO PinyinTemp SET ?";
+            return await query(sql, [obj]);
+        } catch (error) {
+            console.error('添加拼音临时数据失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 添加已完成的拼音
+     * @param {Object} obj 完成记录
+     * @returns {Promise<Object>} 插入结果
+     */
+    static async AddPinyinFinished(obj) {
+        try {
+            const sql = "INSERT INTO PinyinFinished SET ?";
+            return await query(sql, [obj]);
+        } catch (error) {
+            console.error('添加已完成的拼音失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 删除已完成的拼音
+     * @param {Object} obj 删除参数
+     * @param {number} obj.UserID 用户ID
+     * @param {string} obj.Title 标题
+     * @param {string} obj.Style 样式
+     * @returns {Promise<Object>} 删除结果
+     */
+    static async DeletePinyinFinished(obj) {
+        try {
+            const sql = "DELETE FROM PinyinFinished WHERE UserID=? AND Title=? AND Style=?";
+            return await query(sql, [obj.UserID, obj.Title, obj.Style]);
+        } catch (error) {
+            console.error('删除已完成的拼音失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 获取已完成的拼音数据
+     * @param {Object} obj 查询参数
+     * @param {number} obj.UserID 用户ID
+     * @param {string} obj.Category 分类
+     * @returns {Promise<Array>} 完成数据
+     */
+    static async GetPinyinFinishedData(obj) {
+        try {
+            const sql = "SELECT * FROM PinyinFinished WHERE UserID=? AND Category=?";
+            return await query(sql, [obj.UserID, obj.Category]);
+        } catch (error) {
+            console.error('获取已完成的拼音数据失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 获取拼音用户兑换信息
+     * @param {Object} obj 查询参数
+     * @param {number} obj.ID 记录ID
+     * @returns {Promise<Array>} 兑换信息
+     */
+    static async GetPinyinUserExchange(obj) {
+        try {
+            const sql = "SELECT * FROM ProductPayInfo WHERE ID=?";
+            return await query(sql, [obj.ID]);
+        } catch (error) {
+            console.error('获取拼音用户兑换信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 设置拼音用户兑换信息
+     * @param {Object} obj 更新参数
+     * @param {number} obj.ID 记录ID
+     * @returns {Promise<Object>} 更新结果
+     */
+    static async SetPinyinUserExchange(obj) {
+        try {
+            const sql = "UPDATE ProductPayInfo SET ? WHERE ID=?";
+            return await query(sql, [obj, obj.ID]);
+        } catch (error) {
+            console.error('设置拼音用户兑换信息失败:', error);
+            throw error;
+        }
+    }
+}
+
+export default Pinyin;