WuXia/assets/Scripts/Mgr_LocalData/Base/BaseLocalDataProxy.ts

import Md5 from './Md5';
import BaseDataProxy from './BaseDataProxy';
import BaseData from './BaseData';
import ObjectProxyT from './ObjectProxyT';
import { MainConfig }from '../../../Launch/_MainConfig';
import LocalStorage from '../LocalStorage';

/**
 * 基类本地数据代理，通过此类可以访问本地保存的数据
 * 泛型为数据类型
 */
export default abstract class BaseLocalDataProxy<Data extends BaseData> extends BaseDataProxy<Data> {
    /**
     * 是否对比数据
     * 默认为true，如果为真当为线上模式时会生成一个加密的对比数据，防止用户改动本地数据
     */
    protected _ifDifferData: boolean = true;
    
    protected _Versions:number = 1;

    /** 
     * 获取保存名称
     * 默认返回类名，可以重写
     */
    protected get _saveName(): string {
        //默认返回类名
        return this.constructor.name;
    }

    //获取保存数据的名字
    private get saveName(): string {
        //项目名字 + 保存名字 + 项目版本
        //_MainConfig.Name
        return `${""}_${this._saveName}`
    }

    // 获取对比数据的保存名字
    private get differName(): string {
        //
        return this.encrypt(this.saveName + '__verify');
    }

    /**
     * 初始化数据
     */
    public  initData() {
        //记录时间
        let _time = Date.now();
        this.m_data = null;
        //
        this.m_data = this._readData();
        //设置代理包装数据
        if (this.m_ifSetProxy) {
            //获取数据代理工具
            this.m_objectProxyT = new ObjectProxyT();
            this.m_data = this.m_objectProxyT.setProxy(this.m_data);
            //添加设置监听
            this.m_objectProxyT.addMonitor(this, this._dataSetMonitor);
        }
        //
        this._initData();
        //判断时间差
        _time = Date.now() - _time;
        if (_time > 100) {
            ConsoleEx.Warn('初始化本地数据时间过长', this.saveName, _time)
        }
    }



    /** 初始化完成，继承使用 */
    protected _initData() { }


    public initLogic(){
        ConsoleEx.Log(this._saveName)
        this._initLogic();
    }

    /**数据初始化后 逻辑处理 */
    protected  _initLogic(){

    }

    public ClearData(){
        this._ClearData();
    }

    protected _ClearData(){

    }

    public ReBuildData(){
        this._ReBuildData();
        this.Save();
    }

    protected _ReBuildData(){
        // let _time = Date.now();
        // let newdata = this.getNewData();
        // if(this.m_objectProxyT){
        //     this.m_objectProxyT.clearMonitor(this);
        //     delete this.m_objectProxyT;
        //     this.m_objectProxyT = null;
        // }
        // this.save(newdata);
        // //判断时间差
        // _time = Date.now() - _time;
        // if (_time > 100) {
        //     ConsoleEx.Warn('ReBuildData本地数据时间过长', this.saveName, _time)
        // }
    }

    public RepairData(){
        this._RepairData();
    }

    protected _RepairData(){
    }


    /**每日刷新数据 */
    protected _RefreshEveryDay() { };
    /**每周刷新数据 */
    protected _RefreshWeek() { };
    /**每月刷新数据 */
    protected _RefreshMonth() { };

    /** 数据被设置监听 */
    private _dataSetMonitor() {
        this.save(this.m_data);
    }

    /**
     * 手动保存数据
     * @param _ifCl 是否限流 默认为true
     */
    public Save(_ifCl: boolean = true) {
        this.save(this.m_data, _ifCl);
    }

    /** 保存执行队列 */
    private m_saveToDiskQueue: number = 0;
    /**保存时间 */
    private m_saveToDiskTime: number = 0;
    /**读取时间 */
    private m_readToDiskTime: number = 0;
    /**
     * 保存数据到本地
     * @param m_data 数据
     * @param _ifCl 是否限流
     */
    private save(m_data: Data, _ifCl: boolean = true) {
        //添加时间判断
        if (this.m_saveToDiskTime == 0) {
            this.m_saveToDiskTime = Date.now();
        }
        //判断是否限流
        // if (!_ifCl) {
             this._save(m_data);
        // }
        // else {
        //     this.m_saveToDiskQueue++;
        //     //限流，每一次宏任务只保存一次数据
        //     //把保存任务注册进微任务列表，将会在本次数据修改的宏任务完成后并在下次宏任务开始前被全部执行
        //     // queueMicrotask(() => {//某些平台会不兼容
        //     Promise.resolve().then(() => {
        //         this.m_saveToDiskQueue--;
        //         if (this.m_saveToDiskQueue == 0) {
        //             this._save(m_data);
        //         }
        //     }).catch((e) => {
        //         ConsoleEx.Error(e);
        //     });
        // }
    }
    //保存数据到本地
    private _save(m_data?: Data) {
        //序列化
        LocalStorage.setItem(this.saveName, m_data);
        //判断是否是线上环境
        if (MainConfig.OnLine && this._ifDifferData) {
            let json = JSON.stringify(m_data);
            //获取对比数据
            let _differJson = this.getDifferData(json);
            //保存对比数据
            LocalStorage.setItem(this.differName, _differJson);
        }
        //判断时间
        let _time = Date.now() - this.m_saveToDiskTime;
        this.m_saveToDiskTime = 0;
        //判断时间差
        if (_time > 1000) {
            ConsoleEx.Warn('数据保存时间过长', this.saveName, _time);
        }
    }

    //从本地获取数据
    private _readData(): Data {
        if(this.m_readToDiskTime == 0){
            this.m_readToDiskTime = Date.now();
        }
        //读取本地数据
        let data = LocalStorage.getItem(this.saveName);
        //判断是否是线上环境
        if (MainConfig.OnLine && this._ifDifferData) {
            let readStr = JSON.stringify(data);
            //对比数据
            let _differ = LocalStorage.getItem(this.differName);
            if (this.getDifferData(readStr) != _differ) {
                return this._saveNewData();
            }
        }
        //获取一个新的实例
        let _saveData: Data = this.getNewData();
        //判断数据是否被篡改
        try {
            if (data) {
                let jsonData = data;
                //用本地的数据填充当前数据
                for (let key in _saveData) {
                    if(jsonData[key]!=undefined){
                        _saveData[key] = jsonData[key];
                    }
                }
            } else {
                this.logreadTime();
                return this._saveNewData();
            }
        }
        catch {
            this.logreadTime();
            return this._saveNewData();
        }
        this.logreadTime();
        return _saveData;
    }

    logreadTime() {
        //判断时间
        let _time = Date.now() - this.m_readToDiskTime;
        this.m_readToDiskTime = 0;
        //判断时间差
        if (_time > 1000) {
            ConsoleEx.Warn('数据读取时间过长', this.saveName, _time);
        }
    }

    //获取并保存一个新数据
    private _saveNewData(): Data {
        let m_data: Data = this.getNewData();
        //保存数据，不限流
        this.save(m_data as Data, false);
        //
        return m_data as Data;
    }

    //处理对比数据
    private getDifferData(_string: string): string {
        //判断是否为空
        if (!_string) return '';
        //加密
        return this.encrypt(_string);
    }

    //数据单向加密
    private encrypt(_string: string) {
        let _encryptStr: string = `CocosMiniGame-${this.saveName}:${_string}`;
        //判断能否使用md5
        if (Md5.ifUse) {
            return Md5.hashStr(_encryptStr).toString();
        } else {
            //不用任何加密
            return 'noEncrypt';
        }
    }
}