ExamAbsentReplaceService.cs 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807
  1. using Furion.DatabaseAccessor.Extensions;
  2. using Furion.JsonSerialization;
  3. using NPOI.OpenXmlFormats.Wordprocessing;
  4. using NPOI.SS.UserModel;
  5. using NPOI.XWPF.UserModel;
  6. using System.Dynamic;
  7. using YBEE.EQM.Core;
  8. namespace YBEE.EQM.Application;
  9. /// <summary>
  10. /// 缺测替补管理服务
  11. /// </summary>
  12. public partial class ExamAbsentReplaceService(
  13. IRepository<ExamAbsentReplace> rep,
  14. IExamGradeService examGradeService,
  15. ISysDictDataService sysDictDataService,
  16. ISchoolClassService schoolClassService,
  17. IResourceFileService resourceFileService,
  18. ICourseService courseService
  19. ) : IExamAbsentReplaceService, ITransient
  20. {
  21. #region 批量导入
  22. /// <summary>
  23. /// 上传监测缺测替补批量导入文件
  24. /// </summary>
  25. /// <param name="filePath"></param>
  26. /// <param name="examPlanId"></param>
  27. /// <returns></returns>
  28. public async Task<UploadExamDataOutput<UploadExamAbsentReplaceOutput>> Upload(string filePath, int examPlanId)
  29. {
  30. UploadExamDataOutput<UploadExamAbsentReplaceOutput> result = new();
  31. try
  32. {
  33. using FileStream fs = new(filePath, FileMode.Open, FileAccess.Read);
  34. IWorkbook workbook = ExcelUtil.GetWorkbook(filePath, fs);
  35. var sheet = workbook.GetSheetAt(0);
  36. var rows = sheet.GetRowEnumerator();
  37. #region 验证表结构
  38. // 少于2行验证
  39. if (sheet.LastRowNum < 2)
  40. {
  41. result.ErrorMessage.Add("第一行应为填写说明,第二行应为标题行,请勿修改模板结构。");
  42. return result;
  43. }
  44. // 跳过第一行
  45. rows.MoveNext();
  46. // 读取表头
  47. rows.MoveNext();
  48. IRow headerRow = (IRow)rows.Current;
  49. int index = 0;
  50. int GRADE_INDEX = index++;
  51. int CLASS_INDEX = index++;
  52. int NAME_INDEX = index++;
  53. int EXAM_NUM_INDEX = index++;
  54. int REASON_INDEX = index++;
  55. int COURSES_INDEX = index++;
  56. int TEL_INDEX = index++;
  57. int REPLACE_NAME_INDEX = index++;
  58. int REPLACE_EXAM_NUM_INDEX = index++;
  59. int REMARK_INDEX = index;
  60. Dictionary<int, string> headers = new()
  61. {
  62. { GRADE_INDEX, "年级号" },
  63. { CLASS_INDEX, "班级号" },
  64. { NAME_INDEX, "缺测学生姓名" },
  65. { EXAM_NUM_INDEX, "缺测学生监测号" },
  66. { REASON_INDEX, "缺测原因" },
  67. { COURSES_INDEX, "缺测科目" },
  68. { TEL_INDEX, "缺测学生家长电话" },
  69. { REPLACE_NAME_INDEX, "替补学生姓名" },
  70. { REPLACE_EXAM_NUM_INDEX, "替补学生监测号" },
  71. { REMARK_INDEX, "备注" },
  72. };
  73. List<string> headerErrors = new();
  74. for (int i = 0; i <= index; i++)
  75. {
  76. if (headerRow.GetCell(i)?.ToString() != headers[i])
  77. {
  78. char letter = (char)('A' + i);
  79. headerErrors.Add(letter.ToString());
  80. }
  81. }
  82. if (headerErrors.Any())
  83. {
  84. string columnErrors = string.Join("、", headerErrors);
  85. result.ErrorMessage.Add($"第2行标题行{columnErrors}列名错误。从A列开始依次应为年级号、班级号、缺测学生姓名、缺测学生监测号、缺测原因、缺测科目、家长电话、替补学生姓名、替补学生监测号和备注。");
  86. return result;
  87. }
  88. result.StructureCorrect = true;
  89. #endregion
  90. #region 处理数据
  91. // 监测年级
  92. var examGrades = await examGradeService.GetListByExamPlanId(examPlanId);
  93. // 科目列表
  94. var courses = await courseService.GetAllLiteList();
  95. // 科目字典
  96. var courseDicts = courses.ToDictionary(t => t.Name);
  97. // 读取数据
  98. List<UploadExamAbsentReplaceOutput> data = new();
  99. int rn = 0;
  100. while (rows.MoveNext())
  101. {
  102. IRow row = (IRow)rows.Current;
  103. string rv = row.GetCell(0)?.ToString().Trim() ?? "";
  104. rv += row.GetCell(1)?.ToString().Trim() ?? "";
  105. if (rv == "")
  106. {
  107. break;
  108. }
  109. UploadExamAbsentReplaceOutput item = new() { RowNumber = ++rn };
  110. // 年级
  111. if (short.TryParse(row.GetCell(GRADE_INDEX)?.ToString(), out short gradeNumber))
  112. {
  113. var g = examGrades.FirstOrDefault(t => t.Grade.GradeNumber == gradeNumber);
  114. if (g == null)
  115. {
  116. item.ErrorMessage.Add($"{headers[GRADE_INDEX]}与监测年级不符");
  117. }
  118. else
  119. {
  120. item.ExamGradeId = g.Id;
  121. item.GradeId = g.GradeId;
  122. }
  123. }
  124. else
  125. {
  126. item.ErrorMessage.Add(headers[CLASS_INDEX]);
  127. }
  128. // 班级
  129. if (short.TryParse(row.GetCell(CLASS_INDEX)?.ToString(), out short classNumber))
  130. {
  131. item.ClassNumber = classNumber;
  132. if (item.ClassNumber < 1 || item.ClassNumber > 35)
  133. {
  134. item.ErrorMessage.Add($"{headers[CLASS_INDEX]}超限");
  135. }
  136. }
  137. else
  138. {
  139. item.ErrorMessage.Add(headers[CLASS_INDEX]);
  140. }
  141. // 缺测学生姓名
  142. item.AbsentName = (row.GetCell(NAME_INDEX)?.ToString() ?? "").ClearWhitespace();
  143. if (item.AbsentName == "" || item.AbsentName.Length > 100)
  144. {
  145. item.ErrorMessage.Add($"{headers[NAME_INDEX]}未填或超出100字");
  146. }
  147. if (item.AbsentName.Length > 100) { item.AbsentName = item.AbsentName[..100]; }
  148. // 缺测学生监测号
  149. item.AbsentExamNumber = (row.GetCell(EXAM_NUM_INDEX)?.ToString() ?? "").ClearWhitespace().ToUpper();
  150. if (item.AbsentExamNumber == "" || item.AbsentExamNumber.Length > 20)
  151. {
  152. item.ErrorMessage.Add($"{headers[EXAM_NUM_INDEX]}格式错误");
  153. }
  154. if (item.AbsentExamNumber.Length > 20) { item.AbsentExamNumber = item.AbsentExamNumber[..20]; }
  155. // 缺测原因
  156. item.AbsentReason = (row.GetCell(REASON_INDEX)?.ToString() ?? "").ClearWhitespace();
  157. if (item.AbsentReason == "" || item.AbsentReason.Length > 200)
  158. {
  159. item.ErrorMessage.Add($"{headers[REASON_INDEX]}未填或超出200字");
  160. }
  161. if (item.AbsentReason.Length > 200) { item.AbsentReason = item.AbsentReason[..200]; }
  162. // 缺测科目
  163. item.AbsentCourseText = (row.GetCell(COURSES_INDEX)?.ToString() ?? "").ClearWhitespace();
  164. if (item.AbsentCourseText == "")
  165. {
  166. item.ErrorMessage.Add($"{headers[COURSES_INDEX]}未填");
  167. }
  168. else
  169. {
  170. var acourses = GetCourses(courseDicts, item.AbsentCourseText);
  171. item.AbsentCourseList = acourses.courses;
  172. if (acourses.errorMessage.Count > 0)
  173. {
  174. item.ErrorMessage.Add($"{headers[COURSES_INDEX]}({string.Join("、", acourses.errorMessage)})名称错误");
  175. }
  176. }
  177. // 缺测学生家长电话
  178. item.PatriarchTel = (row.GetCell(TEL_INDEX)?.ToString() ?? "").ClearWhitespace();
  179. if (item.PatriarchTel == "" || item.PatriarchTel.Length > 50)
  180. {
  181. item.ErrorMessage.Add($"{headers[TEL_INDEX]}未填或超出50字");
  182. }
  183. if (item.PatriarchTel.Length > 50) { item.PatriarchTel = item.PatriarchTel[..50]; }
  184. // 替补学生姓名
  185. item.ReplaceName = (row.GetCell(REPLACE_NAME_INDEX)?.ToString() ?? "").ClearWhitespace();
  186. if (item.ReplaceName.Length > 100) { item.ReplaceName = item.ReplaceName[..100]; }
  187. // 替补学生监测号
  188. item.ReplaceExamNumber = (row.GetCell(REPLACE_EXAM_NUM_INDEX)?.ToString() ?? "").ClearWhitespace().ToUpper();
  189. if (item.ReplaceExamNumber.Length > 20) { item.ReplaceExamNumber = item.ReplaceExamNumber[..20]; }
  190. if (item.ReplaceName.Length == 0 && item.ReplaceExamNumber.Length != 0 || item.ReplaceName.Length != 0 && item.ReplaceExamNumber.Length == 0)
  191. {
  192. item.ErrorMessage.Add($"有替补时替补学生姓名和监测号必须都填写");
  193. }
  194. // 备注
  195. item.Remark = (row.GetCell(REMARK_INDEX)?.ToString() ?? "").ClearWhitespace();
  196. if (item.Remark.Length > 200) { item.Remark = item.Remark[..200]; }
  197. // 行是否验证通过
  198. item.IsSuccess = item.ErrorMessage.Count == 0;
  199. data.Add(item);
  200. result.TotalRowCount++;
  201. if (!item.IsSuccess)
  202. {
  203. result.ErrorRowCount++;
  204. }
  205. }
  206. result.Rows = data;
  207. #endregion
  208. workbook.Close();
  209. fs.Close();
  210. }
  211. catch (Exception ex)
  212. {
  213. throw new Exception(ex.Message);
  214. }
  215. finally
  216. {
  217. File.Delete(filePath);
  218. }
  219. return result;
  220. }
  221. /// <summary>
  222. /// 批量导入监测缺测替补
  223. /// </summary>
  224. /// <param name="input"></param>
  225. /// <returns></returns>
  226. public async Task<int> Import(ImportExamAbsentReplaceInput input)
  227. {
  228. var orgId = input.SysOrgId ?? CurrentSysUserInfo.SysOrgId;
  229. var existsIdNumberList = await rep.DetachedEntities.Where(t => t.ExamPlanId == input.ExamPlanId && t.SysOrgId == orgId).Select(t => t.AbsentExamNumber).Distinct().ToListAsync() ?? new List<string>();
  230. List<ExamAbsentReplace> items = new();
  231. var spStus = input.Items.Where(t => !existsIdNumberList.Contains(t.AbsentExamNumber)).ToList();
  232. var gs = spStus.Select(t => t.ExamGradeId).Distinct().ToList();
  233. var examGrades = await rep.Change<ExamGrade>().DetachedEntities.Where(t => gs.Contains(t.Id)).Select(t => t.Adapt<ExamGradeOutput>()).ToListAsync();
  234. int c = 0;
  235. foreach (var eg in examGrades)
  236. {
  237. var classNumbers = spStus.Where(t => t.ExamGradeId == eg.Id).Select(t => t.ClassNumber).Distinct().ToList();
  238. var classDict = await schoolClassService.GetImportSchoolClassList(new()
  239. {
  240. SysOrgId = orgId,
  241. SysOrgBranchId = input.SysOrgBranchId,
  242. ExamGrade = eg,
  243. ClassNumberList = classNumbers,
  244. });
  245. var citems = spStus.Where(t => t.ExamGradeId == eg.Id).ToList();
  246. foreach (var ni in citems)
  247. {
  248. var item = ni.Adapt<ExamAbsentReplace>();
  249. item.ExamPlanId = input.ExamPlanId;
  250. item.SysOrgId = orgId;
  251. item.SysOrgBranchId = input.SysOrgBranchId;
  252. item.SchoolClassId = classDict[ni.ClassNumber];
  253. item.AbsentName = item.AbsentName?.ClearWhitespace();
  254. item.AbsentExamNumber = item.AbsentExamNumber?.ClearWhitespace();
  255. item.ReplaceName = item.ReplaceName?.ClearWhitespace();
  256. item.ReplaceExamNumber = item.ReplaceExamNumber?.ClearWhitespace();
  257. items.Add(item);
  258. c++;
  259. }
  260. }
  261. await rep.InsertAsync(items);
  262. return c;
  263. }
  264. #endregion
  265. #region 创建编辑
  266. /// <summary>
  267. /// 添加监测缺测替补
  268. /// </summary>
  269. /// <param name="input"></param>
  270. /// <returns></returns>
  271. public async Task Add(AddExamAbsentReplaceInput input)
  272. {
  273. var orgId = CurrentSysUserInfo.SysOrgId;
  274. // 检测同一监测计划中同机构内是否有相同监测号的学生
  275. var sameItems = await rep.DetachedEntities.Where(t => t.ExamPlanId == input.ExamPlanId && t.SysOrgId == orgId && t.AbsentExamNumber.ToUpper() == input.AbsentExamNumber.ToUpper()).ProjectToType<ExamAbsentReplaceOutput>().ToListAsync();
  276. if (sameItems.Count != 0)
  277. {
  278. throw Oops.Oh(ErrorCode.E2003, string.Join("、", sameItems.Select(t => $"{t.ExamGrade.Grade.Name}{t.ClassNumber}班{t.AbsentName}")), "监测号");
  279. }
  280. var examGrade = await examGradeService.GetById(input.ExamGradeId);
  281. var schoolClass = await schoolClassService.GetSchoolClass(orgId, input.SysOrgBranchId, examGrade, input.ClassNumber);
  282. var item = input.Adapt<ExamAbsentReplace>();
  283. item.SysOrgId = orgId;
  284. item.SchoolClassId = schoolClass.Id;
  285. item.AbsentName = item.AbsentName?.ClearWhitespace();
  286. item.AbsentExamNumber = item.AbsentExamNumber?.ClearWhitespace();
  287. item.ReplaceName = item.ReplaceName?.ClearWhitespace();
  288. item.ReplaceExamNumber = item.ReplaceExamNumber?.ClearWhitespace();
  289. await item.InsertAsync();
  290. }
  291. /// <summary>
  292. /// 更新监测缺测替补
  293. /// </summary>
  294. /// <param name="input"></param>
  295. /// <returns></returns>
  296. public async Task Update(UpdateExamAbsentReplaceInput input)
  297. {
  298. var oitem = await rep.DetachedEntities.FirstOrDefaultAsync(t => t.Id == input.Id) ?? throw Oops.Oh(ErrorCode.E2001);
  299. var examGrade = await examGradeService.GetById(oitem.ExamGradeId);
  300. var schoolClass = await schoolClassService.GetSchoolClass(oitem.SysOrgId, input.SysOrgBranchId, examGrade, input.ClassNumber);
  301. var item = input.Adapt<ExamAbsentReplace>();
  302. item.SchoolClassId = schoolClass.Id;
  303. item.AbsentName = item.AbsentName?.ClearWhitespace();
  304. item.AbsentExamNumber = item.AbsentExamNumber?.ClearWhitespace();
  305. item.ReplaceName = item.ReplaceName?.ClearWhitespace();
  306. item.ReplaceExamNumber = item.ReplaceExamNumber?.ClearWhitespace();
  307. await item.UpdateIncludeAsync(new[] {
  308. nameof(item.SysOrgBranchId),
  309. nameof(item.SchoolClassId),
  310. nameof(item.ClassNumber),
  311. nameof(item.AbsentName),
  312. nameof(item.AbsentExamNumber),
  313. nameof(item.AbsentReason),
  314. nameof(item.AbsentCourses),
  315. nameof(item.IsReplaced),
  316. nameof(item.ReplaceName),
  317. nameof(item.ReplaceExamNumber),
  318. nameof(item.Remark),
  319. nameof(item.PatriarchName),
  320. nameof(item.PatriarchTel),
  321. });
  322. }
  323. /// <summary>
  324. /// 添加缺测替补佐证材料
  325. /// </summary>
  326. /// <param name="input"></param>
  327. /// <returns></returns>
  328. public async Task AddAttachment(AddAttachmentInput input)
  329. {
  330. var item = await rep.FirstOrDefaultAsync(t => t.Id == input.SourceId) ?? throw Oops.Oh(ErrorCode.E2001);
  331. item.Attachments = AttachmentUtil.InsertInto(item.Attachments, input.Adapt<AttachmentItem>());
  332. await item.UpdateIncludeAsync([nameof(item.Attachments)]);
  333. }
  334. /// <summary>
  335. /// 删除缺测替补佐证材料
  336. /// </summary>
  337. /// <param name="input"></param>
  338. /// <returns></returns>
  339. public async Task DelAttachment(DeleteAttachmentInput input)
  340. {
  341. var item = await rep.FirstOrDefaultAsync(t => t.Id == input.SourceId) ?? throw Oops.Oh(ErrorCode.E2001);
  342. var attachments = AttachmentUtil.GetList(item.Attachments);
  343. var a = attachments.FirstOrDefault(t => t.FileId == input.FileId);
  344. if (a != null)
  345. {
  346. attachments.Remove(a);
  347. item.Attachments = JSON.Serialize(attachments);
  348. await item.UpdateIncludeAsync(new[] { nameof(item.Attachments) });
  349. await resourceFileService.Del(new() { Id = a.FileId });
  350. if (a.ThumbFileId.HasValue && a.ThumbFileId > 0)
  351. {
  352. await resourceFileService.Del(new() { Id = a.ThumbFileId.Value });
  353. }
  354. }
  355. }
  356. /// <summary>
  357. /// 验证缺测替补佐证材料
  358. /// </summary>
  359. /// <param name="examPlanId"></param>
  360. /// <returns></returns>
  361. public async Task<bool> VerifyAttachment(int examPlanId)
  362. {
  363. var items = await rep.DetachedEntities.Where(t => t.ExamPlanId == examPlanId && t.SysOrgId == CurrentSysUserInfo.SysOrgId).ProjectToType<ExamAbsentReplaceOutput>().ToListAsync();
  364. if (items.Any(t => t.AttachmentList.Count == 0))
  365. {
  366. return false;
  367. }
  368. return true;
  369. }
  370. /// <summary>
  371. /// 删除监测缺测替补
  372. /// </summary>
  373. /// <param name="input"></param>
  374. /// <returns></returns>
  375. public async Task Del(BaseId input)
  376. {
  377. var item = await rep.FirstOrDefaultAsync(t => t.Id == input.Id) ?? throw Oops.Oh(ErrorCode.E2001);
  378. var attachments = JSON.Deserialize<List<AttachmentItem>>(item.Attachments);
  379. if (attachments != null && attachments.Count != 0)
  380. {
  381. foreach (var attachment in attachments)
  382. {
  383. await resourceFileService.Del(new() { Id = attachment.FileId });
  384. if (attachment.ThumbFileId.HasValue && attachment.ThumbFileId > 0)
  385. {
  386. await resourceFileService.Del(new() { Id = attachment.ThumbFileId.Value });
  387. }
  388. }
  389. }
  390. await item.DeleteAsync();
  391. }
  392. /// <summary>
  393. /// 清空监测缺测替补
  394. /// </summary>
  395. /// <param name="input"></param>
  396. /// <returns></returns>
  397. public async Task Clear(ClearExamAbsentReplaceInput input)
  398. {
  399. var orgId = CurrentSysUserInfo.SysOrgId;
  400. await rep.Where(t => t.ExamPlanId == input.ExamPlanId && t.SysOrgId == orgId).ExecuteDeleteAsync();
  401. }
  402. /// <summary>
  403. /// 导出监测缺测替补上报打印表格
  404. /// </summary>
  405. /// <param name="examPlanId"></param>
  406. /// <returns></returns>
  407. public async Task<byte[]> ExportPrintTable(int examPlanId)
  408. {
  409. var items = await rep.DetachedEntities.Include(t => t.Grade).Include(t => t.SysOrg).Where(t => t.ExamPlanId == examPlanId && t.SysOrgId == CurrentSysUserInfo.SysOrgId).ToListAsync();
  410. if (items.Count == 0)
  411. {
  412. throw Oops.Oh(ErrorCode.E2001);
  413. }
  414. // 获取证件类型
  415. var cts = await sysDictDataService.GetListByDictTypeId(304);
  416. var certificateTypes = cts.ToDictionary(x => (CertificateType)x.Value, y => y.Name);
  417. XWPFDocument doc = new();
  418. doc.Document.body.sectPr = new();
  419. var sectPr = doc.Document.body.sectPr;
  420. sectPr.pgSz.orient = ST_PageOrientation.landscape;
  421. sectPr.pgSz.w = 16838;
  422. sectPr.pgSz.h = 11906;
  423. sectPr.pgMar.left = sectPr.pgMar.right = 1080;
  424. sectPr.pgMar.top = sectPr.pgMar.bottom = 1440;
  425. var gradeItems = items.GroupBy(t => t.GradeId).OrderBy(t => t.Key).ToList();
  426. int pi = 0;
  427. foreach (var gitem in gradeItems)
  428. {
  429. var gradeFirst = gitem.First();
  430. // 多于一个年级分多页
  431. if (0 < pi++)
  432. {
  433. doc.CreateParagraph().IsPageBreak = true;
  434. }
  435. // 标题行
  436. XWPFParagraph pHeader = doc.CreateParagraph();
  437. pHeader.Alignment = ParagraphAlignment.CENTER;
  438. pHeader.SpacingLineRule = LineSpacingRule.AUTO;
  439. pHeader.SetSpacingBetween(1.5, LineSpacingRule.AUTO);
  440. var pHeaderRun = pHeader.CreateRun();
  441. pHeaderRun.SetText($"{gradeFirst.SysOrg.FullName.Replace("重庆市", "").Replace("重庆", "")}缺测替补明细表({gradeFirst.Grade.Name})");
  442. pHeaderRun.FontSize = 18;
  443. pHeaderRun.IsBold = true;
  444. // 空行
  445. CreateBlanParagraph();
  446. // 签字行
  447. XWPFParagraph pSign = doc.CreateParagraph();
  448. pSign.SpacingLineRule = LineSpacingRule.AUTO;
  449. pSign.SetSpacingBetween(2, LineSpacingRule.AUTO);
  450. var pSignRun = pSign.CreateRun();
  451. pSignRun.SetText("学校盖章: 纪检负责人: 校长签字:");
  452. pSignRun.FontSize = 12;
  453. // 签字行
  454. XWPFParagraph pCount = doc.CreateParagraph();
  455. pCount.SpacingLineRule = LineSpacingRule.AUTO;
  456. pCount.SetSpacingBetween(2, LineSpacingRule.AUTO);
  457. var dt = DateTime.Now;
  458. var pCountRun = pCount.CreateRun();
  459. pCountRun.SetText($"填表人: 联系电话: 督考签字: 缺测替补计({gitem.Count()})人 {dt.Year}年{dt.Month}月{dt.Day}日");
  460. pCountRun.FontSize = 12;
  461. // 空行
  462. CreateBlanParagraph(1);
  463. #region 生成表格
  464. const int COLUMN_COUNT = 10;
  465. XWPFTable table = doc.CreateTable(gitem.Count() + 2, COLUMN_COUNT);
  466. var tableLayout = table.GetCTTbl().tblPr.AddNewTblLayout();
  467. tableLayout.type = ST_TblLayoutType.@fixed;
  468. table.Width = 5080;
  469. table.SetColumnWidth(0, 280);
  470. table.SetColumnWidth(1, 280);
  471. table.SetColumnWidth(2, 540);
  472. table.SetColumnWidth(3, 640);
  473. table.SetColumnWidth(4, 1000);
  474. table.SetColumnWidth(5, 1200);
  475. table.SetColumnWidth(6, 660);
  476. table.SetColumnWidth(7, 540);
  477. table.SetColumnWidth(8, 640);
  478. table.SetColumnWidth(9, 660);
  479. int ri = 0;
  480. table.GetRow(ri).GetCTRow().AddNewTrPr().AddNewTrHeight().val = 480;
  481. table.GetRow(ri).GetCell(0).SetParagraph(SetCellText(table, "序号", ParagraphAlignment.CENTER, true));
  482. table.GetRow(ri).GetCell(1).SetParagraph(SetCellText(table, "班级", ParagraphAlignment.CENTER, true));
  483. table.GetRow(ri).GetCell(2).SetParagraph(SetCellText(table, "学生姓名", ParagraphAlignment.CENTER, true));
  484. table.GetRow(ri).GetCell(3).SetParagraph(SetCellText(table, "监测号", ParagraphAlignment.CENTER, true));
  485. table.GetRow(ri).GetCell(4).SetParagraph(SetCellText(table, "缺测原因", ParagraphAlignment.CENTER, true));
  486. table.GetRow(ri).GetCell(5).SetParagraph(SetCellText(table, "缺测科目", ParagraphAlignment.CENTER, true));
  487. table.GetRow(ri).GetCell(6).SetParagraph(SetCellText(table, "家长电话", ParagraphAlignment.CENTER, true));
  488. table.GetRow(ri).GetCell(7).SetParagraph(SetCellText(table, "有替补学生", ParagraphAlignment.CENTER, true));
  489. table.GetRow(ri).GetCell(8).SetParagraph(SetCellText(table, null, ParagraphAlignment.CENTER, true));
  490. table.GetRow(ri).GetCell(9).SetParagraph(SetCellText(table, "备注", ParagraphAlignment.CENTER, true));
  491. for (int ci = 0; ci < COLUMN_COUNT; ci++)
  492. {
  493. table.GetRow(ri).GetCell(ci).GetCTTc().AddNewTcPr().AddNewVAlign().val = ST_VerticalJc.center;
  494. }
  495. ri++;
  496. table.GetRow(ri).GetCTRow().AddNewTrPr().AddNewTrHeight().val = 480;
  497. table.GetRow(ri).GetCell(7).SetParagraph(SetCellText(table, "姓名", ParagraphAlignment.CENTER, true));
  498. table.GetRow(ri).GetCell(7).GetCTTc().AddNewTcPr().AddNewVAlign().val = ST_VerticalJc.center;
  499. table.GetRow(ri).GetCell(8).SetParagraph(SetCellText(table, "监测号", ParagraphAlignment.CENTER, true));
  500. table.GetRow(ri).GetCell(8).GetCTTc().AddNewTcPr().AddNewVAlign().val = ST_VerticalJc.center;
  501. MergeCells(table, 9, 9, ri - 1, ri);
  502. MergeCells(table, 7, 8, ri - 1, ri - 1);
  503. for (int i = 0; i < 7; i++)
  504. {
  505. MergeCells(table, i, i, ri - 1, ri);
  506. }
  507. int tableRowNumber = 1;
  508. foreach (var item in gitem)
  509. {
  510. var courses = JSON.Deserialize<List<CourseMiniOutput>>(item.AbsentCourses);
  511. var courseText = string.Join("、", courses.Select(t => t.Name));
  512. ri++;
  513. table.GetRow(ri).GetCTRow().AddNewTrPr().AddNewTrHeight().val = 480;
  514. table.GetRow(ri).GetCell(0).SetParagraph(SetCellText(table, $"{tableRowNumber++}", ParagraphAlignment.CENTER));
  515. table.GetRow(ri).GetCell(1).SetParagraph(SetCellText(table, $"{item.ClassNumber}", ParagraphAlignment.CENTER));
  516. table.GetRow(ri).GetCell(2).SetParagraph(SetCellText(table, item.AbsentName, ParagraphAlignment.CENTER));
  517. table.GetRow(ri).GetCell(3).SetParagraph(SetCellText(table, item.AbsentExamNumber, ParagraphAlignment.CENTER));
  518. table.GetRow(ri).GetCell(4).SetParagraph(SetCellText(table, item.AbsentReason, ParagraphAlignment.LEFT));
  519. table.GetRow(ri).GetCell(5).SetParagraph(SetCellText(table, courseText, ParagraphAlignment.LEFT));
  520. table.GetRow(ri).GetCell(6).SetParagraph(SetCellText(table, item.PatriarchTel, ParagraphAlignment.CENTER));
  521. table.GetRow(ri).GetCell(7).SetParagraph(SetCellText(table, item.ReplaceName, ParagraphAlignment.CENTER));
  522. table.GetRow(ri).GetCell(8).SetParagraph(SetCellText(table, item.ReplaceExamNumber, ParagraphAlignment.CENTER));
  523. table.GetRow(ri).GetCell(9).SetParagraph(SetCellText(table, item.Remark, ParagraphAlignment.LEFT));
  524. for (int ci = 0; ci < COLUMN_COUNT; ci++)
  525. {
  526. table.GetRow(ri).GetCell(ci).GetCTTc().AddNewTcPr().AddNewVAlign().val = ST_VerticalJc.center;
  527. }
  528. }
  529. // 空行
  530. CreateBlanParagraph();
  531. #endregion
  532. }
  533. // 生成流
  534. using MemoryStream ms = new();
  535. doc.Write(ms);
  536. doc.Close();
  537. var retDoc = ms.ToArray();
  538. ms.Close();
  539. return retDoc;
  540. // 创建空行
  541. void CreateBlanParagraph(double lineSpacing = 1.5)
  542. {
  543. var p = doc.CreateParagraph();
  544. p.SpacingLineRule = LineSpacingRule.AUTO;
  545. p.SetSpacingBetween(lineSpacing, LineSpacingRule.AUTO);
  546. p.CreateRun().FontSize = 12;
  547. }
  548. }
  549. #endregion
  550. #region 查询统计
  551. /// <summary>
  552. /// 分页查询监测缺测替补列表
  553. /// </summary>
  554. /// <param name="input"></param>
  555. /// <returns></returns>
  556. public async Task<PageResult<ExamAbsentReplaceOutput>> QueryPageList(ExamAbsentReplacePageInput input)
  557. {
  558. var query = GetQueryBase(input);
  559. var ret = await query.OrderBy(t => t.GradeId).ThenBy(t => t.ClassNumber).ThenBy(t => t.Id)
  560. .ProjectToType<ExamAbsentReplaceOutput>()
  561. .ToADPagedListAsync(input.PageIndex, input.PageSize);
  562. return ret;
  563. }
  564. /// <summary>
  565. /// 获取机构班级缺测替补上报人数统计列表
  566. /// </summary>
  567. /// <param name="examPlanId"></param>
  568. /// <param name="sysOrgId"></param>
  569. /// <returns></returns>
  570. public async Task<ExamAbsentReplaceCountOutput> GetOrgGradeClassStudentCount(int examPlanId, short? sysOrgId = null)
  571. {
  572. var orgId = sysOrgId ?? CurrentSysUserInfo.SysOrgId;
  573. var items = await rep.DetachedEntities.Where(t => t.ExamPlanId == examPlanId && t.SysOrgId == orgId)
  574. .GroupBy(t => new { t.GradeId, t.ClassNumber })
  575. .Select(t => new
  576. {
  577. t.Key.GradeId,
  578. t.Key.ClassNumber,
  579. t.FirstOrDefault().Grade,
  580. Count = t.Count(),
  581. })
  582. .ToListAsync();
  583. var cols = items.Select(t => t.ClassNumber).Distinct().ToList();
  584. var retItems = items.ToPivotList(c => c.ClassNumber, r => r.GradeId, d => d.Any() ? d.Sum(x => x.Count) : 0);
  585. foreach (var item in retItems)
  586. {
  587. item.Grade = items.FirstOrDefault(t => t.GradeId == item.GradeId).Grade;
  588. item.GradeTotal = items.Where(t => t.GradeId == item.GradeId).Sum(x => x.Count);
  589. }
  590. int total = retItems.Sum(x => x.GradeTotal);
  591. IDictionary<string, object> totalItem = new ExpandoObject();
  592. totalItem.Add("GradeId", 9999);
  593. totalItem.Add("Grade", new { Id = 9999, Name = "合计" });
  594. totalItem.Add("GradeTotal", total);
  595. retItems.Add(totalItem);
  596. return new()
  597. {
  598. ClassNumberList = cols,
  599. Items = retItems,
  600. Total = total,
  601. };
  602. }
  603. /// <summary>
  604. /// 获取状态数量
  605. /// </summary>
  606. /// <returns></returns>
  607. public async Task<List<StatusCount>> QueryStatusCount(ExamAbsentReplacePageInput input)
  608. {
  609. var query = GetQueryBase(input);
  610. if (query == null)
  611. {
  612. return [];
  613. }
  614. var counts = await query.GroupBy(t => t.Status).Select(t => new StatusCount { Status = (int)t.Key, Count = t.Count() }).ToListAsync();
  615. return counts;
  616. }
  617. #endregion
  618. #region 公有静态方法
  619. /// <summary>
  620. /// 根据科目字符串组合获取科目列表
  621. /// </summary>
  622. /// <param name="courseDict">科目字典</param>
  623. /// <param name="courses">科目组合</param>
  624. /// <returns></returns>
  625. public static (List<string> errorMessage, List<CourseMiniOutput> courses) GetCourses(Dictionary<string, CourseLiteOutput> courseDict, string courses)
  626. {
  627. List<CourseMiniOutput> ret = [];
  628. List<string> errs = [];
  629. var cns = courses.ClearWhitespace().Split(['、', ',', ',', ';', ';']);
  630. foreach (var cn in cns)
  631. {
  632. if (courseDict.TryGetValue(cn, out CourseLiteOutput c))
  633. {
  634. if (ret.Any(t => t.Id != c.Id))
  635. {
  636. ret.Add(c.Adapt<CourseMiniOutput>());
  637. }
  638. }
  639. else
  640. {
  641. errs.Add(cn);
  642. }
  643. }
  644. return (errs, ret);
  645. }
  646. #endregion
  647. #region 私有方法
  648. /// <summary>
  649. /// 构建查询
  650. /// </summary>
  651. /// <param name="input"></param>
  652. /// <returns></returns>
  653. private IQueryable<ExamAbsentReplace> GetQueryBase(ExamAbsentReplacePageInput input)
  654. {
  655. var orgId = input.SysOrgId ?? CurrentSysUserInfo.SysOrgId;
  656. var absentName = !string.IsNullOrEmpty(input.AbsentName?.Trim());
  657. var absentExamNumber = !string.IsNullOrEmpty(input.AbsentExamNumber?.Trim());
  658. var absentReason = !string.IsNullOrEmpty(input.AbsentReason?.Trim());
  659. var replaceName = !string.IsNullOrEmpty(input.ReplaceName?.Trim());
  660. var replaceExamNumber = !string.IsNullOrEmpty(input.ReplaceExamNumber?.Trim());
  661. var patriarchTel = !string.IsNullOrEmpty(input.PatriarchTel?.Trim());
  662. var remark = !string.IsNullOrEmpty(input.Remark?.Trim());
  663. var query = rep.DetachedEntities.Where(t => t.ExamPlanId == input.ExamPlanId && t.SysOrgId == orgId)
  664. .Where((absentName, u => EF.Functions.Like(u.AbsentName, $"%{input.AbsentName.Trim()}%")))
  665. .Where((absentExamNumber, u => EF.Functions.Like(u.AbsentExamNumber, $"%{input.AbsentExamNumber.Trim()}%")))
  666. .Where((absentReason, u => EF.Functions.Like(u.AbsentReason, $"%{input.AbsentReason.Trim()}%")))
  667. .Where((replaceName, u => EF.Functions.Like(u.ReplaceName, $"%{input.ReplaceName.Trim()}%")))
  668. .Where((replaceExamNumber, u => EF.Functions.Like(u.ReplaceExamNumber, $"%{input.ReplaceExamNumber.Trim()}%")))
  669. .Where((patriarchTel, u => EF.Functions.Like(u.PatriarchTel, $"%{input.PatriarchTel.Trim()}%")))
  670. .Where((remark, u => EF.Functions.Like(u.Remark, $"%{input.Remark.Trim()}%")))
  671. .Where((input.AbentCourseId.HasValue, u => EF.Functions.Like(u.AbsentCourses, $"%{input.AbentCourseId}%")))
  672. .Where(input.Status.HasValue, t => t.Status == input.Status)
  673. .Where(input.IsReplaced.HasValue, t => t.IsReplaced == input.IsReplaced)
  674. .Where(input.GradeId.HasValue, t => t.GradeId == input.GradeId)
  675. .Where(input.ClassNumber.HasValue, t => t.ClassNumber == input.ClassNumber)
  676. .Where(input.SysOrgBranchId.HasValue, t => t.SchoolClass.SysOrgBranchId == input.SysOrgBranchId);
  677. return query;
  678. }
  679. /// <summary>
  680. /// 设置单元格文本
  681. /// </summary>
  682. /// <param name="table"></param>
  683. /// <param name="text"></param>
  684. /// <param name="align"></param>
  685. /// <param name="isBold"></param>
  686. /// <returns></returns>
  687. private static XWPFParagraph SetCellText(XWPFTable table, string text, ParagraphAlignment align = ParagraphAlignment.CENTER, bool isBold = false)
  688. {
  689. CT_P para = new();
  690. XWPFParagraph pCell = new(para, table.Body)
  691. {
  692. Alignment = align,
  693. VerticalAlignment = TextAlignment.CENTER,
  694. };
  695. XWPFRun r1 = pCell.CreateRun();
  696. r1.SetText(text);
  697. r1.FontSize = 11;
  698. r1.FontFamily = "宋体";
  699. r1.IsBold = isBold;
  700. return pCell;
  701. }
  702. /// <summary>
  703. /// 合并单元格
  704. /// </summary>
  705. /// <param name="table"></param>
  706. /// <param name="fromCol"></param>
  707. /// <param name="toCol"></param>
  708. /// <param name="fromRow"></param>
  709. /// <param name="toRow"></param>
  710. /// <returns></returns>
  711. private static XWPFTableCell MergeCells(XWPFTable table, int fromCol, int toCol, int fromRow, int toRow)
  712. {
  713. for (int rowIndex = fromRow; rowIndex <= toRow; rowIndex++)
  714. {
  715. if (fromCol < toCol)
  716. {
  717. table.GetRow(rowIndex).MergeCells(fromCol, toCol);
  718. }
  719. XWPFTableCell rowcell = table.GetRow(rowIndex).GetCell(fromCol);
  720. CT_Tc cttc = rowcell.GetCTTc();
  721. if (cttc.tcPr == null)
  722. {
  723. cttc.AddNewTcPr();
  724. }
  725. if (rowIndex == fromRow)
  726. {
  727. // The first merged cell is set with RESTART merge value
  728. rowcell.GetCTTc().tcPr.AddNewVMerge().val = ST_Merge.restart;
  729. }
  730. else
  731. {
  732. // Cells which join (merge) the first one, are set with CONTINUE
  733. rowcell.GetCTTc().tcPr.AddNewVMerge().val = ST_Merge.@continue;
  734. }
  735. }
  736. table.GetRow(fromRow).GetCell(fromCol).SetVerticalAlignment(XWPFTableCell.XWPFVertAlign.CENTER);
  737. //table.GetRow(fromRow).GetCell(fromCol).Paragraphs[0].Alignment = ParagraphAlignment.CENTER;
  738. table.GetRow(fromRow).GetCell(fromCol).Paragraphs[0].Alignment = ParagraphAlignment.LEFT;
  739. return table.GetRow(fromRow).GetCell(fromCol);
  740. }
  741. #endregion
  742. }