话费充值推送失败就退款

app/controller/api/Notify.php

@@ -58,7 +58,26 @@ class Notify
                             //话费充值支付成功推送
                             try{
                                 $Huafei = new Huafei();
-                                $Huafei->pushHf($order_data['uid'], $order_data['order_no'], $order_data['mobile'], $order_data['pay_price']);
+                                $pay_wx = systemConfig('pay_wx');
+                                $push = $Huafei->pushHf($order_data['uid'], $order_data['order_no'], $order_data['mobile'], $order_data['pay_price']);
+                                if($push['code'] != '0000'){
+                                    //推送失败 给新支付的这一笔退款
+                                    Db::name('log')->insert(['data' => '给新话费充值支付的这一笔退款']);
+                                    if ($pay_wx == 3){
+                                        $key='api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871';
+                                    }else{
+                                        $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
+                                    }
+                                    $refund_traits = [
+                                        'payment_id'  => $post_data_str['id'],
+                                        'app_id'      => $post['app_id'],
+                                        'order_no'    => app()->make(StoreRefundOrderRepository::class)->getNewOrderId(),
+                                        'reverse_amt' => $post_data_str['pay_amt'],
+                                        'notify_url'  => env('APP_URL') . "/api/hf_notify/reverse_order",
+                                    ];
+                                    $hf_refund_res = app()->make(StoreRefundOrderRepository::class)->payment_Reverse($refund_traits, $pay_type['pay_type'] == '1' ? 2 : 1, $pay_wx, $key);
+                                    Db::name('log')->insert(['data'=>'话费充值汇付支付撤销返回结果：'.json_encode($hf_refund_res)]);
+                                }
                             }catch (\Exception $e) {
                                 Db::name('log')->insert(['data'=>'话费充值支付回调推送订单错误：'.$e->getFile().'：'.$e->getLine().'【'.$e->getMessage().'】']);
                             }