src/Controller/ApiController.php line 35

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Controller\Base\BaseController;
  6. use App\Repository\TPublikasiRepository;
  7. use App\Repository\TVariabelRepository;
  8. use DateTime;
  9. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpFoundation\Response;
  12. use Symfony\Component\Routing\Annotation\Route;
  14. class ApiController extends BaseController
  15. {
  16.     /**
  17.      * @Route("/api/{id}", name="api", methods={"GET", "POST"})
  18.      */
  19.     public function index(?string $id, Request $request, TPublikasiRepository $tPublikasiRepo)
  20.     {
  21.         $publikasi = $tPublikasiRepo->find($id);
  22.         $url = $this->base_url();
  23.         // dump($url); exit;
  24.         return $this->render('api/index.html.twig', [
  25.             'publikasi' => $publikasi,
  26.             'url' => $url,
  27.         ]);
  28.     }
  30.     /**
  31.      * @Route("/api/{id}/get/{row}", name="api_get", methods={"GET"})
  32.      */
  33.     public function getApi(?string $id, string $row = null, Request $request, TVariabelRepository $tVariabelRepo, TPublikasiRepository $tPublikasiRepo)
  34.     {
  35.         $tVariabel = $tVariabelRepo->findBy(['pub' => $id, 'is_tampil' => true], ['id'=>'asc']);
  36.         $tPublikasi = $tPublikasiRepo->find($id);
  37.         $dataset = $this->getDataTable($id, $request->get('limit', null), $request->get('skip', null), null, 1, $row);
  39.         if (!$dataset) {
  40.             $result['message'] = 'Data not found';
  41.             $result['status'] = 404;
  42.             $result['data'] = [];
  44.             return $this->json($result);
  46.         }
  48.         $variabel = array();
  49.         foreach($tVariabel as $var){
  50.             $variabel[] = $var->getNama();
  51.         }
  53.         foreach($dataset as $k => $dt)
  54.         {
  55.             foreach($variabel as $key => $var)
  56.             {
  57.                 $dataset[$k][$var] = $dataset[$k][$key];
  58.                 unset($dataset[$k][$key]);
  59.             }
  60.         }
  61.         
  62.         $result['result'][0]['message'] = 'Get data successfull';
  63.         $result['result'][0]['status'] = 200;
  64.         $result['result'][0]['total'] = count($dataset);
  65.         $result['result'][0]['title'] = $tPublikasi->getJudul();
  66.         $result['result'][0]['description'] = $tPublikasi->getDeskripsi();
  67.         $result['result'][0]['unit'] = $tPublikasi->getSatuan();
  68.         $result['result'][0]['source'] = $tPublikasi->getSumber();
  69.         $result['result'][0]['year'] = $tPublikasi->getTahun();
  70.         // $result['result'][0]['urusan_code'] = ($tPublikasi->getUrusan()) ? $tPublikasi->getUrusan()->getKode() : '';
  71.         $result['result'][0]['urusan_code'] = '9';
  72.         // $result['result'][0]['sektor_code'] = ($tPublikasi->getSektor()) ? $tPublikasi->getSektor()->getKode() : '';
  73.         $result['result'][0]['sektor_code'] = '901';
  74.         $result['result'][0]['created_at'] = $tPublikasi->getCreatedAt()->format("Y-m-d H:i:s");
  75.         $result['result'][0]['updated_at'] = $tPublikasi->getUpdatedAt()->format("Y-m-d H:i:s");
  76.         $result['result'][0]['data'] = $dataset;
  78.         return $this->json($result);
  79.     }
  81.     /**
  82.      * @Route("/get/api", name="api_get_data", methods={"GET"})
  83.      */
  84.     public function getData(Request $request)
  85.     {
  86.         // $token = "4a81432adf56aeb6aadfffa65ab70ab1";
  87.         $headers = apache_request_headers();
  89.         // if (!isset($headers['token']) || $headers['token'] != $token) {
  90.         //     return $this->json(['status' => 400]);
  91.         // }
  93.         // $getToken = $headers['token'];
  95.         $request_body = file_get_contents('php://input');
  96.         header('Content-Type: application/json');
  98.         $get = json_decode($request_body, true);
  100.         if(isset($get['limit'])) {
  101.             if(!is_numeric($get['limit'])) {
  102.                 $response = $this->deliver_response(400,"invalid request");
  103.                 return $this->json($response);
  104.             }
  105.         }
  106.         if(isset($get['page'])) {
  107.             if(!is_numeric($get['page'])) {
  108.                 $response = $this->deliver_response(400,"invalid request");
  109.                 return $this->json($response);
  110.             }
  111.         }
  112.         if(isset($get['key'])) {
  113.             if(!is_numeric($get['key'])) {
  114.                 $response = $this->deliver_response(400,"invalid request");
  115.                 return $this->json($response);
  116.             }
  117.         }
  119.         // $conn = pg_connect("host=localhost port=5432 dbname=open user='postgres' password='piramida123'");
  120.         $conn = $this->getDoctrine()->getConnection();
  121.         if (!$conn) {
  122.             $response = $this->deliver_response(400,"connection failed");
  123.             return $this->json($response);
  124.         }
  126.         $key = isset($get['key']) ? ' AND a.id = ' . $get['key'] : '';
  127.         $limit = isset($get['limit']) ? $get['limit'] : 1;
  128.         $offset = null;
  129.         if (isset($get['limit']) && isset($get['page'])) {
  130.             $offset = $limit * ($get['page'] - 1);
  131.         }
  132.         else if(isset($get['page'])) {
  133.             $offset = $get['page'];
  134.         }
  135.         $sql_limit = " LIMIT $limit";
  136.         $sql_offset = " OFFSET $offset";
  138.         $ids_pub = "SELECT a.id
  139.                     FROM t_publikasi a
  140.                     WHERE a.status_id = 3 $key
  141.                     ORDER BY a.id ASC";
  143.         if (!isset($get['key'])) {
  144.             if (isset($get['limit'])) {
  145.                 $ids_pub .= $sql_limit;
  146.             }
  147.             if (isset($get['page'])) {
  148.                 $ids_pub .= $sql_offset;
  149.             }
  150.         }
  152.         $stmt = $conn->prepare($ids_pub);
  153.         $stmt->execute();
  155.         // $result = pg_prepare($conn, 'ids', $ids_pub);
  156.         // $result = pg_execute($conn, 'ids', array());
  157.         $rs_ids = [];
  158.         foreach ($stmt->fetchAll() as $row)
  159.         {
  160.             $rs_ids[] = $row['id'];
  161.         }
  162.         // return $this->json($rs_ids);
  164.         $isHeader = true;
  165.         $isVariable = true;
  166.         $isData = true;
  167.         if (isset($get['type'])) {
  168.             $tipe = $get['type'];
  169.             switch ($tipe) {
  170.                 case 'header':
  171.                     $isHeader = true;
  172.                     $isVariable = false;
  173.                     $isData = false;
  174.                     break;
  176.                 case 'variable':
  177.                     $isHeader = false;
  178.                     $isVariable = true;
  179.                     $isData = false;
  180.                     break;
  182.                 case 'data':
  183.                     $isHeader = false;
  184.                     $isVariable = false;
  185.                     $isData = true;
  186.                     break;
  187.                 
  188.                 default:
  189.                     break;
  190.             }
  191.         }
  193.         $hasil = [];
  195.         foreach ($rs_ids as $id) {
  196.             if ($isHeader) {
  197.                 $sql = "SELECT a.id, a.kode as kode, a.judul as judul, a.satuan, a.sumber as sumber, c.periode,
  198.                         a.tahun as tahun, a.deskripsi as deskripsi, d.div_nama as perangkat_daerah, e.nama as urusan,
  199.                         f.nama as sektor, g.nama as status_verifikasi, a.updated_at as tanggal
  200.                         FROM t_publikasi a
  201.                         JOIN m_periode c
  202.                         ON a.periode_id = c.id
  203.                         JOIn t_div d
  204.                         On a.div_id = d.id
  205.                         JOIN m_urusan e
  206.                         ON a.urusan_id = e.id
  207.                         JOIN m_sektor f
  208.                         ON a.sektor_id = f.id
  209.                         JOIN m_status g
  210.                         ON a.status_id = g.id
  211.                         WHERE a.id = $id";
  212.         
  213.                 $stmt = $conn->prepare($sql);
  214.                 $stmt->execute();
  215.                 
  216.                 // $result = pg_prepare($conn, '', $sql);
  217.                 // $result = pg_execute($conn, '', array());
  218.         
  219.                 foreach ($stmt->fetchAll() as $row)
  220.                 {
  221.                     $hasil[$id]['header'] = $row;
  222.                 }
  223.             }
  224.         
  225.             if ($isVariable) {
  226.                 $sql = "SELECT a.nama
  227.                         FROM t_variabel a
  228.                         WHERE a.pub_id = $id AND is_tampil is true order by a.id asc";
  229.         
  230.                 $stmt = $conn->prepare($sql);
  231.                 $stmt->execute();
  233.                 // $result = pg_prepare($conn, '', $sql);
  234.                 // $result = pg_execute($conn, '', array());
  235.         
  236.                 foreach ($stmt->fetchAll() as $row)
  237.                 {
  238.                     $hasil[$id]['variable'][] = $row['nama'];
  239.                 }
  240.             }
  241.         
  242.             if ($isData) {
  243.         
  244.                 $as_columns = "";
  245.                 $sql = "SELECT a.*
  246.                         FROM t_variabel a
  247.                         WHERE a.pub_id = $id order by a.id asc";
  248.         
  249.                 $stmt = $conn->prepare($sql);
  250.                 $stmt->execute();
  252.                 // $result = pg_prepare($conn, '', $sql);
  253.                 // $result = pg_execute($conn, '', array());
  254.                 $as_columns = "";
  255.                 $sel_columns = "row_id";
  256.                 foreach ($stmt->fetchAll() as $row)
  257.                 {
  258.                     $as_columns .= ', "' . $row['nama'] . '" text';
  259.                     if($row['nama'] != "periode_order") {
  260.                         $sel_columns .= ", " .$row['nama'] .":: text";
  261.                     }
  262.                 }
  263.         
  264.                 $sql = "SELECT $sel_columns FROM crosstab($$ select a.row_id, b.id, a.isi 
  265.                         from t_data a 
  266.                         join t_variabel b 
  267.                         on a.variabel_id = b.id
  268.                         where a.pub_id = $id order by 1, 2 $$)
  269.                         AS ct (row_id int" .$as_columns. ") where 1=1 
  270.                         ORDER BY row_id";
  271.                 
  273.                         $stmt = $conn->prepare($sql);
  274.                 $stmt->execute();
  276.                 // $rs = pg_prepare($conn, '', $sql);
  277.                 // $rs = pg_execute($conn, '', array());
  278.         
  279.                 $hasil[$id]['data'] = [];
  280.                 foreach ($stmt->fetchAll() as $row)
  281.                 {
  282.                     $hasil[$id]['data'][] = $row;
  283.                 }
  284.             }
  285.         
  286.         }
  288.         $data = (isset($hasil)) ? $hasil : [];
  290.         $response = $this->deliver_response(200, 'data found', $data);
  291.         return $this->json($response);
  292.         // return $this->json($get);
  293.     }
  295.     function deliver_response($status, $status_message, $data = [], $type = '')
  296.     {
  297.         // header("HTTP/1.1 $status $status_message");    
  298.         $response = array();
  299.         $response['status'] = $status;
  300.         $response['status_message'] = $status_message;
  301.         // if($type == 'data') {
  302.             $response['total_data'] = count($data);
  303.         // }
  304.         $response['result'] = $data;
  306.         // $json = json_encode($response, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT);
  307.         // echo $json;
  308.         return $response;
  309.     }
  311.     /**
  312.      * @Route("/data.json", name="api_json", methods={"GET"})
  313.      */
  314.     public function getJsonData(Request $request, TPublikasiRepository $tPublikasiRepo)
  315.     {
  316.         header('Content-Type: application/json');
  317.         $data = array(
  318.             "@context" => "https://project-open-data.cio.gov/v1.1/schema/catalog.jsonld",
  319.             "@id"      => "https://opendata.kedirikab.go.id/data.json",
  320.             "@type"    => "dcat:Catalog",
  321.             "conformsTo"    => "https://project-open-data.cio.gov/v1.1/schema",
  322.             "describedBy"   => "https://project-open-data.cio.gov/v1.1/schema/catalog.json",
  323.             
  324.         );
  326.         $dataset = [];
  328.         $publikasi = $tPublikasiRepo->findBy(["status" => 3]);
  329.         foreach ($publikasi as $pub) {
  330.             $dataset[] = [
  331.                 "@type" => "dcat:Dataset",
  332.                 "accessLevel" => "public",
  333.                 "contactPoint" => [
  334.                     "fn" => "Rustam",
  335.                     "hasEmail" => "mailto:noemailprovided@usa.gov"
  336.                 ],
  337.                 "distribution" => [
  338.                     [
  339.                         "@type" => "dcat:Distribution",
  340.                         "downloadURL" => "https://opendata.kedirikab.go.id/dataset/" .$pub->getId(). "/csv/download_excel",
  341.                         "mediaType" => "text/csv",
  342.                         "format" => "csv",
  343.                         "title" => $pub->getJudul()
  344.                     ]
  345.                 ],
  346.                 "identifier" => md5($pub->getId()),
  347.                 "issued" => "-",
  348.                 "landingPage" => "https://opendata.kedirikab.go.id/dataset/" .$pub->getId(). "/detail",
  349.                 "modified" => $pub->getCreatedAt()->format("Y-m-d"),
  350.                 "publisher" => [
  351.                     "@type" => "org:Organization",
  352.                     "name" => "https://opendata.kedirikab.go.id/"
  353.                 ],
  354.                 "title" => $pub->getJudul(),
  355.                 "description" => $pub->getDeskripsi() ? strip_tags($pub->getDeskripsi()) : "",
  356.                 "keyword" => is_array($pub->getKeyword()) ? implode(",", $pub->getKeyword()) : ""
  357.             ];
  358.         }
  360.         $data['dataset'] = $dataset;
  362.         return $this->json($data);
  363.     }
  364. }