Merge branch 'master' into 'pay_wanjl_0830'

# Conflicts:
#   conf/application.ini
#   conf/cli.ini
add: merge ini

application/exception/custom/RefundException.php

@@ -26,5 +26,8 @@ class RefundException extends BaseException
         11 => 'pingxx退单缺少matadata！',
         12 => 'pingxx未支付订单不允许退款。',
         13 => 'pingxx订单可能存在多次成功支付，需人工确认处理。',
+        14 => '不存在满足条件的退款订单。',
+        15 => '订单未支付或不存在，请核对。',
+        16 => '订单退款回调处理失败，请核对。',
     ];
 }

application/models/order/mysql/PayOrderClearingItem.php

@@ -2,6 +2,7 @@
 namespace App\Models\order\mysql;
 
 use Api\PhpUtils\Mysql\MysqlBase;
+use App\Exception\BaseException;
 
 class PayOrderClearingItem extends MysqlBase
 {
@@ -20,10 +21,21 @@ class PayOrderClearingItem extends MysqlBase
             return $ret;
         }
 
+        /**/
         $sql = "select sum(poci.`pay_amount`) as 'pay_amount', notify_account_status  from pay_order_clearing_item poci 
 join pay_order_item poi on poi.`order_item_id` = poci.`order_item_id` 
 where poci.pay_sub_type = 105 and poci.account_id = ? and poi.refund_order_status = 0 group by notify_account_status ";
 
