Merge branch 'master' of http://192.168.1.222:3000/zhengbingbing/ZLJ_API_V6.0

代码/TVShoppingCallCenter_ZLJ/Controllers/Customer/VIPInfoController.cs

 using TVShoppingCallCenter_ZLJ.Models.Inputs;
 using SqlSugar;
 using System.Common.Helpers;
+using Microsoft.Extensions.Configuration;
+using System.Data;
+using System.Reflection;
 
 namespace TVShoppingCallCenter_ZLJ.Controllers.Customer
 {
         private readonly ICus_VipInfoRepository _cus_vip_infoRepository;
         private readonly ISys_UserAccountRepository _sys_user_accountRepository;
         private readonly ICus_MsgRepository _cus_msgRepository;
+        private readonly IConfiguration _configuration;
 
-        public VipInfoController(ICus_VipInfoRepository cus_vip_infoRepository, ISys_UserAccountRepository sys_user_accountRepository, ICus_MsgRepository cus_msgRepository)
+        public VipInfoController(ICus_VipInfoRepository cus_vip_infoRepository, ISys_UserAccountRepository sys_user_accountRepository, ICus_MsgRepository cus_msgRepository,IConfiguration configuration)
         {
             _cus_vip_infoRepository = cus_vip_infoRepository;
             _sys_user_accountRepository = sys_user_accountRepository;
             _cus_msgRepository = cus_msgRepository;
+            _configuration = configuration;
         }
 
         [HttpGet]
             }
             //return Success("导出成功");
         }
+
+        /// <summary>
+        /// 上传文件并导入数据库
+        /// </summary>
+        /// <returns></returns>
+        [HttpPost("importexcel")]
+        public async Task<IActionResult> ImportExcel( int headrow = 0)
+        {
+           
+            //string usercode = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+
+            Microsoft.AspNetCore.Http.IFormFile _upfile = Request.Form.Files[0];
+            if (!_upfile.ContentType.Equals("application/vnd.ms-excel") && !_upfile.ContentType.Equals("application/x-xls") && !_upfile.ContentType.Equals("application/x-xlsx") && !_upfile.ContentType.Equals("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet") && !_upfile.ContentType.Equals("application/octet-stream"))
+                return Error($"请正确上传Excel文件：file.ContentType={_upfile.ContentType}");
+
+            NPOIHelper npoi = new NPOIHelper();
+            var dtExcel = npoi.ExcelToTable1(_upfile, headrow);
+            int num = dtExcel.Rows.Count;
+            var cols = dtExcel.Columns;
+            int colnum = cols.Count;
+
+            string dbkeys = _configuration["upload:acotdbkeys"].ToString();
+            string[] dbcols = dbkeys.Split(",");
+            string errmsg = string.Empty;
+
+            if (num > 0)
+            {
+                int index = 1;
+                foreach (DataRow dr in dtExcel.Rows)
+                {
+                    var model = new T_Cus_VipInfo();
+                    
+                    model.F_State = 1;
+                    model.F_CreateBy = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
+                    model.F_CreateOn = DateTime.Now;
+
+                    var dbcolslist = dbcols.ToList();
+                    
+                    Type t = model.GetType();
+                    PropertyInfo[] PropertyList = t.GetProperties();
+
+                    foreach (PropertyInfo item in PropertyList)
+                    {
+                        if (dbcolslist.Contains(item.Name))
+                        {
+                            object v = Convert.ChangeType(dr[dbcolslist.IndexOf(item.Name)].ToString(), item.PropertyType);
+                            item.SetValue(model, v, null);
+                            
+                        }
+                    }
+
+                    int b = await _cus_vip_infoRepository.Add(model);
+
+                    
+                    if (b>0)
+                    {
+                        if (!string.IsNullOrEmpty(errmsg))
+                        {
+                            errmsg = errmsg + "\r\n第" + index + "行导入失败！";
+                        }
+                        else
+                        {
+                            errmsg = "第" + index + "行导入失败！";
+                        }
+                    }
+                    index++;
+                    
+                }
+            }
+            else
+            {
+                return Error("文件中无数据");
+            }
+
+            if (!string.IsNullOrEmpty(errmsg))
+            {
+                //删除已导入的部分
+                return Error(errmsg);
+            }
+
+            return Success("导入成功");
+        }
         #endregion
     }
 }

代码/TVShoppingCallCenter_ZLJ/appsettings.json

     "Defaultdatabase": "5",
     "InstanceName": "base"
   },
+  "upload": {
+    "url": "http://192.168.4.18:5008/api/upload",
+    "params": "uploadtype=excel",
+    "acotmbname": "会员信息导入模板.xlsx",
+    "acotmbkeys": "会员卡号,姓名,生日,年龄,性别,鞋码,手机号1,手机号2,固定电话,推荐人,标签,备注,昵称,注册时间,省份,城市,县区,乡镇,邮编,地址1,地址2,会员积分,累计消费,累计积分,销售负责人,最近联系时间,会员类型",
+    "acotdbkeys": "F_VIPCode,F_Name,F_Birthday,F_Age,F_Sex,F_ShoeSize,F_Mobile,F_Mobile1,F_Phone,F_Recommender,F_Label,F_Note,F_Nickname,F_RegTime,F_Province,F_City,F_Area,F_Town,F_Postcode,F_Address,F_Address1,F_Score,F_Money,F_TotalScore,F_Saleperson,F_Contact,F_Type"
+  },
   "Logging": {
     "LogLevel": {
       "Default": "Warning"