代码加组织过滤

yl

2023-06-17 5b4fb9c56426b5096555560a44dd365b02853ad4

 VueWebApi/DLL/DAL/ProductionManagementDAL.cs

@@ -22,12 +22,27 @@


        #region[ERP订单查询]
        public static ToMessage ErpOrderSearch(string erporderstus, string erpordercode, string partcode, string partname, string partspec, int startNum, string paydatestartdate, string paydateenddate, string paydatestartdate1, string paydateenddate2, string creatuser, int endNum, string prop, string order)
        public static ToMessage ErpOrderSearch(string stu_torgcode,string stu_torgtypecode,string erporderstus, string erpordercode, string partcode, string partname, string partspec, int startNum, string paydatestartdate, string paydateenddate, string paydatestartdate1, string paydateenddate2, string creatuser, int endNum, string prop, string order)
        {
            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;
                }
                if (erporderstus != "" && erporderstus != null)
                {
                    search += "and A.status=@erporderstus ";
@@ -84,6 +99,7 @@
                            left join TOrganization C on A.wkshp_code=C.org_code
                            left join T_Sec_Stck D on A.stck_code=D.code 
                            left join TUser U on A.createuser=U.usercode 
                            left join TOrganization L on  C.parent_id=L.id
                            where A.is_delete<>'1' " + search;
                var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                mes.code = "200";
@@ -307,12 +323,27 @@


        #region[MES工单查询]
        public static ToMessage MesOrderSearch(string mesorderstus, string mesordercode, string sourceorder, string ordertype, string partcode, string partname, string partspec, int startNum, string creatuser, string createdate, int endNum, string prop, string order)
        public static ToMessage MesOrderSearch(string stu_torgcode,string stu_torgtypecode,string mesorderstus, string mesordercode, string sourceorder, string ordertype, string partcode, string partname, string partspec, int startNum, string creatuser, string createdate, int endNum, string prop, string order)
        {
            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;
                }
                if (mesorderstus != "" && mesorderstus != null)
                {
                    search += "and A.status=@mesorderstus ";
@@ -374,6 +405,7 @@
                            left join TFlw_Rout E on A.route_code=E.code
                            left join T_Sec_Stck F on A.stck_code=F.code 
                            left join TUser U on A.lm_user=U.usercode 
                            left join TOrganization L on  C.parent_id=L.id
                            where A.is_delete<>'1' " + search;
                var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                mes.code = "200";
@@ -470,7 +502,7 @@
        #endregion

        #region[产品编码查找工艺路线下拉接口]
        public static ToMessage PartSelectRoute(string partcode)
        public static ToMessage PartSelectRoute(string partcode,string wkshopcode)
        {
            string sql = "";
            var dynamicParams = new DynamicParameters();
@@ -480,8 +512,9 @@
                sql = @"select R.code,R.name,A.default_route  from TMateriel_Info A
                        inner join  TMateriel_Route M on A.partcode=M.materiel_code
                        inner join  TFlw_Rout R on M.route_code=R.code
                        where A.partcode=@partcode ";
                        where A.partcode=@partcode and M.torg_code=@torg_code";
                dynamicParams.Add("@partcode", partcode);
                dynamicParams.Add("@torg_code", wkshopcode);
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.Message = "查询成功!";
@@ -499,23 +532,38 @@
        #endregion

        #region[工艺路线查找车间下拉接口]
        public static ToMessage RouteSelectWkshop(string partcode, string routecode)
        public static ToMessage RouteSelectWkshop(string stu_torgcode,string stu_torgtypecode,string partcode)
        {
            string sql = "";
            string search = "";
            var dynamicParams = new DynamicParameters();
            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 F.org_code=@stu_torgcode ";
                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
                        break;
                    default:
                        break;
                }
                //获取车间下拉框数据
                sql = @"select distinct F.org_code,F.org_name  from TFlw_Rout A
                        inner join  TMateriel_Route M on A.code=M.route_code
                        inner join   TFlw_Rtdt B on A.code=B.rout_code
                sql = @"select distinct F.org_code,F.org_name   from TMateriel_Route M
                        inner join   TFlw_Rtdt B on M.route_code=B.rout_code
                        inner join TStep C on B.step_code=C.stepcode
                        inner join TFlw_Rteqp D on C.stepcode=D.step_code
                        inner join TEqpInfo  E on D.eqp_code=E.code
                        left join TOrganization F on E.wksp_code=F.org_code
                        where A.code=@routecode and M.materiel_code=@partcode and E.enable='Y'";
                        left join TOrganization L on  F.parent_id=L.id
                        where M.materiel_code=@partcode and E.enable='Y' "+search;
                dynamicParams.Add("@partcode", partcode);
                dynamicParams.Add("@routecode", routecode);
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.Message = "查询成功!";
@@ -1296,7 +1344,7 @@
        #endregion

        #region[生产开报工扫码获取工单对应工序任务(自制)]
        public static ToMessage MesOrderStepSearch(string orderstepqrcode, int startNum, int endNum, string prop, string order)
        public static ToMessage MesOrderStepSearch(string stu_torgcode,string stu_torgtypecode, string orderstepqrcode, int startNum, int endNum, string prop, string order)
        {
            var sql = "";
            string search = "";
@@ -1324,7 +1372,7 @@
                        stepcode = arra[1]; //获取指定字符串前面的字符
                    }

                    if (ordercode != "" && ordercode != null) //工单号不为空,工序号为空
                    if (ordercode != "" && stepcode == null) //工单号不为空,工序号为空
                    {
                        search += "and A.wo_code=@ordercode ";
                        dynamicParams.Add("@ordercode", ordercode);
@@ -1363,14 +1411,31 @@
                        }
                    }
                }
                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 F.org_code=@stu_torgcode ";
                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
                        break;
                    default:
                        break;
                }
                //根据条件查询工单工序任务(自制工序)
                sql = @"select A.status,A.wo_code,B.route_code,M.partcode,M.partname,M.partspec,A.seq,A.isbott,A.isend,
                            S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.bad_qty,A.plan_startdate,A.plan_enddate,B.lm_date
                            from TK_Wrk_Step A
                            left join TK_Wrk_Man B on A.wo_code=B.wo_code
                            left join TMateriel_Info M on B.materiel_code=M.partcode
                            left join TStep S on A.step_code=S.stepcode
                            where A.status in('ALLO','START') and S.flwtype='Z'  " + search;
                        S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.bad_qty,A.plan_startdate,A.plan_enddate,B.lm_date
                        from TK_Wrk_Step A
                        left join TK_Wrk_Man B on A.wo_code=B.wo_code
                        left join TMateriel_Info M on B.materiel_code=M.partcode
                        left join TStep S on A.step_code=S.stepcode
                        left join TOrganization F on B.wkshp_code=F.org_code
                        left join TOrganization L on  F.parent_id=L.id
                        where A.status in('ALLO','START') and S.flwtype='Z'  " + search;
                var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                if (data.ToList().Count > 0)
                {
@@ -1401,7 +1466,7 @@
        #endregion

        #region[生产开报工扫码获取工单对应工序任务(外协)]
        public static ToMessage MesOrderWxStepSearch(string orderstepqrcode, int startNum, int endNum, string prop, string order)
        public static ToMessage MesOrderWxStepSearch(string stu_torgcode,string stu_torgtypecode,string orderstepqrcode, int startNum, int endNum, string prop, string order)
        {
            var sql = "";
            string search = "";
@@ -1428,7 +1493,7 @@
                        ordercode = arra[0]; //获取指定字符串前面的字符
                        stepcode = arra[1]; //获取指定字符串前面的字符
                    }
                    if (ordercode != "" && ordercode != null) //工单号不为空,工序号为空
                    if (ordercode != "" && stepcode == null) //工单号不为空,工序号为空
                    {
                        search += "and A.wo_code=@ordercode ";
                        dynamicParams.Add("@ordercode", ordercode);
@@ -1467,13 +1532,30 @@
                        }
                    }
                }
                //根据条件查询工单工序任务(自制工序)
                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 F.org_code=@stu_torgcode ";
                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
                        break;
                    default:
                        break;
                }
                //根据条件查询工单工序任务(外协工序)
                sql = @"select A.status,A.wo_code,B.route_code,M.partcode,M.partname,M.partspec,A.seq,A.isbott,A.isend,
                            S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.bad_qty,A.plan_startdate,A.plan_enddate,B.lm_date
                            from TK_Wrk_Step A
                            left join TK_Wrk_Man B on A.wo_code=B.wo_code
                            left join TMateriel_Info M on B.materiel_code=M.partcode
                            left join TStep S on A.step_code=S.stepcode
                            left join TOrganization F on B.wkshp_code=F.org_code
                            left join TOrganization L on  F.parent_id=L.id
                            where A.status in('ALLO','START') and S.flwtype='W'  " + search;
                var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                if (data.ToList().Count > 0)
