|
|
@ -378,6 +378,66 @@ namespace CustomerOnlineV2.Repository.Repository.TransactionRepository |
|
|
|
} |
|
|
|
return await Task.FromResult(_response); |
|
|
|
} |
|
|
|
|
|
|
|
public async Task<CustomerNotificationModel> GetRewardPoints(LoginResponse loginDetails) |
|
|
|
{ |
|
|
|
CustomerNotificationModel _response = new CustomerNotificationModel(); |
|
|
|
try |
|
|
|
{ |
|
|
|
var sql = "EXEC mobile_proc_customerMaster"; |
|
|
|
sql += " @Flag = " + _connHelper.FilterString("get-invite-details"); |
|
|
|
// sql += ",@User = " + _connHelper.FilterString(loginDetails.UserName);
|
|
|
|
sql += ",@sourceCustomerId = " + _connHelper.FilterString(loginDetails.UserId); |
|
|
|
_logger.LogDebug("HOMEREPOSITORY | GETREWARDPOINTS | SQL | " + sql); |
|
|
|
var dt = _connHelper.ExecuteDataTable(sql); |
|
|
|
|
|
|
|
if (dt == null || dt.Rows.Count <= 0) |
|
|
|
{ |
|
|
|
_response.ResponseCode = ResponseHelper.FAILED; |
|
|
|
_response.ResponseMessage = "DB Null Error!"; |
|
|
|
|
|
|
|
_logger.LogError("HOMEREPOSITORY | GETREWARDPOINTS | DB RESPONSE | " + JsonConvert.SerializeObject(_response)); |
|
|
|
} |
|
|
|
else |
|
|
|
{ |
|
|
|
//_response.ResponseCode = Convert.ToInt16(dt.Rows[0]["errorCode"]);
|
|
|
|
//_response.ResponseMessage = Convert.ToString(dt.Rows[0]["msg"]);
|
|
|
|
|
|
|
|
List<NotificationModel> obj = new List<NotificationModel>(); |
|
|
|
|
|
|
|
foreach (DataRow item in dt.Rows) |
|
|
|
{ |
|
|
|
obj.Add(new NotificationModel |
|
|
|
{ |
|
|
|
//Id = Convert.ToString(item["rowId"]),
|
|
|
|
//Title = Convert.ToString(item["REWARD_TYPE"]),
|
|
|
|
RewardAmount = Convert.ToString(item["REWARD_AMOUNT"]), |
|
|
|
//CustomerName = Convert.ToString(item["CUSTOMER_NAME"]),
|
|
|
|
//Date = Convert.ToString(item["CREATED_DATE"]),
|
|
|
|
RewardPoints = Convert.ToString(item["REWARD_POINTS"]), |
|
|
|
ReferralCode = loginDetails.MembershipId, |
|
|
|
//ReferralCode = Convert.ToString(item["REFERRAL_CODE"]),
|
|
|
|
//IsRead = Convert.ToString(item["isRead"]),
|
|
|
|
//Type = Convert.ToString(item["type"]),
|
|
|
|
//SentId = Convert.ToString(item["sentId"]),
|
|
|
|
// Category = Convert.ToString(item["category"]),
|
|
|
|
//url = Convert.ToString(item["url"]),
|
|
|
|
//IsClickable = Convert.ToString(item["isClickable"])
|
|
|
|
// notificationCount = Convert.ToString(item["notificationCount"])
|
|
|
|
}); |
|
|
|
} |
|
|
|
_response.NotificationModel = obj; |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) |
|
|
|
{ |
|
|
|
_response.ResponseCode = ResponseHelper.EXCEPTION; |
|
|
|
_response.ResponseMessage = "Exception occured: " + ex.Message; |
|
|
|
|
|
|
|
_logger.LogError("HOMEREPOSITORY | GETREWARDPOINTS | EXCEPTION | " + JsonConvert.SerializeObject(_response)); |
|
|
|
} |
|
|
|
return await Task.FromResult(_response); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|