SysController.cs 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763
  1. using EasyCaching.Core;
  2. using Hotline.Application.ExportExcel;
  3. using Hotline.Api.Filter;
  4. using Hotline.Application.Systems;
  5. using Hotline.Caching.Interfaces;
  6. using Hotline.CallCenter.Ivrs;
  7. using Hotline.CallCenter.Tels;
  8. using Hotline.Configurations;
  9. using Hotline.FlowEngine.WorkflowModules;
  10. using Hotline.Orders;
  11. using Hotline.Permissions;
  12. using Hotline.Realtimes;
  13. using Hotline.Repository.SqlSugar.Extensions;
  14. using Hotline.Settings;
  15. using Hotline.Settings.CommonOpinions;
  16. using Hotline.Share.Dtos;
  17. using Hotline.Share.Dtos.Dic;
  18. using Hotline.Share.Dtos.Menu;
  19. using Hotline.Share.Dtos.Order;
  20. using Hotline.Share.Dtos.Settings;
  21. using Hotline.Share.Enums.Settings;
  22. using Hotline.Share.Requests;
  23. using Hotline.Share.Tools;
  24. using Hotline.Users;
  25. using Hotline.YbEnterprise.Sdk;
  26. using MapsterMapper;
  27. using Microsoft.AspNetCore.Authorization;
  28. using Microsoft.AspNetCore.Mvc;
  29. using Microsoft.Extensions.Options;
  30. using NPOI.SS.Formula.Functions;
  31. using SqlSugar;
  32. using StackExchange.Redis;
  33. using Wex.Sdk;
  34. using XF.Domain.Authentications;
  35. using XF.Domain.Cache;
  36. using XF.Domain.Exceptions;
  37. using XF.Domain.Repository;
  38. using XF.Utility.EnumExtensions;
  39. using Hotline.Tools;
  40. using Hotline.Share.Dtos.TrCallCenter;
  41. namespace Hotline.Api.Controllers
  42. {
  43. /// <summary>
  44. /// 系统管理相关接口
  45. /// </summary>
  46. public class SysController : BaseController
  47. {
  48. private readonly IMapper _mapper;
  49. private readonly IRepository<SystemSetting> _systemSettingsRepository;
  50. private readonly ISystemMenuRepository _systemMenuRepository;
  51. private readonly IRepository<SystemDicType> _sysDicTypeRepository;
  52. private readonly IRepository<SystemDicData> _sysDicDataRepository;
  53. private readonly ISystemAreaDomainService _systemAreaDomainService;
  54. private readonly IRepository<SystemArea> _systemAreaRepository;
  55. private readonly ISystemCommonOpinionDomainService _commonOpinionDomainService;
  56. private readonly IRepository<SystemCommonOpinion> _commonOpinionRepository;
  57. private readonly ISessionContext _sessionContext;
  58. private readonly ISystemDicDataCacheManager _systemDicDataCacheManager;
  59. private readonly IRepository<SystemLog> _systemLogRepository;
  60. private readonly ISystemMobilAreaApplication _systemMobilAreaApplication;
  61. private readonly IServiceScopeFactory _serviceScopeFactory;
  62. private readonly IRedisCachingProvider _redisCaching;
  63. private readonly IEasyCachingProvider _easyCaching;
  64. private readonly IOptionsSnapshot<AppConfiguration> _appOptions;
  65. private readonly ISystemLogApplication _systemLogApplication;
  66. private readonly IExportApplication _exportApplication;
  67. private readonly IHybridCachingProvider _hybridCaching;
  68. /// <summary>
  69. /// 系统管理相关接口
  70. /// </summary>
  71. /// <param name="mapper"></param>
  72. /// <param name="systemSettingsRepository"></param>
  73. /// <param name="systemMenuRepository"></param>
  74. /// <param name="sysDicTypeRepository"></param>
  75. /// <param name="sysDicDataRepository"></param>
  76. /// <param name="systemAreaDomainService"></param>
  77. /// <param name="systemAreaRepository"></param>
  78. /// <param name="commonOpinionDomainService"></param>
  79. /// <param name="commonOpinionRepository"></param>
  80. /// <param name="sessionContext"></param>
  81. /// <param name="systemDicDataCacheManager"></param>
  82. /// <param name="systemLogRepository"></param>
  83. /// <param name="systemMobilAreaApplication"></param>
  84. public SysController(
  85. IMapper mapper,
  86. IRepository<SystemSetting> systemSettingsRepository,
  87. ISystemMenuRepository systemMenuRepository,
  88. IRepository<SystemDicType> sysDicTypeRepository,
  89. IRepository<SystemDicData> sysDicDataRepository,
  90. ISystemAreaDomainService systemAreaDomainService,
  91. IRepository<SystemArea> systemAreaRepository,
  92. ISystemCommonOpinionDomainService commonOpinionDomainService,
  93. IRepository<SystemCommonOpinion> commonOpinionRepository,
  94. ISessionContext sessionContext,
  95. ISystemDicDataCacheManager systemDicDataCacheManager,
  96. IRepository<SystemLog> systemLogRepository,
  97. ISystemMobilAreaApplication systemMobilAreaApplication,
  98. IServiceScopeFactory serviceScopeFactory,
  99. IRedisCachingProvider redisCaching,
  100. IEasyCachingProvider easyCaching
  101. ,
  102. IOptionsSnapshot<AppConfiguration> appOptions,
  103. ISystemLogApplication systemLogApplication,
  104. IExportApplication exportApplication,
  105. IHybridCachingProvider hybridCaching)
  106. {
  107. _mapper = mapper;
  108. _systemSettingsRepository = systemSettingsRepository;
  109. _systemMenuRepository = systemMenuRepository;
  110. _sysDicTypeRepository = sysDicTypeRepository;
  111. _sysDicDataRepository = sysDicDataRepository;
  112. _systemAreaDomainService = systemAreaDomainService;
  113. _systemAreaRepository = systemAreaRepository;
  114. _commonOpinionDomainService = commonOpinionDomainService;
  115. _commonOpinionRepository = commonOpinionRepository;
  116. _sessionContext = sessionContext;
  117. _systemDicDataCacheManager = systemDicDataCacheManager;
  118. _systemLogRepository = systemLogRepository;
  119. _systemMobilAreaApplication = systemMobilAreaApplication;
  120. _serviceScopeFactory = serviceScopeFactory;
  121. _redisCaching = redisCaching;
  122. _easyCaching = easyCaching;
  123. _appOptions = appOptions;
  124. _systemLogApplication = systemLogApplication;
  125. _exportApplication = exportApplication;
  126. _hybridCaching = hybridCaching;
  127. }
  128. #region 菜单管理
  129. /// <summary>
  130. /// 获取菜单
  131. /// </summary>
  132. /// <returns></returns>
  133. [Permission(EPermission.GetMenuJson)]
  134. [AllowAnonymous]
  135. [HttpGet("getmenujson")]
  136. public async Task<IReadOnlyList<SystemMenu>> GetMenuJson()
  137. {
  138. //获取菜单树形
  139. return await _systemMenuRepository.GetSystemMenus();
  140. }
  141. /// <summary>
  142. /// 新增菜单
  143. /// </summary>
  144. /// <param name="dto"></param>
  145. /// <returns></returns>
  146. //[Permission(EPermission.AddMenu)]
  147. [HttpPost("add-menu")]
  148. public async Task AddMenu([FromBody] AddMenuDto dto)
  149. {
  150. var menu = _mapper.Map<SystemMenu>(dto);
  151. await _systemMenuRepository.AddAsync(menu, HttpContext.RequestAborted);
  152. }
  153. /// <summary>
  154. /// 修改菜单
  155. /// </summary>
  156. /// <param name="dto"></param>
  157. /// <returns></returns>
  158. //[Permission(EPermission.UpdateMenu)]
  159. [HttpPost("update-menu")]
  160. public async Task UpdateMenu([FromBody] UpdateMenuDto dto)
  161. {
  162. var menu = await _systemMenuRepository.GetAsync(dto.Id, HttpContext.RequestAborted);
  163. if (menu is null)
  164. throw UserFriendlyException.SameMessage("无效菜单");
  165. _mapper.Map(dto, menu);
  166. await _systemMenuRepository.UpdateAsync(menu, HttpContext.RequestAborted);
  167. }
  168. /// <summary>
  169. /// 删除菜单
  170. /// </summary>
  171. /// <param name="id"></param>
  172. /// <returns></returns>
  173. //[Permission(EPermission.RemoveMenu)]
  174. [HttpDelete("removemenu/{id}")]
  175. public async Task RemoveMenu(string id)
  176. {
  177. var menu = await _systemMenuRepository.GetAsync(id, HttpContext.RequestAborted);
  178. if (menu is null)
  179. throw UserFriendlyException.SameMessage("无效菜单");
  180. //检查是否存在下级菜单
  181. var ishavemenu = await _systemMenuRepository.AnyAsync(x => x.ParentId == id);
  182. if (ishavemenu)
  183. throw UserFriendlyException.SameMessage("存在下级菜单,暂时不能删除");
  184. //检查是否存在按钮
  185. //var ishavebutton = await _systemButtonRepository.AnyAsync(x => x.MenuId == id);
  186. //if (ishavebutton)
  187. // throw UserFriendlyException.SameMessage("存在按钮权限,暂时不能删除");
  188. await _systemMenuRepository.RemoveAsync(id, false, HttpContext.RequestAborted);
  189. }
  190. /// <summary>
  191. /// 获取菜单对象
  192. /// </summary>
  193. /// <param name="id"></param>
  194. /// <returns></returns>
  195. [HttpGet("menu/{id}")]
  196. public async Task<SystemMenu> GetMenu(string id)
  197. {
  198. var menu = await _systemMenuRepository.GetAsync(id, HttpContext.RequestAborted);
  199. if (menu is null)
  200. throw UserFriendlyException.SameMessage("无效菜单");
  201. return menu;
  202. }
  203. #region 按钮管理
  204. ///// <summary>
  205. ///// 通过菜单ID获取按钮列表
  206. ///// </summary>
  207. ///// <param name="menuid"></param>
  208. ///// <returns></returns>
  209. //[HttpGet("getbuttonmenu")]
  210. //public async Task<IReadOnlyList<SystemButton>> GetButtonByMenu(string menuid)
  211. //{
  212. // return await _systemButtonRepository.QueryAsync(x => x.MenuId == menuid);
  213. //}
  214. ///// <summary>
  215. ///// 新增按钮
  216. ///// </summary>
  217. ///// <param name="dto"></param>
  218. ///// <returns></returns>
  219. //[HttpPost("add-button")]
  220. //public async Task AddButton([FromBody] AddButtonDto dto)
  221. //{
  222. // var button = _mapper.Map<SystemButton>(dto);
  223. // await _systemButtonRepository.AddAsync(button);
  224. //}
  225. ///// <summary>
  226. ///// 编辑按钮
  227. ///// </summary>
  228. ///// <param name="dto"></param>
  229. ///// <returns></returns>
  230. //[HttpPost("update-button")]
  231. //public async Task UpdateButton([FromBody] UpdateButtonDto dto)
  232. //{
  233. // var button = await _systemButtonRepository.GetAsync(dto.Id, HttpContext.RequestAborted);
  234. // if (button is null)
  235. // throw UserFriendlyException.SameMessage("无效按钮");
  236. // _mapper.Map(dto, button);
  237. // await _systemButtonRepository.UpdateAsync(button);
  238. //}
  239. ///// <summary>
  240. ///// 删除按钮
  241. ///// </summary>
  242. ///// <param name="id"></param>
  243. ///// <returns></returns>
  244. //[HttpDelete("removebutton/{id}")]
  245. //public async Task RemoveButton(string id)
  246. //{
  247. // var button = await _systemButtonRepository.GetAsync(id, HttpContext.RequestAborted);
  248. // if (button is null)
  249. // throw UserFriendlyException.SameMessage("无效按钮");
  250. // await _systemButtonRepository.RemoveAsync(id, false, HttpContext.RequestAborted);
  251. //}
  252. ///// <summary>
  253. ///// 获取按钮对象
  254. ///// </summary>
  255. ///// <param name="id"></param>
  256. ///// <returns></returns>
  257. //[HttpGet("button/{id}")]
  258. //public async Task<SystemButton> GetButton(string id)
  259. //{
  260. // var button = await _systemButtonRepository.GetAsync(id, HttpContext.RequestAborted);
  261. // if (button is null)
  262. // throw UserFriendlyException.SameMessage("无效按钮");
  263. // return button;
  264. //}
  265. #endregion
  266. #endregion
  267. #region 字典管理
  268. /// <summary>
  269. /// 获取字典类型列表
  270. /// </summary>
  271. /// <returns></returns>
  272. [HttpPost("dictype-list")]
  273. public async Task<List<SystemDicType>> GetSysDicType()
  274. {
  275. return await _sysDicTypeRepository.Queryable().ToListAsync();
  276. }
  277. /// <summary>
  278. /// 根据字典类型ID获取字典列表
  279. /// </summary>
  280. /// <param name="dto"></param>
  281. /// <returns></returns>
  282. [HttpGet("dictdata-type")]
  283. public async Task<List<SystemDicData>> GetSysDicData([FromQuery] GetSysDicDataDto dto)
  284. {
  285. return await _sysDicDataRepository.Queryable().Where(x => x.DicTypeId == dto.typeid).OrderBy(x => x.Sort)/*.WhereIF(!string.IsNullOrEmpty(dto.datavalue),x=>x.DicDataValue.Contains(dto.datavalue))*/.ToTreeAsync(x => x.Children, x => x.ParentId, "");
  286. //return await _sysDicDataRepository.Queryable().Where(x => x.DicTypeId == dto.typeid).WhereIF(!string.IsNullOrEmpty(dto.datavalue), x => x.DicDataValue.Contains(dto.datavalue)).WhereIF(!string.IsNullOrEmpty(dto.ParentId), x => x.ParentId == dto.ParentId).ToListAsync();
  287. }
  288. /// <summary>
  289. /// 根据字典类型ID获取字典列表
  290. /// </summary>
  291. /// <param name="dto"></param>
  292. /// <returns></returns>
  293. [HttpPost("dictdata-type/export")]
  294. [LogFilterAlpha("导出日志")]
  295. public async Task<FileStreamResult> GetSysDicDataExport([FromBody] ExportExcelDto<GetSysDicDataDto> dto)
  296. {
  297. var items = await _sysDicDataRepository.Queryable().Where(x => x.DicTypeId == dto.QueryDto.typeid).OrderBy(x => x.Sort).ToTreeAsync(x => x.Children, x => x.ParentId, "");
  298. return _exportApplication.GetExcelFile(dto, items, "字典列表");
  299. }
  300. /// <summary>
  301. /// 根据字典类型Code获取字典列表
  302. /// </summary>
  303. /// <param name="code"></param>
  304. /// <returns></returns>
  305. [HttpGet("dictdata-code/{code}")]
  306. public async Task<List<SystemDicData>> GetSysDicDataByCode(string code)
  307. {
  308. return await _sysDicDataRepository.Queryable().Where(x => x.DicTypeCode == code).OrderBy(x => x.Sort).ToListAsync();
  309. }
  310. /// <summary>
  311. /// 获取字典对象
  312. /// </summary>
  313. /// <param name="id"></param>
  314. /// <returns></returns>
  315. [HttpGet("dicdata/{id}")]
  316. public async Task<SystemDicData> SysDicDataModel(string id)
  317. {
  318. var dicData = await _sysDicDataRepository.GetAsync(id, HttpContext.RequestAborted);
  319. if (dicData is null)
  320. throw UserFriendlyException.SameMessage("无效数据");
  321. return dicData;
  322. }
  323. /// <summary>
  324. /// 新增字典数据
  325. /// </summary>
  326. /// <param name="dto"></param>
  327. /// <returns></returns>
  328. [HttpPost("add-dicdata")]
  329. public async Task AddDicData([FromBody] AddDicDataDto dto)
  330. {
  331. var dicType = await _sysDicTypeRepository.GetAsync(dto.DicTypeId, HttpContext.RequestAborted);
  332. if (dicType is null)
  333. throw UserFriendlyException.SameMessage("无效字典类型");
  334. var dicData = _mapper.Map<SystemDicData>(dto);
  335. dicData.DicTypeCode = dicType.DicTypeCode;
  336. dicData.IsShow = true;
  337. _systemDicDataCacheManager.RemoveSysDicDataCache(dicType.DicTypeCode);
  338. await _sysDicDataRepository.AddAsync(dicData);
  339. }
  340. /// <summary>
  341. /// 修改字典数据
  342. /// </summary>
  343. /// <param name="dto"></param>
  344. /// <returns></returns>
  345. [HttpPost("update-dicdata")]
  346. [LogFilter("修改字典数据")]
  347. public async Task UpdateDicData([FromBody] UpdateDicDataDto dto)
  348. {
  349. var dicData = await _sysDicDataRepository.GetAsync(dto.Id, HttpContext.RequestAborted);
  350. if (dicData is null)
  351. throw UserFriendlyException.SameMessage("无效字典数据");
  352. var dicType = await _sysDicTypeRepository.GetAsync(dto.DicTypeId, HttpContext.RequestAborted);
  353. if (dicType is null)
  354. throw UserFriendlyException.SameMessage("无效字典类型");
  355. _mapper.Map(dto, dicData);
  356. dicData.DicTypeCode = dicType.DicTypeCode;
  357. _systemDicDataCacheManager.RemoveSysDicDataCache(dicType.DicTypeCode);
  358. await _sysDicDataRepository.UpdateAsync(dicData, HttpContext.RequestAborted);
  359. }
  360. /// <summary>
  361. /// 删除字典数据
  362. /// </summary>
  363. /// <param name="id"></param>
  364. /// <returns></returns>
  365. [HttpDelete("delete-dicdata/{id}")]
  366. [LogFilter("删除字典")]
  367. public async Task DeleteDicData(string id)
  368. {
  369. var dicData = await _sysDicDataRepository.GetAsync(id, HttpContext.RequestAborted);
  370. if (dicData is null)
  371. throw UserFriendlyException.SameMessage("无效字典数据");
  372. var chail = await _sysDicDataRepository.AnyAsync(p => p.ParentId == id, HttpContext.RequestAborted);
  373. if (chail == true)
  374. throw UserFriendlyException.SameMessage("存在下级数据,请先删除下级数据!");
  375. var dicType = await _sysDicTypeRepository.GetAsync(dicData.DicTypeId, HttpContext.RequestAborted);
  376. if (dicType != null)
  377. _systemDicDataCacheManager.RemoveSysDicDataCache(dicType.DicTypeCode);
  378. await _sysDicDataRepository.RemoveAsync(dicData, true, HttpContext.RequestAborted);
  379. }
  380. #endregion
  381. #region 行政区划
  382. /// <summary>
  383. /// 获取省市区树形
  384. /// </summary>
  385. /// <returns></returns>
  386. [HttpGet("area/tree")]
  387. public async Task<List<SystemArea>> GetAreaTree()
  388. {
  389. return await _systemAreaDomainService.GetAreaTree(_appOptions.Value.IsZiGong ? 6 : 0);
  390. }
  391. /// <summary>
  392. /// 获取省市区树形 来电弹单界面获取
  393. /// </summary>
  394. /// <returns></returns>
  395. [HttpGet("area/tree_accepted")]
  396. public async Task<List<SystemArea>> GetAreaTree_Accepted()
  397. {
  398. return await _systemAreaDomainService.GetAreaTree(_appOptions.Value.IsZiGong ? 6 : 0, _appOptions.Value.IsLuZhou ? "510500" : "510000");
  399. }
  400. /// <summary>
  401. /// 获取省市区树形
  402. /// </summary>
  403. /// <returns></returns>
  404. [HttpPost("area/tree/export")]
  405. [LogFilterAlpha("导出日志")]
  406. public async Task<FileStreamResult> GetAreaTreeExport([FromBody] ExportExcelDto<string> dto)
  407. {
  408. var items = await _systemAreaDomainService.GetAreaTree(_appOptions.Value.IsZiGong ? 6 : 0);
  409. return _exportApplication.GetExcelFile(dto, items, "行政区域");
  410. }
  411. /// <summary>
  412. /// 新增省市区
  413. /// </summary>
  414. /// <param name="dto"></param>
  415. /// <returns></returns>
  416. [HttpPost("area")]
  417. public async Task AddArea([FromBody] AddAreaDto dto)
  418. {
  419. var model = _mapper.Map<SystemArea>(dto);
  420. if (string.IsNullOrEmpty(model.ParentId) || model.ParentId.Length > 8)
  421. {
  422. throw UserFriendlyException.SameMessage("只允许添加乡镇、街道数据,请选择区县");
  423. }
  424. if (model.ParentId.Substring(4, 2) == "00")
  425. {
  426. throw UserFriendlyException.SameMessage("只允许添加乡镇、街道数据,请选择区县");
  427. }
  428. //验证重复
  429. var area = await _systemAreaRepository.Queryable(includeDeleted: true).FirstAsync(x => x.ParentId == dto.ParentId && x.AreaName == dto.AreaName);
  430. if (area != null)
  431. {
  432. if (area.IsDeleted)
  433. {
  434. area.IsDeleted = false;
  435. await _systemAreaRepository.UpdateAsync(area, HttpContext.RequestAborted);
  436. throw UserFriendlyException.SameMessage("同目录下已存在被删除的相同数据,已重新启用");
  437. }
  438. else
  439. {
  440. throw UserFriendlyException.SameMessage("同目录下已存在相同数据,不能重复添加");
  441. }
  442. }
  443. //生成新Code
  444. model.Id = await _systemAreaDomainService.GenerateNewAreaCodeAsync(dto.ParentId, HttpContext.RequestAborted);
  445. model.IsCanModify = true;
  446. await _systemAreaDomainService.AddArea(model, HttpContext.RequestAborted);
  447. }
  448. /// <summary>
  449. /// 修改省市区
  450. /// </summary>
  451. /// <param name="dto"></param>
  452. /// <returns></returns>
  453. [HttpPut("area")]
  454. public async Task ModifyArea([FromBody] ModifyAreaDto dto)
  455. {
  456. var model = await _systemAreaDomainService.GetArea(dto.Id, HttpContext.RequestAborted);
  457. if (model is null)
  458. throw UserFriendlyException.SameMessage("未知数据,请刷新页面");
  459. if (!model.IsCanModify)
  460. throw UserFriendlyException.SameMessage("系统数据,不能修改");
  461. _mapper.Map(dto, model); //_mapper.Map<SystemArea>(dto);
  462. //验证重复
  463. var area = await _systemAreaRepository.Queryable(includeDeleted: true).Where(x => x.ParentId == dto.ParentId && x.AreaName == dto.AreaName).ToListAsync();
  464. if (area.Count > 1)
  465. {
  466. throw UserFriendlyException.SameMessage("同目录下已存在相同数据,不能修改");
  467. }
  468. await _systemAreaDomainService.ModifyArea(model, HttpContext.RequestAborted);
  469. }
  470. /// <summary>
  471. /// 删除省市区(逻辑)
  472. /// </summary>
  473. /// <param name="id"></param>
  474. /// <returns></returns>
  475. [HttpDelete("area/{id}")]
  476. public async Task DelArea(string id)
  477. {
  478. var model = await _systemAreaDomainService.GetArea(id, HttpContext.RequestAborted);
  479. if (model is null)
  480. throw UserFriendlyException.SameMessage("未知数据,请刷新页面");
  481. if (!model.IsCanModify)
  482. throw UserFriendlyException.SameMessage("系统数据不能删除");
  483. await _systemAreaDomainService.DelArea(id, HttpContext.RequestAborted);
  484. }
  485. /// <summary>
  486. /// 获取区域
  487. /// </summary>
  488. /// <param name="id"></param>
  489. /// <returns></returns>
  490. [HttpGet("area/{id}")]
  491. public async Task<SystemArea?> GetArea(string id)
  492. {
  493. var model = await _systemAreaDomainService.GetArea(id, HttpContext.RequestAborted);
  494. if (model is null)
  495. throw UserFriendlyException.SameMessage("未知数据,请刷新页面");
  496. return model;
  497. }
  498. #endregion
  499. #region 常用意见
  500. #region 个人
  501. /// <summary>
  502. /// 获取常用意见
  503. /// </summary>
  504. /// <returns></returns>
  505. [HttpGet("common-list")]
  506. public async Task<IReadOnlyList<SystemCommonOpinion>> GetCommon([FromQuery] ECommonType commonType, bool isOpen)
  507. {
  508. return await _commonOpinionRepository.Queryable().Where(x => x.CommonType == commonType)
  509. .WhereIF(isOpen == true, x => (x.IsOpen == true || (x.CreatorOrgId == _sessionContext.RequiredOrgId && x.AttributionType == ECommonAttributionType.Org && x.IsOpen == false)))
  510. .WhereIF(isOpen == false, x => x.IsOpen == false && x.CreatorId == _sessionContext.RequiredUserId).ToListAsync();
  511. }
  512. /// <summary>
  513. /// 新增常用意见
  514. /// </summary>
  515. /// <param name="dto"></param>
  516. /// <returns></returns>
  517. [HttpPost("add-common")]
  518. public async Task AddCommon([FromBody] AddCommonDto dto)
  519. {
  520. var entity = _mapper.Map<SystemCommonOpinion>(dto);
  521. await _commonOpinionDomainService.AddCommonOpinion(entity, HttpContext.RequestAborted);
  522. }
  523. /// <summary>
  524. /// 批量删除常用意见
  525. /// </summary>
  526. /// <param name="dto"></param>
  527. /// <returns></returns>
  528. [HttpPost("del-common")]
  529. public async Task DelCommon([FromBody] DelCommonDto dto)
  530. {
  531. await _commonOpinionDomainService.DelCommonOpinion(dto.Ids, HttpContext.RequestAborted);
  532. }
  533. /// <summary>
  534. /// 常用意见页面基础信息
  535. /// </summary>
  536. /// <returns></returns>
  537. [HttpGet("common-basepage")]
  538. public async Task<object> CommonBasePage()
  539. {
  540. var rsp = new
  541. {
  542. CommonType = EnumExts.GetDescriptions<ECommonType>(),
  543. };
  544. return rsp;
  545. }
  546. #endregion
  547. #region 公开
  548. /// <summary>
  549. /// 查询公开常用意见
  550. /// </summary>
  551. /// <returns></returns>
  552. [HttpGet("open-common")]
  553. public async Task<PagedDto<SystemCommonOpinion>> QueryOpenCommonOpinionList([FromQuery] QueryCommonDto dto)
  554. {
  555. var (total, items) = await _commonOpinionRepository.Queryable()
  556. .WhereIF(dto.IsOpen != null, x => x.IsOpen == dto.IsOpen)
  557. .WhereIF(!string.IsNullOrEmpty(dto.UserName), x => x.CreatorName.Contains(dto.UserName))
  558. .WhereIF(dto.CommonType != null, x => x.CommonType == dto.CommonType)
  559. .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
  560. return new PagedDto<SystemCommonOpinion>(total, items);
  561. }
  562. /// <summary>export
  563. /// 查询公开常用意见导出
  564. /// </summary>
  565. /// <param name="dto"></param>
  566. /// <returns></returns>
  567. [HttpPost("open-common/export")]
  568. [LogFilterAlpha("导出日志")]
  569. public async Task<FileStreamResult> QueryOpenCommonOpinionExport([FromBody] ExportExcelDto<QueryCommonDto> dto)
  570. {
  571. var query = _commonOpinionRepository.Queryable()
  572. .WhereIF(dto.QueryDto.IsOpen != null, x => x.IsOpen == dto.QueryDto.IsOpen)
  573. .WhereIF(!string.IsNullOrEmpty(dto.QueryDto.UserName), x => x.CreatorName.Contains(dto.QueryDto.UserName))
  574. .WhereIF(dto.QueryDto.CommonType != null, x => x.CommonType == dto.QueryDto.CommonType);
  575. var total = 0;
  576. var items = new List<SystemCommonOpinion>();
  577. if (dto.IsExportAll)
  578. {
  579. items = await query.ToListAsync(HttpContext.RequestAborted);
  580. }
  581. else
  582. {
  583. (total, items) = await query.ToPagedListAsync(dto.QueryDto.PageIndex, dto.QueryDto.PageSize, HttpContext.RequestAborted);
  584. }
  585. dynamic? dynamicClass = DynamicClassHelper.CreateDynamicClass<SystemCommonOpinionDto>(dto.ColumnInfos);
  586. var dtos = _mapper.Map<ICollection<SystemCommonOpinionDto>>(items)
  587. .Select(stu => _mapper.Map(stu, typeof(SystemCommonOpinionDto), dynamicClass))
  588. .Cast<object>()
  589. .ToList();
  590. var stream = ExcelHelper.CreateStream(dtos);
  591. return ExcelStreamResult(stream, "常用意见管理");
  592. }
  593. /// <summary>
  594. /// 修改公开常用意见
  595. /// </summary>
  596. /// <param name="dto"></param>
  597. /// <returns></returns>
  598. [HttpPost("common-modify")]
  599. public async Task CommonModify([FromBody] CommonModifyDto dto)
  600. {
  601. var model = await _commonOpinionRepository.GetAsync(dto.Id, HttpContext.RequestAborted);
  602. if (model is null)
  603. throw UserFriendlyException.SameMessage("无效数据");
  604. _mapper.Map(dto, model);
  605. await _commonOpinionRepository.UpdateAsync(model, HttpContext.RequestAborted);
  606. }
  607. #endregion
  608. #endregion
  609. #region 日志
  610. /// <summary>
  611. /// 获取日志列表
  612. /// </summary>
  613. /// <param name="dto"></param>
  614. /// <returns></returns>
  615. [HttpGet("log_list")]
  616. public async Task<PagedDto<SystemLogDto>> GetSystemLotItems([FromQuery] SysLogPagedKeywordRequest dto)
  617. {
  618. return (await _systemLogApplication.GetSystemLotItems(dto).ToPagedListAsync(dto)).ToPaged();
  619. }
  620. /// <summary>
  621. /// 获取日志实体
  622. /// </summary>
  623. /// <param name="id"></param>
  624. /// <returns></returns>
  625. [HttpGet("log/{id}")]
  626. public async Task<SystemLogDto> ItemEntity(string id)
  627. {
  628. var log = await _systemLogRepository.Queryable()
  629. .FirstAsync(x => x.Id == id);
  630. return _mapper.Map<SystemLogDto>(log);
  631. }
  632. [HttpPost("log")]
  633. public async Task<string> LogAdd([FromBody] SystemLogDto dto)
  634. {
  635. var log = _mapper.Map<SystemLog>(dto);
  636. return await _systemLogRepository.AddAsync(log, HttpContext.RequestAborted);
  637. }
  638. #endregion
  639. /// <summary>
  640. /// 验证电话外呼是否需要加0
  641. /// </summary>
  642. /// <param name="mobile"></param>
  643. /// <returns></returns>
  644. [HttpGet("vaild_mobile/{mobile}")]
  645. public async Task<string> VaildMobile(string mobile)
  646. {
  647. return await _systemMobilAreaApplication.VaildMobile(mobile);
  648. }
  649. /// <summary>
  650. /// 删除缓存
  651. /// </summary>
  652. /// <param name="dto"></param>
  653. /// <returns></returns>
  654. [HttpPut("cache/remove")]
  655. public async Task<IActionResult> ClearCache([FromBody] CleanCacheInDto dto)
  656. {
  657. foreach (var key in dto.Keys)
  658. {
  659. await _hybridCaching.RemoveAsync(key, HttpContext.RequestAborted);
  660. }
  661. return Ok();
  662. }
  663. /// <summary>
  664. /// 获取所有缓存的Key
  665. /// </summary>
  666. /// <param name="cacheKey">不传默认: Hotline:*</param>
  667. /// <returns></returns>
  668. [HttpGet("cache")]
  669. public async Task<List<string>> GetCache(string cacheKey = "Hotline:*")
  670. {
  671. return await _redisCaching.SearchKeysAsync(cacheKey);
  672. }
  673. /// <summary>
  674. /// 获取缓存
  675. /// </summary>
  676. /// <param name="key"></param>
  677. /// <returns></returns>
  678. [HttpGet("cache/{key}")]
  679. public async Task<List<string>> GetCacheByKey(string key)
  680. {
  681. var cacheResult = new List<string>();
  682. var result = await _easyCaching.GetAsync<object>(key, cancellationToken: HttpContext.RequestAborted);
  683. if (result != null)
  684. {
  685. cacheResult.Add(result.ToJson());
  686. }
  687. var stringResult = await _redisCaching.StringGetAsync(key);
  688. if (stringResult != null)
  689. {
  690. cacheResult.Add(stringResult);
  691. }
  692. return cacheResult;
  693. }
  694. }
  695. }