morrning/hesabixCore
1
1
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

add special sms patern to accpro plugin

Browse source
This commit is contained in:
babak alizadeh 2024-10-06 11:29:01 +03:30
parent c1f35dad4b
commit 2e87a61539
3 changed files with 147 additions and 59 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
hesabixCore/src/Controller/AdminController.php
View file

@ -223,6 +223,9 @@ class AdminController extends AbstractController
'creating' => $registryMGR->get('sms', 'plugRepserviceStateCreating'), 'creating' => $registryMGR->get('sms', 'plugRepserviceStateCreating'),
'created' => $registryMGR->get('sms', 'plugRepserviceStateCreated') 'created' => $registryMGR->get('sms', 'plugRepserviceStateCreated')
]; ];
$resp['plugAccpro'] = [
'sharefaktor' => $registryMGR->get('sms', 'plugAccproSharefaktor'),
];
return $this->json($resp); return $this->json($resp);
} }
@ -274,7 +277,10 @@ class AdminController extends AbstractController
if (array_key_exists('created', $params['plugRepservice'])) if (array_key_exists('created', $params['plugRepservice']))
$registryMGR->update('sms', 'plugRepserviceStateCreated', $params['plugRepservice']['created']); $registryMGR->update('sms', 'plugRepserviceStateCreated', $params['plugRepservice']['created']);
} }
if (array_key_exists('plugAccpro', $params)) {
if (array_key_exists('sharefaktor', $params['plugAccpro']))
$registryMGR->update('sms', 'plugAccproSharefaktor', $params['plugAccpro']['sharefaktor']);
}
return $this->json(JsonResp::success()); return $this->json(JsonResp::success());
} }
@ -521,4 +527,20 @@ class AdminController extends AbstractController
} }
return $this->json(array_reverse($temps)); return $this->json(array_reverse($temps));
} }
/**
* @throws Exception
*/
#[Route('/script', name: 'script')]
public function script(EntityManagerInterface $entitymanager): JsonResponse
{
$items = $entitymanager->getRepository(\App\Entity\HesabdariDoc::class)->findAll();
foreach($items as $item){
$item->setDate(str_replace("-","/",$item->getDate()));
$entitymanager->persist($item);
$entitymanager->flush();
}
echo str_replace("-","/","1403-02-06");
}
} }

140
hesabixCore/src/Controller/SMSController.php
View file

