| | |
| | | public static SqlParameter[] parameters; //定义全局SqlParameter参数数组 |
| | | |
| | | #region[App生产看板] |
| | | public static ToMessage ProductionKanban(string usercode, string startopendate, string endclosedate,string defecttype) |
| | | public static ToMessage ProductionKanban(string stu_torgcode,string stu_torgtypecode,string usercode, string startopendate, string endclosedate,string defecttype) |
| | | { |
| | | Dictionary<object, object> dList = new Dictionary<object, object>(); |
| | | var dynamicParams = new DynamicParameters(); |
| | | string search = ""; |
| | | try |
| | | { |
| | | switch (stu_torgtypecode) |
| | | { |
| | | case "": |
| | | break; |
| | | case "D": |
| | | search += "and L.org_code=@stu_torgcode "; |
| | | dynamicParams.Add("@stu_torgcode", stu_torgcode); |
| | | break; |
| | | case "W": |
| | | search += "and C.org_code=@stu_torgcode "; |
| | | dynamicParams.Add("@stu_torgcode", stu_torgcode); |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | // --------------生产总览-------------- |
| | | var sql = @"select |
| | | sum(CASE AA.clmname WHEN '计划数量' THEN AA.clmqty ELSE 0 END) as 'plan_qty', |
| | |
| | | sum(CASE AA.clmname WHEN '缺陷产出' THEN AA.clmqty ELSE 0 END) as 'defect_qty' |
| | | from( |
| | | select isnull(sum(A.plan_qty),0) as clmqty,'计划数量'as clmname from TK_Wrk_Man A |
| | | where A.lm_date between @startopendate and @endclosedate |
| | | union all |
| | | left join TOrganization C on A.wkshp_code=C.org_code |
| | | left join TOrganization L on C.parent_id=L.id |
| | | where A.lm_date between @startopendate and @endclosedate "+search; |
| | | sql += @"union all |
| | | select isnull(sum(P.good_qty),0) as report_qty,'合格产出' as 合格产出 from TK_Wrk_Man A |
| | | inner join TK_Wrk_Step P on A.wo_code=P.wo_code and P.isend='Y' |
| | | where A.lm_date between @startopendate and @endclosedate |
| | | union all |
| | | left join TOrganization C on A.wkshp_code=C.org_code |
| | | left join TOrganization L on C.parent_id=L.id |
| | | where A.lm_date between @startopendate and @endclosedate "+search; |
| | | sql += @"union all |
| | | select (isnull(sum(P.ng_qty),0)+isnull(sum(P.bad_qty),0)) as ngqty,'缺陷产出' as 缺陷产出 from TK_Wrk_Man A |
| | | inner join TK_Wrk_Step P on A.wo_code=P.wo_code |
| | | where A.lm_date between @startopendate and @endclosedate |
| | | ) as AA"; |
| | | left join TOrganization C on A.wkshp_code=C.org_code |
| | | left join TOrganization L on C.parent_id=L.id |
| | | where A.lm_date between @startopendate and @endclosedate "+search+") as AA"; |
| | | dynamicParams.Add("@startopendate", startopendate + " 00:00:00"); |
| | | dynamicParams.Add("@endclosedate", endclosedate + " 23:59:59"); |
| | | var data0 = DapperHelper.selectdata(sql, dynamicParams); |
| | |
| | | select COUNT(A.id) as cluntqty, |
| | | case when A.status='START' then '执行中' when A.status='CLOSED' then '已结束' else '未开始' end as wo_status |
| | | from TK_Wrk_Man A |
| | | where A.lm_date between @startopendate and @endclosedate |
| | | group by A.status |
| | | ) as AA group by AA.wo_status"; |
| | | left join TOrganization C on A.wkshp_code=C.org_code |
| | | left join TOrganization L on C.parent_id=L.id |
| | | where A.lm_date between @startopendate and @endclosedate "+search+" group by A.status) as AA group by AA.wo_status"; |
| | | var data1 = DapperHelper.selectdata(sql1, dynamicParams); |
| | | dList.Add("dt1", data1); |
| | | // --------------缺陷统计-------------- |
| | |
| | | select A.plan_qty,M.partname,S.ng_qty,S.bad_qty from TK_Wrk_Man A |
| | | inner join (select wo_code, isnull(sum(ng_qty),0) as ng_qty,isnull(sum(bad_qty),0) as bad_qty from TK_Wrk_Step where ng_qty>0 or bad_qty>0 group by wo_code) S on A.wo_code=S.wo_code |
| | | inner join TMateriel_Info M on A.materiel_code=M.partcode |
| | | where A.lm_date between @startopendate and @endclosedate |
| | | ) as AA |
| | | group by AA.partname |
| | | order by defect_qty desc"; |
| | | left join TOrganization C on A.wkshp_code=C.org_code |
| | | left join TOrganization L on C.parent_id=L.id |
| | | where A.lm_date between @startopendate and @endclosedate "+search+") as AA group by AA.partname order by defect_qty desc"; |
| | | break; |
| | | case "stp"://按工序统计 |
| | | sql2 = @"select top 5 sum(AA.plan_qty) as plan_qty,AA.stepname,sum(AA.ng_qty)+sum(AA.bad_qty) as defect_qty from ( |
| | | select A.plan_qty,T.stepname,S.ng_qty,S.bad_qty from TK_Wrk_Man A |
| | | inner join (select wo_code,step_code, isnull(sum(ng_qty),0) as ng_qty,isnull(sum(bad_qty),0) as bad_qty from TK_Wrk_Step where ng_qty>0 or bad_qty>0 group by wo_code,step_code) S on A.wo_code=S.wo_code |
| | | inner join TStep T on S.step_code=T.stepcode |
| | | where A.lm_date between @startopendate and @endclosedate |
| | | ) as AA |
| | | group by AA.stepname |
| | | order by defect_qty desc"; |
| | | left join TOrganization C on A.wkshp_code=C.org_code |
| | | left join TOrganization L on C.parent_id=L.id |
| | | where A.lm_date between @startopendate and @endclosedate "+search+") as AA group by AA.stepname order by defect_qty desc"; |
| | | break; |
| | | default: |
| | | break; |
| | |
| | | #endregion |
| | | |
| | | #region[App生产进度看板单据信息] |
| | | public static ToMessage ProductionScheduleKanban(string ordertype, string partcode, string startopendate, string endclosedate) |
| | | public static ToMessage ProductionScheduleKanban(string stu_torgcode,string stu_torgtypecode, string ordertype, string partcode, string startopendate, string endclosedate) |
| | | { |
| | | Dictionary<object, object> dList = new Dictionary<object, object>(); |
| | | List<AppScheduleKanban> list = new List<AppScheduleKanban>(); |
| | | var dynamicParams = new DynamicParameters(); |
| | | string search = "",sql=""; |
| | | string search = "", search1 = "",sql =""; |
| | | DataTable dt; |
| | | try |
| | | { |
| | | switch (stu_torgtypecode) |
| | | { |
| | | case "": |
| | | break; |
| | | case "D": |
| | | search1 += "and L.org_code=@stu_torgcode "; |
| | | dynamicParams.Add("@stu_torgcode", stu_torgcode); |
| | | break; |
| | | case "W": |
| | | search1 += "and C.org_code=@stu_torgcode "; |
| | | dynamicParams.Add("@stu_torgcode", stu_torgcode); |
| | | break; |
| | | default: |
| | | break; |
| | | } |
| | | //根据查询条件,查找符合要求的单据 |
| | | switch (ordertype) |
| | | { |
| | |
| | | //获取单据信息 |
| | | sql = @"select distinct A.wo_code,T.partcode,T.partname,T.partspec,A.lm_date,sum(A.plan_qty) as orderqty |
| | | from TK_Wrk_Man A |
| | | left join TOrganization C on A.wkshp_code=C.org_code |
| | | left join TOrganization L on C.parent_id=L.id |
| | | left join TMateriel_Info T on A.materiel_code=T.partcode |
| | | where 1=1 "+search+" group by A.wo_code,T.partcode,T.partname,T.partspec,A.lm_date order by A.lm_date desc"; |
| | | where 1=1 " + search+search1+" group by A.wo_code,T.partcode,T.partname,T.partspec,A.lm_date order by A.lm_date desc"; |
| | | dt = DapperHelper.selectlist(sql, dynamicParams); |
| | | if (dt.Rows.Count > 0) |
| | | { |