package com.vci.ubcs.code.service.impl;


import com.alibaba.cloud.commons.lang.StringUtils;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.yulichang.base.MPJBaseServiceImpl;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.vci.ubcs.code.constant.MdmBtmTypeConstant;
import com.vci.ubcs.code.dto.CodeClassifyProcessTempDTO;
import com.vci.ubcs.code.dto.CodeReferConfigDTO;
import com.vci.ubcs.code.entity.*;
import com.vci.ubcs.code.mapper.CodeReferConfigMapper;
import com.vci.ubcs.code.mapper.CodeShowFieldConfigMapper;
import com.vci.ubcs.code.service.CodeReferConfigService;
import com.vci.ubcs.code.service.CodeShowFieldConfigService;
import com.vci.ubcs.code.service.CodeSrchCondConfigService;
import com.vci.ubcs.code.vo.CodeReferConfigVO;
import com.vci.ubcs.code.wrapper.CodeClassifyProcessTempWrapper;
import com.vci.ubcs.code.wrapper.CodeReferConfigWraper;
import com.vci.ubcs.code.wrapper.CodeShowFieldConfigWraper;
import com.vci.ubcs.code.wrapper.CodeSrchCondConfigWraper;
import com.vci.ubcs.starter.exception.VciBaseException;
import com.vci.ubcs.starter.util.DefaultAttrAssimtUtil;
import com.vci.ubcs.starter.util.Map2MPJLambdaUtil;
import com.vci.ubcs.starter.web.pagemodel.BaseQueryObject;
import com.vci.ubcs.starter.web.pagemodel.BladeQueryObject;
import com.vci.ubcs.starter.web.util.BeanUtilForVCI;
import com.vci.ubcs.starter.web.util.VciBaseUtil;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.BeanUtil;
import org.springframework.cglib.beans.BeanMap;
import org.springframework.stereotype.Service;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageImpl;
import org.springframework.data.domain.PageRequest;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.Objects;

import static com.vci.ubcs.code.constant.FrameWorkLangCodeConstant.TS_NOT_PROCESS;

/**
 * 参照配置表(CodeReferconfig)表服务实现类
 *
 * @author ludc
 * @since 2023-05-19 17:48:02
 */
@Service("CodeReferconfigService")
public class CodeReferConfigServiceImpl extends MPJBaseServiceImpl<CodeReferConfigMapper,CodeReferConfig> implements CodeReferConfigService {

    @Resource
    private CodeReferConfigMapper codeReferconfigMapper;

	@Resource
	private CodeShowFieldConfigService codeShowFieldConfigService;

	@Resource
	private CodeSrchCondConfigService codeSrchCondConfigService;

    /**
     * 通过ID查询单条数据
     *
     * @param oid 主键
     * @return 实例对象
     */
    @Override
    public CodeReferConfigVO queryById(String oid) {
		CodeReferConfig codeReferConfig = this.codeReferconfigMapper.selectJoinOne(CodeReferConfig.class, this.getMPJLambdaWrapper().eq(CodeReferConfig::getOid, oid));
		return CodeReferConfigWraper.build().entityVO(codeReferConfig);
    }

	@Override
	public IPage<CodeReferConfigVO> queryByJoinPage(BladeQueryObject bladeQueryObject) {
		CodeReferConfig codeReferConfig = new CodeReferConfig();
		// 根据租户进行区分对应的参照配置
		Map<String, Object> conditionMap = bladeQueryObject.getConditionMap();
		conditionMap.put("tenantId",AuthUtil.getTenantId());
		BeanMap beanMap = BeanMap.create(codeReferConfig);
		beanMap.putAll(conditionMap);
		// 添加默认排序字段,根据时间进行排序
		Query query = bladeQueryObject.getQuery();
		query.setAscs("CREATETIME");
		IPage<CodeReferConfig> codeReferConfigs = codeReferconfigMapper.selectJoinPage(codeReferConfig, Condition.getPage(query));
		return CodeReferConfigWraper.build().pageVO(codeReferConfigs);
	}

	/**
     * 分页查询
     *
     * @param codeReferConfigVO 筛选条件
     * @return 查询结果
     */
    @Override
    public List<CodeReferConfigVO> queryByList(CodeReferConfigVO codeReferConfigVO) {
		codeReferConfigVO.setTenantId(AuthUtil.getTenantId());
		//MPJLambdaWrapper<CodeReferConfig> mpjLambdaWrapper = Map2MPJLambdaUtil.getMPJLambdaWrapper(bladeQueryObject.getConditionMap(), CodeReferConfig.class)
		MPJLambdaWrapper<CodeReferConfig> mpjLambdaWrapper = getMPJLambdaWrapper()
			.setEntity(codeReferConfigVO)
			.orderBy(true, true, CodeReferConfig::getCreateTime);
		List<CodeReferConfig> codeReferConfigList = codeReferconfigMapper.selectJoinList(CodeReferConfig.class, mpjLambdaWrapper);
		return CodeReferConfigWraper.build().listVO(codeReferConfigList);
	}

