修改代码中的业务逻辑

src/main/java/com/emato/cuspay/notify/CusMerchantNotice.java

@@ -102,6 +102,7 @@ public class CusMerchantNotice implements MerchantNotice{
             }
         } catch (Exception e) {
             logger.error("更新商户通知数据失败", e);
+            throw new RuntimeException("更新商户通知数据失败",e);
         }
     }
 

src/main/java/com/emato/cuspay/wx/common/WxDict.java

@@ -206,8 +206,8 @@ public abstract class WxDict {
     public enum MerchNoticeStatus {
         i_10("10", "等待海关处理"),
         i_11("11", "海关申报中"),
-        i_12("12", "海关申报失败"),
-        i_13("13", "海关申报成功");
+        i_12("12", "海关申报成功"),
+        i_13("13", "海关申报失败");
 
         private String item;
         private String itemName;

src/main/java/com/emato/cuspay/wx/declare/AbstractCusDeclare.java

@@ -12,8 +12,10 @@ import com.emato.cuspay.dto.merch.MerchNoti;
 import com.emato.cuspay.dto.merch.MerchPayCfg;
 import com.google.common.collect.Maps;
 import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.config.BeanPostProcessor;
 
+import javax.annotation.PostConstruct;
 import java.util.List;
 import java.util.Map;
 
@@ -24,28 +26,19 @@ import java.util.Map;
  * @version 1.0
  * 2018-05-18 14:21
  */
-public abstract class AbstractCusDeclare implements BeanPostProcessor, CusDeclare{
+public abstract class AbstractCusDeclare implements CusDeclare{
 
+    @Autowired
     private MerchPaymentService paymentService;
 
     //商户支付信息缓存
     private Map<String, MerchPayCfg> payCaches = Maps.newHashMap();
 
-    //初始化商户支付配置信息
-    public Object postProcessAfterInitialization(Object bean, String beanName)
-            throws BeansException {
-        if (bean instanceof MerchPaymentService) {
-            this.setPaymentService((MerchPaymentService)bean);
-            this.reloadPayCaches();
-        }
-        return bean;
-    }
 
-    public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
-        return bean;
-    }
+
 
     //重新加载缓存
+    @PostConstruct
     private void reloadPayCaches() {
         if (this.paymentService == null)
             throw new NullPointerException("paymentService is null");

src/main/java/com/emato/cuspay/wx/declare/WxCusDeclare.java

@@ -181,7 +181,7 @@ public class WxCusDeclare extends AbstractCusDeclare implements CusDeclare{
                     //通知商户
                     MerchNoti merchNoti = builder.code(WxContants.ERROR_FAIL)
                                     .msg(wxResponseMsgDto.getReturnMsg())
-                                    .cusDeclStatus(WxDict.MerchNoticeStatus.i_12.getItem())
+                                    .cusDeclStatus(WxDict.MerchNoticeStatus.i_13.getItem())
                                     .build();
                     merchNotis.add(merchNoti);
                 }
@@ -209,7 +209,7 @@ public class WxCusDeclare extends AbstractCusDeclare implements CusDeclare{
 
                         MerchNoti merchNoti = builder.code(WxContants.ERROR_FAIL)
                                         .msg("未申报")
-                                        .cusDeclStatus(WxDict.MerchNoticeStatus.i_12.getItem())
+                                        .cusDeclStatus(WxDict.MerchNoticeStatus.i_10.getItem())
                                         .build();
                         merchNotis.add(merchNoti);
                     }
@@ -242,7 +242,7 @@ public class WxCusDeclare extends AbstractCusDeclare implements CusDeclare{
 
                         MerchNoti merchNoti = builder.code(wxResponseMsgDto.getErrCode())
                                 .msg(wxResponseMsgDto.getErrCodeDes())
-                                .cusDeclStatus(WxDict.MerchNoticeStatus.i_13.getItem())
+                                .cusDeclStatus(WxDict.MerchNoticeStatus.i_12.getItem())
                                 .build();
                         merchNotis.add(merchNoti);
                     }
@@ -252,7 +252,7 @@ public class WxCusDeclare extends AbstractCusDeclare implements CusDeclare{
 
                         MerchNoti merchNoti = builder.code(WxContants.ERROR_FAIL)
                                     .msg("海关申报失败")
-                                    .cusDeclStatus(WxDict.MerchNoticeStatus.i_12.getItem())
+                                    .cusDeclStatus(WxDict.MerchNoticeStatus.i_13.getItem())
                                 .build();
                         merchNotis.add(merchNoti);
                     }
@@ -262,7 +262,7 @@ public class WxCusDeclare extends AbstractCusDeclare implements CusDeclare{
 
                         MerchNoti merchNoti = builder.code(WxContants.ERROR_EXCEPT)
                                     .msg("海关接口异常")
-                                    .cusDeclStatus(WxDict.MerchNoticeStatus.i_12.getItem())
+                                    .cusDeclStatus(WxDict.MerchNoticeStatus.i_13.getItem())
                                     .build();
                         merchNotis.add(merchNoti);
                     }
@@ -279,12 +279,12 @@ public class WxCusDeclare extends AbstractCusDeclare implements CusDeclare{
 
                     MerchNoti merchNoti = builder.code(wxResponseMsgDto.getErrCode())
                                 .msg(wxResponseMsgDto.getErrCodeDes())
-                                .cusDeclStatus(WxDict.MerchNoticeStatus.i_12.getItem())
+                                .cusDeclStatus(WxDict.MerchNoticeStatus.i_13.getItem())
                                 .build();
                     merchNotis.add(merchNoti);
                 }
 
-            } catch (IOException e) {
+            } catch (Exception e) {
                 logger.error("数据请求异常的支付单请求数据为xml:"+xml, e);
                 WxPayError wxPayError = createWxPayError(wxCbPayDoc);
                 errors.add(wxPayError);
@@ -313,7 +313,7 @@ public class WxCusDeclare extends AbstractCusDeclare implements CusDeclare{
             }
         } catch (Exception e) {
             logger.error("持久化支付申报异常信息数据失败data:" + errors, e);
-            return;
+            throw new RuntimeException("持久化支付申报异常信息数据失败data:",e);
         }
     }
 

src/main/java/com/emato/cuspay/wx/service/impl/WxCbPayDocServiceImpl.java

@@ -77,7 +77,12 @@ public class WxCbPayDocServiceImpl implements WxCbPayDocService {
     }
 
     public int updateWxCbPay(WxCbPayDoc wxCbPayDoc) {
-        return wxCbPayDocMapper.updateByPrimaryKeySelective(wxCbPayDoc);
+        try {
+            return wxCbPayDocMapper.updateByPrimaryKeySelective(wxCbPayDoc);
+        } catch (Exception e) {
+            logger.error("更新支付单数据失败");
+            throw new RuntimeException("更新支付单数据失败");
+        }
     }
 
     public int updateBatch(List<WxCbPayDoc> wxCbPayDocs) {