添加数据为数组

谁践踏了优雅 2022-03-11 05:28 202阅读 0赞

添加数据为数组且不知道多少个  
循环组装添加皆可

/**
         * @param $params
         * @return bool
         * @throws Exception
         */
        public function add($params)
        {
    
            $objMdl = app::get('syscompany')->model('card');
    
            $data = [
                'company_name'=>$params['company_name'],
                'user_name'=>$params['user_name'],
                'job'=>$params['job'],
                'type_id'=>$params['type_id'],
                'user_id'=>1,
                'mobile'=>$params['mobile'],
                'create_time'=>time(),
            ];
    
    
            ########产品表写入
            if(is_array($params['product_id'])){
                $params['product_id'] = $params['product_id'];
            }else{
                $params['product_id'] = explode(',',$params['product_id']);
            }
            $newStr = '';
            $params['product_id'] = array_filter($params['product_id']);
            foreach ($params['product_id'] as $key=>$value){
                $productData['card_id'] = $params['card_id'];
                $productData['product_id'] = $value;
                $productData['create_time'] = time();
                $newStr = $newStr.'('.implode(',', $productData)."),";
            }
            $strValues = substr($newStr, 0, -1);
            $sql = "INSERT INTO
                        `syscompany_card_product`
                        (`card_id`,
                        `product_id`,                   
                        `create_time`
                        ) VALUES $strValues";
            ################
    
    
            $db = app::get('syscompany')->database();
            $db->beginTransaction();
    
            try {
    
                $objMdl->insert($data);
                app::get('base')->database()->executeQuery($sql);
                $db->commit();
    
                return true;
    
    
            } catch (Exception $e) {
                $db->rollback();
    
                throw new Exception('添加失败了了');
            }
    
        }