package doumeemes.service.business.impl;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.JSONValidator;
import doumeemes.core.constants.ResponseStatus;
import doumeemes.core.exception.BusinessException;
import doumeemes.core.model.LoginUserInfo;
import doumeemes.core.model.PageData;
import doumeemes.core.model.PageWrap;
import doumeemes.core.utils.Constants;
import doumeemes.core.utils.Utils;
import doumeemes.dao.business.CompanyMapper;
import doumeemes.dao.business.model.Company;
import doumeemes.dao.business.model.CompanyLog;
import doumeemes.dao.business.model.Multifiles;
import doumeemes.dao.ext.dto.DingDingConfig;
import doumeemes.service.business.CompanyLogService;
import doumeemes.service.business.CompanyService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import doumeemes.service.business.MultifilesService;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.Objects;

/**
 * 系统-企业信息表，记录用户认证公司时记录的营业执照（公司认证必须填写表）Service实现
 * @author 江蹄蹄
 * @date 2022/04/20 09:33
 */
@Service
public class CompanyServiceImpl implements CompanyService {

    @Autowired
    private CompanyMapper companyMapper;

    @Autowired
    private CompanyLogService companyLogService;


    @Override
    public Integer create(Company company) {
        companyMapper.insert(company);
        return company.getId();
    }

    @Override
    public void deleteById(Integer id) {
        Company company =new Company();
        company.setId(id);
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        company.setUpdateTime(new Date());
        company.setUpdateUser(user.getId());
        company.setDeleted(Constants.ONE);
        companyMapper.updateById(company);
    }

    @Override
    public void delete(Company company) {
        /*UpdateWrapper<Company> deleteWrapper = new UpdateWrapper<>(company);
        companyMapper.delete(deleteWrapper);*/
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        company.setUpdateTime(new Date());
        company.setUpdateUser(user.getId());
        company.setDeleted(Constants.ONE);
        companyMapper.updateById(company);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        Date now=new Date();
        Company company=new Company();
        for(int i=0;i<ids.size();i++){
            Integer id=ids.get(i);
            company.setDeleted(Constants.ONE);
            company.setId(id);
            company.setUpdateTime(now);
            company.setUpdateUser(user.getId());
        }
        companyMapper.updateById(company);
      //  companyMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(Company company) {
        companyMapper.updateById(company);
    }

    @Transactional(rollbackFor = {Exception.class,BusinessException.class})
    @Override
    public void update(Company company) {

        LoginUserInfo principal = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();


        if (StringUtils.isNotEmpty(company.getDingdingInfo()) && !isParseObject(company.getDingdingInfo())){
            throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"钉钉内部应用参数配置错误");
        }
        Company update = new Company();
        update.setId(company.getId());
        update.setStatus(company.getStatus());
        update.setDingdingInfo(company.getDingdingInfo());
        companyMapper.updateById(update);

//        更新记录

