<?php

namespace App\Libraries\DBMigration\Process;

use App\Entities\UserEntity;
use CodeIgniter\Database\BaseConnection;

class ClientProcess implements MigrationProcessInterface
{
  private $db;
  public function __construct(BaseConnection $db)
  {
    $this->db = $db;
  }

  private function getClientCode(string $site, string $client_code): string
  {
    $format = env("Client.Prefix.{$site}.code.format", false);
    if (!$format) {
      throw new \Exception(__METHOD__ . "에서 code의 prefix[Client.Prefix.{$site}.code.format]가 정의되지 않았습니다.");
    }
    return sprintf($format, (int)substr($client_code, 1));
  }
  public function process(array $row, int $cnt): void
  {
    $temps = [];
    $temps['site'] = 'prime';
    $temps['code']     = $this->getClientCode($temps['site'], $row['Client_Code']);
    $temps['user_uid'] = 1;
    $temps['role'] = $row['Client_Reseller'] == 30 ? "reseller" : "user";
    $temps['name'] = $row['Client_Name'];
    $temps['phone'] = empty($row['Client_Phone1']) ? "" : $row['Client_Phone1'];
    if (empty($temps['phone'])) {
      $temps['phone'] = empty($row['Client_Phone2']) ? "" : $row['Client_Phone2'];
    }
    $temps['email'] = empty($row['Client_EMail1']) ? "" : $row['Client_EMail1'];
    if (empty($temps['email'])) {
      $temps['email'] = empty($row['Client_EMail2']) ? "" : $row['Client_EMail2'];
    }
    $temps['account_balance'] = intval($row['Client_Money']);
    $temps['coupon_balance'] = 0;
    $temps['point_balance'] = 0;
    $temps['status'] = UserEntity::STATUS_NORMAL; // Default status
    $temps['updated_at'] = empty($row['Client_Renew_date']) ? NULL : $row['Client_Renew_date'];
    if (!empty($row['Client_Receive_date'])) {
      $temps['created_at'] = $row['Client_Receive_date'];
    }
    if (!$this->db->table('clientinfo')->insert($temps)) {
      throw new \Exception($this->db->error()['message']);
    }
    echo "{$cnt} -> {$temps['name']} 고객완료.\n";
  }
}