TG.WXCRM.V4/DAL/WeWork/Rcontact_DAL.cs

124 lines
6.3 KiB
C#

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.OracleClient;
using WX.CRM.Common;
using WX.CRM.Model.DTO.wework;
namespace WX.CRM.DAL.WeWork
{
public class Rcontact_DAL
{
public void Rcontact_Set(Rcontact info, string jsontext)
{
try
{
//v_remoteid VARCHAR2,
//v_vid VARCHAR2,
//v_name VARCHAR2,
//v_mobile VARCHAR2,
//v_job VARCHAR2,
//v_userdeptinfolist VARCHAR2,
//v_unionid VARCHAR2,
//v_corpid VARCHAR2,
//v_avatorurl VARCHAR2,
//v_md5 VARCHAR2
var param = new List<OracleParameter>
{
new OracleParameter() { ParameterName = "v_remoteid", OracleType = OracleType.VarChar, Value =info.remoteId.ToString() },
new OracleParameter() { ParameterName = "v_vid", OracleType = OracleType.VarChar, Value =info.vid },
new OracleParameter() { ParameterName = "v_name", OracleType = OracleType.VarChar, Value =info.name },
new OracleParameter() { ParameterName = "v_mobile", OracleType = OracleType.VarChar, Value =info.mobile },
new OracleParameter() { ParameterName = "v_job", OracleType = OracleType.VarChar, Value =info.job },
new OracleParameter() { ParameterName = "v_userdeptinfolist", OracleType = OracleType.VarChar, Value =info.GetUserDeptInfoJson() },
new OracleParameter() { ParameterName = "v_unionid", OracleType = OracleType.VarChar, Value =info.unionid },
new OracleParameter() { ParameterName = "v_corpid", OracleType = OracleType.VarChar, Value =info.corpid.ToString() },
new OracleParameter() { ParameterName = "v_avatorurl", OracleType = OracleType.VarChar, Value =info.avatorUrl },
new OracleParameter() { ParameterName = "v_md5", OracleType = OracleType.VarChar, Value =Utility.EncryptMD5(jsontext) },
new OracleParameter() { ParameterName = "v_jsontext", OracleType = OracleType.Clob, Value =jsontext },
new OracleParameter() { ParameterName = "v_companyremark", OracleType = OracleType.VarChar, Value =info.extras.GetCompanyRemark() },
new OracleParameter() { ParameterName = "v_remarkphone", OracleType = OracleType.VarChar, Value =info.extras.GetRemarkPhone() },
new OracleParameter() { ParameterName = "v_realremark", OracleType = OracleType.VarChar, Value =info.extras.GetRealRemark() },
new OracleParameter() { ParameterName = "v_remarks", OracleType = OracleType.VarChar, Value =info.extras.remarks },
};
OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_WEWORK.Rcontact_All_Set", param.ToArray());
}
catch { throw; }
}
public void Rcontact_Relate(string remoteid, string vid, string resid)
{
try
{
var param = new List<OracleParameter>
{
new OracleParameter() { ParameterName = "v_remoteid", OracleType = OracleType.VarChar, Value =remoteid },
new OracleParameter() { ParameterName = "v_vid", OracleType = OracleType.VarChar, Value =vid },
new OracleParameter() { ParameterName = "v_resid", OracleType = OracleType.VarChar, Value =resid }
};
OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_WEWORK.Rcontact_Relate", param.ToArray());
}
catch { throw; }
}
public void Res_Customer_Relate(string resids)
{
try
{
var param = new List<OracleParameter>
{
new OracleParameter() { ParameterName = "v_resids", OracleType = OracleType.VarChar, Value =resids }
};
OracleHelper.ExecuteNonQuery(CommandType.StoredProcedure, "PACK_WEWORK.Res_Customer_Relate", param.ToArray());
}
catch { throw; }
}
/// <summary>
/// 获取工作微信好友列表
/// </summary>
/// <param name="v_vid">企微ID</param>
/// <returns></returns>
public List<shRcontact> Rcontact_Get(string v_vid)
{
DataTable tab = null;
List<shRcontact> shRcontactslist = new List<shRcontact>();
try
{
var param1 = new List<OracleParameter>()
{
new OracleParameter() { ParameterName = "v_vid", OracleType = OracleType.VarChar, Value =v_vid },
new OracleParameter() { ParameterName="v_data",OracleType=OracleType.Cursor,Direction = ParameterDirection.Output }
};
tab = OracleHelper.DataQueray(CommandType.StoredProcedure, "PACK_WEWORK.Rcontact_Get", param1.ToArray()).Tables[0];
foreach (DataRow item in tab.Rows)
{
shRcontact model = new shRcontact();
model.remoteid = Convert.ToString(item["remoteid"]);
model.name = Convert.ToString(item["name"]);
model.mobile = Convert.ToString(item["mobile"]);
model.job = Convert.ToString(item["job"]);
model.userdeptinfolist = Convert.ToString(item["userdeptinfolist"]);
model.unionid = Convert.ToString(item["unionid"]);
model.corpid = Convert.ToString(item["corpid"]);
model.avatorurl = Convert.ToString(item["avatorurl"]);
model.md5 = Convert.ToString(item["md5"]);
model.ctime = Convert.ToDateTime(item["ctime"]);
if (item["utime"] != DBNull.Value)
model.ctime = Convert.ToDateTime(item["utime"]);
model.vid = Convert.ToString(item["vid"]);
model.realremark = Convert.ToString(item["realremark"]);
shRcontactslist.Add(model);
}
}
catch (Exception ex)
{
LogHelper.Error(ex);
}
return shRcontactslist;
}
}
}