首页 > 解决方案 > Yii2如何将接收到的JSON数据保存到数据库中

问题描述

我创建了一个API返回我的数据数组json

Array ( [0] => stdClass Object ( [MSN] => 002999001207 [PingDateTime] => 2018-05-04T16:33:27 [PingValue] => 22 ) [1] => stdClass Object ( [MSN] => 002999001195 [PingDateTime] => 2018-05-04T16:34:11 [PingValue] => 21 ) [2] => stdClass Object ( [MSN] => 002999001180 [PingDateTime] => 2018-05-04T14:42:40 [PingValue] => 20 ) [3] => stdClass Object ( [MSN] => 002999001157 [PingDateTime] => 2018-05-04T14:42:52 [PingValue] => 30 ) [4] => stdClass Object ( [MSN] => 002999001142 [PingDateTime] => 2018-05-04T16:37:19 [PingValue] => 13 ) [5] => stdClass Object ( [MSN] => 002999001138 [PingDateTime] => 2018-05-04T16:32:22 [PingValue] => 20 ) [6] => stdClass Object ( [MSN] => 002999001114 [PingDateTime] => 2018-05-04T16:32:52 [PingValue] => 22 )

现在,我正在尝试将其保存在我的DB

    $curl = curl_init($api_url);

    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($curl, CURLOPT_TIMEOUT, 1000);
    curl_setopt($curl, CURLOPT_HTTPHEADER, array('Key'));

    $m->start_date_time = date('Y-m-d h:i:s');

    $curl_response = curl_exec($curl);
    $json = json_decode($curl_response);
    $record = $json->data;

    foreach ($record as $item){
        if($this->isSaved($item->MSN))
        {
            return false;
        }
        else if($this->ogpCreated($item->MSN))
        {
           $m->end_date_time = date('Y-m-d h:i:s');
           $m->meter_msn = $item->MSN;
           $m->meter_id = Meters::msnmapToid($m->meter_msn);
           $m->sub_div_code = Ogpdetail::msnTosubdiv($item->MSN);
           $m->sub_div_name = Ogpdetail::subDivToName($m->sub_div_code);
           $m->meter_ping_date_time = str_replace('T', ' ', $item->PingDateTime);
            $m->save();
        }
    }
    return $this->redirect(['index']);

在上面的代码中,有两个 if 条件

isSaved($item->MSN)

 $meter = MeterPing::find()->where(['meter_msn' => $msn])->one();

    if($meter)
        return true;
    return false;

从上面的函数中,我试图检查传入MSN是否已经保存。如果它已经存在于表中,它将不会保存该特定内容,但会保存之前未保存MSN的所有其他内容。MSN

ogpCreated($item->MSN)

 $meter = Ogpdetail::find()->where(['meter_serial' => $msn])->one();

    if($meter)
        return true;
    return false;

从上面的函数中,我试图检查传入MSN的是否已OGP创建。同样,它不应该保存任何MSNOGP创建的内容。

现在,当我尝试运行此Create功能时,它一次只保存一条记录。

我认为存在一些问题,if..... elseif即只允许保存一个条目。但我不确定。

更新 1

我试图删除检查,然后保存传入的数据,但它仍然只保存一条记录

如何在所有检查正常工作的情况下将收到的全部JSON数据保存到我的?DB

标签: phparraysjsonyii2yii2-advanced-app

解决方案


您需要$m=new YourModel();foreach循环中添加模型初始化elseif($this->ogpCreated($item->MSN)),这就是为什么它只保存一条记录

foreach ($record as $item){

 if($this->isSaved($item->MSN)){
        return false;
 }
 else if($this->ogpCreated($item->MSN)){
    $m= new YourModel();

您也在$mcurl 命令中使用,最好发布所有代码以防遇到一些逻辑错误,您需要相应地调整代码,或者从$m内部更改变量的名称foreach

除此之外,您可以将此扩展Yii2-Curl用于 curl 命令,它可以让您以更易读的方式更灵活地编写代码


推荐阅读