国际化新接口

src/functional/mvc/control/i18n.control.ts

@@ -27,7 +27,7 @@ export const list = async (req: any, infoPageVO: I18nInfoPageVO) => {
     }
 };
 /**
- * 添加国际化信息
+ * 添加国际化信息-发布版本
  * @param req
  * @param infoVO
  */
@@ -35,7 +35,6 @@ export const add = async (req: any, infoVO: I18nInfoVO) => {
     let func_name = "i18nCtrl.add";
     let cmd = req.path;
     try {
-        await preCheck(infoVO);
         let ip = isIp(req.ip) ? req.ip : '*.*.*.*';
         let currentUserId = await getCurrentUserId(req.cookies.session_id);
         let res = await i18nService.add(infoVO,currentUserId,ip);
@@ -46,19 +45,19 @@ export const add = async (req: any, infoVO: I18nInfoVO) => {
         return Res3Utils.getErrorResult(e);
     }
 };
+
 /**
- * 修改国际化信息
+ * 添加国际化信息-发布版本-预览
  * @param req
  * @param infoVO
  */
-export const update = async (req: any, infoVO: I18nInfoVO) => {
-    let func_name = "i18nCtrl.update";
+export const preview = async (req: any, infoVO: I18nInfoVO) => {
+    let func_name = "i18nCtrl.preview";
     let cmd = req.path;
     try {
-        ApiAssert.notNull(ErrorCode.PARAM_MISS, infoVO.id);
         let ip = isIp(req.ip) ? req.ip : '*.*.*.*';
         let currentUserId = await getCurrentUserId(req.cookies.session_id);
-        let res = await i18nService.update(infoVO,currentUserId,ip);
+        let res = await i18nService.preview(infoVO,currentUserId,ip);
         return Res3Utils.result(res);
     }
     catch (e) {
@@ -67,18 +66,15 @@ export const update = async (req: any, infoVO: I18nInfoVO) => {
     }
 };
 /**
- * 删除国际化信息
+ * 国际化信息版本列表
  * @param req
  * @param infoVO
  */
-export const del = async (req: any, infoVO: I18nInfoVO) => {
-    let func_name = "i18nCtrl.del";
+export const versionList = async (req: any, infoVO: I18nInfoVO) => {
+    let func_name = "i18nCtrl.versionList";
     let cmd = req.path;
     try {
-        ApiAssert.notNull(ErrorCode.PARAM_MISS, infoVO.id);
-        let ip = isIp(req.ip) ? req.ip : '*.*.*.*';
-        let currentUserId = await getCurrentUserId(req.cookies.session_id);
-        let res = await i18nService.del(infoVO,currentUserId,ip);
+        let res = await i18nService.versionList();
         return Res3Utils.result(res);
     }
     catch (e) {
@@ -88,16 +84,3 @@ export const del = async (req: any, infoVO: I18nInfoVO) => {
 };
 
 
-/**
- * 校验
- * @param infoVO
- */
-async function preCheck(infoVO: I18nInfoVO) {
-    if (![1, 2, 3, 4, 5].includes(infoVO.platform)) {
-        throw ErrorCode.PARAM_MISS;
-    }
-    ApiAssert.notNull(ErrorCode.PARAM_MISS, infoVO.module);
-    ApiAssert.notNull(ErrorCode.PARAM_MISS, infoVO.code);
-    ApiAssert.notNull(ErrorCode.PARAM_MISS, infoVO.lang);
-    ApiAssert.notNull(ErrorCode.PARAM_MISS, infoVO.content);
-}
\ No newline at end of file

src/functional/mvc/control/i18nlog.control.ts

@@ -36,8 +36,7 @@ export const revert = async (req: any, i18nInfoLogVO: I18nInfoLogVO) => {
     try {
         let ip = isIp(req.ip) ? req.ip : '*.*.*.*';
         let currentUserId = await getCurrentUserId(req.cookies.session_id);
-        ApiAssert.notNull(ErrorCode.PARAM_MISS, i18nInfoLogVO.id);
-        ApiAssert.notNull(ErrorCode.PARAM_MISS, i18nInfoLogVO.info_id);
+        ApiAssert.notNull(ErrorCode.PARAM_MISS, i18nInfoLogVO.version);
         let res = await i18nLogService.revert(i18nInfoLogVO,currentUserId,ip);
         return Res3Utils.result(res);
     }

src/functional/mvc/service/i18n.service.ts

 // @madex/ex-ts-dao 是 ts 的 dao, 代码在 bitbucket/ex-js-dao 的 ts 分支上
-import { i18nInfo, i18nInfoLog, ormDB } from "@madex/ex-ts-dao";
+import { i18nInfo, i18nInfoHistory, ormDB } from "@madex/ex-ts-dao";
 import * as i18nLogService from "../service/i18nlog.service";
 import { ErrorCode } from "../../../constant/errorCode";
 import { addOptLog } from "./userOptLog.service";
 import { sendRobotMessage, ROBOT_KEYS } from "../../../utils/robotUtils";
 
 let { logger } = require('@madex/ex-js-public');
+let _ = require('lodash');
 
 export interface I18nInfoVO {
-    id?: number;
+    info_json: string;
+}
+
+export interface I18nInfoPageVO extends I18nInfoVO {
+    page?: number;
+
+    size?: number
 
     platform: number;
 
@@ -16,47 +23,28 @@ export interface I18nInfoVO {
 
     code?: string | any;
 
-    sub_code?: string | any;
-
-    lang?: string;
-
-    desc?: string | any;
-
-    content?: string | any;
-
-    createdAt?: Date | any;
-
-    updatedAt?: Date | any;
-}
-
-export interface I18nInfoPageVO extends I18nInfoVO {
-    page?: number;
-
-    size?: number
+    zh_cn?: string | any;
 }
 
 export const list = async (infoPageVO: I18nInfoPageVO) => {
-
-    if (infoPageVO.code) {
-        infoPageVO.code = { [ormDB.Op.like]: `${infoPageVO.code}%` };
+    let condition = {};
+    if (infoPageVO.platform) {
+        condition['platform'] = Number(infoPageVO.platform);
     }
-
-    if (infoPageVO.sub_code) {
-        infoPageVO.sub_code = { [ormDB.Op.like]: `${infoPageVO.sub_code}%` };
+    if (infoPageVO.module) {
+        condition['module'] = Number(infoPageVO.module);
     }
-    if (infoPageVO.desc) {
-        infoPageVO.desc = { [ormDB.Op.like]: `${infoPageVO.desc}%` };
+    if (infoPageVO.code) {
+        condition['code'] = infoPageVO.code;
     }
-    if (infoPageVO.updatedAt) {
-        infoPageVO.updatedAt = { [ormDB.Op.gte]: new Date(infoPageVO.updatedAt).getTime() };
+    if (infoPageVO.zh_cn) {
+        condition['zh_cn'] = { [ormDB.Op.like]: `${infoPageVO.zh_cn}%` };
     }
+
     let page = Number(infoPageVO.page);
     let size = Number(infoPageVO.size);
-    let where = Object.assign(infoPageVO);
-    delete infoPageVO.page;
-    delete infoPageVO.size;
     let resList = await i18nInfo.prototype.findAndCount({
-        where: where,
+        where: condition,
         limit: size,
         offset: (page - 1) * size,
         order: [["id", "asc"]],
@@ -65,155 +53,252 @@ export const list = async (infoPageVO: I18nInfoPageVO) => {
     return resList;
 };
 export const add = async (infoVO: I18nInfoVO, currentUserId: any, ip: any) => {
-    if (!infoVO.createdAt) {
-        infoVO.createdAt = new Date();
+
+    let infoJson = infoVO.info_json;
+    if (!infoJson) {
+        throw ErrorCode.PARAM_MISS;
+    }
+    let infoList = JSON.parse(infoJson);
+    let lastVersionList = await getLastVersionList();
+
+    let timestamp = new Date().getTime();
+    let insertHistoryList: any = [];
+    let idList: any = [];
+    let lastVersionMap: any = {};
+
+    for (let item of lastVersionList) {
+        let key = item['platform'] + '_' + item['module'] + '_' + item['code'];
+        lastVersionMap[key] = item;
+        idList.push(item['id']);
+        item['info_id'] = item['id'];
+        item['created_at'] = item['updated_at'];
+        delete item['id'];
+        insertHistoryList.push(item);
+    }
+
+    let version = await getVersion();
+
+    let insertOrUpdateList: any = [];
+    for (let insertOne of infoList) {
+        if (!insertOne.platform || !insertOne.module || !insertOne.code) {
+            throw ErrorCode.PARAM_MISS;
         }
-    if (!infoVO.updatedAt) {
-        infoVO.updatedAt = new Date();
+        let key = insertOne['platform'] + '_' + insertOne['module'] + '_' + insertOne['code'];
+
+        insertOne.version = version;
+        insertOne.sub_code = insertOne.sub_code ? insertOne.sub_code :
+            (lastVersionMap[key] ? lastVersionMap[key].sub_code : '');
+
+        insertOne.zh_cn = insertOne.zh_cn ? insertOne.zh_cn :
+            (lastVersionMap[key] ? lastVersionMap[key].zh_cn : '');
+
+        insertOne.en_us = insertOne.en_us ? insertOne.en_us :
+            (lastVersionMap[key] ? lastVersionMap[key].en_us : '');
+
+        insertOne.ja_jp = insertOne.ja_jp ? insertOne.ja_jp :
+            (lastVersionMap[key] ? lastVersionMap[key].ja_jp : '');
+
+        insertOne.ko_kr = insertOne.ko_kr ? insertOne.ko_kr :
+            (lastVersionMap[key] ? lastVersionMap[key].ko_kr : '');
+
+        insertOne.vi_vn = insertOne.vi_vn ? insertOne.vi_vn :
+            (lastVersionMap[key] ? lastVersionMap[key].vi_vn : '');
+
+        insertOne.ar_ae = insertOne.ar_ae ? insertOne.ar_ae :
+            (lastVersionMap[key] ? lastVersionMap[key].ar_ae : '');
+
+        insertOne.created_at = timestamp;
+        insertOne.updated_at = timestamp;
+        insertOrUpdateList.push(insertOne);
     }
-    let dbInfo = await i18nInfo.prototype.findOne({
+
+    let tx;
+    try {
+        tx = await ormDB.transaction();
+
+        //先迁移历史表
+        if (insertHistoryList.length) {
+            await i18nInfoHistory.prototype.bulkCreate(insertHistoryList, {
+                transaction: tx
+            });
+        }
+        //更新版本
+        if (lastVersionList.length) {
+            await i18nInfo.prototype.update({
+                version: version,
+                updated_at: timestamp
+            }, {
                 where: {
-            platform: infoVO.platform,
-            module: infoVO.module,
-            code: infoVO.code,
-            lang: infoVO.lang,
+                    id: idList
                 },
-        raw: true
+                transaction: tx
+            })
+        }
+        //批量插入或更新
+        if (insertOrUpdateList.length) {
+            await i18nInfo.prototype.bulkCreate(insertOrUpdateList, {
+                updateOnDuplicate: ['sub_code', 'zh_cn', 'en_us', 'ja_jp', 'ko_kr', 'vi_vn', 'ar_ae', 'updated_at'],
+                transaction: tx
             });
-    if (dbInfo) {
-        throw ErrorCode.DATA_EXIST;
         }
-    await i18nInfo.prototype.create(infoVO);
+        await tx.commit();
+    }
+    catch (e) {
+        if (tx) {
+            await tx.rollback();
+        }
+        logger.error('i18nInfo.add.error:' + e);
+        throw e;
+    }
     //管理后台操作日志
-    addOptLog(currentUserId, 0, '新增国际化信息', ip, JSON.stringify(infoVO), '国际化管理');
+    addOptLog(currentUserId, 0, '新增国际化信息', ip, insertOrUpdateList.length, '国际化管理');
     sendRobotMessage(ROBOT_KEYS.COMMON_KEY, `新增国际化信息:${JSON.stringify(infoVO)}`);
     return 'ok';
 };
 
-export const update = async (infoVO: I18nInfoVO, currentUserId: any, ip: any) => {
-    let transaction: any;
-    try {
-        let dbOneI18nInfo = await i18nInfo.prototype.findOne({
-            raw: true,
-            where: {
-                id: infoVO.id
+export const preview = async (infoVO: I18nInfoVO, currentUserId: any, ip: any) => {
+
+    let infoJson = infoVO.info_json;
+    if (!infoJson) {
+        throw ErrorCode.PARAM_MISS;
     }
-        });
-        if (!dbOneI18nInfo) {
-            throw ErrorCode.DATA_NOT_EXIST;
+    let infoList = JSON.parse(infoJson);
+    let lastVersionList = await getLastVersionList();
+
+    let timestamp = new Date().getTime();
+    let lastVersionMap: any = {};
+
+    for (let item of lastVersionList) {
+        let key = item['platform'] + '_' + item['module'] + '_' + item['code'];
+
+        delete item['id'];
+        delete item['version'];
+        delete item['created_at'];
+
+        lastVersionMap[key] = item;
+
     }
-        //查询是否有重复的
-        let dbInfo = await i18nInfo.prototype.findOne({
-            where: {
-                platform: infoVO.platform,
-                module: infoVO.module,
-                code: infoVO.code,
-                lang: infoVO.lang,
-                id: { [ormDB.Op.ne]: infoVO.id }
-            },
-            raw: true
-        });
-        if (dbInfo) {
-            throw ErrorCode.DATA_EXIST;
+
+
+    for (let insertOne of infoList) {
+        if (!insertOne.platform || !insertOne.module || !insertOne.code) {
+            throw ErrorCode.PARAM_MISS;
         }
+        let key = insertOne['platform'] + '_' + insertOne['module'] + '_' + insertOne['code'];
 
-        delete infoVO.id;
-        let i18nInfoLogOne = await buildOneI18nInfoLog(dbOneI18nInfo, infoVO);
+        insertOne.sub_code = insertOne.sub_code ? insertOne.sub_code :
+            (lastVersionMap[key] ? lastVersionMap[key].sub_code : '');
 
-        transaction = await ormDB.transaction();
+        insertOne.zh_cn = insertOne.zh_cn ? insertOne.zh_cn :
+            (lastVersionMap[key] ? lastVersionMap[key].zh_cn : '');
 
+        insertOne.en_us = insertOne.en_us ? insertOne.en_us :
+            (lastVersionMap[key] ? lastVersionMap[key].en_us : '');
 
-        await i18nInfo.prototype.update(infoVO, {
-            where: {
-                id: dbOneI18nInfo.id
-            },
-            transaction: transaction,
-        });
-        //日志
-        await i18nLogService.add(i18nInfoLogOne, transaction);
-        await transaction.commit();
-        //管理后台操作日志
-        addOptLog(currentUserId, 0, '修改国际化信息', ip, JSON.stringify(infoVO), '国际化管理');
-        sendRobotMessage(ROBOT_KEYS.COMMON_KEY, `修改国际化信息:id:${infoVO.id},修改为:${JSON.stringify(infoVO)}`);
+        insertOne.ja_jp = insertOne.ja_jp ? insertOne.ja_jp :
+            (lastVersionMap[key] ? lastVersionMap[key].ja_jp : '');
 
-        return 'ok';
-    }
-    catch (e) {
-        logger.error(`i18nService.update.error:${e}`);
-        if (transaction) {
-            await transaction.rollback();
+        insertOne.ko_kr = insertOne.ko_kr ? insertOne.ko_kr :
+            (lastVersionMap[key] ? lastVersionMap[key].ko_kr : '');
+
+        insertOne.vi_vn = insertOne.vi_vn ? insertOne.vi_vn :
+            (lastVersionMap[key] ? lastVersionMap[key].vi_vn : '');
+
+        insertOne.ar_ae = insertOne.ar_ae ? insertOne.ar_ae :
+            (lastVersionMap[key] ? lastVersionMap[key].ar_ae : '');
+
+        insertOne.updated_at = timestamp;
+        lastVersionMap[key] = insertOne;
     }
-        throw e;
+
+    let resList: any = [];
+    for (let key of _.keys(lastVersionMap)) {
+        resList.push(lastVersionMap[key]);
     }
+    return 'ok';
 };
 
-export const del = async (infoVO: I18nInfoVO, currentUserId: any, ip: any) => {
-    let transaction: any;
-    try {
-        let dbOneI18nInfo = await i18nInfo.prototype.findOne({
-            raw: true,
-            where: {
-                id: infoVO.id
-            }
-        });
-        if (!dbOneI18nInfo) {
-            throw ErrorCode.DATA_NOT_EXIST;
+export const versionList = async () => {
+    let options = {
+        attributes: ['version', 'created_at', 'updated_at'],
+        where: {},
+        order: [['version', 'desc']],
+        group: ['version', 'created_at', 'updated_at'],
+        raw: true
     }
-        delete infoVO.id;
-        let i18nInfoLogOne = await buildOneI18nInfoLog(dbOneI18nInfo, infoVO);
+    let task1 = i18nInfo.prototype.findAll(options);
+    let task2 = i18nInfoHistory.prototype.findAll(options);
 
+    let [currentInfo, historyInfo] = await Promise.all([task1, task2]);
 
-        transaction = await ormDB.transaction();
+    return {
+        current_version: currentInfo,
+        history_version: historyInfo
+    }
 
+};
 
-        await i18nInfo.prototype.destroy({
-            where: {
-                id: dbOneI18nInfo.id
-            },
-            transaction: transaction,
+
+/**
+ * 查询版本记录
+ */
+export async function getLastVersionList() {
+    return await i18nInfo.prototype.findAll({
+        where: {},
+        order: [['id', 'asc']],
+        raw: true
     });
-        //日志
-        await i18nLogService.add(i18nInfoLogOne, transaction);
-        await transaction.commit();
-        //管理后台操作日志
-        addOptLog(currentUserId, 0, '删除国际化信息', ip, JSON.stringify(infoVO), '国际化管理');
-        sendRobotMessage(ROBOT_KEYS.COMMON_KEY, `删除国际化信息:id:${infoVO.id}`);
+}
 
-        return 'ok';
+async function getVersion() {
+    let version: any;
+    let options = {
+        where: {},
+        order: [['version', 'desc']],
+        raw: true
     }
-    catch (e) {
-        logger.error(`i18nService.del.error:${e}`);
-        if (transaction) {
-            await transaction.rollback();
+    let task1 = i18nInfo.prototype.findOne(options);
+    let task2 = i18nInfoHistory.prototype.findOne(options);
+    let [oneInfo, oneHistory] = await Promise.all([task1, task2]);
+
+    if (oneInfo && oneHistory) {
+        version = _.max([oneInfo.version, oneHistory.version]);
     }
-        throw e;
+    else if (oneInfo && !oneHistory) {
+        version = oneInfo.version;
     }
-};
+    else {
+        return '1.0.0';
+    }
+    return addVersion(version, 1);
+
+}
 
 
-async function buildOneI18nInfoLog(dbOneI18nInfo: any, infoVO: I18nInfoVO) {
+/**
+ * 版本号+1
+ * @param version
+ * @param add
+ */
+function addVersion(version: string, add: number) {
 
-    let i18nInfoLogOne = {
-        //修改前
-        info_id: dbOneI18nInfo.id,
-        platform: dbOneI18nInfo.platform,
-        module: dbOneI18nInfo.module,
-        code: dbOneI18nInfo.code,
-        sub_code: dbOneI18nInfo.sub_code,
-        lang: dbOneI18nInfo.lang,
-        desc: dbOneI18nInfo.desc,
-        content: dbOneI18nInfo.content,
+    let versionStrArr = version.split('.');
+    let versionNumArr: number[] = []
+    for (let i = 0; i < versionStrArr.length; i++) {
+        versionNumArr[i] = Number(versionStrArr[i]);
+    }
 
-        //修改后
-        platform_after: infoVO.platform ? infoVO.platform : dbOneI18nInfo.platform,
-        module_after: infoVO.module ? infoVO.module : dbOneI18nInfo.module,
-        code_after: infoVO.code ? infoVO.code : dbOneI18nInfo.code,
-        sub_code_after: infoVO.sub_code ? infoVO.sub_code : dbOneI18nInfo.sub_code,
-        lang_after: infoVO.lang ? infoVO.lang : dbOneI18nInfo.lang,
-        desc_after: infoVO.desc ? infoVO.desc : dbOneI18nInfo.desc,
-        content_after: infoVO.content ? infoVO.content : dbOneI18nInfo.content
+    for (let i = versionNumArr.length - 1; i >= 0; i--) {
+        versionNumArr[i] += add;
+        while (versionNumArr[i] >= 10) {
+            versionNumArr[i] -= 10;
+            if (i > 0) {
+                versionNumArr[i - 1]++;
+            }
+        }
+        add = 0;
     }
 
+    return versionNumArr.join('.');
 
-    return i18nInfoLogOne;
 }

src/functional/mvc/service/i18nlog.service.ts

 // @madex/ex-ts-dao 是 ts 的 dao, 代码在 bitbucket/ex-js-dao 的 ts 分支上
-import { i18nInfo, i18nInfoLog, ormDB } from "@madex/ex-ts-dao";
+import { i18nInfo, i18nInfoHistory, ormDB } from "@madex/ex-ts-dao";
 import * as i18nService from "./i18n.service";
-import { I18nInfoPageVO, I18nInfoVO } from "./i18n.service";
+import { getLastVersionList, I18nInfoPageVO, I18nInfoVO } from "./i18n.service";
 import { ErrorCode } from "../../../constant/errorCode";
+import { addOptLog } from "./userOptLog.service";
+import { ROBOT_KEYS, sendRobotMessage } from "../../../utils/robotUtils";
+
+let { logger } = require('@madex/ex-js-public');
 
 export interface I18nInfoLogVO extends I18nInfoPageVO {
     info_id?: number;
+
+    version: string;
 }
 
 
 export async function list(i18nInfoLogVO: I18nInfoLogVO) {
-
-    if (i18nInfoLogVO.code) {
-        i18nInfoLogVO.code = { [ormDB.Op.like]: `${i18nInfoLogVO.code}%` };
+    let condition = {};
+    if (i18nInfoLogVO.platform) {
+        condition['platform'] = Number(i18nInfoLogVO.platform);
     }
-
-    if (i18nInfoLogVO.sub_code) {
-        i18nInfoLogVO.sub_code = { [ormDB.Op.like]: `${i18nInfoLogVO.sub_code}%` };
+    if (i18nInfoLogVO.module) {
+        condition['module'] = Number(i18nInfoLogVO.module);
     }
-    if (i18nInfoLogVO.desc) {
-        i18nInfoLogVO.desc = { [ormDB.Op.like]: `${i18nInfoLogVO.desc}%` };
+    if (i18nInfoLogVO.code) {
+        condition['code'] = i18nInfoLogVO.code;
     }
-    if (i18nInfoLogVO.updatedAt) {
-        i18nInfoLogVO.updatedAt = { [ormDB.Op.gte]: new Date(i18nInfoLogVO.updatedAt).getTime() };
+    if (i18nInfoLogVO.zh_cn) {
+        condition['zh_cn'] = { [ormDB.Op.like]: `${i18nInfoLogVO.zh_cn}%` };
     }
+
     let page = Number(i18nInfoLogVO.page);
     let size = Number(i18nInfoLogVO.size);
-    let where = Object.assign(i18nInfoLogVO);
-    delete i18nInfoLogVO.page;
-    delete i18nInfoLogVO.size;
-    let resList = await i18nInfoLog.prototype.findAndCount({
-        where: where,
+    let resList = await i18nInfoHistory.prototype.findAndCount({
+        where: condition,
         limit: size,
         offset: (page - 1) * size,
-        order: [["updatedAt", "desc"]],
+        order: [["id", "asc"]],
         raw: true
     });
     return resList;
 }
 
-export const add = async (infoLogVO: any, tx: any) => {
-    if (!infoLogVO.createdAt) {
-        infoLogVO.createdAt = new Date();
-    }
-    if (!infoLogVO.updatedAt) {
-        infoLogVO.updatedAt = new Date();
-    }
-    await i18nInfoLog.prototype.create(infoLogVO, {
-        transaction: tx,
-    });
-};
 
 export async function revert(i18nInfoLogVO: I18nInfoLogVO, currentUserId: any, ip: any) {
-    let dbOneI18nInfoLog = await i18nInfoLog.prototype.findOne({
-        raw: true,
+    let dbHistoryList = await i18nInfoHistory.prototype.findAll({
         where: {
-            id: i18nInfoLogVO.id
-        }
+            version: i18nInfoLogVO.version
+        },
+        order: [['info_id', 'asc']],
+        raw: true,
     });
-    if (!dbOneI18nInfoLog) {
-        throw ErrorCode.DATA_NOT_EXIST;
+
+    let insertInfoList: any = [];
+    let insertHistoryList: any = [];
+
+    for (let item of dbHistoryList) {
+        delete item.info_id;
+        delete item.id;
+        insertInfoList.push(item);
     }
-    let infoId = dbOneI18nInfoLog.info_id;
 
-    let dbOneI18nInfo = await i18nInfo.prototype.findOne({
-        raw: true,
-        where: {
-            id: infoId
+    let currentVersionList = await getLastVersionList();
+
+    let current_version = "";
+    for (let item of currentVersionList) {
+        current_version = item.version;
+        let info_id = item.id;
+        item.info_id = info_id;
+        item.created_at = item.updated_at;
+        delete item.id;
+        insertHistoryList.push(item)
     }
+
+    let tx;
+
+    try {
+        tx = await ormDB.transaction();
+        if (insertInfoList.length) {
+            //删除历史版本
+            await i18nInfoHistory.prototype.destroy({
+                where: {
+                    version: i18nInfoLogVO.version
+                },
+                transaction: tx
             });
-    let itemInfo = {
-        platform: dbOneI18nInfoLog.platform,
-        module: dbOneI18nInfoLog.module,
-        code: dbOneI18nInfoLog.code,
-        sub_code: dbOneI18nInfoLog.sub_code,
-        lang: dbOneI18nInfoLog.lang,
-        desc: dbOneI18nInfoLog.desc,
-        content: dbOneI18nInfoLog.content,
-        createdAt: dbOneI18nInfoLog.createdAt,
-        updatedAt: dbOneI18nInfoLog.updatedAt,
-    }
-    if (!dbOneI18nInfo) {
-        await i18nService.add(itemInfo, currentUserId, ip);
+            //删除当前版本
+            await i18nInfo.prototype.destroy({
+                where: {},
+                transaction: tx
+            });
+            //当前版本存入历史
+            await i18nInfoHistory.prototype.bulkCreate(insertHistoryList, {
+                transaction: tx
+            });
+            //恢复到传入的历史版本
+            await i18nInfo.prototype.bulkCreate(insertInfoList);
         }
-    else {
-        delete itemInfo.createdAt;
-        await i18nInfo.prototype.update(itemInfo, {
-            where: {
-                id: infoId
+        await tx.commit();
     }
-        });
+    catch (e) {
+        if (tx) {
+            await tx.rollback();
         }
-    await i18nInfoLog.prototype.destroy({
-        where: {
-            id: Number(i18nInfoLogVO.id)
+        logger.error('i18nInfo.add.error:' + e);
+        throw e;
     }
-    });
-    return 'ok';
-
+    //管理后台操作日志
+    addOptLog(currentUserId, 0, '国际化信息版本回退', ip, `当前版本:${current_version},回退到:${i18nInfoLogVO.version}`, '国际化管理');
+    sendRobotMessage(ROBOT_KEYS.COMMON_KEY, `国际化信息版本回退:当前版本:${current_version},回退到:${i18nInfoLogVO.version}`);
+    return 'success';
 }
\ No newline at end of file

src/functional/router/v1/index.ts

@@ -55,12 +55,12 @@ const getFunc = {
 
 const postFunc = {
     //技术部-其他管理-国际化管理
-    'i18n/info/list': i18nCtrl.list,
-    'i18n/info/add': i18nCtrl.add,
-    'i18n/info/update': i18nCtrl.update,
-    'i18n/info/del': i18nCtrl.del,
-    'i18n/info/log/list': i18nLogCtrl.list,
-    'i18n/info/log/revert': i18nLogCtrl.revert,
+    'i18n/info/list': i18nCtrl.list,//当前版本信息列表
+    'i18n/info/add': i18nCtrl.add,//发布版本
+    'i18n/info/preview': i18nCtrl.preview,//发布版本-预览
+    'i18n/info/version/list': i18nCtrl.versionList,//版本列表
+    'i18n/info/history/list': i18nLogCtrl.list,//历史版本信息列表
+    'i18n/info/history/revert': i18nLogCtrl.revert,//版本回退
     //金融部-交易管理-交易对配置
     'spotPair/save': spotPairCtrl.save,//新增
     'spotPair/update': spotPairCtrl.update,//修改

src/setting/access-limit.ts

@@ -12,10 +12,10 @@ let cmdWhiteList = {
     //技术部-其他管理-国际化管理
     'i18n/info/list': 1,
     'i18n/info/add': 1,
-    'i18n/info/update': 1,
-    'i18n/info/del': 1,
-    'i18n/info/log/list': 1,
-    'i18n/info/log/revert': 1,
+    'i18n/info/preview': 1,
+    'i18n/info/version/list': 1,
+    'i18n/info/history/list': 1,
+    'i18n/info/history/revert': 1,
     //金融部-交易管理-交易对配置
     'spotPair/save': 1,
     'spotPair/update': 1,