settle_controller.js 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359
  1. 'use strict';
  2. /**
  3. * 过程结算 控制器
  4. *
  5. * @author Mai
  6. * @date 2023/10/27
  7. * @version
  8. */
  9. const auditConst = require('../const/audit');
  10. const shenpiConst = require('../const/shenpi');
  11. const tenderConst = require('../const/tender');
  12. const measureType = tenderConst.measureType;
  13. const spreadConst = require('../const/spread');
  14. const spreadSetting = require('../lib/spread_setting');
  15. module.exports = app => {
  16. class SettleController extends app.BaseController {
  17. /**
  18. * 构造函数
  19. *
  20. * @param {Object} ctx - egg全局变量
  21. * @return {void}
  22. */
  23. constructor(ctx) {
  24. super(ctx);
  25. ctx.showProject = true;
  26. ctx.showTender = true;
  27. ctx.showTitle = true;
  28. }
  29. /**
  30. * 期列表(Get)
  31. * @param ctx
  32. * @return {Promise<void>}
  33. */
  34. async list(ctx) {
  35. try {
  36. const renderData = {
  37. tender: ctx.tender.data,
  38. preUrl: `/tender/${ctx.tender.id}/measure/stage`,
  39. auditConst: auditConst.settle,
  40. auditType: auditConst.auditType,
  41. };
  42. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.settle.list);
  43. renderData.settles = await ctx.service.settle.getValidSettles(ctx.tender.id);
  44. for (const s of renderData.settles) {
  45. if (s.status === auditConst.settle.status.uncheck) {
  46. s.curAuditors = [];
  47. } else if (s.status === auditConst.settle.status.checkNo) {
  48. s.curAuditors = await ctx.service.settleAudit.getAuditorsByStatus(sid, s.status, s.times - 1);
  49. } else {
  50. s.curAuditors = await ctx.service.settleAudit.getAuditorsByStatus(s.id, s.status, s.times);
  51. }
  52. if (s.status === auditConst.settle.status.checkNoPre) {
  53. s.curAuditorsPre = await ctx.service.stageAudit.getAuditorsByStatus(s.id, auditConst.settle.status.checking, s.times);
  54. }
  55. }
  56. renderData.checkedStageCount = await ctx.service.stage.count({ tid: ctx.tender.id, status: auditConst.stage.status.checked });
  57. await this.layout('settle/list.ejs', renderData, 'settle/list_modal.ejs');
  58. } catch (err) {
  59. ctx.log(err);
  60. ctx.redirect(this.menu.menu.dashboard.url);
  61. }
  62. }
  63. /**
  64. * 期审批流程(Get)
  65. * @param ctx
  66. * @return {Promise<void>}
  67. */
  68. async loadAuditors(ctx) {
  69. try {
  70. const order = JSON.parse(ctx.request.body.data).order;
  71. const tenderId = ctx.params.id;
  72. const settle = await ctx.service.settle.getDataByCondition({ tid: tenderId, settle_order: order });
  73. await ctx.service.settle.loadRelaUser(settle);
  74. await ctx.service.settle.loadAuditViewData(settle);
  75. ctx.body = { err: 0, msg: '', data: settle };
  76. } catch (error) {
  77. ctx.log(error);
  78. ctx.body = { err: 1, msg: error.toString(), data: null };
  79. }
  80. }
  81. async add(ctx) {
  82. try {
  83. if (ctx.session.sessionUser.accountId !== ctx.tender.data.user_id) throw '您无权创建计量期';
  84. const date = ctx.request.body.date;
  85. const period = ctx.request.body.period;
  86. if (!date || !period) throw '请选择结算年月和结算周期';
  87. const newSettle = await ctx.service.settle.addSettle(ctx.tender.id, date, period);
  88. ctx.redirect('/tender/' + ctx.tender.id + '/settle/' + newSettle.settle_order);
  89. } catch (err) {
  90. ctx.log(err);
  91. ctx.postError(err, '新增结算期失败,请重试');
  92. ctx.redirect('/tender/' + ctx.tender.id + '/settle');
  93. }
  94. }
  95. async save(ctx) {
  96. try {
  97. const data = {
  98. order: ctx.request.body.order,
  99. date: ctx.request.body.date,
  100. period: ctx.request.body.period,
  101. };
  102. const settle = await ctx.service.settle.getDataByCondition({ tid: ctx.tender.id, settle_order: data.order });
  103. if (!settle) throw '修改的结算期不存在';
  104. if (ctx.session.sessionUser.accountId !== stage.user_id) throw '您无权修改该数据';
  105. await this.ctx.service.stage.saveSettle(ctx.tender.id, data.order, data.date, data.period);
  106. ctx.redirect('/tender/' + ctx.tender.id + '/settle');
  107. } catch (err) {
  108. ctx.log(err);
  109. ctx.postError(err, '保存结算期数据失败,请重试');
  110. ctx.redirect('/tender/' + ctx.tender.id + '/settle');
  111. }
  112. }
  113. async delete(ctx) {
  114. try {
  115. if (ctx.request.body.confirm !== undefined && ctx.request.body.confirm !== '确认删除本期') {
  116. throw '请输入正确的文本信息';
  117. }
  118. const sid = ctx.request.body.settle_id;
  119. const settle = await ctx.service.settle.getDataById(sid);
  120. const settleCount = await ctx.service.settle.count({ tid: ctx.tender.id });
  121. if (!settle || settle.tid !== ctx.tender.id) throw '选择的结算期已不存在';
  122. if (settleCount === settle.settle_order) throw '选择的结算期无法删除';
  123. if (ctx.session.sessionUser.accountId !== settle.user_id && !ctx.session.sessionUser.is_admin) throw '您无权删除结算期';
  124. await ctx.service.deleteSettle(sid);
  125. ctx.redirect('/tender/' + ctx.tender.id + '/settle/');
  126. } catch (err) {
  127. ctx.log(err);
  128. ctx.postError(err, '删除结算期数据失败,请重试');
  129. ctx.redirect('/tender/' + ctx.tender.id + '/settle/');
  130. }
  131. }
  132. async _getDefaultRenderData(ctx) {
  133. const data = {
  134. tender: ctx.tender.data,
  135. auditConst: auditConst.settle,
  136. measureType,
  137. preUrl: '/tender/' + ctx.tender.id + '/settle/' + ctx.params.sorder,
  138. settle: ctx.settle,
  139. shenpiConst,
  140. auditType: auditConst.auditType,
  141. thirdParty: {
  142. gxby: ctx.session.sessionProject.gxby_status,
  143. dagl: ctx.session.sessionProject.dagl_status,
  144. },
  145. };
  146. // 是否已验证手机短信
  147. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  148. data.authMobile = pa.auth_mobile;
  149. const loadAccount = ctx.session.sessionUser.is_admin
  150. ? true
  151. : ctx.session.sessionUser.accountId === ctx.settle.user_id && ([auditConst.settle.status.uncheck, auditConst.settle.status.checkNo].indexOf(ctx.settle.audit_status) >= 0);
  152. if (!loadAccount) return data;
  153. // 获取所有项目参与者
  154. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  155. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  156. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  157. });
  158. data.accountList = accountList;
  159. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  160. data.accountGroup = unitList.map(item => {
  161. const groupList = accountList.filter(item1 => item1.company === item.name);
  162. return { groupName: item.name, groupList };
  163. });
  164. return data;
  165. }
  166. async index(ctx) {
  167. const status = auditConst.settle.status;
  168. let url = (ctx.settle.audit_status === status.uncheck || ctx.settle.audit_status === status.checkNo) && (ctx.session.sessionUser.is_admin || ctx.session.sessionUser.accountId === ctx.settle.user_id) ? 'select' : 'ledger';
  169. ctx.redirect(ctx.url + '/' + url);
  170. }
  171. async select(ctx) {
  172. try {
  173. await ctx.service.settle.loadAuditViewData(ctx.settle);
  174. const renderData = await this._getDefaultRenderData(ctx);
  175. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.settle.select);
  176. const projectFunInfo = await this.ctx.service.project.getFunRela(ctx.session.sessionProject.id);
  177. renderData.whiteList = this.ctx.app.config.multipart.whitelist;
  178. await this.layout('settle/select.ejs', renderData, 'settle/select_modal.ejs');
  179. } catch(err) {
  180. console.log(err);
  181. ctx.log(err);
  182. ctx.redirect('/tender/' + ctx.tender.id + '/settle');
  183. }
  184. }
  185. async ledger(ctx) {
  186. try {
  187. await ctx.service.settle.loadAuditViewData(ctx.settle);
  188. const renderData = await this._getDefaultRenderData(ctx);
  189. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.settle.ledger);
  190. const projectFunInfo = await this.ctx.service.project.getFunRela(ctx.session.sessionProject.id);
  191. renderData.whiteList = this.ctx.app.config.multipart.whitelist;
  192. await this.layout('settle/index.ejs', renderData, 'settle/modal.ejs');
  193. } catch(err) {
  194. console.log(err);
  195. ctx.log(err);
  196. ctx.redirect('/tender/' + ctx.tender.id + '/settle');
  197. }
  198. }
  199. checkNeedPretreadData(ctx) {
  200. return ctx.settle.audit_status === auditConst.settle.status.uncheck || (ctx.settle.audit_status === auditConst.settle.status.checkNo && !ctx.settle.readOnly);
  201. }
  202. async _loadLatestStage(ctx) {
  203. if (ctx.settle.latestStage) return;
  204. ctx.settle.latestStage = ctx.settle.final_sid
  205. ? await this.ctx.service.stage.getDataById(ctx.settle.final_sid)
  206. : await this.ctx.service.stage.getLastestCompleteStage(ctx.tender.id);
  207. }
  208. async _getStageBillsData(ctx) {
  209. this.ledgerColumn = [
  210. 'id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf',
  211. 'code', 'b_code', 'name', 'unit', 'unit_price',
  212. 'quantity', 'total_price', 'memo', 'drawing_code', 'node_type'];
  213. const ledgerData = await ctx.service.ledger.getAllDataByCondition({ columns: this.ledgerColumn, where: { tender_id: ctx.tender.id } });
  214. const endStageData = await ctx.service.stageBillsFinal.getAllDataByCondition({ where: { sid: ctx.settle.latestStage.id } });
  215. this.ctx.helper.assignRelaData(ledgerData, [
  216. { data: endStageData, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'end_', relaId: 'lid' },
  217. ]);
  218. return ledgerData;
  219. }
  220. async _getStagePosData(ctx) {
  221. this.posColumn = ['id', 'tid', 'lid', 'name', 'position', 'porder', 'quantity', 'add_stage_order', 'drawing_code'];
  222. const posData = await ctx.service.pos.getAllDataByCondition({ columns: this.posColumn, where: { tid: ctx.tender.id } });
  223. const endStageData = await ctx.service.stagePosFinal.getAllDataByCondition({ where: { sid: ctx.settle.latestStage.id } });
  224. this.ctx.helper.assignRelaData(posData, [
  225. { data: endStageData, fields: ['contract_qty', 'qc_qty', 'qc_minus_qty'], prefix: 'end_', relaId: 'pid' },
  226. ]);
  227. return posData;
  228. }
  229. async _loadPretreatSettleData(ctx) {
  230. if (this.checkNeedPretreadData(ctx)) {
  231. this.pretreadSettle = {};
  232. const Pretreat = require('../lib/settle');
  233. const pretreadObj = new Pretreat(ctx);
  234. [this.pretreadSettle.settleBills, this.pretreadSettle.settlePos] = await pretreadObj.doSettle(this.ctx.settle);
  235. }
  236. }
  237. async _loadSettleDataByKey(ctx, key, hpack) {
  238. switch (key) {
  239. case 'stageBills':
  240. await this._loadLatestStage(ctx);
  241. const bills = await this._getStageBillsData(ctx);
  242. return hpack ? [ctx.helper.hpackArr(bills), 'stageBills'] : [bills, ''];
  243. case 'stagePos':
  244. await this._loadLatestStage(ctx);
  245. const pos = await this._getStagePosData(ctx);
  246. return hpack ? [ctx.helper.hpackArr(pos), 'stagePos'] : [pos, ''];
  247. case 'settleChange':
  248. await this._loadLatestStage(ctx);
  249. const settleChange = await ctx.service.stageChangeFinal.getUnSettleChangeData(ctx.settle.latestStage);
  250. return hpack ? [ctx.helper.hpackArr(settleChange), key] : [settleChange, ''];
  251. case 'settleBills':
  252. await this._loadPretreatSettleData(ctx);
  253. const settleBills = this.checkNeedPretreadData(ctx)
  254. ? this.pretreadSettle.settleBills
  255. : await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.settle.id } });
  256. return hpack ? [ctx.helper.hpackArr(settleBills), 'settleBills'] : [settleBills, ''];
  257. case 'settlePos':
  258. await this._loadPretreatSettleData(ctx);
  259. const settlePos = this.checkNeedPretreadData(ctx)
  260. ? this.pretreadSettle.settlePos
  261. : await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.settle.id } });
  262. return hpack ? [ctx.helper.hpackArr(settlePos), 'settlePos'] : [settlePos, ''];
  263. case 'settleSelect':
  264. const settleSelect = await ctx.service.settleSelect.getAllDataByCondition({ where: { settle_id: ctx.settle.id } });
  265. return [settleSelect, ''];
  266. case 'tag':
  267. const tag = await ctx.service.ledgerTag.getDatas(ctx.tender.id, -1, ctx.settle.id);
  268. return [tag, ''];
  269. default:
  270. return [null, ''];
  271. }
  272. }
  273. async loadSettleData(ctx) {
  274. try {
  275. const data = JSON.parse(ctx.request.body.data);
  276. const filter = data.filter.split(';');
  277. const responseData = { err: 0, msg: '', data: {}, hpack: [] };
  278. const hpack = true;
  279. for (const f of filter) {
  280. const [relaData, hpackKey] = await this._loadSettleDataByKey(ctx, f, hpack);
  281. responseData.data[f] = relaData;
  282. if (hpackKey) responseData.hpack.push(hpackKey);
  283. }
  284. ctx.body = responseData;
  285. } catch (err) {
  286. ctx.log(err);
  287. ctx.ajaxErrorBody(err, '获取结算数据出错');
  288. }
  289. }
  290. async updateSelect(ctx) {
  291. try {
  292. const data = JSON.parse(ctx.request.body.data);
  293. if (!data.add && !data.del) throw '提交数据错误';
  294. const result = await ctx.service.settleSelect.updateData(data);
  295. ctx.body = { err: 0, msg: '', data: result };
  296. } catch (err) {
  297. ctx.log(err);
  298. ctx.ajaxErrorBody(err, '提交结算数据出错');
  299. }
  300. }
  301. async loadGatherData(ctx) {
  302. try {
  303. const settle = await this.ctx.service.settle.getLatestCompleteSettle(ctx.tender.id);
  304. const bills = await this.ctx.service.settleBills.getDataByCondition({ where: { settle_id: settle.id }});
  305. const pos = await this.ctx.service.settlePos.getDataByCondition({ where: { settle_id: settle.id }});
  306. ctx.body = { err: 0, msg: '', data: { bills, pos } };
  307. } catch(err) {
  308. ctx.log(err);
  309. ctx.ajaxErrorBody(err, '获取结算汇总数据错误');
  310. }
  311. }
  312. async gather(ctx) {
  313. try {
  314. const renderData = {
  315. tender: ctx.tender.data,
  316. preUrl: `/tender/${ctx.tender.id}/measure/stage`,
  317. };
  318. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.settle.gather);
  319. await this.layout('settle/gather.ejs', renderData, 'settle/gather_modal.ejs');
  320. } catch (err) {
  321. ctx.log(err);
  322. ctx.redirect(this.menu.menu.dashboard.url);
  323. }
  324. }
  325. }
  326. return SettleController;
  327. };