    /**
     * 新增数据
     *
     * @param codeReferConfigVO 实例对象
     * @return 实例对象
     */
    @Override
	@Transactional(rollbackFor = Exception.class)
    public R insert(CodeReferConfigVO codeReferConfigVO) {
		VciBaseUtil.alertNotNull(codeReferConfigVO,"需要添加的数据对象");
		if (StringUtils.isBlank(codeReferConfigVO.getReferType())){
			throw new VciBaseException("参照配置不能为空");
		}
		Long count = countCodeReferConfig(codeReferConfigVO);
		if(count > 0){
			throw new VciBaseException("已存在相同的参照配置");
		}

		CodeReferConfig CodeReferConfig = Objects.requireNonNull(BeanUtil.copy(codeReferConfigVO, CodeReferConfig.class));
		boolean resInsertReferConfig = this.codeReferconfigMapper.insert(CodeReferConfig) > 0;
		if (!resInsertReferConfig) {
			return R.fail("新增参照配置失败！");
		}
		codeShowFieldConfigService.insertBatch(codeReferConfigVO.getCodeShowFieldConfigVOS());
		codeSrchCondConfigService.insertBatch(codeReferConfigVO.getCodeSrchCondConfigVOS());
		return R.data(codeReferConfigVO);
    }

	/**
	 * 获取已存在的参照配置
	 * @param codeReferConfigVO
	 * @return 个数
	 */
	private Long countCodeReferConfig(CodeReferConfigVO codeReferConfigVO) {
		String templateName = codeReferConfigVO.getName();
		if (StringUtils.isBlank(templateName)){
			throw new VciBaseException("参照配置名称不能为空");
		}
		LambdaQueryWrapper<CodeReferConfig> wrapper = Wrappers.<CodeReferConfig>query()
			.lambda().eq(CodeReferConfig::getId, codeReferConfigVO.getId())
			.eq(CodeReferConfig::getTenantId, codeReferConfigVO.getTenantId());
		Long count = codeReferconfigMapper.selectCount(wrapper);
		return count;
	}

	/**
	 * 连表查询Wrapper对象获取
	 * @return
	 */
	private MPJLambdaWrapper<CodeReferConfig> getMPJLambdaWrapper(){
		MPJLambdaWrapper<CodeReferConfig> mpjLambdaWrapper = new MPJLambdaWrapper<>(CodeReferConfig.class)
			.selectAll(CodeReferConfig.class)
			//			.select(CodeShowFieldConfig::getField
//				,CodeShowFieldConfig::getTitle
//				,CodeShowFieldConfig::getFieldType
//				,CodeShowFieldConfig::getSort
//				,CodeShowFieldConfig::getAttrSortField
//				,CodeShowFieldConfig::getWidth
//				,CodeShowFieldConfig::getFixedPosition
//				,CodeShowFieldConfig::getTemplet)
//			.select(
//				CodeSrchCondConfig::getFilterType,
//				CodeSrchCondConfig::getFilterField,
//				CodeSrchCondConfig::getFilterValue)
			.selectCollection(CodeShowFieldConfig.class, CodeReferConfig::getCodeShowFieldConfigs)
			.selectCollection(CodeSrchCondConfig.class, CodeReferConfig::getCodeSrchCondConfigs)
			.leftJoin(CodeShowFieldConfig.class, CodeShowFieldConfig::getReferConfigOid,CodeReferConfig::getOid)
			.leftJoin(CodeSrchCondConfig.class, CodeSrchCondConfig::getReferConfigOid, CodeReferConfig::getOid);
		return mpjLambdaWrapper;
	}

    /**
     * 修改数据
     *
     * @param codeReferConfigVO 实例对象
     * @return 实例对象
     */
    @Override
	@Transactional(rollbackFor = Exception.class)
    public R update(CodeReferConfigVO codeReferConfigVO) {
		boolean resUpdateReferConfig = this.codeReferconfigMapper.updateById(codeReferConfigVO) > 0;
		if (!resUpdateReferConfig) {
			return R.fail("参照配置修改失败！");
		}
		this.codeShowFieldConfigService.updateBatch(codeReferConfigVO.getCodeShowFieldConfigVOS());
		this.codeSrchCondConfigService.updateBatch(codeReferConfigVO.getCodeSrchCondConfigVOS());
        return R.data(codeReferConfigVO);
    }

    /**
     * 通过主键删除数据
     *
     * @param codeReferConfigDTO
     * @return 是否成功
     */
    @Override
	@Transactional(rollbackFor = Exception.class)
    public R deleteById(CodeReferConfigDTO codeReferConfigDTO) {
		CodeReferConfig tsDO = new CodeReferConfig();
		BeanUtil.copyProperties(tsDO,codeReferConfigDTO);
		CodeReferConfig codeReferConfig = codeReferconfigMapper.queryById(codeReferConfigDTO.getOid());
		// 检查ts字段是否一致
		if (!checkTs(tsDO,codeReferConfig)) {
			return R.fail(TS_NOT_PROCESS);
		}
		boolean resDeleteReferConfig = this.codeReferconfigMapper.deleteById(codeReferConfigDTO.getOid()) > 0;
		if (!resDeleteReferConfig) {
			return R.fail("参照配置删除失败！");
		}
		this.codeShowFieldConfigService.deleteByReferConfigOid(codeReferConfigDTO.getOid());
		this.codeSrchCondConfigService.deleteByReferConfigOid(codeReferConfigDTO.getOid());
        return  R.status(resDeleteReferConfig);
    }

	/**
	 * 检查ts
	 * @param tempDO
	 * @param codeReferConfig
	 * @return
	 */
	private boolean checkTs(CodeReferConfig tempDO, CodeReferConfig codeReferConfig){
		Date dbTs = codeReferConfig.getTs();
		Date currentTs = tempDO.getTs();
		if(currentTs == null ?  dbTs == null:currentTs.compareTo(dbTs)==0){
			return true;
		}
		return false;
	}

}