diff --git a/B3WeChat.Web/Pages/WeChatReceive.cs b/B3WeChat.Web/Pages/WeChatReceive.cs index 099ad2a..7e4cbc5 100644 --- a/B3WeChat.Web/Pages/WeChatReceive.cs +++ b/B3WeChat.Web/Pages/WeChatReceive.cs @@ -18,7 +18,7 @@ namespace BWP.Web.Pages { class WeChatReceive : IHttpHandler { - static Forks.Utils.Logger logger = new Forks.Utils.Logger("InOutMessageUtil"); + static Forks.Utils.Logger mLogger = new Forks.Utils.Logger("WeChatReceive"); string echoStr { get @@ -73,19 +73,21 @@ namespace BWP.Web.Pages else if (result is QRCodeMessage) { QRCodeMessage msg = result as QRCodeMessage; - logger.Info("EventKey:" + msg.EventKey + ",FromUserName:" + msg.FromUserName); - UpdateQRCode(msg.EventKey, msg.FromUserName); - logger.Info("关联成功"); + var query = new DmoQuery(typeof(QRCode)); + query.Where.Conditions.Add(DQCondition.EQ("ID", msg.EventKey)); + query.Range = SelectRange.Top(1); + var scene = query.EExecuteScalar(); + + try + { + CustomerUserBL.Instance.Follow(scene.Customer, scene.UserId, msg.FromUserName); + } + catch (Exception ex) + { + mLogger.Error(ex.ToString()); + } } } - static void UpdateQRCode(string sceneId, string OppenId) - { - var query = new DmoQuery(typeof(QRCode)); - query.Where.Conditions.Add(DQCondition.EQ("ID", sceneId)); - query.Range = SelectRange.Top(1); - var scene = query.EExecuteScalar(); - CustomerUserBL.Instance.Follow(scene.Customer, scene.UserId, OppenId); - } } } diff --git a/B3WeChat/BL/ICustomerUserBL.cs b/B3WeChat/BL/ICustomerUserBL.cs index 666b836..eefa4de 100644 --- a/B3WeChat/BL/ICustomerUserBL.cs +++ b/B3WeChat/BL/ICustomerUserBL.cs @@ -39,7 +39,7 @@ namespace BWP.B3WeChat.BL public void Follow(string customerCode, string customerUsername, string openID) { - var user = InnerBLUtil.GetSingleDmo(Session, new Tuple("CustomerCode", "customerCode"), + var user = InnerBLUtil.GetSingleDmo(Session, new Tuple("CustomerCode", customerCode), new Tuple("CustomerUsername", customerUsername)); if (user != null) @@ -51,7 +51,7 @@ new Tuple("CustomerUsername", customerUsername)); Session.Update(user); var update = new DQUpdateDom(typeof(ApproveMessage)); update.Where.Conditions.Add(DQCondition.EQ("CustomerCode", user.CustomerCode)); - update.Where.Conditions.Add(DQCondition.EQ("CustomerUsername", user.CustomerUsername)); + update.Where.Conditions.Add(DQCondition.EQ("Username", user.CustomerUsername)); update.Columns.Add(new DQUpdateColumn("OpenID", openID)); Session.ExecuteNonQuery(update); diff --git a/B3WeChat/Utils/SendMessageUtil.cs b/B3WeChat/Utils/SendMessageUtil.cs index 545eca5..a423a6d 100644 --- a/B3WeChat/Utils/SendMessageUtil.cs +++ b/B3WeChat/Utils/SendMessageUtil.cs @@ -84,7 +84,7 @@ namespace BWP.B3WeChat.Utils } -//模板:IDQp53p4jHyk9vxXiLs0VRUN_5HHwmjeWPT-7XLwG2FkU +//模板ID:Qp53p4jHyk9vxXiLs0VRUN_5HHwmjeWPT-7XLwG2FkU //标题:绑定通知 //详细内容 //{{first.DATA}} @@ -99,6 +99,7 @@ namespace BWP.B3WeChat.Utils dict.Add("keyword1", new ValueColor(username)); dict.Add("keyword2", new ValueColor(FormatTime(BLContext.Now))); dict.Add("remark", new ValueColor("若不是你本人操作,请与管理员联系")); + InOutMessageUtil.SendTemplateMessage(openID, "Qp53p4jHyk9vxXiLs0VRUN_5HHwmjeWPT-7XLwG2FkU", dict); } } }