FTP异步处理

tangzy

2022-02-24 d4b00c05321d9373a33bfb26618735e2a5868a81

 src/main/java/org/springblade/modules/accreditation/service/impl/AccreditationRecordsServiceImpl.java

@@ -12,6 +12,8 @@
import org.springblade.modules.accreditation.mapper.AccreditationRecordsMapper;
import org.springblade.modules.accreditation.service.AccreditationRecordsService;
import org.springblade.modules.accreditation.vo.AccreditationRecordsVo;
import org.springblade.modules.system.service.MyAsyncService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.net.MalformedURLException;
@@ -25,15 +27,18 @@

/**
 * 制证记录服务实现类
 *
 * @author zhongrj
 */
@Service
@AllArgsConstructor
public class AccreditationRecordsServiceImpl extends ServiceImpl<AccreditationRecordsMapper, AccreditationRecords> implements AccreditationRecordsService {

   @Autowired
   private MyAsyncService myAsyncService;

   /**
    * 自定义分页
    *
    * @param page
    * @param accreditationRecords
    * @return
@@ -46,6 +51,7 @@

   /**
    * 制证申请(批量）
    *
    * @param accreditationRecords 制证记录信息对象
    */
   @Override
@@ -78,7 +84,8 @@
                  + "'" + records.getStatus() +"'" + ","
                  + "'" + records.getType() +"'" + ","
                  +"'" + records.getAuditStatus() + "'" + ")";
               FtpUtil.sqlFileUpload(s);
               //FtpUtil.sqlFileUpload(s);
               myAsyncService.FTP(s);
            }
         }
         //判断类型，如果是证书的，审核未通过的可以再次申请，审核通过的，暂时不给于新增记录
@@ -98,7 +105,8 @@
                  + "'" + records.getStatus() +"'" + ","
                  + "'" + records.getType() +"'" + ","
                  +"'" + records.getAuditStatus() + "'" + ")";
               FtpUtil.sqlFileUpload(s);
               //FtpUtil.sqlFileUpload(s);
               myAsyncService.FTP(s);
            }
         }

@@ -108,6 +116,7 @@

   /**
    * 自定义详情信息
    *
    * @param accreditationRecords
    * @return
    */
@@ -118,6 +127,7 @@

   /**
    * 导出保安员证信息
    *
    * @param accreditationRecords
    * @return
    */
@@ -186,6 +196,7 @@

   /**
    * 导出证书制证信息
    *
    * @param accreditationRecords
    * @return
    */
@@ -209,6 +220,7 @@

   /**
    * 批量修改为已制证
    *
    * @param accreditationRecords 制证记录信息对象
    */
   @Override
@@ -227,7 +239,8 @@
         String s =
            "update sys_accreditation_records set status = " + accreditationRecords.getStatus() + "" +
               "where id = " + "'" + accreditationRecords.getId() + "'";
         FtpUtil.sqlFileUpload(s);
         //FtpUtil.sqlFileUpload(s);
         myAsyncService.FTP(s);
      });
      return true;
   }