YangHuCost/modules/main/controllers/bills_controller.js

/**
 * Created by jimiz on 2017/4/7.
 */
let mongoose = require('mongoose');
var billsData = require('../models/bills');
let ration_model = require('../models/ration');
let ProjectsData = require('../../pm/models/project_model').project;
let logger = require("../../../logs/log_helper").logger;
let quantity_detail = require("../facade/quantity_detail_facade");
let bill_facade = require("../facade/bill_facade");
let raiton_facade = require("../facade/ration_facade");
let stdBillsModel = mongoose.model('std_bills_lib_bills');
let stdBillJobsModel = mongoose.model('std_bills_lib_jobContent');
let stdBillCharacterModel = mongoose.model('std_bills_lib_itemCharacter');
const { fixedFlag } = require('../../../public/common_constants');
let LZString = require('lz-string');
const uuidV1 = require('uuid/v1');
const billType = {
    DXFY: 1,//大项费用
    FB: 2,//分部
    FX: 3,//分项
    BILL: 4,//清单
    BX: 5//补项
};
//上传的09表、广联达表
const uploadType = { lj: 'lj', gld: 'gld' };
// 上传控件
const multiparty = require("multiparty");
const fs = require("fs");
// excel解析
const excel = require("node-xlsx");
const urlencode = require('urlencode');
//统一回调函数
var callback = function (req, res, err, message, data) {
    res.json({ error: err, message: message, data: data });
};

