dbmsv2/app/Services/Customer/ServiceService.php
2025-10-01 11:32:56 +09:00

379 lines
16 KiB
PHP

<?php
namespace App\Services\Customer;
use App\Entities\Customer\ServiceEntity;
use App\Entities\Equipment\ServerEntity;
use App\Entities\Equipment\ServerPartEntity;
use App\Entities\PaymentEntity;
use App\Helpers\Customer\ServiceHelper;
use App\Interfaces\Equipment\ServerInterface;
use App\Interfaces\Equipment\ServerPartInterface;
use App\Models\Customer\ServiceModel;
use App\Services\Equipment\ServerPartService;
use App\Services\Equipment\ServerService;
use App\Services\PaymentService;
class ServiceService extends CustomerService implements ServerInterface, ServerPartInterface
{
private ?ServerService $_serverService = null;
private ?PaymentService $_paymentService = null;
private ?ServerPartService $_serverPartService = null;
public function __construct()
{
parent::__construct(new ServiceModel(), new ServiceHelper());
$this->addClassName('Service');
}
public function getFormFields(): array
{
return [
"site",
"location",
"clientinfo_uid",
'serverinfo_uid',
"rack",
"line",
"start_at",
"billing_at",
"status",
'sale',
'amount',
"history",
];
}
public function getFormFilters(): array
{
return [
'site',
'location',
'clientinfo_uid',
'serverinfo_uid',
'rack',
'line',
'status',
];
}
public function getIndexFields(): array
{
return [
'site',
'location',
'clientinfo_uid',
'serverinfo_uid',
'sale',
'amount',
'billing_at',
'status',
'start_at',
'updated_at',
];
}
public function getIndexFilters(): array
{
return [
'site',
'location',
'clientinfo_uid',
'serverinfo_uid',
'user_uid', //home의 최신신규서버현황에서 사용
'status',
];
}
public function getBatchjobFields(): array
{
return ['site', 'location', 'clientinfo_uid', 'status'];
}
public function getFormRule(string $action, string $field): string
{
if (is_array($field)) {
throw new \Exception(__FUNCTION__ . "=> field가 array 입니다.\n" . var_export($field, true));
}
switch ($field) {
case "serverinfo_uid":
$rule = "required|numeric";
break;;
default:
$rule = parent::getFormRule($action, $field);
break;
}
return $rule;
}
protected function getEntity_process(mixed $entity): ServiceEntity
{
if (!$entity instanceof ServiceEntity) {
throw new \Exception(__METHOD__ . "에서 형식오류:ServiceEntity만 허용됩니다.");
}
//서버정보 정의
$serverEntity = $this->getServerService()->getEntity($entity->getServerInfoUID());
if ($serverEntity instanceof ServerEntity) {
$entity->setServerEntity($serverEntity);
}
//결제정보 정의
if ($entity->getPaymentUID()) {
$paymentEntity = $this->getPaymentService()->getEntity($entity->getPaymentUID());
if ($paymentEntity instanceof PaymentEntity) {
$entity->setPaymentEntity($paymentEntity);
}
}
return $entity;
}
final public function getPaymentService(): PaymentService
{
if (!$this->_paymentService) {
$this->_paymentService = new PaymentService();
}
return $this->_paymentService;
}
public function getServerService(): ServerService
{
if (!$this->_serverService) {
$this->_serverService = new ServerService();
}
return $this->_serverService;
}
final public function getServerPartService(): ServerPartService
{
if (!$this->_serverPartService) {
$this->_serverPartService = new ServerPartService();
}
return $this->_serverPartService;
}
//interval을 기준으로 최근 신규 서비스정보 가져오기
final public function getEntitiesByNewService(int $interval, string $status = ServiceEntity::DEFAULT_STATUS): array
{
return $this->getEntities(sprintf("start_at >= NOW()-INTERVAL {$interval} DAY AND status = '%s'", $status));
}
//서비스별 총 금액
final public function getTotalAmounts($where = []): array
{
$rows = $this->getModel()->groupBy('clientinfo_uid')->select("clientinfo_uid,SUM(amount) AS amount")
->where($where)
->get()->getResult();
$amounts = [];
foreach ($rows as $row) {
$amounts[$row->clientinfo_uid] = $row->amount;
}
return $amounts;
}
//다음 달로 결제일을 연장합니다.
final public function extendBillingAt(string $billing_at, string $status): bool
{
$sql = "UPDATE serviceinfo SET billing_at =
IF(DAY(billing_at) > DAY(LAST_DAY(billing_at)),
LAST_DAY(DATE_ADD(billing_at, INTERVAL 1 MONTH)),
DATE_ADD(billing_at, INTERVAL 1 MONTH)
) WHERE billing_at = ? AND status = ?";
return $this->getModel()->query($sql, [$billing_at, $status]);
}
//조정된 금액 설정
final public function getCaculatedAmount(ServiceEntity $entity): int
{
//총서비스금액 계산
//기본:상면비+회선비+서버금액(price)+서버파트연결(월비용)-할인액
$caculatedAmount = $entity->getRack() + $entity->getLine() + $entity->getServerEntity()->getPrice();
//해당 서비스(서버) 관련 결제방식(Billing)이 Month인 ServerPart 전체를 다시 검사하여 월청구액을 합산한다.
foreach ($this->getServerPartService()->getEntities(['serverinfo_uid' => $entity->getServerEntity()->getPK()]) as $serverPartEntity) {
if ($serverPartEntity->getBilling() === PAYMENT['BILLING']['MONTH']) { //월비용일때만 적용
$caculatedAmount += $serverPartEntity->getTotalAmount(); //단가*Cnt
}
}
return $caculatedAmount - $entity->getSale();
}
final public function setAmount(ServiceEntity $entity): ServiceEntity
{
$caculatedAmount = $this->getCaculatedAmount($entity);
//계산된 금액이 현재 금액과 다른 경우
if ($entity->getAmount() !== $caculatedAmount) {
$paymentEntity = $entity->getPaymentEntity();
if (!$paymentEntity instanceof PaymentEntity) {
throw new \Exception(__METHOD__ . "에서 오류발생: 결제정보가 정의되지 않았습니다.");
}
//금액설정
$entity = parent::modify($entity, ['amount' => $caculatedAmount]);
}
return $entity;
}
//기본 기능부분
//FieldForm관련용
public function getFormOption(string $field, array $options = []): array
{
switch ($field) {
case 'serverinfo_uid':
$options = $this->getServerService()->getEntities();
break;
case 'CPU':
case 'RAM':
case 'DISK':
case 'OS':
case 'SOFTWARE':
case 'SWITCH':
case 'IP':
case 'CS':
$options = $this->getServerService()->getFormOption($field, $options);
break;
default:
$options = parent::getFormOption($field, $options);
break;
}
return $options;
}
//생성
public function create(array $formDatas): ServiceEntity
{
if (!array_key_exists('serverinfo_uid', $formDatas)) {
throw new \Exception(__METHOD__ . "에서 오류발생: 서버가 지정되지 않았습니다.");
}
//신규등록(월청구액 전달값 그대로 사용)
$entity = parent::create($formDatas);
//서버등록
$entity = $this->getServerService()->setService($entity, $formDatas);
//전체 서비스금액 설정
$entity = $this->setAmount($entity);
//결제정보수정
$entity = $this->getPaymentService()->setService($entity, $formDatas);
//결제정보 PK설정
return parent::modify($entity, ['payment_uid' => $entity->getPaymentEntity()->getPK()]);
}
//수정
public function modify(mixed $entity, array $formDatas): ServiceEntity
{
//수정전 정보
$oldEntity = $entity;
//서비스정보 수정
$entity = parent::modify($entity, $formDatas);
//기존 서버정보와 다르다면 서버변경
if ($entity->getServerEntity()->getPK() != $formDatas['serverinfo_uid']) {
$entity = $this->getServerService()->changeService($oldEntity, $entity, $formDatas);
}
//전체 서비스금액 설정
$entity = $this->setAmount($entity);
//결제정보수정
$entity = $this->getPaymentService()->changeService($oldEntity, $entity, $formDatas);
//결제정보 PK설정
return parent::modify($entity, ['payment_uid' => $entity->getPaymentEntity()->getPK()]);
}
//삭제
public function delete(mixed $entity): ServiceEntity
{
//서버해지
$this->getServerService()->unsetService($entity, ['serverinfo_uid' => $entity->getServerEntity()->getPK()]);
return parent::delete($entity);
}
//대체서버추가(가격변동은 없음)
final public function addServer(ServiceEntity $entity, array $formDatas): ServiceEntity
{
$this->getServerService()->setService($entity, $formDatas);
return $entity;
}
//대체 서버를 메인서버로 설정
final public function changeServere(ServiceEntity $entity, array $formDatas): ServiceEntity
{
// //기존메인서버 정보
// $oldServerEntity = $entity->getServerEntity();
// //메인서버로 선정된 대체서버정보
$serverEntity = $this->getServerService()->getEntity($formDatas['serverinfo_uid']);
if (!$serverEntity instanceof ServerEntity) {
throw new \Exception("{$formDatas['serverinfo_uid']}에 대한 서버정보를 찾을수 없습니다.");
}
// //메인서버로 선정된 서버의 형식을 기존메인서버의 형식으로 바꿈
// $serverEntity = $this->getServerService()->modify($serverEntity, ['type' => $oldServerEntity->getType()]);
//수정전 서비스정보
$oldEntity = $entity;
//메인서버 변경(메인서버를 선정된 대체서버로 바꾼다.)
$entity = parent::modify($entity, ['serverinfo_uid' => $serverEntity->getPK()]);
//전체 서비스금액 설정
$entity = $this->setAmount($entity);
//결제정보수정
$entity = $this->getPaymentService()->changeService($oldEntity, $entity, $formDatas);
//결제정보 PK설정
return parent::modify($entity, ['payment_uid' => $entity->getPaymentEntity()->getPK()]);
}
//뎇[서버해지(대체서버는 해지는 가격변동은 없음)
final public function terminateServer(ServiceEntity $entity, array $formDatas): ServiceEntity
{
$this->getServerService()->unsetService($entity, $formDatas);
return $entity;
}
//서버관련 작업
public function setServer(ServerEntity $serverEntity, array $serverDatas): ServerEntity
{
//서비스중인지 확인
if ($serverEntity->getServiceInfoUID() === null || $serverEntity->getStatus() === STATUS['AVAILABLE']) {
throw new \Exception("서비스가 정의되지 않은 서버는 서비스정보를 설정할 수 없습니다.");
}
//아무것도 하지 않음
return $serverEntity;
}
public function changeServer(ServerEntity $oldServerEntity, ServerEntity $serverEntity, array $serverDatas): ServerEntity
{
//서비스정보가 NULL이 아니고 형식이 대체(alternative)가 아닌경우만 적용
if ($serverEntity->getServiceInfoUID() === null || $serverEntity->getType() === "alternative") {
throw new \Exception(__METHOD__ . "에서 오류발생: 서비스가 정의되어있지 않거나 , 대체서버의 경우는 서비스정보를 변경할수 없습니다.");
}
//Service Entity 가져오기
$oldEntity = $entity = $this->getEntity($serverEntity->getServiceInfoUID());
if (!$oldEntity instanceof ServiceEntity) {
throw new \Exception("[{$serverEntity->getServiceInfoUID()}]에 대한 서비스정보를 찾을수 없습니다.");
}
//서비스금액변경 사항이 있는지 확인후 처리
$entity = $this->setAmount($oldEntity);
//결제정보수정
$entity = $this->getPaymentService()->changeService($oldEntity, $entity, []);
//결제정보 PK설정
$entity = parent::modify($entity, ['payment_uid' => $entity->getPaymentEntity()->getPK()]);
return $serverEntity;
}
public function unsetServer(ServerEntity $serverEntity, array $serverDatas): ServerEntity
{
//서비스중인지 확인
if ($serverEntity->getServiceInfoUID() !== null || $serverEntity->getStatus() === STATUS['OCCUPIED']) {
throw new \Exception("서비스중인 서버는 삭제하실수 없습니다.");
}
//아무것도 하지 않음
return $serverEntity;
}
//서버파트관련 작업
public function setServerPart(ServerPartEntity $serverPartEntity, array $serverPartDatas): ServerPartEntity
{
if ($serverPartEntity->getBilling() !== PAYMENT['BILLING']['MONTH']) {
throw new \Exception("[{$serverPartEntity->getBilling()}],청구방식이 매월이 아닙니다.");
}
//Service Entity 가져오기
$entity = $this->getEntity($serverPartEntity->getServiceInfoUID());
if (!$entity instanceof ServiceEntity) {
throw new \Exception("[{$serverPartEntity->getServiceInfoUID()}]에 대한 서비스정보를 찾을수 없습니다.");
}
//서비스금액변경 사항이 있는지 확인후 처리
$entity = $this->setAmount($entity);
//결제정보수정
$entity = $this->getPaymentService()->setService($entity, []);
//결제정보 PK설정
return $serverPartEntity;
}
//setServerPart와 같은기능
public function changeServerPart(ServerPartEntity $oldServerPartEntity, ServerPartEntity $serverPartEntity, array $serverPartDatas): ServerPartEntity
{
//Service Entity 가져오기
$oldEntity = $entity = $this->getEntity($serverPartEntity->getServiceInfoUID());
if (!$oldEntity instanceof ServiceEntity) {
throw new \Exception("[{$serverPartEntity->getServiceInfoUID()}]에 대한 서비스정보를 찾을수 없습니다.");
}
//서비스금액변경 사항이 있는지 확인후 처리
$entity = $this->setAmount($oldEntity);
//결제정보수정
$entity = $this->getPaymentService()->changeService($oldEntity, $entity, []);
//결제정보 PK설정
$entity = parent::modify($entity, ['payment_uid' => $entity->getPaymentEntity()->getPK()]);
return $serverPartEntity;
}
//setServerPart와 같은기능
public function unsetServerPart(ServerPartEntity $serverPartEntity, array $serverPartDatas): ServerPartEntity
{
//가격이 변동되므로 changeServerPart와 같은기능사용
return $this->changeServerPart($serverPartEntity, $serverPartEntity, $serverPartDatas);
}
}