QualityController.cs 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607
  1. using Hotline.Caching.Interfaces;
  2. using MapsterMapper;
  3. using XF.Domain.Authentications;
  4. using XF.Domain.Repository;
  5. using Hotline.Quality;
  6. using Hotline.Permissions;
  7. using Hotline.Repository.SqlSugar.Extensions;
  8. using Hotline.Settings;
  9. using Hotline.Share.Dtos;
  10. using Hotline.Share.Dtos.File;
  11. using Microsoft.AspNetCore.Mvc;
  12. using XF.Domain.Exceptions;
  13. using Hotline.Share.Dtos.Quality;
  14. using Hotline.Share.Dtos.Order;
  15. using Hotline.Share.Enums.Quality;
  16. using Hotline.Share.Enums.Order;
  17. using XF.Utility.EnumExtensions;
  18. using System.Xml.Linq;
  19. using System.Threading;
  20. using Hotline.CallCenter.Calls;
  21. using Hotline.Application.Quality;
  22. using Microsoft.AspNetCore.Authorization;
  23. using Hotline.Orders;
  24. using Hotline.Ai.Quality;
  25. namespace Hotline.Api.Controllers
  26. {
  27. public class QualityController : BaseController
  28. {
  29. private readonly ISessionContext _sessionContext;
  30. private readonly IMapper _mapper;
  31. private readonly IQualityRepository _qualitey;
  32. private readonly IRepository<QualityDetail> _qualiteyDetail;
  33. private readonly IRepository<QualityItem> _qualiteyItem;
  34. private readonly IRepository<QualityTemplate> _qualityTemplate;
  35. private readonly IRepository<QualityTemplateDetail> _qualiteyTemplateDetail;
  36. private readonly IRepository<QualityProhibited> _qualiteyProhibited;
  37. private readonly ISystemDicDataCacheManager _systemDicDataCacheManager;
  38. private readonly IRepository<TrCallRecord> _trCallRecordRepository;
  39. private readonly IQualityApplication _qualityApplication;
  40. private readonly IOrderRepository _orderRepository;
  41. private readonly IAiQualityService _aiQualityService;
  42. public QualityController(
  43. ISessionContext sessionContext,
  44. IMapper mapper,
  45. IQualityRepository qualitey,
  46. IRepository<Quality.QualityDetail> qualiteyDetail,
  47. IRepository<QualityItem> qualiteyItem,
  48. IRepository<QualityTemplate> qualityTemplate,
  49. IRepository<QualityTemplateDetail> qualiteyTemplateDetail,
  50. IRepository<QualityProhibited> qualiteyProhibited,
  51. ISystemDicDataCacheManager systemDicDataCacheManager,
  52. IRepository<TrCallRecord> trCallRecordRepository,
  53. IQualityApplication qualityApplication,
  54. IOrderRepository orderRepository,
  55. IAiQualityService aiQualityService
  56. )
  57. {
  58. _sessionContext = sessionContext;
  59. _mapper = mapper;
  60. _qualitey = qualitey;
  61. _qualiteyDetail = qualiteyDetail;
  62. _qualiteyItem = qualiteyItem;
  63. _qualityTemplate = qualityTemplate;
  64. _qualiteyTemplateDetail = qualiteyTemplateDetail;
  65. _qualiteyProhibited = qualiteyProhibited;
  66. _systemDicDataCacheManager = systemDicDataCacheManager;
  67. _trCallRecordRepository = trCallRecordRepository;
  68. _qualityApplication = qualityApplication;
  69. _orderRepository = orderRepository;
  70. _aiQualityService = aiQualityService;
  71. }
  72. #region 质检管理
  73. /// <summary>
  74. /// 删除质检
  75. /// </summary>
  76. /// <param name="dto"></param>
  77. /// <returns></returns>
  78. [HttpDelete]
  79. public async Task Delete([FromBody] DeleteQualityDto dto)
  80. {
  81. foreach (var Id in dto.Ids)
  82. {
  83. await _qualitey.RemoveAsync(x => x.Id == Id);
  84. List<QualityDetail> details = await _qualiteyDetail.Queryable().Where(x => x.QualityId == Id).ToListAsync();
  85. await _qualiteyDetail.RemoveRangeAsync(details, HttpContext.RequestAborted);
  86. }
  87. }
  88. /// <summary>
  89. /// 更新质检
  90. /// </summary>
  91. /// <param name="dto"></param>
  92. /// <returns></returns>
  93. [Permission(EPermission.UpdateQuality)]
  94. [HttpPut]
  95. public async Task Update([FromBody] UpdateQualityDto dto)
  96. {
  97. await _qualityApplication.UpdateQualityAsync(dto, HttpContext.RequestAborted);
  98. }
  99. /// <summary>
  100. /// 获取质检列表
  101. /// </summary>
  102. /// <param name="dto"></param>
  103. /// <returns></returns>
  104. [HttpGet("list")]
  105. public async Task<PagedDto<QualityDto>> List([FromQuery] QualityListDto dto)
  106. {
  107. var (total, items) = await _qualitey.Queryable()
  108. .Includes(x => x.Order)
  109. .Includes(x => x.Visit)
  110. .Includes(x => x.Visit,e=>e.Employee)
  111. .Includes(x => x.QualityDetails)
  112. .WhereIF(!string.IsNullOrEmpty(dto.Keyword), x => x.Order.Title.Contains(dto.Keyword!) || x.Order.No.Contains(dto.Keyword!))
  113. .WhereIF(dto.State.HasValue, x => x.State == dto.State)
  114. .WhereIF(dto.Source.HasValue, x=> x.Source == dto.Source)
  115. .WhereIF(dto.Source.HasValue && dto.Source == EQualitySource.Accepted, x=> !string.IsNullOrEmpty(x.Order.CallId))
  116. .WhereIF(dto.Source.HasValue && dto.Source == EQualitySource.Visit, x => !string.IsNullOrEmpty(x.Visit.CallId))
  117. .WhereIF(dto.CreationTimeStart.HasValue, x => x.CreationTime >= dto.CreationTimeStart)
  118. .WhereIF(dto.CreationTimeEnd.HasValue, x => x.CreationTime <= dto.CreationTimeEnd)
  119. .OrderByDescending(x => x.CreationTime)
  120. .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
  121. return new PagedDto<QualityDto>(total, _mapper.Map<IReadOnlyList<QualityDto>>(items));
  122. }
  123. /// <summary>
  124. /// 获取质检实体
  125. /// </summary>
  126. /// <param name="id"></param>
  127. /// <returns></returns>
  128. [HttpGet("{id}")]
  129. public async Task<QualityDto> Entity(string id)
  130. {
  131. var quality = await _qualitey.Queryable()
  132. .Includes(x => x.Order)
  133. .Includes(x => x.Visit)
  134. .Includes(x => x.Visit, e => e.Employee)
  135. .Includes(x => x.QualityDetails)
  136. .FirstAsync(x => x.Id == id);
  137. var qualityDto = _mapper.Map<QualityDto>(quality);
  138. if (qualityDto.Order != null) {
  139. var call = await _trCallRecordRepository.Queryable().Where(x => x.CallAccept == qualityDto.Order.CallId).FirstAsync();
  140. if (call != null) qualityDto.Order.RecordingFileUrl = call.RecordingFileUrl;
  141. }
  142. if (qualityDto.Visit != null)
  143. {
  144. var call = await _trCallRecordRepository.Queryable().Where(x => x.CallAccept == qualityDto.Visit.CallId).FirstAsync();
  145. if (call != null) qualityDto.Visit.RecordingFileUrl = call.RecordingFileUrl;
  146. }
  147. return qualityDto;
  148. }
  149. #endregion
  150. #region 质检项管理
  151. /// <summary>
  152. /// 新增项目
  153. /// </summary>
  154. /// <param name="dtos"></param>
  155. /// <returns></returns>
  156. [Permission(EPermission.AddQualityItem)]
  157. [HttpPost("item")]
  158. public async Task Add([FromBody] QualityItemAddDto dto)
  159. {
  160. var count = await _qualiteyItem.CountAsync(x => x.Name == dto.Name);
  161. if (count > 0)
  162. throw UserFriendlyException.SameMessage("质检项目名称已存在");
  163. var model = _mapper.Map<QualityItem>(dto);
  164. await _qualiteyItem.AddAsync(model, HttpContext.RequestAborted);
  165. }
  166. ///// <summary>
  167. ///// 删除项目
  168. ///// </summary>
  169. ///// <param name="dto"></param>
  170. ///// <returns></returns>
  171. //[Permission(EPermission.DeleteQualityItem)]
  172. //[HttpDelete("item")]
  173. //public async Task Delete([FromBody] QualityItemDeleteDto dto)
  174. //{
  175. // await _qualiteyItem.RemoveAsync(x => x.Id == dto.Id);
  176. //}
  177. /// <summary>
  178. /// 删除项目
  179. /// </summary>
  180. /// <param name="dto"></param>
  181. /// <returns></returns>
  182. [Permission(EPermission.DeleteQualityItem)]
  183. [HttpDelete("itemBatch")]
  184. public async Task Delete([FromBody] QualityItemBatchDeleteDto dto)
  185. {
  186. List<QualityItem> items = await _qualiteyItem.Queryable().In(x => x.Id, dto.Ids).ToListAsync();
  187. foreach (var item in items)
  188. {
  189. var detail = await _qualiteyDetail.Queryable().Where(x => x.Name == item.Name).AnyAsync();
  190. //质检中已存在不可以删
  191. if (detail) items.Remove(item);
  192. }
  193. if (items.Any())
  194. {
  195. await _qualiteyItem.RemoveRangeAsync(items, true, HttpContext.RequestAborted);
  196. var tempItems = await _qualiteyTemplateDetail.Queryable().In(x => x.ItemId, items.Select(x => x.Id)).ToListAsync(HttpContext.RequestAborted);
  197. if (tempItems.Any()) await _qualiteyTemplateDetail.RemoveRangeAsync(tempItems, HttpContext.RequestAborted);
  198. }
  199. }
  200. /// <summary>
  201. /// 更新项目
  202. /// </summary>
  203. /// <param name="dto"></param>
  204. /// <returns></returns>
  205. [Permission(EPermission.UpdateQualityItem)]
  206. [HttpPut("item")]
  207. public async Task Update([FromBody] QualityItemUpdateDto dto)
  208. {
  209. var item = await _qualiteyItem.GetAsync(dto.Id, HttpContext.RequestAborted);
  210. if (item is null)
  211. throw UserFriendlyException.SameMessage("无效质检项目");
  212. if (item.IsEnable != dto.IsEnable || item.Name != dto.Name) {
  213. var detail = await _qualiteyDetail.Queryable().Where(x => x.Name == item.Name && !x.IsDeleted).AnyAsync();
  214. if(detail) throw UserFriendlyException.SameMessage("质检项目在中心质检中已使用,不能修改状态和名称!");
  215. }
  216. _mapper.Map(dto, item);
  217. item.LastModificationName = _sessionContext.UserName;
  218. await _qualiteyItem.UpdateAsync(item, HttpContext.RequestAborted);
  219. }
  220. /// <summary>
  221. /// 获取项目列表
  222. /// </summary>
  223. /// <param name="dto"></param>
  224. /// <returns></returns>
  225. [Permission(EPermission.QualityItemList)]
  226. [HttpGet("item/list")]
  227. public async Task<PagedDto<QualityItemDto>> List([FromQuery] QualityItemListDto dto)
  228. {
  229. var (total, items) = await _qualiteyItem.Queryable()
  230. .WhereIF(!string.IsNullOrEmpty(dto.Name), d => d.Name.Contains(dto.Name!))
  231. .WhereIF(!string.IsNullOrEmpty(dto.GroupingName), d => d.GroupingName.Contains(dto.GroupingName!))
  232. .WhereIF(dto.IsEnable.HasValue,d=>d.IsEnable == dto.IsEnable)
  233. .OrderByDescending(x => x.CreationTime)
  234. .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
  235. return new PagedDto<QualityItemDto>(total, _mapper.Map<IReadOnlyList<QualityItemDto>>(items));
  236. }
  237. /// <summary>
  238. /// 获取项目实体
  239. /// </summary>
  240. /// <param name="id"></param>
  241. /// <returns></returns>
  242. [HttpGet("item/{id}")]
  243. public async Task<QualityItem> ItemEntity(string id)
  244. {
  245. return await _qualiteyItem.Queryable()
  246. .FirstAsync(x => x.Id == id);
  247. }
  248. #endregion
  249. #region 质检模版管理
  250. /// <summary>
  251. /// 新增模版
  252. /// </summary>
  253. /// <param name="dtos"></param>
  254. /// <returns></returns>
  255. [Permission(EPermission.AddQualityTemplate)]
  256. [HttpPost("template")]
  257. public async Task Add([FromBody] TemplateAddDto dto)
  258. {
  259. var groupingCount = await _qualityTemplate.CountAsync(x => x.Grouping == dto.Grouping && x.IsEnable == 1);
  260. if (groupingCount > 0 && dto.IsEnable == 1)
  261. throw UserFriendlyException.SameMessage("当前已存在");
  262. var names = dto.TemplateDetails.Select(x => x.ItemId).ToList();
  263. var nameCount= names.GroupBy(x => x).Count(c => c.Count() > 1);
  264. if (nameCount > 0)
  265. throw UserFriendlyException.SameMessage("质检模版存在重复质检项");
  266. var model = _mapper.Map<QualityTemplate>(dto);
  267. var id = await _qualityTemplate.AddAsync(model, HttpContext.RequestAborted);
  268. if (!string.IsNullOrEmpty(id))
  269. {
  270. foreach (var item in dto.TemplateDetails)
  271. {
  272. item.TemplateId = id;
  273. }
  274. List<QualityTemplateDetail> details = _mapper.Map<List<QualityTemplateDetail>>(dto.TemplateDetails);
  275. await _qualiteyTemplateDetail.AddRangeAsync(details, HttpContext.RequestAborted);
  276. }
  277. }
  278. /// <summary>
  279. /// 删除模版
  280. /// </summary>
  281. /// <param name="dto"></param>
  282. /// <returns></returns>
  283. [Permission(EPermission.DeleteQualityTemplate)]
  284. [HttpDelete("template")]
  285. public async Task Delete([FromBody] TemplateDeleteDto dto)
  286. {
  287. await _qualityTemplate.RemoveAsync(x => x.Id == dto.Id);
  288. List<QualityTemplateDetail> details = await _qualiteyTemplateDetail.Queryable().Where(x => x.TemplateId == dto.Id).ToListAsync();
  289. await _qualiteyTemplateDetail.RemoveRangeAsync(details, HttpContext.RequestAborted);
  290. }
  291. /// <summary>
  292. /// 删除模版
  293. /// </summary>
  294. /// <param name="dto"></param>
  295. /// <returns></returns>
  296. [Permission(EPermission.DeleteQualityTemplate)]
  297. [HttpDelete("templateBatch")]
  298. public async Task Delete([FromBody] TemplateBatchDeleteDto dto)
  299. {
  300. List<QualityTemplate> templates = await _qualityTemplate.Queryable().In(x=>x.Id,dto.Ids).ToListAsync();
  301. List<QualityTemplateDetail> details = await _qualiteyTemplateDetail.Queryable().In(x => x.TemplateId,dto.Ids).ToListAsync();
  302. await _qualityTemplate.RemoveRangeAsync(templates, HttpContext.RequestAborted);
  303. await _qualiteyTemplateDetail.RemoveRangeAsync(details, HttpContext.RequestAborted);
  304. }
  305. /// <summary>
  306. /// 更新模版
  307. /// </summary>
  308. /// <param name="dto"></param>
  309. /// <returns></returns>
  310. [Permission(EPermission.UpdateQualityTemplate)]
  311. [HttpPut("template")]
  312. public async Task Update([FromBody] TemplateUpdateDto dto)
  313. {
  314. var template = await _qualityTemplate.GetAsync(dto.Id, HttpContext.RequestAborted);
  315. if (template is null)
  316. throw UserFriendlyException.SameMessage("无效质检模版");
  317. var groupingCount = await _qualityTemplate.CountAsync(x => x.Grouping == dto.Grouping && x.Id != dto.Id && x.IsEnable == 1);
  318. if (groupingCount > 0)
  319. throw UserFriendlyException.SameMessage("当前质检分类已存在");
  320. _mapper.Map(dto, template);
  321. template.LastModificationName = _sessionContext.UserName;
  322. await _qualityTemplate.UpdateAsync(template, HttpContext.RequestAborted);
  323. if (dto.TemplateDetails.Any())
  324. {
  325. List<QualityTemplateDetail> details = await _qualiteyTemplateDetail.Queryable().Where(x => x.TemplateId == dto.Id).ToListAsync();
  326. await _qualiteyTemplateDetail.RemoveRangeAsync(details, HttpContext.RequestAborted);
  327. foreach (var item in dto.TemplateDetails)
  328. {
  329. item.TemplateId = dto.Id;
  330. }
  331. List<QualityTemplateDetail> newDetails = _mapper.Map<List<QualityTemplateDetail>>(dto.TemplateDetails);
  332. await _qualiteyTemplateDetail.AddRangeAsync(newDetails, HttpContext.RequestAborted);
  333. }
  334. }
  335. /// <summary>
  336. /// 获取模版列表
  337. /// </summary>
  338. /// <param name="dto"></param>
  339. /// <returns></returns>
  340. [Permission(EPermission.QualityTemplateList)]
  341. [HttpGet("template/list")]
  342. public async Task<PagedDto<QualityTemplateDto>> List([FromQuery] TemplateListDto dto)
  343. {
  344. var (total, items) = await _qualityTemplate.Queryable()
  345. .Includes(x => x.templateDetails)
  346. .Includes(x=>x.templateDetails,y=>y.QualityItem)
  347. .WhereIF(!string.IsNullOrEmpty(dto.Name), d => d.Name.Contains(dto.Name!))
  348. .WhereIF(dto.Grouping.HasValue, d => d.Grouping == dto.Grouping)
  349. .WhereIF(dto.IsEnable.HasValue, d => d.IsEnable == dto.IsEnable)
  350. .OrderByDescending(x => x.CreationTime)
  351. .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
  352. return new PagedDto<QualityTemplateDto>(total, _mapper.Map<IReadOnlyList<QualityTemplateDto>>(items));
  353. }
  354. /// <summary>
  355. /// 获取模版实体
  356. /// </summary>
  357. /// <param name="id"></param>
  358. /// <returns></returns>
  359. [HttpGet("template/{id}")]
  360. public async Task<QualityTemplateDto> TemplateEntity(string id)
  361. {
  362. var template = await _qualityTemplate.Queryable()
  363. .Includes(x => x.templateDetails)
  364. .Includes(x => x.templateDetails, y => y.QualityItem)
  365. .FirstAsync(x => x.Id == id);
  366. return _mapper.Map<QualityTemplateDto>(template);
  367. }
  368. /// <summary>
  369. /// 启禁用
  370. /// </summary>
  371. /// <param name="dto"></param>
  372. /// <returns></returns>
  373. [Permission(EPermission.EnableQualityTemplate)]
  374. [HttpPut("template/enable")]
  375. public async Task Enable([FromBody] TemplateUpdateDto dto)
  376. {
  377. var template = await _qualityTemplate.GetAsync(dto.Id, HttpContext.RequestAborted);
  378. var groupingCount = await _qualityTemplate.CountAsync(x => x.Grouping == dto.Grouping && x.Id != dto.Id && x.IsEnable == 1);
  379. if (groupingCount > 0)
  380. throw UserFriendlyException.SameMessage("当前质检分类已存在");
  381. if (template is null)
  382. throw UserFriendlyException.SameMessage("无效质检模版");
  383. _mapper.Map(dto, template);
  384. await _qualityTemplate.UpdateAsync(template, HttpContext.RequestAborted);
  385. }
  386. #endregion
  387. #region 质检词库管理
  388. /// <summary>
  389. /// 新增违禁词
  390. /// </summary>
  391. /// <param name="dtos"></param>
  392. /// <returns></returns>
  393. [Permission(EPermission.AddQualityProhibited)]
  394. [HttpPost("prohibited")]
  395. public async Task Add([FromBody] ProhibitedAddDto dto)
  396. {
  397. var model = _mapper.Map<QualityProhibited>(dto);
  398. await _qualiteyProhibited.AddAsync(model, HttpContext.RequestAborted);
  399. }
  400. /// <summary>
  401. /// 删除违禁词
  402. /// </summary>
  403. /// <param name="dto"></param>
  404. /// <returns></returns>
  405. [Permission(EPermission.DeleteQualityProhibited)]
  406. [HttpDelete("prohibited")]
  407. public async Task Delete([FromBody] ProhibitedDeleteDto dto)
  408. {
  409. await _qualiteyProhibited.RemoveAsync(x => x.Id == dto.Id);
  410. }
  411. /// <summary>
  412. /// 删除违禁词
  413. /// </summary>
  414. /// <param name="dto"></param>
  415. /// <returns></returns>
  416. [Permission(EPermission.DeleteQualityProhibited)]
  417. [HttpDelete("prohibitedBatch")]
  418. public async Task Delete([FromBody] ProhibitedBatchDeleteDto dto)
  419. {
  420. List<QualityProhibited> prohibiteds = await _qualiteyProhibited.Queryable().In(x=>x.Id,dto.Ids).ToListAsync();
  421. await _qualiteyProhibited.RemoveRangeAsync(prohibiteds, HttpContext.RequestAborted);
  422. }
  423. /// <summary>
  424. /// 更新违禁词
  425. /// </summary>
  426. /// <param name="dto"></param>
  427. /// <returns></returns>
  428. [Permission(EPermission.UpdateQualityProhibited)]
  429. [HttpPut("prohibited")]
  430. public async Task Update([FromBody] ProhibitedUpdateDto dto)
  431. {
  432. var prohibited = await _qualiteyProhibited.GetAsync(dto.Id, HttpContext.RequestAborted);
  433. if (prohibited is null)
  434. throw UserFriendlyException.SameMessage("无效质检模版");
  435. _mapper.Map(dto, prohibited);
  436. prohibited.LastModificationName = _sessionContext.UserName;
  437. await _qualiteyProhibited.UpdateAsync(prohibited, HttpContext.RequestAborted);
  438. }
  439. /// <summary>
  440. /// 获取违禁词列表
  441. /// </summary>
  442. /// <param name="dto"></param>
  443. /// <returns></returns>
  444. [Permission(EPermission.QualityProhibitedList)]
  445. [HttpGet("prohibited/list")]
  446. public async Task<PagedDto<QualityProhibitedDto>> List([FromQuery] ProhibitedListDto dto)
  447. {
  448. var (total, items) = await _qualiteyProhibited.Queryable()
  449. .WhereIF(!string.IsNullOrEmpty(dto.Name), d => d.Name.Contains(dto.Name!))
  450. .WhereIF(!string.IsNullOrEmpty(dto.Classify), d => d.Classify.Contains(dto.Classify!))
  451. .WhereIF(!string.IsNullOrEmpty(dto.Type), d => d.Type.Contains(dto.Type!))
  452. .OrderByDescending(x => x.CreationTime)
  453. .ToPagedListAsync(dto.PageIndex, dto.PageSize, HttpContext.RequestAborted);
  454. return new PagedDto<QualityProhibitedDto>(total, _mapper.Map<IReadOnlyList<QualityProhibitedDto>>(items));
  455. }
  456. /// <summary>
  457. /// 获取违禁词实体
  458. /// </summary>
  459. /// <param name="id"></param>
  460. /// <returns></returns>
  461. [HttpGet("prohibited/{id}")]
  462. public async Task<QualityProhibited> ProhibitedEntity(string id)
  463. {
  464. return await _qualiteyProhibited.Queryable()
  465. .FirstAsync(x => x.Id == id);
  466. }
  467. #endregion
  468. /// <summary>
  469. /// 获取质检基本信息
  470. /// </summary>
  471. /// <returns></returns>
  472. [HttpGet("base")]
  473. public async Task<object> Base()
  474. {
  475. var rsp = new
  476. {
  477. QualityState = EnumExts.GetDescriptions<EQualityState>(),
  478. QualitySource = EnumExts.GetDescriptions<EQualitySource>()
  479. };
  480. return rsp;
  481. }
  482. /// <summary>
  483. /// 获取质检项目基本信息
  484. /// </summary>
  485. /// <returns></returns>
  486. [HttpGet("item_base")]
  487. public async Task<object> ItemBase()
  488. {
  489. var rsp = new
  490. {
  491. QualityItemGrouping = _systemDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.QualityItemGrouping)
  492. };
  493. return rsp;
  494. }
  495. /// <summary>
  496. /// 获取质检模版基本信息
  497. /// </summary>
  498. /// <returns></returns>
  499. [HttpGet("template_base")]
  500. public async Task<object> TemplateBase()
  501. {
  502. var rsp = new
  503. {
  504. TemplateGrouping = EnumExts.GetDescriptions<ETemplateGrouping>()
  505. };
  506. return rsp;
  507. }
  508. /// <summary>
  509. /// 获取质检违禁词基本信息
  510. /// </summary>
  511. /// <returns></returns>
  512. [HttpGet("prohibited_base")]
  513. public async Task<object> ProhibitedBase()
  514. {
  515. var rsp = new
  516. {
  517. ProhibitedClassify = _systemDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.ProhibitedClassify),
  518. ProhibitedType = _systemDicDataCacheManager.GetSysDicDataCache(SysDicTypeConsts.ProhibitedType),
  519. };
  520. return rsp;
  521. }
  522. /// <summary>
  523. /// 智能质检结果返回接收
  524. /// </summary>
  525. /// <param name="dto"></param>
  526. /// <returns></returns>
  527. [AllowAnonymous]
  528. [HttpPost("AiResult")]
  529. public async Task AiResult([FromBody] List<AiQualityResultDto> dto)
  530. {
  531. foreach (var item in dto)
  532. {
  533. var quality = await _qualitey.GetAsync(item.record_id);
  534. if (quality is { State: EQualityState.Apply } && item.score_items != null && item.score_items.Any())
  535. {
  536. List<QualityDetail> details = new List<QualityDetail>();
  537. foreach (var item2 in item.score_items)
  538. {
  539. QualityDetail detail = new QualityDetail
  540. {
  541. QualityId = quality.Id,
  542. Second = 0,
  543. Name = item2.name,
  544. //Content = item.name,
  545. Grade = item2.score
  546. };
  547. details.Add(detail);
  548. }
  549. await _qualiteyDetail.AddRangeAsync(details);
  550. }
  551. }
  552. }
  553. /// <summary>
  554. /// 重推质检
  555. /// </summary>
  556. /// <param name="id"></param>
  557. /// <returns></returns>
  558. [AllowAnonymous]
  559. [HttpPost("AiResultTest/{id}")]
  560. public async Task TaskAsync(string id)
  561. {
  562. var quality = await _qualitey.GetAsync(id, HttpContext.RequestAborted);
  563. var order = await _orderRepository.GetAsync(quality.OrderId, HttpContext.RequestAborted);
  564. if (order != null && !string.IsNullOrEmpty(order.CallId))
  565. {
  566. quality.AiQuality = true;
  567. var call = await _trCallRecordRepository.GetAsync(x => x.CallAccept == order.CallId, HttpContext.RequestAborted);
  568. await _aiQualityService.CreateAiOrderQualityTask(quality, call, order, HttpContext.RequestAborted);
  569. await _qualitey.UpdateAsync(quality, HttpContext.RequestAborted);
  570. }
  571. }
  572. }
  573. }