数组分块函数array_chunk和array_slice

小鱼儿 2022-11-04 12:26 205阅读 0赞

在一些场景，例如当查询出的一个数组列表元素过大时，再次进行查询效率会变慢

这时候需要进行分块然后分批查询

可以使用array\_chunk分块  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FoYW90YXRh_size_16_color_FFFFFF_t_70]  
array\_slice() 函数在数组中根据条件取出一段值，并返回  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FoYW90YXRh_size_16_color_FFFFFF_t_70 1]  
看一个使用案例

public function insuranceRecordOp($date)
        {
            if (!empty($date)) {
                $start_time = $date . ' 00:00:00';
                $end_time = $date . ' 23:59:59';
            } else {
                $start_time = date('Y-m-d', (time() - 24 * 60 * 60)) . ' 00:00:00';
                $end_time = date('Y-m-d', (time() - 24 * 60 * 60)) . ' 23:59:59';
            }
    
            $where = array(
                'create_time' => [['egt', $start_time], ['elt', $end_time], 'and'],
            );
            $od_list = \Order\Model\OrderModel::odSelect($where, 'create_time,id', null);
    
            $od_ids = array_column($od_list, 'id');
            $done_od_ids = [];
            //$ids_chunk = array_chunk($od_ids, 200);
            foreach (array_chunk($od_ids, 200) as $ids) {
                $insurance_list = $this->__insurance_record_model->getInsuranceList(['od_id' => ['in', $ids]], ['od_id']);
                $done_od_ids = array_merge($done_od_ids, array_column($insurance_list, 'od_id'));
            }
            $od_id_list = array_diff($od_ids, $done_od_ids);
            if (empty($od_id_list)) echo ERRNO::SUCCESS;
    
            $offset = 0;
            $length = 50;
            $data_count = count($od_id_list);
            $data_list = [];
            //分批获取数据
            while ($offset < $data_count) {
                $tmp_data = array_slice($od_id_list, $offset, $length);
                $filters = [
                    'od_id' => [
                        'predicate' => FILTER_PREDICATE::IN,
                        'value' => array_values($tmp_data),
                    ],
                ];
                $dbg = [];
                $limit = array('page_num' => 0, 'page_size' => $length);
                $fields = [
                    "od_id", "od_link_id", "od_basic_id", "group_id", "com_id", "order_dn", "b_tr_tr_num", "tr_num",
                    "num", "billing_date", "weight", "declared_value", "b_tr_basic_id", "order_num", "g_name",
                    "co_point", "cor_addr_info_str", "cee_addr_info_str", "od_ext_info", "entrust_num", "goods_num",
                    "b_tr_tr_num_ext", "pickup_tr_num", "od_create_time", "od_ext_info", "cor_addr_info", "cee_addr_info"
                ];
                list($data_list_tmp) = OrderModel::fetchOrders($fields, $filters, '', $limit, null, $dbg, [], []);
                if (empty($data_list_tmp)) {
                    c_log('运单od_id为:' . implode(',', $data_list_tmp) . '生成保单时获取昨日运单信息错误', 'ERROR_TRACE');
                    //return $this->doResponse(\Basic\Cnsts\ERRNO::INVALID_ERRNO, '生成保单时无法获取运单信息', $data_list_tmp);
                }
                $data_list = array_merge($data_list, $data_list_tmp);
                $offset += $length;
                usleep(200);
            }
    
            foreach ($data_list as $key => $value) {
                $data = [
                    'info' => [
                        'group_id' => $value['group_id'],
                        'company_id' => $value['com_id']
                    ],
                    'b_info' => [
                        'b_basic_id' => $value['b_tr_basic_id']
                    ],
                    'tr_num' => $value['b_tr_tr_num']
                ];
                //$value['cor_addr_info'] = json_decode($value['cor_addr_info_str'], true);
                //$value['cee_addr_info'] = json_decode($value['cee_addr_info_str'], true);
                $ret_insurance = $this->insurance_srv->insuranceRecordManageData($value, $data, 'add');
                if ($ret_insurance['errno'] != ERRNO::SUCCESS) {
                    c_log('运单order_num为:' . $value['order_num'] . '生成保单错误', 'ERROR_TRACE');
                    //return $this->doResponse($ret_insurance['errno'], $ret_insurance['errmsg'], $data_list);
                }
            }
            echo ERRNO::SUCCESS;
    
        }

在上诉场景中，都使用array\_chunk分块然后循环更好

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FoYW90YXRh_size_16_color_FFFFFF_t_70]: /images/20221023/a87d39a4f03647e19cf92e489bbb70af.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FoYW90YXRh_size_16_color_FFFFFF_t_70 1]: /images/20221023/618b718145504a71a16110e0f98f6973.png