setting_controller.js 40 KB

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