package com.oying.modules.pc.product.service.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.bean.copier.CopyOptions;
import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.oying.exception.BadRequestException;
import com.oying.modules.pc.common.core.constrant.AuditStatusEnum;
import com.oying.modules.pc.product.domain.Product;
import com.oying.modules.pc.product.domain.ProductAudit;
import com.oying.modules.pc.product.domain.ProductImage;
import com.oying.modules.pc.product.domain.ProductLabel;
import com.oying.modules.pc.product.domain.dto.*;
import com.oying.modules.pc.product.domain.enums.ProductAuditTypeEnum;
import com.oying.modules.pc.product.domain.enums.ProductCreationType;
import com.oying.modules.pc.product.domain.enums.ProductStatusEnum;
import com.oying.modules.pc.product.service.*;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;
import java.util.Set;

@Slf4j
@Service
@RequiredArgsConstructor
public class ProductMerchantServiceImpl implements ProductMerchantService {

    private final ProductService productService;
    private final ProductImageService productImageService;
    private final ProductLabelService productLabelService;
    private final ProductAuditService productAuditService;
    private final ProductCreationContext productCreationService;
    private final ProductMerchantImagesUpdateProcessor productMerchantImagesUpdateProcessor;
    private final ProductMerchantLabelUpdateProcessor productMerchantLabelUpdateProcessor;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void create(ProductMerchantCreateRequest request) {
        productCreationService.createProduct(request, ProductCreationType.DIRECT);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void createWithAudit(ProductMerchantCreateRequest request) {
        productCreationService.createProduct(request, ProductCreationType.WITH_AUDIT);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void submitToAudit(Long productId, ProductAuditTypeEnum productAuditType) {
        Product existingProduct = productService.getById(productId);
        if (!ProductStatusEnum.DRAFT.getValue().equals(existingProduct.getStatus())) {
            throw new BadRequestException("无法提交，该商品已提交审核或已上架");
        }

        List<ProductImage> productImages = productImageService.queryImagesByProductId(existingProduct.getProductId());
        existingProduct.setImages(productImages);
        List<ProductLabel> productLabels = productLabelService.queryLabelsByProductId(existingProduct.getProductId());
        existingProduct.setLabels(productLabels);

        ProductAudit audit = new ProductAudit();
        audit.setProductId(existingProduct.getProductId());
        audit.setType(productAuditType.name());
        audit.setStatus(AuditStatusEnum.PENDING.getValue());
        ProductAuditData auditData = new ProductAuditData();
        auditData.setProduct(existingProduct);
        audit.setData(JSON.toJSONString(auditData));
        productAuditService.create(audit);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void update(ProductMerchantUpdateRequest request) {

        Product existingProduct = productService.getProduct(request.getProductId());
        this.validateAuditStatus(existingProduct.getStatus());

        productMerchantImagesUpdateProcessor.processImagesUpdate(request);
        productMerchantLabelUpdateProcessor.processLabelsUpdate(request);
        BeanUtils.copyProperties(request, existingProduct);
        existingProduct.setStatus(ProductStatusEnum.PENDING.getValue());
        existingProduct.setShelfStatus(ProductStatusEnum.NO_AVAILABLE.getValue());
        productService.update(existingProduct);

        ProductAudit audit = new ProductAudit();
        audit.setProductId(existingProduct.getProductId());
        audit.setType(ProductAuditTypeEnum.FULL_UPDATE.name());
        audit.setStatus(AuditStatusEnum.PENDING.getValue());
        ProductAuditData auditData = new ProductAuditData();
        auditData.setOriginalProduct(existingProduct);
        Product newProduct = new Product();
        BeanUtil.copyProperties(request, newProduct, CopyOptions.create().setIgnoreNullValue(true));
        auditData.setProduct(existingProduct);
        ProductRevisionRecord revisionRecord = new ProductRevisionRecord();
        BeanUtil.copyProperties(request, revisionRecord, CopyOptions.create().setIgnoreNullValue(true));
        auditData.setRevisionRecord(revisionRecord);
        audit.setData(JSON.toJSONString(auditData));
        productAuditService.create(audit);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updatePrice(ProductPriceUpdateRequest request) {
        Product existingProduct = productService.getProduct(request.getProductId());
        existingProduct.setPrice(request.getPrice());
        productService.update(existingProduct, true);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateImages(ProductMerchantUpdateRequest request) {
        Product existingProduct = productService.getProduct(request.getProductId());
        this.validateAuditStatus(existingProduct.getStatus());
        productMerchantImagesUpdateProcessor.processImagesUpdate(request);

        ProductAudit audit = new ProductAudit();
        audit.setProductId(existingProduct.getProductId());
        audit.setType(ProductAuditTypeEnum.IMAGE_UPDATE.name());
        audit.setStatus(AuditStatusEnum.PENDING.getValue());
        ProductAuditData auditData = new ProductAuditData();
        auditData.setOriginalProduct(existingProduct);
        Product newProduct = new Product();
        BeanUtil.copyProperties(request, newProduct, CopyOptions.create().setIgnoreNullValue(true));
        auditData.setProduct(existingProduct);
        ProductRevisionRecord revisionRecord = new ProductRevisionRecord();
        BeanUtil.copyProperties(request, revisionRecord, CopyOptions.create().setIgnoreNullValue(true));
        auditData.setRevisionRecord(revisionRecord);
        audit.setData(JSON.toJSONString(auditData));
        productAuditService.create(audit);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateLabels(ProductMerchantUpdateRequest request) {
        Product existingProduct = productService.getProduct(request.getProductId());
        this.validateAuditStatus(existingProduct.getStatus());
        productMerchantLabelUpdateProcessor.processLabelsUpdate(request);

        ProductAudit audit = new ProductAudit();
        audit.setProductId(existingProduct.getProductId());
        audit.setType(ProductAuditTypeEnum.LABEL_UPDATE.name());
        audit.setStatus(AuditStatusEnum.PENDING.getValue());
        ProductAuditData auditData = new ProductAuditData();
        auditData.setOriginalProduct(existingProduct);
        Product newProduct = new Product();
        BeanUtil.copyProperties(request, newProduct, CopyOptions.create().setIgnoreNullValue(true));
        auditData.setProduct(existingProduct);
        ProductRevisionRecord revisionRecord = new ProductRevisionRecord();
        BeanUtil.copyProperties(request, revisionRecord, CopyOptions.create().setIgnoreNullValue(true));
        auditData.setRevisionRecord(revisionRecord);
        audit.setData(JSON.toJSONString(auditData));
        productAuditService.create(audit);
    }

    @Transactional
    @Override
    public void batchDelete(List<Long> ids) {
        productService.deleteAll(ids);
    }

    @Override
    public void putOnShelf(Long productId) {
        Product existingProduct = productService.getById(productId);
        if (ProductStatusEnum.AVAILABLE.getValue().equals(existingProduct.getStatus())) {
            return;
        }
        if (!(ProductStatusEnum.APPROVED.getValue().equals(existingProduct.getStatus())
                || ProductStatusEnum.NO_AVAILABLE.getValue().equals(existingProduct.getStatus()))) {
            throw new BadRequestException("无法上架，商品未审核");
        }
        LambdaUpdateWrapper<Product> wrapper = new LambdaUpdateWrapper<Product>()
                .eq(Product::getProductId, productId)
                .set(Product::getStatus, ProductStatusEnum.AVAILABLE.getValue())
                .set(Product::getShelfStatus, ProductStatusEnum.AVAILABLE.getValue());
        productService.update(wrapper);
    }

    @Override
    public void takeOffShelf(Long productId) {
        Product existingProduct = productService.getById(productId);
        if (ProductStatusEnum.NO_AVAILABLE.getValue().equals(existingProduct.getShelfStatus())) {
            return;
        }
        if (!ProductStatusEnum.AVAILABLE.getValue().equals(existingProduct.getShelfStatus())) {
            return;
        }
        LambdaUpdateWrapper<Product> wrapper = new LambdaUpdateWrapper<Product>()
                .eq(Product::getProductId, productId)
                .set(Product::getStatus, ProductStatusEnum.NO_AVAILABLE.getValue())
                .set(Product::getShelfStatus, ProductStatusEnum.NO_AVAILABLE.getValue());
        productService.update(wrapper);
    }

    private void validateAuditStatus(Integer status) {
        Set<ProductStatusEnum> statusEnumSet = CollectionUtil.newHashSet(ProductStatusEnum.PENDING,
                ProductStatusEnum.UNDER_REVIEW);
        ProductStatusEnum existingStatus = ProductStatusEnum.getOrDefault(status, ProductStatusEnum.DRAFT);
        if (statusEnumSet.contains(existingStatus)) {
            throw new BadRequestException("商品已在审核流程中无法修改");
        }
    }
}