sub_proj_setting_controller.js 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433
  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').projectSettingMenu;
  15. const projectLog = require('../const/project_log');
  16. const imType = require('../const/tender').imType;
  17. const path = require('path');
  18. const funSet = require('../const/fun_set');
  19. const projectSettingConst = require('../const/project_setting');
  20. const shenpiConst = require('../const/shenpi');
  21. module.exports = app => {
  22. class SettingController extends app.BaseController {
  23. /**
  24. * 构造函数
  25. *
  26. * @param {Object} ctx - egg全局context
  27. * @return {void}
  28. */
  29. constructor(ctx) {
  30. super(ctx);
  31. ctx.subMenu = JSON.parse(JSON.stringify(settingMenu));
  32. for (const index in ctx.subMenu) {
  33. const menu = ctx.subMenu[index];
  34. menu.url = `/sp/${ctx.subProject.id}` + menu.url;
  35. }
  36. }
  37. async defaultCheck(ctx) {
  38. if (!ctx.subProject) throw '没有对应的项目数据';
  39. if (ctx.session.sessionUser.is_admin === 0) throw '没有访问权限';
  40. }
  41. /**
  42. * 项目设置 -- 自定义标段分类(Get)
  43. *
  44. * @param ctx
  45. * @return {Promise<void>}
  46. */
  47. async category(ctx) {
  48. try {
  49. this.defaultCheck(ctx);
  50. // 获取项目数据
  51. const categoryData = await ctx.service.category.getAllCategory(ctx.subProject);
  52. const tenderData = await ctx.service.tender.getList('', null, 1);
  53. const renderData = {
  54. categoryType: settingConst.cType,
  55. categoryData,
  56. tenderData,
  57. };
  58. await this.layout('sp_setting/category.ejs', renderData, 'sp_setting/category_modal.ejs');
  59. } catch (error) {
  60. console.log(error);
  61. ctx.redirect('/dashboard');
  62. }
  63. }
  64. /**
  65. * 新增分类(Ajax)
  66. *
  67. * @param ctx
  68. * @return {Promise<void>}
  69. */
  70. async addCategory(ctx) {
  71. try {
  72. const responseData = {
  73. err: 0, msg: '', data: null,
  74. };
  75. const data = JSON.parse(ctx.request.body.data);
  76. if (!data.name) {
  77. throw '提交数据错误';
  78. }
  79. responseData.data = await ctx.service.category.addCategory(ctx.subProject, data.name, settingConst.cType.key.dropDown);
  80. ctx.body = responseData;
  81. } catch (err) {
  82. this.log(err);
  83. ctx.body = {err: 1, msg: err.toString(), data: null};
  84. }
  85. }
  86. /**
  87. * 编辑分类(Ajax)
  88. *
  89. * @param ctx
  90. * @return {Promise<void>}
  91. */
  92. async updateCategory(ctx) {
  93. try {
  94. const responseData = {err: 0, msg: '', data: null};
  95. const data = JSON.parse(ctx.request.body.data);
  96. if (!data.id) {
  97. throw '提交数据错误';
  98. }
  99. if (data.name) {
  100. const count = await ctx.service.category.count({spid: ctx.subProject.id, name: data.name});
  101. if (count >= 1) {
  102. throw '存在同名类别';
  103. }
  104. }
  105. const result = await ctx.service.category.update(data, {id: data.id});
  106. if (!result) {
  107. throw '提交数据失败';
  108. }
  109. responseData.data = await ctx.service.category.getCategory(data.id);
  110. ctx.body = responseData;
  111. } catch (err) {
  112. this.log(err);
  113. ctx.body = {err: 1, msg: err.toString(), data: null};
  114. }
  115. }
  116. async setCategoryValue(ctx) {
  117. try {
  118. const responseData = {err: 0, msg: '', data: {}};
  119. const data = JSON.parse(ctx.request.body.data);
  120. if (!data.id) {
  121. throw '提交数据错误';
  122. }
  123. await ctx.service.categoryValue.setCategoryValue(data.id, data.updateValue);
  124. responseData.data.category = await ctx.service.category.getCategory(data.id);
  125. // todo 查询标段
  126. responseData.data.tenders = await ctx.service.tender.getList('', null, 1);
  127. ctx.body = responseData;
  128. } catch (err) {
  129. this.log(err);
  130. ctx.body = {err: 1, msg: err instanceof String ? err : '提交数据失败', data: null};
  131. }
  132. }
  133. /**
  134. * 删除分类(Ajax)
  135. *
  136. * @param ctx
  137. * @return {Promise<void>}
  138. */
  139. async deleteCategory(ctx) {
  140. try {
  141. const responseData = {
  142. err: 0, msg: '', data: null,
  143. };
  144. const data = JSON.parse(ctx.request.body.data);
  145. if (!data.id) {
  146. throw '提交数据错误';
  147. }
  148. await ctx.service.category.deleteCategory(ctx.subProject, data.id);
  149. ctx.body = responseData;
  150. } catch (err) {
  151. this.log(err);
  152. ctx.body = {err: 1, msg: err.toString(), data: null};
  153. }
  154. }
  155. /**
  156. * 调整分类层次排序(Ajax)
  157. *
  158. * @param ctx
  159. * @return {Promise<void>}
  160. */
  161. async resetCategoryLevel(ctx) {
  162. try {
  163. const responseData = {
  164. err: 0, msg: '', data: null,
  165. };
  166. const data = JSON.parse(ctx.request.body.data);
  167. await ctx.service.category.resetCategoryLevel(data);
  168. responseData.data = await ctx.service.category.getAllCategory(ctx.subProject);
  169. ctx.body = responseData;
  170. } catch (err) {
  171. this.log(err);
  172. ctx.body = {err: 1, msg: err.toString(), data: null};
  173. }
  174. }
  175. async selfCategoryLevel(ctx) {
  176. try {
  177. const data = JSON.parse(ctx.request.body.data);
  178. await ctx.service.subProjPermission.defaultUpdate({
  179. self_category_level: data.self_category_level || ''
  180. }, { where: { spid: ctx.subProject.id, uid: ctx.session.sessionUser.accountId}});
  181. ctx.body = {
  182. err: 0, msg: '', data: null,
  183. };
  184. } catch (err) {
  185. ctx.log(err);
  186. ctx.ajaxErrorBody(err, '保存自定义分类失败');
  187. }
  188. }
  189. async logs(ctx) {
  190. try {
  191. this.defaultCheck(ctx);
  192. // 获取项目数据
  193. const settingType = ctx.params.type ? parseInt(ctx.params.type) : 0;
  194. const logs = await ctx.service.projectLog.getLogs(ctx.subProject.id, settingType);
  195. const renderData = {
  196. officeList,
  197. projectLog,
  198. settingType,
  199. logs,
  200. };
  201. await this.layout('sp_setting/logs.ejs', renderData);
  202. } catch (error) {
  203. console.log(error);
  204. ctx.redirect('/dashboard');
  205. }
  206. }
  207. async fun(ctx) {
  208. try {
  209. this.defaultCheck(ctx);
  210. const funRela = await ctx.service.subProject.getFunRela(ctx.subProject);
  211. const fun_set = await ctx.service.subProject.getFunSet(ctx.subProject.fun_set);
  212. await this.layout('sp_setting/fun.ejs', {
  213. funRela,
  214. imType,
  215. endMonth: funSet.endMonth,
  216. funSet: fun_set,
  217. }, 'sp_setting/fun_modal.ejs');
  218. } catch (error) {
  219. ctx.helper.log(error);
  220. ctx.redirect('/dashboard');
  221. }
  222. }
  223. /**
  224. * 保存功能设置相关
  225. * @param ctx
  226. * @returns {Promise<void>}
  227. */
  228. async updateFun(ctx) {
  229. try {
  230. this.defaultCheck(ctx);
  231. const data = JSON.parse(ctx.request.body.data);
  232. if (data) ctx.request.body = data;
  233. const rule = ctx.service.subProject.rule('fun');
  234. ctx.validate(rule);
  235. const result = await ctx.service.subProject.updateFunRela(ctx.subProject, ctx.request.body);
  236. if (!result) throw '保存数据失败';
  237. this.ctx.session.sessionProject.page_show.openChangeProject = data.openChangeProject ? 1 : 0;
  238. this.ctx.session.sessionProject.page_show.openChangeApply = data.openChangeApply ? 1 : 0;
  239. this.ctx.session.sessionProject.page_show.openChangePlan = data.openChangePlan ? 1 : 0;
  240. this.ctx.session.sessionProject.page_show.openChangeWhiteList = data.openChangeWhiteList ? 1 : 0;
  241. this.ctx.session.sessionProject.page_show.openChangeState = data.openChangeState ? 1 : 0;
  242. this.ctx.session.sessionProject.page_show.openMaterialTax = data.openMaterialTax ? 1 : 0;
  243. this.ctx.session.sessionProject.page_show.openMaterialChecklist = data.openMaterialChecklist ? 1 : 0;
  244. this.ctx.session.sessionProject.page_show.openMaterialSelf = data.openMaterialSelf ? 1 : 0;
  245. this.ctx.session.sessionProject.page_show.openMaterialEditForAudit = data.openMaterialEditForAudit ? 1 : 0;
  246. this.ctx.session.sessionProject.page_show.openStageStart = data.openStageStart ? 1 : 0;
  247. const result2 = await ctx.service.subProject.updatePageshow(ctx.subProject);
  248. if (!result2) throw '保存数据失败';
  249. if (data.addFunSet) {
  250. const funSet = ctx.subProject.fun_set ? JSON.parse(ctx.subProject.fun_set) : {};
  251. ctx.helper._.defaultsDeep(data.addFunSet, funSet);
  252. const result3 = await ctx.service.subProject.updateFunSet(ctx.subProject, data.addFunSet);
  253. if (!result3) throw '保存数据失败';
  254. }
  255. ctx.body = {err: 0, msg: '', data: null};
  256. } catch (error) {
  257. ctx.helper.log(error);
  258. this.ajaxErrorBody(error, '保存数据失败');
  259. }
  260. }
  261. async dataCollect(ctx) {
  262. try {
  263. this.defaultCheck(ctx);
  264. if (!ctx.session.sessionProject.page_show.openDataCollect) {
  265. throw '该功能已关闭或无法查看';
  266. }
  267. ctx.subProject.data_collect_pages = ctx.subProject.data_collect_pages ? ctx.subProject.data_collect_pages.split(',') : [];
  268. ctx.session.sessionProject.dataCollect = ctx.subProject.data_collect;
  269. if (ctx.session.sessionUser.is_admin === 0) throw '没有访问权限';
  270. const dataCollectAudits = await ctx.service.datacollectAudit.getList(ctx.subProject.project_id);
  271. // 获取所有项目参与者
  272. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  273. where: {project_id: ctx.session.sessionProject.id, enable: 1},
  274. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  275. });
  276. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({where: {pid: ctx.session.sessionProject.id}});
  277. const accountGroupList = unitList.map(item => {
  278. const groupList = accountList.filter(item1 => item1.company === item.name);
  279. return {groupName: item.name, companyId: item.id, groupList};
  280. });
  281. const categoryData = await ctx.service.category.getAllCategory(ctx.subProject);
  282. const tenders = await ctx.service.tender.getList('', null, 1);
  283. const dcTenders = await ctx.service.datacollectTender.getList(ctx.subProject.project_id);
  284. const is_dz2 = ['P0505', 'P0506', 'P1201', 'P1202', 'GY18Y', 'GYJJ1', 'P1103'].indexOf(ctx.session.sessionProject.code) !== -1 ? 6 : false;
  285. const renderData = {
  286. dataCollectAudits,
  287. accountList,
  288. accountGroup: accountGroupList,
  289. categoryData,
  290. tenders,
  291. dcTenders,
  292. is_dz1: ['P0505', 'MI22U'].indexOf(ctx.session.sessionProject.code) !== -1 ? 5 : false,
  293. is_dz2,
  294. };
  295. if (is_dz2) {
  296. const projectData = await this.ctx.service.project.getDataById(ctx.subProject.project_id);
  297. // 获取分类及对应值
  298. const commonJson = projectData.common_json ? JSON.parse(projectData.common_json) : null;
  299. renderData.daPing06Set = commonJson && commonJson.daPing06_set ? commonJson.daPing06_set : ctx.helper._.cloneDeep(projectSettingConst.daPing06Set);
  300. }
  301. await this.layout('sp_setting/datacollect.ejs', renderData, 'sp_setting/datacollect_modal.ejs');
  302. } catch (error) {
  303. ctx.helper.log(error);
  304. ctx.session.postError = error.toString();
  305. ctx.redirect('/dashboard');
  306. }
  307. }
  308. async dataCollectSave(ctx) {
  309. try {
  310. this.defaultCheck(ctx);
  311. const responseData = {
  312. err: 0, msg: '', data: null,
  313. };
  314. const data = JSON.parse(ctx.request.body.data);
  315. if (!data.type) {
  316. throw '提交数据错误';
  317. }
  318. switch (data.type) {
  319. case 'show':
  320. responseData.data = await ctx.service.subProject.update({
  321. data_collect: data.data_collect,
  322. data_collect_pages: data.data_collect_pages.join(','),
  323. }, {id: ctx.subProject.id});
  324. ctx.subProject.dataCollect = data.data_collect;
  325. ctx.subProject.showDataCollect = data.data_collect ? 1 : 0;
  326. break;
  327. case 'add-audit':
  328. // 判断该用户是否已加入到表中,已加入则提示无需添加
  329. const auditInfo = await ctx.service.datacollectAudit.getDataByCondition({
  330. pid: ctx.subProject.project_id,
  331. uid: data.id
  332. });
  333. if (auditInfo) {
  334. throw '该用户已存在权限中,无需重复添加';
  335. }
  336. await ctx.service.datacollectAudit.saveAudit(ctx.subProject.project_id, data.id);
  337. responseData.data = await ctx.service.datacollectAudit.getList(ctx.subProject.project_id);
  338. break;
  339. case 'add-company':
  340. const companyInfo = await ctx.service.datacollectAudit.getCompanyInfo(ctx.subProject.project_id, data.id);
  341. if (companyInfo) {
  342. throw '该单位已存在权限中,无需重复添加';
  343. }
  344. await ctx.service.datacollectAudit.saveCompany(ctx.subProject.project_id, data.id);
  345. responseData.data = await ctx.service.datacollectAudit.getList(ctx.subProject.project_id);
  346. break;
  347. case 'del-audit':
  348. const auditInfo2 = await ctx.service.datacollectAudit.getDataById(data.id);
  349. if (!auditInfo2) {
  350. throw '该用户已不存在权限中,移除失败';
  351. }
  352. await ctx.service.datacollectAudit.delAudit(data.id);
  353. responseData.data = await ctx.service.datacollectAudit.getList(ctx.subProject.project_id);
  354. break;
  355. case 'del-group':
  356. const groupInfo3 = await ctx.service.datacollectAudit.getDataById(data.id);
  357. if (!groupInfo3) {
  358. throw '该单位已不存在权限中,移除失败';
  359. }
  360. await ctx.service.datacollectAudit.delAudit(data.id);
  361. responseData.data = await ctx.service.datacollectAudit.getList(projectId);
  362. break;
  363. case 'del-company':
  364. const companyInfo2 = await ctx.service.datacollectAudit.getDataById(data.id);
  365. if (!companyInfo2) {
  366. throw '该单位已不存在权限中,移除失败';
  367. }
  368. await ctx.service.datacollectAudit.delAudit(data.id);
  369. responseData.data = await ctx.service.datacollectAudit.getList(projectId);
  370. break;
  371. case 'tender':
  372. if (ctx.session.sessionProject.page_show.addDataCollect !== parseInt(data.add_datacollect)) {
  373. ctx.session.sessionProject.page_show.addDataCollect = parseInt(data.add_datacollect);
  374. await ctx.service.project.updatePageshow(projectId);
  375. }
  376. await ctx.service.datacollectTender.updateList(projectId, data.tids);
  377. responseData.data = {
  378. dcTenders: await ctx.service.datacollectTender.getList(projectId),
  379. addDatacollect: ctx.session.sessionProject.page_show.addDataCollect,
  380. };
  381. break;
  382. case 'save-dp06':
  383. responseData.data = await ctx.service.project.saveCommonJson(projectId, 'daPing06_set', data.daPing06Set);
  384. break;
  385. default:
  386. throw '参数有误';
  387. }
  388. ctx.body = responseData;
  389. } catch (err) {
  390. this.log(err);
  391. ctx.body = {err: 1, msg: err.toString(), data: null};
  392. }
  393. }
  394. }
  395. return SettingController;
  396. };