setting_controller.js 48 KB

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