From 2cf76c21aa27bef90017ecfaa14abf066d5f28bc Mon Sep 17 00:00:00 2001
From: tangzy <tangzy123456>
Date: Thu, 19 Aug 2021 17:50:04 +0800
Subject: [PATCH] 1.单位
---
src/main/java/org/springblade/modules/information/controller/InformationController.java | 103 ++++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 92 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 1220323..a55c9ec 100644
--- a/src/main/java/org/springblade/modules/information/controller/InformationController.java
+++ b/src/main/java/org/springblade/modules/information/controller/InformationController.java
@@ -16,16 +16,17 @@
*/
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 com.google.gson.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
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.common.utils.FtpUtil;
+import org.springblade.common.utils.OutJson;
import org.springblade.core.boot.ctrl.BladeController;
import org.springblade.core.cache.utils.CacheUtil;
import org.springblade.core.excel.util.ExcelUtil;
@@ -39,18 +40,12 @@
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 +113,6 @@
}
-
/**
* 新增
*/
@@ -180,7 +174,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));
@@ -312,4 +306,91 @@
// }
+ @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 = "";
+ //本地路径
+ String localPath = "D:\\anbao";
+ //文件名
+ String fileName = "sql.json";
+ FtpUtil.downloadFtpFile(ftpHost, ftpUserName, ftpPassword, ftpPort, ftpPath, localPath, fileName);
+ String s = TestJson();
+ System.out.println(s);
+ }
+
+
+ public static String TestJson(){
+ File file = new File("D:\\anbao\\sql.json");
+ StringBuilder localStrBulider = new StringBuilder();
+ if(file.isFile() && file.exists()) {
+ try {
+ InputStreamReader inputStreamReader = new InputStreamReader(new FileInputStream(file), "utf-8");
+ BufferedReader bufferReader = new BufferedReader(inputStreamReader);
+ String lineStr = null;
+ try {
+ while((lineStr = bufferReader.readLine()) != null) {
+ localStrBulider.append(lineStr);
+ }
+ bufferReader.close();
+ inputStreamReader.close();
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ System.out.println("file read error!");
+ e.printStackTrace();
+ }
+ } catch (UnsupportedEncodingException e) {
+ // TODO Auto-generated catch block
+ System.out.println("file catch unsupported encoding!");
+ e.printStackTrace();
+ } catch (FileNotFoundException e) {
+ // TODO Auto-generated catch block
+ System.out.println("file not found!");
+ e.printStackTrace();
+ }
+ }else {
+ System.out.println("file is not a file or file is not existing!");
+ }
+ return localStrBulider.toString();
+ }
+
+
+
}
--
Gitblit v1.9.3