Merge remote-tracking branch 'origin/test' into test

src/main/java/com/sqx/modules/common/controller/app/AppCommonController.java

@@ -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);
+    }
+
 }

src/main/java/com/sqx/modules/common/service/CommonInfoService.java

@@ -45,4 +45,6 @@ public interface CommonInfoService {
     Map<Integer,String> findAppKv();
 
     void cleanAppKv();
+
+    String putOss();
 }

src/main/java/com/sqx/modules/common/service/impl/CommonInfoServiceImpl.java

@@ -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;
     }
 
 }