新增结算定时

app/controller/admin/system/merchant/MerchantIntention.php

@@ -160,7 +160,8 @@ class MerchantIntention extends BaseController
 //            $commit_res=$this->repository->commit_res($shenhe_commit,$name);
 //            $commit_res=$this->repository->commit_res_query(['subApiKey'=>'api_live_2d788178-808b-4d73-bd9f-17c0d09cec44']);
 //            dump($commit_res);
-            $mer_id='276';
+            // $mer_id='276';
+            $mer_id = $id;
 
             $this -> repository -> huifu_create($id,1,'api_live_b3a56559-bb1a-42d0-89e2-b1d85e04a655','app_f3cba57b-15f3-4135-afda-ebe9fe3416ce',$mer_id);
             $this -> repository -> huifu_create($id,2,'api_live_68c25d10-2808-4042-8659-900e7b98ed1f','app_bd63b366-dbf1-4c66-97ef-a1438e9c935e',$mer_id);

app/controller/api/cron/CommissionCron.php

@@ -4,7 +4,9 @@
 namespace app\controller\api\cron;
 
 
+use AdaPaySdk\Drawcash;
 use AdaPaySdk\PaymentConfirm;
+use AdaPaySdk\SettleAccount;
 use app\common\dao\store\order\StoreOrderDao;
 use app\common\repositories\merchant\order\OrderGzcRepository;
 use app\common\repositories\merchant\order\OrderMerchantRepository;
@@ -14,8 +16,10 @@ use app\common\repositories\user\UserRepository;
 use app\controller\api\Common;
 use app\controller\merchant\finance\Reconciliation;
 use app\traits\GongApiRequest;
+use app\traits\ShouxinyiApiRequest;
 use Carbon\Carbon;
 use Exception;
+use PHPMailer\PHPMailer\PHPMailer;
 use think\db\exception\DataNotFoundException;
 use think\db\exception\DbException;
 use think\db\exception\ModelNotFoundException;
@@ -1034,4 +1038,269 @@ where o.paid=1 and o.is_settlement=1 and settlement_time between '$this->startMo
         $merber->isError();
         return $merber->result;
     }
