payment_controller.js 44 KB

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