form_rekomendasi_controller.php

<?php 
ob_start();
require_once 'connectdb.php';

 require_once 'user_controller.php';
$func = $_GET['func'];

if ($func == 1){
	insertRekomendasi();
}

function insertRekomendasi(){
	$conn = connect_database();

	$id_pegawai = $_POST["NIK_dinilai"];
	$id_penilai =  $_POST["NIK_penilai"]; //dari POST
	$Rek_promosi =  $_POST["Rek_promosi"];
	$Rek_pendidikan =  $_POST["Rek_pendidikan"];
	$Rek_mutasi =  $_POST["Rek_mutasi"] ;

	
	// Cek apakah NIP & periode sudah ada di tabel penilaian
	$id_penilaian = 0;
	$cur_periode = date("Y");
	
// Cek apakah NIP & periode sudah ada di tabel penilaian
	$sql = "SELECT id_penilaian FROM penilaian WHERE id_pegawai ='$id_pegawai' AND periode = YEAR(CURDATE())";
	$result = $conn->query($sql);

	// Jika sudah ada, ambil id_penilaiannya
	if ($result->num_rows > 0) { 
	    while($row = $result->fetch_assoc()) {
	        $id_penilaian = $row["id_penilaian"];
	        echo "udah ada penilaian " . $id_penilaian. "<br>";
	    }
	} else { // Jika belum ada, buat record di tabel penilaian
	    $sql1 = "INSERT INTO penilaian (id_pegawai, id_penilai, periode)
		VALUES ('$id_pegawai','$id_penilai', YEAR(CURDATE()))";

		if ($conn->query($sql1) === TRUE) {
		    echo "New record created successfully";
		} else {
		    echo "Error: " . $sql . "<br>" . $conn->error;
		}

		$sql2 = "SELECT id_penilaian FROM penilaian WHERE id_pegawai ='$id_pegawai' AND periode = YEAR(CURDATE())";
		$result = $conn->query($sql2);

		if ($result->num_rows > 0) {
		    while($row = $result->fetch_assoc()) {
		        $id_penilaian = $row["id_penilaian"];
		    }
		}

		 echo "belom ada penilaian " . $id_penilaian. "<br>";

	}

	// Cek apakah rekomendasi udah ada dgn id_penilaian yg didapatkan
	echo "id_penilaian " . $id_penilaian. "<br>";
	$id_rekomendasi = 0;
	$sql = "SELECT id_rekomendasi FROM rekomendasi WHERE id_penilaian=$id_penilaian";
	echo $sql . "<br>" ;

	$result = $conn->query($sql);
	echo "-- <br>";
	// Jika sudah ada, update
	if ($result->num_rows > 0) {
		echo "** <br>";
	    while($row = $result->fetch_assoc()) {
	        $id_rekomendasi = $row["id_rekomendasi"];
	    }

	    $sql1 = "UPDATE rekomendasi
	    SET rek_pelatihan='$Rek_pendidikan' , rek_promosi = '$Rek_promosi', rek_mutasi = '$Rek_mutasi'
	    WHERE id_rekomendasi = '$id_rekomendasi' ";

		if ($conn->query($sql1) === TRUE) {
		    echo "New record created successfully";
		} else {
		    echo "Error: " . $sql . "<br>" . $conn->error;
		}


	} else { // Jika belom ada, insert
		echo "++ <br>";
		$sql1 = "INSERT INTO rekomendasi (id_penilaian,id_rekomendasi,rek_pelatihan,rek_promosi,rek_mutasi)
		VALUES ($id_penilaian, $id_rekomendasi, '$Rek_pendidikan', '$Rek_promosi', '$Rek_mutasi')";
		echo $sql1 . "<br>";
		if ($conn->query($sql1) === TRUE) {
		    echo "New record created successfully";
		} else {
		    echo "Error: " . $sql . "<br>" . $conn->error;
		}

	}
	


	header( 'Location: ../isi_rekomendasi.php' ) ;
	exit();
}


ob_end_flush();
?>