0

src/api/mathcalculate/mathController.js

@@ -0,0 +1,329 @@
+import moment from 'moment';
+import commonModel from '../../model/commonModel.js';
+import mathcalculate from '../../model/mathcalculate.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';
+import constantClass from '../../util/constant/index.js';
+import fs from 'fs';
+import { promises as fsPromises } from 'fs';
+import COS from 'cos-nodejs-sdk-v5';
+
+export async function MathLogin(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.math_appid}&secret=${config.wx.math_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.math_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 mathcalculate.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 mathcalculate.UpdateUsers(param);
+            userList = await mathcalculate.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 mathcalculate.AddUsers(param);
+            userList = await mathcalculate.GetUsersInfo(param);
+        }
+
+        delete userList[0].OpenID;
+        delete userList[0].UnionID;
+
+        //产品支付是否显示
+        if (param.ProgramVersion) {
+            let param2 = {
+                ProgramID: 105,
+                Version: param.ProgramVersion,
+            };
+            let result3 = await commonModel.GetProductVersionList(param2);
+            if (result3) {
+                if ((param2.Version == result3[0].Version && result3[0].IsShowPay <= 0)
+                    || param2.Version > result3[0].Version) {
+                    userList[0].IsShow = result3[0].IsShowPay;
+                }
+                else {
+                    userList[0].IsShow = 1;
+                }
+
+                //针对iphone测试用户，永远是无支付状态
+                if (userList[0].Brand == 'iPhone' && userList[0].WXLanguage == 'en-US'
+                    && userList[0].UserSource == '1001' && userList[0].IsPay == 0) {
+                    userList[0].IsShow = 0;
+                }
+
+                //针对微信测试用户，永远是无支付状态
+                if ((userList[0].UserSource=='1001' && userList[0].System=="iOS 10.0.1")
+                    || (!userList[0].UserSource && (!userList[0].LastUserSource || userList[0].LastUserSource>10000))
+                    || userList[0].NickName.indexOf("dgztest")>=0){
+                    userList[0].IsShow=-1;
+                }
+
+                if (userList[0].IsMember===1)
+                    userList[0].IsShow=1;
+            }
+        }
+
+        result = {errcode: 10000, result: userList[0]};
+    }
+
+    ctx.body = result;
+}
+
+export async function GetQuestionTypes(ctx) {
+    const param = {
+        QuestionMode: ctx.query.Mode,
+    };
+    const list = await mathcalculate.GetQuestionTypesList(param);
+    const result = [];
+    let temp;
+    let arr = [];
+    
+    for (let i = 0; i < list.length; i++) {
+        const item = list[i];
+        if (temp && temp.Category != item.Category) {
+            const obj = {
+                ID: temp.CategoryID,
+                Name: temp.CategoryName + "·" + temp.CategoryLevel,
+                Description: temp.CategoryDescription,
+                ImageUrl: temp.CategoryImageUrl,
+                QuestionCategoryInfoShow: true,
+                List: arr,
+            };
+            result.push(obj);
+            arr = [];
+        }
+        
+        item.Example = item.Example.split(",");
+        item.SelectItemClass = "";
+        
+        arr.push(item);
+        temp = item;
+    }
+
+    const obj = {
+        ID: temp.CategoryID,
+        Name: temp.CategoryName + temp.CategoryLevel,
+        Description: temp.CategoryDescription,
+        ImageUrl: temp.CategoryImageUrl,
+        QuestionCategoryInfoShow: true,
+        List: arr,
+    };
+    result.push(obj);
+
+    for (let i = 0; i < result.length; i++) {
+        for (let j = 0; j < result[i].List.length; j++) {
+            const item = result[i].List[j];
+            delete item.CategoryID;
+            delete item.CategoryName;
+            delete item.CategoryLevel;
+            delete item.CategoryDescription;
+            delete item.CategoryImageUrl;
+        }
+    }
+
+    for (let i = 0; i < result.length; i++) {
+        for (let j = 0; j < result[i].List.length; j++) {
+            const item = result[i].List[j];
+            switch (item.ID){
+                case 167:
+                case 174:
+                case 166:
+                case 190:
+                case 191:
+                case 192:
+                case 193:
+                case 164:
+                case 165:
+                case 195:
+                    item.CategoryName = "乘除运算";
+                    item.CategoryLevel = "3级";
+                    break;
+            }
+        }
+    }
+
+    ctx.body = {"errcode": 10000, result: result};
+}
+
+// exports.GetQuestionTypesPrint = function* () {
+//     var param = {
+//         QuestionTypeID: this.query.ID || 1,
+//         QuestionTypeCategory:this.query.QuestionTypeCategory || 2,
+//         PageNum:this.query.PageNum || 1,
+//     }
+//     var questionType = yield mathcalculate.GetQuestionTypesInfo(param);
+//     questionType = questionType[0];
+
+
+//     var questionNumber = questionType.QuestionNumber2;
+//     if (param.QuestionTypeCategory==3)
+//         questionNumber = questionType.QuestionNumber3;
+
+//     questionNumber=questionNumber*param.PageNum;
+
+//     questionType.QuestionNumber=questionNumber;
+//     //console.log("questionType.QuestionNumber:"+questionType.QuestionNumber);
+//     var list = getQuestionTypeInfo(questionType);
+
+//     var questionList = [];
+//     //如果要求题目数小于原有题目数，则直接随机获取题目
+//     if (list.length > questionNumber) {
+
+//         do {
+//             var rnd = stringClass.Random(0, list.length - 1);
+//             if (list[rnd]) {
+//                 questionList.push(list[rnd]);
+//                 list[rnd] = null;
+//             }
+//         }
+//         while (questionList.length < questionNumber);
+//     }
+//     //如果要求题目数大于原有题目数，则获取全部原有题目的倍数，再将剩余数随机获取
+//     else {
+//         var nCount = Math.floor(questionNumber / list.length);
+//         for (var n = 0; n < nCount; n++) {
+//             for (var i = 0; i < list.length; i++) {
+//                 questionList.push(list[i]);
+//             }
+//         }
+
+//         while (questionList.length < questionNumber) {
+//             var rnd = stringClass.Random(0, list.length - 1);
+//             if (list[rnd]) {
+//                 questionList.push(list[rnd]);
+//                 list[rnd] = null;
+//             }
+//         }
+//     }
+
+//     questionList = stringClass.RemoveJSONNull(questionList);
+
+//     questionList.sort(function () {
+//         return 0.5 - Math.random()
+//     });
+
+//     var questionListResult = [];
+//     for (var i = 0; i < questionList.length; i++) {
+//         var item = {};
+//         for (var k in questionList[i]) {
+//             item[k] = questionList[i][k];
+
+//             if (item[k]=="−") {
+//                 item[k] = "-";
+//             }
+//         }
+//         item.ID = i + 1;
+//         var arr = questionType.HiddenColumn.split(",");
+//         var hidden = arr[stringClass.Random(0, arr.length - 1)];
+//         item.HiddenColumn = hidden;
+//         item.Result = item[item.HiddenColumn];
+
+//         if (param.QuestionTypeCategory==3) {
+//             item.Vertical=computeMath(item);
+//         }
+
+//         questionListResult.push(item);
+//     }
+
+//     var categoryArray = [{}, { Num: 1, Name: "一年级", Array: [1, 2] }, { Num: 2, Name: "二年级", Array: [3, 4] }, { Num: 3, Name: "三年级", Array: [5, 6] }, { Num: 4, Name: "四年级及以上", Array: [7] }];
+//     var categoryName="";
+//     for(var i=1;i<categoryArray.length;i++){
+//         for(var j=0;j<categoryArray[i].Array.length;j++){
+//             if (categoryArray[i].Array[j]==questionType.Category){
+//                 categoryName=categoryArray[i].Name;
+//                 break;
+//             }
+//         }
+//     }
+
+//     var result = {
+//         ID: questionType.ID,
+//         Category: questionType.Category,
+//         CategoryName: categoryName,
+//         //错误接口参数
+//         Cagegory: questionType.Category,
+//         CagegoryName: categoryName,
+
+//         CreateTime:moment(new Date()).format('YYYY年MM月DD日 HH:mm'),
+//         Name: questionType.Name,
+//         QuestionTypeCategory:Number(param.QuestionTypeCategory),
+//         QuestionTypeLevel: questionType.CategoryName + questionType.CategoryLevel,
+//         Difficulty: questionType.Difficulty,
+//         PageCount:questionNumber/param.PageNum,
+//         QuestionList: questionListResult,
+//     }
+//     //console.log(result);
+//     //var time=buildPrint(result);
+
+//     this.body = {"errcode": 10000,result:result};
+
+// }

