diff --git a/APT.MicroApi/APT.SC.WebApi/Controllers/Api/BIController/BIKanBanController.cs b/APT.MicroApi/APT.SC.WebApi/Controllers/Api/BIController/BIKanBanController.cs index 0634644..d1ee2a6 100644 --- a/APT.MicroApi/APT.SC.WebApi/Controllers/Api/BIController/BIKanBanController.cs +++ b/APT.MicroApi/APT.SC.WebApi/Controllers/Api/BIController/BIKanBanController.cs @@ -276,31 +276,12 @@ namespace APT.SC.WebApi.Controllers.Api.BI JsonActionResult result = new JsonActionResult(); result.Data = new ReturnAll(); DataTable tableRisk = new DataTable(); - DataTable tableJob = new DataTable(); DataTable tableJobGroup = new DataTable(); DataTable tableHidden = new DataTable(); DataTable tableTask = new DataTable(); DataTable tableJobRate = new DataTable(); DataTable tableSafeCheck = new DataTable(); DataTable tableLink = new DataTable(); - DateTime startDate = DateTime.Now.Date; - DateTime endDate = Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd 23:59:59")); - if (!string.IsNullOrEmpty(filter.Parameter1)) - { - startDate = Convert.ToDateTime(filter.Parameter1).Date; - } - if (!string.IsNullOrEmpty(filter.Parameter2)) - { - endDate = Convert.ToDateTime(Convert.ToDateTime(filter.Parameter2).Date.ToString("yyyy-MM-dd 23:59:59")); - } - if (startDate.Year != DateTime.Now.Year) - { - throw new Exception("只能查询本年度数据,请修改开始时间!"); - } - if (endDate.Year != DateTime.Now.Year) - { - throw new Exception("只能查询本年度数据,请修改结束时间!"); - } //培训教育 对应统计 var ListAllORG = GetEntities(e => !e.IS_DELETED && e.CODE != "003", null, null).OrderBy(e => e.TENANT_CODE).ToList(); string strConn = OPTenantDBConnService.GetConnByORGID(filter.OrgId.Value);//获取数据库链接 @@ -329,12 +310,7 @@ namespace APT.SC.WebApi.Controllers.Api.BI //SqlDataAdapter jobGroupData = new SqlDataAdapter(comJobGroup); //jobGroupData.Fill(tableJobGroup); //result.Data.jobTodayTop3 = JobTodayTopData(filter.OrgId.Value, tableJob, tableJobGroup); - //当日工作票的统计数量 - string sqlJob = "select WORK_PERMIT_TYPE_ID,NAME,count(*) as QTY from vhome_jobTodayNew where create_time >=" + startDate + "and create_time<=" + endDate + " GROUP BY WORK_PERMIT_TYPE_ID,NAME ORDER BY QTY DESC"; - SqlCommand comJob = new SqlCommand(sqlJob, connection); - SqlDataAdapter jobData = new SqlDataAdapter(comJob); - jobData.Fill(tableJob); - result.Data.jobTodayQty = JobTodayQtyData(tableJob); + //隐患统计数据 string sqlHidden = "select * from vhome_hiddenSummary"; SqlCommand comHidden = new SqlCommand(sqlHidden, connection); @@ -1023,7 +999,7 @@ namespace APT.SC.WebApi.Controllers.Api.BI /// /// [HttpPost, Route("JobManage")] - public JsonActionResult> JobManage([FromBody] KeywordFilter filter) + public JsonActionResult JobManage([FromBody] KeywordFilter filter) { DateTime startDate = DateTime.Now.Date; DateTime endDate = Convert.ToDateTime(DateTime.Now.ToString("yyyy-MM-dd 23:59:59")); @@ -1043,9 +1019,11 @@ namespace APT.SC.WebApi.Controllers.Api.BI { throw new Exception("只能查询本年度数据,请修改结束时间!"); } - JsonActionResult> result = new JsonActionResult>(); - var list = new List(); + JsonActionResult result = new JsonActionResult(); + result.Data = new JobManage(); + var list = new List(); DataTable tableList = new DataTable(); + DataTable tableJob = new DataTable(); string strConn = OPTenantDBConnService.GetConnByORGID(filter.OrgId.Value);//获取数据库链接 using (SqlConnection connection = new SqlConnection(strConn)) { @@ -1054,7 +1032,7 @@ namespace APT.SC.WebApi.Controllers.Api.BI connection.Open(); //当日危险作业清单 - string sql = "select * from vhome_jobTodayList where create_time >="+ startDate + "and create_time<="+ endDate; + string sql = "select * from vhome_jobTodayList where create_time >='"+ startDate +"' and create_time<='" + endDate+"'"; SqlCommand com = new SqlCommand(sql, connection); SqlDataAdapter data = new SqlDataAdapter(com); data.Fill(tableList); @@ -1062,7 +1040,7 @@ namespace APT.SC.WebApi.Controllers.Api.BI { foreach (DataRow item in tableList.Rows) { - JobManage job = new JobManage(); + JobList job = new JobList(); job.companyName = item["companyName"] != null ? item["companyName"].ToString() : null; job.startDate = item["JOB_DATE"] != null ? item["JOB_DATE"].ToString() : null; job.endDate = item["JOB_END_DATE"] != null ? item["JOB_END_DATE"].ToString() : null; @@ -1075,6 +1053,13 @@ namespace APT.SC.WebApi.Controllers.Api.BI list.Add(job); } } + result.Data.jobList = list.ToList(); + //当日工作票的统计数量 + string sqlJob = "select WORK_PERMIT_TYPE_ID,NAME,count(*) as QTY from vhome_jobTodayNew where create_time >='" + startDate + "' and create_time<='" + endDate + "' GROUP BY WORK_PERMIT_TYPE_ID,NAME ORDER BY QTY DESC"; + SqlCommand comJob = new SqlCommand(sqlJob, connection); + SqlDataAdapter jobData = new SqlDataAdapter(comJob); + jobData.Fill(tableJob); + result.Data.jobTodayQty = JobTodayQtyData(tableJob); connection.Close(); } catch (Exception ex) @@ -1085,7 +1070,6 @@ namespace APT.SC.WebApi.Controllers.Api.BI throw new Exception("【" + HttpContext.Request.Path + "】错误日志:[Message]" + ex.Message); } } - result.Data = list; return result; } @@ -1177,6 +1161,17 @@ namespace APT.SC.WebApi.Controllers.Api.BI public int? qty { get; set; } } public class JobManage + { + /// + /// 作业清单 + /// + public List jobList { get; set; } + /// + /// + /// + public List jobTodayQty { get; set; } + } + public class JobList { /// /// 公司名称