sub_proj_setting_controller.js 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774
  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. ctx.log(error);
  61. ctx.redirect(`/sp/${ctx.subProject.id}/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. ctx.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. ctx.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(ctx.subProject, 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. ctx.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. ctx.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. ctx.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 user(ctx) {
  190. try {
  191. this.defaultCheck(ctx);
  192. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  193. const filter = {
  194. company: ctx.query.company || '',
  195. keyword: ctx.query.keyword || '',
  196. };
  197. const total = await ctx.service.projectAccount.getSubProjectAccountCount(ctx.subProject, filter);
  198. const subProjectAccountList = await ctx.service.projectAccount.getSubProjectAccountListWithPermission(ctx.subProject, filter);
  199. const subProjectAllAccountList = await ctx.service.projectAccount.getSubProjecAllAccountListWithPermission(ctx.subProject);
  200. const subProjectUnitList = unitList.map(item => {
  201. const users = subProjectAllAccountList.filter(item1 => item1.company === item.name);
  202. return { name: item.name, users };
  203. }).filter(x => { return x.users.length > 0; });
  204. const pageInfo = {
  205. page: ctx.page,
  206. pageSizeSelect: 1,
  207. pageSize: ctx.pageSize,
  208. total_num: total,
  209. total: Math.ceil(total / ctx.pageSize),
  210. queryData: JSON.stringify(ctx.urlInfo.query),
  211. };
  212. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  213. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile', 'company_id'],
  214. where: { project_id: ctx.subProject.project_id },
  215. });
  216. accountList.forEach(x => {
  217. x.sp_exist = subProjectAllAccountList.findIndex(y => { return y.id === x.id; }) >= 0;
  218. });
  219. const accountGroup = unitList.map(item => {
  220. const groupList = accountList.filter(item1 => item1.company === item.name);
  221. return { id: item.id, name: item.name, groupList };
  222. }).filter(x => { return x.groupList.length > 0; });
  223. // const subProjects = await this.ctx.service.subProject.getAllDataByCondition({ where: { project_id: this.ctx.session.sessionProject.id, is_delete: 0 }});
  224. const subProjects = await this.ctx.service.subProject.getSubProjectTreeNodes(this.ctx.session.sessionProject.id,
  225. this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin);
  226. const renderData = {
  227. pageInfo,
  228. accountGroup,
  229. subProjectAccountList,
  230. subProjectUnitList,
  231. subProjectAllAccountList,
  232. keyword: filter.keyword,
  233. company: filter.company,
  234. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.setting.sp_permission),
  235. permissionBlock: ctx.service.subProjPermission.PermissionBlock,
  236. accountList,
  237. subProjects,
  238. };
  239. await this.layout('sp_setting/user.ejs', renderData, 'sp_setting/user_modal.ejs');
  240. } catch (error) {
  241. ctx.log(error);
  242. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  243. }
  244. }
  245. /*
  246. view 查看 1 file_permission
  247. upload 上传/引用 2 file_permission
  248. editfile 编辑文件 4 file_permission
  249. filing 文件类别编辑 3 file_permission
  250. */
  251. async permission(ctx) {
  252. try {
  253. this.defaultCheck(ctx);
  254. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  255. const filter = {
  256. keyword: ctx.query.keyword || '',
  257. };
  258. const permissionConst = this.service.subProjPermission.PermissionConst;
  259. const subProjectAccountList = await ctx.service.projectAccount.getSubProjecAllAccountListWithPermission(ctx.subProject, filter);
  260. const subProjectAllAccountList = await ctx.service.projectAccount.getSubProjecAllAccountListWithPermission(ctx.subProject);
  261. const subProjectUnitList = unitList.map(item => {
  262. const users = subProjectAccountList.filter(item1 => item1.company === item.name);
  263. return { name: item.name, users };
  264. }).filter(x => { return x.users.length > 0; });
  265. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  266. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile', 'company_id'],
  267. where: { project_id: ctx.subProject.project_id },
  268. });
  269. accountList.forEach(x => {
  270. x.sp_exist = subProjectAllAccountList.findIndex(y => { return y.id === x.id; }) >= 0;
  271. });
  272. const accountGroup = unitList.map(item => {
  273. const groupList = accountList.filter(item1 => item1.company === item.name);
  274. return { id: item.id, name: item.name, groupList };
  275. }).filter(x => { return x.groupList.length > 0; });
  276. const relaBlock = ctx.service.subProjPermission.getRelaPermissionBlock(ctx.query.ptype);
  277. const subProjects = await this.ctx.service.subProject.getAllDataByCondition({ where: { project_id: this.ctx.session.sessionProject.id, is_folder: 0, is_delete: 0 } });
  278. const renderData = {
  279. ptype: ctx.query.ptype,
  280. ptypeStr: relaBlock ? relaBlock.name : '',
  281. ptypeHint: relaBlock && relaBlock.hint ? relaBlock.hint : '',
  282. accountGroup,
  283. subProjectAccountList,
  284. subProjectAllAccountList,
  285. subProjectUnitList,
  286. keyword: filter.keyword,
  287. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.setting.sp_permission),
  288. permissionBlock: ctx.service.subProjPermission.PermissionBlock,
  289. permissionConst: permissionConst[ctx.query.ptype],
  290. accountList,
  291. subProjects,
  292. };
  293. await this.layout('sp_setting/permission.ejs', renderData, 'sp_setting/user_modal.ejs');
  294. } catch (error) {
  295. ctx.log(error);
  296. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  297. }
  298. }
  299. async permissionUpdate(ctx) {
  300. try {
  301. this.defaultCheck(ctx);
  302. const data = JSON.parse(ctx.request.body.data);
  303. const result = await ctx.service.subProjPermission.updatePermission(ctx.subProject, data);
  304. ctx.body = { err: 0, msg: '', data: result };
  305. } catch (err) {
  306. ctx.log(err);
  307. ctx.ajaxErrorBody(err, '更新账号权限失败');
  308. }
  309. }
  310. async dataRange(ctx) {
  311. try {
  312. this.defaultCheck(ctx);
  313. const moduleKey = ctx.query.module || 'file';
  314. const moduleInfo = ctx.service.subProjDataRange.getModule(moduleKey);
  315. const result = await Promise.all([
  316. ctx.service.subProjDataRange.getRangeTree(ctx.subProject),
  317. ctx.service.subProjDataRange.getRangeConfig(ctx.subProject.id, moduleKey),
  318. ]);
  319. const renderData = {
  320. moduleKey,
  321. moduleInfo,
  322. moduleList: ctx.service.subProjDataRange.getModuleList(),
  323. rangeTree: result[0].tree,
  324. unassignedUsers: result[0].unassignedUsers,
  325. rangeConfig: result[1],
  326. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.setting.sp_data_range),
  327. };
  328. await this.layout('sp_setting/data_range.ejs', renderData, 'sp_setting/data_range_modal.ejs');
  329. } catch (error) {
  330. ctx.log(error);
  331. ctx.session.postError = error.toString();
  332. ctx.redirect(`/sp/${ctx.subProject.id}/setting/user`);
  333. }
  334. }
  335. async dataRangeUpdate(ctx) {
  336. try {
  337. this.defaultCheck(ctx);
  338. const data = JSON.parse(ctx.request.body.data);
  339. const moduleKey = data.module_key || 'file';
  340. const result = await ctx.service.subProjDataRange.saveRange(
  341. ctx.subProject,
  342. moduleKey,
  343. data.ranges,
  344. ctx.session.sessionUser.accountId
  345. );
  346. ctx.body = { err: 0, msg: '', data: result };
  347. } catch (err) {
  348. ctx.log(err);
  349. ctx.ajaxErrorBody(err, '保存数据范围失败');
  350. }
  351. }
  352. async logs(ctx) {
  353. try {
  354. this.defaultCheck(ctx);
  355. // 获取项目数据
  356. const settingType = ctx.params.type ? parseInt(ctx.params.type) : 0;
  357. const logs = await ctx.service.projectLog.getLogs(ctx.subProject.id, settingType);
  358. const renderData = {
  359. officeList,
  360. projectLog,
  361. settingType,
  362. logs,
  363. };
  364. await this.layout('sp_setting/logs.ejs', renderData);
  365. } catch (error) {
  366. ctx.log(error);
  367. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  368. }
  369. }
  370. async fun(ctx) {
  371. try {
  372. await this.defaultCheck(ctx);
  373. const funRela = this.ctx.subProject.fun_rela;
  374. const fun_set = this.ctx.subProject.fun_set;
  375. const renderData = {
  376. funRela,
  377. imType,
  378. endMonth: funSet.endMonth,
  379. funSet: fun_set,
  380. };
  381. await this.layout('sp_setting/fun.ejs', renderData, 'sp_setting/fun_modal.ejs');
  382. } catch (error) {
  383. ctx.log(error);
  384. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  385. }
  386. }
  387. /**
  388. * 保存功能设置相关
  389. * @param ctx
  390. * @return {Promise<void>}
  391. */
  392. async updateFun(ctx) {
  393. try {
  394. await this.defaultCheck(ctx);
  395. const data = JSON.parse(ctx.request.body.data);
  396. if (data) ctx.request.body = data;
  397. const rule = ctx.service.subProject.rule('fun');
  398. ctx.validate(rule);
  399. if (data.addFunSet && Object.prototype.hasOwnProperty.call(data.addFunSet, 'change_plan_name')) {
  400. if (typeof data.addFunSet.change_plan_name !== 'string') throw '变更方案名称格式错误';
  401. data.addFunSet.change_plan_name = data.addFunSet.change_plan_name.trim();
  402. if (data.addFunSet.change_plan_name.length > 5) throw '变更方案名称字符不能超过5个';
  403. }
  404. const result = await ctx.service.subProject.updateFunRela(ctx.subProject.id, ctx.request.body);
  405. if (!result) throw '保存数据失败';
  406. this.ctx.subProject.page_show.openChangeProject = data.openChangeProject ? 1 : 0;
  407. this.ctx.subProject.page_show.openChangeApply = data.openChangeApply ? 1 : 0;
  408. this.ctx.subProject.page_show.openChangePlan = data.openChangePlan ? 1 : 0;
  409. this.ctx.subProject.page_show.openChangeWhiteList = data.openChangeWhiteList ? 1 : 0;
  410. this.ctx.subProject.page_show.openChangeState = data.openChangeState ? 1 : 0;
  411. this.ctx.subProject.page_show.openMaterialTax = data.openMaterialTax ? 1 : 0;
  412. this.ctx.subProject.page_show.openMaterialChecklist = data.openMaterialChecklist ? 1 : 0;
  413. this.ctx.subProject.page_show.openMaterialSelf = data.openMaterialSelf ? 1 : 0;
  414. this.ctx.subProject.page_show.openMaterialEditForAudit = data.openMaterialEditForAudit ? 1 : 0;
  415. this.ctx.subProject.page_show.openStageStart = data.openStageStart ? 1 : 0;
  416. this.ctx.subProject.page_show.openMaterialStageRepeat = data.openMaterialStageRepeat ? 1 : 0;
  417. this.ctx.subProject.page_show.openMaterialListQty = data.openMaterialListQty ? 1 : 0;
  418. this.ctx.subProject.page_show.openContractExpr = data.openContractExpr ? 1 : 0;
  419. this.ctx.subProject.page_show.correctCalcContractTp = data.correctCalcContractTp ? 1 : 0;
  420. this.ctx.subProject.page_show.close1stStageCheckDealParam = data.close1stStageCheckDealParam ? 1 : 0;
  421. this.ctx.subProject.page_show.openMultiStageCalc = data.openMultiStageCalc ? 1 : 0;
  422. this.ctx.subProject.page_show.closeWapYfSf = data.closeWapYfSf ? 1 : 0;
  423. this.ctx.subProject.page_show.openStageAudit = data.openStageAudit ? 1 : 0;
  424. this.ctx.subProject.page_show.stageAuditEarly = data.stageAuditEarly || 0;
  425. this.ctx.subProject.page_show.stageAuditWorry = data.stageAuditWorry || 0;
  426. this.ctx.subProject.page_show.posCalcDetail = data.posCalcDetail ? 1 : 0;
  427. const result2 = await ctx.service.subProject.updatePageshow(ctx.subProject.id);
  428. if (!result2) throw '保存数据失败';
  429. if (data.addFunSet) {
  430. const funSet = ctx.subProject.fun_set;
  431. ctx.helper._.defaultsDeep(data.addFunSet, funSet);
  432. const result3 = await ctx.service.subProject.updateFunSet(ctx.subProject.id, data.addFunSet);
  433. if (!result3) throw '保存数据失败';
  434. }
  435. ctx.body = { err: 0, msg: '', data: null };
  436. } catch (error) {
  437. ctx.log(error);
  438. this.ajaxErrorBody(error, '保存数据失败');
  439. }
  440. }
  441. async dataCollect(ctx) {
  442. try {
  443. this.defaultCheck(ctx);
  444. if (!ctx.subProject.page_show.openDataCollect) {
  445. throw '该功能已关闭或无法查看';
  446. }
  447. ctx.subProject.data_collect_pages = ctx.subProject.data_collect_pages ? ctx.subProject.data_collect_pages.split(',') : [];
  448. if (ctx.session.sessionUser.is_admin === 0) throw '没有访问权限';
  449. const dataCollectAudits = await ctx.service.subProjPermission.getDatacollectAuditList(ctx.subProject.id);
  450. // 获取所有项目参与者
  451. const accountList = await ctx.service.projectAccount.getAllSubProjectAccount(ctx.subProject);
  452. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  453. const accountGroupList = unitList.map(item => {
  454. const groupList = accountList.filter(item1 => item1.company === item.name);
  455. return { groupName: item.name, companyId: item.id, groupList };
  456. }).filter(x => { return x.groupList.length > 0; });
  457. const categoryData = await ctx.service.category.getAllCategory(ctx.subProject);
  458. const tenders = await ctx.service.tender.getList('', null, 1);
  459. const dcTenders = await ctx.service.datacollectTender.getList(ctx.subProject.project_id, ctx.subProject.id);
  460. const is_dz2 = ['P0505', 'P0506', 'P1201', 'P1202', 'GY18Y', 'GYJJ1', 'P1103', 'KLG25', 'I2U5B', 'SEN48'].indexOf(ctx.session.sessionProject.code) !== -1 ? 6 : false;
  461. const is_dzcb = ['P0505', 'P0506', 'P1201', 'P1202', 'GY18Y', 'Y3T2Q'].indexOf(ctx.session.sessionProject.code) !== -1 ? 7 : false;// 成本管理定制大屏
  462. const is_dztz = ['P0505', 'P0506', 'P1201', 'P1202', 'GY18Y', 'Y3T2Q'].indexOf(ctx.session.sessionProject.code) !== -1 ? 8 : false;// 投资总控定制大屏
  463. const renderData = {
  464. dataCollectAudits,
  465. accountList,
  466. accountGroup: accountGroupList,
  467. categoryData,
  468. tenders,
  469. dcTenders,
  470. is_dz1: ['P0505', 'MI22U'].indexOf(ctx.session.sessionProject.code) !== -1 ? 5 : false,
  471. is_dz2,
  472. is_dzcb,
  473. is_dztz,
  474. selfCategoryLevel: await ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId),
  475. };
  476. if (is_dz2) {
  477. const projectData = await this.ctx.service.project.getDataById(ctx.subProject.project_id);
  478. // 获取分类及对应值
  479. if (!ctx.subProject.common_json) {
  480. ctx.subProject.common_json = await ctx.service.subProject.updateCommonJsonDaping06(ctx.subProject, projectData);
  481. }
  482. const commonJson = ctx.subProject.common_json ? JSON.parse(ctx.subProject.common_json) : null;
  483. renderData.daPing06Set = commonJson && commonJson.daPing06_set ? commonJson.daPing06_set : ctx.helper._.cloneDeep(projectSettingConst.daPing06Set);
  484. }
  485. if (is_dztz) {
  486. const commonJson = ctx.subProject.common_json ? JSON.parse(ctx.subProject.common_json) : null;
  487. renderData.daPing08Set = commonJson && commonJson.daPing08_set ? commonJson.daPing08_set : ctx.helper._.cloneDeep(projectSettingConst.daPing08Set);
  488. }
  489. await this.layout('sp_setting/datacollect.ejs', renderData, 'sp_setting/datacollect_modal.ejs');
  490. } catch (error) {
  491. ctx.log(error);
  492. ctx.session.postError = error.toString();
  493. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  494. }
  495. }
  496. async dataCollectSave(ctx) {
  497. try {
  498. this.defaultCheck(ctx);
  499. const responseData = {
  500. err: 0, msg: '', data: null,
  501. };
  502. const data = JSON.parse(ctx.request.body.data);
  503. if (!data.type) {
  504. throw '提交数据错误';
  505. }
  506. let uids;
  507. let auditList = [];
  508. switch (data.type) {
  509. case 'show':
  510. responseData.data = await ctx.service.subProject.update({
  511. data_collect: data.data_collect,
  512. data_collect_pages: data.data_collect_pages.join(','),
  513. }, { id: ctx.subProject.id });
  514. ctx.subProject.data_collect = data.data_collect;
  515. ctx.subProject.showDataCollect = data.data_collect ? 1 : 0;
  516. break;
  517. case 'add-audit':
  518. uids = data.id instanceof Array ? data.id : [data.id];
  519. // 判断该用户是否已加入到表中,已加入则提示无需添加
  520. auditList = await ctx.service.subProjPermission.getDatacollectAuditList(ctx.subProject.id, uids);
  521. const addAidList = ctx.helper._.difference(uids, ctx.helper._.map(auditList, 'uid'));
  522. if (addAidList.length === 0) {
  523. throw '用户已存在权限中,无需重复添加';
  524. }
  525. // await ctx.service.datacollectAudit.saveAudit(ctx.subProject.project_id, data.id);
  526. await ctx.service.subProjPermission.saveDatacollectPermissionAudits(ctx.subProject.id, addAidList, 'add');
  527. responseData.data = await ctx.service.subProjPermission.getDatacollectAuditList(ctx.subProject.id);
  528. break;
  529. case 'del-audit':
  530. uids = data.id instanceof Array ? data.id : [data.id];
  531. auditList = await ctx.service.subProjPermission.getDatacollectAuditList(ctx.subProject.id, uids);
  532. if (auditList.length !== uids.length) {
  533. throw '该用户已不存在权限中,移除失败';
  534. }
  535. await ctx.service.subProjPermission.saveDatacollectPermissionAudits(ctx.subProject.id, uids, 'del');
  536. responseData.data = await ctx.service.subProjPermission.getDatacollectAuditList(ctx.subProject.id);
  537. break;
  538. case 'tender':
  539. if (ctx.subProject.page_show.addDataCollect !== parseInt(data.add_datacollect)) {
  540. ctx.subProject.page_show.addDataCollect = parseInt(data.add_datacollect);
  541. await ctx.service.subProject.updatePageshow(ctx.subProject.id);
  542. }
  543. await ctx.service.datacollectTender.updateList(ctx.subProject.project_id, data.tids);
  544. responseData.data = {
  545. dcTenders: await ctx.service.datacollectTender.getList(ctx.subProject.project_id, ctx.subProject.id),
  546. addDatacollect: ctx.subProject.page_show.addDataCollect,
  547. };
  548. break;
  549. case 'save-dp06':
  550. responseData.data = await ctx.service.subProject.saveCommonJson(ctx.subProject.id, 'daPing06_set', data.daPing06Set);
  551. break;
  552. case 'save-dp08':
  553. responseData.data = await ctx.service.subProject.saveCommonJson(ctx.subProject.id, 'daPing08_set', data.daPing08Set);
  554. break;
  555. default:
  556. throw '参数有误';
  557. }
  558. ctx.body = responseData;
  559. } catch (err) {
  560. ctx.log(err);
  561. ctx.body = { err: 1, msg: err.toString(), data: null };
  562. }
  563. }
  564. async manage(ctx) {
  565. try {
  566. this.defaultCheck(ctx);
  567. const projectId = ctx.session.sessionProject.id;
  568. const projectData = await ctx.service.project.getDataById(projectId);
  569. if (projectData === null) throw '没有对应的项目数据';
  570. if (ctx.session.sessionUser.is_admin === 0) throw '没有访问权限';
  571. // 默认过滤完工的标段即显示build的标段
  572. const { done = '1' } = ctx.query || {};
  573. const buildStatusFilter = ctx.service.tender.db.format(' AND build_status = ?', [tenderConst.buildStatus.status.build]);
  574. const tenderList = await ctx.service.tender.getList('', null, 1, done === '1' ? buildStatusFilter : '');
  575. const removeTenders = await ctx.service.shenpiAudit.getRemoveTenders(tenderList);
  576. if (removeTenders.length > 0) {
  577. ctx.helper._.remove(tenderList, function(n) {
  578. return removeTenders.indexOf(n.id) !== -1;
  579. });
  580. }
  581. // for (const t of tenderList) {
  582. // t.visitor = (await this.ctx.service.tenderTourist.getTourists(t.id)).map(x => { return x.user_name; });
  583. // await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
  584. // }
  585. // todo 自定义分类移动到子项目内部后,在整个项目上没有分类了
  586. const categoryData = await ctx.service.category.getAllCategory(ctx.subProject);
  587. // const categoryData = []; // await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  588. // 获取所有项目参与者
  589. const accountList = await ctx.service.projectAccount.getAllSubProjectAccount(ctx.subProject);
  590. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  591. const accountGroupList = unitList.map(item => {
  592. const groupList = accountList.filter(item1 => item1.company === item.name);
  593. return { groupName: item.name, groupList };
  594. }).filter(x => { return x.groupList.length > 0; });
  595. // console.log(accountGroupList);
  596. // 获取项目列表
  597. // const subProjects = await ctx.service.subProject.getAllDataByCondition({ where: { project_id: projectId, is_folder: 0, is_delete: 0 } });
  598. const subProjects = await ctx.service.subProject.getSubProject(projectId, ctx.session.sessionUser.accountId, ctx.session.sessionUser.is_admin);
  599. const renderData = {
  600. projectData,
  601. tenderList,
  602. auditConst,
  603. auditType: auditConst.auditType,
  604. accountList,
  605. accountGroup: accountGroupList,
  606. categoryData,
  607. settingConst,
  608. measureType: tenderConst.measureType,
  609. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.setting.sp_manage),
  610. uid: this.ctx.session.sessionUser.accountId,
  611. pid: this.ctx.session.sessionProject.id,
  612. spid: ctx.subProject.id,
  613. scPermission: scheduleConst.permission,
  614. change_type_list: shenpiConst.change_type_list,
  615. contract_type_list: shenpiConst.contract_type_list,
  616. subProjects,
  617. };
  618. const permissionKey = ['quality', 'inspection', 'safe_inspection', 'safe_payment', 'schedule'];
  619. renderData.selfCategoryLevel = await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
  620. renderData.permissionConst = ctx.service.tenderPermission.partPermissionConst(permissionKey);
  621. renderData.permissionBlock = ctx.service.tenderPermission.partPermissionBlock(permissionKey);
  622. await this.layout('sp_setting/manage.ejs', renderData, 'sp_setting/manage_modal.ejs');
  623. } catch (error) {
  624. ctx.log(error);
  625. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  626. }
  627. }
  628. async manageTenderSave(ctx) {
  629. try {
  630. this.defaultCheck(ctx);
  631. if (ctx.session.sessionUser.is_admin === 0) throw '没有设置权限';
  632. const projectId = ctx.session.sessionProject.id;
  633. const responseData = {
  634. err: 0, msg: '', data: {},
  635. };
  636. const data = JSON.parse(ctx.request.body.data);
  637. if (!data.type) {
  638. throw '提交数据错误';
  639. }
  640. // 单个tenderPermission字段用这个
  641. // const permissionKey = ['quality', 'inspection', 'safe_inspection', 'safe_payment'];
  642. const permissionKey = ['schedule'];
  643. // 多个tenderPermission字段融合处理用这个
  644. const tPsKeys = {
  645. quality: ['quality', 'inspection'],
  646. safe: ['safe_inspection', 'safe_payment'],
  647. };
  648. switch (data.type) {
  649. case 'msg':
  650. if (!data.tid) {
  651. throw '参数有误';
  652. }
  653. const tender = await ctx.service.tender.getDataById(data.tid);
  654. if (!tender) {
  655. throw '标段不存在';
  656. }
  657. const tenderInfo = await ctx.service.tenderInfo.getTenderInfo(tender.id);
  658. const lastRevise = await ctx.service.ledgerRevise.getLastestRevise(tender.id);
  659. const revising = (lastRevise && lastRevise.status !== auditConst.revise.status.checked) || false;
  660. // 获取审批流,游客账号,及投资进度账号信息
  661. responseData.data.tender = tender;
  662. responseData.data.revising = revising;
  663. responseData.data.shenpi = await ctx.service.shenpiAudit.getShenpi(tender.id, tenderInfo);
  664. const tourists = await ctx.service.tenderTourist.getTourists(tender.id);
  665. for (const t of tourists) {
  666. t.permission = await ctx.service.tenderTourist.getTouristPermission(t);
  667. }
  668. responseData.data.tourists = tourists;
  669. // responseData.data.scheduleAuditList = await ctx.service.scheduleAudit.getAllDataByCondition({ where: { tid: tender.id } });
  670. responseData.data.contractAuditList = await ctx.service.contractAudit.getList({ tid: tender.id });
  671. responseData.data.constructionAuditList = await ctx.service.constructionAudit.getList(tender.id);
  672. for (const key of permissionKey) {
  673. responseData.data[`${key}AuditList`] = await ctx.service.tenderPermission.getPartsPermission(tender.id, [key]);
  674. }
  675. for (const tpsKey in tPsKeys) {
  676. responseData.data[`${tpsKey}AuditList`] = await ctx.service.tenderPermission.getPartsPermission(tender.id, tPsKeys[tpsKey]);
  677. }
  678. break;
  679. case 'copy2otu':
  680. if (data.userType === 'tourist') {
  681. await ctx.service.tenderTourist.setOtherTender(data.tidList, data.auditList);
  682. // } else if (data.userType === 'schedule') {
  683. // await ctx.service.scheduleAudit.setOtherTender(data.tidList, data.auditList);
  684. } else if (data.userType === 'contract') {
  685. await ctx.service.contractAudit.setOtherTender(data.tidList, data.auditList);
  686. } else if (data.userType === 'construction') {
  687. await ctx.service.constructionAudit.setOtherTender(data.tidList, data.auditList);
  688. } else if (permissionKey.includes(data.userType)) {
  689. await ctx.service.tenderPermission.setOtherTender(data.tidList, data.auditList, [data.userType]);
  690. } else if (Object.keys(tPsKeys).includes(data.userType)) {
  691. await ctx.service.tenderPermission.setOtherTender(data.tidList, data.auditList, tPsKeys[data.userType]);
  692. } else {
  693. throw '参数有误';
  694. }
  695. break;
  696. case 'noSp-tenders':
  697. responseData.data = await ctx.service.tender.getNoSpTenders(projectId);
  698. break;
  699. case 'bind-sp':
  700. if (!data.spid || !data.tidList) {
  701. throw '参数有误';
  702. }
  703. if (data.tidList.split(',').length === 0) {
  704. throw '参数有误';
  705. }
  706. responseData.data = await ctx.service.tender.bindSp(projectId, data.spid, data.tidList.split(','));
  707. break;
  708. case 'get-category':
  709. responseData.data = await ctx.service.category.getAllCategory({ id: data.spid });
  710. break;
  711. default:
  712. throw '参数有误';
  713. }
  714. ctx.body = responseData;
  715. } catch (err) {
  716. ctx.log(err);
  717. ctx.body = { err: 1, msg: err.toString(), data: null };
  718. }
  719. }
  720. }
  721. return SettingController;
  722. };