CaseFileCompareController.cs 48 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167
  1. using AntDesign;
  2. using DocumentFormat.OpenXml.InkML;
  3. using DocumentFormat.OpenXml.Presentation;
  4. using DynamicExpresso;
  5. using Microsoft.AspNetCore.Authorization;
  6. using Microsoft.AspNetCore.Http;
  7. using Microsoft.AspNetCore.Mvc;
  8. using Microsoft.EntityFrameworkCore;
  9. using Microsoft.EntityFrameworkCore.Query;
  10. using Microsoft.EntityFrameworkCore.Query.SqlExpressions;
  11. using System;
  12. using System.Collections;
  13. using System.Collections.Generic;
  14. using System.Data;
  15. using System.Diagnostics;
  16. using System.Dynamic;
  17. using System.Linq;
  18. using System.Linq.Expressions;
  19. using System.Text.RegularExpressions;
  20. using wispro.sp.api.AppealHandler;
  21. using wispro.sp.api.Job;
  22. using wispro.sp.api.Services;
  23. using wispro.sp.entity;
  24. using wispro.sp.entity.CompareCase;
  25. using wispro.sp.share;
  26. using static OneOf.Types.TrueFalseOrNull;
  27. namespace wispro.sp.api.Controllers
  28. {
  29. [Route("api/[controller]/[action]")]
  30. [ApiController]
  31. public class CaseFileCompareController : ControllerBase
  32. {
  33. spDbContext Context;
  34. IFileTaskService fileTaskService;
  35. public CaseFileCompareController(spDbContext context, IFileTaskService _fileTaskService)
  36. {
  37. Context = context;
  38. fileTaskService = _fileTaskService;
  39. }
  40. [Authorize]
  41. public ApiSaveResponse Save(CaseInfo caseInfo)
  42. {
  43. ApiSaveResponse ret = new ApiSaveResponse();
  44. ret.Success = true;
  45. using (Context.Database.BeginTransaction())
  46. {
  47. try
  48. {
  49. #region 客户处理
  50. if (caseInfo.Customer != null && !string.IsNullOrEmpty(caseInfo.Customer.Name))
  51. {
  52. var temCustomer = Context.Customers.Where<Customer>(c => c.Name == caseInfo.Customer.Name).FirstOrDefault();
  53. if (temCustomer == null)
  54. {
  55. temCustomer = new Customer() { Name = caseInfo.Customer.Name };
  56. //item.Customer.Id = 0;
  57. Context.Customers.Add(temCustomer);
  58. Context.SaveChanges();
  59. caseInfo.Customer = temCustomer;
  60. //item.CustomerId = item.Customer.Id;
  61. }
  62. else
  63. {
  64. caseInfo.Customer = temCustomer;
  65. }
  66. caseInfo.CustomerId = caseInfo.Customer.Id;
  67. caseInfo.Customer = null;
  68. }
  69. else
  70. {
  71. caseInfo.Customer = null;
  72. }
  73. #endregion
  74. #region 审核人
  75. if (caseInfo.Reviewer != null && !string.IsNullOrEmpty(caseInfo.Reviewer.Name))
  76. {
  77. var temReviewer = Context.Staffs.Where<Staff>(c => c.Name == caseInfo.Reviewer.Name).FirstOrDefault();
  78. if (temReviewer == null)
  79. {
  80. temReviewer = new Staff() { Name = caseInfo.Reviewer.Name };
  81. //item.Customer.Id = 0;
  82. Context.Staffs.Add(temReviewer);
  83. Context.SaveChanges();
  84. caseInfo.Reviewer = temReviewer;
  85. //item.CustomerId = item.Customer.Id;
  86. }
  87. else
  88. {
  89. caseInfo.Reviewer = temReviewer;
  90. }
  91. caseInfo.ReviewerId = caseInfo.Reviewer.Id;
  92. caseInfo.Reviewer = null;
  93. }
  94. else
  95. {
  96. caseInfo.Reviewer = null;
  97. }
  98. #endregion
  99. if (caseInfo.DRRAbstract != null) {
  100. Context.CaseCompareResults.Add(caseInfo.DRRAbstract);
  101. Context.SaveChanges();
  102. caseInfo.DRRAbstractId = caseInfo.DRRAbstract.Id;
  103. caseInfo.DRRAbstract = null;
  104. }
  105. if (caseInfo.DRRCalim != null)
  106. {
  107. Context.CaseCompareResults.Add(caseInfo.DRRCalim);
  108. Context.SaveChanges();
  109. caseInfo.DRRCalimId = caseInfo.DRRCalim.Id;
  110. caseInfo.DRRCalim = null;
  111. }
  112. if (caseInfo.DRRFulltext != null)
  113. {
  114. Context.CaseCompareResults.Add(caseInfo.DRRFulltext);
  115. Context.SaveChanges();
  116. caseInfo.DRRFulltextId = caseInfo.DRRFulltext.Id;
  117. caseInfo.DRRFulltext = null;
  118. }
  119. if (caseInfo.DRRAll != null)
  120. {
  121. Context.CaseCompareResults.Add(caseInfo.DRRAll);
  122. Context.SaveChanges();
  123. caseInfo.DRRAllId = caseInfo.DRRAll.Id;
  124. caseInfo.DRRAll = null;
  125. }
  126. if (caseInfo.RFRAbstract != null)
  127. {
  128. Context.CaseCompareResults.Add(caseInfo.RFRAbstract);
  129. Context.SaveChanges();
  130. caseInfo.RFRAbstractId = caseInfo.RFRAbstract.Id;
  131. caseInfo.RFRAbstract = null;
  132. }
  133. if (caseInfo.RFRCalim != null)
  134. {
  135. Context.CaseCompareResults.Add(caseInfo.RFRCalim);
  136. Context.SaveChanges();
  137. caseInfo.RFRCalimId = caseInfo.RFRCalim.Id;
  138. caseInfo.RFRCalim = null;
  139. }
  140. if (caseInfo.RFRFulltext != null)
  141. {
  142. Context.CaseCompareResults.Add(caseInfo.RFRFulltext);
  143. Context.SaveChanges();
  144. caseInfo.RFRFulltextId = caseInfo.RFRFulltext.Id;
  145. caseInfo.RFRFulltext = null;
  146. }
  147. if (caseInfo.RFRAll != null)
  148. {
  149. Context.CaseCompareResults.Add(caseInfo.RFRAll);
  150. Context.SaveChanges();
  151. caseInfo.RFRAllId = caseInfo.RFRAll.Id;
  152. caseInfo.RFRAll = null;
  153. }
  154. Context.CaseInfos.Add(caseInfo);
  155. Context.SaveChanges();
  156. Context.Database.CommitTransaction();
  157. }
  158. catch (Exception ex)
  159. {
  160. ret.Success = false;
  161. ret.ErrorMessage = ex.Message;
  162. Context.Database.RollbackTransaction();
  163. }
  164. }
  165. return ret;
  166. }
  167. public ListApiResponse<CaseInfo> QueryFilter(QueryFilter queryFilter)
  168. {
  169. ListApiResponse<CaseInfo> ret = new ListApiResponse<CaseInfo>();
  170. IQueryable<CaseInfo> response = NewMethod(queryFilter);
  171. int totals = response.Count();
  172. if (totals > 0 && totals < (queryFilter.PageIndex) * queryFilter.PageSize)
  173. {
  174. response = response
  175. .Include(pi => pi.DRRCalim)
  176. .Include(pi => pi.DRRAbstract)
  177. .Include(pi => pi.DRRFulltext)
  178. .Include(pi => pi.DRRAll)
  179. .Include(pi => pi.RFRCalim)
  180. .Include(pi => pi.RFRAbstract)
  181. .Include(pi => pi.RFRFulltext)
  182. .Include(pi => pi.RFRAll)
  183. .Include(pi => pi.Customer)
  184. .Include(pi => pi.Reviewer)
  185. .OrderConditions<CaseInfo>(queryFilter.Sorts)
  186. .Skip((queryFilter.PageIndex - 1) * queryFilter.PageSize)
  187. .Take(totals - (queryFilter.PageIndex - 1) * queryFilter.PageSize);
  188. //.Pager<PerformanceItem>(1, queryFilter.PageSize, out totals);
  189. }
  190. else
  191. {
  192. response = response
  193. .Include(pi => pi.DRRCalim)
  194. .Include(pi => pi.DRRAbstract)
  195. .Include(pi => pi.DRRFulltext)
  196. .Include(pi=>pi.DRRAll)
  197. .Include(pi => pi.RFRCalim)
  198. .Include(pi => pi.RFRAbstract)
  199. .Include(pi => pi.RFRFulltext)
  200. .Include(pi => pi.RFRAll)
  201. .Include(pi => pi.Customer)
  202. .Include(pi => pi.Reviewer)
  203. .OrderConditions<CaseInfo>(queryFilter.Sorts)
  204. .Skip((queryFilter.PageIndex - 1) * queryFilter.PageSize)
  205. .Take(queryFilter.PageSize);
  206. }
  207. ret.TotalCount = totals;
  208. var retList = response.ToList<CaseInfo>();
  209. #region 将某些属性设为null,避免循环取值造成返回json过大
  210. foreach (CaseInfo item in retList)
  211. {
  212. if (item.Customer != null)
  213. {
  214. item.Customer.PerformanceItems = null;
  215. item.Customer.ResponseMan = null;
  216. }
  217. if (item.Reviewer != null)
  218. {
  219. item.Reviewer.Customers = null;
  220. item.Reviewer.ExternalHandlerItems = null;
  221. item.Reviewer.ItemStaffs = null;
  222. item.Reviewer.AllocationRatios = null;
  223. item.Reviewer.ReviewerItems = null;
  224. }
  225. }
  226. #endregion
  227. ret.Results = retList.ToList();
  228. return ret;
  229. }
  230. public bool CaseExist(string caseNo)
  231. {
  232. return Context.CaseInfos.Where(p => p.CaseNo == caseNo.Trim()).Count() > 0;
  233. }
  234. public static (double, double) UpdateStatistics(int n, double mean, double variance, double newValue)
  235. {
  236. double newMean = (n * mean + newValue) / (n + 1);
  237. double newVariance = Math.Sqrt((n * (mean - newMean) * (mean - newMean) + (newValue - newMean) * (newValue - newMean) + n * variance * variance) / (n + 1));
  238. return (newMean, newVariance);
  239. }
  240. /// <summary>
  241. /// 计算指定日期之前一年的指定客户的平均权利要求差异度和标准方差
  242. /// </summary>
  243. /// <param name="endDate">结束日期</param>
  244. /// /// <param name="customerName">客户名称,默认不指定,获取所有客户的平均权利要求差异度和标准方差</param>
  245. /// <returns></returns>
  246. private List<CustomerCompareStatistics> getLaseYearMean_Variance(DateTime endDate,List<CaseInfo> caseList,string customerName=null)
  247. {
  248. if(caseList == null)
  249. {
  250. caseList = Context.CaseInfos.Where<CaseInfo>(
  251. p => p.CreateTime >= endDate.AddYears(-1) &&
  252. p.CreateTime <= endDate &&
  253. p.Customer.Name == customerName
  254. )
  255. .Include(p => p.Customer)
  256. .Include(p => p.Reviewer)
  257. .Include(p => p.DRRAbstract)
  258. .Include(p => p.DRRAbstract)
  259. .Include(p => p.DRRCalim)
  260. .Include(p => p.DRRFulltext)
  261. .Include(p => p.DRRAll)
  262. .Include(p => p.RFRAbstract)
  263. .Include(p => p.RFRCalim)
  264. .Include(p => p.RFRFulltext)
  265. .Include(p => p.RFRAll)
  266. .ToList();
  267. }
  268. //IIncludableQueryable<CaseInfo, CompareResult> caseList;
  269. var temcaseList = caseList;
  270. if (customerName != null) {
  271. temcaseList = caseList.Where(p=> p.Customer.Name == customerName)
  272. .ToList();
  273. }
  274. List < CustomerCompareStatistics > retList = new List < CustomerCompareStatistics >();
  275. foreach ( var item in temcaseList)
  276. {
  277. var temObj = retList.Where(p=>p.CustomerName == item.Customer.Name).FirstOrDefault<CustomerCompareStatistics>();
  278. if(temObj == null) {
  279. temObj = new CustomerCompareStatistics();
  280. temObj.CustomerName = item.Customer.Name;
  281. retList.Add(temObj);
  282. }
  283. temObj.CaseCount += 1;
  284. if (item.DRRCalim != null)
  285. {
  286. if (temObj.Diff_FinalDrafted_Claims_Count > 0) {
  287. var retStatistics = UpdateStatistics(temObj.Diff_Drafted_Claims_Count, temObj.Diff_Drafted_Claims_Avg, temObj.Diff_Drafted_Claims_Std, item.DRRCalim.diffRate);
  288. temObj.Diff_Drafted_Claims_Std = retStatistics.Item2;
  289. temObj.Diff_Drafted_Claims_Avg = retStatistics.Item1;
  290. temObj.Diff_Drafted_Claims_Count += 1;
  291. }
  292. else
  293. {
  294. temObj.Diff_Drafted_Claims_Std = 0.0;
  295. temObj.Diff_Drafted_Claims_Avg = item.DRRCalim.diffRate;
  296. temObj.Diff_Drafted_Claims_Count = 1;
  297. }
  298. }
  299. if (item.RFRCalim != null)
  300. {
  301. if (temObj.Diff_FinalDrafted_Claims_Count > 0)
  302. {
  303. var retStatistics = UpdateStatistics(temObj.Diff_FinalDrafted_Claims_Count, temObj.Diff_FinalDrafted_Claims_Avg, temObj.Diff_FinalDrafted_Claims_Std, item.RFRCalim.diffRate);
  304. temObj.Diff_FinalDrafted_Claims_Std = retStatistics.Item2;
  305. temObj.Diff_FinalDrafted_Claims_Avg = retStatistics.Item1;
  306. temObj.Diff_FinalDrafted_Claims_Count += 1;
  307. }
  308. else
  309. {
  310. temObj.Diff_FinalDrafted_Claims_Std = 0.0;
  311. temObj.Diff_FinalDrafted_Claims_Avg = item.RFRCalim.diffRate;
  312. temObj.Diff_FinalDrafted_Claims_Count = 1;
  313. }
  314. }
  315. }
  316. return retList;
  317. }
  318. /// <summary>
  319. /// 获取指定时间内客户的权要修改差异率最高的10各案件
  320. /// </summary>
  321. /// <param name="start">开始日期</param>
  322. /// <param name="end">结束日期</param>
  323. /// <param name="customerName">客户名称</param>
  324. /// <param name="type">类型:
  325. /// 0:外部核稿差异率,默认值,
  326. /// 1:内部核稿差异率
  327. /// </param>
  328. /// <returns></returns>
  329. private List<CaseInfo> getTop10DiffRateCases(DateTime start, DateTime end,string customerName,int type=0,List<CaseInfo> caseList=null)
  330. {
  331. if (caseList == null) {
  332. caseList = Context.CaseInfos.Where<CaseInfo>(
  333. p => p.CreateTime >= end.AddYears(-1) &&
  334. p.CreateTime <= end &&
  335. p.Customer.Name == customerName
  336. )
  337. .Include(p => p.Customer)
  338. .Include(p => p.Reviewer)
  339. .Include(p => p.DRRAbstract)
  340. .Include(p => p.DRRAbstract)
  341. .Include(p => p.DRRCalim)
  342. .Include(p => p.DRRFulltext)
  343. .Include(p => p.DRRAll)
  344. .Include(p => p.RFRAbstract)
  345. .Include(p => p.RFRCalim)
  346. .Include(p => p.RFRFulltext)
  347. .Include(p => p.RFRAll)
  348. .ToList();
  349. }
  350. if (type == 0) {
  351. var top10Case = caseList.Where<CaseInfo>(p=>p.Customer.Name == customerName)
  352. .OrderByDescending(p => p.RFRCalim?.diffRate).Take(10);
  353. return top10Case.Where<CaseInfo>(c=>c.CreateTime>=start).ToList();
  354. }
  355. else
  356. {
  357. var top10Case = caseList.Where<CaseInfo>(p => p.Customer.Name == customerName)
  358. .OrderByDescending(p => p.DRRCalim?.diffRate).Take(10);
  359. return top10Case.Where<CaseInfo>(c => c.CreateTime >= start).ToList();
  360. }
  361. }
  362. /// <summary>
  363. /// 获取指定时间内客户权要修改差异度计算出的异常案件
  364. /// </summary>
  365. /// <param name="start">开始日期</param>
  366. /// <param name="end">结束日期</param>
  367. /// <param name="customerName">客户名称</param>
  368. /// <returns></returns>
  369. private List<CaseInfo> GetAbnormalCases(DateTime start, DateTime end, string customerName,List<CaseInfo> caseList)
  370. {
  371. var customerStatics = getLaseYearMean_Variance(end, caseList,customerName);
  372. var cStatics = customerStatics.Where(s => s.CustomerName == customerName).FirstOrDefault();
  373. return _GetAbnormalCases(start, end, customerName, cStatics,caseList);
  374. }
  375. private List<CaseInfo> _GetAbnormalCases(DateTime start, DateTime end, string customerName, CustomerCompareStatistics cStatics,List<CaseInfo> caseList)
  376. {
  377. if (cStatics != null)
  378. {
  379. if (caseList == null) {
  380. caseList = Context.CaseInfos.Where<CaseInfo>(
  381. p => p.CreateTime >= end.AddYears(-1) &&
  382. p.CreateTime <= end &&
  383. p.Customer.Name == customerName
  384. )
  385. .Include(p => p.Customer)
  386. .Include(p => p.Reviewer)
  387. .Include(p => p.DRRAbstract)
  388. .Include(p => p.DRRAbstract)
  389. .Include(p => p.DRRCalim)
  390. .Include(p => p.DRRFulltext)
  391. .Include(p => p.DRRAll)
  392. .Include(p => p.RFRAbstract)
  393. .Include(p => p.RFRCalim)
  394. .Include(p => p.RFRFulltext)
  395. .Include(p => p.RFRAll)
  396. .ToList();
  397. }
  398. var retList = new List<CaseInfo>();
  399. var temCaseList = caseList.Where(p=>p.Customer.Name== customerName).ToList();
  400. foreach (var item in temCaseList)
  401. {
  402. if (item.CreateTime >= start)
  403. {
  404. double first = item.DRRCalim == null ? 0.0 : item.DRRCalim.diffRate;
  405. double second = item.RFRCalim == null ? 0.0 : item.RFRCalim.diffRate;
  406. double score1 = (first - cStatics.Diff_Drafted_Claims_Avg) / cStatics.Diff_Drafted_Claims_Std;
  407. double score2 = (second - cStatics.Diff_FinalDrafted_Claims_Avg) / cStatics.Diff_FinalDrafted_Claims_Std;
  408. double score = Math.Sqrt(score1 * score1 + score2 * score2);
  409. if (score > 3.0)
  410. {
  411. if (score2 > 0)
  412. {
  413. if (score1 < 0)
  414. {
  415. item.AbnormalMessage = $"内部核稿修改相对少,外部修改相对很多!【核稿人不给力/沟通有问题?】,【分数为:{score.ToString("0.00")}】";
  416. }
  417. else
  418. {
  419. item.AbnormalMessage = $"内部核稿相对多,外部修改也相对多!【沟通有问题?】,【分数为:{score.ToString("0.00")}】";
  420. }
  421. }
  422. else
  423. {
  424. if (score1 < 0)
  425. {
  426. item.AbnormalMessage = $"内部核稿修改相对少,外部修改相对少!【撰稿人给力】,【分数为:{score.ToString("0.00")}】";
  427. }
  428. else
  429. {
  430. item.AbnormalMessage = $"内部核稿相对多,外部修改也相对少!【核稿人给力】,【分数为:{score.ToString("0.00")}】";
  431. }
  432. }
  433. retList.Add(item);
  434. }
  435. }
  436. }
  437. return retList;
  438. }
  439. else
  440. {
  441. return new List<CaseInfo>();
  442. }
  443. }
  444. internal class mailCaseInfo
  445. {
  446. public CustomerCompareStatistics CustomerCompareStatistics { get; set; }
  447. public List<CaseInfo> Top10Cases { get; set; } = new List<CaseInfo>();
  448. public List<CaseInfo> AbnormalCases { get; set; }= new List<CaseInfo>();
  449. }
  450. public void getMailCaseInfo(DateTime start, DateTime end)
  451. {
  452. var caseList = Context.CaseInfos.Where<CaseInfo>(
  453. p => p.CreateTime >= end.AddYears(-1) &&
  454. p.CreateTime <= end
  455. )
  456. .Include(p => p.Customer)
  457. .Include(p => p.Reviewer)
  458. .Include(p => p.DRRAbstract)
  459. .Include(p => p.DRRAbstract)
  460. .Include(p => p.DRRCalim)
  461. .Include(p => p.DRRFulltext)
  462. .Include(p => p.DRRAll)
  463. .Include(p => p.RFRAbstract)
  464. .Include(p => p.RFRCalim)
  465. .Include(p => p.RFRFulltext)
  466. .Include(p => p.RFRAll)
  467. .ToList();
  468. List<string> defaultStaffNames = new List<string>() { "罗才洋","李庆波","钟子敏"};
  469. var DefaultEmailAccounts = Context.Staffs.Where(p => defaultStaffNames.Contains(p.Name)).ToList();
  470. var customerStatics = getLaseYearMean_Variance(end,caseList);
  471. Hashtable staffMailInfo = new Hashtable();
  472. foreach (var cStatics in customerStatics)
  473. {
  474. if(cStatics.CaseCount < 20)
  475. {
  476. continue;
  477. }
  478. //var cStatics = customerStatics.Where(s => s.CustomerName == item.Customer.Name).FirstOrDefault();
  479. var Top10Cases =getTop10DiffRateCases(start, end, cStatics.CustomerName,0,caseList);
  480. foreach (var caseInfo in Top10Cases)
  481. {
  482. foreach (Staff staff in DefaultEmailAccounts)
  483. {
  484. AddtoHashTable(caseInfo, 0, staff, staffMailInfo, cStatics);
  485. }
  486. if (caseInfo.Reviewer != null)
  487. {
  488. AddtoHashTable(caseInfo,0, caseInfo.Reviewer,staffMailInfo,cStatics);
  489. }
  490. if (caseInfo.Customer.ResponseManId != null)
  491. {
  492. Staff respMan = Context.Staffs.FirstOrDefault<Staff>(p => p.Id == caseInfo.Customer.ResponseManId);
  493. if (respMan != null)
  494. {
  495. AddtoHashTable(caseInfo, 0, respMan, staffMailInfo, cStatics);
  496. }
  497. }
  498. }
  499. var AbnormalCases = _GetAbnormalCases(start,end, cStatics.CustomerName, cStatics,caseList);
  500. foreach (var caseInfo in AbnormalCases)
  501. {
  502. foreach(Staff staff in DefaultEmailAccounts)
  503. {
  504. AddtoHashTable(caseInfo, 1, staff, staffMailInfo, cStatics);
  505. }
  506. if (caseInfo.Reviewer != null)
  507. {
  508. AddtoHashTable(caseInfo, 1, caseInfo.Reviewer, staffMailInfo, cStatics);
  509. }
  510. if (caseInfo.Customer.ResponseManId != null)
  511. {
  512. Staff respMan = Context.Staffs.FirstOrDefault<Staff>(p => p.Id == caseInfo.Customer.ResponseManId);
  513. if (respMan != null)
  514. {
  515. AddtoHashTable(caseInfo, 1, respMan, staffMailInfo, cStatics);
  516. }
  517. }
  518. }
  519. }
  520. if (staffMailInfo.Count > 0) {
  521. foreach (var key in staffMailInfo.Keys)
  522. {
  523. Staff staff = key as Staff;
  524. List<mailCaseInfo> mailCases = (List<mailCaseInfo>)staffMailInfo[key];
  525. string strMessage = string.Empty ;
  526. foreach(var m in mailCases)
  527. {
  528. if ((m.Top10Cases != null && m.Top10Cases.Count > 0) || (m.AbnormalCases != null && m.AbnormalCases.Count > 0))
  529. {
  530. strMessage += $"<br/><div><b>{m.CustomerCompareStatistics.CustomerName}:</b>";
  531. strMessage += $"<br/>一年内案件数量:{m.CustomerCompareStatistics.CaseCount}";
  532. strMessage += $"<br/>内部核稿平均修改率:{m.CustomerCompareStatistics.Diff_Drafted_Claims_Avg}&nbsp;&nbsp;内部核稿修改率标准方差:{m.CustomerCompareStatistics.Diff_Drafted_Claims_Std}";
  533. strMessage += $"<br/>外部部核稿平均修改率:{m.CustomerCompareStatistics.Diff_FinalDrafted_Claims_Avg}&nbsp;&nbsp;外部核稿修改率标准方差:{m.CustomerCompareStatistics.Diff_FinalDrafted_Claims_Std}</div>";
  534. if (m.Top10Cases != null && m.Top10Cases.Count > 0)
  535. {
  536. strMessage += $"<div>外部核稿修改率前10名案件清单:</div>";
  537. strMessage += "<table border='1'><thead><td>案号</td><td>案件名称</td><td>处理人</td><td>核稿人</td><td>内部核稿修改率(%)</td><td>外部核稿修改率(%)</td></thead><body>";
  538. foreach (var c in m.Top10Cases)
  539. {
  540. strMessage += $"<tr><td><a href=\"{($"http://1.116.113.26/CompareFile/detail/{c.CaseNo}")}\">{c.CaseNo}</a></td><td>{c.CaseName}</td><td>{c.Handlers}</td><td>{(c.Reviewer == null ? "" : c.Reviewer.Name)}</td><td>{(c.DRRCalim == null ? "" : (c.DRRCalim.diffRate*100).ToString("0.0000"))}</td><td>{(c.RFRCalim == null ? "" : (c.RFRCalim.diffRate * 100).ToString("0.0000"))}</td></tr>";
  541. }
  542. strMessage += "</body></table>";
  543. }
  544. if (m.AbnormalCases != null && m.AbnormalCases.Count > 0)
  545. {
  546. strMessage += $"<br/><div>疑似异常案件清单:</div>";
  547. strMessage += "<table border='1'><thead><td>案号</td><td>案件名称</td><td>处理人</td><td>核稿人</td><td>内部核稿修改率</td><td>外部核稿修改率</td><td>异常说明</td></thead><body>";
  548. foreach (var c in m.AbnormalCases)
  549. {
  550. strMessage += $"<tr><td><a href=\"{($"http://1.116.113.26/CompareFile/detail/{c.CaseNo}")}\">{c.CaseNo}</a></td><td>{c.CaseName}</td><td>{c.Handlers}</td><td>{(c.Reviewer == null ? "" : c.Reviewer.Name)}</td><td>{(c.DRRCalim == null ? "" : (c.DRRCalim.diffRate*100).ToString("0.0000"))}</td><td>{(c.RFRCalim == null ? "" : (c.RFRCalim.diffRate*100).ToString("0.0000"))}</td><td>{c.AbnormalMessage}</td></tr>";
  551. }
  552. strMessage += "</body></table><br/>";
  553. }
  554. strMessage += "</div>";
  555. }
  556. }
  557. string strTem = $"如下是{start.ToString("yyyy-MM-dd")}到{end.ToString("yyyy-MM-dd")}国内专利申请案件在客户核稿处于年内修改率前10名的案件和疑似异常案件清单,请关注!";
  558. string strBody = $"<div><div>{staff.Name},你好!</div><br/><div>{strTem}</div>{strMessage}<br/><div >小美集团绩效管理系统</div></div>";
  559. staff.Mail = "luocaiyang@china-wispro.com";
  560. _ = QuartzUtil.AddMailJob($"{start.ToString("yyyyMMdd")}-{end.ToString("yyyyMMdd")}申请文件比较邮件", strBody, staff.Name, staff.Mail);
  561. }
  562. }
  563. }
  564. private void AddtoHashTable(CaseInfo caseInfo, int v, Staff staff, Hashtable staffMailInfo,CustomerCompareStatistics cStatics)
  565. {
  566. var staffCaseMailInfo = new mailCaseInfo()
  567. {
  568. CustomerCompareStatistics = cStatics,
  569. };
  570. List<mailCaseInfo> staffCaseMailInfos = new List<mailCaseInfo>();
  571. if (staffMailInfo.ContainsKey(staff))
  572. {
  573. staffCaseMailInfos = (List<mailCaseInfo>)staffMailInfo[staff];
  574. }
  575. else
  576. {
  577. staffMailInfo.Add(staff,staffCaseMailInfos);
  578. }
  579. var temObj = staffCaseMailInfos.Where(p => p.CustomerCompareStatistics.CustomerName == caseInfo.Customer.Name).FirstOrDefault();
  580. if (temObj != null)
  581. {
  582. staffCaseMailInfo = temObj;
  583. }
  584. else
  585. {
  586. staffCaseMailInfos.Add(staffCaseMailInfo);
  587. }
  588. if (v == 0)
  589. {
  590. staffCaseMailInfo.Top10Cases.Add(caseInfo);
  591. }
  592. else
  593. {
  594. staffCaseMailInfo.AbnormalCases.Add(caseInfo);
  595. }
  596. }
  597. /// <summary>
  598. /// 计算案件的zScore
  599. /// </summary>
  600. /// <param name="start">定稿日开始时间</param>
  601. /// <param name="end">定稿日结束时间</param>
  602. /// <param name="type">
  603. /// 0:基于文本相似度计算,
  604. /// 1:基于文本修改差异度计算
  605. /// 2:基于权要权重70说明书30计算
  606. /// 3:基于权要文本相似度计算
  607. /// 4: 基于权要文字修改差异度计算
  608. /// </param>
  609. /// <returns></returns>
  610. public IList<Object> CalCustomer_mean(DateTime start,DateTime end,int type=0)
  611. {
  612. var caseList = Context.CaseInfos.Where<CaseInfo>(
  613. p => p.FinalVersionDate >= start && p.FinalVersionDate <= end)
  614. .Include(p=>p.Customer)
  615. .Include(p=>p.Reviewer)
  616. .Include(p=>p.DRRAbstract)
  617. .Include(p => p.DRRAbstract)
  618. .Include(p => p.DRRCalim)
  619. .Include(p => p.DRRFulltext)
  620. .Include(p => p.DRRAll)
  621. .Include(p => p.RFRAbstract)
  622. .Include(p => p.RFRCalim)
  623. .Include(p => p.RFRFulltext)
  624. .Include(p => p.RFRAll);
  625. int iTotals = caseList.Count();
  626. int iIndex = 0;
  627. List<Object> retList = new List<Object>();
  628. #region 计算客户相似度平均值和标准方差
  629. List<CustomerAvg_Std> avg_std1 = new List<CustomerAvg_Std>();
  630. List<CustomerAvg_Std> avg_std2 = new List<CustomerAvg_Std>();
  631. foreach (var caseInfo in caseList)
  632. {
  633. iIndex++;
  634. Debug.WriteLine($"{iIndex}/{iTotals}\t{caseInfo.CaseNo}\t{caseInfo.DRRAbstractId},{caseInfo.DRRCalimId},{caseInfo.DRRFulltextId},{caseInfo.DRRAllId},{caseInfo.RFRAbstractId},{caseInfo.RFRCalimId},{caseInfo.RFRFulltextId},{caseInfo.RFRAllId}");
  635. string tmpCustomerName = "未知";
  636. if(caseInfo.Customer!= null)
  637. {
  638. tmpCustomerName = caseInfo.Customer.Name;
  639. }
  640. var one = avg_std1.Where<CustomerAvg_Std>(p => p.Name == tmpCustomerName).FirstOrDefault();
  641. if (one == null)
  642. {
  643. one = new CustomerAvg_Std() { Name = tmpCustomerName };
  644. avg_std1.Add(one);
  645. }
  646. var two = avg_std2.Where<CustomerAvg_Std>(p => p.Name == tmpCustomerName).FirstOrDefault();
  647. if (two == null)
  648. {
  649. two = new CustomerAvg_Std() { Name = tmpCustomerName };
  650. avg_std2.Add(two);
  651. }
  652. double? oneTmp = getCalValue(caseInfo, type, 0);
  653. if(oneTmp != null)
  654. {
  655. one.Sum += oneTmp.Value;
  656. one.SquareSum += oneTmp.Value * oneTmp.Value;
  657. one.count += 1;
  658. }
  659. double? twoTmp = getCalValue(caseInfo, type, 1);
  660. if (twoTmp != null)
  661. {
  662. two.Sum += twoTmp.Value;
  663. two.SquareSum += twoTmp.Value * twoTmp.Value;
  664. two.count += 1;
  665. }
  666. }
  667. #endregion
  668. System.Data.DataTable dt = new System.Data.DataTable();
  669. dt.Columns.Add("我方文号");
  670. dt.Columns.Add("案件名称");
  671. dt.Columns.Add("客户");
  672. dt.Columns.Add("处理人");
  673. dt.Columns.Add("核稿人");
  674. dt.Columns.Add("内部核稿相似度或差异度");
  675. dt.Columns.Add("内部客户平均值");
  676. dt.Columns.Add("内部客户标准偏差");
  677. dt.Columns.Add("内部核稿分数");
  678. dt.Columns.Add("外部核稿相似度或差异度");
  679. dt.Columns.Add("外部客户平均值");
  680. dt.Columns.Add("外部客户标准偏差");
  681. dt.Columns.Add("外部核稿分数");
  682. dt.Columns.Add("备注");
  683. foreach (var item in caseList)
  684. {
  685. string tmpCustomerName = "未知";
  686. if (item.Customer != null)
  687. {
  688. tmpCustomerName = item.Customer.Name;
  689. }
  690. var one = avg_std1.Where<CustomerAvg_Std>(p => p.Name == tmpCustomerName).FirstOrDefault();
  691. var two = avg_std2.Where<CustomerAvg_Std>(p => p.Name == tmpCustomerName).FirstOrDefault();
  692. double? oneSim = getCalValue(item,type,0);
  693. double? twoSim = getCalValue(item, type, 1); ;
  694. DataRow row = dt.NewRow();
  695. row["我方文号"] = item.CaseNo;
  696. row["案件名称"] = item.CaseName;
  697. row["客户"] = item.Customer?.Name;
  698. row["核稿人"] = item.Reviewer?.Name;
  699. row["处理人"] = item.Handlers;
  700. double? zScoreA = null;
  701. if (oneSim != null)
  702. {
  703. zScoreA = (oneSim - one.Average) / one.Std_Deviation;
  704. }
  705. row["内部核稿分数"] = zScoreA;
  706. row["内部核稿相似度或差异度"] = oneSim;
  707. row["内部客户平均值"] = one.Average;
  708. row["内部客户标准偏差"] = one.Std_Deviation;
  709. row["外部核稿相似度或差异度"] = twoSim;
  710. row["外部客户平均值"] = two.Average;
  711. row["外部客户标准偏差"] = two.Std_Deviation;
  712. double? zScoreB = null;
  713. if (twoSim != null)
  714. {
  715. zScoreB = (twoSim - two.Average) / two.Std_Deviation;
  716. }
  717. row["外部核稿分数"] = zScoreB;
  718. if (zScoreA != null && zScoreB != null)
  719. {
  720. var distince = Math.Sqrt(zScoreB.Value * zScoreB.Value + zScoreA.Value * zScoreA.Value);
  721. if (type == 0 || type == 2 || type==3)
  722. {
  723. if (distince > 3)
  724. {
  725. if (zScoreA.Value > 0 && zScoreB.Value > 0)
  726. {
  727. row["备注"] = "内部核稿、外部核稿修改都较少![撰稿人给力或客户友好]";
  728. }
  729. if (zScoreA.Value > 0 && zScoreB.Value < 0)
  730. {
  731. row["备注"] = "内部核稿较少、外部核稿修改较多![核稿人没有尽责!]";
  732. }
  733. if (zScoreA.Value < 0 && zScoreB.Value > 0)
  734. {
  735. row["备注"] = "内部核稿较多、外部核稿修改都较少![核稿人给力]";
  736. }
  737. if (zScoreA.Value < 0 && zScoreB.Value < 0)
  738. {
  739. row["备注"] = "内部核稿和外部核稿修改都较多![案件沟通问题?]";
  740. }
  741. }
  742. }
  743. else
  744. {
  745. if (distince > 3)
  746. {
  747. if (zScoreA.Value > 0 && zScoreB.Value > 0)
  748. {
  749. row["备注"] = "内部核稿和外部核稿修改都较多![案件沟通问题?]";
  750. }
  751. if (zScoreA.Value > 0 && zScoreB.Value < 0)
  752. {
  753. row["备注"] = "内部核稿较多、外部核稿修改都较少![核稿人给力]";
  754. }
  755. if (zScoreA.Value < 0 && zScoreB.Value > 0)
  756. {
  757. row["备注"] = "内部核稿较少、外部核稿修改较多![核稿人没有尽责!]";
  758. }
  759. if (zScoreA.Value < 0 && zScoreB.Value < 0)
  760. {
  761. row["备注"] = "内部核稿、外部核稿修改都较少![撰稿人给力或客户友好]";
  762. }
  763. }
  764. }
  765. }
  766. dt.Rows.Add(row);
  767. retList.Add(
  768. new
  769. {
  770. Id = item.Id,
  771. CaseNo = item.CaseNo,
  772. CaseName = item.CaseName,
  773. Customer = item.Customer,
  774. Reviewer = item.Reviewer,
  775. Handlers = item.Handlers,
  776. zScoreA = (oneSim - one.Average) / one.Std_Deviation,
  777. zScoreB = (twoSim - two.Average) / two.Std_Deviation
  778. }
  779. );
  780. }
  781. wispro.sp.utility.NPOIExcel.DataTableToExcel(dt,$"c:\\temp\\{DateTime.Now.ToString("yyyyMMdd")}-内部核稿外部核稿情况案件清单_{typeName(type)}.xlsx");
  782. return retList;
  783. }
  784. private double? getCalValue(CaseInfo caseInfo,int type,int stage)
  785. {
  786. double? calValue = null;
  787. switch (type)
  788. {
  789. case 0:
  790. if(stage == 0)
  791. {
  792. if(caseInfo.DRRFulltext != null && caseInfo.DRRAbstract != null)
  793. {
  794. calValue = caseInfo.DRRAll.TextSimilarity;
  795. }
  796. else
  797. {
  798. if(caseInfo.DRRCalim != null)
  799. {
  800. calValue = caseInfo.DRRCalim.TextSimilarity;
  801. }
  802. }
  803. }
  804. else
  805. {
  806. if (caseInfo.RFRFulltext != null && caseInfo.RFRAbstract != null)
  807. {
  808. calValue = caseInfo.RFRAll.TextSimilarity;
  809. }
  810. else
  811. {
  812. if (caseInfo.RFRCalim != null)
  813. {
  814. calValue = caseInfo.RFRCalim.TextSimilarity;
  815. }
  816. }
  817. }
  818. break;
  819. case 1:
  820. if (stage == 0)
  821. {
  822. if (caseInfo.DRRFulltext != null && caseInfo.DRRAbstract != null)
  823. {
  824. calValue = caseInfo.DRRAll.diffRate;
  825. }
  826. else
  827. {
  828. if (caseInfo.DRRCalim != null)
  829. {
  830. calValue = caseInfo.DRRCalim.diffRate;
  831. }
  832. }
  833. }
  834. else
  835. {
  836. if (caseInfo.RFRFulltext != null && caseInfo.RFRAbstract != null)
  837. {
  838. calValue = caseInfo.RFRAll.diffRate;
  839. }
  840. else
  841. {
  842. if (caseInfo.RFRCalim != null)
  843. {
  844. calValue = caseInfo.RFRCalim.diffRate;
  845. }
  846. }
  847. }
  848. break;
  849. case 2:
  850. if (stage == 0)
  851. {
  852. if(caseInfo.DRRFulltext != null && caseInfo.DRRCalim!= null)
  853. {
  854. calValue = caseInfo.DRRCalim.TextSimilarity * 0.7 + caseInfo.DRRFulltext.TextSimilarity * 0.3;
  855. }
  856. else
  857. {
  858. if( caseInfo.DRRCalim != null)
  859. {
  860. calValue = caseInfo.DRRCalim.TextSimilarity;
  861. }
  862. else
  863. {
  864. if(caseInfo.DRRAll != null)
  865. {
  866. calValue = caseInfo.DRRAll.TextSimilarity;
  867. }
  868. }
  869. }
  870. }
  871. else
  872. {
  873. if (caseInfo.RFRFulltext != null && caseInfo.RFRCalim != null)
  874. {
  875. calValue = caseInfo.RFRCalim.TextSimilarity * 0.7 + caseInfo.RFRFulltext.TextSimilarity * 0.3;
  876. }
  877. else
  878. {
  879. if (caseInfo.RFRCalim != null)
  880. {
  881. calValue = caseInfo.RFRCalim.TextSimilarity;
  882. }
  883. else
  884. {
  885. if (caseInfo.RFRAll != null)
  886. {
  887. calValue = caseInfo.RFRAll.TextSimilarity;
  888. }
  889. }
  890. }
  891. }
  892. break;
  893. case 3:
  894. if (stage == 0)
  895. {
  896. if (caseInfo.DRRCalim != null)
  897. {
  898. calValue = caseInfo.DRRCalim.TextSimilarity;
  899. }
  900. }
  901. else
  902. {
  903. if (caseInfo.RFRCalim != null)
  904. {
  905. calValue = caseInfo.RFRCalim.TextSimilarity;
  906. }
  907. }
  908. break;
  909. case 4:
  910. if (stage == 0)
  911. {
  912. if (caseInfo.DRRCalim != null)
  913. {
  914. calValue = caseInfo.DRRCalim.diffRate;
  915. }
  916. }
  917. else
  918. {
  919. if (caseInfo.RFRCalim != null)
  920. {
  921. calValue = caseInfo.RFRCalim.diffRate;
  922. }
  923. }
  924. break;
  925. }
  926. return calValue;
  927. }
  928. private string typeName(int type)
  929. {
  930. switch (type)
  931. {
  932. case 0:
  933. return "文本相似度计算";
  934. case 1:
  935. return "字符修改计算";
  936. case 2:
  937. return "权要权重70说明书30";
  938. case 3:
  939. return "权要相似度计算";
  940. }
  941. return "";
  942. }
  943. public IList<Object> CalMean_Std(DateTime start,DateTime end)
  944. {
  945. double AverageA = Context.CaseInfos.Where<CaseInfo>(
  946. p => p.FinalVersionDate >= start && p.FinalVersionDate <= end && p.DRRCalim!= null)
  947. .Average(x=>x.DRRCalim.TextSimilarity);
  948. double AverageB = Context.CaseInfos.Where<CaseInfo>(
  949. p => p.FinalVersionDate >= start && p.FinalVersionDate <= end && p.RFRAll != null)
  950. .Average(x => x.RFRAll.TextSimilarity);
  951. double stdA = Math.Sqrt( Context.CaseInfos.Where<CaseInfo>(
  952. p => p.FinalVersionDate >= start && p.FinalVersionDate <= end)
  953. .Average((x => (x.DRRCalim.TextSimilarity - AverageA) * (x.DRRCalim.TextSimilarity - AverageA))));
  954. double stdB = Math.Sqrt(Context.CaseInfos.Where<CaseInfo>(
  955. p => p.FinalVersionDate >= start && p.FinalVersionDate <= end)
  956. .Average((x => (x.RFRAll.TextSimilarity - AverageB) * (x.RFRAll.TextSimilarity - AverageB))));
  957. var response2 = Context.CaseInfos.Where<CaseInfo>(
  958. p => p.FinalVersionDate >= start && p.FinalVersionDate <= end)
  959. .Include(p=>p.DRRCalim)
  960. .Include(p=>p.RFRAll);
  961. IList<Object> results = new List<Object>();
  962. foreach(var item in response2.ToList())
  963. {
  964. results.Add(
  965. new {
  966. Id = item.Id,
  967. CaseNo = item.CaseNo,
  968. CaseName = item.CaseName,
  969. Customer = item.Customer,
  970. Reviewer = item.Reviewer,
  971. Handlers = item.Handlers,
  972. zScoreA = (item.DRRCalim?.TextSimilarity -AverageA)/stdA,
  973. zScoreB = (item.RFRAll?.TextSimilarity - AverageB) /stdB
  974. }
  975. );
  976. }
  977. return results;
  978. }
  979. private string GetExpress(IList<FieldCondition> conditions)
  980. {
  981. string str = "";
  982. foreach (var c in conditions)
  983. {
  984. if (string.IsNullOrEmpty(str))
  985. {
  986. str = c.ToExpressString("s");
  987. }
  988. else
  989. {
  990. if (c.LogicOperate == LogicEnum.And)
  991. {
  992. str = $"({str}) && {c.ToExpressString("s")}";
  993. }
  994. else
  995. {
  996. str = $"({str}) || {c.ToExpressString("s")}";
  997. }
  998. }
  999. }
  1000. return str;
  1001. }
  1002. private IQueryable<CaseInfo> NewMethod(QueryFilter queryFilter)
  1003. {
  1004. string strExpress = "";
  1005. if (queryFilter.ConditionTree != null)
  1006. {
  1007. strExpress = GetExpress(queryFilter.ConditionTree);
  1008. }
  1009. var interpreter = new Interpreter();
  1010. if (string.IsNullOrEmpty(strExpress))
  1011. {
  1012. return new spDbContext().CaseInfos.Where<CaseInfo>(p=>(p.Id>0));
  1013. }
  1014. else
  1015. {
  1016. Expression<Func<CaseInfo, bool>> dynamicWhere = interpreter.ParseAsExpression<Func<CaseInfo, bool>>(strExpress, "s");
  1017. IQueryable<CaseInfo> response = new spDbContext().CaseInfos.Where<CaseInfo>(dynamicWhere);
  1018. return response;
  1019. }
  1020. }
  1021. }
  1022. }