浏览代码

Async Break

Narmada 2 年前
父节点
当前提交
73e8dbe2c6

+ 4
- 4
CRM.Visitors/ActionProviders/FeedBackPostActionProvider.cs 查看文件

80
                 var req = obj1 as IDictionary<string, object>;
80
                 var req = obj1 as IDictionary<string, object>;
81
                 var code = Convert.ChangeType(req["uniqueid"].ToString(), typeof(object)).ToString();
81
                 var code = Convert.ChangeType(req["uniqueid"].ToString(), typeof(object)).ToString();
82
                 var feedBackJson = Convert.ChangeType(req["feedbackrating"].ToString(), typeof(object)).ToString();
82
                 var feedBackJson = Convert.ChangeType(req["feedbackrating"].ToString(), typeof(object)).ToString();
83
-                var feedBackObj = JsonSerializer.Deserialize<Request.VisitorRequest>(feedBackJson);
83
+                var feedBackObj =  JsonSerializer.Deserialize<Request.VisitorRequest>(feedBackJson);
84
                 var comments = feedBackObj.Comments;
84
                 var comments = feedBackObj.Comments;
85
                 var rating = feedBackObj.Rating;
85
                 var rating = feedBackObj.Rating;
86
                 var visitorInfo = await visitorManager.GetpreVisitorsAsync(srequest, code);
86
                 var visitorInfo = await visitorManager.GetpreVisitorsAsync(srequest, code);
90
                     var sql = new Unibase.Data.Sql.Select("bizgazecrm_visitors").Columns("bizgazecrm_visitors.installedappid", "bizgazecrm_visitors.fullname", "bizgazecrm_visitors.mobilenumber", "bizgazecrm_visitors.emailid", "bizgazecrm_visitors.photourl", "unibase_stagestatus.stageStatusName", "unibase_stagestatus.RefStatusId").InnerJoin("unibase_stages", Exp.EqColumns("unibase_stages.stageid", "bizgazecrm_visitors.stageid")).InnerJoin("unibase_stagestatus", Exp.EqColumns("unibase_stagestatus.stagestatusid", "unibase_stages.stagestatusid")).Where("bizgazecrm_visitors.visitorid", visitorId);
90
                     var sql = new Unibase.Data.Sql.Select("bizgazecrm_visitors").Columns("bizgazecrm_visitors.installedappid", "bizgazecrm_visitors.fullname", "bizgazecrm_visitors.mobilenumber", "bizgazecrm_visitors.emailid", "bizgazecrm_visitors.photourl", "unibase_stagestatus.stageStatusName", "unibase_stagestatus.RefStatusId").InnerJoin("unibase_stages", Exp.EqColumns("unibase_stages.stageid", "bizgazecrm_visitors.stageid")).InnerJoin("unibase_stagestatus", Exp.EqColumns("unibase_stagestatus.stagestatusid", "unibase_stages.stagestatusid")).Where("bizgazecrm_visitors.visitorid", visitorId);
91
                     List<Parameter> param = new List<Parameter>();
91
                     List<Parameter> param = new List<Parameter>();
92
                     param.Add(new Parameter("@bizgazecrm_visitors.visitorid", visitorId));
92
                     param.Add(new Parameter("@bizgazecrm_visitors.visitorid", visitorId));
93
-                    var dt = GetDataTable(srequest, sql, param);                    
93
+                    var dt = await GetDataTableAsync(srequest, sql, param);                    
94
                     var stageStatusName = "";                   
94
                     var stageStatusName = "";                   
95
                     if (dt.Rows.Count > 0)
95
                     if (dt.Rows.Count > 0)
