SysController.cs 26 KB

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