fork download
copy 
  1. <?php
  2.  
  3. class Announcement {
  4.  
  5.     private $id;
  6.     private $text;
  7.     private $attachedFile;
  8.     private $expiredDate;
  9.  
  10.     public function __construct($text, DateTime $expiredDate = null, AttachedFile $attachedFile = null, $id = null) {
  11.  
  12.         if (trim(strip_tags($text)) === '' && $attachedFile === null) {
  13.  
  14.             throw new Exception('Announcement can\'t have no text and no file');           
  15.  
  16.         }
  17.  
  18.         if ($expiredDate !== null && (int)$expiredDate->format('U') > pow(2, 31) - 1) {
  19.  
  20.             throw new Exception('Too big expired date');   
  21.  
  22.         }
  23.  
  24.         if ($id !== null && !ctype_digit((string)$id)) {
  25.  
  26.             throw new Exception('Announcement id must be numeric');
  27.  
  28.         }
  29.  
  30.         $this->id = $id;
  31.         $this->text = trim($text);
  32.         $this->attachedFile = $attachedFile;
  33.         $this->expiredDate = $expiredDate;            
  34.  
  35.  
  36.     }
  37.  
  38.     public function putToDatabase() {
  39.  
  40.         $mysqli = new mysqli(DATABASE_SERVER, DATABASE_USER, DATABASE_PASSWORD, DATABASE_NAME);
  41.  
  42.         if (mysqli_connect_error()) {
  43.  
  44.             throw new Exception('Can\'t connect to database: ' . mysqli_connect_error());
  45.  
  46.         }
  47.  
  48.         if (!$mysqli->set_charset('utf8')) {
  49.  
  50.             $mysqli->close();
  51.             throw new Exception('Can\'t set utf8 to mysqli');
  52.  
  53.         }
  54.  
  55.         $sqlExpdate = $this->haveExpiredDate() ? 'FROM_UNIXTIME(' . $this->expiredDate->format('U') . ')' : 'NULL';
  56.  
  57.         if ($this->id === null) {
  58.  
  59.             if ($this->attachedFile !== null) {
  60.  
  61.                 $query = 'INSERT INTO announcements (ann_text, ann_file, ann_expdate) VALUES ("' . $mysqli->escape_string($this->text) . '", "' . $mysqli->escape_string($this->attachedFile->getFilepath()) . '", ' . $sqlExpdate . ')';
  62.  
  63.             } else {
  64.  
  65.                 $query = 'INSERT INTO announcements (ann_text, ann_expdate) VALUES ("' . $mysqli->escape_string($this->text) . '", ' . $sqlExpdate . ')';
  66.  
  67.             }
  68.  
  69.             if (!$mysqli->query($query)) {
  70.  
  71.                 $mysqli->close();
  72.                 throw new Exception('Unsuccessful INSERT query');
  73.  
  74.             }
  75.  
  76.             if ($mysqli->affected_rows === 1) {
  77.  
  78.                 $this->id = $mysqli->insert_id;
  79.  
  80.                 $mysqli->close();
  81.  
  82.                 return true;
  83.  
  84.             } else {
  85.  
  86.                 $mysqli->close();
  87.                 throw new Exception('No affected rows (or more than 1) after succesful INSERT query');                
  88.  
  89.             }
  90.  
  91.         }
  92.  
  93.         else {
  94.  
  95.             if ($this->attachedFile !== null) {
  96.  
  97.                 $query = 'UPDATE announcements SET ann_text = "' . $mysqli->escape_string($this->text) . '", ann_file = "' . $mysqli->escape_string($this->attachedFile->getFilepath()) . '", ann_expdate = ' . $sqlExpdate . ' WHERE ann_id = ' . $this->id;
  98.  
  99.             } else {
  100.  
  101.                 $query = 'UPDATE announcements SET ann_text = "' . $mysqli->escape_string($this->text) . '", ann_expdate = ' . $sqlExpdate . ' WHERE ann_id = ' . $this->id;
  102.  
  103.             }
  104.  
  105.             if (!$mysqli->query($query)) {
  106.  
  107.                 $mysqli->close();
  108.                 throw new Exception('Unsuccessful UPDATE query');
  109.  
  110.             }
  111.  
  112.             // закомментировано потому, что update без изменений не дает affected_rows
  113.             // if ($mysqli->affected_rows === 1)
  114.  
  115.             $mysqli->close();
  116.  
  117.             return true;	
  118.  
  119.         }        
  120.  
  121.     }
  122.  
  123.     const ACTION_REMOVE = 1;
  124.     const ACTION_RESTORE = 2;
  125.  
  126.     public function deleteMe() {
  127.  
  128.         self::toggleAnnouncement($this->id, self::ACTION_REMOVE);
  129.  
  130.     }
  131.  
  132.     public static function deleteAnnouncement($id) {
  133.  
  134.         self::toggleAnnouncement($id, self::ACTION_REMOVE);
  135.  
  136.     }
  137.  
  138.     public static function restoreAnnouncement($id) {
  139.  
  140.         self::toggleAnnouncement($id, self::ACTION_RESTORE);
  141.  
  142.     }
  143.  
  144.     public static function toggleAnnouncement($id, $concreteAction = null) {
  145.  
  146.         if (!ctype_digit($id)) {
  147.  
  148.             throw new Exception('Announcement id must be numeric');
  149.  
  150.         }
  151.  
  152.         $mysqli = new mysqli(DATABASE_SERVER, DATABASE_USER, DATABASE_PASSWORD, DATABASE_NAME);
  153.  
  154.         if (mysqli_connect_error()) {
  155.  
  156.             throw new Exception('Can\'t connect to database: ' . mysqli_connect_error());
  157.  
  158.         }
  159.  
  160.         if (!$mysqli->set_charset('utf8')) {
  161.  
  162.             $mysqli->close();
  163.             throw new Exception('Can\'t set utf8 to mysqli');
  164.  
  165.         }
  166.  
  167.         if (!($result = $mysqli->query('SELECT ann_hidden FROM announcements WHERE ann_id = ' . $id)) || $result->num_rows < 1) {
  168.  
  169.             $mysqli->close();
  170.             throw new Exception('Can\'t find announcement with id ' . $id);
  171.  
  172.         }
  173.  
  174.         $row = $result->fetch_assoc();
  175.         $result->free();
  176.  
  177.         if ($row['ann_hidden'] === '1' && $concreteAction === self::ACTION_REMOVE) {
  178.  
  179.             // Уже удалено
  180.             return false;
  181.  
  182.         } elseif ($row['ann_hidden'] === '0' && $concreteAction === self::ACTION_RESTORE) {
  183.  
  184.             // Уже восстановлено
  185.             return false;
  186.  
  187.         }
  188.  
  189.         $toggleHidden = $row['ann_hidden'] === '0' ? '1' : '0';
  190.  
  191.         if (!$mysqli->query('UPDATE announcements SET ann_hidden = ' . $toggleHidden . ' WHERE ann_id = ' . $id) || $mysqli->affected_rows < 1) {
  192.  
  193.             $mysqli->close();
  194.             throw new Exception('Unsuccessful UPDATE query');
  195.  
  196.         }
  197.  
  198.         // Здесь будет помещение в корзину
  199.  
  200.         $mysqli->close();
  201.  
  202.         return true;        
  203.  
  204.     }
  205.  
  206.     public function getHumanReadableExpiredDate() {
  207.  
  208.         return $this->expiredDate->format('j') . ' ' . $GLOBALS['MONTHS_ARRAY'][(int)$this->expiredDate->format('n')] . (($this->expiredDate->format('Y') !== date('Y')) ? ' ' . $this->expiredDate->format('Y') : '');
  209.  
  210.     }
  211.  
  212.     public function getId() {
  213.  
  214.         return $this->id;
  215.  
  216.     }
  217.  
  218.     public function getText() {
  219.  
  220.         return $this->text;
  221.  
  222.     }
  223.  
  224.     public function getFile() {
  225.  
  226.         return $this->attachedFile;
  227.  
  228.     }
  229.  
  230.     public function haveText() {
  231.  
  232.         return !empty($this->text);
  233.  
  234.     }
  235.  
  236.     public function haveAttachedFile() {
  237.  
  238.         return !is_null($this->attachedFile);
  239.  
  240.     }
  241.  
  242.     public function haveExpiredDate() {
  243.  
  244.         return !is_null($this->expiredDate);
  245.  
  246.     }
  247.  
  248.     public function getExpiredDate() {
  249.  
  250.         return $this->expiredDate;
  251.  
  252.     }
  253.  
  254.     public static function separateActualAndNonactual(array $anns) {
  255.  
  256.         $actual = array();
  257.         $nonactual = array();
  258.  
  259.         foreach ($anns as $ann) if ($ann instanceof Announcement) {
  260.  
  261.             if (!$ann->haveExpiredDate() || (int)$ann->getExpiredDate()->format('U') > time()) {
  262.  
  263.                 $actual[] = $ann;
  264.  
  265.             } else {
  266.  
  267.                 $nonactual[] = $ann;
  268.  
  269.             }
  270.  
  271.         }
  272.  
  273.         return array('actual' => $actual, 'nonactual' => $nonactual);
  274.  
  275.     }
  276.  
  277.     public static function getAnnouncementsFromDatabase($onlyActual = true) {
  278.  
  279. 		$anns = array();
  280.  
  281. 		$mysqli = new mysqli(DATABASE_SERVER, DATABASE_USER, DATABASE_PASSWORD, DATABASE_NAME);
  282.  
  283.         if (mysqli_connect_error()) {
  284.  
  285.             throw new Exception('Can\'t connect to database: ' . mysqli_connect_error());
  286.  
  287.         }
  288.  
  289.         if (!$mysqli->set_charset('utf8')) {
  290.  
  291.             $mysqli->close();
  292.             throw new Exception('Can\'t set utf8 to mysqli');
  293.  
  294.         }
  295.  
  296. 		if (!($result = $mysqli->query('SELECT * FROM announcements WHERE ann_hidden != 1' . ($onlyActual ? ' AND (ann_expdate > NOW() OR ann_expdate IS NULL)' : '') . ' ORDER BY ann_id DESC'))) {
  297.  
  298.             $mysqli->close();
  299.             throw new Exception('Unsuccessful SELECT query');
  300.  
  301.         }
  302.  
  303.         while ($row = $result->fetch_assoc()) {
  304.  
  305.             try {
  306.  
  307.                 $attachedFile = ($row['ann_file'] !== null) ? new AttachedFile($row['ann_file']) : null;
  308.                 $expdate      = ($row['ann_expdate'] !== null) ? new DateTime($row['ann_expdate']) : null;
  309.  
  310.                 $anns[] = new Announcement($row['ann_text'], $expdate, $attachedFile, $row['ann_id']);
  311.  
  312.             } catch (Exception $e) {
  313.  
  314.                 $result->free();
  315.                 $mysqli->close();
  316.  
  317.                 throw $e;
  318.  
  319.             }
  320.  
  321.         }
  322.  
  323.         $result->free();
  324.         $mysqli->close();
  325.  
  326. 		return $anns;
  327.  
  328.     }    
  329.  
  330. }
Success #stdin #stdout 0.02s 52472KB
comments (?)
stdin
copy 
Standard input is empty
stdout
copy 
Standard output is empty
https://ideone.com/ri11JH
language:
PHP (php 7.3.5)
created:
8 years ago
visibility:
public

Share or Embed source code

Discover > Sphere Engine API

The brand new service which powers Ideone!

Discover > IDE Widget

Widget for compiling and running the source code in a web browser!