@@ -1505,7 +1587,7 @@
        #endregion

        #region[生产开报工扫码获取工单对应工序任务(不良)]
        public static ToMessage MesOrderNgStepSearch(string orderstepqrcode, int startNum, int endNum, string prop, string order)
        public static ToMessage MesOrderNgStepSearch(string stu_torgcode,string stu_torgtypecode,string orderstepqrcode, int startNum, int endNum, string prop, string order)
        {
            var sql = "";
            string search = "";
@@ -1532,7 +1614,7 @@
                        ordercode = arra[0]; //获取指定字符串前面的字符
                        stepcode = arra[1]; //获取指定字符串前面的字符
                    }
                    if (ordercode != "" && ordercode != null) //工单号不为空,工序号为空
                    if (ordercode != "" && stepcode == null) //工单号不为空,工序号为空
                    {
                        search += "and A.wo_code=@ordercode ";
                        dynamicParams.Add("@ordercode", ordercode);
@@ -1561,14 +1643,31 @@
                        return mes;
                    }
                }
                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 F.org_code=@stu_torgcode ";
                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
                        break;
                    default:
                        break;
                }
                //根据条件查询工单工序任务,且不良数量大于0
                sql = @"select A.wo_code,M.partcode,M.partname,M.partspec,A.seq,A.isend,
                            S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.bad_qty,B.lm_date
                            from TK_Wrk_Step A
                            left join TK_Wrk_Man B on A.wo_code=B.wo_code
                            left join TMateriel_Info M on B.materiel_code=M.partcode
                            left join TStep S on A.step_code=S.stepcode
                            where A.status in('ALLO','START') and A.ng_qty>0 " + search;
                        S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.bad_qty,B.lm_date
                        from TK_Wrk_Step A
                        left join TK_Wrk_Man B on A.wo_code=B.wo_code
                        left join TMateriel_Info M on B.materiel_code=M.partcode
                        left join TStep S on A.step_code=S.stepcode
                        left join TOrganization F on B.wkshp_code=F.org_code
                        left join TOrganization L on  F.parent_id=L.id
                        where A.status in('ALLO','START') and A.ng_qty>0 " + search;
                var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                if (data.ToList().Count > 0)
                {
@@ -1806,9 +1905,11 @@
                    return mes;
                }
                //获取工序关联的设备
                sql = @"select B.code,B.name from TFlw_Rteqp A
                sql = @"select B.code,B.name  from TK_Wrk_Man M
                        inner join TFlw_Rtdt R on M.route_code=R.rout_code
                        inner join TFlw_Rteqp A on R.step_code=A.step_code
                        left join TEqpInfo B on A.eqp_code=B.code
                        where A.style='E' and A.step_code=@stepcode and B.enable='Y'";
                        where A.style='E' and M.wo_code=@wo_code and A.step_code=@stepcode and B.enable='Y'";
                dynamicParams.Add("@wo_code", ordercode);
                dynamicParams.Add("@stepcode", stepcode);
                var data = DapperHelper.selectdata(sql, dynamicParams);
