123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578 |
- '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,
- 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 ? xmj.mx_id : [null, ''],
- },
- });
- 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 ? 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`' +
- ' 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);
- }
- /**
- * 复制上一期并生成新一期清单工料关联,计算新一期小计值
- * @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, 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);
- }
- return copyMLArray.length !== 0 ? await transaction.insert(this.tableName, copyMLArray) : true;
- }
- }
- /**
- * 添加工料清单关联(多清单对应)
- * @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) {
- 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) {
- 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();
- return checklist ? await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } }) : 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 });
- 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);
- return checklist ? await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } }) : 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 = [];
- for (const xmj of datas.xmjs) {
- 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,
- },
- });
- }
- }
- 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();
- return checklist ? await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } }) : 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 {
- for (const data of datas.pasteData) {
- const updateDatas = [];
- const updateListGcl = [];
- const listGcl = [];
- for (const xmj of datas.xmjs) {
- 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();
- return checklist ? await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } }) : await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id);
- } catch (err) {
- await transaction.rollback();
- throw err;
- }
- }
- }
- return MaterialList;
- };
|