MeiXinLaiRui/ShenSuoGanKongZhi.git

			@@ -15,6 +15,7 @@
			using WIDESEAWCS_DTO.Telescopic;
			using SqlSugar.DistributedSystem.Snowflake;
			using System.IO;
			using System.Net;

			namespace WIDESEAWCS_TelescopicService
			{
			@@ -22,14 +23,16 @@
			{
			public IRepository<Dt_Maintenance> Repository => BaseDal;
			public readonly IRepository<Dt_MaintenanceTeam> _team;
			private readonly IRepository<Dt_CustomIPaddress> _ipaddress;
			private readonly IRepository<Sys_User> _user;



			public MaintenanceService(IRepository<Dt_Maintenance> BaseDal, IRepository<Sys_User> user, IRepository<Dt_MaintenanceTeam> team) : base(BaseDal)
			public MaintenanceService(IRepository<Dt_CustomIPaddress>ipaddress,IRepository<Dt_Maintenance> BaseDal, IRepository<Sys_User> user, IRepository<Dt_MaintenanceTeam> team) : base(BaseDal)
			{
			_user = user;
			_team = team;

			_ipaddress = ipaddress;
			}


			@@ -111,100 +114,107 @@


			/// <summary>
			/// 人员监控
			/// 人员监控（数字大屏）
			/// </summary>
			/// <param name="pageIndex"></param>
			/// <param name="pageSize"></param>
			/// <param name="searchKeyword"></param>
			/// <returns></returns>(这个没有用到了)
			/// <returns></returns>
			//public WebResponseContent PersonnelMonitoring(PaginationDTO pagination)
			//{
			// try
			// {
			// int totalCount = 0;
			// var sys = _user.Db.Queryable<Sys_User>();


			// var query = sys.InnerJoin<Dt_Maintenance>((a, b) => a.UserName == b.UserAccount)
			// .RightJoin<Dt_CustomIPaddress>((a,b,c)=>b.IPAddress==c.IPaddress)
			// .Where((a, b) => b.MaintenanceStatus==1); // 展示运行检修的

			// // 搜索关键字
			// if (!string.IsNullOrEmpty(pagination.searchKeyword))
			// {
			// query = query.Where((a, b) =>
			// a.UserTrueName.Contains(pagination.searchKeyword) \|\|
			// a.Userteam.Contains(pagination.searchKeyword));
			// }

			// var result = query
			// .Select((a, b,c) => new
			// {
			// b.UserAccount,//账号
			// a.UserTrueName,
			// a.Userteam,//班组
			// a.Unit,//单位
			// a.RoleName,//角色名称
			// //b.IPAddress,//站台
			// IPAddress = c.Addressname ?? b.IPAddress, // 优先显示自定义名称
			// b.ID,//id
			// b.MaintenanceStatus,//检修状态
			// b.CreateDate,//日期
			// b.MaintenancStartTime,//开始时间
			// })
			// .ToPageList(pagination.pageIndex, pagination.pageSize, ref totalCount);

			// return new WebResponseContent
			// {
			// Status = true,
			// Data = new
			// {
			// TotalCount = totalCount,
			// PageIndex = pagination.pageIndex,
			// PageSize = pagination.pageSize,
			// Items = result
			// }
			// };
			// }
			// catch (Exception ex)
			// {
			// return new WebResponseContent { Status = false, Data = ex.Message };
			// }
			//}
			public WebResponseContent PersonnelMonitoring(PaginationDTO pagination)
			{
			try
			{
			// 第一步：自动清理过期检修状态
			var today = DateTime.Today;
			var recordsToUpdate = Db.Queryable<Dt_Maintenance>()
			.Where(b => b.MaintenanceDate != null &&
			b.MaintenanceDate.Value.Date < today )
			.ToList();

			if (recordsToUpdate.Count > 0)
			{
			foreach (var record in recordsToUpdate)//更新
			{
			record.MaintenanceDate = null;//清空检修日期
			record.MaintenancStartTime = null;//清空开始时间
			record.MaintenancEendTime = null;//清空结束时间
			record.MaintenanceStatus = 0; // Set to false
			record.IsPossible = "NULL"; //更改状态为false不运行检修//默认为NULL
			}
			Db.Updateable(recordsToUpdate).ExecuteCommand();
			}

			int totalCount = 0;
			var sys = _user.Db.Queryable<Sys_User>();
			var main = Db.Queryable<Dt_Maintenance>();

			var query = sys.InnerJoin<Dt_Maintenance>((a, b) => a.UserName == b.UserAccount)
			.Where((a, b) => b.IsPossible == "true"); // 展示运行检修的
			var query = _user.Db.Queryable<Dt_Maintenance>()
			.Where(b => b.MaintenanceStatus == 1)
			.InnerJoin<Sys_User>((b, a) => b.UserAccount == a.UserName)
			.LeftJoin<Dt_CustomIPaddress>((b, a, c) => b.IPAddress == c.IPaddress);

			// 搜索关键字
			if (!string.IsNullOrEmpty(pagination.searchKeyword))
			{
			query = query.Where((a, b) =>
			query = query.Where((b, a, c) =>
			a.UserTrueName.Contains(pagination.searchKeyword) \|\|
			a.Userteam.Contains(pagination.searchKeyword));
			}

			// 状态参数
			if (pagination.status.HasValue)
			var result = query.Select((b, a, c) => new
			{
			query = query.Where((a, b) => b.MaintenanceStatus == pagination.status.Value);
			}

			// 如果不是管理员，请按部门过滤
			if (pagination.account != "admin")
			{
			var currentUser = _user.Db.Queryable<Sys_User>()
			.Where(u => u.UserName == pagination.account)
			.First();

			if (currentUser == null)
			{
			return new WebResponseContent { Status = false, Data = "未获取到用户信息" };
			}

			int? deptId = currentUser.Dept_Id;
			query = query.Where((a, b) => a.Dept_Id == deptId);
			}

			var result = query
			.Select((a, b) => new
			{
			a.UserTrueName,
			a.Userteam,
			a.HeadImageUrl,
			b.MaintenanceStatus,
			b.MaintenanceDate,
			b.IsPossible,
			})
			.ToPageList(pagination.pageIndex, pagination.pageSize, ref totalCount);
			b.UserAccount,
			a.UserTrueName,
			a.Userteam,
			a.Unit,
			a.RoleName,
			IPAddress = c.Addressname ?? b.IPAddress ?? "无IP",
			b.ID,
			b.MaintenanceStatus,
			b.CreateDate,
			b.MaintenancStartTime
			}).ToPageList(pagination.pageIndex, pagination.pageSize, ref totalCount);

			return new WebResponseContent
			{
			Status = true,
			Data = new
			{
			TotalCount = totalCount,
			PageIndex = pagination.pageIndex,
			PageSize = pagination.pageSize,
			Items = result
			}
			Data = new { totalCount, pagination.pageIndex, pagination.pageSize, result }
			};
			}
			catch (Exception ex)
			{
			return new WebResponseContent { Status = false, Data = ex.Message };
			return new WebResponseContent { Status = false, Message = ex.Message };
			}
			}

			@@ -213,48 +223,62 @@


			/// <summary>
			/// 更新状态是否允许进入检修（添加了检修记录）
			/// 更新状态强制下线（添加了检修记录
			/// </summary>
			/// <param name="id"></param>
			/// <param name="ispossible"></param>
			/// <param name="id">要强制谁下线</param>
			/// <param name="account">登入人员账号</param>
			/// <param name="LocalIP">地址ip</param>
			/// <returns></returns>
			public WebResponseContent RunOperation(int id, string ispossible)
			public WebResponseContent RunOperation(int id, string account, string LocalIP)
			{
			try
			{
			var mon = BaseDal.QueryFirst(x => x.ID == id);
			if (mon == null)
			// 1. 查找目标用户（要被强制下线的人）
			var maint = BaseDal.QueryData().FirstOrDefault(x => x.ID == id);
			var sysuer = _user.QueryData(x => x.UserName == maint.UserAccount).FirstOrDefault();//user表
			if (maint == null \|\| sysuer==null)
			{
			return new WebResponseContent { Status = false, Message = "无法更改，没有找到该用户" };
			return new WebResponseContent { Status = false, Message = "没有找到该用户" };
			}
			var sysuer = _user.QueryData(x => x.UserName == mon.UserAccount).FirstOrDefault();
			if (ispossible == "true")
			{
			mon.IsPossible = "true";
			mon.MaintenanceDate = DateTime.Now;
			BaseDal.UpdateData(mon);
			var recording = new Dt_MaintenanceTeam //添加记录
			{
			OperatorName = sysuer.UserTrueName,
			TeamName = sysuer.RoleName,
			DistributionTime = DateTime.Now,
			Creater = "admin",
			CreateDate = DateTime.Now,


			};
			_team.AddData(recording);
			}
			else
			// 2. 查找当前登录用户（执行操作的人）
			var currentUser = _user.QueryData(x => x.UserName == account).FirstOrDefault();
			if (currentUser == null)
			{
			mon.IsPossible = "false";
			BaseDal.UpdateData(mon);
			return new WebResponseContent { Status = false, Message = "当前登录用户无效" };
			}
			return new WebResponseContent { Status = true, Data = mon };

			// 3. 权限检查：当前用户是 admin 或当前用户是组长（IsLeader == 1）
			bool isAdmin = account == "admin";
			bool isLeader = currentUser.IsLeader == 1; // 假设 Sys_User 表有 IsLeader 字段

			if (!isAdmin && !isLeader)
			{
			return new WebResponseContent { Status = false, Message = "你没有权限强制下线" };
			}

			// 4. 执行强制下线
			maint.MaintenanceStatus = 0; // 改变状态为下线
			BaseDal.UpdateData(maint);

			// 5. 记录操作日志
			var recording = new Dt_MaintenanceTeam
			{
			Account = maint.UserAccount,
			MaintenanceStatus = 0,
			OperatorName = sysuer.UserTrueName, // 操作人姓名
			TeamName = sysuer.RoleName, // 操作人角色
			DistributionTime = DateTime.Now,
			IPAddress = LocalIP,
			};
			_team.AddData(recording);

			return new WebResponseContent { Status = true, Message = "强制下线成功" };
			}
			catch (Exception ex)
			{

			return new WebResponseContent { Status = false, Message = "失败：" + ex };
			return new WebResponseContent { Status = false, Message = "失败：" + ex.Message };
			}
			}

			@@ -590,11 +614,12 @@
			var user = BaseDal.QueryData();//检修表
			var maint = user.Where(x => x.UserAccount == account).FirstOrDefault(); //在检修表中先找到该用户
			var sysuer = _user.QueryData(x => x.UserName == account).FirstOrDefault();//在用户表中找到用户

			if (maint == null \|\| sysuer == null)
			{
			return new WebResponseContent { Status = false, Message = "没有找到该用户" };
			}
			// 查找该用户在 _team 表中的最新一条记录
			// 查找该用户在 Dt_MaintenanceTeam 表中的最新一条记录
			var lastRecord = _team.QueryData(x => x.Account == account)
			.OrderByDescending(x => x.CreateDate)
			.FirstOrDefault();
			@@ -610,18 +635,25 @@
			bool leaderStarted = user.Any(x => x.IsLeader == 1 && x.MaintenanceStatus == 1); //否有满足条件找到一条就返回true MaintenanceStatus（0没有开始，1开始）
			if (!leaderStarted)
			{
			return new WebResponseContent { Status = false, Message = "请等待组长开始检修" };
			return new WebResponseContent { Status = false, Message = "请等待一级人员开始检修" };
			}

			}
			if (true)
			{

			}
			//如果满足下面的条件就开始
			maint.MaintenancStartTime = DateTime.Now;//记录开始时间
			maint.MaintenanceStatus = 1;//更改状态
			maint.IPAddress = LocalIP;//更改ip地址
			BaseDal.UpdateData(maint);
			var address = _ipaddress.QueryData(x=>x.IPaddress== LocalIP).FirstOrDefault();
			var addressIp = "";
			if (address!=null) //找到了
			{
			addressIp = address.Addressname;
			}
			else
			{
			addressIp = LocalIP;
			}
			//插入记录表
			var recording = new Dt_MaintenanceTeam //添加记录
			{
			@@ -630,7 +662,7 @@
			OperatorName = sysuer.UserTrueName,
			TeamName = sysuer.RoleName,
			DistributionTime = DateTime.Now,
			IPAddress = LocalIP,
			IPAddress = addressIp,
			};
			_team.AddData(recording);

			@@ -642,19 +674,19 @@
			}
			}


			/// <summary>
			/// 结束检修
			/// </summary>MaintenanceStatus 0代表检修完成 1代表检修中
			/// </summary>
			/// <param name="account"></param>
			/// <returns></returns>
			public WebResponseContent StopMaintenanceTask(string account)
			public WebResponseContent StopMaintenanceTask(string account,string LocalIP)
			{
			try
			{
			var user = BaseDal.QueryData();//检修表
			var user = BaseDal.QueryData(); // 检修表
			var maint = user.Where(x => x.UserAccount == account).FirstOrDefault();
			var sysuer = _user.QueryData(x => x.UserName == account).FirstOrDefault();//用户表
			var sysuer = _user.QueryData(x => x.UserName == account).FirstOrDefault(); // 用户表

			if (maint == null \|\| sysuer == null)
			{
			return new WebResponseContent { Status = false, Message = "没有找到该用户" };
			@@ -662,35 +694,63 @@

			// 查找该用户在 _team 表中的最新一条记录
			var lastRecord = _team.QueryData(x => x.Account == account)
			.OrderByDescending(x => x.CreateDate)
			.FirstOrDefault();
			.OrderByDescending(x => x.CreateDate)
			.FirstOrDefault();

			if (lastRecord == null \|\| lastRecord.MaintenanceStatus != 1)
			{
			return new WebResponseContent { Status = false, Message = "你还没有开始检修，请先点击开始检修" };
			}

			if (maint.IsLeader == 1)//如果该用户是班长，那么要等全部人都检修完成，他才可以结束检修
			// 检查是否至少有一个组长在场
			var activeLeaders = user.Where(x => x.IsLeader == 1 && x.MaintenanceStatus == 1).ToList();

			// 如果当前用户是组长
			if (maint.IsLeader == 1)
			{
			//先查找所有用户的组是那个组的，组员状态有一个不是1
			// 查找同组未完成的组员（IsLeader=0 && MaintenanceStatus=1）
			var hasUnfinishedMembers = user.Where(x =>x.IsLeader == 0 &&x.MaintenanceStatus == 1).ToList(); //：Any()有一个满足就返回true表示存在满足条件的记录
			if (hasUnfinishedMembers.Count>0)
			// 如果是最后一个在场的组长
			if (activeLeaders.Count == 1 && activeLeaders[0].UserAccount == account)
			{
			return new WebResponseContent { Status = false, Message = "还有组员未完成当前批次检修" };
			// 检查是否还有未完成的组员
			var unfinishedMembers = user.Where(x => x.IsLeader == 0 && x.MaintenanceStatus == 1).Any();
			if (unfinishedMembers)
			{
			return new WebResponseContent
			{
			Status = false,
			Message = "您是最后一个在场的组长，请等待所有组员完成检修后再结束"
			};
			}
			}
			}
			//如果满足下面的条件就开始
			maint.MaintenancEendTime = DateTime.Now;//记录结束时间
			maint.MaintenanceStatus = 0;//更改状态
			//if (LocalIP!=maint.IPAddress)
			//{
			// return new WebResponseContent { Status = false, Message = "操作设备不同，请回到原本设备再点击结束检修" };
			//}
			var address = _ipaddress.QueryData(x => x.IPaddress == LocalIP).FirstOrDefault();
			var addressIp = "";
			if (address != null) //找到了
			{
			addressIp = address.Addressname;
			}
			else
			{
			addressIp = LocalIP;
			}

			// 更新当前用户的检修状态
			maint.MaintenancEendTime = DateTime.Now; // 记录结束时间
			maint.MaintenanceStatus = 0; // 更改状态
			BaseDal.UpdateData(maint);
			////插入记录表
			var recording = new Dt_MaintenanceTeam //添加记录

			// 插入记录表
			var recording = new Dt_MaintenanceTeam // 添加记录
			{
			Account = account,
			MaintenanceStatus=0,
			MaintenanceStatus = 0,
			OperatorName = sysuer.UserTrueName,
			TeamName = sysuer.RoleName,
			IPAddress = addressIp,
			EndTime = DateTime.Now,
			};
			_team.AddData(recording);