wyw/mh_jy_safe
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
何美荣 2026-01-19 16:36:04 +08:00
parent 0ed4841adc
commit f9c566418b
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
APT.MicroApi/APT.SC.WebApi/Controllers/Api/BIController/BIKanBanController.cs
View File

@ -139,10 +139,11 @@ namespace APT.SC.WebApi.Controllers.Api.BI
/// <param name="filter">分页过滤实体</param> /// <param name="filter">分页过滤实体</param>
/// <returns></returns> /// <returns></returns>
[HttpPost, Route("ReturnAllData")] [HttpPost, Route("ReturnAllData")]
public ReturnAll ReturnAllData([FromBody] KeywordFilter filter) public JsonActionResult<ReturnAll> ReturnAllData([FromBody] KeywordFilter filter)
{ {
string connhead = ConfigurationManager.ConnectionStrings["head"]; string connhead = ConfigurationManager.ConnectionStrings["head"];
ReturnAll result = new ReturnAll(); JsonActionResult<ReturnAll> result = new JsonActionResult<ReturnAll>();
result.Data = new ReturnAll();
DataTable tableRisk = new DataTable(); DataTable tableRisk = new DataTable();
DataTable tableJob = new DataTable(); DataTable tableJob = new DataTable();
DataTable tableJobGroup = new DataTable(); DataTable tableJobGroup = new DataTable();
@ -160,7 +161,7 @@ namespace APT.SC.WebApi.Controllers.Api.BI
SqlCommand comRisk = new SqlCommand(sqlRisk, connection); SqlCommand comRisk = new SqlCommand(sqlRisk, connection);
SqlDataAdapter riskData = new SqlDataAdapter(comRisk); SqlDataAdapter riskData = new SqlDataAdapter(comRisk);
riskData.Fill(tableRisk); riskData.Fill(tableRisk);
result.riskTypeRate = RiskTypeRateData(connhead, tableRisk); result.Data.riskTypeRate = RiskTypeRateData(connhead, tableRisk);
//当日工作票排名前三 //当日工作票排名前三
string sqlJob = "select * from vhome_jobtop3_today "; string sqlJob = "select * from vhome_jobtop3_today ";
SqlCommand comJob = new SqlCommand(sqlJob, connection); SqlCommand comJob = new SqlCommand(sqlJob, connection);
@ -170,31 +171,31 @@ namespace APT.SC.WebApi.Controllers.Api.BI
SqlCommand comJobGroup = new SqlCommand(sqlJobGroup, connection); SqlCommand comJobGroup = new SqlCommand(sqlJobGroup, connection);
SqlDataAdapter jobGroupData = new SqlDataAdapter(comJobGroup); SqlDataAdapter jobGroupData = new SqlDataAdapter(comJobGroup);
jobGroupData.Fill(tableJobGroup); jobGroupData.Fill(tableJobGroup);
result.jobTodayTop3 = JobTodayTopData(connhead, filter.OrgId.Value, tableJob,tableJobGroup); result.Data.jobTodayTop3 = JobTodayTopData(connhead, filter.OrgId.Value, tableJob,tableJobGroup);
//隐患整改率 //隐患整改率
string sqlHidden = "select * from vhome_hidden_data_result "; string sqlHidden = "select * from vhome_hidden_data_result ";
SqlCommand comHidden = new SqlCommand(sqlHidden, connection); SqlCommand comHidden = new SqlCommand(sqlHidden, connection);
SqlDataAdapter hiddenData = new SqlDataAdapter(comHidden); SqlDataAdapter hiddenData = new SqlDataAdapter(comHidden);
hiddenData.Fill(tableHidden); hiddenData.Fill(tableHidden);
result.hiddenRectify = HiddenRectifyData(connhead, tableHidden); result.Data.hiddenRectify = HiddenRectifyData(connhead, tableHidden);
//各事项排名前三 //各事项排名前三
string sqlTask = "select * from vhome_task_data_result "; string sqlTask = "select * from vhome_task_data_result ";
SqlCommand comTask = new SqlCommand(sqlTask, connection); SqlCommand comTask = new SqlCommand(sqlTask, connection);
SqlDataAdapter taskData = new SqlDataAdapter(comTask); SqlDataAdapter taskData = new SqlDataAdapter(comTask);
taskData.Fill(tableTask); taskData.Fill(tableTask);
result.taskTop3 = TaskTopData(connhead, tableTask); result.Data.taskTop3 = TaskTopData(connhead, tableTask);
//作业现场完成情况统计 //作业现场完成情况统计
string sqlJobRate = "select * from vhome_jobrecord_data "; string sqlJobRate = "select * from vhome_jobrecord_data ";
SqlCommand comJobRate = new SqlCommand(sqlJobRate, connection); SqlCommand comJobRate = new SqlCommand(sqlJobRate, connection);
SqlDataAdapter jobRateData = new SqlDataAdapter(comJobRate); SqlDataAdapter jobRateData = new SqlDataAdapter(comJobRate);
jobRateData.Fill(tableJobRate); jobRateData.Fill(tableJobRate);
result.jobFinishRate = jobFinishRateData(connhead, tableJobRate); result.Data.jobFinishRate = jobFinishRateData(connhead, tableJobRate);
//各公司安全检查统计 //各公司安全检查统计
string sqlSafecCheck= "select * from vhome_check_total "; string sqlSafecCheck= "select * from vhome_check_total ";
SqlCommand comSafecCheck = new SqlCommand(sqlSafecCheck, connection); SqlCommand comSafecCheck = new SqlCommand(sqlSafecCheck, connection);
SqlDataAdapter safecCheckData = new SqlDataAdapter(comSafecCheck); SqlDataAdapter safecCheckData = new SqlDataAdapter(comSafecCheck);
safecCheckData.Fill(tableSafeCheck); safecCheckData.Fill(tableSafeCheck);
result.safeCheckSum = safeCheckSumData(connhead, tableSafeCheck); result.Data.safeCheckSum = safeCheckSumData(connhead, tableSafeCheck);
connection.Close(); connection.Close();
} }
catch (Exception ex) catch (Exception ex)