caimei365-manager/src/main/java/com/caimei/modules/info/web/InfoController.java

package com.caimei.modules.info.web;

import java.util.*;

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

import com.caimei.modules.info.dao.InfoDao;
import com.caimei.modules.info.entity.CmInfoDocSyn;
import com.caimei.modules.info.service.CmInfoDocSynService;
import com.caimei.modules.opensearch.GenerateUtils;
import com.caimei.modules.opensearch.CoreServiceUitls;
import com.caimei.redis.RedisService;
import org.apache.commons.collections.CollectionUtils;
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;

import com.caimei.modules.info.entity.Info;
import com.caimei.modules.info.entity.InfoType;
import com.caimei.modules.info.service.InfoService;
import com.caimei.modules.info.service.InfoTypeService;
import com.google.common.collect.Maps;
import com.thinkgem.jeesite.common.config.Global;
import com.thinkgem.jeesite.common.persistence.Page;
import com.thinkgem.jeesite.common.utils.StringUtils;
import com.thinkgem.jeesite.common.web.BaseController;

/**
 * 信息列表Controller
 * @author LG
 * @version 2016-06-27
 */
@Controller
@RequestMapping(value = "${adminPath}/info/info")
public class InfoController extends BaseController {

	@Autowired
	private InfoService infoService;

	@Autowired
	private InfoTypeService infoTypeService;

	@Autowired
	CmInfoDocSynService cmInfoDocSynService;
    @Autowired
    private CoreServiceUitls coreServiceUitls;
    @Autowired
	private RedisService redisService;
    @Resource
    private GenerateUtils generateUtils;
	@Autowired
	private InfoDao infoDao;
	@ModelAttribute
	public Info get(@RequestParam(required=false) String id) {
		Info entity = null;
		if (StringUtils.isNotBlank(id)){
			entity = infoService.get(id);
		}
		if (entity == null){
			entity = new Info();
		}
		return entity;
	}

	@RequiresPermissions("info:info:view")
	@RequestMapping(value = {"list", ""})
	public String list(Info info, HttpServletRequest request, HttpServletResponse response, Model model) {
		if (null != info.getStartPubDate() && !"".equals(info.getStartPubDate()) && !info.getStartPubDate().endsWith("00:00:00")) {
			model.addAttribute("startConfirmTime", info.getStartPubDate());
			info.setStartPubDate(info.getStartPubDate().trim() + " 00:00:00");
		}
		if (null != info.getEndPubDate() && !"".equals(info.getEndPubDate()) && !info.getEndPubDate().endsWith("23:59:59")) {
			model.addAttribute("endConfirmTime", info.getEndPubDate());
			info.setEndPubDate(info.getEndPubDate().trim() + " 23:59:59");
		}
		Page<Info> page = infoService.findPage(new Page<Info>(request, response), info);
		List<Info> list = page.getList();
		if(CollectionUtils.isNotEmpty(list)){
			String admin2Server = Global.getConfig("admin2Server");//获取admin2文件服务器地址
			for (Info info2 : list) {
				String image = info2.getGuidanceImage();
				 if(StringUtils.isNotBlank(image) && !image.contains("http:") && !image.contains("https:")){//不以http开头的
					 info2.setGuidanceImage(admin2Server+"/uploadFile/infoImage/"+image);
				 }
			}
		}
		InfoType infoType = new InfoType();
		infoType.setEnabledStatus("1");
		List<InfoType> typeList = infoTypeService.findList(infoType);
		List<Info> topList = infoService.findTopList();
		model.addAttribute("topLength", topList.size());
		model.addAttribute("typeList", typeList);
		model.addAttribute("page", page);
		if (null != info.getPublishSource() && 2 == info.getPublishSource()) {
			return "modules/info/shopInfoList";
		} else {
			return "modules/info/infoList";
		}
	}

	@RequiresPermissions("info:info:view")
	@RequestMapping(value = "list1")
	public String list1(Info info, HttpServletRequest request, HttpServletResponse response, Model model) {
		info.setEnabledStatus("1");
		Page<Info> page = infoService.findPage(new Page<Info>(request, response), info);
		/*List<Info> list = page.getList();
		if(CollectionUtils.isNotEmpty(list)){
			String admin2Server = Global.getConfig("admin2Server");//获取admin2文件服务器地址
			for (Info info2 : list) {
				String image = info2.getGuidanceImage();
				 if(StringUtils.isNotBlank(image) && !image.contains("http:") && !image.contains("https:")){//不以http开头的
					 info2.setGuidanceImage(admin2Server+"/uploadFile/infoImage/"+image);
				 }
			}
		}
		List<InfoType> typeList = infoTypeService.findList(new InfoType());
		model.addAttribute("typeList", typeList);*/
		model.addAttribute("page", page);
		return "modules/info/infoList1";
	}

