package com.mzl.flower.service.supplier;

import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.mzl.flower.config.exception.ValidationException;
import com.mzl.flower.config.security.SecurityUtils;
import com.mzl.flower.constant.Constants;
import com.mzl.flower.dto.request.supplier.*;
import com.mzl.flower.dto.response.supplier.SupplierDTO;
import com.mzl.flower.entity.supplier.Supplier;
import com.mzl.flower.mapper.supplier.SupplierMapper;
import com.mzl.flower.service.BaseService;
import com.mzl.flower.utils.DateUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.oauth2.common.OAuth2AccessToken;
import org.springframework.security.oauth2.common.OAuth2RefreshToken;
import org.springframework.security.oauth2.provider.token.TokenStore;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.List;

@Service
@Transactional
public class SupplierService {

    private final static String SUPPLIER_STATUS_AUDIT = "U"; // 待审核
    private final static String SUPPLIER_STATUS_PASS = "P"; // 审核通过
    private final static String SUPPLIER_STATUS_REJECT = "R"; // 审核拒绝

    private final SupplierMapper supplierMapper;

    @Resource
    private BaseService baseService;

    public SupplierService(SupplierMapper supplierMapper) {
        this.supplierMapper = supplierMapper;
    }

    public void addOrUpdateSupplier(UpdateSupplierDTO dto) {
        Supplier supplier;
        if(dto.getId()==null){ //注册
            if(checkExist(dto.getUserId())){
                throw new ValidationException("供应商信息已登记");
            }
            if(checkExistName(dto.getName(),null)){
                throw new ValidationException("店铺名称已存在");
            }
            supplier = new Supplier();
            BeanUtils.copyProperties(dto, supplier,"id");
            supplier.setIdCards(JSON.toJSONString(dto.getIdCards()));
            supplier.setPictures(JSON.toJSONString(dto.getPictures()));
            supplier.create(SecurityUtils.getUserId());
            supplier.setShowed(true);
            supplier.setStatus(SUPPLIER_STATUS_AUDIT);
            supplier.setIsEnabled(true);
            supplierMapper.insert(supplier);
        }else{//重新修改
            supplier = supplierMapper.selectById(dto.getId());
            if(supplier==null){
                throw new ValidationException("供应商信息未登记");
            }
            if(checkExistName(dto.getName(),supplier.getId())){
                throw new ValidationException("店铺名称已存在");
            }
            BeanUtils.copyProperties(dto, supplier,"id");
            supplier.setIdCards(JSON.toJSONString(dto.getIdCards()));
            supplier.setPictures(JSON.toJSONString(dto.getPictures()));
            supplier.setStatus(SUPPLIER_STATUS_AUDIT);
            supplier.update(SecurityUtils.getUserId());
            supplierMapper.updateById(supplier);
        }
    }

    public void operationUpdate(UpdateSupplierOpDTO dto) {
        if(dto.getId()==null || dto.getId()==0){
            throw new ValidationException("id不能为空");
        }
        Supplier supplier = supplierMapper.selectById(dto.getId());
        if(supplier==null){
            throw new ValidationException("供应商信息未登记");
        }
        if(checkExistName(dto.getName(),supplier.getId())){
            throw new ValidationException("店铺名称已存在");
        }
        BeanUtils.copyProperties(dto, supplier,"id");
        supplier.update(SecurityUtils.getUserId());
        supplierMapper.updateById(supplier);
    }

    private boolean checkExistName(String name, Long id) {
        if(StringUtils.isNotBlank(name)){
            LambdaQueryWrapper<Supplier> lambdaQueryWrapper = new LambdaQueryWrapper();
            lambdaQueryWrapper.eq(Supplier::getName,name);
            if(id != null){
                lambdaQueryWrapper.ne(Supplier::getId,id);
            }
            return supplierMapper.selectCount(lambdaQueryWrapper)>0;
        }
        return false;


    }

    private boolean checkExist(String userId) {
       return supplierMapper.selectCount(new LambdaQueryWrapper<Supplier>().eq(Supplier::getUserId,userId))>0;
    }

