package com.gkhy.safePlatform.account.service.impl;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.gkhy.safePlatform.account.entity.app.AppVersionInfo;
|
import com.gkhy.safePlatform.account.enums.AppTypeEnum;
|
import com.gkhy.safePlatform.account.enums.AppVersionStatusEnum;
|
import com.gkhy.safePlatform.account.model.bo.ObjectItemBO;
|
import com.gkhy.safePlatform.account.model.dto.req.AppAddReqDTO;
|
import com.gkhy.safePlatform.account.model.dto.req.AppModReqDTO;
|
import com.gkhy.safePlatform.account.model.dto.resp.AppVersionRespDTO;
|
import com.gkhy.safePlatform.account.model.dto.resp.ObjectItemRespDTO;
|
import com.gkhy.safePlatform.account.model.query.AppVersionPageQuery;
|
import com.gkhy.safePlatform.account.model.query.db.AppVersionPageDBQuery;
|
import com.gkhy.safePlatform.account.service.AppVersionService;
|
import com.gkhy.safePlatform.account.service.baseService.AppVersionInfoService;
|
import com.gkhy.safePlatform.account.utils.MinioUtils;
|
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
|
import com.gkhy.safePlatform.commons.enums.E;
|
import com.gkhy.safePlatform.commons.enums.ResultCodes;
|
import com.gkhy.safePlatform.commons.exception.AusinessException;
|
import com.gkhy.safePlatform.commons.exception.BusinessException;
|
import com.gkhy.safePlatform.commons.query.PageQuery;
|
import com.gkhy.safePlatform.commons.utils.StringUtils;
|
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service("appVersionService")
|
public class AppVersionServiceImpl implements AppVersionService {
|
|
@Autowired
|
private MinioUtils minioUtils;
|
@Value("${accountminio.floders.app}")
|
private String appFloder;
|
@Autowired
|
private AppVersionInfoService appInfoService;
|
|
@Override
|
public ObjectItemRespDTO getAppPresignedUrl(ContextCacheUser currentUser, String filename) {
|
if (StringUtils.isBlank(filename)) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "文件名传入为空");
|
}
|
// todo 校验文件名是否合法
|
ObjectItemBO item = minioUtils.getPresignedUrl(appFloder, filename.trim());
|
if (item == null) {
|
throw new BusinessException(ResultCodes.SERVER_ERROR);
|
}
|
ObjectItemRespDTO respDTO = new ObjectItemRespDTO();
|
respDTO.setObjectName(item.getObjectName());
|
respDTO.setPresignedUrl(item.getPresignedUrl());
|
return respDTO;
|
}
|
|
@Override
|
public void addAppVersion(ContextCacheUser currentUser, AppAddReqDTO reqDTO) {
|
if (StringUtils.isBlank(reqDTO.getAppName())) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "文件名称不能为空");
|
}
|
if (StringUtils.isBlank(reqDTO.getCustomVersion())) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "版本号不能为空");
|
}
|
if (StringUtils.isBlank(reqDTO.getObjectName())) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "文件对象名不能为空");
|
}
|
if (reqDTO.getAppType() == null) {
|
throw new AusinessException(E.DATA_PARAM_NULL, "app文件类型不能为空");
|
}
|
AppTypeEnum typeEnum = AppTypeEnum.parse(reqDTO.getAppType());
|
if (typeEnum == null) {
|
throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "app文件类型非法");
|
}
|
// todo 校验文件是否存在
|
// 1.文件个数查询
|
long count = appInfoService.countByAppType(reqDTO.getAppType());
|
// 自定义版本名称是否存在
|
AppVersionInfo appVersionInfo = appInfoService.getAppVersionInfoByCustomVersion(reqDTO.getCustomVersion().trim(),reqDTO.getAppType());
|
if (appVersionInfo != null) {
|
throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "app自定义版本已经存在");
|
}
|
// exc
|
AppVersionInfo appEntity = new AppVersionInfo();
|
appEntity.setName(reqDTO.getAppName().trim());
|
appEntity.setInfo(reqDTO.getInfo());
|
appEntity.setVersion((int) (count + 1));
|
appEntity.setStatus(AppVersionStatusEnum.ENABLED.code);
|
appEntity.setObjectName(reqDTO.getObjectName());
|
appEntity.setGmtCreate(LocalDateTime.now());
|
appEntity.setCreateUid(currentUser.getUid());
|
appEntity.setCreateUname(currentUser.getRealName());
|
appEntity.setAppType(reqDTO.getAppType());
|
appEntity.setCustomVersion(reqDTO.getCustomVersion());
|
appInfoService.saveAppInfo(appEntity);
|
|
}
|
|
@Override
|
public void modAppVersion(ContextCacheUser currentUser, AppModReqDTO reqDTO) {
|
if (reqDTO.getId() == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
AppVersionInfo appInfo = appInfoService.getById(reqDTO.getId());
|
if (appInfo == null) {
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "APP版本信息不存在");
|
}
|
|
AppVersionInfo appEntity = new AppVersionInfo();
|
appEntity.setId(appInfo.getId());
|
appEntity.setInfo(reqDTO.getInfo());
|
appEntity.setGmtModified(LocalDateTime.now());
|
appEntity.setModifiedUid(currentUser.getUid());
|
appEntity.setModifiedUname(currentUser.getRealName());
|
if (StringUtils.isNotBlank((reqDTO.getAppName()))) {
|
appEntity.setName(reqDTO.getAppName().trim());
|
}
|
if (StringUtils.isNotBlank(reqDTO.getCustomVersion())) {
|
AppVersionInfo version = appInfoService.getAppVersionInfoByCustomVersion(reqDTO.getCustomVersion().trim(), reqDTO.getAppType());
|
if (version != null && !version.getId().equals(appInfo.getId())) {
|
throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "app自定义版本已经存在");
|
}
|
appEntity.setCustomVersion(reqDTO.getCustomVersion().trim());
|
}
|
// 文件 ObjectName
|
if (StringUtils.isNotBlank(reqDTO.getObjectName())) {
|
// todo 校验文件是否存在
|
appEntity.setObjectName(reqDTO.getObjectName().trim());
|
}
|
appInfoService.updateAppInfo(appEntity);
|
}
|
|
@Override
|
public void delAppVersion(ContextCacheUser currentUser, Long id) {
|
if (id == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
AppVersionInfo appInfo = appInfoService.getById(id);
|
if (appInfo == null) {
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT, "APP版本信息不存在");
|
}
|
if (!appInfo.getStatus().equals(AppVersionStatusEnum.ENABLED.code)) {
|
throw new AusinessException(E.DATA_DATABASE_EXIST_BUT_NOT_VALID, "APP版本信息不存在");
|
}
|
AppVersionInfo appEntity = new AppVersionInfo();
|
appEntity.setId(appInfo.getId());
|
appEntity.setGmtModified(LocalDateTime.now());
|
appEntity.setModifiedUid(currentUser.getUid());
|
appEntity.setModifiedUname(currentUser.getRealName());
|
appEntity.setStatus(AppVersionStatusEnum.ABANDONED.code);
|
appInfoService.updateAppInfo(appEntity);
|
}
|
|
@Override
|
public SearchResultVO<List<AppVersionRespDTO>> listAppVersionByPage(ContextCacheUser currentUser, PageQuery<AppVersionPageQuery> pageQuery) {
|
AppVersionPageDBQuery dbQuery = new AppVersionPageDBQuery();
|
if (pageQuery.getSearchParams() != null) {
|
dbQuery.setAppType(pageQuery.getSearchParams().getAppType());
|
dbQuery.setAppName(pageQuery.getSearchParams().getAppName());
|
dbQuery.setCustomVersion(pageQuery.getSearchParams().getCustomVersion());
|
}
|
Page<AppVersionInfo> page = new Page<>(pageQuery.getPageIndex(), pageQuery.getPageSize());
|
List<AppVersionInfo> dbData = appInfoService.listAppVersionInfoByPage(page, dbQuery);
|
List<AppVersionRespDTO> result = new ArrayList<>(dbData.size());
|
if (dbData.size() > 0) {
|
AppVersionStatusEnum statusEnum;
|
AppTypeEnum appTypeEnum;
|
AppVersionRespDTO respDTO;
|
for (AppVersionInfo appVersionInfo : dbData) {
|
respDTO = new AppVersionRespDTO();
|
respDTO.setId(appVersionInfo.getId());
|
respDTO.setName(appVersionInfo.getName());
|
respDTO.setInfo(appVersionInfo.getInfo());
|
respDTO.setCustomVersion(appVersionInfo.getCustomVersion());
|
respDTO.setVersion(appVersionInfo.getVersion());
|
respDTO.setStatus(appVersionInfo.getStatus());
|
statusEnum = AppVersionStatusEnum.parse(appVersionInfo.getStatus());
|
if (statusEnum != null) {
|
respDTO.setStatusDesc(statusEnum.value);
|
}
|
respDTO.setAppType(appVersionInfo.getAppType());
|
appTypeEnum = AppTypeEnum.parse(appVersionInfo.getAppType());
|
if (appTypeEnum != null) {
|
respDTO.setAppTypeDesc(appTypeEnum.getValue());
|
}
|
respDTO.setObjectName(appVersionInfo.getObjectName());
|
respDTO.setObjectUrl(minioUtils.getAccessibleUrl(appFloder,appVersionInfo.getObjectName()));
|
respDTO.setGmtCreate(appVersionInfo.getGmtCreate());
|
respDTO.setCreateUid(appVersionInfo.getCreateUid());
|
respDTO.setCreateUname(appVersionInfo.getCreateUname());
|
respDTO.setGmtModified(appVersionInfo.getGmtModified());
|
respDTO.setModifiedUid(appVersionInfo.getModifiedUid());
|
respDTO.setModifiedUname(appVersionInfo.getModifiedUname());
|
|
result.add(respDTO);
|
}
|
}
|
|
return new SearchResultVO<>(
|
true,
|
page.getCurrent(),
|
page.getSize(),
|
page.getPages(),
|
page.getTotal(),
|
result,
|
ResultCodes.OK);
|
|
}
|
|
@Override
|
public AppVersionRespDTO getLastestAppRelease(ContextCacheUser currentUser, Byte appType) {
|
if (appType == null) {
|
throw new BusinessException(ResultCodes.CLIENT_PARAM_NULL);
|
}
|
AppTypeEnum appTypeEnum = AppTypeEnum.parse(appType);
|
if (appTypeEnum == null) {
|
throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "app类型非法");
|
}
|
AppVersionInfo appVersionInfo = appInfoService.getLastestAppRelease(appType);
|
|
AppVersionRespDTO result = null;
|
if (appVersionInfo != null) {
|
result = new AppVersionRespDTO();
|
result.setId(appVersionInfo.getId());
|
result.setName(appVersionInfo.getName());
|
result.setInfo(appVersionInfo.getInfo());
|
result.setCustomVersion(appVersionInfo.getCustomVersion());
|
result.setVersion(appVersionInfo.getVersion());
|
result.setStatus(appVersionInfo.getStatus());
|
AppVersionStatusEnum statusEnum = AppVersionStatusEnum.parse(appVersionInfo.getStatus());
|
if (statusEnum != null) {
|
result.setStatusDesc(statusEnum.value);
|
}
|
result.setAppType(appVersionInfo.getAppType());
|
appTypeEnum = AppTypeEnum.parse(appVersionInfo.getAppType());
|
if (appTypeEnum != null) {
|
result.setAppTypeDesc(appTypeEnum.getValue());
|
}
|
result.setObjectName(appVersionInfo.getObjectName());
|
result.setObjectUrl(minioUtils.getAccessibleUrl(appFloder,appVersionInfo.getObjectName()));
|
result.setGmtCreate(appVersionInfo.getGmtCreate());
|
result.setCreateUid(appVersionInfo.getCreateUid());
|
result.setCreateUname(appVersionInfo.getCreateUname());
|
result.setGmtModified(appVersionInfo.getGmtModified());
|
result.setModifiedUid(appVersionInfo.getModifiedUid());
|
result.setModifiedUname(appVersionInfo.getModifiedUname());
|
}
|
|
return result;
|
}
|
}
|
