class.dc.blog.php @ 1468:3132a0aca046

Visit:

Revision 1468:3132a0aca046, 60.6 KB checked in by franck <carnet.franck.paul@…>, 12 years ago (diff)
Merge 2.5 commits into default branch (should be verified)

Line
1	<?php
2	# -- BEGIN LICENSE BLOCK ---------------------------------------
3	#
4	# This file is part of Dotclear 2.
5	#
6	# Copyright (c) 2003-2013 Olivier Meunier & Association Dotclear
7	# Licensed under the GPL version 2.0 license.
8	# See LICENSE file or
9	# http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
10	#
11	# -- END LICENSE BLOCK -----------------------------------------
12	if (!defined('DC_RC_PATH')) { return; }
13
14	/**
15	@ingroup DC_CORE
16	@nosubgrouping
17	@brief Dotclear blog class.
18
19	Dotclear blog class instance is provided by dcCore $blog property.
20	*/
21	class dcBlog
22	{
23	/** @var dcCore dcCore instance */
24	protected $core;
25	/** @var connection Database connection object */
26	public $con;
27	/** @var string Database table prefix */
28	public $prefix;
29
30	/** @var string Blog ID */
31	public $id;
32	/** @var string Blog unique ID */
33	public $uid;
34	/** @var string Blog name */
35	public $name;
36	/** @var string Blog description */
37	public $desc;
38	/** @var string Blog URL */
39	public $url;
40	/** @var string Blog host */
41	public $host;
42	/** @var string Blog creation date */
43	public $creadt;
44	/** @var string Blog last update date */
45	public $upddt;
46	/** @var string Blog status */
47	public $status;
48
49	/** @var dcSettings dcSettings object */
50	public $settings;
51	/** @var string Blog theme path */
52	public $themes_path;
53	/** @var string Blog public path */
54	public $public_path;
55
56	private $post_status = array();
57	private $comment_status = array();
58
59	private $categories;
60
61	/** @var boolean Disallow entries password protection */
62	public $without_password = true;
63
64	/**
65	Inits dcBlog object
66
67	@param core <b>dcCore</b> Dotclear core reference
68	@param id <b>string</b> Blog ID
69	*/
70	public function __construct($core, $id)
71	{
72	$this->con =& $core->con;
73	$this->prefix = $core->prefix;
74	$this->core =& $core;
75
76	if (($b = $this->core->getBlog($id)) !== false)
77	{
78	$this->id = $id;
79	$this->uid = $b->blog_uid;
80	$this->name = $b->blog_name;
81	$this->desc = $b->blog_desc;
82	$this->url = $b->blog_url;
83	$this->host = http::getHostFromURL($this->url);
84	$this->creadt = strtotime($b->blog_creadt);
85	$this->upddt = strtotime($b->blog_upddt);
86	$this->status = $b->blog_status;
87
88	$this->settings = new dcSettings($this->core,$this->id);
89
90	$this->themes_path = path::fullFromRoot($this->settings->system->themes_path,DC_ROOT);
91	$this->public_path = path::fullFromRoot($this->settings->system->public_path,DC_ROOT);
92
93	$this->post_status['-2'] = __('Pending');
94	$this->post_status['-1'] = __('Scheduled');
95	$this->post_status['0'] = __('Unpublished');
96	$this->post_status['1'] = __('Published');
97
98	$this->comment_status['-2'] = __('Junk');
99	$this->comment_status['-1'] = __('Pending');
100	$this->comment_status['0'] = __('Unpublished');
101	$this->comment_status['1'] = __('Published');
102
103	# --BEHAVIOR-- coreBlogConstruct
104	$this->core->callBehavior('coreBlogConstruct',$this);
105	}
106	}
107
108	/// @name Common public methods
109	//@{
110	/**
111	Returns blog URL ending with a question mark.
112	*/
113	public function getQmarkURL()
114	{
115	if (substr($this->url,-1) != '?') {
116	return $this->url.'?';
117	}
118
119	return $this->url;
120	}
121
122	/**
123	Returns an entry status name given to a code. Status are translated, never
124	use it for tests. If status code does not exist, returns <i>unpublished</i>.
125
126	@param s <b>integer</b> Status code
127	@return <b>string</b> Blog status name
128	*/
129	public function getPostStatus($s)
130	{
131	if (isset($this->post_status[$s])) {
132	return $this->post_status[$s];
133	}
134	return $this->post_status['0'];
135	}
136
137	/**
138	Returns an array of available entry status codes and names.
139
140	@return <b>array</b> Simple array with codes in keys and names in value
141	*/
142	public function getAllPostStatus()
143	{
144	return $this->post_status;
145	}
146
147	/**
148	Returns an array of available comment status codes and names.
149
150	@return <b>array</b> Simple array with codes in keys and names in value
151	*/
152	public function getAllCommentStatus()
153	{
154	return $this->comment_status;
155	}
156
157	/**
158	Disallows entries password protection. You need to set it to
159	<var>false</var> while serving a public blog.
160
161	@param v <b>boolean</b>
162	*/
163	public function withoutPassword($v)
164	{
165	$this->without_password = (boolean) $v;
166	}
167	//@}
168
169	/// @name Triggers methods
170	//@{
171	/**
172	Updates blog last update date. Should be called every time you change
173	an element related to the blog.
174	*/
175	public function triggerBlog()
176	{
177	$cur = $this->con->openCursor($this->prefix.'blog');
178
179	$cur->blog_upddt = date('Y-m-d H:i:s');
180
181	$cur->update("WHERE blog_id = '".$this->con->escape($this->id)."' ");
182
183	# --BEHAVIOR-- coreBlogAfterTriggerBlog
184	$this->core->callBehavior('coreBlogAfterTriggerBlog',$cur);
185	}
186
187	/**
188	Updates comment and trackback counters in post table. Should be called
189	every time a comment or trackback is added, removed or changed its status.
190
191	@param id <b>integer</b> Comment ID
192	@param del <b>boolean</b> If comment is delete, set this to true
193	*/
194	public function triggerComment($id,$del=false)
195	{
196	$this->triggerComments($id,$del);
197	}
198
199	/**
200	Updates comments and trackbacks counters in post table. Should be called
201	every time comments or trackbacks are added, removed or changed there status.
202
203	@param ids <b>mixed</b> Comment(s) ID(s)
204	@param del <b>boolean</b> If comment is delete, set this to true
205	*/
206	public function triggerComments($ids,$del=false)
207	{
208	$co_ids = dcUtils::cleanIds($ids);
209
210	# a) Retrieve posts affected by comments edition
211	$strReq =
212	'SELECT post_id, comment_trackback '.
213	'FROM '.$this->prefix.'comment '.
214	'WHERE comment_id'.$this->con->in($co_ids).
215	'GROUP BY post_id,comment_trackback';
216
217	$rs = $this->con->select($strReq);
218
219	$a_ids = $a_tbs = array();
220	while ($rs->fetch()) {
221	$a_ids[] = (integer) $rs->post_id;
222	$a_tbs[] = (integer) $rs->comment_trackback;
223	}
224
225	# b) Count comments of each posts previously retrieved
226	# Note that this does not return posts without comment
227	$strReq =
228	'SELECT post_id, COUNT(post_id) AS nb_comment,comment_trackback '.
229	'FROM '.$this->prefix.'comment '.
230	'WHERE comment_status = 1 '.
231	(count($a_ids) > 0 ? 'AND post_id'.$this->con->in($a_ids) : ' ');
232
233	if ($del) {
234	$strReq .=
235	'AND comment_id NOT'.$this->con->in($co_ids);
236	}
237
238	$strReq .=
239	'GROUP BY post_id,comment_trackback';
240
241	$rs = $this->con->select($strReq);
242
243	$b_ids = $b_tbs = $b_nbs = array();
244	while ($rs->fetch()) {
245	$b_ids[] = (integer) $rs->post_id;
246	$b_tbs[] = (integer) $rs->comment_trackback;
247	$b_nbs[] = (integer) $rs->nb_comment;
248	}
249
250	# c) Update comments numbers on posts
251	# This compare previous requests to update also posts without comment
252	$cur = $this->con->openCursor($this->prefix.'post');
253
254	foreach($a_ids as $a_key => $a_id)
255	{
256	$nb_comment = $nb_trackback = 0;
257	foreach($b_ids as $b_key => $b_id)
258	{
259	if ($a_id != $b_id \|\| $a_tbs[$a_key] != $b_tbs[$b_key]) {
260	continue;
261	}
262
263	if ($b_tbs[$b_key]) {
264	$nb_trackback = $b_nbs[$b_key];
265	} else {
266	$nb_comment = $b_nbs[$b_key];
267	}
268	}
269
270	if ($a_tbs[$a_key]) {
271	$cur->nb_trackback = $nb_trackback;
272	} else {
273	$cur->nb_comment = $nb_comment;
274	}
275	$cur->update('WHERE post_id = '.$a_id);
276	}
277	}
278	//@}
279
280	/// @name Categories management methods
281	//@{
282	public function categories()
283	{
284	if (!($this->categories instanceof dcCategories)) {
285	$this->categories = new dcCategories($this->core);
286	}
287
288	return $this->categories;
289	}
290
291	/**
292	Retrieves categories. <var>$params</var> is an associative array which can
293	take the following parameters:
294
295	- post_type: Get only entries with given type (default "post")
296	- cat_url: filter on cat_url field
297	- cat_id: filter on cat_id field
298	- start: start with a given category
299	- level: categories level to retrieve
300
301	@param params <b>array</b> Parameters
302	@return <b>record</b>
303	*/
304	public function getCategories($params=array())
305	{
306	$c_params = array();
307	if (isset($params['post_type'])) {
308	$c_params['post_type'] = $params['post_type'];
309	unset($params['post_type']);
310	}
311	$counter = $this->getCategoriesCounter($c_params);
312
313	$without_empty = $this->core->auth->userID() == false; # For public display
314
315	$start = isset($params['start']) ? (integer) $params['start'] : 0;
316	$l = isset($params['level']) ? (integer) $params['level'] : 0;
317
318	$rs = $this->categories()->getChildren($start,null,'desc');
319
320	# Get each categories total posts count
321	$data = array();
322	$stack = array();
323	$level = 0;
324	$cols = $rs->columns();
325	while ($rs->fetch())
326	{
327	$nb_post = isset($counter[$rs->cat_id]) ? (integer) $counter[$rs->cat_id] : 0;
328
329	if ($rs->level > $level) {
330	$nb_total = $nb_post;
331	$stack[$rs->level] = (integer) $nb_post;
332	} elseif ($rs->level == $level) {
333	$nb_total = $nb_post;
334	$stack[$rs->level] += $nb_post;
335	} else {
336	$nb_total = $stack[$rs->level+1] + $nb_post;
337	if (isset($stack[$rs->level])) {
338	$stack[$rs->level] += $nb_total;
339	} else {
340	$stack[$rs->level] = $nb_total;
341	}
342	unset($stack[$rs->level+1]);
343	}
344
345	if ($nb_total == 0 && $without_empty) {
346	continue;
347	}
348
349	$level = $rs->level;
350
351	$t = array();
352	foreach ($cols as $c) {
353	$t[$c] = $rs->f($c);
354	}
355	$t['nb_post'] = $nb_post;
356	$t['nb_total'] = $nb_total;
357
358	if ($l == 0 \|\| ($l > 0 && $l == $rs->level)) {
359	array_unshift($data,$t);
360	}
361	}
362
363	# We need to apply filter after counting
364	if (isset($params['cat_id']) && $params['cat_id'] !== '')
365	{
366	$found = false;
367	foreach ($data as $v) {
368	if ($v['cat_id'] == $params['cat_id']) {
369	$found = true;
370	$data = array($v);
371	break;
372	}
373	}
374	if (!$found) {
375	$data = array();
376	}
377	}
378
379	if (isset($params['cat_url']) && ($params['cat_url'] !== '')
380	&& !isset($params['cat_id']))
381	{
382	$found = false;
383	foreach ($data as $v) {
384	if ($v['cat_url'] == $params['cat_url']) {
385	$found = true;
386	$data = array($v);
387	break;
388	}
389	}
390	if (!$found) {
391	$data = array();
392	}
393	}
394
395	return staticRecord::newFromArray($data);
396	}
397
398	/**
399	Retrieves a category by its ID.
400
401	@param id <b>integer</b> Category ID
402	@return <b>record</b>
403	*/
404	public function getCategory($id)
405	{
406	return $this->getCategories(array('cat_id' => $id));
407	}
408
409	/**
410	Retrieves parents of a given category.
411
412	@param id <b>integer</b> Category ID
413	@return <b>record</b>
414	*/
415	public function getCategoryParents($id)
416	{
417	return $this->categories()->getParents($id);
418	}
419
420	/**
421	Retrieves first parent of a given category.
422
423	@param id <b>integer</b> Category ID
424	@return <b>record</b>
425	*/
426	public function getCategoryParent($id)
427	{
428	return $this->categories()->getParent($id);
429	}
430
431	/**
432	Retrieves all category's first children
433
434	@param id <b>integer</b> Category ID
435	@return <b>record</b>
436	*/
437	public function getCategoryFirstChildren($id)
438	{
439	return $this->getCategories(array('start' => $id,'level' => $id == 0 ? 1 : 2));
440	}
441
442	private function getCategoriesCounter($params=array())
443	{
444	$strReq =
445	'SELECT C.cat_id, COUNT(P.post_id) AS nb_post '.
446	'FROM '.$this->prefix.'category AS C '.
447	'JOIN '.$this->prefix."post P ON (C.cat_id = P.cat_id AND P.blog_id = '".$this->con->escape($this->id)."' ) ".
448	"WHERE C.blog_id = '".$this->con->escape($this->id)."' ";
449
450	if (!$this->core->auth->userID()) {
451	$strReq .= 'AND P.post_status = 1 ';
452	}
453
454	if (!empty($params['post_type'])) {
455	$strReq .= 'AND P.post_type '.$this->con->in($params['post_type']);
456	}
457
458	$strReq .= 'GROUP BY C.cat_id ';
459
460	$rs = $this->con->select($strReq);
461	$counters = array();
462	while ($rs->fetch()) {
463	$counters[$rs->cat_id] = $rs->nb_post;
464	}
465
466	return $counters;
467	}
468
469	/**
470	Creates a new category. Takes a cursor as input and returns the new category
471	ID.
472
473	@param cur <b>cursor</b> Category cursor
474	@return <b>integer</b> New category ID
475	*/
476	public function addCategory($cur,$parent=0)
477	{
478	if (!$this->core->auth->check('categories',$this->id)) {
479	throw new Exception(__('You are not allowed to add categories'));
480	}
481
482	$url = array();
483	if ($parent != 0)
484	{
485	$rs = $this->getCategory($parent);
486	if ($rs->isEmpty()) {
487	$url = array();
488	} else {
489	$url[] = $rs->cat_url;
490	}
491	}
492
493	if ($cur->cat_url == '') {
494	$url[] = text::tidyURL($cur->cat_title,false);
495	} else {
496	$url[] = $cur->cat_url;
497	}
498
499	$cur->cat_url = implode('/',$url);
500
501	$this->getCategoryCursor($cur);
502	$cur->blog_id = (string) $this->id;
503
504	# --BEHAVIOR-- coreBeforeCategoryCreate
505	$this->core->callBehavior('coreBeforeCategoryCreate',$this,$cur);
506
507	$this->categories()->addNode($cur,$parent);
508
509	# --BEHAVIOR-- coreAfterCategoryCreate
510	$this->core->callBehavior('coreAfterCategoryCreate',$this,$cur);
511	$this->triggerBlog();
512
513	return $cur->cat_id;
514	}
515
516	/**
517	Updates an existing category.
518
519	@param id <b>integer</b> Category ID
520	@param cur <b>cursor</b> Category cursor
521	*/
522	public function updCategory($id,$cur)
523	{
524	if (!$this->core->auth->check('categories',$this->id)) {
525	throw new Exception(__('You are not allowed to update categories'));
526	}
527
528	if ($cur->cat_url == '')
529	{
530	$url = array();
531	$rs = $this->categories()->getParents($id);
532	while ($rs->fetch()) {
533	if ($rs->index() == $rs->count()-1) {
534	$url[] = $rs->cat_url;
535	}
536	}
537
538
539	$url[] = text::tidyURL($cur->cat_title,false);
540	$cur->cat_url = implode('/',$url);
541	}
542
543	$this->getCategoryCursor($cur,$id);
544
545	# --BEHAVIOR-- coreBeforeCategoryUpdate
546	$this->core->callBehavior('coreBeforeCategoryUpdate',$this,$cur);
547
548	$cur->update(
549	'WHERE cat_id = '.(integer) $id.' '.
550	"AND blog_id = '".$this->con->escape($this->id)."' ");
551
552	# --BEHAVIOR-- coreAfterCategoryUpdate
553	$this->core->callBehavior('coreAfterCategoryUpdate',$this,$cur);
554
555	$this->triggerBlog();
556	}
557
558	/**
559	DEPRECATED METHOD. Use dcBlog::setCategoryParent and dcBlog::moveCategory
560	instead.
561
562	@param id <b>integer</b> Category ID
563	@param order <b>integer</b> Category position
564	*/
565	public function updCategoryOrder($id,$order)
566	{
567	return;
568	}
569
570	/**
571	Set a category parent
572
573	@param id <b>integer</b> Category ID
574	@param parent <b>integer</b> Parent Category ID
575	*/
576	public function setCategoryParent($id,$parent)
577	{
578	$this->categories()->setNodeParent($id,$parent);
579	$this->triggerBlog();
580	}
581
582	/**
583	Set category position
584
585	@param id <b>integer</b> Category ID
586	@param sibling <b>integer</b> Sibling Category ID
587	@param move <b>integer</b> Order (before\|after)
588	*/
589	public function setCategoryPosition($id,$sibling,$move)
590	{
591	$this->categories()->setNodePosition($id,$sibling,$move);
592	$this->triggerBlog();
593	}
594
595	/**
596	Deletes a category.
597
598	@param id <b>integer</b> Category ID
599	*/
600	public function delCategory($id)
601	{
602	if (!$this->core->auth->check('categories',$this->id)) {
603	throw new Exception(__('You are not allowed to delete categories'));
604	}
605
606	$strReq = 'SELECT COUNT(post_id) AS nb_post '.
607	'FROM '.$this->prefix.'post '.
608	'WHERE cat_id = '.(integer) $id.' '.
609	"AND blog_id = '".$this->con->escape($this->id)."' ";
610
611	$rs = $this->con->select($strReq);
612
613	if ($rs->nb_post > 0) {
614	throw new Exception(__('This category is not empty.'));
615	}
616
617	$this->categories()->deleteNode($id,true);
618	$this->triggerBlog();
619	}
620
621	/**
622	Reset categories order and relocate them to first level
623	*/
624	public function resetCategoriesOrder()
625	{
626	if (!$this->core->auth->check('categories',$this->id)) {
627	throw new Exception(__('You are not allowed to reset categories order'));
628	}
629
630	$this->categories()->resetOrder();
631	$this->triggerBlog();
632	}
633
634	private function checkCategory($title,$url,$id=null)
635	{
636	# Let's check if URL is taken...
637	$strReq =
638	'SELECT cat_url FROM '.$this->prefix.'category '.
639	"WHERE cat_url = '".$this->con->escape($url)."' ".
640	($id ? 'AND cat_id <> '.(integer) $id. ' ' : '').
641	"AND blog_id = '".$this->con->escape($this->id)."' ".
642	'ORDER BY cat_url DESC';
643
644	$rs = $this->con->select($strReq);
645
646	if (!$rs->isEmpty())
647	{
648	if ($this->con->driver() == 'mysql') {
649	$clause = "REGEXP '^".$this->con->escape($url)."[0-9]+$'";
650	} elseif ($this->con->driver() == 'pgsql') {
651	$clause = "~ '^".$this->con->escape($url)."[0-9]+$'";
652	} else {
653	$clause = "LIKE '".$this->con->escape($url)."%'";
654	}
655	$strReq =
656	'SELECT cat_url FROM '.$this->prefix.'category '.
657	"WHERE cat_url ".$clause.' '.
658	($id ? 'AND cat_id <> '.(integer) $id. ' ' : '').
659	"AND blog_id = '".$this->con->escape($this->id)."' ".
660	'ORDER BY cat_url DESC ';
661
662	$rs = $this->con->select($strReq);
663	$a = array();
664	while ($rs->fetch()) {
665	$a[] = $rs->cat_url;
666	}
667
668	natsort($a);
669	$t_url = end($a);
670
671	if (preg_match('/(.*?)([0-9]+)$/',$t_url,$m)) {
672	$i = (integer) $m[2];
673	$url = $m[1];
674	} else {
675	$i = 1;
676	}
677
678	return $url.($i+1);
679	}
680
681	# URL is empty?
682	if ($url == '') {
683	throw new Exception(__('Empty category URL'));
684	}
685
686	return $url;
687	}
688
689	private function getCategoryCursor($cur,$id=null)
690	{
691	if ($cur->cat_title == '') {
692	throw new Exception(__('You must provide a category title'));
693	}
694
695	# If we don't have any cat_url, let's do one
696	if ($cur->cat_url == '') {
697	$cur->cat_url = text::tidyURL($cur->cat_title,false);
698	}
699
700	# Still empty ?
701	if ($cur->cat_url == '') {
702	throw new Exception(__('You must provide a category URL'));
703	} else {
704	$cur->cat_url = text::tidyURL($cur->cat_url,true);
705	}
706
707	# Check if title or url are unique
708	$cur->cat_url = $this->checkCategory($cur->cat_title,$cur->cat_url,$id);
709
710	if ($cur->cat_desc !== null) {
711	$cur->cat_desc = $this->core->HTMLfilter($cur->cat_desc);
712	}
713	}
714	//@}
715
716	/// @name Entries management methods
717	//@{
718	/**
719	Retrieves entries. <b>$params</b> is an array taking the following
720	optionnal parameters:
721
722	- no_content: Don't retrieve entry content (excerpt and content)
723	- post_type: Get only entries with given type (default "post", array for many types and '' for no type)
724	- post_id: (integer) Get entry with given post_id
725	- post_url: Get entry with given post_url field
726	- user_id: (integer) Get entries belonging to given user ID
727	- cat_id: (string or array) Get entries belonging to given category ID
728	- cat_id_not: deprecated (use cat_id with "id ?not" instead)
729	- cat_url: (string or array) Get entries belonging to given category URL
730	- cat_url_not: deprecated (use cat_url with "url ?not" instead)
731	- post_status: (integer) Get entries with given post_status
732	- post_selected: (boolean) Get select flaged entries
733	- post_year: (integer) Get entries with given year
734	- post_month: (integer) Get entries with given month
735	- post_day: (integer) Get entries with given day
736	- post_lang: Get entries with given language code
737	- search: Get entries corresponding of the following search string
738	- columns: (array) More columns to retrieve
739	- sql: Append SQL string at the end of the query
740	- from: Append SQL string after "FROM" statement in query
741	- order: Order of results (default "ORDER BY post_dt DES")
742	- limit: Limit parameter
743	- sql_only : return the sql request instead of results. Only ids are selected
744
745	Please note that on every cat_id or cat_url, you can add ?not to exclude
746	the category and ?sub to get subcategories.
747
748	@param params <b>array</b> Parameters
749	@param count_only <b>boolean</b> Only counts results
750	@return <b>record</b> A record with some more capabilities or the SQL request
751	*/
752	public function getPosts($params=array(),$count_only=false)
753	{
754	# --BEHAVIOR-- coreBlogBeforeGetPosts
755	$params = new ArrayObject($params);
756	$this->core->callBehavior('coreBlogBeforeGetPosts',$params);
757
758	if ($count_only)
759	{
760	$strReq = 'SELECT count(P.post_id) ';
761	}
762	elseif (!empty($params['sql_only']))
763	{
764	$strReq = 'SELECT P.post_id ';
765	}
766	else
767	{
768	if (!empty($params['no_content'])) {
769	$content_req = '';
770	} else {
771	$content_req =
772	'post_excerpt, post_excerpt_xhtml, '.
773	'post_content, post_content_xhtml, post_notes, ';
774	}
775
776	if (!empty($params['columns']) && is_array($params['columns'])) {
777	$content_req .= implode(', ',$params['columns']).', ';
778	}
779
780	$strReq =
781	'SELECT P.post_id, P.blog_id, P.user_id, P.cat_id, post_dt, '.
782	'post_tz, post_creadt, post_upddt, post_format, post_password, '.
783	'post_url, post_lang, post_title, '.$content_req.
784	'post_type, post_meta, post_status, post_selected, post_position, '.
785	'post_open_comment, post_open_tb, nb_comment, nb_trackback, '.
786	'U.user_name, U.user_firstname, U.user_displayname, U.user_email, '.
787	'U.user_url, '.
788	'C.cat_title, C.cat_url, C.cat_desc ';
789	}
790
791	$strReq .=
792	'FROM '.$this->prefix.'post P '.
793	'INNER JOIN '.$this->prefix.'user U ON U.user_id = P.user_id '.
794	'LEFT OUTER JOIN '.$this->prefix.'category C ON P.cat_id = C.cat_id ';
795
796	if (!empty($params['from'])) {
797	$strReq .= $params['from'].' ';
798	}
799
800	$strReq .=
801	"WHERE P.blog_id = '".$this->con->escape($this->id)."' ";
802
803	if (!$this->core->auth->check('contentadmin',$this->id)) {
804	$strReq .= 'AND ((post_status = 1 ';
805
806	if ($this->without_password) {
807	$strReq .= 'AND post_password IS NULL ';
808	}
809	$strReq .= ') ';
810
811	if ($this->core->auth->userID()) {
812	$strReq .= "OR P.user_id = '".$this->con->escape($this->core->auth->userID())."')";
813	} else {
814	$strReq .= ') ';
815	}
816	}
817
818	#Adding parameters
819	if (isset($params['post_type']))
820	{
821	if (is_array($params['post_type']) \|\| $params['post_type'] != '') {
822	$strReq .= 'AND post_type '.$this->con->in($params['post_type']);
823	}
824	}
825	else
826	{
827	$strReq .= "AND post_type = 'post' ";
828	}
829
830	if (isset($params['post_id']) && $params['post_id'] !== '') {
831	if (is_array($params['post_id'])) {
832	array_walk($params['post_id'],create_function('&$v,$k','if($v!==null){$v=(integer)$v;}'));
833	} else {
834	$params['post_id'] = array((integer) $params['post_id']);
835	}
836	$strReq .= 'AND P.post_id '.$this->con->in($params['post_id']);
837	}
838
839	if (isset($params['post_url']) && $params['post_url'] !== '') {
840	$strReq .= "AND post_url = '".$this->con->escape($params['post_url'])."' ";
841	}
842
843	if (!empty($params['user_id'])) {
844	$strReq .= "AND U.user_id = '".$this->con->escape($params['user_id'])."' ";
845	}
846
847	if (isset($params['cat_id']) && $params['cat_id'] !== '')
848	{
849	if (!is_array($params['cat_id'])) {
850	$params['cat_id'] = array($params['cat_id']);
851	}
852	if (!empty($params['cat_id_not'])) {
853	array_walk($params['cat_id'],create_function('&$v,$k','$v=$v." ?not";'));
854	}
855	$strReq .= 'AND '.$this->getPostsCategoryFilter($params['cat_id'],'cat_id').' ';
856	}
857	elseif (isset($params['cat_url']) && $params['cat_url'] !== '')
858	{
859	if (!is_array($params['cat_url'])) {
860	$params['cat_url'] = array($params['cat_url']);
861	}
862	if (!empty($params['cat_url_not'])) {
863	array_walk($params['cat_url'],create_function('&$v,$k','$v=$v." ?not";'));
864	}
865	$strReq .= 'AND '.$this->getPostsCategoryFilter($params['cat_url'],'cat_url').' ';
866	}
867
868	/* Other filters */
869	if (isset($params['post_status'])) {
870	$strReq .= 'AND post_status = '.(integer) $params['post_status'].' ';
871	}
872
873	if (isset($params['post_selected'])) {
874	$strReq .= 'AND post_selected = '.(integer) $params['post_selected'].' ';
875	}
876
877	if (!empty($params['post_year'])) {
878	$strReq .= 'AND '.$this->con->dateFormat('post_dt','%Y').' = '.
879	"'".sprintf('%04d',$params['post_year'])."' ";
880	}
881
882	if (!empty($params['post_month'])) {
883	$strReq .= 'AND '.$this->con->dateFormat('post_dt','%m').' = '.
884	"'".sprintf('%02d',$params['post_month'])."' ";
885	}
886
887	if (!empty($params['post_day'])) {
888	$strReq .= 'AND '.$this->con->dateFormat('post_dt','%d').' = '.
889	"'".sprintf('%02d',$params['post_day'])."' ";
890	}
891
892	if (!empty($params['post_lang'])) {
893	$strReq .= "AND P.post_lang = '".$this->con->escape($params['post_lang'])."' ";
894	}
895
896	if (!empty($params['search']))
897	{
898	$words = text::splitWords($params['search']);
899
900	if (!empty($words))
901	{
902	# --BEHAVIOR-- corePostSearch
903	if ($this->core->hasBehavior('corePostSearch')) {
904	$this->core->callBehavior('corePostSearch',$this->core,array(&$words,&$strReq,&$params));
905	}
906
907	if ($words)
908	{
909	foreach ($words as $i => $w) {
910	$words[$i] = "post_words LIKE '%".$this->con->escape($w)."%'";
911	}
912	$strReq .= 'AND '.implode(' AND ',$words).' ';
913	}
914	}
915	}
916
917	if (!empty($params['sql'])) {
918	$strReq .= $params['sql'].' ';
919	}
920
921	if (!$count_only)
922	{
923	if (!empty($params['order'])) {
924	$strReq .= 'ORDER BY '.$this->con->escape($params['order']).' ';
925	} else {
926	$strReq .= 'ORDER BY post_dt DESC ';
927	}
928	}
929
930	if (!$count_only && !empty($params['limit'])) {
931	$strReq .= $this->con->limit($params['limit']);
932	}
933
934	if (!empty($params['sql_only'])) {
935	return $strReq;
936	}
937
938	$rs = $this->con->select($strReq);
939	$rs->core = $this->core;
940	$rs->_nb_media = array();
941	$rs->extend('rsExtPost');
942
943	# --BEHAVIOR-- coreBlogGetPosts
944	$this->core->callBehavior('coreBlogGetPosts',$rs);
945
946	return $rs;
947	}
948
949	/**
950	Returns a record with post id, title and date for next or previous post
951	according to the post ID.
952	$dir could be 1 (next post) or -1 (previous post).
953
954	@param post_id <b>integer</b> Post ID
955	@param dir <b>integer</b> Search direction
956	@param restrict_to_category <b>boolean</b> Restrict to post with same category
957	@param restrict_to_lang <b>boolean</b> Restrict to post with same lang
958	@return record
959	*/
960	public function getNextPost($post,$dir,$restrict_to_category=false, $restrict_to_lang=false)
961	{
962	$dt = $post->post_dt;
963	$post_id = (integer) $post->post_id;
964
965	if($dir > 0) {
966	$sign = '>';
967	$order = 'ASC';
968	}
969	else {
970	$sign = '<';
971	$order = 'DESC';
972	}
973
974	$params['post_type'] = $post->post_type;
975	$params['limit'] = 1;
976	$params['order'] = 'post_dt '.$order.', P.post_id '.$order;
977	$params['sql'] =
978	'AND ( '.
979	" (post_dt = '".$this->con->escape($dt)."' AND P.post_id ".$sign." ".$post_id.") ".
980	" OR post_dt ".$sign." '".$this->con->escape($dt)."' ".
981	') ';
982
983	if ($restrict_to_category) {
984	$params['sql'] .= $post->cat_id ? 'AND P.cat_id = '.(integer) $post->cat_id.' ' : 'AND P.cat_id IS NULL ';
985	}
986
987	if ($restrict_to_lang) {
988	$params['sql'] .= $post->post_lang ? 'AND P.post_lang = \''. $this->con->escape($post->post_lang) .'\' ': 'AND P.post_lang IS NULL ';
989	}
990
991	$rs = $this->getPosts($params);
992
993	if ($rs->isEmpty()) {
994	return null;
995	}
996
997	return $rs;
998	}
999
1000	/**
1001	Retrieves different languages and post count on blog, based on post_lang
1002	field. <var>$params</var> is an array taking the following optionnal
1003	parameters:
1004
1005	- post_type: Get only entries with given type (default "post", '' for no type)
1006	- lang: retrieve post count for selected lang
1007	- order: order statement (default post_lang DESC)
1008
1009	@param params <b>array</b> Parameters
1010	@return record
1011	*/
1012	public function getLangs($params=array())
1013	{
1014	$strReq = 'SELECT COUNT(post_id) as nb_post, post_lang '.
1015	'FROM '.$this->prefix.'post '.
1016	"WHERE blog_id = '".$this->con->escape($this->id)."' ".
1017	"AND post_lang <> '' ".
1018	"AND post_lang IS NOT NULL ";
1019
1020	if (!$this->core->auth->check('contentadmin',$this->id)) {
1021	$strReq .= 'AND ((post_status = 1 ';
1022
1023	if ($this->without_password) {
1024	$strReq .= 'AND post_password IS NULL ';
1025	}
1026	$strReq .= ') ';
1027
1028	if ($this->core->auth->userID()) {
1029	$strReq .= "OR user_id = '".$this->con->escape($this->core->auth->userID())."')";
1030	} else {
1031	$strReq .= ') ';
1032	}
1033	}
1034
1035	if (isset($params['post_type'])) {
1036	if ($params['post_type'] != '') {
1037	$strReq .= "AND post_type = '".$this->con->escape($params['post_type'])."' ";
1038	}
1039	} else {
1040	$strReq .= "AND post_type = 'post' ";
1041	}
1042
1043	if (isset($params['lang'])) {
1044	$strReq .= "AND post_lang = '".$this->con->escape($params['lang'])."' ";
1045	}
1046
1047	$strReq .= 'GROUP BY post_lang ';
1048
1049	$order = 'desc';
1050	if (!empty($params['order']) && preg_match('/^(desc\|asc)$/i',$params['order'])) {
1051	$order = $params['order'];
1052	}
1053	$strReq .= 'ORDER BY post_lang '.$order.' ';
1054
1055	return $this->con->select($strReq);
1056	}
1057
1058	/**
1059	Returns a record with all distinct blog dates and post count.
1060	<var>$params</var> is an array taking the following optionnal parameters:
1061
1062	- type: (day\|month\|year) Get days, months or years
1063	- year: (integer) Get dates for given year
1064	- month: (integer) Get dates for given month
1065	- day: (integer) Get dates for given day
1066	- cat_id: (integer) Category ID filter
1067	- cat_url: Category URL filter
1068	- post_lang: lang of the posts
1069	- next: Get date following match
1070	- previous: Get date before match
1071	- order: Sort by date "ASC" or "DESC"
1072
1073	@param params <b>array</b> Parameters array
1074	@return record
1075	*/
1076	public function getDates($params=array())
1077	{
1078	$dt_f = '%Y-%m-%d';
1079	$dt_fc = '%Y%m%d';
1080	if (isset($params['type'])) {
1081	if ($params['type'] == 'year') {
1082	$dt_f = '%Y-01-01';
1083	$dt_fc = '%Y0101';
1084	} elseif ($params['type'] == 'month') {
1085	$dt_f = '%Y-%m-01';
1086	$dt_fc = '%Y%m01';
1087	}
1088	}
1089	$dt_f .= ' 00:00:00';
1090	$dt_fc .= '000000';
1091
1092	$cat_field = $catReq = $limit = '';
1093
1094	if (isset($params['cat_id']) && $params['cat_id'] !== '') {
1095	$catReq = 'AND P.cat_id = '.(integer) $params['cat_id'].' ';
1096	$cat_field = ', C.cat_url ';
1097	} elseif (isset($params['cat_url']) && $params['cat_url'] !== '') {
1098	$catReq = "AND C.cat_url = '".$this->con->escape($params['cat_url'])."' ";
1099	$cat_field = ', C.cat_url ';
1100	}
1101	if (!empty($params['post_lang'])) {
1102	$catReq = 'AND P.post_lang = \''. $params['post_lang'].'\' ';
1103	}
1104
1105	$strReq = 'SELECT DISTINCT('.$this->con->dateFormat('post_dt',$dt_f).') AS dt '.
1106	$cat_field.
1107	',COUNT(P.post_id) AS nb_post '.
1108	'FROM '.$this->prefix.'post P LEFT JOIN '.$this->prefix.'category C '.
1109	'ON P.cat_id = C.cat_id '.
1110	"WHERE P.blog_id = '".$this->con->escape($this->id)."' ".
1111	$catReq;
1112
1113	if (!$this->core->auth->check('contentadmin',$this->id)) {
1114	$strReq .= 'AND ((post_status = 1 ';
1115
1116	if ($this->without_password) {
1117	$strReq .= 'AND post_password IS NULL ';
1118	}
1119	$strReq .= ') ';
1120
1121	if ($this->core->auth->userID()) {
1122	$strReq .= "OR P.user_id = '".$this->con->escape($this->core->auth->userID())."')";
1123	} else {
1124	$strReq .= ') ';
1125	}
1126	}
1127
1128	if (!empty($params['post_type'])) {
1129	$strReq .= "AND post_type ".$this->con->in($params['post_type'])." ";
1130	} else {
1131	$strReq .= "AND post_type = 'post' ";
1132	}
1133
1134	if (!empty($params['year'])) {
1135	$strReq .= 'AND '.$this->con->dateFormat('post_dt','%Y')." = '".sprintf('%04d',$params['year'])."' ";
1136	}
1137
1138	if (!empty($params['month'])) {
1139	$strReq .= 'AND '.$this->con->dateFormat('post_dt','%m')." = '".sprintf('%02d',$params['month'])."' ";
1140	}
1141
1142	if (!empty($params['day'])) {
1143	$strReq .= 'AND '.$this->con->dateFormat('post_dt','%d')." = '".sprintf('%02d',$params['day'])."' ";
1144	}
1145
1146	# Get next or previous date
1147	if (!empty($params['next']) \|\| !empty($params['previous']))
1148	{
1149	if (!empty($params['next'])) {
1150	$pdir = ' > ';
1151	$params['order'] = 'asc';
1152	$dt = $params['next'];
1153	} else {
1154	$pdir = ' < ';
1155	$params['order'] = 'desc';
1156	$dt = $params['previous'];
1157	}
1158
1159	$dt = date('YmdHis',strtotime($dt));
1160
1161	$strReq .= 'AND '.$this->con->dateFormat('post_dt',$dt_fc).$pdir."'".$dt."' ";
1162	$limit = $this->con->limit(1);
1163	}
1164
1165	$strReq .= 'GROUP BY dt '.$cat_field;
1166
1167	$order = 'desc';
1168	if (!empty($params['order']) && preg_match('/^(desc\|asc)$/i',$params['order'])) {
1169	$order = $params['order'];
1170	}
1171
1172	$strReq .=
1173	'ORDER BY dt '.$order.' '.
1174	$limit;
1175
1176	$rs = $this->con->select($strReq);
1177	$rs->extend('rsExtDates');
1178	return $rs;
1179	}
1180
1181	/**
1182	Creates a new entry. Takes a cursor as input and returns the new entry
1183	ID.
1184
1185	@param cur <b>cursor</b> Post cursor
1186	@return <b>integer</b> New post ID
1187	*/
1188	public function addPost($cur)
1189	{
1190	if (!$this->core->auth->check('usage,contentadmin',$this->id)) {
1191	throw new Exception(__('You are not allowed to create an entry'));
1192	}
1193
1194	$this->con->writeLock($this->prefix.'post');
1195	try
1196	{
1197	# Get ID
1198	$rs = $this->con->select(
1199	'SELECT MAX(post_id) '.
1200	'FROM '.$this->prefix.'post '
1201	);
1202
1203	$cur->post_id = (integer) $rs->f(0) + 1;
1204	$cur->blog_id = (string) $this->id;
1205	$cur->post_creadt = date('Y-m-d H:i:s');
1206	$cur->post_upddt = date('Y-m-d H:i:s');
1207	$cur->post_tz = $this->core->auth->getInfo('user_tz');
1208
1209	# Post excerpt and content
1210	$this->getPostContent($cur,$cur->post_id);
1211
1212	$this->getPostCursor($cur);
1213
1214	$cur->post_url = $this->getPostURL($cur->post_url,$cur->post_dt,$cur->post_title,$cur->post_id);
1215
1216	if (!$this->core->auth->check('publish,contentadmin',$this->id)) {
1217	$cur->post_status = -2;
1218	}
1219
1220	# --BEHAVIOR-- coreBeforePostCreate
1221	$this->core->callBehavior('coreBeforePostCreate',$this,$cur);
1222
1223	$cur->insert();
1224	$this->con->unlock();
1225	}
1226	catch (Exception $e)
1227	{
1228	$this->con->unlock();
1229	throw $e;
1230	}
1231
1232	# --BEHAVIOR-- coreAfterPostCreate
1233	$this->core->callBehavior('coreAfterPostCreate',$this,$cur);
1234
1235	$this->triggerBlog();
1236
1237	return $cur->post_id;
1238	}
1239
1240	/**
1241	Updates an existing post.
1242
1243	@param id <b>integer</b> Post ID
1244	@param cur <b>cursor</b> Post cursor
1245	*/
1246	public function updPost($id,$cur)
1247	{
1248	if (!$this->core->auth->check('usage,contentadmin',$this->id)) {
1249	throw new Exception(__('You are not allowed to update entries'));
1250	}
1251
1252	$id = (integer) $id;
1253
1254	if (empty($id)) {
1255	throw new Exception(__('No such entry ID'));
1256	}
1257
1258	# Post excerpt and content
1259	$this->getPostContent($cur,$id);
1260
1261	$this->getPostCursor($cur);
1262
1263	if ($cur->post_url !== null) {
1264	$cur->post_url = $this->getPostURL($cur->post_url,$cur->post_dt,$cur->post_title,$id);
1265	}
1266
1267	if (!$this->core->auth->check('publish,contentadmin',$this->id)) {
1268	$cur->unsetField('post_status');
1269	}
1270
1271	$cur->post_upddt = date('Y-m-d H:i:s');
1272
1273	#If user is only "usage", we need to check the post's owner
1274	if (!$this->core->auth->check('contentadmin',$this->id))
1275	{
1276	$strReq = 'SELECT post_id '.
1277	'FROM '.$this->prefix.'post '.
1278	'WHERE post_id = '.$id.' '.
1279	"AND user_id = '".$this->con->escape($this->core->auth->userID())."' ";
1280
1281	$rs = $this->con->select($strReq);
1282
1283	if ($rs->isEmpty()) {
1284	throw new Exception(__('You are not allowed to edit this entry'));
1285	}
1286	}
1287
1288	# --BEHAVIOR-- coreBeforePostUpdate
1289	$this->core->callBehavior('coreBeforePostUpdate',$this,$cur);
1290
1291	$cur->update('WHERE post_id = '.$id.' ');
1292
1293	# --BEHAVIOR-- coreAfterPostUpdate
1294	$this->core->callBehavior('coreAfterPostUpdate',$this,$cur);
1295
1296	$this->triggerBlog();
1297	}
1298
1299	/**
1300	Updates post status.
1301
1302	@param id <b>integer</b> Post ID
1303	@param status <b>integer</b> Post status
1304	*/
1305	public function updPostStatus($id,$status)
1306	{
1307	$this->updPostsStatus($id,$status);
1308	}
1309
1310	/**
1311	Updates posts status.
1312
1313	@param ids <b>mixed</b> Post(s) ID(s)
1314	@param status <b>integer</b> Post status
1315	*/
1316	public function updPostsStatus($ids,$status)
1317	{
1318	if (!$this->core->auth->check('publish,contentadmin',$this->id)) {
1319	throw new Exception(__('You are not allowed to change this entry status'));
1320	}
1321
1322	$posts_ids = dcUtils::cleanIds($ids);
1323	$status = (integer) $status;
1324
1325	$strReq = "WHERE blog_id = '".$this->con->escape($this->id)."' ".
1326	"AND post_id ".$this->con->in($posts_ids);
1327
1328	#If user can only publish, we need to check the post's owner
1329	if (!$this->core->auth->check('contentadmin',$this->id))
1330	{
1331	$strReq .= "AND user_id = '".$this->con->escape($this->core->auth->userID())."' ";
1332	}
1333
1334	$cur = $this->con->openCursor($this->prefix.'post');
1335
1336	$cur->post_status = $status;
1337	$cur->post_upddt = date('Y-m-d H:i:s');
1338
1339	$cur->update($strReq);
1340	$this->triggerBlog();
1341	}
1342
1343	/**
1344	Updates post selection.
1345
1346	@param id <b>integer</b> Post ID
1347	@param selected <b>integer</b> Is selected post
1348	*/
1349	public function updPostSelected($id,$selected)
1350	{
1351	$this->updPostsSelected($id,$selected);
1352	}
1353
1354	/**
1355	Updates posts selection.
1356
1357	@param ids <b>mixed</b> Post(s) ID(s)
1358	@param selected <b>integer</b> Is selected post(s)
1359	*/
1360	public function updPostsSelected($ids,$selected)
1361	{
1362	if (!$this->core->auth->check('usage,contentadmin',$this->id)) {
1363	throw new Exception(__('You are not allowed to change this entry category'));
1364	}
1365
1366	$posts_ids = dcUtils::cleanIds($ids);
1367	$selected = (boolean) $selected;
1368
1369	$strReq = "WHERE blog_id = '".$this->con->escape($this->id)."' ".
1370	"AND post_id ".$this->con->in($posts_ids);
1371
1372	# If user is only usage, we need to check the post's owner
1373	if (!$this->core->auth->check('contentadmin',$this->id))
1374	{
1375	$strReq .= "AND user_id = '".$this->con->escape($this->core->auth->userID())."' ";
1376	}
1377
1378	$cur = $this->con->openCursor($this->prefix.'post');
1379
1380	$cur->post_selected = (integer) $selected;
1381	$cur->post_upddt = date('Y-m-d H:i:s');
1382
1383	$cur->update($strReq);
1384	$this->triggerBlog();
1385	}
1386
1387	/**
1388	Updates post category. <var>$cat_id</var> can be null.
1389
1390	@param id <b>integer</b> Post ID
1391	@param cat_id <b>integer</b> Category ID
1392	*/
1393	public function updPostCategory($id,$cat_id)
1394	{
1395	$this->updPostsCategory($id,$cat_id);
1396	}
1397
1398	/**
1399	Updates posts category. <var>$cat_id</var> can be null.
1400
1401	@param ids <b>mixed</b> Post(s) ID(s)
1402	@param cat_id <b>integer</b> Category ID
1403	*/
1404	public function updPostsCategory($ids,$cat_id)
1405	{
1406	if (!$this->core->auth->check('usage,contentadmin',$this->id)) {
1407	throw new Exception(__('You are not allowed to change this entry category'));
1408	}
1409
1410	$posts_ids = dcUtils::cleanIds($ids);
1411	$cat_id = (integer) $cat_id;
1412
1413	$strReq = "WHERE blog_id = '".$this->con->escape($this->id)."' ".
1414	"AND post_id ".$this->con->in($posts_ids);
1415
1416	# If user is only usage, we need to check the post's owner
1417	if (!$this->core->auth->check('contentadmin',$this->id))
1418	{
1419	$strReq .= "AND user_id = '".$this->con->escape($this->core->auth->userID())."' ";
1420	}
1421
1422	$cur = $this->con->openCursor($this->prefix.'post');
1423
1424	$cur->cat_id = ($cat_id ? $cat_id : null);
1425	$cur->post_upddt = date('Y-m-d H:i:s');
1426
1427	$cur->update($strReq);
1428	$this->triggerBlog();
1429	}
1430
1431	/**
1432	Updates posts category. <var>$new_cat_id</var> can be null.
1433
1434	@param old_cat_id <b>integer</b> Old category ID
1435	@param new_cat_id <b>integer</b> New category ID
1436	*/
1437	public function changePostsCategory($old_cat_id,$new_cat_id)
1438	{
1439	if (!$this->core->auth->check('contentadmin,categories',$this->id)) {
1440	throw new Exception(__('You are not allowed to change entries category'));
1441	}
1442
1443	$old_cat_id = (integer) $old_cat_id;
1444	$new_cat_id = (integer) $new_cat_id;
1445
1446	$cur = $this->con->openCursor($this->prefix.'post');
1447
1448	$cur->cat_id = ($new_cat_id ? $new_cat_id : null);
1449	$cur->post_upddt = date('Y-m-d H:i:s');
1450
1451	$cur->update(
1452	'WHERE cat_id = '.$old_cat_id.' '.
1453	"AND blog_id = '".$this->con->escape($this->id)."' "
1454	);
1455	$this->triggerBlog();
1456	}
1457
1458	/**
1459	Deletes a post.
1460
1461	@param id <b>integer</b> Post ID
1462	*/
1463	public function delPost($id)
1464	{
1465	$this->delPosts($id);
1466	}
1467
1468	/**
1469	Deletes multiple posts.
1470
1471	@param ids <b>mixed</b> Post(s) ID(s)
1472	*/
1473	public function delPosts($ids)
1474	{
1475	if (!$this->core->auth->check('delete,contentadmin',$this->id)) {
1476	throw new Exception(__('You are not allowed to delete entries'));
1477	}
1478
1479	$posts_ids = dcUtils::cleanIds($ids);
1480
1481	if (empty($posts_ids)) {
1482	throw new Exception(__('No such entry ID'));
1483	}
1484
1485	$strReq = 'DELETE FROM '.$this->prefix.'post '.
1486	"WHERE blog_id = '".$this->con->escape($this->id)."' ".
1487	"AND post_id ".$this->con->in($posts_ids);
1488
1489	#If user can only delete, we need to check the post's owner
1490	if (!$this->core->auth->check('contentadmin',$this->id))
1491	{
1492	$strReq .= "AND user_id = '".$this->con->escape($this->core->auth->userID())."' ";
1493	}
1494
1495	$this->con->execute($strReq);
1496	$this->triggerBlog();
1497	}
1498
1499	/**
1500	Publishes all entries flaged as "scheduled".
1501	*/
1502	public function publishScheduledEntries()
1503	{
1504	$strReq = 'SELECT post_id, post_dt, post_tz '.
1505	'FROM '.$this->prefix.'post '.
1506	'WHERE post_status = -1 '.
1507	"AND blog_id = '".$this->con->escape($this->id)."' ";
1508
1509	$rs = $this->con->select($strReq);
1510
1511	$now = dt::toUTC(time());
1512	$to_change = new ArrayObject();
1513
1514	if ($rs->isEmpty()) {
1515	return;
1516	}
1517
1518	while ($rs->fetch())
1519	{
1520	# Now timestamp with post timezone
1521	$now_tz = $now + dt::getTimeOffset($rs->post_tz,$now);
1522
1523	# Post timestamp
1524	$post_ts = strtotime($rs->post_dt);
1525
1526	# If now_tz >= post_ts, we publish the entry
1527	if ($now_tz >= $post_ts) {
1528	$to_change[] = (integer) $rs->post_id;
1529	}
1530	}
1531	if (count($to_change))
1532	{
1533	# --BEHAVIOR-- coreBeforeScheduledEntriesPublish
1534	$this->core->callBehavior('coreBeforeScheduledEntriesPublish',$this,$to_change);
1535
1536	$strReq =
1537	'UPDATE '.$this->prefix.'post SET '.
1538	'post_status = 1 '.
1539	"WHERE blog_id = '".$this->con->escape($this->id)."' ".
1540	'AND post_id '.$this->con->in((array)$to_change).' ';
1541	$this->con->execute($strReq);
1542	$this->triggerBlog();
1543
1544	# --BEHAVIOR-- coreAfterScheduledEntriesPublish
1545	$this->core->callBehavior('coreAfterScheduledEntriesPublish',$this,$to_change);
1546	}
1547
1548	}
1549
1550	/**
1551	Retrieves all users having posts on current blog.
1552
1553	@param post_type <b>string</b> post_type filter (post)
1554	@return record
1555	*/
1556	public function getPostsUsers($post_type='post')
1557	{
1558	$strReq = 'SELECT P.user_id, user_name, user_firstname, '.
1559	'user_displayname, user_email '.
1560	'FROM '.$this->prefix.'post P, '.$this->prefix.'user U '.
1561	'WHERE P.user_id = U.user_id '.
1562	"AND blog_id = '".$this->con->escape($this->id)."' ";
1563
1564	if ($post_type) {
1565	$strReq .= "AND post_type = '".$this->con->escape($post_type)."' ";
1566	}
1567
1568	$strReq .= 'GROUP BY P.user_id, user_name, user_firstname, user_displayname, user_email ';
1569
1570	return $this->con->select($strReq);
1571	}
1572
1573	private function getPostsCategoryFilter($arr,$field='cat_id')
1574	{
1575	$field = $field == 'cat_id' ? 'cat_id' : 'cat_url';
1576
1577	$sub = array();
1578	$not = array();
1579	$queries = array();
1580
1581	foreach ($arr as $v)
1582	{
1583	$v = trim($v);
1584	$args = preg_split('/\s[?]\s/',$v,-1,PREG_SPLIT_NO_EMPTY);
1585	$id = array_shift($args);
1586	$args = array_flip($args);
1587
1588	if (isset($args['not'])) { $not[$id] = 1; }
1589	if (isset($args['sub'])) { $sub[$id] = 1; }
1590	if ($field == 'cat_id') {
1591	if (preg_match('/^null$/i',$id)) {
1592	$queries[$id] = 'P.cat_id IS NULL';
1593	}
1594	else {
1595	$queries[$id] = 'P.cat_id = '.(integer) $id;
1596	}
1597	} else {
1598	$queries[$id] = "C.cat_url = '".$this->con->escape($id)."' ";
1599	}
1600	}
1601
1602	if (!empty($sub)) {
1603	$rs = $this->con->select(
1604	'SELECT cat_id, cat_url, cat_lft, cat_rgt FROM '.$this->prefix.'category '.
1605	"WHERE blog_id = '".$this->con->escape($this->id)."' ".
1606	'AND '.$field.' '.$this->con->in(array_keys($sub))
1607	);
1608
1609	while ($rs->fetch()) {
1610	$queries[$rs->f($field)] = '(C.cat_lft BETWEEN '.$rs->cat_lft.' AND '.$rs->cat_rgt.')';
1611	}
1612	}
1613
1614	# Create queries
1615	$sql = array(
1616	0 => array(), # wanted categories
1617	1 => array() # excluded categories
1618	);
1619
1620	foreach ($queries as $id => $q) {
1621	$sql[(integer) isset($not[$id])][] = $q;
1622	}
1623
1624	$sql[0] = implode(' OR ',$sql[0]);
1625	$sql[1] = implode(' OR ',$sql[1]);
1626
1627	if ($sql[0]) {
1628	$sql[0] = '('.$sql[0].')';
1629	} else {
1630	unset($sql[0]);
1631	}
1632
1633	if ($sql[1]) {
1634	$sql[1] = '(P.cat_id IS NULL OR NOT('.$sql[1].'))';
1635	} else {
1636	unset($sql[1]);
1637	}
1638
1639	return implode(' AND ',$sql);
1640	}
1641
1642	private function getPostCursor($cur,$post_id=null)
1643	{
1644	if ($cur->post_title == '') {
1645	throw new Exception(__('No entry title'));
1646	}
1647
1648	if ($cur->post_content == '') {
1649	throw new Exception(__('No entry content'));
1650	}
1651
1652	if ($cur->post_password === '') {
1653	$cur->post_password = null;
1654	}
1655
1656	if ($cur->post_dt == '') {
1657	$offset = dt::getTimeOffset($this->core->auth->getInfo('user_tz'));
1658	$now = time() + $offset;
1659	$cur->post_dt = date('Y-m-d H:i:00',$now);
1660	}
1661
1662	$post_id = is_int($post_id) ? $post_id : $cur->post_id;
1663
1664	if ($cur->post_content_xhtml == '') {
1665	throw new Exception(__('No entry content'));
1666	}
1667
1668	# Words list
1669	if ($cur->post_title !== null && $cur->post_excerpt_xhtml !== null
1670	&& $cur->post_content_xhtml !== null)
1671	{
1672	$words =
1673	$cur->post_title.' '.
1674	$cur->post_excerpt_xhtml.' '.
1675	$cur->post_content_xhtml;
1676
1677	$cur->post_words = implode(' ',text::splitWords($words));
1678	}
1679	}
1680
1681	private function getPostContent($cur,$post_id)
1682	{
1683	$post_excerpt = $cur->post_excerpt;
1684	$post_excerpt_xhtml = $cur->post_excerpt_xhtml;
1685	$post_content = $cur->post_content;
1686	$post_content_xhtml = $cur->post_content_xhtml;
1687
1688	$this->setPostContent(
1689	$post_id,$cur->post_format,$cur->post_lang,
1690	$post_excerpt,$post_excerpt_xhtml,
1691	$post_content,$post_content_xhtml
1692	);
1693
1694	$cur->post_excerpt = $post_excerpt;
1695	$cur->post_excerpt_xhtml = $post_excerpt_xhtml;
1696	$cur->post_content = $post_content;
1697	$cur->post_content_xhtml = $post_content_xhtml;
1698	}
1699
1700	/**
1701	Creates post HTML content, taking format and lang into account.
1702
1703	@param post_id <b>integer</b> Post ID
1704	@param format <b>string</b> Post format
1705	@param lang <b>string</b> Post lang
1706	@param excerpt <b>string</b> Post excerpt
1707	@param[out] excerpt_xhtml <b>string</b> Post excerpt HTML
1708	@param content <b>string</b> Post content
1709	@param[out] content_xhtml <b>string</b> Post content HTML
1710	*/
1711	public function setPostContent($post_id,$format,$lang,&$excerpt,&$excerpt_xhtml,&$content,&$content_xhtml)
1712	{
1713	if ($format == 'wiki')
1714	{
1715	$this->core->initWikiPost();
1716	$this->core->wiki2xhtml->setOpt('note_prefix','pnote-'.$post_id);
1717	switch ($this->settings->system->note_title_tag) {
1718	case 1:
1719	$tag = 'h3';
1720	break;
1721	case 2:
1722	$tag = 'p';
1723	break;
1724	default:
1725	$tag = 'h4';
1726	break;
1727	}
1728	$this->core->wiki2xhtml->setOpt('note_str','<div class="footnotes"><'.$tag.' class="footnotes-title">'.
1729	__('Notes').'</'.$tag.'>%s</div>');
1730	$this->core->wiki2xhtml->setOpt('note_str_single','<div class="footnotes"><'.$tag.' class="footnotes-title">'.
1731	__('Note').'</'.$tag.'>%s</div>');
1732	if (strpos($lang,'fr') === 0) {
1733	$this->core->wiki2xhtml->setOpt('active_fr_syntax',1);
1734	}
1735	}
1736
1737	if ($excerpt) {
1738	$excerpt_xhtml = $this->core->callFormater($format,$excerpt);
1739	$excerpt_xhtml = $this->core->HTMLfilter($excerpt_xhtml);
1740	} else {
1741	$excerpt_xhtml = '';
1742	}
1743
1744	if ($content) {
1745	$content_xhtml = $this->core->callFormater($format,$content);
1746	$content_xhtml = $this->core->HTMLfilter($content_xhtml);
1747	} else {
1748	$content_xhtml = '';
1749	}
1750
1751	# --BEHAVIOR-- coreAfterPostContentFormat
1752	$this->core->callBehavior('coreAfterPostContentFormat',array(
1753	'excerpt' => &$excerpt,
1754	'content' => &$content,
1755	'excerpt_xhtml' => &$excerpt_xhtml,
1756	'content_xhtml' => &$content_xhtml
1757	));
1758	}
1759
1760	/**
1761	Returns URL for a post according to blog setting <var>post_url_format</var>.
1762	It will try to guess URL and append some figures if needed.
1763
1764	@param url <b>string</b> Origin URL, could be empty
1765	@param post_dt <b>string</b> Post date (in YYYY-MM-DD HH:mm:ss)
1766	@param post_title <b>string</b> Post title
1767	@param post_id <b>integer</b> Post ID
1768	@return <b>string</b> result URL
1769	*/
1770	public function getPostURL($url,$post_dt,$post_title,$post_id)
1771	{
1772	$url = trim($url);
1773
1774	$url_patterns = array(
1775	'{y}' => date('Y',strtotime($post_dt)),
1776	'{m}' => date('m',strtotime($post_dt)),
1777	'{d}' => date('d',strtotime($post_dt)),
1778	'{t}' => text::tidyURL($post_title),
1779	'{id}' => (integer) $post_id
1780	);
1781
1782	# If URL is empty, we create a new one
1783	if ($url == '')
1784	{
1785	# Transform with format
1786	$url = str_replace(
1787	array_keys($url_patterns),
1788	array_values($url_patterns),
1789	$this->settings->system->post_url_format
1790	);
1791	}
1792	else
1793	{
1794	$url = text::tidyURL($url);
1795	}
1796
1797	# Let's check if URL is taken...
1798	$strReq = 'SELECT post_url FROM '.$this->prefix.'post '.
1799	"WHERE post_url = '".$this->con->escape($url)."' ".
1800	'AND post_id <> '.(integer) $post_id. ' '.
1801	"AND blog_id = '".$this->con->escape($this->id)."' ".
1802	'ORDER BY post_url DESC';
1803
1804	$rs = $this->con->select($strReq);
1805
1806	if (!$rs->isEmpty())
1807	{
1808	if ($this->con->driver() == 'mysql') {
1809	$clause = "REGEXP '^".$this->con->escape($url)."[0-9]+$'";
1810	} elseif ($this->con->driver() == 'pgsql') {
1811	$clause = "~ '^".$this->con->escape($url)."[0-9]+$'";
1812	} else {
1813	$clause = "LIKE '".$this->con->escape($url)."%'";
1814	}
1815	$strReq = 'SELECT post_url FROM '.$this->prefix.'post '.
1816	"WHERE post_url ".$clause.' '.
1817	'AND post_id <> '.(integer) $post_id.' '.
1818	"AND blog_id = '".$this->con->escape($this->id)."' ".
1819	'ORDER BY post_url DESC ';
1820
1821	$rs = $this->con->select($strReq);
1822	$a = array();
1823	while ($rs->fetch()) {
1824	$a[] = $rs->post_url;
1825	}
1826
1827	natsort($a);
1828	$t_url = end($a);
1829
1830	if (preg_match('/(.*?)([0-9]+)$/',$t_url,$m)) {
1831	$i = (integer) $m[2];
1832	$url = $m[1];
1833	} else {
1834	$i = 1;
1835	}
1836
1837	return $url.($i+1);
1838	}
1839
1840	# URL is empty?
1841	if ($url == '') {
1842	throw new Exception(__('Empty entry URL'));
1843	}
1844
1845	return $url;
1846	}
1847	//@}
1848
1849	/// @name Comments management methods
1850	//@{
1851	/**
1852	Retrieves comments. <b>$params</b> is an array taking the following
1853	optionnal parameters:
1854
1855	- no_content: Don't retrieve comment content
1856	- post_type: Get only entries with given type (default no type, array for many types)
1857	- post_id: (integer) Get comments belonging to given post_id
1858	- cat_id: (integer or array) Get comments belonging to entries of given category ID
1859	- comment_id: (integer) Get comment with given ID
1860	- comment_status: (integer) Get comments with given comment_status
1861	- comment_trackback: (integer) Get only comments (0) or trackbacks (1)
1862	- comment_ip: (string) Get comments with given IP address
1863	- post_url: Get entry with given post_url field
1864	- user_id: (integer) Get entries belonging to given user ID
1865	- q_author: Search comments by author
1866	- sql: Append SQL string at the end of the query
1867	- from: Append SQL string after "FROM" statement in query
1868	- order: Order of results (default "ORDER BY comment_dt DES")
1869	- limit: Limit parameter
1870	- sql_only : return the sql request instead of results. Only ids are selected
1871
1872	@param params <b>array</b> Parameters
1873	@param count_only <b>boolean</b> Only counts results
1874	@return <b>record</b> A record with some more capabilities
1875	*/
1876	public function getComments($params=array(),$count_only=false)
1877	{
1878	if ($count_only)
1879	{
1880	$strReq = 'SELECT count(comment_id) ';
1881	}
1882	elseif (!empty($params['sql_only']))
1883	{
1884	$strReq = 'SELECT P.post_id ';
1885	}
1886	else
1887	{
1888	if (!empty($params['no_content'])) {
1889	$content_req = '';
1890	} else {
1891	$content_req = 'comment_content, ';
1892	}
1893
1894	if (!empty($params['columns']) && is_array($params['columns'])) {
1895	$content_req .= implode(', ',$params['columns']).', ';
1896	}
1897
1898	$strReq =
1899	'SELECT C.comment_id, comment_dt, comment_tz, comment_upddt, '.
1900	'comment_author, comment_email, comment_site, '.
1901	$content_req.' comment_trackback, comment_status, '.
1902	'comment_spam_status, comment_spam_filter, comment_ip, '.
1903	'P.post_title, P.post_url, P.post_id, P.post_password, P.post_type, '.
1904	'P.post_dt, P.user_id, U.user_email, U.user_url ';
1905	}
1906
1907	$strReq .=
1908	'FROM '.$this->prefix.'comment C '.
1909	'INNER JOIN '.$this->prefix.'post P ON C.post_id = P.post_id '.
1910	'INNER JOIN '.$this->prefix.'user U ON P.user_id = U.user_id ';
1911
1912	if (!empty($params['from'])) {
1913	$strReq .= $params['from'].' ';
1914	}
1915
1916	$strReq .=
1917	"WHERE P.blog_id = '".$this->con->escape($this->id)."' ";
1918
1919	if (!$this->core->auth->check('contentadmin',$this->id)) {
1920	$strReq .= 'AND ((comment_status = 1 AND P.post_status = 1 ';
1921
1922	if ($this->without_password) {
1923	$strReq .= 'AND post_password IS NULL ';
1924	}
1925	$strReq .= ') ';
1926
1927	if ($this->core->auth->userID()) {
1928	$strReq .= "OR P.user_id = '".$this->con->escape($this->core->auth->userID())."')";
1929	} else {
1930	$strReq .= ') ';
1931	}
1932	}
1933
1934	if (!empty($params['post_type']))
1935	{
1936	$strReq .= 'AND post_type '.$this->con->in($params['post_type']);
1937	}
1938
1939	if (isset($params['post_id']) && $params['post_id'] !== '') {
1940	$strReq .= 'AND P.post_id = '.(integer) $params['post_id'].' ';
1941	}
1942
1943	if (isset($params['cat_id']) && $params['cat_id'] !== '') {
1944	$strReq .= 'AND P.cat_id = '.(integer) $params['cat_id'].' ';
1945	}
1946
1947	if (isset($params['comment_id']) && $params['comment_id'] !== '') {
1948	$strReq .= 'AND comment_id = '.(integer) $params['comment_id'].' ';
1949	}
1950
1951	if (isset($params['comment_status'])) {
1952	$strReq .= 'AND comment_status = '.(integer) $params['comment_status'].' ';
1953	}
1954
1955	if (!empty($params['comment_status_not']))
1956	{
1957	$strReq .= 'AND comment_status <> '.(integer) $params['comment_status_not'].' ';
1958	}
1959
1960	if (isset($params['comment_trackback'])) {
1961	$strReq .= 'AND comment_trackback = '.(integer) (boolean) $params['comment_trackback'].' ';
1962	}
1963
1964	if (isset($params['comment_ip'])) {
1965	$comment_ip = $this->con->escape(str_replace('*','%',$params['comment_ip']));
1966	$strReq .= "AND comment_ip LIKE '".$comment_ip."' ";
1967	}
1968
1969	if (isset($params['q_author'])) {
1970	$q_author = $this->con->escape(str_replace('*','%',strtolower($params['q_author'])));
1971	$strReq .= "AND LOWER(comment_author) LIKE '".$q_author."' ";
1972	}
1973
1974	if (!empty($params['search']))
1975	{
1976	$words = text::splitWords($params['search']);
1977
1978	if (!empty($words))
1979	{
1980	# --BEHAVIOR coreCommentSearch
1981	if ($this->core->hasBehavior('coreCommentSearch')) {
1982	$this->core->callBehavior('coreCommentSearch',$this->core,array(&$words,&$strReq,&$params));
1983	}
1984
1985	if ($words)
1986	{
1987	foreach ($words as $i => $w) {
1988	$words[$i] = "comment_words LIKE '%".$this->con->escape($w)."%'";
1989	}
1990	$strReq .= 'AND '.implode(' AND ',$words).' ';
1991	}
1992	}
1993	}
1994
1995	if (!empty($params['sql'])) {
1996	$strReq .= $params['sql'].' ';
1997	}
1998
1999	if (!$count_only)
2000	{
2001	if (!empty($params['order'])) {
2002	$strReq .= 'ORDER BY '.$this->con->escape($params['order']).' ';
2003	} else {
2004	$strReq .= 'ORDER BY comment_dt DESC ';
2005	}
2006	}
2007
2008	if (!$count_only && !empty($params['limit'])) {
2009	$strReq .= $this->con->limit($params['limit']);
2010	}
2011
2012	if (!empty($params['sql_only'])) {
2013	return $strReq;
2014	}
2015
2016	$rs = $this->con->select($strReq);
2017	$rs->core = $this->core;
2018	$rs->extend('rsExtComment');
2019
2020	# --BEHAVIOR-- coreBlogGetComments
2021	$this->core->callBehavior('coreBlogGetComments',$rs);
2022
2023	return $rs;
2024	}
2025
2026	/**
2027	Creates a new comment. Takes a cursor as input and returns the new comment
2028	ID.
2029
2030	@param cur <b>cursor</b> Comment cursor
2031	@return <b>integer</b> New comment ID
2032	*/
2033	public function addComment($cur)
2034	{
2035	$this->con->writeLock($this->prefix.'comment');
2036	try
2037	{
2038	# Get ID
2039	$rs = $this->con->select(
2040	'SELECT MAX(comment_id) '.
2041	'FROM '.$this->prefix.'comment '
2042	);
2043
2044	$cur->comment_id = (integer) $rs->f(0) + 1;
2045	$cur->comment_upddt = date('Y-m-d H:i:s');
2046
2047	$offset = dt::getTimeOffset($this->settings->system->blog_timezone);
2048	$cur->comment_dt = date('Y-m-d H:i:s',time() + $offset);
2049	$cur->comment_tz = $this->settings->system->blog_timezone;
2050
2051	$this->getCommentCursor($cur);
2052
2053	if ($cur->comment_ip === null) {
2054	$cur->comment_ip = http::realIP();
2055	}
2056
2057	# --BEHAVIOR-- coreBeforeCommentCreate
2058	$this->core->callBehavior('coreBeforeCommentCreate',$this,$cur);
2059
2060	$cur->insert();
2061	$this->con->unlock();
2062	}
2063	catch (Exception $e)
2064	{
2065	$this->con->unlock();
2066	throw $e;
2067	}
2068
2069	# --BEHAVIOR-- coreAfterCommentCreate
2070	$this->core->callBehavior('coreAfterCommentCreate',$this,$cur);
2071
2072	$this->triggerComment($cur->comment_id);
2073	if ($cur->comment_status != -2) {
2074	$this->triggerBlog();
2075	}
2076	return $cur->comment_id;
2077	}
2078
2079	/**
2080	Updates an existing comment.
2081
2082	@param id <b>integer</b> Comment ID
2083	@param cur <b>cursor</b> Comment cursor
2084	*/
2085	public function updComment($id,$cur)
2086	{
2087	if (!$this->core->auth->check('usage,contentadmin',$this->id)) {
2088	throw new Exception(__('You are not allowed to update comments'));
2089	}
2090
2091	$id = (integer) $id;
2092
2093	if (empty($id)) {
2094	throw new Exception(__('No such comment ID'));
2095	}
2096
2097	$rs = $this->getComments(array('comment_id' => $id));
2098
2099	if ($rs->isEmpty()) {
2100	throw new Exception(__('No such comment ID'));
2101	}
2102
2103	#If user is only usage, we need to check the post's owner
2104	if (!$this->core->auth->check('contentadmin',$this->id))
2105	{
2106	if ($rs->user_id != $this->core->auth->userID()) {
2107	throw new Exception(__('You are not allowed to update this comment'));
2108	}
2109	}
2110
2111	$this->getCommentCursor($cur);
2112
2113	$cur->comment_upddt = date('Y-m-d H:i:s');
2114
2115	if (!$this->core->auth->check('publish,contentadmin',$this->id)) {
2116	$cur->unsetField('comment_status');
2117	}
2118
2119	# --BEHAVIOR-- coreBeforeCommentUpdate
2120	$this->core->callBehavior('coreBeforeCommentUpdate',$this,$cur,$rs);
2121
2122	$cur->update('WHERE comment_id = '.$id.' ');
2123
2124	# --BEHAVIOR-- coreAfterCommentUpdate
2125	$this->core->callBehavior('coreAfterCommentUpdate',$this,$cur,$rs);
2126
2127	$this->triggerComment($id);
2128	$this->triggerBlog();
2129	}
2130
2131	/**
2132	Updates comment status.
2133
2134	@param id <b>integer</b> Comment ID
2135	@param status <b>integer</b> Comment status
2136	*/
2137	public function updCommentStatus($id,$status)
2138	{
2139	$this->updCommentsStatus($id,$status);
2140	}
2141
2142	/**
2143	Updates comments status.
2144
2145	@param ids <b>mixed</b> Comment(s) ID(s)
2146	@param status <b>integer</b> Comment status
2147	*/
2148	public function updCommentsStatus($ids,$status)
2149	{
2150	if (!$this->core->auth->check('publish,contentadmin',$this->id)) {
2151	throw new Exception(__("You are not allowed to change this comment's status"));
2152	}
2153
2154	$co_ids = dcUtils::cleanIds($ids);
2155	$status = (integer) $status;
2156
2157	$strReq =
2158	'UPDATE '.$this->prefix.'comment tc ';
2159
2160	# mySQL uses "JOIN" synthax
2161	if ($this->con->driver() == 'mysql') {
2162	$strReq .=
2163	'JOIN '.$this->prefix.'post tp ON tc.post_id = tp.post_id ';
2164	}
2165
2166	$strReq .=
2167	'SET comment_status = '.$status.' ';
2168
2169	# pgSQL uses "FROM" synthax
2170	if ($this->con->driver() != 'mysql') {
2171	$strReq .=
2172	'FROM '.$this->prefix.'post tp ';
2173	}
2174
2175	$strReq .=
2176	"WHERE blog_id = '".$this->con->escape($this->id)."' ".
2177	'AND comment_id'.$this->con->in($co_ids);
2178
2179	# add pgSQL "WHERE" clause
2180	if ($this->con->driver() != 'mysql') {
2181	$strReq .=
2182	'AND tc.post_id = tp.post_id ';
2183	}
2184
2185	#If user is only usage, we need to check the post's owner
2186	if (!$this->core->auth->check('contentadmin',$this->id))
2187	{
2188	$strReq .=
2189	"AND user_id = '".$this->con->escape($this->core->auth->userID())."' ";
2190	}
2191
2192	$this->con->execute($strReq);
2193	$this->triggerComments($co_ids);
2194	$this->triggerBlog();
2195	}
2196
2197	/**
2198	Delete a comment
2199
2200	@param id <b>integer</b> Comment ID
2201	*/
2202	public function delComment($id)
2203	{
2204	$this->delComments($id);
2205	}
2206
2207	/**
2208	Delete comments
2209
2210	@param ids <b>mixed</b> Comment(s) ID(s)
2211	*/
2212	public function delComments($ids)
2213	{
2214	if (!$this->core->auth->check('delete,contentadmin',$this->id)) {
2215	throw new Exception(__('You are not allowed to delete comments'));
2216	}
2217
2218	$co_ids = dcUtils::cleanIds($ids);
2219
2220	if (empty($ids)) {
2221	throw new Exception(__('No such comment ID'));
2222	}
2223
2224	# mySQL uses "INNER JOIN" synthax
2225	if ($this->con->driver() == 'mysql') {
2226	$strReq =
2227	'DELETE FROM tc '.
2228	'USING '.$this->prefix.'comment tc '.
2229	'INNER JOIN '.$this->prefix.'post tp ';
2230	}
2231	# pgSQL uses nothing special
2232	else {
2233	$strReq =
2234	'DELETE FROM '.$this->prefix.'comment tc '.
2235	'USING '.$this->prefix.'post tp ';
2236	}
2237
2238	$strReq .=
2239	'WHERE tc.post_id = tp.post_id '.
2240	"AND tp.blog_id = '".$this->con->escape($this->id)."' ".
2241	'AND comment_id'.$this->con->in($co_ids);
2242
2243	#If user can only delete, we need to check the post's owner
2244	if (!$this->core->auth->check('contentadmin',$this->id))
2245	{
2246	$strReq .=
2247	"AND user_id = '".$this->con->escape($this->core->auth->userID())."' ";
2248	}
2249
2250	$this->con->execute($strReq);
2251	$this->triggerComments($co_ids,true);
2252	$this->triggerBlog();
2253	}
2254
2255	public function delJunkComments()
2256	{
2257	if (!$this->core->auth->check('delete,contentadmin',$this->id)) {
2258	throw new Exception(__('You are not allowed to delete comments'));
2259	}
2260
2261	# mySQL uses "INNER JOIN" synthax
2262	if ($this->con->driver() == 'mysql') {
2263	$strReq =
2264	'DELETE FROM tc '.
2265	'USING '.$this->prefix.'comment tc '.
2266	'INNER JOIN '.$this->prefix.'post tp ';
2267	}
2268	# pgSQL uses nothing special
2269	else {
2270	$strReq =
2271	'DELETE FROM '.$this->prefix.'comment tc '.
2272	'USING '.$this->prefix.'post tp ';
2273	}
2274
2275	$strReq .=
2276	'WHERE tc.post_id = tp.post_id '.
2277	"AND tp.blog_id = '".$this->con->escape($this->id)."' ".
2278	'AND comment_status = -2';
2279
2280	#If user can only delete, we need to check the post's owner
2281	if (!$this->core->auth->check('contentadmin',$this->id))
2282	{
2283	$strReq .=
2284	"AND user_id = '".$this->con->escape($this->core->auth->userID())."' ";
2285	}
2286
2287	$this->con->execute($strReq);
2288	$this->triggerBlog();
2289	}
2290
2291	private function getCommentCursor($cur)
2292	{
2293	if ($cur->comment_content !== null && $cur->comment_content == '') {
2294	throw new Exception(__('You must provide a comment'));
2295	}
2296
2297	if ($cur->comment_author !== null && $cur->comment_author == '') {
2298	throw new Exception(__('You must provide an author name'));
2299	}
2300
2301	if ($cur->comment_email != '' && !text::isEmail($cur->comment_email)) {
2302	throw new Exception(__('Email address is not valid.'));
2303	}
2304
2305	if ($cur->comment_site !== null && $cur->comment_site != '') {
2306	if (!preg_match('\|^http(s?)://\|',$cur->comment_site)) {
2307	$cur->comment_site = 'http://'.$cur->comment_site;
2308	}
2309	}
2310
2311	if ($cur->comment_status === null) {
2312	$cur->comment_status = (integer) $this->settings->system->comments_pub;
2313	}
2314
2315	# Words list
2316	if ($cur->comment_content !== null)
2317	{
2318	$cur->comment_words = implode(' ',text::splitWords($cur->comment_content));
2319	}
2320	}
2321	//@}
2322	}
2323	?>

Note: See TracBrowser for help on using the repository browser.

Dotclear

Context Navigation

source: inc/core/class.dc.blog.php @ 1468:3132a0aca046

Download in other formats:

Sites map