From 39f66c32212f11d9a9d41c69e37f68e989c55cde Mon Sep 17 00:00:00 2001
From: yl <ykxkd@outlook.com>
Date: 星期一, 08 十二月 2025 10:56:23 +0800
Subject: [PATCH] 1.报工调整增加工序查询条件 2.报工调整增加批量改价 3.生产订单、生产工单车间查询条件改为多选

---
 VueWebCoreApi/DLL/DAL/WorkOrderDAL.cs |  201 ++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 177 insertions(+), 24 deletions(-)

diff --git a/VueWebCoreApi/DLL/DAL/WorkOrderDAL.cs b/VueWebCoreApi/DLL/DAL/WorkOrderDAL.cs
index 248f8f8..fc7d964 100644
--- a/VueWebCoreApi/DLL/DAL/WorkOrderDAL.cs
+++ b/VueWebCoreApi/DLL/DAL/WorkOrderDAL.cs
@@ -42,8 +42,9 @@
                 }
                 if (wkshopcode != "" && wkshopcode != null)
                 {
-                    search += "and A.wkshp_code=@wkshopcode ";
-                    dynamicParams.Add("@wkshopcode", wkshopcode);
+                    string[] wkshoplist = Array.ConvertAll<string, string>(wkshopcode.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries), s => s.ToString()); //string鍒嗗壊杞瑂tring[] 
+                    search += "and A.wkshp_code in @wkshoplist ";
+                    dynamicParams.Add("@wkshoplist", wkshoplist);
                 }
                 if (erpordercode != "" && erpordercode != null)
                 {
@@ -609,30 +610,47 @@
             var dynamicParams = new DynamicParameters();
             try
             {
-                sql = @"select *  from TK_Wrk_Man where m_po=@erpordercode and status<> 'CLOSED'";
+                sql = @"select *  from TK_Wrk_Man where m_po=@erpordercode and sourceid=@sourceid";
                 dynamicParams.Add("@erpordercode", erpordercode);
+                dynamicParams.Add("@sourceid", erporderid);
                 var data = DapperHelper.selectdata(sql, dynamicParams);
                 if (data.Rows.Count > 0)
                 {
-                    mes.code = "300";
-                    mes.count = 0;
-                    mes.message = "褰撳墠璁㈠崟鏈変笅杈炬湭鍏抽棴鐨凪ES宸ュ崟,璁㈠崟涓嶅厑璁稿叧闂�,璇峰厛鍒犻櫎鎴栧叧闂浉鍏冲伐鍗�!";
-                    mes.data = null;
-                }
-                else
-                {
-                    //鍏抽棴璁㈠崟
-                    sql = @"update  TKimp_Ewo set status='CLOSED' where wo=@wo and id=@erporderid";
+                    // 浣跨敤LINQ鍜宭ambda琛ㄨ揪寮忔潵杞崲wo_code瀛楁鐨勫�间负閫楀彿闅斿紑鐨勫瓧绗︿覆鏁扮粍  
+                    string[] result = data.AsEnumerable().Select(row => "" + row.Field<string>("wo_code") + "").ToArray();
+                    //鍏抽棴宸ュ簭浠诲姟
+                    sql = @"update  TK_Wrk_Step set status='CLOSED',closebeforestatus=status where wo_code in @wocode";
                     list.Add(new
                     {
                         str = sql,
                         parm = new
                         {
-                            wo = erpordercode,
-                            erporderid = erporderid
+                            wocode = result
+                        }
+                    });
+                    //鍏抽棴宸ュ崟
+                    sql = @"update  TK_Wrk_Man set status='CLOSED',closebeforestatus=status where m_po=@erpordercode and sourceid=@sourceid";
+                    list.Add(new
+                    {
+                        str = sql,
+                        parm = new
+                        {
+                            erpordercode = erpordercode,
+                            sourceid = erporderid
                         }
                     });
                 }
+                //鍏抽棴璁㈠崟
+                sql = @"update  TKimp_Ewo set status='CLOSED',closebeforestatus=status where wo=@wo and id=@erporderid";
+                list.Add(new
+                {
+                    str = sql,
+                    parm = new
+                    {
+                        wo = erpordercode,
+                        erporderid = erporderid
+                    }
+                });
                 bool aa = DapperHelper.DoTransaction(list);
                 if (aa)
                 {
@@ -833,8 +851,9 @@
                 }
                 if (wkshopcode != "" && wkshopcode != null)
                 {
-                    search += "and A.wkshp_code=@wkshopcode ";
-                    dynamicParams.Add("@wkshopcode", wkshopcode);
+                    string[] wkshoplist = Array.ConvertAll<string, string>(wkshopcode.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries), s => s.ToString()); //string鍒嗗壊杞瑂tring[] 
+                    search += "and A.wkshp_code in @wkshoplist ";
+                    dynamicParams.Add("@wkshoplist", wkshoplist);
                 }
                 if (mesordercode != "" && mesordercode != null)
                 {
@@ -910,7 +929,7 @@
                 }
                 // --------------鏌ヨ鎸囧畾鏁版嵁--------------
                 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.route_code,B.default_route,R.name as route_name,A.plan_qty,A.wkshp_code,C.torg_name as wkshp_name,
+                var sql = @"select A.id, A.status,A.wotype,A.wo_code,A.materiel_code as partcode,B.partname,B.partspec,A.idTopInventory,A.TopInventoryCode,A.TopInventoryName,A.route_code,B.default_route,R.name as route_name,A.plan_qty,A.wkshp_code,C.torg_name as wkshp_name,
                             A.stck_code,D.name as stck_name,A.plan_startdate,A.plan_enddate,A.piroque,A.sourceid,A.m_po,A.saleOrderDeliveryDate,W.saleOrderCode,U.username as lm_user,A.lm_date,A.data_sources,A.isstep,A.clerkuser,
                             B.priuserdefnvc1,B.priuserdefnvc2,B.priuserdefnvc3,B.priuserdefnvc4,B.priuserdefnvc5,B.priuserdefnvc6,A.printcount
                             from TK_Wrk_Man A
@@ -998,7 +1017,7 @@
                 }
                 // --------------鏌ヨ鎸囧畾鏁版嵁--------------
                 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.torg_name as wkshp_name,
