ComplianceServer/oldcode/DAL/Wx/WX_HONGBAO_DAL.cs

151 lines
7.5 KiB
C#

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.OracleClient;
using WX.CRM.Common;
namespace WX.CRM.DAL.Wx
{
public class WX_HONGBAO_DAL
{
/// <summary>
/// 群维护
/// </summary>
/// <param name="v_chatroomname"></param>
/// <param name="v_name"></param>
/// <param name="v_ROOMOWNER"></param>
/// <param name="v_createtime"></param>
public bool WxHongBao(string v_sendid, string v_msgsvrid, string v_talker, string v_sendusername, decimal v_type, DateTime v_createtime, string v_title, string v_chatroomname, string v_jobusername)
{
bool isSucced = true;
try
{
var p = new List<OracleParameter>()
{
new OracleParameter() { ParameterName = "v_sendid", OracleType = OracleType.VarChar, Value =v_sendid },
new OracleParameter() { ParameterName = "v_msgsvrid", OracleType = OracleType.VarChar, Value =v_msgsvrid },
new OracleParameter() { ParameterName = "v_talker", OracleType = OracleType.VarChar, Value =v_talker },
new OracleParameter() { ParameterName = "v_sendusername", OracleType = OracleType.VarChar, Value =v_sendusername },
new OracleParameter() { ParameterName = "v_type", OracleType = OracleType.Number, Value =v_type },
new OracleParameter() { ParameterName = "v_createtime", OracleType = OracleType.DateTime, Value =v_createtime },
new OracleParameter() { ParameterName = "v_title", OracleType = OracleType.NVarChar, Value =v_title },
new OracleParameter() { ParameterName = "v_chatroomname", OracleType = OracleType.VarChar, Value =v_chatroomname },
new OracleParameter() { ParameterName = "v_jobusername", OracleType = OracleType.VarChar, Value =v_jobusername }
};
OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_WX_HONGBAO.WxHongBao", p.ToArray());
}
catch (Exception ex)
{
LogHelper.Error(string.Format("WxHongBao====v_sendid:{0},v_msgsvrid:{1},v_talker:{2},v_sendusername:{3},v_type:{4},v_createtime:{5},v_title:{6},v_chatroomname:{7},v_jobusername:{8}", v_sendid, v_msgsvrid, v_talker, v_sendusername, v_type, v_createtime.ToString("yyyy-MM-dd mm:hh:ss"), v_title, v_chatroomname, v_jobusername));
LogHelper.Error("PACK_WX_HONGBAO.WxHongBao:" + ex.ToString());
isSucced = false;
}
return isSucced;
}
/// <summary>
/// 领取红包
/// </summary>
/// <param name="v_chatroomname"></param>
/// <param name="v_name"></param>
/// <param name="v_ROOMOWNER"></param>
/// <param name="v_createtime"></param>
public bool WxHongBaoReceuve(string v_sendid, string v_msgsvrid, string v_username, DateTime v_createtime, string v_jobusername)
{
bool isSucced = true;
try
{
var p = new List<OracleParameter>()
{
new OracleParameter() { ParameterName = "v_sendid", OracleType = OracleType.VarChar, Value =v_sendid },
new OracleParameter() { ParameterName = "v_msgsvrid", OracleType = OracleType.VarChar, Value =v_msgsvrid },
new OracleParameter() { ParameterName = "v_username", OracleType = OracleType.VarChar, Value =v_username },
new OracleParameter() { ParameterName = "v_createtime", OracleType = OracleType.DateTime, Value =v_createtime },
new OracleParameter() { ParameterName = "v_jobusername", OracleType = OracleType.VarChar, Value =v_jobusername }
};
OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_WX_HONGBAO.WxHongBaoReceuve", p.ToArray());
}
catch (Exception ex)
{
LogHelper.Error(string.Format("WxHongBaoReceuve=====v_sendid:{0},v_msgsvrid:{1},v_username:{2},v_createtime:{3},v_jobusername:{4}", v_sendid, v_msgsvrid, v_username, v_createtime.ToString("yyyy-MM-dd mm:hh:ss"), v_jobusername));
LogHelper.Error("PACK_WX_HONGBAO.WxHongBaoReceuve:" + ex.ToString());
isSucced = false;
}
return isSucced;
}
/// <summary>
/// 显示红包
/// </summary>
/// <param name="v_username"></param>
/// <returns></returns>
public DataTable ShowWxHongBao(string v_username, decimal? v_eid, DateTime? stime, DateTime? etime)
{
try
{
var param = new List<OracleParameter>();
param.Add(new OracleParameter() { ParameterName = "v_username", OracleType = OracleType.VarChar, Value = v_username });
if (stime.HasValue)
param.Add(new OracleParameter() { ParameterName = "v_sdate", OracleType = OracleType.DateTime, Value = stime.Value });
else
param.Add(new OracleParameter() { ParameterName = "v_sdate", OracleType = OracleType.DateTime, Value = DBNull.Value });
if (etime.HasValue)
param.Add(new OracleParameter() { ParameterName = "v_edate", OracleType = OracleType.DateTime, Value = etime.Value });
else
param.Add(new OracleParameter() { ParameterName = "v_edate", OracleType = OracleType.DateTime, Value = DBNull.Value });
if (v_eid.HasValue)
param.Add(new OracleParameter() { ParameterName = "v_eid", OracleType = OracleType.Number, Value = v_eid.Value });
else
param.Add(new OracleParameter() { ParameterName = "v_eid", OracleType = OracleType.Number, Value = DBNull.Value });
param.Add(new OracleParameter() { ParameterName = "v_data", OracleType = OracleType.Cursor, Direction = ParameterDirection.Output });
DataSet dest = OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_WX_HONGBAO.ShowHongBao", param.ToArray());
return dest.Tables[0];
}
catch (Exception ex)
{
LogHelper.Error(ex);
throw;
}
}
public DataTable GetHonBaoNotice()
{
DataTable table = null;
try
{
OracleParameter[] p2 =
{
new OracleParameter() { ParameterName = "p_data", OracleType=OracleType.Cursor,Direction = ParameterDirection.Output}
};
table = OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_WX_HONGBAO.GetHongBaoNotice", p2).Tables[0];
}
catch (Exception ex)
{
LogHelper.Error(ex.ToString());
}
return table;
}
public bool UpdateHongBaoLookStatus(decimal eid)
{
bool result = false;
try
{
OracleParameter[] p2 =
{
new OracleParameter() { ParameterName = "p_eid", OracleType=OracleType.Number,Value=eid}
};
OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_WX_HONGBAO.UpdateHongBaoLookStatus", p2);
result = true;
}
catch (Exception ex)
{
LogHelper.Error(ex.ToString());
}
return result;
}
}
}