package cn.ksource.web.facade.message;

import java.io.File;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import cn.ksource.web.service.message.MessageRunable;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import cn.ksource.beans.GG_MESSAGE;
import cn.ksource.core.dao.BaseDao;
import cn.ksource.core.dao.SqlParameter;
import cn.ksource.core.page.PageInfo;
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.DateUtil;
import cn.ksource.core.util.FileUtil;
import cn.ksource.core.util.MyFileUploadException;
import cn.ksource.core.util.ParamsMapUtil;
import cn.ksource.core.util.StringUtil;
import cn.ksource.core.util.ZipUtil;
import cn.ksource.core.web.LoginUser;
import cn.ksource.core.web.WebUtil;
import cn.ksource.web.entity.message.CmsNews;
import cn.ksource.web.service.colunm.ColunmService;
import cn.ksource.web.service.file.FileService;
import cn.ksource.web.service.message.MessageService;

@Service("messageFacade")
@SuppressWarnings("unchecked")
public class MessageFacadeImpl implements MessageFacade {

	@Resource(name="messageService")
	private MessageService messageService;
	
	@Resource(name="colunmService")
	private ColunmService colunmService;
	
	@Resource(name="fileService")
	private FileService fileService;
	
	@Autowired
	private BaseDao baseDao;

	@Override
	public List<Map> queryMeunListById() {
		return messageService.queryMeunListById();
	}

	@Override
	public boolean isShowAddButton(String categoryId) {
		//判断是否需要展示添加按钮
        //如果此分类是列表展示，则显示添加按钮，如果此分类是单信息，则查询该分类下有无数据，如果有一条数据，则不显示添加按钮，如果无数据，则显示添加按钮
		//通过分类id查询分类详情
		Map colunmMap = colunmService.queryColunmById(categoryId);
		//判断该分类的类型
		String type = ConvertUtil.obj2StrBlank(colunmMap.get("SHOW_TYPE"));
		boolean b = false;
		if(type.equals("1")) {
			b = true;
		} else if(type.equals("2")) {
			//查询该分类下有无信息
			int count = messageService.queryMessageCountByCategoryId(categoryId);
			if(count==0) {
				b = true;
			}
		}
		return b;
	}
	
	
	/**
	 * 保存信息内容
	 */
	@Override
	public boolean save(CmsNews cmsNews, HttpServletRequest request) {
		String[] allowType =  new String[]{"gif","jpg","jpeg","png"};
		int categoryId = cmsNews.getCategoryId();
		Map colunm = colunmService.queryColunmById(ConvertUtil.obj2StrBlank(categoryId));
		
		cmsNews.setShenpiStatus(1);
		
		//判断是否需要标题图片
		int titleimage = ConvertUtil.obj2Int(colunm.get("TITLEIMAGE"));
		
		
		String uploadUrl = new String();
		if(titleimage==1) {
			try {
				uploadUrl = FileUtil.uploadFile4SpringMVC(request, "titleimage" ,"/upload/classify"+categoryId,allowType);
				//判断是否需要生成缩略图
				int thumbnail = ConvertUtil.obj2Int(colunm.get("THUMBNAIL"));
				if(thumbnail!=1){
					//获得生成的缩略图的等比或者强制宽和高
					String widthStr = ConvertUtil.obj2StrBlank(colunm.get("TITLEIMAGE_WIDTH"));
					String heightStr = ConvertUtil.obj2StrBlank(colunm.get("TITLEIMAGE_HEIGHT"));
					if(!widthStr.equals("") && !heightStr.equals("") && !widthStr.equals("0") && !heightStr.equals("0")) {
						int width = ConvertUtil.obj2Int(widthStr);
						int height = ConvertUtil.obj2Int(heightStr);
						String pathPix = request.getSession().getServletContext().getRealPath("/");
						boolean b = false;
						if(thumbnail==3) {
							b = true;
						}
						String newName = FileUtil.resizeForEqualImg(new File(pathPix+uploadUrl), width, height, b);
						uploadUrl = uploadUrl.replace(uploadUrl.substring(uploadUrl.lastIndexOf("/")+1), newName);
					}
				}
				cmsNews.setTitleimageurl(uploadUrl);
				
			} catch (MyFileUploadException e) {
				return false;
			}
		}
		
		messageService.saveMessage(cmsNews,request);
		
		return true;
	}

	
//	private CmsNews dealUploadFiles(HttpServletRequest request,CmsNews cmsNews) throws MyFileUploadException {
//		
//		    List<FileUtil.FileInfo> infos =FileUtil.uploadFiles(request, "/upload/attachment/", null);
//		    List<SqlParameter> attachMentList = new ArrayList<SqlParameter>();
//		    for(FileUtil.FileInfo fileInfo:infos){
//		       if(fileInfo.getFilePath()==null){
//		    	   continue;
//		       }
//		       if(fileInfo.getFieldName().equals("infoFile")) {
//		    	   SqlParameter map = new SqlParameter();
//		    	   map.put("FILENAME", fileInfo.getOriginalFilename());
//		    	   map.put("FILEPATH", fileInfo.getFilePath());
//		    	   map.put("FILETYPE", fileInfo.getExtName());
//		    	   map.put("FILESIZE", fileInfo.getFileSize());
//		    	   attachMentList.add(map);
//		       }
//		    }
//		    cmsNews.setListAttachMents(attachMentList);
//		
//		return cmsNews;
//	}
//	
	/**
	 * 查询指定分类下的所有信息列表
	 */
	@Override
	public Map queryMessageListJson(String categoryId, int page, int pageSize) {
		return messageService.queryMessageListJson(categoryId,page,pageSize);
	}