+                var sql = @"select A.id, A.status,A.wotype,A.wo_code,A.materiel_code as partcode,B.partname,B.partspec,A.idTopInventory,A.TopInventoryCode,A.TopInventoryName,A.plan_qty,A.wkshp_code,C.torg_name as wkshp_name,
                             A.stck_code,D.name as stck_name,A.plan_startdate,A.plan_enddate,A.piroque,A.sourceid,A.m_po,A.saleOrderDeliveryDate,W.saleOrderCode,U.username as lm_user,A.lm_date,S.laborbad_qty,S.materielbad_qty,
                             B.priuserdefnvc1,B.priuserdefnvc2,B.priuserdefnvc3,B.priuserdefnvc4,B.priuserdefnvc5,B.priuserdefnvc6
                             from TK_Wrk_Man A
@@ -3379,7 +3398,7 @@
 
 
         #region[鐢熶骇鎵ц,鎶ュ伐璋冩暣鏁版嵁鏌ヨ鎺ュ彛]
-        public static ToMessage MesOrderStepVerifySearch(string wkshopcode, string wo_code, string partnumber, string partname, string partspec, string reportuser, string reportdateopendate, string reportdateclosedate, int startNum, int endNum, string prop, string order)
+        public static ToMessage MesOrderStepVerifySearch(string wkshopcode, string wo_code, string partnumber, string partname, string partspec,string stepcode, string reportuser, string reportdateopendate, string reportdateclosedate, int startNum, int endNum, string prop, string order)
         {
             var dynamicParams = new DynamicParameters();
             string search = "";
@@ -3410,6 +3429,11 @@
                     search += "and AA.partspec like '%'+@partspec+'%' ";
                     dynamicParams.Add("@partspec", partspec);
                 }