+        /*
+        $sql = "select  sum(poci.`pay_amount`) as 'pay_amount', 
+notify_account_status  from pay_order_clearing_item poci 
+join pay_order_item poi on poi.`order_item_id` = poci.`order_item_id` 
+where 
+not exists (select 1 from refund_order ro where ro.`order_item_id` = poci.`order_item_id`) and 
+poci.pay_sub_type = 105 and poci.account_id = ? 
+group by notify_account_status ";
+        */
+
         /*
         type=1: 该团长历史累计分销佣金收入总和
         type=2: 该团长当前未结算分销佣金总和

application/modules/Pay/controllers/Order.php

@@ -2,6 +2,7 @@
 
 use App\Base\Base;
 
+use App\Exception\custom\PayException;
 use App\Services\pay\PayService;
 use App\Services\refund\RefundService;
 use Api\PhpUtils\Log\FileLog;
@@ -39,15 +40,25 @@ class OrderController extends Base
 
     public function refundAction() {
 
-        $params = $this->params;
-        $user_id    = $params['user_id'];
-        $order_item_id = $params['order_item_id'];
+        $params = $this->getRequest()->getPost();
+
+        if(!empty($params['order_item_id'])) {
+            if(!is_array($params['order_item_id'])) {
+                $params['order_item_id'] = explode(',', $params['order_item_id']);
+            }
+
+        } else {
+            $params['order_item_id'] = [];
+        }
+
+        if(empty($params['order_id'])) {
+            throw new PayException(['cus' => 1]);
+        }
 
         $refundSrv = new RefundService();
-        $ret = $refundSrv->do_refund($order_item_id, $user_id);
+        $ret = $refundSrv->do_refund($params['order_id'], $params['order_item_id']);
 
         $this->success(['result'=>$ret]);
-
     }
 
     public function chargesAction() {

application/modules/Pay/controllers/Tcc.php

@@ -73,4 +73,13 @@ class TccController extends Base
 
         $this->success(['result'=>[]]);
     }
+
+    public function traceAction() {
+        $params = $this->getRequest()->getPost();
+        //$params['traceId'] = \Api\PhpUtils\Log\Tracer::getTraceId();
+
+        file_put_contents('/tmp/aa.log', json_encode($_SERVER), FILE_APPEND);
+        $params['traceId'] = \Helpers\Tracer::getTraceId();
+        $this->success($params);
+    }
 }

application/plugins/Hook.php

@@ -46,7 +46,7 @@ class Hook extends \Yaf\Plugin_Abstract {
 	}
 
 	public function preDispatch(\Yaf\Request_Abstract $request, \Yaf\Response_Abstract $response) {
-		// application/json形式，仅处理$_POST, 不整合$_GET, $_REQUEST
+		// application/json形式，仅处理$_POST, 不整合$_GET
 		if($request->isPost()
 			&& $request->getServer('CONTENT_TYPE') == 'application/json') {
 
@@ -57,10 +57,13 @@ class Hook extends \Yaf\Plugin_Abstract {
             }
 
             $_POST = json_decode($jsonPost, true);
+
             if(!is_array($_POST)) {
                 $_POST = [];
                 FileLog::error('bp-gateway', 'json decode error raw:' . $jsonPost);
             }
+
+            $_REQUEST = array_merge($_REQUEST, $_POST);
 		}
 	}
 

application/services/pay/PayService.php

@@ -10,7 +10,6 @@ use App\Models\order\mysql\PayOrder;
 use App\Models\order\mysql\PayOrderItem;
 use App\Models\order\mysql\PayOrderClearing;
 use App\Models\order\mysql\PayOrderClearingItem;
-use App\Models\order\mysql\RefundOrder;
 use App\Services\order\OrderService;
 
 use App\Services\pingxx\PingxxService;
@@ -65,6 +64,7 @@ class PayService
 
         $metadata = [
             'app_id'=>'merchant-c',
+            'pingxx_id'=>PingxxService::getInstance()->getAppId(),
             'environ'=>Application::app()->environ(),
             'order_id'=>$order_id,
             'goods'=>[],
@@ -113,6 +113,7 @@ class PayService
             'expire_time' => date('Y-m-d H:i:s', $pay_expiration_time),
             'source_name' => 10,
             'service_name' => 1,
+            'business_from' => $order_info['business_from'],
             'extra' => json_encode([]),
         ];
 
@@ -285,20 +286,24 @@ class PayService
             $title = '';
         }
 
+
         try{
             //通知消息
             $app_id = 'wx65e9ba99c333444f';
             $template_id = 'EzOH2ZpfW-eUdFf9gzjZTAv-Z9PFmKHNsQ0VOGvvN7c';
-            $page_url = 'https://testwx.appgc.cn/%23/bpmp/ticket/my';
+            $page_url = \Yaf\Application::app()->getConfig()->get('wxApp.jw.order');
             $type = 1;
-            $param = [
+            $query = [
                 $title,
                 $pay_order['order_id'],
                 round($pay_order['pay_amount'] / 100, 2),
                 date('Y-m-d'),
             ];
 
-            Msg::send($pay_order['user_id'], $app_id, $template_id, $page_url, $type, $param);
+            if(isset($ret['result']['order_info']['business_from']) && $ret['result']['order_info']['business_from'] != 2) {
+                //接龙业务不发送消息
+                Msg::send($pay_order['user_id'], $app_id, $template_id, $page_url, $type, $query);
+            }
 
         }catch (\Throwable $e) {
             ;
@@ -373,30 +378,32 @@ class PayService
      */
     public function write_off($order_item_id, $life_account_id)
     {
+        $cnt = 0;
         //锁定状态
         try{
             PayOrderItem::beginTransaction();
-            $cnt = PayOrderItem::update([
-                'notify_account_status' => 0,
-                'can_notify_account' => 1,
-                'can_notify_account_time' => date('Y-m-d H:i:s'),
-            ], ['order_item_id' => $order_item_id, 'can_notify_account'=>0]);
-
-            $refund = RefundOrder::getMaster('*', ['order_item_id'=>$order_item_id]);
-            if(!empty($refund)) {
-                throw new PayException(['cus'=>9]);
-            }
 
             $item = PayOrderItem::getMaster('*', ['order_item_id' => $order_item_id]);
             if(empty($item)) {
                 throw new PayException(['cus'=>10]);
             }
 
+            if($item['refund_order_status'] != 0) {
+                throw new PayException(['cus'=>9]);
+            }
+
             $pay_order = PayOrder::getMaster('*', ['pay_order_id'=>$item['pay_order_id']]);
             if(empty($pay_order) || $pay_order['life_account_id'] != $life_account_id) {
                 throw new PayException(['cus'=>11]);
             }
 
+            $cnt = PayOrderItem::update([
+                'notify_account_status' => 0,
+                'can_notify_account' => 1,
+                'can_notify_account_time' => date('Y-m-d H:i:s'),
+            ], ['order_item_id' => $order_item_id, 'can_notify_account'=>0, 'refund_order_status'=>0]);
+
+
             PayOrderItem::commit();
         }catch (\Exception $e) {
             PayOrderItem::rollback();
@@ -499,6 +506,7 @@ class PayService
                 'pay_order_id' => $this->pay_order['pay_order_id'],
                 'order_id' => $this->pay_order['order_id'],
                 'order_item_id' => $r['order_item_id'],
+                'payment' => $r['payment'],
                 'user_id' => $this->pay_order['user_id'],
             ];
         }

