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

import com.alibaba.nacos.shaded.com.google.protobuf.ServiceException;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
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.wrapper.MPJLambdaWrapper;
import com.vci.ubcs.code.entity.*;
import com.vci.ubcs.code.mapper.DockingSystemConfigMapper;
import com.vci.ubcs.code.service.*;
import com.vci.ubcs.code.vo.pagemodel.*;
import com.vci.ubcs.code.wrapper.*;
import com.vci.ubcs.starter.util.UBCSCondition;
import com.vci.ubcs.starter.util.UBCSSqlKeyword;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.utils.Func;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Map;

@Service
public class DokingSysManaentServiceImpl extends ServiceImpl<DockingSystemConfigMapper, DockingSystemConfig> implements IDokingSysManaentService {

	//	/***
//	 * 任务生成服务
//	 */
//	@Resource
//	private IDockingTaskService dockingTaskService;

	/***
	 * 日志生成服务
	 */
	@Autowired( required = false)
	private IDockingLogeService dockingLogeService;

	/***
	 * 集成任务服务
	 */
	@Autowired( required = false)
	private IDockingTaskService dockingTaskService;

	/***
	 * 集成接口头协议服务
	 */
	@Autowired( required = false)
	private  IDockingSysIntHeaderService dockingSysIntHeaderService;
	/***
	 * 集成接口参数服务
	 */
	@Autowired( required = false)
	private IDockingSysIntParamService dockingSysIntParamService;

	/***
	 * 待集成数据服务
	 */
	@Autowired( required = false)
	private  IDockingDataService dockingDataService;
	/**
	 * data列表
	 * @param condtionMap 基础查询对象，包含查询条件，分页，排序等
	 * @return 系统集成的系统信息显示对象列表
	 */
	@Override
	public IPage<DockingTaskVO> gridDockingTask(Map<String,String> condtionMap, Query query) {
		IPage<DockingTask> pages=dockingTaskService.page(Condition.getPage(query),UBCSSqlKeyword.buildConditionByMapString(condtionMap));
		return DockingTaskWrapper.build().pageVO(pages);
	}

	@Override
	public IPage<DockingDataVO> gridDockingData(Map<String,String> condtionMap, Query query) {
		IPage<DockingData> pages=dockingDataService.page(Condition.getPage(query), UBCSSqlKeyword.buildConditionByMapString(condtionMap));
		return DockingDataWrapper.build().pageVO(pages);
	}

	/**
	 * 根据集成日志oid，查询日志详情
	 * @param oid
	 * @return
	 * @throws ServiceException
	 */
	@Override
	public DockingLogeVO getDockingLogDetailByOid(String oid) throws ServiceException {
		if(Func.isBlank(oid)){
			throw new ServiceException("必传参数集成日志oid不能为空！");
		}
		DockingLog dockingLog = dockingLogeService.getOne(Wrappers.<DockingLog>query().lambda().eq(DockingLog::getOid, oid));
		return DockingLogeWrapper.build().entityVO(dockingLog);
	}

	/**
	 * 推送数据集成日志列表
	 * @param condtionMap 基础查询对象，包含查询条件，分页，排序等
	 * @return 集成日志显示对象列表
	 */
	@Override
	public IPage<DockingLogeVO> gridLoge(Map<String,String> condtionMap, Query query) {
		//IPage<DockingLog> pages=dockingLogeService.page(Condition.getPage(query), Condition.getQueryWrapper(dockingLog));
		LambdaQueryWrapper<DockingLog> lambdaQueryWrapper = UBCSCondition.getQueryWrapperByMapString(condtionMap, DockingLog.class).lambda();
		lambdaQueryWrapper.select(
			DockingLog::getOid,
			DockingLog::getCreateTime,
			DockingLog::getCreator,
			DockingLog::getLastModifier,
			DockingLog::getLastModifyTime,
			DockingLog::getTenantId,
			DockingLog::getSystemOid,
			DockingLog::getSystemCode,
			DockingLog::getSystemName,
			DockingLog::getClassifyOid,
			DockingLog::getClassifyId,
			DockingLog::getClassifyName,
			DockingLog::getUniqueCode,
			DockingLog::getType,
			DockingLog::getMsg,
			//DockingLog::getParamString,
			DockingLog::getSendXml,
			DockingLog::getReturnString,
			DockingLog::getInterfaceStatus
		);
		IPage<DockingLog> pages=dockingLogeService.page(Condition.getPage(query), lambdaQueryWrapper);
		return DockingLogeWrapper.build().pageVO(pages);
	}

	@Override
	public IPage<DockingSysIntParamVO> gridParam(Map<String,String> condtionMap, Query query) {
		IPage<DockingSysIntParam> pages=dockingSysIntParamService.page(Condition.getPage(query), UBCSSqlKeyword.buildConditionByMapString(condtionMap));
		return DockingSysIntParamWrapper.build().pageVO(pages);
	}
	/**
	 * 接口param列表
	 * @param condtionMap 基础查询对象，包含查询条件，分页，排序等
	 * @return 集成日志显示对象列表
	 */
	@Override
	public IPage<DockingSysIntHeaderVO> gridHeader(Map<String,String> condtionMap , Query query) {
		IPage<DockingSysIntHeader> pages = dockingSysIntHeaderService.page(Condition.getPage(query), UBCSSqlKeyword.buildConditionByMapString(condtionMap));
		return DockingSysIntHeaderWrapper.build().pageVO(pages);
	}

}