Calculation/app/public/report/js/rpt_indexDb.js

/**
 * Created by Tony on 2021/11/5.
 * 实现本地indexDb的业务操作
 */

const indexDbOprObj = {
    currentDb: null,
    tb_name_request: 'tb_ReportRequests',   // 记录报表请求信息，在不同的场景传递中有用
    tb_name_page: 'tb_ReportPages',         // 记录已请求并返回的报表结果信息
    iniDb: function (dbName, version) {
        let rst = window.indexedDB.open(dbName, version);
        rst.onsuccess = function (event) {
            indexDbOprObj.currentDb = event.target.result;
            console.log('数据库打开成功！');
        };
        rst.onupgradeneeded = function (event) {
            let db = event.target.result;
            indexDbOprObj.currentDb = db;
            console.log('数据库升级及初始化！');
            indexDbOprObj._iniTable(db);
        }
    },
    _iniTable: function(db) {
        if (db) {
            //本地表，主要是用来储存报表结果对象，主要是为PDF多表导出用，当然，其他方式也是可以用的(如打印)，看实际需要
            if (!db.objectStoreNames.contains(this.tb_name_page)) {
                db.createObjectStore(this.tb_name_page, { keyPath: 'id' });
            }
            if (!db.objectStoreNames.contains(this.tb_name_request)) {
                db.createObjectStore(this.tb_name_request, { keyPath: 'id' });
            }
        }
    },
    batchAdd: function (tbName, datas, signatureRelArr, cb) {
        let db =  indexDbOprObj.currentDb;
        let ttlAmt = datas.length;
        // console.log(`已选报表数量：${ttlAmt}`);
        let cnt = 0;
        let store = db.transaction([tbName], 'readwrite').objectStore(tbName);
        for (let data of datas) {
            let request = store.add(data);
            request.onsuccess = function (event) {
                cnt++;
                // console.log(`已选加数量：${cnt}`);
                if (cnt === ttlAmt && cb) {
                    cb(datas, signatureRelArr);
                }
            };
        }
    },
    getOne: function (tbName, id, cb = null) {
        let db =  indexDbOprObj.currentDb;
        // let objectStore = db.transaction(tbName).objectStore(tbName);
        let objectStore = db.transaction([tbName], 'readwrite').objectStore(tbName);
        let request = objectStore.get(id);
        request.onsuccess = function (event) {
            let data = event.target.result;
            if (cb) cb(data);
        }
    },
    getAll: function (tbName, idRst, cb = null) {
        let db =  indexDbOprObj.currentDb;
        let objectStore = db.transaction(tbName).objectStore(tbName);
        let amt = 0;
        objectStore.openCursor().onsuccess = function (event) {
            let cursor = event.target.result;
            if (cursor) {
                if (idRst) {
                    idRst.push(cursor.key);
                }
                amt++;
                cursor.continue();
            } else {
                console.log(`已取数量：${amt}`);
                if (cb) {
                    cb(idRst);
                }
            }
        };
    },
    storeReportRequest: function (stage_id, rptNodes, isArchive = false, cb = null) {
        if (rptNodes && rptNodes.length > 0) {
            indexDbOprObj.removeAll(()=>{
                let datas = [];
                for (let node of rptNodes) {
                    let keyStr = `_${stage_id}_${node.refId}`;
                    let gather_select = null;
                    let stage_select = null;
                    if (customSelects) {
                        gather_select = customSelects.gather_select.find(function (x) {
                            return x.id === node.refId;
                        });
                        stage_select = customSelects.stage_select.find(function (x) {
                            return x.id === node.refId;
                        });
                    }
                    let data = {id: keyStr, name: node.name, rpt_id: node.refId, stage_id, gather_select, stage_select, pageSize: rptControlObj.getCurrentPageSize(), CFG: CUST_CFG};
                    datas.push(data);
                }
                indexDbOprObj.batchAdd(this.tb_name_request, datas, [], (rstArr)=>{
                    console.log('batch add succeeded!');
                    console.log(rstArr);
                    //其他操作
                    if (rstArr.length > 0 && cb) {
                        cb(stage_id, rptNodes, isArchive);
                    }
                });
            });
        }
    },
    startRequestReport: async function(stage_id, rptNodes, isArchive = false) {
        //划重点：这里要能处理所有相关的报表请求，除非是带选择的，否则就要静悄悄地处理完，带选择的只需要选择一次同类型的！！！
        //第一步：只需要请求数据并保存
        //第二步：所有请求数据完备后，才开始转PDF并上传
        //所有这些处理都是异步的！！！
        //1. 开始，初始化
        let gather_select_param = null;
        let stage_select_param = null;
        let idRst = [];
        let normal_request = [], gather_request = [], stage_request = [];
        let db =  indexDbOprObj.currentDb;
        let needWaterMark = false;
        if (COMMON_WATER_MARK_PIC_DATA === null || COMMON_WATER_MARK_PIC_DATA === '') {
            needWaterMark = true;
        }
        const _requestNormalReport = async function() {
            let refRptTplIds = [], rpt_names = [], splitArchives = [];
            for (let req of normal_request) {
                //{id: keyStr, name: node.name, rpt_id: node.refId, stage_id, gather_select, stage_select, pageSize: rptControlObj.getCurrentPageSize(), CFG: CUST_CFG}
                refRptTplIds.push(req.rpt_id);
                rpt_names.push(req.name);
                let splitArcObj = null;
                for (let rnIdx = 0; rnIdx < rptNodes.length; rnIdx++) {
                    if (rptNodes[rnIdx].refId === req.rpt_id) {
                        if (rptNodes[rnIdx].flags && rptNodes[rnIdx].flags.amendmentType === 'splitArchive') {
                            splitArcObj = {rpt_id: rptNodes[rnIdx].refId, split_field_id: parseInt(rptNodes[rnIdx].flags.splitArchiveField)};
                        }
                        break;
                    }
                }
                splitArchives.push(splitArcObj);
            }
            let params = rptControlObj.creatCommonExportParam(refRptTplIds);
            params.splitArchives = splitArchives;
            if (customSelects) await rptCustomObj.getCustomSelect(params);
            // params.customSelect = [];
            params.needWaterMark = needWaterMark;
            params.isArchive = isArchive;
            indexDbOprObj._getRptDataForDb(params, rpt_names, stage_id, (records, rstRoleRel)=>{
                console.log('the normal type page results have been saved!');
                // console.log(records);
                _createPDF(0, records, rptNodes, rstRoleRel, ()=>{
                    console.log('the normal type archive PDFs have been created!');
                    let ids = [];
                    for (let rec of records) {
                        ids.push(rec.id);
                    }
                    indexDbOprObj.remove(indexDbOprObj.tb_name_request, ids);
                    indexDbOprObj.remove(indexDbOprObj.tb_name_page, ids);
                    _requestGatherReport();
                });
            });
        };
        const _requestGatherReport = function(rstRoleRel) {
            if (gather_request.length > 0) {
                let refRptTplIds = [], rpt_names = [];
                for (let req of gather_request) {
                    //{id: keyStr, name: node.name, rpt_id: node.refId, stage_id, gather_select, stage_select, pageSize: rptControlObj.getCurrentPageSize(), CFG: CUST_CFG}
                    refRptTplIds.push(req.rpt_id);
                    rpt_names.push(req.name);
                }
                let params = rptControlObj.creatCommonExportParam(refRptTplIds);
                params.customSelect = [];
                params.needWaterMark = needWaterMark;
                indexDbOprObj._getRptDataForDb(params, rpt_names, stage_id, (records, rstRoleRel)=>{
                    console.log('the normal type page results have been saved!');
                    // console.log(records);
                    _createPDF(0, records, rptNodes, rstRoleRel, ()=>{
                        console.log('the normal type archive PDFs have been created!');
                        let ids = [];
                        for (let rec of records) {
                            ids.push(rec.id);
                        }
                        indexDbOprObj.remove(indexDbOprObj.tb_name_request, ids);
                        indexDbOprObj.remove(indexDbOprObj.tb_name_page, ids);
                        _requestStageReport();
                    });
                });
            } else {
                _requestStageReport();
            }
        };
        const _requestStageReport = function() {
            console.log('go on stage report...');
        };
        indexDbOprObj.getAll(indexDbOprObj.tb_name_request, idRst, (ids)=>{
            if (ids && ids.length > 0) {
                let cnt = 0;
                let store = db.transaction([indexDbOprObj.tb_name_request], 'readwrite').objectStore(indexDbOprObj.tb_name_request);
                for (let id of ids) {
                    let request = store.get(id);
                    request.onsuccess = function(event) {
                        cnt++;
                        if (request.result) {
                            // if (request.result.gather_select) {
                            //     gather_request.push(request.result);
                            // } else if (request.result.stage_select) {
                            //     stage_request.push(request.result);
                            // } else {
                            //     normal_request.push(request.result);
                            // }
                            normal_request.push(request.result);
                        } else {
                            // console.log('未获得数据记录');
                        }
                        if (cnt === ids.length) {
                            //下一步处理
                            _requestNormalReport();
                        }
                    };
                }
            }
        });
    },
    removeAll: function(cb = null) {
        let tbArr = [indexDbOprObj.tb_name_request, indexDbOprObj.tb_name_page];
        let tbAmt = 0;
        for (let tbName of tbArr) {
            tbAmt++;
            let idRst = [];
            indexDbOprObj.getAll(tbName, idRst, (ids)=>{
                if (ids && ids.length > 0) {
                    let db =  indexDbOprObj.currentDb;
                    let store = db.transaction([tbName], 'readwrite').objectStore(tbName);
                    let amt = 0;
                    for (let id of ids) {
                        let req = store.delete(id);
                        req.onsuccess = function (event) {
                            amt++;
                            if (tbAmt === tbArr.length && amt === ids.length && cb) {
                                cb();
                            }
                        };

                    }
                } else if (tbAmt === tbArr.length && cb) {
                    cb();
                }
            });
        }
    },
    remove: function(tbName, ids) {
        if (ids && ids.length > 0) {
            let db =  indexDbOprObj.currentDb;
            let store = db.transaction([tbName], 'readwrite').objectStore(tbName);
            for (let id of ids) {
                store.delete(id);
            }
        }
    },
    _getRptDataForDb: async function(params, rpt_names, stage_id, cb) {
        CommonAjax.postXsrfEx("/tender/report_api/getMultiReports", params, 60000, true, getCookie('csrfToken_j'),
            async function(result){
                const signatureRelArr = [];
                STAGE_AUDIT = result.stageAudit;
                if (params.needWaterMark) sessionStorage.waterMarkStr = result.waterMarkStr;
                for (const signatureRel of result.signatureRelInfo) {
                    signatureRelArr.push(JSON.parse(signatureRel.rel_content));
                }
                for (let idx = 0; idx < result.data.length; idx++) {
                    let singleSignatureRelArr = [];
                    for (let rIdx = 0; rIdx < result.signatureRelInfo.length; rIdx++) {
                        if (result.signatureRelInfo[rIdx].rpt_id === params.rpt_ids[idx]) {
                            singleSignatureRelArr = signatureRelArr[rIdx]; // 有些报表可能没有签名
                            break;
                        }
                    }
                    for (const pageData of result.data) {
                        await rptSignatureHelper.resetDummySignature(pageData, null); //
                    }
                    if (params.stage_status === 3) {
                        rptSignatureHelper.mergeSignDate(result.data[idx], singleSignatureRelArr, false);
                        rptSignatureHelper.mergeSignature(result.data[idx], singleSignatureRelArr, true); //这里要把签名数据设置进来
                        rptSignatureHelper.mergeSignAudit(result.data[idx], singleSignatureRelArr, result.stageAudit);
                    }
                }
                let multiRptData = result.data;
                let datas = [];
                for (let idx = 0; idx < multiRptData.length; idx++) {
                    // this._storeReportPages(multiRptData[idx], stage_id, params.rpt_ids[idx], cb);
                    let keyStr = `_${stage_id}_${params.rpt_ids[idx]}`;
                    let data = {id: keyStr, rpt_id: params.rpt_ids[idx], rpt_name: rpt_names[idx], stage_id, pageData: multiRptData[idx]};
                    datas.push(data);
                }
                indexDbOprObj.batchAdd(indexDbOprObj.tb_name_page, datas, signatureRelArr, (rstArr, rstRoleRel)=>{
                    cb(rstArr, rstRoleRel);
                });
            },
            function(failRst){
                // sessionStorage.currentPageData = null;
                console.log(failRst);
            },
            function(exceptionRst){
                // sessionStorage.currentPageData = null;
                console.log(exceptionRst);
            }
        );
    },
    _startToCreatePDF: function(idArr) {
        //
    }
};

function _createPDF(currentIdx, records, rptNodes, rstRoleRel, cb) {
    if (currentIdx === records.length) {
        if (cb) {
            cb();
        }
    } else {
        let rec = records[currentIdx];
        let curRoleRel = rstRoleRel[currentIdx];
        let nextIdx = currentIdx + 1;
        indexDbOprObj.getOne(indexDbOprObj.tb_name_page, rec.id, (record)=>{
            for (let node of rptNodes) {
                if (node.refId === record.rpt_id) {
                    // curRoleRel
                    rptArchiveObj.archiveCurrentReport(record.pageData, node, curRoleRel, (err, msg, uuid)=>{
                        _createPDF(nextIdx, records, rptNodes, rstRoleRel, cb);
                    });
                    break;
                }
            }
        });
    }
};