dev

data/logic/queue.logic.php

@@ -1459,12 +1459,46 @@ class queueLogic
 
     public function OnRiskSN($params)
     {
+        $msg_adder = function ($order_id)
+        {
+            if($order_id <= 0) return false;
+
+            $mod_order = Model('vr_order');
+            $mod_refill = Model('refill_order');
+
+            $order_info = $mod_order->getOrderInfo(['order_id' => $order_id]);
+            $refill_info = $mod_refill->getOrderInfo(['order_id' => $order_id]);
+
+            if(empty($refill_info) || empty($order_info)) {
+                return false;
+            }
+
+            $sn = $refill_info['official_sn'];
+            if(empty($sn)) {
+                $desc = "成功返回订单不含流水号。未给用户回调。";
+            } else {
+                $desc = "流水号:{$sn},有风险。未给用户回调。";
+            }
+
+            $params = ['title' => '风险号预警',
+                'order_id' => $refill_info['order_id'],
+                'order_sn' => $refill_info['order_sn'],
+                'mchid' => $refill_info['mchid'],
+                'store_id' => $order_info['store_id'],
+                'store_name' => $order_info['store_name'],
+                'execpt_desc' => $desc,
+                'add_time' => time()
+            ];
+
+            $mod_except = Model('refill_exception');
+            return $mod_except->add_except($params);
+        };
+
         $store_id = intval($params['store_id']);
         $channel_name = $params['channel_name'];
-        $order_sn = $params['order_sn'];
         $order_id = intval($params['order_id']);
 
-
+        $msg_adder($order_id);
 
         if($store_id <= 0 || empty($channel_name)) {
             return callback(false, 'OnRiskSN 参数有空');

data/model/refill_exception.model.php

@@ -21,4 +21,9 @@ class refill_exceptionModel extends Model
         $update['except_state'] = 1;
         return $this->where(['except_id' => $exc_id])->update($update);
     }
+
+    public function add_except($datas)
+    {
+        return $this->insert($datas);
+    }
 }

helper/refill/RefillBase.php

@@ -166,7 +166,10 @@ class RefillBase
 
             if($success && $this->risksn_check($refill_info)) {
                 $tran->commit();
-                $params = ['store_id' => $order_info['store_id'], 'channel_name' => $refill_info['channel_name'], 'order_sn' => $refill_info['order_sn'], 'order_id' => $refill_info['order_id']];
+                $params = ['store_id' => $order_info['store_id'],
+                    'channel_name' => $refill_info['channel_name'],
+                    'order_sn' => $refill_info['order_sn'],
+                    'order_id' => $refill_info['order_id']];
                 QueueClient::async_push("OnRiskSN", $params, 1);
                 return false;
             }