@@ -1828,14 +1929,38 @@
        #endregion

        #region[生产开报工：报工时获取生产班组下拉框]
        public static ToMessage MesOrderStepReportSelectUserGroup()
        public static ToMessage MesOrderStepReportSelectUserGroup(string stu_torgcode,string stu_torgtypecode,string wkshopcode)
        {
            string sql = "";
            string search = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                if (wkshopcode != "" && wkshopcode != null)
                {
                    search += "and A.torg_code=@workShop ";
                    dynamicParams.Add("@workShop", wkshopcode);
                }
                else
                {
                    switch (stu_torgtypecode)
                    {
                        case "":
                            search += "and T.description=@description ";
                            dynamicParams.Add("@description", "W");
                            break;
                        case "D":
                            search += "and  L.org_code=@stu_torgcode ";
                            dynamicParams.Add("@stu_torgcode", stu_torgcode);
                            break;
                    }
                }
                //获取用户组
                sql = @"select group_code,group_name from TGroup";
                var data = DapperHelper.selecttable(sql);
                sql = @"select group_code,group_name from TGroup  A
                        left join TOrganization T on A.torg_code=T.org_code 
                        left join TOrganization as L on T.parent_id=L.id 
                        where 1=1 "+search;
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.Message = "查询成功!";
                mes.data = data;
@@ -2972,12 +3097,27 @@


        #region[MES工单批量关闭查询]
        public static ToMessage MesOrderBitchClosedSearch(string mesorderstus, string mesordercode, string sourceorder, string ordertype, string partcode, string partname, string partspec, int startNum, string creatuser, string createdate, int endNum, string prop, string order)
        public static ToMessage MesOrderBitchClosedSearch(string stu_torgcode,string stu_torgtypecode,string mesorderstus, string mesordercode, string sourceorder, string ordertype, string partcode, string partname, string partspec, int startNum, string creatuser, string createdate, int endNum, string prop, string order)
        {
            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;
                }
                if (mesorderstus != "" && mesorderstus != null)
                {
                    search += "and A.status=@mesorderstus ";
@@ -3042,6 +3182,7 @@
                            left join TFlw_Rout E on A.route_code=E.code
                            left join T_Sec_Stck F on A.stck_code=F.code 
                            left join TUser U on A.lm_user=U.usercode 
                            left join TOrganization L on  C.parent_id=L.id
                            where A.is_delete<>'1' " + search;
                var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                mes.code = "200";
@@ -4633,7 +4774,7 @@
                // --------------查询指定数据--------------
                var total = 0; //总条数
                var sql = @"select *   from(
                            select A.inbarcode,E.saleOrderid,isnull(E.saleOrderCode,'') as saleOrderCode,E.saleOrderDetailId,E.woid as mpoid,M.m_po,E.sbid,A.wo_code,E.materiel_id,P.partcode,P.partname,P.partspec,E.unitid,E.unitcode,E.unitname,
                            select A.inbarcode,E.saleOrderid,isnull(E.saleOrderCode,'') as saleOrderCode,E.saleOrderDetailId,E.woid as mpoid,M.m_po,E.sbid,M.id as wo_id,A.wo_code,E.materiel_id,P.partcode,P.partname,P.partspec,E.unitid,E.unitcode,E.unitname,
                            A.step_code,E.wkshp_id,M.wkshp_code,stck_id,K.code as stockcode,k.name as stockname,
                            E.saleOrderqty,E.qty,M.plan_qty,A.good_qty,isnull(A.inhouseqty,0) as inhouseqty,A.good_qty-isnull(A.inhouseqty,0) as stinhouseqty,M.lm_date,A.style   
                            from  TK_Wrk_Record A
@@ -4644,7 +4785,7 @@
                            left join T_Sec_Stck K on E.stck_code=K.code
                            where A.style='B' and S.isend='Y' and A.good_qty>0
                            union all
                            select A.inbarcode,E.saleOrderid,isnull(E.saleOrderCode,'') as saleOrderCode,E.saleOrderDetailId,E.woid as mpoid,M.m_po,E.sbid,A.wo_code,E.materiel_id,P.partcode,P.partname,P.partspec,E.unitid,E.unitcode,E.unitname,
                            select A.inbarcode,E.saleOrderid,isnull(E.saleOrderCode,'') as saleOrderCode,E.saleOrderDetailId,E.woid as mpoid,M.m_po,E.sbid,M.id as wo_id,A.wo_code,E.materiel_id,P.partcode,P.partname,P.partspec,E.unitid,E.unitcode,E.unitname,
                            A.step_code,E.wkshp_id,M.wkshp_code,stck_id,K.code as stockcode,k.name as stockname,
                            E.saleOrderqty,E.qty,M.plan_qty,A.sqty as sqty,isnull(A.inhouseqty,0) as inhouseqty,A.sqty-isnull(A.inhouseqty,0) as stinhouseqty,M.lm_date,A.style   
                            from  TK_Wrk_OutRecord A
@@ -4654,7 +4795,7 @@
                            left join TKimp_Ewo E on M.sourceid=E.id
                            left join T_Sec_Stck K on E.stck_code=K.code
                            where A.style='S' and S.isend='Y' and A.sqty>0
                            ) as AA  where 1=1 " + search;
                            ) as AA  where AA.good_qty>AA.inhouseqty " + search;
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.Message = "查询成功!";
@@ -4752,17 +4893,18 @@
                        }
                    });
                    //写入MES库存表
                    sql = @"insert into TK_WMS_Stock(labcode,materiel_code,storehouse_code,qty,lm_user,lm_date)
                        values(@labcode,@materiel_code,@storehouse_code,@qty,@lm_user,@lm_date)";
                    sql = @"insert into TK_WMS_Stock(hbillno,labcode,materiel_code,storehouse_code,qty,lm_user,lm_date)
                        values(@hbillno,@labcode,@materiel_code,@storehouse_code,@qty,@lm_user,@lm_date)";
                    list.Add(new
                    {
                        str = sql,
                        parm = new
                        {
                            labcode=sub_arra[i]["inbarcode"].ToString(),
                            hbillno = obj["head"]["hbillno"].ToString(),
                            labcode = sub_arra[i]["inbarcode"].ToString(),
                            materiel_code = sub_arra[i]["partcode"].ToString(),
                            storehouse_code = sub_arra[i]["stockcode"].ToString(),
                            qty =decimal.Parse(sub_arra[i]["stinhouseqty"].ToString()),
                            qty = decimal.Parse(sub_arra[i]["stinhouseqty"].ToString()),
                            lm_user = username,
                            lm_date = DateTime.Now.ToString()
                        }
@@ -4776,91 +4918,113 @@
                    str = sql,
                    parm = new
                    {
                        docu_typecode="1202",
                        hbillno= obj["head"]["hbillno"].ToString(),
                        hsoucenillnoid= obj["head"]["sourceVoucherId"].ToString(),
                        docu_typecode = "1202",
                        hbillno = obj["head"]["hbillno"].ToString(),
                        hsoucenillnoid = obj["head"]["sourceVoucherId"].ToString(),
                        hsoucenillno = obj["head"]["sourceVoucherCode"].ToString(),
                        saleorderid = obj["head"]["saleOrderId"].ToString(),
                        saleordercode = obj["head"]["saleOrderCode"].ToString(),
                        status = "NEW",
                        wkshpcode = obj["head"]["wkshpcode"].ToString(),
                        lm_user = username,
                        lm_date= DateTime.Now.ToString()
                        lm_date = DateTime.Now.ToString()
                    }
                });

                //获取ERP入库表sql
                DataTable dt = DapperHelper.lissql("h_p_MesInErpProductWareHous");
                //DataTable dt = DapperHelper.lissql("h_p_MesInErpProductWareHous");
                //写入ERP入库记录主表
                sql = @"" + dt.Rows[0]["cname"].ToString() + "";
                list.Add(new
                {
                    str = sql,
                    parm = new
                    {
                        code = obj["head"]["hbillno"].ToString(),
                        sourceVoucherId = obj["head"]["sourceVoucherId"].ToString(),
                        sourceVoucherCode = obj["head"]["sourceVoucherCode"].ToString(),
                        saleOrderId = obj["head"]["saleOrderId"].ToString(),
                        saleOrderCode = obj["head"]["saleOrderCode"].ToString(),
                        rdDirectionFlag = obj["head"]["rdDirectionFlag"].ToString(),
                        makerid = obj["head"]["makerid"].ToString(),
                        maker = obj["head"]["maker"].ToString(),
                        accountingyear = obj["head"]["accountingyear"].ToString(),
                        VoucherYear = obj["head"]["VoucherYear"].ToString(),
                        VoucherPeriod = obj["head"]["VoucherPeriod"].ToString(),
                        ManufactureOrderCode = obj["head"]["ManufactureOrderCode"].ToString(),
                        idbusitype = obj["head"]["idbusitype"].ToString(),
                        iddepartment = obj["head"]["iddepartment"].ToString(),
                        idrdstyle = obj["head"]["idrdstyle"].ToString(),
                        idwarehouse = obj["head"]["idwarehouse"].ToString(),
                        voucherState = obj["head"]["voucherState"].ToString(),
                        idvouchertype = obj["head"]["idvouchertype"].ToString(),
                        voucherdate = obj["head"]["voucherdate"].ToString(),
                        madedate = obj["head"]["madedate"].ToString(),
                        createdtime = obj["head"]["createdtime"].ToString(),
                        DataSource = obj["head"]["DataSource"].ToString(),
                //sql = @"" + dt.Rows[0]["cname"].ToString() + "";
                //list.Add(new
                //{
                //    str = sql,
                //    parm = new
                //    {
                //        code = obj["head"]["hbillno"].ToString(),
                //        sourceVoucherId = obj["head"]["sourceVoucherId"].ToString(),
                //        sourceVoucherCode = obj["head"]["sourceVoucherCode"].ToString(),
                //        saleOrderId = obj["head"]["saleOrderId"].ToString(),
                //        saleOrderCode = obj["head"]["saleOrderCode"].ToString(),
                //        rdDirectionFlag = obj["head"]["rdDirectionFlag"].ToString(),
                //        makerid = obj["head"]["makerid"].ToString(),
                //        maker = obj["head"]["maker"].ToString(),
                //        accountingyear = obj["head"]["accountingyear"].ToString(),
                //        VoucherYear = obj["head"]["VoucherYear"].ToString(),
                //        VoucherPeriod = obj["head"]["VoucherPeriod"].ToString(),
                //        ManufactureOrderCode = obj["head"]["ManufactureOrderCode"].ToString(),
                //        idbusitype = obj["head"]["idbusitype"].ToString(),
                //        iddepartment = obj["head"]["iddepartment"].ToString(),
                //        idrdstyle = obj["head"]["idrdstyle"].ToString(),
                //        idwarehouse = obj["head"]["idwarehouse"].ToString(),
                //        voucherState = obj["head"]["voucherState"].ToString(),
                //        idvouchertype = obj["head"]["idvouchertype"].ToString(),
                //        voucherdate = obj["head"]["voucherdate"].ToString(),
                //        madedate = obj["head"]["madedate"].ToString(),
                //        createdtime = obj["head"]["createdtime"].ToString(),
                //        DataSource = obj["head"]["DataSource"].ToString(),
                //        idsourcevouchertype= obj["head"]["idsourcevouchertype"].ToString()

                    }
                });
                //    }
                //});
                //写入ERP、MES入库记录子表
                for (int j = 0; j < subsum_arra.Count; j++)
                {
                    //写入ERP入库记录子表
                    sql = @"" + dt.Rows[1]["cname"].ToString() + "";
                    list.Add(new
                    {
                        str = sql,
                        parm = new
                        {
                            code = subsum_arra[j]["code"].ToString(),
                            arrivalQuantity = subsum_arra[j]["arrivalQuantity"].ToString(),
                            quantity = subsum_arra[j]["quantity"].ToString(),
                            compositionQuantity = subsum_arra[j]["compositionQuantity"].ToString(),
                            baseQuantity = subsum_arra[j]["baseQuantity"].ToString(),
                            sourceVoucherId = subsum_arra[j]["sourceVoucherId"].ToString(),
                            sourceVoucherCode = subsum_arra[j]["sourceVoucherCode"].ToString(),
                            sourceVoucherDetailId = subsum_arra[j]["sourceVoucherDetailId"].ToString(),
                            idsourcevouchertype = subsum_arra[j]["idsourcevouchertype"].ToString(),
                            saleOrderId = subsum_arra[j]["saleOrderId"].ToString(),
                            saleOrderCode = subsum_arra[j]["saleOrderCode"].ToString(),
                            saleOrderDetailId = subsum_arra[j]["saleOrderDetailId"].ToString(),
                            ManufactureOrderId = subsum_arra[j]["ManufactureOrderId"].ToString(),
                            ManufactureOrderCode = subsum_arra[j]["ManufactureOrderCode"].ToString(),
                            ManufactureOrderDetailId = subsum_arra[j]["ManufactureOrderDetailId"].ToString(),
                            idbusiTypeByMergedFlow = subsum_arra[j]["idbusiTypeByMergedFlow"].ToString(),
                            idinventory = subsum_arra[j]["idinventory"].ToString(),
                            idbaseunit = subsum_arra[j]["idbaseunit"].ToString(),
                            idunit = subsum_arra[j]["idunit"].ToString(),
                            idwarehouse = subsum_arra[j]["idwarehouse"].ToString(),
                            SourceVoucherIdByMergedFlow = subsum_arra[j]["SourceVoucherIdByMergedFlow"].ToString(),
                            SourceVoucherCodeByMergedFlow = subsum_arra[j]["SourceVoucherCodeByMergedFlow"].ToString(),
                            SourceVoucherDetailIdByMergedFlow = subsum_arra[j]["SourceVoucherDetailIdByMergedFlow"].ToString(),
                            idsourceVoucherTypeByMergedFlow = subsum_arra[j]["idsourceVoucherTypeByMergedFlow"].ToString(),
                            createdtime = subsum_arra[j]["createdtime"].ToString(),
                            DataSource = subsum_arra[j]["DataSource"].ToString()
                        }
                    });
                    //sql = @"" + dt.Rows[1]["cname"].ToString() + "";
                    //list.Add(new
                    //{
                    //    str = sql,
                    //    parm = new
                    //    {
                    //        code = subsum_arra[j]["code"].ToString(),
                    //        arrivalQuantity = subsum_arra[j]["arrivalQuantity"].ToString(),
                    //        quantity = subsum_arra[j]["quantity"].ToString(),
                    //        compositionQuantity = subsum_arra[j]["compositionQuantity"].ToString(),
                    //        baseQuantity = subsum_arra[j]["baseQuantity"].ToString(),
                    //        sourceVoucherId = subsum_arra[j]["sourceVoucherId"].ToString(),
                    //        sourceVoucherCode = subsum_arra[j]["sourceVoucherCode"].ToString(),
                    //        sourceVoucherDetailId = subsum_arra[j]["sourceVoucherDetailId"].ToString(),
                    //        idsourcevouchertype = subsum_arra[j]["idsourcevouchertype"].ToString(),
                    //        saleOrderId = subsum_arra[j]["saleOrderId"].ToString(),
                    //        saleOrderCode = subsum_arra[j]["saleOrderCode"].ToString(),
                    //        saleOrderDetailId = subsum_arra[j]["saleOrderDetailId"].ToString(),
                    //        ManufactureOrderId = subsum_arra[j]["ManufactureOrderId"].ToString(),
                    //        ManufactureOrderCode = subsum_arra[j]["ManufactureOrderCode"].ToString(),
                    //        ManufactureOrderDetailId = subsum_arra[j]["ManufactureOrderDetailId"].ToString(),
                    //        idbusiTypeByMergedFlow = subsum_arra[j]["idbusiTypeByMergedFlow"].ToString(),
                    //        idinventory = subsum_arra[j]["idinventory"].ToString(),
                    //        idbaseunit = subsum_arra[j]["idbaseunit"].ToString(),
                    //        idunit = subsum_arra[j]["idunit"].ToString(),
                    //        idwarehouse = subsum_arra[j]["idwarehouse"].ToString(),
                    //        SourceVoucherIdByMergedFlow = subsum_arra[j]["SourceVoucherIdByMergedFlow"].ToString(),
                    //        SourceVoucherCodeByMergedFlow = subsum_arra[j]["SourceVoucherCodeByMergedFlow"].ToString(),
                    //        SourceVoucherDetailIdByMergedFlow = subsum_arra[j]["SourceVoucherDetailIdByMergedFlow"].ToString(),
                    //        idsourceVoucherTypeByMergedFlow = subsum_arra[j]["idsourceVoucherTypeByMergedFlow"].ToString(),
                    //        createdtime = subsum_arra[j]["createdtime"].ToString(),
                    //        DataSource = subsum_arra[j]["DataSource"].ToString()
                    //    }
                    //});
                    //写入ERP现存量查询表
                    //sql = @"" + dt.Rows[2]["cname"].ToString() + "";
                    //list.Add(new
                    //{
                    //    str = sql,
                    //    parm = new
                    //    {
                    //        idinventory = subsum_arra[j]["idinventory"].ToString(),
                    //        idwarehouse = subsum_arra[j]["idwarehouse"].ToString(),
                    //        propertyName = "ProductForReceive",
                    //        baseQuantity= subsum_arra[j]["quantity"].ToString(),
                    //        IdMarketingOrgan="1",
                    //        idbaseunit= subsum_arra[j]["idbaseunit"].ToString(),
                    //        updated= DateTime.Now.ToString(),
                    //        isCarriedForwardOut ="0",
                    //        isCarriedForwardIn = "0"
                    //    }
                    //}); 



                    //写入MES入库记录子表
                    sql = @"insert into TK_WMS_Inwh_Sub(hbillno,rownumber,materiel_code,storehouse_code,qty)
                        values(@hbillno,@rownumber,@materiel_code,@storehouse_code,@qty)";
@@ -4907,5 +5071,108 @@
            return mes;
        }
        #endregion


        #region[生产入库扫描条码]
        public static ToMessage MesAppProductInHouseOrderBarCodeSearch(string labcode)
        {
            string sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                //判断条码是否存在
                sql = @"select distinct AA.inbarcode  from (
                         select A.inbarcode
                         from  TK_Wrk_Record A
                         inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
                         where A.style='B' and S.isend='Y' and A.good_qty>0 and A.inbarcode=@labcode
                         union all
                         select A.inbarcode
                         from  TK_Wrk_OutRecord A
                         inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
                         where A.style='S' and S.isend='Y' and A.sqty>0 and A.inbarcode=@labcode
                         ) as AA";
                dynamicParams.Add("@labcode", labcode);
                var data0 = DapperHelper.selectdata(sql, dynamicParams);
                if (data0.Rows.Count <= 0)
                {
                    mes.code = "300";
                    mes.Message = "无效条码!";
                    mes.data = null;
                    return mes;
                }
                //判断条码是否存可用
                sql = @"select distinct AA.inbarcode,AA.good_qty,AA.inhouseqty  from (
                        select A.inbarcode,sum(A.good_qty) as good_qty,sum(isnull(A.inhouseqty,0)) as inhouseqty
                        from  TK_Wrk_Record A
                        inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
                        where A.style='B' and S.isend='Y' and A.good_qty>0 and A.inbarcode=@labcode
                        group by A.inbarcode
                        union all
                        select A.inbarcode,sum(A.sqty) as good_qty,sum(isnull(A.inhouseqty,0)) as inhouseqty
                        from  TK_Wrk_OutRecord A
                        inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
                        where A.style='S' and S.isend='Y' and A.sqty>0 and A.inbarcode=@labcode
                        group by A.inbarcode
                        ) as AA  where AA.good_qty>AA.inhouseqty ";
                dynamicParams.Add("@labcode", labcode);
                var data1 = DapperHelper.selectdata(sql, dynamicParams);
                if (data1.Rows.Count <= 0)
                {
                    mes.code = "300";
                    mes.Message = "当前条码已入库!";
                    mes.data = null;
                    return mes;
                }

                //根据采购订单号查询物料信息，供应商信息
                sql = @"select *   from(
                        select A.inbarcode,E.saleOrderid,isnull(E.saleOrderCode,'') as saleOrderCode,E.saleOrderDetailId,E.woid as mpoid,M.m_po,E.sbid,M.id as wo_id,A.wo_code,E.materiel_id,P.partcode,P.partname,P.partspec,E.unitid,E.unitcode,E.unitname,
                        A.step_code,E.wkshp_id,M.wkshp_code,stck_id,K.code as stockcode,k.name as stockname,
                        E.saleOrderqty,E.qty,M.plan_qty,A.good_qty,isnull(A.inhouseqty,0) as inhouseqty,A.good_qty-isnull(A.inhouseqty,0) as stinhouseqty,A.lm_date,A.style   
                        from  TK_Wrk_Record A
                        inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
                        inner join TK_Wrk_Man M on S.wo_code=M.wo_code
                        inner join TMateriel_Info P on M.materiel_code=P.partcode
                        left join TKimp_Ewo E on M.sourceid=E.id
                        left join T_Sec_Stck K on E.stck_code=K.code
                        where A.style='B' and S.isend='Y' and A.good_qty>0 and A.inbarcode=@labcode
                        union all
                        select A.inbarcode,E.saleOrderid,isnull(E.saleOrderCode,'') as saleOrderCode,E.saleOrderDetailId,E.woid as mpoid,M.m_po,E.sbid,M.id as wo_id,A.wo_code,E.materiel_id,P.partcode,P.partname,P.partspec,E.unitid,E.unitcode,E.unitname,
                        A.step_code,E.wkshp_id,M.wkshp_code,stck_id,K.code as stockcode,k.name as stockname,
                        E.saleOrderqty,E.qty,M.plan_qty,A.sqty as sqty,isnull(A.inhouseqty,0) as inhouseqty,A.sqty-isnull(A.inhouseqty,0) as stinhouseqty,A.lm_date,A.style   
                        from  TK_Wrk_OutRecord A
                        inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
                        inner join TK_Wrk_Man M on S.wo_code=M.wo_code
                        inner join TMateriel_Info P on M.materiel_code=P.partcode
                        left join TKimp_Ewo E on M.sourceid=E.id
                        left join T_Sec_Stck K on E.stck_code=K.code
                        where A.style='S' and S.isend='Y' and A.sqty>0 and A.inbarcode=@labcode
                        ) as AA  where AA.good_qty>AA.inhouseqty";
                dynamicParams.Add("@labcode", labcode);
                var data = DapperHelper.selectdata(sql, dynamicParams);
                if (data.Rows.Count > 0)
                {
                    mes.code = "200";
                    mes.Message = "查询成功!";
                    mes.data = data;
                }
                else
                {
                    mes.code = "300";
                    mes.Message = "暂无物料数据!";
                    mes.data = null;
                }
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.Message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
    }
}