material_list.js 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852
  1. 'use strict';
  2. /**
  3. * 调差清单关联工料表 数据模型
  4. *
  5. * @author Mai
  6. * @date 2018/8/13
  7. * @version
  8. */
  9. const auditConst = require('../const/audit').material;
  10. module.exports = app => {
  11. class MaterialList extends app.BaseService {
  12. /**
  13. * 构造函数
  14. *
  15. * @param {Object} ctx - egg全局变量
  16. * @return {void}
  17. */
  18. constructor(ctx) {
  19. super(ctx);
  20. this.tableName = 'material_list';
  21. }
  22. /**
  23. * 添加工料清单关联
  24. * @return {void}
  25. */
  26. async add(data, ms_id = null) {
  27. if (!this.ctx.tender || !this.ctx.material) {
  28. throw '数据错误';
  29. }
  30. const list = [];
  31. for (const mb of data.mb_id) {
  32. const newLists = {
  33. tid: this.ctx.tender.id,
  34. order: this.ctx.material.order,
  35. mid: this.ctx.material.id,
  36. mb_id: mb,
  37. gcl_id: data.gcl_id,
  38. xmj_id: data.xmj_id,
  39. mx_id: data.mx_id,
  40. gather_qty: data.gather_qty,
  41. is_join: data.is_join,
  42. is_self: 1,
  43. ms_id: ms_id ? ms_id : null,
  44. in_time: new Date(),
  45. };
  46. list.push(newLists);
  47. }
  48. // 新增工料
  49. const result = await this.db.insert(this.tableName, list);
  50. if (result.affectedRows === 0) {
  51. throw '新增工料数据失败';
  52. }
  53. return await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id);
  54. }
  55. /**
  56. * 删除工料清单关联
  57. * @param {int} id 工料id
  58. * @return {void}
  59. */
  60. async del(id, mb_id, ms_id = null) {
  61. if (!this.ctx.tender || !this.ctx.material) {
  62. throw '数据错误';
  63. }
  64. const transaction = await this.db.beginTransaction();
  65. try {
  66. // 判断是否可删
  67. await transaction.delete(this.tableName, { id });
  68. await this.calcQuantityByML(transaction, mb_id, ms_id);
  69. await transaction.commit();
  70. return true;
  71. } catch (err) {
  72. await transaction.rollback();
  73. throw err;
  74. }
  75. }
  76. /**
  77. * 修改工料清单关联信息
  78. * @param {Object} data 工料内容
  79. * @param {int} order 期数
  80. * @return {void}
  81. */
  82. async save(data, ms_id = null) {
  83. if (!this.ctx.tender || !this.ctx.material) {
  84. throw '数据错误';
  85. }
  86. const transaction = await this.db.beginTransaction();
  87. try {
  88. const mb_id = data.mb_id;
  89. delete data.mb_id;
  90. await transaction.update(this.tableName, data);
  91. await this.calcQuantityByML(transaction, mb_id, ms_id);
  92. await transaction.commit();
  93. return true;
  94. } catch (err) {
  95. await transaction.rollback();
  96. throw err;
  97. }
  98. }
  99. /**
  100. * 修改工料信息
  101. * @param {Object} data 工料内容
  102. * @return {void}
  103. */
  104. async saveDatas(datas, ms_id = null) {
  105. if (!this.ctx.tender || !this.ctx.material) {
  106. throw '数据错误';
  107. }
  108. // 判断是否可修改
  109. // 判断t_type是否为费用
  110. const transaction = await this.db.beginTransaction();
  111. try {
  112. for (const data of datas) {
  113. const mb_id = data.mb_id;
  114. delete data.mb_id;
  115. await transaction.update(this.tableName, data);
  116. await this.calcQuantityByML(transaction, mb_id, ms_id);
  117. }
  118. await transaction.commit();
  119. return true;
  120. } catch (err) {
  121. await transaction.rollback();
  122. throw err;
  123. }
  124. }
  125. /**
  126. * 应用工料清单到其它清单中
  127. * @return {void}
  128. */
  129. async addOther(data) {
  130. if (!this.ctx.tender || !this.ctx.material) {
  131. throw '数据错误';
  132. }
  133. const transaction = await this.db.beginTransaction();
  134. try {
  135. // 先删除addxmj里所有的清单工料再添加新工料,并重新计算每个工料的单价数量
  136. // 还要找出删除的工料,更新单价数量
  137. const list = [];
  138. const delList = [];
  139. const materialBills = data.materialBills;
  140. const mb_idList = [];
  141. for (const xmj of data.addXmj) {
  142. const mlList = await this.getAllDataByCondition({
  143. where: {
  144. mid: this.ctx.material.id,
  145. gcl_id: xmj.gcl_id,
  146. xmj_id: xmj.id,
  147. mx_id: xmj.mx_id,
  148. },
  149. });
  150. const mbIdList = this._.map(mlList, 'mb_id');
  151. mb_idList.push(...mbIdList);
  152. delList.push(...this._.map(mlList, 'id'));
  153. for (const mb of materialBills) {
  154. const newLists = {
  155. tid: this.ctx.tender.id,
  156. order: mb.order,
  157. mid: this.ctx.material.id,
  158. mb_id: mb.mb_id,
  159. gcl_id: xmj.gcl_id,
  160. xmj_id: xmj.id,
  161. mx_id: xmj.mx_id,
  162. gather_qty: xmj.gather_qty ? xmj.gather_qty : null,
  163. quantity: mb.quantity,
  164. expr: mb.expr,
  165. in_time: new Date(),
  166. };
  167. list.push(newLists);
  168. mb_idList.push(mb.mb_id);
  169. }
  170. }
  171. // 删除工料清单关联
  172. if (delList.length > 0) await transaction.delete(this.tableName, { id: delList });
  173. // 新增工料清单关联
  174. if (list.length > 0) {
  175. const result = await transaction.insert(this.tableName, list);
  176. if (result.affectedRows === 0) {
  177. throw '新增工料数据失败';
  178. }
  179. }
  180. // 重算工料和总金额
  181. const calcMBIdList = this._.uniq(mb_idList);
  182. if (calcMBIdList.length > 0) {
  183. for (const select of calcMBIdList) {
  184. await this.calcQuantityByML(transaction, select);
  185. }
  186. }
  187. // throw 'fail';
  188. // await this.calcQuantityByML(transaction, select.mb_id);
  189. await transaction.commit();
  190. return await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id);
  191. } catch (err) {
  192. await transaction.rollback();
  193. throw err;
  194. }
  195. }
  196. /**
  197. * 修改material_bills的quantity值和计算本期金额
  198. * @param transaction
  199. * @param mb_id
  200. * @return {Promise<*>}
  201. */
  202. async calcQuantityByML(transaction, mb_id, ms_id = null, updateAllStage = '') {
  203. // 修改material_bills值
  204. const mbInfo = await this.ctx.service.materialBills.getDataById(mb_id);
  205. if (!mbInfo) {
  206. throw '不存在该工料';
  207. }
  208. let m_spread = mbInfo.m_spread;
  209. let updateId = mb_id;
  210. if (ms_id) {
  211. const msbInfo = await this.ctx.service.materialStageBills.getDataByCondition({ mid: this.ctx.material.id, mb_id, ms_id });
  212. m_spread = msbInfo.m_spread;
  213. updateId = msbInfo.id;
  214. }
  215. const msSql = ms_id ? ' AND `ms_id` = ' + ms_id : '';
  216. 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';
  217. const sqlParam = [this.ctx.material.id, mb_id];
  218. const mb_quantity = await transaction.queryOne(sql, sqlParam);
  219. console.log(mb_quantity);
  220. const newQuantity = this.ctx.helper.round(mb_quantity.quantity, this.ctx.material.decimal.qty);
  221. const newTp = this.ctx.helper.round(this.ctx.helper.mul(newQuantity, m_spread), this.ctx.material.decimal.tp);
  222. const updateData = {
  223. id: updateId,
  224. quantity: newQuantity,
  225. m_tp: newTp,
  226. 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),
  227. };
  228. if (ms_id) {
  229. await transaction.update(this.ctx.service.materialStageBills.tableName, updateData);
  230. await this.ctx.service.materialStage.updateMtp(transaction, ms_id);
  231. if (updateAllStage === 'all') {
  232. const updateDatas = [];
  233. const updateMsIds = [];
  234. const msbList = await transaction.select(this.ctx.service.materialStageBills.tableName, { where: { mid: this.ctx.material.id, mb_id } });
  235. for (const msb of msbList) {
  236. if (msb.ms_id !== parseInt(ms_id)) {
  237. 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';
  238. const sqlParam4 = [this.ctx.material.id, mb_id, msb.ms_id];
  239. const mb_quantity4 = await transaction.queryOne(sql4, sqlParam4);
  240. const newQuantity4 = this.ctx.helper.round(mb_quantity4.quantity, this.ctx.material.decimal.qty);
  241. const newTp4 = this.ctx.helper.round(this.ctx.helper.mul(newQuantity4, msb.m_spread), this.ctx.material.decimal.tp);
  242. const updateData4 = {
  243. id: msb.id,
  244. quantity: newQuantity4,
  245. m_tp: newTp4,
  246. 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),
  247. };
  248. updateDatas.push(updateData4);
  249. updateMsIds.push(msb.ms_id);
  250. }
  251. }
  252. if (updateDatas.length > 0) {
  253. await transaction.updateRows(this.ctx.service.materialStageBills.tableName, updateDatas);
  254. for (const msId of updateMsIds) {
  255. await this.ctx.service.materialStage.updateMtp(transaction, msId);
  256. }
  257. }
  258. }
  259. // 还要更新bills表的m_tp和m_tax_tp值
  260. 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';
  261. const sqlParam3 = [this.ctx.tender.id, this.ctx.material.id, mb_id];
  262. const tp3 = await transaction.queryOne(sql3, sqlParam3);
  263. const updateBillsData = {
  264. id: mb_id,
  265. m_tp: tp3.total_price,
  266. m_tax_tp: tp3.tax_total_price,
  267. };
  268. await transaction.update(this.ctx.service.materialBills.tableName, updateBillsData);
  269. } else {
  270. await transaction.update(this.ctx.service.materialBills.tableName, updateData);
  271. }
  272. // 计算本期总金额
  273. 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';
  274. const sqlParam2 = [this.ctx.tender.id];
  275. const tp = await transaction.queryOne(sql2, sqlParam2);
  276. console.log(tp);
  277. const updateData2 = {
  278. id: this.ctx.material.id,
  279. m_tp: tp.total_price,
  280. m_tax_tp: tp.tax_total_price,
  281. };
  282. const result = await transaction.update(this.ctx.service.material.tableName, updateData2);
  283. // 找出当前人并更新tp_data
  284. const tp_data = await this.ctx.service.materialAudit.getTpData(transaction, this.ctx.material.id);
  285. if (this.ctx.material.status === auditConst.status.uncheck || this.ctx.material.status === auditConst.status.checkNo) {
  286. await transaction.update(this.ctx.service.material.tableName, {
  287. id: this.ctx.material.id,
  288. tp_data: JSON.stringify(tp_data),
  289. });
  290. } else if (this.ctx.material.curAuditor) {
  291. await transaction.update(this.ctx.service.materialAudit.tableName, {
  292. id: this.ctx.material.curAuditor.id,
  293. tp_data: JSON.stringify(tp_data),
  294. });
  295. }
  296. return result;
  297. }
  298. /**
  299. * 修改material_bills的quantity值和计算本期金额
  300. * @param transaction
  301. * @param mb_id
  302. * @return {Promise<*>}
  303. */
  304. async calcAllQuantityByML(transaction, mbIds) {
  305. const mbList = await transaction.select(this.ctx.service.materialBills.tableName, { where: { id: mbIds } });
  306. // 修改material_bills值
  307. for (const mbInfo of mbList) {
  308. if (!mbInfo) {
  309. throw '不存在该工料';
  310. }
  311. if (this.ctx.material.is_stage_self) {
  312. const updateDatas = [];
  313. const updateMsIds = [];
  314. const msbList = await transaction.select(this.ctx.service.materialStageBills.tableName, { where: { mid: this.ctx.material.id, mb_id: mbInfo.id } });
  315. for (const msb of msbList) {
  316. 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';
  317. const sqlParam = [this.ctx.material.id, mbInfo.id, msb.ms_id];
  318. const mb_quantity = await transaction.queryOne(sql, sqlParam);
  319. const newQuantity = this.ctx.helper.round(mb_quantity.quantity, this.ctx.material.decimal.qty);
  320. const newTp = this.ctx.helper.round(this.ctx.helper.mul(newQuantity, msb.m_spread), this.ctx.material.decimal.tp);
  321. const updateData = {
  322. id: msb.id,
  323. quantity: newQuantity,
  324. m_tp: newTp,
  325. 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),
  326. };
  327. updateDatas.push(updateData);
  328. updateMsIds.push(msb.ms_id);
  329. }
  330. if (updateDatas.length > 0) {
  331. await transaction.updateRows(this.ctx.service.materialStageBills.tableName, updateDatas);
  332. for (const msId of updateMsIds) {
  333. await this.ctx.service.materialStage.updateMtp(transaction, msId);
  334. }
  335. }
  336. // 还要更新bills表的m_tp和m_tax_tp值
  337. 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';
  338. const sqlParam3 = [this.ctx.tender.id, this.ctx.material.id, mbInfo.id];
  339. const tp3 = await transaction.queryOne(sql3, sqlParam3);
  340. const updateBillsData = {
  341. id: mbInfo.id,
  342. m_tp: tp3.total_price,
  343. m_tax_tp: tp3.tax_total_price,
  344. };
  345. await transaction.update(this.ctx.service.materialBills.tableName, updateBillsData);
  346. } else {
  347. 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';
  348. const sqlParam = [this.ctx.material.id, mbInfo.id];
  349. const mb_quantity = await transaction.queryOne(sql, sqlParam);
  350. console.log(mb_quantity);
  351. const newQuantity = this.ctx.helper.round(mb_quantity.quantity, this.ctx.material.decimal.qty);
  352. const newTp = this.ctx.helper.round(this.ctx.helper.mul(newQuantity, mbInfo.m_spread), this.ctx.material.decimal.tp);
  353. const updateData = {
  354. id: mbInfo.id,
  355. quantity: newQuantity,
  356. m_tp: newTp,
  357. 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),
  358. };
  359. await transaction.update(this.ctx.service.materialBills.tableName, updateData);
  360. }
  361. }
  362. // 计算本期总金额
  363. 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';
  364. const sqlParam2 = [this.ctx.tender.id];
  365. const tp = await transaction.queryOne(sql2, sqlParam2);
  366. console.log(tp);
  367. const updateData2 = {
  368. id: this.ctx.material.id,
  369. m_tp: tp.total_price,
  370. m_tax_tp: tp.tax_total_price,
  371. };
  372. return await transaction.update(this.ctx.service.material.tableName, updateData2);
  373. }
  374. /**
  375. * 获取工料清单关联表
  376. * @param {int} tid 标段id
  377. * @param {Object} mid 期id
  378. * @return {void}
  379. */
  380. async getMaterialData(tid, mid) {
  381. 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' +
  382. ' FROM ' + this.tableName + ' as ml' +
  383. ' LEFT JOIN ' + this.ctx.service.materialBills.tableName + ' as mb' +
  384. ' ON ml.`mb_id` = mb.`id`' +
  385. ' WHERE ml.`tid` = ? AND ml.`mid` = ?';
  386. const sqlParam = [tid, mid];
  387. return await this.db.query(sql, sqlParam);
  388. }
  389. async getPreMaterialData(tid, mid) {
  390. 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' +
  391. ' FROM ' + this.tableName + ' as ml' +
  392. ' LEFT JOIN ' + this.ctx.service.materialBills.tableName + ' as mb ON ml.`mb_id` = mb.`id`' +
  393. ' LEFT JOIN ' + this.ctx.service.materialBillsHistory.tableName + ' as mbh ON ml.`mb_id` = mbh.`mb_id` and mbh.mid = ?' +
  394. ' WHERE ml.`tid` = ? AND ml.`mid` = ?';
  395. const sqlParam = [mid, tid, mid];
  396. return await this.db.query(sql, sqlParam);
  397. }
  398. async getMaterialStageData(tid, mid) {
  399. 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' +
  400. ' FROM ' + this.tableName + ' as ml' +
  401. ' LEFT JOIN ' + this.ctx.service.materialBills.tableName + ' as mb ON ml.`mb_id` = mb.`id`' +
  402. ' LEFT JOIN ' + this.ctx.service.materialStageBills.tableName + ' as msb ON ml.mb_id = msb.mb_id AND ml.ms_id = msb.ms_id' +
  403. ' LEFT JOIN ' + this.ctx.service.materialStage.tableName + ' as ms ON ml.`ms_id` = ms.`id`' +
  404. ' WHERE ml.`tid` = ? AND ml.`mid` = ?';
  405. const sqlParam = [tid, mid];
  406. return await this.db.query(sql, sqlParam);
  407. }
  408. async getPreMaterialStageData(tid, mid) {
  409. 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' +
  410. ' FROM ' + this.tableName + ' as ml' +
  411. ' LEFT JOIN ' + this.ctx.service.materialBills.tableName + ' as mb ON ml.`mb_id` = mb.`id`' +
  412. ' 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' +
  413. ' LEFT JOIN ' + this.ctx.service.materialStage.tableName + ' as ms ON ml.`ms_id` = ms.`id`' +
  414. ' WHERE ml.`tid` = ? AND ml.`mid` = ?';
  415. const sqlParam = [tid, mid];
  416. return await this.db.query(sql, sqlParam);
  417. }
  418. /**
  419. * 复制上一期并生成新一期清单工料关联,计算新一期小计值
  420. * @param transaction
  421. * @param preMaterial
  422. * @param newMid
  423. * @return {Promise<void>}
  424. */
  425. async copyPreMaterialList(transaction, preMaterial, newMaterial) {
  426. const materialListData = await this.getAllDataByCondition({ where: { tid: this.ctx.tender.id, mid: preMaterial.id } });
  427. const copyMLArray = [];
  428. for (const ml of materialListData) {
  429. // 获取小计值
  430. let qtys = null;
  431. if (ml.mx_id !== null && ml.mx_id !== '') {
  432. qtys = await this.ctx.service.stagePos.getGatherQtyByMaterial(ml.tid, newMaterial.stage_id, ml.gcl_id, ml.mx_id);
  433. } else {
  434. qtys = await this.ctx.service.stageBills.getGatherQtyByMaterial(ml.tid, newMaterial.stage_id, ml.gcl_id);
  435. }
  436. const newMaterialList = {
  437. tid: ml.tid,
  438. order: ml.order,
  439. mid: newMaterial.id,
  440. mb_id: ml.mb_id,
  441. gcl_id: ml.gcl_id,
  442. xmj_id: ml.xmj_id,
  443. mx_id: ml.mx_id,
  444. contract_qty: qtys ? qtys.contract_qty : null,
  445. qc_qty: qtys ? qtys.qc_qty : null,
  446. qc_minus_qty: qtys ? qtys.qc_minus_qty : null,
  447. gather_qty: qtys ? qtys.gather_qty : null,
  448. quantity: ml.quantity,
  449. expr: ml.expr,
  450. is_join: ml.is_join,
  451. in_time: new Date(),
  452. };
  453. copyMLArray.push(newMaterialList);
  454. }
  455. return copyMLArray.length !== 0 ? await transaction.insert(this.tableName, copyMLArray) : true;
  456. }
  457. /**
  458. * 复制上一期并生成新一期清单工料关联,计算新一期小计值
  459. * @param transaction
  460. * @param preMaterial
  461. * @param newMid
  462. * @return {Promise<void>}
  463. */
  464. async copyPreMaterialList2(transaction, materialListData, materialSelfListData, notJoinList, newMaterial, materialStageData) {
  465. if (materialListData && materialListData.length > 0) {
  466. const copyMLArray = [];
  467. for (const ml of materialListData) {
  468. const is_join = this._.find(notJoinList, { gcl_id: ml.gcl_id, xmj_id: ml.xmj_id, mx_id: ml.mx_id, type: 1 });
  469. const is_change = this._.find(notJoinList, { gcl_id: ml.gcl_id, xmj_id: ml.xmj_id, mx_id: ml.mx_id, type: 2 });
  470. const newMaterialList = {
  471. tid: newMaterial.tid,
  472. order: ml.order,
  473. mid: newMaterial.id,
  474. mb_id: ml.mb_id,
  475. gcl_id: ml.gcl_id,
  476. xmj_id: ml.xmj_id,
  477. mx_id: ml.mx_id,
  478. contract_qty: ml.contract_qty,
  479. qc_qty: ml.qc_qty,
  480. qc_minus_qty: ml.qc_minus_qty,
  481. gather_qty: ml.gather_qty,
  482. quantity: ml.quantity ? ml.quantity : 0,
  483. expr: ml.expr ? ml.expr : '',
  484. is_join: is_join ? 0 : 1,
  485. in_time: new Date(),
  486. };
  487. if (ml.sid) {
  488. const ms = this._.find(materialStageData, { sid: ml.sid });
  489. if (ms && ms.id) newMaterialList.ms_id = ms.id;
  490. }
  491. copyMLArray.push(newMaterialList);
  492. }
  493. if (copyMLArray.length !== 0) await transaction.insert(this.tableName, copyMLArray);
  494. }
  495. if (materialSelfListData && materialSelfListData.length > 0) {
  496. const copyMLArray2 = [];
  497. for (const ml of materialSelfListData) {
  498. const is_join = this._.find(notJoinList, { gcl_id: ml.gcl_id, xmj_id: ml.xmj_id, mx_id: ml.mx_id, type: 1 });
  499. const is_change = this._.find(notJoinList, { gcl_id: ml.gcl_id, xmj_id: ml.xmj_id, mx_id: ml.mx_id, type: 2 });
  500. const newMaterialList = {
  501. tid: newMaterial.tid,
  502. order: ml.order,
  503. mid: newMaterial.id,
  504. mb_id: ml.mb_id,
  505. gcl_id: ml.gcl_id,
  506. xmj_id: ml.xmj_id,
  507. mx_id: ml.mx_id,
  508. contract_qty: ml.contract_qty,
  509. qc_qty: ml.qc_qty,
  510. qc_minus_qty: ml.qc_minus_qty,
  511. gather_qty: ml.gather_qty,
  512. quantity: ml.quantity ? ml.quantity : 0,
  513. expr: ml.expr ? ml.expr : '',
  514. is_join: is_join ? 0 : 1,
  515. is_self: 1,
  516. in_time: new Date(),
  517. };
  518. if (ml.sid) {
  519. const ms = this._.find(materialStageData, { sid: ml.sid });
  520. if (ms && ms.id) newMaterialList.ms_id = ms.id;
  521. }
  522. copyMLArray2.push(newMaterialList);
  523. }
  524. if (copyMLArray2.length !== 0) await transaction.insert(this.tableName, copyMLArray2);
  525. }
  526. }
  527. /**
  528. * 添加工料清单关联(多清单对应)
  529. * @return {void}
  530. */
  531. async adds(datas, checklist = false) {
  532. if (!this.ctx.tender || !this.ctx.material) {
  533. throw '数据错误';
  534. }
  535. const transaction = await this.db.beginTransaction();
  536. try {
  537. const list = [];
  538. const listGcl = [];
  539. const uplist = [];
  540. const uplistGcl = [];
  541. // const delList = [];
  542. // const mb_idList = [];
  543. const selfList = await transaction.select(this.ctx.service.materialListSelf.tableName, { where: { tid: this.ctx.tender.id, mid: this.ctx.material.id } });
  544. const oldGclList = await transaction.select(this.ctx.service.materialListGcl.tableName, { where: { tid: this.ctx.tender.id } });
  545. const oldMaterialList = await transaction.select(this.ctx.service.materialList.tableName, { where: { tid: this.ctx.tender.id, mid: this.ctx.material.id } });
  546. for (const xmj of datas.xmjs) {
  547. for (const mb of datas.mbIds) {
  548. // // 旧数据兼容问题,要去删除相同已存在的工料
  549. // const mlInfo = await this.getDataByCondition({
  550. // mid: this.ctx.material.id,
  551. // gcl_id: xmj.gcl_id,
  552. // xmj_id: xmj.xmj_id,
  553. // mx_id: xmj.mx_id ? xmj.mx_id : [null, ''],
  554. // mb_id: mb,
  555. // });
  556. // if (mlInfo) {
  557. // delList.push(mlInfo.id);
  558. // mb_idList.push(mb);
  559. // }
  560. const mbId = typeof mb === 'object' ? mb.id : mb;
  561. const quantity = typeof mb === 'object' ? mb.quantity : 0;
  562. if (xmj.gather_qty && this._.findIndex(selfList, { gcl_id: xmj.gcl_id, xmj_id: xmj.xmj_id, mx_id: xmj.mx_id }) === -1) {
  563. 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 });
  564. if (mlInfo) {
  565. uplist.push({ id: mlInfo.id, quantity, expr: '' });
  566. } else {
  567. const newLists = {
  568. tid: this.ctx.tender.id,
  569. order: this.ctx.material.order,
  570. mid: this.ctx.material.id,
  571. mb_id: mbId,
  572. gcl_id: xmj.gcl_id,
  573. xmj_id: xmj.xmj_id,
  574. mx_id: xmj.mx_id,
  575. ms_id: xmj.ms_id ? xmj.ms_id : null,
  576. contract_qty: xmj.contract_qty,
  577. qc_qty: xmj.qc_qty,
  578. qc_minus_qty: xmj.qc_minus_qty,
  579. gather_qty: xmj.gather_qty,
  580. quantity,
  581. in_time: new Date(),
  582. is_join: xmj.is_join,
  583. };
  584. list.push(newLists);
  585. }
  586. }
  587. const gclIndex = this._.findIndex(oldGclList, { gcl_id: xmj.gcl_id, mb_id: mbId });
  588. if (gclIndex === -1 && this._.findIndex(listGcl, { gcl_id: xmj.gcl_id, mb_id: mbId }) === -1) {
  589. const newListGcl = {
  590. tid: this.ctx.tender.id,
  591. order: this.ctx.material.order,
  592. mid: this.ctx.material.id,
  593. mb_id: mbId,
  594. gcl_id: xmj.gcl_id,
  595. quantity,
  596. expr: '',
  597. };
  598. listGcl.push(newListGcl);
  599. } else if (gclIndex !== -1 && this._.findIndex(uplistGcl, { id: oldGclList[gclIndex].id }) === -1) {
  600. uplistGcl.push({
  601. id: oldGclList[gclIndex].id,
  602. expr: '',
  603. quantity,
  604. });
  605. }
  606. }
  607. }
  608. // 维护list_gcl表
  609. // 删除工料清单关联
  610. // if (delList.length > 0) await transaction.delete(this.tableName, { id: delList });
  611. // 新增工料清单关联
  612. if (list.length > 0) {
  613. const result = await transaction.insert(this.tableName, list);
  614. if (result.affectedRows === 0) {
  615. throw '新增工料数据失败';
  616. }
  617. }
  618. if (listGcl.length > 0) {
  619. const result2 = await transaction.insert(this.ctx.service.materialListGcl.tableName, listGcl);
  620. if (result2.affectedRows === 0) {
  621. throw '新增工料关联数据失败';
  622. }
  623. }
  624. // 覆盖
  625. if (uplist.length > 0) {
  626. await transaction.updateRows(this.tableName, uplist);
  627. }
  628. if (uplistGcl.length > 0) {
  629. await transaction.updateRows(this.ctx.service.materialListGcl.tableName, uplistGcl);
  630. }
  631. if (checklist) {
  632. await this.ctx.service.materialChecklist.updateHadBills(transaction, checklist.id, checklist.had_bills);
  633. }
  634. // 重算工料和总金额
  635. // const calcMBIdList = this._.uniq(mb_idList);
  636. // if (calcMBIdList.length > 0) {
  637. // for (const select of calcMBIdList) {
  638. // await this.calcQuantityByML(transaction, select);
  639. // }
  640. // }
  641. if ((list.length > 0 || uplist.length > 0) && datas.export) {
  642. await this.calcAllQuantityByML(transaction, this._.map(datas.mbIds, 'id'));
  643. }
  644. await transaction.commit();
  645. const gclList = await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } });
  646. return checklist ? gclList : {
  647. gclList,
  648. materialListData: await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id),
  649. };
  650. } catch (err) {
  651. await transaction.rollback();
  652. throw err;
  653. }
  654. }
  655. /**
  656. * 删除工料清单关联(多清单对应)
  657. * @param {int} id 工料id
  658. * @return {void}
  659. */
  660. async dels(datas, checklist = false, fromCheckList = false, ms_id = null) {
  661. if (!this.ctx.tender || !this.ctx.material) {
  662. throw '数据错误';
  663. }
  664. const transaction = await this.db.beginTransaction();
  665. try {
  666. // 判断是否可删
  667. const listGcl = [];
  668. for (const xmj of datas.xmjs) {
  669. 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 });
  670. if (this._.indexOf(listGcl, xmj.gcl_id) === -1) {
  671. 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 });
  672. listGcl.push(xmj.gcl_id);
  673. }
  674. }
  675. // await transaction.delete(this.tableName, { id });
  676. await this.calcQuantityByML(transaction, datas.mb_id, ms_id, 'all');
  677. if (checklist) {
  678. await this.ctx.service.materialChecklist.updateHadBills(transaction, checklist.id, checklist.had_bills);
  679. }
  680. await transaction.commit();
  681. // console.log(datas);
  682. const gclList = await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } });
  683. return fromCheckList ? gclList : {
  684. gclList,
  685. materialListData: await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id),
  686. };
  687. } catch (err) {
  688. await transaction.rollback();
  689. throw err;
  690. }
  691. }
  692. /**
  693. * 修改工料清单关联信息(多清单对应)
  694. * @param {Object} data 工料内容
  695. * @param {int} order 期数
  696. * @return {void}
  697. */
  698. async saves(datas, checklist = false, ms_id = null) {
  699. if (!this.ctx.tender || !this.ctx.material) {
  700. throw '数据错误';
  701. }
  702. const transaction = await this.db.beginTransaction();
  703. try {
  704. const mb_id = datas.mb_id;
  705. const updateDatas = [];
  706. const updateListGcl = [];
  707. const listGcl = [];
  708. const selfList = await transaction.select(this.ctx.service.materialListSelf.tableName, { where: { tid: this.ctx.tender.id, mid: this.ctx.material.id } });
  709. for (const xmj of datas.xmjs) {
  710. if (this._.findIndex(selfList, { gcl_id: xmj.gcl_id, xmj_id: xmj.xmj_id, mx_id: xmj.mx_id }) === -1) {
  711. const udata = {
  712. row: {
  713. expr: datas.expr,
  714. quantity: datas.quantity,
  715. },
  716. where: {
  717. tid: this.ctx.tender.id,
  718. mid: this.ctx.material.id,
  719. mb_id,
  720. gcl_id: xmj.gcl_id,
  721. xmj_id: xmj.xmj_id,
  722. mx_id: xmj.mx_id,
  723. },
  724. };
  725. updateDatas.push(udata);
  726. }
  727. if (this._.indexOf(listGcl, xmj.gcl_id) === -1) {
  728. listGcl.push(xmj.gcl_id);
  729. updateListGcl.push({
  730. row: {
  731. expr: datas.expr,
  732. quantity: datas.quantity,
  733. },
  734. where: {
  735. tid: this.ctx.tender.id,
  736. // mid: this.ctx.material.id,
  737. mb_id,
  738. gcl_id: xmj.gcl_id,
  739. },
  740. });
  741. }
  742. }
  743. if (updateDatas.length > 0) await transaction.updateRows(this.tableName, updateDatas);
  744. if (updateListGcl.length > 0) await transaction.updateRows(this.service.materialListGcl.tableName, updateListGcl);
  745. await this.calcQuantityByML(transaction, mb_id, ms_id, 'all');
  746. await transaction.commit();
  747. const gclList = await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } });
  748. return checklist ? gclList : {
  749. gclList,
  750. materialListData: await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id),
  751. };
  752. } catch (err) {
  753. await transaction.rollback();
  754. throw err;
  755. }
  756. }
  757. /**
  758. * 复制粘贴多工料信息(多清单对应)
  759. * @param {Object} data 工料内容
  760. * @return {void}
  761. */
  762. async savePastes(datas, checklist = false, ms_id = null) {
  763. if (!this.ctx.tender || !this.ctx.material) {
  764. throw '数据错误';
  765. }
  766. // 判断是否可修改
  767. // 判断t_type是否为费用
  768. const transaction = await this.db.beginTransaction();
  769. try {
  770. const selfList = await transaction.select(this.ctx.service.materialListSelf.tableName, { where: { tid: this.ctx.tender.id, mid: this.ctx.material.id } });
  771. for (const data of datas.pasteData) {
  772. const updateDatas = [];
  773. const updateListGcl = [];
  774. const listGcl = [];
  775. for (const xmj of datas.xmjs) {
  776. if (this._.findIndex(selfList, { gcl_id: xmj.gcl_id, xmj_id: xmj.xmj_id, mx_id: xmj.mx_id }) === -1) {
  777. const udata = {
  778. row: {
  779. expr: data.expr,
  780. quantity: data.quantity,
  781. },
  782. where: {
  783. tid: this.ctx.tender.id,
  784. mid: this.ctx.material.id,
  785. mb_id: data.mb_id,
  786. gcl_id: xmj.gcl_id,
  787. xmj_id: xmj.xmj_id,
  788. mx_id: xmj.mx_id,
  789. },
  790. };
  791. updateDatas.push(udata);
  792. }
  793. if (this._.indexOf(listGcl, xmj.gcl_id) === -1) {
  794. listGcl.push(xmj.gcl_id);
  795. updateListGcl.push({
  796. row: {
  797. expr: data.expr,
  798. quantity: data.quantity,
  799. },
  800. where: {
  801. tid: this.ctx.tender.id,
  802. // mid: this.ctx.material.id,
  803. mb_id: data.mb_id,
  804. gcl_id: xmj.gcl_id,
  805. },
  806. });
  807. }
  808. }
  809. if (updateDatas.length > 0) await transaction.updateRows(this.tableName, updateDatas);
  810. if (updateListGcl.length > 0) await transaction.updateRows(this.service.materialListGcl.tableName, updateListGcl);
  811. await this.calcQuantityByML(transaction, data.mb_id, ms_id, 'all');
  812. }
  813. await transaction.commit();
  814. const gclList = await this.ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: this.ctx.tender.id } });
  815. return checklist ? gclList : {
  816. gclList,
  817. materialListData: await this.getMaterialData(this.ctx.tender.id, this.ctx.material.id),
  818. };
  819. } catch (err) {
  820. await transaction.rollback();
  821. throw err;
  822. }
  823. }
  824. }
  825. return MaterialList;
  826. };