Browse Source

用户绑定的微信号被覆盖时给原来的微信号发消息

master
yashen 9 years ago
parent
commit
4e35514510
3 changed files with 18 additions and 15 deletions
  1. +14
    -12
      B3WeChat.Web/Pages/WeChatReceive.cs
  2. +2
    -2
      B3WeChat/BL/ICustomerUserBL.cs
  3. +2
    -1
      B3WeChat/Utils/SendMessageUtil.cs

+ 14
- 12
B3WeChat.Web/Pages/WeChatReceive.cs View File

@ -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<QRCode>();
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<QRCode>();
CustomerUserBL.Instance.Follow(scene.Customer, scene.UserId, OppenId);
}
}
}

+ 2
- 2
B3WeChat/BL/ICustomerUserBL.cs View File

@ -39,7 +39,7 @@ namespace BWP.B3WeChat.BL
public void Follow(string customerCode, string customerUsername, string openID)
{
var user = InnerBLUtil.GetSingleDmo<CustomerUser>(Session, new Tuple<string, object>("CustomerCode", "customerCode"),
var user = InnerBLUtil.GetSingleDmo<CustomerUser>(Session, new Tuple<string, object>("CustomerCode", customerCode),
new Tuple<string, object>("CustomerUsername", customerUsername));
if (user != null)
@ -51,7 +51,7 @@ new Tuple<string, object>("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);


+ 2
- 1
B3WeChat/Utils/SendMessageUtil.cs View File

@ -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);
}
}
}

Loading…
Cancel
Save