| | |
| | | using Castle.Core.Resource; |
| | | using MES.Service.DB; |
| | | using MES.Service.DB; |
| | | using MES.Service.Dto.webApi; |
| | | using MES.Service.Modes; |
| | | using SqlSugar; |
| | |
| | | } |
| | | |
| | | // 插入或更新员工的方法 |
| | | private bool InsertOrUpdateStaff(SqlSugarScope db, SysUser sysUser, |
| | | private bool InsertOrUpdateStaff(SqlSugarScope db, SysUser sysUser, |
| | | MesStaff entity) |
| | | { |
| | | var exists = db.Queryable<SysUser>().Any(u => u.Sid == sysUser.Sid); |
| | |
| | | var updateUser = db.Updateable<SysUser>() |
| | | .SetColumns(s => s.Fcode == sysUser.Fcode) |
| | | .SetColumns(s => s.Fname == sysUser.Fname) |
| | | .SetColumns(s => s.ErpUpdaeDate == DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") ) |
| | | .SetColumns(s => |
| | | s.ErpUpdaeDate == |
| | | DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")) |
| | | .Where(s => s.Sid == sysUser.Sid) |
| | | .ExecuteCommand(); |
| | | if (updateUser > 0) |
| | |
| | | |
| | | return false; |
| | | } |
| | | /* private bool InsertOrUpdateStaff(SqlSugarScope db, SysUser sysUser, MesStaff entity) |
| | | { |
| | | try |
| | | { |
| | | // 检查用户是否存在 |
| | | var userExists = db.Queryable<SysUser>().Any(u => u.Sid == sysUser.Sid); |
| | | if (userExists) |
| | | { |
| | | // 更新用户 |
| | | var updateUser = db.Updateable<SysUser>() |
| | | .SetColumns(s => new SysUser |
| | | { |
| | | Fcode = sysUser.Fcode, |
| | | Fname = sysUser.Fname |
| | | }) |
| | | .Where(s => s.Sid == sysUser.Sid) |
| | | .ExecuteCommand(); |
| | | /* private bool InsertOrUpdateStaff(SqlSugarScope db, SysUser sysUser, MesStaff entity) |
| | | { |
| | | try |
| | | { |
| | | // 检查用户是否存在 |
| | | var userExists = db.Queryable<SysUser>().Any(u => u.Sid == sysUser.Sid); |
| | | if (userExists) |
| | | { |
| | | // 更新用户 |
| | | var updateUser = db.Updateable<SysUser>() |
| | | .SetColumns(s => new SysUser |
| | | { |
| | | Fcode = sysUser.Fcode, |
| | | Fname = sysUser.Fname |
| | | }) |
| | | .Where(s => s.Sid == sysUser.Sid) |
| | | .ExecuteCommand(); |
| | | |
| | | if (updateUser > 0) |
| | | { |
| | | // 检查员工是否已存在 |
| | | var staffExists = db.Queryable<MesStaff>().Any(s => s.Id == entity.Id); |
| | | if (staffExists) |
| | | { |
| | | // 更新员工 |
| | | var updateStaff = db.Updateable(entity).Where(s => s.Id == entity.Id).ExecuteCommand(); |
| | | if (updateStaff > 0) |
| | | return true; |
| | | } |
| | | else |
| | | { |
| | | // 插入员工 |
| | | var insertStaff = db.Insertable(entity).ExecuteCommand(); |
| | | if (insertStaff > 0) |
| | | return true; |
| | | } |
| | | } |
| | | } |
| | | else |
| | | { |
| | | // 插入用户 |
| | | var insertUser = db.Insertable(sysUser).ExecuteCommand(); |
| | | if (insertUser > 0) |
| | | { |
| | | // 插入员工 |
| | | var staffExists = db.Queryable<MesStaff>().Any(s => s.Id == entity.Id); |
| | | if (!staffExists) |
| | | { |
| | | var insertStaff = db.Insertable(entity).ExecuteCommand(); |
| | | if (insertStaff > 0) |
| | | return true; |
| | | } |
| | | else |
| | | { |
| | | // 如果员工已存在,可以选择更新或抛出异常 |
| | | throw new Exception("员工记录已存在,无法插入重复记录。"); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | // 记录日志或处理异常 |
| | | Console.WriteLine($"Error: {ex.Message}"); |
| | | } |
| | | if (updateUser > 0) |
| | | { |
| | | // 检查员工是否已存在 |
| | | var staffExists = db.Queryable<MesStaff>().Any(s => s.Id == entity.Id); |
| | | if (staffExists) |
| | | { |
| | | // 更新员工 |
| | | var updateStaff = db.Updateable(entity).Where(s => s.Id == entity.Id).ExecuteCommand(); |
| | | if (updateStaff > 0) |
| | | return true; |
| | | } |
| | | else |
| | | { |
| | | // 插入员工 |
| | | var insertStaff = db.Insertable(entity).ExecuteCommand(); |
| | | if (insertStaff > 0) |
| | | return true; |
| | | } |
| | | } |
| | | } |
| | | else |
| | | { |
| | | // 插入用户 |
| | | var insertUser = db.Insertable(sysUser).ExecuteCommand(); |
| | | if (insertUser > 0) |
| | | { |
| | | // 插入员工 |
| | | var staffExists = db.Queryable<MesStaff>().Any(s => s.Id == entity.Id); |
| | | if (!staffExists) |
| | | { |
| | | var insertStaff = db.Insertable(entity).ExecuteCommand(); |
| | | if (insertStaff > 0) |
| | | return true; |
| | | } |
| | | else |
| | | { |
| | | // 如果员工已存在,可以选择更新或抛出异常 |
| | | throw new Exception("员工记录已存在,无法插入重复记录。"); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | | // 记录日志或处理异常 |
| | | Console.WriteLine($"Error: {ex.Message}"); |
| | | } |
| | | |
| | | return false; |
| | | } |
| | | */ |
| | | return false; |
| | | } |
| | | */ |
| | | |
| | | // 删除员工的方法 |
| | | private bool DeleteStaff(SqlSugarScope db, SysUser sysUser, decimal staffId) |
| | |
| | | Tet = 0, |
| | | Prd = 1, |
| | | Departmentid = staff.FPostDept, |
| | | CreateDate = DateTime.Now //当前时间 |
| | | |
| | | CreateDate = DateTime.Now //当前时间 |
| | | }; |
| | | } |
| | | |