20251023 排产计划
This commit is contained in:
@@ -0,0 +1,123 @@
|
||||
ALTER PROCEDURE [dbo].[Sp_HJGL_ProductionPlanStatistics]
|
||||
@projectId nvarchar(50)=null
|
||||
AS
|
||||
BEGIN
|
||||
SET NOCOUNT ON; -- 减少网络流量，提高性能
|
||||
|
||||
-- 使用CTE预先过滤和聚合数据
|
||||
WITH PipelineFiltered AS (
|
||||
SELECT UnitWorkId, FlowingSection, PipelineId
|
||||
FROM HJGL_Pipeline
|
||||
WHERE PipeArea='1'
|
||||
AND FlowingSection IS NOT NULL
|
||||
AND FlowingSection != ''
|
||||
AND (@projectId IS NULL OR UnitWorkId IN (
|
||||
SELECT UnitWorkId FROM WBS_UnitWork WHERE ProjectId = @projectId
|
||||
))
|
||||
),
|
||||
|
||||
-- 工厂预制总达因
|
||||
TotalDiaCTE AS (
|
||||
SELECT p.UnitWorkId, p.FlowingSection, SUM(wj.Size) as TotalDia
|
||||
FROM HJGL_WeldJoint wj
|
||||
INNER JOIN PipelineFiltered p ON p.PipelineId = wj.PipelineId
|
||||
WHERE wj.JointAttribute='预制口'
|
||||
GROUP BY p.UnitWorkId, p.FlowingSection
|
||||
),
|
||||
|
||||
-- 当日完成工作量
|
||||
CurrentDayCompletedCTE AS (
|
||||
SELECT p.UnitWorkId, p.FlowingSection, SUM(wj.Size) as CurrentDayCompletedDia
|
||||
FROM HJGL_WeldJoint wj
|
||||
INNER JOIN PipelineFiltered p ON p.PipelineId = wj.PipelineId
|
||||
INNER JOIN HJGL_WeldingDaily wd ON wd.WeldingDailyId = wj.WeldingDailyId
|
||||
WHERE wj.JointAttribute='预制口'
|
||||
AND wj.WeldingDailyId IS NOT NULL
|
||||
AND wd.WeldingDate >= CAST(GETDATE() AS DATE) -- 优化日期比较，使用日期范围
|
||||
AND wd.WeldingDate < DATEADD(DAY, 1, CAST(GETDATE() AS DATE))
|
||||
GROUP BY p.UnitWorkId, p.FlowingSection
|
||||
),
|
||||
|
||||
-- 累计已完成量
|
||||
TotalCompletedCTE AS (
|
||||
SELECT p.UnitWorkId, p.FlowingSection, SUM(wj.Size) as totalCompletedDia
|
||||
FROM HJGL_WeldJoint wj
|
||||
INNER JOIN PipelineFiltered p ON p.PipelineId = wj.PipelineId
|
||||
WHERE wj.JointAttribute='预制口'
|
||||
AND wj.WeldingDailyId IS NOT NULL
|
||||
GROUP BY p.UnitWorkId, p.FlowingSection
|
||||
),
|
||||
|
||||
-- 当前焊工数量
|
||||
WelderCountCTE AS (
|
||||
SELECT p.UnitWorkId, p.FlowingSection,
|
||||
COUNT(DISTINCT pp.PersonId) as WelderCount -- 使用DISTINCT避免重复计数
|
||||
FROM Person_Persons pp
|
||||
INNER JOIN HJGL_WeldJoint wj ON wj.BackingWelderId = pp.PersonId
|
||||
INNER JOIN PipelineFiltered p ON p.PipelineId = wj.PipelineId
|
||||
WHERE wj.JointAttribute='预制口'
|
||||
AND wj.WeldingDailyId IS NOT NULL
|
||||
GROUP BY p.UnitWorkId, p.FlowingSection
|
||||
)--,
|
||||
|
||||
---- 预警焊工数量
|
||||
--WarningWelderCountCTE AS (
|
||||
-- SELECT p.UnitWorkId, p.FlowingSection,
|
||||
-- COUNT(DISTINCT pp.PersonId) as WarningWelderCount
|
||||
-- FROM Person_Persons pp
|
||||
-- INNER JOIN HJGL_WeldJoint wj ON wj.BackingWelderId = pp.PersonId
|
||||
-- INNER JOIN PipelineFiltered p ON p.PipelineId = wj.PipelineId
|
||||
-- INNER JOIN Welder_WelderQualify wq ON wq.WelderId = pp.PersonId
|
||||
-- WHERE wj.JointAttribute='预制口'
|
||||
-- AND wj.WeldingDailyId IS NOT NULL
|
||||
-- AND wq.LimitDate < GETDATE() -- 焊工资格过期预警
|
||||
-- GROUP BY p.UnitWorkId, p.FlowingSection
|
||||
--)
|
||||
|
||||
SELECT DISTINCT
|
||||
unitWork.UnitWorkId,
|
||||
unitWork.UnitWorkCode,
|
||||
unitWork.UnitWorkName,
|
||||
unitWork.ProjectId,
|
||||
pipeline.FlowingSection,
|
||||
isnull(total.TotalDia,0) as TotalDia,--工厂预制总达因
|
||||
p.PlanStartDate,--计划开始日期
|
||||
p.PlanEndDate,--计划完成日期
|
||||
--(DATEDIFF(day, p.PlanStartDate, p.PlanEndDate) +1) as TotalDays,--总天数
|
||||
--(case when p.PlanEndDate>= getdate() then (DATEDIFF(day, p.PlanStartDate, p.PlanEndDate)-(DATEDIFF(day,p.PlanStartDate,GETDATE()))) else '' end) as RemainingDays,--剩余天数
|
||||
--(case when DATEDIFF(day, p.PlanStartDate, p.PlanEndDate)>0 then cast(isnull(total.TotalDia,0)/DATEDIFF(day, p.PlanStartDate, p.PlanEndDate) as decimal(18,2)) else 0 end) as AvgDayCompleteDia, --平均每日应完成工作量
|
||||
ISNULL(currentDay.CurrentDayCompletedDia,0) as CurrentDayCompletedDia, --当日完成工作量
|
||||
|
||||
--cast(case when (case when p.PlanEndDate>= getdate() then (DATEDIFF(day, p.PlanStartDate, p.PlanEndDate)-(DATEDIFF(day,p.PlanStartDate,GETDATE()))) else 0 end)>0 then
|
||||
--(isnull(total.TotalDia,0)-isnull(totalCompleted.totalCompletedDia,0))/ (case when p.PlanEndDate>= getdate() then (DATEDIFF(day, p.PlanStartDate, p.PlanEndDate)-(DATEDIFF(day,p.PlanStartDate,GETDATE()))) else 0 end) else 0 end as decimal(18,2)) as NextDayComplete, --次日应完成量
|
||||
|
||||
isnull(totalCompleted.totalCompletedDia,0) as totalCompletedDia, --累计已完成量
|
||||
cast(cast((case when isnull(total.TotalDia,0)>0 then
|
||||
(isnull(totalCompleted.totalCompletedDia,0) / isnull(total.TotalDia,0)*100) else 0 end) as decimal(18,2)) as varchar(10))+'%' as CompletedRate, --已完成百分比
|
||||
welder.WelderCount, --当前焊工数量
|
||||
--warningWelder.WarningWelderCount --预警焊工数量
|
||||
(case when welder.WelderCount>0 then cast((ISNULL(currentDay.CurrentDayCompletedDia,0)/welder.WelderCount) as decimal(18,2)) else 0 end) as WarningWelderCount--焊工日功效
|
||||
FROM WBS_UnitWork AS unitWork
|
||||
INNER JOIN PipelineFiltered pipeline ON pipeline.UnitWorkId = unitWork.UnitWorkId -- 使用INNER JOIN，因为pipeline数据必须存在
|
||||
--LEFT JOIN HJGL_ProductionSchedulingPlan p ON p.PipelineId = unitWork.UnitWorkId AND p.FlowNum = pipeline.FlowingSection
|
||||
--排产计划中最早和最晚日期
|
||||
left join (select min(PlanStartDate) as PlanStartDate,max(PlanEndDate) as PlanEndDate,PipelineId,FlowNum from HJGL_ProductionSchedulingPlan
|
||||
group by PipelineId,FlowNum
|
||||
) as p on p.PipelineId=unitWork.UnitWorkId and p.FlowNum = pipeline.FlowingSection
|
||||
|
||||
--工厂预制总达因
|
||||
LEFT JOIN TotalDiaCTE total ON total.UnitWorkId = unitWork.UnitWorkId AND total.FlowingSection = pipeline.FlowingSection
|
||||
--当日完成工作量
|
||||
LEFT JOIN CurrentDayCompletedCTE currentDay ON currentDay.UnitWorkId = unitWork.UnitWorkId AND currentDay.FlowingSection = pipeline.FlowingSection
|
||||
--累计已完成量
|
||||
LEFT JOIN TotalCompletedCTE totalCompleted ON totalCompleted.UnitWorkId = unitWork.UnitWorkId AND totalCompleted.FlowingSection = pipeline.FlowingSection
|
||||
--当前焊工数量
|
||||
LEFT JOIN WelderCountCTE welder ON welder.UnitWorkId = unitWork.UnitWorkId AND welder.FlowingSection = pipeline.FlowingSection
|
||||
--预警焊工数量
|
||||
--LEFT JOIN WarningWelderCountCTE warningWelder ON warningWelder.UnitWorkId = unitWork.UnitWorkId AND warningWelder.FlowingSection = pipeline.FlowingSection
|
||||
WHERE (@projectId IS NULL OR unitWork.ProjectId = @projectId)
|
||||
AND pipeline.FlowingSection IS NOT NULL
|
||||
END
|
||||
GO
|
||||
|
||||
|
||||
Reference in New Issue
Block a user