完整实现ftp上传与下载并解析csv文件

/*package com.task.service.impl; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.io.InputStreamReader; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Properties; import java.util.UUID; import java.util.Vector; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.shiro.crypto.hash.Md5Hash; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.jcraft.jsch.Channel; import com.jcraft.jsch.ChannelSftp; import com.jcraft.jsch.JSch; import com.jcraft.jsch.JSchException; import com.jcraft.jsch.Session; import com.jcraft.jsch.SftpException; import com.task.bean.GridInfo; import com.task.bean.GridLog; import com.task.bean.GridPersonInfo; import com.task.bean.GridType; import com.task.bean.Pojo; import com.task.bean.Staff; import com.task.bean.StaffLog; import com.task.bean.SysOrg; import com.task.bean.SysStaffOrg; import com.task.mapper.GridInfoMapper; import com.task.service.GridInfoService; import com.task.test.ReadProperties; @Service public class GridInfoServiceImpl implements GridInfoService { @Autowired private GridInfoMapper gridInfoMapper; private String localPathss = ""; // @Test public void readGridInfo(String localFilePath, String batchNo, int a) { System.out.println("localPathss:::::::::::::::::::::::::::==" + localPathss); List<String> list = new ArrayList<>(); try { FileInputStream in = new FileInputStream(localFilePath); // FileInputStream in = new // FileInputStream("E:\\nmg/unit20180601.csv"); BufferedReader reader = new BufferedReader(new InputStreamReader(in, "GBK")); reader.readLine();// 第一行信息，为标题信息，不用,如果需要，注释掉 String line = null; while ((line = reader.readLine()) != null) { String [] lines = line.split(","); if(lines.length==11){ list.add(line.replace("\"", "")); } } reader.close(); int listSize = list.size(); //去重 for (int i = 0; i < list.size() - 1; i++) { for (int j = list.size() - 1; j > i; j--) { if (list.get(j).equals(list.get(i))) { list.remove(j); } } } if (listSize != 0) { for (int k = 0; k < list.size(); k++) { System.out.println("KKKKK==" + list.get(k)); String item[] = list.get(k).split(",");// CSV格式文件为逗号分隔符文件，这里根据逗号切分 // for (int i = 0; i < item.length; i++) { System.out.println("item==============================" + item[0]); StringBuffer errorInfo = new StringBuffer(); GridLog gridLog = new GridLog(); if (item[0].equals("") || item[0] == null) { errorInfo.append("网格名称不能为空！"); } if (item[1].equals("") || item[1] == null) { errorInfo.append("网格编码不能为空！"); } if (item[5].equals("") || item[5] == null) { errorInfo.append("归属地市编码不能为空！"); } if (item[7].equals("") || item[7] == null) { errorInfo.append("归属区县编码不能为空！"); } if (item[8].equals("") || item[8] == null) { errorInfo.append("是否有效不能为空！"); } System.out.println("item[8]:"+item[8]); * if(item[8].equals("") || item[8]==null){ * errorInfo.append("网格分类不能为空！"); } // 根据网格Code查询分类 GridType gridType = gridInfoMapper.selectGridTypeInfo(item[9]); String county = gridInfoMapper.transCountyCode(item[7]); GridInfo grid =null; if(county!=null){ grid = gridInfoMapper.transCityCode(county); } // 如果错误提示信息为0，则进行保存或者修改操作 if (errorInfo.length() == 0 && gridType!=null) { if(!"".equals(county)){ if(grid!=null){ GridInfo gridInfo = new GridInfo(); gridInfo.setGridName(item[0]);// 网格名称 gridInfo.setGridId(item[1]);// 网格编码 gridInfo.setCityCode(grid.getCityCode());// 归属地市编码 // gridInfo.setCountyCode(item[5]);// 归属区县编码 // 区县编码进行转换 gridInfo.setCountyCode(gridInfoMapper.transCountyCode(item[7]));// 归属区县编码 // gridInfoMapper.transCountyCode(item[5]); if ("0".equals(item[8])) { gridInfo.setStatus("1");// 是否有效 } if ("1".equals(item[8])) { gridInfo.setStatus("0");// 是否有效 } gridInfo.setGridSubCategory(gridType.getZqZhin());// 网格细类 gridInfo.setGridCategory(gridType.getGridBussType());// 网格分类 gridInfo.setCreatedBy(10010); gridInfo.setLastUpdatedBy(10010); // System.out.println("item"+item[i]+":"+item[1]); // 根据网格编码查询是否地数据库存在，如果不存在则新增，存在则修改 int count = gridInfoMapper.searchGridInfoByGridId(item[1]); if (count == 0) {// 保存 int ii = gridInfoMapper.saveGridInfo(gridInfo); if (ii > 0) {// 进行添加日志操作 gridLog.setLogId(UUID.randomUUID() + ""); gridLog.setGridName(item[0]);// 网格名称 gridLog.setGridId(item[1]);// 网格编码 gridLog.setCityCode(grid.getCityCode());// 归属地市编码 gridLog.setCountyCode(gridInfoMapper.transCountyCode(item[7]));// 归属区县编码 gridLog.setStatus(item[8]);// 是否有效 gridLog.setFlag("true"); gridLog.setFlagInfo("添加成功"); gridLog.setBatchNo(batchNo); gridInfoMapper.saveGridLog(gridLog); } else { gridLog.setLogId(UUID.randomUUID() + ""); gridLog.setGridName(item[0]);// 网格名称 gridLog.setGridId(item[1]);// 网格编码 gridLog.setCityCode(grid.getCityCode());// 归属地市编码 gridLog.setCountyCode(gridInfoMapper.transCountyCode(item[7]));// 归属区县编码 gridLog.setStatus(item[8]);// 是否有效 gridLog.setFlag("false"); gridLog.setFlagInfo("添加失败"); gridLog.setBatchNo(batchNo); gridInfoMapper.saveGridLog(gridLog); } } else {// 修改 int ii = gridInfoMapper.updateGridInfo(gridInfo); if (ii > 0) { gridLog.setLogId(UUID.randomUUID() + ""); gridLog.setGridName(item[0]);// 网格名称 gridLog.setGridId(item[1]);// 网格编码 gridLog.setCityCode(grid.getCityCode());// 归属地市编码 gridLog.setCountyCode(gridInfoMapper.transCountyCode(item[7]));// 归属区县编码 gridLog.setStatus(item[8]);// 是否有效 gridLog.setFlag("true"); gridLog.setFlagInfo("修改成功"); gridLog.setBatchNo(batchNo); gridInfoMapper.saveGridLog(gridLog); } else { gridLog.setLogId(UUID.randomUUID() + ""); gridLog.setGridName(item[0]);// 网格名称 gridLog.setGridId(item[1]);// 网格编码 gridLog.setCityCode(grid.getCityCode());// 归属地市编码 gridLog.setCountyCode(gridInfoMapper.transCountyCode(item[7]));// 归属区县编码 gridLog.setStatus(item[8]);// 是否有效 gridLog.setFlag("false"); gridLog.setFlagInfo("修改失败"); gridLog.setBatchNo(batchNo); gridInfoMapper.saveGridLog(gridLog); } } }else{ gridLog.setLogId(UUID.randomUUID() + ""); gridLog.setGridName(item[0]);// 网格名称 gridLog.setGridId(item[1]);// 网格编码 gridLog.setC