Import Category
getConnection();
?>
prepare($getProductId);
$stmt->execute();
$itemCount1 = $stmt->rowCount();
$result=[];
if($itemCount1>0){
$result = $stmt->fetch(PDO::FETCH_ASSOC);
}
if($_POST['assign_category']=='1' && $itemCount1>0){ //DELETE OTHER CATEGORY FROM PRODUCT
$sqlQueryDelete = "DELETE FROM ahqa_catalog_category_product
WHERE product_id=".$result['entity_id']."";
$stmtDel = $db->prepare($sqlQueryDelete);
$stmtDel->execute();
}
$numcols = count($data);
for($j=1; $j<$numcols;$j++){
if($data[$j]!=''){
try {
// // Load Category ID
$getCategoryId= "SELECT entity_id FROM ahqa_catalog_category_product WHERE value = '".$data[$j]."' ORDER BY value_id ASC LIMIT 1 ";
$stmt2 = $db->prepare($getCategoryId);
$stmt2->execute();
$itemCount2 = $stmt2->rowCount();
if($itemCount1>0 && $itemCount2>0){
$result2 = $stmt2->fetch(PDO::FETCH_ASSOC);
if($_POST['assign_category']=='3'){ //DELETE OTHER CATEGORY FROM PRODUCT
echo $result['entity_id'];
$sqlQueryDelete = "DELETE FROM ahqa_catalog_category_product WHERE product_id=".$result['entity_id']." AND category_id=".$result2['entity_id']." ";
$stmtDel = $db->prepare($sqlQueryDelete);
$stmtDel->execute();
}else{
//$data[$j].' = '.$data[$j].'=='.$result2['entity_id'].'==p=='.$result['entity_id'].'
';
$sqlQuery2 = "INSERT IGNORE INTO ahqa_catalog_category_product (category_id, product_id) VALUES (".$result2['entity_id'].", ".$result['entity_id'].")";
$stmt3 = $db->prepare($sqlQuery2);
if($stmt3->execute()){
http_response_code(200);
} else{
http_response_code(404);
echo $data[$j].' Sku is not updated with this = '.$data[$j].'
';
}
}
}else{
if($itemCount2==0){
echo $data[0].'-->'.$data[$j].' This Category does not exist
';
}else{
echo $data[0].'-->'.$data[$j].' This sku does not exist
';
}
}
} catch (\Exception $e) {
echo $er->getMessage() . "====>\n".$data[0].'
';
}
}
}
}
}
fclose($handle);
}
move_uploaded_file($csvfile, $target_dir . $_FILES['csvfile']['name']);
echo 'Category has been sucessfully imported';
?>