新版本

src/main/java/com/chenyang/nse/bussiness/commmon/ApplicationConstants.java

+package com.chenyang.nse.bussiness.commmon;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public final class ApplicationConstants {
+   public static String webRoot;
+   public static String driverClass;
+   public static String url;
+   public static String username;
+   public static String password;
+   public static String pmrep_path;
+   public static String pmcmd_path;
+   public static String con_path;
+   public static String log_path;
+   public static String paramfile_path;
+   public static String exefile_path;
+   public static String webservice_url;
+   public static String wsdl_url;
+   public static String wsdl_url_web;
+   public static String export_path;
+
+   private ApplicationConstants() {
+   }
+}

src/main/java/com/chenyang/nse/bussiness/controller/core/ApplogController.java

+package com.chenyang.nse.bussiness.controller.core;
+
+import com.chenyang.nse.bussiness.commmon.json.RespHelper;
+import com.chenyang.nse.bussiness.commmon.json.Response;
+import com.chenyang.nse.bussiness.config.PropertiesLoaderUtils;
+import com.chenyang.nse.bussiness.dao.table.core.notice.SysLogDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.notice.MailInformation;
+import com.chenyang.nse.bussiness.entity.orm.table.core.notice.SnmpTrapInfomation;
+import com.chenyang.nse.bussiness.entity.orm.table.core.notice.SyslogInfomation;
+import com.chenyang.nse.bussiness.service.core.MailService;
+import com.chenyang.nse.bussiness.service.core.SnmpTrapService;
+import com.chenyang.nse.bussiness.tools.syslog.MySyslogClient;
+import com.chenyang.nse.bussiness.tools.thread.GenericAsyProcess;
+import com.chenyang.nse.bussiness.tools.trapServer.SnmpTrapSender;
+import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping({"/core/applog"})
+public class ApplogController {
+   private static Logger logger = LoggerFactory.getLogger(EmailController.class);
+   @Autowired
+   private MailService mailService;
+   @Autowired
+   private SnmpTrapService snmpTrapService;
+   @Autowired
+   private SysLogDao sysLogDao;
+   @Autowired
+   private JavaMailSender jms;
+   private static Properties props = new Properties();
+   private static String mailSubject = "";
+   private static String mailContent = "";
+   private static String mailTo = "";
+
+   @RequestMapping({"/sendAlertInfo"})
+   @ResponseBody
+   public Response sendAlertInfo(@RequestParam Map<String, String> params, HttpServletRequest request, HttpServletResponse response, Model model) {
+      List<MailInformation> mailList = this.mailService.queryAll();
+      if (mailList.size() > 0) {
+         MailInformation mail = (MailInformation)mailList.get(0);
+         mail.setMailsubject(mail.getMailsubject() == null ? mailSubject : mail.getMailsubject());
+         mail.setMailto(mailTo);
+         mail.setMailbody(mail.getMailbody() == null ? mailContent : mail.getMailbody());
+         GenericAsyProcess.asyCommitThreadPool("sendSimpleMail", this.mailService, mail);
+      }
+
+      List<SnmpTrapInfomation> snmpList = this.snmpTrapService.queryAll();
+      if (snmpList.size() > 0) {
+         SnmpTrapInfomation snmp = (SnmpTrapInfomation)snmpList.get(0);
+         SnmpTrapSender snmpTrapSender = new SnmpTrapSender();
+         GenericAsyProcess.asyCommitThreadPool("sendSnpm", snmpTrapSender, snmp.getSnmp_server_ip(), snmp.getPort());
+      }
+
+      List<SyslogInfomation> syslogList = this.sysLogDao.queryAll();
+      if (syslogList.size() > 0) {
+         SyslogInfomation syslog = (SyslogInfomation)syslogList.get(0);
+         MySyslogClient syslogClient = new MySyslogClient();
+         GenericAsyProcess.asyCommitThreadPool("sendSyslog", syslogClient, syslog.getHostname(), syslog.getPort().intValue());
+      }
+
+      return RespHelper.successResp();
+   }
+
+   static {
+      try {
+         props = PropertiesLoaderUtils.loadAllProperties("config.properties");
+         mailSubject = props.getProperty("mailSubject");
+         mailContent = props.getProperty("mailContent");
+         mailTo = props.getProperty("mailTo");
+      } catch (IOException e) {
+         e.printStackTrace();
+      }
+
+   }
+}

src/main/java/com/chenyang/nse/bussiness/controller/core/ArticleController.java

+package com.chenyang.nse.bussiness.controller.core;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+@EnableAsync
+@Controller
+@RequestMapping({"/core/article"})
+public class ArticleController {
+   @RequestMapping
+   public String index(HttpServletRequest request, HttpServletResponse response, Model model, Integer pageCurr) {
+      if (pageCurr != null) {
+         model.addAttribute("toPageCurr", pageCurr);
+      } else {
+         model.addAttribute("toPageCurr", 1);
+      }
+
+      return "core/article/articlelist";
+   }
+}

src/main/java/com/chenyang/nse/bussiness/controller/core/log/auditbysyslog/AuditBySysLogController.java

+package com.chenyang.nse.bussiness.controller.core.log.auditbysyslog;
+
+import com.chenyang.nse.bussiness.commmon.json.RespHelper;
+import com.chenyang.nse.bussiness.commmon.json.Response;
+import com.chenyang.nse.bussiness.config.PropertiesLoaderUtils;
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.entity.vo.auditlog.AuditBySyslogVO;
+import com.chenyang.nse.bussiness.tools.datatime.DateTimeTool;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Properties;
+import net.sf.json.JSONObject;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+@Controller
+@RequestMapping({"/core/log/app/auditbysyslog"})
+public class AuditBySysLogController {
+   @PostMapping({"/getabslog"})
+   @ResponseBody
+   public Response getAuditBySyslog(@RequestBody Map<String, String> map) throws IOException {
+      int pagenum = Integer.parseInt((String)map.get("page"));
+      int pagesize = Integer.parseInt((String)map.get("rows"));
+      PageInfo pageInfo = new PageInfo();
+      pageInfo.setPageno(pagenum);
+      pageInfo.setPagesize(pagesize);
+      String username = (String)map.get("username");
+      String range = (String)map.get("range");
+      new Properties();
+      Properties props = PropertiesLoaderUtils.loadAllProperties("config.properties");
+      String filepath = props.getProperty("syslog4auditserverlogpath");
+      List<AuditBySyslogVO> arrayList = new ArrayList();
+      Date today = new Date();
+      if ("0".equals(range)) {
+         String fm = "yyyy-MM-dd";
+         String toFileName = DateTimeTool.formatDateTime(today, fm);
+         File file = new File(filepath + "/syslog4audit/" + toFileName + ".txt");
+         InputStreamReader inputReader = new InputStreamReader(new FileInputStream(file), StandardCharsets.UTF_8);
+         BufferedReader bf = new BufferedReader(inputReader);
+
+         String str1;
+         while((str1 = bf.readLine()) != null) {
+            JSONObject jsonObject = JSONObject.fromObject(str1);
+            AuditBySyslogVO vo = (AuditBySyslogVO)JSONObject.toBean(jsonObject, AuditBySyslogVO.class);
+            vo.setMessage((String)jsonObject.getJSONObject("message").get("message"));
+            arrayList.add(vo);
+         }
+
+         bf.close();
+         inputReader.close();
+      }
+
+      List<String> files = new ArrayList();
+      if (!"0".equals(range)) {
+         String path = filepath + "syslog4audit";
+         File file1 = new File(path);
+         File[] tempList = file1.listFiles();
+
+         for(int i = 0; i < ((File[])Objects.requireNonNull(tempList)).length; ++i) {
+            if (tempList[i].isFile()) {
+               String fileName = tempList[i].getName().substring(0, tempList[i].getName().indexOf("txt") - 1);
+               Date date = DateTimeTool.parseDateTime(fileName, "yyyy-MM-dd");
+               today = new Date();
+               if (!"全部".equals(range)) {
+                  if (DateTimeTool.beforeDays(today, Integer.parseInt(range) + 1).before(date)) {
+                     files.add(tempList[i].getName());
+                  }
+               } else {
+                  files.add(tempList[i].getName());
+               }
+            }
+         }
+
+         for(String s : files) {
+            File file2 = new File(filepath + "syslog4audit/" + s);
+            InputStreamReader inReader = new InputStreamReader(new FileInputStream(file2), StandardCharsets.UTF_8);
+            BufferedReader bf1 = new BufferedReader(inReader);
+
+            String str1;
+            while((str1 = bf1.readLine()) != null) {
+               JSONObject jsonObject = JSONObject.fromObject(str1);
+               AuditBySyslogVO vo = (AuditBySyslogVO)JSONObject.toBean(jsonObject, AuditBySyslogVO.class);
+               vo.setMessage((String)jsonObject.getJSONObject("message").get("message"));
+               arrayList.add(vo);
+            }
+
+            bf1.close();
+            inReader.close();
+         }
+      }
+
+      new ArrayList();
+      List var26;
+      if (arrayList.size() < pagenum * pagesize) {
+         var26 = arrayList.subList((pagenum - 1) * pagesize, arrayList.size());
+      } else {
+         var26 = arrayList.subList((pagenum - 1) * pagesize, pagenum * pagesize);
+      }
+
+      pageInfo.setCount((long)var26.size());
+      return RespHelper.updateResp(pageInfo, var26);
+   }
+}

src/main/java/com/chenyang/nse/bussiness/controller/core/strategy/audit/AuditAppDataRuleController.java

+package com.chenyang.nse.bussiness.controller.core.strategy.audit;
+
+import com.chenyang.nse.bussiness.commmon.json.RespHelper;
+import com.chenyang.nse.bussiness.commmon.json.Response;
+import com.chenyang.nse.bussiness.engine.infa.powercenter961.pubtool.StringUtil;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.app.AuditAppDataRule;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditApplicationConditions;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditDateConditions;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditDbuserConditions;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditIpConditions;
+import com.chenyang.nse.bussiness.service.core.strategy.AuditAppDataRuleService;
+import com.chenyang.nse.bussiness.tools.login.CommonUtils;
+import com.chenyang.nse.bussiness.tools.msg.MesUtil;
+import com.chenyang.nse.bussiness.tools.object.ObjectTool;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+@Controller
+@RequestMapping({"/core/audit/appdatarule"})
+public class AuditAppDataRuleController {
+   @Autowired
+   private AuditAppDataRuleService auditAppDataRuleService;
+   private static final Logger ddmauditLogger = LoggerFactory.getLogger("ddmauditLogger");
+   private static final Logger operationLogger = LoggerFactory.getLogger("operationLogger");
+
+   @PostMapping({"/add"})
+   @ResponseBody
+   public Response auditDataRuleAdd(@RequestBody Map<String, Object> params) {
+      AuditAppDataRule ruleinfo = (AuditAppDataRule)ObjectTool.getObjectByMap(AuditAppDataRule.class, (Map)params.get("ruleinfo"));
+      String id = ruleinfo.getId();
+      AuditAppDataRule appDataRule = new AuditAppDataRule();
+      BeanUtils.copyProperties(ruleinfo, appDataRule);
+      if (StringUtil.isBlank(id)) {
+         appDataRule.setId(UUID.randomUUID().toString());
+         ddmauditLogger.info(MesUtil.getMsg("DDM_01601", new String[]{CommonUtils.loginUsername(), ruleinfo.getRulename()}));
+      } else {
+         this.auditAppDataRuleService.delIpConditionsInfoByRuleId(id);
+         this.auditAppDataRuleService.delApplicationConditionsInfoByRuleId(id);
+         this.auditAppDataRuleService.delDbuserConditionsInfoByRuleId(id);
+         this.auditAppDataRuleService.delDateConditionsInfoByRuleId(id);
+         ddmauditLogger.info(MesUtil.getMsg("DDM_01603", new String[]{CommonUtils.loginUsername(), ruleinfo.getRulename()}));
+      }
+
+      List ipconditionslist = (List)params.get("ipconditionslist");
+      ipconditionslist.forEach((ipconditions) -> {
+         AuditIpConditions ipcs = (AuditIpConditions)ObjectTool.getObjectByMap(AuditIpConditions.class, (Map)ipconditions);
+         AuditIpConditions ipConditions = new AuditIpConditions();
+         BeanUtils.copyProperties(ipcs, ipConditions);
+         ipConditions.setRuleid(appDataRule.getId());
+         this.auditAppDataRuleService.saveIpConditionsInfo(ipConditions);
+      });
+      List applicationconditionslist = (List)params.get("applicationconditionslist");
+      applicationconditionslist.forEach((applicationconditions) -> {
+         AuditApplicationConditions appcs = (AuditApplicationConditions)ObjectTool.getObjectByMap(AuditApplicationConditions.class, (Map)applicationconditions);
+         AuditApplicationConditions applicationConditions = new AuditApplicationConditions();
+         BeanUtils.copyProperties(appcs, applicationConditions);
+         applicationConditions.setRuleid(appDataRule.getId());
+         this.auditAppDataRuleService.saveApplicationConditionsInfo(applicationConditions);
+      });
+      List dbuserconditionslist = (List)params.get("dbuserconditionslist");
+      dbuserconditionslist.forEach((dbuserconditions) -> {
+         AuditDbuserConditions dbusercs = (AuditDbuserConditions)ObjectTool.getObjectByMap(AuditDbuserConditions.class, (Map)dbuserconditions);
+         AuditDbuserConditions dbuserConditions = new AuditDbuserConditions();
+         BeanUtils.copyProperties(dbusercs, dbuserConditions);
+         dbuserConditions.setRuleid(appDataRule.getId());
+         this.auditAppDataRuleService.saveDbuserConditionsInfo(dbuserConditions);
+      });
+      List dateconditionslist = (List)params.get("dateconditionslist");
+      dateconditionslist.forEach((dateconditions) -> {
+         AuditDateConditions datecs = (AuditDateConditions)ObjectTool.getObjectByMap(AuditDateConditions.class, (Map)dateconditions);
+         AuditDateConditions dateConditions = new AuditDateConditions();
+         BeanUtils.copyProperties(datecs, dateConditions);
+         dateConditions.setRuleid(appDataRule.getId());
+         this.auditAppDataRuleService.saveDateConditionsInfo(dateConditions);
+      });
+      this.auditAppDataRuleService.saveAppRuleInfo(appDataRule, id);
+      return RespHelper.successResp();
+   }
+
+   @GetMapping({"/initEdit"})
+   @ResponseBody
+   public Response auditDataRuleInitEdit(@RequestParam("id") String id, @RequestParam("name") String name) {
+      ddmauditLogger.info(MesUtil.getMsg("DDM_01602", new String[]{CommonUtils.loginUsername(), name}));
+      List<AuditAppDataRule> appRuleInfo = this.auditAppDataRuleService.getAppRuleInfoById(id);
+      List<AuditIpConditions> ipConditionsList = this.auditAppDataRuleService.getIpConditionsInfoByRuleId(id);
+      List<AuditApplicationConditions> applicationConditionsList = this.auditAppDataRuleService.getApplicationConditionsInfoByRuleId(id);
+      List<AuditDbuserConditions> dbuserConditionsList = this.auditAppDataRuleService.getDbuserConditionsInfoByRuleId(id);
+      List<AuditDateConditions> dateConditionsList = this.auditAppDataRuleService.getDateConditionsInfoByRuleId(id);
+      Map<String, Object> map = new HashMap();
+      map.put("ruleinfo", appRuleInfo.get(0));
+      map.put("ipConditions", ipConditionsList);
+      map.put("applicationConditions", applicationConditionsList);
+      map.put("dbuserConditions", dbuserConditionsList);
+      map.put("dateConditions", dateConditionsList);
+      return RespHelper.successResp(map);
+   }
+
+   @PostMapping({"/del"})
+   @ResponseBody
+   public Response auditDataRuleDel(@RequestBody Map<String, Object> params) {
+      String id = (String)params.get("id");
+      String rulename = (String)params.get("name");
+      ddmauditLogger.info(MesUtil.getMsg("DDM_01604", new String[]{CommonUtils.loginUsername(), rulename}));
+      this.auditAppDataRuleService.delAppRuleInfoById(id);
+      this.auditAppDataRuleService.delIpConditionsInfoByRuleId(id);
+      this.auditAppDataRuleService.delApplicationConditionsInfoByRuleId(id);
+      this.auditAppDataRuleService.delDbuserConditionsInfoByRuleId(id);
+      this.auditAppDataRuleService.delDateConditionsInfoByRuleId(id);
+      return RespHelper.successResp();
+   }
+
+   @GetMapping({"/query"})
+   @ResponseBody
+   public Response auditDataRuleQuery() {
+      ddmauditLogger.info(MesUtil.getMsg("DDM_01301", new String[]{CommonUtils.loginUsername()}));
+      return RespHelper.successResp(this.auditAppDataRuleService.queryAll());
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/core/AssignmentNameDao.java

+package com.chenyang.nse.bussiness.dao.core;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.entity.orm.table.core.TCoreComplianceDirectory;
+import com.chenyang.nse.bussiness.entity.orm.table.core.TCoreDataScope;
+import com.chenyang.nse.bussiness.entity.orm.table.core.TCoreSensitiveLevel;
+import com.chenyang.nse.bussiness.entity.vo.datascope.AssignmentNameVO;
+import com.chenyang.nse.bussiness.tools.xml.XmlTool;
+import java.util.List;
+import org.hibernate.transform.Transformers;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class AssignmentNameDao extends BaseDao<Object, String> {
+   public List<AssignmentNameVO> assignmentNameVO(PageInfo pageInfo, String taskname) {
+      String sql = XmlTool.getSql("assignmentname", "selectAssignmentNameList");
+      System.out.println(taskname);
+      List<AssignmentNameVO> vo = this.getSession().createNativeQuery(sql).setParameter("tname", taskname).setResultTransformer(Transformers.aliasToBean(AssignmentNameVO.class)).getResultList();
+      return vo;
+   }
+
+   public int insertscopefield(String scope_field) {
+      String sql = "INSERT INTO t_core_scope_field(id,tablefield_id,assignment_id,scope_id) VALUES " + scope_field;
+      return this.getSession().createNativeQuery(sql).executeUpdate();
+   }
+
+   public int insertdirectoryfield(String directory_field) {
+      String sql = "INSERT INTO t_core_field_directory(id,tablefield_id,assignment_id,directory_id) VALUES " + directory_field;
+      return this.getSession().createNativeQuery(sql).executeUpdate();
+   }
+
+   public int insertsensitivefield(String sensitive_field) {
+      String sql = "INSERT INTO t_core_field_sensitive(id,tablefield_id,assignment_id,sensitive_id) VALUES " + sensitive_field;
+      return this.getSession().createNativeQuery(sql).executeUpdate();
+   }
+
+   public List<TCoreDataScope> getDataScopeList(String id) {
+      String sql = "select t.scope_name,t.scope_id from t_core_scope_field f,t_core_data_scope t where t.scope_id= f.scope_id and f.tablefield_id = '" + id + "'";
+      return this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.aliasToBean(TCoreDataScope.class)).getResultList();
+   }
+
+   public List<TCoreComplianceDirectory> getComplianceDirectoryList(String id) {
+      String sql = "select t.directory_name directory_name,t.id id from t_core_field_directory f,t_core_compliance_directory t where t.id = f.directory_id and f.tablefield_id = '" + id + "'";
+      return this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.aliasToBean(TCoreComplianceDirectory.class)).getResultList();
+   }
+
+   public List<TCoreSensitiveLevel> getSensitiveLevel(String id) {
+      String sql = "select t.sensitive_name sensitive_name,t.id id from t_core_field_sensitive f,t_core_sensitive_level t where t.id = f.sensitive_id and f.tablefield_id = '" + id + "'";
+      return this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.aliasToBean(TCoreSensitiveLevel.class)).getResultList();
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/strategy/audit/app/AuditAppDataRuleDao.java

+package com.chenyang.nse.bussiness.dao.table.core.strategy.audit.app;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.app.AuditAppDataRule;
+import com.chenyang.nse.bussiness.entity.vo.strategy.StrategeVO;
+import java.util.List;
+import org.hibernate.transform.Transformers;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class AuditAppDataRuleDao extends BaseDao<AuditAppDataRule, String> {
+   public List<StrategeVO> queryAllStrategy() {
+      String sql = "select id as id ,name ,remark, type, enablestatus from t_console_audit_appdatarule   union all select id as id ,name ,remark, '1' as type, enablestatus from t_console_masking_appdatarule";
+      List<StrategeVO> list = this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.aliasToBean(StrategeVO.class)).getResultList();
+      return list;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/strategy/audit/conditions/AuditApplicationConditionsDao.java

+package com.chenyang.nse.bussiness.dao.table.core.strategy.audit.conditions;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditApplicationConditions;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class AuditApplicationConditionsDao extends BaseDao<AuditApplicationConditions, String> {
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/strategy/audit/conditions/AuditDbuserConditionsDao.java

+package com.chenyang.nse.bussiness.dao.table.core.strategy.audit.conditions;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditDbuserConditions;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class AuditDbuserConditionsDao extends BaseDao<AuditDbuserConditions, String> {
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/strategy/audit/conditions/AuditIpConditionsDao.java

+package com.chenyang.nse.bussiness.dao.table.core.strategy.audit.conditions;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditIpConditions;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class AuditIpConditionsDao extends BaseDao<AuditIpConditions, String> {
+}

src/main/java/com/chenyang/nse/bussiness/engine/infa/basic/wsclient/Attribute.java

+package com.chenyang.nse.bussiness.engine.infa.basic.wsclient;
+
+import javax.xml.bind.annotation.XmlAccessType;
+import javax.xml.bind.annotation.XmlAccessorType;
+import javax.xml.bind.annotation.XmlElement;
+import javax.xml.bind.annotation.XmlType;
+
+@XmlAccessorType(XmlAccessType.FIELD)
+@XmlType(
+   name = "Attribute",
+   propOrder = {"name", "value"}
+)
+public class Attribute {
+   @XmlElement(
+      name = "Name",
+      required = true
+   )
+   protected String name;
+   @XmlElement(
+      name = "Value",
+      required = true
+   )
+   protected String value;
+
+   public String getName() {
+      return this.name;
+   }
+
+   public void setName(String value) {
+      this.name = value;
+   }
+
+   public String getValue() {
+      return this.value;
+   }
+
+   public void setValue(String value) {
+      this.value = value;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/engine/infa/basic/xmlbean/ASSOCIATEDSOURCEINSTANCE.java

+package com.chenyang.nse.bussiness.engine.infa.basic.xmlbean;
+
+import javax.xml.bind.annotation.XmlAccessType;
+import javax.xml.bind.annotation.XmlAccessorType;
+import javax.xml.bind.annotation.XmlAttribute;
+import javax.xml.bind.annotation.XmlRootElement;
+import javax.xml.bind.annotation.XmlType;
+import javax.xml.bind.annotation.adapters.NormalizedStringAdapter;
+import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
+
+@XmlAccessorType(XmlAccessType.FIELD)
+@XmlType(
+   name = ""
+)
+@XmlRootElement(
+   name = "ASSOCIATED_SOURCE_INSTANCE"
+)
+public class ASSOCIATEDSOURCEINSTANCE {
+   @XmlAttribute(
+      name = "NAME",
+      required = true
+   )
+   @XmlJavaTypeAdapter(NormalizedStringAdapter.class)
+   protected String name;
+
+   public String getNAME() {
+      return this.name;
+   }
+
+   public void setNAME(String value) {
+      this.name = value;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/engine/infa/basic/xmlbean/ATTRIBUTE.java

+package com.chenyang.nse.bussiness.engine.infa.basic.xmlbean;
+
+import com.sun.xml.internal.txw2.annotation.XmlCDATA;
+import javax.xml.bind.annotation.XmlAccessType;
+import javax.xml.bind.annotation.XmlAccessorType;
+import javax.xml.bind.annotation.XmlAttribute;
+import javax.xml.bind.annotation.XmlRootElement;
+import javax.xml.bind.annotation.XmlType;
+import javax.xml.bind.annotation.adapters.NormalizedStringAdapter;
+import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
+
+@XmlAccessorType(XmlAccessType.FIELD)
+@XmlType(
+   name = "",
+   propOrder = {"value", "name"}
+)
+@XmlRootElement(
+   name = "ATTRIBUTE"
+)
+public class ATTRIBUTE {
+   @XmlAttribute(
+      name = "NAME",
+      required = true
+   )
+   @XmlJavaTypeAdapter(NormalizedStringAdapter.class)
+   protected String name;
+   @XmlAttribute(
+      name = "VALUE",
+      required = true
+   )
+   @XmlJavaTypeAdapter(NormalizedStringAdapter.class)
+   protected String value;
+   @XmlAttribute(
+      name = "PARTITIONNAME"
+   )
+   @XmlJavaTypeAdapter(NormalizedStringAdapter.class)
+   protected String partitionname;
+
+   public String getNAME() {
+      return this.name;
+   }
+
+   @XmlCDATA
+   public void setNAME(String value) {
+      this.name = value;
+   }
+
+   public String getVALUE() {
+      return this.value;
+   }
+
+   @XmlCDATA
+   public void setVALUE(String value) {
+      this.value = value;
+   }
+
+   public String getPARTITIONNAME() {
+      return this.partitionname;
+   }
+
+   public void setPARTITIONNAME(String value) {
+      this.partitionname = value;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/strategy/audit/app/AuditAppDataRule.java

+package com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.app;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TInitEntity;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "t_console_audit_appdatarule"
+)
+public class AuditAppDataRule extends TInitEntity {
+   private String name;
+   private String datasourceid;
+   private String rulename;
+   private String type;
+   private String belongtogroup;
+   private String remark;
+   private String desensitizationexpression;
+   private String auditswitch;
+   private String enablestatus;
+
+   public String getRulename() {
+      return this.rulename;
+   }
+
+   public void setRulename(String rulename) {
+      this.rulename = rulename;
+   }
+
+   public String getType() {
+      return this.type;
+   }
+
+   public void setType(String type) {
+      this.type = type;
+   }
+
+   public String getBelongtogroup() {
+      return this.belongtogroup;
+   }
+
+   public void setBelongtogroup(String belongtogroup) {
+      this.belongtogroup = belongtogroup;
+   }
+
+   public String getRemark() {
+      return this.remark;
+   }
+
+   public void setRemark(String remark) {
+      this.remark = remark;
+   }
+
+   public String getDesensitizationexpression() {
+      return this.desensitizationexpression;
+   }
+
+   public void setDesensitizationexpression(String desensitizationexpression) {
+      this.desensitizationexpression = desensitizationexpression;
+   }
+
+   public String getAuditswitch() {
+      return this.auditswitch;
+   }
+
+   public void setAuditswitch(String auditswitch) {
+      this.auditswitch = auditswitch;
+   }
+
+   public String getName() {
+      return this.name;
+   }
+
+   public void setName(String name) {
+      this.name = name;
+   }
+
+   public String getDatasourceid() {
+      return this.datasourceid;
+   }
+
+   public void setDatasourceid(String datasourceid) {
+      this.datasourceid = datasourceid;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/strategy/audit/conditions/AuditApplicationConditions.java

+package com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "t_console_audit_applicationconditions"
+)
+public class AuditApplicationConditions extends TBaseEntity {
+   private String matchsymbol;
+   private String matchval;
+   private String ruleid;
+
+   public String getMatchsymbol() {
+      return this.matchsymbol;
+   }
+
+   public void setMatchsymbol(String matchsymbol) {
+      this.matchsymbol = matchsymbol;
+   }
+
+   public String getMatchval() {
+      return this.matchval;
+   }
+
+   public void setMatchval(String matchval) {
+      this.matchval = matchval;
+   }
+
+   public String getRuleid() {
+      return this.ruleid;
+   }
+
+   public void setRuleid(String ruleid) {
+      this.ruleid = ruleid;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/strategy/audit/conditions/AuditDateConditions.java

+package com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "t_console_audit_dateconditions"
+)
+public class AuditDateConditions extends TBaseEntity {
+   private String starttime;
+   private String endtime;
+   private String ruleid;
+
+   public String getStarttime() {
+      return this.starttime;
+   }
+
+   public void setStarttime(String starttime) {
+      this.starttime = starttime;
+   }
+
+   public String getEndtime() {
+      return this.endtime;
+   }
+
+   public void setEndtime(String endtime) {
+      this.endtime = endtime;
+   }
+
+   public String getRuleid() {
+      return this.ruleid;
+   }
+
+   public void setRuleid(String ruleid) {
+      this.ruleid = ruleid;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/strategy/audit/conditions/AuditDbuserConditions.java

+package com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "t_console_audit_dbuserconditions"
+)
+public class AuditDbuserConditions extends TBaseEntity {
+   private String matchsymbol;
+   private String matchval;
+   private String ruleid;
+
+   public String getMatchsymbol() {
+      return this.matchsymbol;
+   }
+
+   public void setMatchsymbol(String matchsymbol) {
+      this.matchsymbol = matchsymbol;
+   }
+
+   public String getMatchval() {
+      return this.matchval;
+   }
+
+   public void setMatchval(String matchval) {
+      this.matchval = matchval;
+   }
+
+   public String getRuleid() {
+      return this.ruleid;
+   }
+
+   public void setRuleid(String ruleid) {
+      this.ruleid = ruleid;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/strategy/audit/conditions/AuditIpConditions.java

+package com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "t_console_audit_ipconditions"
+)
+public class AuditIpConditions extends TBaseEntity {
+   private String matchsymbol;
+   private String matchval;
+   private String startval;
+   private String endval;
+   private String ruleid;
+
+   public String getMatchsymbol() {
+      return this.matchsymbol;
+   }
+
+   public void setMatchsymbol(String matchsymbol) {
+      this.matchsymbol = matchsymbol;
+   }
+
+   public String getMatchval() {
+      return this.matchval;
+   }
+
+   public void setMatchval(String matchval) {
+      this.matchval = matchval;
+   }
+
+   public String getRuleid() {
+      return this.ruleid;
+   }
+
+   public void setRuleid(String ruleid) {
+      this.ruleid = ruleid;
+   }
+
+   public String getStartval() {
+      return this.startval;
+   }
+
+   public void setStartval(String startval) {
+      this.startval = startval;
+   }
+
+   public String getEndval() {
+      return this.endval;
+   }
+
+   public void setEndval(String endval) {
+      this.endval = endval;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/vo/AppUserVO.java

+package com.chenyang.nse.bussiness.entity.vo;
+
+import java.util.Date;
+
+public class AppUserVO {
+   private String id;
+   private String tid;
+   private String username;
+   private String useridentifier;
+   private String isoriginal;
+   private String ismask;
+   private String note;
+   private Date createtime;
+   private Date updatetime;
+   private String createuser;
+   private String updateuser;
+   private String updateuserid;
+
+   public String getTid() {
+      return this.id;
+   }
+
+   public void setTid(String id) {
+      this.id = id;
+   }
+
+   public String getId() {
+      return this.id;
+   }
+
+   public void setId(String id) {
+      this.id = id;
+   }
+
+   public String getUsername() {
+      return this.username;
+   }
+
+   public void setUsername(String username) {
+      this.username = username;
+   }
+
+   public String getUseridentifier() {
+      return this.useridentifier;
+   }
+
+   public void setUseridentifier(String useridentifier) {
+      this.useridentifier = useridentifier;
+   }
+
+   public String getIsoriginal() {
+      return this.isoriginal;
+   }
+
+   public void setIsoriginal(String isoriginal) {
+      this.isoriginal = isoriginal;
+   }
+
+   public String getIsmask() {
+      return this.ismask;
+   }
+
+   public void setIsmask(String ismask) {
+      this.ismask = ismask;
+   }
+
+   public String getNote() {
+      return this.note;
+   }
+
+   public void setNote(String note) {
+      this.note = note;
+   }
+
+   public Date getCreatetime() {
+      return this.createtime;
+   }
+
+   public void setCreatetime(Date createtime) {
+      this.createtime = createtime;
+   }
+
+   public Date getUpdatetime() {
+      return this.updatetime;
+   }
+
+   public void setUpdatetime(Date updatetime) {
+      this.updatetime = updatetime;
+   }
+
+   public String getCreateuser() {
+      return this.createuser;
+   }
+
+   public void setCreateuser(String createuser) {
+      this.createuser = createuser;
+   }
+
+   public String getUpdateuser() {
+      return this.updateuser;
+   }
+
+   public void setUpdateuser(String updateuser) {
+      this.updateuser = updateuser;
+   }
+
+   public String getUpdateuserid() {
+      return this.updateuserid;
+   }
+
+   public void setUpdateuserid(String updateuserid) {
+      this.updateuserid = updateuserid;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/vo/auditlog/AuditBySyslogVO.java

+package com.chenyang.nse.bussiness.entity.vo.auditlog;
+
+public class AuditBySyslogVO {
+   private String userName;
+   private String from;
+   private String hostname;
+   private String message;
+   private String oTime;
+
+   public String getFrom() {
+      return this.from;
+   }
+
+   public void setFrom(String from) {
+      this.from = from;
+   }
+
+   public String getHostname() {
+      return this.hostname;
+   }
+
+   public void setHostname(String hostname) {
+      this.hostname = hostname;
+   }
+
+   public String getMessage() {
+      return this.message;
+   }
+
+   public void setMessage(String message) {
+      this.message = message;
+   }
+
+   public String getUserName() {
+      return this.userName;
+   }
+
+   public void setUserName(String userName) {
+      this.userName = userName;
+   }
+
+   public String getoTime() {
+      return this.oTime;
+   }
+
+   public void setoTime(String oTime) {
+      this.oTime = oTime;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/vo/datascope/AssignmentNameVO.java

+package com.chenyang.nse.bussiness.entity.vo.datascope;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import java.util.Date;
+
+public class AssignmentNameVO {
+   private String id;
+   private String assignment_name;
+   private String datasystem_name;
+   private String note;
+   private String create_user;
+   @JsonFormat(
+      pattern = "yyyy-MM-dd HH:mm:ss"
+   )
+   private Date create_date;
+
+   public String getTid() {
+      return this.id;
+   }
+
+   public void setTid(String id) {
+      this.id = id;
+   }
+
+   public String getAssignment_name() {
+      return this.assignment_name;
+   }
+
+   public void setAssignment_name(String assignment_name) {
+      this.assignment_name = assignment_name;
+   }
+
+   public String getDatasystem_name() {
+      return this.datasystem_name;
+   }
+
+   public void setDatasystem_name(String datasystem_name) {
+      this.datasystem_name = datasystem_name;
+   }
+
+   public String getNote() {
+      return this.note;
+   }
+
+   public void setNote(String note) {
+      this.note = note;
+   }
+
+   public String getCreate_user() {
+      return this.create_user;
+   }
+
+   public void setCreate_user(String create_user) {
+      this.create_user = create_user;
+   }
+
+   public Date getCreate_date() {
+      return this.create_date;
+   }
+
+   public void setCreate_date(Date create_date) {
+      this.create_date = create_date;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/service/core/impl/encryption/AppUserOriginalVO.java

+package com.chenyang.nse.bussiness.service.core.impl.encryption;
+
+class AppUserOriginalVO {
+   String username;
+   String isOriginal = "0";
+   String ismask = "0";
+
+   public AppUserOriginalVO() {
+   }
+
+   public String getUsername() {
+      return this.username;
+   }
+
+   public String getIsOriginal() {
+      return this.isOriginal;
+   }
+
+   public String getIsmask() {
+      return this.ismask;
+   }
+
+   public void setUsername(final String username) {
+      this.username = username;
+   }
+
+   public void setIsOriginal(final String isOriginal) {
+      this.isOriginal = isOriginal;
+   }
+
+   public void setIsmask(final String ismask) {
+      this.ismask = ismask;
+   }
+
+   public boolean equals(final Object o) {
+      if (o == this) {
+         return true;
+      } else if (!(o instanceof AppUserOriginalVO)) {
+         return false;
+      } else {
+         AppUserOriginalVO other = (AppUserOriginalVO)o;
+         if (!other.canEqual(this)) {
+            return false;
+         } else {
+            Object this$username = this.getUsername();
+            Object other$username = other.getUsername();
+            if (this$username == null) {
+               if (other$username != null) {
+                  return false;
+               }
+            } else if (!this$username.equals(other$username)) {
+               return false;
+            }
+
+            Object this$isOriginal = this.getIsOriginal();
+            Object other$isOriginal = other.getIsOriginal();
+            if (this$isOriginal == null) {
+               if (other$isOriginal != null) {
+                  return false;
+               }
+            } else if (!this$isOriginal.equals(other$isOriginal)) {
+               return false;
+            }
+
+            Object this$ismask = this.getIsmask();
+            Object other$ismask = other.getIsmask();
+            if (this$ismask == null) {
+               if (other$ismask != null) {
+                  return false;
+               }
+            } else if (!this$ismask.equals(other$ismask)) {
+               return false;
+            }
+
+            return true;
+         }
+      }
+   }
+
+   protected boolean canEqual(final Object other) {
+      return other instanceof AppUserOriginalVO;
+   }
+
+   public int hashCode() {
+      int PRIME = 59;
+      int result = 1;
+      Object $username = this.getUsername();
+      result = result * 59 + ($username == null ? 43 : $username.hashCode());
+      Object $isOriginal = this.getIsOriginal();
+      result = result * 59 + ($isOriginal == null ? 43 : $isOriginal.hashCode());
+      Object $ismask = this.getIsmask();
+      result = result * 59 + ($ismask == null ? 43 : $ismask.hashCode());
+      return result;
+   }
+
+   public String toString() {
+      return "AppUserOriginalVO(username=" + this.getUsername() + ", isOriginal=" + this.getIsOriginal() + ", ismask=" + this.getIsmask() + ")";
+   }
+}

src/main/java/com/chenyang/nse/bussiness/service/core/impl/strategy/AuditAppDataRuleServiceImpl.java

+package com.chenyang.nse.bussiness.service.core.impl.strategy;
+
+import com.chenyang.nse.bussiness.dao.table.core.strategy.audit.app.AuditAppDataRuleDao;
+import com.chenyang.nse.bussiness.dao.table.core.strategy.audit.conditions.AuditApplicationConditionsDao;
+import com.chenyang.nse.bussiness.dao.table.core.strategy.audit.conditions.AuditDateConditionsDao;
+import com.chenyang.nse.bussiness.dao.table.core.strategy.audit.conditions.AuditDbuserConditionsDao;
+import com.chenyang.nse.bussiness.dao.table.core.strategy.audit.conditions.AuditIpConditionsDao;
+import com.chenyang.nse.bussiness.engine.infa.powercenter961.pubtool.StringUtil;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.app.AuditAppDataRule;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditApplicationConditions;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditDateConditions;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditDbuserConditions;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditIpConditions;
+import com.chenyang.nse.bussiness.entity.vo.strategy.StrategeVO;
+import com.chenyang.nse.bussiness.service.core.strategy.AuditAppDataRuleService;
+import com.chenyang.nse.bussiness.tools.login.CommonUtils;
+import java.util.Date;
+import java.util.List;
+import org.hibernate.criterion.Criterion;
+import org.hibernate.criterion.Restrictions;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional
+public class AuditAppDataRuleServiceImpl implements AuditAppDataRuleService {
+   @Autowired
+   private AuditAppDataRuleDao auditAppDataRuleDao;
+   @Autowired
+   private AuditIpConditionsDao auditIpConditionsDao;
+   @Autowired
+   private AuditApplicationConditionsDao auditApplicationConditionsDao;
+   @Autowired
+   private AuditDbuserConditionsDao auditDbuserConditionsDao;
+   @Autowired
+   private AuditDateConditionsDao auditDateConditionsDao;
+
+   public void saveAppRuleInfo(AuditAppDataRule appDataRule, String id) {
+      if (StringUtil.isBlank(id)) {
+         appDataRule.setCreateuser(CommonUtils.loginUsername());
+         appDataRule.setCreatetime(new Date());
+         this.auditAppDataRuleDao.save(appDataRule);
+      } else {
+         appDataRule.setUpdateuser(CommonUtils.loginUsername());
+         appDataRule.setUpdatetime(new Date());
+         this.auditAppDataRuleDao.saveOrUpdate(appDataRule);
+      }
+
+   }
+
+   public void saveIpConditionsInfo(AuditIpConditions ipConditions) {
+      this.auditIpConditionsDao.saveOrUpdate(ipConditions);
+   }
+
+   public void saveApplicationConditionsInfo(AuditApplicationConditions applicationConditions) {
+      this.auditApplicationConditionsDao.saveOrUpdate(applicationConditions);
+   }
+
+   public void saveDbuserConditionsInfo(AuditDbuserConditions dbuserConditions) {
+      this.auditDbuserConditionsDao.saveOrUpdate(dbuserConditions);
+   }
+
+   public void saveDateConditionsInfo(AuditDateConditions dateConditions) {
+      this.auditDateConditionsDao.saveOrUpdate(dateConditions);
+   }
+
+   public List<AuditAppDataRule> getAppRuleInfoById(String id) {
+      return this.auditAppDataRuleDao.queryAll(new Criterion[]{Restrictions.eq("id", id)});
+   }
+
+   public List<AuditIpConditions> getIpConditionsInfoByRuleId(String ruleid) {
+      return this.auditIpConditionsDao.queryAll(new Criterion[]{Restrictions.eq("ruleid", ruleid)});
+   }
+
+   public List<AuditApplicationConditions> getApplicationConditionsInfoByRuleId(String ruleid) {
+      return this.auditApplicationConditionsDao.queryAll(new Criterion[]{Restrictions.eq("ruleid", ruleid)});
+   }
+
+   public List<AuditDbuserConditions> getDbuserConditionsInfoByRuleId(String ruleid) {
+      return this.auditDbuserConditionsDao.queryAll(new Criterion[]{Restrictions.eq("ruleid", ruleid)});
+   }
+
+   public List<AuditDateConditions> getDateConditionsInfoByRuleId(String ruleid) {
+      return this.auditDateConditionsDao.queryAll(new Criterion[]{Restrictions.eq("ruleid", ruleid)});
+   }
+
+   public void delAppRuleInfoById(String id) {
+      this.auditAppDataRuleDao.removeById(id);
+   }
+
+   public void delIpConditionsInfoByRuleId(String ruleid) {
+      this.auditIpConditionsDao.remove(new Criterion[]{Restrictions.eq("ruleid", ruleid)});
+   }
+
+   public void delApplicationConditionsInfoByRuleId(String ruleid) {
+      this.auditApplicationConditionsDao.remove(new Criterion[]{Restrictions.eq("ruleid", ruleid)});
+   }
+
+   public void delDbuserConditionsInfoByRuleId(String ruleid) {
+      this.auditDbuserConditionsDao.remove(new Criterion[]{Restrictions.eq("ruleid", ruleid)});
+   }
+
+   public void delDateConditionsInfoByRuleId(String ruleid) {
+      this.auditDateConditionsDao.remove(new Criterion[]{Restrictions.eq("ruleid", ruleid)});
+   }
+
+   public List<StrategeVO> queryAll() {
+      return this.auditAppDataRuleDao.queryAllStrategy();
+   }
+
+   public List<AuditAppDataRule> getAuditInfoByDatasystemid(String datasystemid) {
+      return this.auditAppDataRuleDao.queryAll(new Criterion[]{Restrictions.eq("datasourceid", datasystemid), Restrictions.eq("auditswitch", "1")});
+   }
+}

src/main/java/com/chenyang/nse/bussiness/service/core/strategy/AuditAppDataRuleService.java

+package com.chenyang.nse.bussiness.service.core.strategy;
+
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.app.AuditAppDataRule;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditApplicationConditions;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditDateConditions;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditDbuserConditions;
+import com.chenyang.nse.bussiness.entity.orm.table.core.strategy.audit.conditions.AuditIpConditions;
+import com.chenyang.nse.bussiness.entity.vo.strategy.StrategeVO;
+import java.util.List;
+
+public interface AuditAppDataRuleService {
+   void saveAppRuleInfo(AuditAppDataRule appDataRule, String id);
+
+   void saveIpConditionsInfo(AuditIpConditions ipConditions);
+
+   void saveApplicationConditionsInfo(AuditApplicationConditions applicationConditions);
+
+   void saveDbuserConditionsInfo(AuditDbuserConditions dbuserConditions);
+
+   void saveDateConditionsInfo(AuditDateConditions dateConditions);
+
+   List<AuditAppDataRule> getAppRuleInfoById(String id);
+
+   List<AuditIpConditions> getIpConditionsInfoByRuleId(String ruleid);
+
+   List<AuditApplicationConditions> getApplicationConditionsInfoByRuleId(String ruleid);
+
+   List<AuditDbuserConditions> getDbuserConditionsInfoByRuleId(String ruleid);
+
+   List<AuditDateConditions> getDateConditionsInfoByRuleId(String ruleid);
+
+   void delAppRuleInfoById(String id);
+
+   void delIpConditionsInfoByRuleId(String ruleid);
+
+   void delApplicationConditionsInfoByRuleId(String ruleid);
+
+   void delDbuserConditionsInfoByRuleId(String ruleid);
+
+   void delDateConditionsInfoByRuleId(String ruleid);
+
+   List<StrategeVO> queryAll();
+
+   List<AuditAppDataRule> getAuditInfoByDatasystemid(String datasystemid);
+}

src/main/java/com/chenyang/nse/bussiness/tools/dataprocess/ApplicationContextProvider.java

+package com.chenyang.nse.bussiness.tools.dataprocess;
+
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ApplicationContextProvider implements ApplicationContextAware {
+   private static ApplicationContext applicationContext;
+
+   public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+      ApplicationContextProvider.applicationContext = applicationContext;
+   }
+
+   public static ApplicationContext getApplicationContext() {
+      return applicationContext;
+   }
+
+   public static Object getBean(String name) {
+      return getApplicationContext().getBean(name);
+   }
+
+   public static <T> T getBean(Class<T> clazz) {
+      return (T)getApplicationContext().getBean(clazz);
+   }
+
+   public static <T> T getBean(String name, Class<T> clazz) {
+      return (T)getApplicationContext().getBean(name, clazz);
+   }
+}

src/main/java/com/chenyang/nse/bussiness/tools/logger/applog/ApplogService.java

+package com.chenyang.nse.bussiness.tools.logger.applog;
+
+import com.chenyang.nse.bussiness.config.PropertiesLoaderUtils;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.net.HttpURLConnection;
+import java.net.SocketAddress;
+import java.net.URL;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Properties;
+import org.graylog2.syslog4j.server.SyslogServer;
+import org.graylog2.syslog4j.server.SyslogServerConfigIF;
+import org.graylog2.syslog4j.server.SyslogServerEventIF;
+import org.graylog2.syslog4j.server.SyslogServerIF;
+import org.graylog2.syslog4j.server.SyslogServerSessionEventHandlerIF;
+import org.graylog2.syslog4j.server.impl.net.udp.UDPNetSyslogServerConfig;
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ApplogService implements ApplicationContextAware {
+   protected static ApplicationContext applicationContext;
+   private static Properties props = new Properties();
+   private static String filepath = "";
+   private static String appAlertInterface = "";
+   private static String HOST = "192.168.2.212";
+   private static Integer PORT = 32376;
+   private static final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+   private static FileOutputStream outputStream = null;
+
+   private void receiveSyslogMessage() throws InterruptedException {
+      SyslogServerIF server = SyslogServer.getInstance("udp");
+      UDPNetSyslogServerConfig udpConfig = (UDPNetSyslogServerConfig)server.getConfig();
+      udpConfig.setMaxMessageSize(10240);
+      SyslogServerConfigIF config = server.getConfig();
+      config.setHost(HOST);
+      config.setPort(PORT);
+      config.addEventHandler(new SyslogServerSessionEventHandlerIF() {
+         public Object sessionOpened(SyslogServerIF syslogServerIF, SocketAddress socketAddress) {
+            return null;
+         }
+
+         public void event(Object o, SyslogServerIF syslogServerIF, SocketAddress socketAddress, SyslogServerEventIF syslogServerEventIF) {
+            String sendvalue = "{\"from\": \"" + socketAddress.toString().replace("/", "").split("\\:")[0] + "\",\"hostname\":\"" + syslogServerEventIF.getHost() + "\"," + syslogServerEventIF.getMessage().replace(syslogServerEventIF.getHost(), "\"message\":") + "}\n";
+            File file = null;
+            if (sendvalue.contains("\"type\":\"2\"")) {
+               file = new File(ApplogService.filepath + File.separator + "audit" + File.separator + ApplogService.sdf.format(new Date()) + ".txt");
+            } else if (sendvalue.contains("\"type\":\"1\"")) {
+               if (sendvalue.contains("\"auditswitch\":\"0\"")) {
+                  file = new File(ApplogService.filepath + File.separator + "masking" + File.separator + ApplogService.sdf.format(new Date()) + ".txt");
+                  ApplogService.interfaceUtil(ApplogService.appAlertInterface, "");
+               } else if (sendvalue.contains("\"auditswitch\":\"1\"")) {
+                  file = new File(ApplogService.filepath + File.separator + "masking" + File.separator + ApplogService.sdf.format(new Date()) + ".txt");
+               }
+            }
+
+            if (!file.exists()) {
+               try {
+                  file.getParentFile().mkdirs();
+                  file.createNewFile();
+               } catch (Exception e) {
+                  e.printStackTrace();
+               }
+            }
+
+            try {
+               ApplogService.outputStream = new FileOutputStream(file, true);
+               ApplogService.outputStream.write(sendvalue.getBytes());
+            } catch (Exception e) {
+               e.printStackTrace();
+            } finally {
+               try {
+                  ApplogService.outputStream.close();
+               } catch (IOException e) {
+                  e.printStackTrace();
+               }
+
+            }
+
+         }
+
+         public void exception(Object o, SyslogServerIF syslogServerIF, SocketAddress socketAddress, Exception e) {
+         }
+
+         public void sessionClosed(Object o, SyslogServerIF syslogServerIF, SocketAddress socketAddress, boolean b) {
+         }
+
+         public void initialize(SyslogServerIF syslogServerIF) {
+         }
+
+         public void destroy(SyslogServerIF syslogServerIF) {
+         }
+      });
+      SyslogServer.getThreadedInstance("udp");
+   }
+
+   public static void interfaceUtil(String path, String data) {
+      try {
+         URL url = new URL(path);
+         HttpURLConnection conn = (HttpURLConnection)url.openConnection();
+         PrintWriter out = null;
+         conn.setRequestProperty("accept", "*/*");
+         conn.setRequestProperty("connection", "Keep-Alive");
+         conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");
+         conn.setDoOutput(true);
+         conn.setDoInput(true);
+         out = new PrintWriter(conn.getOutputStream());
+         out.print(data);
+         out.flush();
+         InputStream is = conn.getInputStream();
+         BufferedReader br = new BufferedReader(new InputStreamReader(is));
+         String str = "";
+
+         while((str = br.readLine()) != null) {
+            System.out.println(str);
+         }
+
+         is.close();
+         conn.disconnect();
+         System.out.println("告警结束");
+      } catch (Exception e) {
+         e.printStackTrace();
+      }
+
+   }
+
+   public void setApplicationContext(ApplicationContext arg0) throws BeansException {
+      if (applicationContext == null) {
+         applicationContext = arg0;
+      }
+
+   }
+
+   public static void main(String[] args) throws InterruptedException {
+      (new ApplogService()).receiveSyslogMessage();
+   }
+
+   public static void execute() throws InterruptedException {
+      (new ApplogService()).receiveSyslogMessage();
+   }
+
+   static {
+      try {
+         props = PropertiesLoaderUtils.loadAllProperties("config.properties");
+         filepath = props.getProperty("appserverlogpath");
+         appAlertInterface = props.getProperty("app_alert_interface");
+         HOST = props.getProperty("applogServerHost");
+         PORT = Integer.parseInt(props.getProperty("applogServerPort"));
+      } catch (IOException e) {
+         e.printStackTrace();
+      }
+
+   }
+}

src/main/resources/sql/assignmentname.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper>
+		<!-- 查询任务列表 -->
+		<select id="selectAssignmentNameList">		
+		SELECT
+		  an.id id,
+		  an.assignment_name assignment_name,
+		  ds.sysname	 datasystem_name,
+		  an.create_user,
+		  an.create_date
+		FROM
+			t_core_assignment_name an,
+			t_core_datasystem ds
+		WHERE
+			an.datasystem_id = ds.id
+			and an.assignment_name like (CONCAT('%',:tname, '%')) order by an.create_date desc
+		</select>		
+
+
+
+
+
+
+</mapper>
+