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 { /// /// 群维护 /// /// /// /// /// 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() { 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; } /// /// 领取红包 /// /// /// /// /// 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() { 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; } /// /// 显示红包 /// /// /// public DataTable ShowWxHongBao(string v_username, decimal? v_eid, DateTime? stime, DateTime? etime) { try { var param = new List(); 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; } } }