TmtnAlarmOrderController.cs 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747
  1. using Microsoft.AspNetCore.Mvc;
  2. using Microsoft.Extensions.Logging;
  3. using Ropin.Inspection.Api.Common;
  4. using Ropin.Inspection.Model;
  5. using Ropin.Inspection.Service.DEV.Interface;
  6. using Ropin.Inspection.Service.MTN.Interface;
  7. using System.Collections.Generic;
  8. using System.Threading.Tasks;
  9. using System;
  10. using Ropin.Inspection.Model.ViewModel.MTN;
  11. using Ropin.Inspection.Model.SearchModel.MTN;
  12. using Ropin.Inspection.Service;
  13. using Microsoft.AspNetCore.Authorization;
  14. using NPOI.SS.UserModel;
  15. using NPOI.Util;
  16. using NPOI.XSSF.UserModel;
  17. using NPOI.XWPF.UserModel;
  18. using Ropin.Inspection.Model.Common;
  19. using System.IO.Compression;
  20. using System.IO;
  21. using System.Linq;
  22. using log4net;
  23. using NPOI.SS.Formula.Functions;
  24. using Newtonsoft.Json;
  25. using ICSharpCode.SharpZipLib.Zip;
  26. using Ropin.Inspection.Common.Helper;
  27. using NPOI.SS.Formula;
  28. namespace Ropin.Inspection.Api.Controllers.MTN
  29. {
  30. public class TmtnAlarmOrderController : BaseController
  31. {
  32. public ILogger<TmtnAlarmOrderController> _logger { get; }
  33. private readonly ITmtnAlarmOrderService _repository;
  34. private readonly IPushMsgService _pushMsgService;
  35. private readonly ITmtnPushMsgResultService _tmtnPushMsgResultService;
  36. private static readonly ILog log = LogManager.GetLogger(typeof(TmtnAlarmOrderController));
  37. /// <summary>
  38. /// 构造函数
  39. /// </summary>
  40. /// <param name="logger"></param>
  41. /// <param name="repository"></param>
  42. /// <param name="pushMsgService"></param>
  43. /// <param name="tmtnPushMsgResultService"></param>
  44. public TmtnAlarmOrderController(ILogger<TmtnAlarmOrderController> logger, ITmtnAlarmOrderService repository, IPushMsgService pushMsgService, ITmtnPushMsgResultService tmtnPushMsgResultService)
  45. {
  46. _logger = logger;
  47. _repository = repository;
  48. _pushMsgService = pushMsgService;
  49. _tmtnPushMsgResultService = tmtnPushMsgResultService;
  50. }
  51. /// <summary>
  52. /// 创建报警工单
  53. /// </summary>
  54. /// <param name="content"></param>
  55. /// <returns></returns>
  56. [HttpPost("CreateAsync")]
  57. public async Task<ApiResult> CreateAsync(AlarmOrderViewModel content)
  58. {
  59. if (content == null)
  60. {
  61. return new ApiResult(ReturnCode.ArgsError);
  62. }
  63. try
  64. {
  65. await _repository.CreateOneAsync(content);
  66. }
  67. catch (Exception ex)
  68. {
  69. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  70. }
  71. return new ApiResult(ReturnCode.Success);
  72. }
  73. /// <summary>
  74. /// 创建报警工单+处理记录
  75. /// </summary>
  76. /// <param name="content"></param>
  77. /// <returns></returns>
  78. [HttpPost("CreateAlarmOrderAsync")]
  79. public async Task<ApiResult> CreateAlarmOrderAsync(AddAlarmOrderViewModel content)
  80. {
  81. if (content == null|| content.C_PushMsgResultCode==null)
  82. {
  83. return new ApiResult(ReturnCode.ArgsError);
  84. }
  85. try
  86. {
  87. await _repository.CreateOrderAsync(content);
  88. log.Info($"创建报警工单+处理记录-保存数据成功【数据=[{JsonConvert.SerializeObject(content)}]】");
  89. //Guid guid = Guid.Parse(content.C_PushMsgResultCode);
  90. var PushMsg=await _tmtnPushMsgResultService.GetByIdAsync(content.C_PushMsgResultCode);
  91. log.Info($"创建报警工单+处理记录-根据PushMsgResultCode获取 TMTN_PushMsgResult 数据=[{JsonConvert.SerializeObject(PushMsg)}]");
  92. await _pushMsgService.PushAlarmMsgAsync(new TpushMsgModel
  93. {
  94. C_DevStoreCode = PushMsg.C_DevStoreCode,
  95. C_MsgTypeCode = "MSG_TYPE_019",
  96. Msg = content.C_Record,//content.C_Name + " " + content.C_Remark,
  97. Subject = content.C_Name,//"上报报警," + content.C_Name,
  98. DevNumber = PushMsg.C_DevStoreCode,
  99. DevName = "",
  100. GenerationType = 2,
  101. msgStatus = 0,
  102. },"设备报警工单");
  103. log.Info($"创建报警工单+处理记录-保存数据END");
  104. }
  105. catch (Exception ex)
  106. {
  107. log.Info($"创建报警工单+处理记录-保存数据成功异常【{ex.Message}】");
  108. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  109. }
  110. return new ApiResult(ReturnCode.Success);
  111. }
  112. /// <summary>
  113. /// 删除报警工单
  114. /// </summary>
  115. /// <param name="id"></param>
  116. /// <returns></returns>
  117. [HttpDelete("DeleteAsync/{id}")]
  118. public async Task<ApiResult> DeleteAsync(string id)
  119. {
  120. if (string.IsNullOrEmpty(id))
  121. {
  122. return new ApiResult(ReturnCode.GeneralError);
  123. }
  124. try
  125. {
  126. await _repository.DeleteAsync(id);
  127. }
  128. catch (Exception ex)
  129. {
  130. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  131. }
  132. return new ApiResult(ReturnCode.Success);
  133. }
  134. /// <summary>
  135. /// 更新报警工单
  136. /// </summary>
  137. /// <param name="id"></param>
  138. /// <param name="updateModel"></param>
  139. /// <returns></returns>
  140. [HttpPut("UpdateAsync/{id}")]
  141. public async Task<ApiResult> UpdateAsync(string id, AlarmOrderViewModel updateModel)
  142. {
  143. if (string.IsNullOrEmpty(id))
  144. {
  145. return new ApiResult(ReturnCode.GeneralError);
  146. }
  147. try
  148. {
  149. await _repository.UpdateAsync(id, updateModel);
  150. log.Info($"更新报警工单-保存数据成功【id={id};数据=[{JsonConvert.SerializeObject(updateModel)}]】");
  151. var content = await _repository.GetByIdAsync(id);
  152. if (updateModel.C_Status=="5") {
  153. await _pushMsgService.PushAlarmMsgAsync(new TpushMsgModel
  154. {
  155. C_DevStoreCode = content.C_DevStoreCode,
  156. C_MsgTypeCode = "MSG_TYPE_020",
  157. Msg = updateModel.C_Remark,//content.C_Name + " " + updateModel.C_Remark,
  158. Subject = content.C_Name,//"报警取消," + content.C_Name,
  159. DevNumber = content.C_DevStoreCode,
  160. DevName = content.C_DevName,
  161. GenerationType = 2,
  162. msgStatus = 0,
  163. },"设备报警工单");
  164. }
  165. log.Info($"更新报警工单-保存数据END");
  166. }
  167. catch (Exception ex)
  168. {
  169. log.Info($"更新报警工单-保存数据成功异常【{ex.Message}】");
  170. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  171. }
  172. return new ApiResult(ReturnCode.Success);
  173. }
  174. /// <summary>
  175. /// 报警工单-流程
  176. /// </summary>
  177. /// <param name="id"></param>
  178. /// <param name="updateModel"></param>
  179. /// <returns></returns>
  180. [HttpPut("OrderFlowAsync/{id}")]
  181. public async Task<ApiResult> OrderFlowAsync(string id, UpdateAlarmOrderViewModel updateModel)
  182. {
  183. if (string.IsNullOrEmpty(id))
  184. {
  185. return new ApiResult(ReturnCode.GeneralError);
  186. }
  187. try
  188. {
  189. await _repository.OrderFlowAsync(id, updateModel);
  190. log.Info($"报警工单-流程-保存数据成功【id={id};数据=[{JsonConvert.SerializeObject(updateModel)}]】");
  191. // 0 = 禁用(删除);1 = 上报报警(报警上报);5 = 报警取消;2 = 报警确认;
  192. // 3 = 正在处理报警;4 = 处理报警完成;6 = 报警处理维保返工; 7 = 报警处理完成确认
  193. if (updateModel.C_Status=="2"|| updateModel.C_Status=="4" || updateModel.C_Status == "7")
  194. {
  195. var content = await _repository.GetByIdAsync(id);
  196. string title = "";string code = "";
  197. switch (updateModel.C_Status)
  198. {
  199. case "2": title = "报警确认,"; code = "MSG_TYPE_021"; break;
  200. case "7": title = "报警完成确认,"; code = "MSG_TYPE_021"; break;
  201. case "4": title = "报警完成,"; code = "MSG_TYPE_022"; break;
  202. case "5": title = "报警取消,"; code = "MSG_TYPE_020"; break;
  203. }
  204. await _pushMsgService.PushAlarmMsgAsync(new TpushMsgModel
  205. {
  206. C_DevStoreCode = content.C_DevStoreCode,
  207. C_MsgTypeCode = code,
  208. Msg = updateModel.C_Record,//content.C_Name + " " + updateModel.C_Remark,
  209. Subject = content.C_Name,// title + content.C_Name,
  210. DevNumber = content.C_DevStoreCode,
  211. DevName = content.C_DevName,
  212. GenerationType = 2,
  213. msgStatus = 0,
  214. }, "设备报警工单");
  215. }
  216. log.Info($"报警工单-流程-保存数据END");
  217. }
  218. catch (Exception ex)
  219. {
  220. log.Info($"报警工单-流程-保存数据成功异常【{ex.Message}】");
  221. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  222. }
  223. return new ApiResult(ReturnCode.Success);
  224. }
  225. /// <summary>
  226. /// 通过id获取报警工单信息
  227. /// </summary>
  228. /// <param name="id"></param>
  229. /// <returns></returns>
  230. [HttpGet("GetAlarmOrderAsync/{id}")]
  231. public async Task<ApiResult> GetAlarmOrderAsync(string id)
  232. {
  233. if (string.IsNullOrEmpty(id))
  234. {
  235. return new ApiResult(ReturnCode.GeneralError);
  236. }
  237. try
  238. {
  239. var content = await _repository.GetByIdAsync(id);
  240. return new ApiResult<AlarmOrderViewModel>(content);
  241. }
  242. catch (Exception ex)
  243. {
  244. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  245. }
  246. }
  247. /// <summary>
  248. /// 报警工单列表
  249. /// </summary>
  250. /// <param name="searchModel"></param>
  251. /// <returns></returns>
  252. [HttpPost("GetAlarmOrderListAsync")]
  253. public async Task<ApiResult> GetAlarmOrderListAsync(AlarmOrderSearchModel searchModel)
  254. {
  255. if (searchModel == null)
  256. {
  257. return new ApiResult(ReturnCode.ArgsError);
  258. }
  259. try
  260. {
  261. var contentList = await _repository.GetAlarmOrderList(searchModel);
  262. return new ApiResult<PagesModel<AlarmOrderViewModel>>(new PagesModel<AlarmOrderViewModel>(contentList, searchModel));
  263. }
  264. catch (Exception ex)
  265. {
  266. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  267. }
  268. }
  269. /// <summary>
  270. /// 报警工单处理记录列表
  271. /// </summary>
  272. /// <param name="searchModel"></param>
  273. /// <returns></returns>
  274. [HttpPost("GetAlarmOrderRecordList")]
  275. public async Task<ApiResult> GetAlarmOrderRecordList(AlarmOrderSearchModel searchModel)
  276. {
  277. if (searchModel==null)
  278. {
  279. return new ApiResult(ReturnCode.ArgsError);
  280. }
  281. try
  282. {
  283. searchModel.IsPagination = false;
  284. var contentList = await _repository.GetAlarmOrderRecordList(searchModel);
  285. return new ApiResult<IEnumerable<AlarmOrderRecordViewModel>>(contentList);
  286. }
  287. catch (Exception ex)
  288. {
  289. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  290. }
  291. }
  292. /// <summary>
  293. /// 报警工单统计
  294. /// </summary>
  295. /// <param name="searchModel"></param>
  296. /// <returns></returns>
  297. [HttpPost("AlarmOrderStatistics")]
  298. public async Task<ApiResult> AlarmOrderStatistics(AlarmOrderSearchModel searchModel)
  299. {
  300. if (searchModel == null&& searchModel.C_StoreCode!=null)
  301. {
  302. return new ApiResult(ReturnCode.ArgsError);
  303. }
  304. try
  305. {
  306. searchModel.IsPagination = false;
  307. var contentList = await _repository.AlarmOrderStatistics(searchModel);
  308. return new ApiResult<AlarmOrderStatistics>(contentList);
  309. }
  310. catch (Exception ex)
  311. {
  312. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  313. }
  314. }
  315. /// <summary>
  316. /// 工单表移动端统计(6个月)
  317. /// </summary>
  318. /// <param name="storeCode"></param>
  319. /// <returns></returns>
  320. [HttpGet("GetAlarmOrderStatisticsAsync/{storeCode}")]
  321. public async Task<ApiResult> GetAlarmOrderStatisticsAsync(string storeCode)
  322. {
  323. if (string.IsNullOrEmpty(storeCode))
  324. {
  325. return new ApiResult(ReturnCode.GeneralError);
  326. }
  327. try
  328. {
  329. var content = await _repository.GetAlarmOrderStatisticsAsync(storeCode);
  330. return new ApiResult<RepairStatistics>(content);
  331. }
  332. catch (Exception ex)
  333. {
  334. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  335. }
  336. }
  337. /// <summary>
  338. /// 导出报警记录压缩包
  339. /// </summary>
  340. /// <param name="searchModel"></param>
  341. /// <returns></returns>
  342. [HttpPost("ExportZip")]
  343. [AllowAnonymous]
  344. public async Task<IActionResult> ExportZip(AlarmOrderSearchModel searchModel)
  345. {
  346. var recordList = await _repository.GetAlarmOrderList(searchModel);
  347. string zip = @"wwwroot\\ZipFile";
  348. if (!System.IO.Directory.Exists(zip))
  349. {
  350. Directory.CreateDirectory(zip);
  351. }
  352. string zipPaht = zip + "\\报警记录下载.zip";
  353. System.IO.File.Delete(zipPaht);
  354. IWorkbook workbook = new XSSFWorkbook();
  355. ISheet sheet = workbook.CreateSheet();
  356. #region
  357. //标题加粗居中.
  358. IFont font = workbook.CreateFont();
  359. font.IsBold = true;
  360. font.FontHeightInPoints = 25;
  361. font.FontName = "宋体";
  362. ICellStyle titleCellStyle = workbook.CreateCellStyle();
  363. titleCellStyle.SetFont(font);
  364. titleCellStyle.Alignment = HorizontalAlignment.Center; //字体居中
  365. //边框
  366. titleCellStyle.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
  367. titleCellStyle.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
  368. titleCellStyle.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
  369. titleCellStyle.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
  370. titleCellStyle.WrapText = true;
  371. #endregion
  372. #region
  373. //表头加粗居中.
  374. IFont font1 = workbook.CreateFont();
  375. font1.IsBold = true;
  376. font1.FontHeightInPoints = 14;
  377. font1.FontName = "宋体";
  378. ICellStyle headCellStyle = workbook.CreateCellStyle();
  379. headCellStyle.SetFont(font1);
  380. headCellStyle.Alignment = HorizontalAlignment.Center; //字体居中
  381. //边框
  382. headCellStyle.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
  383. headCellStyle.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
  384. headCellStyle.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
  385. headCellStyle.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
  386. headCellStyle.WrapText = true;
  387. #endregion
  388. #region
  389. //行.
  390. IFont font2 = workbook.CreateFont();
  391. font2.IsBold = false;
  392. font2.FontHeightInPoints = 12;
  393. font2.FontName = "宋体";
  394. ICellStyle rowCellStyle = workbook.CreateCellStyle();
  395. rowCellStyle.SetFont(font2);
  396. rowCellStyle.Alignment = HorizontalAlignment.Center; //字体居中
  397. //边框
  398. rowCellStyle.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
  399. rowCellStyle.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
  400. rowCellStyle.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
  401. rowCellStyle.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
  402. rowCellStyle.WrapText = true;
  403. #endregion
  404. #region 超链接
  405. // 创建样式
  406. ICellStyle styleLInk = workbook.CreateCellStyle();
  407. // 设置字体颜色为蓝色
  408. IFont fontLink = workbook.CreateFont();
  409. fontLink.IsBold = false;
  410. fontLink.FontHeightInPoints = 12;
  411. fontLink.FontName = "宋体";
  412. fontLink.Color = IndexedColors.Green.Index;
  413. styleLInk.SetFont(fontLink);
  414. // 设置下划线
  415. fontLink.Underline = FontUnderlineType.Single;
  416. styleLInk.SetFont(fontLink);
  417. styleLInk.Alignment = HorizontalAlignment.Center; //字体居中
  418. //边框
  419. styleLInk.BorderBottom = NPOI.SS.UserModel.BorderStyle.Thin;
  420. styleLInk.BorderLeft = NPOI.SS.UserModel.BorderStyle.Thin;
  421. styleLInk.BorderRight = NPOI.SS.UserModel.BorderStyle.Thin;
  422. styleLInk.BorderTop = NPOI.SS.UserModel.BorderStyle.Thin;
  423. styleLInk.WrapText = true;
  424. #endregion
  425. sheet.AddMergedRegion(new NPOI.SS.Util.CellRangeAddress(0, 0, 0, 7));
  426. IRow title = sheet.CreateRow(0);
  427. title.Height = 30 * 25;
  428. title.CreateCell(0).SetCellValue("报警记录报表" + (searchModel.C_StoreName == null ? "" : "(" + searchModel.C_StoreName + ")"));
  429. foreach (var item in title.Cells)
  430. {
  431. item.CellStyle = titleCellStyle;
  432. }
  433. IRow head = sheet.CreateRow(1);
  434. head.CreateCell(0).SetCellValue("序号");
  435. head.CreateCell(1).SetCellValue("报警名称");
  436. head.CreateCell(2).SetCellValue("状态");
  437. head.CreateCell(3).SetCellValue("审批人");
  438. head.CreateCell(4).SetCellValue("审批时间");
  439. head.CreateCell(5).SetCellValue("上报人员");
  440. head.CreateCell(6).SetCellValue("上报时间");
  441. head.CreateCell(7).SetCellValue("记录查看");
  442. foreach (var item in head.Cells)
  443. {
  444. item.CellStyle = headCellStyle;
  445. }
  446. int rowNumber = 2; int number = 1;
  447. if (recordList.Any() && recordList.FirstOrDefault() != null)
  448. {
  449. foreach (var x in recordList)
  450. {
  451. if (x!=null)
  452. {
  453. string status = string.Empty;
  454. switch (x.C_Status)
  455. {
  456. case "1": status = "报警上报"; break;
  457. case "2": status = "报警确认"; break;
  458. case "3": status = "正在处理"; break;
  459. case "4": status = "报警完成"; break;
  460. case "5": status = "报警取消"; break;
  461. case "6": status = "报警返工"; break;
  462. case "7": status = "报警完成确认"; break;
  463. }
  464. IRow content = sheet.CreateRow(rowNumber);
  465. content.CreateCell(0).SetCellValue(number);
  466. content.CreateCell(1).SetCellValue(x.C_Name);
  467. content.CreateCell(2).SetCellValue(status);
  468. content.CreateCell(3).SetCellValue(x.C_ExamineName);
  469. content.CreateCell(4).SetCellValue(x.D_ExamineOn?.ToString("yyyy-MM-dd"));
  470. content.CreateCell(5).SetCellValue(x.C_CreateName);
  471. content.CreateCell(6).SetCellValue(x.D_CreateOn.ToString("yyyy-MM-dd"));
  472. //超链接
  473. NPOI.SS.UserModel.ICell cell = content.CreateCell(7);
  474. cell.SetCellValue("附件");
  475. IHyperlink link = new XSSFHyperlink(HyperlinkType.Url);
  476. link.Address = ("报警记录/" + x.C_ID + ".docx");
  477. cell.Hyperlink = link;
  478. foreach (var item in content.Cells)
  479. {
  480. item.CellStyle = rowCellStyle;
  481. }
  482. cell.CellStyle = styleLInk;
  483. rowNumber++; number++;
  484. }
  485. }
  486. }
  487. else
  488. {
  489. IRow content1 = sheet.CreateRow(rowNumber);
  490. content1.CreateCell(0).SetCellValue("暂无数据");
  491. sheet.AddMergedRegion(new NPOI.SS.Util.CellRangeAddress(2, 2, 0, 7));
  492. }
  493. for (int i = 0; i <= 7; i++)
  494. {
  495. if (i == 0)
  496. {
  497. sheet.SetColumnWidth(i, 2000);
  498. }
  499. else if (i == 1)
  500. {
  501. sheet.SetColumnWidth(i, 7000);
  502. }
  503. else
  504. {
  505. sheet.SetColumnWidth(i, 4500);
  506. }
  507. }
  508. using (var zipFile = new FileStream(zipPaht, FileMode.Create))
  509. {
  510. // 列表Excel
  511. using (var memoryStream = new NpoiMemoryStream())
  512. {
  513. workbook.Write(memoryStream);
  514. byte[] excelData = memoryStream.ToArray();
  515. using (var archive = new ZipArchive(zipFile, ZipArchiveMode.Update))
  516. {
  517. archive.CreateEntry("报警记录报表.xlsx").Open().Write(excelData, 0, excelData.Length);
  518. }
  519. }
  520. }
  521. //内容word
  522. foreach (var cell in recordList.ToList())
  523. {
  524. if (cell != null)
  525. {
  526. AlarmOrderSearchModel orderSearch = new AlarmOrderSearchModel();
  527. orderSearch.IsPagination = false;
  528. orderSearch.C_ID = cell.C_ID;
  529. var recordItems = await _repository.GetAlarmOrderRecordList(orderSearch);
  530. if (recordItems.Count() > 0)
  531. {
  532. XWPFDocument doc = new XWPFDocument();
  533. var paragraph = doc.CreateParagraph();
  534. var run1 = paragraph.CreateRun();
  535. run1.FontSize = 18;
  536. run1.SetText("报警名称:" + cell.C_Name);
  537. int serialNum = 1;
  538. foreach (var recordItem in recordItems)
  539. {
  540. if (recordItem==null) { continue; }
  541. var p0 = doc.CreateParagraph();
  542. var run0 = p0.CreateRun();
  543. run0.FontSize = 16;
  544. run0.SetText(" " + serialNum.ToString());
  545. var p1 = doc.CreateParagraph();
  546. var run = p1.CreateRun();
  547. run.FontSize = 14;
  548. string status = string.Empty;
  549. switch (recordItem.C_Status)
  550. {
  551. case "1": status = "报警上报"; break;
  552. case "2": status = "报警确认"; break;
  553. case "3": status = "正在处理"; break;
  554. case "4": status = "报警完成"; break;
  555. case "5": status = "报警取消"; break;
  556. case "6": status = "报警返工"; break;
  557. case "7": status = "报警完成确认"; break;
  558. }
  559. run.AppendText(" 操作时间:" + recordItem.D_CreateOn.ToString("yyyy-MM-dd HH:mm:ss"));
  560. run.AddCarriageReturn();
  561. run.AppendText(" 状态:" + status);
  562. run.AddCarriageReturn();
  563. run.AppendText(" 处理人员:" + recordItem.C_CreateName);
  564. run.AddCarriageReturn();
  565. run.AppendText(" 现场描述:" + recordItem.C_Remark);
  566. run.AddCarriageReturn();
  567. run.AppendText(" 现场记录:" + recordItem.C_Record);
  568. if (recordItem.fileList != null && recordItem.fileList.Count() > 0)
  569. {
  570. run.AddCarriageReturn();
  571. run.AppendText(" 现场拍照:");
  572. foreach (var path in recordItem.fileList)
  573. {
  574. string pathFile = path.C_Url;
  575. if (!string.IsNullOrEmpty(pathFile))
  576. {
  577. if (pathFile[0].ToString() == @"/")
  578. {
  579. pathFile = pathFile.Substring(1);
  580. }
  581. if (!System.IO.File.Exists(pathFile))
  582. {
  583. pathFile = @"wwwroot/error.png";
  584. }
  585. FileStream fileStream = new FileStream(pathFile, FileMode.Open, FileAccess.Read);
  586. run.AddCarriageReturn();
  587. run.AddPicture(fileStream, 6, pathFile, Units.ToEMU(100), Units.ToEMU(100));
  588. }
  589. }
  590. }
  591. serialNum++;
  592. }
  593. using (var zipFile = new FileStream(zipPaht, FileMode.OpenOrCreate))
  594. {
  595. using (var memoryStream = new NpoiMemoryStream())
  596. {
  597. doc.Write(memoryStream);
  598. byte[] excelData = memoryStream.ToArray();
  599. using (var archive = new ZipArchive(zipFile, ZipArchiveMode.Update))
  600. {
  601. archive.CreateEntry("报警记录/" + cell.C_ID + ".docx").Open().Write(excelData, 0, excelData.Length);
  602. }
  603. }
  604. }
  605. }
  606. }
  607. }
  608. var zipFile1 = new FileStream(zipPaht, FileMode.Open);
  609. // 将压缩后的数据作为响应返回给客户端(这里假设你使用的是HTTP GET请求)
  610. return File(zipFile1, "application/zip", "报警记录报表.zip"); // 这里假设你的文件类型是.xlsx的GZip压缩文件。你可以根据需要调整MIME类型和文件扩展名。
  611. }
  612. /// <summary>
  613. /// 发送邮件-根据消息ID获取报警详情
  614. /// </summary>
  615. /// <param name="searchModel"></param>
  616. /// <returns></returns>
  617. [HttpPost("SendEmilByPushMsgResultCode")]
  618. [AllowAnonymous]
  619. public async Task<ApiResult> SendEmilByPushMsgResultCode(SendAlarmOrderModel searchModel)
  620. {
  621. try
  622. {
  623. if (searchModel==null&&string.IsNullOrEmpty(searchModel.C_PushMsgResultCode))
  624. {
  625. return new ApiResult(ReturnCode.ArgsError, "请输入参数");
  626. }
  627. AlarmOrderSearchModel orderSearchModel = new AlarmOrderSearchModel();
  628. orderSearchModel.IsPagination = false;
  629. orderSearchModel.C_PushMsgResultCode = searchModel.C_PushMsgResultCode;
  630. var recordItems = await _repository.GetAlarmOrderRecordList(orderSearchModel);
  631. string zip = @"wwwroot\\ZipFile";
  632. if (!System.IO.Directory.Exists(zip))
  633. {
  634. Directory.CreateDirectory(zip);
  635. }
  636. string zipPaht = zip + $"\\{searchModel.C_PushMsgResultCode}报警详情下载.zip";
  637. if (recordItems.Count() > 0)
  638. {
  639. XWPFDocument doc = new XWPFDocument();
  640. var paragraph = doc.CreateParagraph();
  641. var run1 = paragraph.CreateRun();
  642. run1.FontSize = 18;
  643. run1.AppendText("报警时间:" + searchModel.AlarmTime);
  644. run1.AddCarriageReturn();
  645. run1.AppendText("报警内容:" + searchModel.AlarmContent);
  646. int serialNum = 1;
  647. foreach (var recordItem in recordItems)
  648. {
  649. if (recordItem == null) { continue; }
  650. var p0 = doc.CreateParagraph();
  651. var run0 = p0.CreateRun();
  652. run0.FontSize = 16;
  653. run0.SetText(" " + serialNum.ToString());
  654. var p1 = doc.CreateParagraph();
  655. var run = p1.CreateRun();
  656. run.FontSize = 14;
  657. string status = string.Empty;
  658. switch (recordItem.C_Status)
  659. {
  660. case "1": status = "报警上报"; break;
  661. case "2": status = "报警确认"; break;
  662. case "3": status = "正在处理"; break;
  663. case "4": status = "报警完成"; break;
  664. case "5": status = "报警取消"; break;
  665. case "6": status = "报警返工"; break;
  666. case "7": status = "报警完成确认"; break;
  667. }
  668. run.AppendText(" 操作时间:" + recordItem.D_CreateOn.ToString("yyyy-MM-dd HH:mm:ss"));
  669. run.AddCarriageReturn();
  670. run.AppendText(" 状态:" + status);
  671. run.AddCarriageReturn();
  672. run.AppendText(" 处理人员:" + recordItem.C_CreateName);
  673. run.AddCarriageReturn();
  674. run.AppendText(" 现场描述:" + recordItem.C_Remark);
  675. run.AddCarriageReturn();
  676. run.AppendText(" 现场记录:" + recordItem.C_Record);
  677. if (recordItem.fileList != null && recordItem.fileList.Count() > 0)
  678. {
  679. run.AddCarriageReturn();
  680. run.AppendText(" 现场拍照:");
  681. foreach (var path in recordItem.fileList)
  682. {
  683. string pathFile = path.C_Url;
  684. if (!string.IsNullOrEmpty(pathFile))
  685. {
  686. if (pathFile[0].ToString() == @"/")
  687. {
  688. pathFile = pathFile.Substring(1);
  689. }
  690. if (!System.IO.File.Exists(pathFile))
  691. {
  692. pathFile = @"wwwroot/error.png";
  693. }
  694. FileStream fileStream = new FileStream(pathFile, FileMode.Open, FileAccess.Read);
  695. run.AddCarriageReturn();
  696. run.AddPicture(fileStream, 6, pathFile, Units.ToEMU(100), Units.ToEMU(100));
  697. }
  698. }
  699. }
  700. serialNum++;
  701. }
  702. using (var zipFile = new FileStream(zipPaht, FileMode.Create))
  703. {
  704. using (var memoryStream = new NpoiMemoryStream())
  705. {
  706. doc.Write(memoryStream);
  707. byte[] excelData = memoryStream.ToArray();
  708. using (var archive = new ZipArchive(zipFile, ZipArchiveMode.Update))
  709. {
  710. archive.CreateEntry($"{searchModel.C_PushMsgResultCode}报警详情.docx").Open().Write(excelData, 0, excelData.Length);
  711. }
  712. }
  713. }
  714. }
  715. string emailName = $"{searchModel.AlarmContent}-报警详情";
  716. using (var zipFile1 = new FileStream(zipPaht, FileMode.Open))
  717. {
  718. await Task.Run(() =>
  719. {
  720. EmailHelper.SendEmail(searchModel.Mails, emailName, "", "详情见附件", $"{emailName}.zip", "application/zip", zipFile1);
  721. });
  722. }
  723. System.IO.File.Delete(zipPaht);
  724. return new ApiResult(ReturnCode.Success);
  725. }
  726. catch (Exception ex)
  727. {
  728. return new ApiResult(ReturnCode.GeneralError, ex.Message);
  729. }
  730. }
  731. }
  732. }