|
|
|
@ -9,15 +9,12 @@ import cn.hutool.extra.ssh.JschUtil;
|
|
|
|
|
import cn.hutool.extra.ssh.Sftp;
|
|
|
|
|
import cn.hutool.http.HttpRequest;
|
|
|
|
|
import cn.hutool.http.HttpResponse;
|
|
|
|
|
import cn.hutool.poi.excel.ExcelUtil;
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
|
|
import com.google.common.collect.Lists;
|
|
|
|
|
import com.jcraft.jsch.Session;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import me.zhengjie.exception.BadRequestException;
|
|
|
|
|
import me.zhengjie.modules.upload.domain.UploadFile;
|
|
|
|
|
import me.zhengjie.modules.upload.service.dto.UploadFileDto;
|
|
|
|
|
import me.zhengjie.modules.upload.task.model.ResponseEncryptJsonContent;
|
|
|
|
|
import me.zhengjie.modules.upload.task.model.SendEncryptJsonContent;
|
|
|
|
|
import me.zhengjie.modules.upload.task.model.SendRemoteUpdateJsonContent;
|
|
|
|
@ -49,8 +46,8 @@ import java.util.Map;
|
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
|
|
import static me.zhengjie.modules.upload.consts.SysConst.*;
|
|
|
|
|
import static me.zhengjie.modules.upload.consts.SysConst.REMOTE_TRANS_DIR_PATH;
|
|
|
|
|
import static me.zhengjie.modules.upload.consts.UploadFileConst.*;
|
|
|
|
|
import static me.zhengjie.modules.upload.consts.UploadFileConst.FAIL_TAG;
|
|
|
|
|
import static me.zhengjie.modules.upload.consts.UploadFileConst.SUCCESS_TAG;
|
|
|
|
|
|
|
|
|
|
@Component
|
|
|
|
|
@Scope("prototype")
|
|
|
|
@ -224,7 +221,7 @@ public class SaveToFileNewTask {
|
|
|
|
|
String responseStr = httpResponse.body();
|
|
|
|
|
// 解析返回的结果,并写回本地
|
|
|
|
|
if (!parseResponseStr(filePath, responseStr)) {
|
|
|
|
|
log.error("========== [ SaveToFileTask|batchSendToEncrypt parse fail ] ==========");
|
|
|
|
|
log.error("========== [ SaveToFileTask|batchSendToEncrpt parse fail ] ==========");
|
|
|
|
|
booleanTag = false;
|
|
|
|
|
}
|
|
|
|
|
break;
|
|
|
|
|