灵翔API
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
yl
2022-09-28 0aae85d3e241b2aa415c96f12e9f6ac415cffa49 
 VueWebApi/DLL/DAL/ProductionManagementDAL.cs


@@ -138,18 +138,20 @@


                    }


                    if (i == Convert.ToInt32(ordernum))  //最后一单时


                    {


                        sql = @"insert into TK_Wrk_Man(wo_code,status,wkshp_code,plan_qty,stck_code,materiel_code,m_po,lm_user,lm_date) values(@wo_code,@status,@wkshp_code,@plan_qty,@stck_code,@materiel_code,@m_po,@username,@CreateDate)";


                        sql = @"insert into TK_Wrk_Man(wo_code,wotype,status,wkshp_code,plan_qty,stck_code,materiel_code,sourceid,m_po,lm_user,lm_date) values(@wo_code,@wotype,@status,@wkshp_code,@plan_qty,@stck_code,@materiel_code,@sourceid,@m_po,@username,@CreateDate)";


                        list.Add(new


                        {


                            str = sql,


                            parm = new


                            {


                                wo_code = wo,


                                wotype="PO",


                                status = "NEW",


                                wkshp_code = wkshopcode,


                                plan_qty = cdqty + (decimal.Parse(markqty) - sumqty),  //末单下单数量=切分数量+(下单数量-累计切分下单数量)


                                stck_code = warehousecode,


                                materiel_code = partcode,


                                sourceid=erporderid,


                                m_po = erpordercode,


                                username = username,


                                CreateDate = DateTime.Now.ToString()


@@ -160,18 +162,20 @@


                    else


                    {




                        sql = @"insert into TK_Wrk_Man(wo_code,status,wkshp_code,plan_qty,stck_code,materiel_code,m_po,lm_user,lm_date) values(@wo_code,@status,@wkshp_code,@plan_qty,@stck_code,@materiel_code,@m_po,@username,@CreateDate)";


                        sql = @"insert into TK_Wrk_Man(wo_code,wotype,status,wkshp_code,plan_qty,stck_code,materiel_code,sourceid,m_po,lm_user,lm_date) values(@wo_code,@wotype,@status,@wkshp_code,@plan_qty,@stck_code,@materiel_code,@sourceid,@m_po,@username,@CreateDate)";


                        list.Add(new


                        {


                            str = sql,


                            parm = new


                            {


                                wo_code = wo,


                                wotype = "PO",


                                status = "NEW",


                                wkshp_code = wkshopcode,


                                plan_qty = cdqty,


                                stck_code = warehousecode,


                                materiel_code = partcode,


                                sourceid = erporderid,


                                m_po = erpordercode,


                                username = username,


                                CreateDate = DateTime.Now.ToString()


@@ -296,7 +300,7 @@






        #region[MES工单查询]


        public static ToMessage ErpOrderSearch(string mesorderstus, string mesordercode, string partcode, string partname, string partspec, int startNum, string creatuser, string createdate, int endNum, string prop, string order)


        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)


        {


            var dynamicParams = new DynamicParameters();


            string search = "";


@@ -311,6 +315,16 @@


                {


                    search += "and A.wo_code like '%'+@mesordercode+'%' ";


                    dynamicParams.Add("@mesordercode", mesordercode);


                }


                if (sourceorder != "" && sourceorder != null)


                {


                    search += "and A.m_po like '%'+@sourceorder+'%' ";


                    dynamicParams.Add("@sourceorder", sourceorder);


                }


                if (ordertype != "" && ordertype != null)


                {


                    search += "and A.wotype like '%'+@ordertype+'%' ";


                    dynamicParams.Add("@ordertype", ordertype);


                }


                if (partcode != "" && partcode != null)


                {


@@ -344,8 +358,8 @@


                }


                // --------------查询指定数据--------------


                var total = 0; //总条数


                var sql = @"select A.status,A.wo_code,A.materiel_code as partcode,B.partname,B.partspec,A.plan_qty,A.wkshp_code,C.org_name as wkshp_name,


                            A.route_code,E.name as route_name,A.stck_code,F.name as stck_name,A.plan_startdate,A.plan_enddate,A.piroque,A.m_po,U.username as lm_user,A.lm_date


                var sql = @"select A.id, A.status,A.wotype,A.wo_code,A.materiel_code as partcode,B.partname,B.partspec,A.plan_qty,A.wkshp_code,C.org_name as wkshp_name,


                            A.route_code,E.name as route_name,A.stck_code,F.name as stck_name,A.plan_startdate,A.plan_enddate,A.piroque,A.sourceid,A.m_po,U.username as lm_user,A.lm_date


                            from TK_Wrk_Man A


                            left join TMateriel_Info B on A.materiel_code=B.partcode


                            left join TOrganization C on A.wkshp_code=C.org_code


@@ -463,7 +477,7 @@


        #endregion




        #region[MES工单新增、编辑提交]


        public static ToMessage AddUpdateMesOrder(string mesorderstus, string mesordercode, string partcode, string mesqty, string routecode, string wkshopcode, string planstartdate, string planenddate, string orderlev, string username, string opertype)


        public static ToMessage AddUpdateMesOrder(string mesorderstus,string sourceorder,string ordertype, string mesordercode, string partcode, string mesqty, string routecode, string wkshopcode, string planstartdate, string planenddate, string orderlev, string username, string opertype)


        {


            var sql = "";


            var dynamicParams = new DynamicParameters();


@@ -473,14 +487,16 @@


                if (opertype == "Add")


                {


                    //写入工单表


                    sql = @"insert into TK_Wrk_Man(wo_code,status,wkshp_code,plan_qty,plan_startdate,plan_enddate,route_code,stck_code,lm_user,lm_date,materiel_code,m_po,piroque)


                                values(@mesordercode,@mesorderstus,@wkshopcode,@mesqty,@planstartdate,@planenddate,@routecode,@stck_code,@username,@CreateDate,@materiel_code,@m_po,@orderlev)";


                    sql = @"insert into TK_Wrk_Man(wo_code,wotype,status,wkshp_code,plan_qty,plan_startdate,plan_enddate,route_code,stck_code,lm_user,lm_date,materiel_code,m_po,piroque)


                                values(@mesordercode,@wotype,@mesorderstus,@wkshopcode,@mesqty,@planstartdate,@planenddate,@routecode,@stck_code,@username,@CreateDate,@materiel_code,@m_po,@orderlev)";


                    list.Add(new


                    {


                        str = sql,


                        parm = new


                        {


                            mesordercode = mesordercode,


                            wotype = ordertype,


                            m_po = sourceorder,


                            mesorderstus = "ALLO", //派发


                            wkshopcode = wkshopcode,


                            mesqty = mesqty,


@@ -491,7 +507,6 @@


                            username = username,


                            CreateDate = DateTime.Now.ToString(),


                            materiel_code = partcode,


                            m_po = "",


                            orderlev = orderlev


                        }


                    });


@@ -608,7 +623,7 @@


        #endregion




        #region[MES工单删除]


        public static ToMessage DeleteMesOrder(string wocode, string m_po, string orderqty)


        public static ToMessage DeleteMesOrder(string souceid, string wocode, string m_po, string orderqty)


        {


            var sql = "";


            List<object> list = new List<object>();


@@ -624,21 +639,22 @@


                    if (m_po != "" && m_po != null)


                    {


                        //查询生产订单表数据


                        sql = @"select *  from TKimp_Ewo where wo=@m_po";


                        sql = @"select *  from TKimp_Ewo where wo=@m_po and id=@souceid";


                        dynamicParams.Add("@m_po", m_po);


                        dynamicParams.Add("@souceid", souceid);


                        var data0 = DapperHelper.selectdata(sql, dynamicParams);


                        decimal relse_qty = decimal.Parse(data0.Rows[0]["RELSE_QTY"].ToString());//以下单数量


                        if ((relse_qty - decimal.Parse(orderqty)) == 0)  //全部撤销 订单状态回写未开始,已下单数量为0


                        {


                            //回写订单表状态及已下单数量


                            sql = @"update TKimp_Ewo set status='NEW',relse_qty=0  where wo=@m_po";


                            list.Add(new { str = sql, parm = new { m_po = m_po } });


                            sql = @"update TKimp_Ewo set status='NEW',relse_qty=0  where wo=@m_po and id=@souceid";


                            list.Add(new { str = sql, parm = new { m_po = m_po, souceid= souceid } });


                        }


                        else


                        {


                            //回写订单表状态及已下单数量


                            sql = @"update TKimp_Ewo set status='CREATING',relse_qty=relse_qty-@orderqty  where wo=@m_po";


                            list.Add(new { str = sql, parm = new { m_po = m_po, orderqty = decimal.Parse(orderqty) } });


                            sql = @"update TKimp_Ewo set status='CREATING',relse_qty=relse_qty-@orderqty  where wo=@m_po and id=@souceid";


                            list.Add(new { str = sql, parm = new { m_po = m_po, souceid= souceid, orderqty = decimal.Parse(orderqty) } });


                        }


                    }


                    //删除工单工序表


@@ -684,7 +700,7 @@


        #endregion




        #region[MES工单关闭]


        public static ToMessage ClosedMesOrder(string wocode, string m_po)


        public static ToMessage ClosedMesOrder(string username,string wocode, string m_po)


        {


            var sql = "";


            List<object> list = new List<object>();


@@ -695,8 +711,8 @@


                sql = @"update TK_Wrk_Step set status='CLOSED'  where wo_code=@wocode";


                list.Add(new { str = sql, parm = new { wocode = wocode } });


                //回写工单表状态为(关闭)


                sql = @"update TK_Wrk_Man set status='CLOSED'  where wo_code=@wocode";


                list.Add(new { str = sql, parm = new { wocode = wocode } });


                sql = @"update TK_Wrk_Man set status='CLOSED',closeuser=@username,closedate=@closedate  where wo_code=@wocode";


                list.Add(new { str = sql, parm = new { wocode = wocode, username = username, closedate=DateTime.Now.ToString() } });


                bool aa = DapperHelper.DoTransaction(list);


                if (aa)


                {


@@ -826,7 +842,7 @@


                }


                //根据条件查询工单工序任务(自制工序)


                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.plan_startdate,A.plan_enddate


                            S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.bad_qty,A.plan_startdate,A.plan_enddate


                            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


@@ -930,7 +946,7 @@


                }


                //根据条件查询工单工序任务(自制工序)


                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.plan_startdate,A.plan_enddate


                            S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.bad_qty,A.plan_startdate,A.plan_enddate


                            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


@@ -1009,7 +1025,7 @@


                if (stepcode != "")


                {


                    //查找当前工序任务


                    sql = @"select *  from TStep  where stepcode=@stepcode and wo_code=@ordercode";


                    sql = @"select *  from TK_Wrk_Step  where step_code=@stepcode and wo_code=@ordercode";


                    dynamicParams.Add("@stepcode", stepcode);


                    dynamicParams.Add("@ordercode", ordercode);


                    var data0 = DapperHelper.selectdata(sql, dynamicParams);


@@ -1024,7 +1040,7 @@


                }


                //根据条件查询工单工序任务,且不良数量大于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


                            S.stepcode,S.stepname,S.descr,A.plan_qty,A.good_qty,A.ng_qty,A.bad_qty


                            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


@@ -1041,7 +1057,7 @@


                }


                else


                {


                    mes.code = "300";


                    mes.code = "301";


                    mes.count = 0;


                    mes.Message = "无可执行的生产任务,任务已完成或已关闭!";


                    mes.data = null;


@@ -1092,7 +1108,7 @@


                    }


                }


                //1.根据工单+工序查找当前工序是否首道工序


                sql = @"select A.wo_code,P.partcode,P.partname,P.partspec, T.stepcode,T.stepname,A.seq,T.flwtype,T.descr,A.status,A.plan_qty,A.isbott,A.isend  


                sql = @"select A.wo_code,P.partcode,P.partname,P.partspec, T.stepcode,T.stepname,A.seq,T.flwtype,T.descr,A.status,A.plan_qty,A.good_qty,A.ng_qty,A.bad_qty,A.isbott,A.isend  


                        from TK_Wrk_Step A


                        left join  TStep T on A.step_code=T.stepcode


                        left join  TK_Wrk_Man M on A.wo_code=M.wo_code


@@ -1111,7 +1127,8 @@


                    rt.stepname = data.Rows[0]["STEPNAME"].ToString(); //工序名称


                    rt.stepdesc = data.Rows[0]["DESCR"].ToString(); //工序描述


                    rt.planqty = decimal.Parse(data.Rows[0]["PLAN_QTY"].ToString()); //任务数量




                    rt.noreportqty = decimal.Parse(data.Rows[0]["GOOD_QTY"].ToString()); //报工数量


                    rt.noputqty = decimal.Parse(data.Rows[0]["NG_QTY"].ToString()); //不良数量


                    string isend = data.Rows[0]["ISEND"].ToString();//末道工序


                    rt.seq = data.Rows[0]["SEQ"].ToString();//工序序号




@@ -1350,7 +1367,7 @@


                    dynamicParams.Add("@usercode", usercode);


                }


                //班组获取人员列表


                sql = @"select usercode,username  from TUser where is_delete<>'1' " + search;


                sql = @"select usercode,username  from TUser where is_delete<>'1' and usercode<>'9999'" + search;


                dynamicParams.Add("@usercode", usercode);


                var data = DapperHelper.selectdata(sql, dynamicParams);


                mes.code = "200";


@@ -1537,7 +1554,7 @@


        #endregion




        #region[生产开报工,报工提交]


        public static ToMessage SavaMesOrderStepReport(string mesordercode, string partcode, string stepseq, string stepcode, string eqpcode, string usergroupcode, string reportuser, string taskqty, string startqty, string reportqty, string ngqty, string badcode, string username)


        public static ToMessage SavaMesOrderStepReport(string mesordercode, string partcode, string stepseq, string stepcode, string eqpcode, string usergroupcode, string reportuser, string taskqty, string startqty, string reportqty, string ngqty, string badcode,string remarks, string username)


        {


            var sql = "";


            string[] arra = new string[] { };


@@ -1578,16 +1595,20 @@


                }


                if (data.Rows.Count > 0)


                {


                    //修改报工记录


                    sql = @"update TK_Wrk_Record set good_qty=good_qty+@reportqty,ng_qty=ng_qty+@ngqty,


                                lm_user=@username,lm_date=@CreateDate where wo_code=@mesordercode and step_code=@stepcode and style='B'";


                    list.Add(new { str = sql, parm = new { reportqty = decimal.Parse(reportqty), ngqty = decimal.Parse(ngqty), mesordercode = mesordercode, stepcode = stepcode, username = username, CreateDate = date } });


                    //获取主表最大ID


                    sql = @"select ISNULL(IDENT_CURRENT('TK_Wrk_Record')+1,1) as id";


                    var dt = DapperHelper.selecttable(sql);


                    //写入开报工记录表


                    sql = @"insert into  TK_Wrk_Record(wo_code,step_seq,step_code,eqp_code,materiel_code,task_qty,start_qty,good_qty,ng_qty,style,lm_user,lm_date) 


                                values(@mesordercode,@stepseq,@stepcode,@eqpcode,@partcode,@taskqty,@startqty,@reportqty,@ngqty,@style,@lm_user,@lm_date)";


                    list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepseq = stepseq, stepcode = stepcode, eqpcode = eqpcode, partcode = partcode, taskqty = taskqty, startqty = startqty, reportqty = reportqty, ngqty = ngqty, style = "B", lm_user = username, lm_date = date } });




                    //写入子表


                    for (int i = 0; i < arra.Length; i++)


                    {


                        sql = @"insert into  TK_Wrk_RecordSub(m_id,eqp_code,report_person,report_date,report_qty,usergroup_code,ng_qty,style,lm_user,lm_date) 


                                values(@m_id,@eqp_code,@report_person,@report_date,@report_qty,@usergroup_code,@ng_qty,@style,@lm_user,@lm_date)";


                        list.Add(new { str = sql, parm = new { m_id = int.Parse(data.Rows[0]["ID"].ToString()), eqp_code = eqpcode, report_person = arra[i], report_date = date, report_qty = reportqty, usergroup_code = usergroupcode, ng_qty = ngqty, style = "B", lm_user = username, lm_date = date } });


                        list.Add(new { str = sql, parm = new { m_id = int.Parse(dt.Rows[0]["ID"].ToString()), eqp_code = eqpcode, report_person = arra[i], report_date = date, report_qty = reportqty, usergroup_code = usergroupcode, ng_qty = ngqty, style = "B", lm_user = username, lm_date = date } });




                    }


                    if (badcode != "" && ngqty != "0")


@@ -1595,12 +1616,35 @@


                        //写入缺陷记录表


                        for (int i = 0; i < arra1.Length; i++)


                        {


                            sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date) 


                                values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";


                            list.Add(new { str = sql, parm = new { record_id = int.Parse(data.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "B", lm_user = username, lm_date = date } });


                            sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,remarks,style,lm_user,lm_date) 


                                values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@remarks,@style,@lm_user,@lm_date)";


                            list.Add(new { str = sql, parm = new { record_id = int.Parse(dt.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i],remarks=remarks,style = "B", lm_user = username, lm_date = date } });




                        }


                    }


                    ////修改报工记录


                    //sql = @"update TK_Wrk_Record set good_qty=good_qty+@reportqty,ng_qty=ng_qty+@ngqty,


                    //            lm_user=@username,lm_date=@CreateDate where wo_code=@mesordercode and step_code=@stepcode and style='B'";


                    //list.Add(new { str = sql, parm = new { reportqty = decimal.Parse(reportqty), ngqty = decimal.Parse(ngqty), mesordercode = mesordercode, stepcode = stepcode, username = username, CreateDate = date } });


                    ////写入子表


                    //for (int i = 0; i < arra.Length; i++)


                    //{


                    //    sql = @"insert into  TK_Wrk_RecordSub(m_id,eqp_code,report_person,report_date,report_qty,usergroup_code,ng_qty,style,lm_user,lm_date) 


                    //            values(@m_id,@eqp_code,@report_person,@report_date,@report_qty,@usergroup_code,@ng_qty,@style,@lm_user,@lm_date)";


                    //    list.Add(new { str = sql, parm = new { m_id = int.Parse(data.Rows[0]["ID"].ToString()), eqp_code = eqpcode, report_person = arra[i], report_date = date, report_qty = reportqty, usergroup_code = usergroupcode, ng_qty = ngqty, style = "B", lm_user = username, lm_date = date } });




                    //}


                    //if (badcode != "" && ngqty != "0")


                    //{


                    //    //写入缺陷记录表


                    //    for (int i = 0; i < arra1.Length; i++)


                    //    {


                    //        sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date) 


                    //            values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";


                    //        list.Add(new { str = sql, parm = new { record_id = int.Parse(data.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "B", lm_user = username, lm_date = date } });




                    //    }


                    //}


                }


                else


                {


@@ -1625,9 +1669,9 @@


                        //写入缺陷记录表


                        for (int i = 0; i < arra1.Length; i++)


                        {


                            sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date) 


                                values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";


                            list.Add(new { str = sql, parm = new { record_id = int.Parse(dt.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "B", lm_user = username, lm_date = date } });


                            sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,remarks,style,lm_user,lm_date) 


                                values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@remarks,@style,@lm_user,@lm_date)";


                            list.Add(new { str = sql, parm = new { record_id = int.Parse(dt.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], remarks= remarks, style = "B", lm_user = username, lm_date = date } });




                        }


                    }