src/api/mathcalculate/routes.js

@@ -0,0 +1,11 @@
+import Router from 'koa-router';
+import * as math from './mathController.js';
+
+
+const router = new Router();
+
+router.post('/api/MathLogin',math.MathLogin);
+router.get('/api/GetQuestionTypes',math.GetQuestionTypes);
+//router.get('/api/GetQuestionTypesPrint',math.GetQuestionTypesPrint);
+
+export default router;

src/api/mps/mpsSchoolController.js

@@ -145,7 +145,7 @@ export async function GetMPSSchool(ctx) {
                 KeyName: cacheKey,
                 ValueString: JSON.stringify(result)
             });
-            console.log("数据已缓存");
+            //console.log("数据已缓存");
         } else {
             result = JSON.parse(cachedData[0].ValueString);
         }

src/api/mps/mpsScoreController.js

@@ -9,10 +9,10 @@ import _ from 'lodash';
 // 更新学校点赞数
 export async function UpdateMPSUserSchoolLikeNum(ctx) {
     const param = {
-        UserID: ctx.request.body.UserID || 0,
-        SchoolID: ctx.request.body.SchoolID || 0,
-        SchoolType1: ctx.request.body.SchoolType1 || '高中',
-        LikeNum: ctx.request.body.LikeNum || 0
+        UserID: ctx.query.UserID || 0,
+        SchoolID: ctx.query.SchoolID || 0,
+        SchoolType1: ctx.query.SchoolType1 || '高中',
+        LikeNum: ctx.query.LikeNum || 0
     };
 
     var sql="select * from MPS_UserSchoolClickLike where UserID="+param.UserID+" and SchoolID="+param.SchoolID;

src/api/web/webController.js

@@ -195,7 +195,7 @@ export async function GetKylx365TableColumnByTable(ctx) {
         TableName: ctx.query.table || "",
     };
     let result = await commonModel.RunSql(null,"SHOW COLUMNS FROM `"+param.TableName+"`;");
-    console.log("字段数："+result.length);
+    //console.log("字段数："+result.length);
     ctx.body = {"errcode": 10000, result: result};
 };
         

