16 changed files with 510 additions and 44 deletions
Split View
Diff Options
-
+51 -19B3WeChat.Web/B3WeChat.Web.csproj
-
+38 -0B3WeChat.Web/Pages/WeiChatLogin.cs
-
+4 -0B3WeChat.Web/PluginClass.cs
-
+55 -20B3WeChat/B3WeChat.csproj
-
+11 -0B3WeChat/B3WeChatConsts.cs
-
+44 -0B3WeChat/BL/IApproveMessageBL.cs
-
+44 -0B3WeChat/BL/ICustomerUserBL.cs
-
+52 -0B3WeChat/BO/ApproveMessage.cs
-
+20 -5B3WeChat/BO/CustomerUser.cs
-
+19 -0B3WeChat/BO/NamedValueTemplate.cs
-
+54 -0B3WeChat/Rpcs/ApproveMessageRpc.cs
-
+1 -0B3WeChat/Rpcs/ClientRpc.cs
-
+41 -0B3WeChat/Utils/WeChatPageUtil.cs
-
+22 -0B3WeChat/WeiChatObjs/AuthorizationCodeResponse.cs
-
+44 -0B3WeChat/WeiChatObjs/BaseResponse.cs
-
+10 -0WebFolder/config/NamedValue/B3WeChat.xml
+ 51
- 19
B3WeChat.Web/B3WeChat.Web.csproj
View File
+ 38
- 0
B3WeChat.Web/Pages/WeiChatLogin.cs
View File
| @ -0,0 +1,38 @@ | |||
| using Bwp.MainSystem; | |||
| using BWP.B3WeChat.Utils; | |||
| using Forks.EnterpriseServices.BusinessInterfaces; | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| using System.Web; | |||
| using TSingSoft.WebPluginFramework; | |||
| namespace BWP.Web.Pages | |||
| { | |||
| class WeiChatLogin:IHttpHandler | |||
| { | |||
| public bool IsReusable | |||
| { | |||
| get { return true; } | |||
| } | |||
| public void ProcessRequest(HttpContext context) | |||
| { | |||
| var code = context.Request.QueryString["code"]; | |||
| var openID = WeChatPageUtil.QueryOpenID(code); | |||
| var userBL = BIFactory.Create<IUserBL>(); | |||
| var user = userBL.Get(openID); | |||
| if (user == null) | |||
| { | |||
| throw new Exception("当前微信公众号用户还没有在系统中注册"); | |||
| } | |||
| var url = context.Request.QueryString["url"]; | |||
| context.Response.Redirect(url); | |||
| } | |||
| } | |||
| } | |||
+ 4
- 0
B3WeChat.Web/PluginClass.cs
View File
+ 55
- 20
B3WeChat/B3WeChat.csproj
View File
+ 11
- 0
B3WeChat/B3WeChatConsts.cs
View File
| @ -0,0 +1,11 @@ | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| namespace BWP.B3WeChat | |||
| { | |||
| public static class B3WeChatConsts | |||
| { | |||
| } | |||
| } | |||
+ 44
- 0
B3WeChat/BL/IApproveMessageBL.cs
View File
| @ -0,0 +1,44 @@ | |||
| using BWP.B3WeChat.BO; | |||
| using Forks.EnterpriseServices.BusinessInterfaces; | |||
| using Forks.EnterpriseServices.DomainObjects2.DQuery; | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| namespace BWP.B3WeChat.BL | |||
| { | |||
| [BusinessInterface(typeof(ApproveMessageBL))] | |||
| public interface IApproveMessageBL | |||
| { | |||
| void Insert(ApproveMessage message); | |||
| void Delete(string messageID); | |||
| } | |||
| public class ApproveMessageBL : BusinessClass, IApproveMessageBL | |||
| { | |||
| static Lazy<IApproveMessageBL> mInstance = new Lazy<IApproveMessageBL>(() => BIFactory.Create<IApproveMessageBL>()); | |||
| public static IApproveMessageBL Instance | |||
| { | |||
| get | |||
| { | |||
| return mInstance.Value; | |||
| } | |||
| } | |||
| public void Insert(ApproveMessage message) | |||
| { | |||
| Session.Insert(message); | |||
| } | |||
| public void Delete(string messageID) | |||
| { | |||
| var del = new DQDeleteDom(typeof(ApproveMessage)); | |||
| del.Where.Conditions.Add(DQCondition.EQ("ID", messageID)); | |||
| Session.ExecuteNonQuery(del); | |||
| } | |||
| } | |||
| } | |||
+ 44
- 0
B3WeChat/BL/ICustomerUserBL.cs
View File
| @ -0,0 +1,44 @@ | |||
| using BWP.B3WeChat.BO; | |||
| using Forks.EnterpriseServices.BusinessInterfaces; | |||
| using Forks.EnterpriseServices.DomainObjects2.DQuery; | |||
| using Forks.Utils; | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| using TSingSoft.WebPluginFramework; | |||
| namespace BWP.B3WeChat.BL | |||
| { | |||
| [BusinessInterface(typeof(CustomerUserBL))] | |||
| public interface ICustomerUserBL | |||
| { | |||
| [Log(Disabled=true)] | |||
| void Follow(string customerCode, string username, string openID); | |||
| } | |||
| public class CustomerUserBL : BusinessClass, ICustomerUserBL | |||
| { | |||
| public void Follow(string customerCode, string customerUsername, string openID) | |||
| { | |||
| var del = new DQDeleteDom(typeof(CustomerUser)); | |||
| del.Where.Conditions.Add(DQCondition.EQ("CustomerCode", customerCode)); | |||
| del.Where.Conditions.Add(DQCondition.EQ("CustomerUsername", customerUsername)); | |||
| var customerUser = new CustomerUser() | |||
| { | |||
| CustomerCode = customerCode, | |||
| CustomerUsername = customerUsername, | |||
| OpenID = openID | |||
| }; | |||
| Session.Insert(customerUser); | |||
| var userBL = BIFactory.Create<IUserBL>(this); | |||
| if (userBL.Exist(openID)) | |||
| { | |||
| userBL.Create(openID, StringUtil.CreateRandomString(30), "wechat", customerCode + "/" + customerUsername); | |||
| } | |||
| } | |||
| } | |||
| } | |||
+ 52
- 0
B3WeChat/BO/ApproveMessage.cs
View File
| @ -0,0 +1,52 @@ | |||
| using BWP.B3WeChat.BO.NamedValueTemplate; | |||
| using Forks.EnterpriseServices; | |||
| using Forks.EnterpriseServices.DataForm; | |||
| using Forks.EnterpriseServices.DomainObjects2; | |||
| using Forks.Utils; | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| using TSingSoft.WebPluginFramework; | |||
| namespace BWP.B3WeChat.BO | |||
| { | |||
| [LogicName("审批消息")] | |||
| [BOClass,DFClass] | |||
| [KeyField("ID",KeyGenType.assigned)] | |||
| public class ApproveMessage | |||
| { | |||
| /// <summary> | |||
| /// 消息ID,由客户端提交 | |||
| /// </summary> | |||
| [DbColumn(AllowNull=false)] | |||
| public string ID { get; set; } | |||
| [LogicName("客户号")] | |||
| [DbColumn(AllowNull=false)] | |||
| public string CustomerCode { get; set; } | |||
| /// <summary> | |||
| /// 客户端用户名 | |||
| /// </summary> | |||
| [LogicName("用户名")] | |||
| [DbColumn(AllowNull=false)] | |||
| public string Username { get; set; } | |||
| [DbColumn(Length=255)] | |||
| [LogicName("标题")] | |||
| public string Title { get; set; } | |||
| [DbColumn(Length=4000)] | |||
| [LogicName("正文")] | |||
| public string Content { get; set; } | |||
| [LogicName("审批结果")] | |||
| public NamedValue<审批状态> ApproveResult { get; set; } | |||
| [LogicName("审批意见")] | |||
| public string ApproveComment { get; set; } | |||
| } | |||
| } | |||
+ 20
- 5
B3WeChat/BO/CustomerUser.cs
View File
| @ -1,15 +1,30 @@ | |||
| using System; | |||
| using Forks.EnterpriseServices; | |||
| using Forks.EnterpriseServices.DomainObjects2; | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| namespace BWP.B3WeChat.BO | |||
| { | |||
| class CustomerUser | |||
| [LogicName("微信用户")] | |||
| [KeyField("CustomerCode", KeyGenType.assigned)] | |||
| [KeyField("CustomerUsername", KeyGenType.assigned)] | |||
| public class CustomerUser | |||
| { | |||
| public string CustomerNumber { get; set; } | |||
| public string Username { get; set; } | |||
| //加密后的微信号，同一个微信号在不同的公众号有不同的OpenID | |||
| //可能存在一个微信号在多个客户里关注的情况，另外同一个客户也可能和不同的用户名绑定 | |||
| [DbColumn(AllowNull=false)] | |||
| public string OpenID { get; set; } | |||
| [LogicName("客户编码")] | |||
| [DbColumn(AllowNull=false)] | |||
| public string CustomerCode { get;set; } | |||
| [LogicName("客户用户名")] | |||
| [DbColumn(AllowNull=false)] | |||
| public string CustomerUsername { get; set; } | |||
| public string WeixinUsername { get; set; } | |||
| } | |||
| } | |||
+ 19
- 0
B3WeChat/BO/NamedValueTemplate.cs
View File
| @ -0,0 +1,19 @@ | |||
| using Forks.Utils; | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| namespace BWP.B3WeChat.BO.NamedValueTemplate | |||
| { | |||
| public sealed class 审批状态 | |||
| { | |||
| public static NamedValue<审批状态> 待审批 = new NamedValue<审批状态>(0); | |||
| public static NamedValue<审批状态> 已审批 = new NamedValue<审批状态>(10); | |||
| public static NamedValue<审批状态> 已退回 = new NamedValue<审批状态>(20); | |||
| /// <summary> | |||
| /// 审批消息本身没有已删除状态，只用来查询消息状态用 | |||
| /// </summary> | |||
| public static NamedValue<审批状态> 已删除 = new NamedValue<审批状态>(30); | |||
| } | |||
| } | |||
+ 54
- 0
B3WeChat/Rpcs/ApproveMessageRpc.cs
View File
| @ -0,0 +1,54 @@ | |||
| using BWP.B3WeChat.BL; | |||
| using BWP.B3WeChat.BO; | |||
| using BWP.B3WeChat.BO.NamedValueTemplate; | |||
| using Forks.EnterpriseServices.BusinessInterfaces; | |||
| using Forks.EnterpriseServices.DomainObjects2; | |||
| using Forks.EnterpriseServices.DomainObjects2.DQuery; | |||
| using Forks.EnterpriseServices.JsonRpc; | |||
| using Forks.EnterpriseServices.SqlDoms; | |||
| using Forks.Utils; | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| using TSingSoft.WebPluginFramework; | |||
| namespace BWP.B3WeChat.Rpcs | |||
| { | |||
| [Rpc] | |||
| public static class ApproveMessageRpc | |||
| { | |||
| static IApproveMessageBL bl = BIFactory.Create<IApproveMessageBL>(); | |||
| [Rpc] | |||
| public static void Insert(ApproveMessage message) | |||
| { | |||
| ApproveMessageBL.Instance.Insert(message); | |||
| } | |||
| /// <summary> | |||
| /// 返回消息状态 | |||
| /// </summary> | |||
| /// <param name="messageID"></param> | |||
| /// <returns></returns> | |||
| [Rpc] | |||
| public static short QueryMessageState(string messageID) | |||
| { | |||
| var query = new DQueryDom(new JoinAlias(typeof(ApproveMessage))); | |||
| query.Where.Conditions.Add(DQCondition.EQ("ID", messageID)); | |||
| query.Columns.Add(DQSelectColumn.Field("ApproveResult")); | |||
| query.Range = SelectRange.Top(1); | |||
| var state = query.EExecuteScalar<NamedValue<审批状态>?>() ?? 审批状态.已删除; | |||
| return state.Value; | |||
| } | |||
| [Rpc] | |||
| public static void Delete(string messageID) | |||
| { | |||
| bl.Delete(messageID); | |||
| } | |||
| } | |||
| } | |||
+ 1
- 0
B3WeChat/Rpcs/ClientRpc.cs
View File
+ 41
- 0
B3WeChat/Utils/WeChatPageUtil.cs
View File
| @ -0,0 +1,41 @@ | |||
| using BWP.B3WeChat.WeiChatObjs; | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Net; | |||
| using System.Text; | |||
| using System.Web; | |||
| using System.Web.Script.Serialization; | |||
| namespace BWP.B3WeChat.Utils | |||
| { | |||
| public static class WeChatPageUtil | |||
| { | |||
| const string template = "https://open.weixin.qq.com/connect/oauth2/authorize?appid={APPID}&redirect_uri={REDIRECT_URI}&response_type=code&scope=snsapi_base&state={STAT}&connect_redirect=1#wechat_redirect"; | |||
| public static string GetWeChatUrl(string url,string state="1") | |||
| { | |||
| var config = new B3WeChatConfig(); | |||
| var result = template.Replace("{APPID}", config.AppID) | |||
| .Replace("{REDIRECT_URI}", HttpUtility.UrlEncode(url)) | |||
| .Replace("{STATE}", state); | |||
| return result; | |||
| } | |||
| const string getAccessTokenTemplate = "https://api.weixin.qq.com/sns/oauth2/access_token?appid={APPID}&secret={SECRET}&code={CODE}&grant_type=authorization_code"; | |||
| public static string QueryOpenID(string code) | |||
| { | |||
| var config = new B3WeChatConfig(); | |||
| var url = getAccessTokenTemplate.Replace("{APPID", config.AppID) | |||
| .Replace("{SECRET}", config.AppSecret) | |||
| .Replace("{CODE}", code); | |||
| var json = new WebClient() { Encoding = Encoding.UTF8 }.DownloadString(url); | |||
| var response = AuthorizationCodeResponse.Parse(json); | |||
| return response.openid; | |||
| } | |||
| } | |||
| } | |||
+ 22
- 0
B3WeChat/WeiChatObjs/AuthorizationCodeResponse.cs
View File
| @ -0,0 +1,22 @@ | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| namespace BWP.B3WeChat.WeiChatObjs | |||
| { | |||
| //http://mp.weixin.qq.com/wiki/4/9ac2e7b1f1d22e9e57260f6553822520.html | |||
| public class AuthorizationCodeResponse : BaseResponse<AuthorizationCodeResponse> | |||
| { | |||
| public string access_token { get; set; } | |||
| public int expires_in { get; set; } | |||
| public string refresh_token { get; set; } | |||
| public string openid { get; set; } | |||
| public string scope { get; set; } | |||
| } | |||
| } | |||
+ 44
- 0
B3WeChat/WeiChatObjs/BaseResponse.cs
View File
| @ -0,0 +1,44 @@ | |||
| using System; | |||
| using System.Collections.Generic; | |||
| using System.Linq; | |||
| using System.Text; | |||
| using System.Web.Script.Serialization; | |||
| namespace BWP.B3WeChat.WeiChatObjs | |||
| { | |||
| public class BaseResponse<T> : BaseResponse where T : BaseResponse | |||
| { | |||
| public static T Parse(string jsonr) | |||
| { | |||
| var result = new JavaScriptSerializer().Deserialize<T>(jsonr); | |||
| result.CheckError(); | |||
| return result; | |||
| } | |||
| } | |||
| public class BaseResponse | |||
| { | |||
| public int errcode { get; set; } | |||
| public string errmsg { get; set; } | |||
| public bool IsError | |||
| { | |||
| get | |||
| { | |||
| return errcode > 0; | |||
| } | |||
| } | |||
| public void CheckError() | |||
| { | |||
| if (errcode > 0) | |||
| { | |||
| throw new Exception(string.Format("{0} {1} {2}", this.GetType().Name, errcode, errmsg)); | |||
| } | |||
| } | |||
| } | |||
| } | |||
+ 10
- 0
WebFolder/config/NamedValue/B3WeChat.xml
View File
| @ -0,0 +1,10 @@ | |||
| <?xml version="1.0" encoding="utf-8" ?> | |||
| <NamedValueSettings> | |||
| <NamedValue type="BWP.B3WeChat.BO.NamedValueTemplate.审批状态, B3WeChat"> | |||
| <Word name="待审批" value="0"/> | |||
| <Word name="已审批" value="10"/> | |||
| <Word name="已退回" value="20"/> | |||
| <Word name="已删除" value="30"/> | |||
| </NamedValue> | |||
| </NamedValueSettings> | |||