	/**
	 * 删除指定id的信息
	 */
	@Override
	public void deleteMessage(String id) {
		messageService.deleteMessage(id);
	}

	/**
	 * 通过信息id查询信息详情
	 */
	@Override
	public Map queryMessageById(String messageId) {
		return messageService.queryMessageById(messageId);
	}

	/**
	 * 修改信息
	 */
	@Override
	public boolean updateMessage(CmsNews cmsNews, HttpServletRequest request) {
		String[] allowType =  new String[]{"gif","jpg","jpeg","png"};
		int categoryId = cmsNews.getCategoryId();
		Map colunm = colunmService.queryColunmById(ConvertUtil.obj2StrBlank(categoryId));
		//判断是否需要标题图片
		int titleimage = ConvertUtil.obj2Int(colunm.get("TITLEIMAGE"));
		
		
		String uploadUrl = new String();
		if(titleimage==1) {
			try {
				uploadUrl = FileUtil.uploadFile4SpringMVC(request, "titleimage" ,"/upload/classify"+categoryId,allowType);
				if(null!=uploadUrl) {
					//判断是否需要生成缩略图
					int thumbnail = ConvertUtil.obj2Int(colunm.get("THUMBNAIL"));
					if(thumbnail!=1){
						//获得生成的缩略图的等比或者强制宽和高
						String widthStr = ConvertUtil.obj2StrBlank(colunm.get("TITLEIMAGE_WIDTH"));
						String heightStr = ConvertUtil.obj2StrBlank(colunm.get("TITLEIMAGE_HEIGHT"));
						if(!widthStr.equals("") && !heightStr.equals("") && !widthStr.equals("0") && !heightStr.equals("0")) {
							int width = ConvertUtil.obj2Int(widthStr);
							int height = ConvertUtil.obj2Int(heightStr);
							String pathPix = request.getSession().getServletContext().getRealPath("/");
							boolean b = false;
							if(thumbnail==3) {
								b = true;
							}
							String newName = FileUtil.resizeForEqualImg(new File(pathPix+uploadUrl), width, height, b);
							uploadUrl = uploadUrl.replace(uploadUrl.substring(uploadUrl.lastIndexOf("/")+1), newName);
						}
					}
					cmsNews.setTitleimageurl(uploadUrl);
				}
				
			} catch (MyFileUploadException e) {
				return false;
			}
		}
		//上传附件
//		try {
//			cmsNews = dealUploadFiles(request, cmsNews);
//		} catch (MyFileUploadException e) {
//			return false;
//		}
		
		messageService.updateMessage(cmsNews);
		//上传附件
		LoginUser loginUser = WebUtil.getLoginUser(request);
		String createUserId = String.valueOf(loginUser.getLoginUser().get("ID"));
		String createUserName = String.valueOf(loginUser.getLoginUser().get("LOGINNAME"));
		Map<String,String> params = ParamsMapUtil.getParameterMap(request);
		params.put("business_id", ConvertUtil.obj2Str(cmsNews.getId()));
		params.put("userId", createUserId);
		params.put("userName", createUserName);
		fileService.uploadFile(params);
		return true;
	}

