湖北消金 - 保存请求和发送的的原始文件

src/main/java/cn/quantgroup/financial/service/impl/HuBeiServiceImpl.java

@@ -35,6 +35,9 @@ import javax.xml.parsers.ParserConfigurationException;
 import javax.xml.transform.TransformerException;
 import java.io.*;
 import java.math.BigDecimal;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -50,6 +53,9 @@ public class HuBeiServiceImpl implements IHuBeiService {
     @Value("${spring.mail.username}")
     private String sender;
 
+    @Value("${hubei.history.filepath}")
+    private String hubeiHistoryFilePath;
+
 
     @Autowired
     private IHuBeiDispatcher huBeiHandlerDispatcher;
@@ -151,9 +157,12 @@ public class HuBeiServiceImpl implements IHuBeiService {
         }
         logger.info("apiUrl={}, requestBody={}",hubeiApiUrl,requestBody);
         requestMap.put(HubeiCFCField.xmlString,requestBody);
+        String filePre = docName==null?dataType.get()+"_":dataType.get()+"_"+docName;
+        saveHistoryFile(requestBody,filePre+"_request");
         HttpResult httpResult = NetUtil.postRequestUrl(hubeiApiUrl,requestMap,headerMap, SysConstant.retryOneNums);
         if(httpResult.getStatus()==NetUtil.RequestStatus.SUCCESS_STATUS){
             String responseBody = httpResult.getResult();
+            saveHistoryFile(responseBody,filePre+"_response");
             if(logger.isDebugEnabled()){
                 logger.info("responseBody={}",responseBody);
             }
@@ -170,6 +179,7 @@ public class HuBeiServiceImpl implements IHuBeiService {
                 DataSource dataSource = null;
                 switch (dataType){
                     case SEND_DEBIT:
+                    case SEND_ADVANCE_REPAYMENT_CHECK:
                         //发送送盘文件 邮件
                         dataSource = iMailService.getDataSource(new String(Base64.decodeBase64(response.getFileConent())),response.getFileName());
                         sendMailAttachment(dataType,new ArrayList<DataSource>(Arrays.asList(dataSource)));
@@ -178,7 +188,6 @@ public class HuBeiServiceImpl implements IHuBeiService {
                     case RETURN_ADVANCE_REPAYMENT:
                     case RETURN_BATCH_DEBIT:
                     case RETURN_BATCH_COMPENSATION:
-                    case SEND_ADVANCE_REPAYMENT_CHECK:
                         //发送回盘 邮件
                         dataSource = iMailService.getDataSource(new String(Base64.decodeBase64(huBeiCFCRequest.getFileConent())),huBeiCFCRequest.getFileName());
                         sendMailAttachment(dataType,new ArrayList<DataSource>(Arrays.asList(dataSource)));
@@ -309,6 +318,7 @@ public class HuBeiServiceImpl implements IHuBeiService {
     public void saveResponseData(HuBeiCFCResponse response, HubeiCFCDataType type) throws ServerErrorException {
         logger.info("saveResponseData method is called");
         String line = null;
+        saveHistoryFile(response.getFileConent(),response.getFileName());
         try(BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(new ByteArrayInputStream(Base64.decodeBase64(response.getFileConent()))))) {
             HuBeiDocName docName = new HuBeiDocName();
             docName.setDocName(response.getFileName());
@@ -797,5 +807,40 @@ public class HuBeiServiceImpl implements IHuBeiService {
         return huBeiDocName;
     }
 
+    /**
+     * 保存发送和接收的内容方便历史查询
+     * @param fileContent
+     * @param fileName
+     */
+    public void saveHistoryFile(String fileContent,String fileName){
+        if(StringUtils.isEmpty(fileContent)||StringUtils.isEmpty(fileName)){
+            logger.info("saveHistoryFile fileContent or fileName is empty");
+            return;
+        }
+        try {
+            fileName = fileName +"_"+System.currentTimeMillis();
+            createDir();
+            File file = new File(hubeiHistoryFilePath+DateUtil.sampleDateFormatFormat(new Date())+File.separatorChar+fileName);
+            file.createNewFile();
+            try(BufferedOutputStream outputStream = new BufferedOutputStream(new FileOutputStream(file))){
+                outputStream.write(fileContent.getBytes(EncodingConfig.defaultCharset));
+                outputStream.flush();
+            }
+            logger.info("File save successfully!");
+        } catch (Exception e) {
+            logger.error(e.getMessage(),e);
+            logger.info("save fileContent fail,fileName={}, content=",fileName);
+            logger.info("{}",fileContent);
+        }
+    }
+
+    public void createDir(){
+        String dateFormat = DateUtil.sampleDateFormatFormat(new Date());
+        File fileDir = new File(hubeiHistoryFilePath+dateFormat+File.separatorChar);
+        if(!fileDir.exists()||!fileDir.isDirectory()){
+            fileDir.mkdir();
+        }
+    }
+
 
 }

src/main/resources/config/local/financial_api.properties

 hubei.mail.touser=bo.wang@quantgroup.cn
+hubei.history.filepath=E:/hubeitest/
 log_dir=quant_group
 #定时任务环境变量的名 系统变量为-1表示关闭定时任务 其他为开启
 scheduled_trigger=scheduled_trigger
\ No newline at end of file

src/main/resources/config/release/financial_api.properties

 hubei.mail.touser=bo.wang@quantgroup.cn
+hubei.history.filepath=/vpants/hubeifiles/
 log_dir=quant_group
 #定时任务环境变量的名 系统变量为-1表示关闭定时任务 其他为开启
 scheduled_trigger=scheduled_trigger
\ No newline at end of file

src/main/resources/config/test/financial_api.properties

 hubei.mail.touser=bo.wang@quantgroup.cn
+hubei.history.filepath=/home/results/
 log_dir=quant_group
 #定时任务环境变量的名 系统变量为-1表示关闭定时任务 其他为开启
 scheduled_trigger=scheduled_trigger
\ No newline at end of file

src/test/java/cn/quantgroup/financial/service/HuBeiServiceTest.java

@@ -88,7 +88,7 @@ public class HuBeiServiceTest {
     public void testGetSendDisc(){
         //20170119_9009_T01.txt
         try {
-            huBeiService.handleDiscData(HubeiCFCDataType.SEND_DEBIT,null,null,new Integer(1).byteValue(),"20170222");
+            huBeiService.handleDiscData(HubeiCFCDataType.SEND_DEBIT,null,null,new Integer(1).byteValue(),"20170224");
         } catch (Exception e) {
             logger.error(e.getMessage(),e);
         }