IME-LONDON
/
PUSH_JOB
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

synnc

feature/Redmine-17825-Email_Template^2
shakun 9 months ago
parent
4edba7f018
commit
8987982253
3 changed files with 106 additions and 53 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 63
      SendMail/API/NotifierV2.cs
  2. 66
      SendMail/Business/TxnPush.cs
  3. 30
      SendMail/DAO/TxnPushDAO.cs

63
SendMail/API/NotifierV2.cs
View File

@ -0,0 +1,63 @@
using JMETxnPushScheduler.Common;
using Newtonsoft.Json;
using Swift.API.Common.Enum;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
namespace JMETxnPushScheduler.API
{
public static class NotifierV2
{
// private static readonly ILog Log = LogManager.GetLogger(typeof(NotifierV2));
public static JsonResponse SendNotification(SendNotificationRequestMobile request, NOTIFICATION_TYPE nOTIFICATION_TYPE = NOTIFICATION_TYPE.PUSH_NOTIFICATION)
{
using (var client = RestApiClient.CallJMEThirdParty())
{
JsonResponse jsonResponse = new JsonResponse();
var obj = JsonConvert.SerializeObject(request);
var jbdContent = new StringContent(obj.ToString(), Encoding.UTF8, "application/json");
try
{
var URL = "api/v1/TP/NotificationAPI";
HttpResponseMessage resp = client.PostAsync(URL, jbdContent).Result;
string resultData = resp.Content.ReadAsStringAsync().Result;
if (resp.IsSuccessStatusCode)
{
jsonResponse = JsonConvert.DeserializeObject<JsonResponse>(resultData);
var a = (jsonResponse.Data != null ? JsonConvert.DeserializeObject<JsonResponse>(jsonResponse.Data.ToString()) : null);
jsonResponse.Data = a;
return jsonResponse;
}
else
{
var errorJson = JsonConvert.DeserializeObject<ErrorJosn>(resultData);
var jsonResponseData = JsonConvert.DeserializeObject<JsonResponse>(errorJson.Message);
var data = JsonConvert.DeserializeObject<List<Data>>(jsonResponseData.Data.ToString());
jsonResponse.Id = jsonResponseData.Id;
jsonResponse.ResponseCode = jsonResponseData.ResponseCode;
jsonResponse.Msg = jsonResponseData.Msg;
jsonResponse.Data = data;
jsonResponse.Extra = jsonResponseData.Extra;
jsonResponse.Extra1 = jsonResponseData.Extra1;
return jsonResponse;
}
}
catch (Exception ex)
{
return new JsonResponse()
{
ResponseCode = "1",
Msg = (ex.InnerException == null ? ex.Message : ex.InnerException.Message)
};
}
}
}
}
}

66
SendMail/Business/TxnPush.cs
View File