	/**
	 * 查询附件信息
	 */
	@Override
	public List queryAttachment(String messageId) {
		return messageService.queryAttachment(messageId);
	}

	
	@Override
	public String saveZip(HttpServletRequest request) {
		String uploadUrl = new String();
		String indexPath = new String();
		//定义zip路径
		/*String zipPackage = "/upload/zippackage";
			try {
				uploadUrl = FileUtil.uploadFile4SpringMVC(request, "zippackage" ,zipPackage,new String[]{"zip"});
				String pathPix = request.getSession().getServletContext().getRealPath("/");
				try {
					//ZipUtil.decompress(pathPix+zipPackage,pathPix+uploadUrl);
					String unzipPath = ZipUtil.unzip(pathPix+uploadUrl,pathPix+zipPackage,"index.html");
					String pathSuf = uploadUrl.substring(uploadUrl.lastIndexOf("/"),uploadUrl.lastIndexOf("."));
					indexPath = zipPackage+pathSuf+"/"+unzipPath;
                    
				} catch (Exception e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			} catch (MyFileUploadException e) {
				return "";
			}*/
			//fileService.uploadFile(request, "12345689789");
		return indexPath;
	}
	
	@Override
	public void saveNum(List list) {
		String sql = "UPDATE CMS_NEWS SET SHOW_NUM = :SHOW_NUM WHERE ID = :ID";
		baseDao.executeBatch(sql, list);
	}

	@Override
	public int querymessageCount(String categoryId) {
		StringBuilder builder = new StringBuilder("SELECT COUNT(ID) FROM CMS_NEWS WHERE CATEGORY_ID = :categoryId ");
		Map paramMap = new HashMap();
		paramMap.put("categoryId", categoryId);
		
		
		int count = baseDao.queryForInteger(builder.toString(), paramMap);
		
		return count;
	}

