wap_controller.js 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800
  1. 'use strict';
  2. /**
  3. * 登录页面控制器
  4. *
  5. * @author CaiAoLin
  6. * @date 2017/11/15
  7. * @version
  8. */
  9. const URL = require('url');
  10. const maintainConst = require('../const/maintain');
  11. const auditConst = require('../const/audit');
  12. const changeConst = require('../const/change');
  13. const advanceConst = require('../const/advance');
  14. const fs = require('fs');
  15. const path = require('path');
  16. const sendToWormhole = require('stream-wormhole');
  17. const moment = require('moment');
  18. module.exports = app => {
  19. class WapController extends app.BaseController {
  20. /**
  21. * 登录页面
  22. *
  23. * @param {Object} ctx - egg全局页面
  24. * @return {void}
  25. */
  26. async index(ctx) {
  27. if (!ctx.helper.isMobile(ctx.request.header['user-agent'])) {
  28. ctx.redirect('/');
  29. return;
  30. }
  31. const errorMessage = ctx.session.loginError;
  32. // 显示完删除
  33. ctx.session.loginError = null;
  34. // 获取系统维护信息
  35. const maintainData = await ctx.service.maintain.getDataById(1);
  36. if (!ctx.app.config.is_debug) {
  37. await ctx.service.maintain.syncMaintainData();
  38. }
  39. let projectData = '';
  40. if (ctx.session.wapTenderID) {
  41. const tenderData = await ctx.service.tender.getDataById(ctx.session.wapTenderID);
  42. if (tenderData) projectData = await ctx.service.project.getDataById(tenderData.project_id);
  43. }
  44. const renderData = {
  45. maintainData,
  46. maintainConst,
  47. errorMessage,
  48. projectData,
  49. };
  50. await ctx.render('wap/login.ejs', renderData);
  51. }
  52. /**
  53. * 登录操作
  54. *
  55. * @param {Object} ctx - egg全局变量
  56. * @return {void}
  57. */
  58. async login(ctx) {
  59. let loginType = ctx.request.body.type;
  60. try {
  61. loginType = parseInt(loginType);
  62. const result = await ctx.service.projectAccount.accountLogin(ctx.request.body, loginType);
  63. if (!result) {
  64. throw '用户名或密码错误';
  65. }
  66. if (result === 2) {
  67. throw '该账号已被停用,请联系销售人员';
  68. }
  69. // 调用 rotateCsrfSecret 刷新用户的 CSRF token
  70. ctx.rotateCsrfSecret();
  71. // 判断是否已经有对应用户信息,没有则跳转初始化页面
  72. const needBoot = await ctx.service.customer.isNeedBoot(ctx.request.body);
  73. const url = needBoot ? '/boot' : '/wap/dashboard';
  74. const query = URL.parse(ctx.request.header.referer, true).query;
  75. let referer = '';
  76. if (ctx.session.wapTenderID) {
  77. referer = query.referer ? query.referer + '#shenpi' : url;
  78. ctx.session.wapTenderID = null;
  79. }
  80. ctx.redirect(referer ? referer : url);
  81. } catch (error) {
  82. this.log(error);
  83. ctx.session.loginError = error;
  84. ctx.redirect('/wap');
  85. }
  86. }
  87. /**
  88. * 退出登录
  89. *
  90. * @param {Object} ctx - egg全局变量
  91. * @return {void}
  92. */
  93. async logout(ctx) {
  94. // 删除session并跳转
  95. ctx.session = null;
  96. ctx.redirect('/wap');
  97. }
  98. /**
  99. * 待办页
  100. *
  101. * @param {Object} ctx - egg全局变量
  102. * @return {void}
  103. */
  104. async dashboard(ctx) {
  105. // 获取待审批的期
  106. const auditStages = await ctx.service.stageAudit.getAuditStageByWap(ctx.session.sessionUser.accountId);
  107. for (const audit of auditStages) {
  108. await this.ctx.service.stage.checkStageGatherData(audit);
  109. audit.gather_tp = ctx.helper.add(audit.contract_tp, audit.qc_tp);
  110. audit.end_contract_tp = ctx.helper.add(audit.contract_tp, audit.pre_contract_tp);
  111. audit.end_qc_tp = ctx.helper.add(audit.qc_tp, audit.pre_qc_tp);
  112. audit.end_gather_tp = ctx.helper.add(audit.end_contract_tp, audit.end_qc_tp);
  113. audit.pre_gather_tp = ctx.helper.add(audit.pre_contract_tp, audit.pre_qc_tp);
  114. }
  115. // 获取待审批的变更期
  116. const auditChanges = await ctx.service.changeAudit.getAuditChangeByWap(ctx.session.sessionUser.accountId);
  117. // 获取待审批的变更方案
  118. let auditChangePlans = [];
  119. if (ctx.session.sessionProject.page_show.openChangePlan) {
  120. auditChangePlans = await ctx.service.changePlanAudit.getAuditChangePlanByWap(ctx.session.sessionUser.accountId);
  121. }
  122. // 获取待审批的台账修订
  123. const auditRevise = await ctx.service.reviseAudit.getAuditReviseByWap(ctx.session.sessionUser.accountId);
  124. for (const revise of auditRevise) {
  125. const yb_audit = await ctx.service.projectAccount.getAccountInfoById(revise.audit_id);
  126. revise.yb_name = yb_audit.name;
  127. }
  128. // 获取待审批的预付款
  129. const auditAdvance = await ctx.service.advanceAudit.getAuditAdvanceByWap(ctx.session.sessionUser.accountId);
  130. const renderData = {
  131. auditStages,
  132. auditChanges,
  133. auditChangePlans,
  134. auditRevise,
  135. auditAdvance,
  136. changeConst,
  137. advanceConst,
  138. tpUnit: 2,
  139. };
  140. await ctx.render('wap/dashboard.ejs', renderData);
  141. }
  142. /**
  143. * 标段列表页
  144. *
  145. * @param {Object} ctx - egg全局变量
  146. * @return {void}
  147. */
  148. async list(ctx) {
  149. try {
  150. // 获取用户新建标段权利
  151. const accountInfo = await this.ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  152. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  153. const tenderList = await this.ctx.service.tender.getList('', userPermission);
  154. for (const t of tenderList) {
  155. if (t.user_id === this.ctx.session.sessionUser.accountId && (
  156. t.ledger_status === auditConst.ledger.status.checkNo || t.ledger_status === auditConst.ledger.status.uncheck)) {
  157. const sum = await this.ctx.service.ledger.addUp({tender_id: t.id/*, is_leaf: true*/});
  158. t.total_price = sum.total_price;
  159. t.deal_tp = sum.deal_tp;
  160. }
  161. if (t.ledger_status === auditConst.ledger.status.checked) {
  162. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);
  163. if (!t.lastStage) continue;
  164. if (t.lastStage.status === auditConst.stage.status.uncheck && t.lastStage.user_id !== this.ctx.session.sessionUser.accountId) {
  165. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id);
  166. }
  167. if (!t.lastStage) continue;
  168. await this.ctx.service.stage.checkStageGatherData(t.lastStage);
  169. }
  170. }
  171. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  172. const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  173. const renderData = {
  174. tenderList,
  175. categoryData,
  176. auditConst,
  177. userPermission,
  178. valuations,
  179. uid: this.ctx.session.sessionUser.accountId,
  180. pid: this.ctx.session.sessionProject.id,
  181. };
  182. await ctx.render('wap/list.ejs', renderData);
  183. } catch (err) {
  184. this.log(err);
  185. this.ctx.redirect('/wap/dashboard');
  186. }
  187. }
  188. /**
  189. * 标段详细页
  190. *
  191. * @param {Object} ctx - egg全局变量
  192. * @return {void}
  193. */
  194. async tender(ctx) {
  195. try {
  196. const tender = ctx.tender.data;
  197. if (tender.user_id === this.ctx.session.sessionUser.accountId && (
  198. tender.ledger_status === auditConst.ledger.status.checkNo || tender.ledger_status === auditConst.ledger.status.uncheck)) {
  199. const sum = await this.ctx.service.ledger.addUp({tender_id: tender.id/*, is_leaf: true*/});
  200. tender.total_price = sum.total_price;
  201. tender.deal_tp = sum.deal_tp;
  202. }
  203. const stages = await ctx.service.stage.getValidStages(ctx.tender.id);
  204. const lastStage = stages.length > 0 ? stages[0] : null; //await ctx.service.stage.getLastestStage(ctx.tender.id);
  205. if (lastStage) {
  206. await this.ctx.service.stage.checkStageGatherData(lastStage);
  207. tender.gather_tp = ctx.helper.add(lastStage.contract_tp, lastStage.qc_tp);
  208. tender.end_contract_tp = ctx.helper.add(lastStage.contract_tp, lastStage.pre_contract_tp);
  209. tender.end_qc_tp = ctx.helper.add(lastStage.qc_tp, lastStage.pre_qc_tp);
  210. tender.end_gather_tp = ctx.helper.add(tender.end_contract_tp, tender.end_qc_tp);
  211. tender.pre_gather_tp = ctx.helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
  212. tender.yf_tp = lastStage.yf_tp;
  213. tender.qc_ratio = ctx.helper.mul(ctx.helper.div(tender.end_qc_tp, ctx.tender.info.deal_param.contractPrice, 2), 100);
  214. tender.sum = ctx.helper.add(tender.total_price, tender.end_qc_tp);
  215. tender.pre_ratio = ctx.helper.mul(ctx.helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
  216. tender.cur_ratio = ctx.helper.mul(ctx.helper.div(tender.gather_tp, tender.sum, 2), 100);
  217. tender.other_tp = ctx.helper.sub(ctx.helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
  218. tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
  219. }
  220. const monthProgress = [];
  221. for (const s of stages) {
  222. if (s.s_time) {
  223. let progress = monthProgress.find(function(x) {
  224. return x.month === s.s_time;
  225. });
  226. if (!progress) {
  227. progress = { month: s.s_time };
  228. monthProgress.push(progress);
  229. }
  230. progress.tp = ctx.helper.add(ctx.helper.add(progress.tp, s.contract_tp), s.qc_tp);
  231. }
  232. }
  233. monthProgress.sort(function(x, y) {
  234. return Date.parse(x.month) - Date.parse(y.month);
  235. });
  236. let sum = 0;
  237. for (const p of monthProgress) {
  238. p.ratio = ctx.helper.mul(ctx.helper.div(p.tp, tender.sum, 4), 100);
  239. sum = ctx.helper.add(sum, p.tp);
  240. p.end_tp = sum;
  241. p.end_ratio = ctx.helper.mul(ctx.helper.div(p.end_tp, tender.sum, 4), 100);
  242. }
  243. // 变更令列表
  244. const changes = await ctx.service.change.getListByStatus(tender.id, 0, 0);
  245. for (const c of changes) {
  246. c.curAuditor = await ctx.service.changeAudit.getLastUser(c.cid, c.times);
  247. }
  248. // 变更令列表
  249. let changePlans = [];
  250. if (ctx.session.sessionProject.page_show.openChangePlan) {
  251. changePlans = await ctx.service.changePlan.getListByStatus(tender.id, 0, 0);
  252. for (const c of changePlans) {
  253. c.curAuditor = await ctx.service.changePlanAudit.getAuditorByStatus(c.id, c.status, c.times);
  254. }
  255. }
  256. // 台账修订列表
  257. const revises = await ctx.service.ledgerRevise.getReviseList(ctx.tender.id);
  258. for (const lr of revises) {
  259. if (lr.valid) {
  260. lr.curAuditor = await ctx.service.reviseAudit.getAuditorByStatus(lr.id, lr.status, lr.times);
  261. }
  262. }
  263. // 预付款期数获取
  264. const advanceList = [];
  265. for (const t of advanceConst.typeCol) {
  266. const advance = await ctx.service.advance.getLastestAdvance(ctx.tender.id, t.type, true);
  267. advanceList.push(advance);
  268. }
  269. const renderData = {
  270. tender,
  271. stages,
  272. changes,
  273. changePlans,
  274. revises,
  275. advanceList,
  276. auditConst: auditConst.stage,
  277. auditChangeConst: auditConst.flow,
  278. auditChangePlanConst: auditConst.changePlan,
  279. auditReviseConst: auditConst.revise,
  280. changeConst,
  281. advanceConst,
  282. tpUnit: ctx.tender.info.decimal.tp,
  283. monthProgress,
  284. stagesEcharts: JSON.parse(JSON.stringify(stages)).reverse(),
  285. };
  286. if (stages.length > 0) {
  287. for (const s of stages) {
  288. // s.curAuditor = null;
  289. // 根据期状态返回展示用户
  290. s.curAuditor = await ctx.service.stageAudit.getAuditorByStatus(s.id, s.status, s.times);
  291. if (s.status === auditConst.stage.status.checkNoPre) {
  292. s.curAuditor2 = await ctx.service.stageAudit.getAuditorByStatus(s.id, auditConst.stage.status.checking);
  293. }
  294. }
  295. renderData.stage = stages[0];
  296. const times = renderData.stage.status === auditConst.stage.status.checkNo ? renderData.stage.times - 1 : renderData.stage.times;
  297. renderData.stage.user = await ctx.service.projectAccount.getAccountInfoById(renderData.stage.user_id);
  298. renderData.stage.auditors = await ctx.service.stageAudit.getAuditors(renderData.stage.id, times);
  299. // 获取审批流程中左边列表
  300. renderData.stage.auditors2 = await ctx.service.stageAudit.getAuditGroupByList(renderData.stage.id, times);
  301. }
  302. await ctx.render('wap/tender.ejs', renderData);
  303. } catch (err) {
  304. this.log(err);
  305. ctx.redirect('/wap/list');
  306. }
  307. }
  308. /**
  309. * 期审批详细页
  310. *
  311. * @param {Object} ctx - egg全局变量
  312. * @return {void}
  313. */
  314. async stage(ctx) {
  315. try {
  316. const tender = ctx.tender.data;
  317. const stages = await ctx.service.stage.getValidStages(ctx.tender.id);
  318. const lastStage = stages.length > 0 ? stages[0] : null;
  319. if (lastStage) {
  320. await this.ctx.service.stage.checkStageGatherData(lastStage);
  321. }
  322. const stage = lastStage;
  323. const renderData = {
  324. tender,
  325. stage,
  326. auditConst: auditConst.stage,
  327. };
  328. const times = renderData.stage.status === auditConst.stage.status.checkNo ? renderData.stage.times - 1 : renderData.stage.times;
  329. renderData.stage.user = await ctx.service.projectAccount.getAccountInfoById(renderData.stage.user_id);
  330. renderData.stage.auditors = await ctx.service.stageAudit.getAuditors(renderData.stage.id, times);
  331. // 获取审批流程中左边列表
  332. renderData.stage.auditors2 = await ctx.service.stageAudit.getAuditGroupByList(renderData.stage.id, times);
  333. await ctx.render('wap/shenpi_stage.ejs', renderData);
  334. } catch (err) {
  335. this.log(err);
  336. ctx.redirect('/wap/list');
  337. }
  338. }
  339. /**
  340. * 变更审批详细页
  341. *
  342. * @param {Object} ctx - egg全局变量
  343. * @return {void}
  344. */
  345. async change(ctx) {
  346. try {
  347. const tender = ctx.tender.data;
  348. const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
  349. const times = change.status !== auditConst.flow.status.back ? change.times : change.times - 1;
  350. const auditList = await ctx.service.changeAudit.getListOrderByTimes(change.cid, times);
  351. const auditGroupList = await ctx.service.changeAudit.getListGroupByTimes(change.cid, times);
  352. const renderData = {
  353. tender,
  354. change,
  355. auditList,
  356. auditGroupList,
  357. auditConst: auditConst.flow,
  358. changeConst,
  359. tpUnit: ctx.tender.info.decimal.tp,
  360. };
  361. await ctx.render('wap/shenpi_change.ejs', renderData);
  362. } catch (err) {
  363. this.log(err);
  364. ctx.redirect('/wap/list');
  365. }
  366. }
  367. /**
  368. * 变更方案审批详细页
  369. *
  370. * @param {Object} ctx - egg全局变量
  371. * @return {void}
  372. */
  373. async changePlan(ctx) {
  374. try {
  375. const tender = ctx.tender.data;
  376. if (!ctx.session.sessionProject.page_show.openChangePlan) {
  377. throw '该功能已关闭';
  378. }
  379. const change = await ctx.service.changePlan.getDataById(ctx.params.cpid);
  380. const renderData = {
  381. tender,
  382. change,
  383. auditConst: auditConst.changePlan,
  384. changeConst,
  385. tpUnit: ctx.tender.info.decimal.tp,
  386. };
  387. const times = change.status !== auditConst.changePlan.status.checkNo ? change.times : change.times - 1;
  388. renderData.change.user = await ctx.service.projectAccount.getAccountInfoById(change.uid);
  389. renderData.change.auditors = await ctx.service.changePlanAudit.getAuditors(change.id, times);
  390. // 获取审批流程中左边列表
  391. renderData.change.auditors2 = await ctx.service.changePlanAudit.getAuditGroupByList(change.id, times);
  392. await ctx.render('wap/shenpi_change_plan.ejs', renderData);
  393. } catch (err) {
  394. this.log(err);
  395. ctx.redirect('/wap/list');
  396. }
  397. }
  398. /**
  399. * 修订审批详细页
  400. *
  401. * @param {Object} ctx - egg全局变量
  402. * @return {void}
  403. */
  404. async revise(ctx) {
  405. try {
  406. const tender = ctx.tender.data;
  407. const revise = await ctx.service.ledgerRevise.getDataByCondition({ id: ctx.params.rid });
  408. revise.user = await ctx.service.projectAccount.getAccountInfoById(revise.uid);
  409. const times = revise.status === auditConst.revise.status.checkNo ? revise.times - 1 : revise.times;
  410. revise.curAuditor = await ctx.service.reviseAudit.getAuditorByStatus(revise.id, revise.status, times);
  411. revise.auditors = await ctx.service.reviseAudit.getAuditors(revise.id, times);
  412. console.log(times, revise.auditors);
  413. const renderData = {
  414. tender,
  415. revise,
  416. auditConst: auditConst.revise,
  417. };
  418. await ctx.render('wap/shenpi_revise.ejs', renderData);
  419. } catch (err) {
  420. this.log(err);
  421. ctx.redirect('/wap/list');
  422. }
  423. }
  424. /**
  425. * 预付款列表页
  426. *
  427. * @param {Object} ctx - egg全局变量
  428. * @return {void}
  429. */
  430. async advance(ctx) {
  431. try {
  432. const tender = ctx.tender.data;
  433. const { decimal } = ctx.tender.info;
  434. this.decimal = decimal.pay ? decimal.payTp : decimal.tp;
  435. const advancePayTotalList = [];
  436. const advanceList = [];
  437. for (const t of advanceConst.typeCol) {
  438. const advancePayTotal = ctx.tender.info.deal_param[t.key + 'Advance'];
  439. advancePayTotalList.push(advancePayTotal);
  440. const advances = await ctx.service.advance.getAdvanceList(ctx.tender.id, t.type, this.decimal, advancePayTotal);
  441. advanceList.push(advances);
  442. }
  443. const renderData = {
  444. tender,
  445. advancePayTotalList,
  446. advanceList,
  447. auditConst: auditConst.advance,
  448. advanceConst,
  449. };
  450. await ctx.render('wap/shenpi_advance.ejs', renderData);
  451. } catch (err) {
  452. this.log(err);
  453. ctx.redirect('/wap/list');
  454. }
  455. }
  456. /**
  457. * 预付款详情页 GET
  458. * @param {Object} ctx 全局上下文
  459. */
  460. async advanceDetail(ctx) {
  461. try {
  462. const tender = ctx.tender.data;
  463. ctx.advance.advancePayTotal = ctx.tender.info.deal_param[ advanceConst.typeCol[ctx.advance.type].key + 'Advance'];
  464. const times = ctx.advance.status === auditConst.advance.status.checkNo ? ctx.advance.times - 1 : ctx.advance.times;
  465. if (ctx.advance.status === auditConst.advance.status.checkNo) {
  466. ctx.advance.curAuditor = await ctx.service.advanceAudit.getAuditorByStatus(ctx.advance.id, ctx.advance.status, times);
  467. ctx.advance.auditors = await ctx.service.advanceAudit.getAuditors(ctx.advance.id, times);
  468. }
  469. // 获取审批流程中左边列表
  470. ctx.advance.auditors2 = await ctx.service.advanceAudit.getAuditGroupByList(ctx.advance.id, times);
  471. const renderData = {
  472. tender,
  473. advance: ctx.advance,
  474. auditConst: auditConst.advance,
  475. advanceConst,
  476. };
  477. await ctx.render('wap/shenpi_advance_detail.ejs', renderData);
  478. } catch (error) {
  479. this.log(error);
  480. ctx.redirect('/wap/tender/' + ctx.tender.id + '/advance');
  481. }
  482. }
  483. /**
  484. * 变更令审批
  485. * @param {Object} ctx - egg全局变量
  486. * @return {void}
  487. */
  488. async changeApproval(ctx) {
  489. try {
  490. const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.change_id });
  491. if (!changeData) {
  492. throw '变更令数据错误';
  493. }
  494. const status = parseInt(ctx.request.body.status);
  495. const pid = this.ctx.session.sessionProject.id;
  496. let result = false;
  497. switch (status) {
  498. case 3:// 审批通过
  499. // 获取前一个人的list,生成bills_list
  500. // 获取已选清单
  501. const changeList = await ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: ctx.request.body.change_id } });
  502. const bills_array = [];
  503. for (const cl of changeList) {
  504. const bill = cl.id + '_' + cl.spamount;
  505. bills_array.push(bill);
  506. }
  507. const postData = ctx.request.body;
  508. postData.bills_list = bills_array.join(',');
  509. result = await ctx.service.change.approvalSuccess(pid, ctx.request.body, changeData);
  510. break;
  511. case 4:// 审批终止
  512. result = await ctx.service.change.approvalStop(ctx.request.body);
  513. break;
  514. case 5:// 审批退回到原报人
  515. result = await ctx.service.change.approvalBack(pid, ctx.request.body, changeData);
  516. break;
  517. case 6:// 审批退回到上一个审批人
  518. result = await ctx.service.change.approvalBackNew(pid, ctx.request.body, changeData);
  519. break;
  520. default:break;
  521. }
  522. if (!result) {
  523. throw '审批失败';
  524. }
  525. ctx.redirect(ctx.request.header.referer);
  526. } catch (err) {
  527. console.log(err);
  528. ctx.redirect(ctx.request.header.referer);
  529. }
  530. }
  531. /**
  532. * 收方单附件上传页
  533. * @param {Object} ctx - egg全局变量
  534. * @return {void}
  535. */
  536. async shoufangUpload(ctx) {
  537. try {
  538. const tid = parseInt(ctx.query.tid) || 0;
  539. const order = parseInt(ctx.query.order) || 0;
  540. const sfid = parseInt(ctx.query.sfid) || 0;
  541. if (!tid || !order || !sfid) {
  542. throw '参数有误';
  543. }
  544. const tender = await ctx.service.tender.getDataById(tid);
  545. if (!tender) {
  546. throw '该标段不存在';
  547. }
  548. const sfInfo = await ctx.service.stageShoufang.getDataByCondition({ id: sfid, tid, order });
  549. if (!sfInfo) {
  550. throw '该收方单不存在';
  551. }
  552. // 查找对应的台账或计量单元名称
  553. const ledger = await ctx.service.ledger.getData(tid);
  554. const ledgerInfo = ctx.helper._.find(ledger, { id: sfInfo.lid });
  555. let name = ledgerInfo.b_code;
  556. if (sfInfo.pid) {
  557. const pos = await ctx.service.pos.getPosData({ tid });
  558. const posInfo = ctx.helper._.find(pos, { lid: sfInfo.lid, id: sfInfo.pid });
  559. name += ' / ' + posInfo.name;
  560. }
  561. const renderData = {
  562. tender,
  563. order,
  564. name,
  565. sfid,
  566. whiteList: this.ctx.app.config.multipart.whitelist,
  567. };
  568. await ctx.render('wap/shoufangupload.ejs', renderData);
  569. } catch (error) {
  570. this.log(error);
  571. ctx.redirect('/wap/login');
  572. }
  573. }
  574. /**
  575. * 上传附件
  576. * @param {Object} ctx - egg全局变量
  577. * @return {void}
  578. */
  579. async shoufangUpFile(ctx) {
  580. const responseData = {
  581. err: 0,
  582. msg: '',
  583. data: [],
  584. };
  585. let stream;
  586. try {
  587. const parts = ctx.multipart({ autoFields: true });
  588. const files = [];
  589. let index = 0;
  590. while ((stream = await parts()) !== undefined) {
  591. // 判断是否存在
  592. const sfInfo = await ctx.service.stageShoufang.getDataById(parts.field.sfid);
  593. if (!sfInfo) {
  594. throw '该清单 / 计量单元下不存在收方单';
  595. }
  596. // 判断用户是否选择上传文件
  597. if (!stream.filename) {
  598. throw '请选择上传的文件!';
  599. }
  600. // const dirName = 'app/public/upload/stage/' + moment().format('YYYYMMDD');
  601. // 判断文件夹是否存在,不存在则直接创建文件夹
  602. // if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
  603. // await fs.mkdirSync(path.join(this.app.baseDir, dirName));
  604. // }
  605. const fileInfo = path.parse(stream.filename);
  606. const now_time = new Date();
  607. const create_time = Date.parse(now_time) / 1000;
  608. const filepath = `app/public/upload/${sfInfo.tid}/stage/shoufang/fujian_${create_time + index.toString() + fileInfo.ext}`;
  609. // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, filepath));
  610. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  611. // console.log(await fs.existsSync(path.resolve(this.app.baseDir, 'app', filepath)));
  612. // const fileInfo = path.parse(stream.filename);
  613. // const fileName = 'stage' + create_time + '_' + index + fileInfo.ext;
  614. // 保存文件
  615. // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, dirName, fileName));
  616. if (stream) {
  617. await sendToWormhole(stream);
  618. }
  619. // 保存数据到att表
  620. const fileData = {
  621. tid: sfInfo.tid,
  622. sid: sfInfo.sid,
  623. sfid: sfInfo.id,
  624. in_time: now_time,
  625. filename: fileInfo.name,
  626. fileext: fileInfo.ext,
  627. filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
  628. filepath,
  629. };
  630. // if (ctx.reUploadPermission) {
  631. // fileData.re_upload = 1;
  632. // }
  633. const result = await ctx.service.stageShoufangAtt.save(fileData);
  634. if (!result) {
  635. throw '导入数据库保存失败';
  636. }
  637. const attData = await ctx.service.stageShoufangAtt.getDataByFid(result.insertId);
  638. attData.in_time = moment(create_time * 1000).format('YYYY-MM-DD');
  639. files.length !== 0 ? files.unshift(attData) : files.push(attData);
  640. ++index;
  641. }
  642. responseData.data = files;
  643. } catch (err) {
  644. this.log(err);
  645. // 失败需要消耗掉stream 以防卡死
  646. if (stream) {
  647. await sendToWormhole(stream);
  648. }
  649. this.setMessage(err.toString(), this.messageType.ERROR);
  650. responseData.err = 1;
  651. responseData.msg = err.toString();
  652. }
  653. ctx.body = responseData;
  654. }
  655. /**
  656. * 删除附件
  657. * @param {Object} ctx - egg全局变量
  658. * @return {void}
  659. */
  660. async shoufangDeleteFile(ctx) {
  661. const responseData = {
  662. err: 0,
  663. msg: '',
  664. data: '',
  665. };
  666. try {
  667. const data = JSON.parse(ctx.request.body.data);
  668. const fileInfo = await ctx.service.stageShoufangAtt.getDataById(data.id);
  669. if (!fileInfo || !Object.keys(fileInfo).length) {
  670. throw '该文件不存在';
  671. }
  672. if (fileInfo !== undefined && fileInfo !== '') {
  673. // 先删除文件
  674. // await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
  675. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
  676. // 再删除数据库
  677. await ctx.service.stageShoufangAtt.deleteById(data.id);
  678. responseData.data = '';
  679. } else {
  680. throw '不存在该文件';
  681. }
  682. } catch (err) {
  683. responseData.err = 1;
  684. responseData.msg = err;
  685. }
  686. ctx.body = responseData;
  687. }
  688. /**
  689. * 编辑附件
  690. * @param {Object} ctx - egg全局变量
  691. * @return {void}
  692. */
  693. async shoufangEditFile(ctx) {
  694. const responseData = {
  695. err: 0,
  696. msg: '',
  697. data: '',
  698. };
  699. try {
  700. const data = JSON.parse(ctx.request.body.data);
  701. const fileInfo = await ctx.service.stageShoufangAtt.getDataById(data.id);
  702. if (!fileInfo || !Object.keys(fileInfo).length) {
  703. throw '该文件不存在';
  704. }
  705. await ctx.service.stageShoufangAtt.edit(data);
  706. } catch (err) {
  707. responseData.err = 1;
  708. responseData.msg = err;
  709. }
  710. ctx.body = responseData;
  711. }
  712. /**
  713. * 下载附件
  714. * @param {Object} ctx - egg全局变量
  715. * @return {void}
  716. */
  717. async shoufangDownloadFile(ctx) {
  718. const id = ctx.params.fid;
  719. if (id) {
  720. try {
  721. const fileInfo = await ctx.service.stageShoufangAtt.getDataById(id);
  722. if (fileInfo !== undefined && fileInfo !== '') {
  723. // const fileName = path.join(this.app.baseDir, fileInfo.filepath);
  724. // 解决中文无法下载问题
  725. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  726. let disposition = '';
  727. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  728. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename + fileInfo.fileext);
  729. } else if (userAgent.indexOf('firefox') >= 0) {
  730. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename + fileInfo.fileext) + '"';
  731. } else {
  732. /* safari等其他非主流浏览器只能自求多福了 */
  733. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename + fileInfo.fileext).toString('binary');
  734. }
  735. ctx.response.set({
  736. 'Content-Type': 'application/octet-stream',
  737. 'Content-Disposition': disposition,
  738. 'Content-Length': fileInfo.filesize,
  739. });
  740. // ctx.body = await fs.createReadStream(fileName);
  741. ctx.body = await ctx.helper.ossFileGet(fileInfo.filepath);
  742. } else {
  743. throw '不存在该文件';
  744. }
  745. } catch (err) {
  746. this.log(err);
  747. this.setMessage(err.toString(), this.messageType.ERROR);
  748. }
  749. }
  750. }
  751. }
  752. return WapController;
  753. };