tender_controller.js 89 KB

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