SysController.cs 28 KB

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