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);
|
}
|
|
}
|
