jiaoyi-webman/app/controller/notify/Life.php

<?php

namespace app\controller\notify;

use app\extra\basic\Base;
use app\extra\dyMini\PlanLive;
use app\model\saas\SaasGoods;
use app\model\saas\SaasOrder;
use LinFly\Annotation\Attributes\Route\Controller;
use LinFly\Annotation\Attributes\Route\GetMapping;
use LinFly\Annotation\Attributes\Route\PostMapping;
use support\Request;
use support\Response;
use Webman\RedisQueue\Redis;


/**
 * 生活应用解决方案接入
 */
#[Controller("/life")]
class Life extends Base
{


    #[GetMapping("test")]
    public function test2data(Request $request): Response
    {
        try {
//            $param = $this->_valid([
//                "order.require"     => trans("empty.require"),
//            ],$request->method());
//            if (!is_array($param)) return error($param);
//            Redis::send("order-done",['order' => $param['order']]);
//            return success('ok');

            $data = (new PlanLive)->config([
                "appid"     => sConf("wechat.mini_appid"),
                "secret"    => sConf("wechat.mini_secret"),
            ])->token()->getPlan2Goods([7663786142546708530]);
            return success('success',$data);
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }

    #[PostMapping("spi")]
    public function getLifeSpi(Request $request): Response
    {
        try {
            $param = $request->all();
//            echo getDateFull()."===自研应用回调===\n";
//            print_r($param);
            return error("ddd");
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }



    #[PostMapping("hook")]
    public function getLifeHook(Request $request): Response
    {
        try {
            $data = $request->all();
//            echo getDateFull()."===自研应用回调WebHook===\n";
//            print_r($data);
            if (isset($data['event']) && $data['event'] == "verify_webhook") {
                return json(['challenge' => $data['content']['challenge']]);
            }
            $content = json_decode($data['content'],true);
            switch ($data['event']) {
                case "life_product_status_change": // 商品状态变化
                    if (in_array($content['status'],['GOODS_OFFLINE','GOODS_BAN','GOODS_DELETE'])) { // 商品下架
                        (new SaasGoods)->where("goods_id",$content['product_id'])->update(['status' => 3]);
                    }
                    break;
                case "verify": // 核销
                    $order = (new SaasOrder)->where("order_sn",$content['certificate']['order_id'])->findOrEmpty();
                    if (!$order->isEmpty()) {
                        $order->save([
                            "express_status"    => 3,
                            "done_at"           => getDateFull(),
                        ]);
                    }
                    break;
                default:
                    break;
            }
            return error("ddd");
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }




    #[PostMapping("mini")]
    public function getMiniHook(Request $request): Response
    {
        try {
            $data = $request->all();
//            echo getDateFull()."===小程序WebHook===\n";
//            print_r($data);
            if (isset($data['event']) && $data['event'] == "verify_webhook") {
                return json(['challenge' => $data['content']['challenge']]);
            }
            return error("ddd");
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }

}