rgutierrez/resq
1
0
Fork 0
Code Issues 126 Pull requests 49 Projects Releases 4 Packages Wiki Activity Actions

Tie battery sizes to subscription plans #799

Browse source
This commit is contained in:
Ramon Gutierrez 2024-08-12 06:50:01 +08:00
parent debb399e96
commit 5a2f57492d
2 changed files with 171 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/Controller/BatterySizeController.php
View file

@ -9,11 +9,24 @@ use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Validator\Validator\ValidatorInterface;
use Symfony\Bundle\FrameworkBundle\Controller\Controller;
use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
use App\Service\PayMongoConnector;
use Catalyst\MenuBundle\Annotation\Menu;
class BatterySizeController extends Controller
{
protected $pm;
public function __construct(PayMongoConnector $pm, ParameterBagInterface $params)
{
$this->pm = $pm;
$this->pm->initialize(
$params->get('subscription_paymongo_public_key'),
$params->get('subscription_paymongo_secret_key'),
);
}
/**
* @Menu(selected="bsize_list")
*/
@ -168,6 +181,9 @@ class BatterySizeController extends Controller
$em->persist($row);
$em->flush();
// create new paymongo subscription plan
$this->pm->createOrUpdateSubPlan($row);
// return successful response
return $this->json([
'success' => 'Changes have been saved!'
@ -235,6 +251,9 @@ class BatterySizeController extends Controller
// validated! save the entity
$em->flush();
// find if paymongo subscription plan exists, then update accordingly
$this->pm->createOrUpdateSubPlan($row);
// return successful response
return $this->json([
'success' => 'Changes have been saved!'

156
src/Service/PayMongoConnector.php
View file

@ -7,6 +7,7 @@ use GuzzleHttp\Psr7;
use GuzzleHttp\Exception\RequestException;
use App\Entity\Customer;
use App\Entity\BatterySize;
class PayMongoConnector
{
@ -88,6 +89,150 @@ class PayMongoConnector
return $this->doRequest('/v1/webhooks/' . $id . '/enable', 'POST');
}
public function getPlans()
{
return $this->doRequest('/v1/subscriptions/plans', 'GET');
}
public function createPlan($plan_data)
{
$body = [
'data' => [
'attributes' => [
'amount' => (int)$plan_data['amount'],
'currency' => 'PHP',
'description' => $plan_data['description'],
'interval' => $plan_data['interval'],
'interval_count' => $plan_data['interval_count'],
'name' => $plan_data['name'],
'metadata' => $plan_data['metadata'],
],
],
];
return $this->doRequest('/v1/subscriptions/plans', 'POST', $body);
}
public function updatePlan($plan_id, $plan_data)
{
$body = [
'data' => [
'attributes' => [
'amount' => (int)$plan_data['amount'],
],
],
];
return $this->doRequest('/v1/subscriptions/plans/' . $plan_id, 'PUT', $body);
}
public function createOrUpdateSubPlan(BatterySize $bsize)
{
// get all plans
$plans = $this->getPlans();
// find the plan with the matching substring (battery size name)
$found_plan = null;
if ($plans['success'] && !empty($plans['response']['data'])) {
foreach ($plans['response']['data'] as $plan) {
$plan_bsize_id = $plan['attributes']['metadata']['battery_size_id'] ?? null;
if (!empty($plan_bsize_id)) {
$found_plan = $plan;
break;
}
}
}
if (!empty($found_plan)) {
// update existing plan
$result = $this->updatePlan($found_plan['id'], [
'amount' => bcmul($bsize->getSubRecurringFee(), 100),
]);
} else {
// create new plan
$result = $this->createPlan([
'name' => "RESQ Subscription",
'amount' => bcmul($bsize->getSubRecurringFee(), 100),
'description' => "Motolite Battery Subscription Plan",
'interval' => 'monthly',
'interval_count' => 1,
'metadata' => [
'battery_size_id' => (string)$bsize->getID(),
],
]);
}
return $result;
}
public function findCustomer($email)
{
return $this->doRequest('/v1/customers?email=' . $email, 'GET');
}
public function createCustomer(Customer $cust)
{
$body = [
'data' => [
'attributes' => [
'first_name' => $cust->getFirstName(),
'last_name' => $cust->getLastName(),
'phone' => $cust->getPhoneMobile(),
'email' => $cust->getEmail(),
'default_device' => 'email',
],
],
];
return $this->doRequest('/v1/customers', 'POST', $body);
}
public function updateCustomer(Customer $cust, $ext_cust_id)
{
$body = [
'data' => [
'attributes' => [
'first_name' => $cust->getFirstName(),
'last_name' => $cust->getLastName(),
'phone' => $cust->getPhoneMobile(),
'email' => $cust->getEmail(),
],
],
];
return $this->doRequest('/v1/customers/' . $ext_cust_id, 'PUT', $body);
}
public function createSubscription($ext_cust_id, $plan_id)
{
$body = [
'data' => [
'attributes' => [
'customer_id' => $ext_cust_id,
'plan_id' => $plan_id,
],
],
];
return $this->doRequest('/v1/subscriptions', 'POST', $body);
}
public function attachPaymentIntent($pm_id, $pi_id)
{
$body = [
'data' => [
'attributes' => [
'payment_method' => $pm_id,
],
],
];
return $this->doRequest('/v1/payment_intents/' . $pi_id . '/attach', 'POST', $body);
}
protected function generateHash()
{
return base64_encode($this->secret_key);
@ -102,11 +247,14 @@ class PayMongoConnector
'authorization' => 'Basic '. $this->hash,
];
$request_params = ['headers' => $headers];
if (!empty($request_body)) {
$request_params['json'] = $request_body;
}
try {
$response = $client->request($method, $this->base_url . '/' . $url, [
'json' => $request_body,
'headers' => $headers,
]);
$response = $client->request($method, $this->base_url . $url, $request_params);
} catch (RequestException $e) {
$error = ['message' => $e->getMessage()];