@ -14,7 +14,7 @@ namespace JMETxnPushScheduler.Business
TxnPushDAO _txnPush = new TxnPushDAO();
public void TxnSyncMain()
{
DataTable txnData = _txnPush.GetTxnDataForApprove();
if (txnData.Rows.Count == 0 || null == txnData)
{
@ -47,60 +47,20 @@ namespace JMETxnPushScheduler.Business
{
if (result.ResponseCode == "0")
{
_txnPush.UpdateTxnPost(item["ID"].ToString(), result.Extra);
GetTxnDetails(item["ID"].ToString());
_txnPush.UpdateTxnInstantPaid(item["ID"].ToString());
}
else if (result.ResponseCode == "100")//Transaction has been processed for Bank Deposit.
{
_txnPush.UpdateTxnPost(item["ID"].ToString());
_txnPush.UpdateTxnPost(item["ID"].ToString(), result.Extra);
GetTxnDetails(item["ID"].ToString());
}
else if (result.ResponseCode == "7000" && result.Msg.Contains("ALREADY USED"))
{
_txnPush.UpdateTxnPost(item["ID"].ToString());
GetTxnDetails(item["ID"].ToString());
}
}
else if (_dbRes.Msg == "394132")
{
if (result.ResponseCode == "0" || (!string.IsNullOrEmpty(result.Extra) && result.Extra.Equals("0006"))) //Duplicate records
{
_txnPush.UpdateTxnPost(item["ID"].ToString());
GetTxnDetails(item["ID"].ToString());
}
}
else if (_dbRes.Msg == "394414") //brac
{
if (result.ResponseCode == "0" || (!string.IsNullOrEmpty(result.Msg) && result.Msg.Equals("DuplicateTTNumber"))) //004- Duplicate records
{
_txnPush.UpdateTxnPost(item["ID"].ToString());
GetTxnDetails(item["ID"].ToString());
}
}
else if (_dbRes.Msg == "394428") //Cebuana
{
if (result.ResponseCode == "0" || (!string.IsNullOrEmpty(result.Extra) && result.Extra.Equals("05"))) // Control Number Already In Use
{
_txnPush.UpdateTxnPost(item["ID"].ToString());
GetTxnDetails(item["ID"].ToString());
}
else if (!string.IsNullOrEmpty(result.Extra) && result.Extra.Equals("19")) //"RTA Internal Error-Reference Number Already Exists
{
_txnPush.UpdateTxnPost(item["ID"].ToString());
GetTxnDetails(item["ID"].ToString());
}
}
else if (_dbRes.Msg == "394434") //wings
{
if (result.ResponseCode == "0")
{
_txnPush.UpdateTxnPost(item["ID"].ToString());
GetTxnDetails(item["ID"].ToString());
}
else if (!string.IsNullOrEmpty(result.Extra) && result.Extra.Equals("200")) //" Txn found in wings system.
{
_txnPush.UpdateTxnPost(item["ID"].ToString());
GetTxnDetails(item["ID"].ToString());
// GetTxnDetails(item["ID"].ToString());
}
}
else
@ -137,7 +97,7 @@ namespace JMETxnPushScheduler.Business
bodyMappings.Add(new Mapping() { SValue = "Fee", SText = cd.serviceCharge });
bodyMappings.Add(new Mapping() { SValue = "TotalAmt", SText = cd.TotalAmount });
if(cd.paymentMethod.ToUpper() == "BANK DEPOSIT")
if (cd.paymentMethod.ToUpper() == "BANK DEPOSIT")
{
SendNotificationRequestMobile request = new SendNotificationRequestMobile()
{
@ -159,8 +119,12 @@ namespace JMETxnPushScheduler.Business
}
}
};
var r = NotifierV2.SendNotification(request);
Console.Write(JsonConvert.SerializeObject(r));
}
else if(cd.paymentMethod.ToUpper() == "CASH PAYMENT")
else if (cd.paymentMethod.ToUpper() == "CASH PAYMENT")
{
SendNotificationRequestMobile request = new SendNotificationRequestMobile()
{
@ -182,8 +146,12 @@ namespace JMETxnPushScheduler.Business
}
}
};
var r1 = NotifierV2.SendNotification(request);
Console.Write(JsonConvert.SerializeObject(r1));
}
}

30
SendMail/DAO/TxnPushDAO.cs
View File

@ -20,11 +20,12 @@ namespace JMETxnPushScheduler.DAO
return ExecuteDataTable(sql);
}
public void UpdateTxnPost(string id)
public void UpdateTxnPost(string id, string pCurrCostRate = null )
{
string sql = "EXEC PROC_TP_TXN_PUSH @FLAG = 'UPDATE-POST'";
sql += ", @TRAN_ID = " + FilterString(id);
sql += ", @pCurrCostRate = " + FilterString(pCurrCostRate);
ExecuteDataTable(sql);
}
@ -47,10 +48,31 @@ namespace JMETxnPushScheduler.DAO
public TxnDetails GetTxnDetails(string tranId)
{
string sql = "EXEC GetUserInfo @FLAG = 'txn-details'";
var sql = "EXEC GetUserInfo @flag='txn-details' ";
sql += ", @tranId = " + FilterString(tranId);
var row = ExecuteDataRow(sql);
TxnDetails userDetails = new TxnDetails();
if (row != null)
{
userDetails.senderName = row["senderName"].ToString();
userDetails.PayoutCountry = row["pcountry"].ToString();
userDetails.controlNo = row["controlNo"].ToString();
userDetails.BeneficiaryName = row["receiverName"].ToString();
userDetails.paymentMethod = row["paymentMethod"].ToString();
userDetails.BankName = row["pBankName"].ToString();
userDetails.BankBranch = row["pBankBranchName"].ToString();
userDetails.email = row["email"].ToString();
userDetails.AccountNo = row["accountNo"].ToString();
userDetails.PayoutAmount = row["pAmt"].ToString();
userDetails.TransferAmount = row["tamt"].ToString();
userDetails.TotalAmount = row["camt"].ToString();
userDetails.serviceCharge = row["serviceCharge"].ToString();
// userDetails.rewardPoints = row["rewardPoints"].ToString();
userDetails.TranDate = row["createdDate"].ToString();
}
return ParseDbResult<TxnDetails>(sql);
return userDetails;
}
private T ParseDbResult<T>(string sql)

Write Preview
Loading…
Cancel
Save