/**
 * Copyright (c) 2015-2016, Michael Yang 杨福海 (fuhai999@gmail.com).
 *
 * Licensed under the GNU Lesser General Public License (LGPL) ,Version 3.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.gnu.org/licenses/lgpl-3.0.txt
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package io.jpress.model.query;

import com.jfinal.plugin.activerecord.Page;
import com.jfinal.plugin.ehcache.IDataLoader;
import io.jpress.model.Comment;

import java.math.BigInteger;
import java.util.LinkedList;

public class CommentQuery extends JBaseQuery {

	protected static final Comment DAO = new Comment();
	private static final CommentQuery QUERY = new CommentQuery();

	public static CommentQuery me() {
		return QUERY;
	}

	public Page<Comment> paginateWithContent(int pageNumber, int pageSize, String module, String type,
			BigInteger contentId, BigInteger parentCommentId, String status) {

		String select = " select c.*,content.title content_title,u.username,u.nickname,u.avatar, "
				+ "quote_comment.text qc_content,quote_comment.author qc_author,"
				+ "quote_user.username qc_username,quote_user.nickname qc_nickname,quote_user.avatar qc_avatar ";

		StringBuilder fromBuilder = new StringBuilder("  from comment c");
		fromBuilder.append(" left join content on c.content_id = content.id");
		fromBuilder.append(" left join user u on c.user_id = u.id ");
		fromBuilder.append(" left join comment quote_comment on c.parent_id = quote_comment.id");
		fromBuilder.append(" left join user quote_user on quote_comment.user_id = quote_user.id ");

		LinkedList<Object> params = new LinkedList<Object>();
		boolean needWhere = true;
		needWhere = appendIfNotEmpty(fromBuilder, " c.`type`", type, params, needWhere);
		needWhere = appendIfNotEmpty(fromBuilder, " c.content_module", module, params, needWhere);
		needWhere = appendIfNotEmpty(fromBuilder, " c.`status`", status, params, needWhere);
		needWhere = appendIfNotEmpty(fromBuilder, " c.parent_id", parentCommentId, params, needWhere);
		needWhere = appendIfNotEmpty(fromBuilder, " content.id", contentId, params, needWhere);

		fromBuilder.append("order by c.created desc");

		if (params.isEmpty()) {
			return DAO.paginate(pageNumber, pageSize, select, fromBuilder.toString());
		}
		return DAO.paginate(pageNumber, pageSize, select, fromBuilder.toString(), params.toArray());
	}

	public Page<Comment> paginateWithContentNotInDelete(int pageNumber, int pageSize, String module, String type,
			BigInteger contentId, BigInteger parentCommentId) {

		String select = " select c.*,content.title content_title,u.username,u.nickname,u.avatar, "
				+ "quote_comment.text qc_content,quote_comment.author qc_author,"
				+ "quote_user.username qc_username,quote_user.nickname qc_nickname,quote_user.avatar qc_avatar ";

		StringBuilder fromBuilder = new StringBuilder("  from comment c");
		fromBuilder.append(" left join content on c.content_id = content.id");
		fromBuilder.append(" left join user u on c.user_id = u.id ");
		fromBuilder.append(" left join comment quote_comment on c.parent_id = quote_comment.id");
		fromBuilder.append(" left join user quote_user on quote_comment.user_id = quote_user.id ");

		fromBuilder.append(" WHERE c.status <> '" + Comment.STATUS_DELETE + "' ");

		LinkedList<Object> params = new LinkedList<Object>();
		appendIfNotEmpty(fromBuilder, " c.`type`", type, params, false);
		appendIfNotEmpty(fromBuilder, " c.content_module", module, params, false);
		appendIfNotEmpty(fromBuilder, " c.parent_id", parentCommentId, params, false);
		appendIfNotEmpty(fromBuilder, " content.id", contentId, params, false);

		fromBuilder.append("order by c.created desc");

		if (params.isEmpty()) {
			return DAO.paginate(pageNumber, pageSize, select, fromBuilder.toString());
		}
		return DAO.paginate(pageNumber, pageSize, select, fromBuilder.toString(), params.toArray());
	}

	public Page<Comment> paginateWithContentAndSon(int pageNumber, int pageSize, String module, String type,
														BigInteger contentId, BigInteger parentCommentId, Boolean hasSon) {

		String select = " select c.*,content.title content_title,u.username,u.nickname,u.avatar, "
				+ "quote_comment.text qc_content,quote_comment.author qc_author,"
				+ "quote_user.username qc_username,quote_user.nickname qc_nickname,quote_user.avatar qc_avatar ";

		StringBuilder fromBuilder = new StringBuilder("  from comment c");
		fromBuilder.append(" left join content on c.content_id = content.id");
		fromBuilder.append(" left join user u on c.user_id = u.id ");
		fromBuilder.append(" left join comment quote_comment on c.parent_id = quote_comment.id");
		fromBuilder.append(" left join user quote_user on quote_comment.user_id = quote_user.id ");

		fromBuilder.append(" WHERE c.status <> '" + Comment.STATUS_DELETE + "' ");

		if (hasSon == true) {
			fromBuilder.append("and c.parent_id is not null ");
		} else {
			//不找作者本身的回复(需再思考  数量和实际显示)
			fromBuilder.append("and c.parent_id is null and c.user_id != content.user_id ");
		}

		LinkedList<Object> params = new LinkedList<Object>();
		appendIfNotEmpty(fromBuilder, " c.`type`", type, params, false);
		appendIfNotEmpty(fromBuilder, " c.content_module", module, params, false);
		appendIfNotEmpty(fromBuilder, " c.parent_id", parentCommentId, params, false);
		appendIfNotEmpty(fromBuilder, " content.id", contentId, params, false);

		fromBuilder.append("order by c.created desc");

		if (params.isEmpty()) {
			return DAO.paginate(pageNumber, pageSize, select, fromBuilder.toString());
		}
		return DAO.paginate(pageNumber, pageSize, select, fromBuilder.toString(), params.toArray());
	}

	public Page<Comment> paginateByContentId(int pageNumber, int pageSize, BigInteger contentId) {
		return paginateWithContent(pageNumber, pageSize, null, null, contentId, null, Comment.STATUS_NORMAL);
	}

	public long findCountByContentIdInNormal(BigInteger contentId) {
		return findCountByContentId(contentId, Comment.STATUS_NORMAL);
	}

	public long findCountByContentId(BigInteger contentId, String status) {
		return DAO.doFindCount(" content_id = ? and status=? ", contentId, status);
	}

	public long findCountByParentIdInNormal(BigInteger pId) {
		return findCountByParentId(pId, Comment.STATUS_NORMAL);
	}

	public long findCountByParentId(BigInteger pId, String status) {
		return DAO.doFindCount(" parent_id = ? and status=? ", pId, status);
	}

	public long findCountByUserIdInNormal(BigInteger userId) {
		return findCountByUserId(userId, Comment.STATUS_NORMAL);
	}

	public long findCountByUserId(BigInteger userId, String status) {
		return DAO.doFindCount(" user_id = ? and status=? ", userId, status);
	}

	public Comment findById(final Object idValue) {
		return DAO.getCache(idValue, new IDataLoader() {
			@Override
			public Object load() {
				return DAO.findById(idValue);
			}
		});
	}

	public long findCountByModule(String module) {
		return DAO.doFindCount("content_module = ?", module);
	}

	public long findCountInNormalByModule(String module) {
		return DAO.doFindCount("content_module = ? AND status <> ?", module, Comment.STATUS_DELETE);
	}

	public long findCountByModuleAndStatus(String module, String status) {
		return DAO.doFindCount("content_module = ? and status=?", module, status);
	}

	public long findCountByModuleAndSonAndContentId(BigInteger contentId, String module, boolean hasSon) {
		io.jpress.model.Content content = DAO.getContentById(contentId);
		BigInteger authorUserId = null;
		if (content != null) {
			authorUserId = content.getUserId();
		}
		Long count = new Long(0);
		if (hasSon == true) {
			count = DAO.doFindCount("content_module = ? and parent_id is not null and content_id = ?", module ,contentId);
		} else {
			if (authorUserId == null) {
				count = DAO.doFindCount("content_module = ? and parent_id is null and content_id = ? ", module ,contentId);
			} else {
				count = DAO.doFindCount("content_module = ? and parent_id is null and content_id = ? and user_id != ?", module ,contentId ,authorUserId);
			}
		}

		return count;
	}

	public long findCountByModuleAndStatusAndContentId(BigInteger contentId, String module, String status) {
		return DAO.doFindCount(" content_id = ? and content_module = ? and status=?",contentId, module, status);
	}

	public long findCountByModuleAndStatusAndContentId(BigInteger contentId, String module, boolean parent) {
		Long count = new Long(0);
		if (parent == true) {
			count = DAO.doFindCount("content_module = ? and parent_id is not null and content_id = " + contentId, module);
		} else {
			count = DAO.doFindCount("content_module = ? and parent_id is null and content_id = " + contentId, module);
		}

		return count;
	}
}