jiaoyi-webman/app/controller/api/Notify.php

<?php

namespace app\controller\api;

use app\extra\basic\Base;
use app\extra\dyLife\data\OrderData;
use app\extra\tools\LifeWeb;
use app\model\saas\SaasGoods;
use app\model\saas\SaasOrder;
use app\model\saas\SaasOrderItem;
use LinFly\Annotation\Attributes\Route\Controller;
use LinFly\Annotation\Attributes\Route\PostMapping;
use support\Request;
use support\Response;
use Webman\RedisQueue\Redis;


#[Controller("/notify")]
class Notify extends Base
{

    #[PostMapping("douyin")]
    public function getOrderNotify(Request $request): Response
    {
        try {
            $param = $request->all();
            echo getDateFull()."===支付返回\n";
            $data = !empty($param['msg']) ? json_decode($param['msg'],true) : [];
            print_r($data);
            $orderSn = $data['out_order_no'];
            if ($data['status'] <> "SUCCESS") return json(['err_no' => 0,'err_tips' => "success"]);
            if (empty($data)) return json(['err_no' => 0,'err_tips' => "success"]);
            $order = (new SaasOrder)->where("out_order_no",$orderSn)->findOrEmpty();
            if ($order->isEmpty()) return json(['err_no' => 0,'err_tips' => "success"]);
            if ($order['status'] <> 0) return json(['err_no' => 0,'err_tips' => "success"]);
            (new SaasOrderItem)->where("order_sn",$order['order_sn'])->update(['status' => 1]);
            // 查询订单详情 - 延迟30秒读取
            Redis::send("sync-order-info",['order' => $order['order_sn']],30);
//            $orderData = (new OrderData)->config([
//                "appid"     => sConf("wechat.appid"),
//                "secret"    => sConf("wechat.secret"),
//                "account"   => sConf("wechat.shop_id"),
//            ])->token()->getOrderData($order['order_sn']);
//            if (isset($orderData['orders'][0]['anchor_id'])) {
//                $order->douyin_uid = $orderData['orders'][0]['anchor_id'];
//            }
            (new SaasGoods)->where("goods_id",$order['life_goods_id'])->inc("sale_stock")->save();
            $order->status = 1;
            $order->pay_at = getDateFull();
            $order->pay_type = $data['pay_channel'];
            $order->pay_sn = $data['channel_pay_id'];
            $order->pay_money = $data['total_amount'];
            $order->is_show = 1;
            $order->save();
            return json(['err_no' => 0,'err_tips' => "success"]);
        } catch (\Throwable $th) {
            echo $th->getMessage()."\n";
            echo $th->getFile()."\n";
            echo $th->getLine()."\n";
            return error($th->getMessage());
        }
    }

    #[PostMapping("price")]
    public function getOrderNotifyPrice(Request $request): Response
    {
        try {
            $param = $request->all();
            echo getDateFull()."===支付返回\n";
            $data = !empty($param['msg']) ? json_decode($param['msg'],true) : [];
            print_r($data);
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }


    #[PostMapping("mini")]
    public function getOrderNotifyMini(Request $request): Response
    {
        try {
            $param = $request->all();
            echo getDateFull()."===支付返回\n";
            $data = !empty($param['msg']) ? json_decode($param['msg'],true) : [];
            print_r($data);
            $orderSn = $data['cp_extra'];
            if ($data['status'] <> "SUCCESS") return json(['err_no' => 0,'err_tips' => "success"]);
            if (empty($data)) return json(['err_no' => 0,'err_tips' => "success"]);
            $order = (new SaasOrder)->where("order_sn",$orderSn)->findOrEmpty();
            if ($order->isEmpty()) return json(['err_no' => 0,'err_tips' => "success"]);
            if ($order['status'] <> 0) return json(['err_no' => 0,'err_tips' => "success"]);
            $order->status = 1;
            $order->pay_at = getDateFull();
            $order->pay_type = $data['way'];
            $order->pay_sn = $data['cp_orderno'];
            $order->pay_money = $data['total_amount'];
            $order->save();
            return json(['err_no' => 0,'err_tips' => "success"]);
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }

    #[PostMapping("refund")]
    public function getOrderRefund(Request $request): Response
    {
        try {
            $param = $request->all();
            echo getDateFull()."===退款返回\n";
            $data = !empty($param['msg']) ? json_decode($param['msg'],true) : [];
            print_r($data);
            $orderSn = $data['order_id'];
            if ($data['status'] <> "SUCCESS") return json(['err_no' => 0,'err_tips' => "success"]);
            if (empty($data)) return json(['err_no' => 0,'err_tips' => "success"]);
            $order = (new SaasOrder)->where("order_sn",$orderSn)->findOrEmpty();
            if ($order['status'] <> 4) return json(['err_no' => 0,'err_tips' => "success"]);
            $itemNum = (new SaasOrderItem)->where(["order_sn" => $order['order_sn'],'status' => 2])->count();
            $trueNum = count($data['refund_item_detail']['item_order_detail']);
            if (($trueNum+$itemNum) <> $order['number']) { // 部分退款
                $order->status = 6;
            } else { // 全部退款
                $order->status = 3;
            }
            if (!empty($data['refund_item_detail']['item_order_detail']))
            {
                foreach ($data['refund_item_detail']['item_order_detail'] as $val) {
                    (new SaasOrderItem)->where("item_order_id",$val['item_order_id'])->update(['status' => 2]);
                }
            }
            $order->refund_at = getDateFull();
            $order->save();
            return json(['err_no' => 0,'err_tips' => "success"]);
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }


    #[PostMapping("refund/mini")]
    public function getOrderRefundMini(Request $request): Response
    {
        try {
            $param = $request->all();
            echo getDateFull()."===小程序退款返回\n";
            $data = !empty($param['msg']) ? json_decode($param['msg'],true) : [];
            print_r($data);
            $orderSn = $data['cp_extra'];
            if ($data['status'] <> "SUCCESS") return json(['err_no' => 0,'err_tips' => "success"]);
            if (empty($data)) return json(['err_no' => 0,'err_tips' => "success"]);
            $order = (new SaasOrder)->where("order_sn",$orderSn)->findOrEmpty();
            if ($order['status'] <> 4) return json(['err_no' => 0,'err_tips' => "success"]);
            $order->status = 3;
            $order->refund_at = getDateFull();
            $order->save();
            return json(['err_no' => 0,'err_tips' => "success"]);
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }
}