caimei365-manager/src/main/java/com/caimei/modules/info/service/InfoService.java

package com.caimei.modules.info.service;

import java.util.Date;
import java.util.List;

import javax.servlet.http.HttpServletRequest;

import com.caimei.modules.live.entity.NewPageLive;
import com.caimei.modules.sys.utils.UploadImageUtils;
import org.apache.commons.collections.CollectionUtils;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
import org.jsoup.select.Elements;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.caimei.dfs.image.beens.ImageUploadInfo;
import com.caimei.modules.brand.utils.ImagePathUtils;
import com.caimei.modules.info.dao.InfoDao;
import com.caimei.modules.info.dao.InfoLabelDao;
import com.caimei.modules.info.entity.Info;
import com.caimei.modules.info.entity.InfoLabel;
import com.thinkgem.jeesite.common.config.Global;
import com.thinkgem.jeesite.common.persistence.Page;
import com.thinkgem.jeesite.common.service.CrudService;
import com.thinkgem.jeesite.common.utils.Encodes;
import com.thinkgem.jeesite.common.utils.StringUtils;

/**
 * 信息列表Service
 *
 * @author LG
 * @version 2016-06-27
 */
@Service
@Transactional(readOnly = true)
public class InfoService extends CrudService<InfoDao, Info> {

	@Autowired
	private InfoDao infoDao;

	@Autowired
	private InfoLabelDao infoLabelDao;

	public Info get(String id) {
		Info info = super.get(id);
		if (null != info) {
			String admin2Server = Global.getConfig("admin2Server");//获取admin2文件服务器地址
			String image = info.getGuidanceImage();
			if (StringUtils.isNotBlank(image) && !image.contains("http:") && !image.contains("https:") && !image.contains("https:")) {//不包含http的
				info.setGuidanceImage(admin2Server + "/uploadFile/infoImage/" + image);
			}
		}
		return info;
	}

	public List<Info> findList(Info info) {
		return super.findList(info);
	}

	public Page<Info> findPage(Page<Info> page, Info info) {
		if (null != info.getPublishSource() && 2 == info.getPublishSource()) {
			page.setOrderBy("a.createDate desc");
		}
		Page<Info> infoPage = super.findPage(page, info);
		List<Info> infoList = infoPage.getList();
		infoList.forEach(infoItem -> {
			//是否置顶
			if (StringUtils.isNotEmpty(infoItem.getTopPosition())) {
				if ("1".equals(infoItem.getTopPosition())) {
					infoItem.setTopPosition("第一位");
				} else if ("2".equals(infoItem.getTopPosition())) {
					infoItem.setTopPosition("第二位");
				} else if ("3".equals(infoItem.getTopPosition())) {
					infoItem.setTopPosition("第三位");
				}
			}
		});
		return infoPage;
	}

