using System;
using System.Collections.Generic;
using System.Linq;
using System.Data;
using System.Data.SqlClient;
namespace BLL
{
public static class APIReportQueryService
{
#region 根据焊工号获取焊工业绩
/// <summary>
/// 根据焊工号获取焊工业绩
/// </summary>
/// <param name="projectId"></param>
/// <param name="welderCode"></param>
/// <returns></returns>
public static Model.WelderPerformanceItem GetWelderPerformanceByWelderCode(string projectId, string welderCode)
{
using (Model.HJGLDB db = new Model.HJGLDB(Funs.ConnString))
{
// todo 二维码分解待做
var getDataLists = from x in db.View_WelderPerformance
where x.ProjectId == projectId && x.WelderCode == welderCode
select new Model.WelderPerformanceItem
{
WelderCode = x.WelderCode,
WelderName = x.WelderName,
UnitName = x.UnitName,
WelderLevel = x.WelderLevel,
TotalJotDin = x.Nowtotal_jot.ToString() + "/" + x.Nowtotal_din.ToString(),
OneCheckJotNum = x.OneCheckJotNum.ToString(),
OneCheckPassJotNum = x.OneCheckPassJotNum,
OnePassRate = x.PassRate,
OneCheckTotalFilm = x.OneCheckTotalFilm.ToString(),
OneCheckPassFilm = x.OneCheckPassFilm.ToString(),
PassfilmRate = x.Passfilmrate,
RepairJotNum = x.OneCheckRepairJotNum.ToString(),
ExpandJotNum = x.ExpandJotNum.ToString()
};
return getDataLists.FirstOrDefault();
}
}
#endregion
#region 根据条件获取管线综合信息
/// <summary>
/// 根据条件获取管线综合信息
/// </summary>
/// <param name="projectId">项目</param>
/// <param name="workAreaId">区域</param>
/// <param name="pipelineCode">管线号</param>
/// <returns></returns>
public static List<Model.PipeLineQueryItem> GetPipeLineInfo(string projectId, string workAreaId, string pipelineCode)
{
List<SqlParameter> listStr = new List<SqlParameter>();
listStr.Add(new SqlParameter("@unitId", null));
if (!string.IsNullOrEmpty(pipelineCode))
{
listStr.Add(new SqlParameter("@pipelineCode", pipelineCode));
}
else
{
listStr.Add(new SqlParameter("@pipelineCode", null));
}
if (!string.IsNullOrEmpty(workAreaId))
{
listStr.Add(new SqlParameter("@workAreaId", workAreaId));
}
else
{
listStr.Add(new SqlParameter("@workAreaId", null));
}
listStr.Add(new SqlParameter("@materialId", null));
listStr.Add(new SqlParameter("@projectId", projectId));
SqlParameter[] parameter = listStr.ToArray();
DataTable dt = SQLHelper.GetDataTableRunProc("sp_rpt_IsoCmprehensive", parameter);
List<Model.PipeLineQueryItem> reportList = new List<Model.PipeLineQueryItem>();
foreach (DataRow row in dt.Rows)
{
Model.PipeLineQueryItem report = new Model.PipeLineQueryItem();
report.UnitName= row["UnitName"].ToString();
report.WorkAreaCode = row["WorkAreaCode"].ToString();
report.PipelineCode = row["PipelineCode"].ToString();
report.Maxdate = row["maxdate"].ToString();
report.TotalJot = row["total_jot"].ToString();
report.FinishedJot = row["finished_total_jot"].ToString();
report.FinisedRate = row["finisedrate"].ToString();
report.TotalDI = row["total_din"].ToString();
report.FinishedDin = row["finished_total_din"].ToString();
report.FinishedDinRate = row["finisedrate_din"].ToString();
report.TotalFilm = row["total_film"].ToString();
report.PassFilm = row["pass_film"].ToString();
report.PassRate = row["passreate"].ToString();
report.TrustJot = row["trust_total_jot"].ToString();
report.TrustRate = row["trustrate"].ToString();
report.ExtJot = row["ext_jot"].ToString();
report.RepairJot = row["total_repairjot"].ToString();
report.CutJot = row["cut_total_jot"].ToString();
reportList.Add(report);
}
return reportList;
}
#endregion
#region 焊接工作量查询
/// <summary>
/// 焊接工作量查询
/// </summary>
/// <param name="projectArea">项目区域</param>
/// <param name="projectId">项目Id</param>
/// <returns></returns>
public static List<Model.WorkloadItem> GetWeldWorkload(string projectArea, string projectId)
{
string strSql = @"SELECT pro.ProjectCode, CAST(v.totalDin AS DECIMAL(9,2)) AS '预估',
CAST((v.totalDin-ISNULL(v1.LastDin,0)) AS DECIMAL(9,2)) AS '完成',
CAST(ISNULL(v1.LastDin,0) AS DECIMAL(9,2)) AS '剩余',
CAST(ISNULL(v2.LastWeekDin,0) AS DECIMAL(9,2)) AS '近一周'
FROM
(SELECT ProjectId, ISNULL(SUM(ISNULL(Size,0)),0) AS totalDin
FROM dbo.Pipeline_WeldJoint GROUP BY ProjectId) v
LEFT JOIN
(SELECT ProjectId, ISNULL(SUM(ISNULL(Size,0)),0) AS LastDin
FROM dbo.Pipeline_WeldJoint
WHERE WeldingDailyId IS NULL GROUP BY ProjectId) v1 ON v1.ProjectId = v.ProjectId
LEFT JOIN
(SELECT jot.ProjectId, ISNULL(SUM(ISNULL(jot.Size,0)),0) AS LastWeekDin
FROM dbo.Pipeline_WeldJoint jot
LEFT JOIN dbo.Pipeline_WeldingDaily report ON report.WeldingDailyId = jot.WeldingDailyId
WHERE jot.WeldingDailyId IS NOT NULL AND report.WeldingDate<=GETDATE() AND report.WeldingDate>DATEADD(ww,-1,GETDATE())
GROUP BY jot.ProjectId) v2 ON v2.ProjectId = v.ProjectId
LEFT JOIN dbo.Base_Project pro ON pro.ProjectId = v.ProjectId
WHERE pro.ProjectArea=@projectArea ";
List<SqlParameter> listStr = new List<SqlParameter>();
listStr.Add(new SqlParameter("@ProjectArea", projectArea));
if (!string.IsNullOrEmpty(projectId))
{
strSql = strSql + " AND v.ProjectId=@ProjectId";
listStr.Add(new SqlParameter("@ProjectId", projectId));
}
SqlParameter[] parameter = listStr.ToArray();
DataTable dt = SQLHelper.GetDataTableRunText(strSql, parameter);
List<Model.WorkloadItem> workloadList = new List<Model.WorkloadItem>();
foreach (DataRow row in dt.Rows)
{
Model.WorkloadItem item = new Model.WorkloadItem();
item.ProjectCode = row["ProjectCode"].ToString();
item.TotalNum = row["预估"].ToString();
item.FinishedNum = row["完成"].ToString();
item.RemainNum = row["剩余"].ToString();
item.LateOneWeekNum = row["近一周"].ToString();
workloadList.Add(item);
}
return workloadList;
}
#endregion
#region 拍片工作量查询
/// <summary>
/// 焊接工作量查询
/// </summary>
/// <param name="projectArea">项目区域</param>
/// <param name="projectId">项目Id</param>
/// <returns></returns>
public static List<Model.WorkloadItem> GetWeldNdtFilm(string projectArea, string projectId)
{
string strSql = @"SELECT pro.ProjectCode, ISNULL(v1.BatchTrustNum,0) AS '委托数',ISNULL(v2.NdtCheckNum,0) AS '拍片焊口',
(ISNULL(v1.BatchTrustNum,0)-ISNULL(v2.NdtCheckNum,0)) AS '积压焊口' ,
ISNULL(v3.LastWeekCheckNum,0) AS '近一周检测'
FROM
(SELECT trust.ProjectId, COUNT(d.TrustBatchItemId) AS BatchTrustNum
FROM dbo.Batch_BatchTrustItem d
LEFT JOIN dbo.Batch_BatchTrust trust ON trust.TrustBatchId = d.TrustBatchId
LEFT JOIN dbo.Base_DetectionType ndt ON ndt.DetectionTypeId = trust.DetectionTypeId
WHERE ndt.SysType='射线检测' GROUP BY trust.ProjectId) v1
LEFT JOIN
(SELECT ndt.ProjectId,COUNT(ndtItme.NDEItemID) AS NdtCheckNum
FROM dbo.Batch_NDEItem ndtItme
LEFT JOIN dbo.Batch_NDE ndt ON ndt.NDEID = ndtItme.NDEID
LEFT JOIN dbo.Base_DetectionType ndtType ON ndtType.DetectionTypeId = ndtItme.DetectionTypeId
WHERE ndtType.SysType ='射线检测' AND SubmitDate IS NOT NULL
GROUP BY ndt.ProjectId ) v2 ON v2.ProjectId = v1.ProjectId
LEFT JOIN
(SELECT ndt.ProjectId,COUNT(ndtItme.NDEItemID) AS LastWeekCheckNum
FROM dbo.Batch_NDEItem ndtItme
LEFT JOIN dbo.Batch_NDE ndt ON ndt.NDEID = ndtItme.NDEID
LEFT JOIN dbo.Base_DetectionType ndtType ON ndtType.DetectionTypeId = ndtItme.DetectionTypeId
WHERE ndtType.SysType ='射线检测' AND SubmitDate IS NOT NULL
AND ndtItme.SubmitDate<=GETDATE() AND ndtItme.SubmitDate>DATEADD(ww,-1,GETDATE())
GROUP BY ndt.ProjectId ) v3 ON v3.ProjectId = v1.ProjectId
LEFT JOIN dbo.Base_Project pro ON pro.ProjectId = v1.ProjectId
WHERE pro.ProjectArea=@projectArea AND ISNULL(v1.BatchTrustNum,0)>0 ";
List<SqlParameter> listStr = new List<SqlParameter>();
listStr.Add(new SqlParameter("@ProjectArea", projectArea));
if (!string.IsNullOrEmpty(projectId))
{
strSql = strSql + " AND v1.ProjectId=@ProjectId";
listStr.Add(new SqlParameter("@ProjectId", projectId));
}
SqlParameter[] parameter = listStr.ToArray();
DataTable dt = SQLHelper.GetDataTableRunText(strSql, parameter);
List<Model.WorkloadItem> workloadList = new List<Model.WorkloadItem>();
foreach (DataRow row in dt.Rows)
{
Model.WorkloadItem item = new Model.WorkloadItem();
item.ProjectCode = row["ProjectCode"].ToString();
item.TotalNum = row["委托数"].ToString();
item.FinishedNum = row["拍片焊口"].ToString();
item.RemainNum = row["积压焊口"].ToString();
item.LateOneWeekNum = row["近一周检测"].ToString();
workloadList.Add(item);
}
return workloadList;
}
#endregion
}
}