tender_controller.js 88 KB

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