Learn.Archives.API/Controllers/SchoolBusinessController.cs

@@ -138,6 +138,7 @@ namespace Learn.Archives.API.Controllers
             //处理数据
             var errorExcelInfo = new List<SchoolBusinessImportError>();
             var insertInfo = new List<SchoolBusiness>();
+            var db = schoolService.Context;
             foreach (var imp in dataList)
             {
                 var school = await schoolService.GetFirstAsync(s => s.Name == imp.School);
@@ -166,8 +167,7 @@ namespace Learn.Archives.API.Controllers
                     .Select(s => s.Name).ToArrayAsync();
                 if (adminArr == null || adminArr.Length!= adminNameArr.Length)
                 {
-                    var nStr = string.Join(',', adminNameArr.Where(s => !adminArr.Contains(s)));
+                    imp.Error = $"赴校人员未能完全识别成功";
-                    imp.Error = $"赴校人员未能完全识别成功 ->{nStr}";
                     errorExcelInfo.Add(imp);
                     continue;
                 }

Learn.Archives.API/Controllers/StudentController.cs

@@ -456,48 +456,25 @@ namespace Learn.Archives.API.Controllers
                         s.JoinTime,
                         s.ExitTime,
                         s.Remark}.Any(x => !(x == default || x == null))).ToList();
-                //查询差异
+                //  测试IgnoreColumns是否真实有效
-                var addInfoUserArr = updateArr.Select(s => s.UserCenterId).ToArray();
+                await baseService.AsUpdateable(updateArr)
-                var hasUIdArr = await baseService.AsQueryable()
+                    .UpdateColumns(s => new
-                    .Where(s => addInfoUserArr.Contains(s.UserCenterId))
+                    {
-                    .Select(s => s.UserCenterId).ToArrayAsync();
+                        s.AmountRelief,
-                var hasUIdHash = hasUIdArr.ToHashSet();
+                        s.ReliefApplication,
-                var updateData = new List<Student>(10);
+                        s.ReliefType,
-                var InsertData = new List<Student>(10);
+                        s.ReliefSubTime,
-                foreach (var item in updateArr)
+                        s.StudentType,
-                {
+                        s.Status,
-                    if (hasUIdHash.Contains(item.UserCenterId))
+                        s.JoinTime,
-                        updateData.Add(item);
+                        s.ExitTime,
-                    else
+                        s.Remark
-                        InsertData.Add(item);
+                    })
-                }
+                    //更新忽略null并且忽略默认值 (比如int默认值是0就不更新)
-                //开启事务
+                    .IgnoreColumns(ignoreAllNullColumns: true, ignoreAllDefaultValue: true)
-                baseService.Context.Ado
+                    .WhereColumns(it => new { it.UserCenterId })
-                    .UseTran(() =>
+                    .ExecuteCommandAsync();
-                {
-                    baseService.InsertRange(InsertData);
-                    baseService.AsUpdateable(updateData)
-                        .UpdateColumns(s => new
-                        {
-                            s.AmountRelief,
-                            s.ReliefApplication,
-                            s.ReliefType,
-                            s.ReliefSubTime,
-                            s.StudentType,
-                            s.Status,
-                            s.JoinTime,
-                            s.ExitTime,
-                            s.Remark
-                        })
-                        //更新忽略null并且忽略默认值 (比如int默认值是0就不更新)
-                        //如果修改为0会出现修改不了的问题
-                        .IgnoreColumns(ignoreAllNullColumns: true, ignoreAllDefaultValue: true)
-                        .WhereColumns(it => new { it.UserCenterId })
-                        .ExecuteCommand();
-                    return true;
-                }, ex => { throw ex; });
             }
-            //写入选科方向
             if (userCenterUpdate.Count > 0)
                 await userService.AsUpdateable(userCenterUpdate)
                     .UpdateColumns(s => new

Learn.Archives.API/appsettings.json

@@ -13,8 +13,8 @@
     },
     "DB": {
       "ConnectionString": "AllowLoadLocalInfile=true;Server=58.17.132.2;User ID=marking;Password=qwe123!@#;Database=learn.archives;CharSet=utf8mb4;Port=43306;pooling=true;SslMode=None;",
-      //正式库
+     //正式库
-      //"ConnectionString": "AllowLoadLocalInfile=true;Server=archives-mysql.23544.com;User ID=archives;Password=MPsSSNuvFO7wBqADXC9zweh9tdOPNwm6;Port=3306;Database=learn.archives;CharSet=utf8mb4;pooling=true;SslMode=None",
+      //"ConnectionString": "AllowLoadLocalInfile=true;Server=rm-2vc20nd3d11g0oh6g2o.rwlb.cn-chengdu.rds.aliyuncs.com;User ID=marking;Password=poiuytPOIUYT098765)(*&^%;Port=3306;Database=learn.archives;CharSet=utf8mb4;pooling=true;SslMode=None",
       "SqlType": "MySql",
       "UpdateTable": false
     },