md

emis-oms-biz-web/src/main/java/com/xdadan/erp/oms/web/Oms2cWaybillController.java

@@ -101,6 +101,9 @@ public class Oms2cWaybillController extends BaseController
     {
         waybillOrder.setUserId(getLoginUser().getUser().getId());
         waybillOrder.setCustomerCode(getLoginUser().getUser().getCustomerCode());
+        waybillOrder.setDataFrom(Re);
+
+
         return this.iRpcWaybillSvc.realSubmitOrderByOms(waybillOrder,isModify);
     }
 
@@ -122,6 +125,7 @@ public class Oms2cWaybillController extends BaseController
     public AjaxResult draftSubmitOrder(@RequestBody EmisWaybill emisWaybillSave){
         emisWaybillSave.setUserId(getLoginUser().getUser().getId());
         emisWaybillSave.setCustomerCode(getLoginUser().getUser().getCustomerCode());
+        emisWaybillSave.setDataFrom("");
         return this.iRpcWaybillSvc.draftSubmitOrderByOms(emisWaybillSave);
     }
 

emis-oms-biz/src/main/java/com/xdadan/erp/oms/domain/vo/WaybillOrder.java

@@ -345,6 +345,9 @@ public class WaybillOrder  implements Serializable {
     /* 录单人 */
     private String registerManName;
 
+    /* 数据来源 */
+    private String dataFrom;
+
     // 销售,回款
 //    private String salesmenName;
 //    private String payeeName;
@@ -609,6 +612,8 @@ public class WaybillOrder  implements Serializable {
 //        voItem.setCreateSite(dbWaybill.getCreateSite());
 //        voItem.setUpdateSite(dbWaybill.getUpdateSite());
 
+        voItem.setDataFrom(dbWaybill.getDataFrom());
+
         voItem.setLockFlag(dbWaybill.getLockFlag());
         voItem.setLockReason(dbWaybill.getLockReason());
 
@@ -815,6 +820,8 @@ public class WaybillOrder  implements Serializable {
 //        dbWaybill.setCreateSite(this.getCreateSite());
 //        dbWaybill.setUpdateSite(this.getUpdateSite());
 
+        dbWaybill.setDataFrom(this.getDataFrom());
+
         return dbWaybill;
 
     }

emis-oms-biz/src/main/java/com/xdadan/erp/oms/service/svc/FeignErrorDecoder.java

@@ -1,14 +1,51 @@
 package com.xdadan.erp.oms.service.svc;
 
+import feign.RequestInterceptor;
+import feign.RequestTemplate;
 import feign.Response;
 import feign.RetryableException;
 import feign.codec.ErrorDecoder;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Enumeration;
+import java.util.LinkedHashMap;
+import java.util.Map;
 
 @Slf4j
 @Configuration
-public class FeignErrorDecoder extends ErrorDecoder.Default {
+public class FeignErrorDecoder extends ErrorDecoder.Default implements RequestInterceptor {
+
+    @Override
+    public void apply(RequestTemplate requestTemplate) {
+        Map<String,String> headers = getHeaders(getHttpServletRequest());
+        for(String headerName : headers.keySet()){
+            requestTemplate.header(headerName, getHeaders(getHttpServletRequest()).get(headerName));
+        }
+    }
+
+    private HttpServletRequest getHttpServletRequest() {
+        try {
+            return ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    private Map<String, String> getHeaders(HttpServletRequest request) {
+        Map<String, String> map = new LinkedHashMap<>();
+        Enumeration<String> enumeration = request.getHeaderNames();
+        while (enumeration.hasMoreElements()) {
+            String key = enumeration.nextElement();
+            String value = request.getHeader(key);
+            map.put(key, value);
+        }
+        return map;
+    }
 
     @Override
     public Exception decode(String methodKey, Response response) {