精选文章｜浅谈资损防控

import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import groovy.util.logging.Slf4j; import org.springframework.stereotype.Service;  import javax.annotation.Resource;  /**  * DCheck:冷静期内-平台客服取消订单-退买家支付金额  */ @Slf4j @Service class CheckRefundPayForLess30min implements BaseScript {      @Resource     private OrderDevOpsApi orderDevOpsApi;      @Resource    DCheckApi dCheckApi;      @Resource     private PayServiceFeignClient payServiceFeignClient      String logTag = "TAG_CheckCrossAndOverSeaRefundPayForLess30min:{}"      // 1.关单时间-支付时间<30分钟     @Override     boolean filter(JSONObject doneCleanData) {         // 查询支付时间         String unionId = doneCleanData.getString("order_no");         String payTime = getOrderData(unionId,"payTime", DevOpsSceneEnum.FORWARD_PAY);         long modifyTime = doneCleanData.getDate("modify_time").getTime();          long diffTime = modifyTime - Long.valueOf(payTime)         if (diffTime < 30 * 60 * 1000){             return true;         }         log.info(logTag,"===>有符合数据进入Check")         return false;     }      @Override     String check(JSONObject doneCleanData) {         String subOrderNo = doneCleanData.getString("sub_order_no");         Result<List<String>> listResult = dCheckApi.queryPayNoBySubOrderNo(subOrderNo);         if(listResult == null || listResult.getData() == null) {             return "根据正向查询接口通过子订单号查询支付流水号数据为空";         }         if(listResult.getData().size() > 1){             return "根据正向查询接口通过子订单号查询支付流水号多条数据，请查看是否需要优化逻辑";         }                 String outPayNo = listResult.getData().get(0);         RefundQueryRequest refundQueryRequest = new RefundQueryRequest();         refundQueryRequest.setPayLogNum(outPayNo);         Result<List<RefundBillDTO>>  resp = payServiceFeignClient.queryRefundsByPayLogNum(refundQueryRequest);         // 判断支付查询数据是否为空，如果为空直接报数据错误，以及是否查询到了多条数据         if (resp == null || resp.getData() == null) {             return "上游数据为空:支付退款查询(根据支付流水号)";         }         else if (resp.getData().size() != 1) {             return "上游数据为多条请确认逻辑:支付退款查询(根据支付流水号)";         }          // 检查点逻辑判断1: 状态为打款成功         if (resp.getData().get(0).getStatus() !=2 ){             return "校验支付打款状态非2";         }          // 逻辑校验点2：交易退款和RPC查询的金额一致，否则告警         if (resp.getData().get(0).getAmount() != doneCleanData.getLong("amount")) {             return "校验交易退款金额和支付打款金额不一致";         }         return "SUCCESS";     }      // 数据库查询对应字段值     String getOrderData(String unionNo,String key,DevOpsSceneEnum devOpsSceneEnum){         // 内部方法省略....         return value;     } }

[{id=10086, refundNo=RE10086, orderNo=100888, userId=15206, bizType=110, payTool=0, payStatus=404,amount=100, feature=, isDel=0, createTime=2021-05-11 21:39:34.000, modifyTime=2021-05-11 21:39:34.000, moneyFrom=1, currency=, countryCode=},{id=10087, refundNo=RE10087, orderNo=100999, userId=15206, bizType=202, payTool=0, payStatus=404, amount=400, feature=, isDel=0, createTime=2021-05-11 21:39:34.000, modifyTime=2021-05-11 21:39:34.000, moneyFrom=1, countryCode=}]