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

12345

Browse Source
This commit is contained in:
wyw 2026-01-20 14:22:50 +08:00
parent d2c594c296
commit dbe5981d58
1 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3,6 +3,7 @@ using APT.BaseData.Domain.Entities.FM;
using APT.BaseData.Domain.Entities.OP; using APT.BaseData.Domain.Entities.OP;
using APT.BaseData.Domain.Enums; using APT.BaseData.Domain.Enums;
using APT.BaseData.Domain.IServices.FM; using APT.BaseData.Domain.IServices.FM;
using APT.BaseData.Domain.IServices.OP;
using APT.BaseData.Services.Services.FM; using APT.BaseData.Services.Services.FM;
using APT.BaseData.Services.Services.OP; using APT.BaseData.Services.Services.OP;
using APT.Infrastructure.Api; using APT.Infrastructure.Api;
@ -39,6 +40,12 @@ namespace APT.SC.WebApi.Controllers.Api.BI
[Route("api/BI/BIKanBanController")] [Route("api/BI/BIKanBanController")]
public class BIKanBanController : APTApiController<T_FM_NOTIFICATION_TASK> public class BIKanBanController : APTApiController<T_FM_NOTIFICATION_TASK>
{ {
IOPTenantDBConnService OPTenantDBConnService { get; set; }
public BIKanBanController(IOPTenantDBConnService opTenantDBConnService)
{
OPTenantDBConnService = opTenantDBConnService;
}
/// <summary> /// <summary>
/// 返回所有 /// 返回所有
/// </summary> /// </summary>
@ -241,6 +248,15 @@ namespace APT.SC.WebApi.Controllers.Api.BI
DataTable tableJobRate = new DataTable(); DataTable tableJobRate = new DataTable();
DataTable tableSafeCheck = new DataTable(); DataTable tableSafeCheck = new DataTable();
DataTable tableLink = new DataTable(); DataTable tableLink = new DataTable();
//培训教育 对应统计
var ListAllORG = GetEntities<T_FM_ORGANIZATION>(e => !e.IS_DELETED && e.CODE != "003", null, null).OrderBy(e => e.TENANT_CODE).ToList();
string strConn = OPTenantDBConnService.GetConnByORGID(filter.OrgId.Value);//获取数据库链接
List<string> listVNAME = new List<string>() { "vhome_Train_Hour" };//, "vhome_risk_type_data"
DataSet ds = new DataSet();
GETDBDATA(strConn, listVNAME, ref ds);//获取视图 数据 listVNAME 与 ds.Tables 一一对应
result.Data.listSETrainSum = GetTrainInfo(ds.Tables[0], ListAllORG);
using (SqlConnection connection = new SqlConnection(connhead)) using (SqlConnection connection = new SqlConnection(connhead))
{ {
try try
@ -293,17 +309,6 @@ namespace APT.SC.WebApi.Controllers.Api.BI
linkData.Fill(tableLink); linkData.Fill(tableLink);
result.Data.linkSum = linkSumData(connhead, tableLink); result.Data.linkSum = linkSumData(connhead, tableLink);
//培训教育 对应统计
var ListAllORG = GetEntities<T_FM_ORGANIZATION>(e => !e.IS_DELETED && e.CODE != "003", null, null).OrderBy(e => e.TENANT_CODE).ToList();
string strConn = OPTenantDBConnService.GetConnByORGID(filter.OrgId.Value);//获取数据库链接
List<string> listVNAME = new List<string>() { "vhome_Train_Hour" };//, "vhome_risk_type_data"
DataSet ds = new DataSet();
GETDBDATA(strConn, listVNAME, ref ds);//获取视图 数据 listVNAME 与 ds.Tables 一一对应
result.Data.listSETrainSum = GetTrainInfo(ds.Tables[0], ListAllORG);
connection.Close(); connection.Close();
} }
catch (Exception ex) catch (Exception ex)