From 02fe59564a19996974a9d36be6ab61f29ee4c004 Mon Sep 17 00:00:00 2001
From: wzp <2040239371@qq.com>
Date: 星期三, 02 十一月 2022 17:06:36 +0800
Subject: [PATCH] 修复好几个bug

---
 web/Dao/GwAuditCacheDao.cs |   63 ++++++++++++++++++++++++++++++-
 1 files changed, 61 insertions(+), 2 deletions(-)

diff --git a/web/Dao/GwAuditCacheDao.cs b/web/Dao/GwAuditCacheDao.cs
index f95e3ce..5f16a45 100644
--- a/web/Dao/GwAuditCacheDao.cs
+++ b/web/Dao/GwAuditCacheDao.cs
@@ -7,6 +7,7 @@
     using System;
     using System.Collections.Generic;
     using System.Data;
+    using System.Data.Common;
     using System.Runtime.InteropServices;
     using System.Text;
     using System.Text.RegularExpressions;
@@ -94,8 +95,19 @@
         {
             string OP = "";
             if (opname != "")
-                OP = $"and op.OP_NAME='{opname}'";
-            string str = string.Format("SELECT  op.op_name,ca.SP_ID,ca.OP_ID,ca.MSG_CONTENT,ca.KEYWORD,ca.HASH_CODE,COUNT(*) CNT FROM GW_AUDIT_CACHE ca left join gw_op op on ca.op_id=op.op_id WHERE  {0} ca.AP_SUBMIT_TIME BETWEEN :START_TIME AND :END_TIME AND (ca.MSG_CONTENT LIKE :CONTENT OR :CONTENT='%%') AND ca.AUDITING_STATUS=:AUDITING_STATUS {1} \r\n   GROUP BY ca.SP_ID,ca.OP_ID,ca.MSG_CONTENT,ca.KEYWORD,ca.HASH_CODE,op.op_name", this.GenerateOpIDsString(spids), OP);
+            { OP = $"and op.OP_NAME='{opname}'"; }
+            //string str = string.Format("SELECT op.op_name,ca.SP_ID,ca.OP_ID,ca.MSG_CONTENT,ca.KEYWORD,ca.HASH_CODE,COUNT(*) CNT " +
+            //    "FROM GW_AUDIT_CACHE ca left join gw_op op on ca.op_id=op.op_id WHERE " +
+            //    " {0} ca.AP_SUBMIT_TIME BETWEEN :START_TIME AND :END_TIME AND (ca.MSG_CONTENT LIKE :CONTENT OR :CONTENT='%%')" +
+            //    " AND ca.AUDITING_STATUS=:AUDITING_STATUS {1} \r\n  " +
+            //    " GROUP BY ca.SP_ID,ca.OP_ID,ca.MSG_CONTENT,ca.KEYWORD,ca.HASH_CODE,op.op_name", this.GenerateOpIDsString(spids), OP);
+            //鏈�鏂�
+            string str = string.Format("SELECT op.op_name,ca.SP_ID,ca.OP_ID,ca.MSG_CONTENT,ca.KEYWORD,ca.HASH_CODE,COUNT(*) CNT " +
+                "FROM GW_AUDIT_CACHE ca left join gw_op op on ca.op_id=op.op_id WHERE " +
+                " ca.SP_ID IN '{0}' and ca.AP_SUBMIT_TIME BETWEEN :START_TIME AND :END_TIME AND (ca.MSG_CONTENT LIKE :CONTENT OR :CONTENT='%%')" +
+                " AND ca.AUDITING_STATUS=:AUDITING_STATUS {1} \r\n  " +
+                " GROUP BY ca.SP_ID,ca.OP_ID,ca.MSG_CONTENT,ca.KEYWORD,ca.HASH_CODE,op.op_name",spids, OP);
+
             List<GwAuditCache> list = new List<GwAuditCache>();
             OracleParameter[] parameterArray = new OracleParameter[] { new OracleParameter(":START_TIME", begin), new OracleParameter(":END_TIME", end), new OracleParameter(":CONTENT", "%" + content + "%"), new OracleParameter(":AUDITING_STATUS", status) };
             recordCount = Convert.ToInt32(OracleHelper.ExecuteScalar(OracleHelper.ToCountSql(str), OracleHelper.Connection, parameterArray));
@@ -190,5 +202,52 @@
             OracleParameter[] parameterArray = new OracleParameter[] { new OracleParameter(":AUDITING_STATUS", (int)status), new OracleParameter(":HASH_CODE", hashCode), new OracleParameter(":OP_ID", opID) };
             return (OracleHelper.ExecuteSql(str, OracleHelper.Connection, parameterArray) > 0);
         }
+
+        //鍙戦�佸唴瀹�:寰呭鏍哥粺璁�
+        public List<Dictionary<string, object>> GetSendAudit(string permissionsSQL)
+        {
+            List<Dictionary<string, object>> list = new List<Dictionary<string, object>>();
+            StringBuilder builder = new StringBuilder();
+            builder.Append(" SELECT COUNT(1) COUNT  FROM GW_AUDIT_CACHE WHERE AUDITING_STATUS =0 ");
+            builder.Append(permissionsSQL);
+
+            using (OracleDataReader reader = OracleHelper.ExecuteReader(builder.ToString(), OracleHelper.Connection))
+            {
+                while (reader != null && ((DbDataReader)reader).Read())
+                {
+                    OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
+                    int count = oracleReaderWrapper.GetInt("COUNT", 0);
+
+                    Dictionary<string, object> map = new Dictionary<string, object>();
+                    map.Add("count", count);
+                    list.Add(map);
+                }
+            }
+            return list;
+        }
+
+        //鍙戦�佸唴瀹�:浜屾寰呭鏍哥粺璁�
+        public List<Dictionary<string, object>> GetSendAuditTow(string permissionsSQL)
+        {
+            List<Dictionary<string, object>> list = new List<Dictionary<string, object>>();
+            StringBuilder builder = new StringBuilder();
+            builder.Append(" SELECT COUNT(1) COUNT  FROM GW_AUDIT_CACHE WHERE AUDITING_STATUS =10 ");
+            builder.Append(permissionsSQL);
+
+            using (OracleDataReader reader = OracleHelper.ExecuteReader(builder.ToString(), OracleHelper.Connection))
+            {
+                while (reader != null && ((DbDataReader)reader).Read())
+                {
+                    OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
+                    int count = oracleReaderWrapper.GetInt("COUNT", 0);
+
+                    Dictionary<string, object> map = new Dictionary<string, object>();
+                    map.Add("count", count);
+                    list.Add(map);
+                }
+            }
+            return list;
+        }
     }
+
 }

--
Gitblit v1.9.1