liyg 2 anos atrás
pai
commit
6524d92318

+ 35 - 1
src/main/java/com/steerinfo/dil/controller/AmsSaleOrderController.java

@@ -806,6 +806,11 @@ public class AmsSaleOrderController<RedisTemplate> extends BaseRESTfulController
         String json = JSONUtils.toJSONString(totalMap);
         System.out.println(json);
         Map<String,Object> s = joinFeign.pushCarNumberToEas(totalMap);
+        try {
+            newFileTool.newFile("pushCarNumberToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         if (s == null || s.size() == 0) {
             try{
                 //失败,存入重试队列,准备重试
@@ -1031,6 +1036,11 @@ public class AmsSaleOrderController<RedisTemplate> extends BaseRESTfulController
             String json = JSONUtils.toJSONString(totalMap);
             System.out.println(json);
             Map<String, Object> s = joinFeign.pushCarNumberToEas(totalMap);
+            try {
+                newFileTool.newFile("pushCarNumberToEas:"+totalMap,"金蝶通讯报文");
+            }catch (Exception e){
+                e.printStackTrace();
+            }
             System.out.println("-------------------------------------");
             System.out.println(s);
             System.out.println("-------------------------------------");
@@ -1158,6 +1168,11 @@ public class AmsSaleOrderController<RedisTemplate> extends BaseRESTfulController
                 System.out.println(json);
                 System.out.println("--------------------------------------------");
                 Map<String, Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
+                try {
+                    newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+                }catch (Exception e){
+                    e.printStackTrace();
+                }
                 System.out.println("--------------------------------------------");
                 System.out.println(resultMap);
                 //Map<String,Object> outMap = (Map<String,Object>) resultMap.get("output");
@@ -1199,6 +1214,11 @@ public class AmsSaleOrderController<RedisTemplate> extends BaseRESTfulController
         String json = JSONUtils.toJSONString(totalMap);
         System.out.println(json);
         Map<String,Object> resultMap = joinFeign.pushSaleOrderToEas(totalMap);
+        try {
+            newFileTool.newFile("pushSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         System.out.println(resultMap);
         return success(result);
     }
@@ -1414,6 +1434,11 @@ public class AmsSaleOrderController<RedisTemplate> extends BaseRESTfulController
         String json = JSONUtils.toJSONString(totalMap);
         System.out.println(json);
         Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
+        try {
+            newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         System.out.println(resultMap);
         return success(result);
     }
@@ -1489,7 +1514,11 @@ public class AmsSaleOrderController<RedisTemplate> extends BaseRESTfulController
                     String json = JSONUtils.toJSONString(totalMap);
                     System.out.println(json);
                     Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
-
+                    try {
+                        newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+                    }catch (Exception e){
+                        e.printStackTrace();
+                    }
                     System.out.println(resultMap);
                 }
             }catch (Exception e){
@@ -1667,6 +1696,11 @@ public class AmsSaleOrderController<RedisTemplate> extends BaseRESTfulController
             String json = JSONUtils.toJSONString(totalMap);
             System.out.println(json);
             Map<String,Object> s = joinFeign.pushCarNumberToEas(totalMap);
+            try {
+                newFileTool.newFile("pushCarNumberToEas:"+totalMap,"金蝶通讯报文");
+            }catch (Exception e){
+                e.printStackTrace();
+            }
             if (s == null || s.size() == 0) {
                 //失败,存入新的重试队列,准备下一次重试
                 newRetry.add(mapList);

+ 50 - 0
src/main/java/com/steerinfo/dil/service/impl/AmsSaleOrderServiceImpl.java

@@ -262,6 +262,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
         System.out.println(json);
         // 得到金蝶返回结果
         Map<String,Object> s = joinFeign.pushSaleOrderToEas(totalMap);
+        try {
+            newFileTool.newFile("pushSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         String status = (String) s.get("status");
         if ("-1".equals(status)) {
             throw new Exception(amsSaleOrder.getSaleNumber() + "上传金蝶失败!");
@@ -1325,6 +1330,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
             String json = JSONUtils.toJSONString(totalMap);
             System.out.println(json);
             Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
+            try {
+                newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+            }catch (Exception e){
+                e.printStackTrace();
+            }
             System.out.println(resultMap);
         }else if(amsSaleOrder1.getSaleOrderStatus().intValue() == 1 || amsSaleOrder1.getSaleOrderStatus().intValue() == 2){
             String reason = "修改物资关闭上一条销售订单";
@@ -1401,6 +1411,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
             String json = JSONUtils.toJSONString(totalMap);
             System.out.println(json);
             Map<String,Object> s = joinFeign.pushSaleOrderToEas(totalMap);
+            try {
+                newFileTool.newFile("pushSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+            }catch (Exception e){
+                e.printStackTrace();
+            }
             String status = (String) s.get("status");
             if ("-1".equals(status)) {
                 continue;
@@ -1957,6 +1972,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
         String json = JSONUtils.toJSONString(totalMap);
         System.out.println(json);
         Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
+        try {
+            newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         System.out.println(resultMap);
         AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
         amsSaleOrder.setSaleOrderId(saleOrderId);
@@ -2376,6 +2396,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
         String json = JSONUtils.toJSONString(totalMap);
         System.out.println(json);
         Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
+        try {
+            newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         System.out.println(resultMap);
         return result;
     }
@@ -2415,6 +2440,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
         String json = JSONUtils.toJSONString(totalMap);
         System.out.println(json);
         Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
+        try {
+            newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         System.out.println(resultMap);
         return result;
     }
@@ -2475,6 +2505,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
                 String json = JSONUtils.toJSONString(totalMap);
                 System.out.println(json);
                 Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
+                try {
+                    newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+                }catch (Exception e){
+                    e.printStackTrace();
+                }
                 System.out.println(resultMap);
             }
             return 0;
@@ -2495,6 +2530,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
         String json = JSONUtils.toJSONString(totalMap);
         System.out.println(json);
         Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
+        try {
+            newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         System.out.println(resultMap);
         String outPutMap = (String) resultMap.get("output");
         JSONObject jsonObject = JSON.parseObject(outPutMap);
@@ -2607,6 +2647,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
         JSONObject jsonObject = new JSONObject(totalMap);
         System.out.println(jsonObject);
         Map<String,Object> resultMap = joinFeign.deleteSaleOrderToEas(totalMap);
+        try {
+            newFileTool.newFile("deleteSaleOrderToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         System.out.println("返回");
         System.out.println(resultMap);
         String outPut = (String) resultMap.get("output");
@@ -2881,6 +2926,11 @@ public class AmsSaleOrderServiceImpl implements IAmsSaleOrderService {
         String json = JSONUtils.toJSONString(totalMap);
         System.out.println(json);
         Map<String,Object> s = joinFeign.pushCarNumberToEas(totalMap);
+        try {
+            newFileTool.newFile("pushCarNumberToEas:"+totalMap,"金蝶通讯报文");
+        }catch (Exception e){
+            e.printStackTrace();
+        }
         if (s == null || s.size() == 0) {
             throw new Exception("登录金蝶失败!请重试派车!");
         }else{

+ 44 - 0
src/main/java/com/steerinfo/dil/util/newFileTool.java

@@ -0,0 +1,44 @@
+package com.steerinfo.dil.util;
+
+import org.apache.commons.lang.time.FastDateFormat;
+
+import java.io.File;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.util.Date;
+
+public class newFileTool {
+    public static void newFile(String jsonString,String type){
+        try{
+            new Thread(new Runnable() {
+                @Override
+                public void run() {
+                    try{
+                        //SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+                        FastDateFormat format = FastDateFormat.getInstance("yyyy-MM-dd");
+                        String date  = format.format(new Date());
+                        File file = new File("/shared/" + date + "-" + type + ".txt");
+                        //File file = new File("/shared/test.txt");
+                        FileWriter fileWriter = new FileWriter(file,true);
+                        FastDateFormat format1 = FastDateFormat.getInstance("yyyy-MM-dd HH:mm:ss");
+                        fileWriter.append("\n");
+                        fileWriter.append(format1.format(new Date()) + "-----------------------");
+                        fileWriter.append("\n");
+                        fileWriter.append(jsonString);
+                        fileWriter.append("\n");
+                        fileWriter.append(format1.format(new Date()) + "-----------------------");
+                        fileWriter.append("\n");
+                        fileWriter.flush();
+                        fileWriter.close();
+                    }catch (Exception e){
+                        System.out.println("IO异常");
+                        e.printStackTrace();
+                    }
+                }
+            }).start();
+        }catch (Exception e){
+            System.out.println("读写线程异常");
+            e.printStackTrace();
+        }
+    }
+}