From f69928e4371ad7903c69ab22a58afc3e284d9c7c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=BD=95=E7=BE=8E=E8=8D=A3?=
<10755671+mei-rong-he@user.noreply.gitee.com>
Date: Thu, 11 Sep 2025 19:03:19 +0800
Subject: [PATCH 1/3] 1
---
APT.BaseData.Domain/Enums/FM/FMEnums.cs | 2 +-
.../Controllers/FMUserController.cs | 204 +++++++++++++++++-
2 files changed, 201 insertions(+), 5 deletions(-)
diff --git a/APT.BaseData.Domain/Enums/FM/FMEnums.cs b/APT.BaseData.Domain/Enums/FM/FMEnums.cs
index 48ae9c5..f4abbc6 100644
--- a/APT.BaseData.Domain/Enums/FM/FMEnums.cs
+++ b/APT.BaseData.Domain/Enums/FM/FMEnums.cs
@@ -143,7 +143,7 @@ namespace APT.BaseData.Domain.Enums
///
/// 班组 20
///
- [Description("车间")]
+ [Description("班组")]
Class = 20,
}
diff --git a/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs b/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs
index 1d34b04..9821fb0 100644
--- a/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs
+++ b/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs
@@ -13,9 +13,14 @@ using APT.Migrations;
using APT.MS.Domain.Entities.BS;
using APT.MS.Domain.Entities.HM;
using APT.MS.Domain.Entities.PF;
+using APT.MS.Domain.Entities.SC.BI;
+using APT.MS.Domain.Entities.SK;
using APT.MS.Domain.Enums;
+using APT.MS.Domain.Enums.SK;
using APT.Utility;
using Microsoft.AspNetCore.Mvc;
+using NPOI.SS.Formula.Functions;
+using Org.BouncyCastle.Utilities.Collections;
using System;
using System.Collections.Generic;
using System.Data;
@@ -23,6 +28,7 @@ using System.IO;
using System.Linq;
using System.Linq.Expressions;
using System.Security.Cryptography;
+using static NPOI.HSSF.Util.HSSFColor;
namespace APT.BS.WebApi.Controllers.Api
{
@@ -733,12 +739,12 @@ namespace APT.BS.WebApi.Controllers.Api
//获取数据
Dictionary startRowIndexs = new Dictionary();
- startRowIndexs.Add(0, 0);//根据Excel格式数据赋值
+ startRowIndexs.Add(0, 1);//根据Excel格式数据赋值
DataSet dataTables = FileUtils.ReadExcelByOledb(filePath, startRowIndexs);
string Msg = string.Empty;
- bool isOK = InsertModel(dataTables.Tables[0], orgId.Value, telnetCode, ref Msg);
-
+ bool isOK = InsertModel(dataTables.Tables[0], orgId.Value, telnetCode, ref Msg);
+ //bool isOK = InsertModel2(dataTables.Tables[0], orgId.Value, telnetCode, ref Msg);
try
{
System.IO.File.Delete(filePath);
@@ -1670,6 +1676,196 @@ namespace APT.BS.WebApi.Controllers.Api
return true;
}
+ public bool InsertModel2(DataTable dtSource, Guid? orgId, string telnetCode, ref string Msg, int rowIndex = 1)
+ {
+ var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
+ if (dtSource == null || dtSource.Rows.Count < rowIndex)
+ {
+ Msg = "未获取到导入数据";
+ throw new Exception(Msg);
+ }
+ int rowAll = dtSource.Rows.Count;
+ List userLists = new List();
+ List userPersonLists = new List();
+ List userRoleLists = new List();
+ List userUnitLists = new List();
+ if (rowAll == 1)
+ {
+ throw new Exception("导入必须两条以上，一条请直接新增");
+ }
+ var departs = this.GetEntities(t => t.ENABLE_STATUS == 0, new BaseFilter(orgId));
+ var roles = this.GetEntities(t => t.IS_DELETED == false, new BaseFilter(orgId));
+ var units = this.GetEntities(t => t.CODE == "BSMineTypeEnum", new BaseFilter(orgId));
+ var posts = this.GetEntities(t => t.IS_DELETED == false, new BaseFilter(orgId));
+ var approves = this.GetEntities(t => t.IS_DELETED == false, new BaseFilter(orgId));
+ for (int i = 0; i < rowAll; i++)
+ {
+ var company = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][0].ToString().Trim());
+ var depart = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][1].ToString().Trim());
+ var shop = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][2].ToString().Trim());
+ var classFirst = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][3].ToString().Trim());
+ var post = posts.FirstOrDefault(t => t.NAME == dtSource.Rows[i][8].ToString().Trim());
+ Guid? depId = null;
+ int? minetype = 0;
+ if (classFirst != null)
+ {
+ depId = classFirst.ID;
+ minetype=classFirst.MineType;
+ }
+ else if (shop != null)
+ {
+ depId = shop.ID;
+ minetype = shop.MineType;
+ }
+ else if (depart != null)
+ {
+ depId = depart.ID;
+ minetype = depart.MineType;
+ }
+ else
+ {
+ depId = company.ID;
+ minetype = company.MineType;
+ }
+ var sex = dtSource.Rows[i][9].ToString().Trim();
+ T_FM_PERSON person = new T_FM_PERSON();
+ person.ID = Guid.NewGuid();
+ person.ORG_ID = orgId;
+ person.NAME = dtSource.Rows[i][4].ToString().Trim();
+ person.CODE = dtSource.Rows[i][5].ToString().Trim();
+ person.TEL = dtSource.Rows[i][6].ToString().Trim();
+ person.SEX = sex == "男" ? 1 : 0;
+ person.DEPARTMENT_ID = depId;
+ person.POST_ID = post?.ID;
+ userPersonLists.Add(person);
+ T_FM_USER user = new T_FM_USER();
+ user.ID = Guid.NewGuid();
+ user.ORG_ID = orgId;
+ user.PERSON_ID = person.ID;
+ user.NAME = dtSource.Rows[i][4].ToString().Trim();
+ user.CODE = dtSource.Rows[i][5].ToString().Trim();
+ user.PHONE = dtSource.Rows[i][6].ToString().Trim();
+ user.ID_CARD = dtSource.Rows[i][7].ToString().Trim();
+ user.DEPARTMENT_ID = depId;
+ user.SEX = sex == "男" ? 1 : 0;
+ user.MineType = minetype.ToString();
+ var inTime = dtSource.Rows[i][10].ToString().Trim();
+ if (string.IsNullOrEmpty(inTime))
+ {
+ inTime = DateTime.Now.ToShortTimeString();
+ }
+ user.ENTRYTIME = DateTime.Parse(inTime);
+ var yearInt = dtSource.Rows[i][11].ToString().Trim();
+ if (string.IsNullOrEmpty(yearInt))
+ {
+ yearInt = "0";
+ }
+ user.WORKINGYEAR = int.Parse(yearInt);
+ var approve = approves.FirstOrDefault(t => t.NAME == dtSource.Rows[i][12].ToString().Trim());
+ user.APPROVE_ROLE_ID = approve?.ID;
+ //if (!string.IsNullOrEmpty(user.NAME) && !string.IsNullOrEmpty(user.CODE))
+ //{
+ // MD5 md5 = MD5.Create();
+ // string code = DataHelper.GetCodeNO(user.CODE);
+ // string nameHead = DataHelper.MkPinyinString(user.NAME);
+ // string NewPwd = DataHelper.MD5Encrypt32(md5, nameHead + code);
+ // user.PASSWORD = NewPwd;
+ //}
+ userLists.Add(user);
+ #region 增加新增人员到ops表
+ using (var context = new MigrationContext(ConfigurationManager.ConnectionStrings["default"]))
+ {
+ var tennant = context.GetEntity(t => t.ID == orgId, new string[] { "CODE" }).CODE;
+ T_OP_ALLUSER alluser = new T_OP_ALLUSER();
+ alluser.ID = user.ID;
+ alluser.CODE = user.CODE;
+ alluser.TENANT = tennant;
+ alluser.ORG_ID = orgId;
+ alluser.PHONE = user.PHONE;
+ context.AddEntity(alluser);
+ context.SaveChanges();
+ }
+ #endregion
+ if (user.APPROVE_ROLE_ID != null)
+ {
+ var role1 = roles.FirstOrDefault(t => t.NAME == "负责人");
+ var role2 = roles.FirstOrDefault(t => t.NAME == "App用户");
+ if (role1 != null)
+ {
+ T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
+ belongRole.ID = Guid.NewGuid();
+ belongRole.USER_ID = user.ID;
+ belongRole.BELONG_ROLE_ID = role1.ID;
+ belongRole.ORG_ID = orgId;
+ userRoleLists.Add(belongRole);
+ }
+ if (role2 != null)
+ {
+ T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
+ belongRole.ID = Guid.NewGuid();
+ belongRole.USER_ID = user.ID;
+ belongRole.BELONG_ROLE_ID = role2.ID;
+ belongRole.ORG_ID = orgId;
+ userRoleLists.Add(belongRole);
+ }
+ }
+ else
+ {
+ var role1 = roles.FirstOrDefault(t => t.NAME == "作业员");
+ var role2 = roles.FirstOrDefault(t => t.NAME == "App用户");
+ if (role1 != null)
+ {
+ T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
+ belongRole.ID = Guid.NewGuid();
+ belongRole.USER_ID = user.ID;
+ belongRole.BELONG_ROLE_ID = role1.ID;
+ belongRole.ORG_ID = orgId;
+ userRoleLists.Add(belongRole);
+ }
+ if (role2 != null)
+ {
+ T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
+ belongRole.ID = Guid.NewGuid();
+ belongRole.USER_ID = user.ID;
+ belongRole.BELONG_ROLE_ID = role2.ID;
+ belongRole.ORG_ID = orgId;
+ userRoleLists.Add(belongRole);
+ }
+ }
+ var unit = units.FirstOrDefault(t => t.VALUE == minetype);
+ if (unit != null)
+ {
+ T_FM_USER_PRODUCTION_UNIT pro = new T_FM_USER_PRODUCTION_UNIT();
+ pro.ID = Guid.NewGuid();
+ pro.ORG_ID = orgId;
+ pro.USER_ID = user.ID;
+ pro.ENUMS_ID = unit.ID;
+ userUnitLists.Add(pro);
+ }
+ }
+ if (!string.IsNullOrEmpty(Msg))
+ {
+ throw new Exception(Msg);
+ }
+ else
+ {
+ UnifiedCommit(() =>
+ {
+ if (userLists != null && userLists.Any())
+ BantchAddEntityNoCommit(userLists);
+ if (userUnitLists != null && userUnitLists.Any())
+ BantchAddEntityNoCommit(userUnitLists);
+ if (userRoleLists != null && userRoleLists.Any())
+ BantchAddEntityNoCommit(userRoleLists);
+ if (userPersonLists != null && userPersonLists.Any())
+ BantchAddEntityNoCommit(userPersonLists);
+ });
+ Msg = "导入成功！";
+ }
+ return true;
+ }
#endregion
}
-}
\ No newline at end of file
+}
+
+
From 0a72c22bb10bafacf94d80f14cb5a9e858f7d32b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=BD=95=E7=BE=8E=E8=8D=A3?=
<10755671+mei-rong-he@user.noreply.gitee.com>
Date: Thu, 11 Sep 2025 19:04:26 +0800
Subject: [PATCH 2/3] 2
---
.../Controllers/FMUserController.cs | 189 +-----------------
1 file changed, 1 insertion(+), 188 deletions(-)
diff --git a/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs b/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs
index 9821fb0..dfc2b2f 100644
--- a/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs
+++ b/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs
@@ -1676,194 +1676,7 @@ namespace APT.BS.WebApi.Controllers.Api
return true;
}
- public bool InsertModel2(DataTable dtSource, Guid? orgId, string telnetCode, ref string Msg, int rowIndex = 1)
- {
- var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
- if (dtSource == null || dtSource.Rows.Count < rowIndex)
- {
- Msg = "未获取到导入数据";
- throw new Exception(Msg);
- }
- int rowAll = dtSource.Rows.Count;
- List userLists = new List();
- List userPersonLists = new List();
- List userRoleLists = new List();
- List userUnitLists = new List();
- if (rowAll == 1)
- {
- throw new Exception("导入必须两条以上，一条请直接新增");
- }
- var departs = this.GetEntities(t => t.ENABLE_STATUS == 0, new BaseFilter(orgId));
- var roles = this.GetEntities(t => t.IS_DELETED == false, new BaseFilter(orgId));
- var units = this.GetEntities(t => t.CODE == "BSMineTypeEnum", new BaseFilter(orgId));
- var posts = this.GetEntities(t => t.IS_DELETED == false, new BaseFilter(orgId));
- var approves = this.GetEntities(t => t.IS_DELETED == false, new BaseFilter(orgId));
- for (int i = 0; i < rowAll; i++)
- {
- var company = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][0].ToString().Trim());
- var depart = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][1].ToString().Trim());
- var shop = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][2].ToString().Trim());
- var classFirst = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][3].ToString().Trim());
- var post = posts.FirstOrDefault(t => t.NAME == dtSource.Rows[i][8].ToString().Trim());
- Guid? depId = null;
- int? minetype = 0;
- if (classFirst != null)
- {
- depId = classFirst.ID;
- minetype=classFirst.MineType;
- }
- else if (shop != null)
- {
- depId = shop.ID;
- minetype = shop.MineType;
- }
- else if (depart != null)
- {
- depId = depart.ID;
- minetype = depart.MineType;
- }
- else
- {
- depId = company.ID;
- minetype = company.MineType;
- }
- var sex = dtSource.Rows[i][9].ToString().Trim();
- T_FM_PERSON person = new T_FM_PERSON();
- person.ID = Guid.NewGuid();
- person.ORG_ID = orgId;
- person.NAME = dtSource.Rows[i][4].ToString().Trim();
- person.CODE = dtSource.Rows[i][5].ToString().Trim();
- person.TEL = dtSource.Rows[i][6].ToString().Trim();
- person.SEX = sex == "男" ? 1 : 0;
- person.DEPARTMENT_ID = depId;
- person.POST_ID = post?.ID;
- userPersonLists.Add(person);
- T_FM_USER user = new T_FM_USER();
- user.ID = Guid.NewGuid();
- user.ORG_ID = orgId;
- user.PERSON_ID = person.ID;
- user.NAME = dtSource.Rows[i][4].ToString().Trim();
- user.CODE = dtSource.Rows[i][5].ToString().Trim();
- user.PHONE = dtSource.Rows[i][6].ToString().Trim();
- user.ID_CARD = dtSource.Rows[i][7].ToString().Trim();
- user.DEPARTMENT_ID = depId;
- user.SEX = sex == "男" ? 1 : 0;
- user.MineType = minetype.ToString();
- var inTime = dtSource.Rows[i][10].ToString().Trim();
- if (string.IsNullOrEmpty(inTime))
- {
- inTime = DateTime.Now.ToShortTimeString();
- }
- user.ENTRYTIME = DateTime.Parse(inTime);
- var yearInt = dtSource.Rows[i][11].ToString().Trim();
- if (string.IsNullOrEmpty(yearInt))
- {
- yearInt = "0";
- }
- user.WORKINGYEAR = int.Parse(yearInt);
- var approve = approves.FirstOrDefault(t => t.NAME == dtSource.Rows[i][12].ToString().Trim());
- user.APPROVE_ROLE_ID = approve?.ID;
- //if (!string.IsNullOrEmpty(user.NAME) && !string.IsNullOrEmpty(user.CODE))
- //{
- // MD5 md5 = MD5.Create();
- // string code = DataHelper.GetCodeNO(user.CODE);
- // string nameHead = DataHelper.MkPinyinString(user.NAME);
- // string NewPwd = DataHelper.MD5Encrypt32(md5, nameHead + code);
- // user.PASSWORD = NewPwd;
- //}
- userLists.Add(user);
- #region 增加新增人员到ops表
- using (var context = new MigrationContext(ConfigurationManager.ConnectionStrings["default"]))
- {
- var tennant = context.GetEntity(t => t.ID == orgId, new string[] { "CODE" }).CODE;
- T_OP_ALLUSER alluser = new T_OP_ALLUSER();
- alluser.ID = user.ID;
- alluser.CODE = user.CODE;
- alluser.TENANT = tennant;
- alluser.ORG_ID = orgId;
- alluser.PHONE = user.PHONE;
- context.AddEntity(alluser);
- context.SaveChanges();
- }
- #endregion
- if (user.APPROVE_ROLE_ID != null)
- {
- var role1 = roles.FirstOrDefault(t => t.NAME == "负责人");
- var role2 = roles.FirstOrDefault(t => t.NAME == "App用户");
- if (role1 != null)
- {
- T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
- belongRole.ID = Guid.NewGuid();
- belongRole.USER_ID = user.ID;
- belongRole.BELONG_ROLE_ID = role1.ID;
- belongRole.ORG_ID = orgId;
- userRoleLists.Add(belongRole);
- }
- if (role2 != null)
- {
- T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
- belongRole.ID = Guid.NewGuid();
- belongRole.USER_ID = user.ID;
- belongRole.BELONG_ROLE_ID = role2.ID;
- belongRole.ORG_ID = orgId;
- userRoleLists.Add(belongRole);
- }
- }
- else
- {
- var role1 = roles.FirstOrDefault(t => t.NAME == "作业员");
- var role2 = roles.FirstOrDefault(t => t.NAME == "App用户");
- if (role1 != null)
- {
- T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
- belongRole.ID = Guid.NewGuid();
- belongRole.USER_ID = user.ID;
- belongRole.BELONG_ROLE_ID = role1.ID;
- belongRole.ORG_ID = orgId;
- userRoleLists.Add(belongRole);
- }
- if (role2 != null)
- {
- T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
- belongRole.ID = Guid.NewGuid();
- belongRole.USER_ID = user.ID;
- belongRole.BELONG_ROLE_ID = role2.ID;
- belongRole.ORG_ID = orgId;
- userRoleLists.Add(belongRole);
- }
- }
- var unit = units.FirstOrDefault(t => t.VALUE == minetype);
- if (unit != null)
- {
- T_FM_USER_PRODUCTION_UNIT pro = new T_FM_USER_PRODUCTION_UNIT();
- pro.ID = Guid.NewGuid();
- pro.ORG_ID = orgId;
- pro.USER_ID = user.ID;
- pro.ENUMS_ID = unit.ID;
- userUnitLists.Add(pro);
- }
- }
- if (!string.IsNullOrEmpty(Msg))
- {
- throw new Exception(Msg);
- }
- else
- {
- UnifiedCommit(() =>
- {
- if (userLists != null && userLists.Any())
- BantchAddEntityNoCommit(userLists);
- if (userUnitLists != null && userUnitLists.Any())
- BantchAddEntityNoCommit(userUnitLists);
- if (userRoleLists != null && userRoleLists.Any())
- BantchAddEntityNoCommit(userRoleLists);
- if (userPersonLists != null && userPersonLists.Any())
- BantchAddEntityNoCommit(userPersonLists);
- });
- Msg = "导入成功！";
- }
- return true;
- }
+
#endregion
}
}
From f68fe0fda56bb9f8043657a0ca0b2c81eebc36db Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=BD=95=E7=BE=8E=E8=8D=A3?=
<10755671+mei-rong-he@user.noreply.gitee.com>
Date: Thu, 11 Sep 2025 19:05:08 +0800
Subject: [PATCH 3/3] 3
---
.../Controllers/FMUserController.cs | 189 +++++++++++++++++-
1 file changed, 188 insertions(+), 1 deletion(-)
diff --git a/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs b/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs
index dfc2b2f..f5f0921 100644
--- a/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs
+++ b/APT.MicroApi/APT.FM.WebApi/Controllers/FMUserController.cs
@@ -1676,7 +1676,194 @@ namespace APT.BS.WebApi.Controllers.Api
return true;
}
-
+ public bool InsertModel2(DataTable dtSource, Guid? orgId, string telnetCode, ref string Msg, int rowIndex = 1)
+ {
+ var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
+ if (dtSource == null || dtSource.Rows.Count < rowIndex)
+ {
+ Msg = "未获取到导入数据";
+ throw new Exception(Msg);
+ }
+ int rowAll = dtSource.Rows.Count;
+ List userLists = new List();
+ List userPersonLists = new List();
+ List userRoleLists = new List();
+ List userUnitLists = new List();
+ if (rowAll == 1)
+ {
+ throw new Exception("导入必须两条以上，一条请直接新增");
+ }
+ var departs = this.GetEntities(t => t.ENABLE_STATUS == 0, new BaseFilter(orgId));
+ var roles = this.GetEntities(t => t.IS_DELETED == false, new BaseFilter(orgId));
+ var units = this.GetEntities(t => t.CODE == "BSMineTypeEnum", new BaseFilter(orgId));
+ var posts = this.GetEntities(t => t.IS_DELETED == false, new BaseFilter(orgId));
+ var approves = this.GetEntities(t => t.IS_DELETED == false, new BaseFilter(orgId));
+ for (int i = 0; i < rowAll; i++)
+ {
+ var company = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][0].ToString().Trim());
+ var depart = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][1].ToString().Trim());
+ var shop = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][2].ToString().Trim());
+ var classFirst = departs.FirstOrDefault(t => t.NAME == dtSource.Rows[i][3].ToString().Trim());
+ var post = posts.FirstOrDefault(t => t.NAME == dtSource.Rows[i][8].ToString().Trim());
+ Guid? depId = null;
+ int? minetype = 0;
+ if (classFirst != null)
+ {
+ depId = classFirst.ID;
+ minetype = classFirst.MineType;
+ }
+ else if (shop != null)
+ {
+ depId = shop.ID;
+ minetype = shop.MineType;
+ }
+ else if (depart != null)
+ {
+ depId = depart.ID;
+ minetype = depart.MineType;
+ }
+ else
+ {
+ depId = company.ID;
+ minetype = company.MineType;
+ }
+ var sex = dtSource.Rows[i][9].ToString().Trim();
+ T_FM_PERSON person = new T_FM_PERSON();
+ person.ID = Guid.NewGuid();
+ person.ORG_ID = orgId;
+ person.NAME = dtSource.Rows[i][4].ToString().Trim();
+ person.CODE = dtSource.Rows[i][5].ToString().Trim();
+ person.TEL = dtSource.Rows[i][6].ToString().Trim();
+ person.SEX = sex == "男" ? 1 : 0;
+ person.DEPARTMENT_ID = depId;
+ person.POST_ID = post?.ID;
+ userPersonLists.Add(person);
+ T_FM_USER user = new T_FM_USER();
+ user.ID = Guid.NewGuid();
+ user.ORG_ID = orgId;
+ user.PERSON_ID = person.ID;
+ user.NAME = dtSource.Rows[i][4].ToString().Trim();
+ user.CODE = dtSource.Rows[i][5].ToString().Trim();
+ user.PHONE = dtSource.Rows[i][6].ToString().Trim();
+ user.ID_CARD = dtSource.Rows[i][7].ToString().Trim();
+ user.DEPARTMENT_ID = depId;
+ user.SEX = sex == "男" ? 1 : 0;
+ user.MineType = minetype.ToString();
+ var inTime = dtSource.Rows[i][10].ToString().Trim();
+ if (string.IsNullOrEmpty(inTime))
+ {
+ inTime = DateTime.Now.ToShortTimeString();
+ }
+ user.ENTRYTIME = DateTime.Parse(inTime);
+ var yearInt = dtSource.Rows[i][11].ToString().Trim();
+ if (string.IsNullOrEmpty(yearInt))
+ {
+ yearInt = "0";
+ }
+ user.WORKINGYEAR = int.Parse(yearInt);
+ var approve = approves.FirstOrDefault(t => t.NAME == dtSource.Rows[i][12].ToString().Trim());
+ user.APPROVE_ROLE_ID = approve?.ID;
+ //if (!string.IsNullOrEmpty(user.NAME) && !string.IsNullOrEmpty(user.CODE))
+ //{
+ // MD5 md5 = MD5.Create();
+ // string code = DataHelper.GetCodeNO(user.CODE);
+ // string nameHead = DataHelper.MkPinyinString(user.NAME);
+ // string NewPwd = DataHelper.MD5Encrypt32(md5, nameHead + code);
+ // user.PASSWORD = NewPwd;
+ //}
+ userLists.Add(user);
+ #region 增加新增人员到ops表
+ using (var context = new MigrationContext(ConfigurationManager.ConnectionStrings["default"]))
+ {
+ var tennant = context.GetEntity(t => t.ID == orgId, new string[] { "CODE" }).CODE;
+ T_OP_ALLUSER alluser = new T_OP_ALLUSER();
+ alluser.ID = user.ID;
+ alluser.CODE = user.CODE;
+ alluser.TENANT = tennant;
+ alluser.ORG_ID = orgId;
+ alluser.PHONE = user.PHONE;
+ context.AddEntity(alluser);
+ context.SaveChanges();
+ }
+ #endregion
+ if (user.APPROVE_ROLE_ID != null)
+ {
+ var role1 = roles.FirstOrDefault(t => t.NAME == "负责人");
+ var role2 = roles.FirstOrDefault(t => t.NAME == "App用户");
+ if (role1 != null)
+ {
+ T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
+ belongRole.ID = Guid.NewGuid();
+ belongRole.USER_ID = user.ID;
+ belongRole.BELONG_ROLE_ID = role1.ID;
+ belongRole.ORG_ID = orgId;
+ userRoleLists.Add(belongRole);
+ }
+ if (role2 != null)
+ {
+ T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
+ belongRole.ID = Guid.NewGuid();
+ belongRole.USER_ID = user.ID;
+ belongRole.BELONG_ROLE_ID = role2.ID;
+ belongRole.ORG_ID = orgId;
+ userRoleLists.Add(belongRole);
+ }
+ }
+ else
+ {
+ var role1 = roles.FirstOrDefault(t => t.NAME == "作业员");
+ var role2 = roles.FirstOrDefault(t => t.NAME == "App用户");
+ if (role1 != null)
+ {
+ T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
+ belongRole.ID = Guid.NewGuid();
+ belongRole.USER_ID = user.ID;
+ belongRole.BELONG_ROLE_ID = role1.ID;
+ belongRole.ORG_ID = orgId;
+ userRoleLists.Add(belongRole);
+ }
+ if (role2 != null)
+ {
+ T_FM_USER_BELONG_ROLE belongRole = new T_FM_USER_BELONG_ROLE();
+ belongRole.ID = Guid.NewGuid();
+ belongRole.USER_ID = user.ID;
+ belongRole.BELONG_ROLE_ID = role2.ID;
+ belongRole.ORG_ID = orgId;
+ userRoleLists.Add(belongRole);
+ }
+ }
+ var unit = units.FirstOrDefault(t => t.VALUE == minetype);
+ if (unit != null)
+ {
+ T_FM_USER_PRODUCTION_UNIT pro = new T_FM_USER_PRODUCTION_UNIT();
+ pro.ID = Guid.NewGuid();
+ pro.ORG_ID = orgId;
+ pro.USER_ID = user.ID;
+ pro.ENUMS_ID = unit.ID;
+ userUnitLists.Add(pro);
+ }
+ }
+ if (!string.IsNullOrEmpty(Msg))
+ {
+ throw new Exception(Msg);
+ }
+ else
+ {
+ UnifiedCommit(() =>
+ {
+ if (userLists != null && userLists.Any())
+ BantchAddEntityNoCommit(userLists);
+ if (userUnitLists != null && userUnitLists.Any())
+ BantchAddEntityNoCommit(userUnitLists);
+ if (userRoleLists != null && userRoleLists.Any())
+ BantchAddEntityNoCommit(userRoleLists);
+ if (userPersonLists != null && userPersonLists.Any())
+ BantchAddEntityNoCommit(userPersonLists);
+ });
+ Msg = "导入成功！";
+ }
+ return true;
+ }
#endregion
}
}