企业微信消息推送接口

using System;
using System.Collections.Generic;
using System.Text;

namespace Nany.Web.Trans
{
    public class AccessToken
    {
        private string Access_token;

        public string access_token
        {
            get { return Access_token; }
            set { Access_token = value; }
        }
        private int Expires_in;

        public int expires_in
        {
            get { return Expires_in; }
            set { Expires_in = value; }
        }

        private int Errcode;

        public int errcode
        {
            get
            {
                return Errcode;
            }
            set
            {
                Errcode = value;
            }
        }

        private string Errmsg;

        public string errmsg
        {
            get
            {
                return Errmsg;
            }
            set
            {
                Errmsg = value;
            }
        }


    }
}

using System;
using System.Collections.Generic;
using System.Text;

namespace Nany.Web.Trans
{
    public class ThumbMedia
    {
        private string Type;

        public string type
        {
            get { return Type; }
            set { Type = value; }
        }
        private string Media_Id;

        public string media_id
        {
            get { return Media_Id; }
            set { Media_Id = value; }
        }

        private string Created_At;

        public string created_at
        {
            get { return Created_At; }
            set { Created_At = value; }
        }

        private int Errcode;

        public int errcode
        {
            get
            {
                return Errcode;
            }
            set
            {
                Errcode = value;
            }
        }

        private string Errmsg;

        public string errmsg
        {
            get
            {
                return Errmsg;
            }
            set
            {
                Errmsg = value;
            }
        }

    }
}

using System;
using System.IO;
using System.Net;
using System.Text;
using System.Web;

namespace Nany.Web.Trans
{
    /// <summary>
    /// HTTP请求工具类

    /// </summary>
    public class HttpRequestUtil
    {
        #region 请求Url
        #region 请求Url，不发送数据

        /// <summary>
        /// 请求Url，不发送数据

        /// </summary>
        public static string RequestUrl(string url)
        {
            return RequestUrl(url, "POST");
        }
        #endregion

        #region 请求Url，不发送数据


        public static string GetAppPage(string url, int httpTimeout, Encoding postEncoding)
        {
            string rStr = "";
            System.Net.WebRequest req = null;
            System.Net.WebResponse resp = null;
            System.IO.Stream os = null;
            System.IO.StreamReader sr = null;
            try
            {
                //创建连接
                req = System.Net.WebRequest.Create(url);
                req.ContentType = "application/x-www-form-urlencoded";
                req.Method = "GET";

                //时间
                if (httpTimeout > 0)
                {
                    req.Timeout = httpTimeout;
                }

                //读取返回结果
                resp = req.GetResponse();
                sr = new System.IO.StreamReader(resp.GetResponseStream(), postEncoding);
                rStr = sr.ReadToEnd();
                rStr = rStr.Trim();         //除去空格
            }
            catch
            {


            }
            finally
            {
                try
                {
                    //关闭资源
                    if (os != null)
                    {
                        os.Dispose();
                        os.Close();
                    }
                    if (sr != null)
                    {
                        sr.Dispose();
                        sr.Close();
                    }
                    if (resp != null)
                    {
                        resp.Close();
                    }
                    if (req != null)
                    {
                        req.Abort();
                        req = null;
                    }
                }
                catch
                {

                }
            }
            return rStr;

        }

        public static string HttpPosturl(string filePath, string url)
        {
            string returnStr = string.Empty;
            using (WebClient client = new WebClient())
            {
                byte[] data = client.UploadFile(url, filePath);
                returnStr = Encoding.Default.GetString(data);
            }

            return returnStr;
        }

        /// <summary>
        /// 请求Url，不发送数据

        /// </summary>
        public static string RequestUrl(string url, string method)
        {
            // 设置参数
            HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
            request.Timeout = 600000;
            CookieContainer cookieContainer = new CookieContainer();
            request.CookieContainer = cookieContainer;
            request.AllowAutoRedirect = true;
            request.Method = method;
            request.ContentType = "text/html";
            request.Headers.Add("charset", "utf-8");

            //发送请求并获取相应回应数据
            HttpWebResponse response = request.GetResponse() as HttpWebResponse;
            //直到request.GetResponse()程序才开始向目标网页发送Post请求
            Stream responseStream = response.GetResponseStream();
            StreamReader sr = new StreamReader(responseStream, Encoding.UTF8);
            //返回结果网页（html）代码

            string content = sr.ReadToEnd();
            return content;
        }
        #endregion

        #region 请求Url，发送数据

        /// <summary>
        /// 请求Url，发送数据