@@ -1747,7 +1791,7 @@


        #endregion




        #region[生产开报工, 收料提交]


        public static ToMessage SavaMesOrderStepIn(string mesordercode, string partcode, string stepseq, string stepcode, string wxcode, string inuser, string taskqty, string sqty, string ngqty, string badcode, string username)


        public static ToMessage SavaMesOrderStepIn(string mesordercode, string partcode, string stepseq, string stepcode, string wxcode, string inuser, string taskqty, string sqty, string ngqty, string badcode,string remarks, string username)


        {


            var sql = "";


            string[] arra1 = new string[] { };


@@ -1771,42 +1815,105 @@


                dynamicParams.Add("@wx_code", wxcode);


                var data = DapperHelper.selectdata(sql, dynamicParams);


                //获取发料记录的默认选中的外协供应商与收料时的外协供应商做对比判断


                sql = @"select A.wx_code,B.name   from TK_Wrk_OutRecord A


                sql = @"select A.wx_code,B.name,A.fqty   from TK_Wrk_OutRecord A


                        inner join TCustomer B on A.wx_code=B.code


                        where A.wo_code=@wo_code and A.step_code=@step_code and A.style='F' ";


                        where A.wo_code=@wo_code and A.step_code=@step_code and wx_code=@wx_code and A.style='F' ";


                dynamicParams.Add("@wo_code", mesordercode);


                dynamicParams.Add("@step_code", stepcode);


                dynamicParams.Add("@wx_code", wxcode);


                var da = DapperHelper.selectdata(sql, dynamicParams);


                if (da.Rows[0]["WX_CODE"].ToString() != wxcode)


                if (da.Rows.Count<=0) 


                {


                    sql = @"select A.wx_code,B.name,A.fqty   from TK_Wrk_OutRecord A


                        inner join TCustomer B on A.wx_code=B.code


                        where A.wo_code=@wo_code and A.step_code=@step_code and A.style='F' ";


                    dynamicParams.Add("@wo_code", mesordercode);


                    dynamicParams.Add("@step_code", stepcode);


                    var da1 = DapperHelper.selectdata(sql, dynamicParams);


                    var dr = da1.AsEnumerable().ToList().Select(x => x.Field<string>("NAME")).ToList();


                    string wxstring = (string.Join(",", dr.Select(x => x.ToString()).ToArray()));


                    mes.code = "300";


                    mes.count = 0;


                    mes.Message = "操作失败,当前收料外协供方应为：" + da.Rows[0]["NAME"].ToString() + "!";


                    mes.Message = "操作失败,当前收料外协供方与发料外协供应商不匹配,应为：【"+wxstring+"】!";


                    mes.data = null;


                    return mes;


                }


                if ((decimal.Parse(sqty) + decimal.Parse(ngqty)) > decimal.Parse(da.Rows[0]["FQTY"].ToString()))  //收料数量+不良数量>发料数量


                {


                    mes.code = "300";


                    mes.count = 0;


                    mes.Message = "操作失败,当前收料数量+不良数量,不能大于发料数量:"+da.Rows[0]["FQTY"].ToString()+"!";


                    mes.data = null;


                    return mes;


                }


                //if (da.Rows[0]["WX_CODE"].ToString() != wxcode)


                //{


                //    mes.code = "300";


                //    mes.count = 0;


                //    mes.Message = "操作失败,当前收料外协供方应为：" + da.Rows[0]["NAME"].ToString() + "!";


                //    mes.data = null;


                //    return mes;


                //}


                if (data.Rows.Count > 0)


                {


                    //修改外协记录主表


                    sql = @"update TK_Wrk_OutRecord set sqty=sqty+@sqty,ng_qty=ng_qty+@ngqty,lm_user=@username,lm_date=@CreateDate


                             where wo_code=@mesordercode and step_code=@stepcode and wx_code=@wx_code and style='S'";


                    list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepcode = stepcode, wx_code = wxcode, sqty = decimal.Parse(sqty), ngqty = decimal.Parse(ngqty), username = username, CreateDate = date } });


                    decimal sum_sqty = data.AsEnumerable().Select(d => d.Field<decimal>("SQTY")).Sum();  //获取同单号,同工序,同外协供应商收料总数量


                    decimal sum_fqty = da.AsEnumerable().Select(d => d.Field<decimal>("FQTY")).Sum();  //获取同单号,同工序,同外协供应商发料总数量


                    if ((sum_sqty + decimal.Parse(sqty) + decimal.Parse(ngqty)) > sum_fqty) //已收料总数+当前收料数量+不良数量>总发料数量


                    {


                        mes.code = "300";


                        mes.count = 0;


                        mes.Message = "操作失败,当前收料数量+不良数量,不能大于待收数量:" + (sum_fqty- sum_sqty) + "!";


                        mes.data = null;


                        return mes;


                    }






                    //获取主表最大ID


                    sql = @"select ISNULL(IDENT_CURRENT('TK_Wrk_OutRecord')+1,1) as id";


                    var dt = DapperHelper.selecttable(sql);


                    //写入外协记录主表


                    sql = @"insert into  TK_Wrk_OutRecord(wo_code,step_seq,step_code,wx_code,materiel_code,style,sqty,ng_qty,lm_user,lm_date) 


                                values(@mesordercode,@stepseq,@stepcode,@wx_code,@partcode,@style,@sqty,@ngqty,@lm_user,@lm_date)";


                    list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepseq = stepseq, stepcode = stepcode, wx_code = wxcode, partcode = partcode, style = 'S', sqty = sqty, ngqty = ngqty, lm_user = username, lm_date = date } });




                    //写入外协记录子表


                    sql = @"insert into  TK_Wrk_OutRecordSub(m_id,wx_code,in_person,in_time,sqty,ng_qty,style,lm_user,lm_date) 


                                values(@m_id,@wx_code,@in_person,@in_time,@sqty,@ngqty,@style,@lm_user,@lm_date)";


                    list.Add(new { str = sql, parm = new { m_id = int.Parse(data.Rows[0]["ID"].ToString()), wx_code = wxcode, in_person = inuser, in_time = date, sqty = sqty, ngqty = ngqty, style = 'S', lm_user = username, lm_date = date } });


                                values(@m_id,@wxcode,@in_person,@in_time,@sqty,@ng_qty,@style,@lm_user,@lm_date)";


                    list.Add(new { str = sql, parm = new { m_id = int.Parse(dt.Rows[0]["ID"].ToString()), wxcode = wxcode, in_person = inuser, in_time = date, sqty = sqty, ng_qty = ngqty, style = "S", lm_user = username, lm_date = date } });




                    if (badcode != "" && ngqty != "0")


                    {


                        //写入缺陷记录表


                        for (int i = 0; i < arra1.Length; i++)


                        {


                            sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date) 


                                values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";


                            list.Add(new { str = sql, parm = new { record_id = int.Parse(data.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "S", lm_user = username, lm_date = date } });


                            sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,remarks,style,lm_user,lm_date) 


                                values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@remarks,@style,@lm_user,@lm_date)";


                            list.Add(new { str = sql, parm = new { record_id = int.Parse(dt.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], remarks= remarks, style = "S", lm_user = username, lm_date = date } });




                        }


                    }






                    ////修改外协记录主表


                    //sql = @"update TK_Wrk_OutRecord set sqty=sqty+@sqty,ng_qty=ng_qty+@ngqty,lm_user=@username,lm_date=@CreateDate


                    //         where wo_code=@mesordercode and step_code=@stepcode and wx_code=@wx_code and style='S'";


                    //list.Add(new { str = sql, parm = new { mesordercode = mesordercode, stepcode = stepcode, wx_code = wxcode, sqty = decimal.Parse(sqty), ngqty = decimal.Parse(ngqty), username = username, CreateDate = date } });


                    ////写入外协记录子表


                    //sql = @"insert into  TK_Wrk_OutRecordSub(m_id,wx_code,in_person,in_time,sqty,ng_qty,style,lm_user,lm_date) 


                    //            values(@m_id,@wx_code,@in_person,@in_time,@sqty,@ngqty,@style,@lm_user,@lm_date)";


                    //list.Add(new { str = sql, parm = new { m_id = int.Parse(data.Rows[0]["ID"].ToString()), wx_code = wxcode, in_person = inuser, in_time = date, sqty = sqty, ngqty = ngqty, style = 'S', lm_user = username, lm_date = date } });




                    //if (badcode != "" && ngqty != "0")


                    //{


                    //    //写入缺陷记录表


                    //    for (int i = 0; i < arra1.Length; i++)


                    //    {


                    //        sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date) 


                    //            values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";


                    //        list.Add(new { str = sql, parm = new { record_id = int.Parse(data.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "S", lm_user = username, lm_date = date } });




                    //    }


                    //}


                }


                else


                {


@@ -1828,9 +1935,9 @@


                        //写入缺陷记录表


                        for (int i = 0; i < arra1.Length; i++)


                        {


                            sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,style,lm_user,lm_date) 


                                values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";


                            list.Add(new { str = sql, parm = new { record_id = int.Parse(dt.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], style = "S", lm_user = username, lm_date = date } });


                            sql = @"insert into  CSR_WorkRecord_Defect(record_id,wo_code,partnumber,step_seq,step_code,defect_qty,defect_code,remarks,style,lm_user,lm_date) 


                                values(@record_id,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@remarks,@style,@lm_user,@lm_date)";


                            list.Add(new { str = sql, parm = new { record_id = int.Parse(dt.Rows[0]["ID"].ToString()), wo_code = mesordercode, partcode = partcode, stepseq = stepseq, stepcode = stepcode, ngqty = ngqty, defect_code = arra1[i], remarks= remarks, style = "S", lm_user = username, lm_date = date } });




                        }


                    }


