jiaoyi-webman/app/controller/service/Service.php

<?php

namespace app\controller\service;

use app\extra\basic\Base;
use app\extra\tools\CodeExtend;
use app\middleware\AuthMiddleware;
use app\model\saas\SaasChatMsg;
use app\model\saas\SaasChatStore;
use app\model\saas\SaasOrderPrice;
use app\model\system\SystemUser;
use app\service\saas\ChatStoreService;
use app\service\saas\GoodsService;
use DI\Attribute\Inject;
use LinFly\Annotation\Attributes\Route\Controller;
use LinFly\Annotation\Attributes\Route\GetMapping;
use LinFly\Annotation\Attributes\Route\Middleware;
use LinFly\Annotation\Attributes\Route\PostMapping;
use support\Request;
use support\Response;
use Webman\Push\Api;


#[Controller("/api/service/chat"),Middleware(AuthMiddleware::class)]
class Service extends Base
{

    #[Inject]
    protected ChatStoreService $service;

    #[Inject]
    protected SaasChatStore $model;

    #[Inject]
    protected GoodsService $goodsService;


//    protected array $noNeedLogin = ["getServiceData"];

    #[GetMapping('list')]
    public function getServiceData(Request $request): Response
    {

        try {
            $param = $request->all();
            $param['poi_id'] = $request->user['store_id'];
            $param['service_id'] = $request->user['id'];
            $param['order'] = "descending";
            $param['field'] = "last_at";
            $data = $this->service->setModel()->getList($param,['user' => function($query){
                $query->field("openid,nickname,avatar,mobile,create_at");
            }],true,['last','avatar'],['last' => function($data,$resp) use($param){
                $last = (new SaasChatMsg)->where(["poi_id" => $resp['poi_id'],"service_id" => $param['service_id'],"openid" => $resp['openid']])->order("create_at desc")->field("content,create_at,type")->findOrEmpty();
                if ($last->isEmpty()) {
                    return ['type' => "text","content"=>"-",'num' => 0,'time' => time(),"create_at"=> formatTime(date("Y-m-d H:i:s",time()))];
                }
                $total = (new SaasChatMsg)->where(["poi_id" => $resp['poi_id'],"service_id" => $param['service_id'],"openid" => $resp['openid'],'is_read' => 0])->count();
                return ["content"=> str_cut_ellipsis($last['content'],12),'num' => $total,"create_at"=> formatTime($last['create_at']),"time"=> strtotime($last['create_at']),'type' => $last['type']];
            },'avatar' => function(){
                return "https://washmy.oss-cn-guangzhou.aliyuncs.com/storage/20260511/23627b2cb8f73a8a90b95c31d726e6ecad0cbb9a.png";
            }]);
            return successTrans(100010,pageFormat($data),200);
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }

    #[GetMapping('msg')]
    public function getMessageData(Request $request): Response
    {
        try {
            $param = $request->all();
            $msg = (new SaasChatMsg)->where(['openid' => $param['openid'],'poi_id' => $request->user['store_id']])->append(['avatar','time'])->withAttr(['avatar' => function(){
                return "https://washmy.oss-cn-guangzhou.aliyuncs.com/storage/20260511/23627b2cb8f73a8a90b95c31d726e6ecad0cbb9a.png";
            },'time' => function($resp,$data){
                return strtotime($data['create_at']) * 1000;
            }])->with(['nick' => function ($query) {
                $query->field("id,truename");
            },'user' => function ($query) {
                $query->field("openid,nickname,avatar");
            }])->order("id","desc")->paginate([
                "list_rows" => $param['size'] ?? 10,
                "page"      => $param['page'] ?? 1,
            ]);
            return successTrans(100010,pageFormatMsg($msg),200);
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }


    #[GetMapping('order')]
    public function getMsgOrder(Request $request)
    {
        try {
            $param = $this->_valid([
                "msgId.require" => trans("empty.require")
            ]);
            if (!is_array($param)) return error($param);
            $productType = $this->goodsService->productType();
            $chatStore = $this->model->where("id",$param['msgId'])->with(['orders' => function($query) use($productType){
                $query->field("*")->with(['product' => function($query) use($productType){
                    $query->field("product_id,product_name,product_type")->append(['types'])->withAttr(['types' => function($query,$resp) use($productType){
                        $productTypeArr = [];
                        foreach ($productType as $val) {
                            $productTypeArr[$val['key']] = $val['name'];
                        }
                        return $productTypeArr[$resp['product_type']]??'';
                    }]);
                }]);
            }])->findOrEmpty();
            if ($chatStore->isEmpty()) return error("error");
            return success("ok",['order' => $chatStore['orders']]);
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }

    #[PostMapping('send')]
    public function sendMessageData(Request $request): Response
    {
        try {
            $param = $this->_valid([
                "content.require"   => trans("empty.require"),
                "groupId.require"   => trans("empty.require"),
                "openid.require"    => trans("empty.require"),
                "type.require"      => trans("empty.require"),
            ],"post");
            if (!is_array($param)) return error($param);
            $str = preg_replace('/\s+/','',$param['content']);
            if (empty($str)) return error("请勿发送空消息");
            $state = (new SaasChatMsg)->insertGetId([
                "source"    => 2,
                "openid"    => $param['openid'],
                "content"   => is_array($param['content'])?json_encode($param['content']):$param['content'],
                "type"      => $param['type'],
                "msgId"     => md5($param['openid'].time()),
                "poi_id"    => $param['groupId'],
                "service_id" => $request->user['id'],
            ]);
            (new SaasChatMsg)->where(['openid' => $param['openid'],'service_id' => $request->user['id']])->save(['is_read' => 1]);
            (new SystemUser)->where("id",$request->user['id'])->update(['last_msg_at' => getDateFull()]);
            $api = new Api('http://127.0.0.1:3232', config('plugin.webman.push.app.app_key'),config('plugin.webman.push.app.app_secret'));
            $api->trigger("user-{$param['openid']}","message",[
                "type"  =>  $param['type'],
                "time"  =>  time() * 1000,
                "msgId" => md5($param['openid'].time()),
                "content"   => is_array($param['content'])?json_encode($param['content']):$param['content'],
                "source" => 2,
                "avatar"    => "https://washmy.oss-cn-guangzhou.aliyuncs.com/storage/20260511/23627b2cb8f73a8a90b95c31d726e6ecad0cbb9a.png",
                "poi_id"    => $param['groupId'],
                "openid"  => $param['openid'],
                "service_id"  => $request->user['id'],
                "create_at"  => formatTime(time())
            ]);
            return successTrans("success.data",['time' => formatTime(time())]);
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }


    #[PostMapping('send/price')]
    public function sendPriceData(Request $request): Response
    {
        try {
            $param = $this->_valid([
                "name.require"      => trans("empty.require"),
                "price.require"     => trans("empty.require"),
                "groupId.require"   => trans("empty.require"),
                "openid.require"    => trans("empty.require"),
                "type.require"      => trans("empty.require"),
            ],"post");
            if (!is_array($param)) return error($param);
            $orderSn = CodeExtend::uniqidDate(18,"P");
            $msgId = md5($param['openid'].time());
            $priceState = (new SaasOrderPrice)->insertGetId([
                "openid"        => $param['openid'],
                "poi_id"        => $param['groupId'],
                "service_id"    => $request->user['id'],
                "name"          => $param['name'],
                "price"         => $param['price'] * 100,
                "image"         => "https://jymini.oss-cn-guangzhou.aliyuncs.com/mini/chajia.jpg",
                "order_sn"      => $orderSn,
                "msgId"         => $msgId,
            ]);
            if (!$priceState) return errorTrans("error.data");
            $msgData = [
                "img"   => "https://jymini.oss-cn-guangzhou.aliyuncs.com/mini/chajia.jpg",
                "name"  => $param['name'],
                "order" => $orderSn,
                "price" => $param['price'],
                "msgId" => $msgId,
                "status"    => 0
            ];
            $state = (new SaasChatMsg)->insertGetId([
                "source"    => 2,
                "openid"    => $param['openid'],
                "content"   => json_encode($msgData),
                "type"      => $param['type'],
                "msgId"     => $msgId,
                "poi_id"    => $param['groupId'],
                "service_id" => $request->user['id'],
            ]);
            if (!$state) return errorTrans("error.data");
            $api = new Api('http://127.0.0.1:3232', config('plugin.webman.push.app.app_key'),config('plugin.webman.push.app.app_secret'));
            $api->trigger("user-{$param['openid']}","message",[
                "type"  =>  $param['type'],
                "time"  =>  time() * 1000,
                "msgId" => $msgId,
                "content"   => json_encode($msgData),
                "source" => 2,
                "avatar"    => "https://washmy.oss-cn-guangzhou.aliyuncs.com/storage/20260511/23627b2cb8f73a8a90b95c31d726e6ecad0cbb9a.png",
                "poi_id"    => $param['groupId'],
                "openid"  => $param['openid'],
                "service_id"  => $request->user['id'],
                "create_at"  => formatTime(time()),
            ]);
            return successTrans("success.data",$msgData);
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }

}