| | |
| | | */ |
| | | @Override |
| | | public void onMessage (String msgApi, String msgId, String bizContent) { |
| | | System.err.println("消息对象"+msgApi); |
| | | System.err.println(" 消息对象"+msgApi); |
| | | System.err.println("id"+msgId); |
| | | System.err.println("内容"+bizContent); |
| | | if (msgApi.equals("ant.merchant.expand.indirect.zft.passed")){ |
| | |
| | | OperatorAuthAlipay orderNo = operatorAuthService.getOne(new QueryWrapper<OperatorAuthAlipay>() |
| | | .eq("orderNo", order_id)); |
| | | if (orderNo!=null){ |
| | | orderNo.setRefuseReason(null); |
| | | operatorAuthService.updateById(orderNo); |
| | | Integer operatorId = orderNo.getOperatorId(); |
| | | OperatorUser operatorId1 = operatorUserService.getOne(new QueryWrapper<OperatorUser>() |
| | | .eq("operatorId", operatorId)); |
| | | if (operatorId1!=null){ |
| | | operatorId1.setAlipayNum(smid); |
| | | operatorId1.setAlipayAudit(2); |
| | | operatorUserService.updateById(operatorId1); |
| | | } |
| | | } |
| | | }else if (msgApi.equals("ant.merchant.expand.indirect.zft.rejected")){ |
| | |
| | | String order_id = json.getString("order_id"); |
| | | OperatorAuthAlipay orderNo = operatorAuthService.getOne(new QueryWrapper<OperatorAuthAlipay>() |
| | | .eq("orderNo", order_id)); |
| | | |
| | | if (orderNo!=null){ |
| | | orderNo.setRefuseReason(reason); |
| | | operatorAuthService.updateById(orderNo); |
| | | Integer operatorId = orderNo.getOperatorId(); |
| | | OperatorUser operatorId1 = operatorUserService.getOne(new QueryWrapper<OperatorUser>() |
| | | .eq("operatorId", operatorId)); |
| | | if (operatorId1!=null){ |
| | | operatorId1.setAlipayAudit(3); |
| | | operatorUserService.updateById(operatorId1); |
| | | } |
| | | } |
| | | } |