print-api/app/controller/api/Cart.php

<?php

namespace app\controller\api;

use app\extra\basic\Base;
use app\extra\tools\CodeExtend;
use app\middleware\WxMiddleware;
use app\model\saas\SaasCart;
use app\model\saas\SaasCombo;
use app\model\saas\SaasDiscount;
use app\model\saas\SaasPrice;
use app\model\saas\SaasPrintClient;
use app\model\saas\SaasShop;
use app\model\saas\SaasUser;
use app\model\saas\SaasUserBuy;
use app\model\saas\SaasWordChange;
use LinFly\Annotation\Route\Controller;
use LinFly\Annotation\Route\Middleware;
use LinFly\Annotation\Route\Route;
use Qcloud\Cos\Client;
use support\Request;
use support\Response;
use Webman\RedisQueue\Redis;
use yzh52521\EasyHttp\Http;


#[Controller(prefix: "/wx_api/cart"),Middleware(WxMiddleware::class)]
class Cart extends Base
{
    protected array $noNeedLogin = [];
    /**
     * 颜色
     * @var array|string[]
     */
    protected array $color = ["1" => "彩色", "2" => "黑白"];
    /**
     * 单双面
     * @var array|string[]
     */
    protected array $duplex = ["1" => "单面", "2" => "双面"];
    /**
     * 打印方向
     * @var array|string[]
     */
    protected array $direction = ["1" => "长边翻转","2" => "短边翻转",'3' => ""];
//    protected array $direction = ["1" => "自适应","2" => "横向", "3" => "竖向"];
    /**
     * 配送方式
     * @var array|string[]
     */
    protected array $package = ["1" => "店内打印", "2" => '远程自取' , "3" => "商家配送"];

    protected array $types = [
        '1_1_1' => ['name' => '彩色-单面', 'amount' => 0, 'quantity' => 0,'discount' => 0],
        '1_1_2' => ['name' => '彩色-单面', 'amount' => 0, 'quantity' => 0,'discount' => 0],
        '1_2_1' => ['name' => '彩色-双面', 'amount' => 0, 'quantity' => 0,'discount' => 0],
        '2_1_1' => ['name' => '黑白-单面', 'amount' => 0, 'quantity' => 0,'discount' => 0],
        '2_2_1' => ['name' => '黑白-双面', 'amount' => 0, 'quantity' => 0,'discount' => 0],
        '2_1_2' => ['name' => '黑白-双面', 'amount' => 0, 'quantity' => 0,'discount' => 0],
    ];

