IP拦截提交

src/main/java/com/nis/web/controller/configuration/proxy/InterceptController.java

@@ -0,0 +1,131 @@
+package com.nis.web.controller.configuration.proxy;
+
+import java.util.Date;
+import java.util.List;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.shiro.authz.annotation.Logical;
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+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.servlet.mvc.support.RedirectAttributes;
+
+import com.nis.domain.Page;
+import com.nis.domain.configuration.AreaIpCfg;
+import com.nis.domain.configuration.BaseIpCfg;
+import com.nis.domain.configuration.BaseStringCfg;
+import com.nis.domain.configuration.HttpUrlCfg;
+import com.nis.domain.configuration.IpPortCfg;
+import com.nis.exceptions.MaatConvertException;
+import com.nis.util.Constants;
+import com.nis.web.controller.BaseController;
+
+/**
+ * IP相关配置控制类
+ * @author dell
+ *
+ */
+@Controller
+@RequestMapping("${adminPath}/proxy/intercept")
+public class InterceptController extends BaseController{
+	@RequestMapping(value = {"/ip/list"})
+	@RequiresPermissions(value={"intercept:ip:config","intercept:ip:audit"},logical=Logical.OR)
+	public String ipList(Model model,@ModelAttribute("cfg")IpPortCfg cfg,HttpServletRequest request,HttpServletResponse response) {
+			cfg.setTableName(IpPortCfg.getTablename());
+			Page<BaseIpCfg> searchPage=new Page<BaseIpCfg>(request,response,"r");
+			Page<BaseIpCfg> page = ipCfgService.findPage(searchPage, cfg);
+			model.addAttribute("page", page);
+			initPageCondition(model,cfg);
+		return "/cfg/proxy/ipList";
+	}
+	@RequestMapping(value = {"/ip/form"})
+	@RequiresPermissions(value={"intercept:ip:config"})
+	public String ipForm(Model model,String ids,BaseIpCfg entity) {
+		if(StringUtils.isNotBlank(ids)){
+			entity = ipCfgService.getIpCfgById(IpPortCfg.getTablename(),Long.parseLong(ids));
+		}
+		if(entity.getCfgId()!=null){
+			List<BaseIpCfg> areaCfg=ipCfgService.getListByComileId(AreaIpCfg.getTablename(), String.valueOf(entity.getCompileId()));
+			model.addAttribute("areaCfgs", areaCfg);
+			model.addAttribute("_cfg", entity);
+			initUpdateFormCondition(model,entity);
+		}else{
+			IpPortCfg cfg=new IpPortCfg();
+			cfg.initDefaultValueImpl();
+			cfg.setFunctionId(entity.getFunctionId());
+			cfg.setProtocolId(entity.getProtocolId());
+			model.addAttribute("_cfg", cfg);
+			initFormCondition(model,entity);
+		}
+		
+		return "/cfg/proxy/ipForm";
+	}
+	@RequestMapping(value = {"/ip/saveOrUpdate"})
+	public String saveOrUpdateIp(RedirectAttributes model, IpPortCfg cfg) {
+		Date date=new Date();
+		cfg.setTableName(IpPortCfg.getTablename());
+		logger.info("saveOrUpdateIp loaded");
+		try{
+			cfg.setIsValid(Constants.VALID_NO);
+			cfg.setIsAudit(Constants.AUDIT_NOT_YET);
+			if(cfg.getCfgId()==null){//新增
+				cfg.setCreatorId(cfg.getCurrentUser().getId());
+				cfg.setCreateTime(date);
+				ipCfgService.addIpCfg(cfg);
+			}else{//修改
+				cfg.setEditorId(cfg.getCurrentUser().getId());
+				cfg.setEditTime(new Date());
+				ipCfgService.updateIpCfg(cfg);
+			} 
+			addMessage(model,"save_success");
+		}catch(Exception e){
+			logger.error("保存失败",e);
+			addMessage(model,"save_failed");
+		}
+		return "redirect:" + adminPath +"/proxy/intercept/ip/list?functionId="+cfg.getFunctionId();
+	}
+	@RequestMapping(value = {"/ip/delete"})
+	@RequiresPermissions("iplist:config")
+	public String deleteIp(String ids,String compileIds,Integer functionId,RedirectAttributes model) {
+		try{
+			ipCfgService.deleteIp(ids,compileIds,functionId.intValue());
+			addMessage(model,"delete_success");
+		}catch(Exception e){
+			logger.error("删除失败", e);
+			addMessage(model,"delete_failed");
+		}
+		return "redirect:" + adminPath +"/proxy/intercept/ip/list?functionId="+functionId;
+	}
+	@RequestMapping(value = {"/ip/audit"})
+//	@RequiresPermissions("intercept:ip:audit")
+	public String auditIp(String ids,IpPortCfg cfg,RedirectAttributes redirectAttributes) {
+		try{
+			for(String id:ids.split(",")){
+				Long.parseLong(id);
+			}
+			List<BaseIpCfg> beans=ipCfgService.getListByCfgId(IpPortCfg.getTablename(),ids);
+			Date date=new Date();
+			for(BaseIpCfg bean:beans){
+				bean.setTableName(IpPortCfg.getTablename());
+				bean.setAuditorId(bean.getCurrentUser().getId());
+				bean.setAuditTime(date);
+				bean.setIsAudit(cfg.getIsAudit());
+				bean.setIsValid(cfg.getIsValid());
+				ipCfgService.audit(bean);
+			}
+			addMessage(redirectAttributes,"audit_success");
+		}catch(MaatConvertException e){
+			logger.error("审核失败", e);
+			addMessage(redirectAttributes, e.getMessage());
+		}catch(Exception e){
+			logger.error("审核失败", e);
+			addMessage(redirectAttributes, "audit_failed");
+		}
+		return "redirect:" + adminPath +"/proxy/intercept/ip/list?functionId="+cfg.getFunctionId();
+	}
+}