更新开发环境配置和优化客户信息导入功能

- 修改.env.development文件，将VUE_APP_BASE_API的值更改为'http://localhost:2011'以适应本地开发环境 - 在LqKhxxService中新增ImportCustomersFromCleanup方法，支持从"清理跨店的重复"表导入客户信息，包含详细的导入规则和字段映射说明 - 优化客户导入逻辑，避免重复导入并处理错误信息

更新开发环境配置和优化客户信息导入功能
- 修改.env.development文件，将VUE_APP_BASE_API的值更改为'http://localhost:2011'以适应本地开发环境 - 在LqKhxxService中新增ImportCustomersFromCleanup方法，支持从"清理跨店的重复"表导入客户信息，包含详细的导入规则和字段映射说明 - 优化客户导入逻辑，避免重复导入并处理错误信息
“wangming”
1 parent 1e118117
Showing 3 changed files with 131 additions and 3 deletions
antis-ncc-admin/.env.development
netcore/src/Modularity/Extend/NCC.Extend/LqKdKdjlbService.cs
netcore/src/Modularity/Extend/NCC.Extend/LqKhxxService.cs
 # 开发
  
 VUE_CLI_BABEL_TRANSPILE_MODULES = true
-VUE_APP_BASE_API = 'http://lvqian.antissoft.com'
-# VUE_APP_BASE_API = 'http://localhost:2011'
+# VUE_APP_BASE_API = 'http://lvqian.antissoft.com'
+VUE_APP_BASE_API = 'http://localhost:2011'
 VUE_APP_BASE_WSS = 'ws://192.168.110.45:2011/websocket'
@@ -176,7 +176,7 @@ namespace NCC.Extend.LqKdKdjlb
         [HttpGet("")]
         public async Task<dynamic> GetList([FromQuery] LqKdKdjlbListQueryInput input)
         {
-            var sidx = input.sidx == null ? "id" : input.sidx;
+            var sidx = input.sidx == null ? "kdrq" : input.sidx;
             List<string> queryKdrq = input.kdrq != null ? input.kdrq.Split(',').ToObeject<List<string>>() : null;
             DateTime? startKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.First()) : null;
             DateTime? endKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.Last()) : null;
@@ -630,5 +630,133 @@ namespace NCC.Extend.LqKhxx
         }
         #endregion
  
+        #region 导入客户信息
+        /// <summary>
+        /// 从"清理跨店的重复"表导入客户信息
+        /// </summary>
+        /// <remarks>
+        /// 将"清理跨店的重复"表中的数据导入到客户表中，客户类型设置为"潜客"
+        /// 
+        /// 导入规则：
+        /// 1. 根据客户电话去重，避免重复导入
+        /// 2. 客户类型统一设置为"潜客"
+        /// 3. 使用YitIdHelper生成客户ID
+        /// 4. 根据门店ID设置归属门店
+        /// 5. 根据拓客员工设置拓客人员
+        /// 
+        /// 字段映射：
+        /// - 客户姓名 -> khmc (客户名称)
+        /// - 客户电话 -> sjh (手机号)
+        /// - F_StoreId -> gsmd (归属门店)
+        /// - 拓客员工 -> F_ExpandUser (拓客人员)
+        /// - 日期 -> zcsj (注册时间)
+        /// </remarks>
+        /// <returns>导入结果</returns>
+        /// <response code="200">导入成功</response>
+        /// <response code="500">服务器内部错误</response>
+        [HttpPost("import-customers-from-cleanup")]
+        public async Task<dynamic> ImportCustomersFromCleanup()
+        {
+            try
+            {
+                _db.BeginTran();
+
+                // 1. 查询"清理跨店的重复"表数据，按客户电话去重
+                var cleanupData = await _db.Ado.SqlQueryAsync<dynamic>(@"
+                    SELECT 
+                        F_Id,
+                        客户姓名,
+                        客户电话,
+                        归属门店,
+                        拓客员工,
+                        日期,
+                        F_StoreId,
+                        F_UserId
+                    FROM `清理跨店的重复`
+                    WHERE 客户电话 IS NOT NULL 
+                      AND 客户电话 != ''
+                      AND 客户姓名 IS NOT NULL 
+                      AND 客户姓名 != ''
+                    GROUP BY 客户电话
+                    ORDER BY 日期 DESC");
+
+                int successCount = 0;
+                int skipCount = 0;
+                int errorCount = 0;
+                var errorMessages = new List<string>();
+
+                foreach (var item in cleanupData)
+                {
+                    try
+                    {
+                        // 2. 检查客户是否已存在（根据手机号）
+                        string phoneNumber = (string)item.客户电话;
+                        var existingCustomer = await _db.Queryable<LqKhxxEntity>()
+                            .Where(x => x.Sjh == phoneNumber)
+                            .FirstAsync();
+
+                        if (existingCustomer != null)
+                        {
+                            skipCount++;
+                            continue;
+                        }
+
+                        // 3. 生成客户ID
+                        string customerId = YitIdHelper.NextId().ToString();
+
+                        // 4. 创建客户实体
+                        var customerEntity = new LqKhxxEntity
+                        {
+                            Id = customerId,
+                            Khmc = (string)item.客户姓名,
+                            Sjh = (string)item.客户电话,
+                            Dah = $"GK{DateTime.Now:yyyyMMdd}{customerId.Substring(customerId.Length - 6)}", // 生成档案号
+                            Xb = "未知", // 默认性别
+                            Gsmd = (string)item.F_StoreId, // 使用门店ID
+                            Zcsj = DateTime.TryParse((string)item.日期, out DateTime regDate) ? regDate : DateTime.Now,
+                            Khlx = MemberTypeEnum.线索.GetHashCode().ToString(), // 客户类型设置为潜客
+                            Jdqd = "", // 进店渠道
+                            Lxdz = "", // 联系地址
+                            Bz = "历史潜客导入",
+                            CreateTime = DateTime.Now,
+                            ExpandUser = (string)item.拓客员工, // 拓客人员
+                            MainHealthUser = null,
+                            SubHealthUser = null
+                        };
+
+                        // 5. 插入客户记录
+                        await _db.Insertable(customerEntity).ExecuteCommandAsync();
+
+                        successCount++;
+                    }
+                    catch (Exception ex)
+                    {
+                        errorCount++;
+                        errorMessages.Add($"处理客户 {(string)item.客户姓名}({(string)item.客户电话}) 时出错: {ex.Message}");
+                    }
+                }
+
+                _db.CommitTran();
+
+                return new
+                {
+                    success = true,
+                    message = "客户信息导入完成",
+                    totalRecords = cleanupData.Count,
+                    successCount = successCount,
+                    skipCount = skipCount,
+                    errorCount = errorCount,
+                    errorMessages = errorMessages.Take(10).ToList(), // 只返回前10个错误信息
+                    importTime = DateTime.Now
+                };
+            }
+            catch (Exception ex) when (!(ex is NCCException))
+            {
+                _db.RollbackTran();
+                throw NCCException.Oh($"导入客户信息失败: {ex.Message}");
+            }
+        }
+        #endregion
+
     }
 }