From 1587055ebbe92287a9912d36d17f5e0590c4f530 Mon Sep 17 00:00:00 2001
From: yashen <yashen@gmail.com>
Date: Thu, 22 Sep 2016 17:33:07 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=B3=E6=B3=A8=E5=BE=AE=E4=BF=A1=E6=97=B6?=
 =?UTF-8?q?=E6=9B=B4=E6=96=B0CustomerUser?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 B3WeChat.Web/Pages/WeChatReceive.cs | 35 +++++++++++++++++++++++------
 1 file changed, 28 insertions(+), 7 deletions(-)

diff --git a/B3WeChat.Web/Pages/WeChatReceive.cs b/B3WeChat.Web/Pages/WeChatReceive.cs
index 326412c..2f1b68e 100644
--- a/B3WeChat.Web/Pages/WeChatReceive.cs
+++ b/B3WeChat.Web/Pages/WeChatReceive.cs
@@ -1,13 +1,16 @@
 using BWP.B3WeChat.BO;
 using BWP.B3WeChat.Entities;
 using BWP.B3WeChat.Utils;
+using Forks.EnterpriseServices.BusinessInterfaces;
 using Forks.EnterpriseServices.DomainObjects2;
 using Forks.EnterpriseServices.DomainObjects2.DQuery;
+using Forks.EnterpriseServices.SqlDoms;
 using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Web;
+using TSingSoft.WebPluginFramework;
 
 namespace BWP.Web.Pages
 {
@@ -75,15 +78,33 @@ namespace BWP.Web.Pages
     }
     static void UpdateQRCode(string sceneId, string OppenId)
     {
-      var update = new DQUpdateDom(typeof(QRCode));
-      logger.Info("sceneId:" + sceneId + ",OppenId" + OppenId);
-      update.Where.Conditions.Add(DQCondition.EQ("ID", sceneId));
-      update.Columns.Add(new DQUpdateColumn("OppenId", OppenId));
-      using (var session = Dmo.NewSession())
+
+      var query = new DmoQuery(typeof(QRCode));
+      query.Where.Conditions.Add(DQCondition.EQ("ID", sceneId));
+      query.Range = SelectRange.Top(1);
+      var scene = query.EExecuteScalar<QRCode>();
+
+      var user = new CustomerUser();
+      user.CustomerCode = scene.Customer;
+      user.CustomerUsername = scene.UserId;
+      user.OpenID = OppenId;
+
+      using (var context = new TransactionContext())
       {
-        session.ExecuteNonQuery(update);
-        session.Commit();
+        context.Session.AddInsertOrUpdate(user);
+        context.Commit();
       }
+
+
+      //var update = new DQUpdateDom(typeof(QRCode));
+      //logger.Info("sceneId:" + sceneId + ",OppenId" + OppenId);
+      //update.Where.Conditions.Add(DQCondition.EQ("ID", sceneId));
+      //update.Columns.Add(new DQUpdateColumn("OppenId", OppenId));
+      //using (var session = Dmo.NewSession())
+      //{
+      //  session.ExecuteNonQuery(update);
+      //  session.Commit();
+      //}
     }
 
   }