@ -11,6 +11,7 @@ use App\Service\Access;
use App\Service\Jdate; use App\Service\Jdate;
use App\Service\Log; use App\Service\Log;
use App\Service\Notification; use App\Service\Notification;
use App\Service\PluginService;
use App\Service\Provider; use App\Service\Provider;
use App\Service\registryMGR; use App\Service\registryMGR;
use App\Service\SMS; use App\Service\SMS;
@ -25,36 +26,36 @@ use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
class SMSController extends AbstractController class SMSController extends AbstractController
{ {
#[Route('/api/sms/save/settings', name: 'api_sms_save_settings')] #[Route('/api/sms/save/settings', name: 'api_sms_save_settings')]
public function api_sms_save_settings(Access $access,Log $log,Request $request,EntityManagerInterface $entityManager): Response public function api_sms_save_settings(Access $access, Log $log, Request $request, EntityManagerInterface $entityManager): Response
{ {
$acc = $access->hasRole('owner'); $acc = $access->hasRole('owner');
if(!$acc) if (!$acc)
throw $this->createAccessDeniedException(); throw $this->createAccessDeniedException();
$params = []; $params = [];
if ($content = $request->getContent()) { if ($content = $request->getContent()) {
$params = json_decode($content, true); $params = json_decode($content, true);
} }
if(array_key_exists('settings',$params)) if (array_key_exists('settings', $params))
$params = $params['settings']; $params = $params['settings'];
$settings = $entityManager->getRepository(SMSSettings::class)->findOneBy([ $settings = $entityManager->getRepository(SMSSettings::class)->findOneBy([
'bid'=>$acc['bid'] 'bid' => $acc['bid']
]); ]);
if(!$settings) if (!$settings)
$settings = new SMSSettings(); $settings = new SMSSettings();
$settings->setBid($acc['bid']); $settings->setBid($acc['bid']);
if(array_key_exists('sendAfterSell',$params)) if (array_key_exists('sendAfterSell', $params))
$settings->setSendAfterSell($params['sendAfterSell']); $settings->setSendAfterSell($params['sendAfterSell']);
if(array_key_exists('sendAfterSellPayOnline',$params)) if (array_key_exists('sendAfterSellPayOnline', $params))
$settings->setSendAfterSellPayOnline($params['sendAfterSellPayOnline']); $settings->setSendAfterSellPayOnline($params['sendAfterSellPayOnline']);
if(array_key_exists('sendAfterBuy',$params)) if (array_key_exists('sendAfterBuy', $params))
$settings->setSendAfterBuy($params['sendAfterBuy']); $settings->setSendAfterBuy($params['sendAfterBuy']);
if(array_key_exists('sendAfterBuyToUser',$params)) if (array_key_exists('sendAfterBuyToUser', $params))
$settings->setSendAfterBuyToUser($params['sendAfterBuyToUser']); $settings->setSendAfterBuyToUser($params['sendAfterBuyToUser']);
$entityManager->persist($settings); $entityManager->persist($settings);
$entityManager->flush(); $entityManager->flush();
$log->insert('سرویس پیامک','به روز رسانی تنظیمات' ,$this->getUser(),$acc['bid']); $log->insert('سرویس پیامک', 'به روز رسانی تنظیمات', $this->getUser(), $acc['bid']);
return $this->json(['result'=>1]); return $this->json(['result' => 1]);
} }
@ -62,20 +63,20 @@ class SMSController extends AbstractController
* @throws \ReflectionException * @throws \ReflectionException
*/ */
#[Route('/api/sms/load/pays', name: 'api_sms_load_pays')] #[Route('/api/sms/load/pays', name: 'api_sms_load_pays')]
public function api_sms_load_pays(Jdate $jdate,Provider $provider,Access $access,Log $log,Request $request,EntityManagerInterface $entityManager): Response public function api_sms_load_pays(Jdate $jdate, Provider $provider, Access $access, Log $log, Request $request, EntityManagerInterface $entityManager): Response
{ {
$acc = $access->hasRole('owner'); $acc = $access->hasRole('owner');
if(!$acc) if (!$acc)
throw $this->createAccessDeniedException(); throw $this->createAccessDeniedException();
$items = $entityManager->getRepository(SMSPays::class)->findBy([ $items = $entityManager->getRepository(SMSPays::class)->findBy([
'bid'=>$acc['bid'] 'bid' => $acc['bid']
],['id'=>'DESC']); ], ['id' => 'DESC']);
$res = []; $res = [];
foreach ($items as $item){ foreach ($items as $item) {
$temp = []; $temp = [];
$temp['des']=$item->getDes(); $temp['des'] = $item->getDes();
$temp['submitter']=$item->getSubmitter()->getFullName(); $temp['submitter'] = $item->getSubmitter()->getFullName();
$temp['dateSubmit']=$jdate->jdate('Y/n/d H:i',$item->getDateSubmit()); $temp['dateSubmit'] = $jdate->jdate('Y/n/d H:i', $item->getDateSubmit());
$temp['status'] = $item->getStatus(); $temp['status'] = $item->getStatus();
$temp['price'] = number_format($item->getPrice()); $temp['price'] = number_format($item->getPrice());
$res[] = $temp; $res[] = $temp;
@ -88,38 +89,39 @@ class SMSController extends AbstractController
* @throws \ReflectionException * @throws \ReflectionException
*/ */
#[Route('/api/sms/load/settings', name: 'api_sms_load_settings')] #[Route('/api/sms/load/settings', name: 'api_sms_load_settings')]
public function api_sms_load_settings(Provider $provider,Access $access,Log $log,Request $request,EntityManagerInterface $entityManager): Response public function api_sms_load_settings(Provider $provider, Access $access, Log $log, Request $request, EntityManagerInterface $entityManager): Response
{ {
$acc = $access->hasRole('owner'); $acc = $access->hasRole('owner');
if(!$acc) if (!$acc)
throw $this->createAccessDeniedException(); throw $this->createAccessDeniedException();
$settings = $entityManager->getRepository(SMSSettings::class)->findOneBy([ $settings = $entityManager->getRepository(SMSSettings::class)->findOneBy([
'bid'=>$acc['bid'] 'bid' => $acc['bid']
]); ]);
if(!$settings) if (!$settings)
$settings = new SMSSettings(); $settings = new SMSSettings();
return $this->json($provider->Entity2Array($settings,0)); return $this->json($provider->Entity2Array($settings, 0));
} }
#[Route('/api/sms/charge', name: 'api_sms_charge')] #[Route('/api/sms/charge', name: 'api_sms_charge')]
public function api_sms_charge(Log $log,Notification $notification,Request $request,Access $access,EntityManagerInterface $entityManager): JsonResponse public function api_sms_charge(Log $log, Notification $notification, Request $request, Access $access, EntityManagerInterface $entityManager): JsonResponse
{ {
$acc = $access->hasRole('owner'); $acc = $access->hasRole('owner');
if(!$acc) if (!$acc)
throw $this->createAccessDeniedException(); throw $this->createAccessDeniedException();
$params = []; $params = [];
if ($content = $request->getContent()) { if ($content = $request->getContent()) {
$params = json_decode($content, true); $params = json_decode($content, true);
} }
if(!array_key_exists('price',$params)) if (!array_key_exists('price', $params))
throw $this->createAccessDeniedException('price not set'); throw $this->createAccessDeniedException('price not set');
//get system settings //get system settings
$settings = $entityManager->getRepository(Settings::class)->findAll()[0]; $settings = $entityManager->getRepository(Settings::class)->findAll()[0];
$data = array("merchant_id" => $settings->getZarinpalMerchant(), $data = array(
"merchant_id" => $settings->getZarinpalMerchant(),
"amount" => $params['price'], "amount" => $params['price'],
"callback_url" => $this->generateUrl('api_sms_buy_verify',[],UrlGeneratorInterface::ABSOLUTE_URL), "callback_url" => $this->generateUrl('api_sms_buy_verify', [], UrlGeneratorInterface::ABSOLUTE_URL),
"description" => 'افزایش اعتبار سرویس پیامک', "description" => 'افزایش اعتبار سرویس پیامک',
); );
$jsonData = json_encode($data); $jsonData = json_encode($data);
@ -153,7 +155,7 @@ class SMSController extends AbstractController
$smsPay->setGatePay('zarinpal'); $smsPay->setGatePay('zarinpal');
$entityManager->persist($smsPay); $entityManager->persist($smsPay);
$entityManager->flush(); $entityManager->flush();
$log->insert('سرویس پیامک','صدور فاکتور شارژ سرویس پیامک' ,$this->getUser(),$acc['bid']); $log->insert('سرویس پیامک', 'صدور فاکتور شارژ سرویس پیامک', $this->getUser(), $acc['bid']);
return $this->json([ return $this->json([
'authority' => $result['data']["authority"] 'authority' => $result['data']["authority"]
]); ]);
@ -164,11 +166,11 @@ class SMSController extends AbstractController
} }
#[Route('/api/sms/buy/verify', name: 'api_sms_buy_verify')] #[Route('/api/sms/buy/verify', name: 'api_sms_buy_verify')]
public function api_sms_buy_verify(Notification $notification,Request $request,EntityManagerInterface $entityManager,Log $log): Response public function api_sms_buy_verify(Notification $notification, Request $request, EntityManagerInterface $entityManager, Log $log): Response
{ {
$Authority = $request->get('Authority'); $Authority = $request->get('Authority');
$status = $request->get('Status'); $status = $request->get('Status');
$req = $entityManager->getRepository(SMSPays::class)->findOneBy(['verifyCode'=>$Authority]); $req = $entityManager->getRepository(SMSPays::class)->findOneBy(['verifyCode' => $Authority]);
//get system settings //get system settings
$settings = $entityManager->getRepository(Settings::class)->findAll()[0]; $settings = $entityManager->getRepository(Settings::class)->findAll()[0];
$data = array("merchant_id" => $settings->getZarinpalMerchant(), "authority" => $Authority, "amount" => $req->getPrice()); $data = array("merchant_id" => $settings->getZarinpalMerchant(), "authority" => $Authority, "amount" => $req->getPrice());
@ -192,15 +194,15 @@ class SMSController extends AbstractController
//----------------------------------- //-----------------------------------
if ($err) { if ($err) {
$log->insert('سرویس پیامک','پرداخت ناموفق شارژ سرویس پیامک' ,$this->getUser(),$req->getBid()); $log->insert('سرویس پیامک', 'پرداخت ناموفق شارژ سرویس پیامک', $this->getUser(), $req->getBid());
return $this->render('buy/fail.html.twig', ['results'=>$result]); return $this->render('buy/fail.html.twig', ['results' => $result]);
} else { } else {
if(array_key_exists('code',$result['data'])){ if (array_key_exists('code', $result['data'])) {
if ($result['data']['code'] == 100) { if ($result['data']['code'] == 100) {
$req->setStatus(100); $req->setStatus(100);
$req->setRefID($result['data']['ref_id']); $req->setRefID($result['data']['ref_id']);
$req->setCardPan($result['data']['card_pan']); $req->setCardPan($result['data']['card_pan']);
$req->getBid()->setSmsCharge($req->getBid()->getSmsCharge() + ($req->getPrice()/1.09)); $req->getBid()->setSmsCharge($req->getBid()->getSmsCharge() + ($req->getPrice() / 1.09));
$entityManager->persist($req); $entityManager->persist($req);
$entityManager->flush(); $entityManager->flush();
$log->insert( $log->insert(
@ -209,13 +211,13 @@ class SMSController extends AbstractController
$req->getSubmitter(), $req->getSubmitter(),
$req->getBid() $req->getBid()
); );
$notification->insert(' سرویس پیامک شارژ شد.','/acc/sms/panel',$req->getBid(),$req->getSubmitter()); $notification->insert(' سرویس پیامک شارژ شد.', '/acc/sms/panel', $req->getBid(), $req->getSubmitter());
return $this->render('buy/success.html.twig',['req'=>$req]); return $this->render('buy/success.html.twig', ['req' => $req]);
} }
} }
$notification->insert('پرداخت فاکتور شارژ سرویس پیامک ناموفق بود','/',$req->getBid(),$req->getSubmitter()); $notification->insert('پرداخت فاکتور شارژ سرویس پیامک ناموفق بود', '/', $req->getBid(), $req->getSubmitter());
$log->insert('سرویس پیامک','پرداخت ناموفق شارژ سرویس پیامک' ,$this->getUser(),$req->getBid()); $log->insert('سرویس پیامک', 'پرداخت ناموفق شارژ سرویس پیامک', $this->getUser(), $req->getBid());
return $this->render('buy/fail.html.twig', ['results'=>$result]); return $this->render('buy/fail.html.twig', ['results' => $result]);
} }
} }
@ -223,32 +225,58 @@ class SMSController extends AbstractController
* @throws \ReflectionException * @throws \ReflectionException
*/ */
#[Route('/api/sms/send/sell-invoice/{id}/{num}', name: 'api_sms_send_invoice')] #[Route('/api/sms/send/sell-invoice/{id}/{num}', name: 'api_sms_send_invoice')]
public function api_sms_send_invoice(registryMGR $registryMGR, SMS $SMS,String $id,String $num,Provider $provider,Access $access,Log $log,Request $request,EntityManagerInterface $entityManager): Response public function api_sms_send_invoice(PluginService $pluginService, registryMGR $registryMGR, SMS $SMS, string $id, string $num, Provider $provider, Access $access, Log $log, Request $request, EntityManagerInterface $entityManager): Response
{ {
$acc = $access->hasRole('sell'); $acc = $access->hasRole('sell');
if(!$acc) if (!$acc)
throw $this->createAccessDeniedException(); throw $this->createAccessDeniedException();
$bid = $acc['bid']; $bid = $acc['bid'];
if($bid->getSmsCharge()<530) if ($bid->getSmsCharge() < 530)
return $this->json(['result'=>'2']); return $this->json(['result' => '2']);
$doc = $entityManager->getRepository(HesabdariDoc::class)->findOneBy([ $doc = $entityManager->getRepository(HesabdariDoc::class)->findOneBy([
'id'=>$id, 'id' => $id,
'bid'=>$bid, 'bid' => $bid,
'type'=>'sell' 'type' => 'sell'
]); ]);
if(!$doc) if (!$doc)
return $this->json(['result'=>3]); return $this->json(['result' => 3]);
$shortLink = $doc->getId(); $shortLink = $doc->getId();
if($doc->getShortlink()) if ($doc->getShortlink())
$shortLink = $doc->getShortlink(); $shortLink = $doc->getShortlink();
return $this->json(['result'=> //find custommer
$customer = null;
foreach ($doc->getHesabdariRows() as $row) {
if ($row->getPerson())
$customer = $row->getPerson();
}
if ($pluginService->isActive('accpro', $acc['bid']) && $customer && $bid->getTel()) {
return $this->json([
'result' =>
$SMS->sendByBalance( $SMS->sendByBalance(
[$bid->getName(),'sell/' . $bid->getId() . '/' . $shortLink], [$customer->getnikename(), 'sell/' . $bid->getId() . '/' . $shortLink, $bid->getTel()],
$registryMGR->get('sms','sharefaktor'), $registryMGR->get('sms', 'plugAccproSharefaktor'),
$num,$bid,$this->getUser(),3 $num,
)]); $bid,
$this->getUser(),
3
)
]);
} else {
return $this->json([
'result' =>
$SMS->sendByBalance(
[$bid->getName(), 'sell/' . $bid->getId() . '/' . $shortLink],
$registryMGR->get('sms', 'sharefaktor'),
$num,
$bid,
$this->getUser(),
3
)
]);
}
} }
} }

38
hesabixCore/src/Service/PluginService.php Normal file
View file

@ -0,0 +1,38 @@
<?php
namespace App\Service;
use App\Entity\Business;
use App\Entity\HesabdariDoc;
use App\Entity\Plugin;
use App\Entity\PlugRepserviceOrder;
use App\Entity\User;
use App\Module\RemoteAddress;
use Doctrine\ORM\EntityManagerInterface;
class PluginService
{
private $em;
private $remoteAddress;
function __construct(EntityManagerInterface $entityManager)
{
$this->em = $entityManager;
}
public function isActive(string $plugin, Business | string | null $bid = null ): bool
{
if(is_string($bid))
$bid = $this->em->getRepository(Business::class)->find($bid);
$ps = $this->em->getRepository(Plugin::class)->findBy([
'bid' =>$bid,
'name'=>$plugin
]);
foreach($ps as $p){
if($p->getDateExpire() > time()){
return true;
}
}
return false;
}
}