src/app.js

@@ -13,6 +13,7 @@ import mpsRouter from './api/mps/routes.js';
 import phonicsRouter from './api/phonics/routes.js';
 import pinyinRouter from './api/pinyin/routes.js';
 import hanziRouter from './api/hanzi/routes.js';
+import mathcalculateRouter from './api/mathcalculate/routes.js';
 import webRouter from './api/web/routes.js';
 
 const __dirname = path.dirname(fileURLToPath(import.meta.url));
@@ -74,6 +75,8 @@ app.use(pinyinRouter.routes());
 app.use(pinyinRouter.allowedMethods());
 app.use(hanziRouter.routes());
 app.use(hanziRouter.allowedMethods());
+app.use(mathcalculateRouter.routes());
+app.use(mathcalculateRouter.allowedMethods());
 app.use(webRouter.routes());
 app.use(webRouter.allowedMethods());
 

src/model/mathcalculate.js

@@ -0,0 +1,98 @@
+import { query } from '../util/db.js';
+
+/**
+ * MathCalculation 模型
+ */
+class MathCalculation {
+    /**
+     * 获取用户信息(通过OpenID)
+     * @param {Object} obj 查询参数
+     * @returns {Promise<Array>} 用户信息
+     */
+    static async GetUsersInfo(obj) {
+        try {
+            const sql = "select * from MathCalculationWXUsers where OpenID=?";
+            return await query(sql, [obj.OpenID]);
+        } catch (error) {
+            console.error('获取用户信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 获取用户信息(通过UserID)
+     * @param {Object} obj 查询参数
+     * @returns {Promise<Array>} 用户信息
+     */
+    static async GetUsersInfoByUserID(obj) {
+        try {
+            const sql = "select * from MathCalculationWXUsers 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 MathCalculationWXUsers SET ?";
+            return await query(sql, [obj]);
+        } catch (error) {
+            console.error('添加用户失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 更新用户信息(通过OpenID)
+     * @param {Object} obj 更新参数
+     * @returns {Promise<Object>} 更新结果
+     */
+    static async UpdateUsers(obj) {
+        try {
+            const sql = "Update MathCalculationWXUsers SET ? where OpenID=?";
+            return await query(sql, [obj, obj.OpenID]);
+        } catch (error) {
+            console.error('更新用户信息失败:', error);
+            throw error;
+        }
+    }
+
+    /**
+     * 更新用户信息(通过UserID)
+     * @param {Object} obj 更新参数
+     * @returns {Promise<Object>} 更新结果
+     */
+    static async UpdateUsersByUserID(obj) {
+        try {
+            const sql = "Update MathCalculationWXUsers SET ? where UserID=?";
+            return await query(sql, [obj, obj.UserID]);
+        } catch (error) {
+            console.error('更新用户信息失败:', error);
+            throw error;
+        }
+    }
+
+    static async GetQuestionTypesList (obj) {
+        let str=" and qt.QuestionNumber>0";
+        if (obj && obj.QuestionMode==2){
+            str="";
+        }
+        try {
+            const sql = "SELECT qc.*,qt.* FROM QuestionTypes qt inner join QuestionCategory qc on qt.Category=qc.CategoryID where qt.Flag=0 "+str+" order by qc.CategoryID,qt.Difficulty,qt.Sort,qt.ID;";
+            return await query(sql, [str]);
+        } catch (error) {
+            console.error('更新用户信息失败:', error);
+            throw error;
+        }
+
+    }
+}
+
+export default MathCalculation;