|
@@ -1,20 +1,17 @@
|
|
|
package com.emato.cuspay.wx.declare;
|
|
|
|
|
|
-import com.emato.cuspay.base.merch.MerchCusService;
|
|
|
-import com.emato.cuspay.base.merch.MerchNotiService;
|
|
|
+import com.emato.cuspay.service.MerchNotiService;
|
|
|
import com.emato.cuspay.common.contant.MerchNoticeDict;
|
|
|
-import com.emato.cuspay.dto.merch.MerchCusCfg;
|
|
|
import com.emato.cuspay.wx.common.MerchNotiBuilder;
|
|
|
import com.emato.cuspay.wx.common.WxContants;
|
|
|
import com.emato.cuspay.wx.common.WxDict;
|
|
|
import com.emato.cuspay.common.contant.TablePrimaryKeyPrefix;
|
|
|
import com.emato.cuspay.common.core.db.IdWorkerAide;
|
|
|
-import com.emato.cuspay.dao.mapper.merch.MerchNotiMapper;
|
|
|
import com.emato.cuspay.wx.dto.WxResponseMsg;
|
|
|
-import com.emato.cuspay.dto.merch.MerchNoti;
|
|
|
-import com.emato.cuspay.dto.merch.MerchPayCfg;
|
|
|
-import com.emato.cuspay.wx.dao.entity.WxCbPayDoc;
|
|
|
-import com.emato.cuspay.wx.dao.entity.WxPayError;
|
|
|
+import com.emato.cuspay.entity.merch.MerchNoti;
|
|
|
+import com.emato.cuspay.entity.merch.MerchPayCfg;
|
|
|
+import com.emato.cuspay.wx.entity.WxCbPayDoc;
|
|
|
+import com.emato.cuspay.wx.entity.WxPayError;
|
|
|
import com.emato.cuspay.util.OkHttpUtils;
|
|
|
import com.emato.cuspay.util.XmlUtils;
|
|
|
import com.emato.cuspay.wx.service.WxCbPayDocService;
|
|
@@ -80,10 +77,15 @@ public class WxCusDeclare extends AbstractCusDeclare implements CusDeclare{
|
|
|
limit = (limit != null && limit > 0) ? limit : 20;
|
|
|
count = (count != null && count > 0) ? count : 10;
|
|
|
|
|
|
- List<WxCbPayDoc> wxCbPayDocs = wxCbPayDocService.selectBeDeclaredData(limit);
|
|
|
-
|
|
|
- if (wxCbPayDocs == null || wxCbPayDocs.isEmpty()) {
|
|
|
- logger.info("没有待申报微信推海关的支付数据");
|
|
|
+ List<WxCbPayDoc> wxCbPayDocs = null;
|
|
|
+ try {
|
|
|
+ wxCbPayDocs = wxCbPayDocService.selectBeDeclaredData(limit);
|
|
|
+ if (wxCbPayDocs == null || wxCbPayDocs.isEmpty()) {
|
|
|
+ logger.info("没有待申报微信推海关的支付数据");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.error("查询待申报微信推海关的支付数据异常", e);
|
|
|
return;
|
|
|
}
|
|
|
|
|
@@ -176,6 +178,7 @@ public class WxCusDeclare extends AbstractCusDeclare implements CusDeclare{
|
|
|
if (WxContants.RETURN_CODE_FAIL.equals(wxResponseMsgDto.getReturnCode()) ||
|
|
|
WxContants.FAIL.equals(wxResponseMsgDto.getReturnCode())) {
|
|
|
wxCbPayDoc.setDocStatus(WxDict.PaymentDocStatus.i_03.getItem());
|
|
|
+
|
|
|
wxCbPayDocService.updateWxCbPay(wxCbPayDoc);
|
|
|
|
|
|
//通知商户
|