package com.ruoyi.system.service.impl;
|
|
import com.ruoyi.common.basic.PageInfo;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.system.domain.SysVersionUpdate;
|
import com.ruoyi.system.dto.SysVersionUpdateAddRequest;
|
import com.ruoyi.system.dto.SysVersionUpdateDeleteRequest;
|
import com.ruoyi.system.dto.SysVersionUpdateDetailRequest;
|
import com.ruoyi.system.dto.SysVersionUpdateEditRequest;
|
import com.ruoyi.system.dto.SysVersionUpdatePageRequest;
|
import com.ruoyi.system.mapper.SysVersionUpdateMapper;
|
import com.ruoyi.system.service.ISysVersionUpdateService;
|
import com.ruoyi.system.vo.SysVersionUpdateVO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* 版本更新服务实现
|
*
|
* @author ruoyi
|
*/
|
@Service
|
public class SysVersionUpdateServiceImpl implements ISysVersionUpdateService
|
{
|
@Autowired
|
private SysVersionUpdateMapper versionUpdateMapper;
|
|
@Override
|
public PageInfo<SysVersionUpdateVO> pageList(SysVersionUpdatePageRequest request)
|
{
|
SysVersionUpdatePageRequest query = request == null ? new SysVersionUpdatePageRequest() : request;
|
PageInfo<SysVersionUpdateVO> pageInfo = new PageInfo<SysVersionUpdateVO>(query.getPageNum(), query.getPageSize());
|
List<SysVersionUpdateVO> list = versionUpdateMapper.pageList(query, pageInfo);
|
SysVersionUpdateVO latest = versionUpdateMapper.selectLatest();
|
Long latestUpdateId = latest == null ? null : latest.getUpdateId();
|
for (SysVersionUpdateVO versionUpdate : list)
|
{
|
versionUpdate.setLatest(Objects.equals(versionUpdate.getUpdateId(), latestUpdateId));
|
}
|
pageInfo.setRecords(list);
|
return pageInfo;
|
}
|
|
@Override
|
public SysVersionUpdateVO latest()
|
{
|
SysVersionUpdateVO latest = versionUpdateMapper.selectLatest();
|
if (latest != null)
|
{
|
latest.setLatest(Boolean.TRUE);
|
}
|
return latest;
|
}
|
|
@Override
|
public SysVersionUpdateVO detail(SysVersionUpdateDetailRequest request)
|
{
|
if (request == null || request.getUpdateId() == null)
|
{
|
throw new ServiceException("更新主键不能为空");
|
}
|
SysVersionUpdateVO detail = versionUpdateMapper.selectById(request.getUpdateId());
|
if (detail == null)
|
{
|
throw new ServiceException("版本更新记录不存在");
|
}
|
SysVersionUpdateVO latest = versionUpdateMapper.selectLatest();
|
detail.setLatest(latest != null && Objects.equals(detail.getUpdateId(), latest.getUpdateId()));
|
return detail;
|
}
|
|
@Override
|
public int add(SysVersionUpdateAddRequest request, String username)
|
{
|
if (request == null)
|
{
|
throw new ServiceException("版本更新内容不能为空");
|
}
|
SysVersionUpdate versionUpdate = buildVersionUpdate(request.getVersionNo(), request.getUpdateContent(),
|
request.getPackageUrl(), request.getPackageName(), request.getForceUpdate());
|
versionUpdate.setCreateBy(username);
|
return versionUpdateMapper.insertVersionUpdate(versionUpdate);
|
}
|
|
@Override
|
public int edit(SysVersionUpdateEditRequest request, String username)
|
{
|
if (request == null || request.getUpdateId() == null || request.getUpdateId() <= 0)
|
{
|
throw new ServiceException("更新主键不能为空");
|
}
|
if (versionUpdateMapper.selectById(request.getUpdateId()) == null)
|
{
|
throw new ServiceException("版本更新记录不存在");
|
}
|
SysVersionUpdate versionUpdate = buildVersionUpdate(request.getVersionNo(), request.getUpdateContent(),
|
request.getPackageUrl(), request.getPackageName(), request.getForceUpdate());
|
versionUpdate.setUpdateId(request.getUpdateId());
|
versionUpdate.setUpdateBy(username);
|
return versionUpdateMapper.updateVersionUpdate(versionUpdate);
|
}
|
|
private SysVersionUpdate buildVersionUpdate(String requestVersionNo, String requestUpdateContent,
|
String requestPackageUrl, String requestPackageName,
|
Boolean requestForceUpdate)
|
{
|
String versionNo = StringUtils.trim(requestVersionNo);
|
if (StringUtils.isEmpty(versionNo))
|
{
|
throw new ServiceException("版本号不能为空");
|
}
|
String versionNumber = versionNo.replaceFirst("^[vV]", "");
|
if (!versionNumber.matches("\\d+(\\.\\d+)*"))
|
{
|
throw new ServiceException("版本号格式不正确，请输入数字或使用小数点分隔");
|
}
|
versionNo = versionNumber;
|
String updateContent = StringUtils.trim(requestUpdateContent);
|
String packageUrl = StringUtils.trim(requestPackageUrl);
|
if (StringUtils.isEmpty(packageUrl))
|
{
|
throw new ServiceException("安装包不能为空");
|
}
|
String packageName = StringUtils.trim(requestPackageName);
|
SysVersionUpdate versionUpdate = new SysVersionUpdate();
|
versionUpdate.setVersionNo(versionNo);
|
versionUpdate.setUpdateContent(updateContent);
|
versionUpdate.setPackageUrl(packageUrl);
|
versionUpdate.setPackageName(StringUtils.isEmpty(packageName) ? packageUrl : packageName);
|
versionUpdate.setForceUpdate(requestForceUpdate == null ? Boolean.FALSE : requestForceUpdate);
|
return versionUpdate;
|
}
|
|
@Override
|
public int delete(SysVersionUpdateDeleteRequest request)
|
{
|
if (request == null || CollectionUtils.isEmpty(request.getUpdateIds()))
|
{
|
throw new ServiceException("更新主键集合不能为空");
|
}
|
SysVersionUpdateVO latest = versionUpdateMapper.selectLatest();
|
if (latest != null && request.getUpdateIds().contains(latest.getUpdateId()))
|
{
|
throw new ServiceException("最新版本不能删除");
|
}
|
return versionUpdateMapper.deleteByIds(request.getUpdateIds());
|
}
|
}
|
