mirror of https://gitee.com/stylefeng/roses
1.整理代码
parent
d244e40b71
commit
79c680f810
|
@ -3,7 +3,6 @@ package cn.stylefeng.roses.kernel.migration.api.pojo;
|
||||||
import cn.stylefeng.roses.kernel.rule.pojo.request.BaseRequest;
|
import cn.stylefeng.roses.kernel.rule.pojo.request.BaseRequest;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
|
|
||||||
import javax.validation.constraints.NotBlank;
|
|
||||||
import javax.validation.constraints.NotNull;
|
import javax.validation.constraints.NotNull;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
|
@ -1,19 +1,15 @@
|
||||||
package cn.stylefeng.roses.kernel.migration.web.service.impl;
|
package cn.stylefeng.roses.kernel.migration.web.service.impl;
|
||||||
|
|
||||||
import cn.hutool.core.date.DateUtil;
|
|
||||||
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
||||||
import cn.hutool.core.util.URLUtil;
|
|
||||||
import cn.stylefeng.roses.kernel.migration.aggregation.scheduling.SchedulingCenter;
|
import cn.stylefeng.roses.kernel.migration.aggregation.scheduling.SchedulingCenter;
|
||||||
import cn.stylefeng.roses.kernel.migration.api.constants.MigrationConstants;
|
import cn.stylefeng.roses.kernel.migration.api.constants.MigrationConstants;
|
||||||
import cn.stylefeng.roses.kernel.migration.api.pojo.MigrationAggregationPOJO;
|
import cn.stylefeng.roses.kernel.migration.api.pojo.MigrationAggregationPOJO;
|
||||||
import cn.stylefeng.roses.kernel.migration.web.pojo.MigrationRequest;
|
import cn.stylefeng.roses.kernel.migration.web.pojo.MigrationRequest;
|
||||||
import cn.stylefeng.roses.kernel.migration.web.service.MigrationService;
|
import cn.stylefeng.roses.kernel.migration.web.service.MigrationService;
|
||||||
import cn.stylefeng.roses.kernel.rule.util.HttpServletUtil;
|
|
||||||
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSON;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.MultipartFile;
|
||||||
|
|
||||||
import javax.servlet.http.HttpServletResponse;
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.nio.charset.StandardCharsets;
|
import java.nio.charset.StandardCharsets;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
|
@ -80,7 +76,7 @@ public class MigrationServiceImpl implements MigrationService {
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void restoreData(MultipartFile file,String type) {
|
public void restoreData(MultipartFile file, String type) {
|
||||||
String jsonStr = null;
|
String jsonStr = null;
|
||||||
try {
|
try {
|
||||||
// 转换文件为String类型
|
// 转换文件为String类型
|
||||||
|
@ -90,7 +86,7 @@ public class MigrationServiceImpl implements MigrationService {
|
||||||
MigrationAggregationPOJO migrationAggregationPOJO = JSON.parseObject(jsonStr, MigrationAggregationPOJO.class);
|
MigrationAggregationPOJO migrationAggregationPOJO = JSON.parseObject(jsonStr, MigrationAggregationPOJO.class);
|
||||||
|
|
||||||
// 交给调度中心去调度
|
// 交给调度中心去调度
|
||||||
SchedulingCenter.importData(migrationAggregationPOJO,type);
|
SchedulingCenter.importData(migrationAggregationPOJO, type);
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue