ym.7in6.com/application/admin/controller/Finishedproduct.php

<?php

namespace app\admin\controller;

use app\common\controller\Backend;
use function EasyWeChat\Kernel\Support\rsa_public_encrypt;

/**
 * 版本管理
 *
 * @icon fa fa-circle-o
 */
class Finishedproduct extends Backend
{

    /**
     * Finishedproduct模型对象
     * @var \app\admin\model\Finishedproduct
     */
    protected $model = null;

    public function _initialize()
    {
        parent::_initialize();
        $this->model = new \app\admin\model\Finishedproduct;
        $this->view->assign("statusList", $this->model->getStatusList());
    }



    /**
     * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
     * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
     * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
     */


    public function index()
    {
        // 获取前端传入的参数：搜索关键词、页码、每页数量（默认为第一页，每页10条）
        $search = input('get.search');
        $page = input('get.page', 1);
        $limit = input('get.limit', 10);
        // 连接配置中的 db3 数据库
        $db3 = \db()->connect(config('database.db3'));

        $query = $db3->name('成品入仓')
            ->where('jjcp_smb', '=', '末 板')
            ->whereNull('Mod_rq');
        $where = ['jjcp_cpdh'=>['like','%'.$search.'%']];

        $total = $query->where($where)->count();
        $data = $query->field('jjcp_cpdh, jjcp_cpmc, jjcp_sl, UniqId, jjcp_smb')
            ->where($where)
            ->limit(($page - 1) * $limit, $limit)
            ->select();

        foreach ($data as &$row) {
            $row['jjcp_smb'] = ($row['jjcp_smb'] === '末 板') ? '完工入库' : '未完工入库';
        }

        //AJAX 请求
        if (request()->isAjax()) {
            return json([
                'data'  => $data,
                'total' => $total,
                'page'  => $page,
                'limit' => $limit
            ]);
        }
        $this->assign('data', $data);
        return $this->fetch();
    }


    public function finished()
    {
        // 获取 JSON 格式的请求体
        $jsonData = file_get_contents("php://input");

        // 解析为 PHP 数组
        $data = json_decode($jsonData, true);

        if (!isset($data['data']) || !is_array($data['data'])) {
            return json(['status' => 'error', 'msg' => '无效数据']);
        }

        // 连接 MongoDB 数据库（你在 config/database.php 中的 mongodb 配置名）
        $mongo = \think\Db::connect('mongodb');

        $insertList = [];

        foreach ($data['data'] as $item) {
            $insertList[] = [
                'jjcp_cpdh' => $item['jjcp_cpdh'],
                'jjcp_cpmc' => $item['jjcp_cpmc'],
                'jjcp_sl'   => intval($item['jjcp_sl']),
                'jjcp_smb'  => '已入库',
                'created_at' => date('Y-m-d H:i:s')
            ];
        }

        try {
            // 批量插入 MongoDB 集合（表） Finished_products
            $mongo->name('Finished_products')->insertAll($insertList);
            return json(['status' => 'success', 'msg' => '成功插入 MongoDB']);
        } catch (\Exception $e) {
            return json(['status' => 'error', 'msg' => '插入失败：' . $e->getMessage()]);
        }
    }



}