	@RequiresPermissions("info:info:view")
	@RequestMapping(value = "form")
	public String form(Info info,String ltype,Model model) {
		if(StringUtils.isBlank(info.getId())){
			info.setRecommendStatus("0");
			info.setEnabledStatus("1");
			info.setPubdate(new Date());
		}
		InfoType infoType = new InfoType();
		List<InfoType> typeList = infoTypeService.findList(infoType);
		// 敏感词
		String sensitiveWords = infoDao.getSensitiveWords(3);
		model.addAttribute("typeList", typeList);
		model.addAttribute("info", info);
		model.addAttribute("ltype", ltype);
		model.addAttribute("sensitiveWords", sensitiveWords);
		return "modules/info/infoForm";
	}

	@RequiresPermissions("info:info:edit")
	@RequestMapping(value = "save")
	public String save(Info info, Model model,String ltype, RedirectAttributes redirectAttributes, HttpServletRequest request) {
		if (!beanValidator(model,info)){
			return form(info,ltype, model);
		}
		String content = info.getInfoContent();
		int stringLengthByUtf8 = com.caimei.utils.StringUtils.getStringLengthByUtf8(content);
		logger.info("信息内容字数"+stringLengthByUtf8);
		logger.info("原始传入信息："+content);
			//富文本数量超过text保存最大数
			if (stringLengthByUtf8 > 300000) {
				List<String> list = new ArrayList<String>();
				list.add(0, "信息内容编辑框输入字数超过30万,当前字数："+stringLengthByUtf8);
				addMessage(model, list.toArray(new String[]{}));
				return form(info,ltype, model);
			}
		//新增时才设置随机值
		if (null==info.getId() || "".equals(info.getId())){
			if (0==info.getBasePv() || "0".equals(info.getBasePv().toString())){
				Random random = new Random();
				info.setBasePv((long)(random.nextInt(191)+10));
			}
		}
		boolean flag = false;
		if (StringUtils.isBlank(info.getId())) {
			flag = true;
		}
		// 保存成功返回info.id
		infoService.save(info,request);
		addMessage(redirectAttributes, "保存信息成功");
		// 更新索引
		coreServiceUitls.updateArticleIndex(Integer.valueOf(info.getId()));
		if (flag) {
			// 新增文章 百度链接实时推送
			generateUtils.pushBaiduLink("https://www.caimei365.com/info/detail-"+info.getId()+"-1.html");
		}
		if(StringUtils.equals("1", ltype)) {
			return "redirect:"+Global.getAdminPath()+"/info/infoLabel/list";
		}
		info.setPublishSource(null == info.getPublishSource() ? 1 : info.getPublishSource());
		return "redirect:" + Global.getAdminPath() + "/info/info/list?repage&publishSource=" + info.getPublishSource();
	}

	@RequiresPermissions("info:info:delete")
	@RequestMapping(value = "delete")
	public String delete(Info info, RedirectAttributes redirectAttributes) {
		infoService.delete(info);
		if (info.getTopPosition() != null && !StringUtils.equals("", info.getTopPosition())) {
			//清除置顶，将后面置顶位的数据往前移
			infoService.moveTopList(info);
			// 重新生成静态首页
			generateUtils.generateHome();
		}
		addMessage(redirectAttributes, "删除信息成功");
		// 删除索引
		coreServiceUitls.deleteArticleIndex(Integer.valueOf(info.getId()));
		return "redirect:"+Global.getAdminPath()+"/info/info/?repage&publishSource=1";
	}