module.exports = {
    getData: function (req, res) {
        var data = JSON.parse(req.body.data);
        billsData.getData(data.projectId, function (err, message, billsList) {
            if (err === 0) {
                callback(req, res, err, message, billsList);
            } else {
                callback(req, res, err, message, null);
            }
        });
    },

    getItemTemplate: function (req, res) {
        //var data = JSON.parse(req.body.data);
        billsData.getItemTemplate(function (err, message, billsItem) {
            if (billsItem) {
                callback(req, res, err, message, billsItem);
            } else {
                callback(req, res, err, message, null);
            }
        });
    },

    allocIDs: function (req, res) {
        billsData.allocIDs(function (err, message, data) {
            if (err) {
                callback(req, res, err, message, data);
            } else {
                callback(req, res, err, message, null);
            }
        });
    },
    //zhong 2017-9-1
    updateCharacterContent: function (req, res) {
        let data = JSON.parse(req.body.data);
        let findSet = data.findSet,
            updateObj = data.updateObj,
            txtObj = data.txtObj;
        billsData.updateCharacterContent(findSet, updateObj, txtObj, function (err, message) {
            callback(req, res, err, message, null);
        });
    },
    updateBills: async function (req, res) {
        try {
            let data = JSON.parse(req.body.data);
            await billsData.updateBills(data.updateDatas);
            callback(req, res, 0, 'success', null);
        }
        catch (err) {
            callback(req, res, 1, err, null);
        }
    },
    updateBill: async function (request, response) {
        const data = JSON.parse(request.body.data);
        const findSet = data.findSet;
        const updateData = data.updateData;
        let settingData = {};
        // 筛选出要保存在项目属性的设置
        for (const index in updateData) {
            if (updateData[index].field === 'addRule') {
                settingData = updateData[index].value;
                delete updateData[index];
            }
        }
        /* // 更新项目属性
         const propertyUpdateData = {
         property: 'addRule',
         data: settingData
         };*/
        //const projectResult = await ProjectsData.updateProjectProperty(findSet.projectID, propertyUpdateData);

        const result = await billsData.updateBill(findSet, updateData);
        const message = !result ? '修改失败' : '修改成功';
        const err = !result ? 1 : 0;
        callback(request, response, err, message, null);
    },
    singleDelete: async function (req, res) {
        let result = {
            error: 0
        }
        try {
            let data = req.body.data;
            data = JSON.parse(data);
            let tasks = generateSingleDeleteTasks(data);
            let resultData = await billsData.model.bulkWrite(tasks);
            //删除工程量明细
            await quantity_detail.deleteByQuery({ projectID: data.projectID, billID: data.ID });
            result.data = resultData;
        } catch (err) {
            logger.err(err);
            result.error = 1;
            result.message = err.message;
        }
        res.json(result);
    },
    multiDelete: async function (req, res) {
        let result = {
            error: 0
        };
        try {
            let data = req.body.data;
            data = JSON.parse(data);
            result.data = await doBillsOrRationsDelete(data);
        } catch (err) {
            logger.err(err);
            result.error = 1;
            result.message = err.message;
        }
        res.json(result);
    },
    getSectionInfo: async function (req, res) {
        let result = {
            error: 0
        }
        try {
            let data = req.body.data;
            data = JSON.parse(data);
            let sectionInfo = await bill_facade.getSectionInfo(data);
            result.data = sectionInfo;
        } catch (err) {
            logger.err(err);
            result.error = 1;
            result.message = err.message;
        }
        res.json(result);
    },
    reorganizeFBFX: async function (req, res) {
        let result = {
            error: 0
        }
        try {
            let data = req.body.data;
            data = JSON.parse(data);
            let reorganizeResult = await bill_facade.reorganizeFBFX(data);
            result.data = reorganizeResult;
        } catch (err) {
            logger.err(err);
            result.error = 1;
            result.message = err.message;
        }
        res.json(result);
    },
    pasteBlock: async function (req, res) {
        let result = {
            error: 0
        };
        try {
            let data = req.body.data;
            data = JSON.parse(data);
            let pasteResult = await bill_facade.pasteBlock(data, req.session.sessionCompilation);
            result.data = pasteResult;
        } catch (err) {
            logger.err(err);
            result.error = 1;
            result.message = err.message;
        }
        res.json(result);
    },
    //下载导入清单示例
    downloadExample: async function (request, response) {
        try {
            const filePath = './public/static/清单示例.xlsx';
            const stats = fs.statSync(filePath);
            // 下载相关header
            const name = urlencode('清单示例.xlsx');
            //res.setHeader("Content-Disposition", "attachment; filename* = UTF-8''"+name);
            response.set({
                'Content-Type': 'application/octet-stream',
                'Content-Disposition': "attachment; filename* = UTF-8''" + name,
                'Content-Length': stats.size
            });
            fs.createReadStream(filePath).pipe(response);
        } catch (error) {
            response.end(error);
        }

    },
    //导入清单
    import: async function (req, res) {
        let responseData = {
            err: 0,
            msg: '',
            data: []
        };
        const form = new multiparty.Form();
        form.parse(req, async function (err, fields, files) {
            try {
                const projectID = fields.projectID !== undefined && fields.projectID.length > 0 ?
                    parseInt(fields.projectID[0]) : 0;
                if (projectID <= 0) {
                    throw '参数错误';
                }
                //导入清单数据
                let compressData = fields.compressData !== undefined && fields.compressData.length > 0 ?
                    fields.compressData[0] : null;
                if (compressData === null) {
                    throw 'excel没有对应数据'
                }
                let { insertData, removeData } = JSON.parse(LZString.decompressFromUTF16(compressData));
                //导入表
                let importDateA = +new Date();
                let updateFrontData = await importSheet(insertData, removeData, req.session.sessionUser.id, projectID);
                if (updateFrontData) {
                    responseData.data.push(updateFrontData);
                }
                let importDateB = +new Date();
                console.log(`导入时间: ${importDateB - importDateA}=========================================================================`);
                res.json(responseData);
            }
            catch (error) {
                responseData.err = 1;
                console.log(error);
                responseData.msg = typeof error === 'object' ? '上传失败' : error;
                res.json(responseData);
            }

        });
    },
    insertBills: async function (req, res) {
        let data = JSON.parse(req.body.data);
        try {
            await bill_facade.insertBills(data.postData);
            callback(req, res, 0, 'success', null);
        } catch (err) {
            callback(req, res, 1, err, null);
        }
    }
};