        /// </summary>
        public static string PostUrl(string url, string postData)
        {
            byte[] data = Encoding.UTF8.GetBytes(postData);

            // 设置参数
            HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
            CookieContainer cookieContainer = new CookieContainer();
            request.Timeout = 600000;
            request.CookieContainer = cookieContainer;
            request.AllowAutoRedirect = true;
            request.Method = "POST";
            request.ContentType = "application/x-www-form-urlencoded";
            request.ContentLength = data.Length;
            Stream outstream = request.GetRequestStream();
            outstream.Write(data, 0, data.Length);
            outstream.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;
        }
        #endregion
        #endregion

        #region Http下载文件
        /// <summary>
        /// Http下载文件
        /// </summary>
        public static string HttpDownloadFile(string url, string path)
        {
            // 设置参数
            HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
            request.Timeout = 600000;
            //发送请求并获取相应回应数据
            HttpWebResponse response = request.GetResponse() as HttpWebResponse;
            //直到request.GetResponse()程序才开始向目标网页发送Post请求
            Stream responseStream = response.GetResponseStream();

            //创建本地文件写入流

            Stream stream = new FileStream(path, FileMode.Create);

            byte[] bArr = new byte[1024];
            int size = responseStream.Read(bArr, 0, (int)bArr.Length);
            while (size > 0)
            {
                stream.Write(bArr, 0, size);
                size = responseStream.Read(bArr, 0, (int)bArr.Length);
            }
            stream.Close();
            responseStream.Close();
            return path;
        }
        #endregion

