Winsoft.GOV/Winsoft.GOV.XF.WebApi.WXCore/Services/BundlesService.cs

using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;
using System;
using System.Collections.Generic;
using System.Linq;
using Microsoft.AspNetCore.Http;
using System.Threading.Tasks;
using Winsoft.GOV.XF.WebApi.WXCore.Data;
using Winsoft.GOV.XF.WebApi.WXCore.Models;
using Winsoft.GOV.XF.WebApi.WXCore.Helpers;
using Newtonsoft.Json;

namespace Winsoft.GOV.XF.WebApi.WXCore.Services
{
    public class BundlesService : BaseService
    {
        HttpContext _httpContext;
        public BundlesService(XFDbContext context, ILoggerFactory loggerFactory, HttpContext httpContext):base(context, loggerFactory)
        {
            _httpContext = httpContext;
        }
        public async Task<IEnumerable<Bundle>> GetByUserId(int userId)
        {
            return await _context.Bundles.AsNoTracking().Where(e => e.UserId == userId).ToListAsync<Bundle>();
        }
        public async Task<Bundle> Get(string id)
        {
            Guid g;
            if (!String.IsNullOrWhiteSpace(id) && Guid.TryParse(id,out g))
                return await _context.Bundles.AsNoTracking().SingleOrDefaultAsync<Bundle>(m => m.Id == g);
            else
            {
                Logger.LogError(String.Format("id:{0};id不存在或不能转换为guid",id));
            }
            return null;
        }

        public string GetURL(Bundle b)
        {
            string s = _httpContext.Request.GetAbsoluteUri() + "/dist/web12345-pageView/index.html#!/pageView?bid={0}&m={1}";
            s = String.Format(s, b.Id.ToString(), b.Id.ToString().AESEncrypt(b.Key));
            return s;
        }

        public async Task<Bundle> GetDetail(string id)
        {
            Guid g;
            if (!String.IsNullOrWhiteSpace(id) && Guid.TryParse(id, out g))
                return await _context.Bundles.SingleOrDefaultAsync<Bundle>(m => m.Id == g);
            else
            {
                Logger.LogError(String.Format("id:{0};id不存在或不能转换为guid", id));
            }
            return null;
        }

        public async Task<string> Add(Bundle b)
        {
            if (b != null)
            {
                await _context.Bundles.AddAsync(b);
                await _context.SaveChangesAsync();
                return b.Id.ToString();
            }
            return String.Empty;
        }

        public void Update(Bundle b)
        {
            if (b != null)
            {
                _context.Bundles.Update(b);
            }
        }

        public string GenerateBaseURL(Bundle b)
        {
            BundleAccessToken a = new BundleAccessToken()
            {
                Expire = -1,
                BundleId = b.Id
            };
            string multimediaURL = string.Format("{0}://{1}/multimedia?bundleId={2}&ciphertext={3}",
                _httpContext.Request.Scheme,
                _httpContext.Request.Host.Value, b.Id, JsonConvert.SerializeObject(a).AESEncrypt(b.Key));
            return multimediaURL;
        }

        public string GenerateShareURL(Bundle b, string ciphertext)
        {
            string data = ciphertext.AESDecrypt(b.Key);
            BundleAccessToken a = JsonConvert.DeserializeObject<BundleAccessToken>(data);
            if (a == null)
                return 
            if (a.Expire != -1)
            {
                a.Expire = DateTime.Now.AddDays(1).ToTimeStamp();
                string multimediaURL = string.Format("{0}://{1}/multimedia?bundleId={2}&data={3}",
                    Request.Scheme,
                    Request.Host.Value, b.Id, JsonConvert.SerializeObject(a).AESEncrypt(b.Key));
                return Ok(multimediaURL);
            }
            return BadRequest("已过期");
        }
    }
}