	/**
	 * 批量修改启用、停用状态
	 * @param ids
	 * @param request
	 * @param response
	 * @return
	 */
	@RequiresPermissions("info:info:edit")
	@ResponseBody
	@RequestMapping(value="updateStatus")
	public Map<String, Object> updateStatus(String status,String[] ids,String type,HttpServletRequest request,HttpServletResponse response){
		Map<String, Object> map =Maps.newLinkedHashMap();
		try {
			if(StringUtils.equals("enabledStatus", type)){
				infoService.updateEnabledStatusByIds(status,ids);
			}else if (StringUtils.equals("recommendStatus", type)){
				infoService.updateRecommendStatusByIds(status,ids);
			}
			map.put("success",true);
			map.put("msg", "修改成功");
			for (String id : ids){
				// 更新索引
				coreServiceUitls.updateArticleIndex(Integer.valueOf(id));
				Info info = infoService.get(id);
				Boolean topFlag = (info.getTopPosition() != null && !StringUtils.equals("", info.getTopPosition())) ? true : false;
            	if (topFlag) {
					// 重新生成静态首页
					generateUtils.generateHome();
				}
			}
		} catch (Exception e) {
			logger.debug(e.toString(),e);
			map.put("success",false);
			map.put("msg", "修改失败");
		}
        return map;
	}

	@RequestMapping(value = "updateTopPosition")
	@ResponseBody
	public Map<String, Object> updateTopPosition(Integer topPosition,String id,String type){
		Map<String, Object> map = Maps.newLinkedHashMap();
		try {
			Info info = infoService.get(id);
            Boolean topFlag = (info.getTopPosition() != null && !StringUtils.equals("", info.getTopPosition())) ? true : false;
            String oldTopPosition = info.getTopPosition();
			if (StringUtils.equals("setTopPosition", type)) {
				//更新被替换掉置顶的文章
				Info oldInfo = new Info();
				oldInfo.setTopPosition(topPosition.toString());
				List<Info> replacedInfoList = infoService.findList(oldInfo);
				replacedInfoList.forEach(replacedInfo->{
					replacedInfo.setTopPosition(null);
					infoService.update(replacedInfo);
				});
				//新的置顶直播
				info.setTopPosition(topPosition.toString());
				map.put("msg", "置顶成功");
			} else if (StringUtils.equals("clearTopPosition", type)) {
				//清除置顶，将后面置顶位的数据往前移
				infoService.moveTopList(info);
				//清除置顶位
				info.setTopPosition(null);
				map.put("msg", "清除成功");
			}
			infoService.update(info);
            //如果新直播原本也是置顶直播，需要把新直播后面的直播往前挪(新直播更新后再一起挪)
            if (StringUtils.equals("setTopPosition", type) && topFlag) {
                Info oldInfo = new Info();
                oldInfo.setTopPosition(oldTopPosition);
                infoService.moveTopList(oldInfo);
            }
			// 重新生成静态首页
			generateUtils.generateHome();
			map.put("success",true);
		} catch (Exception e) {
			logger.debug(e.toString(),e);
			map.put("success",false);
			map.put("msg", "修改失败");
		}
		return map;
	}

	@RequestMapping(value = { "infoList_multiselect" })
	public String infoPageMulti(Info info,HttpServletRequest request, HttpServletResponse response, Model model) {
		info.setEnabledStatus("1");
		Page<Info> page = infoService.findPage(new Page<Info>(request, response), info);
		model.addAttribute("page", page);
		return "modules/info/infoList_multiselect";
	}

    @RequestMapping(value = "check")
    public String checkInfo(Info info,Model model) {
        model.addAttribute("info", info);
        return "modules/info/checkInfoPage";
    }

    @RequestMapping(value = "toAuditPage")
    public String toAuditPage(Info info,Model model) {
		if(StringUtils.isBlank(info.getId())){
			info.setRecommendStatus("0");
			info.setEnabledStatus("1");
			info.setPubdate(new Date());
		}
		InfoType infoType = new InfoType();
		List<InfoType> typeList = infoTypeService.findList(infoType);
		model.addAttribute("typeList", typeList);
		model.addAttribute("info", info);
		// 敏感词
		String sensitiveWords = infoDao.getSensitiveWords(3);
		model.addAttribute("sensitiveWords", sensitiveWords);
		return "modules/info/auditInfoPage";
    }

    @RequestMapping(value = "auditInfo")
	@ResponseBody
    public Boolean auditInfo(Info info) {
		infoService.auditInfo(info);
        return true;
    }

    @RequestMapping(value = "offline")
	@ResponseBody
    public Boolean offline(Integer id) {
		infoService.offlineInfo(id);
        return true;
    }

}