using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using CommonUtil.Web;
|
using CommonUtil;
|
using WeiXinKfSDK.Response;
|
using RestSharp;
|
using WeiXinKfSDK.Request;
|
using Newtonsoft.Json;
|
using System.Reflection;
|
|
namespace WeiXinKfSDK
|
{
|
public class WeiXinKfClient
|
{
|
/// <summary>
|
/// 获取消息
|
/// </summary>
|
/// <param name="token"></param>
|
/// <param name="accessToken"></param>
|
public static SyncMsgResponse SyncMsg(string token, string cursor, string accessToken)
|
{
|
string url = $"https://qyapi.weixin.qq.com/cgi-bin/kf/sync_msg?access_token={accessToken}";
|
Dictionary<string, object> dic = new Dictionary<string, object>();
|
dic.Add("token", token);
|
if (!cursor.IsNullOrEmpty())
|
{
|
dic.Add("cursor", cursor);
|
}
|
string resStr = new WebUtil().DoPostWithJson(url, dic, null);
|
LogUtil.Info($"[获取消息]token:{token},返回：{resStr}", "接口请求日志");
|
if (resStr.IsNullOrEmpty())
|
{
|
return null;
|
}
|
SyncMsgResponse response = JSONUtil.JsonToObject<SyncMsgResponse>(resStr);
|
return response;
|
}
|
/// <summary>
|
/// 获取微信客服acess_token
|
/// </summary>
|
/// <returns></returns>
|
public static GetAccessTokenResponse GetAccessToken()
|
{
|
string getUrl = $"https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={WeiXinKfSetting._comId}&corpsecret={WeiXinKfSetting._secret}";
|
string resStr = new WebUtil().DoGet(getUrl, null);
|
LogUtil.Info($"[获取access_token]返回：{resStr}", "接口请求日志");
|
if (resStr.IsNullOrEmpty())
|
{
|
return null;
|
}
|
GetAccessTokenResponse response = JSONUtil.JsonToObject<GetAccessTokenResponse>(resStr);
|
return response;
|
}
|
|
/// <summary>
|
/// 获取公众号acess_token
|
/// </summary>
|
/// <returns></returns>
|
public static GetAccessTokenResponse GetGzhAccessToken()
|
{
|
string getUrl = $" https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={WeiXinKfSetting._gzhAppid}&secret={WeiXinKfSetting._gzhSecret}";
|
string resStr = new WebUtil().DoGet(getUrl, null);
|
LogUtil.Info($"[获取access_token]返回：{resStr}", "接口请求日志");
|
if (resStr.IsNullOrEmpty())
|
{
|
return null;
|
}
|
GetAccessTokenResponse response = JSONUtil.JsonToObject<GetAccessTokenResponse>(resStr);
|
return response;
|
}
|
|
/// <summary>
|
/// 发送客服欢迎语
|
/// </summary>
|
/// <param name="request"></param>
|
/// <param name="accessToken"></param>
|
/// <returns></returns>
|
public static SendMsgOnEventResponse SendMsgOnEvent(SendMsgOnEventRequest request, string accessToken)
|
{
|
string url = $"https://qyapi.weixin.qq.com/cgi-bin/kf/send_msg_on_event?access_token={accessToken}";
|
Dictionary<string, object> dic = new Dictionary<string, object>();
|
dic.Add("code", request.code);
|
dic.Add("msgid", request.msgid);
|
dic.Add("msgtype", request.msgtype);
|
if (!request.text.IsNull())
|
{
|
dic.Add("text", request.text);
|
}
|
if (!request.msgmenu.IsNull())
|
{
|
dic.Add("msgmenu", request.msgmenu);
|
}
|
string resStr = new WebUtil().DoPostWithJson(url, dic, null);
|
LogUtil.Info($"[发送客服欢迎语]请求:{JSONUtil.ObjectToJson(request)},返回：{resStr}", "接口请求日志");
|
if (resStr.IsNullOrEmpty())
|
{
|
return null;
|
}
|
SendMsgOnEventResponse response = JSONUtil.JsonToObject<SendMsgOnEventResponse>(resStr);
|
return response;
|
}
|
/// <summary>
|
/// 发送消息
|
/// </summary>
|
/// <param name="accessToken"></param>
|
/// <returns></returns>
|
public static SendMsgOnEventResponse SendMsg(SendMsgRequest request, string accessToken)
|
{
|
string url = $"https://qyapi.weixin.qq.com/cgi-bin/kf/send_msg?access_token={accessToken}";
|
Dictionary<string, object> dic = new Dictionary<string, object>();
|
dic.Add("touser", request.touser);
|
dic.Add("open_kfid", request.open_kfid);
|
if (!request.msgid.IsNullOrEmpty())
|
{
|
dic.Add("msgid", request.msgid);
|
}
|
dic.Add("msgtype", request.msgtype);
|
if (!request.text.IsNull())
|
{
|
dic.Add("text", request.text);
|
}
|
if (!request.image.IsNull())
|
{
|
dic.Add("image", request.image);
|
}
|
string resStr = new WebUtil().DoPostWithJson(url, dic, null);
|
// LogUtil.Info($"[发消息]请求:{JSONUtil.ObjectToJson(request)},返回：{resStr}", "接口请求日志");
|
if (resStr.IsNullOrEmpty())
|
{
|
return null;
|
}
|
SendMsgOnEventResponse response = JSONUtil.JsonToObject<SendMsgOnEventResponse>(resStr);
|
return response;
|
}
|
/// <summary>
|
/// 上传图片
|
/// </summary>
|
/// <param name="imgPath"></param>
|
/// <param name="imgName"></param>
|
/// <param name="accessToken"></param>
|
/// <returns></returns>
|
public static MediaUploadResponse ImgMediaUpload(string imgPath, string imgName, string accessToken)
|
{
|
try
|
{
|
var client = new RestClient($"https://qyapi.weixin.qq.com/cgi-bin/media/upload?access_token={accessToken}&type=image");
|
client.Timeout = -1;
|
var request = new RestRequest(Method.POST);
|
request.AddParameter("filename", imgName);
|
request.AddParameter("Content-Type", "application/octet-stream");
|
request.AddFile("filelength", $"{imgPath}");
|
IRestResponse response = client.Execute(request);
|
MediaUploadResponse res = JSONUtil.JsonToObject<MediaUploadResponse>(response.Content);
|
return res;
|
}
|
catch (Exception e)
|
{
|
return null;
|
}
|
}
|
|
/// <summary>
|
/// 创建公众号菜单
|
/// </summary>
|
public static CreateMenuResponse CreateGzhMenu(CreateMenuRequest request, string accessToken)
|
{
|
string url = $"https://api.weixin.qq.com/cgi-bin/menu/create?access_token={accessToken}";
|
Dictionary<string, object> dic = new Dictionary<string, object>();
|
dic.Add("button", request.button);
|
string resStr = new WebUtil().DoPostWithJson(url, dic, null);
|
LogUtil.Info($"[发消息]请求:{JSONUtil.ObjectToJson(request)},返回：{resStr}", "创建公众号菜单日志");
|
if (resStr.IsNullOrEmpty())
|
{
|
return null;
|
}
|
CreateMenuResponse response = JSONUtil.JsonToObject<CreateMenuResponse>(resStr);
|
return response;
|
}
|
|
/// <summary>
|
/// 发送客服消息
|
/// </summary>
|
/// <returns></returns>
|
public static GzhCustomerSendResponse GzhCustomerSend(GzhCustomerSendRequest request, string accessToken)
|
{
|
string url = $"https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token={accessToken}";
|
Dictionary<string, object> dic = new Dictionary<string, object>();
|
dic.Add("touser", request.touser);
|
dic.Add("msgtype", request.msgtype);
|
switch (request.msgtype)
|
{
|
case "text":
|
dic.Add("text", request.text);
|
break;
|
case "image":
|
dic.Add("image", request.image);
|
break;
|
default: break;
|
}
|
string resStr = new WebUtil().DoPostWithJson(url, dic, null);
|
LogUtil.Info($"[发消息]请求:{JSONUtil.ObjectToJson(request)},返回：{resStr}", "发送客服消息日志");
|
if (resStr.IsNullOrEmpty())
|
{
|
return null;
|
}
|
GzhCustomerSendResponse response = JSONUtil.JsonToObject<GzhCustomerSendResponse>(resStr);
|
return response;
|
}
|
//100000052
|
public static GzhBaseResponse UploadWxMedia(string imgPath, string imgName, string accessToken)
|
{
|
try
|
{
|
var client = new RestClient($"https://api.weixin.qq.com/cgi-bin/material/add_material?access_token={accessToken}&type=image");
|
client.Timeout = -1;
|
var request = new RestRequest(Method.POST);
|
request.AddParameter("filename", imgName);
|
request.AddParameter("type", "image");
|
request.AddParameter("Content-Type", "application/octet-stream");
|
request.AddFile("filelength", $"{imgPath}");
|
IRestResponse response = client.Execute(request);
|
GzhBaseResponse res = JSONUtil.JsonToObject<GzhBaseResponse>(response.Content);
|
return res;
|
}
|
catch (Exception e)
|
{
|
return null;
|
}
|
}
|
|
/// <summary>
|
/// 通过code获取access_token,用户授权
|
/// </summary>
|
/// <param name="code"></param>
|
/// <returns></returns>
|
public static GetOauth2TokenResponse GetOauth2Token(string code)
|
{
|
string getUrl = $"https://api.weixin.qq.com/sns/oauth2/access_token?appid={WeiXinKfSetting._gzhAppid}&secret={WeiXinKfSetting._gzhSecret}&code={code}&grant_type=authorization_code";
|
string resStr = new WebUtil().DoGet(getUrl, null);
|
LogUtil.Info($"[gzh获取access_token]返回：{resStr}", "接口请求日志");
|
GetOauth2TokenResponse response = JSONUtil.JsonToObject<GetOauth2TokenResponse>(resStr);
|
return response;
|
}
|
|
|
/// <summary>
|
/// 通过accesstoken获取用户信息
|
/// </summary>
|
/// <param name="accessToken"></param>
|
/// <param name="openId"></param>
|
/// <returns></returns>
|
public static GetGzhUserInfoResonse GetGzhUserInfo(string accessToken, string openId)
|
{
|
string getUrl = $"https://api.weixin.qq.com/sns/userinfo?access_token={accessToken}&openid={openId}&lang=zh_CN";
|
string resStr = new WebUtil().DoGet(getUrl, null);
|
LogUtil.Info($"[获取用户信息]返回：{resStr}", "接口请求日志");
|
GetGzhUserInfoResonse response = JSONUtil.JsonToObject<GetGzhUserInfoResonse>(resStr);
|
return response;
|
}
|
|
public static string GetGzhRid(string rid, string accessToken)
|
{
|
string url = $"https://api.weixin.qq.com/cgi-bin/openapi/rid/get?access_token={accessToken}";
|
Dictionary<string, object> dic = new Dictionary<string, object>();
|
dic.Add("rid", rid);
|
string resStr = new WebUtil().DoPostWithJson(url, dic, null);
|
LogUtil.Info($"[发消息]请求:{JSONUtil.ObjectToJson(dic)},返回：{resStr}", "发送客服消息日志");
|
return resStr;
|
}
|
/// <summary>
|
/// 发送公众号模板消息
|
/// </summary>
|
/// <param name="request"></param>
|
public static SendTemplateMsgResponse SendTemplateMsg(SendTemplateMsgRequest request, string access_token)
|
{
|
string url = $"https://api.weixin.qq.com/cgi-bin/message/template/send?access_token={access_token}";
|
Dictionary<string, object> dic = new Dictionary<string, object>();
|
dic.Add("touser", request.touser);
|
dic.Add("template_id", request.template_id);
|
dic.Add("data", request.data);
|
string resStr = new WebUtil().DoPostWithJson(url, dic, null);
|
LogUtil.Info($"[发模板消息]请求:{JSONUtil.ObjectToJson(dic)},返回：{resStr}", "发送模板消息日志");
|
SendTemplateMsgResponse res = JSONUtil.JsonToObject<SendTemplateMsgResponse>(resStr);
|
return res;
|
}
|
}
|
}
|
