payment_controller.js 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743
  1. 'use strict';
  2. const accountGroup = require('../const/account_group').group;
  3. const JV = require('../reports/rpt_component/jpc_value_define');
  4. const shenpiConst = require('../const/shenpi');
  5. const auditConst = require('../const/audit').stage;
  6. const paymentConst = require('../const/payment');
  7. module.exports = app => {
  8. class PaymentController extends app.BaseController {
  9. /**
  10. * 构造函数
  11. *
  12. * @param {Object} ctx - egg全局变量
  13. * @return {void}
  14. */
  15. constructor(ctx) {
  16. super(ctx);
  17. ctx.showProject = true;
  18. // ctx.showTitle = true;
  19. }
  20. /**
  21. * 支付审批列表页
  22. *
  23. * @param {Object} ctx - egg全局页面
  24. * @return {void}
  25. */
  26. async index(ctx) {
  27. try {
  28. const auditPermission = await this.ctx.service.paymentPermissionAudit.getOnePermission(ctx.session.sessionUser.is_admin, ctx.session.sessionUser.accountId);
  29. if (!auditPermission) {
  30. throw '权限不足';
  31. }
  32. // 列表读取及目录读取
  33. const renderData = {
  34. auditPermission,
  35. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.payment.index),
  36. };
  37. if (ctx.session.sessionUser.is_admin) {
  38. const projectId = ctx.session.sessionProject.id;
  39. const permissionAudits = await ctx.service.paymentPermissionAudit.getList(projectId);
  40. // 获取所有项目参与者
  41. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  42. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  43. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  44. });
  45. const accountGroupList = accountGroup.map((item, idx) => {
  46. const groupList = accountList.filter(item => item.account_group === idx);
  47. return { groupName: item, groupList };
  48. });
  49. renderData.permissionAudits = permissionAudits;
  50. renderData.accountList = accountList;
  51. renderData.accountGroup = accountGroupList;
  52. }
  53. await this.layout('payment/index.ejs', renderData, 'payment/modal.ejs');
  54. } catch (err) {
  55. console.log(err);
  56. this.log(err);
  57. ctx.redirect(this.menu.menu.dashboard.url);
  58. }
  59. }
  60. async listLoad(ctx) {
  61. const responseData = {
  62. err: 0, msg: '', data: {},
  63. };
  64. // 先获取你创建的标段及参与的标段
  65. const tenderList = await ctx.service.paymentTender.getList(ctx.session.sessionUser.accountId);
  66. // 获取你创建的目录及对应目录下的所有目录
  67. const folderList = await ctx.service.paymentFolder.getList(ctx.session.sessionUser.accountId, tenderList);
  68. if (tenderList.length > 0) {
  69. for (const t of tenderList) {
  70. t.have_notice = await ctx.service.paymentDetail.haveNotice2Tender(t.id, ctx.session.sessionUser.accountId);
  71. t.have_detail = await ctx.service.paymentDetail.haveDetail2Tender(t.id);
  72. }
  73. }
  74. responseData.data.folderList = folderList;
  75. responseData.data.tenderList = tenderList;
  76. ctx.body = responseData;
  77. }
  78. async permissionSave(ctx) {
  79. try {
  80. if (ctx.session.sessionUser.is_admin === 0) throw '没有设置权限';
  81. const projectId = ctx.session.sessionProject.id;
  82. const responseData = {
  83. err: 0, msg: '', data: null,
  84. };
  85. const data = JSON.parse(ctx.request.body.data);
  86. if (!data.type) {
  87. throw '提交数据错误';
  88. }
  89. let uids;
  90. let result = false;
  91. let auditList = [];
  92. switch (data.type) {
  93. case 'add-audit':
  94. // 判断用户是单个还是数组
  95. uids = data.id instanceof Array ? data.id : [data.id];
  96. // 判断该用户的组是否已加入到表中,已加入则提示无需添加
  97. auditList = await ctx.service.paymentPermissionAudit.getAllDataByCondition({ where: { pid: projectId, uid: uids } });
  98. const addAidList = ctx.helper._.difference(uids, ctx.helper._.map(auditList, 'uid'));
  99. if (addAidList.length === 0) {
  100. throw '用户已存在权限中,无需重复添加';
  101. }
  102. const accountList = await ctx.service.projectAccount.getAllDataByCondition({ where: { id: addAidList } });
  103. await ctx.service.paymentPermissionAudit.saveAudits(projectId, accountList);
  104. responseData.data = await ctx.service.paymentPermissionAudit.getList(projectId);
  105. break;
  106. case 'del-audit':
  107. uids = data.id instanceof Array ? data.id : [data.id];
  108. auditList = await ctx.service.paymentPermissionAudit.getAllDataByCondition({ where: { id: uids } });
  109. if (auditList.length !== uids.length) {
  110. throw '该用户已不存在权限中,移除失败';
  111. }
  112. await ctx.service.paymentPermissionAudit.delAudit(uids);
  113. responseData.data = await ctx.service.paymentPermissionAudit.getList(projectId);
  114. break;
  115. case 'save-permission-one':
  116. result = await ctx.service.paymentPermissionAudit.updateOnePermission(data.updateData);
  117. if (!result) {
  118. throw '修改权限失败';
  119. }
  120. break;
  121. case 'save-permission-all':
  122. result = await ctx.service.paymentPermissionAudit.updateAllPermission(projectId, data.permission_type, data.value);
  123. if (!result) {
  124. throw '修改权限失败';
  125. }
  126. responseData.data = await ctx.service.paymentPermissionAudit.getList(projectId);
  127. break;
  128. default: throw '参数有误';
  129. }
  130. ctx.body = responseData;
  131. } catch (err) {
  132. this.log(err);
  133. ctx.body = { err: 1, msg: err.toString(), data: null };
  134. }
  135. }
  136. async save(ctx) {
  137. try {
  138. const projectId = ctx.session.sessionProject.id;
  139. const auditPermission = await this.ctx.service.paymentPermissionAudit.getOnePermission(ctx.session.sessionUser.is_admin, ctx.session.sessionUser.accountId);
  140. if (!auditPermission) {
  141. throw '权限不足';
  142. }
  143. const responseData = {
  144. err: 0, msg: '', data: {},
  145. };
  146. const data = JSON.parse(ctx.request.body.data);
  147. if (!data.type) {
  148. throw '提交数据错误';
  149. }
  150. let type = '';
  151. switch (data.type) {
  152. case 'add-folder':
  153. if (!auditPermission.folder) {
  154. throw '没有权限新建目录';
  155. }
  156. await ctx.service.paymentFolder.addFolder(projectId, ctx.session.sessionUser.accountId, data.parentId, data.name);
  157. break;
  158. case 'add-tender':
  159. if (!auditPermission.tender) {
  160. throw '没有权限新建标段';
  161. }
  162. await ctx.service.paymentTender.addTender(projectId, ctx.session.sessionUser.accountId, data.folderId, data.name);
  163. break;
  164. case 'edit-name':
  165. type = data.postData.type;
  166. const updateData = {
  167. name: data.postData.name,
  168. };
  169. const conditionData = {
  170. id: data.postData.id,
  171. };
  172. if (type === 'tender') {
  173. await ctx.service.paymentTender.update(updateData, conditionData);
  174. } else {
  175. await ctx.service.paymentFolder.update(updateData, conditionData);
  176. }
  177. break;
  178. case 'del':
  179. type = data.postData.type;
  180. if (type === 'tender') {
  181. await ctx.service.paymentTender.deleteTender(data.postData.id);
  182. } else {
  183. await ctx.service.paymentFolder.deleteFolder(data.postData.id);
  184. }
  185. break;
  186. default: throw '参数有误';
  187. }
  188. // 先获取你创建的标段及参与的标段
  189. const tenderList = await ctx.service.paymentTender.getList(ctx.session.sessionUser.accountId);
  190. // 获取你创建的目录及对应目录下的所有目录
  191. const folderList = await ctx.service.paymentFolder.getList(ctx.session.sessionUser.accountId, tenderList);
  192. responseData.data.folderList = folderList;
  193. responseData.data.tenderList = tenderList;
  194. ctx.body = responseData;
  195. } catch (err) {
  196. this.log(err);
  197. ctx.body = { err: 1, msg: err.toString(), data: null };
  198. }
  199. }
  200. /**
  201. * 获取审批界面所需的 原报、审批人数据等
  202. * @param ctx
  203. * @return {Promise<void>}
  204. * @private
  205. */
  206. async _getDetailAuditViewData(ctx) {
  207. const times = ctx.detail.status === auditConst.status.checkNo ? ctx.detail.times - 1 : ctx.detail.times;
  208. ctx.detail.user = await ctx.service.projectAccount.getAccountInfoById(ctx.detail.uid);
  209. ctx.detail.auditHistory = [];
  210. if (times >= 1) {
  211. for (let i = 1; i <= times; i++) {
  212. ctx.detail.auditHistory.push(await ctx.service.paymentDetailAudit.getAuditors(ctx.detail.id, i));
  213. }
  214. }
  215. // 获取审批流程中左边列表
  216. ctx.detail.auditors2 = ctx.detail.status === auditConst.status.checkNo && ctx.detail.uid !== ctx.session.sessionUser.accountId ?
  217. await ctx.service.paymentDetailAudit.getAuditorsWithOwner(ctx.detail.id, times) :
  218. await ctx.service.paymentDetailAudit.getAuditorsWithOwner(ctx.detail.id, ctx.detail.times);
  219. if (ctx.detail.status === auditConst.status.uncheck || ctx.detail.status === auditConst.status.checkNo) {
  220. ctx.detail.auditorList = await ctx.service.paymentDetailAudit.getAuditors(ctx.detail.id, ctx.detail.times);
  221. }
  222. // 是否已验证手机短信
  223. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  224. ctx.detail.authMobile = pa.auth_mobile;
  225. }
  226. /**
  227. * 支付表单页面
  228. *
  229. * @param {Object} ctx - egg全局页面
  230. * @return {void}
  231. */
  232. async detail(ctx) {
  233. try {
  234. await this._getDetailAuditViewData(ctx);
  235. const renderData = {
  236. trInfo: ctx.trInfo,
  237. paymentConst,
  238. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.payment.detail),
  239. auditConst,
  240. shenpiConst,
  241. preUrl: '/payment/' + ctx.tender.id + '/detail/' + ctx.detail.id,
  242. OSS_PATH: ctx.app.config.fujianOssPath,
  243. };
  244. renderData.nextDetail = await ctx.service.paymentDetail.getDataByCondition({ tr_id: ctx.trInfo.id, order: ctx.detail.order + 1 });
  245. let report_json = JSON.parse(ctx.detail.report_json);
  246. const content = [];
  247. // 获取当前报表人
  248. const rptAudit = await ctx.service.paymentRptAudit.getDataByCondition({ td_id: ctx.detail.id, uid: ctx.session.sessionUser.accountId });
  249. if (report_json.items[0].interact_cells.length > 0) {
  250. for (const [i, cell] of report_json.items[0].interact_cells.entries()) {
  251. const push_item = {
  252. type: paymentConst.rpt_dataType[cell.DataType],
  253. value: cell.Prefix ? ctx.helper._.replace(cell.Value, cell.Prefix, '') : cell.Value,
  254. label: cell.Label,
  255. index: i,
  256. };
  257. const thisControl = paymentConst.rpt_control[cell.control] ? cell.control : 'content';
  258. const oneShowContent = ctx.helper._.find(content, { control: thisControl });
  259. if (oneShowContent) {
  260. oneShowContent.items.push(push_item);
  261. } else {
  262. content.push({
  263. control: thisControl,
  264. title: paymentConst.rpt_control[thisControl],
  265. items: [push_item],
  266. });
  267. }
  268. }
  269. if (rptAudit && ((ctx.detail.status !== auditConst.status.checkNo && ctx.detail.status !== auditConst.status.checked) ||
  270. (ctx.detail.status === auditConst.status.checked && !renderData.nextDetail) ||
  271. (ctx.detail.status === auditConst.status.checkNo && ctx.detail.uid === ctx.session.sessionUser.accountId))) {
  272. // 获取个人签字,单位章,个人章地址
  273. const userInfo = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  274. const stampPathList = userInfo.stamp_path ? userInfo.stamp_path.split('!;!') : [];
  275. const companyInfo = userInfo.company ? await ctx.service.constructionUnit.getDataByCondition({ pid: ctx.session.sessionProject.id, name: userInfo.company }) : {};
  276. if (rptAudit.signature_msg) {
  277. const sign_msg = JSON.parse(rptAudit.signature_msg);
  278. report_json = await ctx.service.paymentDetail.signOneSignatureData(report_json, rptAudit.signature_name, sign_msg);
  279. rptAudit.signature_msg = sign_msg;
  280. } else {
  281. rptAudit.signature_msg = paymentConst.signature_msg;
  282. rptAudit.signature_msg.sign_path = userInfo.sign_path ? userInfo.sign_path : '';
  283. }
  284. renderData.signPath = userInfo.sign_path ? userInfo.sign_path : '';
  285. renderData.stampPathList = stampPathList;
  286. renderData.currentStamp = rptAudit && rptAudit.signature_msg.stamp_path ? rptAudit.signature_msg.stamp_path : (stampPathList.length > 0 ? stampPathList[0] : '');
  287. renderData.companyStamp = companyInfo && companyInfo.sign_path ? companyInfo.sign_path : '';
  288. }
  289. }
  290. renderData.rptAudit = rptAudit;
  291. renderData.content = content;
  292. renderData.report_json = report_json;
  293. if ((ctx.detail.status === auditConst.status.uncheck || ctx.detail.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.detail.uid) {
  294. // data.accountGroup = accountGroup;
  295. // 获取所有项目参与者
  296. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  297. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  298. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  299. });
  300. renderData.accountList = accountList;
  301. renderData.accountGroup = accountGroup.map((item, idx) => {
  302. const groupList = accountList.filter(item => item.account_group === idx);
  303. return { groupName: item, groupList };
  304. });
  305. renderData.rptAuditList = await ctx.service.paymentRptAudit.getAllDataByCondition({ where: { td_id: ctx.detail.id } });
  306. }
  307. await this.layout('payment/detail.ejs', renderData, 'payment/detail_modal.ejs');
  308. } catch (err) {
  309. console.log(err);
  310. this.log(err);
  311. ctx.redirect(this.menu.menu.dashboard.url);
  312. }
  313. }
  314. async detailSave(ctx) {
  315. try {
  316. const data = JSON.parse(ctx.request.body.data);
  317. if (!data.type) {
  318. throw '提交数据错误';
  319. }
  320. // 检查权限等
  321. if (ctx.detail.uid !== ctx.session.sessionUser.accountId && data.type !== 'update_sign') {
  322. throw '您无权操作';
  323. }
  324. if (data.type !== 'update_sign' && (ctx.detail.status === auditConst.status.checking || ctx.detail.status === auditConst.status.checked)) {
  325. throw '您无权操作';
  326. }
  327. const responseData = {
  328. err: 0, msg: '', data: {},
  329. };
  330. switch (data.type) {
  331. case 'update_rpt':
  332. responseData.data = await ctx.service.paymentDetail.updateReportJson(ctx.detail.id, data.report_json);
  333. break;
  334. case 'update_sign':
  335. if (ctx.detail.status === auditConst.status.checked) {
  336. throw '您无法操作签字/签章';
  337. }
  338. responseData.data = await ctx.service.paymentRptAudit.updateSignatureMsg(ctx.detail.id, ctx.session.sessionUser.accountId, data.signature_msg);
  339. break;
  340. case 'add_audit':
  341. const auditorId = this.app._.toInteger(data.auditorId);
  342. if (isNaN(auditorId) || auditorId <= 0) {
  343. throw '参数错误';
  344. }
  345. ctx.detail.auditorList = await ctx.service.paymentDetailAudit.getAuditors(ctx.detail.id, ctx.detail.times);
  346. // 检查审核人是否已存在
  347. const exist = this.app._.find(ctx.detail.auditorList, { aid: auditorId });
  348. if (exist) {
  349. throw '该审核人已存在,请勿重复添加';
  350. }
  351. const shenpiInfo = await ctx.service.paymentShenpiAudit.getDataByCondition({ tr_id: ctx.trInfo.id, sp_status: shenpiConst.sp_status.gdzs });
  352. const is_gdzs = shenpiInfo && ctx.trinfo.sp_status === shenpiConst.sp_status.gdzs ? 1 : 0;
  353. const result = await ctx.service.paymentDetailAudit.addAuditor(ctx.detail.id, auditorId, ctx.detail.times, is_gdzs);
  354. if (!result) {
  355. throw '添加审核人失败';
  356. }
  357. responseData.data = await ctx.service.paymentDetailAudit.getAuditorsWithOwner(ctx.detail.id, ctx.detail.times);
  358. break;
  359. case 'del_audit':
  360. const auditorId2 = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  361. if (isNaN(auditorId2) || auditorId2 <= 0) {
  362. throw '参数错误';
  363. }
  364. const result2 = await ctx.service.paymentDetailAudit.deleteAuditor(ctx.detail.id, auditorId2, ctx.detail.times);
  365. if (!result2) {
  366. throw '移除审核人失败';
  367. }
  368. responseData.data = await ctx.service.paymentDetailAudit.getAuditors(ctx.detail.id, ctx.detail.times);
  369. break;
  370. default: throw '参数有误';
  371. }
  372. ctx.body = responseData;
  373. } catch (err) {
  374. this.log(err);
  375. ctx.body = { err: 1, msg: err.toString(), data: null };
  376. }
  377. }
  378. async deleteDetail(ctx) {
  379. try {
  380. const detail_id = ctx.request.body.detail_id;
  381. const detailInfo = await ctx.service.paymentDetail.getDataById(detail_id);
  382. if (!detailInfo) {
  383. throw '所选报表表单详情已删除';
  384. }
  385. // 获取最新的期数
  386. const detail_highOrder = await ctx.service.paymentDetail.count({
  387. tr_id: detailInfo.tr_id,
  388. });
  389. if (!(ctx.session.sessionUser.is_admin || ((detailInfo.status === auditConst.status.uncheck || detailInfo.status === auditConst.status.checkNo) && detailInfo.uid === ctx.session.sessionUser.accountId)) || detail_highOrder !== detailInfo.order) {
  390. throw '您无权删除所选报表表单详情';
  391. }
  392. const result = await ctx.service.paymentDetail.deleteDetail(detail_id);
  393. if (!result) {
  394. throw '删除报表表单详情失败,请重试';
  395. }
  396. ctx.redirect('/payment/' + ctx.tender.id + '/list/' + detailInfo.tr_id);
  397. } catch (err) {
  398. this.log(err);
  399. ctx.redirect(ctx.request.header.referer);
  400. }
  401. }
  402. /**
  403. * 期审批流程(Get)
  404. * @param ctx
  405. * @return {Promise<void>}
  406. */
  407. async detailAuditors(ctx) {
  408. try {
  409. const responseData = {
  410. err: 0, msg: '', data: {},
  411. };
  412. const order = JSON.parse(ctx.request.body.data).order;
  413. const tr_id = ctx.params.trid;
  414. const detailInfo = await ctx.service.paymentDetail.getDataByCondition({ tr_id, order });
  415. // 获取审批流程中右边列表
  416. const auditHistory = [];
  417. const times = detailInfo.status === auditConst.status.checkNo ? detailInfo.times - 1 : detailInfo.times;
  418. if (times >= 1) {
  419. for (let i = 1; i <= times; i++) {
  420. auditHistory.push(await ctx.service.paymentDetailAudit.getAuditors(detailInfo.id, i));
  421. }
  422. }
  423. responseData.data.auditHistory = auditHistory;
  424. // 获取审批流程中左边列表
  425. responseData.data.auditors = await ctx.service.paymentDetailAudit.getAuditorsWithOwner(detailInfo.id, times);
  426. responseData.data.user = await ctx.service.projectAccount.getAccountInfoById(detailInfo.uid);
  427. ctx.body = responseData;
  428. } catch (error) {
  429. this.log(error);
  430. ctx.body = { err: 1, msg: error.toString(), data: null };
  431. }
  432. }
  433. async _returnRptProjectList(ctx, formProcess = false) {
  434. // 获取报表表单列表
  435. if (ctx.tender.uid === ctx.session.sessionUser.accountId || formProcess) {
  436. const rptProject = await ctx.service.rptTreeNode.getDataByCondition({ name: '01.支付审批报表' });
  437. const rptProjectList = rptProject.items ? JSON.parse(rptProject.items) : [];
  438. const tenderRptList = await ctx.service.paymentTenderRpt.getProcessList(ctx.tender.id);
  439. return await ctx.service.paymentTenderRpt.checkAndUpdateList(tenderRptList, rptProjectList, formProcess);
  440. }
  441. return await ctx.service.paymentTenderRpt.getList(ctx.tender.id, ctx.session.sessionUser.accountId);
  442. }
  443. async process(ctx) {
  444. try {
  445. const auditPermission = await this.ctx.service.paymentPermissionAudit.getOnePermission(ctx.session.sessionUser.is_admin, ctx.session.sessionUser.accountId);
  446. if (!auditPermission || !auditPermission.process) {
  447. throw '权限不足';
  448. }
  449. let [tenderRptList, rptProjectList] = await this._returnRptProjectList(ctx, true);
  450. tenderRptList = ctx.helper._.filter(tenderRptList, { is_const: 0, is_del: 0 });
  451. // for (const tr of tenderRptList) {
  452. // if (tr.status === shenpiConst.sp_status.gdspl) {
  453. // tr.auditList = await ctx.service.paymentShenpiAudit.getAuditList(ctx.tender.id, tr.id, tr.sp_status);
  454. // } else if (tr.status === shenpiConst.sp_status.gdzs) {
  455. // tr.audit = await ctx.service.paymentShenpiAudit.getAudit(ctx.tender.id, tr.id, tr.sp_status);
  456. // }
  457. // }
  458. // 获取所有项目参与者
  459. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  460. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  461. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  462. });
  463. const accountGroupList = accountGroup.map((item, idx) => {
  464. const groupList = accountList.filter(item => item.account_group === idx);
  465. return { groupName: item, groupList };
  466. });
  467. const renderData = {
  468. tender: ctx.tender,
  469. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.payment.process),
  470. rptProjectList,
  471. tenderRptList,
  472. shenpi: shenpiConst,
  473. accountList,
  474. accountGroup: accountGroupList,
  475. };
  476. await this.layout('payment/process.ejs', renderData, 'payment/process_modal.ejs');
  477. } catch (err) {
  478. console.log(err);
  479. this.log(err);
  480. ctx.redirect(this.request.headers.referer ? this.request.headers.referer : this.menu.menu.dashboard.url);
  481. }
  482. }
  483. async processSave(ctx) {
  484. try {
  485. const auditPermission = await this.ctx.service.paymentPermissionAudit.getOnePermission(ctx.session.sessionUser.is_admin, ctx.session.sessionUser.accountId);
  486. if (!auditPermission || !auditPermission.process) {
  487. throw '权限不足';
  488. }
  489. const responseData = {
  490. err: 0, msg: '', data: {},
  491. };
  492. const data = JSON.parse(ctx.request.body.data);
  493. if (!data.type) {
  494. throw '提交数据错误';
  495. }
  496. switch (data.type) {
  497. case 'add-rpt':
  498. responseData.data = await ctx.service.paymentTenderRpt.setRpt(ctx.tender.id, data.rpt_list);
  499. break;
  500. case 'change-status':
  501. responseData.data = await ctx.service.paymentTenderRpt.setStatus(data.tr_id, data.status);
  502. break;
  503. case 'get-audits':
  504. responseData.data = await ctx.service.paymentShenpiAudit.getShenpiAudit(data.tr_id, data.status);
  505. break;
  506. case 'add-audit':
  507. responseData.data = await ctx.service.paymentShenpiAudit.addAudit(data);
  508. break;
  509. case 'del-audit':
  510. responseData.data = await ctx.service.paymentShenpiAudit.removeAudit(data);
  511. break;
  512. default: throw '参数有误';
  513. }
  514. ctx.body = responseData;
  515. } catch (err) {
  516. this.log(err);
  517. ctx.body = { err: 1, msg: err.toString(), data: null };
  518. }
  519. }
  520. async rptList(ctx) {
  521. try {
  522. const tenderRptList = await this._returnRptProjectList(ctx);
  523. if (tenderRptList.length === 0) {
  524. throw '当前报表表单您无权打开';
  525. }
  526. for (const tr of tenderRptList) {
  527. tr.have_notice = await ctx.service.paymentDetail.haveNotice2TenderRpt(tr.id, ctx.session.sessionUser.accountId);
  528. }
  529. const trid = ctx.params.trid ? parseInt(ctx.params.trid) : 0;
  530. const trInfo = trid ? ctx.helper._.find(tenderRptList, { id: trid }) : tenderRptList[0];
  531. // 获取列表
  532. const trDetailList = await ctx.service.paymentDetail.getValidDetails(trInfo.id);
  533. for (const s of trDetailList) {
  534. // s.curAuditor = null;
  535. // 根据期状态返回展示用户
  536. s.curAuditor = await ctx.service.paymentDetailAudit.getAuditorByStatus(s.id, s.status, s.times);
  537. }
  538. const renderData = {
  539. tender: ctx.tender,
  540. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.payment.list),
  541. tenderRptList,
  542. trInfo,
  543. trDetailList,
  544. rptMsg: null,
  545. auditConst,
  546. accountGroup: [],
  547. accountList: [],
  548. preUrl: '/payment/' + ctx.tender.id + '/list/' + trInfo.id,
  549. };
  550. // 获取报表信息,新增时及设置报表角色时使用
  551. if (trInfo.uid === ctx.session.sessionUser.accountId && trInfo.is_del === 0 && trInfo.rpt_id) {
  552. const rptTpl = await ctx.service.rptTpl.getDataById(trInfo.rpt_id);
  553. if (rptTpl) {
  554. const pageRst = await ctx.service.jpcReport.getAllPreviewPagesCommon(rptTpl, 'A4');
  555. renderData.rptMsg = pageRst.items[0];
  556. // 判断与原有的报表审批人列表是否有区别
  557. let difference = false;
  558. if (trInfo.report_items_json) {
  559. const report_items_json = JSON.parse(trInfo.report_items_json);
  560. const items = ['cells', 'signature_audit_cells', 'signature_cells', 'signature_date_cells', 'interact_cells'];
  561. for (const item of items) {
  562. if (!difference && report_items_json[item] &&
  563. !ctx.helper._.isEmpty(ctx.helper._.differenceWith(JSON.parse(JSON.stringify(renderData.rptMsg[item])), report_items_json[item], ctx.helper._.isEqual))) {
  564. // 因为interact_cells里存在undefind值,必须先用JSON.parse和JSON.stringify转义才能对比
  565. difference = true;
  566. break;
  567. }
  568. }
  569. }
  570. if (difference) {
  571. // 删除rpt_audit重新配置
  572. await ctx.service.paymentTenderRpt.defaultUpdate({
  573. id: trInfo.id,
  574. report_items_json: JSON.stringify(ctx.helper._.cloneDeep(renderData.rptMsg)),
  575. rpt_audit: null,
  576. is_change: 1,
  577. });
  578. trInfo.rpt_audit = null;
  579. trInfo.is_change = 1;
  580. trInfo.report_items_json = renderData.rptMsg;
  581. }
  582. if (trInfo.rpt_audit) {
  583. trInfo.rpt_audit = JSON.parse(trInfo.rpt_audit);
  584. const prjAccList = await ctx.service.projectAccount.getAllAccountByProjectId(ctx.session.sessionProject.id);
  585. for (const audit of trInfo.rpt_audit) {
  586. if (audit.uid) {
  587. const info = ctx.helper._.find(prjAccList, { id: audit.uid });
  588. audit.name = info.name;
  589. }
  590. }
  591. } else {
  592. trInfo.rpt_audit = [];
  593. for (const sc of renderData.rptMsg.signature_cells) {
  594. trInfo.rpt_audit.push({
  595. uid: null,
  596. rpt_name: sc.signature_name,
  597. });
  598. }
  599. }
  600. renderData.trInfo = trInfo;
  601. }
  602. if (renderData.rptMsg) {
  603. // 获取所有项目参与者
  604. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  605. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  606. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  607. });
  608. const accountGroupList = accountGroup.map((item, idx) => {
  609. const groupList = accountList.filter(item => item.account_group === idx);
  610. return { groupName: item, groupList };
  611. });
  612. renderData.accountList = accountList;
  613. renderData.accountGroup = accountGroupList;
  614. }
  615. }
  616. await this.layout('payment/list.ejs', renderData, 'payment/list_modal.ejs');
  617. } catch (err) {
  618. console.log(err);
  619. this.log(err);
  620. ctx.redirect(this.request && this.request.headers && this.request.headers.referer ? this.request.headers.referer : this.menu.menu.dashboard.url);
  621. }
  622. }
  623. async rptSave(ctx) {
  624. try {
  625. const tr_id = ctx.params.trid;
  626. if (!tr_id) {
  627. throw '参数有误';
  628. }
  629. const trInfo = await ctx.service.paymentTenderRpt.getDataById(tr_id);
  630. if (!trInfo) {
  631. throw '标段报表不存在';
  632. }
  633. if (ctx.session.sessionUser.accountId !== trInfo.uid) {
  634. throw '权限不足';
  635. }
  636. const responseData = {
  637. err: 0, msg: '', data: {},
  638. };
  639. const data = JSON.parse(ctx.request.body.data);
  640. if (!data.type) {
  641. throw '提交数据错误';
  642. }
  643. switch (data.type) {
  644. case 'rpt_audit':
  645. responseData.data = await ctx.service.paymentTenderRpt.updateRptAudit(trInfo, data.rpt_audit);
  646. break;
  647. case 'add-detail':
  648. responseData.data = await ctx.service.paymentDetail.addDetail(trInfo, data.code, data.s_time);
  649. break;
  650. default: throw '参数有误';
  651. }
  652. ctx.body = responseData;
  653. } catch (err) {
  654. this.log(err);
  655. ctx.body = { err: 1, msg: err.toString(), data: null };
  656. }
  657. }
  658. /**
  659. * 上报和重新上报
  660. * @param ctx
  661. * @return {Promise<void>}
  662. */
  663. async startAudit(ctx) {
  664. try {
  665. if (ctx.detail.uid !== ctx.session.sessionUser.accountId) {
  666. throw '您无权上报报表表单详情数据';
  667. }
  668. if (ctx.detail.status === auditConst.status.checking || ctx.detail.status === auditConst.status.checked) {
  669. throw '该报表表单详情数据当前无法上报';
  670. }
  671. await ctx.service.paymentDetailAudit.start(ctx.detail.id, ctx.detail.times);
  672. ctx.redirect(ctx.request.header.referer);
  673. } catch (err) {
  674. this.log(err);
  675. ctx.session.postError = err.toString();
  676. ctx.redirect(ctx.request.header.referer);
  677. }
  678. }
  679. /**
  680. * 审批
  681. * @param ctx
  682. * @return {Promise<void>}
  683. */
  684. async checkAudit(ctx) {
  685. try {
  686. if (!ctx.detail || ctx.detail.status !== auditConst.status.checking) {
  687. throw '当前报表表单详情数据有误';
  688. }
  689. if (!ctx.detail.curAuditor || ctx.detail.curAuditor.aid !== ctx.session.sessionUser.accountId) {
  690. throw '您无权进行该操作';
  691. }
  692. const data = {
  693. checkType: parseInt(ctx.request.body.checkType),
  694. opinion: ctx.request.body.opinion,
  695. };
  696. if (!data.checkType || isNaN(data.checkType)) {
  697. throw '提交数据错误';
  698. }
  699. if (data.checkType === auditConst.status.checkNo) {
  700. if (!data.checkType || isNaN(data.checkType)) {
  701. throw '提交数据错误';
  702. }
  703. }
  704. await ctx.service.paymentDetailAudit.check(ctx.detail.id, data, ctx.detail.times);
  705. ctx.redirect(ctx.request.header.referer);
  706. } catch (err) {
  707. this.log(err);
  708. ctx.session.postError = err.toString();
  709. ctx.redirect(ctx.request.header.referer);
  710. }
  711. }
  712. }
  713. return PaymentController;
  714. };