tender_controller.js 90 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789
  1. 'use strict';
  2. /**
  3. * 标段管理控制器
  4. *
  5. * @author CaiAoLin
  6. * @date 2018/2/5
  7. * @version
  8. */
  9. const tenderConst = require('../const/tender');
  10. const codeRuleConst = require('../const/code_rule');
  11. const settingConst = require('../const/setting.js');
  12. const tenderMenu = require('../../config/menu').tenderMenu;
  13. const auditConst = require('../const/audit');
  14. const shenpiConst = require('../const/shenpi');
  15. const accountGroup = require('../const/account_group').group;
  16. const accountPermission = require('../const/account_permission');
  17. const measureType = require('../const/tender').measureType;
  18. const billsPosConvert = require('../lib/bills_pos_convert');
  19. const path = require('path');
  20. const sendToWormhole = require('stream-wormhole');
  21. const scheduleConst = require('../const/schedule');
  22. const changeConst = require('../const/change');
  23. const tenderInfoModel = require('../lib/tender_info');
  24. const mapConst = require('../const/map');
  25. const advanceConst = require('../const/advance');
  26. const projectSetting = require('../const/project_setting');
  27. const profileConst = require('../const/profile');
  28. const materialConst = require('../const/material');
  29. module.exports = app => {
  30. class TenderController extends app.BaseController {
  31. /**
  32. * 构造函数
  33. *
  34. * @param {Object} ctx - egg全局变量
  35. * @return {void}
  36. */
  37. constructor(ctx) {
  38. super(ctx);
  39. ctx.showProject = true;
  40. ctx.showTitle = true;
  41. this.colSet = [];
  42. }
  43. async _listDetailCache(view, modal = '', type) {
  44. try {
  45. // 获取用户新建标段权利
  46. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  47. const userPermission = accountInfo !== undefined && accountInfo.permission !== ''
  48. ? JSON.parse(accountInfo.permission) : null;
  49. const tenderList = await this.ctx.service.tender.getBuildList('', userPermission, this.ctx.session.sessionUser.is_admin);
  50. for (const t of tenderList) {
  51. await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
  52. t.canFinish = await this.ctx.service.tender.checkTenderCanFinish(t);
  53. }
  54. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.subProject);
  55. const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  56. const subProject = await this.ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin, true);
  57. const renderData = {
  58. tenderList,
  59. tenderConst,
  60. settingConst,
  61. categoryData,
  62. measureType: tenderConst.measureType,
  63. jsFiles: this.app.jsFiles.common.concat(this.jsFiles),
  64. auditConst,
  65. userPermission,
  66. valuations,
  67. uid: this.ctx.session.sessionUser.accountId,
  68. pid: this.ctx.session.sessionProject.id,
  69. colSet: this.colSet,
  70. subProject,
  71. buildStatus: tenderConst.buildStatus,
  72. };
  73. renderData.selfCategoryLevel = this.ctx.subProject.permission.self_category_level; // await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
  74. renderData.is_finish = false;
  75. await this.layout(view, renderData, modal);
  76. } catch (err) {
  77. this.log(err);
  78. this.ctx.redirect('/dashboard');
  79. }
  80. }
  81. async _listDetailFinish(view, modal = '', type) {
  82. try {
  83. // 获取用户新建标段权利
  84. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  85. const userPermission = accountInfo !== undefined && accountInfo.permission !== ''
  86. ? JSON.parse(accountInfo.permission) : null;
  87. const tenderList = await this.ctx.service.tender.getFinishList('', userPermission, this.ctx.session.sessionUser.is_admin);
  88. for (const t of tenderList) {
  89. await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
  90. t.canFinish = await this.ctx.service.tender.checkTenderCanFinish(t);
  91. }
  92. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.subProject);
  93. const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  94. const subProject = await this.ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin, true);
  95. const renderData = {
  96. tenderList,
  97. tenderConst,
  98. settingConst,
  99. categoryData,
  100. measureType: tenderConst.measureType,
  101. jsFiles: this.app.jsFiles.common.concat(this.jsFiles),
  102. auditConst,
  103. userPermission,
  104. valuations,
  105. uid: this.ctx.session.sessionUser.accountId,
  106. pid: this.ctx.session.sessionProject.id,
  107. colSet: this.colSet,
  108. subProject,
  109. buildStatus: tenderConst.buildStatus,
  110. };
  111. renderData.selfCategoryLevel = this.ctx.subProject.permission.self_category_level; // await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
  112. renderData.is_finish = true;
  113. await this.layout(view, renderData, modal);
  114. } catch (err) {
  115. this.log(err);
  116. this.ctx.redirect('/dashboard');
  117. }
  118. }
  119. async _listCache(view, renderData, modal = '', list_status = '') {
  120. try {
  121. renderData.tenderList = await this.ctx.service.tender.getBuildList(list_status, renderData.userPermission, this.ctx.session.sessionUser.is_admin);
  122. for (const t of renderData.tenderList) {
  123. t.visitor = (await this.ctx.service.tenderTourist.getTourists(t.id)).map(x => { return x.user_name; });
  124. await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
  125. t.canFinish = await this.ctx.service.tender.checkTenderCanFinish(t);
  126. }
  127. renderData.categoryData = await this.ctx.service.category.getAllCategory(this.ctx.subProject);
  128. renderData.valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  129. renderData.tenderConst = tenderConst;
  130. renderData.settingConst = settingConst;
  131. renderData.measureType = tenderConst.measureType;
  132. renderData.jsFiles = this.app.jsFiles.common.concat(this.jsFiles);
  133. renderData.auditConst = auditConst;
  134. renderData.uid = this.ctx.session.sessionUser.accountId;
  135. renderData.pid = this.ctx.session.sessionProject.id;
  136. renderData.selfCategoryLevel = this.ctx.subProject.permission.self_category_level; // await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
  137. renderData.is_finish = false;
  138. renderData.colSet = this.colSet;
  139. renderData.buildStatus = tenderConst.buildStatus;
  140. renderData.subProject = await this.ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin, true);
  141. await this.layout(view, renderData, modal);
  142. } catch (err) {
  143. this.log(err);
  144. this.ctx.redirect('/dashboard');
  145. }
  146. }
  147. async _listFinish(view, renderData, modal = '', list_status = '') {
  148. try {
  149. renderData.tenderList = await this.ctx.service.tender.getFinishList(list_status, renderData.userPermission, this.ctx.session.sessionUser.is_admin);
  150. for (const t of renderData.tenderList) {
  151. t.visitor = (await this.ctx.service.tenderTourist.getTourists(t.id)).map(x => { return x.user_name; });
  152. await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
  153. t.canFinish = await this.ctx.service.tender.checkTenderCanFinish(t);
  154. }
  155. renderData.categoryData = await this.ctx.service.category.getAllCategory(this.ctx.subProject);
  156. renderData.valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  157. renderData.tenderConst = tenderConst;
  158. renderData.settingConst = settingConst;
  159. renderData.measureType = tenderConst.measureType;
  160. renderData.jsFiles = this.app.jsFiles.common.concat(this.jsFiles);
  161. renderData.auditConst = auditConst;
  162. renderData.uid = this.ctx.session.sessionUser.accountId;
  163. renderData.pid = this.ctx.session.sessionProject.id;
  164. renderData.selfCategoryLevel = this.ctx.subProject.permission.self_category_level; // await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
  165. renderData.is_finish = true;
  166. renderData.colSet = this.colSet;
  167. renderData.buildStatus = tenderConst.buildStatus;
  168. renderData.subProject = await this.ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin, true);
  169. await this.layout(view, renderData, modal);
  170. } catch (err) {
  171. this.log(err);
  172. this.ctx.redirect('/dashboard');
  173. }
  174. }
  175. async listDefault(ctx) {
  176. this.jsFiles = this.app.jsFiles.tender.list;
  177. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  178. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  179. const renderData = {
  180. accountInfo,
  181. userPermission,
  182. colSet: this.colSet,
  183. };
  184. await this._listCache('tender/index.ejs', renderData, 'tender/modal.ejs');
  185. }
  186. /**
  187. * 标段概况(Get)
  188. *
  189. * @param {object} ctx - egg全局变量
  190. * @return {void}
  191. */
  192. async listInfo(ctx) {
  193. this.jsFiles = this.app.jsFiles.tender.info;
  194. // const projectColSet = await ctx.service.projectColSet.getProjectColSet(ctx.subProject.project_id, ctx.subProject.id);
  195. const projectColSet = await ctx.service.projectColSet.getProjectColSet(ctx.subProject.project_id);
  196. this.colSet = ctx.service.projectColSet.analysisColSetWithDefine(projectSetting.colSet.info, projectColSet.info, projectSetting.defaultColSet.info);
  197. await this._listDetailCache('tender/info.ejs', 'tender/modal.ejs');
  198. }
  199. /**
  200. * 计量进度(Get)
  201. *
  202. * @param ctx
  203. * @return {Promise<void>}
  204. */
  205. async listProgress(ctx) {
  206. this.jsFiles = this.app.jsFiles.tender.progress;
  207. await this._listDetailCache('tender/progress.ejs', 'tender/modal.ejs');
  208. }
  209. /**
  210. * 标段管理(Get)
  211. *
  212. * @param ctx
  213. * @return {Promise<void>}
  214. */
  215. async listManage(ctx) {
  216. this.jsFiles = this.app.jsFiles.tender.manage;
  217. // 先判断权限
  218. // 获取用户新建标段权利
  219. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  220. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  221. if (userPermission !== null && userPermission.tender !== undefined && userPermission.tender.indexOf('1') !== -1) {
  222. const renderData = {
  223. accountInfo,
  224. userPermission,
  225. };
  226. await this._listCache('tender/manage.ejs', renderData, 'tender/manage_modal.ejs', 'manage');
  227. } else {
  228. this.ctx.redirect(ctx.request.header.referer);
  229. }
  230. }
  231. async listDefaultFinish(ctx) {
  232. this.jsFiles = this.app.jsFiles.tender.list;
  233. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  234. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  235. const renderData = {
  236. accountInfo,
  237. userPermission,
  238. };
  239. await this._listFinish('tender/index.ejs', renderData, 'tender/modal.ejs');
  240. }
  241. async listInfoFinish(ctx) {
  242. this.jsFiles = this.app.jsFiles.tender.info;
  243. // const projectColSet = await ctx.service.projectColSet.getProjectColSet(ctx.subProject.project_id, ctx.subProject.id);
  244. const projectColSet = await ctx.service.projectColSet.getProjectColSet(ctx.subProject.project_id);
  245. this.colSet = ctx.service.projectColSet.analysisColSetWithDefine(projectSetting.colSet.info, projectColSet.info, projectSetting.defaultColSet.info);
  246. await this._listDetailFinish('tender/info.ejs', 'tender/modal.ejs');
  247. }
  248. /**
  249. * 标段管理(Get)
  250. *
  251. * @param ctx
  252. * @return {Promise<void>}
  253. */
  254. async listManageFinish(ctx) {
  255. this.jsFiles = this.app.jsFiles.tender.manage;
  256. // 先判断权限
  257. // 获取用户新建标段权利
  258. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  259. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  260. if (userPermission !== null && userPermission.tender !== undefined && userPermission.tender.indexOf('1') !== -1) {
  261. const renderData = {
  262. accountInfo,
  263. userPermission,
  264. };
  265. await this._listFinish('tender/manage.ejs', renderData, 'tender/manage_modal.ejs', 'manage');
  266. } else {
  267. this.ctx.redirect(ctx.request.header.referer);
  268. }
  269. }
  270. /**
  271. * 新增标段(Ajax)
  272. *
  273. * @param ctx
  274. * @return {Promise<void>}
  275. */
  276. async addTender(ctx) {
  277. try {
  278. const responseData = {
  279. err: 0, msg: '', data: null,
  280. };
  281. // 获取用户新建标段权利
  282. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  283. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  284. if (userPermission === null || userPermission.tender === undefined || userPermission.tender.indexOf('1') === -1) {
  285. throw '当前用户没有创建标段的权限';
  286. }
  287. const data = JSON.parse(ctx.request.body.data);
  288. if (!data.name || data.name === '' || !data.valuation) {
  289. throw '标段信息不完整';
  290. }
  291. responseData.data = await ctx.service.tender.add(data);
  292. ctx.body = responseData;
  293. } catch (error) {
  294. this.log(error);
  295. ctx.body = { err: 1, msg: error.toString(), data: null };
  296. }
  297. }
  298. /**
  299. * 编辑标段(Ajax)
  300. *
  301. * @param ctx
  302. * @return {Promise<void>}
  303. */
  304. async updateTender(ctx) {
  305. try {
  306. const responseData = {
  307. err: 0, msg: '', data: null,
  308. };
  309. const data = JSON.parse(ctx.request.body.data);
  310. if (!data.id) {
  311. throw '提交信息错误';
  312. }
  313. if (!data.name || data.name === '') {
  314. throw '标段信息不完整';
  315. }
  316. if (await ctx.service.tender.save(data, data.id)) {
  317. responseData.data = await ctx.service.tender.getTender(data.id);
  318. }
  319. ctx.body = responseData;
  320. } catch (error) {
  321. this.log(error);
  322. ctx.body = { err: 1, msg: error.toString(), data: null };
  323. }
  324. }
  325. async batchUpdate(ctx) {
  326. try {
  327. const data = JSON.parse(ctx.request.body.data);
  328. const result = await ctx.service.tender.batchUpdate(data);
  329. ctx.body = { err: 0, msg: '', data: result };
  330. } catch(err) {
  331. ctx.log(err);
  332. ctx.ajaxErrorBody(err, '保存失败');
  333. }
  334. }
  335. /**
  336. * 删除标段(Ajax)
  337. *
  338. * @param ctx
  339. * @return {Promise<void>}
  340. */
  341. async deleteTender(ctx) {
  342. try {
  343. const data = JSON.parse(ctx.request.body.data),
  344. result = [];
  345. if (!(data instanceof Array) && (data.length === 0)) {
  346. throw '提交数据有误';
  347. }
  348. for (const id of data) {
  349. if (await ctx.service.tender.deleteTenderNoBackup(id)) {
  350. result.push(id);
  351. }
  352. }
  353. ctx.body = { err: 0, msg: '', data: result };
  354. } catch (err) {
  355. ctx.body = { err: 1, msg: err.toString(), data: [] };
  356. }
  357. }
  358. /**
  359. * 标段概况(Get)
  360. *
  361. * @param ctx
  362. * @return {Promise<void>}
  363. */
  364. async tenderInfo(ctx) {
  365. try {
  366. const tender = ctx.tender.data;
  367. let bCalcTp = tender.user_id === this.ctx.session.sessionUser.accountId && (
  368. tender.ledger_status === auditConst.ledger.status.checkNo || tender.ledger_status === auditConst.ledger.status.uncheck);
  369. const stages = await ctx.service.stage.getValidStages(ctx.tender.id);
  370. const lastStage = stages.length > 0 ? stages[0] : null; // await ctx.service.stage.getLastestStage(ctx.tender.id);
  371. const [change_tp, change_p_tp, change_n_tp, change_valuation_tp, change_unvaluation_tp] = await ctx.service.change.getChangeTp(tender.id);
  372. tender.change_tp = change_tp;
  373. tender.change_p_tp = change_p_tp;
  374. tender.change_n_tp = change_n_tp;
  375. tender.change_valuation_tp = change_valuation_tp;
  376. tender.change_unvaluation_tp = change_unvaluation_tp;
  377. if (lastStage) {
  378. await this.ctx.service.stage.checkStageGatherData(lastStage, this.ctx.session.sessionUser.is_admin);
  379. if ((!bCalcTp) && tender.measure_type === measureType.gcl.value) {
  380. bCalcTp = lastStage.status !== auditConst.stage.status.checked && !lastStage.readOnly;
  381. }
  382. if (bCalcTp) {
  383. const sum = await this.ctx.service.ledger.addUp({ tender_id: tender.id/* , is_leaf: true*/ });
  384. tender.total_price = sum.total_price;
  385. tender.deal_tp = sum.deal_tp;
  386. }
  387. tender.sum = ctx.tender.info.calc_type === 'tp' ? ctx.helper.add(tender.total_price, tender.change_valuation_tp) : ctx.helper.add(tender.total_price, tender.change_tp);
  388. tender.gather_tp = ctx.helper.sum([lastStage.contract_tp, lastStage.qc_tp, lastStage.pc_tp]);
  389. tender.end_contract_tp = ctx.helper.sum([lastStage.contract_tp, lastStage.pre_contract_tp, lastStage.contract_pc_tp]);
  390. tender.end_qc_tp = ctx.helper.sum([lastStage.qc_tp, lastStage.pre_qc_tp, lastStage.qc_pc_tp]);
  391. tender.end_positive_qc_tp = ctx.helper.sum([lastStage.positive_qc_tp, lastStage.pre_positive_qc_tp, lastStage.positive_qc_pc_tp]);
  392. tender.end_negative_qc_tp = ctx.helper.sum([lastStage.negative_qc_tp, lastStage.pre_negative_qc_tp, lastStage.negative_qc_pc_tp]);
  393. tender.end_gather_tp = ctx.helper.add(tender.end_contract_tp, tender.end_qc_tp);
  394. tender.pre_gather_tp = ctx.helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
  395. tender.yf_tp = lastStage.yf_tp;
  396. tender.sf_tp = lastStage.sf_tp;
  397. tender.qc_ratio = ctx.helper.mul(ctx.helper.div(tender.end_qc_tp, ctx.tender.info.deal_param.contractPrice, 2), 100);
  398. tender.pre_ratio = ctx.helper.mul(ctx.helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
  399. tender.cur_ratio = ctx.helper.mul(ctx.helper.div(tender.gather_tp, tender.sum, 2), 100);
  400. tender.other_tp = ctx.helper.sub(ctx.helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
  401. tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
  402. tender.end_yf_tp = ctx.helper.add(lastStage.yf_tp, lastStage.pre_yf_tp);
  403. tender.end_sf_tp = ctx.helper.add(lastStage.sf_tp, lastStage.pre_sf_tp);
  404. tender.undone_tp = ctx.helper.sub(ctx.helper.sub(ctx.helper.add(tender.total_price, change_tp), tender.end_contract_tp), tender.end_qc_tp);
  405. if (lastStage.status === auditConst.stage.status.uncheck) {
  406. const status_name = await this.ctx.service.projectAccount.getAccountInfoById(lastStage.user_id);
  407. lastStage.status_users = status_name ? status_name.name : '';
  408. lastStage.auditors = [];
  409. } else {
  410. lastStage.status = lastStage.status === auditConst.stage.status.checkNoPre ? auditConst.stage.status.checking : lastStage.status;
  411. let cur;
  412. if (lastStage.status === auditConst.stage.status.checked) {
  413. cur = await this.ctx.service.stageAudit.getLastestAuditors(lastStage.id, lastStage.times, auditConst.stage.status.checked);
  414. } else if (lastStage.status === auditConst.stage.status.checking) {
  415. cur = await this.ctx.service.stageAudit.getCurAuditors(lastStage.id, lastStage.times);
  416. } else {
  417. cur = await this.ctx.service.stageAudit.getAuditorsByStatus(lastStage.id, lastStage.status, lastStage.times);
  418. }
  419. // const status_name = await this.ctx.service.stageAudit.getAuditorByStatus(lastStage.id, lastStage.status, lastStage.times);
  420. lastStage.status_users = cur.length > 0 ? (cur[0].audit_type === auditConst.auditType.key.common ? cur[0].name : ctx.helper.transFormToChinese(cur[0].audit_order) + '审') : '';
  421. const times = lastStage.status === auditConst.stage.status.checkNo ? lastStage.times - 1 : lastStage.times;
  422. const history = await ctx.service.stageAudit.getAuditorHistory(lastStage.id, times);
  423. lastStage.auditors = history[history.length - 1];
  424. }
  425. } else {
  426. if (bCalcTp) {
  427. const sum = await this.ctx.service.ledger.addUp({ tender_id: tender.id/* , is_leaf: true*/ });
  428. tender.total_price = sum.total_price;
  429. tender.deal_tp = sum.deal_tp;
  430. }
  431. tender.sum = ctx.helper.add(tender.total_price, tender.change_tp);
  432. if (tender.ledger_status !== auditConst.ledger.status.uncheck) {
  433. let cur;
  434. if (tender.ledger_status === auditConst.ledger.status.checked) {
  435. cur = await this.ctx.service.ledgerAudit.getLastestAuditors(tender.id, tender.ledger_times, auditConst.ledger.status.checked);
  436. } else if (tender.ledger_status === auditConst.ledger.status.checking) {
  437. cur = await this.ctx.service.ledgerAudit.getCurAuditors(tender.id, tender.ledger_times);
  438. } else {
  439. cur = await this.ctx.service.ledgerAudit.getAuditorsByStatus(tender.id, tender.ledger_status, tender.ledger_times);
  440. }
  441. // const status_name = await this.ctx.service.ledgerAudit.getStatusName(tender.id, tender.ledger_times);
  442. // tender.status_users = status_name ? status_name.name : '';
  443. tender.status_users = cur.length > 0 ? (cur[0].audit_type === auditConst.auditType.key.common ? cur[0].name : ctx.helper.transFormToChinese(cur[0].audit_order) + '审') : '';
  444. const times = tender.ledger_status === auditConst.ledger.status.checkNo ? tender.ledger_times - 1 : tender.ledger_times;
  445. const history = await ctx.service.ledgerAudit.getAuditorHistory(tender.id, times);
  446. tender.auditors = history[history.length - 1];
  447. } else {
  448. const status_name = await this.ctx.service.projectAccount.getAccountInfoById(tender.user_id);
  449. tender.status_users = status_name ? status_name.name : '';
  450. }
  451. }
  452. const tiModel = new tenderInfoModel(ctx);
  453. const gclChapter = await tiModel.gatherChapter();
  454. const monthProgress = [];
  455. for (const s of stages) {
  456. if (s.s_time) {
  457. let progress = monthProgress.find(function(x) {
  458. return x.month === s.s_time;
  459. });
  460. if (!progress) {
  461. progress = { month: s.s_time };
  462. monthProgress.push(progress);
  463. }
  464. progress.tp = ctx.helper.add(ctx.helper.add(progress.tp, s.contract_tp), s.qc_tp);
  465. }
  466. }
  467. monthProgress.sort(function(x, y) {
  468. return Date.parse(x.month) - Date.parse(y.month);
  469. });
  470. let sum = 0;
  471. for (const p of monthProgress) {
  472. p.ratio = ctx.helper.mul(ctx.helper.div(p.tp, tender.sum, 4), 100);
  473. sum = ctx.helper.add(sum, p.tp);
  474. p.end_tp = sum;
  475. p.end_ratio = ctx.helper.mul(ctx.helper.div(p.end_tp, tender.sum, 4), 100);
  476. }
  477. const revise = await ctx.service.ledgerRevise.getLastestRevise(tender.id);
  478. // const tenders = await ctx.service.tender.getList('', null, 1);
  479. const tenders = await ctx.service.tender.getList('manage');
  480. const categoryData = await ctx.service.category.getAllCategory(ctx.subProject);
  481. // 变更图表数据
  482. const change_done_total = await ctx.service.change.getCountByStatus2(tender.id, auditConst.filter.status.checked);
  483. const change_doing_total = await ctx.service.change.getCountByStatus2(tender.id, auditConst.filter.status.checking);
  484. const change_uncheck_total = await ctx.service.change.getCountByStatus2(tender.id, auditConst.filter.status.uncheck);
  485. const change_status_total = [
  486. { num: change_uncheck_total, name: '待上报' },
  487. { num: change_doing_total, name: '审批中' },
  488. { num: change_done_total, name: '已完成' },
  489. ];
  490. const change_common_total = await ctx.service.change.getCountByQuality(tender.id, changeConst.quality.common.value);
  491. const change_more_total = await ctx.service.change.getCountByQuality(tender.id, changeConst.quality.more.value);
  492. const change_great_total = await ctx.service.change.getCountByQuality(tender.id, changeConst.quality.great.value);
  493. const change_quality_total = [
  494. { num: change_common_total, name: '一般变更' },
  495. { num: change_more_total, name: '较大变更' },
  496. { num: change_great_total, name: '重大变更' },
  497. ];
  498. // 调差最新期数据
  499. const materials = await ctx.service.material.getValidMaterials(ctx.tender.id);
  500. let materialData = null;
  501. let openMaterialTax = ctx.subProject.page_show.openMaterialTax;
  502. let allMaterialTax = true;
  503. if (materials && materials.length > 0) {
  504. materialData = materials[0];
  505. // materialData.curAuditor = await ctx.service.materialAudit.getAuditorByStatus(materialData.id, materialData.status, materialData.times);
  506. // const times = materialData.status === auditConst.material.status.checkNo ? materialData.times - 1 : materialData.times;
  507. // materialData.auditors = materialData.status === auditConst.material.status.uncheck ? [] : await ctx.service.materialAudit.getFinalAuditGroup(materialData.id, times);
  508. for (const s of materials) {
  509. if (allMaterialTax && s.material_tax === 0) {
  510. allMaterialTax = false;
  511. }
  512. if (!openMaterialTax && s.material_tax === 1) {
  513. openMaterialTax = 1;
  514. }
  515. }
  516. materialData.decimal = materialData.decimal ? JSON.parse(materialData.decimal) : materialConst.decimal;
  517. materialData.status = materialData.status === auditConst.material.status.checkNoPre ? auditConst.material.status.checking : materialData.status;
  518. const times = materialData.status === auditConst.material.status.checkNo ? materialData.times - 1 : materialData.times;
  519. let cur;
  520. if (materialData.status === auditConst.material.status.checked) {
  521. cur = await this.ctx.service.materialAudit.getLastestAuditors(materialData.id, materialData.times, auditConst.material.status.checked);
  522. } else if (materialData.status === auditConst.material.status.checking) {
  523. cur = await this.ctx.service.materialAudit.getCurAuditors(materialData.id, materialData.times);
  524. } else {
  525. cur = await this.ctx.service.materialAudit.getAuditorsByStatus(materialData.id, materialData.status, materialData.times);
  526. }
  527. // const status_name = await this.ctx.service.stageAudit.getAuditorByStatus(lastStage.id, lastStage.status, lastStage.times);
  528. materialData.status_users = cur.length > 0 ? (cur[0].audit_type === auditConst.auditType.key.common ? cur[0].name : ctx.helper.transFormToChinese(cur[0].audit_order) + '审') : '';
  529. const history = await ctx.service.materialAudit.getAuditorHistory(materialData.id, times);
  530. materialData.auditors = history[history.length - 1];
  531. }
  532. // 修订完成数目
  533. // const reviseNum = await ctx.service.ledgerRevise.count({ tid: tender.id, status: auditConst.revise.status.checked });
  534. // 计量完成概况
  535. // tender.total_price
  536. const stage_total = [
  537. { num: tender.end_contract_tp ? tender.end_contract_tp : 0, name: '合同完成' },
  538. { num: tender.end_qc_tp ? tender.end_qc_tp : 0, name: '变更完成' },
  539. { num: tender.undone_tp ? tender.undone_tp : 0, name: '未完成' },
  540. ];
  541. // 地图
  542. const tenderALLInfo = await ctx.service.tender.getDataById(tender.id);
  543. const hadMap = tenderALLInfo.had_map === 0 ? 3 : tenderALLInfo.had_map;// 0为初始值,因为默认可能会变化,所以暂时把0都默认为1。共三种模式坐标模式1,图片模式2,无图模式3。
  544. // const tenderMapList = await ctx.service.tenderMap.getAllDataByCondition({ where: { tid: tender.id } });
  545. const tenderMapList = [];
  546. // 默认坐标,否则则取办事处坐标
  547. // const projectData = await ctx.service.project.getDataById(ctx.session.sessionProject.id);
  548. // let map_json = {
  549. // province: mapConst.map[0].province,
  550. // lng: mapConst.map[0].lng,
  551. // lat: mapConst.map[0].lat,
  552. // level: 15,
  553. // };
  554. // if (projectData.map_json) {
  555. // map_json = JSON.parse(projectData.map_json);
  556. // } else {
  557. // const mapInfo = ctx.helper._.find(mapConst.map, { office: projectData.manager_office });
  558. // if (mapInfo) {
  559. // map_json.province = mapInfo.province;
  560. // map_json.lng = mapInfo.lng;
  561. // map_json.lat = mapInfo.lat;
  562. // }
  563. // }
  564. const canFinish = await this.ctx.service.tender.checkTenderCanFinish(tender);
  565. const projectSpread = await ctx.service.projectSpread.getProjectSpreadType(tender.project_id);
  566. const renderData = {
  567. tenders,
  568. categoryData,
  569. tender,
  570. revise,
  571. tenderInfo: ctx.tender.info,
  572. tenderMenu: this.menu.tenderMenu,
  573. preUrl: '/tender/' + ctx.tender.id,
  574. cooperation: ctx.session.sessionUser.cooperation,
  575. lastStage,
  576. stages: stages.reverse(),
  577. monthProgress,
  578. audit: auditConst,
  579. change_status_total,
  580. change_quality_total,
  581. materialData,
  582. openMaterialTax,
  583. allMaterialTax,
  584. // reviseNum,
  585. stage_total,
  586. hadMap,
  587. map_pic: tenderALLInfo.map_pic,
  588. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.tenderInfo),
  589. gclChapter,
  590. tenderMapList,
  591. // map_json,
  592. fujianOssPath: ctx.app.config.fujianOssPath,
  593. canFinish,
  594. buildStatus: tenderConst.buildStatus,
  595. projectSpread,
  596. };
  597. if (ctx.session.sessionUser.is_admin) {
  598. renderData.tourists = await ctx.service.tenderTourist.getTourists(tender.id);
  599. for (const t of renderData.tourists) {
  600. t.permission = await ctx.service.tenderTourist.getTouristPermission(t);
  601. }
  602. // 获取所有项目参与者
  603. const accountList = await ctx.service.projectAccount.getAllSubProjectAccount(ctx.subProject);
  604. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  605. const accountGroupList = unitList.map(item => {
  606. const groupList = accountList.filter(item1 => item1.company === item.name);
  607. return { groupName: item.name, groupList };
  608. }).filter(x => { return x.groupList.length > 0; });
  609. renderData.accountList = accountList;
  610. renderData.accountGroup = accountGroupList;
  611. }
  612. await this.layout('tender/detail.ejs', renderData, 'tender/detail_modal.ejs');
  613. } catch (error) {
  614. this.log(error);
  615. ctx.redirect(`/sp/${ctx.subProject.id}/list`);
  616. }
  617. }
  618. /**
  619. * 保存标段属性等(Ajax)
  620. *
  621. * @param ctx
  622. * @return {Promise<void>}
  623. */
  624. async saveTenderInfo(ctx) {
  625. try {
  626. const data = JSON.parse(ctx.request.body.data);
  627. if (!data) {
  628. throw '提交数据错误';
  629. }
  630. // 针对查阅所有标段者但非原报和审批人提示
  631. const times = ctx.tender.data.ledger_status === auditConst.ledger.status.checkNo ? ctx.tender.data.ledger_times - 1 : ctx.tender.data.ledger_times;
  632. const auditors = await this.service.ledgerAudit.getAuditors(ctx.tender.id, times);
  633. const auditorsId = ctx.helper._.map(auditors, 'audit_id');
  634. const stageAuditors = await this.service.stageAudit.getAllAuditors(ctx.tender.id);
  635. const stageAUditorsId = ctx.helper._.map(stageAuditors, 'aid');
  636. const accountId = ctx.session.sessionUser.accountId;
  637. if (auditorsId.indexOf(accountId) === -1 && ctx.tender.data.user_id !== accountId &&
  638. stageAUditorsId.indexOf(accountId) === -1 && !ctx.session.sessionUser.is_admin) {
  639. throw '您无权修改标段设置内容';
  640. }
  641. if (ctx.tender.data.ledger_status === auditConst.ledger.status.checked) {
  642. if (data.deal_param && !ctx.session.sessionUser.is_admin) {
  643. const lastStage = await this.ctx.service.stage.getLastestStage(ctx.tender.id, true);
  644. if (lastStage) {
  645. if (lastStage.order > 1 || (lastStage.status === auditConst.stage.status.checked || lastStage.status === auditConst.stage.status.checking)) throw '第一期上报后不可修改合同参数';
  646. if (lastStage.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改合同参数';
  647. }
  648. }
  649. }
  650. if (data.decimal) {
  651. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改小数位数';
  652. await ctx.service.tenderInfo.saveDecimal(ctx.tender.id, data.decimal, ctx.tender.info.decimal);
  653. } else if (data.precision) {
  654. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改清单精度';
  655. await ctx.service.tenderInfo.savePrecision(ctx.tender.id,
  656. data.precision, ctx.tender.info.precision, ctx.tender.info.decimal);
  657. } else {
  658. await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, data);
  659. if (data.deal_param) ctx.service.tenderCache.updateContractPriceCache(ctx.tender);
  660. }
  661. ctx.body = { err: 0, msg: '', data: JSON.parse(ctx.request.body.data) };
  662. } catch (err) {
  663. this.log(err);
  664. ctx.body = this.ajaxErrorBody(err, '保存标段设置失败');
  665. }
  666. }
  667. async saveTenderInfo2(ctx) {
  668. try {
  669. const data = JSON.parse(ctx.request.body.data);
  670. if (!data || (!data.ledger_check && !data.fun_rela && !data.s_type && !data.calc_type && !data.over_range_check)) throw '提交数据错误';
  671. if (!ctx.session.sessionUser.is_admin) throw '您无权修改该内容';
  672. if (data.ledger_check || data.fun_rela || data.s_type || data.over_range_check) {
  673. const updateData = {};
  674. if (data.ledger_check) updateData.ledger_check = data.ledger_check;
  675. if (data.fun_rela) updateData.fun_rela = data.fun_rela;
  676. if (data.over_range_check) updateData.over_range_check = data.over_range_check;
  677. if (data.s_type) updateData.s_type = data.s_type;
  678. await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, updateData);
  679. }
  680. if (data.calc_type !== undefined) await ctx.service.tenderInfo.saveCalcType(ctx.tender.id, data.calc_type);
  681. ctx.body = { err: 0, msg: '', data: JSON.parse(ctx.request.body.data) };
  682. } catch (err) {
  683. this.log(err);
  684. ctx.body = this.ajaxErrorBody(err, '保存失败');
  685. }
  686. }
  687. async saveBuildStatus(ctx) {
  688. try {
  689. const status = parseInt(ctx.query.status || ctx.request.body.status);
  690. await ctx.service.tender.saveBuildStatus(ctx.tender.data, status);
  691. } catch (err) {
  692. this.log(err);
  693. this.postError(err, '修改在建状态失败');
  694. }
  695. ctx.redirect(ctx.request.header.referer);
  696. }
  697. /**
  698. * 设置标段计量类型并调整到标段概况(Get)
  699. *
  700. * @param ctx
  701. * @return {Promise<void>}
  702. */
  703. async tenderType(ctx) {
  704. try {
  705. const tenderId = ctx.params.id,
  706. type = ctx.query.type;
  707. if (!tenderId) {
  708. throw '当前未打开标段';
  709. }
  710. await ctx.service.tender.checkTender(tenderId);
  711. if (!ctx.tender) {
  712. throw '标段数据错误';
  713. }
  714. if (!ctx.tender.measure_type) {
  715. await ctx.service.tender.setTenderType(ctx.tender, parseInt(type));
  716. }
  717. ctx.redirect('/tender/' + tenderId);
  718. } catch (error) {
  719. ctx.helper.log(error);
  720. this.postError(error, '设置标段类型错误');
  721. ctx.redirect(`/sp/${ctx.subProject.id}/list`);
  722. }
  723. }
  724. /**
  725. * 标段协作办公
  726. *
  727. * @param {Object} ctx - egg全局变量
  728. * @return {void}
  729. */
  730. async tenderCooperation(ctx) {
  731. const tenderId = ctx.params.id;
  732. try {
  733. if (!ctx.session.sessionUser.cooperation) {
  734. throw '权限不足';
  735. }
  736. const tender = await ctx.service.tender.getDataById(tenderId);
  737. const user = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  738. // 获取已参与协作用户列表
  739. const cooperationArray = [];
  740. if (tender.cooperation !== null && tender.cooperation !== '') {
  741. const cooperationList = JSON.parse(tender.cooperation);
  742. for (const cl in cooperationList) {
  743. const clArray = [];
  744. for (const audit of cooperationList[cl]) {
  745. const userInfo = await ctx.service.projectAccount.getDataById(audit);
  746. clArray.push(userInfo);
  747. }
  748. cooperationArray[cl] = clArray;
  749. }
  750. }
  751. const renderData = {
  752. user,
  753. tender,
  754. tenderMenu: this.menu.tenderMenu,
  755. preUrl: '/tender/' + tenderId,
  756. tenderPermissionList: accountPermission.tenderPermissionList,
  757. cooperationArray,
  758. };
  759. await this.layout('tender/cooperation.ejs', renderData, 'tender/cooperationModal.ejs');
  760. } catch (error) {
  761. ctx.helper.log(error);
  762. this.ctx.redirect('/tender/' + tenderId);
  763. }
  764. }
  765. checkAssPermissionByType(type) {
  766. if (!type) return false;
  767. if (type === 'ledger') return this.ctx.session.sessionUser.accountId === this.ctx.tender.data.user_id;
  768. return false;
  769. }
  770. async loadAss(ctx) {
  771. try {
  772. const data = JSON.parse(ctx.request.body.data);
  773. if (!this.checkAssPermissionByType(data.type)) throw '您无权查看该协作数据';
  774. const assData = await ctx.service.tenderAss.getAssData(ctx.tender.id, data.type, data.rela_id);
  775. ctx.body = { err: 0, msg: '', data: assData };
  776. } catch (err) {
  777. ctx.log(err);
  778. ctx.ajaxErrorBody(err, '加载协作数据错误');
  779. }
  780. }
  781. async saveAss(ctx) {
  782. try {
  783. const data = JSON.parse(ctx.request.body.data);
  784. if (!this.checkAssPermissionByType(data.type)) throw '您无权修改该协作数据';
  785. await ctx.service.tenderAss.saveAssData(ctx.tender.id, data.type, data.rela_id, data.updateData);
  786. ctx.body = {err: 0, msg: '', data: null};
  787. } catch (err) {
  788. ctx.log(err);
  789. ctx.ajaxErrorBody(err, '保存协作数据错误');
  790. }
  791. }
  792. /**
  793. * 添加标段操作
  794. *
  795. * @param {Object} ctx - egg全局变量
  796. * @return {void}
  797. */
  798. async add(ctx) {
  799. try {
  800. const rule = ctx.service.tender.rule('add');
  801. ctx.helper.validate(rule);
  802. const result = ctx.service.tender.add(ctx.request.body);
  803. if (!result) {
  804. throw '新增标段失败';
  805. }
  806. } catch (error) {
  807. ctx.helper.log(error);
  808. this.setMessage(error.toString(), this.messageType.ERROR);
  809. }
  810. ctx.redirect(ctx.request.header.referer);
  811. }
  812. /**
  813. * 保存标段操作
  814. *
  815. * @param {Object} ctx - egg全局变量
  816. * @return {void}
  817. */
  818. async save(ctx) {
  819. let id = ctx.request.body.tenderId;
  820. id = parseInt(id);
  821. try {
  822. if (isNaN(id) || id < 0) {
  823. throw '参数错误';
  824. }
  825. // 获取数据规则
  826. const rule = ctx.service.tender.rule('save');
  827. ctx.validate(rule);
  828. const result = await ctx.service.tender.save(ctx.request.body, id);
  829. if (!result) {
  830. throw '保存标段数据失败';
  831. }
  832. this.setMessage('保存标段数据成功', this.messageType.SUCCESS);
  833. } catch (error) {
  834. this.postError(error, '保存标段数据失败');
  835. }
  836. ctx.redirect(ctx.request.header.referer);
  837. }
  838. /**
  839. * 删除标段
  840. *
  841. * @param {Object} ctx -egg全局变量
  842. * @return {void}
  843. */
  844. async delete(ctx) {
  845. let id = ctx.request.body.tenderId;
  846. id = parseInt(id);
  847. try {
  848. if (isNaN(id) || id <= 0) {
  849. throw '参数错误';
  850. }
  851. const result = ctx.service.tender.deleteTenderById(id);
  852. if (!result) {
  853. throw '删除标段失败';
  854. }
  855. this.setMessage('删除标段成功', this.messageType.SUCCESS);
  856. } catch (error) {
  857. this.postError(error, '删除标段失败');
  858. }
  859. ctx.redirect(ctx.request.header.referer);
  860. }
  861. async rule(ctx) {
  862. const responseData = {
  863. err: 0,
  864. msg: '',
  865. data: {},
  866. };
  867. try {
  868. const tenderId = ctx.session.sessionUser.tenderId;
  869. if (!tenderId) {
  870. throw '当前未打开标段';
  871. }
  872. const data = JSON.parse(ctx.request.body.data);
  873. if (!data.rule || !JSON.parse(data.data).length || !codeRuleConst.ruleField[data.rule]) {
  874. throw '请选择组件再添加';
  875. }
  876. if (!data.connector) {
  877. throw '请选择连接符';
  878. }
  879. const updateData = {
  880. id: tenderId,
  881. };
  882. if (data.type) {
  883. const tenderData = await ctx.service.tender.getDataById(tenderId);
  884. const c_code_rules = tenderData.c_code_rules ? JSON.parse(tenderData.c_code_rules) : {};
  885. c_code_rules[data.type + '_rule'] = JSON.parse(data.data);
  886. c_code_rules[data.type + '_rule_first'] = 0;
  887. c_code_rules[data.type + '_connector'] = data.connector;
  888. updateData.c_code_rules = JSON.stringify(c_code_rules);
  889. } else {
  890. updateData[codeRuleConst.ruleField[data.rule]] = data.data;
  891. updateData.c_connector = data.connector;
  892. updateData.c_rule_first = 0;
  893. }
  894. const result = await ctx.service.tender.db.update(ctx.service.tender.tableName, updateData);
  895. if (result.affectedRows !== 1) {
  896. throw '更新规则失败';
  897. }
  898. } catch (err) {
  899. ctx.helper.log(err);
  900. responseData.err = 1;
  901. responseData.msg = err.toString();
  902. }
  903. ctx.body = responseData;
  904. }
  905. async ruleFirst(ctx) {
  906. const responseData = {
  907. err: 0,
  908. msg: '',
  909. data: {},
  910. };
  911. try {
  912. const tenderId = ctx.session.sessionUser.tenderId;
  913. if (!tenderId) {
  914. throw '当前未打开标段';
  915. }
  916. const updateData = {
  917. id: tenderId,
  918. };
  919. const data = JSON.parse(ctx.request.body.data);
  920. if (data && data.type) {
  921. const tenderData = await ctx.service.tender.getDataById(tenderId);
  922. const c_code_rules = tenderData.c_code_rules ? JSON.parse(tenderData.c_code_rules) : {};
  923. c_code_rules[data.type + '_rule_first'] = 0;
  924. updateData.c_code_rules = JSON.stringify(c_code_rules);
  925. } else {
  926. updateData.c_rule_first = 0;
  927. }
  928. const result = await ctx.service.tender.db.update(ctx.service.tender.tableName, updateData);
  929. if (result.affectedRows !== 1) {
  930. throw '更新规则失败';
  931. }
  932. } catch (err) {
  933. ctx.helper.log(err);
  934. responseData.err = 1;
  935. responseData.msg = err.toString();
  936. }
  937. ctx.body = responseData;
  938. }
  939. async shenpiSet(ctx) {
  940. if (ctx.session.sessionUser.is_admin === 0) {
  941. ctx.request.headers.referer ? ctx.redirect(ctx.request.headers.referer) : ctx.redirect(`/sp/${ctx.subProject.id}/list`);
  942. }
  943. // 获取所有项目参与者
  944. const accountList = await ctx.service.projectAccount.getAllSubProjectAccount(ctx.subProject);
  945. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  946. const accountGroupList = unitList.map(item => {
  947. const groupList = accountList.filter(item1 => item1.company === item.name);
  948. return { groupName: item.name, groupList };
  949. }).filter(x => { return x.groupList.length > 0; });
  950. // 获取固定审批流 or 固定终审
  951. const spConst = ctx.helper._.cloneDeep(shenpiConst);
  952. for (const sp of spConst.sp_lc) {
  953. sp.status = ctx.tender.info.shenpi ? ctx.tender.info.shenpi[sp.code] : spConst.sp_status.sqspr;
  954. if (sp.status === shenpiConst.sp_status.gdspl) {
  955. sp.groupList = await ctx.service.shenpiGroup.getGroupList(ctx.tender.id, sp.type) || [];
  956. if (sp.groupList && sp.groupList.length > 0) {
  957. for (const group of sp.groupList) {
  958. if (group.change_type) group.change_type = JSON.parse(group.change_type);
  959. group.auditGroupList = await ctx.service.shenpiAudit.getAuditGroupList(ctx.tender.id, sp.type, sp.status, group.id);
  960. if (group.is_select) sp.auditGroupList = group.auditGroupList;
  961. }
  962. } else {
  963. sp.auditGroupList = await ctx.service.shenpiAudit.getAuditGroupList(ctx.tender.id, sp.type, sp.status);
  964. }
  965. } else if (sp.status === shenpiConst.sp_status.gdzs) {
  966. sp.audit = await ctx.service.shenpiAudit.getAudit(ctx.tender.id, sp.type, sp.status);
  967. }
  968. }
  969. const tenders = await ctx.service.tender.getList('', null, 1);
  970. const removeTenders = await ctx.service.shenpiAudit.getRemoveTenders(tenders);
  971. if (removeTenders.length > 0) {
  972. ctx.helper._.remove(tenders, function(n) {
  973. return removeTenders.indexOf(n.id) !== -1;
  974. });
  975. }
  976. const categoryData = await ctx.service.category.getAllCategory(ctx.subProject);
  977. // 是否修订中
  978. const lastRevise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  979. const revising = (lastRevise && lastRevise.status !== auditConst.revise.status.checked) || false;
  980. const cooperationNum = await ctx.service.ledgerCooperation.count({ tid: ctx.tender.id, status: 1 });
  981. const renderData = {
  982. shenpi: spConst,
  983. accountList,
  984. accountGroup: accountGroupList,
  985. tenders,
  986. categoryData,
  987. auditConst,
  988. revising,
  989. measureType,
  990. cooperationNum,
  991. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.shenpi),
  992. auditType: auditConst.auditType,
  993. change_type_list: shenpiConst.change_type_list,
  994. };
  995. await this.layout('tender/shenpi.ejs', renderData, 'tender/shenpi_modal.ejs');
  996. }
  997. async saveTenderInfoShenpi(ctx) {
  998. try {
  999. const data = JSON.parse(ctx.request.body.data);
  1000. if (!data) {
  1001. throw '提交数据错误';
  1002. }
  1003. // 判断修改权限
  1004. if (ctx.session.sessionUser.is_admin === 0) {
  1005. throw '你没有权限修改审批流程';
  1006. }
  1007. // let postData = {};
  1008. // if (!ctx.tender.info.shenpi) {
  1009. // for (const sp of shenpiConst.sp_lc) {
  1010. // if (sp.code === data.code) {
  1011. // postData[sp.code] = data.status;
  1012. // } else {
  1013. // postData[sp.code] = shenpiConst.sp_status.sqspr;
  1014. // }
  1015. // }
  1016. // } else {
  1017. const postData = ctx.tender.info.shenpi;
  1018. postData[data.code] = data.status;
  1019. if (data.code === shenpiConst.sp_lc[shenpiConst.sp_type.stage - 1].code) {
  1020. const status = parseInt(data.status) === shenpiConst.sp_status.gdspl ? 1 : 0;
  1021. await ctx.service.ledgerCooperation.changeAllStatus(status);
  1022. }
  1023. // }
  1024. await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, { shenpi: postData });
  1025. let auditList = [];
  1026. let groupList = [];
  1027. if (data.status === shenpiConst.sp_status.gdspl) {
  1028. groupList = await ctx.service.shenpiGroup.getGroupList(ctx.tender.id, shenpiConst.sp_type[data.code]) || [];
  1029. if (groupList && groupList.length > 0) {
  1030. for (const group of groupList) {
  1031. if (group.change_type) group.change_type = JSON.parse(group.change_type);
  1032. group.auditGroupList = await ctx.service.shenpiAudit.getAuditGroupList(ctx.tender.id, shenpiConst.sp_type[data.code], data.status, group.id);
  1033. if (group.is_select) auditList = group.auditGroupList;
  1034. }
  1035. } else {
  1036. auditList = await ctx.service.shenpiAudit.getAuditGroupList(ctx.tender.id, shenpiConst.sp_type[data.code], data.status);
  1037. }
  1038. } else if (data.status === shenpiConst.sp_status.gdzs) {
  1039. auditList = await ctx.service.shenpiAudit.getAudit(ctx.tender.id, shenpiConst.sp_type[data.code], data.status);
  1040. }
  1041. ctx.body = { err: 0, msg: '', data: { auditList, groupList } };
  1042. } catch (err) {
  1043. this.log(err);
  1044. ctx.body = this.ajaxErrorBody(err, '保存审批流程设置失败');
  1045. }
  1046. }
  1047. async saveShenpiAudit(ctx) {
  1048. try {
  1049. const data = JSON.parse(ctx.request.body.data);
  1050. if (!data) {
  1051. throw '提交数据错误';
  1052. }
  1053. // 判断修改权限
  1054. if (ctx.session.sessionUser.is_admin === 0) {
  1055. throw '你没有权限修改审批流程';
  1056. }
  1057. let info = '';
  1058. switch (data.type) {
  1059. case 'add':
  1060. info = await ctx.service.shenpiAudit.addAudit(data);
  1061. break;
  1062. case 'del':
  1063. await ctx.service.shenpiAudit.removeAudit(data);
  1064. break;
  1065. case 'copy2ot':
  1066. await ctx.service.shenpiAudit.copyAudit2otherTender(data);
  1067. break;
  1068. case 'copy2os':
  1069. await ctx.service.shenpiAudit.copyAudit2otherShenpi(data);
  1070. break;
  1071. case 'pwd':
  1072. info = await ctx.service.ledgerCooperation.save(data);
  1073. break;
  1074. case 'company':
  1075. info = await ctx.service.ledgerCooperation.saveCompany(data);
  1076. break;
  1077. case 'audit-ass':
  1078. info = await ctx.service.auditAss.updateData(data);
  1079. break;
  1080. case 'audit-type':
  1081. await ctx.service.shenpiAudit.setAuditType(data);
  1082. break;
  1083. case 'save-group':
  1084. info = await ctx.service.shenpiGroup.saveGroup(ctx.tender.id, data);
  1085. break;
  1086. case 'change-group':
  1087. await ctx.service.shenpiGroup.changeGroup(data);
  1088. break;
  1089. case 'delete-group':
  1090. await ctx.service.shenpiGroup.deleteGroup(data);
  1091. break;
  1092. default:break;
  1093. }
  1094. ctx.body = { err: 0, msg: '', data: info };
  1095. } catch (err) {
  1096. this.log(err);
  1097. ctx.body = this.ajaxErrorBody(err, '保存审批流程设置失败');
  1098. }
  1099. }
  1100. /**
  1101. * 签名,上传图片 (Ajax)
  1102. * @param ctx
  1103. * @return {Promise<void>}
  1104. */
  1105. async saveCooperateSign(ctx) {
  1106. try {
  1107. const stream = await ctx.getFileStream();
  1108. const create_time = Date.parse(new Date()) / 1000;
  1109. const id = stream.fields.id;
  1110. const fileInfo = path.parse(stream.filename);
  1111. const fileName = path.join('public/upload', ctx.tender.id.toString(), 'sign', 'signImg_' + create_time + fileInfo.ext);
  1112. await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', fileName));
  1113. if (stream) {
  1114. await sendToWormhole(stream);
  1115. }
  1116. await ctx.service.ledgerCooperation.saveSign(id, fileName);
  1117. ctx.body = { err: 0, msg: '', data: fileName };
  1118. } catch (err) {
  1119. this.log(err);
  1120. ctx.body = { err: 1, msg: err.toString(), data: null };
  1121. }
  1122. }
  1123. /**
  1124. * 拷贝设置
  1125. * @param {object} ctx - 上下文
  1126. */
  1127. async copyTender(ctx) {
  1128. try {
  1129. const id = ctx.tender.data.id;
  1130. const { id: copy_id = '', type: typeArr = [] } = JSON.parse(ctx.request.body.data);
  1131. await ctx.service.tenderInfo.copyTenderHandler(id, copy_id, typeArr);
  1132. ctx.body = { err: 0, msg: '' };
  1133. } catch (error) {
  1134. this.log(error);
  1135. ctx.body = this.ajaxErrorBody(error, '保存审批流程设置失败');
  1136. }
  1137. }
  1138. async certSet(ctx) {
  1139. try {
  1140. const allCertList = await ctx.service.accountCert.getAllCertByPid(ctx.session.sessionProject.id);
  1141. const tenderCertList = await ctx.service.tenderCert.getListByTid(ctx.tender.id, allCertList);
  1142. const renderData = {
  1143. allCertList,
  1144. tenderCertList,
  1145. certTypeConst: profileConst.cert.certType,
  1146. certSourceConst: [...profileConst.cert.certReg, ...profileConst.cert.certQual],
  1147. fujianOssPath: ctx.app.config.fujianOssPath,
  1148. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.cert),
  1149. };
  1150. const uidList = ctx.helper._.uniq(ctx.helper._.map(allCertList, 'uid'));
  1151. const accountList = uidList.length > 0 ? await ctx.service.projectAccount.getAllDataByCondition({
  1152. where: { project_id: ctx.session.sessionProject.id, enable: 1, id: uidList },
  1153. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  1154. }) : [];
  1155. renderData.accountList = accountList;
  1156. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  1157. renderData.accountGroup = unitList.map(item => {
  1158. const groupList = accountList.filter(item1 => item1.company === item.name);
  1159. return { groupName: item.name, groupList };
  1160. }).filter(x => { return x.groupList.length > 0; });
  1161. await this.layout('tender/cert.ejs', renderData, 'tender/cert_modal.ejs');
  1162. } catch (err) {
  1163. this.log(err);
  1164. ctx.redirect('/tender/' + ctx.tender.id);
  1165. }
  1166. }
  1167. async saveCert(ctx) {
  1168. const response = { err: 0, msg: '', data: {} };
  1169. try {
  1170. const data = JSON.parse(ctx.request.body.data);
  1171. if (!data) {
  1172. throw '提交数据错误';
  1173. }
  1174. switch (data.type) {
  1175. case 'save_user':
  1176. response.data = await ctx.service.tenderCert.saveUserCert(ctx.tender.id, data.list);
  1177. break;
  1178. case 'update_cert':
  1179. response.data = await ctx.service.tenderCert.updateOneCert(data.update_data);
  1180. break;
  1181. case 'paste_cert':
  1182. response.data = await ctx.service.tenderCert.updateMoreCert(ctx.tender.id, data.update_data);
  1183. break;
  1184. default:break;
  1185. }
  1186. ctx.body = response;
  1187. } catch (err) {
  1188. this.log(err);
  1189. ctx.body = { err: 1, msg: err.toString(), data: {} };
  1190. }
  1191. }
  1192. /**
  1193. * 游客账号设置
  1194. * @param {object} ctx - 上下文
  1195. */
  1196. async saveTourist(ctx) {
  1197. try {
  1198. const data = JSON.parse(ctx.request.body.data);
  1199. if (!data) {
  1200. throw '提交数据错误';
  1201. }
  1202. // 判断修改权限
  1203. if (ctx.session.sessionUser.is_admin === 0) {
  1204. throw '你没有权限修改游客账号';
  1205. }
  1206. let info = '';
  1207. switch (data.type) {
  1208. case 'add':
  1209. const result = await ctx.service.tenderTourist.addAudit(data);
  1210. if (!result) {
  1211. throw '添加审批人失败';
  1212. }
  1213. info = result;
  1214. break;
  1215. case 'del':
  1216. await ctx.service.tenderTourist.removeAudit(data);
  1217. break;
  1218. case 'permission':
  1219. await ctx.service.tenderTourist.setPermission(data);
  1220. break;
  1221. default:break;
  1222. }
  1223. ctx.body = { err: 0, msg: '', data: info };
  1224. } catch (err) {
  1225. this.log(err);
  1226. ctx.body = this.ajaxErrorBody(err, '保存游客账号设置失败');
  1227. }
  1228. }
  1229. /**
  1230. * 获取设置协同人相关(Ajax)
  1231. *
  1232. * @param ctx
  1233. * @return {Promise<void>}
  1234. */
  1235. async loadAuditAss(ctx) {
  1236. try {
  1237. const ledgerData = await ctx.service.ledger.getAllDataByCondition({
  1238. columns: ['id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf', 'code', 'b_code', 'name'],
  1239. where: { tender_id: ctx.tender.id }
  1240. });
  1241. const result = ledgerData.filter(x => { return !x.b_code; });
  1242. const auditAssList = await ctx.service.auditAss.getData(ctx.tender.id);
  1243. ctx.body = { err: 0, msg: '', data: { ledgerList: result, auditAssList } };
  1244. } catch (err) {
  1245. this.log(err);
  1246. ctx.body = { err: 1, msg: err.toString(), data: [] };
  1247. }
  1248. }
  1249. async loadUnionAudit(ctx) {
  1250. try {
  1251. const data = JSON.parse(ctx.request.body.data);
  1252. const result = {};
  1253. result.unionAuditors = await ctx.service.shenpiAudit.getUnionAudit(ctx.tender.id, shenpiConst.sp_type[data.sp_type], data.audit_order);
  1254. if (data.ledger) {
  1255. const ledgerData = await ctx.service.ledger.getAllDataByCondition({
  1256. columns: ['id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf', 'code', 'b_code', 'name'],
  1257. where: { tender_id: ctx.tender.id }
  1258. });
  1259. result.ledgerList = ledgerData.filter(x => { return !x.b_code; });
  1260. }
  1261. ctx.body = { err: 0, msg: '', data: result };
  1262. } catch (err) {
  1263. this.log(err);
  1264. ctx.body = { err: 1, msg: err.toString(), data: [] };
  1265. }
  1266. }
  1267. async saveUnionAudit(ctx) {
  1268. try {
  1269. const data = JSON.parse(ctx.request.body.data);
  1270. await ctx.service.shenpiAudit.saveUnionAudit(ctx.tender.id, data);
  1271. ctx.body = {err: 0, msg: '', data: null};
  1272. } catch(err) {
  1273. ctx.log(err);
  1274. ctx.ajaxErrorBody(err, '保存协同审批数据错误');
  1275. }
  1276. }
  1277. async billsTag(ctx) {
  1278. try {
  1279. const isValidTourist = ctx.tender.isTourist && ctx.tender.touristPermission.tag;
  1280. if (ctx.stage) {
  1281. const isAuditor = ctx.stage.userIds.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
  1282. if (!isAuditor && !isValidTourist) throw '您无权进行该操作';
  1283. } else if (ctx.revise) {
  1284. const isAuditor = ctx.revise.reviseUsers.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
  1285. if (!isAuditor && !isValidTourist) throw '您无权进行该操作';
  1286. } else if (ctx.settle) {
  1287. const isAuditor = ctx.settle.userIds.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
  1288. if (!isAuditor && !isValidTourist) throw '您无权进行该操作';
  1289. } else {
  1290. const isAuditor = ctx.tender.ledgerUsers.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
  1291. const isLedgerAss = ctx.tender.isAssUser;
  1292. if (!isAuditor && !isValidTourist && !isLedgerAss) throw '您无权进行该操作';
  1293. }
  1294. const data = JSON.parse(ctx.request.body.data);
  1295. const result = await ctx.service.ledgerTag.update(data);
  1296. ctx.body = { err: 0, msg: '', data: result };
  1297. } catch (err) {
  1298. this.log(err);
  1299. ctx.body = this.ajaxErrorBody(err, '书签数据错误');
  1300. }
  1301. }
  1302. async listLoad(ctx) {
  1303. try {
  1304. const data = JSON.parse(ctx.request.body.data);
  1305. if (!data.type || !data.tid) throw '数据错误';
  1306. if (data.type !== 'stageBatch' && !data.lid) throw '数据错误';
  1307. const responseData = {
  1308. err: 0,
  1309. msg: '',
  1310. data: { ledgerAuditConst: auditConst.ledger, stageAuditConst: auditConst.stage },
  1311. };
  1312. responseData.data.category = await this.ctx.service.category.getAllCategory(ctx.subProject);
  1313. // 获取用户权限
  1314. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  1315. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  1316. const tenderList = await this.ctx.service.tender.getList('', userPermission);
  1317. for (const t of tenderList) {
  1318. if (t.ledger_status === auditConst.ledger.status.checked) {
  1319. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, false);
  1320. }
  1321. }
  1322. if (data.type === 'all') {
  1323. responseData.data.tenders = tenderList;
  1324. } else if (data.type === 'ledger') {
  1325. responseData.data.tenders = tenderList.filter(x => {
  1326. return x.ledger_status === auditConst.ledger.status.checked;
  1327. });
  1328. const history = await this.ctx.service.sumLoadHistory.getLedgerHistory(data.tid, data.lid);
  1329. if (history) responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'ledger' };
  1330. } else if (data.type === 'stage') {
  1331. responseData.data.tenders = tenderList.filter(x => {
  1332. return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
  1333. });
  1334. let history = await this.ctx.service.sumLoadHistory.getStageHistory(data.tid, data.lid);
  1335. if (history) {
  1336. responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'stage' };
  1337. } else {
  1338. history = await this.ctx.service.sumLoadHistory.getReviseHistory(data.tid, data.lid);
  1339. if (history) {
  1340. responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'revise' };
  1341. } else {
  1342. history = await this.ctx.service.sumLoadHistory.getLedgerHistory(data.tid, data.lid);
  1343. if (history) responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'ledger' };
  1344. }
  1345. }
  1346. } else if (data.type === 'stageBatch') {
  1347. responseData.data.tenders = tenderList.filter(x => {
  1348. return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
  1349. });
  1350. responseData.data.history = await this.ctx.service.sumLoadHistory.getBatchHistory(data.tid);
  1351. } else if (data.type === 'revise') {
  1352. responseData.data.tenders = tenderList.filter(x => {
  1353. return x.ledger_status === auditConst.ledger.status.checked;
  1354. });
  1355. let history = await this.ctx.service.sumLoadHistory.getReviseHistory(data.tid, data.lid);
  1356. if (history) {
  1357. responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'revise' };
  1358. } else {
  1359. history = await this.ctx.service.sumLoadHistory.getLedgerHistory(data.tid, data.lid);
  1360. if (history) responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'ledger' };
  1361. }
  1362. }
  1363. ctx.body = responseData;
  1364. } catch (err) {
  1365. this.log(err);
  1366. this.ajaxErrorBody(err, '获取标段列表错误');
  1367. }
  1368. }
  1369. async listLoad2(ctx) {
  1370. try {
  1371. const data = JSON.parse(ctx.request.body.data);
  1372. if (!data.type) throw '数据错误';
  1373. const responseData = {
  1374. err: 0,
  1375. msg: '',
  1376. data: { ledgerAuditConst: auditConst.ledger, stageAuditConst: auditConst.stage },
  1377. };
  1378. responseData.data.category = await this.ctx.service.category.getAllCategory(ctx.subProject);
  1379. // 获取用户权限
  1380. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  1381. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  1382. const tenderList = await this.ctx.service.tender.getList('', userPermission);
  1383. for (const t of tenderList) {
  1384. if (t.ledger_status === auditConst.ledger.status.checked) {
  1385. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, false);
  1386. t.lastCheckedStage = await this.ctx.service.stage.getLastestCompleteStage(t.id);
  1387. }
  1388. }
  1389. if (data.type === 'all') {
  1390. responseData.data.tenders = tenderList;
  1391. } else if (data.type === 'ledger-checked') {
  1392. responseData.data.tenders = tenderList.filter(x => {
  1393. return x.ledger_status === auditConst.ledger.status.checked;
  1394. });
  1395. } else if (data.type === 'stage') {
  1396. responseData.data.tenders = tenderList.filter(x => {
  1397. return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
  1398. });
  1399. } else if (data.type === 'stage-checked') {
  1400. responseData.data.tenders = tenderList.filter(x => {
  1401. return x.ledger_status === auditConst.ledger.status.checked && !!x.lastCheckedStage;
  1402. });
  1403. } else if (data.type === 'stageBatch') {
  1404. responseData.data.tenders = tenderList.filter(x => {
  1405. return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
  1406. });
  1407. }
  1408. if (data.filter) {
  1409. responseData.data.tenders = responseData.data.tenders.filter(x => {
  1410. return !x[data.filter];
  1411. })
  1412. }
  1413. ctx.body = responseData;
  1414. } catch (err) {
  1415. this.log(err);
  1416. this.ajaxErrorBody(err, '获取标段列表错误');
  1417. }
  1418. }
  1419. async sumLoad(ctx) {
  1420. try {
  1421. const data = JSON.parse(ctx.request.body.data);
  1422. if (!data.lid || !data.type || !data.tenders) throw '数据错误';
  1423. switch (data.type) {
  1424. case 'ledger':
  1425. const refreshData = await this.ctx.service.ledger.sumLoad(data.lid, data.tenders);
  1426. ctx.body = {err: 0, msg: '', data: refreshData};
  1427. break;
  1428. case 'revise':
  1429. const reviseData = await this.ctx.service.reviseBills.sumLoad(data.lid, this.ctx.revise.id, data.tenders, data.subUp);
  1430. ctx.body = {err: 0, msg: '', data: reviseData};
  1431. break;
  1432. case 'stage':
  1433. const stageData = await this.ctx.service.stageBills.sumLoad(data.lid, data.tenders, data.cover, data.ignore, data.change);
  1434. stageData.import_change = { target: { import_lid: data.lid } };
  1435. stageData.import_change.data = await this.ctx.service.stageImportChange.getLeafXmjStageImportData(ctx.stage, data.lid);
  1436. await ctx.service.stage.updateCheckCalcFlag(ctx.stage, true);
  1437. await ctx.service.stage.updateCacheTime(ctx.stage.id);
  1438. ctx.body = {err: 0, msg: '', data: stageData};
  1439. break;
  1440. default:
  1441. throw '数据错误';
  1442. }
  1443. } catch (err) {
  1444. this.log(err);
  1445. ctx.ajaxErrorBody(err, '导入数据失败');
  1446. }
  1447. }
  1448. async auditAssist(ctx) {
  1449. try {
  1450. const data = JSON.parse(ctx.request.body.data);
  1451. if (!data.user_id || !data.type) throw '数据错误';
  1452. switch (data.type) {
  1453. case 'stage':
  1454. const stageAssists = await this.ctx.service.stageAuditAss.getUserAssist(ctx.stage, data.user_id);
  1455. ctx.body = { err: 0, msg: '', data: stageAssists };
  1456. break;
  1457. default:
  1458. throw '数据错误';
  1459. }
  1460. } catch (err) {
  1461. this.log(err);
  1462. ctx.ajaxErrorBody(err, '操作失败');
  1463. }
  1464. }
  1465. async auditAssistConfirm(ctx) {
  1466. try {
  1467. const data = JSON.parse(ctx.request.body.data);
  1468. if (!data.user_id || !data.ass_user_id || !data.type || data.confirm === undefined) throw '数据错误';
  1469. switch (data.type) {
  1470. case 'stage':
  1471. const stageAss = await this.ctx.service.stageAuditAss.updateData(data);
  1472. ctx.body = { err: 0, msg: '', data: stageAss };
  1473. break;
  1474. default:
  1475. throw '数据错误';
  1476. }
  1477. } catch (err) {
  1478. this.log(err);
  1479. ctx.ajaxErrorBody(err, '操作失败');
  1480. }
  1481. }
  1482. /**
  1483. * 地图数据设置(Ajax)
  1484. *
  1485. * @param ctx
  1486. * @return {Promise<void>}
  1487. */
  1488. async saveMap(ctx) {
  1489. try {
  1490. const data = JSON.parse(ctx.request.body.data);
  1491. if (!data) {
  1492. throw '提交数据错误';
  1493. }
  1494. // 判断修改权限
  1495. if (ctx.session.sessionUser.is_admin === 0) {
  1496. throw '你没有权限修改概况设置';
  1497. }
  1498. let info = '';
  1499. let result = '';
  1500. switch (data.type) {
  1501. case 'select-map':
  1502. result = await ctx.service.tender.saveTenderData(ctx.tender.id, { had_map: data.value });
  1503. if (!result) {
  1504. throw '修改概况设置失败';
  1505. }
  1506. info = result;
  1507. break;
  1508. case 'add-map':
  1509. result = await ctx.service.tenderMap.addMap(ctx.tender.id, data.name);
  1510. info = await ctx.service.tenderMap.getDataById(result.insertId);
  1511. break;
  1512. case 'del-map':
  1513. await ctx.service.tenderMap.deleteById(data.id);
  1514. break;
  1515. case 'save-map':
  1516. await ctx.service.tenderMap.saveMap(data.mapData);
  1517. break;
  1518. default:break;
  1519. }
  1520. ctx.body = { err: 0, msg: '', data: info };
  1521. } catch (err) {
  1522. this.log(err);
  1523. ctx.body = this.ajaxErrorBody(err, '保存概况设置失败');
  1524. }
  1525. }
  1526. /**
  1527. * 上传静态图
  1528. *
  1529. * @param {object} ctx - egg全局变量
  1530. * @return {void}
  1531. */
  1532. async uploadMap(ctx) {
  1533. const responseData = {
  1534. err: 0, msg: '', data: null,
  1535. };
  1536. try {
  1537. const stream = await ctx.getFileStream();
  1538. const create_time = Date.parse(new Date()) / 1000;
  1539. const fileInfo = path.parse(stream.filename);
  1540. const filepath = `app/public/upload/${ctx.tender.id}/map/${create_time}${fileInfo.ext}`;
  1541. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  1542. await sendToWormhole(stream);
  1543. const tenderInfo = await ctx.service.tender.getDataById(ctx.tender.id);
  1544. const oldMapPic = tenderInfo && tenderInfo.map_pic ? tenderInfo.map_pic : null;
  1545. const result = await ctx.service.tender.update({ map_pic: filepath }, { id: ctx.tender.id });
  1546. if (result) {
  1547. // 移除旧的map_pic oss
  1548. if (oldMapPic) {
  1549. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + oldMapPic);
  1550. }
  1551. responseData.data = { map_pic: filepath };
  1552. } else {
  1553. throw '添加数据库失败';
  1554. }
  1555. } catch (err) {
  1556. this.log(err);
  1557. responseData.err = 1;
  1558. responseData.msg = err;
  1559. }
  1560. ctx.body = responseData;
  1561. }
  1562. async loadData(ctx) {
  1563. try {
  1564. const data = JSON.parse(ctx.request.body.data);
  1565. const filter = data.filter.split(';');
  1566. const responseData = { err: 0, msg: '', data: {} };
  1567. const where = { tid: this.ctx.tender.id };
  1568. for (const f of filter) {
  1569. switch (f) {
  1570. case 'change':
  1571. where.valid = 1;
  1572. if (ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.flow.status.checked;
  1573. responseData.data[f] = await ctx.service.change.getAllDataByCondition({
  1574. columns: [ 'cid', 'code', 'name', 'selected' ],
  1575. where,
  1576. orders: [['in_time', 'desc']],
  1577. });
  1578. break;
  1579. case 'change_project':
  1580. if (ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.changeProject.status.checked;
  1581. responseData.data[f] = await ctx.service.changeProject.getAllDataByCondition({
  1582. columns: [ 'id', 'code', 'name', 'selected' ],
  1583. where,
  1584. orders: [['in_time', 'desc']],
  1585. });
  1586. break;
  1587. case 'change_apply':
  1588. if (ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.changeApply.status.checked;
  1589. responseData.data[f] = await ctx.service.changeApply.getAllDataByCondition({
  1590. columns: [ 'id', 'code', 'name', 'selected' ],
  1591. where,
  1592. orders: [['in_time', 'desc']],
  1593. });
  1594. break;
  1595. case 'change_plan':
  1596. if (ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.changeApply.status.checked;
  1597. responseData.data[f] = await ctx.service.changePlan.getAllDataByCondition({
  1598. columns: [ 'id', 'code', 'name', 'selected' ],
  1599. where,
  1600. orders: [['in_time', 'desc']],
  1601. });
  1602. break;
  1603. case 'advance':
  1604. const advance = await ctx.service.advance.getAllDataByCondition({
  1605. columns: [ 'id', 'order', 'status', 'selected', 'type' ],
  1606. where,
  1607. orders: [['type', 'asc'], ['create_time', 'desc']],
  1608. });
  1609. advance.forEach(x => {
  1610. x.orderStr = `第${x.order}期`;
  1611. x.statusStr = auditConst.advance.statusString[x.status];
  1612. x.typeStr = advanceConst.typeColMap[x.type].text;
  1613. });
  1614. responseData.data[f] = advance;
  1615. break;
  1616. case 'pm_deal':
  1617. if (accountPermission.PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission)) {
  1618. const selects = await this.ctx.service.project.getPmDealCache(this.ctx.session.sessionProject.id);
  1619. const pm = require('../lib/pm');
  1620. const tenders = await pm.dealCatagory(ctx, this.ctx.session.sessionProject.code);
  1621. tenders.forEach(x => {
  1622. x.selected = selects.indexOf(x.bidsectionId + '') >= 0;
  1623. });
  1624. responseData.data[f] = tenders;
  1625. } else {
  1626. throw '您无权查看该数据';
  1627. }
  1628. break;
  1629. case 'show_level':
  1630. responseData.data[f] = ctx.tender.data.rpt_show_level;
  1631. break;
  1632. case 'tender_info':
  1633. responseData.data[f] = ctx.tender.info;
  1634. break;
  1635. default:
  1636. throw '未知数据类型';
  1637. }
  1638. }
  1639. ctx.body = responseData;
  1640. } catch (err) {
  1641. ctx.log(err);
  1642. ctx.ajaxErrorBody(err, '加载数据错误');
  1643. }
  1644. }
  1645. async saveRelaData(ctx) {
  1646. try {
  1647. const data = JSON.parse(ctx.request.body.data);
  1648. const responseData = { err: 0, msg: '', data: {} };
  1649. if (data.change) await this.ctx.service.change.updateChangeSelect(data.change);
  1650. if (data.change_apply) await this.ctx.service.changeApply.defaultUpdateRows(data.change_apply);
  1651. if (data.change_project) await this.ctx.service.changeProject.defaultUpdateRows(data.change_project);
  1652. if (data.change_plan) await this.ctx.service.changePlan.defaultUpdateRows(data.change_plan);
  1653. if (data.advance) await this.ctx.service.advance.defaultUpdateRows(data.advance);
  1654. if (data.pm_deal) await this.ctx.service.project.setPmDealCache(this.ctx.session.sessionProject.id, data.pm_deal);
  1655. if (data.show_level) await this.ctx.service.tender.saveTenderData(ctx.tender.id, { rpt_show_level: data.show_level });
  1656. ctx.body = responseData;
  1657. } catch (err) {
  1658. ctx.log(err);
  1659. ctx.ajaxErrorBody(err, '保存数据错误');
  1660. }
  1661. }
  1662. async refreshCache(ctx) {
  1663. try {
  1664. const tid = ctx.query.tid;
  1665. if (!tid) throw '参数错误';
  1666. const tender = await this.ctx.service.tender.getTender(tid);
  1667. await this.ctx.service.tenderCache.refreshTenderCache(tender);
  1668. } catch (err) {
  1669. ctx.log(err);
  1670. }
  1671. ctx.redirect(ctx.request.header.referer);
  1672. }
  1673. async saveExpr(ctx) {
  1674. try {
  1675. const data = JSON.parse(ctx.request.body.data);
  1676. if (!data.calc_module || !data.calc_tag || !data.calc_id) throw '保存计算式参数有误';
  1677. await this.ctx.service.expr.saveExpr(ctx.tender.id, data);
  1678. ctx.body = { err: 0, msg: '', data: data.expr };
  1679. } catch(err) {
  1680. ctx.log(err);
  1681. ctx.ajaxErrorBody(err, '保存计算式失败');
  1682. }
  1683. }
  1684. async loadExpr(ctx) {
  1685. try {
  1686. const data = JSON.parse(ctx.request.body.data);
  1687. if (!data.calc_module || !data.calc_tag || !data.calc_id) throw '获取计算式参数有误';
  1688. const expr = await this.ctx.service.expr.loadExpr(ctx.tender.id, data);
  1689. ctx.body = { err: 0, msg: '', data: expr };
  1690. } catch(err) {
  1691. ctx.log(err);
  1692. ctx.ajaxErrorBody(err, '保存计算式失败');
  1693. }
  1694. }
  1695. }
  1696. return TenderController;
  1697. };