<?php namespace myretail\models;use Yii;use yii\base\Model;use myretail\models\SyncConfig;class ImportProduct extends Model{public static $tipe_tabel="inv_item";public function kirimData($data,$access_token){$base=SyncConfig::$base;$curl=curl_init();curl_setopt_array($curl,array(CURLOPT_URL=>"https://$base.jurnal.id/core/api/v1/products/batch_create",CURLOPT_RETURNTRANSFER=>true,CURLOPT_CUSTOMREQUEST=>"POST",CURLOPT_POSTFIELDS=>json_encode($data),CURLOPT_HTTPHEADER=>array("apikey: $access_token","Content-Type: application/json")));$response=curl_exec($curl);curl_close($curl);return $response;}public function simpanStatus($data,$tipe_tabel,$id_lokal,$idHeaderLog,$lastheader){$type_con=SyncConfig::$type_con;$conn=SyncConfig::getConnection();$tgl=date("Y-m-d H:i:s");$berhasil=0;$data=json_decode($data,TRUE);for($i=0;$i<count($data['products']);$i++){$id=$id_lokal[$i];$status=$data['products'][$i]['product']['status'];$id_jurnal=0;if($status==201){$id_jurnal=$data['products'][$i]['product']['content']['id'];$status_sinkron="success";$ket="";$berhasil++;}elseif($status==409){$status_sinkron="skip";$ket="Nama Menu Sudah Ada";}else{$status_sinkron="failed";$ket=json_encode($data['products'][$i]['product']['content']);$ket=addslashes($ket);}$stmt=mysqli_query($conn,"SELECT tipe_tabel, id_record FROM sync_to_jurnal WHERE tipe_tabel = '$tipe_tabel' AND id_record = '$id' AND type_con = '$type_con' AND tipe_proses = 'new'");if(mysqli_fetch_assoc($stmt)<1){$query="INSERT INTO sync_to_jurnal (id_header, last_update, tipe_tabel, id_record, status_sinkron, keterangan, id_jurnal, tipe_proses, type_con) VALUES ('$idHeaderLog', '$tgl', '$tipe_tabel', '$id', '$status_sinkron', '$ket', '$id_jurnal', 'new', '$type_con')";mysqli_query($conn,$query);}else{mysqli_query($conn,"UPDATE sync_to_jurnal SET status_sinkron = '$status_sinkron', keterangan = '$ket', id_jurnal = '$id_jurnal' WHERE type_con = '$type_con' AND id_record = '$id' AND tipe_tabel = '$tipe_tabel' AND id_header = '$lastheader' AND tipe_proses = 'new'");}}return $berhasil;}public function ambilData($status,$tipe_tabel){$type_con=SyncConfig::$type_con;$conn=SyncConfig::getConnection('MyConnection');$connMyRetail=SyncConfig::getConnection('MyRetail');$dbNameMyConnection=SyncConfig::getDbNameMyConnection();$last_key=0;$stmt=mysqli_query($conn,"SELECT id_record FROM sync_to_jurnal WHERE tipe_tabel = '$tipe_tabel' AND type_con = '$type_con' ORDER BY id_record DESC LIMIT 1");$row=mysqli_fetch_assoc($stmt);if($row>0){$last_key=$row['id_record'];}$stmt=mysqli_query($conn,"SELECT inventory_account_number FROM sync_config WHERE type_con = '$type_con'");$row=mysqli_fetch_assoc($stmt);$inv=$row['inventory_account_number'];$result=array();if($status=="import"){$stmt=mysqli_query($connMyRetail,"SELECT a.fpkey, a.fcode, fname, fpur_price, fsalesprice, funit, fdesc, b.fcategory category, c.fcategory sub_category, a.fnonstock
                FROM inv_item a
                LEFT JOIN inv_item_category b ON a.fcategorykey = b.fpkey
                LEFT JOIN inv_item_sub_category c ON a.fcategorykey2 = c.fpkey
                LEFT JOIN inv_item_unit d ON a.fstock_unitkey = d.fpkey
                WHERE a.fpkey > '$last_key' LIMIT 10");}else{$stmt=mysqli_query($connMyRetail,"SELECT a.fpkey, a.fcode, fname, fpur_price, fsalesprice, funit, fdesc, b.fcategory category, c.fcategory sub_category, a.fnonstock
                FROM inv_item a
                LEFT JOIN inv_item_category b ON a.fcategorykey = b.fpkey
                LEFT JOIN inv_item_sub_category c ON a.fcategorykey2 = c.fpkey
                JOIN $dbNameMyConnection.sync_to_jurnal d ON a.fpkey = d.id_record
                LEFT JOIN inv_item_unit e ON a.fstock_unitkey = e.fpkey
                WHERE d.tipe_tabel = '$tipe_tabel' AND status_sinkron = 'proses' AND tipe_proses = 'new' LIMIT 10");}$i=0;while($row=mysqli_fetch_assoc($stmt)){if($row['fnonstock']==0){$stok="true";}else{$stok="false";}$result['products'][$i]['product']['id']=$row['fpkey'];$result['products'][$i]['product']['product_code']=$row['fcode'];$result['products'][$i]['product']['name']=$row['fname'];$result['products'][$i]['product']['unit_name']=$row['funit'];$result['products'][$i]['product']['buy_price_per_unit']=$row['fpur_price'];$result['products'][$i]['product']['sell_price_per_unit']=$row['fsalesprice'];$result['products'][$i]['product']['taxable_sell']=true;$result['products'][$i]['product']['description']=$row['fdesc'];$result['products'][$i]['product']['is_sold']=true;$result['products'][$i]['product']['is_bought']=true;$result['products'][$i]['product']['track_inventory']=$stok;$result['products'][$i]['product']['inventory_asset_account_number']=$inv;$result['products'][$i]['product']['product_category_names'][0]=$row['category'];$result['products'][$i]['product']['product_category_names'][1]=$row['sub_category'];$i++;}return $result;}}