MesController.cs 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853
  1. using LocalhostMES.Core;
  2. using LocalhostMES.DataBase;
  3. using LocalhostMES.Models;
  4. using Newtonsoft.Json;
  5. using Prism.Ioc;
  6. using System;
  7. using System.Collections.Concurrent;
  8. using System.Collections.Generic;
  9. using System.Linq;
  10. using System.Threading;
  11. using System.Threading.Tasks;
  12. using System.Web.Http;
  13. namespace LocalhostMES.Controller
  14. {
  15. [RoutePrefix("api/mes")]
  16. public class MesController : ApiController
  17. {
  18. private static readonly Random _random = new Random();
  19. private static int _snCounter = 1;
  20. private Management management;
  21. public MesController()
  22. {
  23. management = Management.GetManagement();
  24. }
  25. #region 2.1 厂级MES下发工单信息
  26. [HttpPost]
  27. [Route("receiveWorkOrder")]
  28. public IHttpActionResult ReceiveWorkOrder([FromBody] WorkOrderRequest request)
  29. {
  30. try
  31. {
  32. LogHelper.WriteLogInfo("厂级MES下发工单信息");
  33. // 验证必填字段
  34. if (string.IsNullOrEmpty(request.WorkOrderNo) ||
  35. string.IsNullOrEmpty(request.MaterialCode) ||
  36. string.IsNullOrEmpty(request.MaterialName) ||
  37. string.IsNullOrEmpty(request.LineCode))
  38. {
  39. LogHelper.WriteLogInfo("必填字段不能为空");
  40. return BadRequest("必填字段不能为空");
  41. }
  42. // 工单状态验证
  43. if (!IsValidStatus(request.Status))
  44. {
  45. LogHelper.WriteLogInfo("无效的工单状态");
  46. return BadRequest($"无效的工单状态: {request.Status}");
  47. }
  48. // 创建或更新工单信息
  49. var workOrder = new WorkOrderInfo
  50. {
  51. WorkOrderNo = request.WorkOrderNo,
  52. MaterialCode = request.MaterialCode,
  53. OrderNo = request.OrderNo,
  54. MaterialName = request.MaterialName,
  55. PlannedQuantity = int.TryParse(request.WorkOrderNum, out var qty) ? qty : 0,
  56. CompletedQuantity = 0,
  57. Status = request.Status,
  58. LineCode = request.LineCode,
  59. CreateTime = DateTime.Now,
  60. StartTime = DateTime.Now.AddSeconds(2),
  61. EndTime = DateTime.Now.AddSeconds(5)
  62. };
  63. if (DatabaseHelper.InsertWorkOrderInfo(workOrder))
  64. {
  65. var response = new ApiResponse<bool>
  66. {
  67. code = "200",
  68. success = true,
  69. msg = "工单接收成功",
  70. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  71. traceId = Guid.NewGuid().ToString("N").Substring(0, 24),
  72. data = true
  73. };
  74. LogHelper.WriteLogInfo("工单接收成功");
  75. return Ok(response);
  76. }
  77. else
  78. {
  79. var errorResponse = new ErrorResponse
  80. {
  81. code = "55000",
  82. success = false,
  83. msg = $"工单接收失败:数据库插入异常",
  84. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  85. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  86. };
  87. LogHelper.WriteLogInfo("数据库插入异常");
  88. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  89. }
  90. }
  91. catch (Exception ex)
  92. {
  93. var errorResponse = new ErrorResponse
  94. {
  95. code = "55000",
  96. success = false,
  97. msg = $"工单接收失败: {ex.Message}",
  98. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  99. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  100. };
  101. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  102. }
  103. }
  104. [HttpGet]
  105. [Route("getWorkOrders")]
  106. public IHttpActionResult GetWorkOrders()
  107. {
  108. try
  109. {
  110. LogHelper.WriteLogInfo("接口getWorkOrders收到消息");
  111. var workOrders = DatabaseHelper.SelectWorkOrderInfo(null, management.IsLocalhostMode);
  112. var response = new ApiResponse<List<WorkOrderInfo>>
  113. {
  114. code = "200",
  115. success = true,
  116. msg = "获取成功",
  117. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  118. traceId = Guid.NewGuid().ToString("N").Substring(0, 24),
  119. data = workOrders
  120. };
  121. return Ok(response);
  122. }
  123. catch (Exception ex)
  124. {
  125. var errorResponse = new ErrorResponse
  126. {
  127. code = "55000",
  128. success = false,
  129. msg = $"获取工单失败: {ex.Message}",
  130. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  131. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  132. };
  133. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  134. }
  135. }
  136. #endregion
  137. #region 2.2 SN打印请求
  138. [HttpPost]
  139. [Route("requestSnPrint")]
  140. public async Task<IHttpActionResult> RequestSnPrint([FromBody] SnPrintRequest request)
  141. {
  142. try
  143. {
  144. // 验证请求头
  145. if (!ValidateHeaders())
  146. {
  147. return Unauthorized();
  148. }
  149. // 验证必填字段
  150. if (string.IsNullOrEmpty(request.workOrderNo) || request.count <= 0)
  151. {
  152. return BadRequest("工单号和数量为必填项且数量必须大于0");
  153. }
  154. var workOrder = DatabaseHelper.SelectWorkOrderInfo(request.workOrderNo);
  155. // 验证工单是否存在
  156. if (workOrder.Count == 0)
  157. {
  158. return BadRequest($"工单 {request.workOrderNo} 不存在");
  159. }
  160. // 验证打印类型
  161. if (request.printType < 1 || request.printType > 4)
  162. {
  163. return BadRequest($"无效的打印类型: {request.printType}");
  164. }
  165. LogHelper.WriteLogInfo("请求参数:");
  166. LogHelper.WriteLogInfo(JsonConvert.SerializeObject(request, Formatting.Indented));
  167. if (management.IsLocalhostMode)
  168. {
  169. var Manualsninfo = DatabaseHelper.SelectSnInfo(request.workOrderNo);
  170. DatabaseHelper.InsertSnInfo(new SnInfo()
  171. {
  172. Sn = "000001" +DateCodeConverter.GetYearCode(DateTime.Now.Year) +
  173. DateCodeConverter.GetMonthCode(DateTime.Now.Month) +
  174. DateCodeConverter.GetDayCode(DateTime.Now.Day) +
  175. "00000" + Manualsninfo.Count,
  176. IsUsed = false,
  177. WorkOrderNo= request.workOrderNo,
  178. GenerateTime=DateTime.Now,
  179. PrintType="1",
  180. });
  181. }
  182. var sninfo = DatabaseHelper.SelectSnInfo(request.workOrderNo, true, false);
  183. if (sninfo.Count == 0)
  184. {
  185. ApiResponse<SnPrintResponseData> mesres = await management.ApiClient.RequestSnPrintAsync(request);
  186. if (mesres.success && mesres.data!=null&& mesres.data.Sn.Count != 0)
  187. {
  188. for (int i = 0; i < mesres.data.Sn.Count; i++)
  189. {
  190. if (!DatabaseHelper.InsertSnInfo(new SnInfo()
  191. {
  192. WorkOrderNo = mesres.data.WorkOrderNo,
  193. Sn = mesres.data.Sn[i].Sn,
  194. GenerateTime = DateTime.Now,
  195. PrintType = "1",
  196. IsUsed = false,
  197. }))
  198. {
  199. mesres.msg = "插入SN到数据库出错";
  200. mesres.success = false;
  201. return Content(System.Net.HttpStatusCode.InternalServerError, mesres);
  202. }
  203. }
  204. return Ok(mesres);
  205. }
  206. return Content(System.Net.HttpStatusCode.InternalServerError, mesres);
  207. }
  208. // 生成SN列表
  209. var snList = new List<SnItem>();
  210. if (sninfo.Count != 0)
  211. {
  212. snList.Add(new SnItem { Sn = sninfo[0].Sn });
  213. var responseData = new SnPrintResponseData
  214. {
  215. Sn = snList,
  216. OrderNo = request.orderNo ?? "",
  217. WorkOrderNo = request.workOrderNo,
  218. Line = request.line ?? "",
  219. VehicleCode = workOrder[0].MaterialCode,
  220. MaterialDesc = workOrder[0].MaterialName
  221. };
  222. var response = new ApiResponse<SnPrintResponseData>
  223. {
  224. code = "200",
  225. success = true,
  226. msg = "SN生成成功",
  227. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  228. traceId = Guid.NewGuid().ToString("N").Substring(0, 24),
  229. data = responseData
  230. };
  231. return Ok(response);
  232. }
  233. var errorResponse = new ErrorResponse
  234. {
  235. code = "55000",
  236. success = false,
  237. msg = $"SN获取失败",
  238. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  239. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  240. };
  241. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  242. }
  243. catch (Exception ex)
  244. {
  245. var errorResponse = new ErrorResponse
  246. {
  247. code = "55000",
  248. success = false,
  249. msg = $"SN生成失败: {ex.Message}",
  250. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  251. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  252. };
  253. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  254. }
  255. }
  256. [HttpGet]
  257. [Route("getSns/{workOrderNo}")]
  258. public IHttpActionResult GetSns(string workOrderNo)
  259. {
  260. try
  261. {
  262. var sninfo = DatabaseHelper.SelectSnInfo(workOrderNo, true, false);
  263. if (sninfo.Count != 0)
  264. {
  265. var response = new ApiResponse<List<SnInfo>>
  266. {
  267. code = "200",
  268. success = true,
  269. msg = "获取成功",
  270. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  271. traceId = Guid.NewGuid().ToString("N").Substring(0, 24),
  272. data = sninfo
  273. };
  274. return Ok(response);
  275. }
  276. var errorResponse = new ErrorResponse
  277. {
  278. code = "55001",
  279. success = false,
  280. msg = $"工单 {workOrderNo} 没有SN记录",
  281. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  282. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  283. };
  284. return Content(System.Net.HttpStatusCode.NotFound, errorResponse);
  285. }
  286. catch (Exception ex)
  287. {
  288. var errorResponse = new ErrorResponse
  289. {
  290. code = "55000",
  291. success = false,
  292. msg = $"获取SN失败: {ex.Message}",
  293. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  294. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  295. };
  296. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  297. }
  298. }
  299. #endregion
  300. #region 2.3 接收SN和关键件
  301. [HttpPost]
  302. [Route("receiveSnComponent")]
  303. public async Task<IHttpActionResult> ReceiveSnComponent([FromBody] SnKeyComponentRequest request)
  304. {
  305. try
  306. {
  307. LogHelper.WriteLogInfo($"收到请求: 接收SN和关键件");
  308. if (management.IsLocalhostMode)
  309. {
  310. return Ok(new ApiResponse<bool?>() { data = true });
  311. }
  312. // 验证请求头
  313. if (!ValidateHeaders())
  314. {
  315. return Unauthorized();
  316. }
  317. // 验证必填字段
  318. if (string.IsNullOrEmpty(request.plant) ||
  319. string.IsNullOrEmpty(request.stationCode) ||
  320. string.IsNullOrEmpty(request.positionCode) ||
  321. string.IsNullOrEmpty(request.sn) ||
  322. string.IsNullOrEmpty(request.scanTime))
  323. {
  324. return BadRequest("必填字段不能为空");
  325. }
  326. // 处理关键件绑定
  327. if (request.part != null && request.part.Count > 0)
  328. {
  329. foreach (var part in request.part)
  330. {
  331. if (string.IsNullOrEmpty(part.partNum))
  332. {
  333. return BadRequest("关键件条码不能为空");
  334. }
  335. var bindRecord = new BindRecord
  336. {
  337. Sn = request.sn,
  338. PartNum = part.partNum,
  339. StationCode = request.stationCode,
  340. BindTime = DateTime.TryParse(request.scanTime, out var scanTime) ? scanTime : DateTime.Now,
  341. Employee = request.employee ?? "",
  342. ScanType = request.scanTpye
  343. };
  344. //DatabaseHelper.InsertBindRecord(bindRecord);
  345. if (management.IsLocalhostMode)
  346. {
  347. //if (DatabaseHelper.GetProductProductionRecords(request.sn) == 0)
  348. //{
  349. var response = new ApiResponse<bool>
  350. {
  351. code = "200",
  352. success = true,
  353. msg = "已存在记录",
  354. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  355. traceId = Guid.NewGuid().ToString("N").Substring(0, 24),
  356. data = true
  357. };
  358. return Ok(response);
  359. //}
  360. //else
  361. //{
  362. // var errorResponse = new ErrorResponse
  363. // {
  364. // code = "55000",
  365. // success = false,
  366. // msg = $"数据库查询失败",
  367. // msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  368. // traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  369. // };
  370. // return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  371. //}
  372. }
  373. }
  374. }
  375. if (management.IsLocalhostMode)
  376. {
  377. LogHelper.WriteLogInfo($"收到请求: 接收SN和关键件 成功");
  378. return Ok(new ApiResponse<bool?>() { data=true} );
  379. }
  380. var okresponse = await management.ApiClient.SendSnComponentAsync(request);
  381. if (okresponse.success && okresponse.code == "200")
  382. {
  383. LogHelper.WriteLogInfo($"收到请求: 接收SN和关键件 成功");
  384. return Ok(okresponse);
  385. }
  386. else
  387. {
  388. LogHelper.WriteLogInfo($"收到请求: 接收SN和关键件 失败\r\n"+ okresponse.ToString());
  389. okresponse.success = false;
  390. return Content(System.Net.HttpStatusCode.InternalServerError, okresponse);
  391. }
  392. }
  393. catch (Exception ex)
  394. {
  395. var errorResponse = new ErrorResponse
  396. {
  397. code = "55000",
  398. success = false,
  399. msg = $"SN和关键件接收失败: {ex.Message}",
  400. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  401. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  402. };
  403. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  404. }
  405. }
  406. [HttpGet]
  407. [Route("getBindRecords")]
  408. public IHttpActionResult GetBindRecords()
  409. {
  410. try
  411. {
  412. var records = DatabaseHelper.SelectBindRecord();
  413. var response = new ApiResponse<List<BindRecord>>
  414. {
  415. code = "200",
  416. success = true,
  417. msg = "获取成功",
  418. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  419. traceId = Guid.NewGuid().ToString("N").Substring(0, 24),
  420. data = records
  421. };
  422. return Ok(response);
  423. }
  424. catch (Exception ex)
  425. {
  426. var errorResponse = new ErrorResponse
  427. {
  428. code = "55000",
  429. success = false,
  430. msg = $"获取绑定记录失败: {ex.Message}",
  431. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  432. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  433. };
  434. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  435. }
  436. }
  437. #endregion
  438. #region 2.4 接收工件加工参数
  439. [HttpPost]
  440. [Route("receiveProcessParameters")]
  441. public async Task<IHttpActionResult> ReceiveProcessParameters([FromBody] ProcessParameterRequest request)
  442. {
  443. try
  444. {
  445. LogHelper.WriteLogInfo($"收到请求:接收工件加工参数 ");
  446. // 验证请求头
  447. if (!ValidateHeaders())
  448. {
  449. return Unauthorized();
  450. }
  451. // 验证必填字段
  452. if (string.IsNullOrEmpty(request.plant) ||
  453. string.IsNullOrEmpty(request.station) ||
  454. string.IsNullOrEmpty(request.sn) ||
  455. string.IsNullOrEmpty(request.overallResult))
  456. {
  457. return BadRequest("必填字段不能为空");
  458. }
  459. // 验证总结果
  460. if (request.overallResult != "OK" && request.overallResult != "NG")
  461. {
  462. return BadRequest($"无效的总结果: {request.overallResult}");
  463. }
  464. // 保存加工记录
  465. var processRecord = new ProcessRecord
  466. {
  467. Sn = request.sn,
  468. Station = request.station,
  469. OverallResult = request.overallResult,
  470. ProcessTime = DateTime.TryParse(request.messageTime, out var msgTime) ? msgTime : DateTime.Now,
  471. Equipment = request.equipment ?? ""
  472. };
  473. //DatabaseHelper.InsertProcessRecord(processRecord);
  474. if (management.IsLocalhostMode)
  475. {
  476. var response = new ApiResponse<bool>
  477. {
  478. code = "200",
  479. success = true,
  480. msg = "加工参数接收成功",
  481. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  482. traceId = Guid.NewGuid().ToString("N").Substring(0, 24),
  483. data = true
  484. };
  485. LogHelper.WriteLogInfo($"收到请求:接收工件加工参数 成功");
  486. return Ok(response);
  487. }
  488. var mesres =await management.ApiClient.SendProcessParametersAsync(request);
  489. LogHelper.WriteLogInfo($"收到请求:接收工件加工参数 成功");
  490. return Ok(mesres);
  491. }
  492. catch (Exception ex)
  493. {
  494. var errorResponse = new ErrorResponse
  495. {
  496. code = "55000",
  497. success = false,
  498. msg = $"加工参数接收失败: {ex.Message}",
  499. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  500. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  501. };
  502. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  503. }
  504. }
  505. [HttpGet]
  506. [Route("getProcessRecords")]
  507. public IHttpActionResult GetProcessRecords()
  508. {
  509. try
  510. {
  511. var records = DatabaseHelper.SelectProcessRecord();
  512. var response = new ApiResponse<List<ProcessRecord>>
  513. {
  514. code = "200",
  515. success = true,
  516. msg = "获取成功",
  517. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  518. traceId = Guid.NewGuid().ToString("N").Substring(0, 24),
  519. data = records
  520. };
  521. return Ok(response);
  522. }
  523. catch (Exception ex)
  524. {
  525. var errorResponse = new ErrorResponse
  526. {
  527. code = "55000",
  528. success = false,
  529. msg = $"获取加工记录失败: {ex.Message}",
  530. msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  531. traceId = Guid.NewGuid().ToString("N").Substring(0, 24)
  532. };
  533. return Content(System.Net.HttpStatusCode.InternalServerError, errorResponse);
  534. }
  535. }
  536. #endregion
  537. #region 辅助方法
  538. private bool ValidateHeaders()
  539. {
  540. // 简单的token验证
  541. if (Request.Headers.TryGetValues("app-key", out var appKeyValues) &&
  542. Request.Headers.TryGetValues("token", out var tokenValues))
  543. {
  544. var appKey = appKeyValues.FirstOrDefault();
  545. var token = tokenValues.FirstOrDefault();
  546. // 这里使用简单的验证
  547. return appKey == "test-app-key" && token == "test-token-123";
  548. }
  549. return false;
  550. }
  551. private bool IsValidStatus(string status)
  552. {
  553. var validStatuses = new[] { "0", "1", "2", "3", "4", "5", "6", "7" };
  554. return validStatuses.Contains(status);
  555. }
  556. private string GenerateSn(WorkOrderInfo workOrder, int printType)
  557. {
  558. var prefix = GetPrintTypePrefix(printType);
  559. var timestamp = DateTime.Now.ToString("yyMMddHHmm");
  560. var randomStr = Guid.NewGuid().ToString("N").Substring(0, 6).ToUpper();
  561. var counter = Interlocked.Increment(ref _snCounter);
  562. return $"{prefix}-{workOrder.MaterialCode}-{timestamp}-{counter:D4}-{randomStr}";
  563. }
  564. private string GetPrintTypePrefix(int printType)
  565. {
  566. switch (printType)
  567. {
  568. case 1:
  569. return "P";
  570. case 2:
  571. return "C";
  572. case 3:
  573. return "Q";
  574. case 4:
  575. return "B";
  576. default:
  577. return "U";
  578. }
  579. }
  580. private string GetPrintTypeName(int printType)
  581. {
  582. switch (printType)
  583. {
  584. case 1:
  585. return "产品码";
  586. case 2:
  587. return "零件码";
  588. case 3:
  589. return "合格码";
  590. case 4:
  591. return "装箱码";
  592. default:
  593. return "未知";
  594. }
  595. }
  596. #endregion
  597. }
  598. public class DateCodeConverter
  599. {
  600. // ============== 年份对照表 ==============
  601. private static readonly Dictionary<int, string> yearToCode = new Dictionary<int, string>
  602. {
  603. {2018, "1"}, {2019, "2"}, {2020, "3"}, {2021, "4"}, {2022, "5"},
  604. {2023, "6"}, {2024, "7"}, {2025, "8"}, {2026, "9"}, {2027, "A"},
  605. {2028, "B"}, {2029, "C"}, {2030, "D"}, {2031, "E"}, {2032, "F"},
  606. {2033, "G"}, {2034, "H"}, {2035, "J"}, {2036, "K"}, {2037, "L"},
  607. {2038, "M"}, {2039, "N"}, {2040, "P"}, {2041, "R"}, {2042, "S"},
  608. {2043, "T"}, {2044, "V"}, {2045, "W"}, {2046, "X"}, {2047, "Y"},
  609. {2048, "1"}, {2049, "2"}, {2050, "3"}, {2051, "4"}, {2052, "5"},
  610. {2053, "6"}, {2054, "7"}, {2055, "8"}, {2056, "9"}, {2057, "A"}
  611. };
  612. // ============== 月份对照表 ==============
  613. private static readonly Dictionary<int, string> monthToCode = new Dictionary<int, string>
  614. {
  615. {1, "1"}, {2, "2"}, {3, "3"}, {4, "4"}, {5, "5"}, {6, "6"},
  616. {7, "7"}, {8, "8"}, {9, "9"}, {10, "A"}, {11, "B"}, {12, "C"}
  617. };
  618. // ============== 日期对照表 ==============
  619. private static readonly Dictionary<int, string> dayToCode = new Dictionary<int, string>
  620. {
  621. {1, "1"}, {2, "2"}, {3, "3"}, {4, "4"}, {5, "5"}, {6, "6"}, {7, "7"}, {8, "8"}, {9, "9"},
  622. {10, "A"}, {11, "B"}, {12, "C"}, {13, "D"}, {14, "E"}, {15, "F"}, {16, "G"},
  623. {17, "H"}, {18, "J"}, {19, "K"},{20,"L"},{21, "M"}, {22, "N"}, {23, "P"}, {24, "R"},
  624. {25, "S"}, {26, "T"}, {27, "U"}, {28, "V"}, {29, "W"}, {30, "X"}, {31, "Y"}
  625. };
  626. // ============== 反向查找字典 ==============
  627. private static readonly Dictionary<string, int> codeToYear;
  628. private static readonly Dictionary<string, int> codeToMonth;
  629. private static readonly Dictionary<string, int> codeToDay;
  630. static DateCodeConverter()
  631. {
  632. // 初始化反向字典
  633. codeToYear = yearToCode
  634. .GroupBy(kv => kv.Value)
  635. .ToDictionary(g => g.Key, g => g.Last().Key);
  636. codeToMonth = monthToCode
  637. .ToDictionary(kv => kv.Value, kv => kv.Key);
  638. codeToDay = dayToCode
  639. .ToDictionary(kv => kv.Value, kv => kv.Key);
  640. }
  641. // ============== 年份相关方法 ==============
  642. /// <summary>
  643. /// 根据年份获取代码
  644. /// </summary>
  645. public static string GetYearCode(int year)
  646. {
  647. return yearToCode.TryGetValue(year, out string code) ? code : "未知年份";
  648. }
  649. /// <summary>
  650. /// 根据代码获取年份(返回最新的对应年份)
  651. /// </summary>
  652. public static int? GetYearByCode(string code)
  653. {
  654. return codeToYear.TryGetValue(code, out int year) ? year : (int?)null;
  655. }
  656. /// <summary>
  657. /// 获取所有对应某个代码的年份
  658. /// </summary>
  659. public static List<int> GetAllYearsByCode(string code)
  660. {
  661. return yearToCode
  662. .Where(kv => kv.Value == code)
  663. .Select(kv => kv.Key)
  664. .ToList();
  665. }
  666. // ============== 月份相关方法 ==============
  667. /// <summary>
  668. /// 根据月份获取代码
  669. /// </summary>
  670. public static string GetMonthCode(int month)
  671. {
  672. if (month < 1 || month > 12)
  673. return "无效月份";
  674. return monthToCode.TryGetValue(month, out string code) ? code : "未知月份";
  675. }
  676. /// <summary>
  677. /// 根据代码获取月份
  678. /// </summary>
  679. public static int? GetMonthByCode(string code)
  680. {
  681. return codeToMonth.TryGetValue(code, out int month) ? month : (int?)null;
  682. }
  683. // ============== 日期相关方法 ==============
  684. /// <summary>
  685. /// 根据日期获取代码
  686. /// </summary>
  687. public static string GetDayCode(int day)
  688. {
  689. if (day < 1 || day > 31)
  690. return "无效日期";
  691. return dayToCode.TryGetValue(day, out string code) ? code : "未知日期";
  692. }
  693. /// <summary>
  694. /// 根据代码获取日期
  695. /// </summary>
  696. public static int? GetDayByCode(string code)
  697. {
  698. return codeToDay.TryGetValue(code, out int day) ? day : (int?)null;
  699. }
  700. // ============== 完整日期转换方法 ==============
  701. /// <summary>
  702. /// 将DateTime转换为日期代码(3位字符:年份代码 + 月份代码 + 日期代码)
  703. /// </summary>
  704. public static string ConvertToDateCode(DateTime date)
  705. {
  706. string yearCode = GetYearCode(date.Year);
  707. string monthCode = GetMonthCode(date.Month);
  708. string dayCode = GetDayCode(date.Day);
  709. // 检查是否有无效的代码
  710. if (yearCode == "未知年份" || monthCode == "无效月份" || dayCode == "无效日期" || dayCode == "未知日期")
  711. {
  712. return "无效日期";
  713. }
  714. return $"{yearCode}{monthCode}{dayCode}";
  715. }
  716. /// <summary>
  717. /// 将日期代码转换为DateTime(如果有多个年份对应,返回最新的)
  718. /// </summary>
  719. public static DateTime? ConvertFromDateCode(string dateCode)
  720. {
  721. if (string.IsNullOrEmpty(dateCode) || dateCode.Length != 3)
  722. return null;
  723. string yearCode = dateCode.Substring(0, 1);
  724. string monthCode = dateCode.Substring(1, 1);
  725. string dayCode = dateCode.Substring(2, 1);
  726. var year = GetYearByCode(yearCode);
  727. var month = GetMonthByCode(monthCode);
  728. var day = GetDayByCode(dayCode);
  729. if (!year.HasValue || !month.HasValue || !day.HasValue)
  730. return null;
  731. try
  732. {
  733. return new DateTime(year.Value, month.Value, day.Value);
  734. }
  735. catch (ArgumentOutOfRangeException)
  736. {
  737. return null;
  738. }
  739. }
  740. /// <summary>
  741. /// 将日期代码转换为所有可能的DateTime列表(考虑年份重复的情况)
  742. /// </summary>
  743. public static List<DateTime> ConvertAllFromDateCode(string dateCode)
  744. {
  745. var result = new List<DateTime>();
  746. if (string.IsNullOrEmpty(dateCode) || dateCode.Length != 3)
  747. return result;
  748. string yearCode = dateCode.Substring(0, 1);
  749. string monthCode = dateCode.Substring(1, 1);
  750. string dayCode = dateCode.Substring(2, 1);
  751. var allYears = GetAllYearsByCode(yearCode);
  752. var month = GetMonthByCode(monthCode);
  753. var day = GetDayByCode(dayCode);
  754. if (allYears.Count == 0 || !month.HasValue || !day.HasValue)
  755. return result;
  756. foreach (var year in allYears)
  757. {
  758. try
  759. {
  760. result.Add(new DateTime(year, month.Value, day.Value));
  761. }
  762. catch (ArgumentOutOfRangeException)
  763. {
  764. // 跳过无效日期(如2月30日等)
  765. }
  766. }
  767. return result;
  768. }
  769. }
  770. }