96
                     {                        
96
                     {                        
98
                         for (int i = 0; i < dt.Rows.Count; i++)
98
                         for (int i = 0; i < dt.Rows.Count; i++)
99
                         {                           
99
                         {                           
100
                             var installedAppId = Convert.ToInt64(dt.Rows[i]["installedAppId"]);                            
100
                             var installedAppId = Convert.ToInt64(dt.Rows[i]["installedAppId"]);                            
101
-                            var stage = stageManager.GetStageByStageStatus(srequest, installedAppId, stageStatusName);
101
+                            var stage =  await stageManager.GetStageByStageStatusAsync(srequest, installedAppId, stageStatusName);
102
                             var NewStageId = stage.Result.StageId;
102
                             var NewStageId = stage.Result.StageId;
103
                             var UpdateStage = new Update("bizgazecrm_visitors").Value("stageid", NewStageId).Where(Exp.Eq("visitorId", visitorId));
103
                             var UpdateStage = new Update("bizgazecrm_visitors").Value("stageid", NewStageId).Where(Exp.Eq("visitorId", visitorId));
104
-                            _repository.Execute(request, UpdateStage);
104
+                             await _repository.ExecuteAsync(request, UpdateStage);
105
                         }
105
                         }
106
                         var options = new EntityOptions()
106
                         var options = new EntityOptions()
107
                         {
107
                         {

+ 2
- 2
CRM.Visitors/ActionProviders/VisitorStageChangeAndUpDateContacts.cs 查看文件

83
                     var sql = new Unibase.Data.Sql.Select("bizgazecrm_visitors").Columns("bizgazecrm_visitors.installedappid", "bizgazecrm_visitors.fullname", "bizgazecrm_visitors.mobilenumber", "bizgazecrm_visitors.emailid", "bizgazecrm_visitors.photourl", "unibase_stagestatus.stageStatusName", "unibase_stagestatus.RefStatusId").InnerJoin("unibase_stages", Exp.EqColumns("unibase_stages.stageid", "bizgazecrm_visitors.stageid")).InnerJoin("unibase_stagestatus", Exp.EqColumns("unibase_stagestatus.stagestatusid", "unibase_stages.stagestatusid")).Where("bizgazecrm_visitors.visitorid", visitorId);
83
                     var sql = new Unibase.Data.Sql.Select("bizgazecrm_visitors").Columns("bizgazecrm_visitors.installedappid", "bizgazecrm_visitors.fullname", "bizgazecrm_visitors.mobilenumber", "bizgazecrm_visitors.emailid", "bizgazecrm_visitors.photourl", "unibase_stagestatus.stageStatusName", "unibase_stagestatus.RefStatusId").InnerJoin("unibase_stages", Exp.EqColumns("unibase_stages.stageid", "bizgazecrm_visitors.stageid")).InnerJoin("unibase_stagestatus", Exp.EqColumns("unibase_stagestatus.stagestatusid", "unibase_stages.stagestatusid")).Where("bizgazecrm_visitors.visitorid", visitorId);
84
                     List<Parameter> param = new List<Parameter>();
84
                     List<Parameter> param = new List<Parameter>();
85
                     param.Add(new Parameter("@bizgazecrm_visitors.visitorid", visitorId));
85
                     param.Add(new Parameter("@bizgazecrm_visitors.visitorid", visitorId));
86
-                    var dt = GetDataTable(srequest, sql, param);
86
+                    var dt = await GetDataTableAsync(srequest, sql, param);
87
                     var mobileNumber = "";
87
                     var mobileNumber = "";
88
                     var emailId = "";
88
                     var emailId = "";
89
                     long installedAppId = 0;
89
                     long installedAppId = 0;
109
                             installedAppId = Convert.ToInt64(dt.Rows[i]["installedAppId"]);
109
                             installedAppId = Convert.ToInt64(dt.Rows[i]["installedAppId"]);
110
                             visitorName = Convert.ToString(dt.Rows[i]["fullname"]);
110
                             visitorName = Convert.ToString(dt.Rows[i]["fullname"]);
111
                             photourl = Convert.ToString(dt.Rows[i]["photourl"]);
111
                             photourl = Convert.ToString(dt.Rows[i]["photourl"]);
112
-                            var stage = stageManager.GetStageByStageStatus(srequest, installedAppId, stageStatusName);
112
+                            var stage = await stageManager.GetStageByStageStatusAsync(srequest, installedAppId, stageStatusName);
113
                             var NewStageId = stage.Result.StageId;
113
                             var NewStageId = stage.Result.StageId;
114
                             var UpdateStage = new Update("bizgazecrm_visitors").Value("stageid", NewStageId).Where(Exp.Eq("visitorId", visitorId));
114
                             var UpdateStage = new Update("bizgazecrm_visitors").Value("stageid", NewStageId).Where(Exp.Eq("visitorId", visitorId));
115
                             _repository.Execute(request, UpdateStage);
115
                             _repository.Execute(request, UpdateStage);

正在加载...
取消
保存