material_controller.js 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author EllisRan
  6. * @date 2018/6/20
  7. * @version
  8. */
  9. const moment = require('moment');
  10. const auditConst = require('../const/audit').material;
  11. const auditStageConst = require('../const/audit').stage;
  12. const tenderConst = require('../const/tender');
  13. const measureType = tenderConst.measureType;
  14. const accountGroup = require('../const/account_group').group;
  15. const materialConst = require('../const/material');
  16. module.exports = app => {
  17. class MaterialController extends app.BaseController {
  18. /**
  19. * 构造函数
  20. *
  21. * @param {Object} ctx - egg全局变量
  22. * @return {void}
  23. */
  24. constructor(ctx) {
  25. super(ctx);
  26. ctx.showProject = true;
  27. ctx.showTender = true;
  28. ctx.showTitle = true;
  29. }
  30. /**
  31. * 期列表(Get)
  32. * @param ctx
  33. * @returns {Promise<void>}
  34. */
  35. async index(ctx) {
  36. try {
  37. const renderData = {
  38. tender: ctx.tender.data,
  39. tenderMenu: this.menu.tenderMenu,
  40. preUrl: '/tender/' + ctx.tender.id,
  41. auditConst,
  42. auditConst2: JSON.stringify(auditConst),
  43. };
  44. renderData.materials = await ctx.service.material.getValidMaterials(ctx.tender.id);
  45. // 获取未选中和已完成的计量期
  46. const stages = await ctx.service.stage.getAllDataByCondition({ where: { tid: ctx.tender.id, status: auditStageConst.status.checked } });
  47. for (const s of renderData.materials) {
  48. // s.curAuditor = null;
  49. // 根据期状态返回展示用户
  50. s.curAuditor = await ctx.service.materialAudit.getAuditorByStatus(s.id, s.status, s.times);
  51. const materialStageList = s.stage_id.split(',');
  52. for (const ms of materialStageList) {
  53. const index = stages.findIndex(function(item) {
  54. return item.id === parseInt(ms);
  55. });
  56. stages.splice(index, 1);
  57. }
  58. }
  59. renderData.stages = stages;
  60. await this.layout('material/index.ejs', renderData, 'material/modal.ejs');
  61. } catch (err) {
  62. this.log(err);
  63. ctx.redirect(this.menu.menu.dashboard.url);
  64. }
  65. }
  66. /**
  67. * 期审批流程(Get)
  68. * @param ctx
  69. * @returns {Promise<void>}
  70. */
  71. async materialAuditors(ctx) {
  72. try {
  73. const responseData = {
  74. err: 0, msg: '', data: {},
  75. };
  76. const order = JSON.parse(ctx.request.body.data).order;
  77. const tenderId = ctx.params.id;
  78. const materialInfo = await ctx.service.material.getDataByCondition({ tid: tenderId, order });
  79. // 获取审批流程中右边列表
  80. const auditHistory = [];
  81. const times = materialInfo.status === auditConst.status.checkNo ? materialInfo.times - 1 : materialInfo.times;
  82. if (times >= 1) {
  83. for (let i = 1; i <= times; i++) {
  84. auditHistory.push(await ctx.service.materialAudit.getAuditors(materialInfo.id, i));
  85. }
  86. }
  87. responseData.data.auditHistory = auditHistory;
  88. // 获取审批流程中左边列表
  89. responseData.data.auditors = await ctx.service.materialAudit.getAuditGroupByList(materialInfo.id, times);
  90. // 获取原报信息
  91. const materialAuditor = await ctx.service.projectAccount.getAccountInfoById(materialInfo.user_id);
  92. responseData.data.materialAuditor = materialAuditor;
  93. ctx.body = responseData;
  94. } catch (error) {
  95. this.log(error);
  96. ctx.body = { err: 1, msg: error.toString(), data: null };
  97. }
  98. }
  99. /**
  100. * 新增期(Post)
  101. * @param ctx
  102. * @returns {Promise<void>}
  103. */
  104. async add(ctx) {
  105. try {
  106. if (ctx.session.sessionUser.accountId !== ctx.tender.data.user_id) {
  107. throw '您无权创建材料调差期';
  108. }
  109. const data = ctx.request.body;
  110. if (data.s_order === '') {
  111. throw '没有选中计量期';
  112. }
  113. const newMaterial = await ctx.service.material.addMaterial(ctx.tender.id, data);
  114. if (!newMaterial) {
  115. throw '新增材料调差期失败,请重试';
  116. }
  117. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/' + newMaterial.order);
  118. } catch (err) {
  119. this.log(err);
  120. ctx.redirect(ctx.request.header.referer);
  121. }
  122. }
  123. /**
  124. * 删除期(Post)
  125. * @param ctx
  126. * @returns {Promise<void>}
  127. */
  128. async delete(ctx) {
  129. try {
  130. const material_id = ctx.request.body.material_id;
  131. const materialInfo = await ctx.service.material.getDataById(material_id);
  132. // 获取最新的期数
  133. const material_highOrder = await ctx.service.material.count({
  134. tid: ctx.tender.id,
  135. });
  136. if (materialInfo === undefined || ctx.session.sessionUser.accountId !== materialInfo.user_id || material_highOrder !== materialInfo.order) {
  137. throw '您无权删除材料调差期';
  138. }
  139. const result = await ctx.service.material.deleteMaterial(material_id);
  140. if (!result) {
  141. throw '删除材料调差期失败,请重试';
  142. }
  143. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/');
  144. } catch (err) {
  145. this.log(err);
  146. console.log(err);
  147. ctx.redirect(ctx.request.header.referer);
  148. }
  149. }
  150. /**
  151. * 获取通用的renderData(用于layout, Menu, subMenu部分)
  152. * @param ctx
  153. * @returns {{tender, tenderMenu, auditConst}}
  154. * @private
  155. */
  156. async _getDefaultRenderData(ctx) {
  157. const data = {
  158. tender: ctx.tender.data,
  159. tenderMenu: JSON.parse(JSON.stringify(this.menu.stageMenu)),
  160. auditConst,
  161. measureType,
  162. preUrl: '/tender/' + ctx.tender.id + '/measure/material/' + ctx.params.order,
  163. material: ctx.material,
  164. };
  165. if ((ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.material.user_id) {
  166. data.accountGroup = accountGroup;
  167. // 获取所有项目参与者
  168. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  169. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  170. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
  171. });
  172. data.accountList = accountList;
  173. }
  174. data.tenderMenu.back.children[0].url = '/tender/' + ctx.tender.id + '/measure/material';
  175. return data;
  176. }
  177. _materialReadOnly(material) {
  178. return material.status === auditConst.status.checked;
  179. }
  180. /**
  181. * 获取审批界面所需的 原报、审批人数据等
  182. * @param ctx
  183. * @returns {Promise<void>}
  184. * @private
  185. */
  186. async _getMaterialAuditViewData(ctx) {
  187. const times = ctx.material.status === auditConst.status.checkNo ? ctx.material.times - 1 : ctx.material.times;
  188. ctx.material.user = await ctx.service.projectAccount.getAccountInfoById(ctx.material.user_id);
  189. ctx.material.auditHistory = [];
  190. if (ctx.material.times > 1) {
  191. for (let i = 1; i < ctx.material.times; i++) {
  192. ctx.material.auditHistory.push(await ctx.service.materialAudit.getAuditors(ctx.material.id, i));
  193. }
  194. }
  195. // 获取审批流程中左边列表
  196. ctx.material.auditors2 = await ctx.service.materialAudit.getAuditGroupByList(ctx.material.id, times);
  197. if (ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) {
  198. ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  199. }
  200. }
  201. /**
  202. * 调差工料页面 (Get)
  203. * @param {Object} ctx - egg全局变量
  204. * @returns {Promise<void>}
  205. */
  206. async info(ctx) {
  207. try {
  208. await this._getMaterialAuditViewData(ctx);
  209. const renderData = await this._getDefaultRenderData(ctx);
  210. // 取所有工料表
  211. renderData.materialBillsData = await ctx.service.materialBills.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  212. // 取所有已被调用的工料清单表
  213. renderData.materialListData = await ctx.service.materialList.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  214. renderData.materialType = JSON.stringify(materialConst);
  215. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.info);
  216. await this.layout('material/info.ejs', renderData, 'material/info_modal.ejs');
  217. } catch (err) {
  218. this.log(err);
  219. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  220. }
  221. }
  222. /**
  223. * 调差清单页面 (Get)
  224. * @param {Object} ctx - egg全局变量
  225. * @returns {Promise<void>}
  226. */
  227. async list(ctx) {
  228. try {
  229. await this._getMaterialAuditViewData(ctx);
  230. const renderData = await this._getDefaultRenderData(ctx);
  231. // 取所有工料表
  232. renderData.materialBillsData = await ctx.service.materialBills.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  233. // 取所有已被调用的工料清单表
  234. renderData.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id);
  235. renderData.materialNotJoinListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
  236. renderData.materialType = JSON.stringify(materialConst);
  237. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.list);
  238. // 获取清单数据
  239. renderData.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  240. renderData.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  241. // 获取所选期数据并合并相加同类清单项
  242. renderData.curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, ctx.material.stage_id);
  243. renderData.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, ctx.material.stage_id);
  244. await this.layout('material/list.ejs', renderData, 'material/list_modal.ejs');
  245. } catch (err) {
  246. this.log(err);
  247. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  248. }
  249. }
  250. /**
  251. * 调差清单 - 工料操作 (Ajax)
  252. * @param ctx
  253. * @returns {Promise<void>}
  254. */
  255. async saveListsData(ctx) {
  256. try {
  257. const data = JSON.parse(ctx.request.body.data);
  258. const responseData = {
  259. err: 0,
  260. msg: '',
  261. data: {},
  262. };
  263. switch (data.type) {
  264. case 'add':
  265. responseData.data = await ctx.service.materialList.add(data.postData);
  266. break;
  267. case 'del':
  268. await ctx.service.materialList.del(data.id);
  269. break;
  270. case 'update':
  271. if (data.updateData.quantity === '' || data.updateData.quantity === null) {
  272. throw '请输入数量';
  273. }
  274. // 判断数量是否为数字
  275. if (isNaN(data.updateData.quantity)) {
  276. throw '不能输入其它非数字类型字符';
  277. }
  278. await ctx.service.materialList.save(data.updateData);
  279. break;
  280. case 'useOther':
  281. responseData.data = await ctx.service.materialList.addOther(data.postData);
  282. break;
  283. case 'join':
  284. await ctx.service.materialListNotjoin.del(data.select.id);
  285. break;
  286. case 'notjoin':
  287. responseData.data = await ctx.service.materialListNotjoin.add(data.select);
  288. break;
  289. default: throw '参数有误';
  290. }
  291. ctx.body = responseData;
  292. } catch (err) {
  293. this.log(err);
  294. ctx.body = { err: 1, msg: err.toString(), data: null };
  295. }
  296. }
  297. /**
  298. * 调差工料 - 编辑工料项 (Ajax)
  299. * @param ctx
  300. * @returns {Promise<void>}
  301. */
  302. async saveBillsData(ctx) {
  303. try {
  304. const data = JSON.parse(ctx.request.body.data);
  305. const responseData = {
  306. err: 0,
  307. msg: '',
  308. data: {},
  309. };
  310. switch (data.type) {
  311. case 'add':
  312. responseData.data = await ctx.service.materialBills.add();
  313. break;
  314. case 'del':
  315. await ctx.service.materialBills.del(data.id);
  316. break;
  317. case 'update':
  318. if (data.updateData.code === '' || data.updateData.code === null) {
  319. throw '请先输入编号';
  320. }
  321. // 判断编号为纯数字时,不能为小数
  322. if (!isNaN(data.updateData.code) && data.updateData.code.indexOf('.') !== -1) {
  323. throw '编号为纯数字时,不能为小数';
  324. }
  325. if (data.updateData.code.length > 15) {
  326. throw '长度不超过15个字符';
  327. }
  328. // 判断编号是否已存在
  329. const billData = await ctx.service.materialBills.getAllDataByCondition({ where: { mid: ctx.material.id, code: data.updateData.code } });
  330. if (billData.length > 1 || (billData.length > 0 && billData[0].id !== data.updateData.id)) {
  331. throw '该编号已存在,请重新输入。';
  332. }
  333. await ctx.service.materialBills.save(data.updateData);
  334. break;
  335. default: throw '参数有误';
  336. }
  337. ctx.body = responseData;
  338. } catch (err) {
  339. this.log(err);
  340. ctx.body = { err: 1, msg: err.toString(), data: null };
  341. }
  342. }
  343. // 审批相关
  344. /**
  345. * 添加审批人
  346. * @param ctx
  347. * @returns {Promise<void>}
  348. */
  349. async addAudit(ctx) {
  350. try {
  351. const data = JSON.parse(ctx.request.body.data);
  352. const id = this.app._.toInteger(data.auditorId);
  353. if (isNaN(id) || id <= 0) {
  354. throw '参数错误';
  355. }
  356. // 检查权限等
  357. if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
  358. throw '您无权添加审核人';
  359. }
  360. if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
  361. throw '当前不允许添加审核人';
  362. }
  363. ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  364. // 检查审核人是否已存在
  365. const exist = this.app._.find(ctx.material.auditorList, {aid: id});
  366. if (exist) {
  367. throw '该审核人已存在,请勿重复添加';
  368. }
  369. const result = await ctx.service.materialAudit.addAuditor(ctx.material.id, id, ctx.material.times);
  370. if (!result) {
  371. throw '添加审核人失败';
  372. }
  373. const audit = await ctx.service.materialAudit.getAuditor(ctx.material.id, id, ctx.material.times);
  374. ctx.body = {err: 0, msg: '', data: audit};
  375. } catch (err) {
  376. this.log(err);
  377. ctx.body = {err: 1, msg: err.toString(), data: null};
  378. }
  379. }
  380. /**
  381. * 移除审批人
  382. * @param ctx
  383. * @returns {Promise<void>}
  384. */
  385. async deleteAudit(ctx) {
  386. try {
  387. const data = JSON.parse(ctx.request.body.data);
  388. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  389. if (isNaN(id) || id <= 0) {
  390. throw '参数错误';
  391. }
  392. const result = await ctx.service.materialAudit.deleteAuditor(ctx.material.id, id, ctx.material.times);
  393. if (!result) {
  394. throw '移除审核人失败';
  395. }
  396. const auditors = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  397. ctx.body = {err: 0, msg: '', data: auditors};
  398. } catch (err) {
  399. ctx.body = {err: 1, msg: err.toString(), data: null};
  400. }
  401. }
  402. /**
  403. * 上报
  404. * @param ctx
  405. * @returns {Promise<void>}
  406. */
  407. async startAudit(ctx) {
  408. try {
  409. // 检查权限等
  410. if (!ctx.material) {
  411. throw '数据错误';
  412. }
  413. if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
  414. throw '您无权上报该期数据';
  415. }
  416. if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
  417. throw '该材料调差期数据当前无法上报';
  418. }
  419. await ctx.service.materialAudit.start(ctx.material.id, ctx.material.times);
  420. ctx.redirect(ctx.request.header.referer);
  421. } catch (err) {
  422. this.log(err);
  423. ctx.session.postError = err.toString();
  424. ctx.redirect(ctx.request.header.referer);
  425. }
  426. }
  427. /**
  428. * 审批
  429. * @param ctx
  430. * @returns {Promise<void>}
  431. */
  432. async checkAudit(ctx) {
  433. try {
  434. if (!this.ctx.material || this.ctx.material.status !== auditConst.status.checking) {
  435. throw '当前材料调差期数据有误';
  436. }
  437. if (!this.ctx.material.curAuditor || this.ctx.material.curAuditor.aid !== ctx.session.sessionUser.accountId) {
  438. throw '您无权进行该操作';
  439. }
  440. const data = {
  441. checkType: parseInt(ctx.request.body.checkType),
  442. opinion: ctx.request.body.opinion,
  443. };
  444. if (!data.checkType || isNaN(data.checkType)) {
  445. throw '提交数据错误';
  446. }
  447. if (data.checkType === auditConst.status.checkNo) {
  448. if (!data.checkType || isNaN(data.checkType)) {
  449. throw '提交数据错误';
  450. }
  451. }
  452. await ctx.service.materialAudit.check(ctx.material.id, data, ctx.material.times);
  453. ctx.redirect(ctx.request.header.referer);
  454. } catch (err) {
  455. console.log(err);
  456. this.log(err);
  457. ctx.session.postError = err.toString();
  458. ctx.redirect(ctx.request.header.referer);
  459. }
  460. }
  461. }
  462. return MaterialController;
  463. };