setting_controller.js 58 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const tenderConst = require('../const/tender');
  10. const auditConst = require('../const/audit');
  11. const officeList = require('../const/cld_office').list;
  12. const settingConst = require('../const/setting.js');
  13. const scheduleConst = require('../const/schedule');
  14. const settingMenu = require('../../config/menu').settingMenu;
  15. const accountGroup = require('../const/account_group').group;
  16. const permission = require('../const/account_permission').permission;
  17. const projectLog = require('../const/project_log');
  18. const imType = require('../const/tender').imType;
  19. const S2b = require('../lib/s2b');
  20. const measureType = require('../const/tender').measureType;
  21. const sendToWormhole = require('stream-wormhole');
  22. const path = require('path');
  23. const funSet = require('../const/fun_set');
  24. module.exports = app => {
  25. class SettingController extends app.BaseController {
  26. /**
  27. * 构造函数
  28. *
  29. * @param {Object} ctx - egg全局context
  30. * @return {void}
  31. */
  32. constructor(ctx) {
  33. super(ctx);
  34. ctx.subMenu = settingMenu;
  35. }
  36. async _checkMenu(pid) {
  37. const ctx = this.ctx;
  38. await this.ctx.service.s2bProj.refreshSessionS2b(pid);
  39. ctx.subMenu.s2b.display = !!ctx.session.sessionProject.gxby || !!ctx.session.sessionProject.dagl;
  40. ctx.subMenu.datacollect.display = ctx.session.sessionProject.page_show.openDataCollect;
  41. // this.ctx.subMenu.s2b.display = false;
  42. }
  43. /**
  44. * 项目信息页面(Get)
  45. *
  46. * @param {Object} ctx - egg全局变量
  47. * @return {void}
  48. */
  49. async info(ctx) {
  50. try {
  51. // 获取项目数据
  52. const projectId = ctx.session.sessionProject.id;
  53. await this._checkMenu(projectId);
  54. const projectData = await ctx.service.project.getDataById(projectId);
  55. if (projectData === null) {
  56. throw '没有对应的项目数据';
  57. }
  58. // 获取销售人员数据
  59. const salesmanData = await ctx.service.manager.getDataById(projectData.manager_id);
  60. // 数据规则
  61. const rule = ctx.service.project.rule('saveInfo');
  62. const jsValidator = await this.jsValidator.convert(rule).build();
  63. const officeName = officeList[salesmanData.office];
  64. const date = new Date(projectData.create_time * 1000);// 如果date为10位不需要乘1000
  65. const Y = date.getFullYear() + '-';
  66. const M = (date.getMonth() + 1 < 10 ? '0' + (date.getMonth() + 1) : date.getMonth() + 1) + '-';
  67. const D = (date.getDate() < 10 ? '0' + (date.getDate()) : date.getDate()) + ' ';
  68. const h = (date.getHours() < 10 ? '0' + date.getHours() : date.getHours()) + ':';
  69. const m = (date.getMinutes() < 10 ? '0' + date.getMinutes() : date.getMinutes()) + ':';
  70. const s = (date.getSeconds() < 10 ? '0' + date.getSeconds() : date.getSeconds());
  71. const dateStr = Y + M + D + h + m + s;
  72. const renderData = {
  73. projectData,
  74. salesmanData,
  75. officeName,
  76. officeList,
  77. jsValidator,
  78. dateStr,
  79. };
  80. await this.layout('setting/info.ejs', renderData);
  81. } catch (error) {
  82. console.log(error);
  83. ctx.redirect('/dashboard');
  84. }
  85. }
  86. /**
  87. * 项目设置 -- 账号设置(Get)
  88. * @param ctx
  89. * @return {Promise<void>}
  90. */
  91. async user(ctx) {
  92. try {
  93. // 获取项目数据
  94. const projectId = ctx.session.sessionProject.id;
  95. await this._checkMenu(projectId);
  96. const projectData = await ctx.service.project.getDataById(projectId);
  97. if (projectData === null) {
  98. throw '没有对应的项目数据';
  99. }
  100. if (ctx.session.sessionUser.is_admin === 0) {
  101. throw '没有访问权限';
  102. }
  103. let keyword = '';
  104. if (ctx.query.keyword) {
  105. keyword = ctx.query.keyword;
  106. }
  107. let company = '';
  108. if (ctx.query.company) {
  109. company = ctx.query.company;
  110. }
  111. const page = ctx.page;
  112. const pageSize = ctx.pageSize;
  113. // 过滤数据
  114. ctx.service.projectAccount.searchFilter(ctx.request.query, projectId);
  115. ctx.sort = ['id', 'desc'];
  116. const total = await ctx.service.projectAccount.getCountWithBuilder();
  117. // 获取数据规则
  118. // const rule = ctx.service.projectAccount.rule('updateUser');
  119. // const frontRule = ctx.helper.validateConvert(rule);
  120. // const total = await ctx.service.projectAccount.count({ project_id: projectId });
  121. // 获取项目用户列表
  122. // const accountData = await ctx.service.projectAccount.getAllDataByCondition({
  123. // where: { project_id: projectId },
  124. // columns: ['id', 'account', 'name', 'company', 'role', 'mobile', 'auth_mobile', 'telephone', 'enable', 'is_admin', 'account_group'],
  125. // limit: (app.config.pageSize * (page - 1)),
  126. // offset: app.config.pageSize,
  127. // });
  128. // const columns = ['id', 'account', 'name', 'company', 'role', 'mobile', 'auth_mobile', 'telephone', 'enable', 'is_admin', 'account_group', 'bind'];
  129. // const accountData = await ctx.service.projectAccount.getListByProjectId(columns, projectId);
  130. const accountData = await ctx.service.projectAccount.getListWithBuilder();
  131. // 获取账号个数
  132. const user_total = await ctx.service.projectAccount.count({project_id: projectId});
  133. // 分页相关
  134. const pageInfo = {
  135. page,
  136. pageSizeSelect: 1,
  137. pageSize,
  138. total_num: total,
  139. total: Math.ceil(total / pageSize),
  140. queryData: JSON.stringify(ctx.urlInfo.query),
  141. };
  142. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({where: {pid: projectId}});
  143. const renderData = {
  144. projectData,
  145. accountData,
  146. accountGroup,
  147. permission,
  148. pageInfo,
  149. keyword,
  150. user_total,
  151. unitList,
  152. company,
  153. // rule: JSON.stringify(frontRule),
  154. };
  155. await this.layout('setting/user.ejs', renderData, 'setting/user_modal.ejs');
  156. } catch (error) {
  157. console.log(error);
  158. ctx.redirect('/dashboard');
  159. }
  160. }
  161. /**
  162. * 项目设置 -- 账号解绑设置(Post)
  163. * @param ctx
  164. * @return {Promise<void>}
  165. */
  166. async userUnbind(ctx) {
  167. const projectData = ctx.session.sessionProject;
  168. try {
  169. if (projectData.id === undefined) {
  170. throw '不存在对应的项目数据';
  171. }
  172. if (ctx.session.sessionUser.is_admin === 0) {
  173. throw '非管理员无权解绑账号';
  174. }
  175. const accountId = parseInt(ctx.request.body.id);
  176. const result = await ctx.service.projectAccount.update({bind: 0}, {id: accountId});
  177. if (!result) {
  178. throw '解绑失败';
  179. }
  180. this.setMessage('解绑成功', this.messageType.SUCCESS);
  181. } catch (error) {
  182. console.log(error);
  183. this.setMessage(error.toString(), this.messageType.ERROR);
  184. }
  185. ctx.redirect(ctx.request.header.referer);
  186. }
  187. /**
  188. * 项目权限 -- 账号设置(Get)
  189. * @param ctx
  190. * @return {Promise<void>}
  191. */
  192. async userPermissionSet(ctx) {
  193. try {
  194. // 获取项目数据
  195. const projectId = ctx.session.sessionProject.id;
  196. const projectData = await ctx.service.project.getDataById(projectId);
  197. if (projectData === null) {
  198. throw '没有对应的项目数据';
  199. }
  200. if (ctx.session.sessionUser.is_admin === 0) {
  201. throw '没有访问权限';
  202. }
  203. let keyword = '';
  204. if (ctx.query.keyword) {
  205. keyword = ctx.query.keyword;
  206. }
  207. let company = '';
  208. if (ctx.query.company) {
  209. company = ctx.query.company;
  210. }
  211. // 获取数据规则
  212. const page = ctx.page;
  213. const pageSize = ctx.pageSize;
  214. const columns = ['id', 'account', 'name', 'company', 'role', 'mobile', 'auth_mobile', 'telephone', 'enable', 'is_admin', 'bind', 'account_group', 'permission', 'cooperation'];
  215. // 过滤数据
  216. ctx.service.projectAccount.searchFilter(ctx.request.query, projectId, columns);
  217. ctx.sort = ['id', 'desc'];
  218. const total = await ctx.service.projectAccount.getCountWithBuilder();
  219. const accountData = await ctx.service.projectAccount.getListWithBuilder();
  220. // 获取账号个数
  221. const user_total = await ctx.service.projectAccount.count({project_id: projectId});
  222. // 分页相关
  223. const pageInfo = {
  224. page,
  225. pageSizeSelect: 1,
  226. pageSize,
  227. total_num: total,
  228. total: Math.ceil(total / pageSize),
  229. queryData: JSON.stringify(ctx.urlInfo.query),
  230. };
  231. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({where: {pid: projectId}});
  232. const renderData = {
  233. projectData,
  234. accountData,
  235. accountGroup,
  236. permission,
  237. keyword,
  238. permissionStr: JSON.stringify(permission),
  239. pageInfo,
  240. user_total,
  241. unitList,
  242. company,
  243. // rule: JSON.stringify(frontRule),
  244. };
  245. await this.layout('setting/user_permission.ejs', renderData, 'setting/user_permission_modal.ejs');
  246. } catch (error) {
  247. console.log(error);
  248. ctx.redirect('/dashboard');
  249. }
  250. }
  251. /**
  252. * 项目权限 -- 参建单位(Get)
  253. * @param ctx
  254. * @return {Promise<void>}
  255. */
  256. async userUnit(ctx) {
  257. try {
  258. // 获取项目数据
  259. const projectId = ctx.session.sessionProject.id;
  260. const projectData = await ctx.service.project.getDataById(projectId);
  261. if (projectData === null) {
  262. throw '没有对应的项目数据';
  263. }
  264. if (ctx.session.sessionUser.is_admin === 0) {
  265. throw '没有访问权限';
  266. }
  267. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({where: {pid: projectId}});
  268. for (const u of unitList) {
  269. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  270. where: {
  271. project_id: projectId,
  272. company: u.name
  273. }
  274. });
  275. u.account_num = accountList.length;
  276. }
  277. // 获取账号个数
  278. const user_total = await ctx.service.projectAccount.count({project_id: projectId});
  279. const renderData = {
  280. projectData,
  281. accountGroup,
  282. unitList,
  283. user_total,
  284. fujianOssPath: ctx.app.config.fujianOssPath,
  285. };
  286. await this.layout('setting/user_unit.ejs', renderData, 'setting/user_unit_modal.ejs');
  287. } catch (error) {
  288. console.log(error);
  289. ctx.redirect('/dashboard');
  290. }
  291. }
  292. /**
  293. * 项目设置 -- 单位新增设置(Post)
  294. * @param ctx
  295. * @return {Promise<void>}
  296. */
  297. async userUnitAdd(ctx) {
  298. const projectData = ctx.session.sessionProject;
  299. try {
  300. // 验证数据
  301. if (projectData.id === undefined) {
  302. throw '不存在对应的项目数据';
  303. }
  304. // 获取验证规则
  305. const rule = ctx.service.constructionUnit.rule('add');
  306. ctx.validate(rule);
  307. ctx.request.body.pid = projectData.id;
  308. const result = await ctx.service.constructionUnit.save(ctx.request.body);
  309. if (!result) {
  310. throw '保存单位失败';
  311. }
  312. this.setMessage('保存单位成功', this.messageType.SUCCESS);
  313. ctx.redirect('/' + ctx.controllerName + '/user/unit');
  314. } catch (error) {
  315. console.log(error);
  316. this.setMessage(error.toString(), this.messageType.ERROR);
  317. ctx.redirect(ctx.request.header.referer);
  318. }
  319. }
  320. /**
  321. * 项目设置 -- 单位编辑(Post)
  322. * @param ctx
  323. * @return {Promise<void>}
  324. */
  325. async userUnitSave(ctx) {
  326. const projectData = ctx.session.sessionProject;
  327. const responseData = {
  328. err: 0, msg: '', data: null,
  329. };
  330. try {
  331. // 验证数据
  332. if (projectData.id === undefined) {
  333. throw '不存在对应的项目数据';
  334. }
  335. const data = JSON.parse(ctx.request.body.data);
  336. switch (data.type) {
  337. case 'update':
  338. const post_data = {
  339. pid: projectData.id,
  340. id: data.id,
  341. };
  342. post_data[data.val_name] = data.val;
  343. if (data.name) post_data.name = data.name;
  344. const result = await ctx.service.constructionUnit.save(post_data);
  345. if (!result) {
  346. throw '保存单位失败';
  347. }
  348. if (post_data.name) {
  349. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  350. where: {
  351. project_id: projectData.id,
  352. company: post_data.name
  353. }
  354. });
  355. responseData.data = {account_num: accountList.length};
  356. }
  357. break;
  358. case 'delete':
  359. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  360. where: {
  361. project_id: projectData.id,
  362. company: data.name
  363. }
  364. });
  365. if (accountList.length > 0) {
  366. throw '该单位下还存在账号,无法删除';
  367. }
  368. await ctx.service.constructionUnit.del(data.id);
  369. break;
  370. case 'del-sign':
  371. const info = await ctx.service.constructionUnit.getDataById(data.id);
  372. if (info.sign_path) {
  373. // 不删除地址,只删除数据库数据,防止已签章的报表丢失
  374. // await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + info.sign_path);
  375. }
  376. await ctx.service.constructionUnit.update({sign_path: null}, {id: info.id});
  377. break;
  378. default:
  379. break;
  380. }
  381. ctx.body = responseData;
  382. } catch (err) {
  383. this.log(err);
  384. ctx.body = {err: 1, msg: err.toString(), data: null};
  385. }
  386. }
  387. async userUnitUpload(ctx) {
  388. const responseData = {
  389. err: 0, msg: '', data: null,
  390. };
  391. try {
  392. const stream = await ctx.getFileStream();
  393. const create_time = Date.parse(new Date()) / 1000;
  394. const fileInfo = path.parse(stream.filename);
  395. const filepath = `app/public/upload/sign/unit/qianzhang_${create_time + fileInfo.ext}`;
  396. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  397. await sendToWormhole(stream);
  398. const result = await ctx.service.constructionUnit.update({sign_path: filepath}, {id: stream.fields.id});
  399. if (result) {
  400. responseData.data = {sign_path: filepath};
  401. } else {
  402. throw '添加数据库失败';
  403. }
  404. } catch (err) {
  405. this.log(err);
  406. responseData.err = 1;
  407. responseData.msg = err;
  408. }
  409. ctx.body = responseData;
  410. }
  411. /**
  412. * 项目设置 -- 账号启用和停用设置(Post)
  413. * @param ctx
  414. * @return {Promise<void>}
  415. */
  416. async userSwitch(ctx) {
  417. const responseData = {
  418. err: 0, msg: '', data: null,
  419. };
  420. try {
  421. // 获取项目数据
  422. const projectId = ctx.session.sessionProject.id;
  423. const projectData = await ctx.service.project.getDataById(projectId);
  424. if (projectData === null) {
  425. throw '没有对应的项目数据';
  426. }
  427. if (ctx.session.sessionUser.is_admin === 0) {
  428. throw '没有访问权限';
  429. }
  430. const data = JSON.parse(ctx.request.body.data);
  431. const result = await ctx.service.projectAccount.update(data, {id: data.id});
  432. if (!result) {
  433. throw '提交数据失败';
  434. }
  435. } catch (err) {
  436. this.log(err);
  437. responseData.err = 1;
  438. responseData.msg = err;
  439. }
  440. ctx.body = responseData;
  441. }
  442. /**
  443. * 项目设置 -- 账号添加(Post)
  444. * @param ctx
  445. * @return {Promise<void>}
  446. */
  447. async addUser(ctx) {
  448. const projectData = ctx.session.sessionProject;
  449. try {
  450. // 验证数据
  451. if (projectData.id === undefined) {
  452. throw '不存在对应的项目数据';
  453. }
  454. // 获取验证规则
  455. const rule = ctx.service.projectAccount.rule('add');
  456. ctx.validate(rule);
  457. // 判断新密码的强度
  458. const reg = /^(?![0-9]+$)(?![a-zA-Z]+$).{6,16}$/;
  459. if (!reg.test(ctx.request.body.password)) {
  460. throw '请设置至少包含数字和字母的密码';
  461. }
  462. ctx.request.body.project_id = projectData.id;
  463. const result = await ctx.service.projectAccount.save(ctx.request.body);
  464. if (!result) {
  465. throw '保存账号数据失败';
  466. }
  467. this.setMessage('保存账号数据成功', this.messageType.SUCCESS);
  468. ctx.redirect('/' + ctx.controllerName + '/user');
  469. } catch (error) {
  470. console.log(error);
  471. ctx.session.postError = error.toString();
  472. this.setMessage(error.toString(), this.messageType.ERROR);
  473. ctx.redirect(ctx.request.header.referer);
  474. }
  475. }
  476. /**
  477. * 项目设置 -- 账号编辑(Post)
  478. * @param ctx
  479. * @return {Promise<void>}
  480. */
  481. async updateUser(ctx) {
  482. const projectData = ctx.session.sessionProject;
  483. try {
  484. // 验证数据
  485. if (projectData.id === undefined) {
  486. throw '不存在对应的项目数据';
  487. }
  488. // 获取验证规则
  489. const rule = ctx.service.projectAccount.rule('modify');
  490. ctx.validate(rule);
  491. const result = await ctx.service.projectAccount.save(ctx.request.body);
  492. if (!result) {
  493. throw '保存账号数据失败';
  494. }
  495. this.setMessage('保存账号数据成功', this.messageType.SUCCESS);
  496. ctx.redirect(ctx.request.header.referer);
  497. } catch (error) {
  498. console.log(error);
  499. this.setMessage(error.toString(), this.messageType.ERROR);
  500. ctx.redirect(ctx.request.header.referer);
  501. }
  502. }
  503. async resetUserPassword(ctx) {
  504. try {
  505. // 获取项目数据
  506. const projectId = ctx.session.sessionProject.id;
  507. const projectData = await ctx.service.project.getDataById(projectId);
  508. if (projectData === null) {
  509. throw '没有对应的项目数据';
  510. }
  511. if (ctx.session.sessionUser.is_admin === 0) {
  512. throw '没有访问权限';
  513. }
  514. const accountId = parseInt(ctx.request.body.id);
  515. let password = ctx.request.body.reset_password;
  516. password = password.toString();
  517. const account = ctx.request.body.account !== undefined ? ctx.request.body.account : '';
  518. if (isNaN(accountId) || accountId <= 0 || password.length < 6) {
  519. throw '参数错误';
  520. }
  521. // 判断新密码的强度
  522. const reg = /^(?![0-9]+$)(?![a-zA-Z]+$).{6,16}$/;
  523. if (!reg.test(password)) {
  524. throw '请设置至少包含数字和字母的密码';
  525. }
  526. const result = await ctx.service.projectAccount.resetPassword(accountId, password, account);
  527. if (!result) {
  528. throw '重置密码失败!';
  529. }
  530. this.setMessage('保存账号数据成功', this.messageType.SUCCESS);
  531. ctx.redirect(ctx.request.header.referer);
  532. } catch (error) {
  533. console.log(error);
  534. this.setMessage(error.toString(), this.messageType.ERROR);
  535. ctx.redirect(ctx.request.header.referer);
  536. }
  537. }
  538. /**
  539. * 项目设置 -- 账号权限编辑(Post)
  540. * @param ctx
  541. * @return {Promise<void>}
  542. */
  543. async permission(ctx) {
  544. const projectData = ctx.session.sessionProject;
  545. try {
  546. // 验证数据
  547. if (projectData.id === undefined) {
  548. throw '不存在对应的项目数据';
  549. }
  550. const accountId = parseInt(ctx.request.body.id);
  551. const accountInfo = await ctx.service.projectAccount.getDataById(accountId);
  552. if (accountInfo === null) {
  553. throw '不存在该客户';
  554. }
  555. const result = await ctx.service.projectAccount.permissionSave(accountId, ctx.request.body);
  556. if (!result) {
  557. throw '修改权限失败!';
  558. }
  559. this.setMessage('保存账号数据成功', this.messageType.SUCCESS);
  560. ctx.redirect(ctx.request.header.referer);
  561. } catch (error) {
  562. console.log(error);
  563. this.setMessage(error.toString(), this.messageType.ERROR);
  564. ctx.redirect(ctx.request.header.referer);
  565. }
  566. }
  567. /**
  568. * 项目设置 -- 自定义标段分类(Get)
  569. *
  570. * @param ctx
  571. * @return {Promise<void>}
  572. */
  573. async category(ctx) {
  574. try {
  575. // 获取项目数据
  576. const projectId = ctx.session.sessionProject.id;
  577. await this._checkMenu(projectId);
  578. const projectData = await ctx.service.project.getDataById(projectId);
  579. if (projectData === null) {
  580. throw '没有对应的项目数据';
  581. }
  582. if (ctx.session.sessionUser.is_admin === 0) {
  583. throw '没有访问权限';
  584. }
  585. const categoryData = await ctx.service.category.getAllCategory(projectId);
  586. const tenderData = await ctx.service.tender.getList('', null, 1);
  587. const renderData = {
  588. projectData,
  589. categoryType: settingConst.cType,
  590. categoryData,
  591. tenderData,
  592. };
  593. await this.layout('setting/category.ejs', renderData, 'setting/category_modal.ejs');
  594. } catch (error) {
  595. console.log(error);
  596. ctx.redirect('/dashboard');
  597. }
  598. }
  599. /**
  600. * 新增分类(Ajax)
  601. *
  602. * @param ctx
  603. * @return {Promise<void>}
  604. */
  605. async addCategory(ctx) {
  606. try {
  607. const projectId = ctx.session.sessionProject.id;
  608. const responseData = {
  609. err: 0, msg: '', data: null,
  610. };
  611. const data = JSON.parse(ctx.request.body.data);
  612. if (!data.name) {
  613. throw '提交数据错误';
  614. }
  615. responseData.data = await ctx.service.category.addCategory(projectId, data.name, settingConst.cType.key.dropDown);
  616. ctx.body = responseData;
  617. } catch (err) {
  618. this.log(err);
  619. ctx.body = {err: 1, msg: err.toString(), data: null};
  620. }
  621. }
  622. /**
  623. * 编辑分类(Ajax)
  624. *
  625. * @param ctx
  626. * @return {Promise<void>}
  627. */
  628. async updateCategory(ctx) {
  629. try {
  630. const projectId = ctx.session.sessionProject.id;
  631. const responseData = {err: 0, msg: '', data: null};
  632. const data = JSON.parse(ctx.request.body.data);
  633. if (!data.id) {
  634. throw '提交数据错误';
  635. }
  636. if (data.name) {
  637. const count = await ctx.service.category.count({pid: projectId, name: data.name});
  638. if (count >= 1) {
  639. throw '存在同名类别';
  640. }
  641. }
  642. const result = await ctx.service.category.update(data, {id: data.id});
  643. if (!result) {
  644. throw '提交数据失败';
  645. }
  646. responseData.data = await ctx.service.category.getCategory(data.id);
  647. ctx.body = responseData;
  648. } catch (err) {
  649. this.log(err);
  650. ctx.body = {err: 1, msg: err.toString(), data: null};
  651. }
  652. }
  653. async setCategoryValue(ctx) {
  654. try {
  655. const responseData = {err: 0, msg: '', data: {}};
  656. const data = JSON.parse(ctx.request.body.data);
  657. if (!data.id) {
  658. throw '提交数据错误';
  659. }
  660. await ctx.service.categoryValue.setCategoryValue(data.id, data.updateValue);
  661. responseData.data.category = await ctx.service.category.getCategory(data.id);
  662. responseData.data.tenders = await ctx.service.tender.getList('', null, 1);
  663. ctx.body = responseData;
  664. } catch (err) {
  665. this.log(err);
  666. ctx.body = {err: 1, msg: err instanceof String ? err : '提交数据失败', data: null};
  667. }
  668. }
  669. /**
  670. * 删除分类(Ajax)
  671. *
  672. * @param ctx
  673. * @return {Promise<void>}
  674. */
  675. async deleteCategory(ctx) {
  676. try {
  677. const projectId = ctx.session.sessionProject.id;
  678. const responseData = {
  679. err: 0, msg: '', data: null,
  680. };
  681. const data = JSON.parse(ctx.request.body.data);
  682. if (!data.id) {
  683. throw '提交数据错误';
  684. }
  685. await ctx.service.category.deleteCategory(projectId, data.id);
  686. ctx.body = responseData;
  687. } catch (err) {
  688. this.log(err);
  689. ctx.body = {err: 1, msg: err.toString(), data: null};
  690. }
  691. }
  692. /**
  693. * 调整分类层次排序(Ajax)
  694. *
  695. * @param ctx
  696. * @return {Promise<void>}
  697. */
  698. async resetCategoryLevel(ctx) {
  699. try {
  700. const projectId = ctx.session.sessionProject.id;
  701. const responseData = {
  702. err: 0, msg: '', data: null,
  703. };
  704. const data = JSON.parse(ctx.request.body.data);
  705. await ctx.service.category.resetCategoryLevel(data);
  706. responseData.data = await ctx.service.category.getAllCategory(projectId);
  707. ctx.body = responseData;
  708. } catch (err) {
  709. this.log(err);
  710. ctx.body = {err: 1, msg: err.toString(), data: null};
  711. }
  712. }
  713. async selfCategoryLevel(ctx) {
  714. try {
  715. const data = JSON.parse(ctx.request.body.data);
  716. await ctx.service.projectAccount.defaultUpdate({
  717. id: ctx.session.sessionUser.accountId,
  718. self_category_level: data.self_category_level || ''
  719. });
  720. ctx.body = {
  721. err: 0, msg: '', data: null,
  722. };
  723. } catch (err) {
  724. ctx.log(err);
  725. ctx.ajaxErrorBody(err, '保存自定义分类失败');
  726. }
  727. }
  728. /** update porject info
  729. * @author wangfeng
  730. * @date 2018-10-12 15:48:05
  731. * @param ctx
  732. * @return {Promise<void>}
  733. */
  734. async updateinfo(ctx) {
  735. try {
  736. const projectId = ctx.params.id;
  737. const responseData = {
  738. err: 0, msg: '', data: null,
  739. };
  740. const conditionData = {
  741. id: projectId,
  742. };
  743. const data = ctx.request.body;
  744. const result = await ctx.service.project.update(data, conditionData);
  745. if (!result) {
  746. throw '提交数据失败';
  747. }
  748. ctx.redirect('/setting/info');
  749. } catch (err) {
  750. this.log(err);
  751. ctx.body = {err: 1, msg: err.toString(), data: null};
  752. }
  753. }
  754. /**
  755. * 检测账户是否存在
  756. *
  757. * @param {Object} ctx -egg全局变量
  758. * @return {void}
  759. */
  760. async accountExist(ctx) {
  761. const projectData = ctx.session.sessionProject;
  762. const responseData = {
  763. err: 0, msg: '', data: null,
  764. };
  765. try {
  766. const data = JSON.parse(ctx.request.body.data);
  767. const account = data.account;
  768. if (projectData.id === undefined) {
  769. throw '不存在对应项目';
  770. }
  771. responseData.data = await ctx.service.projectAccount.isAccountExist(account, projectData.id);
  772. ctx.body = responseData;
  773. } catch (error) {
  774. ctx.body = {err: 1, msg: error.toString(), data: null};
  775. }
  776. }
  777. /**
  778. * 显示设置(Get)
  779. * @param {Object} ctx -egg全局变量
  780. * @return {void}
  781. */
  782. async show(ctx) {
  783. try {
  784. // 获取项目数据
  785. const projectId = ctx.session.sessionProject.id;
  786. await this._checkMenu(projectId);
  787. const projectData = await ctx.service.project.getDataById(projectId);
  788. if (!projectData) {
  789. throw '没有对应的项目数据';
  790. }
  791. if (ctx.session.sessionUser.is_admin === 0) {
  792. throw '没有访问权限';
  793. }
  794. const showList = await ctx.service.settingShow.getList(projectData.page_path);
  795. const sjsRela = await ctx.service.project.getSjsRela(projectId);
  796. const renderData = {projectData, showList, sjsRela, settingConst};
  797. await this.layout('setting/show.ejs', renderData);
  798. } catch (error) {
  799. this.log(error);
  800. ctx.redirect('/dashboard');
  801. }
  802. }
  803. /**
  804. * 更新显示设置列表
  805. * @param {Object} ctx -egg全局变量
  806. * @return {void}
  807. */
  808. async showListUpdate(ctx) {
  809. try {
  810. // 获取项目id
  811. const projectId = ctx.session.sessionProject.id;
  812. const {data} = ctx.request.body;
  813. const {id} = JSON.parse(data);
  814. const result = await ctx.service.settingShow.setDefaultLabel(id, projectId);
  815. const responseData = {err: 0, msg: '', data: result};
  816. ctx.body = responseData;
  817. } catch (error) {
  818. this.log(error);
  819. ctx.body = {err: 1, msg: error.toString(), data: null};
  820. }
  821. }
  822. async showSjsUpdate(ctx) {
  823. try {
  824. const projectId = ctx.session.sessionProject.id;
  825. const data = JSON.parse(ctx.request.body.data);
  826. const result = await ctx.service.project.updateSjsRela(projectId, data.sub, data.field, data.key, data.value);
  827. ctx.body = {err: 0, msg: '', data: result};
  828. } catch (err) {
  829. this.log(err);
  830. this.ajaxErrorBody(err, '保存数据失败');
  831. }
  832. }
  833. async logs(ctx) {
  834. try {
  835. // 获取项目数据
  836. const projectId = ctx.session.sessionProject.id;
  837. await this._checkMenu(projectId);
  838. const projectData = await ctx.service.project.getDataById(projectId);
  839. if (projectData === null) {
  840. throw '没有对应的项目数据';
  841. }
  842. if (ctx.session.sessionUser.is_admin === 0) {
  843. throw '没有访问权限';
  844. }
  845. const settingType = ctx.params.type ? parseInt(ctx.params.type) : 0;
  846. const logs = await ctx.service.projectLog.getLogs(projectId, settingType);
  847. const renderData = {
  848. projectData,
  849. officeList,
  850. projectLog,
  851. settingType,
  852. logs,
  853. };
  854. await this.layout('setting/logs.ejs', renderData);
  855. } catch (error) {
  856. console.log(error);
  857. ctx.redirect('/dashboard');
  858. }
  859. }
  860. async fun(ctx) {
  861. try {
  862. const projectId = ctx.session.sessionProject.id;
  863. await this._checkMenu(projectId);
  864. const projectData = await ctx.service.project.getDataById(projectId);
  865. const funRela = await ctx.service.project.getFunRela(projectId);
  866. if (projectData === null) {
  867. throw '没有对应的项目数据';
  868. }
  869. if (ctx.session.sessionUser.is_admin === 0) {
  870. throw '没有访问权限';
  871. }
  872. const fun_set = await ctx.service.project.getFunSet(projectData.fun_set);
  873. console.log(fun_set);
  874. await this.layout('setting/fun.ejs', {
  875. projectData,
  876. funRela,
  877. imType,
  878. endMonth: funSet.endMonth,
  879. funSet: fun_set,
  880. }, 'setting/fun_modal.ejs');
  881. } catch (error) {
  882. ctx.helper.log(error);
  883. ctx.redirect('/dashboard');
  884. }
  885. }
  886. /**
  887. * 保存功能设置相关
  888. * @param ctx
  889. * @returns {Promise<void>}
  890. */
  891. async updateFun(ctx) {
  892. try {
  893. const projectId = ctx.session.sessionProject.id;
  894. const projectData = await ctx.service.project.getDataById(projectId);
  895. if (projectData === null) {
  896. throw '没有对应的项目数据';
  897. }
  898. if (ctx.session.sessionUser.is_admin === 0) {
  899. throw '没有访问权限';
  900. }
  901. const data = JSON.parse(ctx.request.body.data);
  902. if (data) ctx.request.body = data;
  903. const rule = ctx.service.project.rule('fun');
  904. ctx.validate(rule);
  905. const result = await ctx.service.project.updateFunRela(projectId, ctx.request.body);
  906. if (!result) throw '保存数据失败';
  907. this.ctx.session.sessionProject.page_show.openChangeProject = data.openChangeProject ? 1 : 0;
  908. this.ctx.session.sessionProject.page_show.openChangeApply = data.openChangeApply ? 1 : 0;
  909. this.ctx.session.sessionProject.page_show.openChangePlan = data.openChangePlan ? 1 : 0;
  910. this.ctx.session.sessionProject.page_show.openChangeWhiteList = data.openChangeWhiteList ? 1 : 0;
  911. this.ctx.session.sessionProject.page_show.openChangeState = data.openChangeState ? 1 : 0;
  912. this.ctx.session.sessionProject.page_show.openMaterialTax = data.openMaterialTax ? 1 : 0;
  913. this.ctx.session.sessionProject.page_show.openMaterialChecklist = data.openMaterialChecklist ? 1 : 0;
  914. this.ctx.session.sessionProject.page_show.openMaterialSelf = data.openMaterialSelf ? 1 : 0;
  915. this.ctx.session.sessionProject.page_show.openMaterialEditForAudit = data.openMaterialEditForAudit ? 1 : 0;
  916. this.ctx.session.sessionProject.page_show.openStageStart = data.openStageStart ? 1 : 0;
  917. const result2 = await ctx.service.project.updatePageshow(projectId);
  918. if (!result2) throw '保存数据失败';
  919. if (data.addFunSet) {
  920. const funSet = projectData.fun_set ? JSON.parse(projectData.fun_set) : {};
  921. ctx.helper._.defaultsDeep(data.addFunSet, funSet);
  922. const result3 = await ctx.service.project.updateFunSet(projectId, data.addFunSet);
  923. if (!result3) throw '保存数据失败';
  924. }
  925. ctx.body = {err: 0, msg: '', data: null};
  926. } catch (error) {
  927. ctx.helper.log(error);
  928. this.ajaxErrorBody(error, '保存数据失败');
  929. }
  930. }
  931. async s2b(ctx) {
  932. try {
  933. const projectId = ctx.session.sessionProject.id;
  934. await this._checkMenu(projectId);
  935. const projectData = await ctx.service.project.getDataById(projectId);
  936. if (projectData === null) throw '没有对应的项目数据';
  937. if (ctx.session.sessionUser.is_admin === 0) throw '没有访问权限';
  938. const tenders = await ctx.service.tender.getAllDataByCondition({where: {project_id: projectId}});
  939. for (const t of tenders) {
  940. t.measure_type_str = t.measure_type === measureType.tz.value ? measureType.tz.title : measureType.gcl.title;
  941. const stages = await ctx.service.stage.getAllDataByCondition({where: {tid: t.id}});
  942. t.stage_count_str = `第${stages.length || 0}期`;
  943. const user = await ctx.service.projectAccount.getAccountInfoById(t.user_id);
  944. t.user_str = user.name + '-' + user.company;
  945. t.show_time = stages.length > 0 ? stages[stages.length - 1].cache_time_r || stages[stages.length - 1].in_time : t.create_time;
  946. }
  947. await this.layout('setting/s2b.ejs', {
  948. projectData,
  949. tenders,
  950. });
  951. } catch (error) {
  952. ctx.helper.log(error);
  953. ctx.redirect('/dashboard');
  954. }
  955. }
  956. async s2bUpdate(ctx) {
  957. try {
  958. const projectId = ctx.session.sessionProject.id;
  959. const projectData = await ctx.service.project.getDataById(projectId);
  960. if (projectData === null) throw '没有对应的项目数据';
  961. if (ctx.session.sessionUser.is_admin === 0) throw '没有访问权限';
  962. const data = JSON.parse(ctx.request.body.data);
  963. if (!data.tid) throw '提交数据错误';
  964. const updateData = {};
  965. if (data.gxby_limit !== undefined) updateData.s2b_gxby_limit = data.gxby_limit;
  966. if (data.gxby_check !== undefined) updateData.s2b_gxby_check = data.gxby_check;
  967. if (data.dagl_limit !== undefined) updateData.s2b_dagl_limit = data.dagl_limit;
  968. if (data.dagl_check !== undefined) updateData.s2b_dagl_check = data.dagl_check;
  969. await ctx.service.tender.saveApiRela(data.tid, updateData);
  970. ctx.body = {err: 0, msg: '', data: null};
  971. } catch (error) {
  972. ctx.helper.log(error);
  973. this.ajaxErrorBody(error, '保存数据失败');
  974. }
  975. }
  976. async s2bUpdateStatus(ctx) {
  977. try {
  978. const projectId = ctx.session.sessionProject.id;
  979. const projectData = await ctx.service.project.getDataById(projectId);
  980. if (projectData === null) throw '没有对应的项目数据';
  981. if (ctx.session.sessionUser.is_admin === 0) throw '没有访问权限';
  982. const data = JSON.parse(ctx.request.body.data);
  983. if (!data.type || data.status === undefined) throw '提交数据错误';
  984. const responseData = {err: 0, msg: '', data: null};
  985. switch (data.type) {
  986. case 'gxby':
  987. responseData.data = await this.ctx.service.s2bProj.updateGxbyStatus(projectId, data.status, data.limit, data.ratio);
  988. break;
  989. case 'dagl':
  990. responseData.data = await this.ctx.service.s2bProj.updateDaglStatus(projectId, data.status, data.limit, data.ratio);
  991. break;
  992. default:
  993. throw '提交数据错误';
  994. }
  995. ctx.body = responseData;
  996. } catch (error) {
  997. console.log(error);
  998. ctx.helper.log(error);
  999. this.ajaxErrorBody(error, '保存数据失败');
  1000. }
  1001. }
  1002. async dataCollect(ctx) {
  1003. try {
  1004. if (!ctx.session.sessionProject.page_show.openDataCollect) {
  1005. throw '该功能已关闭或无法查看';
  1006. }
  1007. const projectId = ctx.session.sessionProject.id;
  1008. await this._checkMenu(projectId);
  1009. const projectData = await ctx.service.project.getDataById(projectId);
  1010. if (projectData === null) throw '没有对应的项目数据';
  1011. projectData.data_collect_pages = projectData.data_collect_pages ? projectData.data_collect_pages.split(',') : [];
  1012. if (ctx.session.sessionUser.is_admin === 0) throw '没有访问权限';
  1013. const dataCollectAudits = await ctx.service.datacollectAudit.getList(projectId);
  1014. // 获取所有项目参与者
  1015. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  1016. where: {project_id: ctx.session.sessionProject.id, enable: 1},
  1017. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  1018. });
  1019. // const accountGroupList = accountGroup.map((item, idx) => {
  1020. // const groupList = accountList.filter(item => item.account_group === idx);
  1021. // return { groupName: item, groupList };
  1022. // });
  1023. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({where: {pid: ctx.session.sessionProject.id}});
  1024. const accountGroupList = unitList.map(item => {
  1025. const groupList = accountList.filter(item1 => item1.company === item.name);
  1026. return {groupName: item.name, companyId: item.id, groupList};
  1027. });
  1028. const categoryData = await ctx.service.category.getAllCategory(ctx.session.sessionProject.id);
  1029. const tenders = await ctx.service.tender.getList('', null, 1);
  1030. const dcTenders = await ctx.service.datacollectTender.getList(projectId);
  1031. await this.layout('setting/datacollect.ejs', {
  1032. projectData,
  1033. dataCollectAudits,
  1034. accountList,
  1035. accountGroup: accountGroupList,
  1036. categoryData,
  1037. tenders,
  1038. dcTenders,
  1039. is_dz1: ['P0505', 'MI22U'].indexOf(ctx.session.sessionProject.code) !== -1 ? 5 : false,
  1040. }, 'setting/datacollect_modal.ejs');
  1041. } catch (error) {
  1042. ctx.helper.log(error);
  1043. ctx.session.postError = error.toString();
  1044. ctx.redirect('/dashboard');
  1045. }
  1046. }
  1047. async dataCollectSave(ctx) {
  1048. try {
  1049. if (ctx.session.sessionUser.is_admin === 0) throw '没有设置权限';
  1050. const projectId = ctx.session.sessionProject.id;
  1051. const responseData = {
  1052. err: 0, msg: '', data: null,
  1053. };
  1054. const data = JSON.parse(ctx.request.body.data);
  1055. if (!data.type) {
  1056. throw '提交数据错误';
  1057. }
  1058. switch (data.type) {
  1059. case 'show':
  1060. responseData.data = await ctx.service.project.update({
  1061. data_collect: data.data_collect,
  1062. data_collect_pages: data.data_collect_pages.join(',')
  1063. }, {id: projectId});
  1064. ctx.session.sessionProject.dataCollect = data.data_collect;
  1065. ctx.session.sessionProject.showDataCollect = data.data_collect ? 1 : 0;
  1066. break;
  1067. case 'add-audit':
  1068. // 判断该用户是否已加入到表中,已加入则提示无需添加
  1069. const auditInfo = await ctx.service.datacollectAudit.getDataByCondition({
  1070. pid: projectId,
  1071. uid: data.id
  1072. });
  1073. if (auditInfo) {
  1074. throw '该用户已存在权限中,无需重复添加';
  1075. }
  1076. // const accountInfo = await ctx.service.projectAccount.getDataById(data.id);
  1077. // const companyInfo = await ctx.service.datacollectAudit.getCompanyInfo(projectId, accountInfo.company_id);
  1078. // if (companyInfo) {
  1079. // throw '该用户所在单位已存在权限中,无需单独添加';
  1080. // }
  1081. await ctx.service.datacollectAudit.saveAudit(projectId, data.id);
  1082. responseData.data = await ctx.service.datacollectAudit.getList(projectId);
  1083. break;
  1084. case 'add-company':
  1085. const companyInfo = await ctx.service.datacollectAudit.getCompanyInfo(projectId, data.id);
  1086. if (companyInfo) {
  1087. throw '该单位已存在权限中,无需重复添加';
  1088. }
  1089. await ctx.service.datacollectAudit.saveCompany(projectId, data.id);
  1090. responseData.data = await ctx.service.datacollectAudit.getList(projectId);
  1091. break;
  1092. case 'del-audit':
  1093. const auditInfo2 = await ctx.service.datacollectAudit.getDataById(data.id);
  1094. if (!auditInfo2) {
  1095. throw '该用户已不存在权限中,移除失败';
  1096. }
  1097. await ctx.service.datacollectAudit.delAudit(data.id);
  1098. responseData.data = await ctx.service.datacollectAudit.getList(projectId);
  1099. break;
  1100. case 'del-group':
  1101. const groupInfo3 = await ctx.service.datacollectAudit.getDataById(data.id);
  1102. if (!groupInfo3) {
  1103. throw '该单位已不存在权限中,移除失败';
  1104. }
  1105. await ctx.service.datacollectAudit.delAudit(data.id);
  1106. responseData.data = await ctx.service.datacollectAudit.getList(projectId);
  1107. break;
  1108. case 'del-company':
  1109. const companyInfo2 = await ctx.service.datacollectAudit.getDataById(data.id);
  1110. if (!companyInfo2) {
  1111. throw '该单位已不存在权限中,移除失败';
  1112. }
  1113. await ctx.service.datacollectAudit.delAudit(data.id);
  1114. responseData.data = await ctx.service.datacollectAudit.getList(projectId);
  1115. break;
  1116. case 'tender':
  1117. if (ctx.session.sessionProject.page_show.addDataCollect !== parseInt(data.add_datacollect)) {
  1118. ctx.session.sessionProject.page_show.addDataCollect = parseInt(data.add_datacollect);
  1119. await ctx.service.project.updatePageshow(projectId);
  1120. }
  1121. await ctx.service.datacollectTender.updateList(projectId, data.tids);
  1122. responseData.data = {
  1123. dcTenders: await ctx.service.datacollectTender.getList(projectId),
  1124. addDatacollect: ctx.session.sessionProject.page_show.addDataCollect,
  1125. };
  1126. break;
  1127. default:
  1128. throw '参数有误';
  1129. }
  1130. ctx.body = responseData;
  1131. } catch (err) {
  1132. this.log(err);
  1133. ctx.body = {err: 1, msg: err.toString(), data: null};
  1134. }
  1135. }
  1136. async manage(ctx) {
  1137. try {
  1138. const projectId = ctx.session.sessionProject.id;
  1139. await this._checkMenu(projectId);
  1140. const projectData = await ctx.service.project.getDataById(projectId);
  1141. if (projectData === null) throw '没有对应的项目数据';
  1142. if (ctx.session.sessionUser.is_admin === 0) throw '没有访问权限';
  1143. const tenderList = await ctx.service.tender.getList('', null, 1);
  1144. const removeTenders = await ctx.service.shenpiAudit.getRemoveTenders(tenderList);
  1145. if (removeTenders.length > 0) {
  1146. ctx.helper._.remove(tenderList, function(n) {
  1147. return removeTenders.indexOf(n.id) !== -1;
  1148. });
  1149. }
  1150. for (const t of tenderList) {
  1151. t.visitor = (await this.ctx.service.tenderTourist.getTourists(t.id)).map(x => { return x.user_name; });
  1152. await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
  1153. }
  1154. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  1155. // 获取所有项目参与者
  1156. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  1157. where: {project_id: ctx.session.sessionProject.id, enable: 1},
  1158. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  1159. });
  1160. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({where: {pid: ctx.session.sessionProject.id}});
  1161. const accountGroupList = unitList.map(item => {
  1162. const groupList = accountList.filter(item1 => item1.company === item.name);
  1163. return {groupName: item.name, groupList};
  1164. });
  1165. const renderData = {
  1166. projectData,
  1167. tenderList,
  1168. auditConst,
  1169. auditType: auditConst.auditType,
  1170. accountList,
  1171. accountGroup: accountGroupList,
  1172. categoryData,
  1173. settingConst,
  1174. measureType: tenderConst.measureType,
  1175. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.setting.manage),
  1176. uid: this.ctx.session.sessionUser.accountId,
  1177. pid: this.ctx.session.sessionProject.id,
  1178. scPermission: scheduleConst.permission,
  1179. };
  1180. renderData.selfCategoryLevel = await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
  1181. await this.layout('setting/manage.ejs', renderData, 'setting/manage_modal.ejs');
  1182. } catch (error) {
  1183. ctx.helper.log(error);
  1184. ctx.redirect('/dashboard');
  1185. }
  1186. }
  1187. async manageTenderSave(ctx) {
  1188. try {
  1189. if (ctx.session.sessionUser.is_admin === 0) throw '没有设置权限';
  1190. const projectId = ctx.session.sessionProject.id;
  1191. const responseData = {
  1192. err: 0, msg: '', data: {},
  1193. };
  1194. const data = JSON.parse(ctx.request.body.data);
  1195. if (!data.type) {
  1196. throw '提交数据错误';
  1197. }
  1198. if (!data.tid) {
  1199. throw '参数有误';
  1200. }
  1201. const tender = await ctx.service.tender.getDataById(data.tid);
  1202. if (!tender) {
  1203. throw '标段不存在';
  1204. }
  1205. const tenderInfo = await ctx.service.tenderInfo.getTenderInfo(tender.id);
  1206. switch (data.type) {
  1207. case 'msg':
  1208. const lastRevise = await ctx.service.ledgerRevise.getLastestRevise(tender.id);
  1209. const revising = (lastRevise && lastRevise.status !== auditConst.revise.status.checked) || false;
  1210. // 获取审批流,游客账号,及投资进度账号信息
  1211. responseData.data.tender = tender;
  1212. responseData.data.revising = revising;
  1213. responseData.data.shenpi = await ctx.service.shenpiAudit.getShenpi(tender.id, tenderInfo);
  1214. const tourists = await ctx.service.tenderTourist.getTourists(tender.id);
  1215. for (const t of tourists) {
  1216. t.permission = await ctx.service.tenderTourist.getTouristPermission(t);
  1217. }
  1218. responseData.data.tourists = tourists;
  1219. responseData.data.scheduleAuditList = ctx.session.sessionProject.page_show.xxjd ? await ctx.service.scheduleAudit.getAllDataByCondition({ where: { tid: tender.id } }) : [];
  1220. responseData.data.constructionAuditList = ctx.session.sessionProject.page_show.openConstruction ? await ctx.service.constructionAudit.getList(tender.id) : [];
  1221. break;
  1222. case 'copy2otu':
  1223. if (data.userType === 'tourist') {
  1224. await ctx.service.tenderTourist.setOtherTender(data.tidList, data.auditList);
  1225. } else if (data.userType === 'schedule') {
  1226. await ctx.service.scheduleAudit.setOtherTender(data.tidList, data.auditList);
  1227. } else if (data.userType === 'construction') {
  1228. await ctx.service.constructionAudit.setOtherTender(data.tidList, data.auditList);
  1229. } else {
  1230. throw '参数有误';
  1231. }
  1232. break;
  1233. default:
  1234. throw '参数有误';
  1235. }
  1236. ctx.body = responseData;
  1237. } catch (err) {
  1238. this.log(err);
  1239. ctx.body = { err: 1, msg: err.toString(), data: null };
  1240. }
  1241. }
  1242. }
  1243. return SettingController;
  1244. };