1

gx_api/GxPress/Api/GxPress.Api/WebControllers/AlipayController.cs

@@ -1,7 +1,10 @@
 using System.Collections.Generic;
+using System.Threading.Tasks;
 using Alipay.AopSdk.Core.Util;
 using GxPress.Common.AliPay;
+using GxPress.Service.Interface.Order;
 using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 
 namespace GxPress.Api.WebControllers
@@ -11,41 +14,64 @@ namespace GxPress.Api.WebControllers
     [Authorize]
     public class AlipayController : Controller
     {
+        private readonly IOrderService orderService;
+        private IHttpContextAccessor _contextAccessor;
+        private HttpContext _context { get { return _contextAccessor.HttpContext; } }
+
+        public AlipayController(IOrderService orderService, IHttpContextAccessor contextAccessor)
+        {
+            this.orderService = orderService;
+            _contextAccessor = contextAccessor;
+        }
+
         [HttpGet()]
         [AllowAnonymous]
         public string GetNativePayUrl()
         {
             var alipay = new PcPay();
-            return alipay.PayRequest("637263608658642540", "汪峰讲故事", "0.01", "汪峰讲故事");
+            return alipay.PayRequest("637263608658642540_7", "汪峰讲故事", "0.01", "汪峰讲故事");
         }
         /// <summary>
         /// 回调地址
         /// </summary>
         [HttpGet("notify")]
         [AllowAnonymous]
-        public void Callback()
+        public async Task Callback()
         {
-            /* 实际验证过程建议商户添加以下校验。
-             1、商户需要验证该通知数据中的out_trade_no是否为商户系统中创建的订单号，
-             2、判断total_amount是否确实为该订单的实际金额（即商户订单创建时的金额），
-             3、校验通知中的seller_id（或者seller_email) 是否为out_trade_no这笔单据的对应的操作方（有的时候，一个商户可能有多个seller_id/seller_email）
-             4、验证app_id是否为该商户本身。
-             */
             Dictionary<string, string> sArray = GetRequestGet();
             if (sArray.Count != 0)
             {
-                bool flag = AlipaySignature.RSACheckV1(sArray, Config.AlipayPublicKey, Config.CharSet, Config.SignType, false);
-                if (flag)
+                try
                 {
-                    //Console.WriteLine($"同步验证通过，订单号：{sArray["out_trade_no"]}");
-                    ViewData["PayResult"] = "同步验证通过";
+                    //校验数据的正确性
+                    bool flag = AlipaySignature.RSACheckV1(sArray, Config.AlipayPublicKey, Config.CharSet, Config.SignType, false);
+                    if (flag)
+                    {
+                        //Console.WriteLine($"同步验证通过，订单号：{sArray["out_trade_no"]}");
+                        if (await orderService.InsertAliPayOrderAsync(sArray))
+                        {
+                            _context.Response.StatusCode = 200;
+                        }
+                        else
+                        {
+                            _context.Response.StatusCode = 500;
+                        }
+                    }
+                    else
+                    {
+                        // Console.WriteLine($"同步验证失败，订单号：{sArray["out_trade_no"]}");
+                        _context.Response.StatusCode = 500;
+                    }
                 }
-                else
+                catch (System.Exception)
                 {
-                    // Console.WriteLine($"同步验证失败，订单号：{sArray["out_trade_no"]}");
-                    ViewData["PayResult"] = "同步验证失败";
+                    _context.Response.StatusCode = 500;
                 }
             }
+            else
+            {
+                _context.Response.StatusCode = 500;
+            }
         }
         private Dictionary<string, string> GetRequestPost()
         {

gx_api/GxPress/Api/GxPress.Api/WebControllers/WebMediaController.cs

@@ -0,0 +1,44 @@
+using System.Threading.Tasks;
+using GxPress.Auth;
+using GxPress.Repository.Interface.Media;
+using GxPress.Result.Media;
+using GxPress.Service.Interface.Media;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+
+namespace GxPress.Api.WebControllers
+{
+    /// <summary>
+    /// 媒体
+    /// </summary>
+    [Route("api/web/media")]
+    [ApiController]
+    [Authorize]
+    public class WebMediaController : Controller
+    {
+        private readonly IMediaRepository mediaRepository;
+        private readonly ILoginContext _loginContext;
+        private readonly IMediaService mediaService;
+        private readonly IHttpContextAccessor httpContextAccessor;
+        public WebMediaController(IMediaRepository mediaRepository, ILoginContext _loginContext, IMediaService mediaService, IHttpContextAccessor httpContextAccessor)
+        {
+            this.mediaRepository = mediaRepository;
+            this._loginContext = _loginContext;
+            this.mediaService = mediaService;
+            this.httpContextAccessor = httpContextAccessor;
+        }
+        /// <summary>
+        /// 详情
+        /// </summary>
+        /// <param name="id"></param>
+        /// <returns></returns>
+        [HttpGet("{id}")]
+        [AllowAnonymous]
+        public async Task<MediaResult> GetAsync(int id)
+        {
+            Common.Epub.Analysis.ProcessMake();
+            return await mediaService.GetAsync(id);
+        }
+    }
+}

gx_api/GxPress/Infrastructure/GxPress.Common/Epub/Analysis.cs

@@ -0,0 +1,85 @@
+using System.Collections.Generic;
+using System.Drawing;
+using System.IO;
+using System.Linq;
+using VersOne.Epub;
+
+namespace GxPress.Common.Epub
+{
+    /// <summary>
+    /// 分析Epub
+    /// </summary>
+    public static class Analysis
+    {
+        /// <summary>
+        /// 加工制造
+        /// </summary>
+        public static void ProcessMake()
+        {
+         
+            // var url = "https://apk.tederen.com/service/cache/20200525/7682915b9dc44f8e98781ddd839291a9.epub";
+            // FileStream fs = new FileStream(url, FileMode.Open, FileAccess.Read);
+            // // 读取文件的 byte[]
+            // byte[] bytes = new byte[fs.Length];
+            // fs.Read(bytes, 0, bytes.Length);
+            // fs.Close();
+            // // 把 byte[] 转换成 Stream
+            // Stream stream = new MemoryStream(bytes);
+            //获取
+            EpubBook epubBook = EpubReader.ReadBook("wwwroot/cache/20200529/e875998ea9e3407888d93f9060a4154a.epub");
+            //标题
+            string title = epubBook.Title;
+            //作者
+            string author = epubBook.Author;
+            //作者集合
+            List<string> authors = epubBook.AuthorList;
+            //获取图片封面
+            // byte[] coverImageContent = epubBook.CoverImage;
+            // if (coverImageContent != null)
+            // {
+            //     using (MemoryStream coverImageStream = new MemoryStream(coverImageContent))
+            //     {
+            //         Image coverImage = Image.FromStream(coverImageStream);
+            //     }
+            // }
+            // 目录
+            //列举章节
+            foreach (EpubNavigationItem chapter in epubBook.Navigation)
+            {
+                //本章标题
+                string chapterTitle = chapter.Title;
+                //嵌套章节
+                List<EpubNavigationItem> subChapters = chapter.NestedItems;
+            }
+            //阅读顺序
+
+            //按照阅读顺序枚举本书的全文内容
+            foreach (EpubTextContentFile textContentFile in epubBook.ReadingOrder)
+            {
+                //当前文本内容文件的HTML
+                string htmlContent = textContentFile.Content;
+            }
+            //内容
+
+            //书籍的内容（HTML文件，手写板，图像，字体等）
+            EpubContent bookContent = epubBook.Content;
+            // 图片
+
+            //书中的所有图片（文件名是关键）
+            Dictionary<string, EpubByteContentFile> images = bookContent.Images;
+
+            EpubByteContentFile firstImage = images.Values.First();
+            //内容类型（例如EpubContentType.IMAGE_JPEG，EpubContentType.IMAGE_PNG）
+            EpubContentType contentType = firstImage.ContentType;
+            // MIME类型（例如“ image / jpeg”，“ image / png”）
+            string mimeType = firstImage.ContentMimeType;
+
+            // 从内容创建Image类实例
+            using (MemoryStream imageStream = new MemoryStream(firstImage.Content))
+            {
+                Image image = Image.FromStream(imageStream);
+            }
+
+        }
+    }
+}

gx_api/GxPress/Infrastructure/GxPress.Common/GxPress.Common.csproj

@@ -18,6 +18,7 @@
     <PackageReference Include="aliyun-net-sdk-ecs" Version="4.19.4" />
     <PackageReference Include="LitJson" Version="0.16.0" />
     <PackageReference Include="Alipay.AopSdk.Core" Version="2.5.0.1" />
+    <PackageReference Include="VersOne.Epub" Version="3.0.3.1" />
   </ItemGroup>
 
 </Project>

gx_api/GxPress/Service/GxPress.Service.Implement/Order/OrderService.cs

@@ -5,6 +5,7 @@ using GxPress.Service.Interface.Order;
 using GxPress.Repository.Interface.Media;
 using GxPress.Repository.Interface;
 using System;
+using System.Collections.Generic;
 
 namespace GxPress.Service.Implement.Order
 {
@@ -40,10 +41,10 @@ namespace GxPress.Service.Implement.Order
                 order.IsSuccess = true;
                 order.IsVip = user.IsVip;
                 order.MediaId = media.Id;
-                order.Explain=media.Title;
+                order.Explain = media.Title;
                 order.Name = user.Name;
                 order.OrderNumber = DateTime.Now.Ticks.ToString();
-                order.Price =Decimal.Parse(data.GetValue("total_fee").ToString())/100;
+                order.Price = Decimal.Parse(data.GetValue("total_fee").ToString()) / 100;
                 order.TransactionId = data.GetValue("transaction_id").ToString();
                 order.UserId = user.Id;
                 order.PayWay = 1;
@@ -51,5 +52,37 @@ namespace GxPress.Service.Implement.Order
             }
             return false;
         }
+        /// <summary>
+        /// 支付宝
+        /// </summary>
+        /// <param name="sArray"></param>
+        /// <returns></returns>
+        public async Task<bool> InsertAliPayOrderAsync(Dictionary<string, string> sArray)
+        {
+            var order = new Entity.Order.Order();
+            var attach = sArray["out_trade_no"].ToString();
+            if (attach.Split('_').Length > 0)
+            {
+                //获取medio属性
+                var media = await mediaRepository.GetAsync(attach.Split('_')[0]);
+                //获取用户数据
+                var user = await userRepository.GetAsync(int.Parse(attach.Split('_')[1]));
+                order.OutTradeNo = sArray["out_trade_no"].ToString();
+                order.OrderType = 1;
+                order.IsRefund = false;
+                order.IsSuccess = true;
+                order.IsVip = user.IsVip;
+                order.MediaId = media.Id;
+                order.Explain = media.Title;
+                order.Name = user.Name;
+                order.OrderNumber = DateTime.Now.Ticks.ToString();
+                order.Price = decimal.Parse(sArray["total_amount"].ToString());
+                order.TransactionId = sArray["trade_no"].ToString();
+                order.UserId = user.Id;
+                order.PayWay = 2;
+                return await orderRepository.InsertAsync(order) > 0;
+            }
+            return false;
+        }
     }
 }

gx_api/GxPress/Service/GxPress.Service.Interface/Order/IOrderService.cs

@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using System.Threading.Tasks;
 using GxPress.Common.WechatPay;
 
@@ -11,5 +12,11 @@ namespace GxPress.Service.Interface.Order
         /// <param name="data"></param>
         /// <returns></returns>
         Task<bool> InsertWxOrderAsync(WxPayData data);
+        /// <summary>
+        /// 支付宝
+        /// </summary>
+        /// <param name="sArray"></param>
+        /// <returns></returns>
+        Task<bool> InsertAliPayOrderAsync(Dictionary<string, string> sArray);
     }
 }