80 lines
3.0 KiB
C#
80 lines
3.0 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Data.OracleClient;
|
|
|
|
|
|
namespace WX.CRM.DAL.Res
|
|
{
|
|
public class RES_IMPORTRES_DAL
|
|
{
|
|
public void ImpotDt(System.Data.DataSet ds, int timeOut = 300)
|
|
{
|
|
var tb1 = ds.Tables["RES_IMPORTRES"];
|
|
var tb2 = ds.Tables["RES_IMPORTRES_DETAIL"];
|
|
if (tb1 != null)
|
|
OracleHelper.BulkToDB(tb1, "RES_IMPORTRES", timeOut);
|
|
if (tb2 != null)
|
|
OracleHelper.BulkToDB(tb2, "RES_IMPORTRES_DETAIL", timeOut);
|
|
}
|
|
|
|
public void DoImportDt(decimal p_importid)
|
|
{
|
|
System.Data.OracleClient.OracleParameter[] p =
|
|
{
|
|
new System.Data.OracleClient.OracleParameter("p_importid", System.Data.OracleClient.OracleType.Number)
|
|
};
|
|
p[0].Value = p_importid;
|
|
OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_RES.res_importres_do", p);
|
|
}
|
|
|
|
|
|
public DataSet ReportResource(DateTime? dtstart, DateTime? dtend)
|
|
{
|
|
var conn = new System.Data.OracleClient.OracleConnection(OracleHelper.AYCRMConn);
|
|
if (conn.State == ConnectionState.Closed)
|
|
conn.Open();
|
|
try
|
|
{
|
|
using (var trans = conn.BeginTransaction())
|
|
{
|
|
var p2 = new List<System.Data.OracleClient.OracleParameter>
|
|
{
|
|
new System.Data.OracleClient.OracleParameter() {ParameterName = "p_sd1", OracleType = System.Data.OracleClient.OracleType.DateTime, Value = dtstart},
|
|
new System.Data.OracleClient.OracleParameter() {ParameterName = "p_sd2", OracleType = System.Data.OracleClient.OracleType.DateTime, Value = dtend},
|
|
new System.Data.OracleClient.OracleParameter()
|
|
{
|
|
ParameterName = "v_emps",
|
|
OracleType = System.Data.OracleClient.OracleType.Cursor,
|
|
Direction = ParameterDirection.Output
|
|
}
|
|
};
|
|
var ds = OracleHelper.DataQueray(trans, CommandType.StoredProcedure,
|
|
"PACK_RES.res_ReportResource", p2.ToArray());
|
|
trans.Commit();
|
|
return ds;
|
|
}
|
|
}
|
|
catch (Exception)
|
|
{
|
|
throw;
|
|
}
|
|
finally
|
|
{
|
|
conn.Close();
|
|
}
|
|
}
|
|
|
|
public void BatchRemove(decimal importId)
|
|
{
|
|
var sql = "delete from exp_resimportid r where r.importid=:importId";
|
|
var param = new List<OracleParameter>()
|
|
{
|
|
new OracleParameter() { ParameterName="importId",OracleType= OracleType.VarChar,Value=importId}
|
|
};
|
|
OracleHelper.ExecuteNonQuery(CommandType.Text, sql, param.ToArray());
|
|
}
|
|
|
|
}
|
|
}
|