645 lines
27 KiB
C#
645 lines
27 KiB
C#
using AppletMvcService.Common;
|
||
using AppletMvcService.Models;
|
||
using Newtonsoft.Json;
|
||
using Ninject;
|
||
using System;
|
||
using System.Collections.Generic;
|
||
using System.Configuration;
|
||
using System.Data;
|
||
using System.IO;
|
||
using System.Net;
|
||
using System.Text;
|
||
using WX.CRM.Common;
|
||
using WX.CRM.IBLL.weapp;
|
||
using WX.CRM.Model.weapp;
|
||
using WX.CRM.WebHelper.Infrastructure;
|
||
namespace AppletMvcService.Hanlder
|
||
{
|
||
public class MessageHandler
|
||
{
|
||
public static IAppletMsg appletmsg = NinjectControllerFactory.ninjectKernel.Get<IAppletMsg>();
|
||
public static IWX_UserInfo userinfo = NinjectControllerFactory.ninjectKernel.Get<IWX_UserInfo>();
|
||
private static Dictionary<string, WxAccount> wxaccount = null;
|
||
|
||
public static Dictionary<string, WxAccount> GetWxAccount()
|
||
{
|
||
if (wxaccount != null && wxaccount.Count > 0)
|
||
return wxaccount;
|
||
wxaccount = new Dictionary<string, WxAccount>();
|
||
DataTable tab = userinfo.GetWxAccount();
|
||
if (tab != null && tab.Rows.Count > 0)
|
||
{
|
||
LogHelper.Error("wxaccount为空，需要进行初始化！");
|
||
foreach (DataRow item in tab.Rows)
|
||
{
|
||
WxAccount account = new WxAccount();
|
||
account.accountName = item["ACCOUNTNAME"].ToString();
|
||
account.pkid = Convert.ToDecimal(item["PKID"]);
|
||
account.accountNum = item["ACCOUNTNUM"].ToString();
|
||
account.appId = item["APPID"].ToString();
|
||
account.appSecret = item["APPSECRET"].ToString();
|
||
account.fenPeiPoc = item["FENPEIPOC"].ToString();
|
||
if (!wxaccount.ContainsKey(account.accountNum))
|
||
wxaccount.Add(account.accountNum, account);
|
||
account.tokenhttp = item["TOKENHTTP"].ToString();
|
||
account.isonline = Convert.ToInt32(item["ISONLINE"]);
|
||
}
|
||
}
|
||
return wxaccount;
|
||
}
|
||
#region 在线客服维护
|
||
public static Dictionary<string, List<UserDetail>> GetConnectedByRedis()
|
||
{
|
||
Dictionary<string, List<UserDetail>> nn = new Dictionary<string, List<UserDetail>>();
|
||
try
|
||
{
|
||
LogHelper.Error("客服数据获取");
|
||
//Dictionary<string, WxAccount> naccount = GetWxAccount();
|
||
DataTable tab = userinfo.GetOnlineUser();
|
||
if (tab != null && tab.Rows.Count > 0)
|
||
{
|
||
foreach (DataRow item in tab.Rows)
|
||
{
|
||
UserDetail detial = new UserDetail();
|
||
detial.ConnectionId = item["connectionid"].ToString();
|
||
detial.DeptName = item["deptname"].ToString();
|
||
detial.LoginTime = Convert.ToDateTime(item["logintime"]);
|
||
detial.UserID = item["userid"].ToString();
|
||
detial.UserName = item["username"].ToString();
|
||
string accountnum = item["accountnum"].ToString();
|
||
if (!nn.ContainsKey(accountnum))
|
||
nn.Add(accountnum, new List<UserDetail>());
|
||
nn[accountnum].Add(detial);
|
||
}
|
||
}
|
||
|
||
}
|
||
catch (Exception x)
|
||
{
|
||
LogHelper.Error(x.ToString());
|
||
}
|
||
return nn;
|
||
}
|
||
public static void AddConnectedToRedis(UserDetail connected, string accountnum)
|
||
{
|
||
try
|
||
{
|
||
userinfo.Logon(connected.ConnectionId, connected.UserID, connected.UserName, connected.DeptName, connected.LoginTime, accountnum);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
LogHelper.Error(ex.ToString());
|
||
}
|
||
}
|
||
|
||
public static void RemoveConnectedToRedis(UserDetail connected, string accountnum)
|
||
{
|
||
try
|
||
{
|
||
userinfo.UnLogon(connected.UserID, accountnum);
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
LogHelper.Error(ex.ToString());
|
||
}
|
||
}
|
||
|
||
#endregion
|
||
public static void UpdateSendTime(string v_openid, DateTime v_ctime, string v_AccountNum, decimal eid)
|
||
{
|
||
userinfo.UpdateSendTime(v_openid, v_ctime, v_AccountNum, eid);
|
||
}
|
||
public static CustoemrDetail GetCustomerHeadInfo(CustoemrDetail info)
|
||
{
|
||
DataTable table = userinfo.GetUserHeadInfo(info.OpenId);
|
||
if (table != null && table.Rows.Count > 0)
|
||
{
|
||
info.NickName = table.Rows[0]["nickname"].ToString();
|
||
info.HeaderUrl = table.Rows[0]["avatarurl"].ToString();
|
||
}
|
||
return info;
|
||
}
|
||
|
||
public static void weapp_update_subscribe(string v_openid, string v_subType, DateTime v_time, string v_AccountNum)
|
||
{
|
||
userinfo.weapp_update_subscribe(v_openid, v_subType, v_time, v_AccountNum);
|
||
}
|
||
/// <summary>
|
||
/// 获取分配信息
|
||
/// </summary>
|
||
/// <param name="openId"></param>
|
||
/// <param name="onlineUser">在线人员</param>
|
||
/// <param name="accountnum">公众号</param>
|
||
/// <returns></returns>
|
||
public static string GetFenPeiEID(int type, string openId, string onlineUser, string accountnum, string fenpei, ref int isNew)
|
||
{
|
||
//LogHelper.Error("1");
|
||
if (string.IsNullOrEmpty(fenpei))
|
||
return "1";
|
||
//LogHelper.Error("2");
|
||
DataTable table = userinfo.GetFenPeiCustomerService(type, openId, onlineUser, accountnum, fenpei);
|
||
//LogHelper.Error("3");
|
||
string eid = "1";
|
||
isNew = 0;
|
||
if (table != null && table.Rows.Count > 0)
|
||
{
|
||
eid = table.Rows[0]["eid"].ToString();
|
||
isNew = Convert.ToInt32(table.Rows[0]["isNew"]);
|
||
}
|
||
//LogHelper.Error("4");
|
||
//LogHelper.Error("eid:" + eid + ",isNew:" + isNew + ",ChatHub.ConnectedUsers:" + (ChatHub.ConnectedUsers == null));
|
||
//if (ChatHub.ConnectedUsers == null)
|
||
//{
|
||
// LogHelper.Error("ChatHub.ConnectedUsers被销毁" + eid);
|
||
// return "1";
|
||
//}
|
||
//LogHelper.Error("ChatHub.ConnectedUsers.Count：" + ChatHub.ConnectedUsers.Count);
|
||
//if (ChatHub.ConnectedUsers[accountnum].Count == 0)//没有售后客服在线
|
||
//{
|
||
// eid = "1";//系统工号
|
||
//}
|
||
//else if (!string.IsNullOrEmpty(eid) && ChatHub.ConnectedUsers[accountnum].Count > 0)//检测目标售后是否在线
|
||
//{
|
||
// LogHelper.Error("count:" + ChatHub.ConnectedUsers[accountnum].Count);
|
||
|
||
// UserDetail detail = ChatHub.ConnectedUsers[accountnum].FirstOrDefault(m => m.UserID == eid);
|
||
// if (detail == null)
|
||
// {
|
||
// Random rd = new Random();
|
||
// eid = ChatHub.ConnectedUsers[accountnum][rd.Next(ChatHub.ConnectedUsers.Count)].UserID;
|
||
// }
|
||
//}
|
||
return eid;
|
||
}
|
||
/// <summary>
|
||
/// 获取好友列表
|
||
/// </summary>
|
||
/// <param name="eid"></param>
|
||
/// <param name="accountnum"></param>
|
||
/// <returns></returns>
|
||
public static List<CustoemrDetail> GetFriends(decimal eid, string accountnum)
|
||
{
|
||
List<CustoemrDetail> friends = new List<CustoemrDetail>();
|
||
DataTable table = userinfo.GetFriends(eid, accountnum);
|
||
if (table == null || table.Rows.Count == 0)
|
||
return friends;
|
||
CustoemrDetail fd = null;
|
||
foreach (DataRow item in table.Rows)
|
||
{
|
||
fd = new CustoemrDetail();
|
||
fd.ConnectionId = item["openid"].ToString();
|
||
fd.HeaderUrl = item["avatarurl"].ToString();
|
||
fd.LoginTime = DateTime.Now;
|
||
fd.NickName = item["nickname"].ToString();
|
||
fd.OpenId = item["openid"].ToString();
|
||
fd.Remarks = item["remarks"].ToString();
|
||
if (item["subscribe"] == DBNull.Value)
|
||
fd.subscribe = 0;
|
||
else
|
||
fd.subscribe = Convert.ToInt32(item["subscribe"]);
|
||
if (item["ChatTime"] == DBNull.Value)
|
||
fd.ChatTime = new DateTime(2017, 1, 1);
|
||
else
|
||
fd.ChatTime = Convert.ToDateTime(item["ChatTime"]);
|
||
|
||
fd.Hours = Convert.ToInt32(item["hours"]);
|
||
if (string.IsNullOrEmpty(fd.HeaderUrl))
|
||
fd.HeaderUrl = "/Content/Images/defaulthead.jpg";
|
||
fd.resid = string.Format("{0}", item["resid"]);
|
||
friends.Add(fd);
|
||
}
|
||
return friends;
|
||
|
||
}
|
||
public static void SendNoLineMsg(string toUserId, string accountnum)
|
||
{
|
||
string message = "无客服在线！请在上班9:00~11:30 13:00~18:00进行咨询";
|
||
SendMsg(toUserId, message, 1, accountnum);
|
||
}
|
||
private static string GetToken(string accountnum, bool GetNew = false)
|
||
{
|
||
|
||
string url = GetWxAccount()[accountnum].tokenhttp + accountnum + (GetNew == true ? "&isForce=true" : "");
|
||
string result = RequestHelper.CreateGetString(url, null, "", null);
|
||
AccessToken imgmsg = JsonConvert.DeserializeObject<AccessToken>(result);
|
||
return imgmsg.access_token;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送消息
|
||
/// </summary>
|
||
/// <param name="toUserId"></param>
|
||
/// <param name="message"></param>
|
||
public static void SendMsg(string toUserId, string message, int eid, string accountnum)
|
||
{
|
||
string token = GetToken(accountnum);
|
||
SendMsg msg = new SendMsg();
|
||
string resultJson = string.Empty;
|
||
for (int i = 0; i < 2; i++)
|
||
{
|
||
string url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=" + token;
|
||
//LogHelper.Info(string.Format("userid:{0},token:{1}", toUserId, token));
|
||
msg.touser = toUserId.Replace("userid-", "");
|
||
msg.text = new MsgContent() { content = message };
|
||
msg.msgtype = "text";
|
||
resultJson = RequestHelper.CreatePostGetString(url, JsonConvert.SerializeObject(msg), null, "", Encoding.UTF8, null);
|
||
//LogHelper.Info("返回值：" + resultJson);
|
||
if (resultJson.IndexOf("\"errcode\":40001") > -1)
|
||
token = GetToken(accountnum, true);
|
||
else
|
||
break;
|
||
}
|
||
ResultModel rest = JsonConvert.DeserializeObject<ResultModel>(resultJson);
|
||
if (rest.errmsg != "ok")//发送失败
|
||
{
|
||
LogHelper.Error("发送文本错误：" + resultJson);
|
||
}
|
||
else
|
||
{
|
||
AppletMsgModel appletMsg = new AppletMsgModel();
|
||
appletMsg.Content = message;
|
||
DateTime time1 = System.DateTime.Now;
|
||
appletMsg.CreateTime = DateTimeTool.ConvertDateTimeInt(time1);
|
||
appletMsg.MsgId = 0;
|
||
appletMsg.MsgType = "text";
|
||
appletMsg.ToUserName = msg.touser;
|
||
appletMsg.FromUserName = accountnum;
|
||
appletmsg.WeapAddMessage(appletMsg, eid, 1, 1);
|
||
UpdateSendTime(msg.touser, time1, accountnum, eid);
|
||
}
|
||
}
|
||
public static string GetSuCaiUrl(string mediaId, string accountnum, ref string erroMsg)
|
||
{
|
||
string token = GetToken(accountnum);
|
||
string resultJson = string.Empty;
|
||
HttpWebResponse response = null;
|
||
Stream stream = null;
|
||
StreamReader sr = null;
|
||
string filePath = string.Empty;
|
||
byte[] mbyte = null;
|
||
int startmbyte = 0;
|
||
try
|
||
{
|
||
for (int i = 0; i < 2; i++)
|
||
{
|
||
string url = "https://api.weixin.qq.com/cgi-bin/media/get?access_token=" + token + "&media_id=" + mediaId;
|
||
WebClient client = new WebClient();
|
||
stream = client.OpenRead(url);
|
||
sr = new StreamReader(stream);
|
||
mbyte = new byte[1000000];
|
||
int allmybyte = (int)mbyte.Length;
|
||
while (allmybyte > 0)
|
||
{
|
||
|
||
int m = stream.Read(mbyte, startmbyte, allmybyte);
|
||
if (m == 0)
|
||
break;
|
||
|
||
startmbyte += m;
|
||
allmybyte -= m;
|
||
}
|
||
resultJson = sr.ReadToEnd();
|
||
|
||
if (resultJson.IndexOf("\"errcode\":40001") > -1)
|
||
token = GetToken(accountnum, true);
|
||
else
|
||
break;
|
||
}
|
||
if (resultJson.IndexOf("errcode") > -1)//发送失败
|
||
{
|
||
LogHelper.Error("素材获取失败：" + resultJson);
|
||
return "";
|
||
}
|
||
else
|
||
{
|
||
|
||
#region 下载文件
|
||
// 把 byte[] 写入文件
|
||
|
||
var yearMonth = DateTime.Now.Year.ToString() + DateTime.Now.Month.ToString();
|
||
string fileNameWithoutExt = yearMonth + "/" + mediaId;
|
||
string vpath = ConfigurationManager.AppSettings["weappfile"] + fileNameWithoutExt + ".amr";
|
||
|
||
FileStream fstr = new FileStream(vpath, FileMode.OpenOrCreate, FileAccess.Write);
|
||
fstr.Write(mbyte, 0, startmbyte);
|
||
fstr.Flush();
|
||
fstr.Close();
|
||
|
||
#endregion
|
||
|
||
#region 文件转换成MP3
|
||
var webPath = FileUnit.GetBaseDirectory();
|
||
var exePath = webPath + "silk2mp3";
|
||
//var fileNameWithoutExt = Path.GetFileNameWithoutExtension(vpath);
|
||
var basePath = Utility.GetSettingByKey("weappfile");
|
||
var path = basePath + "audio/" + yearMonth;
|
||
if (!Directory.Exists(path))
|
||
{
|
||
Directory.CreateDirectory(path);
|
||
}
|
||
if (!System.IO.File.Exists(vpath))
|
||
{
|
||
erroMsg = "未能找到文件！";
|
||
}
|
||
|
||
var targetFileNameMp3 = Path.Combine(path, mediaId + ".mp3");
|
||
if (!System.IO.File.Exists(targetFileNameMp3))
|
||
{
|
||
SilkConvertToMp3 amr = new SilkConvertToMp3();
|
||
amr.ConvertToMp3(exePath, vpath, targetFileNameMp3);
|
||
}
|
||
#endregion
|
||
|
||
filePath = "/audio/" + yearMonth + "/" + mediaId + ".mp3";
|
||
}
|
||
}
|
||
catch (Exception ex) { LogHelper.Error(ex.ToString()); }
|
||
finally
|
||
{
|
||
if (sr != null) { sr.Close(); }
|
||
if (stream != null) { stream.Close(); }
|
||
if (response != null) { response.Close(); }
|
||
}
|
||
return filePath;
|
||
}
|
||
/// <summary>
|
||
/// 新增一个图片文件
|
||
/// </summary>
|
||
public static ImageMsg SendImg(string type, string accountnum, string filename, string nfile)
|
||
{
|
||
string token = GetToken(accountnum);
|
||
string resultJson = string.Empty;
|
||
for (int i = 0; i < 2; i++)
|
||
{
|
||
string url = "https://api.weixin.qq.com/cgi-bin/media/upload?access_token=" + token + "&type=" + type;
|
||
resultJson = HttpUploadFile(url, filename);
|
||
if (resultJson.IndexOf("\"errcode\":40001") > -1)
|
||
token = GetToken(accountnum, true);
|
||
else
|
||
break;
|
||
}
|
||
if (resultJson.IndexOf("errcode") > -1)//发送失败
|
||
{
|
||
LogHelper.Error("新增素材失败：" + resultJson);
|
||
return null;
|
||
}
|
||
else
|
||
{
|
||
ImageMsg imgmsg = JsonConvert.DeserializeObject<ImageMsg>(resultJson);
|
||
MessageHandler.appletmsg.WeapAddFilePath(0, imgmsg.media_id, nfile);
|
||
return imgmsg;
|
||
}
|
||
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 发送图片素材
|
||
/// </summary>
|
||
/// <param name="imgmsg"></param>
|
||
/// <param name="toUser"></param>
|
||
/// <param name="accountnum"></param>
|
||
public static void SendImgMsg(ImageMsg imgmsg, string sucaitype, string toUser, string accountnum, int eid, string name, ref string content)
|
||
{
|
||
if (imgmsg == null)
|
||
return;
|
||
string token = GetToken(accountnum);
|
||
string resultJson = string.Empty;
|
||
content = string.Empty;
|
||
for (int i = 0; i < 2; i++)
|
||
{
|
||
string url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=" + token;
|
||
var ojb = new object();
|
||
if (sucaitype == "image")
|
||
{
|
||
|
||
ojb = new { touser = toUser, msgtype = sucaitype, image = new { media_id = imgmsg.media_id } };
|
||
content = "图片素材【" + (string.IsNullOrEmpty(name) ? "本地图片" : name) + "】";
|
||
}
|
||
else if (sucaitype == "voice")
|
||
{
|
||
ojb = new { touser = toUser, msgtype = sucaitype, voice = new { media_id = imgmsg.media_id } };
|
||
content = "语音素材【" + name + "】";
|
||
}
|
||
else if (sucaitype == "video")
|
||
{
|
||
ojb = new { touser = toUser, msgtype = sucaitype, video = new { media_id = imgmsg.media_id } };
|
||
content = "视频素材【" + name + "】";
|
||
}
|
||
else if (sucaitype == "mpnews")
|
||
{
|
||
ojb = new { touser = toUser, msgtype = "mpnews", mpnews = new { media_id = imgmsg.media_id } };
|
||
content = "图文素材【" + name + "】";
|
||
}
|
||
resultJson = RequestHelper.CreatePostGetString(url, JsonConvert.SerializeObject(ojb), null, "", Encoding.UTF8, null);
|
||
if (resultJson.IndexOf("\"errcode\":40001") > -1)
|
||
token = GetToken(accountnum, true);
|
||
else
|
||
break;
|
||
}
|
||
ResultModel rest = JsonConvert.DeserializeObject<ResultModel>(resultJson);
|
||
if (rest.errmsg != "ok")//发送失败
|
||
{
|
||
LogHelper.Error("发送" + content + "素材错误：" + resultJson);
|
||
}
|
||
else
|
||
{
|
||
AppletMsgModel appletMsg = new AppletMsgModel();
|
||
appletMsg.CreateTime = DateTimeTool.ConvertDateTimeInt(System.DateTime.Now);
|
||
appletMsg.MsgId = 0;
|
||
appletMsg.MsgType = sucaitype;
|
||
appletMsg.ToUserName = toUser;
|
||
appletMsg.FromUserName = accountnum;
|
||
appletMsg.MediaId = imgmsg.media_id;
|
||
appletMsg.Content = content;
|
||
appletmsg.WeapAddMessage(appletMsg, eid, 1, 1);
|
||
}
|
||
}
|
||
public static DataTable IsNeedDownLoadSuCai(string media_id)
|
||
{
|
||
return appletmsg.IsHasMediaId(media_id);
|
||
}
|
||
/// <summary>
|
||
/// 下载文件素材
|
||
/// </summary>
|
||
/// <param name="URLAddress"></param>
|
||
/// <returns></returns>
|
||
public static string DownLoadSuCaiPath(string media_id, string URLAddress)
|
||
{
|
||
string filepath = string.Empty;
|
||
try
|
||
{
|
||
string fix = ".jpg";
|
||
LogHelper.Error("fix:" + fix);
|
||
WebClient client = new WebClient();
|
||
Stream str = client.OpenRead(URLAddress);
|
||
StreamReader reader = new StreamReader(str);
|
||
byte[] mbyte = new byte[1000000];
|
||
int allmybyte = (int)mbyte.Length;
|
||
int startmbyte = 0;
|
||
|
||
while (allmybyte > 0)
|
||
{
|
||
|
||
int m = str.Read(mbyte, startmbyte, allmybyte);
|
||
if (m == 0)
|
||
break;
|
||
|
||
startmbyte += m;
|
||
allmybyte -= m;
|
||
}
|
||
|
||
reader.Dispose();
|
||
str.Dispose();
|
||
var yearMonth = DateTime.Now.Year.ToString() + DateTime.Now.Month.ToString();
|
||
string uploadFolder = (ConfigurationManager.AppSettings["weappfile"] ?? "weappfile") + "/" + yearMonth;
|
||
if (!Directory.Exists(uploadFolder))
|
||
{
|
||
Directory.CreateDirectory(uploadFolder);
|
||
}
|
||
string imgname = "G" + DateTime.Now.ToString("yyyyMMddHHmmssffff") + fix;
|
||
string path = Path.Combine(uploadFolder, imgname);
|
||
filepath = "/" + yearMonth + "/" + imgname;
|
||
FileStream fstr = new FileStream(path, FileMode.OpenOrCreate, FileAccess.Write);
|
||
fstr.Write(mbyte, 0, startmbyte);
|
||
fstr.Flush();
|
||
fstr.Close();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
LogHelper.Error("download erro:" + ex.ToString());
|
||
filepath = "";
|
||
}
|
||
return filepath;
|
||
|
||
}
|
||
|
||
public static string HttpUploadFile(string url, string path)//这个方法是两个URL第一个url是条到微信的，第二个是本地图片路径
|
||
{
|
||
// 设置参数
|
||
HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
|
||
CookieContainer cookieContainer = new CookieContainer();
|
||
request.CookieContainer = cookieContainer;
|
||
request.AllowAutoRedirect = true;
|
||
request.Method = "POST";
|
||
string boundary = DateTime.Now.Ticks.ToString("X"); // 随机分隔线
|
||
request.ContentType = "multipart/form-data;charset=utf-8;boundary=" + boundary;
|
||
byte[] itemBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "\r\n");
|
||
byte[] endBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n");
|
||
|
||
int pos = path.LastIndexOf("\\");
|
||
string fileName = path.Substring(pos + 1);
|
||
|
||
//请求头部信息
|
||
StringBuilder sbHeader = new StringBuilder(string.Format("Content-Disposition:form-data;name=\"file\";filename=\"{0}\"\r\nContent-Type:application/octet-stream\r\n\r\n", fileName));
|
||
byte[] postHeaderBytes = Encoding.UTF8.GetBytes(sbHeader.ToString());
|
||
|
||
FileStream fs = new FileStream(path, FileMode.Open, FileAccess.Read);
|
||
byte[] bArr = new byte[fs.Length];
|
||
fs.Read(bArr, 0, bArr.Length);
|
||
fs.Close();
|
||
|
||
Stream postStream = request.GetRequestStream();
|
||
postStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
|
||
postStream.Write(postHeaderBytes, 0, postHeaderBytes.Length);
|
||
postStream.Write(bArr, 0, bArr.Length);
|
||
postStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
|
||
postStream.Close();
|
||
|
||
//发送请求并获取相应回应数据
|
||
HttpWebResponse response = request.GetResponse() as HttpWebResponse;
|
||
//直到request.GetResponse()程序才开始向目标网页发送Post请求
|
||
Stream instream = response.GetResponseStream();
|
||
StreamReader sr = new StreamReader(instream, Encoding.UTF8);
|
||
//返回结果网页（html）代码
|
||
string content = sr.ReadToEnd();
|
||
return content;
|
||
}
|
||
|
||
#region 获取素材
|
||
|
||
public static object GetSucaiModel(string type, int count, int offset, string accountnum)
|
||
{
|
||
string token = GetToken(accountnum);
|
||
string resultJson = string.Empty;
|
||
for (int i = 0; i < 2; i++)
|
||
{
|
||
string url = "https://api.weixin.qq.com/cgi-bin/material/batchget_material?access_token=" + token;
|
||
SuCaiSendModel model = new SuCaiSendModel();
|
||
model.count = count;
|
||
model.offset = offset;
|
||
model.type = type;
|
||
resultJson = RequestHelper.CreatePostGetString(url, JsonConvert.SerializeObject(model), null, "", Encoding.UTF8, null);
|
||
if (resultJson.IndexOf("\"errcode\":40001") > -1)
|
||
token = GetToken(accountnum, true);
|
||
else
|
||
break;
|
||
|
||
}
|
||
if (resultJson.IndexOf("errcode") > -1)
|
||
{
|
||
//ResultModel result = JsonConvert.DeserializeObject<ResultModel>(resultJson);
|
||
return new { result = false, msg = resultJson };
|
||
}
|
||
if (type == "news")
|
||
{
|
||
//LogHelper.Info(resultJson);
|
||
//NewsModel newsmodel = JsonConvert.DeserializeObject<NewsModel>(resultJson);
|
||
//newsmodel.result = true;
|
||
//return newsmodel;
|
||
NewsModel2 newmodel = new NewsModel2();
|
||
newmodel.result = true;
|
||
newmodel.dataResult = resultJson;
|
||
return newmodel;
|
||
}
|
||
else
|
||
{
|
||
SuCaiModel newsmodel = JsonConvert.DeserializeObject<SuCaiModel>(resultJson);
|
||
newsmodel.result = true;
|
||
return newsmodel;
|
||
}
|
||
|
||
}
|
||
#endregion
|
||
}
|
||
public class SilkConvertToMp3
|
||
{
|
||
public void ConvertToPcm(string applicationPath, string fileName, string targetFileName)
|
||
{
|
||
string para = applicationPath + @"\silk_v3_decoder.exe " + fileName + " " + targetFileName + "&exit";
|
||
Cmd(para);
|
||
}
|
||
public void ConvertToMp3(string applicationPath, string fileName, string targetFilName)
|
||
{
|
||
string c = applicationPath + @"\ffmpeg.exe -i " + fileName + " " + targetFilName + "&exit"; ;
|
||
Cmd(c);
|
||
}
|
||
private void Cmd(string c)
|
||
{
|
||
try
|
||
{
|
||
System.Diagnostics.Process process = new System.Diagnostics.Process();
|
||
process.StartInfo.FileName = "cmd.exe";
|
||
process.StartInfo.UseShellExecute = false;
|
||
process.StartInfo.CreateNoWindow = true;
|
||
process.StartInfo.RedirectStandardOutput = true;
|
||
process.StartInfo.RedirectStandardInput = true;
|
||
process.Start();
|
||
|
||
process.StandardInput.WriteLine(c);
|
||
process.StandardInput.AutoFlush = true;
|
||
//process.StandardInput.WriteLine("exit");
|
||
|
||
var reader = process.StandardOutput.ReadToEnd(); //截取输出流
|
||
|
||
process.WaitForExit();
|
||
process.Close();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
LogHelper.Error("转换录音文件失败：" + ex.ToString());
|
||
}
|
||
}
|
||
}
|
||
|
||
} |