blame | history | patch | commit | commitdiff | ignore whitespace
tangzy
2021-08-19 2cf76c21aa27bef90017ecfaa14abf066d5f28bc 
 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();


   }








}