using System; using System.Collections.Generic; using System.Linq; using System.Web; using Oracle.ManagedDataAccess.Client; using System.Data; namespace ResfullApi.Models { public class usersDataAccess { public usersDataAccess() { } public static DataSet USERS_API_DK_HUY(string v_msisdn, string v_users, string v_pass, string v_passnew, string n_serviceid, string v_command, string v_channel, string v_role) { // {"msisdn":"50940227941","users":"123","pass":"123","serviceId":"23","type":"DK","channel":"WEB"} string str; str = ""; str = "api_pkg.USERS_API_DK_HUY"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_msisdn", OracleDbType.NVarchar2), new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_pass", OracleDbType.NVarchar2), new OracleParameter("v_passnew", OracleDbType.NVarchar2), new OracleParameter("n_serviceid", OracleDbType.NVarchar2), new OracleParameter("v_command", OracleDbType.NVarchar2), new OracleParameter("v_channel", OracleDbType.NVarchar2), new OracleParameter("v_role", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = v_msisdn; parms[1].Value = v_users; parms[2].Value = v_pass; parms[3].Value = v_passnew; parms[4].Value = n_serviceid; parms[5].Value = v_command; parms[6].Value = v_channel; parms[7].Value = v_role; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GET_STATUS(string v_users, string n_serviceid) { // {"users":"123","serviceId":"23"} string str; str = ""; str = "api_pkg.USERS_GET_STATUS"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("n_serviceid", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = v_users; parms[1].Value = n_serviceid; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet SERVICE_SEARCH_DETAIL(string serviceId, string msisdn, string role) { string sSQL = "MPS_PKG.SEARCH_SUB"; OracleParameter[] cmdParms = new OracleParameter[] { new OracleParameter("vtype", OracleDbType.NVarchar2), new OracleParameter("vmsisdn", OracleDbType.NVarchar2), new OracleParameter("vrole", OracleDbType.NVarchar2), new OracleParameter("returnds", OracleDbType.RefCursor, ParameterDirection.Output) }; cmdParms[0].Value = serviceId; cmdParms[1].Value = msisdn; cmdParms[2].Value = role; return DataAccess.getDataFromProcedure(sSQL, "HR_Content", cmdParms); } public static DataSet USERS_UPDATE_PROFILE(string users, string fullName, string sex, string address, string province, string cardNumber, string email, string company, string description, string picture,string sexNeed,string birthday,string height,string weight,string work,string serviceid,string lookingFor) { // {"users":"123","serviceId":"23"} string str; str = ""; str = "api_pkg.USERS_UPDATE_PROFILE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_fullName", OracleDbType.NVarchar2), new OracleParameter("v_sex", OracleDbType.NVarchar2), new OracleParameter("v_address", OracleDbType.NVarchar2), new OracleParameter("v_province", OracleDbType.NVarchar2), new OracleParameter("v_cardNumber", OracleDbType.NVarchar2), new OracleParameter("v_email", OracleDbType.NVarchar2), new OracleParameter("v_company", OracleDbType.NVarchar2), new OracleParameter("v_description", OracleDbType.NVarchar2), new OracleParameter("v_picture", OracleDbType.NVarchar2), new OracleParameter("v_sexNeed", OracleDbType.NVarchar2), new OracleParameter("v_birthday", OracleDbType.NVarchar2), new OracleParameter("v_height", OracleDbType.NVarchar2), new OracleParameter("v_weight", OracleDbType.NVarchar2), new OracleParameter("v_work", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_lookingFor", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = fullName; parms[2].Value = sex; parms[3].Value = address; parms[4].Value = province; parms[5].Value = cardNumber; parms[6].Value = email; parms[7].Value = company; parms[8].Value = description; parms[9].Value = picture; parms[10].Value = sexNeed; parms[11].Value = birthday; parms[12].Value = height; parms[13].Value = weight; parms[14].Value = work; parms[15].Value = serviceid; parms[16].Value = lookingFor; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GET_PROFILE(string users, string serviceid, string uidQuery) { // {"users":"123","serviceId":"23"} string str; str = ""; str = "api_pkg.USERS_GET_PROFILE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_usersQuery", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = uidQuery; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_SEARCHE_PROFILE(string users, string serviceid, string proviceId, string fromAge, string toAge, string rowsOnPage, string seqPage, string isLike, string type, string v_seek) { // {"users":"50912345678","serviceId":"30","proviceId":"1","fromAge":"1","toAge":"50","rowsOnPage":"2","seqPage":"1","isLike":"1"} string str; str = ""; str = "api_pkg.USERS_SEARCHE_PROFILE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_proviceId", OracleDbType.NVarchar2), new OracleParameter("v_fromAge", OracleDbType.NVarchar2), new OracleParameter("v_toAge", OracleDbType.NVarchar2), new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2), new OracleParameter("v_seqPage", OracleDbType.NVarchar2), new OracleParameter("v_isLike", OracleDbType.NVarchar2), new OracleParameter("v_type", OracleDbType.NVarchar2), new OracleParameter("v_seek", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = proviceId; parms[3].Value = fromAge; parms[4].Value = toAge; parms[5].Value = rowsOnPage; parms[6].Value = seqPage; parms[7].Value = isLike; parms[8].Value = type; parms[9].Value = v_seek; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_CHAT_GET(string users, string serviceid, string rowsOnPage, string seqPage) { string str; str = ""; str = "api_pkg.USERS_CHAT_GET"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2), new OracleParameter("v_seqPage", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = rowsOnPage; parms[3].Value = seqPage; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_CHAT_SEARCH(string users, string serviceid, string rowsOnPage, string seqPage,string keyword) { string str; str = ""; str = "api_pkg.USERS_CHAT_SEARCH"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2), new OracleParameter("v_seqPage", OracleDbType.NVarchar2), new OracleParameter("v_keyword", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = rowsOnPage; parms[3].Value = seqPage; parms[4].Value = keyword; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_CHAT_DETAIL_GET(string chatId, string rowsOnPage, string seqPage,string users,string serviceId) { string str; str = ""; str = "api_pkg.USERS_CHAT_DETAIL_GET"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_chatId", OracleDbType.NVarchar2), new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2), new OracleParameter("v_seqPage", OracleDbType.NVarchar2), new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = chatId; parms[1].Value = rowsOnPage; parms[2].Value = seqPage; parms[3].Value = users; parms[4].Value = serviceId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_CHAT_SEND_MSG(string users, string serviceid, string users_receved, string msg, string title,string chatId) { string str; str = ""; str = "api_pkg.USERS_CHAT_SEND_MSG"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_users_receved", OracleDbType.NVarchar2), new OracleParameter("v_msg", OracleDbType.NVarchar2), new OracleParameter("v_title", OracleDbType.Clob), new OracleParameter("v_chatId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = users_receved; parms[3].Value = msg; parms[4].Value = title; parms[5].Value = chatId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_CHAT_DETAIL_CHECK(string chatDetailId) { string str; str = ""; str = "api_pkg.USERS_CHAT_DETAIL_CHECK"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_chatDetailId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = chatDetailId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_CHAT_DEL(string chatId) { string str; str = ""; str = "api_pkg.USERS_CHAT_DEL"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_chatId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = chatId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_CHAT_DETAIL_DEL(string chatDetailId) { string str; str = ""; str = "api_pkg.USERS_CHAT_DETAIL_DEL"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_chatDetailId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = chatDetailId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_MSG_SEND(string users, string serviceid, string users_receved, string msg_local, string title,string msg_global,string title_global) { string str; str = ""; str = "api_pkg.USERS_MSG_SEND"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_users_receved", OracleDbType.NVarchar2), new OracleParameter("v_msg", OracleDbType.Clob), new OracleParameter("v_title", OracleDbType.NVarchar2), new OracleParameter("v_msg_global", OracleDbType.Clob), new OracleParameter("v_title_global", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = users_receved; parms[3].Value = msg_local; parms[4].Value = title; parms[5].Value = msg_global; parms[6].Value = title_global; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_MSG_GET(string users, string serviceid, string isSend,string messageId , string language, string fromDate, string toDate, string rowsOnPage, string seqPage) { string str; str = ""; str = "api_pkg.USERS_MSG_GET"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_isSend", OracleDbType.NVarchar2), new OracleParameter("v_top", OracleDbType.NVarchar2), new OracleParameter("v_msgId", OracleDbType.NVarchar2), new OracleParameter("v_language", OracleDbType.NVarchar2), new OracleParameter("v_fromDate", OracleDbType.NVarchar2), new OracleParameter("v_toDate", OracleDbType.NVarchar2), new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2), new OracleParameter("v_seqPage", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = isSend; parms[3].Value = messageId; parms[4].Value = language; parms[5].Value = fromDate; parms[6].Value = toDate; parms[7].Value = rowsOnPage; parms[8].Value = seqPage; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_MSG_CHECK( string messageId) { string str; str = ""; str = "api_pkg.USERS_MSG_CHECK"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_msgId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = messageId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_PIC_ADD(string v_users,string serviceId, string v_url, string v_note) { string str; str = ""; str = "api_pkg.USERS_PIC_ADD"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_url", OracleDbType.NVarchar2), new OracleParameter("v_note", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = v_users; parms[1].Value = serviceId; parms[2].Value = v_url; parms[3].Value = v_note; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_PIC_GET(string v_picId, string v_users,string v_serviceId, string v_top) { string str; str = ""; str = "api_pkg.USERS_PIC_GET"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_picId", OracleDbType.NVarchar2), new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_top", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = v_picId; parms[1].Value = v_users; parms[2].Value = v_serviceId; parms[3].Value = v_top; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_PIC_DEL(string v_picId) { string str; str = ""; str = "api_pkg.USERS_PIC_DEL"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_picId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = v_picId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_LIKE_UPDATE(string v_users, string serviceId, string v_usersLike, string v_isLike) { string str; str = ""; str = "api_pkg.USERS_LIKE_UPDATE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users_send", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_users_receved", OracleDbType.NVarchar2), new OracleParameter("v_isLike", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = v_users; parms[1].Value = serviceId; parms[2].Value = v_usersLike; parms[3].Value = v_isLike; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_VIEW_UPDATE(string v_users, string serviceId, string users_receved) { string str; str = ""; str = "api_pkg.USERS_VIEW_UPDATE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_users_receved", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = v_users; parms[1].Value = serviceId; parms[2].Value = users_receved; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GET_LIKE_PROFILE(string users, string serviceid, string type, string rowsOnPage, string seqPage) { // {"users":"50912345678","serviceId":"30","type":"0","rowsOnPage":"2","seqPage":"1"} string str; str = ""; str = "api_pkg.USERS_GET_LIKE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_type", OracleDbType.NVarchar2), new OracleParameter("v_rowsOnPay", OracleDbType.NVarchar2), new OracleParameter("v_seqPage", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = type; parms[3].Value = rowsOnPage; parms[4].Value = seqPage; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_UPDATE_LANGUAGE(string v_users, string serviceId, string v_language) { string str; str = ""; str = "api_pkg.USERS_UPDATE_LANGUAGE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_language", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = v_users; parms[1].Value = serviceId; parms[2].Value = v_language; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GET_PROVICE(string language,string serviceId) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_GET_PROVICE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_language", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = language; parms[1].Value = serviceId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GET_TOPIC(string language, string serviceId) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_GET_TOPIC"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_language", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = language; parms[1].Value = serviceId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet ADMIN_USERS_INFO(string v_users, string v_pass) { // {"msisdn":"50940227941","users":"123","pass":"123","serviceId":"23","type":"DK","channel":"WEB"} string str; str = ""; str = "api_pkg.ADMIN_LOGIN"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_user", OracleDbType.NVarchar2), new OracleParameter("v_pass", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = v_users; parms[1].Value = v_pass; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet ADMIN_USERS_FUNCTION(string role) { // {"msisdn":"50940227941","users":"123","pass":"123","serviceId":"23","type":"DK","channel":"WEB"} string str; str = ""; str = "api_pkg.ADMIN_GET_ROLE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_role", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = role; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GIFT_GET_SUBSERVICECODE(string users, string serviceId, string users_receved, string giftId, string giftType) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_GIFT_GET_SUBSERVICECODE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_users_receved", OracleDbType.NVarchar2), new OracleParameter("v_giftId", OracleDbType.NVarchar2), new OracleParameter("v_giftType", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceId; parms[2].Value = users_receved; parms[3].Value = giftId; parms[4].Value = giftType; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GIFT_GET(string language, string id, string serviceId) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_GIFT_GET"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_language", OracleDbType.NVarchar2), new OracleParameter("v_id", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = language; parms[1].Value = id; parms[2].Value = serviceId; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GIFT_SEND(string users, string serviceid,string users_receved,string giftid) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_GIFT_SEND"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceid", OracleDbType.NVarchar2), new OracleParameter("v_users_receved", OracleDbType.NVarchar2), new OracleParameter("v_giftId", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = users_receved; parms[3].Value = giftid; return DataAccess.getDataFromProcedure(str, "", parms); } //{"giftSendId":"1","users":"50912345678","serviceId":"30","rowsOnPage":"2","seqPage":"1","type":"0"} public static DataSet USERS_GIFT_GET_BUY_USERS( string users, string serviceid, string rowsOnPage, string seqPage, string type) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_GIFT_GET_BUY_USERS"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceid", OracleDbType.NVarchar2), new OracleParameter("v_rowsOnPage", OracleDbType.NVarchar2), new OracleParameter("v_seqPage", OracleDbType.NVarchar2), new OracleParameter("v_type", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; parms[2].Value = rowsOnPage; parms[3].Value = seqPage; parms[4].Value = type; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GIFT_GET_BUY_TOTAL_USERS(string users, string serviceid) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_GIFT_GET_BUY_TOTAL_USERS"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceid", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceid; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GET_INTERESTS(string language) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_GET_INTERESTS"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_language", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = language; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_GET_INTERESTS_BY_USER(string language,string users,string serviceId) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_GET_INTERESTS_BY_USER"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_language", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceId; parms[2].Value = language; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_INTERESTS_UPDATE( string users, string serviceId,string listInterests) { // {"language":"0"} string str; str = ""; str = "api_pkg.USERS_INTERESTS_UPDATE"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceId", OracleDbType.NVarchar2), new OracleParameter("v_listInterests", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = users; parms[1].Value = serviceId; parms[2].Value = listInterests; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet USERS_UPDATE_COIN(string usersId, string coin, string type, string trandCode) { // {"users":"123","serviceId":"23"} string str; str = ""; str = "api_pkg.USERS_UPDATE_COIN"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_usersId", OracleDbType.NVarchar2), new OracleParameter("v_coin", OracleDbType.NVarchar2), new OracleParameter("v_type", OracleDbType.NVarchar2), new OracleParameter("v_tranCode", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = usersId; parms[1].Value = coin; parms[2].Value = type; parms[3].Value = trandCode; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet ChangeCoinToMoney(string usersId, string serviceId, string money) { string str; str = ""; str = "api_pkg.USERS_CHANGE_COIN_MONEY"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("v_serviceid", OracleDbType.NVarchar2), new OracleParameter("v_money", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = usersId; parms[1].Value = serviceId; parms[2].Value = money; return DataAccess.getDataFromProcedure(str, "", parms); } public static void InsertBulkBlackData(string sSQL, List> dataColumn) { OracleConnection connection = null; try { connection = DataAccess.getPoolingConnection(); connection.Open(); OracleTransaction transaction; // Start a local transaction transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted); using (var command = connection.CreateCommand()) { command.CommandText = sSQL; command.CommandType = CommandType.StoredProcedure; command.ArrayBindCount = dataColumn[0].Count; command.Transaction = transaction; var v_msisdn = dataColumn[0].ToArray(); OracleParameter param0 = new OracleParameter("v_msisdn", OracleDbType.NVarchar2, ParameterDirection.Input); param0.Value = v_msisdn; param0.Size = v_msisdn.Length; command.Parameters.Add(param0); var v_type = dataColumn[1].ToArray(); OracleParameter param1 = new OracleParameter("v_isBlaclist", OracleDbType.NVarchar2, ParameterDirection.Input); param1.Value = v_type; param1.Size = v_type.Length; command.Parameters.Add(param1); var v_user = dataColumn[2].ToArray(); OracleParameter param2 = new OracleParameter("v_userName", OracleDbType.NVarchar2, ParameterDirection.Input); param2.Value = v_user; param2.Size = v_user.Length; command.Parameters.Add(param2); command.ExecuteNonQuery(); transaction.Commit(); } } catch (OracleException ex) { Console.WriteLine(ex.ToString()); throw; } finally { connection.Close(); } } public static DataSet GET_BLACKLIST(string msisdn) { string str; str = ""; //str = "report_pkg.GET_USER_INFO"; str = "MPS_PKG.BLACKLIST_GET"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_msisdn", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = msisdn; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet TKupdateCheckPin(string usersname, string ip, string errCode, string message, string channel,string type) { string str; str = ""; str = "api_pkg.tokenUpdate"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_usersname", OracleDbType.NVarchar2), new OracleParameter("v_ip", OracleDbType.NVarchar2), new OracleParameter("v_errCode", OracleDbType.NVarchar2), new OracleParameter("v_message", OracleDbType.NVarchar2), new OracleParameter("v_channel", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = usersname; parms[1].Value = ip; parms[2].Value = errCode; parms[3].Value = message; parms[4].Value = channel; parms[5].Value = type; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet TKcheckSpamCheckPin(string usersname, string ip, string channel,string type) { string str; str = ""; str = "api_pkg.tokenCheckSpamCheckPin"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_usersname", OracleDbType.NVarchar2), new OracleParameter("v_ip", OracleDbType.NVarchar2), new OracleParameter("v_channel", OracleDbType.NVarchar2), new OracleParameter("v_type", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = usersname; parms[1].Value = ip; parms[2].Value = channel; parms[3].Value = type; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet TKcheckToken(string ip, string channel, string token) { string str; str = ""; str = "api_pkg.tokenCheck"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_ip", OracleDbType.NVarchar2), new OracleParameter("v_channel", OracleDbType.NVarchar2), new OracleParameter("v_token", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = ip; parms[1].Value = channel; parms[2].Value = token; return DataAccess.getDataFromProcedure(str, "", parms); } public static DataSet blackGettList(string msisdn, string type, string svid, string v_users) { string str; str = ""; str = "BALANCE_PKG.BLACK_GET"; OracleParameter[] parms; parms = new OracleParameter[] { new OracleParameter("v_msisdn", OracleDbType.NVarchar2), new OracleParameter("v_type", OracleDbType.NVarchar2), new OracleParameter("v_sv_id", OracleDbType.NVarchar2), new OracleParameter("v_users", OracleDbType.NVarchar2), new OracleParameter("P_RESULT",OracleDbType.RefCursor,ParameterDirection.Output), }; parms[0].Value = msisdn; parms[1].Value = type; parms[2].Value = svid; parms[3].Value = v_users; return DataAccess.getDataFromProcedure(str, "", parms); } public static void InsertBulkBlackList(string sSQL, List> dataColumn) { OracleConnection connection = null; try { connection = DataAccess.getPoolingConnection(); connection.Open(); OracleTransaction transaction; // Start a local transaction transaction = connection.BeginTransaction(IsolationLevel.ReadCommitted); using (var command = connection.CreateCommand()) { command.CommandText = sSQL; command.CommandType = CommandType.StoredProcedure; command.ArrayBindCount = dataColumn[0].Count; command.Transaction = transaction; var v_msisdn = dataColumn[0].ToArray(); OracleParameter param0 = new OracleParameter("v_msisdn", OracleDbType.NVarchar2, ParameterDirection.Input); param0.Value = v_msisdn; param0.Size = v_msisdn.Length; command.Parameters.Add(param0); var v_type = dataColumn[1].ToArray(); OracleParameter param1 = new OracleParameter("v_type", OracleDbType.NVarchar2, ParameterDirection.Input); param1.Value = v_type; param1.Size = v_type.Length; command.Parameters.Add(param1); var v_sv_id = dataColumn[2].ToArray(); OracleParameter param2 = new OracleParameter("v_sv_id", OracleDbType.NVarchar2, ParameterDirection.Input); param2.Value = v_sv_id; param2.Size = v_sv_id.Length; command.Parameters.Add(param2); var v_action = dataColumn[3].ToArray(); OracleParameter param3 = new OracleParameter("v_action", OracleDbType.NVarchar2, ParameterDirection.Input); param3.Value = v_action; param3.Size = v_action.Length; command.Parameters.Add(param3); var v_users = dataColumn[4].ToArray(); OracleParameter param4 = new OracleParameter("v_users", OracleDbType.NVarchar2, ParameterDirection.Input); param4.Value = v_users; param4.Size = v_users.Length; command.Parameters.Add(param4); command.ExecuteNonQuery(); transaction.Commit(); } } catch (OracleException ex) { Console.WriteLine(ex.ToString()); throw; } finally { connection.Close(); } } } }