update 团长分销-奖励脚本-增加钱包奖励类型'

'

application/modules/Job/controllers/Colonelorder.php

@@ -234,7 +234,7 @@ class ColonelorderController extends Job
         $res = Idgen::get(appConfig('idgen.partner'), appConfig('idgen.key'), [], $httpParams);
         $ids = $res['id_datetime']['goods'] ?? [];
         if ($count > count($ids)) {
-            throw new Exception('请求idgen服务失败，request:' . json_encode($httpParams) . ';response:' . json_encode($res));
+            throw new Exception('请求idgen服务失败，' . ['req' => $httpParams,'res' => $res]);
         }
         foreach ($data as $key => $item) {
             $data[$key]['pay_info_trade_id'] = $ids[$key];

application/modules/Job/controllers/Colonelwallet.php

@@ -16,6 +16,8 @@ class ColonelwalletController extends Job
     const CAPITAL_POOL_OP = 200; //200：团长奖励
     const WALLET_SERVICE_NAME = 10; // 10生活圈优惠券，11营销活动
     const WALLET_SOURCE_NAME = 1; //使用方名，1生活圈，2主端
+    const WALLET_ORDER_TYPE_USER  = 601; // 钱包-邀请新用户奖励类型
+    const WALLET_ORDER_TYPE_ORDER = 602; // 钱包-邀请下单奖励类型
 
     public $capitalPoolId = null;
 
@@ -72,13 +74,14 @@ class ColonelwalletController extends Job
         $httpParams = self::getWalletHttpParams();
         $list = [];
         foreach ($payInfoList as $payInfo) {
+            $thirdOrderInfo = self::getThirdOrderInfo($payInfo);
             $list[] = [
                 'user_id'             => $payInfo['colonel_user_id'],
                 'service_name'        => self::WALLET_SERVICE_NAME,
                 'source_name'         => self::WALLET_SOURCE_NAME,
                 'third_order_id'      => $payInfo['pay_info_trade_id'],
-                'third_order_id_type' => $payInfo['type'],
-                'third_order_desc'    => self::getThirdOrderDesc($payInfo),
+                'third_order_id_type' => $thirdOrderInfo['type'],
+                'third_order_desc'    => $thirdOrderInfo['desc'],
                 'amount'              => $payInfo['reward'],
                 'extra'               => ''
             ];
@@ -90,7 +93,7 @@ class ColonelwalletController extends Job
             $this->loggerInfo('调用钱包服务成功,count=' . count($payInfoList));
             return true;
         } else {
-            throw new Exception('调用钱包服务失败,httpParams=' . json_encode($httpParams));
+            throw new Exception('调用钱包服务失败,' . json_encode(['req' => $httpParams, 'res' => $response]));
         }
     }
 
@@ -113,13 +116,14 @@ class ColonelwalletController extends Job
         ];
         $body = [];
         foreach ($payInfoList as $payInfo) {
+            $thirdOrderInfo = self::getThirdOrderInfo($payInfo);
             $body[] = [
                 'op'                  => self::CAPITAL_POOL_OP,
                 'user_id'             => $payInfo['colonel_user_id'],
                 'amount'              => $payInfo['reward'],
                 'third_order_id'      => $payInfo['pay_info_trade_id'],
                 'third_order_id_type' => $payInfo['type'],
-                'third_order_desc'    => self::getThirdOrderDesc($payInfo),
+                'third_order_desc'    => $thirdOrderInfo['desc'],
             ];
         }
         $httpParams['body'] = $body;
@@ -129,7 +133,7 @@ class ColonelwalletController extends Job
             $this->loggerInfo('调用资金池服务成功,count=' . count($payInfoList));
             return true;
         } else {
-            throw new Exception('调用资金池服务失败,httpParams=' . json_encode($httpParams));
+            throw new Exception('调用资金池服务失败,' . ['req' => $httpParams,'res' => $res]);
         }
     }
 
@@ -178,17 +182,23 @@ class ColonelwalletController extends Job
      * User: pengfei@yidian-inc.com
      * Date: 2021/9/3 6:10 下午
      * @param $payInfo
-     * @return string
+     * @return array
      */
-    private function getThirdOrderDesc($payInfo): string
+    private function getThirdOrderInfo($payInfo): array
     {
-        $desc = '';
+        $info = [];
         if ($payInfo['type'] == ColonelDistributorPayInfo::TYPE_NEW_USER) {
-            $desc = "邀请新用户（" . $payInfo["invite_user_nick"] . "）完成下单奖励";
+            $info = [
+                'desc' => "邀请新用户（" . $payInfo["invite_user_nick"] . "）完成下单奖励",
+                'type' => self::WALLET_ORDER_TYPE_USER,
+            ];
         } elseif ($payInfo['type'] == ColonelDistributorPayInfo::TYPE_FINISH_TARGET) {
-            $desc = "完成" . $payInfo["finish_num"] . "单用户下单奖励";
+            $info = [
+                'desc' => "完成" . $payInfo["finish_num"] . "单用户下单奖励",
+                'type' => self::WALLET_ORDER_TYPE_ORDER,
+            ];
         }
-        return $desc;
+        return $info;
     }
 
 
@@ -207,7 +217,7 @@ class ColonelwalletController extends Job
             ['pay_info_id' => $payInfoIds]
         );
         if (empty($upStatus)) {
-            throw new Exception('更新pay_info状态失败.pay_info_ids=' . implode(',',$payInfoIds));
+            throw new Exception('更新pay_info状态失败.pay_info_ids=' . implode(',', $payInfoIds));
         }
         return $upStatus;
     }