tender_controller.js 82 KB

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