/***********************************************************************
|
* Project: baifenBinfa
|
* ProjectName: 百分兵法管理系统
|
* Web: http://chuanyin.com
|
* Author:
|
* Email:
|
* CreateTime: 202403/02
|
* Description: 暂无
|
***********************************************************************/
|
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Net.Http;
|
using System.Threading.Tasks;
|
using System.Web;
|
using CoreCms.Net.Caching.AccressToken;
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.IRepository.UnitOfWork;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.Model.Entities;
|
using CoreCms.Net.Model.ViewModels.UI;
|
using CoreCms.Net.Utility.Extensions;
|
using CoreCms.Net.Utility.Helper;
|
using CoreCms.Net.WeChat.Service.Enums;
|
using CoreCms.Net.WeChat.Service.HttpClients;
|
using CoreCms.Net.WeChat.Service.Options;
|
using Microsoft.AspNetCore.Hosting;
|
using Microsoft.Extensions.Options;
|
using Newtonsoft.Json.Linq;
|
using SKIT.FlurlHttpClient.Wechat.Api;
|
using SKIT.FlurlHttpClient.Wechat.Api.Models;
|
|
namespace CoreCms.Net.Services
|
{
|
/// <summary>
|
/// 表单 接口实现
|
/// </summary>
|
public class CoreCmsShareServices : BaseServices<CoreCmsSetting>, ICoreCmsShareServices
|
{
|
private readonly IUnitOfWork _unitOfWork;
|
private readonly IWebHostEnvironment _webHostEnvironment;
|
|
private readonly string _appInterFaceUrl = AppSettingsConstVars.AppConfigAppInterFaceUrl;
|
|
private readonly ICoreCmsGoodsServices _goodsServices;
|
private readonly ICoreCmsSolitaireServices _solitaireServices;
|
private readonly ICoreCmsUserServices _userServices;
|
private readonly WeChatOptions _weChatOptions;
|
private readonly WeChat.Service.HttpClients.IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;
|
|
|
|
public CoreCmsShareServices(IUnitOfWork unitOfWork
|
, IWebHostEnvironment webHostEnvironment
|
, ICoreCmsGoodsServices goodsServices
|
, IOptions<WeChatOptions> weChatOptions, IWeChatApiHttpClientFactory weChatApiHttpClientFactory, ICoreCmsSolitaireServices solitaireServices, ICoreCmsUserServices userServices)
|
|
{
|
_unitOfWork = unitOfWork;
|
_webHostEnvironment = webHostEnvironment;
|
_goodsServices = goodsServices;
|
_weChatApiHttpClientFactory = weChatApiHttpClientFactory;
|
_solitaireServices = solitaireServices;
|
_userServices = userServices;
|
_weChatOptions = weChatOptions.Value;
|
|
}
|
|
#region 二维码分享
|
|
/// <summary>
|
/// 二维码分享
|
/// </summary>
|
/// <param name="client"></param>
|
/// <param name="page"></param>
|
/// <param name="userShareCode"></param>
|
/// <param name="url"></param>
|
/// <param name="parameter"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> QrShare(int client, int page, int userShareCode, string url, JObject parameter)
|
{
|
var res = GetCode(client, page, userShareCode, url, parameter);
|
if (!res.status)
|
{
|
return res;
|
}
|
return await getQr(url, res.otherData.ToString(), client);
|
}
|
|
private async Task<WebApiCallBack> getQr(string url, string code, int client)
|
{
|
var jm = new WebApiCallBack() { status = true };
|
|
switch (client)
|
{
|
case (int)GlobalEnumVars.UrlShareClentType.Wxmnapp:
|
jm = await GetQrCode(code, url);
|
break;
|
default:
|
var urlStr = GetUrl(url, code);
|
urlStr = HttpUtility.UrlEncode(urlStr);
|
break;
|
}
|
return jm;
|
}
|
|
#endregion
|
|
#region 页面分享UrlShare
|
/// <summary>
|
/// 页面分享
|
/// </summary>
|
/// <param name="client"></param>
|
/// <param name="page"></param>
|
/// <param name="userShareCode"></param>
|
/// <param name="url"></param>
|
/// <param name="parameter"></param>
|
/// <returns></returns>
|
public WebApiCallBack UrlShare(int client, int page, int userShareCode, string url, JObject parameter)
|
{
|
var res = GetCode(client, page, userShareCode, url, parameter);
|
if (!res.status)
|
{
|
return res;
|
}
|
res.data = GetUrl(url, res.otherData.ToString());
|
return res;
|
}
|
|
#endregion
|
|
#region 二维码生成
|
/// <summary>
|
/// 二维码生成
|
/// </summary>
|
/// <param name="invite"></param>
|
/// <param name="type"></param>
|
/// <param name="id"></param>
|
/// <param name="groupId"></param>
|
/// <param name="teamId"></param>
|
/// <param name="style"></param>
|
/// <param name="page"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetParameterQrCode(string invite = "", int type = 1, string id = "", string groupId = "", string teamId = "", List<string> style = null, string page = "pages/share/jump")
|
{
|
var jm = new WebApiCallBack() { status = false, msg = "获取失败" };
|
|
var styles = style != null && style.Any() ? string.Join("-", style.ToArray()) : "";
|
var nameStr = CommonHelper.Md5For32(page + invite + type + id + groupId + teamId + _weChatOptions.WxOpenAppId + styles);
|
|
//QrCode 根目录
|
var dir = "/static/qrCode/weChat/";
|
//文件虚拟目录
|
var fileName = dir + nameStr + ".jpg";
|
//文件硬地址
|
var qrCodeDir = _webHostEnvironment.WebRootPath + dir;
|
//QrCode 根目录
|
var pathFileName = qrCodeDir + nameStr + ".jpg";
|
|
//QrCode 根目录
|
if (File.Exists(pathFileName))
|
{
|
//有这个二维码了
|
jm.status = true;
|
jm.msg = "二维码获取成功";
|
jm.data = _appInterFaceUrl + fileName;
|
}
|
else
|
{
|
//没有去官方请求生成
|
var scene = string.Empty;
|
if (type == 1)
|
{
|
//商品详情页
|
if (!string.IsNullOrEmpty(invite))
|
{
|
scene = ShareHelper.share_parameter_encode("2", invite, id, "");
|
}
|
else
|
{
|
scene = ShareHelper.share_parameter_encode("2", "", id, "");
|
}
|
}
|
else if (type == 2)
|
{
|
//首页
|
if (!string.IsNullOrEmpty(invite))
|
{
|
scene = ShareHelper.share_parameter_encode("3", invite, "", "");
|
}
|
else
|
{
|
scene = ShareHelper.share_parameter_encode("3", "", "", "");
|
}
|
}
|
else if (type == 3)
|
{
|
//拼团
|
if (!string.IsNullOrEmpty(invite))
|
{
|
scene = ShareHelper.share_parameter_encode("5", invite, id, !string.IsNullOrEmpty(teamId) ? teamId : "");
|
}
|
else
|
{
|
scene = ShareHelper.share_parameter_encode("5", "", id, !string.IsNullOrEmpty(teamId) ? teamId : "");
|
}
|
}
|
else if (type == 4)
|
{
|
//店铺首页
|
scene = ShareHelper.share_parameter_encode("9", !string.IsNullOrEmpty(invite) ? invite : "", id, "");
|
}
|
else
|
{
|
//默认首页
|
scene = ShareHelper.share_parameter_encode("3", !string.IsNullOrEmpty(invite) ? invite : "", "", "");
|
}
|
|
//没有去官方请求生成
|
var ms = new MemoryStream();
|
|
var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
var request = new WxaGetWxaCodeUnlimitRequest();
|
request.AccessToken = accessToken;
|
request.Scene = scene;
|
request.PagePath = page;
|
request.LineColor = new WxaGetWxaCodeUnlimitRequest.Types.Color() { Red = 221, Blue = 51, Green = 238 };
|
|
var response = await client.ExecuteWxaGetWxaCodeUnlimitAsync(request);
|
if (response.IsSuccessful())
|
{
|
ms = new MemoryStream(response.RawBytes);
|
}
|
else
|
{
|
if (response.ErrorCode == (int)WeChatReturnCode.ReturnCode.page不正确)
|
{
|
jm.msg = "后台小程序配置的APPID和APPSECRET对应的小程序未发布上线,或者page没有发布，无法生成海报";
|
return jm;
|
}
|
else if (response.IsSuccessful() && response.ErrorCode == (int)WeChatReturnCode.ReturnCode.获取access_token时AppSecret错误或者access_token无效)
|
{
|
jm.msg = "微信小程序access_token已过期，无法为你生成海报";
|
return jm;
|
}
|
else
|
{
|
var enumType = EnumHelper.GetEnumberEntity<WeChatReturnCode.ReturnCode>(response.ErrorCode);
|
if (enumType != null)
|
{
|
jm.msg = response.ErrorCode + enumType.title;
|
}
|
return jm;
|
}
|
}
|
|
//QrCode 根目录
|
if (!Directory.Exists(qrCodeDir))
|
{
|
Directory.CreateDirectory(qrCodeDir);
|
}
|
|
await using FileStream fs = System.IO.File.Create(pathFileName);
|
await ms.CopyToAsync(fs);
|
fs.Flush();
|
|
jm.status = true;
|
jm.msg = "二维码生成成功";
|
jm.data = AppSettingsConstVars.AppConfigAppInterFaceUrl + fileName;
|
jm.otherData = response;
|
}
|
return jm;
|
}
|
#endregion
|
|
#region 小程序二维码，和业务没关系【GetQrCode】
|
/// <summary>
|
/// 小程序二维码，和业务没关系
|
/// </summary>
|
/// <param name="scene"></param>
|
/// <param name="page"></param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetQrCode(string scene, string page = "pages/share/jump")
|
{
|
var jm = new WebApiCallBack();
|
|
jm.otherData = scene;
|
|
var fileNameStr = CommonHelper.Md5For32(scene) + CommonHelper.Msectime();
|
//QrCode 根目录
|
var dir = "/static/qrCode/weChat/";
|
//文件虚拟目录
|
var fileName = dir + fileNameStr + ".jpg";
|
//文件硬地址
|
var qrCodeDir = _webHostEnvironment.WebRootPath + dir;
|
//QrCode 文件全路径
|
var pathFileName = qrCodeDir + fileNameStr + ".jpg";
|
var fileNameMin = fileNameStr + ".jpg";
|
|
if (File.Exists(pathFileName))
|
{
|
jm.status = true;
|
jm.msg = "二维码获取成功";
|
jm.data = _appInterFaceUrl + fileName;
|
jm.otherData = fileNameMin;
|
}
|
else
|
{
|
//没有去官方请求生成
|
var ms = new MemoryStream();
|
|
var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
var request = new WxaGetWxaCodeUnlimitRequest();
|
request.AccessToken = accessToken;
|
request.Scene = scene;
|
request.PagePath = page;
|
request.LineColor = new WxaGetWxaCodeUnlimitRequest.Types.Color() { Red = 221, Blue = 51, Green = 238 };
|
|
var response = await client.ExecuteWxaGetWxaCodeUnlimitAsync(request);
|
if (!response.IsSuccessful() && response.ErrorCode == (int)WeChatReturnCode.ReturnCode.page不正确)
|
{
|
jm.msg = "后台小程序配置的APPID和APPSECRET对应的小程序未发布上线,或者page没有发布，无法生成海报";
|
return jm;
|
}
|
else if (!response.IsSuccessful() && response.ErrorCode == (int)WeChatReturnCode.ReturnCode.获取access_token时AppSecret错误或者access_token无效)
|
{
|
jm.msg = "微信小程序access_token已过期，无法为你生成海报";
|
return jm;
|
}
|
else if (!response.IsSuccessful() && response.ErrorCode > 0)
|
{
|
var enumType = EnumHelper.GetEnumberEntity<WeChatReturnCode.ReturnCode>(response.ErrorCode);
|
if (enumType != null)
|
{
|
jm.msg = response.ErrorCode + enumType.title;
|
}
|
return jm;
|
}
|
else
|
{
|
ms = new MemoryStream(response.RawBytes);
|
}
|
|
//QrCode 根目录
|
if (!Directory.Exists(qrCodeDir))
|
{
|
Directory.CreateDirectory(qrCodeDir);
|
}
|
|
FileStream fs = new FileStream(pathFileName, FileMode.OpenOrCreate);
|
BinaryWriter w = new BinaryWriter(fs);
|
w.Write(ms.ToArray());
|
fs.Close();
|
ms.Close();
|
|
jm.status = true;
|
jm.msg = "GetQrCode";
|
jm.data = AppSettingsConstVars.AppConfigAppInterFaceUrl + fileName;
|
jm.otherData = response;
|
}
|
return jm;
|
}
|
|
#endregion
|
|
#region 获得分享的Code【GetCode】
|
/// <summary>
|
/// 获得分享的code
|
/// </summary>
|
/// <param name="client"></param>
|
/// <param name="page"></param>
|
/// <param name="userShareCode"></param>
|
/// <param name="url"></param>
|
/// <param name="parameter"></param>
|
/// <returns></returns>
|
private static WebApiCallBack GetCode(int client, int page, int userShareCode, string url, JObject parameter)
|
{
|
//检查params参数是否正确
|
WebApiCallBack result = en_params(page, parameter);
|
if (!result.status)
|
{
|
return result;
|
}
|
var code = en_url(page, userShareCode, result.data.ToString());
|
result.otherData = code;
|
return result;
|
}
|
|
#endregion
|
|
#region 根据获得的code，拼接url【GetUrl】
|
/// <summary>
|
/// 根据获得的code，拼接url
|
/// </summary>
|
/// <param name="url"></param>
|
/// <param name="code"></param>
|
/// <returns></returns>
|
private static string GetUrl(string url, string code)
|
{
|
return url + "?scene=" + code;
|
}
|
#endregion
|
|
#region url参数加密【en_url】
|
/// <summary>
|
/// url参数加密
|
/// </summary>
|
/// <param name="page"></param>
|
/// <param name="userShareCode"></param>
|
/// <param name="paramsStr"></param>
|
/// <returns></returns>
|
private static string en_url(int page, int userShareCode, string paramsStr)
|
{
|
return page + "-" + userShareCode + "-" + paramsStr;
|
}
|
#endregion
|
|
#region url参数解密【de_url】
|
/// <summary>
|
/// url参数解密
|
/// </summary>
|
/// <param name="code"></param>
|
/// <returns></returns>
|
public WebApiCallBack de_url(string code)
|
{
|
//3-3702-2032_0
|
var jm = new WebApiCallBack();
|
|
var arr = code.Split("-");
|
if (arr.Length != 3)
|
{
|
return jm;
|
}
|
|
var page = arr[0];
|
var userShareCode = arr[1];
|
|
|
var paramsResult = de_params(Convert.ToInt16(arr[0]), arr[2]);
|
if (paramsResult.status)
|
{
|
jm.status = true;
|
jm.data = new
|
{
|
page,
|
userShareCode,
|
@params = paramsResult.data
|
};
|
}
|
else
|
{
|
paramsResult.otherData = code;
|
return paramsResult;
|
}
|
return jm;
|
}
|
#endregion
|
|
#region 检查参数，拼接参数【en_params】
|
/// <summary>
|
/// 检查参数，拼接参数
|
/// </summary>
|
/// <param name="page"></param>
|
/// <param name="parameter"></param>
|
/// <returns></returns>
|
private static WebApiCallBack en_params(int page, JObject parameter)
|
{
|
var jm = new WebApiCallBack();
|
var str = "";
|
|
switch (page)
|
{
|
case (int)GlobalEnumVars.UrlSharePageType.Index:
|
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Goods:
|
if (parameter.ContainsKey("goodsId"))
|
{
|
str = parameter["goodsId"]?.ToString();
|
}
|
else
|
{
|
jm.msg = "参数必须传goodsId";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.PinTuan:
|
if (parameter.ContainsKey("teamId") && parameter.ContainsKey("groupId"))
|
{
|
str = parameter["groupId"] + "_" + parameter["teamId"];
|
}
|
else
|
{
|
jm.msg = "参数必须传goodsId,teamId,groupId";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Inv:
|
if (parameter.ContainsKey("store"))
|
{
|
str = parameter["store"]?.ToString();
|
}
|
else
|
{
|
jm.msg = "参数必须传store";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Article:
|
if (parameter.ContainsKey("articleId") || parameter.ContainsKey("articleType"))
|
{
|
str = parameter["articleId"] + "_" + parameter["articleType"];
|
}
|
else
|
{
|
jm.msg = "参数必须传articleId,articleType";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.AddPinTuan:
|
if (parameter.ContainsKey("groupId") && parameter.ContainsKey("teamId"))
|
{
|
str = parameter["groupId"] + "_" + parameter["teamId"];
|
}
|
else
|
{
|
jm.msg = "参数必须传goodsId,groupId,teamId";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Page:
|
if (parameter.ContainsKey("pageCode"))
|
{
|
str = parameter["pageCode"]?.ToString();
|
}
|
else
|
{
|
jm.msg = "参数必须传pageCode";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Form:
|
if (parameter.ContainsKey("id"))
|
{
|
str = parameter["id"]?.ToString();
|
}
|
else
|
{
|
jm.msg = "参数必须传id";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Group:
|
if (parameter.ContainsKey("groupId"))
|
{
|
str = parameter["groupId"].ToString();
|
}
|
else
|
{
|
jm.msg = "参数必须传groupId";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Seckill:
|
if (parameter.ContainsKey("groupId"))
|
{
|
str = parameter["groupId"].ToString();
|
}
|
else
|
{
|
jm.msg = "参数必须传groupId";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Agent:
|
if (parameter.ContainsKey("store"))
|
{
|
str = parameter["store"]?.ToString();
|
}
|
else
|
{
|
jm.msg = "参数必须传store";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Solitaire:
|
if (parameter.ContainsKey("id"))
|
{
|
str = parameter["id"]?.ToString();
|
}
|
else
|
{
|
jm.msg = "参数必须传id";
|
return jm;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.ServiceGoods:
|
if (parameter.ContainsKey("serviceGoodsId"))
|
{
|
str = parameter["serviceGoodsId"]?.ToString();
|
}
|
else
|
{
|
jm.msg = "参数必须传id";
|
return jm;
|
}
|
break;
|
default:
|
jm.msg = GlobalErrorCodeVars.Code10000;
|
return jm;
|
}
|
|
jm.status = true;
|
jm.data = str;
|
return jm;
|
}
|
|
#endregion
|
|
#region 解码参数【de_params】
|
/// <summary>
|
/// 解码参数
|
/// </summary>
|
/// <param name="page"></param>
|
/// <param name="parameter"></param>
|
/// <returns></returns>
|
private static WebApiCallBack de_params(int page, string parameter)
|
{
|
var jm = new WebApiCallBack();
|
var arr = parameter.Split("_");
|
|
switch (page)
|
{
|
case (int)GlobalEnumVars.UrlSharePageType.Index:
|
jm.status = true;
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Goods:
|
if (arr.Length == 1)
|
{
|
jm.data = new { goodsId = arr[0] };
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.PinTuan:
|
if (arr.Length == 2)
|
{
|
jm.data = new
|
{
|
groupId = arr[0],
|
teamId = arr[1]
|
};
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Inv:
|
if (arr.Length == 1)
|
{
|
jm.data = new { store = arr[0] };
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Article:
|
if (arr.Length == 2)
|
{
|
jm.data = new
|
{
|
articleId = arr[0],
|
articleType = arr[1],
|
};
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.AddPinTuan:
|
if (arr.Length == 2)
|
{
|
jm.data = new
|
{
|
groupId = arr[0],
|
teamId = arr[1]
|
};
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Page:
|
if (arr.Length == 1)
|
{
|
jm.data = new { pageCode = arr[0] };
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Form:
|
if (arr.Length == 1)
|
{
|
jm.data = new { id = arr[0] };
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Group:
|
if (arr.Length == 1)
|
{
|
jm.data = new
|
{
|
groupId = arr[0],
|
};
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Seckill:
|
if (arr.Length == 1)
|
{
|
jm.data = new
|
{
|
groupId = arr[0],
|
};
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Agent:
|
if (arr.Length == 1)
|
{
|
jm.data = new { store = arr[0] };
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.Solitaire:
|
if (arr.Length == 1)
|
{
|
jm.data = new { id = arr[0] };
|
jm.status = true;
|
}
|
break;
|
case (int)GlobalEnumVars.UrlSharePageType.ServiceGoods:
|
if (arr.Length == 1)
|
{
|
jm.data = new { serviceGoodsId = arr[0] };
|
jm.status = true;
|
}
|
break;
|
default:
|
jm.msg = GlobalErrorCodeVars.Code10000;
|
return jm;
|
}
|
return jm;
|
}
|
#endregion
|
}
|
}
|
