兑换码功能实现

New_College.Services/V_CustomerInfoServices.cs

@@ -325,55 +325,7 @@ namespace New_College.Services
             {
                 Task.Run(async () =>
                 {
-                    var xet = XiaoEtongApp.GetUsersList(new UserRequest()
+                    SyncXET(info);
-                    {
-                        phone = info.Phone,
-                        page = 1,
-                        page_size = 1,
-                    });
-                    if (xet.data.list != null && xet.data.list.Count() > 0)
-                    {
-                        var xiaoetong = (await _XiaoEtongUserRepository.Query(e => e.bind_phone == info.Phone));
-                        if (!xiaoetong.Any())
-                        {
-                            await _XiaoEtongUserRepository.Add(new D_XiaoEtongUser()
-                            {
-                                avatar = xet.data.list.First().avatar,
-                                bind_phone = xet.data.list.First().bind_phone,
-                                collect_phone = xet.data.list.First().collect_phone,
-                                CreateBy = "system",
-                                CreateTime = DateTime.Now,
-                                from = xet.data.list.First().from,
-                                IsDelete = false,
-                                ModifyBy = "system",
-                                ModifyTime = DateTime.Now,
-                                OrderSort = 0,
-                                pay_sum = xet.data.list.First().pay_sum,
-                                punch_count = xet.data.list.First().punch_count,
-                                user_created_at = xet.data.list.First().user_created_at,
-                                user_nickname = xet.data.list.First().user_nickname,
-                                wx_app_open_id = xet.data.list.First().wx_app_open_id,
-                                wx_open_id = xet.data.list.First().wx_open_id,
-                                wx_union_id = xet.data.list.First().wx_union_id,
-                                user_id = xet.data.list.First().user_id
-                            });
-                            var orders = XiaoEtongApp.GetOrdersList(new XETOrdersRequest()
-                            {
-                                page = 1,
-                                page_size = 30,
-                                user_id = xet.data.list.First().user_id
-                            });
-                            if (orders.data.list.Any() && orders.data.list.Count() > 0 && !info.IsVIP)
-                            {
-                                var isvip = orders.data.list.Select(c => c.order_info).Where(e => e.activity_type_bitmap.Contains(11));
-                                info.IsVIP = isvip.Count() > 0 ? true : false;
-                                info.ModifyTime = DateTime.Now;
-
-                                await _dal.Update(info);
-
-                            }
-                        }
-                    }
                 });
             }
 
@@ -409,6 +361,64 @@ namespace New_College.Services
             };
         }
 
+        /// <summary>
+        /// 同步小鹅通
+        /// </summary>
+        /// <param name="info"></param>
+        /// <returns></returns>
+        private async Task<V_CustomerInfo> SyncXET(V_CustomerInfo info)
+        {
+            var xet = XiaoEtongApp.GetUsersList(new UserRequest()
+            {
+                phone = info.Phone,
+                page = 1,
+                page_size = 1,
+            });
+            if (xet.data.list != null && xet.data.list.Count() > 0)
+            {
+                var xiaoetong = (await _XiaoEtongUserRepository.Query(e => e.bind_phone == info.Phone));
+                if (!xiaoetong.Any())
+                {
+                    await _XiaoEtongUserRepository.Add(new D_XiaoEtongUser()
+                    {
+                        avatar = xet.data.list.First().avatar,
+                        bind_phone = xet.data.list.First().bind_phone,
+                        collect_phone = xet.data.list.First().collect_phone,
+                        CreateBy = "system",
+                        CreateTime = DateTime.Now,
+                        from = xet.data.list.First().from,
+                        IsDelete = false,
+                        ModifyBy = "system",
+                        ModifyTime = DateTime.Now,
+                        OrderSort = 0,
+                        pay_sum = xet.data.list.First().pay_sum,
+                        punch_count = xet.data.list.First().punch_count,
+                        user_created_at = xet.data.list.First().user_created_at,
+                        user_nickname = xet.data.list.First().user_nickname,
+                        wx_app_open_id = xet.data.list.First().wx_app_open_id,
+                        wx_open_id = xet.data.list.First().wx_open_id,
+                        wx_union_id = xet.data.list.First().wx_union_id,
+                        user_id = xet.data.list.First().user_id
+                    });
+                    var orders = XiaoEtongApp.GetOrdersList(new XETOrdersRequest()
+                    {
+                        page = 1,
+                        page_size = 30,
+                        user_id = xet.data.list.First().user_id
+                    });
+                    if (orders.data.list.Any() && orders.data.list.Count() > 0 && !info.IsVIP)
+                    {
+                        var isvip = orders.data.list.Select(c => c.order_info).Where(e => e.activity_type_bitmap.Contains(11));
+                        info.IsVIP = isvip.Count() > 0 ? true : false;
+                        info.ModifyTime = DateTime.Now;
+                        await _dal.Update(info);
+                    }
+                }
+            }
+
+            return info;
+        }
+
         /// <summary>
         /// 查询CustomerInfo表信息
         /// </summary>
@@ -505,6 +515,7 @@ namespace New_College.Services
             var userinfo = (await _dal.Query(w => w.OpenId == query.openId && w.IsDelete == false)).ToList().FirstOrDefault();
             if (userinfo != null)
             {
+               await SyncXET(userinfo);
                 return new Tuple<bool, CustomerInfoResult>(true, new CustomerInfoResult()
                 {
                     AreaId = userinfo.AreaId,