提交 b1c789b9 authored 作者: hzh's avatar hzh

Merge branch 'dev'

package org.dromara.server.service.impl; package org.dromara.server.service.impl;
import cn.hutool.core.io.FileUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
...@@ -18,7 +17,11 @@ import org.dromara.server.mapper.ProcessConfigMapper; ...@@ -18,7 +17,11 @@ import org.dromara.server.mapper.ProcessConfigMapper;
import org.dromara.server.service.IProcessConfigService; import org.dromara.server.service.IProcessConfigService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.io.File; import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.nio.charset.StandardCharsets;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
...@@ -58,18 +61,29 @@ public class ProcessConfigServiceImpl extends AbstractBaseService<ProcessConfigV ...@@ -58,18 +61,29 @@ public class ProcessConfigServiceImpl extends AbstractBaseService<ProcessConfigV
.ifPresent(pk -> { .ifPresent(pk -> {
if (StringUtils.equals(pk.getKey(), ProcessKey.PROCESS_KEY_TRAVEL.getKey())) { if (StringUtils.equals(pk.getKey(), ProcessKey.PROCESS_KEY_TRAVEL.getKey())) {
File file = FileUtil.file("process/travel_apply.json"); // 使用类加载器加载资源文件
String json = FileUtil.readString(file, "UTF-8"); try (InputStream inputStream = ProcessConfigServiceImpl.class.getClassLoader().getResourceAsStream("process/travel_apply.json");
List<Process> processList = JSON.parseArray(json, Process.class); InputStreamReader inputStreamReader = new InputStreamReader(inputStream, StandardCharsets.UTF_8);
BufferedReader reader = new BufferedReader(inputStreamReader)) {
StringBuilder content = new StringBuilder();
String line;
while ((line = reader.readLine()) != null) {
content.append(line);
}
String json = content.toString();
List<Process> processList = JSON.parseArray(json, Process.class);
TenantHelper.ignore(()->{ TenantHelper.ignore(() -> {
ProcessConfig pc = new ProcessConfig() ProcessConfig pc = new ProcessConfig()
.setProcessKey(pk.getKey()) .setProcessKey(pk.getKey())
.setProcessName(pk.getDesc()) .setProcessName(pk.getDesc())
.setProcess(JSON.toJSONString(processList)); .setProcess(JSON.toJSONString(processList));
pc.setTenantId(tenantId); pc.setTenantId(tenantId);
baseMapper.insert(pc); baseMapper.insert(pc);
}); });
} catch (IOException e) {
e.printStackTrace();
}
} }
}); });
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论