        if(Objects.nonNull(company.getStatus())){
            CompanyLog companyLog = new CompanyLog();
            companyLog.setDeleted((byte)Constants.ZERO);
            companyLog.setUpdateUser(principal.getId());
            companyLog.setCreateUser(principal.getId());
            companyLog.setCreateTime(new Date());
            companyLog.setUpdateTime(new Date());
            companyLog.setRemark(company.getStatus() == 1 ? "数据启用" : "数据禁用");
            companyLog.setCompanyId(company.getId());
            companyLog.setUpdateType(company.getStatus() == 1 ? Constants.CompanyUpdateType.UPDATE_ENABLE.getKey()
                    : Constants.CompanyUpdateType.UPDATE_DISABLE.getKey());
            companyLog.setDetail(company.getStatus() == 1 ? "数据启用" : "数据禁用");
            companyLogService.create(companyLog);
        }else {
            CompanyLog companyLog = new CompanyLog();
            companyLog.setDeleted((byte)Constants.ZERO);
            companyLog.setUpdateUser(principal.getId());
            companyLog.setCreateUser(principal.getId());
            companyLog.setCreateTime(new Date());
            companyLog.setUpdateTime(new Date());
            companyLog.setRemark("更新企业数据");
            companyLog.setCompanyId(company.getId());
            companyLog.setUpdateType(Constants.CompanyUpdateType.UPDATE_CONTENT.getKey());
            companyLog.setDetail("更新企业数据");
            companyLogService.create(companyLog);
        }

    }

    private Boolean isParseObject(String dingdingInfo){
        try {
            JSONValidator from = JSONValidator.from(dingdingInfo);
            return from.validate();
        }catch (Exception e){
            return false;
        }

    }

    @Override
    public void updateByIdInBatch(List<Company> companys) {
        if (CollectionUtils.isEmpty(companys)) {
            return;
        }
        for (Company company: companys) {
            this.updateById(company);
        }
    }

    @Override
    public Company findById(Integer id) {
        return companyMapper.selectById(id);
    }

    @Override
    public Company findOne(Company company) {
        company.setDeleted(Constants.ZERO);
        QueryWrapper<Company> wrapper = new QueryWrapper<>(company);
        return companyMapper.selectOne(wrapper);
    }

    @Override
    public List<Company> findList(Company company) {
        company.setDeleted(Constants.ZERO);
        QueryWrapper<Company> wrapper = new QueryWrapper<>(company);
        return companyMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<Company> findPage(PageWrap<Company> pageWrap) {
        IPage<Company> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<Company> queryWrapper = new QueryWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
        if (pageWrap.getModel().getId() != null) {
            queryWrapper.lambda().eq(Company::getId, pageWrap.getModel().getId());
        }
        if (pageWrap.getModel().getDeleted() != null) {
            queryWrapper.lambda().eq(Company::getDeleted, pageWrap.getModel().getDeleted());
        }
        if (pageWrap.getModel().getCreateUser() != null) {
            queryWrapper.lambda().eq(Company::getCreateUser, pageWrap.getModel().getCreateUser());
        }
        if (pageWrap.getModel().getCreateTime() != null) {
            queryWrapper.lambda().ge(Company::getCreateTime, Utils.Date.getStart(pageWrap.getModel().getCreateTime()));
            queryWrapper.lambda().le(Company::getCreateTime, Utils.Date.getEnd(pageWrap.getModel().getCreateTime()));
        }
        if (pageWrap.getModel().getUpdateUser() != null) {
            queryWrapper.lambda().eq(Company::getUpdateUser, pageWrap.getModel().getUpdateUser());
        }
        if (pageWrap.getModel().getUpdateTime() != null) {
            queryWrapper.lambda().ge(Company::getUpdateTime, Utils.Date.getStart(pageWrap.getModel().getUpdateTime()));
            queryWrapper.lambda().le(Company::getUpdateTime, Utils.Date.getEnd(pageWrap.getModel().getUpdateTime()));
        }
        if (pageWrap.getModel().getOrigin() != null) {
            queryWrapper.lambda().eq(Company::getOrigin, pageWrap.getModel().getOrigin());
        }
        if (pageWrap.getModel().getName() != null) {
            queryWrapper.lambda().eq(Company::getName, pageWrap.getModel().getName());
        }
//        if (pageWrap.getModel().getRemark() != null) {
//            queryWrapper.lambda().eq(Company::getRemark, pageWrap.getModel().getRemark());
//        }
        if (pageWrap.getModel().getType() != null) {
            queryWrapper.lambda().eq(Company::getType, pageWrap.getModel().getType());
        }
        if (pageWrap.getModel().getLegalPersonId() != null) {
            queryWrapper.lambda().eq(Company::getLegalPersonId, pageWrap.getModel().getLegalPersonId());
        }
        if (pageWrap.getModel().getLegalPersonPhone() != null) {
            queryWrapper.lambda().eq(Company::getLegalPersonPhone, pageWrap.getModel().getLegalPersonPhone());
        }
        if (pageWrap.getModel().getRegisterDate() != null) {
            queryWrapper.lambda().ge(Company::getRegisterDate, Utils.Date.getStart(pageWrap.getModel().getRegisterDate()));
            queryWrapper.lambda().le(Company::getRegisterDate, Utils.Date.getEnd(pageWrap.getModel().getRegisterDate()));
        }
        if (pageWrap.getModel().getAddr() != null) {
            queryWrapper.lambda().eq(Company::getAddr, pageWrap.getModel().getAddr());
        }
        if (pageWrap.getModel().getBusinessScope() != null) {
            queryWrapper.lambda().eq(Company::getBusinessScope, pageWrap.getModel().getBusinessScope());
        }
        if (pageWrap.getModel().getBusinessTerm() != null) {
            queryWrapper.lambda().eq(Company::getBusinessTerm, pageWrap.getModel().getBusinessTerm());
        }
        if (pageWrap.getModel().getIssueDate() != null) {
            queryWrapper.lambda().ge(Company::getIssueDate, Utils.Date.getStart(pageWrap.getModel().getIssueDate()));
            queryWrapper.lambda().le(Company::getIssueDate, Utils.Date.getEnd(pageWrap.getModel().getIssueDate()));
        }
        if (pageWrap.getModel().getCreditCode() != null) {
            queryWrapper.lambda().eq(Company::getCreditCode, pageWrap.getModel().getCreditCode());
        }
        if (pageWrap.getModel().getRegisterCapital() != null) {
            queryWrapper.lambda().eq(Company::getRegisterCapital, pageWrap.getModel().getRegisterCapital());
        }
        if (pageWrap.getModel().getFileFormat() != null) {
            queryWrapper.lambda().eq(Company::getFileFormat, pageWrap.getModel().getFileFormat());
        }
        if (pageWrap.getModel().getFileName() != null) {
            queryWrapper.lambda().eq(Company::getFileName, pageWrap.getModel().getFileName());
        }
        if (pageWrap.getModel().getFileStoreAddr() != null) {
            queryWrapper.lambda().eq(Company::getFileStoreAddr, pageWrap.getModel().getFileStoreAddr());
        }
        if (pageWrap.getModel().getAuthStatus() != null) {
            queryWrapper.lambda().eq(Company::getAuthStatus, pageWrap.getModel().getAuthStatus());
        }
        if (pageWrap.getModel().getAuthId() != null) {
            queryWrapper.lambda().eq(Company::getAuthId, pageWrap.getModel().getAuthId());
        }
        if (pageWrap.getModel().getDingdingId() != null) {
            queryWrapper.lambda().eq(Company::getDingdingId, pageWrap.getModel().getDingdingId());
        }
        if (pageWrap.getModel().getOpenUserNum() != null) {
            queryWrapper.lambda().eq(Company::getOpenUserNum, pageWrap.getModel().getOpenUserNum());
        }
        if (pageWrap.getModel().getOpenModules() != null) {
            queryWrapper.lambda().eq(Company::getOpenModules, pageWrap.getModel().getOpenModules());
        }
        if (pageWrap.getModel().getOepnValidDate() != null) {
            queryWrapper.lambda().ge(Company::getOepnValidDate, Utils.Date.getStart(pageWrap.getModel().getOepnValidDate()));
            queryWrapper.lambda().le(Company::getOepnValidDate, Utils.Date.getEnd(pageWrap.getModel().getOepnValidDate()));
        }
        if (pageWrap.getModel().getOepnType() != null) {
            queryWrapper.lambda().eq(Company::getOepnType, pageWrap.getModel().getOepnType());
        }
        if (pageWrap.getModel().getChannelId() != null) {
            queryWrapper.lambda().eq(Company::getChannelId, pageWrap.getModel().getChannelId());
        }
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                queryWrapper.orderByDesc(sortData.getProperty());
            } else {
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        queryWrapper.lambda().eq(Company::getDeleted, Constants.ZERO);
        return PageData.from(companyMapper.selectPage(page, queryWrapper));
    }

    @Override
    public long count(Company company) {
        company.setDeleted(Constants.ZERO);
        QueryWrapper<Company> wrapper = new QueryWrapper<>(company);
        return companyMapper.selectCount(wrapper);
    }
}