123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852 |
- '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, ms_id = null) {
- 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,
- ms_id: ms_id ? ms_id : null,
- 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, ms_id = null) {
- 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, ms_id);
- await transaction.commit();
- return true;
- } catch (err) {
- await transaction.rollback();
- throw err;
- }
- }
- /**
- * 修改工料清单关联信息
- * @param {Object} data 工料内容
- * @param {int} order 期数
- * @return {void}
- */
- async save(data, ms_id = null) {
- 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, ms_id);
- await transaction.commit();
- return true;
- } catch (err) {
- await transaction.rollback();
- throw err;
- }
- }
- /**
- * 修改工料信息
- * @param {Object} data 工料内容
- * @return {void}
- */
- async saveDatas(datas, ms_id = null) {
- 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, ms_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, ms_id = null, updateAllStage = '') {
- // 修改material_bills值
- const mbInfo = await this.ctx.service.materialBills.getDataById(mb_id);
- if (!mbInfo) {
- throw '不存在该工料';
- }
- let m_spread = mbInfo.m_spread;
- let updateId = mb_id;
- if (ms_id) {
- const msbInfo = await this.ctx.service.materialStageBills.getDataByCondition({ mid: this.ctx.material.id, mb_id, ms_id });
- m_spread = msbInfo.m_spread;
- updateId = msbInfo.id;
- }
- const msSql = ms_id ? ' AND `ms_id` = ' + ms_id : '';
- const sql = 'SELECT SUM(' + this.ctx.helper.getQtySource(this.ctx.material.qty_source) + '*`quantity`) as quantity FROM ' + this.tableName + ' WHERE `mid`=? AND `mb_id`=?' + msSql + ' 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, m_spread), this.ctx.material.decimal.tp);
- const updateData = {
- id: updateId,
- 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),
- };
- if (ms_id) {
- await transaction.update(this.ctx.service.materialStageBills.tableName, updateData);
- await this.ctx.service.materialStage.updateMtp(transaction, ms_id);
- if (updateAllStage === 'all') {
- const updateDatas = [];
- const updateMsIds = [];
- const msbList = await transaction.select(this.ctx.service.materialStageBills.tableName, { where: { mid: this.ctx.material.id, mb_id } });
- for (const msb of msbList) {
- if (msb.ms_id !== parseInt(ms_id)) {
- const sql4 = 'SELECT SUM(' + this.ctx.helper.getQtySource(this.ctx.material.qty_source) + '*`quantity`) as quantity FROM ' + this.tableName + ' WHERE `mid`=? AND `mb_id`=? AND `ms_id`=? AND `is_join`=1';
- const sqlParam4 = [this.ctx.material.id, mb_id, msb.ms_id];
- const mb_quantity4 = await transaction.queryOne(sql4, sqlParam4);
- const newQuantity4 = this.ctx.helper.round(mb_quantity4.quantity, this.ctx.material.decimal.qty);
- const newTp4 = this.ctx.helper.round(this.ctx.helper.mul(newQuantity4, msb.m_spread), this.ctx.material.decimal.tp);
- const updateData4 = {
- id: msb.id,
- quantity: newQuantity4,
- m_tp: newTp4,
- m_tax_tp: this.ctx.helper.round(this.ctx.helper.mul(newTp4, (1 + this.ctx.helper.div(mbInfo.m_tax, 100))), this.ctx.material.decimal.tp),
- };
- updateDatas.push(updateData4);
- updateMsIds.push(msb.ms_id);
- }
- }
- if (updateDatas.length > 0) {
- await transaction.updateRows(this.ctx.service.materialStageBills.tableName, updateDatas);
- for (const msId of updateMsIds) {
- await this.ctx.service.materialStage.updateMtp(transaction, msId);
- }
- }
- }
- // 还要更新bills表的m_tp和m_tax_tp值
- const sql3 = '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.materialStageBills.tableName + ' WHERE `tid` = ? AND `mid` = ? AND `mb_id` = ? AND `is_summary` = 1';
- const sqlParam3 = [this.ctx.tender.id, this.ctx.material.id, mb_id];
- const tp3 = await transaction.queryOne(sql3, sqlParam3);
- const updateBillsData = {
- id: mb_id,
- m_tp: tp3.total_price,
- m_tax_tp: tp3.tax_total_price,
- };
- await transaction.update(this.ctx.service.materialBills.tableName, updateBillsData);
- } else {
- 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,
- };
- const result = await transaction.update(this.ctx.service.material.tableName, updateData2);
- // 找出当前人并更新tp_data
- const tp_data = await this.ctx.service.materialAudit.getTpData(transaction, this.ctx.material.id);
- if (this.ctx.material.status === auditConst.status.uncheck || this.ctx.material.status === auditConst.status.checkNo) {
- await transaction.update(this.ctx.service.material.tableName, {
- id: this.ctx.material.id,
- tp_data: JSON.stringify(tp_data),
- });
- } else if (this.ctx.material.curAuditor) {
- await transaction.update(this.ctx.service.materialAudit.tableName, {
- id: this.ctx.material.curAuditor.id,
- tp_data: JSON.stringify(tp_data),
- });
- }
- return result;
- }
- /**
- * 修改material_bills的quantity值和计算本期金额
- * @param transaction
- * @param mb_id
- * @return {Promise<*>}
- */
- async calcAllQuantityByML(transaction, mbIds) {
- const mbList = await transaction.select(this.ctx.service.materialBills.tableName, { where: { id: mbIds } });
- // 修改material_bills值
- for (const mbInfo of mbList) {
- if (!mbInfo) {
- throw '不存在该工料';
- }
- if (this.ctx.material.is_stage_self) {
- const updateDatas = [];
- const updateMsIds = [];
- const msbList = await transaction.select(this.ctx.service.materialStageBills.tableName, { where: { mid: this.ctx.material.id, mb_id: mbInfo.id } });
- for (const msb of msbList) {
- const sql = 'SELECT SUM(' + this.ctx.helper.getQtySource(this.ctx.material.qty_source) + '*`quantity`) as quantity FROM ' + this.tableName + ' WHERE `mid`=? AND `mb_id`=? AND `ms_id`=? AND `is_join`=1';
- const sqlParam = [this.ctx.material.id, mbInfo.id, msb.ms_id];
- const mb_quantity = await transaction.queryOne(sql, sqlParam);
- 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, msb.m_spread), this.ctx.material.decimal.tp);
- const updateData = {
- id: msb.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),
- };
- updateDatas.push(updateData);
- updateMsIds.push(msb.ms_id);
- }
- if (updateDatas.length > 0) {
- await transaction.updateRows(this.ctx.service.materialStageBills.tableName, updateDatas);
- for (const msId of updateMsIds) {
- await this.ctx.service.materialStage.updateMtp(transaction, msId);
- }
- }
- // 还要更新bills表的m_tp和m_tax_tp值
- const sql3 = '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.materialStageBills.tableName + ' WHERE `tid` = ? AND `mid` = ? AND `mb_id` = ? AND `is_summary` = 1';
- const sqlParam3 = [this.ctx.tender.id, this.ctx.material.id, mbInfo.id];
- const tp3 = await transaction.queryOne(sql3, sqlParam3);
- const updateBillsData = {
- id: mbInfo.id,
- m_tp: tp3.total_price,
- m_tax_tp: tp3.tax_total_price,
- };
- await transaction.update(this.ctx.service.materialBills.tableName, updateBillsData);
- } else {
- const sql = 'SELECT SUM(' + this.ctx.helper.getQtySource(this.ctx.material.qty_source) + '*`quantity`) as quantity FROM ' + this.tableName + ' WHERE `mid`=? AND `mb_id`=? AND `is_join`=1';
- const sqlParam = [this.ctx.material.id, mbInfo.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: mbInfo.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.`contract_qty`, ml.`qc_qty`, ml.`qc_minus_qty`, ml.`gather_qty`, ml.`quantity`, ml.`expr`, ml.`mb_id`, ml.`gcl_id`, ml.`xmj_id`, ml.`mx_id`, ml.`ms_id`, ml.`tid`, ml.`mid`, mb.m_spread, ml.ms_id, ml.is_join' +
- ' 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.`ms_id`, ml.`tid`, ml.`mid`, mbh.m_spread, ml.ms_id' +
- ' 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);
- }
- async getMaterialStageData(tid, mid) {
- const sql = 'SELECT ml.`id`, mb.`code`, mb.`name`, mb.`unit`, ml.`order`, ml.`quantity`, ml.`expr`, msb.id AS mb_id, ml.`gcl_id`, ml.`xmj_id`, ml.`mx_id`, ml.`ms_id`, ml.`tid`, ml.`mid`, msb.m_spread, ml.ms_id, ms.sid, ms.order as s_order' +
- ' 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.materialStageBills.tableName + ' as msb ON ml.mb_id = msb.mb_id AND ml.ms_id = msb.ms_id' +
- ' LEFT JOIN ' + this.ctx.service.materialStage.tableName + ' as ms ON ml.`ms_id` = ms.`id`' +
- ' WHERE ml.`tid` = ? AND ml.`mid` = ?';
- const sqlParam = [tid, mid];
- return await this.db.query(sql, sqlParam);
- }
- async getPreMaterialStageData(tid, mid) {
- const sql = 'SELECT ml.`id`, mb.`code`, mb.`name`, mb.`unit`, ml.`order`, ml.`quantity`, ml.`expr`, msb.id AS mb_id, ml.`gcl_id`, ml.`xmj_id`, ml.`mx_id`, ml.`ms_id`, ml.`tid`, ml.`mid`, msb.m_spread, ml.ms_id, ms.sid, ms.order as s_order' +
- ' 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.materialStageBills.tableName + ' as msb ON ml.`mb_id` = msb.mb_id AND ml.ms_id = msb.ms_id And ml.mid = msb.mid' +
- ' LEFT JOIN ' + this.ctx.service.materialStage.tableName + ' as ms ON ml.`ms_id` = ms.`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 qtys = null;
- if (ml.mx_id !== null && ml.mx_id !== '') {
- qtys = await this.ctx.service.stagePos.getGatherQtyByMaterial(ml.tid, newMaterial.stage_id, ml.gcl_id, ml.mx_id);
- } else {
- qtys = 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,
- contract_qty: qtys ? qtys.contract_qty : null,
- qc_qty: qtys ? qtys.qc_qty : null,
- qc_minus_qty: qtys ? qtys.qc_minus_qty : null,
- gather_qty: qtys ? qtys.gather_qty : null,
- 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, materialStageData) {
- 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, type: 1 });
- const is_change = this._.find(notJoinList, { gcl_id: ml.gcl_id, xmj_id: ml.xmj_id, mx_id: ml.mx_id, type: 2 });
- 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,
- contract_qty: ml.contract_qty,
- qc_qty: ml.qc_qty,
- qc_minus_qty: ml.qc_minus_qty,
- 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(),
- };
- if (ml.sid) {
- const ms = this._.find(materialStageData, { sid: ml.sid });
- if (ms && ms.id) newMaterialList.ms_id = ms.id;
- }
- 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, type: 1 });
- const is_change = this._.find(notJoinList, { gcl_id: ml.gcl_id, xmj_id: ml.xmj_id, mx_id: ml.mx_id, type: 2 });
- 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,
- contract_qty: ml.contract_qty,
- qc_qty: ml.qc_qty,
- qc_minus_qty: ml.qc_minus_qty,
- 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(),
- };
- if (ml.sid) {
- const ms = this._.find(materialStageData, { sid: ml.sid });
- if (ms && ms.id) newMaterialList.ms_id = ms.id;
- }
- 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 uplist = [];
- const uplistGcl = [];
- // const delList = [];
- // const mb_idList = [];
- const selfList = await transaction.select(this.ctx.service.materialListSelf.tableName, { where: { tid: this.ctx.tender.id, mid: this.ctx.material.id } });
- const oldGclList = await transaction.select(this.ctx.service.materialListGcl.tableName, { where: { tid: this.ctx.tender.id } });
- const oldMaterialList = await transaction.select(this.ctx.service.materialList.tableName, { where: { tid: this.ctx.tender.id, mid: this.ctx.material.id } });
- 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);
- // }
- const mbId = typeof mb === 'object' ? mb.id : mb;
- const quantity = typeof mb === 'object' ? mb.quantity : 0;
- if (xmj.gather_qty && this._.findIndex(selfList, { gcl_id: xmj.gcl_id, xmj_id: xmj.xmj_id, mx_id: xmj.mx_id }) === -1) {
- const mlInfo = this._.find(oldMaterialList, { gcl_id: xmj.gcl_id, xmj_id: xmj.xmj_id, mx_id: xmj.mx_id, mb_id: mbId, ms_id: xmj.ms_id ? xmj.ms_id : null });
- if (mlInfo) {
- uplist.push({ id: mlInfo.id, quantity, expr: '' });
- } else {
- const newLists = {
- tid: this.ctx.tender.id,
- order: this.ctx.material.order,
- mid: this.ctx.material.id,
- mb_id: mbId,
- gcl_id: xmj.gcl_id,
- xmj_id: xmj.xmj_id,
- mx_id: xmj.mx_id,
- ms_id: xmj.ms_id ? xmj.ms_id : null,
- contract_qty: xmj.contract_qty,
- qc_qty: xmj.qc_qty,
- qc_minus_qty: xmj.qc_minus_qty,
- gather_qty: xmj.gather_qty,
- quantity,
- in_time: new Date(),
- is_join: xmj.is_join,
- };
- list.push(newLists);
- }
- }
- const gclIndex = this._.findIndex(oldGclList, { gcl_id: xmj.gcl_id, mb_id: mbId });
- if (gclIndex === -1 && this._.findIndex(listGcl, { gcl_id: xmj.gcl_id, mb_id: mbId }) === -1) {
- const newListGcl = {
- tid: this.ctx.tender.id,
- order: this.ctx.material.order,
- mid: this.ctx.material.id,
- mb_id: mbId,
- gcl_id: xmj.gcl_id,
- quantity,
- expr: '',
- };
- listGcl.push(newListGcl);
- } else if (gclIndex !== -1 && this._.findIndex(uplistGcl, { id: oldGclList[gclIndex].id }) === -1) {
- uplistGcl.push({
- id: oldGclList[gclIndex].id,
- expr: '',
- quantity,
- });
- }
- }
- }
- // 维护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 (uplist.length > 0) {
- await transaction.updateRows(this.tableName, uplist);
- }
- if (uplistGcl.length > 0) {
- await transaction.updateRows(this.ctx.service.materialListGcl.tableName, uplistGcl);
- }
- 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);
- // }
- // }
- if ((list.length > 0 || uplist.length > 0) && datas.export) {
- await this.calcAllQuantityByML(transaction, this._.map(datas.mbIds, '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 {int} id 工料id
- * @return {void}
- */
- async dels(datas, checklist = false, fromCheckList = false, ms_id = null) {
- 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, ms_id, 'all');
- 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 fromCheckList ? 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, ms_id = null) {
- 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,
- },
- });
- }
- }
- 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, ms_id, 'all');
- 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, ms_id = null) {
- 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, ms_id, 'all');
- }
- 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;
- };
|