setting_controller.js 63 KB

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