using Api.MessageReceive.Service;
|
using CommonUtil;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.Extensions.Caching.Memory;
|
using Operater.DTO.TopMessage;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using System.Xml;
|
using WeiXinKfSDK;
|
using WeiXinKfSDK.Request;
|
|
namespace Api.MessageReceive.Controllers
|
{
|
/// <summary>
|
/// 微信客服
|
/// </summary>
|
///
|
[Route("wxback/[controller]/[action]")]
|
[Route(TopConstants.API_ROUTE)]
|
public class KfWxController : ControllerBase
|
{
|
public static string _token = "u5tsOEqTNBwKcxgGoL";
|
public static string _aeskey = "XIkbuXu67vOwOcWWpZ1mAdOGxJn6Gs6B6YozPHgFAhE";
|
public static string _gzhappid = "wxc74c0ee1cf8efafd";
|
/// <summary>
|
/// 微信客服消息
|
/// </summary>
|
/// <returns></returns>
|
[AcceptVerbs("GET", "POST")]
|
public async Task<IActionResult> WxKfMessage()
|
{
|
if (HttpContext.Request.Method.ToLower() != "post")
|
{
|
#region 接口校验
|
WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(_token, _aeskey, "");
|
string sVerifyMsgSig = HttpContext.Request.Query["msg_signature"];
|
string sVerifyTimeStamp = HttpContext.Request.Query["timestamp"];
|
string sVerifyNonce = HttpContext.Request.Query["nonce"];
|
string sVerifyEchoStr = HttpContext.Request.Query["echostr"].ToString();
|
int ret = 0;
|
string sEchoStr = "";
|
ret = wxcpt.VerifyURL(sVerifyMsgSig, sVerifyTimeStamp, sVerifyNonce, sVerifyEchoStr, ref sEchoStr);
|
if (ret != 0)
|
{
|
System.Console.WriteLine("ERR: VerifyURL fail, ret: " + ret);
|
|
return Content(sEchoStr);
|
}
|
return Content(sEchoStr);
|
|
#endregion
|
}
|
else
|
{
|
#region 解析官方请求参数
|
StreamReader reader = new StreamReader(HttpContext.Request.Body, Encoding.UTF8);
|
var result = reader.ReadToEndAsync().Result;
|
reader.Close();
|
string sReqMsgSig = HttpContext.Request.Query["msg_signature"];
|
string sReqTimeStamp = HttpContext.Request.Query["timestamp"];
|
string sReqNonce = HttpContext.Request.Query["nonce"];
|
WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(_token, _aeskey, "");
|
|
string sMsg = ""; // 解析之后的明文
|
var code = wxcpt.DecryptMsg(sReqMsgSig, sReqTimeStamp, sReqNonce, result, ref sMsg);
|
LogUtil.Info($"服务商数据回调xmlConten---{sMsg}", $"wxkf_msg_log日志");
|
#endregion
|
WxKfService.WxMessageHandle(sMsg, "wxkf_msg");
|
}
|
|
return Ok("success");
|
}
|
|
/// <summary>
|
/// 公众号消息
|
/// </summary>
|
/// <returns></returns>
|
[AcceptVerbs("GET", "POST")]
|
public async Task<IActionResult> GZHMessage()
|
{
|
if (HttpContext.Request.Method.ToLower() != "post")
|
{
|
#region 接口校验
|
WXBizMsgCryptGZH wxcpt = new WXBizMsgCryptGZH(_token, _aeskey, "");
|
string sVerifyMsgSig = HttpContext.Request.Query["signature"];
|
string sVerifyTimeStamp = HttpContext.Request.Query["timestamp"];
|
string sVerifyNonce = HttpContext.Request.Query["nonce"];
|
string sVerifyEchoStr = HttpContext.Request.Query["echostr"].ToString();
|
// LogUtil.Info($"[sVerifyMsgSig]:{sVerifyMsgSig}--[timestamp]:{sVerifyTimeStamp}--[nonce]:{sVerifyNonce}--[echostr]:{sVerifyEchoStr}", "gzh记录");
|
int ret = 0;
|
string sEchoStr = "";
|
ret = wxcpt.VerifyURL(sVerifyMsgSig, sVerifyTimeStamp, sVerifyNonce, sVerifyEchoStr, ref sEchoStr);
|
//LogUtil.Info(ret.ToString(), "gzh记录");
|
//LogUtil.Info(sEchoStr, "gzh记录");
|
if (ret != 0)
|
{
|
System.Console.WriteLine("ERR: VerifyURL fail, ret: " + ret);
|
|
return Content(sEchoStr);
|
}
|
return Content(sEchoStr);
|
|
#endregion
|
}
|
else
|
{
|
#region 解析官方请求参数
|
StreamReader reader = new StreamReader(HttpContext.Request.Body, Encoding.UTF8);
|
var result = reader.ReadToEndAsync().Result;
|
reader.Close();
|
string sReqMsgSig = HttpContext.Request.Query["signature"];
|
string sReqTimeStamp = HttpContext.Request.Query["timestamp"];
|
string sReqNonce = HttpContext.Request.Query["nonce"];
|
|
// LogUtil.Info($"[signature]:{sReqMsgSig}--[timestamp]:{sReqTimeStamp}--[nonce]:{sReqNonce}", "gzh消息记录");
|
|
WXBizMsgCryptGZH wxcpt = new WXBizMsgCryptGZH(_token, _aeskey, _gzhappid);
|
string sMsg = ""; // 解析之后的明文
|
var code = wxcpt.DecryptMsg(sReqMsgSig, sReqTimeStamp, sReqNonce, result, ref sMsg);
|
|
LogUtil.Info($"服务商数据回调xmlConten---{sMsg}", $"gzh_msg_log日志");
|
#endregion
|
//try
|
//{
|
// XmlDocument doc = new XmlDocument();
|
// XmlNode root;
|
// doc.LoadXml(sMsg);
|
// root = doc.FirstChild;
|
// LogUtil.Info($"[MsgType]:{root["MsgType"].InnerText}--[Content]:{root["Content"].InnerText}","gzh内容");
|
// if(root["MsgType"].InnerText=="text"&& root["Content"].InnerText == "9001")
|
// {
|
// string toUser = root["ToUserName"].InnerText;
|
// string fromUser= root["FromUserName"].InnerText;
|
// string CreateTime= root["CreateTime"].InnerText;
|
// string resXML = $"<xml><ToUserName><![CDATA[{toUser}]]></ToUserName><FromUserName><![CDATA[{fromUser}]]></FromUserName><CreateTime>{sReqTimeStamp}</CreateTime><MsgType><![CDATA[news]]></MsgType><ArticleCount>1</ArticleCount><Articles><item><Title><![CDATA[欢迎关注]]></Title><Description><![CDATA[欢迎语]]></Description><PicUrl><![CDATA[https://yanfeiobpub.obs.cn-east-3.myhuaweicloud.com/dfg/8%E6%9C%88%E9%82%80%E8%AF%B7%E6%B4%BB%E5%8A%A8topbanner.png]]></PicUrl><Url><![CDATA[mp://QQdaIgLEddo5U6H]]></Url></item></Articles></xml>";
|
// LogUtil.Info(resXML, "gzh回复");
|
// string sEncryptMsg = "";
|
// int ret = wxcpt.EncryptMsg(resXML, sReqTimeStamp, sReqNonce, ref sEncryptMsg);
|
// LogUtil.Info(sEncryptMsg, "gzh回复");
|
// return Ok(sEncryptMsg);
|
// }
|
//}
|
//catch(Exception e)
|
//{
|
// LogUtil.Info(e.ToString(), "gzherror");
|
//}
|
|
|
|
WxKfService.WxMessageHandle(sMsg, "gzh_msg");
|
}
|
return Ok("success");
|
}
|
|
public async void MsgHandle(string msgType)
|
{
|
try
|
{
|
if (HttpContext.Request.Method.ToLower() == "post")
|
{
|
|
#region 解析官方请求参数
|
StreamReader reader = new StreamReader(HttpContext.Request.Body, Encoding.UTF8);
|
var result = reader.ReadToEndAsync().Result;
|
reader.Close();
|
string sReqMsgSig = HttpContext.Request.Query["msg_signature"];
|
string sReqTimeStamp = HttpContext.Request.Query["timestamp"];
|
string sReqNonce = HttpContext.Request.Query["nonce"];
|
WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(_token, _aeskey, "");
|
|
string sMsg = ""; // 解析之后的明文
|
var code = wxcpt.DecryptMsg(sReqMsgSig, sReqTimeStamp, sReqNonce, result, ref sMsg);
|
LogUtil.Info($"服务商数据回调xmlConten---{sMsg}", $"{msgType}_log日志");
|
#endregion
|
WxKfService.WxMessageHandle(sMsg, msgType);
|
}
|
}
|
catch (Exception e)
|
{
|
LogUtil.Info(e.ToString(), "微信客服消息error");
|
}
|
}
|
|
/// <summary>
|
/// 创建公众号菜单
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
|
[HttpPost]
|
public IActionResult CreateGzhMenu([FromBody] CreateMenuRequest request)
|
{
|
//获取token
|
var token = WxKfService.GetGzhToken();
|
var response = WeiXinKfClient.CreateGzhMenu(request, token);
|
return Ok(response);
|
}
|
|
|
/// <summary>
|
/// 上传微信素材
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult UploadWxImg([FromBody] UploadWxImgRequest request)
|
{
|
//获取token
|
string imgPath = System.Environment.CurrentDirectory + "/" + request.name;
|
var token = WxKfService.GetGzhToken();
|
var response = WeiXinKfClient.UploadWxMedia(imgPath, request.name, token);
|
return Ok(response);
|
}
|
|
|
[HttpPost]
|
public IActionResult GetRid([FromBody] GetRidRequest request)
|
{
|
var token = WxKfService.GetGzhToken();
|
string ridRes = WeiXinKfClient.GetGzhRid(request.Rid, token);
|
return Ok(ridRes);
|
}
|
|
/// <summary>
|
/// 公众号消息
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult GetAuthCode([FromBody] GetAuthCodeRequest request)
|
{
|
//通过code获取accesstoken
|
var codeRsp = WeiXinKfClient.GetOauth2Token(request.Code);
|
if (codeRsp.IsNull() || codeRsp.errcode > 0)
|
{
|
string errmsg = codeRsp.IsNull() ? "获取token失败" : codeRsp.errmsg;
|
return Ok(errmsg);
|
}
|
//通过accesstoken获取用户信息
|
var userInfo = WeiXinKfClient.GetGzhUserInfo(codeRsp.access_token, codeRsp.openid);
|
|
if (userInfo.IsNull() || userInfo.errcode > 0)
|
{
|
string errmsg = userInfo.IsNull() ? "获取用户信息失败" : userInfo.errmsg;
|
return Ok(errmsg);
|
}
|
WxKfService.RecordeGzhInfo(userInfo);
|
|
return Ok(true);
|
}
|
|
/// <summary>
|
/// 发送公众号模板消息
|
/// </summary>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
[HttpPost]
|
public IActionResult SendGzhTemplateMsg([FromBody] SendTemplateMsgRequest request)
|
{
|
var token = WxKfService.GetGzhToken();
|
var rsp = WeiXinKfClient.SendTemplateMsg(request, token);
|
return Ok(rsp);
|
}
|
}
|
}
|