        #region Http上传文件
        /// <summary>
        /// Http上传文件
        /// </summary>
        public static string HttpUploadFile(string url, string path)
        {
            // 设置参数
            HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
            request.Timeout = 600000;
            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("
--" + boundary + "
");
            byte[] endBoundaryBytes = Encoding.UTF8.GetBytes("
--" + boundary + "--
");

            int pos = path.LastIndexOf("\");
            string fileName = path.Substring(pos + 1);

            //请求头部信息 
            StringBuilder sbHeader = new StringBuilder(string.Format("Content-Disposition:form-data;name="file";filename="{0}"
Content-Type:application/octet-stream

", 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;
        }
        #endregion

    }
}

using System;
using System.Collections.Generic;
using System.Web.Security;
using System.Text;
using System.IO;
using System.Net;
using System.Xml;
using System.Data;
using System.Collections;
using Newtonsoft.Json;
using TWays.Core.DBAccess;

namespace Nany.Web.Trans
{
    public class WeixinManager
    {
        #region 公共方法

        /// <summary>
        /// 记录日志
        /// </summary>
        /// <param name="strMsg"></param>
        private void Logger(string strMsg)
        {
            string strFilePath = System.Windows.Forms.Application.StartupPath + "\" + StaticConst.WxSendLog;
            TWays.Core.Loger.LogMessage(strFilePath, strMsg, true);
        }

        private DataSet GetValue(string type)
        {
            DataSet dr = DataAdapter.Query(string.Format(SqlText.selectGetReprotTypeValue.ToUpper(),type));

            return dr;
        }

        #endregion

        #region 获取配置信息


        /// <summary>
        /// 获取报表
        /// </summary>
        /// <returns></returns>
        public string GetReprotName(string type)
        {
            DataSet ds = GetValue(type);
            if (ds.Tables[0].Rows.Count < 0) return null;

            return TWays.Utils.ToString(ds.Tables[0].Rows[0]["DIC_NAME"]);
        }

        /// <summary>
        /// 获取APP_ID
        /// </summary>
        /// <returns></returns>
        public string GetWeixinAppId(string type)
        {
            //return GetConfigValue(StaticConst.WX_APP_ID);
            DataSet ds = GetValue(type);
            if (ds.Tables[0].Rows.Count < 0) return null;

            return TWays.Utils.ToString(ds.Tables[0].Rows[0]["APP_ID"]);
        }

        /// <summary>
        /// 获取APP_SECRET
        /// </summary>
        /// <returns></returns>
        public string GetWeixinAppSecret(string type)
        {
            //return GetConfigValue(StaticConst.WX_APP_SECRET); 在.config中获取配置信息
            DataSet ds = GetValue(type);
            if (ds.Tables[0].Rows.Count < 0) return null;

            return TWays.Utils.ToString(ds.Tables[0].Rows[0]["APP_SECRT"]);
        }

        /// <summary>
        /// 获取企业号CorpId
        /// </summary>
        /// <returns></returns>
        public string GetWeixinQyCorpId(string type)
        {
            //return GetConfigValue(StaticConst.WX_QY_CORP_ID);
            DataSet ds = GetValue(type);
            if (ds.Tables[0].Rows.Count < 0) return null;

            return TWays.Utils.ToString(ds.Tables[0].Rows[0]["CORP_ID"]);
        }

       


        /// <summary>
        /// 获取配置信息
        /// </summary>
        /// <param name="strKey"></param>
        /// <returns></returns>
        public string GetConfigValue(string strKey)
        {
            string strKeyValue = string.Empty;

            strKeyValue = TWays.Utils.ToString(System.Configuration.ConfigurationManager.AppSettings[strKey]);

            return strKeyValue;
        }

        /// <summary>
        /// 获取各报表的上传图片路径
        /// </summary>
        /// <param name="strReprot"></param>
        /// <returns></returns>
        public string GetWeixinMediaPath(string strReprot)
        {
            string strAgentId = System.Windows.Forms.Application.StartupPath + "\Logo\";

            string strPicName = "Null.jpg";

            strAgentId += strPicName;
            return strAgentId;
        }
        
        #endregion

        #region 获取POST消息

        /// <summary>
        /// 获取post返回来的数据
        /// </summary>
        /// <returns></returns>
        public static string PostInput()
        {
            Stream s = System.Web.HttpContext.Current.Request.InputStream;
            byte[] b = new byte[s.Length];
            s.Read(b, 0, (int)s.Length);
            return Encoding.UTF8.GetString(b);
        }

        #endregion

        #region 获取企业号AccessToken

        public string GetQyAccessToken(string type)
        {
            string QY_CorpID = this.GetWeixinQyCorpId(type);
            string QY_AppSecret = this.GetWeixinAppSecret(type);

            string url = string.Format("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={0}&corpsecret={1}", QY_CorpID, QY_AppSecret);
            return ToAccessTokenJson(HttpRequestUtil.GetAppPage(url, 5000, Encoding.UTF8));
        }

        public string ToAccessTokenJson(string val)
        {
            AccessToken deserializedToken = (AccessToken)JavaScriptConvert.DeserializeObject(val, typeof(AccessToken));
            return deserializedToken.access_token;
        }

        #endregion

        #region 获取MediaId

        public string GetQyMediaId(string strReprot)
        {
            string QY_MediaId = string.Empty;

            string strAccessToken = this.GetQyAccessToken(strReprot);

            string url = string.Format("https://qyapi.weixin.qq.com/cgi-bin/media/upload?access_token={0}&type=image", strAccessToken);

            string postData = GetWeixinMediaPath(strReprot);

            QY_MediaId = ToAccessMediaId(HttpRequestUtil.HttpPosturl(postData, url));

            return QY_MediaId;
        }
        public string ToAccessMediaId(string val)
        {
            ThumbMedia deserializedMediaId = (ThumbMedia)JavaScriptConvert.DeserializeObject(val, typeof(ThumbMedia));
            return deserializedMediaId.media_id;
        }
        #endregion

    }

}

using System;
using System.Collections.Generic;
using System.Data;
using System.Web;
using TWays.Data;
using TWays.Core;
using TWays.Core.DBAccess;
using TWays.Core.Exceptions;
using TWays;
using System.Text;


namespace Nany.Web.Trans
{
    /// <summary>
    ///  传输日销售数据
    /// </summary>
    public class TransSaleSumInfo : ITransTask
    {

        public TransSaleSumInfo()
        {
            _Result = "";
        }

        private string _Result;    // 结果消息
        public string Result
        {
            get
            {
                return _Result;
            }
            set
            {
                _Result = value;
            }
        }

        public bool Process()
        {
            bool boolReturn = false;

            try
            {
                string strUserId = string.Empty;
                string sysDate = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd");
                string week = DateTime.Now.AddDays(-1).ToString("dddd");//周几

                DataSet dsUser = DataAdapter.Query(string.Format(SqlText.selectCanSheetUserId.ToUpper(), Constant.CST_SHEET_TYPE_SALE_SUM));
                if (dsUser == null || dsUser.Tables[0].Rows.Count <= 0)
                {
                    Result = "没有需要发送的人员";
                    return false;
                }

                for (int i = 0; i < dsUser.Tables[0].Rows.Count; i++)
                {
                    DataRow dr = dsUser.Tables[0].Rows[i];

                    DataSet dsSaleInfo = DataAdapter.Query(string.Format(SqlText.selectSaleSumReprot.ToUpper(), sysDate, TWays.Utils.ToString(dr["STAFF_CODE"])));
                    string posData = string.Empty;

                    if (dsSaleInfo != null && dsSaleInfo.Tables[0].Rows.Count > 0)
                    {
                        decimal ysAmt = 0;
                        decimal ssAmt = 0;
                        decimal yhAmt = 0;
                        decimal countOrg = 0;
                        decimal countCust = 0;//客单数
                        decimal price = 0;//客单价
                        decimal custPrice = 0;//平均客单价

                        for (int t = 0; t < dsSaleInfo.Tables[0].Rows.Count; t++)
                        {
                            DataRow drSale = dsSaleInfo.Tables[0].Rows[t];
                            ysAmt += TWays.Utils.ToDecimal(drSale["YS_AMT"]);
                            ssAmt += TWays.Utils.ToDecimal(drSale["SS_AMT"]);
                            yhAmt += TWays.Utils.ToDecimal(drSale["YH_AMT"]);
                            countOrg = TWays.Utils.ToDecimal(dsSaleInfo.Tables[0].Rows[0]["ROWNUM"]);
                            price += TWays.Utils.ToDecimal(drSale["COUNT_AMT"]);
                            countCust += TWays.Utils.ToDecimal(drSale["COUNT"]);
                        }

                        if (price == 0 || countCust == 0)
                        {
                            custPrice = 0;
                        }
                        else
                        {
                            custPrice = price / countCust;
                        }

                        #region 拼接消息内容
                        posData += "<p>日期：[" + sysDate + "](" + week + ")";

                        posData += "<br>1.总店铺数：" + TWays.Utils.ToString(countOrg);
                        posData += "<br>2.应收金额：" + ysAmt.ToString("f2");
                        posData += "<br>3.实收金额：" + ssAmt.ToString("f2");
                        posData += "<br>4.优惠金额：" + yhAmt.ToString("f2");
                        posData += "<br>5.客单量：&nbsp;" + TWays.Utils.ToString(countCust);
                        posData += "<br>6.客单价：&nbsp;" + custPrice.ToString("f2");
                        posData += "</p><br>";
                        #endregion
                    }
                    else
                    {
                        #region 拼接消息内容
                        posData += "<p>日期：[" + sysDate + "](" + week + ")";

                        posData += "<br>1.总店铺数：暂无数据";
                        posData += "<br>2.应收金额：暂无数据";
                        posData += "<br>3.实收金额：暂无数据";
                        posData += "<br>4.优惠金额：暂无数据";
                        posData += "<br>5.客单量：&nbsp;&nbsp;暂无数据";
                        posData += "<br>6.客单价：&nbsp;&nbsp;暂无数据";
                        posData += "</p><br>";
                        #endregion

                    }

                    WeixinManager weiXin = new WeixinManager();

                    string strPostTitle = weiXin.GetReprotName(Constant.CST_SHEET_TYPE_SALE_SUM) + "[" + sysDate + "]";
                    string strPostDesc = "[" + sysDate + "](" + week + ")";

                    string access_token = weiXin.GetQyAccessToken(Constant.CST_SHEET_TYPE_SALE_SUM);
                    string strResult = string.Empty;

                    System.Text.StringBuilder strSendMsg = new StringBuilder();
                    strSendMsg.Append("{"touser": "" + dr["STAFF_CODE"].ToString() + "",");
                    strSendMsg.Append(""toparty": "@all",");
                    strSendMsg.Append(""totag":"@all",");
                    strSendMsg.Append(""msgtype": "mpnews",");
                    strSendMsg.Append(""agentid": "" + weiXin.GetWeixinAppId(Constant.CST_SHEET_TYPE_SALE_SUM) + "",");

                    strSendMsg.Append(""mpnews": {"articles":[{");
                    strSendMsg.Append(""title": "" + strPostTitle + "",");   //标题
                    strSendMsg.Append(""thumb_media_id": "" + weiXin.GetQyMediaId(Constant.CST_SHEET_TYPE_SALE_SUM) + "",");   //MeidaId
                    strSendMsg.Append(""author": "",");   //作者


                    // strSendMsg.Append(""content_source_url": "http://www.lenle.com/weixin/MsgContent.aspx?MASTER_ID=" + strMasterId + "",");  //阅读全文的链接


                    strSendMsg.Append(""content": "" + posData + "",");    //图文内容
                    strSendMsg.Append(""digest": "" + strPostDesc + "",");  //图文消息描述
                    strSendMsg.Append(""show_cover_pic": "0"");

                    strSendMsg.Append("}]},"safe":"1"}");

                    strResult = HttpRequestUtil.PostUrl(string.Format("https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={0}", access_token), strSendMsg.ToString());

                    int isSend = 0;
                    if (strResult.Contains(""errmsg":"ok""))
                    {
                        Result = "success";
                        boolReturn = true;
                        isSend = 1;
                    }
                    else
                    {
                        Result = "no records!";
                        boolReturn = true;
                    }

                    //新增微信推送消息内容表
                    //string s = string.Format(SqlText.insertWeiXinDayReprotContent.ToUpper(),
                    //    dr["STAFF_ID"].ToString(), sysDate, week, isSend), new object[] { Encoding.UTF8.GetBytes(posData) };
                    DataAdapter.Execute(string.Format(SqlText.insertWeiXinDayReprotContent.ToUpper(),
                        dr["STAFF_ID"].ToString(), sysDate, week, isSend), new object[] { Encoding.UTF8.GetBytes(posData) });

                    strSendMsg = null;
                }

            }
            catch (Exception ex)
            {
                Result = ex.Message;
            }

            return boolReturn;
        }

        public void Dispose()
        {
            GC.SuppressFinalize(this);
        }
    }
}