From 2aecd940ab29bcc3783fe63b84ad685dabd49763 Mon Sep 17 00:00:00 2001
From: WYB <908761037@qq.com>
Date: 星期一, 29 三月 2021 20:12:40 +0800
Subject: [PATCH] Merge branch 'master' of http://101.37.171.70:10101/r/MESWMS-API

---
 WebAPI/Service/ProcessDal.cs |   48 +++++++++++++++++++++++++++++++++++-------------
 1 files changed, 35 insertions(+), 13 deletions(-)

diff --git a/WebAPI/Service/ProcessDal.cs b/WebAPI/Service/ProcessDal.cs
index cfb4099..9d29638 100644
--- a/WebAPI/Service/ProcessDal.cs
+++ b/WebAPI/Service/ProcessDal.cs
@@ -9,28 +9,50 @@
 {
     public class ProcessDal
     {
-        public static List<Models.M_StationBillMail> GetProcessList(string hName,int hLevel,string hNumber,string hBillSubType)
+        public static List<Models.M_Process> GetProcessList(string hName, int hLevel, string hNumber, string hBillSubType, int page, int limit,ref int pageCount)
         {
-            var sqlBuilder = new StringBuilder();
-            sqlBuilder.Append("select a.HItemID,a.HNumber,a.HName ,a.HLevel,a.HTypeFlow ,a.HTypeCount ,a.HBillSubType ");
-            sqlBuilder.Append(",a.HEndFlag,a.HStopFlag,b.hname,a.HSNo,a.HProcessID_K3,a.HFixPrice,a.HOverFixPrice ");
-            sqlBuilder.Append(",a.HEndFlag,a.HStopFlag,b.hname,a.HSNo,a.HProcessID_K3,a.HFixPrice,a.HOverFixPrice ");
-            sqlBuilder.Append(",a.HAutoTrunFlag,a.HRemark ,a.HProcessID_K3 from gy_Process a left join h_v_IF_Department b on a.HDeptID=b.hitemid where 1=1 ");
+          
+            var whereBuilder = new StringBuilder();
             if (!string.IsNullOrEmpty(hName))
-                sqlBuilder.Append(" and a.HName like '%@hName%'");
+                whereBuilder.Append($" and a.HName like '%{hName}%'");
             if(!string.IsNullOrEmpty(hNumber))
-                sqlBuilder.Append(" and a.HNumbe like '%@hNumber%'");
+                whereBuilder.Append($" and a.HNumber like '%{hNumber}%'");
             if (!string.IsNullOrEmpty(hBillSubType))
-                sqlBuilder.Append(" and a.HBillSubType like '%@hBillSubType%'");
+                whereBuilder.Append($" and a.HBillSubType like '%{hBillSubType}%'");
             if(hLevel!=0)
-                sqlBuilder.Append(" and a.HLevel=@hLevel");
-            var list = SqlPools.GetInstance("YqnConn").GetModelList<Models.M_StationBillMail>(sqlBuilder.ToString(), new { hName, hLevel, hNumber, hBillSubType });
+                whereBuilder.Append($" and a.HLevel={hLevel}");
+            var sqlBuilder = new StringBuilder();
+            sqlBuilder.Append($"select top {limit} a.HItemID,a.HNumber,a.HName ,a.HLevel,a.HTypeFlow ,a.HTypeCount ,a.HBillSubType ");
+            sqlBuilder.Append(",a.HEndFlag,a.HStopFlag,b.hname,a.HSNo,a.HProcessID_K3,a.HFixPrice,a.HOverFixPrice ");
+            sqlBuilder.Append(",a.HEndFlag,a.HStopFlag,b.hname,a.HSNo,a.HProcessID_K3,a.HFixPrice,a.HOverFixPrice ");
+            sqlBuilder.Append($",a.HAutoTrunFlag,a.HRemark ,a.HProcessID_K3 from gy_Process a left join h_v_IF_Department b on a.HDeptID=b.hitemid where a.HItemID not in (select top {(page-1)*limit} a.HItemID from gy_Process a left join h_v_IF_Department b on a.HDeptID=b.hitemid where 1=1 { whereBuilder }) {whereBuilder}");
+            var countSql = $"select count(*) from gy_Process a where 1=1 {whereBuilder}";
+            pageCount = SqlPools.GetInstance("YqnConn").GetExecuteScalar(countSql);
+            var list = SqlPools.GetInstance("YqnConn").GetModelList<Models.M_Process>(sqlBuilder.ToString());
             return list;
         }
-        public static Models.M_StationBillMail GetProcessDetail(int hItemID)
+        public static Models.M_Process GetProcessDetail(int hItemID)
         {
             var sql = "select HNumber,HHelpCode,HName,HNumber,HDeptID,HProcMulID,HRemark,HSNo,HFixPrice,HOverFixPrice,HBillSubType,HStopflag, HTypeFlow, HTypeCount, HAutoTrunFlag, HItemID from Gy_Process where HItemID=@hItemID";
-            var model = SqlPools.GetInstance("YqnConn").GetModel<Models.M_StationBillMail>(sql, new { hItemID });
+            var model = SqlPools.GetInstance("YqnConn").GetModel<Models.M_Process>(sql, new { hItemID });
+            return model;
+        }
+        public static int DeleteProcess(int hItemID)
+        {
+            var sql = "delete Gy_Process where HItemID=@hItemID";
+            var result = SqlPools.GetInstance("YqnConn").ExecuteCommand(sql, new { hItemID });
+            return result;
+        }
+        public static Models.M_Department GetDepartmentModel(int hItemID)
+        {
+            var sql = "select HName,HNumber,HItemID from  h_v_IF_Department where HItemID=@hItemID";
+            var model = SqlPools.GetInstance("YqnConn").GetModel<Models.M_Department>(sql, new { hItemID });
+            return model;
+        }
+        public static Models.M_ProcMul GetProcMulModel(int hItemID)
+        {
+            var sql = "Select HItemID,HNumber,HName from Gy_ProcMul where HItemID=@hItemID";
+            var model = SqlPools.GetInstance("YqnConn").GetModel<Models.M_ProcMul>(sql, new { hItemID });
             return model;
         }
     }

--
Gitblit v1.9.1