553 lines
21 KiB
PHP
553 lines
21 KiB
PHP
<?php
|
|
|
|
namespace App\Http\Controllers;
|
|
|
|
use Illuminate\Http\Request;
|
|
use App\Models;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Log;
|
|
use App\Models\Merchant;
|
|
use App\Models\Transaction;
|
|
use App\ActivityLog;
|
|
use App\Libs\Smsgateway;
|
|
|
|
class ApiMerchantsController extends Controller{
|
|
public function merchant_login(Request $request){
|
|
$this->validate($request, [
|
|
'phone_number' => 'required',
|
|
'pin' => 'required'
|
|
]);
|
|
$phone_number = $this->validatePhoneNumber($request->phone_number);
|
|
|
|
if ($phone_number === false) {
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => 'Phone Number/PIN is incorrect!'
|
|
], 401);
|
|
}
|
|
|
|
$pin = md5($request->input('pin'));
|
|
|
|
$merchant = Models\Merchant::where('phone', $phone_number)->where('pin', $pin)->first();
|
|
|
|
if ($merchant === null) {
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => 'Phone Number/PIN incorrect!'
|
|
], 401);
|
|
}
|
|
return response()->json([
|
|
'success' => true,
|
|
'message' => 'Login successful',
|
|
'merchant' => [
|
|
'id' => $merchant->id,
|
|
'phone' => $merchant->phone,
|
|
'balance' => $merchant->balance,
|
|
'status' => $merchant->status,
|
|
'fullname' => $merchant->fullname,
|
|
'country' => $merchant->country
|
|
]
|
|
], 200);
|
|
}
|
|
|
|
|
|
public function get_transactions(Request $request)
|
|
{
|
|
// POST body params: merchant_id (required), keyword (optional), start_date, end_date, per_page
|
|
$merchantId = $request->input('merchant_id');
|
|
|
|
if (!$merchantId) {
|
|
return response()->json(['success' => false, 'message' => 'merchant_id is required'], 422);
|
|
}
|
|
$merchant = Models\Merchant::find($merchantId);
|
|
if (!$merchant) {
|
|
return response()->json(['success' => false, 'message' => 'merchant not found'], 404);
|
|
}
|
|
|
|
$perPage = (int) $request->input('per_page', 20);
|
|
|
|
$query = \DB::table('transactions')
|
|
->join('merchants', 'transactions.merchant_id', '=', 'merchants.id')
|
|
->select(
|
|
'merchants.fullname',
|
|
'transactions.id',
|
|
'transactions.status',
|
|
'transactions.msisdn',
|
|
'transactions.amount',
|
|
'transactions.created_at'
|
|
)
|
|
->where('transactions.merchant_id', $merchantId);
|
|
|
|
if ($request->filled('keyword')) {
|
|
$keyword = $request->input('keyword');
|
|
$like = "%{$keyword}%";
|
|
$query->where(function ($q) use ($like) {
|
|
$q->where('merchants.fullname', 'like', $like)
|
|
->orWhere('transactions.msisdn', 'like', $like)
|
|
->orWhere('transactions.status', 'like', $like)
|
|
->orWhere('transactions.amount', 'like', $like)
|
|
->orWhere('transactions.created_at', 'like', $like);
|
|
});
|
|
}
|
|
|
|
if ($request->filled('start_date') || $request->filled('end_date')) {
|
|
try {
|
|
$start = $request->filled('start_date') ? \Carbon\Carbon::parse($request->input('start_date'))->startOfDay() : null;
|
|
$end = $request->filled('end_date') ? \Carbon\Carbon::parse($request->input('end_date'))->endOfDay() : null;
|
|
} catch (\Exception $e) {
|
|
return response()->json(['success' => false, 'message' => 'Invalid date format'], 422);
|
|
}
|
|
|
|
if ($start && $end) {
|
|
$query->whereBetween('transactions.created_at', [$start, $end]);
|
|
} elseif ($start) {
|
|
$query->where('transactions.created_at', '>=', $start);
|
|
} else {
|
|
$query->where('transactions.created_at', '<=', $end);
|
|
}
|
|
}
|
|
|
|
$query->orderBy('transactions.created_at', 'desc');
|
|
|
|
$paginator = $query->paginate($perPage)->appends($request->except('page'));
|
|
|
|
return response()->json($paginator);
|
|
}
|
|
public function get_dealers(Request $request){
|
|
$perPage = (int) $request->input('per_page', 20);
|
|
|
|
#$dealer_arr = \DB::table('organisations')->orderBy('organisations.created_at', 'DESC')->paginate(20);
|
|
|
|
$query = \DB::table('organisations')->select('organisations.id', 'organisations.name', 'organisations.email', 'organisations.phone', 'organisations.status');
|
|
|
|
if ($request->filled('keyword')) {
|
|
$keyword = $request->input('keyword');
|
|
$like = "%{$keyword}%";
|
|
$query->where(function ($q) use ($like) {
|
|
$q->where('organisations.name', 'like', $like)
|
|
->orWhere('organisations.phone', 'like', $like)
|
|
->orWhere('organisations.email', 'like', $like)
|
|
->orWhere('organisations.status', 'like', $like)
|
|
->orWhere('organisations.created_at', 'like', $like);
|
|
});
|
|
}
|
|
$paginator = $query->paginate($perPage)->appends($request->except('page'));
|
|
|
|
return response()->json($paginator);
|
|
}
|
|
|
|
public function getDealerTransactionsJson(Request $request){
|
|
$merchant_id = session('merchant.id');
|
|
// dd($merchant_id);
|
|
$transactions_arr = \DB::table('merchant_top_ups')
|
|
->join('merchants', 'merchant_top_ups.merchant_id', '=', 'merchants.id')
|
|
->join('org_users', 'merchant_top_ups.org_user_id', '=', 'org_users.id')
|
|
->select('merchants.fullname', 'org_users.phone', 'org_users.name', 'merchant_top_ups.id', 'merchant_top_ups.status', 'merchant_top_ups.amount', 'merchant_top_ups.created_at')
|
|
->whereRaw('merchant_top_ups.merchant_id = '. $merchant_id)
|
|
->orderBy('merchant_top_ups.created_at', 'DESC')
|
|
->paginate(20);
|
|
|
|
if($request->has('keyword')){
|
|
$queries = [];
|
|
$keyword = $request->keyword;
|
|
$queries['keyword'] = $keyword;
|
|
$transactions_arr = \DB::table('merchant_top_ups')
|
|
->join('merchants', 'merchant_top_ups.merchant_id', '=', 'merchants.id')
|
|
->join('org_users', 'merchant_top_ups.org_user_id', '=', 'org_users.id')
|
|
->select('merchants.fullname', 'org_users.phone', 'org_users.name', 'merchant_top_ups.id', 'merchant_top_ups.status', 'merchant_top_ups.amount', 'merchant_top_ups.created_at')
|
|
->whereRaw("org_users.phone LIKE '%$keyword%' OR org_users.name LIKE '%$keyword%' OR merchants.fullname LIKE '%$keyword%' OR merchant_top_ups.status LIKE '%$keyword%' OR merchant_top_ups.amount LIKE '%$keyword%' OR merchant_top_ups.created_at LIKE '%$keyword%'")
|
|
->whereRaw('merchant_top_ups.merchant_id = '. $merchant_id)
|
|
->orderBy('merchant_top_ups.created_at', 'DESC')
|
|
->paginate(20)->appends($queries);
|
|
}
|
|
return response()->json($transactions_arr);
|
|
}
|
|
|
|
|
|
public function merchant_transactions($merchant){
|
|
|
|
$transactions = Models\Transaction::where('merchant_id', $merchant->id)
|
|
->select('id', 'created_at')->get()
|
|
->groupBy(function($date) {
|
|
return Carbon::parse($date->created_at)->format('m'); // grouping by months
|
|
});
|
|
$transactionmcount = [];
|
|
$transactionArr = [];
|
|
|
|
|
|
|
|
$pp = 1;
|
|
$trans = [];
|
|
foreach ($transactions as $value) {
|
|
if ($pp == $value) {
|
|
$trans[$pp]= $value;
|
|
}
|
|
else{
|
|
$trans[$pp] = 0;
|
|
}
|
|
|
|
}
|
|
foreach ($transactions as $key => $value) {
|
|
$transactionmcount[(int)$key] = count($value);
|
|
}
|
|
for($i = 1; $i <= 12; $i++){
|
|
if(!empty($transactionmcount[$i])){
|
|
$transactionArr[$i] = $transactionmcount[$i];
|
|
}else{
|
|
$transactionArr[$i] = 0;
|
|
}
|
|
}
|
|
|
|
$transactions = '';
|
|
foreach ($transactionArr as $tran) {
|
|
$transactions = $transactions.','.$tran;
|
|
}
|
|
return response()->json(['transactions' => $transactions]);
|
|
}
|
|
public function customerTopupStoreOld(Request $request){
|
|
$this->validate($request, [
|
|
'phone_number'=> 'required|numeric',
|
|
'amount' => 'required|numeric|min:1',
|
|
'merchant_id' => 'required|numeric'
|
|
]);
|
|
$phone_number = preg_replace('/\s+/', '', $request->phone_number);
|
|
$check_phone = $this->validatePhoneNumber($phone_number);
|
|
if ($check_phone == false) {
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => 'Invalid phone number!'
|
|
], 401);
|
|
}
|
|
$merchant = Models\Merchant::with('orgInfo')->find($request->merchant_id);
|
|
if ($merchant == false) {
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => 'merchant not found!'
|
|
], 401);
|
|
}
|
|
$difference = $merchant->balance - $request->amount;
|
|
if ($merchant->balance < $request->amount) {
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => 'Insufficient balance!'
|
|
], 401);
|
|
}
|
|
$prev_balance = $merchant->balance;
|
|
$extRefId = uniqid() . '-' . date('YmdHis');
|
|
$transaction_arr = [
|
|
'msisdn' => $check_phone,
|
|
'amount' => $request->amount,
|
|
'merchant_id' => $merchant->id,
|
|
'session_id' => $extRefId
|
|
];
|
|
// dd($transaction_arr);
|
|
$trans_result = Models\Transaction::create($transaction_arr);
|
|
$transaction_id = $trans_result->id;
|
|
|
|
$click_params = [
|
|
"msisdn" => $check_phone,
|
|
"amount" => $request->amount,
|
|
"extRefId" => $extRefId
|
|
];
|
|
\Log::info($click_params);
|
|
|
|
$topup_result = $this->ClickADPHttp($click_params);
|
|
|
|
\Log::info($topup_result);
|
|
|
|
$this->sendNtfy($topup_result);
|
|
$topup_result_arr = json_decode($topup_result, TRUE);
|
|
|
|
\Log::info($topup_result_arr);
|
|
if ($topup_result == false) {
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => 'Top Up Could not be processed at this time. Try again later.'
|
|
], 401);
|
|
}
|
|
$log_data = [
|
|
'msisdn' => $check_phone,
|
|
'amount' => $request->tamount,
|
|
'user_id' => $merchant->id,
|
|
'merchant_balance' => $merchant->balance,
|
|
'session_id' => $extRefId,
|
|
'status' => $topup_result_arr,
|
|
'network' => 'n.a'
|
|
];
|
|
$desc = [
|
|
'title' =>'customer top up by Merchant ID ' . $merchant->id,
|
|
'data' => $log_data,
|
|
'type' => 'merchant',
|
|
];
|
|
|
|
$activity = new ActivityLog;
|
|
$activity->user_id = $merchant->id;
|
|
$activity->user_type = 'merchant';
|
|
$activity->description = json_encode($desc);
|
|
$activity->save();
|
|
|
|
|
|
if ($topup_result_arr['code'] == 1) {
|
|
|
|
$merchant_update = Models\Merchant::find($merchant->id);
|
|
$merchant_update->balance = $prev_balance - $request->amount;
|
|
$merchant_update->save();
|
|
$desc = [
|
|
'title' =>'Successful customer top up by Merchant ID ' . $merchant->id,
|
|
'data' => ['previous_balance' => $merchant->balance, 'current_balance' => $merchant->balance - $request->amount],
|
|
'type' => 'merchant',
|
|
];
|
|
#update transactions
|
|
$transaction = Models\Transaction::find($transaction_id);
|
|
$transaction->status = $topup_result_arr['message'];
|
|
$transaction->save();
|
|
|
|
$activity = new ActivityLog;
|
|
$activity->user_id = $merchant->id;
|
|
$activity->user_type = 'merchant';
|
|
$activity->description = json_encode($desc);
|
|
$activity->save();
|
|
return response()->json([
|
|
'success' => true,
|
|
'message' => 'Top Up Successfully processed!'
|
|
], 200);
|
|
}
|
|
|
|
}
|
|
|
|
|
|
public function customerTopupStore(Request $request){
|
|
$request->validate([
|
|
'phone_number' => 'required|string',
|
|
'amount' => 'required|numeric|min:1',
|
|
'merchant_id' => 'required|integer|exists:merchants,id'
|
|
]);
|
|
|
|
|
|
$phone_number = preg_replace('/\s+/', '', $request->phone_number);
|
|
$check_phone = $this->validatePhoneNumber($phone_number);
|
|
|
|
|
|
if (!$check_phone) {
|
|
return response()->json(['success' => false, 'message' => 'Invalid phone number!'], 422);
|
|
}
|
|
|
|
$merchant = Models\Merchant::find($request->merchant_id);
|
|
$country_prefix = substr($check_phone, 0, 3);
|
|
$country = '';
|
|
switch ($country_prefix) {
|
|
case '265':
|
|
$country = 'MALAWI';
|
|
break;
|
|
case '260':
|
|
$country = 'ZAMBIA';
|
|
break;
|
|
|
|
default:
|
|
$country = '';
|
|
break;
|
|
}
|
|
if ($merchant->country !== $country) {
|
|
// find out from team
|
|
return response()->json(['success' => false, 'message' => 'Country not allowed!'], 400);
|
|
}
|
|
$extRefId = uniqid() . '-' . date('YmdHis');
|
|
$topup_result_arr = null;
|
|
|
|
try {
|
|
$topup_result = DB::transaction(function () use ($request, $check_phone, $extRefId, &$topup_result_arr) {
|
|
|
|
|
|
$merchant = Merchant::lockForUpdate()->find($request->merchant_id);
|
|
|
|
if ($merchant->balance < $request->amount) {
|
|
throw new \Exception('Insufficient balance!', 400);
|
|
}
|
|
|
|
|
|
$prev_balance = $merchant->balance;
|
|
$merchant->balance -= $request->amount;
|
|
$merchant->save();
|
|
|
|
|
|
$transaction = Transaction::create([
|
|
'msisdn' => $check_phone,
|
|
'amount' => $request->amount,
|
|
'merchant_id' => $merchant->id,
|
|
'session_id' => $extRefId,
|
|
'status' => 'PENDING'
|
|
]);
|
|
|
|
|
|
$click_params = [
|
|
"msisdn" => $check_phone,
|
|
"amount" => $request->amount,
|
|
"extRefId" => $extRefId
|
|
];
|
|
Log::info('ClickADP Request:', $click_params);
|
|
|
|
$api_response = $this->ClickADPHttp($click_params);
|
|
Log::info('ClickADP Response: ' . $api_response);
|
|
|
|
$this->sendNtfy($api_response);
|
|
$topup_result_arr = json_decode($api_response, true);
|
|
|
|
if (!$api_response || !isset($topup_result_arr['code'])) {
|
|
throw new \Exception('Top Up Could not be processed at this time. Try again later.', 502);
|
|
}
|
|
|
|
if ($topup_result_arr['code'] != 1) {
|
|
throw new \Exception($topup_result_arr['message'] ?? 'Provider failed to process topup.', 422);
|
|
}
|
|
|
|
$transaction->update(['status' => $topup_result_arr['message'] ?? 'SUCCESS']);
|
|
|
|
ActivityLog::create([
|
|
'user_id' => $merchant->id,
|
|
'user_type' => 'merchant',
|
|
'description' => json_encode([
|
|
'title' => 'Successful customer top up by Merchant ID ' . $merchant->id,
|
|
'data' => [
|
|
'msisdn' => $check_phone,
|
|
'amount' => $request->amount,
|
|
'previous_balance' => $prev_balance,
|
|
'current_balance' => $merchant->balance,
|
|
'session_id' => $extRefId,
|
|
'status' => $topup_result_arr,
|
|
'network' => 'n.a'
|
|
],
|
|
'type' => 'merchant',
|
|
])
|
|
]);
|
|
|
|
return true;
|
|
});
|
|
|
|
return response()->json([
|
|
'success' => true,
|
|
'message' => 'Top Up Successfully processed!'
|
|
], 200);
|
|
|
|
} catch (\Exception $e) {
|
|
|
|
Log::error('Topup Failed: ' . $e->getMessage());
|
|
try {
|
|
ActivityLog::create([
|
|
'user_id' => $request->merchant_id,
|
|
'user_type' => 'merchant',
|
|
'description' => json_encode([
|
|
'title' => 'Failed customer top up attempt',
|
|
'error' => $e->getMessage(),
|
|
'data' => ['msisdn' => $check_phone, 'amount' => $request->amount]
|
|
])
|
|
]);
|
|
|
|
// $activity = new ActivityLog;
|
|
// $activity->user_id = $merchant->id;
|
|
// $activity->user_type = 'merchant';
|
|
// $activity->description = json_encode($desc);
|
|
// $activity->save();
|
|
|
|
} catch (\Exception $logEx) {
|
|
Log::error('Failed to write failure activity log: ' . $logEx->getMessage());
|
|
}
|
|
|
|
$code = ($e->getCode() >= 400 && $e->getCode() <= 505) ? $e->getCode() : 500;
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => $e->getMessage()
|
|
], $code);
|
|
}
|
|
}
|
|
|
|
|
|
// Make sure to import your Models and Smsgateway at the top of the file
|
|
|
|
public function merchantToDealerRefund(Request $request){
|
|
$this->validate($request, [
|
|
'transaction_id' => 'required|string',
|
|
'reason' => 'required|string',
|
|
]);
|
|
$transaction = Models\MerchantTopUp::with('merchantInfo', 'orgInfo')->where('status', 'success')->where('transaction_id', $request->transaction_id)->first();
|
|
if ($transaction == null) {
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => 'Transaction not found.'
|
|
], 400);
|
|
}
|
|
|
|
|
|
$dealer = $transaction->orgInfo;
|
|
|
|
if ($transaction->merchantInfo->balance < $request->amount) {
|
|
//ask team to confirm if merchant can have a negative balance
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => 'Insufficient merchant balance to process this refund.'
|
|
], 400);
|
|
}
|
|
|
|
$merchant_name = $transaction->merchantInfo->fullname;
|
|
$dealer_name = $transaction->orgInfo->name;
|
|
$merchant = Models\Merchant::find($transaction->merchantInfo->id);
|
|
$organisation = Models\Organisation::find($transaction->orgInfo->id);
|
|
try {
|
|
//todo : remove one of organisation or dealer
|
|
DB::transaction(function () use ($request, $merchant, $organisation, $dealer, $transaction) {
|
|
Models\MerchantToDealerRefund::create([
|
|
'dealer_id' => $transaction->org_user_id,
|
|
'transaction_id'=> $request->transaction_id,
|
|
'merchant_id' => $transaction->merchant_id,
|
|
'amount' => $transaction->amount,
|
|
'dealer_msisdn' => $transaction->orgInfo->phone,
|
|
'reason' => $request->reason,
|
|
]);
|
|
$merchant->decrement('balance', $transaction->amount);
|
|
$organisation->increment('balance', $transaction->amount);
|
|
|
|
$desc = [
|
|
'title' => 'Dealer Refund',
|
|
'data' => "Refunded a dealer with an amount of " . $transaction->amount, // Typo fixed
|
|
'type' => 'merchant',
|
|
];
|
|
|
|
$activity = new ActivityLog;
|
|
$activity->user_id = $transaction->merchant_id;
|
|
$activity->user_type = 'merchant';
|
|
$activity->description = json_encode($desc);
|
|
$activity->save();
|
|
|
|
$transaction->status = 'refunded';
|
|
$transaction->save();
|
|
});
|
|
|
|
} catch (\Exception $e) {
|
|
\Log::error("API : Refund Transaction Failed: " . $e->getMessage());
|
|
return response()->json([
|
|
'success' => false,
|
|
'message' => "API XX Refund Transaction Failed: " . $e->getMessage()
|
|
], 400);
|
|
}
|
|
$msg = "You have successfully refunded a dealer ($dealer_name) with an amount of $transaction->amount.";
|
|
$dealer_msg = "You have received a refund amount of $transaction->amount from Airtime Merchant ($merchant_name).";
|
|
|
|
if (env('APP_ENV') !== 'local') {
|
|
try {
|
|
$smsgateway = new Smsgateway;
|
|
$smsgateway->sendSmsNew($merchant->phone, $msg);
|
|
$smsgateway->sendSmsNew($organisation->phone, $dealer_msg);
|
|
} catch (\Exception $e) {
|
|
\Log::error("API: Failed to send SMS for refund: " . $e->getMessage());
|
|
}
|
|
}
|
|
|
|
\Log::info("API :" . $msg);
|
|
\Log::info("API :" . $dealer_msg);
|
|
return response()->json([
|
|
'success' => true,
|
|
'message' => "Dealer Refund successfully processed! "
|
|
], 200);
|
|
}
|
|
|
|
}
|