using System; using System.Collections.Generic; using System.Linq; using System.Web; using System.Web.Mvc; using System.Data; using System.Data.SqlClient; using System.IO; using System.Data.OleDb; using MES.Production.Entity; using Ant.ORM; using Ant.Data; using Ant.Common; using System.Text.RegularExpressions; using MES.Production.Entity.Enum; using System.Transactions; using ChangFa.Machinery.WebPage.Controllers; using Central.Control.Domain; using MES.Production.Entity.Entity; using Ant.Service.Utility; using System.Configuration; using ChangFa.Machinery.WebPage.App_Start; namespace ChangFa.Machinery.WebPage.Areas.SysManage.Controllers { public class ExcelController : BaseController { /// /// /// /// /// [HttpPost] public ActionResult UpLoad(HttpPostedFileBase filebase) { HttpPostedFileBase file = Request.Files["file"];//获取上传的文件 string result = string.Empty; string strConn; strConn = "Provider=Microsoft.Jet.OLEDB.4.0;" + "Data Source=" + file + "; " + "Extended Properties=Excel 8.0;"; OleDbDataAdapter myCommand = new OleDbDataAdapter("SELECT * FROM [Sheet1$]", strConn); DataSet myDataSet = new DataSet(); myCommand.Fill(myDataSet, "ExcelInfo"); System.Data.DataTable tab = myDataSet.Tables["ExcelInfo"].DefaultView.ToTable(); // ...用foreach把tab中数据添加到数据库 省略了如果是多表插入,可以调用存储过程.呵呵 result = "导入成功!"; JsonResult json = new JsonResult(); json.Data = result; return json; } /// /// 导入经销商 /// /// /// [HttpPost] public JsonResult DataImportDistributor(HttpPostedFileBase filebase) { HttpPostedFileBase file = Request.Files["file"];//获取上传的文件 string FileName; string savePath; var json = new Ant.Service.Common.JsonHelper() { Msg = "导入成功", Status = "y", ReUrl = "/Sys/Home/Index" }; if (file == null || file.ContentLength <= 0) { json.Status = "n"; json.Msg = "文件不能为空!"; return Json(json); //ViewBag.error = "文件不能为空"; //return View(); } else { string filename = Path.GetFileName(file.FileName); int filesize = file.ContentLength;//获取上传文件的大小单位为字节byte string fileEx = System.IO.Path.GetExtension(filename);//获取上传文件的扩展名 string NoFileName = System.IO.Path.GetFileNameWithoutExtension(filename);//获取无扩展名的文件名 int Maxsize = 10000 * 1024;//定义上传文件的最大空间大小为10M string FileType = ".xls,.xlsx";//定义上传文件的类型字符串 FileName = NoFileName + DateTime.Now.ToString("yyyyMMddhhmmss") + fileEx; if (!FileType.Contains(fileEx)) { json.Status = "n"; json.Msg = "文件类型不对,只能导入xls和xlsx格式的文件"; return Json(json); } if (filesize >= Maxsize) { json.Status = "n"; json.Msg = "上传文件超过10M,不能上传"; return Json(json); } string path = AppDomain.CurrentDomain.BaseDirectory + "upload\\excel\\"; savePath = Path.Combine(path, FileName); file.SaveAs(savePath); string strConn; //strConn = "Provider=Microsoft.Jet.OLEDB.4.0;" + "Data Source=" + savePath + "; " + "Extended Properties=Excel 8.0;"; strConn = "Provider=Microsoft.Ace.OleDb.12.0;" + "data source=" + savePath + ";Extended Properties='Excel 12.0; HDR=Yes; IMEX=1'"; //此连接可以操作.xls与.xlsx文件 (支持Excel2003 和 Excel2007 的连接字符串) //备注: "HDR=yes;"是说Excel文件的第一行是列名而不是数据,"HDR=No;"正好与前面的相反。 // "IMEX=1 "如果列中的数据类型不一致,使用"IMEX=1"可必免数据类型冲突。 //OleDbDataAdapter myCommand = new OleDbDataAdapter("select * from [Sheet1$]", strConn); DataSet myDataSet = new DataSet(); try { //连接串 //string strConn = "Provider=Microsoft.Jet.OLEDB.4.0;" + "DataSource=" + Path + ";" + "ExtendedProperties=Excel8.0;"; OleDbConnection conn = new OleDbConnection(strConn); conn.Open(); //返回Excel的架构,包括各个sheet表的名称,类型,创建时间和修改时间等  DataTable dtSheetName = conn.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, new object[] { null, null, null, "Table" }); //包含excel中表名的字符串数组 string[] strTableNames = new string[dtSheetName.Rows.Count]; for (int k = 0; k < dtSheetName.Rows.Count; k++) { strTableNames[k] = dtSheetName.Rows[k]["TABLE_NAME"].ToString(); } OleDbDataAdapter myCommand = null; DataTable dt = new DataTable(); //从指定的表明查询数据,可先把所有表明列出来供用户选择 string strExcel = "select * from [" + strTableNames[0] + "]"; myCommand = new OleDbDataAdapter(strExcel, strConn); //myCommand.Fill(dt); myCommand.Fill(myDataSet, "ExcelInfo"); } catch (Exception ex) { json.Status = "n"; json.Msg = ex.Message.ToString(); return Json(json); //return View(); } DataTable table = myDataSet.Tables["ExcelInfo"].DefaultView.ToTable(); if (table.Rows.Count > 1000) { json.Status = "n"; json.Msg = "导入数据不能大于1000条!"; return Json(json); } using (TransactionScope transaction = new TransactionScope()) { for (int i = 0; i < table.Rows.Count; i++) { var _entity = new EntSYS_DISTRIBUTORS(); var _userenty = new En_SYS_USER(); //当前经销商和用户 string distridutorid = Guid.NewGuid().ToString(); using (AntORM orm = new AntORM()) { orm.db = DataAccessFactory.CreateDataConnection("CyclingItem"); RequestModel res = new RequestModel { newSt = new SqlNote() { Author = "季健国", NewSt = new System.Diagnostics.StackTrace(true), SqlDesc = "获取公告信息" } }; string name = table.Rows[i]["经销商名称"].ToString(); var distype = table.Rows[i]["经销商类型"].ToString(); string discode = table.Rows[i]["经销商编号"].ToString(); var proudctline1 = table.Rows[i]["轮拖轮式收条线联系人"].ToString();// 601615 var proudctline2 = table.Rows[i]["履带插秧条线联系人"].ToString();//612611 var proudctline3 = table.Rows[i]["玉米收花生机条线联系人"].ToString();//622628 var phone1 = table.Rows[i]["轮拖轮式收条线手机号"].ToString(); var phone2 = table.Rows[i]["履带插秧条线手机号"].ToString(); var phone3 = table.Rows[i]["玉米收花生机条线手机号"].ToString(); var saleproduct = table.Rows[i]["销售产品"].ToString(); var resulut = orm.Queryable().Where(p => p.NAME == name).FirstOrDefault(); if (resulut.IsSuccess)//修改 { EntSYS_DISTRIBUTORS dismod = resulut.ResultModel; distridutorid = dismod.ID; _entity.NAME = table.Rows[i]["经销商名称"].ToString(); _entity.CODE = table.Rows[i]["经销商编号"].ToString(); _entity.Address = table.Rows[i]["地址"].ToString(); string pro = table.Rows[i]["所在省"].ToString(); var resluts = orm.Queryable().Where(p => p.ID == pro).FirstOrDefault(res); if (resluts.IsSuccess) { MES.Production.Entity.SYS_CODE_AREA mod = resluts.ResultModel; _entity.Province = mod.ID.ToInt32(); } string city = table.Rows[i]["所在市"].ToString(); resluts = orm.Queryable().Where(p => p.ID == city).FirstOrDefault(res); if (resluts.IsSuccess) { MES.Production.Entity.SYS_CODE_AREA mod = resluts.ResultModel; _entity.City = mod.ID.ToInt32(); } string area = table.Rows[i]["所在市"].ToString(); resluts = orm.Queryable().Where(p => p.ID == area).FirstOrDefault(res); if (resluts.IsSuccess) { MES.Production.Entity.SYS_CODE_AREA mod = resluts.ResultModel; _entity.Area = mod.ID.ToInt32(); } _entity.FenceRadius = table.Rows[i]["电子围栏范围"].ToInt32(); _entity.Theodolite = table.Rows[i]["经纬度"].ToString().Replace(",", ","); _entity.SaleCar = table.Rows[i]["销售产品"].ToString(); //var reslutdevice = orm.UpdateByLambda(p => _entity, a => a.ID == dismod.ID, res); } else//新增一级经销商和仓库 { if (distype == "一级经销商") { _entity.BUSINESSLEVEL = 2; int sumcount = orm.Queryable().Where(p => p.BUSINESSLEVEL == 2).Count() + 1; string num = sumcount.ToString("D5"); _entity.CODE = "003" + num; _entity.NAME = table.Rows[i]["经销商名称"].ToString(); _entity.DealerNumber = table.Rows[i]["经销商编号"].ToString(); _entity.PARENTID = "32f7a4bd-84de-4587-be29-734d65ad6f70"; _entity.ParentName = "常发农机定位锁车"; _entity.PARENTCODE = "003"; Ent_SYS_USER usermod = new Ent_SYS_USER(); usermod.NAME = table.Rows[i]["经销商联系人"].ToString(); usermod.ACCOUNT = table.Rows[i]["经销商手机号"].ToString(); usermod.DPTID = distridutorid; usermod.PHONE = table.Rows[i]["经销商手机号"].ToString(); var pwd = PasswordUtils.MD5_Encrypt("111111", 32); usermod.PASSWORD = pwd; usermod.USERTYPE = 2; usermod.CREATEPER = "系统导入"; usermod.CREATEDATE = DateTime.Now; var reslut1 = orm.Save(usermod, res); } else //仓库 { var reslut = orm.Queryable().Where(p => p.DealerNumber == discode && p.BUSINESSLEVEL == 2).FirstOrDefault(res); if (reslut.IsSuccess) { EntSYS_DISTRIBUTORS entSYS_DISTRIBUTORS = reslut.ResultModel;//父级经销商数据; int sumcount = orm.Queryable().Where(p => p.BUSINESSLEVEL == 3 && p.PARENTCODE == entSYS_DISTRIBUTORS.CODE).Count() + 1; string num = sumcount.ToString("D3"); _entity.CODE = entSYS_DISTRIBUTORS.CODE + num; _entity.PARENTID = entSYS_DISTRIBUTORS.ID; _entity.ParentName = entSYS_DISTRIBUTORS.NAME; _entity.PARENTCODE = entSYS_DISTRIBUTORS.CODE; } _entity.BUSINESSLEVEL = 3; _entity.NAME = table.Rows[i]["经销商名称"].ToString(); _entity.DealerNumber = table.Rows[i]["经销商编号"].ToString(); } _entity.Address = table.Rows[i]["地址"].ToString(); //_entity.ProvinceCity = table.Rows[i]["所在省"].ToString() +","+ table.Rows[i]["所在市"].ToString(); string pro = table.Rows[i]["所在省"].ToString(); var resluts = orm.Queryable().Where(p => p.ID == pro).FirstOrDefault(res); if (resluts.IsSuccess) { MES.Production.Entity.SYS_CODE_AREA mod = resluts.ResultModel; _entity.Province = mod.ID.ToInt32(); } string city = table.Rows[i]["所在市"].ToString(); resluts = orm.Queryable().Where(p => p.ID == city).FirstOrDefault(res); if (resluts.IsSuccess) { MES.Production.Entity.SYS_CODE_AREA mod = resluts.ResultModel; _entity.City = mod.ID.ToInt32(); } string area = table.Rows[i]["所在市"].ToString(); resluts = orm.Queryable().Where(p => p.ID == area).FirstOrDefault(res); if (resluts.IsSuccess) { MES.Production.Entity.SYS_CODE_AREA mod = resluts.ResultModel; _entity.Area = mod.ID.ToInt32(); } _entity.FenceRadius = table.Rows[i]["电子围栏范围"].ToInt32(); _entity.Theodolite = table.Rows[i]["经纬度"].ToString().ToString().Replace(",", ","); _entity.SaleCar = table.Rows[i]["销售产品"].ToString(); _entity.CREATEDATE = DateTime.Now; orm.Save(_entity, res); //保存经销商信息 } if (!proudctline1.IsEmpty()) { var userreslut = orm.Queryable().Where(p => p.PHONE == phone1).FirstOrDefault(res); if (userreslut.IsSuccess) { En_SYS_USER user = userreslut.ResultModel; int struserid = user.ID.ToInt32(); var count = orm.Queryable().Where(p => p.distributorId == distridutorid && p.userId == struserid).Count(); if (count == 0) { EntYW_UserDistributor userdismod = new EntYW_UserDistributor(); userdismod.ID = Guid.NewGuid(); userdismod.userId = struserid; userdismod.distributorId = distridutorid; userdismod.ProductLine = 601; userdismod.ProductLine1 = 615; userdismod.add_name = "系统导入"; var reslut1 = orm.Save(userdismod, res); } else { var updatereslut = orm.UpdateByLambda(p => new EntYW_UserDistributor { ProductLine = 601, ProductLine1 = 615 }, f => f.distributorId == distridutorid && f.userId == struserid, res); } } else { En_SYS_USER usermod = new En_SYS_USER(); usermod.NAME = proudctline1; usermod.ACCOUNT = phone1; usermod.PHONE = phone1; var pwd = PasswordUtils.MD5_Encrypt("111111", 32); usermod.PASSWORD = pwd; usermod.USERTYPE = 2; usermod.CREATEPER = "系统导入"; usermod.CREATEDATE = DateTime.Now; var reslut = orm.SaveHaveNull(usermod, res); if (reslut.IsSuccess) { int struserid = reslut.RecordNum; var count = orm.Queryable().Where(p => p.distributorId == distridutorid && p.userId == struserid).Count(); if (count == 0) { EntYW_UserDistributor userdismod = new EntYW_UserDistributor(); userdismod.ID = Guid.NewGuid(); userdismod.userId = struserid; userdismod.distributorId = distridutorid; userdismod.ProductLine = 601; userdismod.ProductLine1 = 615; userdismod.add_name = "系统导入"; var reslut1 = orm.Save(userdismod, res); } else { var updatereslut = orm.UpdateByLambda(p => new EntYW_UserDistributor { ProductLine = 601, ProductLine1 = 615 }, f => f.distributorId == distridutorid && f.userId == struserid, res); } } } } if (!proudctline2.IsEmpty()) { var userreslut = orm.Queryable().Where(p => p.PHONE == phone2).FirstOrDefault(res); if (userreslut.IsSuccess) { En_SYS_USER user = userreslut.ResultModel; int struserid = user.ID.ToInt32(); var count = orm.Queryable().Where(p => p.distributorId == distridutorid && p.userId == struserid).Count(); if (count == 0) { EntYW_UserDistributor userdismod = new EntYW_UserDistributor(); userdismod.ID = Guid.NewGuid(); userdismod.userId = struserid; userdismod.distributorId = distridutorid; userdismod.ProductLine2 = 612; userdismod.ProductLine3 = 611; userdismod.add_name = "系统导入"; var reslut1 = orm.Save(userdismod, res); } else { var updatereslut = orm.UpdateByLambda(p => new EntYW_UserDistributor { ProductLine2 = 612, ProductLine3 = 611 }, f => f.distributorId == distridutorid && f.userId == struserid, res); } } else { En_SYS_USER usermod = new En_SYS_USER(); usermod.NAME = proudctline1; usermod.ACCOUNT = phone1; usermod.PHONE = phone1; var pwd = PasswordUtils.MD5_Encrypt("111111", 32); usermod.PASSWORD = pwd; usermod.USERTYPE = 2; usermod.CREATEPER = "系统导入"; usermod.CREATEDATE = DateTime.Now; var reslut = orm.SaveHaveNull(usermod, res); if (reslut.IsSuccess) { int struserid = reslut.RecordNum; var count = orm.Queryable().Where(p => p.distributorId == distridutorid && p.userId == struserid).Count(); if (count == 0) { EntYW_UserDistributor userdismod = new EntYW_UserDistributor(); userdismod.ID = Guid.NewGuid(); userdismod.userId = struserid; userdismod.distributorId = distridutorid; userdismod.ProductLine2 = 612; userdismod.ProductLine3 = 611; userdismod.add_name = "系统导入"; var reslut1 = orm.Save(userdismod, res); } else { var updatereslut = orm.UpdateByLambda(p => new EntYW_UserDistributor { ProductLine2 = 612, ProductLine3 = 611 }, f => f.distributorId == distridutorid && f.userId == struserid, res); } } } } if (!proudctline3.IsEmpty()) { var userreslut = orm.Queryable().Where(p => p.PHONE == phone3).FirstOrDefault(res); if (userreslut.IsSuccess) { En_SYS_USER user = userreslut.ResultModel; int struserid = user.ID.ToInt32(); var count = orm.Queryable().Where(p => p.distributorId == distridutorid && p.userId == struserid).Count(); if (count == 0) { EntYW_UserDistributor userdismod = new EntYW_UserDistributor(); userdismod.ID = Guid.NewGuid(); userdismod.userId = struserid; userdismod.distributorId = distridutorid; userdismod.ProductLine4 = 622; userdismod.ProductLine5 = 628; userdismod.add_name = "系统导入"; var reslut1 = orm.Save(userdismod, res); } else { var updatereslut = orm.UpdateByLambda(p => new EntYW_UserDistributor { ProductLine4 = 622, ProductLine5 = 628 }, f => f.distributorId == distridutorid && f.userId == struserid, res); } } else { En_SYS_USER usermod = new En_SYS_USER(); usermod.NAME = proudctline1; usermod.ACCOUNT = phone1; usermod.PHONE = phone1; var pwd = PasswordUtils.MD5_Encrypt("111111", 32); usermod.PASSWORD = pwd; usermod.USERTYPE = 2; usermod.CREATEPER = "系统导入"; usermod.CREATEDATE = DateTime.Now; var reslut = orm.SaveHaveNull(usermod, res); if (reslut.IsSuccess) { int struserid = reslut.RecordNum; var count = orm.Queryable().Where(p => p.distributorId == distridutorid && p.userId == struserid).Count(); if (count == 0) { EntYW_UserDistributor userdismod = new EntYW_UserDistributor(); userdismod.ID = Guid.NewGuid(); userdismod.userId = struserid; userdismod.distributorId = distridutorid; userdismod.ProductLine4 = 622; userdismod.ProductLine5 = 628; userdismod.add_name = "系统导入"; var reslut1 = orm.Save(userdismod, res); } else { var updatereslut = orm.UpdateByLambda(p => new EntYW_UserDistributor { ProductLine4 = 622, ProductLine5 = 628 }, f => f.distributorId == distridutorid && f.userId == struserid, res); } } } } } } transaction.Complete(); json.Status = "y"; json.Msg = string.Format("成功导入{0}条数据", table.Rows.Count); } } return Json(json); } public FileResult ExportSchoolExcel2() { var schoolInfo = new { RaceName = "2021年武进区迎新春中长跑比赛", SchoolName = "少体校", Leader = "蒋建良", Coacher = "谢川,张晓娜", Contact = "15961169089" }; List sporterInfo = new List(); sporterInfo.Add(new { RaceNo = "2211", Name = "徐文彬", Sex = "男", RegNo = "20192026051", IDCard = "32048320090412131X", Grade = "小五", Group = "小学甲组", Project1 = "1500米", Project2 = "", Project3 = "", Project4 = "", QRCode = "测试", SchoolName = "测试" }); var ms = ExportExcelHelper.ExportSchoolExcel(schoolInfo, sporterInfo); return File(ms, "application/vnd.ms-excel", "武进区学校体育教练员统计表.xls"); } /// /// 将Excel导入绑定农机数据库 /// /// /// [HttpPost] public JsonResult DataImportAll(HttpPostedFileBase filebase) { HttpPostedFileBase file = Request.Files["file"];//获取上传的文件 string result = string.Empty; string distributorsid = Request["distributorsid"]; string distributorName = Request["distributorName"]; string saleid = Request["saleid"]; string FileName; string savePath; var json = new Ant.Service.Common.JsonHelper() { Msg = "导入成功", Status = "y", ReUrl = "/Sys/Home/Index" }; if (file == null || file.ContentLength <= 0) { json.Status = "n"; json.Msg = "文件不能为空!"; return Json(json); //ViewBag.error = "文件不能为空"; //return View(); } else { string filename = Path.GetFileName(file.FileName); int filesize = file.ContentLength;//获取上传文件的大小单位为字节byte string fileEx = System.IO.Path.GetExtension(filename);//获取上传文件的扩展名 string NoFileName = System.IO.Path.GetFileNameWithoutExtension(filename);//获取无扩展名的文件名 int Maxsize = 10000 * 1024;//定义上传文件的最大空间大小为10M string FileType = ".xls,.xlsx";//定义上传文件的类型字符串 FileName = NoFileName + DateTime.Now.ToString("yyyyMMddhhmmss") + fileEx; if (!FileType.Contains(fileEx)) { json.Status = "n"; json.Msg = "文件类型不对,只能导入xls和xlsx格式的文件"; return Json(json); } if (filesize >= Maxsize) { json.Status = "n"; json.Msg = "上传文件超过10M,不能上传"; return Json(json); } string path = AppDomain.CurrentDomain.BaseDirectory + "upload\\excel\\"; savePath = Path.Combine(path, FileName); file.SaveAs(savePath); string strConn; strConn = "Provider=Microsoft.Jet.OLEDB.4.0;" + "Data Source=" + savePath + "; " + "Extended Properties=Excel 8.0;"; //strConn = "Provider=Microsoft.Ace.OleDb.12.0;" + "data source=" + savePath + ";Extended Properties='Excel 12.0; HDR=Yes; IMEX=1'"; //此连接可以操作.xls与.xlsx文件 (支持Excel2003 和 Excel2007 的连接字符串) //备注: "HDR=yes;"是说Excel文件的第一行是列名而不是数据,"HDR=No;"正好与前面的相反。 // "IMEX=1 "如果列中的数据类型不一致,使用"IMEX=1"可必免数据类型冲突。 //OleDbDataAdapter myCommand = new OleDbDataAdapter("select * from [Sheet1$]", strConn); DataSet myDataSet = new DataSet(); try { //连接串 //string strConn = "Provider=Microsoft.Jet.OLEDB.4.0;" + "DataSource=" + Path + ";" + "ExtendedProperties=Excel8.0;"; OleDbConnection conn = new OleDbConnection(strConn); conn.Open(); //返回Excel的架构,包括各个sheet表的名称,类型,创建时间和修改时间等  DataTable dtSheetName = conn.GetOleDbSchemaTable(OleDbSchemaGuid.Tables, new object[] { null, null, null, "Table" }); //包含excel中表名的字符串数组 string[] strTableNames = new string[dtSheetName.Rows.Count]; for (int k = 0; k < dtSheetName.Rows.Count; k++) { strTableNames[k] = dtSheetName.Rows[k]["TABLE_NAME"].ToString(); } OleDbDataAdapter myCommand = null; DataTable dt = new DataTable(); //从指定的表明查询数据,可先把所有表明列出来供用户选择 string strExcel = "select * from [" + strTableNames[0] + "]"; myCommand = new OleDbDataAdapter(strExcel, strConn); //myCommand.Fill(dt); myCommand.Fill(myDataSet, "ExcelInfo"); } catch (Exception ex) { json.Status = "n"; json.Msg = ex.Message.ToString(); return Json(json); //return View(); } DataTable table = myDataSet.Tables["ExcelInfo"].DefaultView.ToTable(); //if (table.Rows.Count > 1000) //{ // json.Status = "n"; // json.Msg = "导入数据不能大于1000条!"; // return Json(json); //} EntSYS_DISTRIBUTORS entSYS_DISTRIBUTORS = new EntSYS_DISTRIBUTORS(); using (AntORM orm = new AntORM()) { orm.db = DataAccessFactory.CreateDataConnection("CyclingItem"); var res = new RequestModel { newSt = new SqlNote() { Author = "季健国", NewSt = new System.Diagnostics.StackTrace(true), SqlDesc = "获取经销商信息" } }; var reslutdis = orm.Queryable().Where(p => p.ID == distributorsid).FirstOrDefault(res); if (reslutdis.IsSuccess) { entSYS_DISTRIBUTORS = reslutdis.ResultModel; } } int n = 0; int m = 0; foreach (DataRow dr in table.Rows) { if (dr["企业编号"].IfNotNull()) { string dealercode = dr["企业编号"].ToString().Trim(); if (!dealercode.IsEmpty()) { using (AntORM orm = new AntORM()) { orm.db = DataAccessFactory.CreateDataConnection("CyclingItem"); RequestModel res = new RequestModel(); res.newSt = new SqlNote() { Author = "季健国", NewSt = new System.Diagnostics.StackTrace(true), SqlDesc = "新增经销商数据" }; List userlist = new List(); string barcode = dr["条码"].ToString().Trim(); string carid = dr["卫星定位模块"].ToString().Trim(); string dealername = dr["经销单位"].ToString().Trim(); var num = orm.Queryable().Where(p => p.carBar == barcode).FirstOrDefault(res); if (num.IsSuccess) { EntYW_Bicycle carmod = num.ResultModel; if (carmod.DistributorsID.IsEmpty()) { var reslut = orm.Queryable().Where(p => p.DealerNumber == dealercode && p.PARENTID == "32f7a4bd-84de-4587-be29-734d65ad6f70").FirstOrDefault(res); if (reslut.IsSuccess) { EntSYS_DISTRIBUTORS entdid = reslut.ResultModel; var resluts = orm.UpdateByLambda(p => new EntYW_Bicycle() { DistributorsID = entdid.ID, DistributorsName = dealername, CustomerCode = dealercode, CustomerName = entdid.NAME }, a => a.carBar == barcode, res); n++; } else { var reslutss = orm.UpdateByLambda(p => new EntYW_Bicycle() { CustomerCode = dealercode, CustomerName = dealername }, a => a.carBar == barcode, res); } } } else { var reslut = orm.Queryable().Where(p => p.DealerNumber == dealercode && p.PARENTID == "32f7a4bd-84de-4587-be29-734d65ad6f70").FirstOrDefault(res); if (reslut.IsSuccess) { EntSYS_DISTRIBUTORS dismod = reslut.ResultModel; string codebar = barcode.Substring(0, 3); if (codebar == "628") { EntYW_Bicycle mod = new EntYW_Bicycle(); mod.ID = Guid.NewGuid(); mod.carBar = barcode.ToString(); //mod.CarName = dr["productName"].ToString().Trim(); int cartype = 2; string productName = "花生机"; mod.DistributorsID = dismod.ID; mod.DistributorsName = dismod.NAME; mod.WarehouseID = dismod.ID; mod.WarehouseName = dismod.NAME; mod.ProductLine = 628; mod.CustomerCode = dealercode; mod.CustomerName = dealername; mod.CarID = carid.ToString(); mod.CarName = productName; mod.CarModel = "CF326"; if (dr["发货日期"] != null) mod.productionDate = dr["发货日期"].ToDateTime(); mod.FactoryNumber = dr["出厂编号"].ToString().Trim(); mod.OutDate = dr["发货日期"].ToDateTime(); mod.LeaseStatus = 0; mod.CarSate = CarState.OutStock.GetHashCode(); mod.LockState = false; mod.carType = cartype; mod.CreateDate = DateTime.Now; mod.Createper = "系统导入"; mod.FenceState = 0; var flag = orm.Save(mod, res); if (flag.IsSuccess) m++; } else { } } } } } } } json.Status = "y"; json.Msg = string.Format("成功导入{0}条数据,修改数据{1}条数据", m, n); } return Json(json); } } }