+                if (stepcode != "" && stepcode != null)
+                {
+                    search += "and AA.step_code=@stepcode ";
+                    dynamicParams.Add("@stepcode", stepcode);
+                }
                 if (reportuser != "" && reportuser != null)
                 {
                     search += "and AA.usercode like '%'+@reportuser+'%' ";
@@ -3432,7 +3456,7 @@
                 var total = 0; //鎬绘潯鏁�
                 var sql = @"select *  from(
                             select A.id,B.id as sbid,A.wo_code,A.materiel_code as partnumber,P.partname,P.partspec,K.plan_quantity,K.plan_qty as task_qty,M.wkshp_code,T.torg_name as wkshp_name,A.eqp_code,E.name as eqp_name,
-                            A.step_seq,A.step_code,S.stepname,S.flwtype as steptype,k.isbott as first_choke,k.isend as last_choke,A.step_price,B.reckway,B.usergroup_code,G.usergroupname as usergroup_name,
+                            A.step_seq,A.step_code,S.stepname,S.flwtype as steptype,A.style,k.isbott as first_choke,k.isend as last_choke,A.step_price,B.reckway,B.usergroup_code,G.usergroupname as usergroup_name,
                             B.report_person as usercode,
                              STUFF((SELECT ',' + U.username
                                     FROM TUser U
@@ -3451,7 +3475,7 @@
                             where A.style='B' and B.style='B' and M.status<>'CLOSED' and A.verify='N'
                             union all
                             select A.id,B.id as sbid,A.wo_code,A.materiel_code as partnumber,P.partname,P.partspec,K.plan_quantity,K.plan_qty as task_qty,M.wkshp_code,T.torg_name as wkshp_name,A.wx_code as eqp_code,E.name as eqp_name,
-                            A.step_seq,A.step_code,S.stepname,S.flwtype as steptype,k.isbott as first_choke,k.isend as last_choke,A.step_price,'person' as reckway,'' as usergroup_code,'' as usergroup_name,
+                            A.step_seq,A.step_code,S.stepname,S.flwtype as steptype,A.style,k.isbott as first_choke,k.isend as last_choke,A.step_price,'person' as reckway,'' as usergroup_code,'' as usergroup_name,
                             B.in_person as usercode,
                             STUFF((SELECT ',' + U.username
                                     FROM TUser U
@@ -4381,6 +4405,118 @@
         }
         #endregion
 
+        #region[鐢熶骇鎵ц,鎶ュ伐璋冩暣鎵归噺鏀逛环鏁版嵁鎻愪氦]
+        public static ToMessage MesOrderStepPriceBatchUpdateSeave(User us, List<BatchPrice> json)
+        {
+            string sql = "";
+            List<object> list = new List<object>();
+            var dynamicParams = new DynamicParameters();
+            try
+            {
+                if (json.Count > 0)
+                {
+                    // 浣跨敤Lambda琛ㄨ揪寮忓垽鏂被鍨嬪垎甯�:鍏ㄩ儴鎶ュ伐鎴栬�呭叏閮ㄦ敹鏂�
+                    bool allB = json.All(p => p.type == "B");
+                    bool allS = json.All(p => p.type == "S");
+                    if (allB)//鍏ㄩ儴鎶ュ伐
+                    {
+                        //灏哃ist<BatchPrice>涓殑id瀛楁杞崲涓哄瓧绗︿覆鏁扮粍
+                        string[] idArray = json.Select(bp => bp.id).ToArray();
+                        //鍥炲啓瀵瑰簲鐨勬姤宸ヨ褰曚富琛ㄥ伐浠�
+                        sql = @"update TK_Wrk_Record set step_price=@step_price where id in @idArray and style='B'";
+                        list.Add(new
+                        {
+                            str = sql,
+                            parm = new
+                            {
+                                step_price = decimal.Parse(json[0].price),
+                                idArray = idArray
+                            }
+                        });
+                    }
+                    else if (allS)//鍏ㄩ儴鏀舵枡
+                    {
+                        //灏哃ist<BatchPrice>涓殑id瀛楁杞崲涓哄瓧绗︿覆鏁扮粍
+                        string[] idArray = json.Select(bp => bp.id).ToArray();
+                        //鍥炲啓瀵瑰簲鐨勬姤宸ヨ褰曚富琛ㄥ伐浠�
+                        sql = @"update TK_Wrk_OutRecord set step_price=@step_price where id in @idArray and style='S'";
+                        list.Add(new
+                        {
+                            str = sql,
+                            parm = new
+                            {
+                                step_price = decimal.Parse(json[0].price),
+                                idArray = idArray
+                            }
+                        });
+                    }
+                    else // 娣峰悎鎯呭喌
+                    {
+                        //灏哃ist<BatchPrice>涓负鎶ュ伐鐨刬d瀛楁杞崲涓哄瓧绗︿覆鏁扮粍
+                        var bList = json.Where(p => p.type == "B").ToList();
+                        string[] idBArray = bList.Select(bp => bp.id).ToArray();
+                        //鍥炲啓瀵瑰簲鐨勬姤宸ヨ褰曚富琛ㄥ伐浠�
+                        sql = @"update TK_Wrk_Record set step_price=@step_price where id in @idBArray and style='B'";
+                        list.Add(new
+                        {
+                            str = sql,
+                            parm = new
+                            {
+                                step_price = decimal.Parse(json[0].price),
+                                idBArray = idBArray
+                            }
+                        });
+                        //灏哃ist<BatchPrice>涓负鏀舵枡鐨刬d瀛楁杞崲涓哄瓧绗︿覆鏁扮粍
+                        var sList = json.Where(p => p.type == "S").ToList();
+                        string[] idSArray = sList.Select(bp => bp.id).ToArray();
+                        //鍥炲啓瀵瑰簲鐨勬姤宸ヨ褰曚富琛ㄥ伐浠�
+                        sql = @"update TK_Wrk_OutRecord set step_price=@step_price where id in @idSArray and style='S'";
+                        list.Add(new
+                        {
+                            str = sql,
+                            parm = new
+                            {
+                                step_price = decimal.Parse(json[0].price),
+                                idSArray = idSArray
+                            }
+                        });
+                    }
+                    bool aa = DapperHelper.DoTransaction(list);
+                    if (aa)
+                    {
+                        //鍐欏叆鎿嶄綔璁板綍琛�
+                        LogHelper.DbOperateLog(us.usercode, "鎵归噺淇敼宸ヤ环", "鎶ュ伐ID:" + string.Join(",",json.Select(bp => bp.id).ToArray())+",鎿嶄綔绫诲瀷:"+ string.Join(",", json.Select(bp => bp.type).ToArray()), us.usertype);
+                        mes.code = "200";
+                        mes.count = 0;
+                        mes.message = "鎿嶄綔鎴愬姛!";
+                        mes.data = null;
+                    }
+                    else
+                    {
+                        mes.code = "300";
+                        mes.count = 0;
+                        mes.message = "鎿嶄綔澶辫触!";
+                        mes.data = null;
+                    }
+                }
+                else 
+                {
+                    mes.code = "300";
+                    mes.count = 0;
+                    mes.message = "璇烽�夋嫨闇�瑕佹壒閲忚皟鏁村伐浠风殑鎶ュ伐璁板綍!";
+                    mes.data = null;
+                    return mes;
+                }
+                return mes;
+            }
+            catch (Exception)
+            {
+
+                throw;
+            }
+        }
+        #endregion
+
 
 
         #region[鐢熶骇鎵ц,鎶ュ伐瀹℃牳鍒楄〃鏁版嵁鏌ヨ鎺ュ彛]
@@ -4620,6 +4756,7 @@
         #endregion
 
 
+
         #region[鐢熶骇鍏ュ簱鏉$爜琛ユ墦]
         public static ToMessage ProductInHouseLabCode(string ordercode)
         {
@@ -4663,12 +4800,26 @@
         #endregion
 
         #region[鐢熶骇鍏ュ簱淇℃伅鏌ヨ]
-        public static ToMessage ProductInHouseOrderSearch(string deptno, string saleordercode, string wkshopcode, string erpordercode, string mesordercode, string partcode, string partname, string partspec)
+        public static ToMessage ProductInHouseOrderSearch(string issouceorder, string deptno, string saleordercode, string wkshopcode, string erpordercode, string mesordercode, string partcode, string partname, string partspec)
         {
             var dynamicParams = new DynamicParameters();
             string search = "";
             try
             {
+                if (issouceorder != "" && issouceorder != null)
+                {
+                    switch (issouceorder)
+                    {
+                        case "Y":
+                            search += " and AA.m_po<>'' ";
+                            break;
+                        case "N":
+                            search += " and AA.m_po='' ";
+                            break;
+                        default:
+                            break;
+                    }
+                }
                 if (deptno != "" && deptno != null)
                 {
                     search += "and AA.dept_code=@deptno ";
@@ -4714,7 +4865,8 @@
                 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,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,T.stepname,M.wkshp_code,O.torg_name as wkshp_name,COALESCE(K.noid, E.stck_id) as stockid,COALESCE(K.code, E.stck_code) as stockcode,k.name as stockname,E.dept_id,E.dept_code,
-                              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,E.voucherdate   
+                              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,
+                              (case when E.voucherdate is null then M.lm_date else E.voucherdate end) as voucherdate 
                               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
@@ -4727,7 +4879,8 @@
                               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,T.stepname,M.wkshp_code,O.torg_name as wkshp_name,COALESCE(K.noid, E.stck_id) as stockid,COALESCE(K.code, E.stck_code) as stockcode,k.name as stockname,E.dept_id,E.dept_code,
-                              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,E.voucherdate   
+                              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,
+                              (case when E.voucherdate is null then M.lm_date else E.voucherdate end) as voucherdate 
                               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

--
Gitblit v1.9.3