MqttRequest.cs 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697
  1. using Edge.Core.Domain.FccOrderInfo;
  2. using HengshanPaymentTerminal.Http.Response;
  3. using Newtonsoft.Json;
  4. using Newtonsoft.Json.Linq;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.ComponentModel.DataAnnotations.Schema;
  8. using System.Linq;
  9. using System.Text;
  10. using System.Text.Json;
  11. using System.Threading.Tasks;
  12. namespace HengshanPaymentTerminal.Mqtt.Request
  13. {
  14. /// <summary>
  15. /// 云端 MQTT 数据对象
  16. /// </summary>
  17. public class MqttRequest
  18. {
  19. ///// <summary>
  20. ///// 类型
  21. ///// </summary>
  22. //public MQTT_TYPE type { get; set; }
  23. /// <summary>
  24. /// 数据
  25. /// </summary>
  26. public string data { get; set; }
  27. public string? UserName { get; set; }
  28. public string? UserPhoneNumber { get; set; }
  29. }
  30. /// <summary>
  31. /// 标识 MQTT 数据类型
  32. /// </summary>
  33. public enum MQTT_TYPE
  34. {
  35. /// <summary>
  36. /// 授权
  37. /// </summary>
  38. AUTHORIZATION = 1,
  39. /// <summary>
  40. /// 取消授权
  41. /// </summary>
  42. UNAUTHORIZATION = 2,
  43. /// <summary>
  44. /// 已支付发送订单信息
  45. /// </summary>
  46. PAID = 3,
  47. /// <summary>
  48. /// 退款发送订单信息
  49. /// </summary>
  50. REFUND = 4
  51. }
  52. /// <summary>
  53. /// 云端 Mqtt 发送授权请求数据对象
  54. /// </summary>
  55. public class MqttAuthorizationRequest
  56. {
  57. /// <summary>
  58. /// 订单唯一标识符
  59. /// </summary>
  60. public long Id { get; set; }
  61. /// <summary>
  62. /// 油站唯一标识符
  63. /// </summary>
  64. public Guid Buid { get; set; }
  65. /// <summary>
  66. /// 用户ID
  67. /// </summary>
  68. public long MiniProgramID { get; set; }
  69. /// <summary>
  70. /// 枪号
  71. /// </summary>
  72. public long NozzleId { get; set; }
  73. /// <summary>
  74. /// 油品ID
  75. /// </summary>
  76. public long ProductId { get; set; }
  77. /// <summary>
  78. /// 实际支付金额
  79. /// </summary>
  80. public decimal? ActualPaymentAmount { get; set; }
  81. /// <summary>
  82. /// 授权时间
  83. /// </summary>
  84. public DateTime? AuthorizationTime { get; set; }
  85. /// <summary>
  86. /// 创建人
  87. /// </summary>
  88. public string? CreateBy { get; set; }
  89. /// <summary>
  90. /// 订单创建时间
  91. /// </summary>
  92. public DateTime? CreateTime { get; set; }
  93. /// <summary>
  94. /// 挂枪时间
  95. /// </summary>
  96. public DateTime? FuelItemTransactionEndTime { get; set; }
  97. /// <summary>
  98. /// 是否删除
  99. /// </summary>
  100. public sbyte? IsDeleted { get; set; } = 0;
  101. /// <summary>
  102. /// 订单状态
  103. /// </summary>
  104. public transactionsORDERSTATUS OrderStatus { get; set; }
  105. /// <summary>
  106. /// 订单类型
  107. /// </summary>
  108. public transactionsORDERTYPE OrderType { get; set; }
  109. /// <summary>
  110. /// 原金额
  111. /// </summary>
  112. public decimal OriginalAmount { get; set; }
  113. /// <summary>
  114. /// 支付方式
  115. /// </summary>
  116. public long? PaymentMethod { get; set; }
  117. /// <summary>
  118. /// 油品名称
  119. /// </summary>
  120. public string ProductName { get; set; }
  121. /// <summary>
  122. /// 原升数
  123. /// </summary>
  124. public decimal Qty { get; set; }
  125. /// <summary>
  126. /// 实际加油升数
  127. /// </summary>
  128. public decimal? OriginalQty { get; set; }
  129. /// <summary>
  130. /// 退款金额
  131. /// </summary>
  132. public decimal? RefundAmount { get; set; }
  133. /// <summary>
  134. /// 订单流水号
  135. /// </summary>
  136. public string TransactionNumber { get; set; }
  137. /// <summary>
  138. /// 交易时间
  139. /// </summary>
  140. public DateTime? TransactionTime { get; set; }
  141. /// <summary>
  142. /// 加密字符串,用于验证金额是否篡改
  143. /// </summary>
  144. public string secret { get; set; }
  145. /// <summary>
  146. /// 支付返回结果
  147. /// </summary>
  148. public string RawResult { get; set; }
  149. /// <summary>
  150. /// 错误信息
  151. /// </summary>
  152. public string ErrorDetail { get; set; }
  153. /// <summary>
  154. /// 支付结果代码
  155. /// </summary>
  156. public string ResultCode { get; set; }
  157. /// <summary>
  158. /// 是否授权
  159. /// </summary>
  160. public AuthorizationStatus authorizationStatus { get; set; }
  161. /// <summary>
  162. /// 单价
  163. /// </summary>
  164. public decimal Price { get; set; }
  165. public FccOrderInfo ToComponent(DateTime authorizationTime, string paymentName,string? userName,string? phoneNumber)
  166. {
  167. string userNameStr = userName ?? "";
  168. string phoneStr = phoneNumber ?? string.Empty;
  169. return new FccOrderInfo()
  170. {
  171. AuthorizationTime = authorizationTime,
  172. PaymentTime = TransactionTime,
  173. NozzleNum = (int)NozzleId,
  174. OilName = ProductName,
  175. PaymentStatus = 1,
  176. PayType = (int?)PaymentMethod,
  177. CloundOrderId = Id,
  178. Amount = OriginalAmount,
  179. Volume = Qty,
  180. AmountPayable = ActualPaymentAmount,
  181. UploadState = 1,
  182. IsDelete = 0,
  183. Price = this.Price,
  184. PaymentName = paymentName,
  185. UserName = userNameStr,
  186. PhoneNumber = phoneStr
  187. };
  188. }
  189. }
  190. /// <summary>
  191. /// 云端发送取消授权数据对象
  192. /// </summary>
  193. public class MqttUnAhorizationRequest
  194. {
  195. /// <summary>
  196. /// 订单唯一标识符
  197. /// </summary>
  198. public long Id { get; set; }
  199. /// <summary>
  200. /// 油站唯一标识符
  201. /// </summary>
  202. public Guid Buid { get; set; }
  203. /// <summary>
  204. /// 用户ID
  205. /// </summary>
  206. public long MiniProgramID { get; set; }
  207. /// <summary>
  208. /// 枪号
  209. /// </summary>
  210. public long NozzleId { get; set; }
  211. /// <summary>
  212. /// 油品ID
  213. /// </summary>
  214. public long ProductId { get; set; }
  215. /// <summary>
  216. /// 实际支付金额
  217. /// </summary>
  218. public decimal? ActualPaymentAmount { get; set; }
  219. /// <summary>
  220. /// 授权时间
  221. /// </summary>
  222. public DateTime? AuthorizationTime { get; set; }
  223. /// <summary>
  224. /// 创建人
  225. /// </summary>
  226. public string? CreateBy { get; set; }
  227. /// <summary>
  228. /// 订单创建时间
  229. /// </summary>
  230. public DateTime? CreateTime { get; set; }
  231. /// <summary>
  232. /// 挂枪时间
  233. /// </summary>
  234. public DateTime? FuelItemTransactionEndTime { get; set; }
  235. /// <summary>
  236. /// 是否删除
  237. /// </summary>
  238. public sbyte? IsDeleted { get; set; } = 0;
  239. /// <summary>
  240. /// 订单状态
  241. /// </summary>
  242. public transactionsORDERSTATUS OrderStatus { get; set; }
  243. /// <summary>
  244. /// 订单类型
  245. /// </summary>
  246. public transactionsORDERTYPE OrderType { get; set; }
  247. /// <summary>
  248. /// 原金额
  249. /// </summary>
  250. public decimal OriginalAmount { get; set; }
  251. /// <summary>
  252. /// 支付方式
  253. /// </summary>
  254. public long? PaymentMethod { get; set; }
  255. /// <summary>
  256. /// 油品名称
  257. /// </summary>
  258. public string ProductName { get; set; }
  259. /// <summary>
  260. /// 原升数
  261. /// </summary>
  262. public decimal Qty { get; set; }
  263. /// <summary>
  264. /// 实际加油升数
  265. /// </summary>
  266. public decimal? OriginalQty { get; set; }
  267. /// <summary>
  268. /// 退款金额
  269. /// </summary>
  270. public decimal? RefundAmount { get; set; }
  271. /// <summary>
  272. /// 订单流水号
  273. /// </summary>
  274. public string TransactionNumber { get; set; }
  275. /// <summary>
  276. /// 交易时间
  277. /// </summary>
  278. public DateTime? TransactionTime { get; set; }
  279. /// <summary>
  280. /// 加密字符串,用于验证金额是否篡改
  281. /// </summary>
  282. public string secret { get; set; }
  283. /// <summary>
  284. /// 支付返回结果
  285. /// </summary>
  286. public string RawResult { get; set; }
  287. /// <summary>
  288. /// 错误信息
  289. /// </summary>
  290. public string ErrorDetail { get; set; }
  291. /// <summary>
  292. /// 支付结果代码
  293. /// </summary>
  294. public string ResultCode { get; set; }
  295. /// <summary>
  296. /// 是否授权
  297. /// </summary>
  298. public AuthorizationStatus authorizationStatus { get; set; }
  299. /// <summary>
  300. /// 单价
  301. /// </summary>
  302. public decimal? Price { get; set; }
  303. }
  304. /// <summary>
  305. /// 云端发送订单已支付数据对象
  306. /// </summary>
  307. public class MqttPaidRequest : MqttRequest
  308. {
  309. /// <summary>
  310. /// 订单唯一标识符
  311. /// </summary>
  312. public long Id { get; set; }
  313. /// <summary>
  314. /// 油站唯一标识符
  315. /// </summary>
  316. public Guid Buid { get; set; }
  317. /// <summary>
  318. /// 用户ID
  319. /// </summary>
  320. public long MiniProgramID { get; set; }
  321. /// <summary>
  322. /// 枪号
  323. /// </summary>
  324. public long NozzleId { get; set; }
  325. /// <summary>
  326. /// 油品ID
  327. /// </summary>
  328. public long ProductId { get; set; }
  329. /// <summary>
  330. /// 实际支付金额
  331. /// </summary>
  332. public decimal? ActualPaymentAmount { get; set; }
  333. /// <summary>
  334. /// 授权时间
  335. /// </summary>
  336. public DateTime? AuthorizationTime { get; set; }
  337. /// <summary>
  338. /// 创建人
  339. /// </summary>
  340. public string? CreateBy { get; set; }
  341. /// <summary>
  342. /// 订单创建时间
  343. /// </summary>
  344. public DateTime? CreateTime { get; set; }
  345. /// <summary>
  346. /// 挂枪时间
  347. /// </summary>
  348. public DateTime? FuelItemTransactionEndTime { get; set; }
  349. /// <summary>
  350. /// 是否删除
  351. /// </summary>
  352. public sbyte? IsDeleted { get; set; } = 0;
  353. /// <summary>
  354. /// 订单状态
  355. /// </summary>
  356. public transactionsORDERSTATUS OrderStatus { get; set; }
  357. /// <summary>
  358. /// 订单类型
  359. /// </summary>
  360. public transactionsORDERTYPE OrderType { get; set; }
  361. /// <summary>
  362. /// 原金额
  363. /// </summary>
  364. public decimal OriginalAmount { get; set; }
  365. /// <summary>
  366. /// 支付方式
  367. /// </summary>
  368. public long? PaymentMethod { get; set; }
  369. /// <summary>
  370. /// 油品名称
  371. /// </summary>
  372. public string ProductName { get; set; }
  373. /// <summary>
  374. /// 原升数
  375. /// </summary>
  376. public decimal Qty { get; set; }
  377. /// <summary>
  378. /// 实际加油升数
  379. /// </summary>
  380. public decimal? OriginalQty { get; set; }
  381. /// <summary>
  382. /// 退款金额
  383. /// </summary>
  384. public decimal? RefundAmount { get; set; }
  385. /// <summary>
  386. /// 订单流水号
  387. /// </summary>
  388. public string TransactionNumber { get; set; }
  389. /// <summary>
  390. /// 交易时间
  391. /// </summary>
  392. public DateTime? TransactionTime { get; set; }
  393. /// <summary>
  394. /// 加密字符串,用于验证金额是否篡改
  395. /// </summary>
  396. public string secret { get; set; }
  397. /// <summary>
  398. /// 支付返回结果
  399. /// </summary>
  400. public string RawResult { get; set; }
  401. /// <summary>
  402. /// 错误信息
  403. /// </summary>
  404. public string ErrorDetail { get; set; }
  405. /// <summary>
  406. /// 支付结果代码
  407. /// </summary>
  408. public string ResultCode { get; set; }
  409. /// <summary>
  410. /// 是否授权
  411. /// </summary>
  412. public AuthorizationStatus authorizationStatus { get; set; }
  413. /// <summary>
  414. /// 单价
  415. /// </summary>
  416. public decimal Price { get; set; }
  417. public decimal? FuelItemPumpTotalizerVolume { get; set; }
  418. public FccOrderInfo ToComponent(string? userName,string? phoneNumber,string paymentName)
  419. {
  420. string userNameStr = userName ?? "";
  421. string phoneStr = phoneNumber ?? string.Empty;
  422. int? paymentType = null;
  423. if (this.PaymentMethod != null) paymentType = (int?)this.PaymentMethod;
  424. return new FccOrderInfo()
  425. {
  426. PaymentTime = this.TransactionTime,
  427. NozzleNum = (int)this.NozzleId,
  428. OilName = this.ProductName,
  429. PaymentStatus = (int)this.OrderStatus,
  430. PayType = paymentType,
  431. CloundOrderId = this.Id,
  432. AmountPayable = this.ActualPaymentAmount,
  433. UploadState = 1,
  434. IsDelete = 0,
  435. Price = this.Price,
  436. UserName = userNameStr,
  437. PhoneNumber = phoneStr,
  438. PaymentName = paymentName,
  439. AuthorizationStatus = 0,
  440. RefundStatus = 0,
  441. VolumePayable = this.Qty,
  442. };
  443. }
  444. }
  445. /// <summary>
  446. /// 云端发送订单退款数据对象
  447. /// </summary>
  448. public class MqttRefundRequest : MqttRequest
  449. {
  450. /// <summary>
  451. /// 订单唯一标识符
  452. /// </summary>
  453. public long Id { get; set; }
  454. /// <summary>
  455. /// 油站唯一标识符
  456. /// </summary>
  457. public Guid Buid { get; set; }
  458. /// <summary>
  459. /// 用户ID
  460. /// </summary>
  461. public long MiniProgramID { get; set; }
  462. /// <summary>
  463. /// 枪号
  464. /// </summary>
  465. public long NozzleId { get; set; }
  466. /// <summary>
  467. /// 油品ID
  468. /// </summary>
  469. public long ProductId { get; set; }
  470. /// <summary>
  471. /// 实际支付金额
  472. /// </summary>
  473. public decimal? ActualPaymentAmount { get; set; }
  474. /// <summary>
  475. /// 授权时间
  476. /// </summary>
  477. public DateTime? AuthorizationTime { get; set; }
  478. /// <summary>
  479. /// 创建人
  480. /// </summary>
  481. public string? CreateBy { get; set; }
  482. /// <summary>
  483. /// 订单创建时间
  484. /// </summary>
  485. public DateTime? CreateTime { get; set; }
  486. /// <summary>
  487. /// 挂枪时间
  488. /// </summary>
  489. public DateTime? FuelItemTransactionEndTime { get; set; }
  490. /// <summary>
  491. /// 是否删除
  492. /// </summary>
  493. public sbyte? IsDeleted { get; set; } = 0;
  494. /// <summary>
  495. /// 订单状态
  496. /// </summary>
  497. public transactionsORDERSTATUS OrderStatus { get; set; }
  498. /// <summary>
  499. /// 订单类型
  500. /// </summary>
  501. public transactionsORDERTYPE OrderType { get; set; }
  502. /// <summary>
  503. /// 原金额
  504. /// </summary>
  505. public decimal OriginalAmount { get; set; }
  506. /// <summary>
  507. /// 支付方式
  508. /// </summary>
  509. public long? PaymentMethod { get; set; }
  510. /// <summary>
  511. /// 油品名称
  512. /// </summary>
  513. public string ProductName { get; set; }
  514. /// <summary>
  515. /// 原升数
  516. /// </summary>
  517. public decimal Qty { get; set; }
  518. /// <summary>
  519. /// 实际加油升数
  520. /// </summary>
  521. public decimal? OriginalQty { get; set; }
  522. /// <summary>
  523. /// 退款金额
  524. /// </summary>
  525. public decimal? RefundAmount { get; set; }
  526. /// <summary>
  527. /// 订单流水号
  528. /// </summary>
  529. public string TransactionNumber { get; set; }
  530. /// <summary>
  531. /// 交易时间
  532. /// </summary>
  533. public DateTime? TransactionTime { get; set; }
  534. /// <summary>
  535. /// 加密字符串,用于验证金额是否篡改
  536. /// </summary>
  537. public string secret { get; set; }
  538. /// <summary>
  539. /// 支付返回结果
  540. /// </summary>
  541. public string RawResult { get; set; }
  542. /// <summary>
  543. /// 错误信息
  544. /// </summary>
  545. public string ErrorDetail { get; set; }
  546. /// <summary>
  547. /// 支付结果代码
  548. /// </summary>
  549. public string ResultCode { get; set; }
  550. /// <summary>
  551. /// 是否授权
  552. /// </summary>
  553. public AuthorizationStatus authorizationStatus { get; set; }
  554. /// <summary>
  555. /// 单价
  556. /// </summary>
  557. public decimal? Price { get; set; }
  558. /// <summary>
  559. /// 订单编号
  560. /// </summary>
  561. public string BillNumber { get; set; }
  562. /// <summary>
  563. /// 退款状态
  564. /// </summary>
  565. [JsonProperty]
  566. public RefundStatus RefundStatus { get; set; }
  567. /// <summary>
  568. /// 泵码
  569. /// </summary>
  570. [JsonProperty]
  571. public decimal? FuelItemPumpTotalizerVolume { get; set; }
  572. }
  573. }