	@Transactional(readOnly = false)
	public void save(Info info, HttpServletRequest request) {
		//替换中文逗号
		String label = StringUtils.replace(info.getLabel(), "，", ",");
		info.setLabel(label);
		String[] split = StringUtils.split(label, ",");
		for (String lab : split) {
			InfoLabel label2 = new InfoLabel(null, lab);
			List<InfoLabel> list = infoLabelDao.findByLabel(label2);
			if (CollectionUtils.isEmpty(list)) {
				label2.preInsert();
				infoLabelDao.insert(label2);
			}
		}
		String photoServer = Global.getConfig("photoServer");//获取文件服务器地址

		/**
		 * 富文本内容处理+内置图片上传
		 */

		String infoContent = Encodes.unescapeHtml(info.getInfoContent());
		infoContent = StringUtils.replace(infoContent, "<body", "<div");
		infoContent = StringUtils.replace(infoContent, "</body>", "</div>");
		//infoContent=Encodes.urlDecode(infoContent);
		Document doc = Jsoup.parse(infoContent);
		Elements links = doc.getElementsByTag("img");
		for (Element link : links) {
			String linkSrc = link.attr("src");
			String linkSrcOld = link.attr("src");
			if (StringUtils.isNotBlank(linkSrc) && !linkSrc.contains("http:") && !linkSrc.contains("https:") && !linkSrc.contains("uploadFile/ueditor")) {//不包含http开头的
//				  String realPath = Encodes.urlDecode(request.getSession().getServletContext().getRealPath(linkSrc));
				linkSrc = Encodes.urlDecode(linkSrc);
				String realPath = UploadImageUtils.getAbsolutePath(linkSrc);
				int pointerIndex = realPath.lastIndexOf(".");
				ImageUploadInfo saveImageSerivce = new ImageUploadInfo();
				try {
					saveImageSerivce = ImagePathUtils.saveImageSerivce(realPath, pointerIndex, realPath);
					String src = photoServer + saveImageSerivce.getSource();
					infoContent = StringUtils.replace(infoContent, linkSrcOld, src);
				} catch (Exception e) {
					logger.error("图片上传错误:" + e.toString(), e);
				}

			}
		}
		info.setInfoContent(infoContent);

		//引导图
		String images = info.getGuidanceImage();
		if (StringUtils.isNotBlank(images) && !images.contains("http:") && !images.contains("https:")) {
			images = Encodes.urlDecode(images);
			String realPath = UploadImageUtils.getAbsolutePath(images);
			int pointerIndex = realPath.lastIndexOf(".");
			ImageUploadInfo saveImageSerivce = new ImageUploadInfo();
			try {
				saveImageSerivce = ImagePathUtils.saveImageSerivce(realPath, pointerIndex, realPath);
				info.setGuidanceImage(photoServer + saveImageSerivce.getSource());
			} catch (Exception e) {
				logger.error("图片上传错误:" + e.toString(), e);
			}
		}
		//商城首页图
		String homePageImage = info.getHomePageImage();
		if (StringUtils.isNotBlank(homePageImage) && !homePageImage.contains("http:") && !homePageImage.contains("https:")) {
			homePageImage = Encodes.urlDecode(homePageImage);
			String realPath = UploadImageUtils.getAbsolutePath(homePageImage);
			int pointerIndex = realPath.lastIndexOf(".");
			ImageUploadInfo saveImageSerivce = new ImageUploadInfo();
			try {
				saveImageSerivce = ImagePathUtils.saveImageSerivce(realPath, pointerIndex, realPath);
				info.setHomePageImage(photoServer + saveImageSerivce.getSource());
			} catch (Exception e) {
				logger.error("图片上传错误:" + e.toString(), e);
			}
		}
		boolean flg = false;
		if (StringUtils.isBlank(info.getId())) {
			flg = true;
		}

		// 管理员审核文章
		if (null != info.getAuditFlag() && 1 == info.getAuditFlag()) {
			info.setOnlineStatus(3);
			if(null != info.getAuditStatus() && 2 == info.getAuditStatus()){
				// 审核通过
				info.setPubdate(new Date());
				info.setOnlineStatus(2);
			}
		}
		super.save(info);

		if (flg) {
			infoDao.insertInfoPraise(info.getId());
		}

		//分段保存信息内容
		String page = "<div style=\"page-break-after: always;\">\r\n\t<span style=\"display: none;\"> </span></div>";//分页标记
		String[] sp = StringUtils.splitByWholeSeparator(infoContent, page);
		infoDao.deleteInfoPageByInfoId(info.getId());
		infoDao.insertInfoPage(info.getId(), sp);
	}

	@Transactional(readOnly = false)
	public void delete(Info info) {
		super.delete(info);
		infoDao.deleteInfoPraise(info.getId());//删除点赞
		infoDao.deleteInfoPageByInfoId(info.getId());//删除信息分页
	}

	@Transactional(readOnly = false)
	public void updateEnabledStatusByIds(String enabledStatus, String[] ids) {
		infoDao.updateEnabledStatusByIds(enabledStatus, ids);
	}

	@Transactional(readOnly = false)
	public void updateRecommendStatusByIds(String recommendStatus, String[] ids) {
		infoDao.updateRecommendStatusByIds(recommendStatus, ids);
	}

	@Transactional(readOnly = false)
	public void deleteByTypeId(String typeId) {
		infoDao.deleteByTypeId(typeId);
	}

	/**
	 * 替换标签
	 *
	 * @param label   原标签值
	 * @param reLabel 要替换的标签值
	 * @author LG
	 * @date 2016年8月15日
	 * @version 1.0
	 */
	@Transactional(readOnly = false)
	public void updateReplaceByLabel(String label, String reLabel) {
		infoDao.updateReplaceByLabel(label, reLabel);
	}


	@Transactional(readOnly = false)
	public void update(Info info){
		infoDao.update(info);
	}

	/**
	 * 置顶文章列表
	 * @return
	 */
	public List<Info> findTopList() {
		Info info = new Info();
		info.setTopFlag("1");
		return infoDao.findList(info);
	}

    /**
     * 清除置顶，将后面置顶位的数据往前移
     * @param oldInfo
     */
    @Transactional(readOnly = false)
    public void moveTopList(Info oldInfo) {
        Integer oldPosition = Integer.parseInt(oldInfo.getTopPosition());
        List<Info> topInfoList = findTopList();
        topInfoList.forEach(topInfo->{
            Integer topPosition = Integer.parseInt(topInfo.getTopPosition());
            if (Integer.parseInt(topInfo.getTopPosition())>oldPosition) {
                topInfo.setTopPosition((--topPosition).toString());
                update(topInfo);
            }
        });
    }

	@Transactional(readOnly = false)
	public void auditInfo(Info info) {
		Date pubdate = null;
		if (info.getAuditStatus() == 2) {
			pubdate = new Date();
		}
		infoDao.auditInfo(info.getId(), info.getAuditStatus(), info.getFailReason(), pubdate);
    }

	@Transactional(readOnly = false)
    public void offlineInfo(Integer id) {
        infoDao.offlineInfo(id);
    }
}