application/services/pingxx/PingxxService.php

@@ -33,6 +33,9 @@ class PingxxService
         return self::$instance;
     }
 
+    public function getAppId() {
+        return Pingpp::getAppId();
+    }
 
     /**
      * @param $order_item_id

application/services/refund/RefundService.php

@@ -29,31 +29,13 @@ class RefundService
      * @throws RefundException
      * 发起退款请求
      */
-    public function do_refund($order_item_id, $user_id) {
+    public function do_refund($order_id, $order_item_ids = []) {
 
-        if(empty($order_item_id)) {
+        if(empty($order_id)) {
             throw new RefundException(['cus' => 1]);
         }
-        // 获取子单信息
-        $ret = OrderService::getOrderItemData($order_item_id);
-        if(empty($ret['result'])) {
-            throw new RefundException(['cus' => 2]);
-        }
-
-        if(empty($ret['result']['user_id']) || $ret['result']['user_id'] != $user_id) {
-            throw new RefundException(['cus' => 3]);
-        }
 
-        $order_item = $ret['result'];
-        $where = [
-            'order_item_id'=>$order_item_id,
-            'user_id'=>$user_id,
-            'order_id'=>$order_item['order_id'],
-            'refund_amount'=>$order_item['payment'],
-            'refund_order_id'=>$this->gen_refund_order_id($user_id),
-        ];
-
-        $data = $this->can_refund($where, $order_item);
+        $data = $this->can_refund($order_id, $order_item_ids);
 
         /*
         https://www.pingxx.com/api/%E8%AE%A2%E5%8D%95%20Refunds%20%E9%80%80%E6%AC%BE%E6%A6%82%E8%BF%B0.html
@@ -82,11 +64,11 @@ class RefundService
             'charge_amount'=>$data['refund_order']['refund_amount'],
             'metadata' => [
                 'app_id'=>'merchant-c',
+                'pingxx_id'=>PingxxService::getInstance()->getAppId(),
                 'environ'=>Application::app()->environ(),
                 'refund_order_id'=>$data['refund_order']['refund_order_id'],
-                'order_id'=>$order_item['order_id'],
-                'order_item_id'=>$data['refund_order']['order_item_id'],
-                'goods_sku_id'=>$order_item['goods_sku_id'] ?? '',
+                'order_item_id'=>$data['order_item_id'],
+                'order_id'=>$order_id,
             ],
         ];
 
@@ -99,11 +81,16 @@ class RefundService
                 throw new BaseException(['msg'=>$ret['error']['message'], 'code'=>'2011']);
             }
 
-            return ['order_item_id'=>$order_item_id];
+            return [
+                'order_item_id'=>$data['order_item_id'],
+                'refund_order_id'=>$data['refund_order']['refund_order_id'],
+            ];
 
         }catch (\Exception $e) {
             $edit = ['refund_order_status'=>0];
             RefundOrder::update($edit, ['refund_order_id'=>$data['refund_order']['refund_order_id']]);
+            PayOrderItem::update(['refund_order_status'=>0], ['order_item_id'=>$data['order_item_id']]);
+
             throw $e;
         }
     }
@@ -146,18 +133,35 @@ class RefundService
             return ['error'=>'退款订单缺少matadata，不做处理。'];
         }
 
+        if(empty($object['metadata']['order_item_id'])) {
+            return ['error'=>'退款订单缺少order_item_id，不做处理。'];
+        }
+
         // 修改状态，锁定业务
+        RefundOrder::beginTransaction();
+
         $refund_order_id = $object['metadata']['refund_order_id'];
         $edit = [
             'refund_order_status'=>2, //pingxx回调成功,
             'pingxx_callback_success_time'=>date('Y-m-d H:i:s'), //回调成功时间
-            'notify_account_status'=>1, //不需要通知钱包
         ];
 
-        $cnt = RefundOrder::update($edit, ['refund_order_id'=>$refund_order_id, 'refund_order_status'=>1]);
-        //保持幂等操作
-        if($cnt == 0) {
-            return ['refund_order_id'=>$refund_order_id];
+        $cnt_r = RefundOrder::update($edit, ['refund_order_id'=>$refund_order_id, 'refund_order_status'=>1]);
+
+        $cnt_i = PayOrderItem::update(['refund_order_status'=>2], [
+            'order_item_id'=>$object['metadata']['order_item_id']
+        ]);
+
+        if($cnt_r && $cnt_i) {
+            RefundOrder::commit();
+        } else {
+            RefundOrder::rollback();
+        }
+
+        $refund = RefundOrder::getMaster('*', ['refund_order_id'=>$refund_order_id]);
+
+        if($refund['refund_order_status'] != 2) {
+            throw new RefundException(['cus' => 16]);
         }
 
         return ['refund_order_id'=>$refund_order_id];
@@ -171,57 +175,52 @@ class RefundService
      * @throws RefundException
      * 判断订单是否可退，判断是否存在退款申请
      */
-    private function can_refund($where, $order_item) {
+    private function can_refund($order_id, $order_item_ids) {
 
         /**
          * 业务方自行解决，订单关闭、订单超过时长不允许退款等逻辑
          * 支付中心退款判断仅做主单是否支付，主单是否支持退款的判断
          */
-
+        $refund_payment = 0;
         try{
             RefundOrder::beginTransaction();
-            $pay_order_item = PayOrderItem::getMaster('*', ['order_item_id'=>$where['order_item_id']]);
-            if(empty($pay_order_item)) {
+            $pay_order = PayOrder::getMaster('*', ['order_id'=>$order_id]);
+            if(empty($pay_order)) {
+                throw new RefundException(['cus' => 15]);
+            }
+
+            $pay_order_items = PayOrderItem::selectMaster('*', ['order_id'=>$order_id]);
+            if(empty($pay_order_items)) {
                 throw new RefundException(['cus' => 4]);
             }
-            if($pay_order_item['can_notify_account'] == 1) {
-                throw new RefundException(['cus' => 5]);
+
+            foreach ($pay_order_items as $item) {
+                if($item['can_notify_account'] == 1) {
+                    continue; //已结算不允许退款
                 }
 
-            $refund_order = RefundOrder::getMaster('*', ['order_item_id'=>$where['order_item_id']]);
-            if(!empty($refund_order)) {
-                if($refund_order['refund_order_status'] == Dictionary::REFUND_ORDER_STATUS_OK) {
-                    throw new RefundException(['cus' => 6]);
+                if(in_array($item['refund_order_status'], [1, 2])) {
+                    continue; //退款中、已退款不允许再次申请
                 }
 
-                if($refund_order['refund_order_status'] == Dictionary::REFUND_ORDER_STATUS_SEND) {
-                    throw new RefundException(['cus' => 7]);
+                if(!empty($order_item_ids) && !in_array($item['order_item_id'], $order_item_ids)) {
+                    continue; //部分退款，且不再退款子单列表，不处理
                 }
 
-            } else {
-                $refund_order = $where;
-                $refund_order['refund_order_status'] = Dictionary::REFUND_ORDER_STATUS_UNDO;
-                //$refund_order['refund_amount'] = 0;
-                $cnt = RefundOrder::insert($refund_order, ['rowCount'=>true]);
-                if($cnt == 0) {
-                    throw new RefundException(['cus' => 0]);
+                $items[] = $item;
+
+                $refund_payment += $item['payment'];
             }
+
+            if(empty($items)) {
+                throw new RefundException(['cus' => 14]); //
             }
 
             //重新计算微信手续费
             $cleared_amount = $cleared_tip = 0;
 
-            $pay_order = PayOrder::getMaster('*', ['order_id'=>$where['order_id']]);
-            // 总共手续费
-            $wx_clear = PayOrderClearing::getMaster('*', [
-                'order_id'=>$where['order_id'],
-                'pay_order_id'=>$pay_order['pay_order_id'],
-                'pay_sub_type'=>406 //三方渠道手续费
-                ]
-            );
-
-            // 计算已退金额、已退手续费
-            $list = RefundOrder::selectMaster('*', ['order_id'=>$where['order_id']]);
+            // 计算已退金额、已退手续费 sum(refund_wx_tip), sum(refund_amount)
+            $list = RefundOrder::selectMaster('*', ['order_id'=>$pay_order['order_id']]);
             foreach ($list as $r) {
                 if($r['refund_order_status'] == Dictionary::REFUND_ORDER_STATUS_UNDO) {
                     continue;
@@ -231,27 +230,43 @@ class RefundService
                 $cleared_tip += $r['refund_wx_tip'];
             }
 
+            // 总共手续费
+            $wx_clear = PayOrderClearing::getMaster('*', [
+                    'order_id'=>$pay_order['order_id'],
+                    'pay_order_id'=>$pay_order['pay_order_id'],
+                    'pay_sub_type'=>406 //三方渠道手续费
+                ]
+            );
             $wx_total_tip = 0;
             if($wx_clear) {
                 $wx_total_tip = $wx_clear['pay_amount'];
             }
 
-            $wx_tip = Strategy::getWxTip($order_item['payment'], $pay_order['pay_amount'], $cleared_amount, $wx_total_tip, $cleared_tip);
+            $wx_tip = Strategy::getWxTip($refund_payment, $pay_order['pay_amount'], $cleared_amount, $wx_total_tip, $cleared_tip);
 
-            $edit = [
-                'refund_order_status'=>Dictionary::REFUND_ORDER_STATUS_SEND,
-                'refund_amount'=>$order_item['payment'],
+            $refund = [
+                'refund_order_id'=>$this->gen_refund_order_id($pay_order['user_id']),
+                'user_id'=>$pay_order['user_id'],
+                'order_id'=>$pay_order['order_id'],
+                'refund_order_status'=>1,
+                'refund_amount'=>$refund_payment,
                 'refund_wx_tip'=>$wx_tip,
+                'source_name'=>$pay_order['source_name'],
+                'extra'=> json_encode(['order_item_id'=>array_column($items, 'order_item_id')]),
             ];
-            $ret = RefundOrder::update($edit, ['refund_order_id'=>$refund_order['refund_order_id']]);
-            if(!$ret) {
+
+            $cnt = RefundOrder::insert($refund, ['rowCount'=>true]);
+            if($cnt == 0) {
                 throw new RefundException(['cus' => 0]);
             }
-            //重新获取
-            $refund_order = RefundOrder::getMaster('*', ['refund_order_id'=>$refund_order['refund_order_id']]);
+
+            //批量更新子单状态  "user_id" => [2, 123, 234, 54],
+            PayOrderItem::update(['refund_order_status'=>1], ['order_item_id'=>array_column($items, 'order_item_id')]);
+
             $data = [
-                'refund_order'=>$refund_order,
+                'refund_order'=>$refund,
                 'pay_order'=>$pay_order,
+                'order_item_id'=>array_column($items, 'order_item_id'),
             ];
 
             RefundOrder::commit();