app/Plugin/RemisePayment42/Repository/RemiseACMemberRepository.php line 24

Open in your IDE?
  1. <?php
  3. namespace Plugin\RemisePayment42\Repository;
  5. use Eccube\Repository\AbstractRepository;
  6. use Doctrine\Persistence\ManagerRegistry as RegistryInterface;
  7. use Symfony\Component\HttpKernel\KernelInterface;
  8. use Eccube\Doctrine\Query\Queries;
  9. use Eccube\Util\StringUtil;
  10. use Eccube\Entity\Master\OrderItemType;
  12. use Plugin\RemisePayment42\Entity\RemiseACMember;
  14. /**
  15.  * ルミーズ定期購買メンバ情報アクセスクラス
  16.  */
  17. class RemiseACMemberRepository extends AbstractRepository
  18. {
  19.     /**
  20.      * コンストラクタ
  21.      *
  22.      * @param RegistryInterface $registry
  23.      */
  24.     public function __construct(RegistryInterface $registry, Queries $queries)
  25.     {
  26.         parent::__construct($registry, RemiseACMember::class);
  27.         $this->queries = $queries;
  28.     }
  30.     /**
  31.      * get query builder.
  32.      *
  33.      * @param  array $searchData
  34.      *
  35.      * @return \Doctrine\ORM\QueryBuilder
  36.      */
  37.     public function getQueryBuilderBySearchDataForAdmin($searchData)
  38.     {
  39.         $qb = $this->createQueryBuilder('rms_acm');
  40.         $qb->innerJoin('\Plugin\RemisePayment42\Entity\OrderResultCard', 'rms_orc', 'WITH', 'rms_orc.member_id = rms_acm.id');
  41.         $qb->innerJoin('\Plugin\RemisePayment42\Entity\OrderResult', 'rms_or', 'WITH', 'rms_or.id = rms_orc.id');
  42.         $qb->innerJoin('\Eccube\Entity\Order', 'ec_o', 'WITH', 'ec_o.id = rms_or.id');
  43.         $qb->select('rms_acm');
  44.         $qb->groupBy('rms_acm.id');
  45.         $qb->orderBy('rms_acm.update_date', 'DESC');
  47.         // multi
  48.         if (isset($searchData['multi']) && StringUtil::isNotBlank($searchData['multi'])) {
  50.             $multiCustomerId = preg_match('/^\d{0,10}$/', $searchData['multi']) ? $searchData['multi'] : null;
  52.             $qb
  53.             ->andWhere(
  54.                 'rms_acm.id = :multi'
  55.                 . ' OR ec_o.Customer = :multi_customer_id'
  56.                 . ' OR CONCAT(ec_o.name01, ec_o.name02) LIKE :likemulti'
  57.                 )
  58.                 ->setParameter('multi', $searchData['multi'])
  59.                 ->setParameter('multi_customer_id', $multiCustomerId)
  60.                 ->setParameter('likemulti', '%' . preg_replace("/( |　)/", "", $searchData['multi'] ) . '%');
  61.         }
  62.         // 定期購買の状態
  63.         if (isset($searchData['status']) && StringUtil::isNotBlank($searchData['status'])) {
  64.             $qb
  65.             ->andWhere('rms_acm.status = :status')
  66.             ->setParameter('status', $searchData['status']);
  67.         }
  68.         // メンバーID（ルミーズ発番のID）
  69.         if (isset($searchData['member_id']) && StringUtil::isNotBlank($searchData['member_id'])) {
  70.             $qb
  71.             ->andWhere('rms_acm.id = :member_id')
  72.             ->setParameter('member_id', $searchData['member_id']);
  73.         }
  74.         // 注文番号
  75.         if (isset($searchData['order_no']) && StringUtil::isNotBlank($searchData['order_no'])) {
  76.             $qb
  77.             ->andWhere('ec_o.order_no = :order_no')
  78.             ->setParameter('order_no', $searchData['order_no']);
  79.         }
  80.         // 会員番号
  81.         if (isset($searchData['customer_id']) && StringUtil::isNotBlank($searchData['customer_id'])) {
  83.             $customerId = preg_match('/^\d{0,10}$/', $searchData['customer_id']) ? $searchData['customer_id'] : null;
  85.             $qb
  86.             ->andWhere('ec_o.Customer = :customer_id')
  87.             ->setParameter('customer_id', $customerId);
  88.         }
  89.         // お名前
  90.         if (isset($searchData['customer_name']) && StringUtil::isNotBlank($searchData['customer_name'])) {
  91.             $qb
  92.             ->andWhere('CONCAT(ec_o.name01, ec_o.name02) LIKE :customer_name')
  93.             ->setParameter('customer_name', '%' . preg_replace("/( |　)/", "", $searchData['customer_name'] ) . '%');
  94.         }
  95.         // お名前(フリガナ)
  96.         if (isset($searchData['customer_kana']) && StringUtil::isNotBlank($searchData['customer_kana'])) {
  97.             $qb
  98.             ->andWhere('CONCAT(ec_o.kana01, ec_o.kana02) LIKE :customer_kana')
  99.             ->setParameter('customer_kana', '%' . preg_replace("/( |　)/", "", $searchData['customer_kana'] ) . '%');
  100.         }
  101.         // メールアドレス
  102.         if (isset($searchData['customer_mail']) && StringUtil::isNotBlank($searchData['customer_mail'])) {
  103.             $qb
  104.             ->andWhere('ec_o.email = :customer_mail')
  105.             ->setParameter('customer_mail', $searchData['customer_mail']);
  106.         }
  107.         // 電話番号
  108.         if (isset($searchData['customer_tel']) && StringUtil::isNotBlank($searchData['customer_tel'])) {
  109.             $qb
  110.             ->andWhere('ec_o.phone_number LIKE :customer_tel')
  111.             ->setParameter('customer_tel', $searchData['customer_tel']);
  112.         }
  113.         // 購入商品名
  114.         if (isset($searchData['product_name']) && StringUtil::isNotBlank($searchData['product_name'])) {
  115.         $qb->leftJoin('\Eccube\Entity\OrderItem', 'ec_oi', 'WITH', 'ec_oi.Order = ec_o.id')
  116.             ->andWhere('ec_oi.OrderItemType = :order_item_type_id')
  117.             ->andWhere('ec_oi.product_name LIKE :product_name')
  118.             ->setParameter('order_item_type_id', OrderItemType::PRODUCT)
  119.             ->setParameter('product_name', '%' . $searchData['product_name'] . '%');
  120.         }
  121.         // 定期購買金額
  122.         if (isset($searchData['total_start']) && StringUtil::isNotBlank($searchData['total_start'])) {
  123.             $qb
  124.             ->andWhere('rms_acm.total >= :total_start')
  125.             ->setParameter('total_start', $searchData['total_start']);
  126.         }
  127.         if (isset($searchData['total_end']) && StringUtil::isNotBlank($searchData['total_end'])) {
  128.             $qb
  129.             ->andWhere('rms_acm.total <= :total_end')
  130.             ->setParameter('total_end', $searchData['total_end']);
  131.         }
  132.         // 受注日
  133.         if (!empty($searchData['order_date_start']) && $searchData['order_date_start']) {
  134.             $date = $searchData['order_date_start']
  135.             ->format('Y-m-d H:i:s');
  136.             $qb
  137.             ->andWhere('ec_o.order_date >= :order_date_start')
  138.             ->setParameter('order_date_start', $date);
  139.         }
  140.         if (!empty($searchData['order_date_end']) && $searchData['order_date_end']) {
  141.             $date = clone $searchData['order_date_end'];
  142.             $date = $date
  143.             ->modify('+1 days')
  144.             ->format('Y-m-d H:i:s');
  145.             $qb
  146.             ->andWhere('ec_o.order_date < :order_date_end')
  147.             ->setParameter('order_date_end', $date);
  148.         }
  149.         // 次回課金日
  150.         if (!empty($searchData['next_date_start']) && $searchData['next_date_start']) {
  151.             $date = $searchData['next_date_start']
  152.             ->format('Y-m-d H:i:s');
  153.             $qb
  154.             ->andWhere('rms_acm.next_date >= :next_date_start')
  155.             ->setParameter('next_date_start', $date);
  156.         }
  157.         if (!empty($searchData['next_date_end']) && $searchData['next_date_end']) {
  158.             $date = clone $searchData['next_date_end'];
  159.             $date = $date
  160.             ->modify('+1 days')
  161.             ->format('Y-m-d H:i:s');
  162.             $qb
  163.             ->andWhere('rms_acm.next_date < :next_date_end')
  164.             ->setParameter('next_date_end', $date);
  165.         }
  167.         return $this->queries->customize('RemiseACMember.getQueryBuilderBySearchData', $qb, $searchData);
  168.     }
  170.     /**
  171.      * @param $customerIds
  172.      *
  173.      * @return RemiseACMember|null|object
  174.      */
  175.     public function getCustomersByCustomerIds($customerIds)
  176.     {
  177.         $qb = $this->createQueryBuilder('rms_acm');
  178.         $qb->innerJoin('\Plugin\RemisePayment42\Entity\OrderResultCard', 'rms_orc', 'WITH', 'rms_orc.member_id = rms_acm.id');
  179.         $qb->innerJoin('\Plugin\RemisePayment42\Entity\OrderResult', 'rms_or', 'WITH', 'rms_or.id = rms_orc.id');
  180.         $qb->innerJoin('\Eccube\Entity\Order', 'ec_o', 'WITH', 'ec_o.id = rms_orc.id');
  181.         $qb->innerJoin('\Eccube\Entity\Customer', 'ec_cus', 'WITH', 'ec_cus.id = ec_o.Customer');
  182.         $qb->select('ec_cus');
  183.         $qb->groupBy('ec_cus.id');
  185.         // 顧客を指定
  186.         $qb
  187.         ->where("ec_o.Customer IN (:customerIds)")
  188.         ->setParameter('customerIds', $customerIds);
  190.         // 定期購買継続中を絞り込む
  191.         $qb
  192.         ->andWhere('rms_acm.status = :status')
  193.         ->setParameter('status', 1);
  195.         $res = $qb->getQuery()->getResult();
  197.         return $res;
  198.     }
  200.     /**
  201.      * @param $customerIds
  202.      *
  203.      * @return RemiseACMember|null|object
  204.      */
  205.     public function getRemiseACMembersByCustomerId($customerId)
  206.     {
  207.         $qb = $this->createQueryBuilder('rms_acm');
  208.         $qb->innerJoin('\Plugin\RemisePayment42\Entity\OrderResultCard', 'rms_orc', 'WITH', 'rms_orc.member_id = rms_acm.id');
  209.         $qb->innerJoin('\Plugin\RemisePayment42\Entity\OrderResult', 'rms_or', 'WITH', 'rms_or.id = rms_orc.id');
  210.         $qb->innerJoin('\Eccube\Entity\Order', 'ec_o', 'WITH', 'ec_o.id = rms_orc.id');
  211.         $qb->select('rms_acm');
  212.         $qb->orderBy('rms_acm.update_date', 'DESC');
  214.         // 顧客を指定
  215.         $qb
  216.         ->where("ec_o.Customer = :customerId")
  217.         ->setParameter('customerId', $customerId);
  219.         // 定期購買継続中を絞り込む
  220.         $qb
  221.         ->andWhere('rms_acm.status = :status')
  222.         ->setParameter('status', 1);
  224.         $res = $qb->getQuery()->getResult();
  226.         return $res;
  227.     }
  228. }