From 568025796c345fe0fdb7daf90b0d0f01f73ab9fc Mon Sep 17 00:00:00 2001
From: tangzy <tangzy123456>
Date: Sat, 21 Aug 2021 09:19:30 +0800
Subject: [PATCH] 1.ftp
---
src/main/java/org/springblade/modules/information/controller/InformationController.java | 79 ++++++++++++++++++++++++++++++++++-----
1 files changed, 68 insertions(+), 11 deletions(-)
diff --git a/src/main/java/org/springblade/modules/information/controller/InformationController.java b/src/main/java/org/springblade/modules/information/controller/InformationController.java
index 4b19187..2d14353 100644
--- a/src/main/java/org/springblade/modules/information/controller/InformationController.java
+++ b/src/main/java/org/springblade/modules/information/controller/InformationController.java
@@ -16,7 +16,6 @@
*/
package org.springblade.modules.information.controller;
-import com.alibaba.fastjson.serializer.SerializerFeature;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import io.swagger.annotations.Api;
@@ -25,7 +24,6 @@
import com.alibaba.fastjson.JSON;
import org.springblade.common.cache.DictCache;
import org.springblade.common.enums.DictEnum;
-import org.springblade.common.utils.arg;
import org.springblade.core.boot.ctrl.BladeController;
import org.springblade.core.cache.utils.CacheUtil;
import org.springblade.core.excel.util.ExcelUtil;
@@ -33,24 +31,20 @@
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.support.Kv;
+import org.springblade.modules.FTP.FtpUtil;
+import org.springblade.modules.FTP.OutJson;
import org.springblade.modules.information.entity.Information;
import org.springblade.modules.information.excel.InforExcel;
import org.springblade.modules.information.excel.InforImporter;
import org.springblade.modules.information.service.IInformationService;
import org.springblade.modules.information.vo.InformationVO;
import org.springblade.modules.system.entity.Dept;
-import org.springblade.modules.system.excel.UserExcel;
-import org.springblade.modules.system.excel.UserImporter;
import org.springblade.modules.system.service.IDeptService;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.OutputStreamWriter;
-import java.io.Writer;
-import java.lang.reflect.Field;
+import java.io.*;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -118,7 +112,6 @@
}
-
/**
* 新增
*/
@@ -163,6 +156,15 @@
dept.setAncestors("0,1420222961377357825");
dept.setDeptCategory(1);
}
+ //跨区域保安公司
+ if (information.getStats().equals("4")) {
+ Long i = 1425366663452196865L;
+ dept.setParentId(i);
+ dept.setTenantId("000000");
+ dept.setDeptName(information.getEnterprisename());
+ dept.setAncestors("0,1425366663452196865");
+ dept.setDeptCategory(1);
+ }
if (iDeptService.submit(dept)) {
CacheUtil.clear(SYS_CACHE);
// 返回懒加载树更新节点所需字段
@@ -171,7 +173,7 @@
String id = kv.get("id").toString();
information.setDepartmentid(id);
}
- String json=JSON.toJSONString(information);
+ //String json=JSON.toJSONString(information);
//com.util.OutJson.createJsonFile(json,"d:/anbao/information/","informationSave");
//arg.test01(arg.url + "/information/save", information);
return R.status(informationService.save(information));
@@ -303,4 +305,59 @@
// }
+ @PostMapping("ss")
+ public void ss() throws FileNotFoundException {
+ //ftp服务器IP地址
+ String ftpHost = "192.168.0.105";
+ //ftp服务器端口
+ int ftpPort = 21;
+ //ftp服务器用户名
+ String ftpUserName = "yly";
+ //ftp服务器密码
+ String ftpPassword = "Yly@123";
+ //ftp服务器路径
+ String ftpPath = "";
+ //本地路径
+ String localPath = "D:\\anbao";
+ //文件名
+ String fileName = "sql.json";
+ Information information = new Information();
+ information.setCreditcode("1");
+ informationService.insertIn(information);
+ Integer id = information.getId();
+ String s = "insert into sys_information(id,creditcode) values(" + "'" + id + "'" + "," + "'" + 1 + "'" + ")";
+ System.out.println(s);
+ Object o = s;
+ String json = JSON.toJSONString(o);
+ OutJson.createJsonFile(json, "d:/", "sql");
+ FileInputStream in = new FileInputStream(new File("D:\\" + fileName));
+ FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/", fileName, in);
+ }
+
+
+ public static void main(String[] args) throws Exception {
+ //ftp服务器IP地址
+ String ftpHost = "192.168.0.105";
+ //ftp服务器端口
+ int ftpPort = 21;
+ //ftp服务器用户名
+ String ftpUserName = "yly";
+ //ftp服务器密码
+ String ftpPassword = "Yly@123";
+ //ftp服务器路径
+ String ftpPath = "anbao/sql.json";
+ //本地路径
+ String localPath = "D:\\anbao";
+ //文件名
+ String fileName = "sql.json";
+// FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
+ String s = OutJson.TestJson();
+ String sql = OutJson.stringReplace(s);
+ System.out.println(sql);
+ //boolean ftpFileExist = FtpUtil.isFTPFileExist(ftpPath, ftpUserName, ftpPassword, ftpHost, ftpPort);
+ //System.out.println(ftpFileExist);
+ }
+
+
+
}
--
Gitblit v1.9.3