async function importSheet(excelBills, removeData, userID, projectID,) {
    //导入位置的有固定行
    let flag = fixedFlag.ONE_SEVEN_BILLS;   //第100章至700章清单
    let fixedBill = await billsData.model.findOne({ projectID: projectID, 'flags.flag': flag, deleteInfo: null });
    //删除相关数据
    // let deleteDatas = await billsData.deepDeleteBill([fixedBill], userID, projectID);
    let deleteDatas = await billsData.newDeepDeleteBill(removeData.rBillIDs, removeData.rRationIDs);
    //新增清单数据
    await billsData.importBills(excelBills);
    //返回数据以更新前端
    return { fixedBill: fixedBill, insert: { bill: excelBills, ration: [] }, remove: { bill: deleteDatas.bill, ration: deleteDatas.ration } };
}


function getImportFlag(position) {
    const fixedItem = { 'fbfx': fixedFlag.SUB_ENGINERRING, 'jscsxm': fixedFlag.CONSTRUCTION_TECH, 'zzcsxm': fixedFlag.CONSTRUCTION_ORGANIZATION };
    return fixedItem[position] ? fixedItem[position] : null;
}
function isDef(data) {
    return typeof data !== 'undefined' && data !== null && data !== '';
}

async function doBillsOrRationsDelete(data) {
    let billTask = [];
    let deleteBillIDs = [];
    let rationTask = [];
    let deleteRationIDs = [];
    let qd_query = null;
    let sub_query = null;
    if (data['bills']) {
        billTask = generateUpdateTasks(data['bills'], data.projectID, data.user_id);
        for (let b_key in data['bills']) {
            if (data['bills'][b_key] === true) {
                deleteBillIDs.push(b_key + '');
            }
        }
        if (deleteBillIDs.length > 0) {
            qd_query = { projectID: data.projectID, billID: { "$in": deleteBillIDs } };
        }
    }
    if (data['ration']) {
        rationTask = generateUpdateTasks(data['ration'], data.projectID, data.user_id);
        for (let r_key in data['ration']) {
            if (data['ration'][r_key] === true) {
                deleteRationIDs.push(r_key + '');
            }
        }
        if (deleteRationIDs.length > 0) {
            if (qd_query == null) {//说明没删除清单
                qd_query = { projectID: data.projectID, rationID: { "$in": deleteRationIDs } };
            } else {
                qd_query = {
                    "$or": [
                        { projectID: data.projectID, billID: { "$in": deleteBillIDs } },
                        { projectID: data.projectID, rationID: { "$in": deleteRationIDs } }
                    ]
                }
            }
            sub_query = { projectID: data.projectID, rationID: { "$in": deleteRationIDs } };
        }
    }
    //先删除工程量明细
    if (qd_query != null) {
        await quantity_detail.deleteByQuery(qd_query);
    }
    if (sub_query != null) {
        await raiton_facade.deleteSubListByQuery(sub_query);
    }
    if (rationTask.length > 0) {
        await ration_model.model.bulkWrite(rationTask);//删除定额
    }
    if (billTask.length > 0) {
        await billsData.model.bulkWrite(billTask);//删除清单
    }
    return 'success';
}



function generateSingleDeleteTasks(data) {
    let updateData = data.updateData;
    updateData[data.ID] = true;
    let tasks = generateUpdateTasks(updateData, data.projectID, data.user_id);
    return tasks;
}

function generateUpdateTasks(data, projectID, user_id) {
    let tasks = [];
    let updateData = data;
    let deleteInfo = { deleted: true, deleteDateTime: new Date(), deleteBy: user_id };
    for (let key in updateData) {
        let task = {
            updateOne: {
                filter: {
                    ID: key,
                    projectID: projectID
                }
            }
        };
        if (updateData[key] === true) {
            //原先是假删除，现在改成真删除
            task = {
                deleteOne: {
                    filter: {
                        ID: key,
                        projectID: projectID
                    }
                }
            }
            /* task.updateOne.update={
             deleteInfo:deleteInfo
             };*/
        } else {
            task.updateOne.update = updateData[key];
        }
        tasks.push(task);
    }
    return tasks;
}