+
+
+
+
+    //服务器配置,一般是默认配置
+    private $CharSet = "UTF-8";                                  //设定邮件编码
+    private $SMTPDebug = 0;                                      // 调试模式输出
+    private $isSMTP = true;                                      // 使用SMTP
+    private $Host = 'smtp.163.com';                              // SMTP服务器
+    private $SMTPAuth = true;                                    // 允许 SMTP 认证
+    private $Username = 'username';                              // SMTP 用户名  即邮箱的用户名
+    private $Password = 'MHIKZOXVPTGNVOMU';                      // SMTP 密码  部分邮箱是授权码(例如163邮箱)
+    private $SMTPSecure = 'ssl';                                 // 允许 TLS 或者ssl协议
+    private $Port = 465;                                         // 服务器端口 25 或者465 具体要看邮箱服务器支持
+    //修改成自己的邮箱
+    private $From = 'formalverification@163.com';                //发件人邮箱
+    private $FromName = 'makalo';                                //发件人的用户昵称
+
+
+    //邮件对象
+    private $mail;
+
+    //一般只有用户名和密码还有端口会变动, 所以这三个参数可以创建对象动态指定，也可以直接写死
+    public function mallInit($Username = '', $Password = '', $Port = '')
+    {
+        if (!empty($Username)) {
+            $this->Username = $Username;
+        }
+        if (!empty($Password)) {
+            $this->Password = $Password;
+        }
+        if (!empty($Port)) {
+            $this->Port = $Port;
+        }
+
+        //为true表示启用异常
+        $mail = new PHPMailer(true);
+        //服务器配置
+        $mail->CharSet = $this->CharSet;                     //设定邮件编码
+        $mail->SMTPDebug = $this->SMTPDebug;                 // 调试模121212        1式输出
+
+        if ($this->isSMTP === true) {
+            $mail->isSMTP();                                 // 使用SMTP
+        }
+        $mail->Host = $this->Host;                           // SMTP服务器
+        $mail->SMTPAuth = $this->SMTPAuth;                   // 允许 SMTP 认证
+        $mail->Username = $this->Username;                   // SMTP 用户名  即邮箱的用户名
+        $mail->Password = $this->Password;                   // SMTP 密码  部分邮箱是授权码(例如163邮箱)
+        $mail->SMTPSecure = $this->SMTPSecure;               // 允许 TLS 或者ssl协议
+        $mail->Port = $this->Port;                           // 服务器端口 25 或者465 具体要看邮箱服务器支持
+        $mail->setFrom($this->From, $this->FromName);        //发件人
+
+        $this->mail = $mail;
+    }
+
+    /**
+    * 发送邮件
+    * @param array $sendAddress 收件人地址数组， 如果为单值数组则只写入收件地址，如果为键值数组则还写入收件人名称
+    * @param array $Attachment 附件数组，如果为单值数组则为添加附件，如果为键值数组则添加附件并且重命名
+    * @param bool $isHtml 是否以html文档格式发送
+    * @param string $Subject 邮件主题
+    * @param string $Body 邮件内容，如果以html格式可以写入html
+    * @param string $AltBody 如果为单值数组则只写入收件地址，如果为键值数组则还写入收件人名称
+    * @param array $CC 抄送地址数组， 如果为单值数组则只写入收件地址，如果为键值数组则还写入收件人名称
+    * @param array $BCC 密送地址数组，如果为单值数组则只写入收件地址，如果为键值数组则还写入收件人名称
+    * @return bool 是否发送成功
+    */
+    public function sendEMail($sendAddress = [], $Subject = '', $Body = '', $AltBody = '', $Attachment = [], $isHtml = true, $CC = [], $BCC = [])
+    {
+        try {
+            //必填参数校验
+            if (empty($sendAddress) || empty($Subject) || empty($Body)) {
+                return false;
+            }
+            //收件人
+            foreach ($sendAddress as $key => $value) {
+                if (is_int($key)) {
+                    // 处理单值
+                    $this->mail->addAddress($value);
+                } else {
+                    // 处理键值
+                    $this->mail->addAddress($value, $key);
+                }
+            }
+            //附件
+            if (!empty($Attachment)) {
+                foreach ($Attachment as $key => $value) {
+                    if (is_int($key)) {
+                        // 处理单值
+                        $this->mail->addAttachment($value);
+                    } else {
+                        // 处理键值
+                        $this->mail->addAttachment($value, $key);
+                    }
+                }
+            }
+            //抄送
+            if (!empty($CC)) {
+                //抄送不为空
+                foreach ($CC as $key => $value) {
+                    if (is_int($key)) {
+                        // 处理单值
+                        $this->mail->addCC($value);
+                    } else {
+                        // 处理键值
+                        $this->mail->addCC($value, $key);
+                    }
+                }
+            }
+            //密送
+            if (!empty($BCC)) {
+                //密送不为空
+                foreach ($BCC as $key => $value) {
+                    if (is_int($key)) {
+                        // 处理单值
+                        $this->mail->addBCC($value);
+                    } else {
+                        // 处理键值
+                        $this->mail->addBCC($value, $key);
+                    }
+                }
+            }
+
+            //回复的时候回复给哪个邮箱 建议和发件人一致
+            $this->mail->addReplyTo($this->From, $this->FromName);
+
+            //Content
+            // 是否以HTML文档格式发送  发送后客户端可直接显示对应HTML内容
+            $this->mail->isHTML($isHtml);
+            //邮件主题
+            $this->mail->Subject = $Subject;
+            //邮件内容
+            $this->mail->Body = $Body;
+            //如果邮件客户端不支持HTML则显示此内容
+            $this->mail->AltBody = $AltBody;
+
+            //发送
+            $this->mail->send();
+            return [
+                'code' => 200,
+            ];
+        } catch (\Exception $e) {
+            return [
+                'code'    => 400,
+                'message' => $this->mail->ErrorInfo
+            ];
+        }
+    }
+
+    public function take()
+    {
+        set_time_limit(0);
+        $this->mallInit('formalverification@163.com', 'SYECAWFLLTUPMDRP');
+        $this->sendEMail(['389123492@qq.com', '420132441@qq.com'], '结算定时', "开始执行" . date('Y-m-d H:i:s'), '如果邮件客户端不支持HTML则显示此内容');
+        $mallStr = '';
+
+//        Log::info('执行一次1 '.date('H:i') );
+//        return ;
+//        $storeOrderRepository = app()->make(StoreOrderRepository::class);
+        $key_list = [
+            1 => 'api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9',
+            2 => 'api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f',
+            3 => 'api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871'
+        ];
+        $appid_list = [
+            1 => 'app_44108546-d27a-48ee-88c1-84b45b75114f',
+            2 => 'app_0827b960-b932-45ec-b800-4e850091b419',
+            3 => 'app_383a75dd-c03d-44ab-8f58-92c60fe9b9d0'
+        ];
+//
+//        $payment_id = ShouxinyiApiRequest::getOrderNumber('split');
+//        $insertData = [
+//            [
+//                'mid'            => 0,
+//                'requestId'      => $payment_id,
+//                'group_order_id' => 'WX171955791230553863',
+//                'splitAmount'    => 0.25,
+//                'status'         => 0
+//            ],
+//        ];
+//        $div_members[] = [
+//            'member_id' => 'member_personal_16704641278422',
+//            'amount'    => '1.00',
+//            'fee_flag'  => 'Y'
+//        ];
+//        //////分账表
+//        Db::name("store_split_order")->insertAll($insertData);
+//        /// 分账表end
+//
+//        $params = [
+//            'payment_id'  => '002212024062814583210652657343702200320',
+//            'order_no'    => $payment_id,
+//            'confirm_amt' => '1.00',
+//            'div_members' => $div_members
+//        ];
+//
+//        $params['api_key'] = $key_list[3];
+//
+//        var_dump($params);
+//        Db::name("log")->insert(array('data' => '汇付延时分账参数-----' . json_encode($params)));//日志记录
+//        $res = $storeOrderRepository->payment_confirm_create_traits($params);
+//        Db::name("log")->insert(array('data' => '汇付延时分账-----' . json_encode($res)));//日志记录
+//        var_dump($res);
+//        // 分账
+//        return;
+
+        $merchant_member_list = Db::name('merchant_member')
+//            ->where('member_id', 'member_personal_16704641278422')
+            ->column('mer_id,type,member_id,settle_account_id');
+
+        foreach ($merchant_member_list as $merchant_member) {
+            $mer_id = $merchant_member['mer_id'];
+            if (empty($mer_id))
+                continue;
+            if (empty($merchant_member['settle_account_id']))
+                continue;
+            $params = [
+                'app_id'            => $appid_list[$merchant_member['type']],
+                'member_id'         => $merchant_member['member_id'],
+                'settle_account_id' => $merchant_member['settle_account_id'],
+                'api_key'           => $key_list[$merchant_member['type']]
+            ];
+            $merber = new SettleAccount();
+            $merber->balance($params);
+            $merber->result;
+//            var_dump($merber->result);
+            if (isset($merber->result[1])) {
+                $result = json_decode($merber->result[1], true);
+                $result = json_decode($result['data'], true);
+                $result['avl_balance'] = $result['avl_balance'] ?? 0;
+                if ($result['avl_balance'] > 0) {
+                    $payment_id = ShouxinyiApiRequest::getOrderNumber('split');
+                    $params = [
+                        'order_no'  => $payment_id,
+                        'app_id'    => $appid_list[$merchant_member['type']],
+                        'cash_type' => 'T1',
+                        'cash_amt'  => sprintf("%01.2f", $result['avl_balance']),
+                        'member_id' => $merchant_member['member_id'],
+                        'api_key'   => $key_list[$merchant_member['type']]
+                    ];
+
+                    $yanglao_member_ids = ['jsdk_member_wx21710232183139', 'jsdk_member_ali1710232187326'];
+                    if (in_array($merchant_member['member_id'], $yanglao_member_ids)) {
+                        $params['remark'] = '天地博爱科技～养老金';
+                    }
+
+                    Db::name("log")->insert(array('data' => '汇付取现参数-----' . json_encode($params)));//日志记录
+                    $merber = new Drawcash();
+                    $merber->create($params);
+                    # 返回查询结果
+                    $merber->isError();
+                    $res = $merber->result;
+                    Db::name("log")->insert(array('data' => '汇付延时分账-----' . json_encode($res)));                    //日志记录
+                    Db::name("log")->insert(array('data' => "mer_id {$mer_id} 请求分账{$result['avl_balance']}元-----"));//日志记录
+                    var_dump("mer_id {$mer_id} 请求分账{$result['avl_balance']}元-----");
+                    $mallStr = $mallStr . "-----mer_id {$mer_id} 请求分账{$result['avl_balance']}元-----<br/>";
+                }
+            }
+        }
+        echo date('Y-m-d H:i:s') . '执行结束' . "\r\n";
+
+
+        $this->sendEMail(['389123492@qq.com', '420132441@qq.com'], '结算定时', "执行结束<br/>" . $mallStr . date('Y-m-d H:i:s'), '如果邮件客户端不支持HTML则显示此内容');
+    }
+
 }

route/api.php

@@ -1255,6 +1255,7 @@ Route::group('api/', function () {
     Route::get('down_gong_product', 'api.cron.CommissionCron/downGongProduct');//下架微唯宝已下架的商品
     Route::get('platform_income_detail_get', 'api.cron.CommissionCron/platform_income_detail_get');//插入平台收支明细
     Route::get('clear_platform_income_detail', 'api.cron.CommissionCron/clear_platform_income_detail');//删除平台收支明细
+    Route::get('take', 'api.cron.CommissionCron/take');//插入平台收支明细
     Route::get('order/group_detail/:id', 'api.store.order.StoreOrder/group_detail');//订单详情
     Route::get('commission_cron_bonus', 'api.cron.CommissionCron/bonus');