shakun 7 months ago
parent
commit
dde9a13ebb
  1. 2
      SendMail/API/ThirdPartyAPI.cs
  2. 13
      SendMail/Business/TxnPush.cs
  3. 3
      SendMail/Common/CommonResponse.cs
  4. 9
      SendMail/DAO/TxnPushDAO.cs

2
SendMail/API/ThirdPartyAPI.cs

@ -1,7 +1,7 @@
using Common;
using JMETxnPushScheduler.Business;
using JMETxnPushScheduler.Common;
using log4net;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;

13
SendMail/Business/TxnPush.cs

@ -63,6 +63,14 @@ namespace JMETxnPushScheduler.Business
// GetTxnDetails(item["ID"].ToString());
}
}
else if (_dbRes.Msg == "394449") //GCC
{
if (result.ResponseCode == "0")
{
_txnPush.UpdateTxnPost(item["ID"].ToString(), result.Extra, result.Id);
GetTxnDetails(item["ID"].ToString());
}
}
else
{
if (result.ResponseCode == "0")
@ -177,6 +185,7 @@ namespace JMETxnPushScheduler.Business
var request = new TFReleaseTxnRequest()
{
TfPin = item["CONTROLNO"].ToString(),
TxnId = item["CONTROLNO2"].ToString(),
RequestBy = "scheduler",
UserName = "scheduler",
ProviderId = item["sSuperAgent"].ToString(),
@ -190,7 +199,9 @@ namespace JMETxnPushScheduler.Business
Console.WriteLine("Release txn completed with response msg: " + result.Msg);
if (result.ResponseCode == "0")
{
_txnPush.UpdateTxnPost(item["ID"].ToString());
// _txnPush.UpdateTxnPost(item["ID"].ToString());
_txnPush.UpdateTxnPostRelease(item["ID"].ToString());
}
else
{

3
SendMail/Common/CommonResponse.cs

@ -52,14 +52,13 @@
public class TFReleaseTxnRequest
{
public string TfPin { get; set; }
public string TxnId { get; set; }
public string ProcessId { get; set; }
public string UserName { get; set; }
public string ProviderId { get; set; }
public string SessionId { get; set; }
public string RequestBy { get; set; }
public string TxnId { get; set; }
}
}

9
SendMail/DAO/TxnPushDAO.cs

@ -20,15 +20,22 @@ namespace JMETxnPushScheduler.DAO
return ExecuteDataTable(sql);
}
public void UpdateTxnPost(string id, string pCurrCostRate = null )
public void UpdateTxnPost(string id, string pCurrCostRate = null, string controlNo2 = null )
{
string sql = "EXEC PROC_TP_TXN_PUSH @FLAG = 'UPDATE-POST'";
sql += ", @TRAN_ID = " + FilterString(id);
sql += ", @control2 = " + FilterString(controlNo2);
sql += ", @pCurrCostRate = " + FilterString(pCurrCostRate);
ExecuteDataTable(sql);
}
public void UpdateTxnPostRelease(string id,string controlNo2 = null)
{
string sql = "EXEC PROC_TP_TXN_PUSH @FLAG = 'UPDATE-POST_RELEASE'";
sql += ", @TRAN_ID = " + FilterString(id);
ExecuteDataTable(sql);
}
public void UpdateTxnInstantPaid(string id)
{
string sql = "EXEC PROC_TP_TXN_PUSH @FLAG = 'INSTANT-PAID'";

Loading…
Cancel
Save