Calculation/app/service/material_list.js

'use strict';

/**
 * 调差清单关联工料表 数据模型
 *
 * @author Mai
 * @date 2018/8/13
 * @version
 */

const auditConst = require('../const/audit').material;

module.exports = app => {
    class MaterialList extends app.BaseService {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            this.tableName = 'material_list';
        }

        /**
         * 添加工料清单关联
         * @return {void}
         */
        async add(data) {
            if (!this.ctx.tender || !this.ctx.material) {
                throw '数据错误';
            }
            const list = [];
            for (const mb of data.mb_id) {
                const newLists = {
                    tid: this.ctx.tender.id,
                    order: this.ctx.material.order,
                    mid: this.ctx.material.id,
                    mb_id: mb,
                    gcl_id: data.gcl_id,
                    xmj_id: data.xmj_id,
                    mx_id: data.mx_id,
                    gather_qty: data.gather_qty,
                    is_join: data.is_join,
                    is_self: 1,
                    in_time: new Date(),
                };
                list.push(newLists);
            }

            // 新增工料
            const result = await this.db.insert(this.tableName, list);
            if (result.affectedRows === 0) {
                throw '新增工料数据失败';
            }
            return await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id);
        }

        /**
         * 删除工料清单关联
         * @param {int} id 工料id
         * @return {void}
         */
        async del(id, mb_id) {
            if (!this.ctx.tender || !this.ctx.material) {
                throw '数据错误';
            }
            const transaction = await this.db.beginTransaction();
            try {
                // 判断是否可删
                await transaction.delete(this.tableName, { id });
                await this.calcQuantityByML(transaction, mb_id);
                await transaction.commit();
                return true;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 修改工料清单关联信息
         * @param {Object} data 工料内容
         * @param {int} order 期数
         * @return {void}
         */
        async save(data, order) {
            if (!this.ctx.tender || !this.ctx.material) {
                throw '数据错误';
            }

            const transaction = await this.db.beginTransaction();
            try {
                const mb_id = data.mb_id;
                delete data.mb_id;
                await transaction.update(this.tableName, data);
                await this.calcQuantityByML(transaction, mb_id);
                await transaction.commit();
                return true;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 修改工料信息
         * @param {Object} data 工料内容
         * @return {void}
         */
        async saveDatas(datas) {
            if (!this.ctx.tender || !this.ctx.material) {
                throw '数据错误';
            }
            // 判断是否可修改
            // 判断t_type是否为费用
            const transaction = await this.db.beginTransaction();
            try {
                for (const data of datas) {
                    const mb_id = data.mb_id;
                    delete data.mb_id;
                    await transaction.update(this.tableName, data);
                    await this.calcQuantityByML(transaction, mb_id);
                }
                await transaction.commit();
                return true;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 应用工料清单到其它清单中
         * @return {void}
         */
        async addOther(data) {
            if (!this.ctx.tender || !this.ctx.material) {
                throw '数据错误';
            }
            const transaction = await this.db.beginTransaction();
            try {
                // 先删除addxmj里所有的清单工料再添加新工料，并重新计算每个工料的单价数量
                // 还要找出删除的工料，更新单价数量
                const list = [];
                const delList = [];
                const materialBills = data.materialBills;
                const mb_idList = [];
                for (const xmj of data.addXmj) {
                    const mlList = await this.getAllDataByCondition({
                        where: {
                            mid: this.ctx.material.id,
                            gcl_id: xmj.gcl_id,
                            xmj_id: xmj.id,
                            mx_id: xmj.mx_id,
                        },
                    });
                    const mbIdList = this._.map(mlList, 'mb_id');
                    mb_idList.push(...mbIdList);
                    delList.push(...this._.map(mlList, 'id'));
                    for (const mb of materialBills) {
                        const newLists = {
                            tid: this.ctx.tender.id,
                            order: mb.order,
                            mid: this.ctx.material.id,
                            mb_id: mb.mb_id,
                            gcl_id: xmj.gcl_id,
                            xmj_id: xmj.id,
                            mx_id: xmj.mx_id,
                            gather_qty: xmj.gather_qty ? xmj.gather_qty : null,
                            quantity: mb.quantity,
                            expr: mb.expr,
                            in_time: new Date(),
                        };
                        list.push(newLists);
                        mb_idList.push(mb.mb_id);
                    }
                }
                // 删除工料清单关联
                if (delList.length > 0) await transaction.delete(this.tableName, { id: delList });
                // 新增工料清单关联
                if (list.length > 0) {
                    const result = await transaction.insert(this.tableName, list);
                    if (result.affectedRows === 0) {
                        throw '新增工料数据失败';
                    }
                }
                // 重算工料和总金额
                const calcMBIdList = this._.uniq(mb_idList);
                if (calcMBIdList.length > 0) {
                    for (const select of calcMBIdList) {
                        await this.calcQuantityByML(transaction, select);
                    }
                }
                // throw 'fail';
                // await this.calcQuantityByML(transaction, select.mb_id);
                await transaction.commit();
                return await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id);
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 修改material_bills的quantity值和计算本期金额
         * @param transaction
         * @param mb_id
         * @return {Promise<*>}
         */
        async calcQuantityByML(transaction, mb_id) {
            // 修改material_bills值
            const mbInfo = await this.ctx.service.materialBills.getDataById(mb_id);
            if (!mbInfo) {
                throw '不存在该工料';
            }
            const sql = 'SELECT SUM(`gather_qty`*`quantity`) as quantity FROM ' + this.tableName + ' WHERE `mid`=? AND `mb_id`=? AND `is_join`=1';
            const sqlParam = [this.ctx.material.id, mb_id];
            const mb_quantity = await transaction.queryOne(sql, sqlParam);
            console.log(mb_quantity);
            const newQuantity = this.ctx.helper.round(mb_quantity.quantity, this.ctx.material.decimal.qty);
            const newTp = this.ctx.helper.round(this.ctx.helper.mul(newQuantity, mbInfo.m_spread), this.ctx.material.decimal.tp);
            const updateData = {
                id: mb_id,
                quantity: newQuantity,
                m_tp: newTp,
                m_tax_tp: this.ctx.helper.round(this.ctx.helper.mul(newTp, (1 + this.ctx.helper.div(mbInfo.m_tax, 100))), this.ctx.material.decimal.tp),
            };
            await transaction.update(this.ctx.service.materialBills.tableName, updateData);
            // 计算本期总金额
            const sql2 = 'SELECT SUM(`m_tp`) as total_price, SUM(IF(`m_tax_tp` is null, `m_tp`, `m_tax_tp`)) as tax_total_price FROM ' + this.ctx.service.materialBills.tableName + ' WHERE `tid` = ? AND `is_summary` = 1';
            const sqlParam2 = [this.ctx.tender.id];
            const tp = await transaction.queryOne(sql2, sqlParam2);
            console.log(tp);
            const updateData2 = {
                id: this.ctx.material.id,
                m_tp: tp.total_price,
                m_tax_tp: tp.tax_total_price,
            };
            return await transaction.update(this.ctx.service.material.tableName, updateData2);
        }

        /**
         * 获取工料清单关联表
         * @param {int} tid 标段id
         * @param {Object} mid 期id
         * @return {void}
         */
        async getMaterialData(tid, mid) {
            const sql = 'SELECT ml.`id`, mb.`code`, mb.`name`, mb.`unit`, ml.`order`, ml.`quantity`, ml.`expr`, ml.`mb_id`, ml.`gcl_id`, ml.`xmj_id`, ml.`mx_id`, ml.`tid`, ml.`mid`, mb.m_spread' +
                ' FROM ' + this.tableName + ' as ml' +
                ' LEFT JOIN ' + this.ctx.service.materialBills.tableName + ' as mb' +
                ' ON ml.`mb_id` = mb.`id`' +
                ' WHERE ml.`tid` = ? AND ml.`mid` = ?';
            const sqlParam = [tid, mid];
            return await this.db.query(sql, sqlParam);
        }

        async getPreMaterialData(tid, mid) {
            const sql = 'SELECT ml.`id`, mb.`code`, mb.`name`, mb.`unit`, ml.`order`, ml.`quantity`, ml.`expr`, ml.`mb_id`, ml.`gcl_id`, ml.`xmj_id`, ml.`mx_id`, ml.`tid`, ml.`mid`, mbh.m_spread' +
                ' FROM ' + this.tableName + ' as ml' +
                ' LEFT JOIN ' + this.ctx.service.materialBills.tableName + ' as mb ON ml.`mb_id` = mb.`id`' +
                ' LEFT JOIN ' + this.ctx.service.materialBillsHistory.tableName + ' as mbh ON ml.`mb_id` = mbh.`mb_id` and mbh.mid = ?' +
                ' WHERE ml.`tid` = ? AND ml.`mid` = ?';
            const sqlParam = [mid, tid, mid];
            return await this.db.query(sql, sqlParam);
        }

        /**
         * 复制上一期并生成新一期清单工料关联，计算新一期小计值
         * @param transaction
         * @param preMaterial
         * @param newMid
         * @return {Promise<void>}
         */
        async copyPreMaterialList(transaction, preMaterial, newMaterial) {
            const materialListData = await this.getAllDataByCondition({ where: { tid: this.ctx.tender.id, mid: preMaterial.id } });
            const copyMLArray = [];
            for (const ml of materialListData) {
                // 获取小计值
                let gather_qty = null;
                if (ml.mx_id !== null && ml.mx_id !== '') {
                    gather_qty = await this.ctx.service.stagePos.getGatherQtyByMaterial(ml.tid, newMaterial.stage_id, ml.gcl_id, ml.mx_id);
                } else {
                    gather_qty = await this.ctx.service.stageBills.getGatherQtyByMaterial(ml.tid, newMaterial.stage_id, ml.gcl_id);
                }
                const newMaterialList = {
                    tid: ml.tid,
                    order: ml.order,
                    mid: newMaterial.id,
                    mb_id: ml.mb_id,
                    gcl_id: ml.gcl_id,
                    xmj_id: ml.xmj_id,
                    mx_id: ml.mx_id,
                    gather_qty,
                    quantity: ml.quantity,
                    expr: ml.expr,
                    is_join: ml.is_join,
                    in_time: new Date(),
                };
                copyMLArray.push(newMaterialList);
            }
            return copyMLArray.length !== 0 ? await transaction.insert(this.tableName, copyMLArray) : true;
        }

        /**
         * 复制上一期并生成新一期清单工料关联，计算新一期小计值
         * @param transaction
         * @param preMaterial
         * @param newMid
         * @return {Promise<void>}
         */
        async copyPreMaterialList2(transaction, materialListData, materialSelfListData, notJoinList, newMaterial) {
            if (materialListData && materialListData.length > 0) {
                const copyMLArray = [];
                for (const ml of materialListData) {
                    const is_join = this._.find(notJoinList, { gcl_id: ml.gcl_id, xmj_id: ml.xmj_id, mx_id: ml.mx_id });
                    const newMaterialList = {
                        tid: newMaterial.tid,
                        order: ml.order,
                        mid: newMaterial.id,
                        mb_id: ml.mb_id,
                        gcl_id: ml.gcl_id,
                        xmj_id: ml.xmj_id,
                        mx_id: ml.mx_id,
                        gather_qty: ml.gather_qty,
                        quantity: ml.quantity ? ml.quantity : 0,
                        expr: ml.expr ? ml.expr : '',
                        is_join: is_join ? 0 : 1,
                        in_time: new Date(),
                    };
                    copyMLArray.push(newMaterialList);
                }
                if (copyMLArray.length !== 0) await transaction.insert(this.tableName, copyMLArray);
            }
            if (materialSelfListData && materialSelfListData.length > 0) {
                const copyMLArray2 = [];
                for (const ml of materialSelfListData) {
                    const is_join = this._.find(notJoinList, { gcl_id: ml.gcl_id, xmj_id: ml.xmj_id, mx_id: ml.mx_id });
                    const newMaterialList = {
                        tid: newMaterial.tid,
                        order: ml.order,
                        mid: newMaterial.id,
                        mb_id: ml.mb_id,
                        gcl_id: ml.gcl_id,
                        xmj_id: ml.xmj_id,
                        mx_id: ml.mx_id,
                        gather_qty: ml.gather_qty,
                        quantity: ml.quantity ? ml.quantity : 0,
                        expr: ml.expr ? ml.expr : '',
                        is_join: is_join ? 0 : 1,
                        is_self: 1,
                        in_time: new Date(),
                    };
                    copyMLArray2.push(newMaterialList);
                }
                if (copyMLArray2.length !== 0) await transaction.insert(this.tableName, copyMLArray2);
            }
        }


        /**
         * 添加工料清单关联(多清单对应)
         * @return {void}
         */
        async adds(datas, checklist = false) {
            if (!this.ctx.tender || !this.ctx.material) {
                throw '数据错误';
            }
            const transaction = await this.db.beginTransaction();
            try {
                const list = [];
                const listGcl = [];
                // const delList = [];
                // const mb_idList = [];
                for (const xmj of datas.xmjs) {
                    const selfList = await transaction.select(this.ctx.service.materialListSelf.tableName, { where: { tid: this.ctx.tender.id, mid: this.ctx.material.id } });
                    for (const mb of datas.mbIds) {
                        // // 旧数据兼容问题，要去删除相同已存在的工料
                        // const mlInfo = await this.getDataByCondition({
                        //     mid: this.ctx.material.id,
                        //     gcl_id: xmj.gcl_id,
                        //     xmj_id: xmj.xmj_id,
                        //     mx_id: xmj.mx_id ? xmj.mx_id : [null, ''],
                        //     mb_id: mb,
                        // });
                        // if (mlInfo) {
                        //     delList.push(mlInfo.id);
                        //     mb_idList.push(mb);
                        // }
                        if (xmj.gather_qty && this._.findIndex(selfList, { gcl_id: xmj.gcl_id, xmj_id: xmj.xmj_id, mx_id: xmj.mx_id }) === -1) {
                            const newLists = {
                                tid: this.ctx.tender.id,
                                order: this.ctx.material.order,
                                mid: this.ctx.material.id,
                                mb_id: mb,
                                gcl_id: xmj.gcl_id,
                                xmj_id: xmj.xmj_id,
                                mx_id: xmj.mx_id,
                                gather_qty: xmj.gather_qty,
                                in_time: new Date(),
                                is_join: xmj.is_join,
                            };
                            list.push(newLists);
                        }
                        if (this._.findIndex(listGcl, { gcl_id: xmj.gcl_id, mb_id: mb }) === -1) {
                            const newListGcl = {
                                tid: this.ctx.tender.id,
                                order: this.ctx.material.order,
                                mid: this.ctx.material.id,
                                mb_id: mb,
                                gcl_id: xmj.gcl_id,
                                quantity: 0,
                                expr: '',
                            };
                            listGcl.push(newListGcl);
                        }
                    }
                }
                // 维护list_gcl表


                // 删除工料清单关联
                // if (delList.length > 0) await transaction.delete(this.tableName, { id: delList });
                // 新增工料清单关联
                if (list.length > 0) {
                    const result = await transaction.insert(this.tableName, list);
                    if (result.affectedRows === 0) {
                        throw '新增工料数据失败';
                    }
                }
                if (listGcl.length > 0) {
                    const result2 = await transaction.insert(this.ctx.service.materialListGcl.tableName, listGcl);
                    if (result2.affectedRows === 0) {
                        throw '新增工料关联数据失败';
                    }
                }
                if (checklist) {
                    await this.ctx.service.materialChecklist.updateHadBills(transaction, checklist.id, checklist.had_bills);
                }
                // 重算工料和总金额
                // const calcMBIdList = this._.uniq(mb_idList);
                // if (calcMBIdList.length > 0) {
                //     for (const select of calcMBIdList) {
                //         await this.calcQuantityByML(transaction, select);
                //     }
                // }
                await transaction.commit();
                const gclList = await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } });
                return checklist ? gclList : {
                    gclList,
                    materialListData: await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id),
                };
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 删除工料清单关联(多清单对应)
         * @param {int} id 工料id
         * @return {void}
         */
        async dels(datas, checklist = false) {
            if (!this.ctx.tender || !this.ctx.material) {
                throw '数据错误';
            }
            const transaction = await this.db.beginTransaction();
            try {
                // 判断是否可删
                const listGcl = [];
                for (const xmj of datas.xmjs) {
                    await transaction.delete(this.tableName, { tid: this.ctx.tender.id, mid: this.ctx.material.id, mb_id: datas.mb_id, gcl_id: xmj.gcl_id, xmj_id: xmj.xmj_id, mx_id: xmj.mx_id, is_self: 0 });
                    if (this._.indexOf(listGcl, xmj.gcl_id) === -1) {
                        await transaction.delete(this.service.materialListGcl.tableName, { tid: this.ctx.tender.id, mid: this.ctx.material.id, mb_id: datas.mb_id, gcl_id: xmj.gcl_id });
                        listGcl.push(xmj.gcl_id);
                    }
                }
                // await transaction.delete(this.tableName, { id });
                await this.calcQuantityByML(transaction, datas.mb_id);
                if (checklist) {
                    await this.ctx.service.materialChecklist.updateHadBills(transaction, checklist.id, checklist.had_bills);
                }
                await transaction.commit();
                // console.log(datas);
                const gclList = await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } });
                return checklist ? gclList : {
                    gclList,
                    materialListData: await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id),
                };
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 修改工料清单关联信息(多清单对应)
         * @param {Object} data 工料内容
         * @param {int} order 期数
         * @return {void}
         */
        async saves(datas, checklist = false) {
            if (!this.ctx.tender || !this.ctx.material) {
                throw '数据错误';
            }

            const transaction = await this.db.beginTransaction();
            try {
                const mb_id = datas.mb_id;
                const updateDatas = [];
                const updateListGcl = [];
                const listGcl = [];
                const selfList = await transaction.select(this.ctx.service.materialListSelf.tableName, { where: { tid: this.ctx.tender.id, mid: this.ctx.material.id } });
                for (const xmj of datas.xmjs) {
                    if (this._.findIndex(selfList, { gcl_id: xmj.gcl_id, xmj_id: xmj.xmj_id, mx_id: xmj.mx_id }) === -1) {
                        const udata = {
                            row: {
                                expr: datas.expr,
                                quantity: datas.quantity,
                            },
                            where: {
                                tid: this.ctx.tender.id,
                                mid: this.ctx.material.id,
                                mb_id,
                                gcl_id: xmj.gcl_id,
                                xmj_id: xmj.xmj_id,
                                mx_id: xmj.mx_id,
                            },
                        };
                        updateDatas.push(udata);
                    }
                    if (this._.indexOf(listGcl, xmj.gcl_id) === -1) {
                        listGcl.push(xmj.gcl_id);
                        updateListGcl.push({
                            row: {
                                expr: datas.expr,
                                quantity: datas.quantity,
                            },
                            where: {
                                tid: this.ctx.tender.id,
                                // mid: this.ctx.material.id,
                                mb_id,
                                gcl_id: xmj.gcl_id,
                            },
                        });
                    }
                }
                console.log(updateDatas);
                if (updateDatas.length > 0) await transaction.updateRows(this.tableName, updateDatas);
                if (updateListGcl.length > 0) await transaction.updateRows(this.service.materialListGcl.tableName, updateListGcl);
                await this.calcQuantityByML(transaction, mb_id);
                await transaction.commit();
                const gclList = await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } });
                return checklist ? gclList : {
                    gclList,
                    materialListData: await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id),
                };
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 复制粘贴多工料信息(多清单对应)
         * @param {Object} data 工料内容
         * @return {void}
         */
        async savePastes(datas, checklist = false) {
            if (!this.ctx.tender || !this.ctx.material) {
                throw '数据错误';
            }
            // 判断是否可修改
            // 判断t_type是否为费用
            const transaction = await this.db.beginTransaction();
            try {
                const selfList = await transaction.select(this.ctx.service.materialListSelf.tableName, { where: { tid: this.ctx.tender.id, mid: this.ctx.material.id } });
                for (const data of datas.pasteData) {
                    const updateDatas = [];
                    const updateListGcl = [];
                    const listGcl = [];
                    for (const xmj of datas.xmjs) {
                        if (this._.findIndex(selfList, { gcl_id: xmj.gcl_id, xmj_id: xmj.xmj_id, mx_id: xmj.mx_id }) === -1) {
                            const udata = {
                                row: {
                                    expr: data.expr,
                                    quantity: data.quantity,
                                },
                                where: {
                                    tid: this.ctx.tender.id,
                                    mid: this.ctx.material.id,
                                    mb_id: data.mb_id,
                                    gcl_id: xmj.gcl_id,
                                    xmj_id: xmj.xmj_id,
                                    mx_id: xmj.mx_id,
                                },
                            };
                            updateDatas.push(udata);
                        }
                        if (this._.indexOf(listGcl, xmj.gcl_id) === -1) {
                            listGcl.push(xmj.gcl_id);
                            updateListGcl.push({
                                row: {
                                    expr: data.expr,
                                    quantity: data.quantity,
                                },
                                where: {
                                    tid: this.ctx.tender.id,
                                    // mid: this.ctx.material.id,
                                    mb_id: data.mb_id,
                                    gcl_id: xmj.gcl_id,
                                },
                            });
                        }
                    }
                    if (updateDatas.length > 0) await transaction.updateRows(this.tableName, updateDatas);
                    if (updateListGcl.length > 0) await transaction.updateRows(this.service.materialListGcl.tableName, updateListGcl);
                    await this.calcQuantityByML(transaction, data.mb_id);
                }
                await transaction.commit();
                const gclList = await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } });
                return checklist ? gclList : {
                    gclList,
                    materialListData: await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id),
                };
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }
    }
    return MaterialList;
};