修改的类如下～～for 311版 package com.jeecms.common.web.freemarker; <br/> <br/>import static org.springframework.web.servlet.view.AbstractTemplateView.SPRING_MACRO_REQUEST_CONTEXT_ATTRIBUTE; <br/> <br/>import java.util.Date; <br/>import java.util.HashMap; <br/>import java.util.Map; <br/>import java.util.Set; <br/> <br/>import org.apache.commons.lang.StringUtils; <br/>import org.springframework.web.servlet.support.RequestContext; <br/> <br/>import com.jeecms.common.web.springmvc.DateTypeEditor; <br/> <br/>import freemarker.core.Environment; <br/>import freemarker.template.AdapterTemplateModel; <br/>import freemarker.template.TemplateBooleanModel; <br/>import freemarker.template.TemplateDateModel; <br/>import freemarker.template.TemplateException; <br/>import freemarker.template.TemplateModel; <br/>import freemarker.template.TemplateModelException; <br/>import freemarker.template.TemplateNumberModel; <br/>import freemarker.template.TemplateScalarModel; <br/> <br/>/** <br/> * Freemarker标签工具类 <br/> *  <br/> * @author liufang <br/> *  <br/> */ <br/>public abstract class DirectiveUtils { <br/> /** <br/>  * 输出参数：对象数据 <br/>  */ <br/> public static final String OUT_BEAN = "tag_bean"; <br/> /** <br/>  * 输出参数：列表数据 <br/>  */ <br/> public static final String OUT_LIST = "tag_list"; <br/> /** <br/>  * 输出参数：分页数据 <br/>  */ <br/> public static final String OUT_PAGINATION = "tag_pagination"; <br/> /** <br/>  * 参数：是否调用模板。 <br/>  */ <br/> public static final String PARAM_TPL = "tpl"; <br/> /** <br/>  * 参数：次级模板名称 <br/>  */ <br/> public static final String PARAM_TPL_SUB = "tplSub"; <br/> <br/> /** <br/>  * 将params的值复制到variable中 <br/>  *  <br/>  * @param env <br/>  * @param params <br/>  * @return 原Variable中的值 <br/>  * @throws TemplateException <br/>  */ <br/> public static Map<String, TemplateModel> addParamsToVariable( <br/> Environment env, Map<String, TemplateModel> params) <br/> throws TemplateException { <br/> Map<String, TemplateModel> origMap = new HashMap<String, TemplateModel>(); <br/> if (params.size() <= 0) { <br/> return origMap; <br/> } <br/> Set<Map.Entry<String, TemplateModel>> entrySet = params.entrySet(); <br/> String key; <br/> TemplateModel value; <br/> for (Map.Entry<String, TemplateModel> entry : entrySet) { <br/> key = entry.getKey(); <br/> value = env.getVariable(key); <br/> if (value != null) { <br/> origMap.put(key, value); <br/> } <br/> env.setVariable(key, entry.getValue()); <br/> } <br/> <br/> System.out.println("origMa=="+origMap); <br/> <br/> return origMap; <br/> } <br/> <br/> /** <br/>  * 将variable中的params值移除 <br/>  *  <br/>  * @param env <br/>  * @param params <br/>  * @param origMap <br/>  * @throws TemplateException <br/>  */ <br/> public static void removeParamsFromVariable(Environment env, <br/> Map<String, TemplateModel> params, <br/> Map<String, TemplateModel> origMap) throws TemplateException { <br/> if (params.size() <= 0) { <br/> return; <br/> } <br/> for (String key : params.keySet()) { <br/> env.setVariable(key, origMap.get(key)); <br/> } <br/> } <br/> <br/> /** <br/>  * 获得RequestContext <br/>  *  <br/>  * ViewResolver中的exposeSpringMacroHelpers必须为true <br/>  *  <br/>  * @param env <br/>  * @return <br/>  * @throws TemplateException <br/>  */ <br/> public static RequestContext getContext(Environment env) <br/> throws TemplateException { <br/> TemplateModel ctx = env <br/> .getGlobalVariable(SPRING_MACRO_REQUEST_CONTEXT_ATTRIBUTE); <br/> if (ctx instanceof AdapterTemplateModel) { <br/> return (RequestContext) ((AdapterTemplateModel) ctx) <br/> .getAdaptedObject(RequestContext.class); <br/> } else { <br/> throw new TemplateModelException("RequestContext '" <br/> + SPRING_MACRO_REQUEST_CONTEXT_ATTRIBUTE <br/> + "' not found in DataModel."); <br/> } <br/> } <br/> <br/> public static String getString(String name, <br/> Map<String, TemplateModel> params) throws TemplateException { <br/> TemplateModel model = params.get(name); <br/> if (model == null) { <br/> return null; <br/> } <br/> if (model instanceof TemplateScalarModel) { <br/> return ((TemplateScalarModel) model).getAsString(); <br/> } else if ((model instanceof TemplateNumberModel)) { <br/> return ((TemplateNumberModel) model).getAsNumber().toString(); <br/> } else { <br/> throw new MustStringException(name); <br/> } <br/> } <br/> <br/> public static Long getLong(String name, Map<String, TemplateModel> params) <br/> throws TemplateException { <br/> TemplateModel model = params.get(name); <br/> if (model == null) { <br/> return null; <br/> } <br/> if (model instanceof TemplateScalarModel) { <br/> String s = ((TemplateScalarModel) model).getAsString(); <br/> if (StringUtils.isBlank(s)) { <br/> return null; <br/> } <br/> try { <br/> return Long.parseLong(s); <br/> } catch (NumberFormatException e) { <br/> throw new MustNumberException(name); <br/> } <br/> } else if (model instanceof TemplateNumberModel) { <br/> return ((TemplateNumberModel) model).getAsNumber().longValue(); <br/> } else { <br/> throw new MustNumberException(name); <br/> } <br/> } <br/> <br/> public static Integer getInt(String name, Map<String, TemplateModel> params) <br/> throws TemplateException { <br/> TemplateModel model = params.get(name); <br/> if (model == null) { <br/> return null; <br/> } <br/> if (model instanceof TemplateScalarModel) { <br/> String s = ((TemplateScalarModel) model).getAsString(); <br/> if (StringUtils.isBlank(s)) { <br/> return null; <br/> } <br/> try { <br/> return Integer.parseInt(s); <br/> } catch (NumberFormatException e) { <br/> throw new MustNumberException(name); <br/> } <br/> } else if (model instanceof TemplateNumberModel) { <br/> return ((TemplateNumberModel) model).getAsNumber().intValue(); <br/> } else { <br/> throw new MustNumberException(name); <br/> } <br/> } <br/> <br/> public static Integer[] getIntArray(String name, <br/> Map<String, TemplateModel> params) throws TemplateException { <br/> String str = DirectiveUtils.getString(name, params); <br/> if (StringUtils.isBlank(str)) { <br/> return null; <br/> } <br/> String[] arr = StringUtils.split(str, ','); <br/> Integer[] ids = new Integer[arr.length]; <br/> int i = 0; <br/> try { <br/> for (String s : arr) { <br/> ids[i++] = Integer.valueOf(s); <br/> } <br/> return ids; <br/> } catch (NumberFormatException e) { <br/> throw new MustSplitNumberException(name, e); <br/> } <br/> } <br/> <br/> public static Boolean getBool(String name, Map<String, TemplateModel> params) <br/> throws TemplateException { <br/> TemplateModel model = params.get(name); <br/> if (model == null) { <br/> return null; <br/> } <br/> if (model instanceof TemplateBooleanModel) { <br/> return ((TemplateBooleanModel) model).getAsBoolean(); <br/> } else if (model instanceof TemplateNumberModel) { <br/> return !(((TemplateNumberModel) model).getAsNumber().intValue() == 0); <br/> } else if (model instanceof TemplateScalarModel) { <br/> String s = ((TemplateScalarModel) model).getAsString(); <br/> // 空串应该返回null还是true呢？ <br/> if (!StringUtils.isBlank(s)) { <br/> return !(s.equals("0") || s.equalsIgnoreCase("false") || s <br/> .equalsIgnoreCase("f")); <br/> } else { <br/> return null; <br/> } <br/> } else { <br/> throw new MustBooleanException(name); <br/> } <br/> } <br/> <br/> public static Date getDate(String name, Map<String, TemplateModel> params) <br/> throws TemplateException { <br/> TemplateModel model = params.get(name); <br/> if (model == null) { <br/> return null; <br/> } <br/> if (model instanceof TemplateDateModel) { <br/> return ((TemplateDateModel) model).getAsDate(); <br/> } else if (model instanceof TemplateScalarModel) { <br/> DateTypeEditor editor = new DateTypeEditor(); <br/> editor.setAsText(((TemplateScalarModel) model).getAsString()); <br/> return (Date) editor.getValue(); <br/> } else { <br/> throw new MustDateException(name); <br/> } <br/> } <br/> <br/> /** <br/>  * 模板调用类型 <br/>  *  <br/>  * @author liufang <br/>  */ <br/> public enum InvokeType { <br/> body, custom, sysDefined, userDefined <br/> }; <br/> <br/> /** <br/>  * 是否调用模板 <br/>  *  <br/>  * 0：不调用，使用标签的body；1：调用自定义模板；2：调用系统预定义模板；3：调用用户预定义模板。默认：0。 <br/>  *  <br/>  * @param params <br/>  * @return <br/>  * @throws TemplateException <br/>  */ <br/> public static InvokeType getInvokeType(Map<String, TemplateModel> params) <br/> throws TemplateException { <br/> String tpl = getString(PARAM_TPL, params); <br/> if ("3".equals(tpl)) { <br/> return InvokeType.userDefined; <br/> } else if ("2".equals(tpl)) { <br/> return InvokeType.sysDefined; <br/> } else if ("1".equals(tpl)) { <br/> return InvokeType.custom; <br/> } else { <br/> return InvokeType.body; <br/> } <br/> } <br/>} <br/> package com.jeecms.cms.action.front; <br/> <br/>import javax.servlet.http.HttpServletRequest; <br/>import javax.servlet.http.HttpServletResponse; <br/> <br/>import org.json.JSONArray; <br/>import org.json.JSONException; <br/>import org.slf4j.Logger; <br/>import org.slf4j.LoggerFactory; <br/>import org.springframework.beans.factory.annotation.Autowired; <br/>import org.springframework.stereotype.Controller; <br/>import org.springframework.web.bind.annotation.RequestMapping; <br/>import org.springframework.web.bind.annotation.RequestMethod; <br/> <br/>import com.jeecms.cms.manager.main.ContentCountMng; <br/>import com.jeecms.cms.service.ContentCountCache; <br/>import com.jeecms.common.web.ResponseUtils; <br/> <br/>@Controller <br/>public class ContentCountAct { <br/> private static final Logger log = LoggerFactory <br/> .getLogger(ContentCountAct.class); <br/> <br/> @RequestMapping(value = "/content_view.jspx", method = RequestMethod.GET) <br/> public void contentView(Integer contentId, HttpServletRequest request, <br/> HttpServletResponse response) throws JSONException { <br/> <br/> <br/> <br/> <br/> if (contentId == null) { <br/> ResponseUtils.renderJson(response, "[]"); <br/> return; <br/> } <br/> int[] counts = contentCountCache.viewAndGet(contentId); <br/> String json; <br/> if (counts != null) { <br/> json = new JSONArray(counts).toString(); <br/> ResponseUtils.renderJson(response, json); <br/> <br/> <br/>// System.out.println("ContentCountAct====="+json); <br/> <br/> <br/> } else { <br/> ResponseUtils.renderJson(response, "[]"); <br/> } <br/> <br/> <br/> <br/> <br/> } <br/> <br/> @RequestMapping(value = "/content_up.jspx", method = RequestMethod.GET) <br/> public void contentUp(Integer contentId, HttpServletRequest request, <br/> HttpServletResponse response) throws JSONException { <br/> if (contentId == null) { <br/> ResponseUtils.renderJson(response, "false"); <br/> } else { <br/> contentCountMng.contentUp(contentId); <br/> ResponseUtils.renderJson(response, "true"); <br/> } <br/> } <br/> <br/> @RequestMapping(value = "/content_down.jspx", method = RequestMethod.GET) <br/> public void contentDown(Integer contentId, HttpServletRequest request, <br/> HttpServletResponse response) throws JSONException { <br/> if (contentId == null) { <br/> ResponseUtils.renderJson(response, "false"); <br/> } else { <br/> contentCountMng.contentDown(contentId); <br/> ResponseUtils.renderJson(response, "true"); <br/> } <br/> } <br/> <br/> @Autowired <br/> private ContentCountCache contentCountCache; <br/> @Autowired <br/> private ContentCountMng contentCountMng; <br/>} <br/>package com.jeecms.cms.action.admin.main; <br/> <br/>import static com.jeecms.common.page.SimplePage.cpn; <br/> <br/>import java.io.IOException; <br/>import java.util.ArrayList; <br/>import java.util.List; <br/>import java.util.Locale; <br/>import java.util.Map; <br/>import java.util.Set; <br/> <br/>import javax.servlet.http.HttpServletRequest; <br/>import javax.servlet.http.HttpServletResponse; <br/> <br/>import org.apache.commons.io.FilenameUtils; <br/>import org.apache.commons.lang.StringUtils; <br/>import org.slf4j.Logger; <br/>import org.slf4j.LoggerFactory; <br/>import org.springframework.beans.factory.annotation.Autowired; <br/>import org.springframework.stereotype.Controller; <br/>import org.springframework.ui.ModelMap; <br/>import org.springframework.web.bind.annotation.RequestMapping; <br/>import org.springframework.web.bind.annotation.RequestParam; <br/>import org.springframework.web.multipart.MultipartFile; <br/> <br/>import com.jeecms.cms.entity.main.Channel; <br/>import com.jeecms.cms.entity.main.CmsGroup; <br/>import com.jeecms.cms.entity.main.CmsModel; <br/>import com.jeecms.cms.entity.main.CmsModelItem; <br/>import com.jeecms.cms.entity.main.CmsSite; <br/>import com.jeecms.cms.entity.main.CmsTopic; <br/>import com.jeecms.cms.entity.main.CmsUser; <br/>import com.jeecms.cms.entity.main.Content; <br/>import com.jeecms.cms.entity.main.ContentExt; <br/>import com.jeecms.cms.entity.main.ContentTxt; <br/>import com.jeecms.cms.entity.main.ContentType; <br/>import com.jeecms.cms.entity.main.Content.ContentStatus; <br/>import com.jeecms.cms.manager.main.ChannelMng; <br/>import com.jeecms.cms.manager.main.CmsGroupMng; <br/>import com.jeecms.cms.manager.main.CmsModelItemMng; <br/>import com.jeecms.cms.manager.main.CmsModelMng; <br/>import com.jeecms.cms.manager.main.CmsTopicMng; <br/>import com.jeecms.cms.manager.main.CmsUserMng; <br/>import com.jeecms.cms.manager.main.ContentMng; <br/>import com.jeecms.cms.manager.main.ContentTypeMng; <br/>import com.jeecms.cms.web.CmsUtils; <br/>import com.jeecms.cms.web.WebErrors; <br/>import com.jeecms.common.page.Pagination; <br/>import com.jeecms.common.upload.FileRepository; <br/>import com.jeecms.common.util.StrUtils; <br/>import com.jeecms.common.web.CookieUtils; <br/>import com.jeecms.common.web.RequestUtils; <br/>import com.jeecms.common.web.ResponseUtils; <br/>import com.jeecms.common.web.springmvc.MessageResolver; <br/>import com.jeecms.core.entity.Ftp; <br/>import com.jeecms.core.manager.DbFileMng; <br/>import com.jeecms.core.tpl.TplManager; <br/>import com.jeecms.core.web.CoreUtils; <br/> <br/>@Controller <br/>public class ContentAct { <br/> private static final Logger log = LoggerFactory.getLogger(ContentAct.class); <br/> <br/> @RequestMapping("/content/v_left.do") <br/> public String left() { <br/> return "content/left"; <br/> } <br/> <br/> /** <br/>  * 栏目导航 <br/>  *  <br/>  * @param root <br/>  * @param request <br/>  * @param response <br/>  * @param model <br/>  * @return <br/>  */ <br/> @RequestMapping(value = "/content/v_tree.do") <br/> public String tree(String root, HttpServletRequest request, <br/> HttpServletResponse response, ModelMap model) { <br/> log.debug("tree path={}", root); <br/> boolean isRoot; <br/> // jquery treeview的根请求为root=source <br/> if (StringUtils.isBlank(root) || "source".equals(root)) { <br/> isRoot = true; <br/> } else { <br/> isRoot = false; <br/> } <br/> model.addAttribute("isRoot", isRoot); <br/> WebErrors errors = validateTree(root, request); <br/> if (errors.hasErrors()) { <br/> log.error(errors.getErrors().get(0)); <br/> ResponseUtils.renderJson(response, "[]"); <br/> return null; <br/> } <br/> Integer siteId = CmsUtils.getSiteId(request); <br/> Integer userId = CmsUtils.getUserId(request); <br/> List<Channel> list; <br/> if (isRoot) { <br/> list = channelMng.getTopListByRigth(userId, siteId, true); <br/> } else { <br/> list = channelMng.getChildListByRight(userId, siteId, Integer <br/> .parseInt(root), true); <br/> } <br/> model.addAttribute("list", list); <br/> response.setHeader("Cache-Control", "no-cache"); <br/> response.setContentType("text/json;charset=UTF-8"); <br/> return "content/tree"; <br/> } <br/> <br/> /** <br/>  * 副栏目树 <br/>  *  <br/>  * @param root <br/>  * @param request <br/>  * @param response <br/>  * @param model <br/>  * @return <br/>  */ <br/> @RequestMapping(value = "/content/v_tree_channels.do") <br/> public String treeChannels(String root, HttpServletRequest request, <br/> HttpServletResponse response, ModelMap model) { <br/> tree(root, request, response, model); <br/> return "content/tree_channels"; <br/> } <br/> <br/> @RequestMapping("/content/v_list.do") <br/> public String list(String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Integer cid, Integer pageNo, <br/> HttpServletRequest request, ModelMap model) { <br/> String queryTitle = RequestUtils.getQueryParam(request, "queryTitle"); <br/> queryTitle = StringUtils.trim(queryTitle); <br/> String queryInputUsername = RequestUtils.getQueryParam(request, <br/> "queryInputUsername"); <br/> queryInputUsername = StringUtils.trim(queryInputUsername); <br/> if (queryTopLevel == null) { <br/> queryTopLevel = false; <br/> } <br/> if (queryRecommend == null) { <br/> queryRecommend = false; <br/> } <br/> if (queryOrderBy == null) { <br/> queryOrderBy = 0; <br/> } <br/> ContentStatus status; <br/> if (!StringUtils.isBlank(queryStatus)) { <br/> status = ContentStatus.valueOf(queryStatus); <br/> } else { <br/> status = ContentStatus.all; <br/> } <br/> Integer queryInputUserId = null; <br/> if (!StringUtils.isBlank(queryInputUsername)) { <br/> CmsUser u = cmsUserMng.findByUsername(queryInputUsername); <br/> if (u != null) { <br/> queryInputUserId = u.getId(); <br/> } else { <br/> // 用户名不存在，清空。 <br/> queryInputUsername = null; <br/> } <br/> } <br/> CmsSite site = CmsUtils.getSite(request); <br/> Integer siteId = site.getId(); <br/> CmsUser user = CmsUtils.getUser(request); <br/> Integer userId = user.getId(); <br/> byte currStep = user.getCheckStep(siteId); <br/> Pagination p = manager.getPageByRight(queryTitle, queryTypeId, <br/> queryInputUserId, queryTopLevel, queryRecommend, status, user <br/> .getCheckStep(siteId), siteId, cid, userId, <br/> queryOrderBy, cpn(pageNo), CookieUtils.getPageSize(request)); <br/> List<ContentType> typeList = contentTypeMng.getList(true); <br/> model.addAttribute("pagination", p); <br/> model.addAttribute("cid", cid); <br/> model.addAttribute("typeList", typeList); <br/> model.addAttribute("currStep", currStep); <br/> <br/> addAttibuteForQuery(model, queryTitle, queryInputUsername, queryStatus, <br/> queryTypeId, queryTopLevel, queryRecommend, queryOrderBy, <br/> pageNo); <br/> <br/> return "content/list"; <br/> } <br/> <br/> @RequestMapping("/content/v_add.do") <br/> public String add(Integer cid, HttpServletRequest request, ModelMap model) { <br/> WebErrors errors = validateAdd(cid, request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> CmsSite site = CmsUtils.getSite(request); <br/> Integer siteId = site.getId(); <br/> CmsUser user = CmsUtils.getUser(request); <br/> Integer userId = user.getId(); <br/> // 栏目 <br/> Channel c; <br/> if (cid != null) { <br/> c = channelMng.findById(cid); <br/> } else { <br/> c = null; <br/> } <br/> // 模型 <br/> CmsModel m; <br/> if (c != null) { <br/> m = c.getModel(); <br/> } else { <br/> m = cmsModelMng.getDefModel(); <br/> // TODO m==null给出错误提示 <br/> if (m == null) { <br/> throw new RuntimeException("default model not found!"); <br/> } <br/> } <br/> // 模型项列表 <br/> List<CmsModelItem> itemList = cmsModelItemMng.getList(m.getId(), false, <br/> false); <br/> // 栏目列表 <br/> List<Channel> channelList; <br/> Set<Channel> rights; <br/> if (user.getUserSite(siteId).getAllChannel()) { <br/> // 拥有所有栏目权限 <br/> rights = null; <br/> } else { <br/> rights = user.getChannels(siteId); <br/> } <br/> if (c != null) { <br/> channelList = c.getListForSelect(rights, true); <br/> } else { <br/> List<Channel> topList = channelMng.getTopListByRigth(userId, <br/> siteId, true); <br/> channelList = Channel.getListForSelect(topList, rights, true); <br/> } <br/> <br/> // 专题列表 <br/> List<CmsTopic> topicList; <br/> if (c != null) { <br/> topicList = cmsTopicMng.getListByChannel(c.getId()); <br/> } else { <br/> topicList = new ArrayList<CmsTopic>(); <br/> } <br/> // 内容模板列表 <br/> List<String> tplList = getTplContent(site, m, null); <br/> // 会员组列表 <br/> List<CmsGroup> groupList = cmsGroupMng.getList(); <br/> // 内容类型 <br/> List<ContentType> typeList = contentTypeMng.getList(false); <br/> <br/> model.addAttribute("model", m); <br/> model.addAttribute("itemList", itemList); <br/> model.addAttribute("channelList", channelList); <br/> model.addAttribute("topicList", topicList); <br/> model.addAttribute("tplList", tplList); <br/> model.addAttribute("groupList", groupList); <br/> model.addAttribute("typeList", typeList); <br/> if (cid != null) { <br/> model.addAttribute("cid", cid); <br/> } <br/> if (c != null) { <br/> model.addAttribute("channel", c); <br/> } <br/> return "content/add"; <br/> } <br/> <br/> @RequestMapping("/content/v_view.do") <br/> public String view(String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Integer pageNo, Integer cid, Integer id, <br/> HttpServletRequest request, ModelMap model) { <br/> <br/> <br/> <br/> <br/> WebErrors errors = validateView(id, request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> CmsSite site = CmsUtils.getSite(request); <br/> CmsUser user = CmsUtils.getUser(request); <br/> byte currStep = user.getCheckStep(site.getId()); <br/> Content content = manager.findById(id); <br/> <br/> model.addAttribute("content", content); <br/> model.addAttribute("currStep", currStep); <br/> <br/> <br/>// System.out.println("view==="+content); <br/> <br/> <br/> if (cid != null) { <br/> model.addAttribute("cid", cid); <br/> } <br/> String queryTitle = RequestUtils.getQueryParam(request, "queryTitle"); <br/> String queryInputUsername = RequestUtils.getQueryParam(request, <br/> "queryInputUsername"); <br/> addAttibuteForQuery(model, queryTitle, queryInputUsername, queryStatus, <br/> queryTypeId, queryTopLevel, queryRecommend, queryOrderBy, <br/> pageNo); <br/> return "content/view"; <br/> } <br/> <br/> @RequestMapping("/content/v_edit.do") <br/> public String edit(String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Integer pageNo, Integer cid, Integer id, <br/> HttpServletRequest request, ModelMap model) { <br/> WebErrors errors = validateEdit(id, request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> CmsSite site = CmsUtils.getSite(request); <br/> Integer siteId = site.getId(); <br/> CmsUser user = CmsUtils.getUser(request); <br/> // 内容 <br/> Content content = manager.findById(id); <br/> // 栏目 <br/> Channel channel = content.getChannel(); <br/> // 模型 <br/> CmsModel m = channel.getModel(); <br/> // 模型项列表 <br/> List<CmsModelItem> itemList = cmsModelItemMng.getList(m.getId(), false, <br/> false); <br/> // 栏目列表 <br/> Set<Channel> rights; <br/> if (user.getUserSite(siteId).getAllChannel()) { <br/> // 拥有所有栏目权限 <br/> rights = null; <br/> } else { <br/> rights = user.getChannels(siteId); <br/> } <br/> <br/> List<Channel> topList = channelMng.getTopList(site.getId(), true); <br/> List<Channel> channelList = Channel.getListForSelect(topList, rights, <br/> true); <br/> <br/> // 专题列表 <br/> List<CmsTopic> topicList = cmsTopicMng <br/> .getListByChannel(channel.getId()); <br/> Set<CmsTopic> topics = content.getTopics(); <br/> for (CmsTopic t : topics) { <br/> if (!topicList.contains(t)) { <br/> topicList.add(t); <br/> } <br/> } <br/> Integer[] topicIds = CmsTopic.fetchIds(content.getTopics()); <br/> // 内容模板列表 <br/> List<String> tplList = getTplContent(site, m, content.getTplContent()); <br/> // 会员组列表 <br/> List<CmsGroup> groupList = cmsGroupMng.getList(); <br/> Integer[] groupIds = CmsGroup.fetchIds(content.getViewGroups()); <br/> // 内容类型 <br/> List<ContentType> typeList = contentTypeMng.getList(false); <br/> // 当前模板，去除基本路径 <br/> int tplPathLength = site.getTplPath().length(); <br/> String tplContent = content.getTplContent(); <br/> if (!StringUtils.isBlank(tplContent)) { <br/> tplContent = tplContent.substring(tplPathLength); <br/> } <br/> <br/> model.addAttribute("content", content); <br/> model.addAttribute("channel", channel); <br/> model.addAttribute("model", m); <br/> model.addAttribute("itemList", itemList); <br/> model.addAttribute("channelList", channelList); <br/> model.addAttribute("topicList", topicList); <br/> model.addAttribute("topicIds", topicIds); <br/> model.addAttribute("tplList", tplList); <br/> model.addAttribute("groupList", groupList); <br/> model.addAttribute("groupIds", groupIds); <br/> model.addAttribute("typeList", typeList); <br/> model.addAttribute("tplContent", tplContent); <br/> if (cid != null) { <br/> model.addAttribute("cid", cid); <br/> } <br/> <br/> String queryTitle = RequestUtils.getQueryParam(request, "queryTitle"); <br/> String queryInputUsername = RequestUtils.getQueryParam(request, <br/> "queryInputUsername"); <br/> addAttibuteForQuery(model, queryTitle, queryInputUsername, queryStatus, <br/> queryTypeId, queryTopLevel, queryRecommend, queryOrderBy, <br/> pageNo); <br/> <br/> return "content/edit"; <br/> } <br/> <br/> @RequestMapping("/content/o_save.do") <br/> public String save(Content bean, ContentExt ext, ContentTxt txt, <br/> Integer[] channelIds, Integer[] topicIds, Integer[] viewGroupIds, <br/> String[] attachmentPaths, String[] attachmentNames, <br/> String[] attachmentFilenames, String[] picPaths, String[] picDescs, <br/> Integer channelId, Integer typeId, String tagStr, Boolean draft, <br/> Integer cid, HttpServletRequest request, ModelMap model) { <br/> WebErrors errors = validateSave(bean, channelId, request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> // 加上模板前缀 <br/> CmsSite site = CmsUtils.getSite(request); <br/> CmsUser user = CmsUtils.getUser(request); <br/> String tplPath = site.getTplPath(); <br/> if (!StringUtils.isBlank(ext.getTplContent())) { <br/> ext.setTplContent(tplPath + ext.getTplContent()); <br/> } <br/> bean.setAttr(RequestUtils.getRequestMap(request, "attr_")); <br/> String[] tagArr = StrUtils.splitAndTrim(tagStr, ",", MessageResolver <br/> .getMessage(request, "content.tagStr.split")); <br/> bean = manager.save(bean, ext, txt, channelIds, topicIds, viewGroupIds, <br/> tagArr, attachmentPaths, attachmentNames, attachmentFilenames, <br/> picPaths, picDescs, channelId, typeId, draft, user, false); <br/> log.info("save Content id={}", bean.getId()); <br/> if (cid != null) { <br/> model.addAttribute("cid", cid); <br/> } <br/> model.addAttribute("message", "global.success"); <br/> return add(cid, request, model); <br/> } <br/> <br/> @RequestMapping("/content/o_update.do") <br/> public String update(String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Content bean, ContentExt ext, ContentTxt txt, <br/> Integer[] channelIds, Integer[] topicIds, Integer[] viewGroupIds, <br/> String[] attachmentPaths, String[] attachmentNames, <br/> String[] attachmentFilenames, String[] picPaths, String[] picDescs, <br/> Integer channelId, Integer typeId, String tagStr, Boolean draft, <br/> Integer cid, Integer pageNo, HttpServletRequest request, <br/> ModelMap model) { <br/> WebErrors errors = validateUpdate(bean.getId(), request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> // 加上模板前缀 <br/> CmsSite site = CmsUtils.getSite(request); <br/> CmsUser user = CmsUtils.getUser(request); <br/> String tplPath = site.getTplPath(); <br/> if (!StringUtils.isBlank(ext.getTplContent())) { <br/> ext.setTplContent(tplPath + ext.getTplContent()); <br/> } <br/> String[] tagArr = StrUtils.splitAndTrim(tagStr, ",", MessageResolver <br/> .getMessage(request, "content.tagStr.split")); <br/> Map<String, String> attr = RequestUtils.getRequestMap(request, "attr_"); <br/> bean = manager.update(bean, ext, txt, tagArr, channelIds, topicIds, <br/> viewGroupIds, attachmentPaths, attachmentNames, <br/> attachmentFilenames, picPaths, picDescs, attr, channelId, <br/> typeId, draft, user, false); <br/> log.info("update Content id={}.", bean.getId()); <br/> return list(queryStatus, queryTypeId, queryTopLevel, queryRecommend, <br/> queryOrderBy, cid, pageNo, request, model); <br/> } <br/> <br/> @RequestMapping("/content/o_delete.do") <br/> public String delete(String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Integer[] ids, Integer cid, Integer pageNo, <br/> HttpServletRequest request, ModelMap model) { <br/> CmsSite site = CmsUtils.getSite(request); <br/> WebErrors errors = validateDelete(ids, request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> Content[] beans; <br/> // 是否开启回收站 <br/> if (site.getResycleOn()) { <br/> beans = manager.cycle(ids); <br/> for (Content bean : beans) { <br/> log.info("delete to cycle, Content id={}", bean.getId()); <br/> } <br/> } else { <br/> beans = manager.deleteByIds(ids); <br/> for (Content bean : beans) { <br/> log.info("delete Content id={}", bean.getId()); <br/> } <br/> } <br/> return list(queryStatus, queryTypeId, queryTopLevel, queryRecommend, <br/> queryOrderBy, cid, pageNo, request, model); <br/> } <br/> <br/> @RequestMapping("/content/o_check.do") <br/> public String check(String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Integer[] ids, Integer cid, Integer pageNo, <br/> HttpServletRequest request, ModelMap model) { <br/> WebErrors errors = validateCheck(ids, request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> CmsUser user = CmsUtils.getUser(request); <br/> Content[] beans = manager.check(ids, user); <br/> for (Content bean : beans) { <br/> log.info("check Content id={}", bean.getId()); <br/> } <br/> return list(queryStatus, queryTypeId, queryTopLevel, queryRecommend, <br/> queryOrderBy, cid, pageNo, request, model); <br/> } <br/> <br/> @RequestMapping("/content/o_reject.do") <br/> public String reject(String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Integer[] ids, Integer cid, Byte rejectStep, <br/> String rejectOpinion, Integer pageNo, HttpServletRequest request, <br/> ModelMap model) { <br/> WebErrors errors = validateReject(ids, request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> CmsUser user = CmsUtils.getUser(request); <br/> Content[] beans = manager.reject(ids, user, rejectStep, rejectOpinion); <br/> for (Content bean : beans) { <br/> log.info("reject Content id={}", bean.getId()); <br/> } <br/> return list(queryStatus, queryTypeId, queryTopLevel, queryRecommend, <br/> queryOrderBy, cid, pageNo, request, model); <br/> } <br/> <br/> @RequestMapping("/content/o_upload_attachment.do") <br/> public String uploadAttachment( <br/> @RequestParam(value = "attachmentFile", required = false) MultipartFile file, <br/> String attachmentNum, HttpServletRequest request, ModelMap model) { <br/> WebErrors errors = validateUpload(file, request); <br/> if (errors.hasErrors()) { <br/> model.addAttribute("error", errors.getErrors().get(0)); <br/> return "content/attachment_iframe"; <br/> } <br/> CmsSite site = CmsUtils.getSite(request); <br/> String origName = file.getOriginalFilename(); <br/> String ext = FilenameUtils.getExtension(origName).toLowerCase( <br/> Locale.ENGLISH); <br/> // TODO 检查允许上传的后缀 <br/> try { <br/> String fileUrl; <br/> if (site.getConfig().getUploadToDb()) { <br/> String dbFilePath = site.getConfig().getDbFileUri(); <br/> fileUrl = dbFileMng.storeByExt(site.getUploadPath(), ext, file <br/> .getInputStream()); <br/> // 加上访问地址 <br/> fileUrl = request.getContextPath() + dbFilePath + fileUrl; <br/> } else if (site.getUploadFtp() != null) { <br/> Ftp ftp = site.getUploadFtp(); <br/> String ftpUrl = ftp.getUrl(); <br/> fileUrl = ftp.storeByExt(site.getUploadPath(), ext, file <br/> .getInputStream()); <br/> // 加上url前缀 <br/> fileUrl = ftpUrl + fileUrl; <br/> } else { <br/> String ctx = request.getContextPath(); <br/> fileUrl = fileRepository.storeByExt(site.getUploadPath(), ext, <br/> file); <br/> // 加上部署路径 <br/> fileUrl = ctx + fileUrl; <br/> } <br/> model.addAttribute("attachmentPath", fileUrl); <br/> model.addAttribute("attachmentName", origName); <br/> model.addAttribute("attachmentNum", attachmentNum); <br/> } catch (IllegalStateException e) { <br/> model.addAttribute("error", e.getMessage()); <br/> log.error("upload file error!", e); <br/> } catch (IOException e) { <br/> model.addAttribute("error", e.getMessage()); <br/> log.error("upload file error!", e); <br/> } <br/> return "content/attachment_iframe"; <br/> } <br/> <br/> @RequestMapping("/content/o_upload_media.do") <br/> public String uploadMedia( <br/> @RequestParam(value = "mediaFile", required = false) MultipartFile file, <br/> String filename, HttpServletRequest request, ModelMap model) { <br/> WebErrors errors = validateUpload(file, request); <br/> if (errors.hasErrors()) { <br/> model.addAttribute("error", errors.getErrors().get(0)); <br/> return "content/media_iframe"; <br/> } <br/> CmsSite site = CmsUtils.getSite(request); <br/> String origName = file.getOriginalFilename(); <br/> String ext = FilenameUtils.getExtension(origName).toLowerCase( <br/> Locale.ENGLISH); <br/> // TODO 检查允许上传的后缀 <br/> try { <br/> String fileUrl; <br/> if (site.getConfig().getUploadToDb()) { <br/> String dbFilePath = site.getConfig().getDbFileUri(); <br/> if (!StringUtils.isBlank(filename) <br/> && FilenameUtils.getExtension(filename).equals(ext)) { <br/> filename = filename.substring(dbFilePath.length()); <br/> fileUrl = dbFileMng.storeByFilename(filename, file <br/> .getInputStream()); <br/> } else { <br/> fileUrl = dbFileMng.storeByExt(site.getUploadPath(), ext, <br/> file.getInputStream()); <br/> // 加上访问地址 <br/> fileUrl = request.getContextPath() + dbFilePath + fileUrl; <br/> } <br/> } else if (site.getUploadFtp() != null) { <br/> Ftp ftp = site.getUploadFtp(); <br/> String ftpUrl = ftp.getUrl(); <br/> if (!StringUtils.isBlank(filename) <br/> && FilenameUtils.getExtension(filename).equals(ext)) { <br/> filename = filename.substring(ftpUrl.length()); <br/> fileUrl = ftp.storeByFilename(filename, file <br/> .getInputStream()); <br/> } else { <br/> fileUrl = ftp.storeByExt(site.getUploadPath(), ext, file <br/> .getInputStream()); <br/> // 加上url前缀 <br/> fileUrl = ftpUrl + fileUrl; <br/> } <br/> } else { <br/> String ctx = request.getContextPath(); <br/> if (!StringUtils.isBlank(filename) <br/> && FilenameUtils.getExtension(filename).equals(ext)) { <br/> filename = filename.substring(ctx.length()); <br/> fileUrl = fileRepository.storeByFilename(filename, file); <br/> } else { <br/> fileUrl = fileRepository.storeByExt(site.getUploadPath(), <br/> ext, file); <br/> // 加上部署路径 <br/> fileUrl = ctx + fileUrl; <br/> } <br/> } <br/> model.addAttribute("mediaPath", fileUrl); <br/> model.addAttribute("mediaExt", ext); <br/> } catch (IllegalStateException e) { <br/> model.addAttribute("error", e.getMessage()); <br/> log.error("upload file error!", e); <br/> } catch (IOException e) { <br/> model.addAttribute("error", e.getMessage()); <br/> log.error("upload file error!", e); <br/> } <br/> return "content/media_iframe"; <br/> } <br/> <br/> @RequestMapping("/content_cycle/v_list.do") <br/> public String cycleList(Integer queryTypeId, Boolean queryTopLevel, <br/> Boolean queryRecommend, Integer queryOrderBy, Integer cid, <br/> Integer pageNo, HttpServletRequest request, ModelMap model) { <br/> list(ContentStatus.recycle.toString(), queryTypeId, queryTopLevel, <br/> queryRecommend, queryOrderBy, cid, pageNo, request, model); <br/> return "content/cycle_list"; <br/> } <br/> <br/> @RequestMapping("/content_cycle/o_recycle.do") <br/> public String cycleRecycle(String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Integer[] ids, Integer cid, Integer pageNo, <br/> HttpServletRequest request, ModelMap model) { <br/> WebErrors errors = validateDelete(ids, request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> Content[] beans = manager.recycle(ids); <br/> for (Content bean : beans) { <br/> log.info("delete Content id={}", bean.getId()); <br/> } <br/> return cycleList(queryTypeId, queryTopLevel, queryRecommend, <br/> queryOrderBy, cid, pageNo, request, model); <br/> } <br/> <br/> @RequestMapping("/content_cycle/o_delete.do") <br/> public String cycleDelete(String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Integer[] ids, Integer cid, Integer pageNo, <br/> HttpServletRequest request, ModelMap model) { <br/> WebErrors errors = validateDelete(ids, request); <br/> if (errors.hasErrors()) { <br/> return errors.showErrorPage(model); <br/> } <br/> Content[] beans = manager.deleteByIds(ids); <br/> for (Content bean : beans) { <br/> log.info("delete Content id={}", bean.getId()); <br/> } <br/> return cycleList(queryTypeId, queryTopLevel, queryRecommend, <br/> queryOrderBy, cid, pageNo, request, model); <br/> } <br/> <br/> private void addAttibuteForQuery(ModelMap model, String queryTitle, <br/> String queryInputUsername, String queryStatus, Integer queryTypeId, <br/> Boolean queryTopLevel, Boolean queryRecommend, <br/> Integer queryOrderBy, Integer pageNo) { <br/> if (!StringUtils.isBlank(queryTitle)) { <br/> model.addAttribute("queryTitle", queryTitle); <br/> } <br/> if (!StringUtils.isBlank(queryInputUsername)) { <br/> model.addAttribute("queryInputUsername", queryInputUsername); <br/> } <br/> if (queryTypeId != null) { <br/> model.addAttribute("queryTypeId", queryTypeId); <br/> } <br/> if (queryStatus != null) { <br/> model.addAttribute("queryStatus", queryStatus); <br/> } <br/> if (queryTopLevel != null) { <br/> model.addAttribute("queryTopLevel", queryTopLevel); <br/> } <br/> if (queryRecommend != null) { <br/> model.addAttribute("queryRecommend", queryRecommend); <br/> } <br/> if (queryOrderBy != null) { <br/> model.addAttribute("queryOrderBy", queryOrderBy); <br/> } <br/> if (pageNo != null) { <br/> model.addAttribute("pageNo", pageNo); <br/> } <br/> } <br/> <br/> private List<String> getTplContent(CmsSite site, CmsModel model, String tpl) { <br/> String sol = site.getSolutionPath(); <br/> String tplPath = site.getTplPath(); <br/> List<String> tplList = tplManager.getNameListByPrefix(model <br/> .getTplContent(sol, false)); <br/> tplList = CoreUtils.tplTrim(tplList, tplPath, tpl); <br/> return tplList; <br/> } <br/> <br/> private WebErrors validateTree(String path, HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> // if (errors.ifBlank(path, "path", 255)) { <br/> // return errors; <br/> // } <br/> return errors; <br/> } <br/> <br/> private WebErrors validateAdd(Integer cid, HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> if (cid == null) { <br/> return errors; <br/> } <br/> Channel c = channelMng.findById(cid); <br/> if (errors.ifNotExist(c, Channel.class, cid)) { <br/> return errors; <br/> } <br/> Integer siteId = CmsUtils.getSiteId(request); <br/> if (!c.getSite().getId().equals(siteId)) { <br/> errors.notInSite(Channel.class, cid); <br/> return errors; <br/> } <br/> return errors; <br/> } <br/> <br/> private WebErrors validateSave(Content bean, Integer channelId, <br/> HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> CmsSite site = CmsUtils.getSite(request); <br/> bean.setSite(site); <br/> if (errors.ifNull(channelId, "channelId")) { <br/> return errors; <br/> } <br/> Channel channel = channelMng.findById(channelId); <br/> if (errors.ifNotExist(channel, Channel.class, channelId)) { <br/> return errors; <br/> } <br/> if (channel.getChild().size() > 0) { <br/> errors.addErrorCode("content.error.notLeafChannel"); <br/> } <br/> return errors; <br/> } <br/> <br/> private WebErrors validateView(Integer id, HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> CmsSite site = CmsUtils.getSite(request); <br/> if (vldExist(id, site.getId(), errors)) { <br/> return errors; <br/> } <br/> return errors; <br/> } <br/> <br/> private WebErrors validateEdit(Integer id, HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> CmsSite site = CmsUtils.getSite(request); <br/> if (vldExist(id, site.getId(), errors)) { <br/> return errors; <br/> } <br/> // Content content = manager.findById(id); <br/> // TODO 是否有编辑的数据权限。 <br/> return errors; <br/> } <br/> <br/> private WebErrors validateUpdate(Integer id, HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> CmsSite site = CmsUtils.getSite(request); <br/> if (vldExist(id, site.getId(), errors)) { <br/> return errors; <br/> } <br/> Content content = manager.findById(id); <br/> // TODO 是否有编辑的数据权限。 <br/> // 是否有审核后更新权限。 <br/> if (!content.isHasUpdateRight()) { <br/> errors.addErrorCode("content.error.afterCheckUpdate"); <br/> return errors; <br/> } <br/> return errors; <br/> } <br/> <br/> private WebErrors validateDelete(Integer[] ids, HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> CmsSite site = CmsUtils.getSite(request); <br/> errors.ifEmpty(ids, "ids"); <br/> for (Integer id : ids) { <br/> if (vldExist(id, site.getId(), errors)) { <br/> return errors; <br/> } <br/> Content content = manager.findById(id); <br/> // TODO 是否有编辑的数据权限。 <br/> // 是否有审核后删除权限。 <br/> if (!content.isHasDeleteRight()) { <br/> errors.addErrorCode("content.error.afterCheckDelete"); <br/> return errors; <br/> } <br/> <br/> } <br/> return errors; <br/> } <br/> <br/> private WebErrors validateCheck(Integer[] ids, HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> CmsSite site = CmsUtils.getSite(request); <br/> errors.ifEmpty(ids, "ids"); <br/> for (Integer id : ids) { <br/> vldExist(id, site.getId(), errors); <br/> } <br/> return errors; <br/> } <br/> <br/> private WebErrors validateReject(Integer[] ids, HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> CmsSite site = CmsUtils.getSite(request); <br/> errors.ifEmpty(ids, "ids"); <br/> for (Integer id : ids) { <br/> vldExist(id, site.getId(), errors); <br/> } <br/> return errors; <br/> } <br/> <br/> private WebErrors validateUpload(MultipartFile file, <br/> HttpServletRequest request) { <br/> WebErrors errors = WebErrors.create(request); <br/> if (errors.ifNull(file, "file")) { <br/> return errors; <br/> } <br/> return errors; <br/> } <br/> <br/> private boolean vldExist(Integer id, Integer siteId, WebErrors errors) { <br/> if (errors.ifNull(id, "id")) { <br/> return true; <br/> } <br/> Content entity = manager.findById(id); <br/> if (errors.ifNotExist(entity, Content.class, id)) { <br/> return true; <br/> } <br/> if (!entity.getSite().getId().equals(siteId)) { <br/> errors.notInSite(Content.class, id); <br/> return true; <br/> } <br/> return false; <br/> } <br/> <br/> @Autowired <br/> private ContentMng manager; <br/> @Autowired <br/> private ChannelMng channelMng; <br/> @Autowired <br/> private CmsUserMng cmsUserMng; <br/> @Autowired <br/> private CmsModelMng cmsModelMng; <br/> @Autowired <br/> private CmsModelItemMng cmsModelItemMng; <br/> @Autowired <br/> private CmsTopicMng cmsTopicMng; <br/> @Autowired <br/> private CmsGroupMng cmsGroupMng; <br/> @Autowired <br/> private ContentTypeMng contentTypeMng; <br/> @Autowired <br/> private TplManager tplManager; <br/> @Autowired <br/> private FileRepository fileRepository; <br/> @Autowired <br/> private DbFileMng dbFileMng; <br/> <br/>}

package com.jeecms.cms.action.directive;

import static com.jeecms.common.web.freemarker.DirectiveUtils.OUT_BEAN;
import static freemarker.template.ObjectWrapper.DEFAULT_WRAPPER;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;

import com.jeecms.cms.entity.main.CmsSite;
import com.jeecms.cms.entity.main.Content;
import com.jeecms.cms.manager.main.ContentMng;
import com.jeecms.cms.web.FrontUtils;
import com.jeecms.common.web.freemarker.DirectiveUtils;
import com.jeecms.common.web.freemarker.ParamsRequiredException;

import freemarker.core.Environment;
import freemarker.template.TemplateDirectiveBody;
import freemarker.template.TemplateDirectiveModel;
import freemarker.template.TemplateException;
import freemarker.template.TemplateModel;

/**
 * 内容对象标签
 * 
 * @author liufang
 * 
 */
public class ContentDirective implements TemplateDirectiveModel {
/**
 * 输入参数，栏目ID。
 */
public static final String PARAM_ID = "id";
/**
 * 输入参数，下一篇。
 */
public static final String PRAMA_NEXT = "next";
/**
 * 输入参数，栏目ID。
 */
public static final String PARAM_CHANNEL_ID = "channelId";

@SuppressWarnings("unchecked")
public void execute(Environment env, Map params, TemplateModel[] loopVars,
TemplateDirectiveBody body) throws TemplateException, IOException {



System.out.println("execute===="+params);


Integer id = getId(params);
Boolean next = DirectiveUtils.getBool(PRAMA_NEXT, params);
Content content;
if (next == null) {
content = contentMng.findById(id);
} else {
CmsSite site = FrontUtils.getSite(env);
Integer channelId = DirectiveUtils.getInt(PARAM_CHANNEL_ID, params);
content = contentMng.getSide(id, site.getId(), channelId, next);
}

Map<String, TemplateModel> paramWrap = new HashMap<String, TemplateModel>(
params);
paramWrap.put(OUT_BEAN, DEFAULT_WRAPPER.wrap(content));



Map<String, TemplateModel> origMap = DirectiveUtils
.addParamsToVariable(env, paramWrap);



System.out.println("execute==origMap=="+origMap);
System.out.println("execute==paramWrap=="+paramWrap);

body.render(env.getOut());
DirectiveUtils.removeParamsFromVariable(env, paramWrap, origMap);
}

private Integer getId(Map<String, TemplateModel> params)
throws TemplateException {
Integer id = DirectiveUtils.getInt(PARAM_ID, params);
if (id != null) {
return id;
} else {
throw new ParamsRequiredException(PARAM_ID);
}
}

@Autowired
private ContentMng contentMng;
}

package com.jeecms.common.image;

import java.io.InputStream;
import java.util.Locale;

/**
 * 图片辅助类
 * 
 * @author liufang
 * 
 */
public abstract class ImageUtils {
/**
 * 图片的后缀
 */
public static final String[] IMAGE_EXT = new String[] { "jpg", "jpeg",
"gif", "png", "bmp" };

/**
 * 是否是图片
 * 
 * @param ext
 * @return "jpg", "jpeg", "gif", "png", "bmp" 为文件后缀名者为图片
 */
public static boolean isValidImageExt(String ext) {
ext = ext.toLowerCase(Locale.ENGLISH);
for (String s : IMAGE_EXT) {
if (s.equalsIgnoreCase(ext)) {
return true;
}
}
return false;
}

/**
 * Checks if the underlying input stream contains an image.
 * 
 * @param in
 *            input stream of an image
 * @return <code>true</code> if the underlying input stream contains an
 *         image, else <code>false</code>
 */
public static boolean isImage(final InputStream in) {
ImageInfo ii = new ImageInfo();
ii.setInput(in);
return ii.check();
}

/**
 * 获得水印位置
 * 
 * @param width
 *            原图宽度
 * @param height
 *            原图高度
 * @param p
 *            水印位置 1-5，其他值为随机。1：左上；2：右上；3：左下；4：右下；5：中央。
 * @param offsetx
 *            水平偏移。
 * @param offsety
 *            垂直偏移。
 * @return 水印位置 Rick.........
 */
public static Position markPosition(int width, int height, int p,
int offsetx, int offsety) {

if (p < 1 || p > 5) {
p = (int) (Math.random() * 5) + 1;
}
int x, y;
switch (p) {
// 左上
case 1:
x = 0;
y = 0;
break;
// 右上
case 2:
x = width - offsetx;
y = 0;
break;
// 左下
case 3:
x = 0;
y = height - offsety;
break;
// 右下
case 4:
x = width - offsetx;
y = height - offsety;
break;
// 中央
case 5:
x = ((width - offsetx) / 2);
y = (height / 2);
break;
default:
throw new RuntimeException("never reach ...");
}

System.out.println("Rick.width:" + width);
System.out.println("Rick.height:" + height);


System.out.println("Rick.offsetx:" + offsetx);
System.out.println("Rick.offsety:" + offsety);

System.out.println("Rick.x:" + x);
System.out.println("Rick.y:" + y);

return new Position(x, y);
}

/**
 * 水印位置
 * 
 * 包含左边偏移量，右边偏移量。
 * 
 * @author liufang
 * 
 */
public static class Position {
private int x;

private int y;

public Position(int x, int y) {
this.x = x;
this.y = y;
}

public int getX() {
return x;
}

public void setX(int x) {
this.x = x;
}

public int getY() {
return y;
}

public void setY(int y) {
this.y = y;
}
}

}

package com.jeecms.common.image;

import java.awt.AlphaComposite;
import java.awt.Color;
import java.awt.Font;
import java.awt.Graphics2D;
import java.awt.image.BufferedImage;
import java.io.File;
import java.io.IOException;

import javax.imageio.ImageIO;

import org.apache.commons.io.FileUtils;

import com.jeecms.common.image.ImageUtils.Position;

/**
 * 图片缩小类。使用方型区域颜色平均算法
 * 
 * @author liufang
 * 
 */
public class AverageImageScale {
/**
 * 缩小图片
 * 
 * @param srcFile
 *            原图片
 * @param destFile
 *            目标图片
 * @param boxWidth
 *            缩略图最大宽度
 * @param boxHeight
 *            缩略图最大高度
 * @throws IOException
 */
public static void resizeFix(File srcFile, File destFile, int boxWidth,
int boxHeight) throws IOException {
BufferedImage srcImgBuff = ImageIO.read(srcFile);
int width = srcImgBuff.getWidth();
int height = srcImgBuff.getHeight();
if (width <= boxWidth && height <= boxHeight) {
FileUtils.copyFile(srcFile, destFile);
return;
}
int zoomWidth;
int zoomHeight;
if ((float) width / height > (float) boxWidth / boxHeight) {
zoomWidth = boxWidth;
zoomHeight = Math.round((float) boxWidth * height / width);
} else {
zoomWidth = Math.round((float) boxHeight * width / height);
zoomHeight = boxHeight;
}
BufferedImage imgBuff = scaleImage(srcImgBuff, width, height,
zoomWidth, zoomHeight);
writeFile(imgBuff, destFile);
}

/**
 * 裁剪并压缩
 * 
 * @param srcFile
 *            原文件
 * @param destFile
 *            目标文件
 * @param boxWidth
 *            缩略图最大宽度
 * @param boxHeight
 *            缩略图最大高度
 * @param cutTop
 *            裁剪TOP
 * @param cutLeft
 *            裁剪LEFT
 * @param cutWidth
 *            裁剪宽度
 * @param catHeight
 *            裁剪高度
 * @throws IOException
 */
public static void resizeFix(File srcFile, File destFile, int boxWidth,
int boxHeight, int cutTop, int cutLeft, int cutWidth, int catHeight)
throws IOException {
BufferedImage srcImgBuff = ImageIO.read(srcFile);
srcImgBuff = srcImgBuff.getSubimage(cutTop, cutLeft, cutWidth,
catHeight);
int width = srcImgBuff.getWidth();
int height = srcImgBuff.getHeight();
if (width <= boxWidth && height <= boxHeight) {
writeFile(srcImgBuff, destFile);
return;
}
int zoomWidth;
int zoomHeight;
if ((float) width / height > (float) boxWidth / boxHeight) {
zoomWidth = boxWidth;
zoomHeight = Math.round((float) boxWidth * height / width);
} else {
zoomWidth = Math.round((float) boxHeight * width / height);
zoomHeight = boxHeight;
}
BufferedImage imgBuff = scaleImage(srcImgBuff, width, height,
zoomWidth, zoomHeight);
writeFile(imgBuff, destFile);
}

public static void writeFile(BufferedImage imgBuf, File destFile)
throws IOException {
File parent = destFile.getParentFile();
if (!parent.exists()) {
parent.mkdirs();
}
ImageIO.write(imgBuf, "jpeg", destFile);
}

/**
 * 添加文字水印
 * 
 * @param srcFile
 *            源图片文件。需要加水印的图片文件。
 * @param destFile
 *            目标图片。加水印后保存的文件。如果和源图片文件一致，则覆盖源图片文件。
 * @param minWidth
 *            需要加水印的最小宽度，如果源图片宽度小于该宽度，则不加水印。
 * @param minHeight
 *            需要加水印的最小高度，如果源图片高度小于该高度，则不加水印。
 * @param pos
 *            加水印的位置。
 * @param offsetX
 *            加水印的位置的偏移量x。
 * @param offsetY
 *            加水印的位置的偏移量y。
 * @param text
 *            水印文字
 * @param color
 *            水印颜色
 * @param size
 *            水印字体大小
 * @param alpha
 *            透明度
 * @throws IOException
 */
public static void imageMark(File srcFile, File destFile, int minWidth,
int minHeight, int pos, int offsetX, int offsetY, String text,
Color color, int size, int alpha) throws IOException {

BufferedImage imgBuff = ImageIO.read(srcFile);
int width = imgBuff.getWidth();
int height = imgBuff.getHeight();
if (width <= minWidth || height <= minHeight) {
imgBuff = null;
if (!srcFile.equals(destFile)) {
FileUtils.copyFile(srcFile, destFile);
}
} else {
imageMark(imgBuff, width, height, pos, offsetX, offsetY, text,
color, size, alpha);
writeFile(imgBuff, destFile);
imgBuff = null;
}
}

/**
 * 添加图片水印
 * 
 * @param srcFile
 *            源图片文件。需要加水印的图片文件。
 * @param destFile
 *            目标图片。加水印后保存的文件。如果和源图片文件一致，则覆盖源图片文件。
 * @param minWidth
 *            需要加水印的最小宽度，如果源图片宽度小于该宽度，则不加水印。
 * @param minHeight
 *            需要加水印的最小高度，如果源图片高度小于该高度，则不加水印。
 * @param pos
 *            加水印的位置。
 * @param offsetX
 *            加水印的位置的偏移量x。
 * @param offsetY
 *            加水印的位置的偏移量y。
 * @param markFile
 *            水印图片
 * @throws IOException
 */
public static void imageMark(File srcFile, File destFile, int minWidth,
int minHeight, int pos, int offsetX, int offsetY, File markFile)
throws IOException {

BufferedImage imgBuff = ImageIO.read(srcFile);
int width = imgBuff.getWidth();
int height = imgBuff.getHeight();
if (width <= minWidth || height <= minHeight) {
imgBuff = null;
if (!srcFile.equals(destFile)) {
FileUtils.copyFile(srcFile, destFile);
}
} else {

int[] pic = getPicWH(markFile.getAbsolutePath());

System.out.println("markFile.getAbsolutePath()=="
+ markFile.getAbsolutePath());
System.out.println("width==" + width);
System.out.println("height==" + height);
System.out.println("pos==" + pos);

System.out.println("offsetX==" + offsetX);
System.out.println("offsetY==" + offsetY);



System.out.println("pic[0]==" + pic[0]);
System.out.println("pic[1]==" + pic[1]);

imageMark(imgBuff, width, height, pos,  pic[0],pic[1], markFile);






// imageMark(imgBuff, width, height, pos, offsetX, offsetY, markFile);














writeFile(imgBuff, destFile);
imgBuff = null;
}

}

/**
 * 添加文字水印
 * 
 * @param imgBuff
 *            原图片
 * @param width
 *            原图宽度
 * @param height
 *            原图高度
 * @param pos
 *            位置。1：左上；2：右上；3左下；4右下；5：中央；0或其他：随机。
 * @param offsetX
 *            水平偏移量。
 * @param offsetY
 *            垂直偏移量。
 * @param text
 *            水印内容
 * @param color
 *            水印颜色
 * @param size
 *            文字大小
 * @param alpha
 *            透明度。0-100。越小越透明。
 * @throws IOException
 */
private static void imageMark(BufferedImage imgBuff, int width, int height,
int pos, int offsetX, int offsetY, String text, Color color,
int size, int alpha) throws IOException {

Position p = ImageUtils.markPosition(width, height, pos, offsetX,
offsetY);
Graphics2D g = imgBuff.createGraphics();
g.setColor(color);
g.setFont(new Font(null, Font.PLAIN, size));
AlphaComposite a = AlphaComposite.getInstance(AlphaComposite.SRC_ATOP,
(float) alpha / 100);
g.setComposite(a);
g.drawString(text, p.getX(), p.getY());

g.dispose();
}

private static void imageMark(BufferedImage imgBuff, int width, int height,
int pos, int offsetX, int offsetY, File markFile)
throws IOException {
Position p = ImageUtils.markPosition(width, height, pos, offsetX,
offsetY);
Graphics2D g = imgBuff.createGraphics();
AlphaComposite a = AlphaComposite.getInstance(AlphaComposite.SRC_ATOP);
g.setComposite(a);
g.drawImage(ImageIO.read(markFile), p.getX(), p.getY(), null);
g.dispose();
}

private static BufferedImage scaleImage(BufferedImage srcImgBuff,
int width, int height, int zoomWidth, int zoomHeight) {
int[] colorArray = srcImgBuff.getRGB(0, 0, width, height, null, 0,
width);
BufferedImage outBuff = new BufferedImage(zoomWidth, zoomHeight,
BufferedImage.TYPE_INT_RGB);
// 宽缩小的倍数
float wScale = (float) width / zoomWidth;
int wScaleInt = (int) (wScale + 0.5);
// 高缩小的倍数
float hScale = (float) height / zoomHeight;
int hScaleInt = (int) (hScale + 0.5);
int area = wScaleInt * hScaleInt;
int x0, x1, y0, y1;
int color;
long red, green, blue;
int x, y, i, j;
for (y = 0; y < zoomHeight; y++) {
// 得到原图高的Y坐标
y0 = (int) (y * hScale);
y1 = y0 + hScaleInt;
for (x = 0; x < zoomWidth; x++) {
x0 = (int) (x * wScale);
x1 = x0 + wScaleInt;
red = green = blue = 0;
for (i = x0; i < x1; i++) {
for (j = y0; j < y1; j++) {
color = colorArray[width * j + i];
red += getRedValue(color);
green += getGreenValue(color);
blue += getBlueValue(color);
}
}
outBuff.setRGB(x, y, comRGB((int) (red / area),
(int) (green / area), (int) (blue / area)));
}
}
return outBuff;
}

private static int getRedValue(int rgbValue) {
return (rgbValue & 0x00ff0000) >> 16;
}

private static int getGreenValue(int rgbValue) {
return (rgbValue & 0x0000ff00) >> 8;
}

private static int getBlueValue(int rgbValue) {
return rgbValue & 0x000000ff;
}

private static int comRGB(int redValue, int greenValue, int blueValue) {
return (redValue << 16) + (greenValue << 8) + blueValue;
}

// public static void imageMark(File srcFile, File destFile, int minWidth,
// int minHeight, int pos, int offsetX, int offsetY, File markFile)

public static int[] getPicWH(String path) {

int reValue[] = new int[2];
File picFile = new File(path); // 图片文件路径
BufferedImage image = null;
try {
image = ImageIO.read(picFile);
} catch (IOException e) {
e.printStackTrace();
}
int width = image.getWidth();// 图片宽度
int height = image.getHeight();// 图片高度

reValue[0] = width;
reValue[1] = height;
return reValue;

}

public static void main(String[] args) throws Exception {
long time = System.currentTimeMillis();
File srcFile = new File("c:/a.jpg");

File destFile = new File("c:/aaa.jpg");

File markFile = new File("c:/b.png");

int[] pic = getPicWH("c:/b.png");

AverageImageScale.imageMark(srcFile, destFile, 100, 100, 4, pic[0],
pic[1], markFile);
time = System.currentTimeMillis() - time;
System.out.println("resize2 img in " + time + "ms");
}
}

package com.jeecms.common.image;

import java.io.InputStream;
import java.util.Locale;

/**
 * 图片辅助类
 * 
 * @author liufang
 * 
 */
public abstract class ImageUtils {
/**
 * 图片的后缀
 */
public static final String[] IMAGE_EXT = new String[] { "jpg", "jpeg",
"gif", "png", "bmp" };

/**
 * 是否是图片
 * 
 * @param ext
 * @return "jpg", "jpeg", "gif", "png", "bmp" 为文件后缀名者为图片
 */
public static boolean isValidImageExt(String ext) {
ext = ext.toLowerCase(Locale.ENGLISH);
for (String s : IMAGE_EXT) {
if (s.equalsIgnoreCase(ext)) {
return true;
}
}
return false;
}

/**
 * Checks if the underlying input stream contains an image.
 * 
 * @param in
 *            input stream of an image
 * @return <code>true</code> if the underlying input stream contains an
 *         image, else <code>false</code>
 */
public static boolean isImage(final InputStream in) {
ImageInfo ii = new ImageInfo();
ii.setInput(in);
return ii.check();
}

/**
 * 获得水印位置
 * 
 * @param width
 *            原图宽度
 * @param height
 *            原图高度
 * @param p
 *            水印位置 1-5，其他值为随机。1：左上；2：右上；3：左下；4：右下；5：中央。
 * @param offsetx
 *            水平偏移。
 * @param offsety
 *            垂直偏移。
 * @return 水印位置 Rick.........
 */
public static Position markPosition(int width, int height, int p,
int offsetx, int offsety) {

if (p < 1 || p > 5) {
p = (int) (Math.random() * 5) + 1;
}
int x, y;
switch (p) {
// 左上
case 1:
x = 0;
y = 0;
break;
// 右上
case 2:
x = width - offsetx;
y = 0;
break;
// 左下
case 3:
x = 0;
y = height - offsety;
break;
// 右下
case 4:
x = width - offsetx;
y = height - offsety;
break;
// 中央
case 5:
x = ((width - offsetx) / 2);
y = (height / 2);
break;
default:
throw new RuntimeException("never reach ...");
}

System.out.println("Rick.width:" + width);
System.out.println("Rick.height:" + height);


System.out.println("Rick.offsetx:" + offsetx);
System.out.println("Rick.offsety:" + offsety);

System.out.println("Rick.x:" + x);
System.out.println("Rick.y:" + y);

return new Position(x, y);
}

/**
 * 水印位置
 * 
 * 包含左边偏移量，右边偏移量。
 * 
 * @author liufang
 * 
 */
public static class Position {
private int x;

private int y;

public Position(int x, int y) {
this.x = x;
this.y = y;
}

public int getX() {
return x;
}

public void setX(int x) {
this.x = x;
}

public int getY() {
return y;
}

public void setY(int y) {
this.y = y;
}
}

}

基本写错了～～～～