优化代码

java110

2022-06-09 22d7512ecb341426ecaa5ac8d48d7aa2b37c1059

 service-job/src/main/java/com/java110/job/smo/DownloadFileFromFtpToTable.java

old mode 100644
new mode 100755
@@ -1,6 +1,5 @@
package com.java110.job.smo;

import com.java110.job.task.TaskSystemQuartz;
import com.java110.job.util.FTPClientTemplate;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
@@ -378,8 +377,8 @@
   /**
    * 分配每个线程处理的起止位置
    */
   public static List contSaveThreadContInfo(Map taskInfo) {
      List contlist = new ArrayList();
   public static List<Map<String,Long>> contSaveThreadContInfo(Map taskInfo) {
      List<Map<String,Long>> contlist = new ArrayList<Map<String,Long>>();
      try {
         RandomAccessFile raf = new RandomAccessFile(taskInfo.get("localfilename").toString(), "r");
         int tnum = Integer.valueOf(taskInfo.get("TNUM").toString());
@@ -399,7 +398,7 @@
            }
            for (int i = 0; i < tnum; i++) {
               if (i == tnum - 1) {
                  Map tmp = new HashMap();
                  Map<String,Long> tmp = new HashMap<String,Long>();
                  tmp.put("begin", begin);
                  tmp.put("end", filelen - 1);
                  contlist.add(tmp);
@@ -410,7 +409,7 @@
               if (end < begin) {
                  begin = 0;
                  end = begin;
                  Map tmp = new HashMap();
                  Map<String,Long> tmp = new HashMap<String,Long>();
                  tmp.put("begin", begin);
                  tmp.put("end", end);
                  contlist.add(tmp);
@@ -420,7 +419,7 @@
               while (end > 0) {
                  raf.seek(end);
                  if (raf.readByte() == '\n') {
                     Map tmp = new HashMap();
                     Map<String,Long> tmp = new HashMap<String,Long>();
                     tmp.put("begin", begin);
                     tmp.put("end", end);
                     contlist.add(tmp);