using Operater.DTO.TopMessage;
|
using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using System.Xml;
|
using WeiXinKfSDK.Response;
|
using CommonUtil;
|
using WeiXinKfSDK;
|
using System.Linq;
|
using Operater.DAL;
|
using Operater.DbModel;
|
|
namespace TradeInterflow.Handle
|
{
|
public class WxKfHandle
|
{
|
|
public static WxKfToken _wxkfToken = new WxKfToken();
|
|
public static List<WxMediaModel> _wxMedia = new List<WxMediaModel>();
|
/// <summary>
|
/// 处理微信客服消息
|
/// </summary>
|
/// <param name="message"></param>
|
public static void HandleExecute(string xmlMessage)
|
{
|
try
|
{
|
Console.WriteLine("微信客服消息");
|
XmlDocument doc = new XmlDocument();
|
XmlNode root;
|
doc.LoadXml(xmlMessage);
|
root = doc.FirstChild;
|
string token = root["Token"].InnerText;
|
//根据token获取 信息内容
|
string accessToken = GetWxKfToken(false);
|
if (accessToken.IsNullOrEmpty())
|
{
|
return;
|
}
|
SyncMsgResponse msgModel = new SyncMsgResponse();
|
//获取nextcursor
|
if (_wxkfToken.NextCursor.IsNullOrEmpty())
|
{
|
var appSet = new AppsetDAL().ListGet(t => t.Id != null);
|
_wxkfToken.NextCursor = appSet[0].WxNextCursor;
|
}
|
while (true)
|
{
|
msgModel = WeiXinKfClient.SyncMsg(token, _wxkfToken.NextCursor, accessToken);
|
if (msgModel.IsNull())
|
{
|
return;
|
}
|
else if (msgModel.errcode != 0 && (msgModel.errmsg.Contains("invalid access_token") || msgModel.errmsg.Contains("access_token expired")))
|
{//token不对
|
accessToken = GetWxKfToken(true);
|
}
|
else if (msgModel.errcode == 0)
|
{
|
break;
|
}
|
else
|
{
|
return;
|
}
|
}
|
//记录nextcursor
|
if (msgModel.msg_list.Count == 0 && msgModel.next_cursor == _wxkfToken.NextCursor)
|
{
|
return;
|
}
|
_wxkfToken.NextCursor = msgModel.next_cursor;
|
Appset appset = new Appset()
|
{
|
WxNextCursor = msgModel.next_cursor
|
};
|
new AppsetDAL().Update(appset, i => new { i.WxNextCursor }, t => t.Id != null);
|
foreach (var msgItem in msgModel.msg_list)
|
{
|
|
switch (msgItem.msgtype)
|
{
|
case "event"://事件消息
|
EventHandle(msgItem);
|
break;
|
case "text"://文本消息
|
TextHandle(msgItem);
|
break;
|
}
|
|
}
|
}
|
catch(Exception e)
|
{
|
LogUtil.Info(e.ToString(),"微信客服消息错误");
|
}
|
|
}
|
|
/// <summary>
|
/// 文本消息
|
/// </summary>
|
/// <param name="msgItem"></param>
|
private static void TextHandle(SyncMsgListDto msgItem)
|
{
|
switch (msgItem.text.content)
|
{
|
case "100"://发送企微码
|
SendQwQR(msgItem);
|
break;
|
default:
|
break;
|
}
|
|
}
|
|
private static void SendQwQR(SyncMsgListDto msgItem)
|
{
|
//获取图片id
|
string mediaId = GetMediaId("smssign", _wxkfToken.AccessToken);
|
if (mediaId.IsNullOrEmpty())
|
{
|
return;
|
}
|
SendMsgImgDomain sendMsgImgDomain = new SendMsgImgDomain()
|
{
|
media_id = mediaId
|
};
|
SendMsgRequest request = new SendMsgRequest()
|
{
|
touser = msgItem.external_userid,
|
open_kfid = msgItem.open_kfid,
|
msgtype = "image",
|
image = sendMsgImgDomain
|
};
|
//string accessToken = GetWxKfToken(false);
|
//if (accessToken.IsNullOrEmpty())
|
//{
|
// return;
|
//}
|
var sendRsp = WeiXinKfClient.SendMsg(request, _wxkfToken.AccessToken);
|
//发送文案
|
SendMsgTextDomain sendMsgTextDomain = new SendMsgTextDomain()
|
{
|
content = "点开图片-长按识别二维码-添加诺诺领福利啦~"
|
};
|
request = new SendMsgRequest()
|
{
|
touser = msgItem.external_userid,
|
open_kfid = msgItem.open_kfid,
|
msgtype = "text",
|
text = sendMsgTextDomain
|
};
|
sendRsp = WeiXinKfClient.SendMsg(request, _wxkfToken.AccessToken);
|
}
|
#region 获取mediaId
|
/// <summary>
|
/// 获取mediaId
|
/// </summary>
|
/// <param name="mediaType"></param>
|
/// <returns></returns>
|
public static string GetMediaId(string mediaType,string accessToken)
|
{
|
var media = _wxMedia.Where(t => t.MediaType == mediaType).ToList();
|
if (media.IsNull() || media.Count == 0 || media[0].ExpreTime < DateTime.Now)
|
{
|
WxMediaModel wxMediaModel = new WxMediaModel();
|
var mediaDb = new WxMediaDAL().ListGet(t => t.HandleType == mediaType);
|
if (!mediaDb.IsNull() && mediaDb.Count > 0 && mediaDb[0].ExpireTime > DateTime.Now)
|
{ //先从数据库获取
|
wxMediaModel.MediaId = mediaDb[0].MediaId;
|
wxMediaModel.ExpreTime = (DateTime)mediaDb[0].ExpireTime;
|
wxMediaModel.MediaType = mediaType;
|
}
|
else
|
{
|
//接口获取
|
string imagName = mediaType + ".png";
|
string imgPath = System.Environment.CurrentDirectory + "/" + imagName;
|
//string accessToken = GetWxKfToken(false);
|
//if (accessToken.IsNullOrEmpty())
|
//{
|
// return null;
|
//}
|
var imgUp = WeiXinKfClient.ImgMediaUpload(imgPath, imagName, accessToken);
|
if (imgUp.IsNull() || imgUp.errcode != 0)
|
{
|
LogUtil.Info($"上传图片错误:{JSONUtil.ObjectToJson(imgUp)}", "错误");
|
return null;
|
}
|
wxMediaModel.MediaId = imgUp.media_id;
|
wxMediaModel.ExpreTime = DateTime.Now.AddHours(68);
|
wxMediaModel.MediaType = mediaType;
|
//修改数据库
|
WxMedia wxMedia = new WxMedia()
|
{
|
Id = Guid.NewGuid().ToString(),
|
MediaId = imgUp.media_id,
|
ExpireTime = wxMediaModel.ExpreTime,
|
HandleType = mediaType
|
};
|
if (!mediaDb.IsNull() && mediaDb.Count > 0)
|
{//修改
|
new WxMediaDAL().Update(wxMedia, i => new { i.MediaId, i.ExpireTime }, t => t.HandleType == mediaType);
|
}
|
else
|
{//新增
|
new WxMediaDAL().Insert(wxMedia);
|
}
|
}
|
if (media.Count > 0)
|
{
|
_wxMedia.Remove(media[0]);
|
}
|
_wxMedia.Add(wxMediaModel);
|
return wxMediaModel.MediaId;
|
}
|
return media[0].MediaId;
|
}
|
|
#endregion
|
|
private static void EventHandle(SyncMsgListDto msgItem)
|
{
|
if (msgItem.Event.event_type != "enter_session")
|
{//非进入对话框
|
return;
|
}
|
switch (msgItem.Event.scene)
|
{//进入会话的场景值
|
case "jd":
|
break;
|
default:
|
EnterSession(msgItem);
|
break;
|
}
|
|
}
|
|
#region 处理欢迎语
|
|
private static void EnterSession(SyncMsgListDto msgItem)
|
{
|
try
|
{
|
if (msgItem.Event.welcome_code.IsNullOrEmpty())
|
{
|
return;
|
}
|
SendMsgOnEventRequest welReq = new SendMsgOnEventRequest();
|
welReq.code = msgItem.Event.welcome_code;
|
welReq.msgid = TopUtil.GetId().ToString();
|
welReq.msgtype = "text";
|
string content = "哈喽~\n\n这里是小欧智能小助手\n\n☞回复100\n\n添加专属福利官~";
|
SendMsgOnEventReqTxt sendMsgOnEventReqTxt = new SendMsgOnEventReqTxt
|
{
|
content = content
|
};
|
welReq.text = sendMsgOnEventReqTxt;
|
|
#region msgmenu类型
|
if (false)
|
{
|
welReq.msgtype = "msgmenu";
|
List<SendMsgOnEventReqMenuList> menuList = new List<SendMsgOnEventReqMenuList>();
|
//click
|
MenuClick menuClick = new MenuClick()
|
{
|
id = "101",
|
content = "点击按钮"
|
};
|
SendMsgOnEventReqMenuList click = new SendMsgOnEventReqMenuList()
|
{
|
type = "click",
|
click = menuClick
|
};
|
menuList.Add(click);
|
//view
|
MenuView menuView = new MenuView()
|
{
|
url = "https://shop120092226.youzan.com/v2/showcase/homepage?alias=EdS1U5LdGX",
|
content = "点击领取优惠"
|
};
|
SendMsgOnEventReqMenuList view = new SendMsgOnEventReqMenuList()
|
{
|
type = "view",
|
view = menuView
|
};
|
menuList.Add(view);
|
|
//miniprogram
|
MenuMiniprogram menuMiniprogram = new MenuMiniprogram()
|
{
|
appid = "wx47cef388625e8b93",
|
pagepath = "pages/home/dashboard/index",
|
content = "点击打开小程序，享受优惠",
|
};
|
SendMsgOnEventReqMenuList miniprogram = new SendMsgOnEventReqMenuList()
|
{
|
type = "miniprogram",
|
miniprogram = menuMiniprogram
|
};
|
menuList.Add(miniprogram);
|
//text
|
MenuTxt menuTxt = new MenuTxt()
|
{
|
content = "纯文本的展示展示展示",
|
no_newline = 0
|
};
|
SendMsgOnEventReqMenuList text = new SendMsgOnEventReqMenuList()
|
{
|
type = "text",
|
text = menuTxt
|
};
|
menuList.Add(text);
|
SendMsgOnEventReqMenu menuObj = new SendMsgOnEventReqMenu()
|
{
|
head_content = "头部欢迎语",
|
tail_content = "尾部结束语",
|
list = menuList
|
};
|
welReq.msgmenu = menuObj;
|
}
|
#endregion
|
string accessToken = GetWxKfToken(false);
|
if (accessToken.IsNullOrEmpty())
|
{
|
return;
|
}
|
var sendRsp = WeiXinKfClient.SendMsgOnEvent(welReq, accessToken);
|
|
}
|
catch (Exception e)
|
{
|
LogUtil.Info($"处理欢迎语失败：{e.ToString()}", "微信客服error");
|
}
|
}
|
|
#endregion
|
|
#region 获取微信客服accesstoken
|
public static string GetWxKfToken(bool isRestart)
|
{
|
string cacheName = "wxkf_acctoken";
|
if (isRestart)
|
{
|
_wxkfToken = null;
|
}
|
if (_wxkfToken.IsNull() || _wxkfToken.AccessToken.IsNullOrEmpty() || _wxkfToken.ExpressTime < DateTime.Now)
|
{//从接口获取
|
var topToken = WeiXinKfClient.GetAccessToken();
|
if (topToken.IsNull())
|
{
|
return null;
|
}
|
if (topToken.errcode != 0)
|
{
|
LogUtil.Info($"获取accesstoken失败：{topToken.errmsg}", "微信客服error");
|
return null;
|
}
|
_wxkfToken = new WxKfToken();
|
_wxkfToken.AccessToken = topToken.access_token;
|
_wxkfToken.ExpressTime = DateTime.Now.AddHours(2);
|
return topToken.access_token;
|
}
|
return _wxkfToken.AccessToken;
|
}
|
#endregion
|
}
|
}
|