@@ -1890,22 +1997,21 @@


                    if (json.Data.Rows[i]["STYLE"].ToString() == "Z")


                    {


                        //回写对应的报工记录子表合格数量、不良数量、报废数量


                        sql = @"update TK_Wrk_RecordSub set report_qty=report_qty+@repair_qty,ng_qty=ng_qty-@repair_qty,bad_qty=bad_qty+@bad_qty


                                where  id=@m_id and m_id=@id and style='B'";


                        sql = @"update TK_Wrk_RecordSub set report_qty=report_qty+@repair_qty,ng_qty=ng_qty-@repair_qty-@bad_qty,bad_qty=bad_qty+@bad_qty


                                where  m_id=@m_id and style='B'";


                        list.Add(new


                        {


                            str = sql,


                            parm = new


                            {


                                id = int.Parse(json.Data.Rows[i]["M_ID"].ToString()),


                                m_id = int.Parse(json.Data.Rows[i]["ID"].ToString()),


                                repair_qty = decimal.Parse(json.Data.Rows[i]["REPAIR_QTY"].ToString()),


                                bad_qty = decimal.Parse(json.Data.Rows[i]["BAD_QTY"].ToString())


                            }


                        });


                        //回写对应的报工记录主表合格数量、不良数量、报废数量


                        sql = @"update TK_Wrk_Record set good_qty=good_qty+@repair_qty,ng_qty=ng_qty-@repair_qty,bad_qty=bad_qty+@bad_qty


                        where wo_code=@wo_code and step_code=@stepcode and id=@id and style='B'";


                        sql = @"update TK_Wrk_Record set good_qty=good_qty+@repair_qty,ng_qty=ng_qty-@repair_qty-@bad_qty,bad_qty=bad_qty+@bad_qty


                        where wo_code=@wo_code and step_code=@step_code and id=@id and style='B'";


                        list.Add(new


                        {


                            str = sql,


@@ -1920,7 +2026,7 @@


                        });


                        //写入报工缺陷处理记录表


                        sql = @"insert into  CSR_WorkRecord_DefectHandle(record_subid,wo_code,partnumber,step_seq,step_code,repair_qty,bad_qty,defect_code,style,lm_user,lm_date) 


                                values(@record_subid,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";


                                values(@record_subid,@wo_code,@partcode,@stepseq,@stepcode,@repair_qty,@bad_qty,@defect_code,@style,@lm_user,@lm_date)";


                        list.Add(new


                        {


                            str = sql,


@@ -1944,25 +2050,24 @@


                        sumbad_qty = sumbad_qty + decimal.Parse(json.Data.Rows[i]["BAD_QTY"].ToString());


                    }


                    //外协工序


                    if (json.Data.Rows[i]["STYLE"].ToString() == "W")


                    if (json.Data.Rows[i]["STYLE"].ToString() == "S")


                    {


                        //回写对应的收料记录子表收料数量、不良数量、报废数量


                        sql = @"update TK_Wrk_OutRecordSub set sqty=sqty+@repair_qty,ng_qty=ng_qty-@repair_qty,bad_qty=bad_qty+@bad_qty


                                where id=@m_id and m_id=@id and style='S'";


                        sql = @"update TK_Wrk_OutRecordSub set sqty=sqty+@repair_qty,ng_qty=ng_qty-@repair_qty-@bad_qty,bad_qty=bad_qty+@bad_qty


                                where  m_id=@m_id and style='S'";


                        list.Add(new


                        {


                            str = sql,


                            parm = new


                            {


                                id = int.Parse(json.Data.Rows[i]["M_ID"].ToString()),


                                m_id = int.Parse(json.Data.Rows[i]["ID"].ToString()),


                                repair_qty = decimal.Parse(json.Data.Rows[i]["REPAIR_QTY"].ToString()),


                                bad_qty = decimal.Parse(json.Data.Rows[i]["BAD_QTY"].ToString())


                            }


                        });


                        //回写对应的收料记录主表合格数量、不良数量、报废数量


                        sql = @"update TK_Wrk_OutRecord set sqty=sqty+@repair_qty,ng_qty=ng_qty-@repair_qty,bad_qty=bad_qty+@bad_qty


                        where wo_code=@wo_code and step_code=@stepcode and id=@id and style='S'";


                        sql = @"update TK_Wrk_OutRecord set sqty=sqty+@repair_qty,ng_qty=ng_qty-@repair_qty-@bad_qty,bad_qty=bad_qty+@bad_qty


                        where wo_code=@wo_code and step_code=@step_code and id=@id and style='S'";


                        list.Add(new


                        {


                            str = sql,


@@ -1977,7 +2082,7 @@


                        });


                        //写入报工缺陷处理记录表


                        sql = @"insert into  CSR_WorkRecord_DefectHandle(record_subid,wo_code,partnumber,step_seq,step_code,repair_qty,bad_qty,defect_code,style,lm_user,lm_date) 


                                values(@record_subid,@wo_code,@partcode,@stepseq,@stepcode,@ngqty,@defect_code,@style,@lm_user,@lm_date)";


                                values(@record_subid,@wo_code,@partcode,@stepseq,@stepcode,@repair_qty,@bad_qty,@defect_code,@style,@lm_user,@lm_date)";


                        list.Add(new


                        {


                            str = sql,


@@ -2002,7 +2107,7 @@


                }




                //回写工单工序表合格数量、不良数量


                sql = @"update TK_Wrk_Step set good_qty=good_qty+@sumrepair_qty,ng_qty=ng_qty-@sumrepair_qty,bad_qty=bad_qty+sumbad_qty  where wo_code=@wo_code and step_code=@stepcode";


                sql = @"update TK_Wrk_Step set good_qty=good_qty+@sumrepair_qty,ng_qty=ng_qty-@sumrepair_qty-@sumbad_qty,bad_qty=bad_qty+@sumbad_qty  where wo_code=@wo_code and step_code=@stepcode";


                list.Add(new


                {


                    str = sql,


@@ -2019,14 +2124,14 @@


                {


                    mes.code = "200";


                    mes.count = 0;


                    mes.Message = "收成功!";


                    mes.Message = "操作成功!";


                    mes.data = null;


                }


                else


                {


                    mes.code = "300";


                    mes.count = 0;


                    mes.Message = "收料失败!";


                    mes.Message = "操作失败!";


                    mes.data = null;


                }


            }


@@ -2167,23 +2272,37 @@


        #endregion




        #region[生产开报工,工序检验提交保存]


        public static ToMessage SaveMesOrderStepCheckItem(string mesordercode, string partcode, string stepcode, string checkstanedcode, string checkusercode, string checktypecode, string checkresult, string checkdescr, string username, List<StepCheck> json)


        public static ToMessage SaveMesOrderStepCheckItem(string mesordercode, string partcode, string stepcode, string checkstanedcode, string checkusercode, string checktypecode, string checkresult, string checkdescr,string checkqty, string username, List<StepCheck> json)


        {


            var sql = "";


            string[] arra = new string[] { };


            string[] arra1 = new string[] { };


            List<object> list = new List<object>();


            string checktypename = "";


            var dynamicParams = new DynamicParameters();


            try


            {


                string date = DateTime.Now.ToString(); //获取系统时间




                list.Clear();




                switch (checktypecode)


                {


                    case "FirstCheck":


                        checktypename = "首检";


                        break;


                    case "PatroCheck":


                        checktypename = "巡检";


                        break;


                    case "EndCheck":


                        checktypename = "完工检验";


                        break;


                    default:


                        break;


                }


                //写入工序检验记录主表


                sql = @"insert into  TStepCheckRecord(wo_code,partcode,step_code,checkstaned_code,check_user,check_type,check_result,check_descr,lm_user,lm_date) 


                                values(@mesordercode,@partcode,@stepcode,@checkstanedcode,@checkusercode,@checktypecode,@checkresult,@checkdescr,@lm_user,@lm_date)";


                list.Add(new { str = sql, parm = new { mesordercode = mesordercode, partcode = partcode, stepcode = stepcode, checkstanedcode = checkstanedcode, checkusercode = checkusercode, checktypecode = checktypecode, checkresult = checkresult, checkdescr = checkdescr, lm_user = username, lm_date = date } });


                sql = @"insert into  TStepCheckRecord(wo_code,partcode,step_code,checkstaned_code,check_user,check_type,check_typename,check_result,check_descr,check_qty,lm_user,lm_date) 


                                values(@mesordercode,@partcode,@stepcode,@checkstanedcode,@checkusercode,@checktypecode,@checktypename,@checkresult,@checkdescr,@check_qty,@lm_user,@lm_date)";


                list.Add(new { str = sql, parm = new { mesordercode = mesordercode, partcode = partcode, stepcode = stepcode, checkstanedcode = checkstanedcode, checkusercode = checkusercode, checktypecode = checktypecode, checktypename = checktypename, checkresult = checkresult, checkdescr = checkdescr, check_qty=checkqty, lm_user = username, lm_date = date } });


                //写入工序检验记录子表


                //获取主表最大ID


                sql = @"select ISNULL(IDENT_CURRENT('TStepCheckRecord')+1,1) as id";


@@ -2223,5 +2342,182 @@


        }


        #endregion






        #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)


        {


            var dynamicParams = new DynamicParameters();


            string search = "";


            try


            {


                if (mesorderstus != "" && mesorderstus != null)


                {


                    search += "and A.status=@mesorderstus ";


                    dynamicParams.Add("@mesorderstus", mesorderstus);


                }


                if (mesordercode != "" && mesordercode != null)


                {


                    search += "and A.wo_code like '%'+@mesordercode+'%' ";


                    dynamicParams.Add("@mesordercode", mesordercode);


                }


                if (sourceorder != "" && sourceorder != null)


                {


                    search += "and A.m_po like '%'+@sourceorder+'%' ";


                    dynamicParams.Add("@sourceorder", sourceorder);


                }


                if (ordertype != "" && ordertype != null)


                {


                    search += "and A.wotype like '%'+@ordertype+'%' ";


                    dynamicParams.Add("@ordertype", ordertype);


                }


                if (partcode != "" && partcode != null)


                {


                    search += "and A.materiel_code like '%'+@partcode+'%' ";


                    dynamicParams.Add("@partcode", partcode);


                }


                if (partname != "" && partname != null)


                {


                    search += "and B.partname like '%'+@partname+'%' ";


                    dynamicParams.Add("@partname", partname);


                }


                if (partspec != "" && partspec != null)


                {


                    search += "and B.partspec like '%'+@partspec+'%' ";


                    dynamicParams.Add("@partspec", partspec);


                }


                if (createdate != "" && createdate != null)


                {


                    search += "and CONVERT(varchar(100),A.lm_date,23)=@createdate ";


                    dynamicParams.Add("@createdate", createdate);


                }


                if (creatuser != "" && creatuser != null)


                {


                    search += "and U.username like '%'+@creatuser+'%' ";


                    dynamicParams.Add("@creatuser", creatuser);


                }




                if (search == "")


                {


                    search = "and 1=1 ";


                }


                // --------------查询指定数据--------------


                var total = 0; //总条数


                var sql = @"select A.id, A.status,A.wotype,A.wo_code,A.materiel_code as partcode,B.partname,B.partspec,A.plan_qty,A.wkshp_code,C.org_name as wkshp_name,


                            A.route_code,E.name as route_name,A.stck_code,F.name as stck_name,A.plan_startdate,A.plan_enddate,A.piroque,A.sourceid,A.m_po,U.username as lm_user,A.lm_date


                            ,(select sum(S.good_qty)  from TK_Wrk_Step S where S.wo_code=A.wo_code and S.isend='Y') as good_qty


                            ,(select sum(S.ng_qty)  from TK_Wrk_Step S where S.wo_code=A.wo_code and S.isend='Y') as ng_qty


                            ,(select sum(S.bad_qty)  from TK_Wrk_Step S where S.wo_code=A.wo_code and S.isend='Y') as bad_qty


                            from TK_Wrk_Man A


                            left join TMateriel_Info B on A.materiel_code=B.partcode


                            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 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 


                            where A.is_delete<>'1' " + search;


                var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);


                mes.code = "200";


                mes.Message = "查询成功!";


                mes.count = total;


                mes.data = data.ToList();


            }


            catch (Exception e)


            {


                mes.code = "300";


                mes.count = 0;


                mes.Message = e.Message;


                mes.data = null;


            }


            return mes;


        }


        #endregion




        #region[MES工单批量关闭提交]


        public static ToMessage MesOrderBitchClosedSeave(string username, DataTable dt)


        {


            var sql = "";


            List<object> list = new List<object>();


            var dynamicParams = new DynamicParameters();


            try


            {


                for (int i = 0; i < dt.Rows.Count; i++)


                {


                    //关闭工单对应工序任务


                    sql = @"update TK_Wrk_Step set status='CLOSED'  where wo_code=@wocode";


                    list.Add(new { str = sql, parm = new { wocode = dt.Rows[i]["WO_CODE"].ToString() } });


                    //回写工单表状态为(关闭)


                    sql = @"update TK_Wrk_Man set status='CLOSED',closeuser=@username,closedate=@closedate  where wo_code=@wocode";


                    list.Add(new { str = sql, parm = new { wocode = dt.Rows[i]["WO_CODE"].ToString(), username = username, closedate = DateTime.Now.ToString() } });


                }


                bool aa = DapperHelper.DoTransaction(list);


                if (aa)


                {


                    mes.code = "200";


                    mes.count = 0;


                    mes.Message = "工单关闭成功!";


                    mes.data = null;


                }


                else


                {


                    mes.code = "300";


                    mes.count = 0;


                    mes.Message = "工单关闭失败!";


                    mes.data = null;


                }


            }


            catch (Exception e)


            {


                mes.code = "300";


                mes.count = 0;


                mes.Message = e.Message;


                mes.data = null;


            }


            return mes;


        }


        #endregion




        #region[MES工单批量反关闭]


        public static ToMessage MesOrderBitchAntiClosedSeave(string username, DataTable dt)


        {


            var sql = "";


            List<object> list = new List<object>();


            var dynamicParams = new DynamicParameters();


            try


            {


                for (int i = 0; i < dt.Rows.Count; i++)


                {


                    //关闭工单对应工序任务


                    sql = @"update TK_Wrk_Step set status='START'  where wo_code=@wocode";


                    list.Add(new { str = sql, parm = new { wocode = dt.Rows[i]["WO_CODE"].ToString() } });


                    //回写工单表状态为(关闭)


                    sql = @"update TK_Wrk_Man set status='START',closeuser=@username,closedate=@closedate  where wo_code=@wocode";


                    list.Add(new { str = sql, parm = new { wocode = dt.Rows[i]["WO_CODE"].ToString(), username = username, closedate = DateTime.Now.ToString() } });


                }


                bool aa = DapperHelper.DoTransaction(list);


                if (aa)


                {


                    mes.code = "200";


                    mes.count = 0;


                    mes.Message = "工单关闭成功!";


                    mes.data = null;


                }


                else


                {


                    mes.code = "300";


                    mes.count = 0;


                    mes.Message = "工单关闭失败!";


                    mes.data = null;


                }


            }


            catch (Exception e)


            {


                mes.code = "300";


                mes.count = 0;


                mes.Message = e.Message;


                mes.data = null;


            }


            return mes;


        }


        #endregion


    }


}