package org.jeecg.modules.system.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.apache.commons.lang.StringUtils;
|
import org.jeecg.common.constant.CommonConstant;
|
|
import org.jeecg.common.system.base.entity.SysUploadRela;
|
import org.jeecg.modules.system.mapper.UploadRelaMapper;
|
import org.jeecg.modules.system.service.IUploadRelaService;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
@Service
|
public class UploadRelaServiceImpl extends ServiceImpl<UploadRelaMapper, SysUploadRela> implements IUploadRelaService {
|
|
@Override
|
public void createUploadRale(String busId, String busType, String uploadId) {
|
SysUploadRela uploadRela = new SysUploadRela();
|
uploadRela.setBusId(busId);
|
uploadRela.setBusType(busType);
|
uploadRela.setUploadId(uploadId);
|
save(uploadRela);
|
}
|
|
//单文件业务:判断当前busId对应的rela数量为1,在当前rela文件上进行更新持久,当前busId对应的rela数量>0,全部remove后重新new并进行持久
|
@Override
|
public void saveOrUpdateUploadRale(String busId, String busType, String uploadId) {
|
List<SysUploadRela> uploadRelaList = this.listByBusIdAndBusType(busId, busType);
|
SysUploadRela uploadRela = new SysUploadRela();
|
uploadRela.setBusId(busId);
|
uploadRela.setBusType(busType);
|
if (CollectionUtils.isNotEmpty(uploadRelaList)) {
|
if (uploadRelaList.size() == 1) {
|
uploadRela = uploadRelaList.get(0);
|
} else {
|
for (SysUploadRela u : uploadRelaList) {
|
this.removeById(u.getId());
|
}
|
}
|
}
|
uploadRela.setUploadId(uploadId);
|
this.saveOrUpdate(uploadRela);
|
}
|
|
/**
|
* 20230606 增加 业务类型为空的判断
|
* @param busId
|
* @param busType
|
* @return
|
*/
|
@Override
|
public List<SysUploadRela> listByBusIdAndBusType(String busId, String busType) {
|
if (StringUtils.isNotBlank(busType)) {
|
return super.lambdaQuery().eq(SysUploadRela::getBusId, busId)
|
.eq(StringUtils.isNotBlank(busType),SysUploadRela::getBusType, busType)
|
.eq(SysUploadRela::getDelFlag, CommonConstant.DEL_FLAG_0).list();
|
} else {
|
return super.lambdaQuery().eq(SysUploadRela::getBusId, busId)
|
.eq(SysUploadRela::getDelFlag, CommonConstant.DEL_FLAG_0).list();
|
}
|
|
}
|
|
@Override
|
public List<SysUploadRela> listByUploadId(String uploadId) {
|
return super.lambdaQuery().eq(SysUploadRela::getUploadId, uploadId)
|
.eq(SysUploadRela::getDelFlag, CommonConstant.DEL_FLAG_0).list();
|
}
|
|
/**
|
* 根据业务类型id和业务数据主键删除关系
|
*
|
* @param busId
|
* @param busType
|
*/
|
@Override
|
public void delSysUploadRelaByBusIdAndBusType(String busId, String busType) {
|
LambdaQueryWrapper<SysUploadRela> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(SysUploadRela::getBusId, busId);
|
wrapper.eq(SysUploadRela::getBusType, busType);
|
baseMapper.delete(wrapper);
|
}
|
|
}
|