yanjinhui
2025-06-05 fcd49db2ee33ee2e1d33e5a41e53d9897a8a3b0f
project/WCS/WIDESEAWCS_Server/WIDESEAWCS_TelescopicService/MaintenanceService.cs
@@ -23,11 +23,13 @@
        public IRepository<Dt_Maintenance> Repository => BaseDal;
        public readonly IRepository<Dt_MaintenanceTeam> _team;
        private readonly IRepository<Sys_User> _user;
        public MaintenanceService(IRepository<Dt_Maintenance> BaseDal, IRepository<Sys_User> user, IRepository<Dt_MaintenanceTeam> team) : base(BaseDal)
        {
            _user = user;
            _team = team;
            _team = team;
        }
@@ -114,7 +116,7 @@
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <param name="searchKeyword"></param>
        /// <returns></returns>
        /// <returns></returns>(这个没有用到了)
        public WebResponseContent PersonnelMonitoring(PaginationDTO pagination)
        {
            try
@@ -351,23 +353,7 @@
                  query=query.OrderByDescending((a, b) => b.Creater);
                }
                // 如果不是管理员,根据部门过滤
                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
                {
@@ -487,35 +473,52 @@
        //}
        ///// <summary>
        ///// 开始检修
        ///// </summary>
        ///// <param name="account"></param>
        ///// <returns></returns>(班长-普通员工)
        //public WebResponseContent StartMaintenceTask(string account)
        ///// <param name="account">账号</param>
        ///// <param name="LocalIP">那台电脑登入的ip地址</param>
        ///// <returns></returns>
        //public WebResponseContent StartMaintenceTask(string account,string LocalIP)
        //{
        //    try
        //    {
        //        var today = DateTime.Today;               // 今天的零点
        //        var tomorrow = today.AddDays(1);         // 明天的零点
        //        var maint = BaseDal.QueryData(x =>
        //            x.UserAccount == account &&
        //            x.IsPossible == "true" &&
        //            x.MaintenanceDate >= today &&
        //            x.MaintenanceDate < tomorrow
        //        ).FirstOrDefault();
        //        if (maint == null)
        //        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 = "未找到今日的维护任务记录" };
        //            return new WebResponseContent { Status = false, Message = "没有找到该用户" };
        //        }
        //        if (maint.IsLeader!=1)//如果该用户不是班长,那么要等班长先做,他才可以做
        //        {
        //            bool leaderStarted = user.Any(x =>x.Roleid == maint.Roleid &&x.IsLeader == 1 &&x.MaintenanceStatus == 1); //没找到肯定是false
        //            if (!leaderStarted)
        //            {
        //                return new WebResponseContent { Status = false, Message = "请等待组长开始检修" };
        //            }
        //        maint.MaintenancStartTime = DateTime.Now;
        //        }
        //       //如果满足下面的条件就开始
        //        maint.MaintenancStartTime = DateTime.Now;//记录开始时间
        //        maint.MaintenanceStatus = 1;//更改状态
        //        BaseDal.UpdateData(maint);
        //        //插入记录表
        //        var recording = new Dt_MaintenanceTeam  //添加记录
        //        {
        //            OperatorName = sysuer.UserTrueName,
        //            TeamName = sysuer.RoleName,
        //            DistributionTime = DateTime.Now,
        //            IPAddress= LocalIP,
        //            //Creater = "admin",
        //            //CreateDate = DateTime.Now,
        //        };
        //        _team.AddData(recording);
        //        return new WebResponseContent { Status = true, Data = maint };
        //        return new WebResponseContent { Status = true, Data = maint,Message="开始检修" };
        //    }
        //    catch (Exception ex)
        //    {
@@ -526,36 +529,52 @@
        ///// <summary>
        ///// 结束检修
        ///// </summary>
        ///// </summary>MaintenanceStatus 0代表检修完成  1代表检修中
        ///// <param name="account"></param>
        ///// <returns></returns>
        //public WebResponseContent StopMaintenanceTask(string account)
        //{
        //    try
        //    {
        //        var today = DateTime.Today;               // 今天的零点
        //        var tomorrow = today.AddDays(1);         // 明天的零点
        //        var maint = BaseDal.QueryData(x => x.UserAccount == account && x.IsPossible == "true"
        //        && x.MaintenanceDate >= today &&x.MaintenanceDate < tomorrow).FirstOrDefault();
        //        if (maint == null)
        //        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 = "未找到可用的维护任务记录" };
        //            return new WebResponseContent { Status = false, Message = "没有找到该用户" };
        //        }
        //        // 修改其结束时间
        //        maint.MaintenancEendTime = DateTime.Now;
        //        maint.IsPossible = "ok";//ok就代表完成了
        //        if (maint.IsLeader == 1)//如果该用户是班长,那么要等全部人都检修完成,他才可以结束检修
        //        {
        //            //先查找所有用户的组是那个组的,组员状态有一个不是1
        //            // 查找同组未完成的组员(IsLeader=0 && MaintenanceStatus=1)
        //            bool hasUnfinishedMembers = user.Any(x =>x.Roleid == maint.Roleid && x.IsLeader == 0 &&
        //                x.MaintenanceStatus == 1); //:Any()有一个满足就返回true表示存在满足条件的记录
        //            if (hasUnfinishedMembers)
        //            {
        //                return new WebResponseContent { Status = false, Message = "还有组员未完成当前批次检修" };
        //            }
        //        }
        //        //如果满足下面的条件就开始
        //        maint.MaintenancEendTime = DateTime.Now;//记录结束时间
        //        maint.MaintenanceStatus = 0;//更改状态
        //        BaseDal.UpdateData(maint);
        //        return new WebResponseContent { Status = true, Data = maint };
        //        ////插入记录表
        //        //var recording = new Dt_MaintenanceTeam  //添加记录
        //        //{
        //        //    OperatorName = sysuer.UserTrueName,
        //        //    TeamName = sysuer.RoleName,
        //        //    DistributionTime = DateTime.Now,
        //        //    EndTime=DateTime.Now,
        //        //};
        //        //_team.AddData(recording);
        //        return new WebResponseContent { Status = true, Data = maint, Message = "完成检修" };
        //    }
        //    catch (Exception ex)
        //    {
        //        return new WebResponseContent { Status = false, Message = "错误信息:" + ex.Message };
        //    }
        //}
        /// <summary>
@@ -564,49 +583,58 @@
        /// <param name="account">账号</param>
        /// <param name="LocalIP">那台电脑登入的ip地址</param>
        /// <returns></returns>
        public WebResponseContent StartMaintenceTask(string account,string LocalIP)
        public WebResponseContent StartMaintenceTask(string account, string LocalIP)
        {
            try
            {
                var user = BaseDal.QueryData();
                var maint = user.Where(x =>x.UserAccount == account).FirstOrDefault();
                var sysuer = _user.QueryData(x => x.UserName == account).FirstOrDefault();//用户表
                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 = "没有找到该用户" };
                }
                if (maint.IsLeader!=1)//如果该用户不是班长,那么要等班长先做,他才可以做
                // 查找该用户在 _team 表中的最新一条记录
                var lastRecord = _team.QueryData(x => x.Account == account)
                                      .OrderByDescending(x => x.CreateDate)
                                      .FirstOrDefault();
                if (lastRecord != null && lastRecord.MaintenanceStatus == 1)
                {
                    //先查找用户的班长是不是做了
                    //bool monitor = user.Where(x => x.Roleid == maint.Roleid && x.IsLeader == 1 && x.MaintenanceStatus == 1);
                    //if (monitor==null)
                    //{
                    //    return new WebResponseContent { Status = false, Message = "你的上级还没有开始检修,请稍后再试" };
                    //}
                    bool leaderStarted = user.Any(x =>x.Roleid == maint.Roleid &&x.IsLeader == 1 &&x.MaintenanceStatus == 1); //没找到肯定是false
                    return new WebResponseContent { Status = false, Message = "你已经在开始检修了,请不要重复点击" };
                }
                //先要找到该用户属于那个角色的,这个角色中属于那个什么类型(组长/组员)
                if (maint.IsLeader != 1)//如果该用户不是班长,那么要等班长先做,他才可以做
                {
                    bool leaderStarted = user.Any(x =>  x.IsLeader == 1 && x.MaintenanceStatus == 1); //否有满足条件 找到一条就返回true MaintenanceStatus(0没有开始,1开始)
                    if (!leaderStarted)
                    {
                        return new WebResponseContent { Status = false, Message = "请等待组长开始检修" };
                    }
                }
               //如果满足下面的条件就开始
                if (true)
                {
                }
                //如果满足下面的条件就开始
                maint.MaintenancStartTime = DateTime.Now;//记录开始时间
                maint.MaintenanceStatus = 1;//更改状态
                BaseDal.UpdateData(maint);
                //插入记录表
                var recording = new Dt_MaintenanceTeam  //添加记录
                {
                    Account = account,
                    MaintenanceStatus=1,
                    OperatorName = sysuer.UserTrueName,
                    TeamName = sysuer.RoleName,
                    DistributionTime = DateTime.Now,
                    IPAddress= LocalIP,
                    //Creater = "admin",
                    //CreateDate = DateTime.Now,
                    IPAddress = LocalIP,
                };
                _team.AddData(recording);
                return new WebResponseContent { Status = true, Data = maint,Message="开始检修" };
                return new WebResponseContent { Status = true, Data = maint, Message = "开始检修" };
            }
            catch (Exception ex)
            {
@@ -631,18 +659,23 @@
                {
                    return new WebResponseContent { Status = false, Message = "没有找到该用户" };
                }
                // 查找该用户在 _team 表中的最新一条记录
                var lastRecord = _team.QueryData(x => x.Account == account)
                                      .OrderByDescending(x => x.CreateDate)
                                      .FirstOrDefault();
                if (lastRecord == null || lastRecord.MaintenanceStatus != 1)
                {
                    return new WebResponseContent { Status = false, Message = "你还没有开始检修,请先点击开始检修" };
                }
                if (maint.IsLeader == 1)//如果该用户是班长,那么要等全部人都检修完成,他才可以结束检修
                {
                    //先查找所有用户的组是那个组的,组员状态有一个不是1
                    //var monitor = user.Where(x => x.Roleid == maint.Roleid && x.IsLeader == 0 && x.MaintenanceStatus == 1).ToList();
                    //if (monitor.Count >0)
                    //{
                    //    return new WebResponseContent { Status = false, Message = "你的组员还没有完成" };
                    //}
                    //先查找所有用户的组是那个组的,组员状态有一个不是1
                    // 查找同组未完成的组员(IsLeader=0 && MaintenanceStatus=1)
                    bool hasUnfinishedMembers = user.Any(x =>x.Roleid == maint.Roleid && x.IsLeader == 0 &&
                        x.MaintenanceStatus == 1); //:Any()有一个满足就返回true表示存在满足条件的记录
                    if (hasUnfinishedMembers)
                    var hasUnfinishedMembers = user.Where(x =>x.IsLeader == 0 &&x.MaintenanceStatus == 1).ToList(); //:Any()有一个满足就返回true表示存在满足条件的记录
                    if (hasUnfinishedMembers.Count>0)
                    {
                        return new WebResponseContent { Status = false, Message = "还有组员未完成当前批次检修" };
                    }
@@ -652,14 +685,15 @@
                maint.MaintenanceStatus = 0;//更改状态
                BaseDal.UpdateData(maint);
                ////插入记录表
                //var recording = new Dt_MaintenanceTeam  //添加记录
                //{
                //    OperatorName = sysuer.UserTrueName,
                //    TeamName = sysuer.RoleName,
                //    DistributionTime = DateTime.Now,
                //    EndTime=DateTime.Now,
                //};
                //_team.AddData(recording);
                var recording = new Dt_MaintenanceTeam  //添加记录
                {
                    Account = account,
                    MaintenanceStatus=0,
                    OperatorName = sysuer.UserTrueName,
                    TeamName = sysuer.RoleName,
                    EndTime = DateTime.Now,
                };
                _team.AddData(recording);
                return new WebResponseContent { Status = true, Data = maint, Message = "完成检修" };
            }
@@ -671,6 +705,28 @@
        /// <summary>
        ///  展示开始检修人员
        /// </summary>
        /// <returns></returns>
        public WebResponseContent YShowStartTake()
        {
            try
            {
                var reslut=BaseDal.QueryData(x => x.MaintenanceStatus == 1).ToList();
                if (reslut.Count<=0)
                {
                    return new WebResponseContent { Status = false, Message = "还没有人开始检修" };
                }
                return new WebResponseContent { Status = true, Data = reslut,Message="检修人员有以下" };
            }
            catch (Exception ex)
            {
                return new WebResponseContent { Status = false, Message = ex.Message };
            }
        }
        /// <summary>
        /// 状态枚举
        /// </summary>
        private enum Maint