    public Page<SupplierDTO> querySupplier(QuerySupplierDTO dto, Page page) {
        if(StringUtils.isNotBlank(dto.getCreateDateBeginStr())){
            dto.setCreateDateBegin(DateUtils.dateToLocalDateTime(dto.getCreateDateBeginStr(),true));
        }
        if(StringUtils.isNotBlank(dto.getCreateDateEndStr())){
            dto.setCreateDateEnd(DateUtils.dateToLocalDateTime(dto.getCreateDateEndStr(),false));
        }
        List<SupplierDTO> list = supplierMapper.querySupplier(dto,page);
        page.setRecords(list);
        return page;
    }

    public SupplierDTO findSupplierDetail(Long id) {
        SupplierDTO dto = supplierMapper.findSupplierDetail(id);
        return dto;
    }

    public SupplierDTO findSupplierByPhone(String phone) {
        SupplierDTO dto = supplierMapper.findSupplierByPhone(phone);
        dto.setOverTime(LocalDate.from(dto.getPassTime()));
        return dto;
    }

    public void auditSupplier(AuditSupplierDTO dto) {
        Supplier supplier = supplierMapper.selectById(dto.getId());
        if(supplier==null){
            throw new ValidationException("供应商信息不存在");
        }
        if(Constants.AUDIT_STATUS.Y.name().equals(dto.getResult())){
            supplier.setStatus(SUPPLIER_STATUS_PASS);
            supplier.setPassTime(LocalDateTime.now());
        }else if(Constants.AUDIT_STATUS.N.name().equals(dto.getResult())){
            supplier.setStatus(SUPPLIER_STATUS_REJECT);
            supplier.setRejectReason(dto.getRejectReason());
        }else{
            throw new ValidationException("审核结果不正确");
        }
        supplier.update(SecurityUtils.getUserId());
        supplierMapper.updateById(supplier);
    }

    public void changeStation(ChangeStationDTO dto) {
        Supplier supplier = supplierMapper.selectById(dto.getId());
        if(supplier==null){
            throw new ValidationException("供应商信息不存在");
        }
        supplier.setStationId(dto.getStationId());
        supplier.update(SecurityUtils.getUserId());
        supplierMapper.updateById(supplier);
    }

    public SupplierDTO getCurrentSupplier() {
        if(!Constants.USER_TYPE.supplier.name().equals(SecurityUtils.getUserType())){
            throw new ValidationException("当前登录用户不是供应商账号");
        }
        SupplierDTO dto = supplierMapper.getCurrentSupplier(SecurityUtils.getUserId());
        return dto;
    }

    public void updateSupplier(UpdateSupplierDTO dto) {
        if(dto.getId() == null || dto.getId() == 0){
            throw new ValidationException("id不能为空");
        }
        Supplier supplier = supplierMapper.selectById(dto.getId());
        if(supplier ==null) {
            throw new ValidationException("供应商信息不存在");
        }
        if(checkExistName(dto.getName(),supplier.getId())){
            throw new ValidationException("店铺名称已存在");
        }
        supplier.setName(dto.getName());
        supplier.setCover(dto.getCover());
        supplier.setDescription(dto.getDescription());
        supplier.update(SecurityUtils.getUserId());
        supplierMapper.updateById(supplier);
    }


    public void configShow(Long id) {
        Supplier supplier = supplierMapper.selectById(id);
        if(supplier ==null) {
            throw new ValidationException("供应商信息不存在");
        }
        if(supplier.getShowed()){
            supplier.setShowed(false);
        }else {
            supplier.setShowed(true);
        }
        supplier.update(SecurityUtils.getUserId());
        supplierMapper.updateById(supplier);
    }

    public void isEnable(Long id) {
        Supplier supplier = supplierMapper.selectById(id);
        if (supplier == null) {
            throw new ValidationException("供应商信息不存在");
        }
        if (supplier.getIsEnabled()) {
            supplier.setIsEnabled(false);
            //强制下线
            baseService.removeToken(supplier.getUserId());
        } else {
            supplier.setIsEnabled(true);
        }
        supplier.update(SecurityUtils.getUserId());
        supplierMapper.updateById(supplier);
    }

    public Supplier getSupplierById(Long supplierId) {
        return supplierMapper.selectById(supplierId);
    }
}