material.js 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453
  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. const projectLogConst = require('../const/project_log');
  11. const materialConst = require('../const/material');
  12. module.exports = app => {
  13. class Material extends app.BaseService {
  14. /**
  15. * 构造函数
  16. *
  17. * @param {Object} ctx - egg全局变量
  18. * @return {void}
  19. */
  20. constructor(ctx) {
  21. super(ctx);
  22. this.tableName = 'material';
  23. }
  24. /**
  25. * 获取 最新一期 材料调差期计量
  26. * @param tenderId
  27. * @param includeUnCheck
  28. * @return {Promise<*>}
  29. */
  30. async getLastestMaterial(tenderId, includeUnCheck = false) {
  31. this.initSqlBuilder();
  32. this.sqlBuilder.setAndWhere('tid', {
  33. value: tenderId,
  34. operate: '=',
  35. });
  36. if (!includeUnCheck) {
  37. this.sqlBuilder.setAndWhere('status', {
  38. value: auditConst.status.uncheck,
  39. operate: '!=',
  40. });
  41. }
  42. this.sqlBuilder.orderBy = [['order', 'desc']];
  43. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  44. const material = await this.db.queryOne(sql, sqlParam);
  45. return material;
  46. }
  47. /**
  48. * 获取 最新一期 审批完成的 材料调差期计量
  49. * @param tenderId
  50. * @return {Promise<*>}
  51. */
  52. async getLastestCompleteMaterial(tenderId) {
  53. this.initSqlBuilder();
  54. this.sqlBuilder.setAndWhere('tid', {
  55. value: tenderId,
  56. operate: '=',
  57. });
  58. this.sqlBuilder.setAndWhere('status', {
  59. value: auditConst.status.checked,
  60. operate: '=',
  61. });
  62. this.sqlBuilder.orderBy = [['order', 'desc']];
  63. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  64. const material = await this.db.queryOne(sql, sqlParam);
  65. return material;
  66. }
  67. async checkMaterial(tid, order) {
  68. if (this.ctx.material) return;
  69. const materials = await this.getSelectMaterial(tid, order);
  70. this.ctx.material = materials[0]
  71. }
  72. /**
  73. * 获取标段下的全部计量期,按倒序
  74. * @param tenderId
  75. * @return {Promise<void>}
  76. */
  77. async getSelectMaterial(tenderId, order) {
  78. const materials = await this.db.select(this.tableName, {
  79. where: { tid: tenderId, order },
  80. });
  81. if (materials.length > 0 && materials[0].status !== auditConst.status.checked) {
  82. const material = materials[0];
  83. const curAuditor = await this.ctx.service.materialAudit.getCurAuditor(material.id, material.times);
  84. const isActive = curAuditor ? curAuditor.id === this.ctx.session.sessionUser.accountId : material.user_id === this.ctx.session.sessionUser.accountId;
  85. if (isActive) {
  86. material.curTimes = material.times;
  87. material.curOrder = curAuditor ? curAuditor.order : 0;
  88. }
  89. }
  90. return materials;
  91. }
  92. async getValidMaterials(tenderId) {
  93. const materials = await this.db.select(this.tableName, {
  94. where: { tid: tenderId },
  95. orders: [['order', 'desc']],
  96. });
  97. if (materials.length !== 0) {
  98. const lastMaterial = materials[materials.length - 1];
  99. if (lastMaterial.status === auditConst.status.uncheck && lastMaterial.user_id !== this.ctx.session.sessionUser.accountId && !this.ctx.tender.isTourist) {
  100. materials.splice(materials.length - 1, 1);
  101. }
  102. }
  103. // 最新一期计量(未审批完成),当前操作人的期详细数据,应实时计算
  104. if (materials.length > 0 && materials[0].status !== auditConst.status.checked) {
  105. const material = materials[0];
  106. const curAuditor = await this.ctx.service.materialAudit.getCurAuditor(material.id, material.times);
  107. const isActive = curAuditor ? curAuditor.id === this.ctx.session.sessionUser.accountId : material.user_id === this.ctx.session.sessionUser.accountId;
  108. if (isActive) {
  109. material.curTimes = material.times;
  110. material.curOrder = curAuditor ? curAuditor.order : 0;
  111. }
  112. }
  113. return materials;
  114. }
  115. /**
  116. * 添加材料调差期
  117. * @param tenderId - 标段id
  118. * @param data - post的数据
  119. * @return {Promise<void>}
  120. */
  121. async addMaterial(tenderId, data) {
  122. const materials = await this.getAllDataByCondition({
  123. where: { tid: tenderId },
  124. order: ['order'],
  125. });
  126. const preMaterial = materials[materials.length - 1];
  127. if (materials.length > 0 && materials[materials.length - 1].status !== auditConst.status.checked) {
  128. throw '上一期未审批通过,请等待上一期审批通过后,再新增数据';
  129. }
  130. const order = materials.length + 1;
  131. const newMaterial = {
  132. tid: tenderId,
  133. order,
  134. period: data.period,
  135. in_time: new Date(),
  136. times: 1,
  137. status: auditConst.status.uncheck,
  138. user_id: this.ctx.session.sessionUser.accountId,
  139. stage_id: data.stage_id.join(','),
  140. s_order: data.s_order,
  141. material_tax: this.ctx.session.sessionProject.page_show.openMaterialTax,
  142. decimal: preMaterial && preMaterial.decimal ? preMaterial.decimal : JSON.stringify(materialConst.decimal),
  143. is_new: 1,
  144. };
  145. const transaction = await this.db.beginTransaction();
  146. try {
  147. if (preMaterial) {
  148. newMaterial.rate = preMaterial.rate;
  149. newMaterial.exponent_rate = preMaterial.exponent_rate;
  150. newMaterial.pre_tp = this.ctx.helper.add(preMaterial.m_tp, preMaterial.pre_tp);
  151. newMaterial.ex_pre_tp = this.ctx.helper.add(preMaterial.ex_tp, preMaterial.ex_pre_tp);
  152. newMaterial.m_tax_pre_tp = preMaterial.material_tax ? this.ctx.helper.add(preMaterial.m_tax_tp, preMaterial.m_tax_pre_tp) : preMaterial.m_tax_pre_tp;
  153. }
  154. // 新增期记录
  155. const result = await transaction.insert(this.tableName, newMaterial);
  156. if (result.affectedRows === 1) {
  157. newMaterial.id = result.insertId;
  158. } else {
  159. throw '新增期数据失败';
  160. }
  161. // 存在上一期时,复制上一期审批流程、不参与调差的清单、上期清单并算本期有效价差,本期应耗数量,并算本期总金额
  162. if (preMaterial) {
  163. const auditResult = await this.ctx.service.materialAudit.copyPreMaterialAuditors(transaction, preMaterial, newMaterial);
  164. if (!auditResult) {
  165. throw '复制上一期审批流程失败';
  166. }
  167. // 复制不参与调差清单
  168. const preNotJoinList = await this.ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: this.ctx.tender.id, mid: preMaterial.id } });
  169. await this.ctx.service.materialListNotjoin.copyNewStageNotJoinList(transaction, preNotJoinList, newMaterial.id);
  170. // 复制单独计量调差清单
  171. const preSelfList = await this.ctx.service.materialListSelf.getAllDataByCondition({ where: { tid: this.ctx.tender.id, mid: preMaterial.id } });
  172. await this.ctx.service.materialListSelf.copyNewStageSelfList(transaction, preSelfList, newMaterial.id);
  173. // 复制调差清单工料关联表
  174. // await this.ctx.service.materialList.copyPreMaterialList(transaction, preMaterial, newMaterial);
  175. await this.ctx.service.materialList.copyPreMaterialList2(transaction, data.material_list, data.material_self_list, preNotJoinList, newMaterial);
  176. // 新增或删除list_gcl表
  177. await this.ctx.service.materialListGcl.insertOrDelGcl(transaction, data.insertGclList, data.removeGclList, newMaterial.id);
  178. // 设置list_gcl表old=>new更新
  179. await this.ctx.service.materialListGcl.setNewOldData(transaction, this.ctx.tender.id);
  180. // 修改本期应耗数量值和有效价差,需要剔除不参与调差的清单数据,并返回总金额
  181. const [m_tp, m_tax_tp] = await this.ctx.service.materialBills.updateNewMaterial(transaction, this.ctx.tender.id, newMaterial.id, this.ctx, newMaterial.stage_id, JSON.parse(newMaterial.decimal));
  182. // 修改现行价格指数,并返回调差基数json
  183. const ex_calc = await this.ctx.service.materialExponent.updateNewMaterial(transaction, newMaterial.id, this.ctx, newMaterial.stage_id, preMaterial.ex_calc, JSON.parse(newMaterial.decimal));
  184. // 计算得出本期总金额
  185. const updateMaterialData = {
  186. id: newMaterial.id,
  187. m_tp,
  188. m_tax_tp,
  189. ex_calc: JSON.stringify(ex_calc),
  190. };
  191. await transaction.update(this.tableName, updateMaterialData);
  192. // 删除material_list表冗余数据,减少表数据量
  193. await transaction.delete(this.ctx.service.materialList.tableName, { tid: this.ctx.tender.id, gather_qty: null, is_self: 0 });
  194. }
  195. await transaction.commit();
  196. return newMaterial;
  197. } catch (err) {
  198. await transaction.rollback();
  199. throw err;
  200. }
  201. }
  202. /**
  203. * 编辑计量期
  204. *
  205. * @param {Number} mid - 第N期
  206. * @param {String} period - 开始-截止时间
  207. * @return {Promise<void>}
  208. */
  209. async saveMaterial(mid, period) {
  210. await this.db.update(this.tableName, {
  211. period,
  212. }, { where: { id: mid } });
  213. }
  214. /**
  215. * 删除材料调差期
  216. *
  217. * @param {Number} id - 期Id
  218. * @return {Promise<void>}
  219. */
  220. async deleteMaterial(id) {
  221. const transaction = await this.db.beginTransaction();
  222. try {
  223. // 删除文件
  224. const attList = await this.ctx.service.materialFile.getAllMaterialFiles(this.ctx.tender.id, id);
  225. await this.ctx.helper.delFiles(attList);
  226. await transaction.delete(this.ctx.service.materialAudit.tableName, { mid: id });
  227. await transaction.delete(this.ctx.service.materialBills.tableName, { mid: id });
  228. await transaction.delete(this.ctx.service.materialList.tableName, { mid: id });
  229. await transaction.delete(this.ctx.service.materialListGcl.tableName, { mid: id });
  230. await transaction.delete(this.ctx.service.materialListSelf.tableName, { mid: id });
  231. await transaction.delete(this.ctx.service.materialListNotjoin.tableName, { mid: id });
  232. await transaction.delete(this.ctx.service.materialBillsHistory.tableName, { mid: id });
  233. await transaction.delete(this.ctx.service.materialFile.tableName, { mid: id });
  234. await transaction.delete(this.ctx.service.materialExponent.tableName, { mid: id });
  235. await transaction.delete(this.ctx.service.materialExponentHistory.tableName, { mid: id });
  236. // 如果存在上一期,把上一期的quantity,expr,msg_tp,msg_times,msg_spread,m_up_risk,m_down_risk,m_spread,m_tp,pre_tp,orgin,is_summary添加到bill中
  237. const materialInfo = await this.getDataById(id);
  238. if (materialInfo.order > 1) {
  239. const sql = 'UPDATE ' + this.ctx.service.materialBills.tableName + ' as mb, ' +
  240. this.ctx.service.materialBillsHistory.tableName + ' as mbh ' +
  241. 'SET mb.`quantity` = mbh.`quantity`, mb.`expr` = mbh.`expr`, ' +
  242. 'mb.`msg_tp` = mbh.`msg_tp`, mb.`msg_times` = mbh.`msg_times`, ' +
  243. 'mb.`msg_spread` = mbh.`msg_spread`, mb.`m_up_risk` = mbh.`m_up_risk`, ' +
  244. 'mb.`m_down_risk` = mbh.`m_down_risk`, mb.`m_spread` = mbh.`m_spread`, ' +
  245. 'mb.`m_tp` = mbh.`m_tp`, mb.`pre_tp` = mbh.`pre_tp`, ' +
  246. 'mb.`m_tax_tp` = mbh.`m_tax_tp`, mb.`tax_pre_tp` = mbh.`tax_pre_tp`, ' +
  247. 'mb.`origin` = mbh.`origin`, mb.`is_summary` = mbh.`is_summary`, mb.`m_tax` = mbh.`m_tax` ' +
  248. 'WHERE mbh.`tid` = ? AND mbh.`order` = ? AND mbh.`mb_id` = mb.`id`';
  249. const sqlParam = [this.ctx.tender.id, materialInfo.order - 1];
  250. await transaction.query(sql, sqlParam);
  251. const sql2 = 'UPDATE ' + this.ctx.service.materialExponent.tableName + ' as me, ' +
  252. this.ctx.service.materialExponentHistory.tableName + ' as meh ' +
  253. 'SET me.`weight_num` = meh.`weight_num`, me.`basic_price` = meh.`basic_price`, ' +
  254. 'me.`basic_times` = meh.`basic_times`, me.`m_price` = meh.`m_price`, ' +
  255. 'me.`calc_num` = meh.`calc_num`, me.`is_summary` = meh.`is_summary` ' +
  256. 'WHERE meh.`tid` = ? AND meh.`order` = ? AND meh.`me_id` = me.`id`';
  257. const sqlParam2 = [this.ctx.tender.id, materialInfo.order - 1];
  258. await transaction.query(sql2, sqlParam2);
  259. }
  260. // 设置list_gcl表old => new更新
  261. await this.ctx.service.materialListGcl.setNewOldData(transaction, this.ctx.tender.id, 'old2new');
  262. // 还要从material_list表更新gcl的old数据,更新方法
  263. await this.ctx.service.materialListGcl.setOldFromLast(transaction, this.ctx.tender.id, materialInfo.order - 2);
  264. await transaction.delete(this.tableName, { id });
  265. // 记录删除日志
  266. await this.ctx.service.projectLog.addProjectLog(transaction, projectLogConst.type.material, projectLogConst.status.delete, '第' + materialInfo.order + '期');
  267. await transaction.commit();
  268. return true;
  269. } catch (err) {
  270. await transaction.rollback();
  271. throw err;
  272. }
  273. }
  274. /**
  275. * 获取包含当前期之前的调差期id
  276. *
  277. * @param {Number} id - 期Id
  278. * @return {Promise<void>}
  279. */
  280. async getPreMidList(tid, order) {
  281. const midList = await this.getAllDataByCondition({
  282. where: { tid },
  283. columns: ['id'],
  284. limit: order,
  285. offset: 0,
  286. });
  287. const list = [];
  288. for (const ml of midList) {
  289. list.push(ml.id);
  290. }
  291. return list;
  292. }
  293. /**
  294. * 修改增税税率
  295. * @param {int} rate 税率
  296. * @return {Promise<*>}
  297. */
  298. async changeRate(rate) {
  299. const updateData = {
  300. id: this.ctx.material.id,
  301. rate,
  302. };
  303. return await this.db.update(this.tableName, updateData);
  304. }
  305. /**
  306. * 修改增税税率
  307. * @param {int} rate 税率
  308. * @return {Promise<*>}
  309. */
  310. async changeExponentRate(rate) {
  311. const updateData = {
  312. id: this.ctx.material.id,
  313. exponent_rate: rate,
  314. };
  315. return await this.db.update(this.tableName, updateData);
  316. }
  317. /**
  318. * 修改调差基数
  319. * @param {int} rate 税率
  320. * @return {Promise<*>}
  321. */
  322. async changeExCalc(ex_calc) {
  323. const transaction = await this.db.beginTransaction();
  324. try {
  325. const updateData = {
  326. id: this.ctx.material.id,
  327. ex_calc: JSON.stringify(ex_calc),
  328. };
  329. await transaction.update(this.tableName, updateData);
  330. const [ex_tp, ex_expr] = await this.ctx.service.materialExponent.calcMaterialExTp(transaction, ex_calc);
  331. await transaction.commit();
  332. return [ex_tp, ex_expr];
  333. } catch (err) {
  334. await transaction.rollback();
  335. throw err;
  336. }
  337. }
  338. /**
  339. * 取当前期截止上期含建筑税金额
  340. * @param {int} tid 标段id
  341. * @param {int} order 调差期数
  342. * @return {Promise<*>}
  343. */
  344. async getPreTpHs(tid, order, tp) {
  345. const sql = 'SELECT SUM(ROUND(`m_tp`*(1+ `rate`/100),' + tp + ')) AS `pre_tp_hs` FROM ?? WHERE `tid` = ? AND `material_tax` = ? AND `order` < ?';
  346. const sqlParam = [this.tableName, tid, 0, order];
  347. const result = await this.db.queryOne(sql, sqlParam);
  348. return result.pre_tp_hs;
  349. }
  350. /**
  351. * 取当前期截止上期含材料税金额
  352. * @param {int} tid 标段id
  353. * @param {int} order 调差期数
  354. * @return {Promise<*>}
  355. */
  356. async getTaxPreTpHs(tid, order) {
  357. const sql = 'SELECT SUM(`m_tax_tp`) AS `tax_pre_tp_hs` FROM ?? WHERE `tid` = ? AND `material_tax` = ? AND `order` < ?';
  358. const sqlParam = [this.tableName, tid, 1, order];
  359. const result = await this.db.queryOne(sql, sqlParam);
  360. return result.tax_pre_tp_hs;
  361. }
  362. /**
  363. * 取当前期截止上期含建筑税指数金额
  364. * @param {int} tid 标段id
  365. * @param {int} order 调差期数
  366. * @return {Promise<*>}
  367. */
  368. async getExPreTpHs(tid, order, tp) {
  369. const sql = 'SELECT SUM(ROUND(`ex_tp`*(1+ `exponent_rate`/100),' + tp + ')) AS `ex_pre_tp_hs` FROM ?? WHERE `tid` = ? AND `order` < ?';
  370. const sqlParam = [this.tableName, tid, order];
  371. const result = await this.db.queryOne(sql, sqlParam);
  372. return result.ex_pre_tp_hs;
  373. }
  374. async updateMaterialTax(id, mtax) {
  375. const updateData = {
  376. id,
  377. material_tax: mtax,
  378. };
  379. return await this.db.update(this.tableName, updateData);
  380. }
  381. async getMaterialTaxTp(id) {
  382. const info = await this.getDataById(id);
  383. return info.m_tax_tp;
  384. }
  385. async getSumMaterial(tid) {
  386. const sql = 'Select sum(IFNULL(m_tp, 0) + IFNULL(ex_tp, 0)) as tp From ' + this.tableName + ' where tid = ?';
  387. const result = await this.db.queryOne(sql, [tid]);
  388. return result ? result.tp : 0;
  389. }
  390. async getOldMaterialTax(tid, order) {
  391. const sql = 'SELECT COUNT(id) as count FROM ?? WHERE `tid` = ? AND `order` <= ? AND `material_tax` = 1';
  392. const sqlParam = [this.tableName, tid, order];
  393. const result = await this.db.queryOne(sql, sqlParam);
  394. return result && result.count !== 0;
  395. }
  396. async saveDecimal(newUp, newTp) {
  397. const transaction = await this.db.beginTransaction();
  398. try {
  399. await this.ctx.service.materialBills.resetDecimal(transaction, newUp, newTp);
  400. this.ctx.material.decimal.up = newUp;
  401. this.ctx.material.decimal.tp = newTp;
  402. const m_tp = await this.ctx.service.materialBills.calcMaterialMTp(transaction);
  403. let update_calc = false;
  404. if (this.ctx.material.ex_calc) {
  405. const ex_calc = JSON.parse(this.ctx.material.ex_calc);
  406. const zdy = this._.find(ex_calc, { code: 'zdy' });
  407. zdy.value = this.ctx.helper.round(zdy.value, newTp);
  408. this.ctx.material.ex_calc = JSON.stringify(ex_calc);
  409. update_calc = true;
  410. }
  411. const [ex_tp, ex_expr] = await this.ctx.service.materialExponent.calcMaterialExTp(transaction);
  412. const updateData = {
  413. id: this.ctx.material.id,
  414. decimal: JSON.stringify(this.ctx.material.decimal),
  415. };
  416. if (update_calc) updateData.ex_calc = this.ctx.material.ex_calc;
  417. await transaction.update(this.tableName, updateData);
  418. await transaction.commit();
  419. return true;
  420. } catch (err) {
  421. console.log(err);
  422. await transaction.rollback();
  423. return false;
  424. }
  425. }
  426. }
  427. return Material;
  428. };