app/Customize/Controller/TopController.php line 45

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of EC-CUBE
  5.  *
  6.  * Copyright(c) EC-CUBE CO.,LTD. All Rights Reserved.
  7.  *
  8.  * http://www.ec-cube.co.jp/
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Customize\Controller;
  16. use Eccube\Entity\Master\CustomerStatus;
  17. use Eccube\Entity\Master\Sex;
  18. use Eccube\Repository\CartRepository;
  19. use Eccube\Repository\Master\CustomerStatusRepository;
  20. use Eccube\Repository\Master\PrefRepository;
  21. use Eccube\Security\Core\Encoder\PasswordEncoder;
  22. use Eccube\Service\SystemService;
  23. use Firebase\JWT\JWT;
  24. use Firebase\JWT\Key;
  25. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Template;
  26. use Symfony\Component\HttpFoundation\JsonResponse;
  27. use Symfony\Component\Routing\Annotation\Route;
  28. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  29. use Symfony\Component\Security\Core\Authentication\Token\UsernamePasswordToken;
  30. use Eccube\Repository\CustomerRepository;
  31. use Eccube\Repository\OrderRepository;
  32. use Symfony\Component\HttpFoundation\Request;
  33. use Eccube\Controller\AbstractController;
  34. use Eccube\Entity\Master\OrderStatus;
  35. use Eccube\Entity\Customer;
  37. class TopController extends AbstractController
  38. {
  39.     private $keyJwt = '4UEX8^j8G|CFz]fzV[';
  41.     /**
  42.      * @Route("/", name="homepage", methods={"GET"})
  43.      * @Template("index.twig")
  44.      */
  45.     public function index(TokenStorageInterface $tokenStorage, CustomerRepository $customerRepository, Request $request)
  46.     {
  47.         $tokenLogin = $request->get('tokenLogin');
  48.         if(!empty($tokenLogin)) {
  49.             try {
  50.                 $decoded = JWT::decode($tokenLogin, new Key($this->keyJwt, 'HS256'));
  51.                 $Customer = $customerRepository->findOneBy(['phone_number' => $decoded->phone]);
  52.                 if($Customer) {
  53.                     $token = new UsernamePasswordToken($Customer, 'customer', ['ROLE_USER']);
  54.                     $tokenStorage->setToken($token);
  55.                     $request->getSession()->migrate(true);
  57.                     return $this->redirect($this->generateUrl('homepage'));
  58.                 }
  59.             } catch (\Exception $e) {
  61.             }
  62.         }
  64.         return [];
  65.     }
  67.     /**
  68.      * @Route("/syncRegisterBel", name="syncRegisterBel", methods={"GET"})
  69.      */
  70.     public function syncRegisterBel(PasswordEncoder $passwordEncoder, CustomerStatusRepository $customerStatusRepository, PrefRepository $prefRepository, CustomerRepository $customerRepository, Request $request) {
  71.         $token = $request->get('token');
  72.         if(!empty($token)) {
  73.             try {
  74.                 $decoded = JWT::decode($token, new Key($this->keyJwt, 'HS256'));
  76.                 $CustomerStatus = $customerStatusRepository->find(CustomerStatus::ACTIVE);
  78.                 $checkPhone = $customerRepository->findOneBy(['phone_number' => $decoded->phone]);
  79.                 if($checkPhone) {
  80.                     return new JsonResponse(['status' => 4,], 200);
  81.                 }
  83. //                $checkEmail = $customerRepository->findOneBy(['email' => $decoded->user_email]);
  84. //                if($checkEmail) {
  85. //                    return new JsonResponse(['status' => 5,], 200);
  86. //                }
  89.                 $sexRepository = $this->entityManager->getRepository(Sex::class);
  90.                 $Sex = $sexRepository->find(4);
  93.                 $salt = $passwordEncoder->createSalt();
  94.                 $password = $passwordEncoder->encodePassword($decoded->password, $salt);
  95.                 $secretKey = $customerRepository->getUniqueSecretKey();
  97.                 $pref = '';
  98.                 $firstPortcode = substr($decoded->postcode, 0, 3);
  99.                 if(strlen($firstPortcode) >= 3) {
  100.                     $curl = curl_init();
  101.                     $options = [
  102.                         CURLOPT_RETURNTRANSFER => 1,
  103.                         CURLOPT_URL => "https://yubinbango.github.io/yubinbango-data/data/" . $firstPortcode . ".js",
  104.                         CURLOPT_POST => false,
  105.                         CURLOPT_USERAGENT => "Mozilla/4.0 (compatible; MSIE 5.01; Windows NT 5.0)",
  106.                     ];
  107.                     curl_setopt_array($curl, $options);
  108.                     $output = curl_exec($curl);
  109.                     $output = str_replace('$yubin(', '', $output);
  110.                     $output = str_replace(');', '', $output);
  111.                     $result = (array)json_decode($output);
  112.                     curl_close($curl);
  113.                     if(isset($result[$decoded->postcode])) {
  114.                         $pref = $result[$decoded->postcode][0];
  115.                     }
  116.                 }
  118.                 $email = $decoded->user_email;
  119.                 if(empty($email)) {
  120.                     $email = $decoded->phone.'@generatebelmony.com';
  121.                 }
  123.                 $Customer = new Customer();
  124.                 $Customer
  125.                     ->setName01($decoded->user_name)
  126.                     ->setName02('')
  127.                     ->setKana01('')
  128.                     ->setKana02('')
  129.                     ->setCompanyName('')
  130.                     ->setEmail($email)
  131.                     ->setPhonenumber($decoded->phone)
  132.                     ->setSex($Sex)
  133.                     ->setPostalcode($decoded->postcode)
  134.                     ->setAddr02('')
  135.                     ->setStatus($CustomerStatus)
  136.                     ->setSalt($salt)
  137.                     ->setPassword($password)
  138.                     ->setSecretKey($secretKey)
  139.                     ->setBirth(new \DateTime($decoded->user_birthday))
  140.                     ->setPoint(0);
  142.                 if (!empty($pref)) {
  143.                     $Pref = $prefRepository->find($pref);
  144.                     if($Pref) {
  145.                         $Customer->setPref($Pref);
  146.                     }
  147.                     $Customer->setAddr01(str_replace($Pref->getName(), '', $decoded->user_address));
  148.                 }else {
  149.                     $Customer->setAddr01($decoded->user_address);
  150.                 }
  152.                 $this->entityManager->persist($Customer);
  153.                 $this->entityManager->flush();
  155.                 return new JsonResponse(['status' => 1,], 200);
  156.             } catch (\Exception $e) {
  157.                 return new JsonResponse(['status' => 2,], 200);
  158.             }
  159.         }
  160.         return new JsonResponse(['status' => 3,], 200);
  161.     }
  163.     /**
  164.      * @Route("/checkConnectLogin", name="checkConnectLogin", methods={"GET"})
  165.      */
  166.     public function checkConnectLogin(TokenStorageInterface $tokenStorage, CustomerRepository $customerRepository, Request $request) {
  167.         $tokenLogin = $request->get('tokenLogin');
  168.         if(!empty($tokenLogin)) {
  169.             try {
  170.                 $decoded = JWT::decode($tokenLogin, new Key($this->keyJwt, 'HS256'));
  171.                 $Customer = $customerRepository->findOneBy(['phone_number' => $decoded->phone]);
  172.                 if($Customer) {
  173.                     die('1');
  174.                 }
  175.             } catch (\Exception $e) {
  176.                 die('2');
  177.             }
  178.         }
  179.         die('3');
  180.     }
  182.     /**
  183.      * @Route("/syncUpdate", name="syncUpdate", methods={"GET"})
  184.      */
  185.     public function syncUpdate(PasswordEncoder $passwordEncoder, CustomerStatusRepository $customerStatusRepository, PrefRepository $prefRepository, CustomerRepository $customerRepository, Request $request) {
  186.         $tokenLogin = $request->get('token');
  187.         if(!empty($tokenLogin)) {
  188.             try {
  189.                 $decoded = JWT::decode((string)$tokenLogin, new Key($this->keyJwt, 'HS256'));
  190.                 //dd($decoded);
  191.                 $Customer = $customerRepository->findOneBy(['phone_number' => $decoded->phone]);
  192.                 //dd($Customer);
  193.                 if($Customer) {
  194.                     $sexRepository = $this->entityManager->getRepository(Sex::class);
  195.                     $Sex = $sexRepository->find(4);
  196.                     $email = $decoded->user_email;
  197.                     if (empty($email)) {
  198.                         $email = $decoded->phone . '@generatebelmony.com';
  199.                     }
  200.                     if($email != $Customer->getEmail()) {
  201.                         $Customer->setEmail($email);
  202.                     }
  204.                     $pref = '';
  205.                     $firstPortcode = substr($decoded->postcode, 0, 3);
  206.                     if(strlen($firstPortcode) >= 3) {
  207.                         $curl = curl_init();
  208.                         $options = [
  209.                             CURLOPT_RETURNTRANSFER => 1,
  210.                             CURLOPT_URL => "https://yubinbango.github.io/yubinbango-data/data/" . $firstPortcode . ".js",
  211.                             CURLOPT_POST => false,
  212.                             CURLOPT_USERAGENT => "Mozilla/4.0 (compatible; MSIE 5.01; Windows NT 5.0)",
  213.                         ];
  214.                         curl_setopt_array($curl, $options);
  215.                         $output = curl_exec($curl);
  216.                         $output = str_replace('$yubin(', '', $output);
  217.                         $output = str_replace(');', '', $output);
  218.                         $result = (array)json_decode($output);
  219.                         curl_close($curl);
  220.                         if(isset($result[$decoded->postcode])) {
  221.                             $pref = $result[$decoded->postcode][0];
  222.                         }
  223.                     }
  225.                     $salt = $passwordEncoder->createSalt();
  226.                     if(!empty($decoded->password)) {
  227.                         $password = $passwordEncoder->encodePassword($decoded->password, $salt);
  228.                         $secretKey = $customerRepository->getUniqueSecretKey();
  229.                         $Customer->setPassword($password);
  230.                     }
  231.                     $Customer->setSecretKey($secretKey);
  232.                     $Customer->setName01($decoded->user_name);
  233.                     $Customer->setSex($Sex);
  234.                     $Customer->setPostalcode($decoded->postcode);
  236.                     $Customer->setSalt($salt);
  237.                     $Customer->setSecretKey($secretKey);
  238.                     $Customer->setBirth(new \DateTime($decoded->user_birthday));
  240.                     if (!empty($pref)) {
  241.                         $Pref = $prefRepository->find($pref);
  242.                         if($Pref) {
  243.                             $Customer->setPref($Pref);
  244.                         }
  245.                         $Customer->setAddr01(str_replace($Pref->getName(), '', $decoded->user_address));
  246.                     }else {
  247.                         $Customer->setAddr01($decoded->user_address);
  248.                     }
  250.                     $this->entityManager->persist($Customer);
  251.                     $this->entityManager->flush();
  252.                     return new JsonResponse(['status' => 1,], 200);
  254.                 }
  255.             } catch (\Exception $e) {
  256.                 return new JsonResponse(['status' => 2,], 200);
  257.             }
  258.         }
  259.         return new JsonResponse(['status' => 3,], 200);
  260.     }
  262.     /**
  263.      * @Route("/checkSyncOrder", name="checkSyncOrder", methods={"GET"})
  264.      */
  265.     public function checkSyncOrder(OrderRepository $orderRepository, CustomerRepository $customerRepository, Request $request) {
  266.         $token = $request->get('token');
  267.         if(!empty($token)) {
  268.             try {
  269.                 $decoded = JWT::decode($token, new Key($this->keyJwt, 'HS256'));
  270.                 $Customer = $customerRepository->findOneBy(['phone_number' => $decoded->user_phone]);
  271.                 if($Customer) {
  272.                     $order = $orderRepository->findOneBy(['id' => $decoded->order_id]);
  273.                     if($order) {
  274.                         if(
  275.                             ( ( $order->getOrderStatus()->getId() == OrderStatus::NEW || $order->getOrderStatus()->getId() == OrderStatus::PENDING or $order->getOrderStatus()->getId() == OrderStatus::PROCESSING) &&
  276.                                 $decoded->created_at_order == $order->getCreateDate()->format('Y-m-d H:i:s') &&
  277.                                 $decoded->usePoint == $order->getUsePoint() && $decoded->addPoint == $order->getAddPoint()) ||
  278.                             ($order->getOrderStatus()->getId() != OrderStatus::PROCESSING &&
  279.                                 $decoded->created_at_order == $order->getCreateDate()->format('Y-m-d H:i:s') &&
  280.                                 $decoded->updated_at_order == $order->getUpdateDate()->format('Y-m-d H:i:s') &&
  281.                                 $decoded->usePoint == $order->getUsePoint() && $decoded->addPoint == $order->getAddPoint())
  282.                         ) {
  283.                             $customerOrder = $order->getCustomer();
  284.                             if($customerOrder->getId()) {
  285.                                 if ($customerOrder->getId() == $Customer->getId()) {
  286.                                     die('1');
  287.                                 }
  288.                             }
  289.                         }
  290.                     }
  291.                 }
  292.             } catch (\Exception $e) {
  293.                 die('2');
  294.             }
  295.         }
  296.         die('3');
  297.     }
  299.     /**
  300.      * @Route("/syncPointBel", name="syncPointBel", methods={"GET"})
  301.      */
  302.     public function syncPointBel(CustomerRepository $customerRepository, Request $request) {
  303.         $token = $request->get('token');
  304.         if(!empty($token)) {
  305.             try {
  306.                 $decoded = JWT::decode($token, new Key($this->keyJwt, 'HS256'));
  307.                 $Customer = $customerRepository->findOneBy(['phone_number' => $decoded->user_phone]);
  308.                 if($Customer) {
  309.                     $Customer->setPoint($decoded->pointBel);
  311.                     $this->entityManager->persist($Customer);
  312.                     $this->entityManager->flush();
  314.                     return new JsonResponse(['status' => 1,], 200);
  315.                 }
  316.             } catch (\Exception $e) {
  317.                 return new JsonResponse(['status' => 2,], 200);
  318.             }
  319.         }
  320.         return new JsonResponse(['status' => 3,], 200);
  321.     }
  323.     /**
  324.      * @Route("/syncCustomerDelete", name="syncCustomerDelete", methods={"GET"})
  325.      */
  326.     public function syncCustomerDelete(CartRepository $cartRepository, OrderRepository $orderRepository, CustomerRepository $customerRepository, CustomerStatusRepository $customerStatusRepository, Request $request) {
  327.         $token = $request->get('token');
  328.         if(!empty($token)) {
  329.             try {
  330.                 $decoded = JWT::decode($token, new Key($this->keyJwt, 'HS256'));
  331.                 $Customer = $customerRepository->findOneBy(['phone_number' => $decoded->user_phone]);
  332.                 if($Customer) {
  333.                     $Cart = $cartRepository->findOneBy(['Customer' => $Customer]);
  334.                     if($Cart) {
  335.                         $cartRepository->delete($Cart);
  336.                         $this->entityManager->flush();
  337.                     }
  339.                     $CustomerStatus = $customerStatusRepository->find(CustomerStatus::WITHDRAWING);
  340.                     $Customer->setStatus($CustomerStatus);
  341.                     $Customer->setEmail('9999'.$Customer->getEmail());
  342.                     $Customer->setPhonenumber('9999'.$Customer->getPhonenumber());
  343.                     $this->entityManager->persist($Customer);
  344.                     $this->entityManager->flush();
  346.                     return new JsonResponse(['status' => 1,], 200);
  347.                 }
  348.             } catch (\Exception $e) {
  349.                 return new JsonResponse(['status' => 2,], 200);
  350.             }
  351.         }
  352.         return new JsonResponse(['status' => 3,], 200);
  353.     }
  355.     /**
  356.      * @Route("/updatePointPC", name="updatePointPC", methods={"GET"})
  357.      */
  358.     public function updatePointPC(CustomerRepository $customerRepository, Request $request) {
  359.         return false;
  360. //        $Customers = $customerRepository->findAll();
  361. //        $secretkeyToken = '4UEX8^j8G|CFz]fzV[';
  362. //        $arrPhone = [];
  363. //        $i = 0;
  364. //        $min = 2000;
  365. //        $max = 2500;
  366. //        foreach ($Customers as $Customer) {
  367. //            $i++;
  368. //            if($i < $min) {
  369. //                continue;
  370. //            }
  371. //            if($i > $max) {
  372. //                var_dump($i);
  373. //                dd('Done');
  374. //                break;
  375. //            }
  376. //            $token = JWT::encode(['email' => $Customer->getEmail(), 'phone' => $Customer->getPhoneNumber()], $secretkeyToken, 'HS256');
  377. //            $curl = curl_init();
  378. //            $options = [
  379. //                CURLOPT_RETURNTRANSFER => 1,
  380. //                CURLOPT_URL => env('SYNC_URL')."/api/syncPoint?token=".$token,
  381. //                CURLOPT_POST => false,
  382. //                CURLOPT_USERAGENT => "Mozilla/4.0 (compatible; MSIE 5.01; Windows NT 5.0)",
  383. //            ];
  384. //            curl_setopt_array($curl, $options);
  385. //            $output = curl_exec($curl);
  386. //            $result = json_decode($output);
  387. //            curl_close($curl);
  388. //
  389. //            if($result) {
  390. //                if ($result->status == 'success') {
  391. //                    $point = (int)$result->data->point;
  392. //                    $arrPhone[$Customer->getPhoneNumber()] = $point;
  393. //                    $Customer->setPoint($point);
  394. //                } else {
  395. //                    $Customer->setPoint(0);
  396. //                }
  397. //            } else {
  398. //                $Customer->setPoint(0);
  399. //            }
  400. //            $this->entityManager->flush();
  401. //
  402. //        }
  403. //        dd($arrPhone);
  404.     }
  406. }