	@Override
	public PageInfo querymessageData(PageInfo pageInfo,String categoryId) {
		StringBuilder builder = new StringBuilder("SELECT * FROM CMS_NEWS WHERE CATEGORY_ID = :categoryId ");
		Map paramMap = new HashMap();
		paramMap.put("categoryId", categoryId);
		
		builder.append(" ORDER BY THETOP ASC,SHOW_NUM ASC ");
		
		PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), paramMap);
		
		return info;
	}
	
	@Override
	public List getMyMessageTitle(String messageType,String userId) {
		StringBuilder sql = new StringBuilder();
		sql.append(" select  m.title,m.WEB_URL url,r.id receiveId from gg_message m inner join gg_message_receiver r ");
		sql.append(" on m.id = r.message_Id where r.receiver_id = :userId and state = 1  ");
		SqlParameter param = new SqlParameter();
		if(StringUtil.isNotBlank(messageType)){
			sql.append(" and m.type = :messageType");
			param.addValue("messageType", messageType);
		}
		param.addValue("userId", userId);
		sql.append(" order by m.send_time desc LIMIT 3 ");
		return baseDao.queryForList(sql.toString(), param);
	}
	
	
	


	@Override
	public void doSendMessage(GG_MESSAGE message, List<Map> receiverList) {
		if(message!=null){
			message.insertOrUpdate();
			if(receiverList!=null&&receiverList.size()>0){
				String sql = "insert into gg_message_receiver " +
				" (id,receiver_id,receiver_name,message_id,state) values " +
				" (:id,:USER_ID,:USER_NAME,:messageId,:state)";
				List<SqlParameter> list = new ArrayList<SqlParameter>();
				String messageId = message.getId();
				for(Map map:receiverList){
					SqlParameter param = new SqlParameter();
					map.put("id", StringUtil.getUUID());
					map.put("state",1);
					map.put("messageId", messageId);
					param.setSource(map);
					list.add(param);
				}
				baseDao.executeBatch(sql,list);
//				messageService.sendMessage(message);
			}
			List<Map> msgs=getRoleLinkEmails(message);
			if(msgs!=null && msgs.size()>0) {
				Thread thread = new Thread(new MessageRunable(message,msgs));
				thread.start();
			}
		}
	}

	public List<Map> getRoleLinkEmails(GG_MESSAGE message) {
		String msgId = message.getId();
		String selectSql = "SELECT B.ISWECHAT,B.ISPHONE,B.ISEMAIL,B.SJHM,B.EMAIL,B.OPEN_ID,B.REMIND_TYPE,B.ID AS USER_ID FROM GG_MESSAGE_RECEIVER A,GG_USER B WHERE A.RECEIVER_ID = B.ID AND B.ZT = 1 AND A.MESSAGE_ID = :msgId ";
		List<Map> msgs = baseDao.queryForList(selectSql,new SqlParameter("msgId",msgId));
		return msgs;
	}
	
	@Override
	public void sendMessage(GG_MESSAGE message, List<Map> receiverList) {
		if(message!=null){
			message.insertOrUpdate();
			if(receiverList!=null&&receiverList.size()>0){
				String sql = "INSERT INTO GG_MESSAGE_RECEIVER " +
				" (ID,RECEIVER_ID,RECEIVER_NAME,MESSAGE_ID,STATE,WX_URL) values " +
				" (:id,:USER_ID,:USER_NAME,:messageId,:state,:wx_url)";
				List<SqlParameter> list = new ArrayList<SqlParameter>();
				String messageId = message.getId();
				for(Map map:receiverList){
					SqlParameter param = new SqlParameter();
					map.put("id", StringUtil.getUUID());
					map.put("state",1);
					map.put("messageId", messageId);
					param.setSource(map);
					list.add(param);
				}
				baseDao.executeBatch(sql,list);
				messageService.sendNoticeMessage(message);
			}
		}
		
	}
	
	
	@Override
	public List getMyMessage(HttpServletRequest request,GG_MESSAGE message,String userId,String state) {
		StringBuilder sql = new StringBuilder();
		SqlParameter param = new SqlParameter();
		param.addValue("userId", userId);
		sql.append(" select m.*,r.state,r.id receiveId from gg_message m inner join gg_message_receiver r ");
		sql.append(" on m.id = r.message_Id where r.receiver_id = :userId ");
		//根据标题查找标题
		if(StringUtil.isNotBlank(message.getTitle())){
			sql.append(" and m.title like :title ");
			param.addValue("title","%"+ message.getTitle() +"%");
		}
		//根据内容查找标题
		if(StringUtil.isNotBlank(message.getContent())){
			sql.append(" and m.content like :content ");
			param.addValue("content","%"+ message.getContent() +"%");
		}
		//根据类型查找
		if(message.getType()!=null){
			sql.append(" and type = :type ");
			param.addValue("type",message.getType());
		}
		//根据状态查找
		if(StringUtil.isNotBlank(state)){
			sql.append(" and r.state = :state ");
			param.addValue("state",state);
		}
		sql.append(" order by m.send_time desc ");
		return baseDao.queryforSplitPage(request,sql.toString(),param);
	}

	@Override
	public Integer getMyMessageCount(GG_MESSAGE message,String userId,String state) {
		
		StringBuilder sql = new StringBuilder();
		SqlParameter param = new SqlParameter();
		param.addValue("userId", userId);
		sql.append(" select count(m.id) from gg_message m inner join gg_message_receiver r ");
		sql.append(" on m.id = r.message_Id where r.receiver_id = :userId ");
		//根据标题查找标题
		if(StringUtil.isNotBlank(message.getTitle())){
			sql.append(" and m.title like :title ");
			param.addValue("title","%"+ message.getTitle() +"%");
		}
		//根据内容查找标题
		if(StringUtil.isNotBlank(message.getContent())){
			sql.append(" and m.content like :content ");
			param.addValue("content","%"+ message.getContent() +"%");
		}
		//根据类型查找
		if(message.getType()!=null){
			sql.append(" and m.type = :type ");
			param.addValue("type",message.getType());
		}
		//根据状态查找
		if(StringUtil.isNotBlank(state)){
			sql.append(" and r.state = :state ");
			param.addValue("state",state);
		}
		return baseDao.queryForInteger(sql.toString(),param);
	}





	@Override
	public void doReadMessage(String businessId, String receiverId) {
		String sql = "update gg_message m inner join gg_message_receiver r on m.id = r.message_id set state=2, READ_TIME=:curDate where "+ 
					" m.BUSINESS_ID=:businessId and r.RECEIVER_ID=:receviceId";
		Long curDate = DateUtil.getCurrentDate14();
		SqlParameter param = new SqlParameter();
		
		param.addValue("businessId", businessId)
			.addValue("receviceId", receiverId)
			.addValue("curDate", curDate);
		baseDao.execute(sql, param);
	}





	@Override
	public int getMyMessageCount(String messageType, String userId) {
		StringBuilder sql = new StringBuilder();
		sql.append(" select  count(m.id) from gg_message m inner join gg_message_receiver r ");
		sql.append(" on m.id = r.message_Id where r.receiver_id = :userId and state = 1  ");
		SqlParameter param = new SqlParameter();
		if(StringUtil.isNotBlank(messageType)){
			sql.append(" and m.type = :messageType");
			param.addValue("messageType", messageType);
		}
		param.addValue("userId", userId);
		sql.append(" order by m.send_time asc LIMIT 5 ");
		return baseDao.queryForInteger(sql.toString(), param);
	}
}