package com.nuvole.four.service.impl;
|
|
import cn.hutool.core.util.StrUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.nuvole.base.domain.SysUser;
|
import com.nuvole.four.contants.Contants;
|
import com.nuvole.four.domain.ChannelInfo;
|
import com.nuvole.four.domain.dto.ChannelInfoDto;
|
import com.nuvole.four.mapper.ChannelInfoMapper;
|
import com.nuvole.four.service.ChannelInfoService;
|
import com.nuvole.four.util.SystemUtil;
|
import com.nuvole.util.IdGenerator;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @Desc: 通道信息ServiceImpl
|
* @Author: dqh
|
* @Date: 2024-04-09
|
**/
|
@Slf4j
|
@Service
|
public class ChannelInfoServiceImpl implements ChannelInfoService {
|
@Autowired
|
private ChannelInfoMapper channelInfoMapper;
|
@Override
|
public List<ChannelInfo> getList(Map map) {
|
return null;
|
}
|
|
/**
|
* 方法描述:查询通道列表
|
**/
|
@Override
|
public List<ChannelInfo> getList(ChannelInfo channelInfo) {
|
return channelInfoMapper.selectAll(channelInfo);
|
}
|
|
/**
|
* 方法描述:分页查询通道列表
|
**/
|
@Override
|
public List<ChannelInfoDto> getPageList(ChannelInfo channelInfo) {
|
return channelInfoMapper.getPageList(channelInfo);
|
}
|
|
@Override
|
public List<Map> getListOfMap(Map map) {
|
return null;
|
}
|
|
@Override
|
public List<Map> getListOfMap(ChannelInfo channelInfo) {
|
return null;
|
}
|
|
@Override
|
public Integer save(ChannelInfo channelInfo) {
|
return null;
|
}
|
|
/**
|
* 方法描述: 新增通道
|
*
|
* @date 2024-04-11 14:39
|
**/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Integer saveChannelInfo(ChannelInfo channelInfo) {
|
ChannelInfo codeExists = channelInfoMapper.checkChannelCode(channelInfo.getChannelCode());
|
if(codeExists != null){
|
throw new IllegalArgumentException("通道code重复");
|
}
|
/*
|
* 解析extendJson的字符串字段转为json存储
|
*
|
**/
|
if(StrUtil.isNotEmpty(channelInfo.getExtendJson())){
|
Object object = JSON.parse(channelInfo.getExtendJson());
|
if(object instanceof JSONArray){
|
channelInfo.setExtendJson(channelInfo.getExtendJson());
|
}
|
}
|
channelInfo.setId(IdGenerator.getId());
|
channelInfo.setCreateTime(new Date());
|
SysUser user = SystemUtil.getLoginUser(Contants.LOGIN_TYPE_PC);
|
channelInfo.setCreateBy(user.getId());
|
channelInfo.setStatus(0);
|
return channelInfoMapper.insert(channelInfo);
|
}
|
|
/**
|
* 方法描述: 修改通道
|
*
|
* @date 2024-04-11 14:38
|
**/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Integer updateChannelInfo(ChannelInfo channelInfo) {
|
ChannelInfo codeExists = channelInfoMapper.checkChannelCode(channelInfo.getChannelCode());
|
if(codeExists != null && !codeExists.getId().equals(channelInfo.getId())){
|
throw new IllegalArgumentException("通道code重复");
|
}
|
/*
|
* 解析extendJson的字符串字段转为json存储
|
*
|
**/
|
if(StrUtil.isNotEmpty(channelInfo.getExtendJson())){
|
Object object = JSON.parse(channelInfo.getExtendJson());
|
if(object instanceof JSONArray){
|
channelInfo.setExtendJson(channelInfo.getExtendJson());
|
}
|
}
|
channelInfo.setUpdateTime(new Date());
|
SysUser user = SystemUtil.getLoginUser(Contants.LOGIN_TYPE_PC);
|
channelInfo.setUpdateBy(user.getId());
|
return channelInfoMapper.updateByPrimaryKeySelective(channelInfo);
|
}
|
|
/**
|
* 方法描述:根据id查询通道详情
|
*
|
* @date 2024-04-11 14:40
|
**/
|
@Override
|
public ChannelInfo getChannelInfo(Long id) {
|
return channelInfoMapper.selectByPrimaryKey(id);
|
}
|
/**
|
* 方法描述:根据code查询通道
|
*
|
* @date 2024-04-11 14:40
|
**/
|
@Override
|
public ChannelInfo getDetailByCode(String channelCode) {
|
return channelInfoMapper.checkChannelCode(channelCode);
|
}
|
|
@Override
|
public Integer update(ChannelInfo channelInfo) {
|
return null;
|
}
|
|
@Override
|
public Integer del(Long id) {
|
return null;
|
}
|
|
@Override
|
public ChannelInfo getById(Long id) {
|
return null;
|
}
|
|
}
|
