package com.qianwen.smartman.modules.visual.service.impl;
|
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.FileNotFoundException;
|
import java.io.IOException;
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
import java.util.stream.Stream;
|
|
import org.apache.commons.io.FileUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.qianwen.core.log.exception.ServiceException;
|
import com.qianwen.core.mp.base.BaseServiceImpl;
|
import com.qianwen.core.oss.model.BladeFile;
|
import com.qianwen.smartman.common.utils.Lambda;
|
import com.qianwen.smartman.modules.resource.builder.oss.OssBuilder;
|
import com.qianwen.smartman.modules.resource.service.IOssService;
|
import com.qianwen.smartman.modules.visual.dto.VisualDTO;
|
import com.qianwen.smartman.modules.visual.dto.VisualDownloadDTO;
|
import com.qianwen.smartman.modules.visual.entity.Visual;
|
import com.qianwen.smartman.modules.visual.entity.VisualConfig;
|
import com.qianwen.smartman.modules.visual.mapper.VisualMapper;
|
import com.qianwen.smartman.modules.visual.service.IVisualConfigService;
|
import com.qianwen.smartman.modules.visual.service.IVisualGlobalApiService;
|
import com.qianwen.smartman.modules.visual.service.IVisualService;
|
import com.qianwen.smartman.modules.visual.utils.VisualUtils;
|
import com.qianwen.smartman.modules.visual.vo.VisualInfoVO;
|
|
import cn.hutool.core.io.FileUtil;
|
import cn.hutool.core.util.ZipUtil;
|
|
@Service
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/visual/service/impl/VisualServiceImpl.class */
|
public class VisualServiceImpl extends BaseServiceImpl<VisualMapper, Visual> implements IVisualService {
|
private final IVisualConfigService configService;
|
private final IVisualGlobalApiService globalApiService;
|
private final OssBuilder ossBuilder;
|
private final IOssService ossService;
|
|
|
public VisualServiceImpl(final IVisualConfigService configService, final IVisualGlobalApiService globalApiService, final OssBuilder ossBuilder, final IOssService ossService) {
|
this.configService = configService;
|
this.globalApiService = globalApiService;
|
this.ossBuilder = ossBuilder;
|
this.ossService = ossService;
|
}
|
|
@Override // org.springblade.modules.visual.service.IVisualService
|
public VisualDTO detail(Long id) {
|
Visual visual = (Visual) getById(id);
|
VisualConfig visualConfig = this.configService.getOne(Wrappers.<VisualConfig>query().lambda().eq(VisualConfig::getVisualId, id));
|
/*
|
VisualConfig visualConfig = (VisualConfig) this.configService.getOne((Wrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getVisualId();
|
}, id));*/
|
VisualDTO dto = new VisualDTO();
|
dto.setVisual(visual);
|
dto.setConfig(visualConfig);
|
dto.setNextId(getGroupNextVisual(visual));
|
dto.setPrevId(getGroupPrevVisual(visual));
|
return dto;
|
}
|
|
private Long getGroupNextVisual(Visual visual) {
|
if (StringUtils.isEmpty(visual.getGroupName())) {
|
return null;
|
}
|
List<Visual> list = list(Lambda.eq(Visual::getGroupName, visual.getGroupName()).orderByAsc(Visual::getGroupIndex));
|
/*
|
List<Visual> list = list((Wrapper) Lambda.eq((v0) -> {
|
return v0.getGroupName();
|
}, visual.getGroupName()).orderByAsc((v0) -> {
|
return v0.getGroupIndex();
|
}));*/
|
if (list.size() <= 1) {
|
return null;
|
}
|
return (Long) list.stream().filter(item -> {
|
return item.getGroupIndex().intValue() > visual.getGroupIndex().intValue();
|
}).findFirst().map(item2 -> {
|
return item2.getId();
|
}).orElseGet(() -> {
|
return ((Visual) list.get(0)).getId();
|
});
|
}
|
|
private Long getGroupPrevVisual(Visual visual) {
|
if (StringUtils.isEmpty(visual.getGroupName())) {
|
return null;
|
}
|
List<Visual> list = list(Lambda.eq(Visual::getGroupName, visual.getGroupName()).orderByDesc(Visual::getGroupIndex));
|
/*
|
List<Visual> list = list((Wrapper) Lambda.eq((v0) -> {
|
return v0.getGroupName();
|
}, visual.getGroupName()).orderByDesc((v0) -> {
|
return v0.getGroupIndex();
|
}));*/
|
if (list.size() <= 1) {
|
return null;
|
}
|
return (Long) list.stream().filter(item -> {
|
return item.getGroupIndex().intValue() < visual.getGroupIndex().intValue();
|
}).findFirst().map(item2 -> {
|
return item2.getId();
|
}).orElseGet(() -> {
|
return list.get(0).getId();
|
});
|
}
|
|
@Override // org.springblade.modules.visual.service.IVisualService
|
@Transactional(rollbackFor = {Exception.class})
|
public boolean saveVisual(VisualDTO dto) {
|
Visual visual = dto.getVisual();
|
VisualConfig visualConfig = dto.getConfig();
|
boolean tempV = save(visual);
|
visualConfig.setVisualId(visual.getId());
|
boolean tempVc = this.configService.save(visualConfig);
|
this.globalApiService.updateVisualId(visual, dto.getGlobalApiId());
|
return tempV && tempVc;
|
}
|
|
@Override // org.springblade.modules.visual.service.IVisualService
|
@Transactional(rollbackFor = {Exception.class})
|
public boolean updateVisual(VisualDTO dto) {
|
Visual visual = dto.getVisual();
|
VisualConfig visualConfig = dto.getConfig();
|
if (visual != null && visual.getId() != null) {
|
updateById(visual);
|
}
|
if (visualConfig != null && visualConfig.getId() != null) {
|
this.configService.updateById(visualConfig);
|
return true;
|
}
|
return true;
|
}
|
|
@Override // org.springblade.modules.visual.service.IVisualService
|
@Transactional(rollbackFor = {Exception.class})
|
public Long copyVisual(Long id) {
|
Visual visual = (Visual) getById(id);
|
|
VisualConfig visualConfig = (VisualConfig)this.configService.getOne(Wrappers.<VisualConfig>query().lambda().eq(VisualConfig::getVisualId, id));
|
/*
|
VisualConfig visualConfig = (VisualConfig) this.configService.getOne((Wrapper) Wrappers.query().lambda().eq((v0) -> {
|
return v0.getVisualId();
|
}, id));*/
|
if (visual != null && visualConfig != null) {
|
visual.setId(null);
|
visualConfig.setId(null);
|
VisualDTO dto = new VisualDTO();
|
dto.setVisual(visual);
|
dto.setConfig(visualConfig);
|
boolean temp = saveVisual(dto);
|
if (temp) {
|
return visual.getId();
|
}
|
return null;
|
}
|
return null;
|
}
|
|
@Override // org.springblade.modules.visual.service.IVisualService
|
@Transactional
|
public Long visualImport(final VisualDTO visualDTO) {
|
Visual visual = visualDTO.getVisual();
|
VisualConfig visualConfig = visualDTO.getConfig();
|
if (visual != null && visualConfig != null) {
|
visual.setId(null);
|
visualConfig.setId(null);
|
boolean temp = saveVisual(visualDTO);
|
if (temp) {
|
return visual.getId();
|
}
|
return null;
|
}
|
return null;
|
}
|
|
@Override // org.springblade.modules.visual.service.IVisualService
|
public List<VisualInfoVO> detailsByCatalog(Integer catalogId) {
|
List<Visual> list = list(Lambda.eq((catalogId != null), Visual::getCategory, catalogId)
|
.select(Visual::getId, Visual::getTitle, Visual::getBackgroundUrl ));
|
/*
|
List<Visual> list = list(Lambda.eq(catalogId != null, (v0) -> {
|
return v0.getCategory();
|
}, catalogId).select((v0) -> {
|
return v0.getId();
|
}, (v0) -> {
|
return v0.getTitle();
|
}, (v0) -> {
|
return v0.getBackgroundUrl();
|
}));*/
|
if (list == null || list.isEmpty()) {
|
return Collections.emptyList();
|
}
|
List<Long> visualIds = list.stream().map((v0) -> {
|
return v0.getId();
|
}).collect(Collectors.toList());
|
List<VisualConfig> config = this.configService.list(Lambda.in((v0) -> {
|
return v0.getVisualId();
|
}, visualIds));
|
return config.stream().map(item -> {
|
Visual match = (Visual) list.stream().filter(visual -> {
|
return visual.getId().equals(item.getVisualId());
|
}).findFirst().orElse(null);
|
return new VisualInfoVO(match != null ? match.getTitle() : "", match != null ? match.getBackgroundUrl() : "", item.getDetail(), item.getComponent());
|
}).collect(Collectors.toList());
|
}
|
|
@Override // org.springblade.modules.visual.service.IVisualService
|
public BladeFile visualZipDownload(List<Long> visualIds) throws FileNotFoundException {
|
List<Visual> visualList = list(Lambda.in((v0) -> {
|
return v0.getId();
|
}, visualIds));
|
List<VisualConfig> configList = this.configService.list(Lambda.in((v0) -> {
|
return v0.getVisualId();
|
}, visualIds));
|
List<String> jsText = new ArrayList<>();
|
visualList.parallelStream().forEach(visual -> {
|
String visualStr = JSONObject.toJSONString(visual);
|
configList.parallelStream().forEach(config -> {
|
VisualDownloadDTO downloadDTO = new VisualDownloadDTO(visualStr, config.getDetail(), config.getComponent());
|
jsText.add(downloadDTO.toString());
|
});
|
});
|
FileInputStream fileInputStream = null;
|
try {
|
File tempFile = VisualUtils.visualDownload((String[]) jsText.toArray(new String[0]));
|
fileInputStream = new FileInputStream(tempFile);
|
BladeFile bladeFile = this.ossBuilder.tempTemplate().putFile(tempFile.getName(), fileInputStream);
|
tempFile.deleteOnExit();
|
if (fileInputStream != null) {
|
try {
|
fileInputStream.close();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
return bladeFile;
|
} catch (Throwable th) {
|
if (fileInputStream != null) {
|
try {
|
fileInputStream.close();
|
} catch (IOException e2) {
|
e2.printStackTrace();
|
}
|
}
|
throw th;
|
}
|
}
|
|
@Override // org.springblade.modules.visual.service.IVisualService
|
public void visualZipImport(MultipartFile zipFile, Integer category) {
|
String localFileName = IdWorker.get32UUID() + ".zip";
|
File localZipFile = new File("static/visual/" + localFileName);
|
try {
|
FileUtils.copyToFile(zipFile.getInputStream(), localZipFile);
|
} catch (IOException e) {
|
log.error("可视化导入错误",e);
|
throw new ServiceException("可视化导入错误"+e.getMessage());
|
}
|
visualZipImport(localZipFile, category);
|
}
|
|
@Override // org.springblade.modules.visual.service.IVisualService
|
public void visualZipImport(File zipFile, Integer category) {
|
File distFile = ZipUtil.unzip(zipFile);
|
File[] files = distFile.listFiles();
|
File imagesDir = (File) Stream.of(files).filter(file -> {
|
return file.isDirectory() && "images".equalsIgnoreCase(file.getName());
|
}).findFirst().orElse(null);
|
if (imagesDir == null) {
|
String[] jsFilesText = (String[]) Stream.of( files).filter(file2 -> {
|
return file2.isFile() && file2.getName().endsWith("js");
|
}).map(item -> {
|
return FileUtil.readString(item, "utf-8");
|
}).toArray(x -> {
|
return new String[x];
|
});
|
File distFile2 = VisualUtils.visualDownload(jsFilesText);
|
visualZipImport(distFile2, category);
|
return;
|
}
|
String[] replaceText = VisualUtils.visualFileUpload(files);
|
List<VisualDTO> dtoList = VisualUtils.createVisualDTO(category, replaceText);
|
dtoList.parallelStream().forEach(dto -> {
|
visualImport(dto);
|
});
|
}
|
}
|
