print-api/app/controller/exe/Prints.php

<?php

namespace app\controller\exe;

use app\extra\basic\Base;
use app\middleware\ExeMiddleware;
use app\model\saas\SaasOrder;
use app\model\saas\SaasOrderDetail;
use app\model\saas\SaasPrintClient;
use app\model\saas\SaasShop;
use LinFly\Annotation\Route\Controller;
use LinFly\Annotation\Route\Middleware;
use LinFly\Annotation\Route\Route;
use support\Request;
use support\Response;


#[Controller(prefix: "/exe/prints"),Middleware(ExeMiddleware::class)]
class Prints extends Base
{

    protected array $noNeedLogin = ["getPrintData"];

    /**
     * 回传打印机信息
     * @param Request $request
     * @return Response
     */
    #[Route(path: "set",methods: "post")]
    public function getPrintList(Request $request): Response
    {
        try {
            $param = $request->post();
            if (empty($param)) return errorTrans("empty.data");
            $shopId = $request->uuid;
            $mode = (new SaasPrintClient);
            $printIn = [];
            foreach ($param as $key=>$val)
            {
                $param[$key] = $val;
                $printId = strToUniqueNumberV4(trim($val['name']));
                $param[$key]['key'] = "{$printId}-{$shopId}";
                $param[$key]['userKey'] = $printId;
                $printData = $mode->where("code",$printId)->where("shop_id",$shopId)->findOrEmpty();
                if ($printData->isEmpty()) {
                    $printIn[$key] = [
                        "shop_id"       => $shopId,
                        "code"          => $printId,
                        "name"          => $val['name'],
                        "ipaddress"     => $val['ipAddress'],
                        "print_status"  => $val['status'],
                    ];
                }
            }
            if (!empty($printIn)) {
                $mode->insertAll(array_values($printIn));
            }
            (new SaasShop)->where("shop_id",$shopId)->update(['line_time' => getDateFull()]);
            return success("ok",$param);
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }

    /**
     * 打印回传
     * @param Request $request
     * @return Response
     */
    #[Route(path: "status",methods: "post")]
    public function getPrintData(Request $request): Response
    {
        try {
            $param = $this->_valid([
                "data.require"      => trans("empty.data"),
                "param.require"     => trans("empty.data"),
            ],$request->method());
            if (!is_array($param)) return error($param);
            $orderId = $param['param']['jobId'];
            $order = (new SaasOrderDetail)->where("id",$orderId)->with(['orders'])->findOrEmpty();
            $total = ['t0' => 0, 't1' => 0, 't2' => 0, 't3' => 0, 'ta' => 0];
            foreach ((new SaasOrderDetail)->where("id",$orderId)->field('create_at,status,count(1) total')->group('status,create_at')->cursor() as $vo)
            {
                [$total["t{$vo['status']}"] += $vo['total'], $total['ta'] += $vo['total']];
            }
            $outPut = $param['data']['outputArray'];
            $logData = [];
            foreach ($outPut as $key=>$val) {
                if ($val['type'] == 'stdout') {
                    $logData[$key] = [
                        "order_sn"  => $param['param']['customFileName'],
                        "msg"       => delNt($val['data'])
                    ];
                } else if ($val['type'] == "exit") {
                    if ($val['code'] == 0) {
                        $order->status = 3;
                        $order->save();
                        if (($total['t3']+1) == $total['ta']) {
                            (new SaasOrder)->where("order_sn",$order['order_sn'])->update(['status' => 3,'print_at' => getDateFull()]);
                        }
                    }
                }
            }
            $logData = array_values($logData);
            if (!empty($logData)) {

            }
            return success("ok");
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }

}