条款、服务协议、隐私政策 这些长text字段,为减缓宽带消耗,放到oss中加载
This commit is contained in:
parent
7370f1adf0
commit
59aba525f8
|
|
@ -78,4 +78,11 @@ public class AppCommonController {
|
|||
return Result.success();
|
||||
}
|
||||
|
||||
//@PutMapping("putAppUseKvToOss")
|
||||
//@ResponseBody
|
||||
public Result putAppUseKvToOss() {
|
||||
String data = commonService.putOss();
|
||||
return Result.success().put("data", data);
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -45,4 +45,6 @@ public interface CommonInfoService {
|
|||
Map<Integer,String> findAppKv();
|
||||
|
||||
void cleanAppKv();
|
||||
|
||||
String putOss();
|
||||
}
|
||||
|
|
@ -1,13 +1,20 @@
|
|||
package com.sqx.modules.common.service.impl;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import cn.hutool.core.io.FileUtil;
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import cn.hutool.json.JSONUtil;
|
||||
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.sqx.common.utils.RedisUtils;
|
||||
import com.sqx.common.utils.Result;
|
||||
import com.sqx.modules.common.dao.CommonInfoDao;
|
||||
import com.sqx.modules.common.entity.CommonInfo;
|
||||
import com.sqx.modules.common.service.CommonInfoService;
|
||||
import com.sqx.modules.course.service.CourseService;
|
||||
import com.sqx.modules.oss.cloud.OSSFactory;
|
||||
import com.sqx.modules.oss.entity.SysOssEntity;
|
||||
import com.sqx.modules.oss.service.SysOssService;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.cache.CacheManager;
|
||||
import org.springframework.cache.annotation.CacheConfig;
|
||||
|
|
@ -15,6 +22,7 @@ import org.springframework.cache.annotation.CacheEvict;
|
|||
import org.springframework.cache.annotation.Cacheable;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.io.File;
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.Date;
|
||||
import java.util.HashMap;
|
||||
|
|
@ -37,6 +45,10 @@ public class CommonInfoServiceImpl extends ServiceImpl<CommonInfoDao, CommonInfo
|
|||
|
||||
@Autowired
|
||||
private CacheManager cacheManager;
|
||||
@Autowired
|
||||
private SysOssService sysOssService;
|
||||
@Autowired
|
||||
private RedisUtils redisUtils;
|
||||
|
||||
|
||||
@CacheEvict(key = "#commonInfo.id")
|
||||
|
|
@ -91,17 +103,57 @@ public class CommonInfoServiceImpl extends ServiceImpl<CommonInfoDao, CommonInfo
|
|||
@Override
|
||||
@Cacheable("commonInfoAppKv")
|
||||
public Map<Integer, String> findAppKv() {
|
||||
List<CommonInfo> list = commonInfoDao.selectList(Wrappers.<CommonInfo>lambdaQuery().eq(CommonInfo::getIsAppUse, 1).orderByAsc(CommonInfo::getType).orderByAsc(CommonInfo::getId));
|
||||
List<CommonInfo> list = commonInfoDao.selectList(Wrappers.<CommonInfo>lambdaQuery()
|
||||
.eq(CommonInfo::getIsAppUse, 1)
|
||||
.orderByAsc(CommonInfo::getType)
|
||||
.orderByAsc(CommonInfo::getId));
|
||||
if (CollUtil.isEmpty(list)) {
|
||||
return new HashMap<>(0);
|
||||
}
|
||||
Map<Integer, String> data = list.stream().collect(Collectors.toMap(CommonInfo::getType, CommonInfo::getValue));
|
||||
String url = putOss();
|
||||
// 移除 条款、服务协议、隐私政策 这些长text字段,为减缓宽带消耗,放到oss中加载
|
||||
data.put(154, url);
|
||||
data.put(155, url);
|
||||
data.put(246, url);
|
||||
return data;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void cleanAppKv() {
|
||||
cacheManager.getCache("commonInfoAppKv").clear();
|
||||
redisUtils.delete(SYS_OSS_CONFIG_JSON_URL_KEY);
|
||||
}
|
||||
|
||||
private static final String SYS_OSS_CONFIG_JSON_URL_KEY = "SYS_OSS_CONFIG_JSON_URL";
|
||||
|
||||
@Override
|
||||
public String putOss() {
|
||||
String url = redisUtils.get(SYS_OSS_CONFIG_JSON_URL_KEY);
|
||||
if (StrUtil.isNotBlank(url)) {
|
||||
return url;
|
||||
}
|
||||
List<CommonInfo> list = commonInfoDao.selectList(Wrappers.<CommonInfo>lambdaQuery()
|
||||
.eq(CommonInfo::getIsAppUse, 1)
|
||||
.in(CommonInfo::getType, 154, 155, 246));
|
||||
if (CollUtil.isEmpty(list)) {
|
||||
return "";
|
||||
}
|
||||
Map<Integer, String> data = list.stream().collect(Collectors.toMap(CommonInfo::getType, CommonInfo::getValue));
|
||||
String jsonStr = JSONUtil.toJsonStr(data);
|
||||
File file = FileUtil.createTempFile("hutool", ".json", null, true);
|
||||
FileUtil.writeUtf8String(jsonStr, file);
|
||||
//上传文件
|
||||
String suffix = FileUtil.extName(file);
|
||||
url = OSSFactory.build().uploadSuffix(FileUtil.readBytes(file), "." + suffix);
|
||||
file.delete();
|
||||
//保存文件信息
|
||||
SysOssEntity ossEntity = new SysOssEntity();
|
||||
ossEntity.setUrl(url);
|
||||
ossEntity.setCreateDate(new Date());
|
||||
sysOssService.save(ossEntity);
|
||||
redisUtils.set(SYS_OSS_CONFIG_JSON_URL_KEY, url);
|
||||
return url;
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue