package com.nis.web.controller.configuration; import java.io.File; import java.security.cert.X509Certificate; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.lang3.StringUtils; 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.bind.annotation.ResponseBody; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.servlet.mvc.support.RedirectAttributes; import com.google.common.collect.Maps; import com.nis.domain.Page; import com.nis.domain.SysDataDictionaryItem; import com.nis.domain.configuration.AppBuiltInFeatureFile; import com.nis.domain.configuration.AppByteCfg; import com.nis.domain.configuration.AppDomainCfg; import com.nis.domain.configuration.AppHeaderCfg; import com.nis.domain.configuration.AppHttpCfg; import com.nis.domain.configuration.AppIpCfg; import com.nis.domain.configuration.AppPolicyCfg; import com.nis.domain.configuration.AppSslCertCfg; import com.nis.domain.configuration.AppTcpCfg; import com.nis.domain.configuration.AppTopicDomainCfg; import com.nis.domain.configuration.IpPortCfg; import com.nis.domain.configuration.NtcSubscribeIdCfg; import com.nis.domain.configuration.AppBuiltInFeatureFile; import com.nis.domain.maat.ToMaatResult; import com.nis.domain.maat.ToMaatResult.ResponseData; import com.nis.domain.specific.SpecificServiceCfg; import com.nis.exceptions.CallExternalProceduresException; import com.nis.exceptions.MaatConvertException; import com.nis.util.CodeDicUtils; import com.nis.util.ConfigServiceUtil; import com.nis.util.Constants; import com.nis.util.DictUtils; import com.nis.util.FileUtils; import com.nis.util.JsonMapper; import com.nis.util.StringUtil; import com.nis.web.controller.BaseController; import com.nis.web.dao.configuration.AppBuiltInFeatureDao; import com.nis.web.dao.dashboard.codedic.CodeResult; import com.nis.web.security.UserUtils; /** * 特定协议相关配置控制类 * @author zhangwei * */ @Controller @RequestMapping("${adminPath}/app") public class AppCfgController extends BaseController { /** * app策略列表 * @param model * @param cfg * @param request * @param response * @return */ @RequestMapping(value = {"policyCfgList"}) public String policyCfgList(Model model,@ModelAttribute("cfg")AppPolicyCfg cfg,HttpServletRequest request,HttpServletResponse response) { Page searchPage=new Page(request,response,"r"); Page page = appCfgService.findAppPolicyList(searchPage, cfg); for(AppPolicyCfg entity:page.getList()){ SpecificServiceCfg app = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); entity.setAppName(app.getSpecServiceName()); } //查找社交应用的所有有效二级特定服务 SpecificServiceCfg second=new SpecificServiceCfg(); for(SysDataDictionaryItem dict:DictUtils.getDictList("SPECIFIC_SERVICE_CFG_TYPE")) { if(Constants.SPECIFIC_SERVICE_CFG_TYPE_APP.equals(dict.getItemValue())) { second.setCfgType(Integer.parseInt(dict.getItemCode())); break; } } second.setIsValid(Constants.VALID_YES); second.setIsLeaf(1); List secondList=specificServiceCfgService.findAllSpecificServiceCfg(second, null); //遍历,找到匹配项后将行为设置进去 for(SpecificServiceCfg secondCfg:secondList) { if(secondCfg.getSpecServiceCode()==null) continue; for(AppPolicyCfg entity:page.getList()){ if(entity.getBehavCode()==null) continue; if(secondCfg.getSpecServiceCode().intValue()==entity.getBehavCode().intValue()) { entity.setBehavName(secondCfg.getSpecServiceName()); break; } } } model.addAttribute("page", page); initPageCondition(model,cfg); return "/cfg/app/appPolicyCfgList"; } /** * 查询APP策略IP子配置 * @param model * @param cfgId * @param index * @return */ @RequestMapping(value = {"ajaxAppPolicyIpList"}) public String ajaxSslSubList(Model model,Long cfgId,Integer index) { AppPolicyCfg cfg = appCfgService.getAppPolicyCfg(cfgId); List tabList = new ArrayList(); if(cfg.getIpPortList()!=null){ String cfgType = null; for(IpPortCfg ip:cfg.getIpPortList()){ if(!ip.getCfgType().equals(cfgType)){ tabList.add(new String[]{"1",ip.getCfgType()}); cfgType = ip.getCfgType(); } } } if(cfg.getNtcSubscribeIdCfgList()!=null){ String cfgType = null; for(NtcSubscribeIdCfg ntc:cfg.getNtcSubscribeIdCfgList()){ if(!ntc.getCfgType().equals(cfgType)){ tabList.add(new String[]{"2",ntc.getCfgType()}); cfgType = ntc.getCfgType(); } } } model.addAttribute("_cfg", cfg); model.addAttribute("index", index); model.addAttribute("tabList", tabList); return "/cfg/app/appPolicyIpList"; } /** * 策略配置表单 * @param model * @param ids * @param entity * @return */ @RequestMapping(value = {"policyCfgForm"}) @RequiresPermissions(value={"app:policy:config"}) public String policyCfgForm(Model model,String ids,AppPolicyCfg entity) { if(StringUtils.isNotBlank(ids)){ entity = appCfgService.getAppPolicyCfg(Long.parseLong(ids)); initUpdateFormCondition(model,entity); }else{ initFormCondition(model,entity); } model.addAttribute("_cfg", entity); return "/cfg/app/appPolicyCfgForm"; } /** * 策略配置新增修改 * @param model * @param request * @param response * @param entity * @param redirectAttributes * @return */ @RequestMapping(value = {"saveAppPolicyCfg"}) @RequiresPermissions(value={"app:policy:config"}) public String saveAppPolicyCfg(Model model,HttpServletRequest request,HttpServletResponse response, AppPolicyCfg entity,RedirectAttributes redirectAttributes) { try { SpecificServiceCfg specificService = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); if(specificService!=null){ entity.setAppCode(specificService.getSpecServiceCode()); } appCfgService.saveOrUpdateAppPolicyCfg(entity); } catch (Exception e) { e.printStackTrace(); addMessage(redirectAttributes, e.getMessage()); } return "redirect:" + adminPath +"/app/policyCfgList?functionId="+entity.getFunctionId(); } /** * 策略配置审核 * @param isAudit * @param isValid * @param ids * @param functionId * @param redirectAttributes * @return */ @RequestMapping(value = {"auditAppPolicyCfg"}) @RequiresPermissions(value={"app:policy:confirm"}) public String auditAppPolicyCfg(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { AppPolicyCfg entity = new AppPolicyCfg(); String[] idArray = ids.split(","); for(String id :idArray){ entity = appCfgService.getAppPolicyCfg(Long.parseLong(id)); entity.setIsAudit(isAudit); entity.setIsValid(isValid); entity.setAuditorId(UserUtils.getUser().getId()); entity.setAuditTime(new Date()); entity.setFunctionId(functionId); entity.setConfigType(Constants.SPECIFIC_SERVICE_CFG_TYPE_APP); try { appCfgService.auditAppPolicyCfg(entity,isAudit); } catch (MaatConvertException e) { e.printStackTrace(); logger.info("app策略配置下发失败:"+e.getMessage()); addMessage(redirectAttributes, e.getMessage()); } } return "redirect:" + adminPath +"/app/policyCfgList?functionId="+functionId; } /** * 策略配置删除 * @param isValid * @param ids * @param functionId * @return */ @RequestMapping(value = {"updateAppPolicyCfgValid"}) @RequiresPermissions(value={"app:policy:config"}) public String updateAppPolicyCfgValid(Integer isValid,String ids,Integer functionId) { appCfgService.updateAppPolicyCfgValid(isValid,ids,functionId); return "redirect:" + adminPath +"/app/policyCfgList?functionId="+functionId; } /** * app协议IP配置列表 * @param model * @param cfg * @param request * @param response * @return */ @RequestMapping(value = {"ipCfgList"}) public String ipCfgList(Model model,@ModelAttribute("cfg")AppIpCfg cfg,HttpServletRequest request,HttpServletResponse response) { Page searchPage=new Page(request,response,"r"); Page page = appCfgService.findAppIpList(searchPage, cfg); for(AppIpCfg entity:page.getList()){ SpecificServiceCfg app = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); entity.setAppName(app.getSpecServiceName()); } model.addAttribute("page", page); initPageCondition(model,cfg); return "/cfg/app/appIpCfgList"; } /** * 协议IP配置表单 * @param model * @param ids * @param entity * @return */ @RequestMapping(value = {"ipCfgForm"}) @RequiresPermissions(value={"app:ip:config"}) public String ipCfgForm(Model model,String ids,AppIpCfg entity) { if(StringUtils.isNotBlank(ids)){ entity = appCfgService.getAppIpCfg(Long.parseLong(ids)); initUpdateFormCondition(model,entity); }else{ initFormCondition(model,entity); } model.addAttribute("_cfg", entity); return "/cfg/app/appIpCfgForm"; } /** * 协议IP配置新增修改 * @param model * @param request * @param response * @param entity * @param redirectAttributes * @return */ @RequestMapping(value = {"saveAppIpCfg"}) @RequiresPermissions(value={"app:ip:config"}) public String saveAppIpCfg(Model model,HttpServletRequest request,HttpServletResponse response, AppIpCfg entity,RedirectAttributes redirectAttributes) { try { SpecificServiceCfg specificService = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); if(specificService!=null){ entity.setAppCode(specificService.getSpecServiceCode()); } appCfgService.saveOrUpdateAppIpCfg(entity); } catch (Exception e) { e.printStackTrace(); addMessage(redirectAttributes, e.getMessage()); } return "redirect:" + adminPath +"/app/ipCfgList?functionId="+entity.getFunctionId(); } /** * 协议IP配置审核 * @param isAudit * @param isValid * @param ids * @param functionId * @param redirectAttributes * @return */ @RequestMapping(value = {"auditAppIpCfg"}) @RequiresPermissions(value={"app:ip:confirm"}) public String auditAppIpCfg(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { AppIpCfg entity = new AppIpCfg(); String[] idArray = ids.split(","); for(String id :idArray){ entity = appCfgService.getAppIpCfg(Long.parseLong(id)); entity.setIsAudit(isAudit); entity.setIsValid(isValid); entity.setAuditorId(UserUtils.getUser().getId()); entity.setAuditTime(new Date()); entity.setFunctionId(functionId); try { appCfgService.auditAppIpCfg(entity,isAudit); } catch (MaatConvertException e) { e.printStackTrace(); logger.info("app协议IP配置下发失败:"+e.getMessage()); addMessage(redirectAttributes, e.getMessage()); } } return "redirect:" + adminPath +"/app/ipCfgList?functionId="+functionId; } /** * IP配置删除 * @param isValid * @param ids * @param functionId * @return */ @RequestMapping(value = {"updateAppIpCfgValid"}) @RequiresPermissions(value={"app:ip:config"}) public String updateAppIpCfgValid(Integer isValid,String ids,Integer functionId) { appCfgService.updateAppIpCfgValid(isValid,ids,functionId); return "redirect:" + adminPath +"/app/ipCfgList?functionId="+functionId; } /** * app协议http配置列表 * @param model * @param cfg * @param request * @param response * @return */ @RequestMapping(value = {"httpCfgList"}) public String httpCfgList(Model model,@ModelAttribute("cfg")AppHttpCfg cfg,HttpServletRequest request,HttpServletResponse response) { Page searchPage=new Page(request,response,"r"); Page page = appCfgService.findAppHttpList(searchPage, cfg); for(AppHttpCfg entity:page.getList()){ SpecificServiceCfg app = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); entity.setAppName(app.getSpecServiceName()); // entity.setCfgKeywords(entity.getCfgKeywords().replace(Constants.KEYWORD_EXPR, "&")); } model.addAttribute("page", page); initPageCondition(model,cfg); return "/cfg/app/appHttpCfgList"; } /** * 协议http配置表单 * @param model * @param ids * @param entity * @return */ @RequestMapping(value = {"httpCfgForm"}) @RequiresPermissions(value={"app:http:config"}) public String httpCfgForm(Model model,String ids,AppHttpCfg entity) { if(StringUtils.isNotBlank(ids)){ entity = appCfgService.getAppHttpCfg(Long.parseLong(ids)); initUpdateFormCondition(model,entity); }else{ initFormCondition(model,entity); } model.addAttribute("_cfg", entity); return "/cfg/app/appHttpCfgForm"; } /** * http配置新增修改 * @param model * @param request * @param response * @param entity * @param redirectAttributes * @return */ @RequestMapping(value = {"saveAppHttpCfg"}) @RequiresPermissions(value={"app:http:config"}) public String saveAppHttpCfg(Model model,HttpServletRequest request,HttpServletResponse response, AppHttpCfg entity,RedirectAttributes redirectAttributes) { try { SpecificServiceCfg specificService = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); if(specificService!=null){ entity.setAppCode(specificService.getSpecServiceCode()); } appCfgService.saveOrUpdateAppHttpCfg(entity); } catch (Exception e) { e.printStackTrace(); addMessage(redirectAttributes, e.getMessage()); } return "redirect:" + adminPath +"/app/httpCfgList?functionId="+entity.getFunctionId(); } /** * http配置审核 * @param isAudit * @param isValid * @param ids * @param functionId * @param redirectAttributes * @return */ @RequestMapping(value = {"auditAppHttpCfg"}) // @RequiresPermissions(value={"app:http:confirm"}) public String auditAppHttpCfg(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { AppHttpCfg entity = new AppHttpCfg(); String[] idArray = ids.split(","); for(String id :idArray){ entity = appCfgService.getAppHttpCfg(Long.parseLong(id)); entity.setIsAudit(isAudit); entity.setIsValid(isValid); entity.setAuditorId(UserUtils.getUser().getId()); entity.setAuditTime(new Date()); entity.setFunctionId(functionId); try { appCfgService.auditAppHttpCfg(entity,isAudit); } catch (MaatConvertException e) { e.printStackTrace(); logger.info("app http配置下发失败:"+e.getMessage()); addMessage(redirectAttributes, e.getMessage()); } } return "redirect:" + adminPath +"/app/httpCfgList?functionId="+functionId; } /** * http配置删除 * @param isValid * @param ids * @param functionId * @return */ @RequestMapping(value = {"updateAppHttpCfgValid"}) @RequiresPermissions(value={"app:http:config"}) public String updateAppHttpCfgValid(Integer isValid,String ids,Integer functionId) { appCfgService.updateAppHttpCfgValid(isValid,ids,functionId); return "redirect:" + adminPath +"/app/httpCfgList?functionId="+functionId; } /** * app协议domain配置列表 * @param model * @param cfg * @param request * @param response * @return */ @RequestMapping(value = {"domainCfgList"}) public String domainCfgList(Model model,@ModelAttribute("cfg")AppDomainCfg cfg,HttpServletRequest request,HttpServletResponse response) { Page searchPage=new Page(request,response,"r"); Page page = appCfgService.findAppDomainList(searchPage, cfg); for(AppDomainCfg entity:page.getList()){ SpecificServiceCfg app = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); entity.setAppName(app.getSpecServiceName()); } model.addAttribute("page", page); initPageCondition(model,cfg); return "/cfg/app/appDomainCfgList"; } /** * 协议domain配置表单 * @param model * @param ids * @param entity * @return */ @RequestMapping(value = {"domainCfgForm"}) @RequiresPermissions(value={"app:domain:config"}) public String domainCfgForm(Model model,String ids,AppDomainCfg entity) { if(StringUtils.isNotBlank(ids)){ entity = appCfgService.getAppDomainCfg(Long.parseLong(ids)); initUpdateFormCondition(model,entity); }else{ initFormCondition(model,entity); } model.addAttribute("_cfg", entity); return "/cfg/app/appDomainCfgForm"; } /** * domain配置新增修改 * @param model * @param request * @param response * @param entity * @param redirectAttributes * @return */ @RequestMapping(value = {"saveAppDomainCfg"}) @RequiresPermissions(value={"app:domain:config"}) public String saveAppDomainCfg(Model model,HttpServletRequest request,HttpServletResponse response, AppDomainCfg entity,RedirectAttributes redirectAttributes) { try { SpecificServiceCfg specificService = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); if(specificService!=null){ entity.setAppCode(specificService.getSpecServiceCode()); } appCfgService.saveOrUpdateAppDomainCfg(entity); } catch (Exception e) { e.printStackTrace(); addMessage(redirectAttributes, e.getMessage()); } return "redirect:" + adminPath +"/app/domainCfgList?functionId="+entity.getFunctionId(); } /** * domain配置审核 * @param isAudit * @param isValid * @param ids * @param functionId * @param redirectAttributes * @return */ @RequestMapping(value = {"auditAppDomainCfg"}) // @RequiresPermissions(value={"app:domain:confirm"}) public String auditAppDomainCfg(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { AppDomainCfg entity = new AppDomainCfg(); String[] idArray = ids.split(","); for(String id :idArray){ entity = appCfgService.getAppDomainCfg(Long.parseLong(id)); entity.setIsAudit(isAudit); entity.setIsValid(isValid); entity.setAuditorId(UserUtils.getUser().getId()); entity.setAuditTime(new Date()); entity.setFunctionId(functionId); try { appCfgService.auditAppDomainCfg(entity,isAudit); } catch (MaatConvertException e) { e.printStackTrace(); logger.info("app协议domain配置下发失败:"+e.getMessage()); addMessage(redirectAttributes, e.getMessage()); } } return "redirect:" + adminPath +"/app/domainCfgList?functionId="+functionId; } /** * domain配置删除 * @param isValid * @param ids * @param functionId * @return */ @RequestMapping(value = {"updateAppDomainCfgValid"}) @RequiresPermissions(value={"app:domain:config"}) public String updateAppDomainCfgValid(Integer isValid,String ids,Integer functionId) { appCfgService.updateAppDomainCfgValid(isValid,ids,functionId); return "redirect:" + adminPath +"/app/domainCfgList?functionId="+functionId; } /** * app协议byte配置列表 * @param model * @param cfg * @param request * @param response * @return */ @RequestMapping(value = {"byteCfgList"}) public String byteCfgList(Model model,@ModelAttribute("cfg")AppByteCfg cfg,HttpServletRequest request,HttpServletResponse response) { Page searchPage=new Page(request,response,"r"); Page page = appCfgService.findAppByteList(searchPage, cfg); for(AppByteCfg entity:page.getList()){ SpecificServiceCfg app = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); entity.setAppName(app.getSpecServiceName()); } model.addAttribute("page", page); initPageCondition(model,cfg); return "/cfg/app/appByteCfgList"; } /** * 协议byte配置表单 * @param model * @param ids * @param entity * @return */ @RequestMapping(value = {"byteCfgForm"}) @RequiresPermissions(value={"app:byte:config"}) public String byteCfgForm(Model model,String ids,AppByteCfg entity) { if(StringUtils.isNotBlank(ids)){ entity = appCfgService.getAppByteCfg(Long.parseLong(ids)); initUpdateFormCondition(model,entity); }else{ initFormCondition(model,entity); } model.addAttribute("_cfg", entity); return "/cfg/app/appByteCfgForm"; } /** * byte配置新增修改 * @param model * @param request * @param response * @param entity * @param redirectAttributes * @return */ @RequestMapping(value = {"saveAppByteCfg"}) @RequiresPermissions(value={"app:byte:config"}) public String saveAppByteCfg(Model model,HttpServletRequest request,HttpServletResponse response, AppByteCfg entity,RedirectAttributes redirectAttributes) { try { SpecificServiceCfg specificService = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); if(specificService!=null){ entity.setAppCode(specificService.getSpecServiceCode()); } appCfgService.saveOrUpdateAppByteCfg(entity); } catch (Exception e) { e.printStackTrace(); addMessage(redirectAttributes, e.getMessage()); } return "redirect:" + adminPath +"/app/byteCfgList?functionId="+entity.getFunctionId(); } /** * byte配置审核 * @param isAudit * @param isValid * @param ids * @param functionId * @param redirectAttributes * @return */ @RequestMapping(value = {"auditAppByteCfg"}) // @RequiresPermissions(value={"app:byte:confirm"}) public String auditAppByteCfg(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { AppByteCfg entity = new AppByteCfg(); String[] idArray = ids.split(","); for(String id :idArray){ entity = appCfgService.getAppByteCfg(Long.parseLong(id)); entity.setIsAudit(isAudit); entity.setIsValid(isValid); entity.setAuditorId(UserUtils.getUser().getId()); entity.setAuditTime(new Date()); entity.setFunctionId(functionId); try { appCfgService.auditAppByteCfg(entity,isAudit); } catch (MaatConvertException e) { e.printStackTrace(); logger.info("app协议byte配置下发失败:"+e.getMessage()); addMessage(redirectAttributes, e.getMessage()); } } return "redirect:" + adminPath +"/app/byteCfgList?functionId="+functionId; } /** * byte配置删除 * @param isValid * @param ids * @param functionId * @return */ @RequestMapping(value = {"updateAppByteCfgValid"}) @RequiresPermissions(value={"app:byte:config"}) public String updateAppByteCfgValid(Integer isValid,String ids,Integer functionId) { appCfgService.updateAppByteCfgValid(isValid,ids,functionId); return "redirect:" + adminPath +"/app/byteCfgList?functionId="+functionId; } /** * APP ssl证书特征配置 列表 * @param model * @param cfg * @param request * @param response * @return */ @RequestMapping(value = {"sslCfgList"}) public String sslCfgList(Model model,@ModelAttribute("cfg")AppSslCertCfg cfg,HttpServletRequest request,HttpServletResponse response) { Page searchPage=new Page(request,response,"r"); Page page = appCfgService.findAppSslList(searchPage, cfg); for(AppSslCertCfg entity:page.getList()){ SpecificServiceCfg app = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); entity.setAppName(app.getSpecServiceName()); } model.addAttribute("page", page); initPageCondition(model,cfg); return "/cfg/app/appSslCfgList"; } /** * APP ssl证书特征配置表单(新增/修改) * @param model * @param ids * @param entity * @return */ @RequestMapping(value = {"sslCfgForm"}) @RequiresPermissions(value={"app:ssl:config"}) public String sslCfgForm(Model model,String ids,AppSslCertCfg entity) { if(StringUtils.isNotBlank(ids)){ entity = appCfgService.getAppSslCfg(Long.parseLong(ids)); initUpdateFormCondition(model,entity); }else{ initFormCondition(model,entity); } model.addAttribute("_cfg", entity); return "/cfg/app/appSslCfgForm"; } /** * APP ssl证书特征配置(新增/修改)提交 * @param model * @param request * @param response * @param entity * @param redirectAttributes * @return */ @RequestMapping(value = {"saveAppSslCfg"}) @RequiresPermissions(value={"app:ssl:config"}) public String saveAppSslCfg(Model model,HttpServletRequest request,HttpServletResponse response, AppSslCertCfg entity,RedirectAttributes redirectAttributes) { try { SpecificServiceCfg specificService = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); if(specificService!=null){ entity.setAppCode(specificService.getSpecServiceCode()); } appCfgService.saveOrUpdateAppSslCfg(entity); } catch (Exception e) { e.printStackTrace(); addMessage(redirectAttributes, e.getMessage()); } return "redirect:" + adminPath +"/app/sslCfgList?functionId="+entity.getFunctionId(); } /** * APP ssl证书特征配置 审核 * @param isAudit * @param isValid * @param ids * @param functionId * @param redirectAttributes * @return */ @RequestMapping(value = {"auditAppSslCfg"}) @RequiresPermissions(value={"app:ssl:confirm"}) public String auditAppSslCfg(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { AppSslCertCfg entity = new AppSslCertCfg(); String[] idArray = ids.split(","); for(String id :idArray){ entity = appCfgService.getAppSslCfg(Long.parseLong(id)); entity.setIsAudit(isAudit); entity.setIsValid(isValid); entity.setAuditorId(UserUtils.getUser().getId()); entity.setAuditTime(new Date()); entity.setFunctionId(functionId); try { appCfgService.auditAppSslCfg(entity,isAudit); } catch (MaatConvertException e) { e.printStackTrace(); logger.info("app SSL配置下发失败:"+e.getMessage()); addMessage(redirectAttributes, e.getMessage()); } } return "redirect:" + adminPath +"/app/sslCfgList?functionId="+functionId; } /** * APP ssl证书特征配置 删除 * @param isValid * @param ids * @param functionId * @return */ @RequestMapping(value = {"updateAppSslCfgValid"}) @RequiresPermissions(value={"app:ssl:config"}) public String updateAppSslCfgValid(Integer isValid,String ids,Integer functionId) { appCfgService.updateAppSslCfgValid(isValid,ids,functionId); return "redirect:" + adminPath +"/app/sslCfgList?functionId="+functionId; } /** * APP TCP会话字节数特征 列表 * @param model * @param cfg * @param request * @param response * @return */ @RequestMapping(value = {"tcpCfgList"}) public String tcpCfgList(Model model,@ModelAttribute("cfg")AppTcpCfg cfg,HttpServletRequest request,HttpServletResponse response) { Page searchPage=new Page(request,response,"r"); Page page = appCfgService.findAppTcpList(searchPage, cfg); for(AppTcpCfg entity:page.getList()){ SpecificServiceCfg app = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); entity.setAppName(app.getSpecServiceName()); } model.addAttribute("page", page); initPageCondition(model,cfg); return "/cfg/app/appTcpCfgList"; } /** * APP TCP会话字节数特征表单(新增/修改) * @param model * @param ids * @param entity * @return */ @RequestMapping(value = {"tcpCfgForm"}) @RequiresPermissions(value={"app:tcp:config"}) public String tcpCfgForm(Model model,String ids,AppTcpCfg entity) { if(StringUtils.isNotBlank(ids)){ entity = appCfgService.getAppTcpCfg(Long.parseLong(ids)); initUpdateFormCondition(model,entity); }else{ initFormCondition(model,entity); } model.addAttribute("_cfg", entity); return "/cfg/app/appTcpCfgForm"; } /** * APP TCP会话字节数特征配置(新增/修改)提交 * @param model * @param request * @param response * @param entity * @param redirectAttributes * @return */ @RequestMapping(value = {"saveAppTcpCfg"}) @RequiresPermissions(value={"app:tcp:config"}) public String saveAppTcpCfg(Model model,HttpServletRequest request,HttpServletResponse response, AppTcpCfg entity,RedirectAttributes redirectAttributes) { try { SpecificServiceCfg specificService = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); if(specificService!=null){ entity.setAppCode(specificService.getSpecServiceCode()); } appCfgService.saveOrUpdateAppTcpeCfg(entity); } catch (Exception e) { e.printStackTrace(); addMessage(redirectAttributes, e.getMessage()); } return "redirect:" + adminPath +"/app/tcpCfgList?functionId="+entity.getFunctionId(); } /** * APP TCP会话字节数特征配置删除 * @param isValid * @param ids * @param functionId * @return */ @RequestMapping(value = {"updateAppTcpCfgValid"}) @RequiresPermissions(value={"app:tcp:config"}) public String updateAppTcpCfgValid(Integer isValid,String ids,Integer functionId) { appCfgService.updateAppTcpCfgValid(isValid,ids,functionId); return "redirect:" + adminPath +"/app/tcpCfgList?functionId="+functionId; } /** * APP TCP会话字节数特征配置 审核 * @param isAudit * @param isValid * @param ids * @param functionId * @param redirectAttributes * @return */ @RequestMapping(value = {"auditAppTcpCfg"}) @RequiresPermissions(value={"app:tcp:confirm"}) public String auditAppTcpCfg(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { AppTcpCfg entity = new AppTcpCfg(); String[] idArray = ids.split(","); for(String id :idArray){ entity = appCfgService.getAppTcpCfg(Long.parseLong(id)); entity.setIsAudit(isAudit); entity.setIsValid(isValid); entity.setAuditorId(UserUtils.getUser().getId()); entity.setAuditTime(new Date()); entity.setFunctionId(functionId); try { appCfgService.auditAppTcpCfg(entity,isAudit); } catch (MaatConvertException e) { e.printStackTrace(); logger.info("app SSL配置下发失败:"+e.getMessage()); addMessage(redirectAttributes, e.getMessage()); } } return "redirect:" + adminPath +"/app/tcpCfgList?functionId="+functionId; } /** * APP header特征配置 列表 * @param model * @param cfg * @param request * @param response * @return */ @RequestMapping(value = {"headerCfgList"}) public String headerCfgList(Model model,@ModelAttribute("cfg")AppHeaderCfg cfg,HttpServletRequest request,HttpServletResponse response) { Page searchPage=new Page(request,response,"r"); Page page = appCfgService.findAppHeaderList(searchPage, cfg); for(AppHeaderCfg entity:page.getList()){ SpecificServiceCfg app = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); entity.setAppName(app.getSpecServiceName()); } model.addAttribute("page", page); initPageCondition(model,cfg); return "/cfg/app/appHeaderCfgList"; } /** * APP header特征配置表单 (修改/新增) * @param model * @param ids * @param entity * @return */ @RequestMapping(value = {"headerCfgForm"}) @RequiresPermissions(value={"app:header:config"}) public String headerCfgForm(Model model,String ids,AppHeaderCfg entity) { if(StringUtils.isNotBlank(ids)){ entity = appCfgService.getAppHeaderCfg(Long.parseLong(ids)); initUpdateFormCondition(model,entity); }else{ initFormCondition(model,entity); } model.addAttribute("_cfg", entity); return "/cfg/app/appHeaderCfgForm"; } /** * APP header特征配置 (新增/修改)表单提交 * @param model * @param request * @param response * @param entity * @param redirectAttributes * @return */ @RequestMapping(value = {"saveAppHeaderCfg"}) @RequiresPermissions(value={"app:header:config"}) public String saveAppHeaderCfg(Model model,HttpServletRequest request,HttpServletResponse response, AppHeaderCfg entity,RedirectAttributes redirectAttributes) { try { SpecificServiceCfg specificService = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); if(specificService!=null){ entity.setAppCode(specificService.getSpecServiceCode()); } appCfgService.saveOrUpdateAppHeaderCfg(entity); } catch (Exception e) { e.printStackTrace(); addMessage(redirectAttributes, e.getMessage()); } return "redirect:" + adminPath +"/app/headerCfgList?functionId="+entity.getFunctionId(); } /** * APP header特征配置 审核 * @param isAudit * @param isValid * @param ids * @param functionId * @param redirectAttributes * @return */ @RequestMapping(value = {"auditAppHeaderCfg"}) @RequiresPermissions(value={"app:header:confirm"}) public String auditAppHeaderCfg(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { AppHeaderCfg entity = new AppHeaderCfg(); String[] idArray = ids.split(","); for(String id :idArray){ entity = appCfgService.getAppHeaderCfg(Long.parseLong(id)); entity.setIsAudit(isAudit); entity.setIsValid(isValid); entity.setAuditorId(UserUtils.getUser().getId()); entity.setAuditTime(new Date()); entity.setFunctionId(functionId); try { appCfgService.auditAppHeaderCfg(entity,isAudit); } catch (MaatConvertException e) { e.printStackTrace(); logger.info("app Header配置下发失败:"+e.getMessage()); addMessage(redirectAttributes, e.getMessage()); } } return "redirect:" + adminPath +"/app/headerCfgList?functionId="+functionId; } /** * APP header特征配置 删除 * @param isValid * @param ids * @param functionId * @return */ @RequestMapping(value = {"updateAppHeaderCfgValid"}) @RequiresPermissions(value={"app:header:config"}) public String updateAppHeaderCfgValid(Integer isValid,String ids,Integer functionId) { appCfgService.updateAppHeaderCfgValid(isValid,ids,functionId); return "redirect:" + adminPath +"/app/headerCfgList?functionId="+functionId; } /** * 主题网站配置列表 * @param model * @param cfg * @param request * @param response * @return */ @RequestMapping(value = {"topicDomainCfgList"}) public String TopicDomainCfgList(Model model,@ModelAttribute("cfg")AppTopicDomainCfg cfg,HttpServletRequest request,HttpServletResponse response) { Page searchPage=new Page(request,response,"r"); Page page = appCfgService.findAppTopicDomainList(searchPage, cfg); // for(AppTopicDomainCfg entity:page.getList()){ // SpecificServiceCfg app = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); // entity.setAppName(app.getSpecServiceName()); // } //设置topic主题 for (AppTopicDomainCfg entity:page.getList()) { List codeList = CodeDicUtils.getCodeList("serviceCode"); for (CodeResult codeResult : codeList) { if(null!=entity.getTopic()&&codeResult.getCode().equals(entity.getTopic())){ entity.setAppName(codeResult.getItem()); } } } model.addAttribute("page", page); initPageCondition(model,cfg); return "/cfg/app/appTopicDomainCfgList"; } /** * app主题网站配置表单 * @param model * @param ids * @param entity * @return */ @RequestMapping(value = {"topicDomainCfgForm"}) @RequiresPermissions(value={"app:topic:config"}) public String topicDomainCfgForm(Model model,String ids,@ModelAttribute("_cfg")AppTopicDomainCfg entity) { if(StringUtils.isNotBlank(ids)){ entity = appCfgService.getAppTopicDomainCfg(Long.parseLong(ids)); initUpdateFormCondition(model,entity); }else{ initFormCondition(model,entity); } model.addAttribute("_cfg", entity); return "/cfg/app/appTopicDomainCfgForm"; } /** * app主题网站配置新增修改 * @param model * @param request * @param response * @param entity * @param redirectAttributes * @return */ @RequestMapping(value = {"saveAppTopicDomainCfg"}) @RequiresPermissions(value={"app:topic:config"}) public String saveAppTopicDomainCfg(Model model,HttpServletRequest request,HttpServletResponse response, AppTopicDomainCfg entity,RedirectAttributes redirectAttributes) { try { // SpecificServiceCfg specificService = specificServiceCfgService.getBySpecServiceId(entity.getSpecServiceId()); // if(specificService!=null){ // entity.setAppCode(specificService.getSpecServiceCode()); // } appCfgService.saveOrUpdateAppTopicDomainCfg(entity); addMessage(redirectAttributes,"save_success"); } catch (Exception e) { if(e instanceof MaatConvertException) { e.printStackTrace(); logger.info("app主题网站配置下发失败:"+e.getMessage());; addMessage(redirectAttributes,"request_service_failed"); }else { e.printStackTrace(); logger.error("app主题网站配置下发失败",e); addMessage(redirectAttributes,"save_failed"); } } return "redirect:" + adminPath +"/app/topicDomainCfgList?functionId="+entity.getFunctionId(); } /** * domain配置审核 * @param isAudit * @param isValid * @param ids * @param functionId * @param redirectAttributes * @return */ @RequestMapping(value = {"auditAppTopicDomainCfg"}) // @RequiresPermissions(value={"app:domain:confirm"}) public String auditAppTopicDomainCfg(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { AppTopicDomainCfg entity = new AppTopicDomainCfg(); String[] idArray = ids.split(","); for(String id :idArray){ entity = appCfgService.getAppTopicDomainCfg(Long.parseLong(id)); entity.setIsAudit(isAudit); entity.setIsValid(isValid); entity.setAuditorId(UserUtils.getUser().getId()); entity.setAuditTime(new Date()); entity.setFunctionId(functionId); try { appCfgService.auditAppTopicDomainCfg(entity,isAudit); addMessage(redirectAttributes,"audit_success"); } catch (MaatConvertException e) { if(e instanceof MaatConvertException) { e.printStackTrace(); logger.info("app主题网站配置下发失败:"+e.getMessage());; addMessage(redirectAttributes,"request_service_failed"); }else { e.printStackTrace(); logger.error("app主题网站配置下发失败",e); addMessage(redirectAttributes,"audit_failed"); } } } return "redirect:" + adminPath +"/app/topicDomainCfgList?functionId="+functionId; } /** * 网站主题配置删除 * @param isValid * @param ids * @param functionId * @return */ @RequestMapping(value = {"updateAppTopicDomainCfgValid"}) @RequiresPermissions(value={"app:topic:config"}) public String updateAppTopicDomainCfgValid(Integer isValid,String ids,Integer functionId,RedirectAttributes redirectAttributes) { try { appCfgService.updateAppTopicDomainCfgValid(isValid,ids,functionId); addMessage(redirectAttributes,"delete_success"); } catch (Exception e) { logger.error("app主题网站删除失败",e); if(e instanceof MaatConvertException||e instanceof CallExternalProceduresException) { e.printStackTrace(); addMessage(redirectAttributes,"request_service_failed"); }else { e.printStackTrace(); addMessage(redirectAttributes,"delete_failed"); } } return "redirect:" + adminPath +"/app/topicDomainCfgList?functionId="+functionId; } /**********************内置APP特征文件上传*******************************/ @RequestMapping(value = {"/appBuiltinFeatureFileForm"}) @RequiresPermissions(value={"app:built_in_file:config"}) public String from(Model model, HttpServletRequest request, HttpServletResponse response, String ids, @ModelAttribute("cfg")AppBuiltInFeatureFile cfg ,RedirectAttributes redirectAttributes){ if(cfg == null){ cfg=new AppBuiltInFeatureFile(); } if(!StringUtil.isEmpty(ids)){ cfg = appBuiltInFeatureService.getAppBuiltInFeatureFile(Long.valueOf(ids),-1); initFormCondition(model, cfg); model.addAttribute("isAdd", false); }else{ initFormCondition(model, cfg); model.addAttribute("isAdd", true); } model.addAttribute("_cfg", cfg); return "/cfg/app/appBuiltinFeatureFileForm"; } @RequestMapping(value = {"/appBuiltinFeatureFileSaveOrUpdate"}) @RequiresPermissions(value={"app:built_in_file:config"}) public String saveOrUpdate(Model model,HttpServletRequest request,HttpServletResponse response, @ModelAttribute("cfg")AppBuiltInFeatureFile cfg, MultipartFile file, RedirectAttributes redirectAttributes){ File fileD=null; try{ if(file != null) { String filename = file.getOriginalFilename(); String prefix = FileUtils.getPrefix(filename, false); String suffix = FileUtils.getSuffix(filename, false); fileD = File.createTempFile("file_"+ prefix, suffix); file.transferTo(fileD);//复制文件 String md5 = FileUtils.getFileMD5(fileD); Map srcMap = Maps.newHashMap(); srcMap.put("filetype", suffix); srcMap.put("datatype", "dbSystem");//源文件存入数据中心 srcMap.put("createTime",new Date()); srcMap.put("key",prefix); srcMap.put("fileName", filename); srcMap.put("checksum", md5); ToMaatResult result = ConfigServiceUtil.postFileCfg(null, fileD, JsonMapper.toJsonString(srcMap)); logger.info("APP 内置特征 文件上传响应信息:"+JsonMapper.toJsonString(result)); String accessUrl = null; if(!StringUtil.isEmpty(result)){ ResponseData data = result.getData(); accessUrl=data.getAccessUrl(); cfg.setFilePath(accessUrl);; } } appBuiltInFeatureService.saveOrUpdate(cfg); addMessage(redirectAttributes,"save_success"); }catch(Exception e){ e.printStackTrace(); addMessage(redirectAttributes,"save_failed"); } return "redirect:" + adminPath +"/app/appBuiltinFeatureFileList?functionId="+cfg.getFunctionId(); } @RequestMapping(value = {"/appBuiltinFeatureFileList"}) public String list(Model model,HttpServletRequest request,HttpServletResponse response ,@ModelAttribute("cfg")AppBuiltInFeatureFile entity ,RedirectAttributes redirectAttributes){ Page page = appBuiltInFeatureService.findPage(new Page(request, response,"r"), entity); model.addAttribute("page", page); initPageCondition(model); return "/cfg/app/appBuiltinFeatureFileList"; } @RequestMapping(value = {"/appBuiltinFeatureFileDelete"}) @RequiresPermissions(value={"app:built_in_file:config"}) public String delete(Integer isAudit,Integer isValid,String ids,Integer functionId ,Model model,HttpServletRequest request ,HttpServletResponse response ,RedirectAttributes redirectAttributes){ if(!StringUtil.isEmpty(ids)){ appBuiltInFeatureService.delete(isAudit,isValid,ids,functionId); } return "redirect:" + adminPath +"/app/appBuiltinFeatureFileList?functionId="+functionId; } @RequestMapping(value = {"/audit"}) @RequiresPermissions(value={"app:built_in_file:confirm"}) public String audit(Integer isAudit,Integer isValid,String ids,Integer functionId, RedirectAttributes redirectAttributes) { if(!StringUtil.isEmpty(ids)){ String[] idArray = ids.split(","); Date auditTime=new Date(); for(String id :idArray){ try { appBuiltInFeatureService.audit(isAudit,isValid,functionId,id,auditTime); } catch (MaatConvertException e) { addMessage(redirectAttributes, e.getMessage()); } } } return "redirect:" + adminPath +"/app/appBuiltinFeatureFileList?functionId="+functionId; } @ResponseBody @RequestMapping(value = "/validCfgId") public boolean validCfgId(Long cfgId) { AppBuiltInFeatureFile dns=appBuiltInFeatureService.getAppBuiltInFeatureFile(cfgId,null); if(dns == null ){ return false; }else{ return true; } } }