package com.doumee.service.business.impl;

import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.DemandRecordMapper;
import com.doumee.dao.business.model.*;
import com.doumee.service.business.DemandRecordService;
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 com.github.yulichang.wrapper.MPJLambdaWrapper;
import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;

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

/**
 * 需求记录Service实现
 * @author 江蹄蹄
 * @date 2025/09/08 10:24
 */
@Service
public class DemandRecordServiceImpl implements DemandRecordService {

    @Autowired
    private DemandRecordMapper demandRecordMapper;

    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    @Override
    public Integer create(DemandRecord demandRecord) {
        if(Objects.isNull(demandRecord)
                || Objects.isNull(demandRecord.getApplicationId())
                || StringUtils.isEmpty(demandRecord.getLinkName())
                || StringUtils.isEmpty(demandRecord.getLinkPhone())
        ){
            throw new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        if(!(Constants.equalsInteger(loginUserInfo.getType(),Constants.ONE)||Constants.equalsInteger(loginUserInfo.getType(),Constants.TWO))){
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"当前用户无法进行该操作");
        }
        demandRecord.setCreateDate(new Date());
        demandRecord.setCreator(loginUserInfo.getId());
        demandRecord.setEditor(demandRecord.getCreator());
        demandRecord.setEditDate(demandRecord.getCreateDate());
        demandRecord.setStatus(Constants.ZERO);
        demandRecord.setIsdeleted(Constants.ZERO);
        demandRecord.setCompanyId(loginUserInfo.getCompanyId());
        demandRecordMapper.insert(demandRecord);
        return demandRecord.getId();
    }

    @Override
    public void deleteById(Integer id) {
        demandRecordMapper.deleteById(id);
    }

    @Override
    public void delete(DemandRecord demandRecord) {
        UpdateWrapper<DemandRecord> deleteWrapper = new UpdateWrapper<>(demandRecord);
        demandRecordMapper.delete(deleteWrapper);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        demandRecordMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(DemandRecord demandRecord) {
        demandRecordMapper.updateById(demandRecord);
    }

    @Override
    public void updateByIdInBatch(List<DemandRecord> demandRecords) {
        if (CollectionUtils.isEmpty(demandRecords)) {
            return;
        }
        for (DemandRecord demandRecord: demandRecords) {
            this.updateById(demandRecord);
        }
    }

    @Override
    public DemandRecord findById(Integer id) {
        return demandRecordMapper.selectById(id);
    }

    @Override
    public DemandRecord findOne(DemandRecord demandRecord) {
        QueryWrapper<DemandRecord> wrapper = new QueryWrapper<>(demandRecord);
        return demandRecordMapper.selectOne(wrapper);
    }

    @Override
    public List<DemandRecord> findList(DemandRecord demandRecord) {
        QueryWrapper<DemandRecord> wrapper = new QueryWrapper<>(demandRecord);
        return demandRecordMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<DemandRecord> findPage(PageWrap<DemandRecord> pageWrap) {
        IPage<DemandRecord> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        MPJLambdaWrapper<DemandRecord> queryWrapper = new MPJLambdaWrapper<DemandRecord>();
        Utils.MP.blankToNull(pageWrap.getModel());
        DemandRecord model = pageWrap.getModel();
        queryWrapper.selectAll(DemandRecord.class)
                .selectAs(Company::getName,DemandRecord::getCompanyName)
                .selectAs(ServerProvider::getName,DemandRecord::getServerName)
                .selectAs(ApplicationInfo::getName,DemandRecord::getApplicationName)
                .selectAs(ApplicationInfo::getLogo,DemandRecord::getApplicationLogo)
                .leftJoin(Company.class,Company::getId,DemandRecord::getCompanyId)
                .leftJoin(ApplicationInfo.class,ApplicationInfo::getId,DemandRecord::getApplicationId)
                .leftJoin(ServerProvider.class,ServerProvider::getId,ApplicationInfo::getServerId)
                .eq(ServerProvider::getIsdeleted,Constants.ZERO)
                .and(org.apache.commons.lang3.StringUtils.isNotBlank(model.getLinkName())
                        , i->i.like(DemandRecord::getLinkName,model.getLinkName()).or().like(DemandRecord::getLinkPhone,model.getLinkName()))
                .like(org.apache.commons.lang3.StringUtils.isNotBlank(model.getApplicationName()),ApplicationInfo::getName,model.getApplicationName())
                .ge(Objects.nonNull(model.getStartDate()),DemandRecord::getCreateDate, Utils.Date.getStart(model.getStartDate()))
                .le(Objects.nonNull(model.getEndDate()),DemandRecord::getCreateDate, Utils.Date.getEnd(model.getEndDate()))
                .orderByDesc(DemandRecord::getId)
        ;
        IPage<DemandRecord> iPage = demandRecordMapper.selectJoinPage( page, DemandRecord.class,  queryWrapper);
        String prefix = systemDictDataBiz.queryByCode(Constants.OSS, Constants.RESOURCE_PATH).getCode() + systemDictDataBiz.queryByCode(Constants.OSS, Constants.LOGO_FILE).getCode();
        for (DemandRecord demandRecord:iPage.getRecords()) {
            if(org.apache.commons.lang3.StringUtils.isNotBlank(demandRecord.getApplicationLogo())){
                demandRecord.setApplicationLogo(prefix + demandRecord.getApplicationLogo());
            }
        }
        return PageData.from(iPage);
    }

    @Override
    public long count(DemandRecord demandRecord) {
        QueryWrapper<DemandRecord> wrapper = new QueryWrapper<>(demandRecord);
        return demandRecordMapper.selectCount(wrapper);
    }
}