From 374ce4ffd0c459bb4067e8d5765f972668aff9b1 Mon Sep 17 00:00:00 2001
From: wzp <2040239371@qq.com>
Date: 星期四, 02 三月 2023 14:56:23 +0800
Subject: [PATCH] 变更oracle访问组件
---
web/Dao/GwAuditCacheDao.cs | 77 +++++++++++++++++++++++++++++++++++++-
1 files changed, 74 insertions(+), 3 deletions(-)
diff --git a/web/Dao/GwAuditCacheDao.cs b/web/Dao/GwAuditCacheDao.cs
index f95e3ce..f3b2388 100644
--- a/web/Dao/GwAuditCacheDao.cs
+++ b/web/Dao/GwAuditCacheDao.cs
@@ -3,10 +3,11 @@
{
using Common;
using Model;
- using Oracle.DataAccess.Client;
+ using Oracle.ManagedDataAccess.Client;
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,21 @@
{
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 spidStr = "";
+ if (!string.IsNullOrEmpty(spids))
+ {
+ spidStr = " and ca.SP_ID ='"+spids+"'";
+ }
+
+
+ string str = string.Format("SELECT op.op_name,ca.SP_ID,ca.client_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 1=1 " +
+ " {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.client_id,ca.OP_ID,ca.MSG_CONTENT,ca.KEYWORD,ca.HASH_CODE,op.op_name", spidStr, 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));
@@ -183,6 +197,16 @@
OracleParameter[] parameterArray = new OracleParameter[] { new OracleParameter(":AUDITING_STATUS", (int)status), new OracleParameter(":HASH_CODE", hashCode) };
return (OracleHelper.ExecuteSql(str, OracleHelper.Connection, parameterArray) > 0);
}
+
+ //鏇存柊鍐呭
+ public bool UpdateCacheContent(string hashCode, string content)
+ {
+ string str = "UPDATE GW_AUDIT_CACHE SET AP_SUBMIT_TIME=SYSDATE,MSG_CONTENT=:MSG_CONTENT WHERE HASH_CODE=:HASH_CODE";
+ OracleParameter[] parameterArray = new OracleParameter[] { new OracleParameter(":MSG_CONTENT", content), new OracleParameter(":HASH_CODE", hashCode) };
+ return (OracleHelper.ExecuteSql(str, OracleHelper.Connection, parameterArray) > 0);
+ }
+
+
public bool UpdateCacheStatus(string hashCode, AuditingStatus status, int opID)
{
@@ -190,5 +214,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