    /**
     * 获取打印购物车列表
     * @return Response
     */
    #[Route(path: "list",methods: "get")]
    public function getCartList(Request $request): Response
    {
        try {
            $param = $this->_valid([
                "shop.require"  => trans("empty.require"),
                "print.require" => trans("empty.require"),
                "type.default"  => 1
            ]);
            if (!is_array($param)) return error($param);
            $cart = (new SaasCart)->where("shop_id",$param['shop'])->where("print_id",$param['print'])->where("openid",$request->user['openid'])->order("create_at desc")->select();
            if ($cart->isEmpty()) return success('ok',['cart' => []]);
            $totalAmount = $totalDiscount = 0;
            foreach ($cart as $k=>$v){
                $key = $v['color'] . '_' . $v['duplex'] . '_' . $v['source'];
                if (isset($this->types[$key])) {
                    $this->types[$key]['quantity'] += $v['page'];
                    $this->types[$key]['amount'] += $v['money'];
                }
                $cart[$k] = $v;
                $cart[$k]['money'] = format_money($v['money'] / 100,2);
                $cart[$k]['name'] = msubstr($v['name'],0,12);
                $cart[$k]['jobStatus'] = 'success';
            }
            $printData = (new SaasPrintClient)->where("shop_id",$param['shop'])->where("code",$param['print'])->select();
            if ($printData->isEmpty()) return error('无可用打印机');
            $rule = [];
            foreach ($printData as $key=>$value) {
                $rule[$key]['check'] = 0;
                $nameColor = "";
                if (empty($value['rule'])) return error("尚未配置打印机~");
                foreach ($value['rule']['color'] as $key2=>$val) {
                    $rule[$key]['color'][$key2][$val] = $this->color[$val];
                    $nameColor .= $this->color[$val];
                }
                foreach ($value['rule']['direction'] as $key2=>$val) {
                    $rule[$key]['direction'][$key2][$val] = $this->direction[$val];
                }
                foreach ($value['rule']['duplex'] as $key2=>$val) {
                    $rule[$key]['duplex'][$key2][$val] = $this->duplex[$val];
                }
                foreach ($value['rule']['package'] as $key2=>$val) {
                    $rule[$key]['package'][$key2][$val] = $this->package[$val];
                }
                foreach ($value['rule']['paper_size'] as $key2=>$val) {
                    $rule[$key]['paper_size'][$key2][$val] = $val;
                }
                if ($param['print'] == $value['code']) {
                    $rule[$key]['check'] = 1;
                }
                $rule[$key]['name'] = $nameColor."-".$value['name'];
                $rule[$key]['code'] = $value['code'];
            }
            // 计算折扣
            foreach ($this->types as $k=>$v) {
                $discount = (new SaasDiscount)->where("shop_id",$param['shop'])->where("keys",$k)->where("number",'<',$v['quantity'])->findOrEmpty();
                if (!$discount->isEmpty()) {
                    $v['discount'] = round($v['amount'] * $discount['rate']);
                    $this->types[$k]['discount'] = $v['discount'];
                }
                $totalAmount += $v['amount'];
                $totalDiscount += $v['discount'];
            }
            $totalAmount = format_money($totalAmount / 100,2);
            $totalDiscount = format_money($totalDiscount / 100,2);
            if ($param['type'] <> 1) {
                $shop = (new SaasShop)->where("shop_id",$param['shop'])->field("shop_name,shop_address,user_card,user_card_price")->find();
                $isRecharge = (new SaasUserBuy)->where("shop_id",$param['shop'])->where("openid",$request->user['openid'])->where("status",1)->sum("money");;
                $cardPrice = [];
                if ($shop['user_card'] < 3) {
                    if ($shop['user_card'] == 2) { // 自定义套餐
                        $cardPrice = array_values($shop['user_card_price']);
                    } else {
                        $cardPrice = (new SaasCombo)->where("type",2)->field("id,name,ROUND(money/100,2) as money,ROUND(old_money/100,2) as old_money,is_first")->where("status",1)->select()->toArray();
                    }
                    $cardPrice = array_filter($cardPrice, function($item) use ($isRecharge) {
                        if ($isRecharge > 0) {
                            return $item['is_first'] != '1'; // 注意：这里使用松散比较，因为数据中有字符串'1'
                        } else {
                            return $item;
                        }
                    });
                    foreach ($cardPrice as $key=>$val) {
                        $cardPrice[$key] = $val;
                        $cardPrice[$key]['money'] = $val['money'];
                        $cardPrice[$key]['old_money'] = $val['old_money'];
                    }
                    $cardPrice = array_values($cardPrice);
                }
                $card = (new SaasUser)->where("openid",$request->user['openid'])->where("shop_id",$param['shop'])->field("ROUND(balance/100,2) as money")->findOrEmpty();
                if ($card->isEmpty()) {
                    $card = null;
                }
                $package = $this->package;
                return success("",compact('rule','totalAmount','totalDiscount','shop','cardPrice','package','card'));
            }
            return success("",compact('cart','rule','totalAmount','totalDiscount'));
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }

    /**
     * 删除购物
     * @param Request $request
     * @return Response
     */
    #[Route(path: "del",methods: "post")]
    public function delCart(Request $request): Response
    {
        try {
            $param = $this->_valid([
                "shop.require"  => trans("empty.require"),
                "id.require"    => trans("empty.require"),
                "print.require" => trans("empty.require"),
            ],"post");
            if (!is_array($param)) return error($param);
            $cart = (new SaasCart)->where("id",$param['id'])->findOrEmpty();
            if ($cart->isEmpty()) return error("操作失败");
            if ($cart['openid'] <> $request->user['openid']) return error("操作失败");
            $state = $cart->delete();
            if (!$state) return error("操作失败");
            return success("操作成功");
        } catch (\Throwable $exception) {
            return error($exception->getMessage());
        }
    }

    /**
     * 更新购物
     * @param Request $request
     * @return Response
     */
    #[Route(path: "update",methods: "post")]
    public function updateCart(Request $request): Response
    {
        try {
            $param = $request->post();
            $cart = (new SaasCart)->where("id",$param['id'])->where("openid",$request->user['openid'])->findOrEmpty();
            if ($cart->isEmpty()) return error('数据格式错误');
            if ($param['end_page'] > $cart['total_page']) return error('打印范围不能大于总页数');
            // 查询默认打印机是否有额外收费规则
            $printData = (new SaasPrintClient)->where("shop_id",$param['shop_id'])->where("code",$param['print'])->findOrEmpty();
            $extraMoney = 0;
            $moneyMode = (new SaasPrice)->where([
                "shop_id"   => $param['shop_id'],
                "paper_size" => $param['paper_size'],
                "type"      => $param['source'],
                "color"     => $param['color'],
                "duplex"    => $param['duplex'],
            ])->findOrEmpty();
            if ($moneyMode->isEmpty()) return error("尚未设置收费规则");
            if (!empty($printData['price']) && $printData['is_price'] == 1) {
                $priceRule = isset($printData['price'][$moneyMode['id']]['price']) ? $printData['price'][$moneyMode['id']]['price'] : 0;
                $extraMoney = $priceRule * 100;
            }
            if ($param['duplex'] == 2) {
                $updateData['page'] = ceil(($param['end_page'] - $param['start_page'] + 1) / 2); // 双面
            } else {
                $updateData['page'] = $param['end_page'] - $param['start_page'] + 1;
            }
            $updateData['extra_money'] = $extraMoney;
            $updateData['money'] = ($moneyMode['price']*100 + $extraMoney) * $updateData['page'] * $param['number'];
            $updateData['single_money'] = $moneyMode['price']*100;
            $updateData['single_id'] = $moneyMode['id'];
            $updateData['paper_size'] = $param['paper_size'];
            $updateData['number'] = $param['number'];
            $updateData['duplex'] = $param['duplex'];
            $updateData['direction'] = $param['direction']??1;
            $updateData['color'] = $param['color'];
            $updateData['start_page'] = $param['start_page'];
            $updateData['end_page'] = $param['end_page'];
            $state = $cart->save($updateData);
            if (!$state) return error("数据操作失败");
            return success("更新成功");
        } catch (\Throwable $exception) {
            return error($exception->getMessage());
        }
    }


    /**
     * 预览
     * @return Response
     */
    #[Route(path: "preview",methods: "post")]
    public function wordPreview(): Response
    {
        try {
            return success("",[
                "host"  => "https://".sConf("storage.cos_http_domain")."/",
                "query" => "?ci-process=doc-preview&dstType=jpg&imageDpi=120&page="
            ]);
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }


    /**
     * 图片打印
     * @return Response
     */
    #[Route(path: "image",methods: "post")]
    public function uploadMultiImage(): Response
    {
        try {
            return success("");
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }

    /**
     * 文档打印
     * @return Response
     */
    #[Route(path: "word",methods: "post")]
    public function uploadWord(Request $request): Response
    {
        try {
            $param = $this->_valid([
                "shop.require"      => trans("empty.require"),
                "word.require"      => trans("empty.require"),
                "print.require"     => trans("empty.require"),
                "type.default"      => 1, // 1打印 2复印
                "size.default"      => "", // 纸张类型
            ],$request->method());
            if (!is_array($param)) return error($param);
            $wordData = json_decode($param["word"], true);
            $printData = (new SaasPrintClient)->where(['shop_id' => $param['shop'],'code' => $param['print']])->findOrEmpty();
            if ($printData->isEmpty()) return error('无可用打印机');
            if ($printData['status'] <> 1) return error('当前打印机不可用');
            $paperRule = is_string($printData['rule'])?json_decode($printData['rule'],true):$printData['rule'];
            $paperSize = count($paperRule['paper_size'])==1?$paperRule['paper_size'][0]:'A4';
            $colorSize = count($paperRule['color'])==1?$paperRule['color'][0]:2;

            $paperSize = empty($param['size'])?$paperSize:$param['size'];
            $moneyMode = (new SaasPrice)->where(['shop_id' => $param['shop'],'paper_size' => $paperSize,'color' => $colorSize,'type' => $param['type']])->findOrEmpty();
            if ($moneyMode->isEmpty()) return error("店铺未设置收费规则");
            $extraMoney = 0;
            // 计算额外收费
            if (!empty($printData['price']) && $printData['is_price'] == 1) {
                $priceRule = isset($printData['price'][$moneyMode['id']]['price']) ? $printData['price'][$moneyMode['id']]['price'] : 0;
                $extraMoney = $priceRule * 100 ;
            }
            $cartData = [];
            foreach ($wordData as $key=>$val) {
                if ($val['total'] <= 0) {
                    return error("请检查上传文档是否有显示页数");
                }
                $cartData[$key] = [
                    "money"         => ($val['total'] * $moneyMode['price'] * 100) + ($extraMoney * $val['total']),
                    "extra_money"   => $extraMoney,
                    "number"        => 1,
                    "duplex"        => 1,
                    "color"         => $colorSize,
                    "page"          => $val['total'],
                    "total_page"    => $val['total'],
                    "end_page"      => $val['total'],
                    "name"          => $val['name'],
                    "openid"        => $request->user['openid'],
                    "shop_id"       => $param['shop'],
                    "paper_size"    => $paperSize,
                    "extension"     => $val['ext'],
                    "source"        => $param['type'],
                    "icon"          => "https://inmei-print.oss-cn-guangzhou.aliyuncs.com/extension/{$val['ext']}.png", // 图标
                    "single_money"  => $moneyMode['price'] * 100,
                    "single_id"     => $moneyMode['id'],
                    "path"          => $val['cosKey'],
                    "print_id"      => $param['print'],
                    "print_name"    => $printData['name'],
                ];
            }
            if (empty($cartData)) return error('上传失败');
            $state = (new SaasCart)->insertAll($cartData);
            if (!$state) return error("解析文档失败,请重试");
            return success("ok");
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }

    /**
     * 读取页码
     * ?ci-process=doc-preview&page=1&dstType=jpg&imageDpi=120
     * ?ci-process=doc-preview&page=2&sheet=1&excelPaperDirection=0
     */
    #[Route(path: "total",methods: ['post','get'])]
    public function checkTotal(Request $request): Response
    {
        try {
            $param = $this->_valid([
                "cosKey.require"  => trans("empty.require"),
                "type.default"  => "",
                "ext.default"  => ""
            ],$request->method());
            if (!is_array($param)) return error($param);
            $suffix = pathinfo($param['cosKey'], PATHINFO_EXTENSION);
            if (empty($suffix)) return error("empty.data.suffix");
            return error("请重启小程序");
            $cosClient = new Client([
                'region' => sConf("storage.cos_region"),
                'schema' => 'https', // 协议头部，默认为 http
                'credentials' => array(
                    'secretId' => sConf("storage.cos_access_key"),
                    'secretKey' => sConf("storage.cos_secret_key"),
                ),
                "verify"    => false
            ]);
            $url = $cosClient->getObjectUrl(sConf("storage.cos_bucket"), $param['cosKey']);
            $params = array(
                'ci-process' => 'doc-preview',
                'page' => 1,
                'dstType' => 'jpg',
                'imageDpi' => '120',
            );
            $query = http_build_query($params);
            $path = $url.$query;
            $resp = Http::get($path)->headers();
            if (!isset($resp['X-Total-Page'])) return error("文档可能需要密码，请先删除后再确认");
            $page = $resp['X-Total-Page']?$resp['X-Total-Page'][0]:1;
            $path = $param['cosKey'];
            return success("ok",compact('page','path'));
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }


    #[Route(path: "change_total",methods: ['post','get'])]
    public function checkChangeStep(Request $request)
    {
        try {
            $param = $this->_valid([
                "cosKey.require"  => trans("empty.require"),
                "type.default"  => "",
                "ext.default"  => ""
            ],$request->method());
            if (!is_array($param)) return error($param);
            $suffix = pathinfo($param['cosKey'], PATHINFO_EXTENSION);
            if (empty($suffix)) return error("empty.data.suffix");
            $cosClient = new Client([
                'region' => sConf("storage.cos_region"),
                'schema' => 'https', // 协议头部，默认为 http
                'credentials' => array(
                    'secretId' => sConf("storage.cos_access_key"),
                    'secretKey' => sConf("storage.cos_secret_key"),
                ),
                "verify"    => false
            ]);
            $url = $cosClient->getObjectUrl(sConf("storage.cos_bucket"), $param['cosKey']);
            $params = array(
                'ci-process' => 'doc-preview',
                'page' => 1,
                'dstType' => 'jpg',
                'imageDpi' => '120',
            );
            $query = http_build_query($params);
            $pathUri = $url.$query;
            $resp = Http::get($pathUri)->headers();
            if (!isset($resp['X-Total-Page'])) return error("文档可能需要密码，请先删除后再确认");
            $page = $resp['X-Total-Page']?$resp['X-Total-Page'][0]:1;
            if ($param['ext'] !== 'pdf') {
                $change = (new SaasWordChange)->where("key",md5($param['cosKey']))->findOrEmpty();
                if ($change->isEmpty())
                {
                    $result = $cosClient->CreateDocProcessJobs([
                        'Bucket' => sConf("storage.cos_bucket"), // 存储桶名称，由 BucketName-Appid 组成，可以在 COS 控制台查看 https://console.cloud.tencent.com/cos5/bucket
                        'Tag' => 'DocProcess', //任务的 Tag：DocProcess 固定值
                        'Input' => array(
                            'Object' => $param['cosKey'] //待操作的文件对象
                        ),
                        'Operation' => array(
                            'DocProcess' => array(
                                'SheetId' => 0, //表格文件参数，转换第 X 个表，默认为1
                                'StartPage' => 1, //从第 X 页开始转换，默认为1
                                'Quality' => 100, //生成预览图的图片质量，取值范围 [1-100]，默认值100
                                'Zoom' => 100, //预览图片的缩放参数，取值范围[10-200]， 默认值100
                                "ImageDpi" => 300
                            ),
                            'Output' => array(
                                'Region' => sConf("storage.cos_region"), //存储桶的地域
                                'Bucket' => sConf("storage.cos_bucket"), // 存储结果的存储桶
                                'Object' => 'out/'.date('Ymd').'/'.time().md5($param['cosKey']).'-${Number}.pdf', //输出文件路径
                            ),
                        ),
                    ])->toArray();
                    $change->insertGetId([
                        "key"       => md5($param['cosKey']),
                        "task_id"   => $result['JobsDetail']['JobId']??'',
                        "total"     => $page
                    ]);
                    return error("error");
                }
                $result = $cosClient->describeDocProcessJob(array(
                    'Bucket' => sConf("storage.cos_bucket"), // 存储桶名称，由 BucketName-Appid 组成，可以在 COS 控制台查看 https://console.cloud.tencent.com/cos5/bucket
                    'Key' => $change['task_id'], // JobId
                ))->toArray();
                if ($result['JobsDetail']['State'] == 'Success') {
                    $change->status = 1;
                    $change->path = $result['JobsDetail']['Operation']['DocProcessResult']['PageInfo'][0]['TgtUri']??'';
                    $change->end_at = getDateFull();
                    $change->save();
                    $page = $change['total'];
                    $path = $change['path'];
                    return success("ok",compact("path","page"));
                }
                return error("Error");
            } else {
                $path = $param['cosKey'];
                return success("ok",compact("path","page"));
            }
        } catch (\Throwable $throwable) {
            return error($throwable->getMessage());
        }
    }



    /**
     * 获取打印机支持的纸张
     * @param Request $request
     * @return Response
     */
    #[Route(path: "size",methods: ['post','get'])]
    public function getPageSize(Request $request): Response
    {
        try {
            $param = $this->_valid([
                "shop.require"      => trans("empty.require"),
                "print.require"     => trans("empty.require")
            ],$request->method());
            if (!is_array($param)) return error($param);
            $printData = (new SaasPrintClient)->where(['shop_id' => $param['shop'],'code' => $param['print']])->findOrEmpty();
            if ($printData->isEmpty()) return error('无可用打印机');
            $paperRule = is_string($printData['rule'])?json_decode($printData['rule'],true):$printData['rule'];
            return success("ok",['size' => $paperRule['paper_size']]);
        } catch (\Throwable $th) {
            return error($th->getMessage());
        }
    }

}