yingzi 2 роки тому
батько
коміт
6af52cd152
2 змінених файлів з 32 додано та 20 видалено
  1. 9 0
      Model/Order/MOrder.Class.php
  2. 23 20
      Util/Common/PartnerTools.Class.php

+ 9 - 0
Model/Order/MOrder.Class.php

@@ -78,6 +78,8 @@ use Util\WeiXin\Pay;
 use Util\AliPay\Pay as aliPay;
 use Util\ByteDance\Pay as bytePay;
 
+use Util\Common\PartnerTools;
+
 class MOrder extends MBaseModel
 {
     /**
@@ -3751,6 +3753,13 @@ class MOrder extends MBaseModel
             if(!$updateMerchantSettlement->isSuccess()){
                 return ResultWrapper::fail($updateMerchantSettlement->getData(), $updateMerchantSettlement->getErrorCode());
             }
+            
+            
+            //只有小程序微信支付订单才可以计算分佣
+            if(!empty($orderData) && $orderData["payAmount"]>0 && $orderData["payType"]==1 && $orderData["source"]==3){
+                PartnerTools::addTask($orderData["id"], $this->onlineEnterpriseId);
+            }
+            
         }
 
 

+ 23 - 20
Util/Common/PartnerTools.Class.php

@@ -96,27 +96,30 @@ class PartnerTools{
      * @return bool
      */
     public static function addTask($orderId,$enterpriseId){
-        if(empty($orderId) || empty($enterpriseId)){
-            
-            return ["code"=>-1,"msg"=>"参数为空"];
+        try{
+            if(empty($orderId) || empty($enterpriseId)){
+                return ["code"=>-1,"msg"=>"参数为空"];
+            }
+            $dbTask = new DNewCommissionTask('default');
+            $taskTableName = $dbTask->getTableName($dbTask->get_Table(), $enterpriseId, 1);
+            $dbTask->setTable($taskTableName);
+            $count = $dbTask->count(["orderId"=>$orderId]);
+            if($count>0){
+                return ["code"=>-1,"msg"=>"任务订单已存在"];
+            }
+            $r = $dbTask->insert([
+                "orderId"=>$orderId,
+                "enterpriseId"=>$enterpriseId,
+                "title"=>"订单完成计算分佣",
+                "mono"=>"",
+                "status"=>0,
+                "run_time"=>0,
+                "time"=>time(),
+            ]);
+            return ["code"=>1,"msg"=>"任务已插入[{$r}]"];
+        } catch (\Exception $e){
+            return ["code"=>-1,"msg"=>"系统错误"];
         }
-        $dbTask = new DNewCommissionTask('default');
-        $taskTableName = $dbTask->getTableName($dbTask->get_Table(), $enterpriseId, 1);
-        $dbTask->setTable($taskTableName);
-        $count = $dbTask->count(["orderId"=>$orderId]);
-        if($count>0){
-            return ["code"=>-1,"msg"=>"任务订单已存在"];
-        }
-        $r = $dbTask->insert([
-            "orderId"=>$orderId,
-            "enterpriseId"=>$enterpriseId,
-            "title"=>"订单完成计算分佣",
-            "mono"=>"",
-            "status"=>0,
-            "run_time"=>0,
-            "time"=>time(),
-        ]);
-        return ["code"=>1,"msg"=>"任务已插入[{$r}]"];
     }
     
     public function runTask(){