新版本

src/main/java/com/chenyang/nse/bussiness/engine/infa/basic/wsclient/DIServerDate.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 = "DIServerDate",
+   propOrder = {"date", "nanoSeconds", "seconds", "minutes", "hours", "month", "year", "utcTime"}
+)
+public class DIServerDate {
+   @XmlElement(
+      name = "Date"
+   )
+   protected int date;
+   @XmlElement(
+      name = "NanoSeconds"
+   )
+   protected int nanoSeconds;
+   @XmlElement(
+      name = "Seconds"
+   )
+   protected int seconds;
+   @XmlElement(
+      name = "Minutes"
+   )
+   protected int minutes;
+   @XmlElement(
+      name = "Hours"
+   )
+   protected int hours;
+   @XmlElement(
+      name = "Month"
+   )
+   protected int month;
+   @XmlElement(
+      name = "Year"
+   )
+   protected int year;
+   @XmlElement(
+      name = "UTCTime"
+   )
+   protected int utcTime;
+
+   public int getDate() {
+      return this.date;
+   }
+
+   public void setDate(int value) {
+      this.date = value;
+   }
+
+   public int getNanoSeconds() {
+      return this.nanoSeconds;
+   }
+
+   public void setNanoSeconds(int value) {
+      this.nanoSeconds = value;
+   }
+
+   public int getSeconds() {
+      return this.seconds;
+   }
+
+   public void setSeconds(int value) {
+      this.seconds = value;
+   }
+
+   public int getMinutes() {
+      return this.minutes;
+   }
+
+   public void setMinutes(int value) {
+      this.minutes = value;
+   }
+
+   public int getHours() {
+      return this.hours;
+   }
+
+   public void setHours(int value) {
+      this.hours = value;
+   }
+
+   public int getMonth() {
+      return this.month;
+   }
+
+   public void setMonth(int value) {
+      this.month = value;
+   }
+
+   public int getYear() {
+      return this.year;
+   }
+
+   public void setYear(int value) {
+      this.year = value;
+   }
+
+   public int getUTCTime() {
+      return this.utcTime;
+   }
+
+   public void setUTCTime(int value) {
+      this.utcTime = value;
+   }
+}

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

+package com.chenyang.nse.bussiness.entity.vo;
+
+import java.util.Date;
+
+public class DiscoveryMonitorVO {
+   private String id;
+   private String projectid;
+   private String taskname;
+   private String projectname;
+   private String discoverytype;
+   private String isdmpflag;
+   private Date createtime;
+
+   public String getId() {
+      return this.id;
+   }
+
+   public void setId(String id) {
+      this.id = id;
+   }
+
+   public String getProjectid() {
+      return this.projectid;
+   }
+
+   public void setProjectid(String projectid) {
+      this.projectid = projectid;
+   }
+
+   public String getTaskname() {
+      return this.taskname;
+   }
+
+   public void setTaskname(String taskname) {
+      this.taskname = taskname;
+   }
+
+   public String getProjectname() {
+      return this.projectname;
+   }
+
+   public void setProjectname(String projectname) {
+      this.projectname = projectname;
+   }
+
+   public Date getCreatetime() {
+      return this.createtime;
+   }
+
+   public void setCreatetime(Date createtime) {
+      this.createtime = createtime;
+   }
+
+   public String getDiscoverytype() {
+      return this.discoverytype;
+   }
+
+   public void setDiscoverytype(String discoverytype) {
+      this.discoverytype = discoverytype;
+   }
+
+   public String getIsdmpflag() {
+      return this.isdmpflag;
+   }
+
+   public void setIsdmpflag(String isdmpflag) {
+      this.isdmpflag = isdmpflag;
+   }
+}

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

+package com.chenyang.nse.bussiness.entity.vo;
+
+import java.util.List;
+
+public class DiscoveryParamVO {
+   private String code;
+   private String schema;
+   private String tablename;
+   private List<String> fields;
+
+   public String getCode() {
+      return this.code;
+   }
+
+   public void setCode(String code) {
+      this.code = code;
+   }
+
+   public String getSchema() {
+      return this.schema;
+   }
+
+   public void setSchema(String schema) {
+      this.schema = schema;
+   }
+
+   public String getTablename() {
+      return this.tablename;
+   }
+
+   public void setTablename(String tablename) {
+      this.tablename = tablename;
+   }
+
+   public List<String> getFields() {
+      return this.fields;
+   }
+
+   public void setFields(List<String> fields) {
+      this.fields = fields;
+   }
+}

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

+package com.chenyang.nse.bussiness.entity.vo;
+
+public class DiscoveryResultVO {
+   private String tablename;
+   private String nschema;
+   private String ntable;
+   private String nfield;
+   private String nareaid;
+   private String nareaname;
+   private String ntruleid;
+   private String ntrulename;
+   private String issure;
+   private String checksure;
+   private String issensitive;
+
+   public String getNareaid() {
+      return this.nareaid;
+   }
+
+   public void setNareaid(String nareaid) {
+      this.nareaid = nareaid;
+   }
+
+   public String getNtruleid() {
+      return this.ntruleid;
+   }
+
+   public void setNtruleid(String ntruleid) {
+      this.ntruleid = ntruleid;
+   }
+
+   public String getIssure() {
+      return this.issure;
+   }
+
+   public void setIssure(String issure) {
+      this.issure = issure;
+   }
+
+   public String getIssensitive() {
+      return this.issensitive;
+   }
+
+   public void setIssensitive(String issensitive) {
+      this.issensitive = issensitive;
+   }
+
+   public String getTablename() {
+      return this.tablename;
+   }
+
+   public void setTablename(String tablename) {
+      this.tablename = tablename;
+   }
+
+   public String getNschema() {
+      return this.nschema;
+   }
+
+   public void setNschema(String nschema) {
+      this.nschema = nschema;
+   }
+
+   public String getNtable() {
+      return this.ntable;
+   }
+
+   public void setNtable(String ntable) {
+      this.ntable = ntable;
+   }
+
+   public String getNfield() {
+      return this.nfield;
+   }
+
+   public void setNfield(String nfield) {
+      this.nfield = nfield;
+   }
+
+   public String getNareaname() {
+      return this.nareaname;
+   }
+
+   public void setNareaname(String nareaname) {
+      this.nareaname = nareaname;
+   }
+
+   public String getNtrulename() {
+      return this.ntrulename;
+   }
+
+   public void setNtrulename(String ntrulename) {
+      this.ntrulename = ntrulename;
+   }
+
+   public String getChecksure() {
+      return this.checksure;
+   }
+
+   public void setChecksure(String checksure) {
+      this.checksure = checksure;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/performance_monitor/entity/DSApiResponseMsg.java

+package com.chenyang.nse.bussiness.performance_monitor.entity;
+
+public class DSApiResponseMsg extends CoreApiResponseMsg {
+}

src/main/java/com/chenyang/nse/bussiness/performance_monitor/entity/DSConstant.java

+package com.chenyang.nse.bussiness.performance_monitor.entity;
+
+public class DSConstant {
+   public static final String SYS_ERROR_CODE = "SE000001";
+   public static final String SYS_ERROR_MSG = "系统异常，请与系统管理员联系";
+   public static final String DATASET_NAME_REPEAT_2 = "数据集名称重复,请修改后重试！";
+   public static final String DATASET_AUTHORITY_NAME_REPEAT_2 = "规则名称重复,请修改后重试！";
+   public static final String STOP_PSERVER_SUCCESS = "代理服务器停止成功";
+   public static final String DEL_SYS_DB_DIRECTIVE_MSG = "系统内置模板不可删除";
+}

src/main/java/com/chenyang/nse/bussiness/service/console/DictionaryService.java

+package com.chenyang.nse.bussiness.service.console;
+
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.entity.orm.table.console.TConsoleDictionary;
+import com.chenyang.nse.bussiness.entity.orm.table.console.TConsoleDictionarytype;
+import com.chenyang.nse.bussiness.entity.orm.table.core.discovery.TcoreDiscoverySensitivecolumn;
+import com.chenyang.nse.bussiness.entity.vo.RegexTypeColorVO;
+import java.util.List;
+import java.util.Map;
+
+public interface DictionaryService {
+   List<TConsoleDictionarytype> getDictinaryTypesbytypename(String typename);
+
+   List<TConsoleDictionary> getDictinaryByname(String typename);
+
+   List<String> querySingleFirstName();
+
+   List<String> queryDoubleFirstName();
+
+   List<String> queryFirstTwoNumOfIdentifyNo();
+
+   List<String> queryProvinceAndCity();
+
+   List<String> queryDictionaryValues(String typeCode);
+
+   List<TConsoleDictionary> queryRuleType();
+
+   void save(String regexTypeName, String regexTypeColor);
+
+   String queryRegexTypeColor(String regexTypeName);
+
+   List<RegexTypeColorVO> queryAllRegexTypeColor();
+
+   List<String> queryAllRegexTypes();
+
+   void delete(String regexTypeName);
+
+   List<TConsoleDictionary> query(String fuzzySearch, String typecode, String value, PageInfo pageInfo);
+
+   List<TConsoleDictionary> query(String typecode, String value, PageInfo pageInfo);
+
+   List<TConsoleDictionarytype> getDictinaryTypes();
+
+   void removeSum(List<String> idlist);
+
+   void remove(String rowid);
+
+   TConsoleDictionary initEditRude(String rowid, String typecode);
+
+   void save(TConsoleDictionary dictionary);
+
+   void addDictionaryType(TConsoleDictionarytype dictionaryType);
+
+   long queryDictionaryTypeCount(String typename);
+
+   List<TConsoleDictionary> querySensitiveTypes();
+
+   List<String> querySensitiveTypeNames();
+
+   void sortSensitiveTypes(List<String> ids);
+
+   List<TcoreDiscoverySensitivecolumn> queryTcoreDiscoverySensitivecolumn(String groupid, String taskversion);
+
+   void tcoreDiscoverySensitivecolumnSave(TcoreDiscoverySensitivecolumn tcoreDiscoverySensitivecolumn);
+
+   List<TConsoleDictionary> queryAll(PageInfo pageInfo);
+
+   List<TConsoleDictionarytype> queryBycode(String code);
+
+   void removetype(String typecode);
+
+   void removeDictionaryType(List<String> idlist);
+
+   List<TConsoleDictionary> queryDictionaryByTypeCode(String typecode, PageInfo pageInfo, Map<String, Object> params);
+
+   TConsoleDictionary initEditDictionary(String id);
+
+   TConsoleDictionarytype initEditDictionaryType(String id);
+}

src/main/java/com/chenyang/nse/bussiness/service/core/DiscoveryConditionService.java

+package com.chenyang.nse.bussiness.service.core;
+
+import com.chenyang.nse.bussiness.entity.orm.table.core.discovery.TcoreDiscoveryCondition;
+import java.util.List;
+
+public interface DiscoveryConditionService {
+   List<TcoreDiscoveryCondition> queryDiscoveryConditionByTaskId(String taskid);
+
+   void saveDiscoveryConditionParamter(List<TcoreDiscoveryCondition> tcoreSensitivesearchlog, String groupId);
+
+   void delDiscoveryConditiontablelog(String groupid);
+}

src/main/java/com/chenyang/nse/bussiness/service/core/DiscoveryResultsRecordService.java

+package com.chenyang.nse.bussiness.service.core;
+
+import com.chenyang.nse.bussiness.entity.orm.table.core.discovery.TcoreDiscoveryResultsRecord;
+
+public interface DiscoveryResultsRecordService {
+   void save(TcoreDiscoveryResultsRecord tcoreDiscoveryResultsRecord);
+}

src/main/java/com/chenyang/nse/bussiness/service/core/DiscoverySensitivecolumnService.java

+package com.chenyang.nse.bussiness.service.core;
+
+import com.chenyang.nse.bussiness.entity.orm.table.core.discovery.TcoreDiscoverySensitivecolumn;
+import java.util.List;
+
+public interface DiscoverySensitivecolumnService {
+   List<TcoreDiscoverySensitivecolumn> querySensitiveColumnsByGroupIdByVersion(String groupid, String version);
+
+   List<TcoreDiscoverySensitivecolumn> querySensitiveColumnsByGroupIdByVersionByCheck(String groupid, String version, String check);
+
+   void save(TcoreDiscoverySensitivecolumn tcoreDiscoverySensitivecolumn);
+
+   List<TcoreDiscoverySensitivecolumn> getSensitiveByIdBySchema(String datasystemid, String schema, String table);
+
+   void saveTcoreDiscoverySensitivecolumn(StringBuilder sql);
+}

src/main/java/com/chenyang/nse/bussiness/service/core/DiscoveryVersrionService.java

+package com.chenyang.nse.bussiness.service.core;
+
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.entity.orm.table.core.discovery.TcoreDiscoveryVersrion;
+import java.util.List;
+
+public interface DiscoveryVersrionService {
+   List<TcoreDiscoveryVersrion> queryTcoreDiscoveryVersriont(PageInfo pageInfo, String taskid);
+
+   List<TcoreDiscoveryVersrion> queryTcoreDiscoveryVersriont(String taskid, String version);
+
+   void save(TcoreDiscoveryVersrion tcoreDiscoveryVersrion);
+}

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

+package com.chenyang.nse.bussiness.service.core.impl;
+
+import com.chenyang.nse.bussiness.dao.table.core.dataproject.TcoreDiscoveryResultsRecordDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.discovery.TcoreDiscoveryResultsRecord;
+import com.chenyang.nse.bussiness.service.core.DiscoveryResultsRecordService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional
+public class DiscoveryResultsRecordServiceImpl implements DiscoveryResultsRecordService {
+   @Autowired
+   private TcoreDiscoveryResultsRecordDao tcoreDiscoveryResultsRecordDao;
+
+   public void save(TcoreDiscoveryResultsRecord tcoreDiscoveryResultsRecord) {
+      this.tcoreDiscoveryResultsRecordDao.save(tcoreDiscoveryResultsRecord);
+   }
+}

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

+package com.chenyang.nse.bussiness.service.core.impl;
+
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.dao.table.core.TcoreDiscoveryVersrionDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.discovery.TcoreDiscoveryVersrion;
+import com.chenyang.nse.bussiness.service.core.DiscoveryVersrionService;
+import java.util.List;
+import org.hibernate.criterion.Criterion;
+import org.hibernate.criterion.Order;
+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 DiscoveryVersrionServiceImpl implements DiscoveryVersrionService {
+   @Autowired
+   private TcoreDiscoveryVersrionDao tcoreDiscoveryVersrionDao;
+
+   public List<TcoreDiscoveryVersrion> queryTcoreDiscoveryVersriont(PageInfo pageInfo, String taskid) {
+      List<TcoreDiscoveryVersrion> list = this.tcoreDiscoveryVersrionDao.queryByPageInfo(pageInfo, Order.desc("createtime"), new Criterion[]{Restrictions.eq("taskid", taskid)});
+      return list;
+   }
+
+   public List<TcoreDiscoveryVersrion> queryTcoreDiscoveryVersriont(String taskid, String version) {
+      List<TcoreDiscoveryVersrion> list = this.tcoreDiscoveryVersrionDao.queryAll(new Criterion[]{Restrictions.eq("taskid", taskid), Restrictions.eq("taskversion", version)});
+      return list;
+   }
+
+   public void save(TcoreDiscoveryVersrion tcoreDiscoveryVersrion) {
+      this.tcoreDiscoveryVersrionDao.save(tcoreDiscoveryVersrion);
+   }
+}

src/main/java/com/chenyang/nse/bussiness/tools/dmp/DmpCommonTool.java

+package com.chenyang.nse.bussiness.tools.dmp;
+
+public class DmpCommonTool {
+   static char[] map = new char[]{'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
+
+   public static int binary16_10(String str) {
+      return Integer.parseInt(str, 16);
+   }
+
+   public static String subZeroAndDot(String s) {
+      if (s.indexOf(".") > 0) {
+         s = s.replaceAll("0+?$", "");
+         s = s.replaceAll("[.]$", "");
+      }
+
+      return s;
+   }
+
+   public static String toHex(byte b) {
+      int i = b & 255;
+      String s = "";
+      if (null != Integer.toHexString(i)) {
+         s = Integer.toHexString(i).toUpperCase();
+         if (s.length() == 1) {
+            s = '0' + s;
+         }
+      } else {
+         System.out.println("btye is:" + b + ":toHex 方法：十进制数转换为十六进制字符串时返回了NULL!");
+      }
+
+      return s;
+   }
+
+   public static String toInt(byte b) {
+      int i = b & 255;
+      String s = "";
+      s = s + i;
+      return s;
+   }
+
+   public static String intToHex(int num) {
+      if (num == 0) {
+         return "0";
+      } else {
+         String result;
+         for(result = ""; num != 0; num >>>= 4) {
+            int x = num & 15;
+            result = map[x] + result;
+         }
+
+         return result;
+      }
+   }
+}

src/main/java/com/chenyang/nse/bussiness/tools/xml/xmlclass/product/DmainsInfa.java

+package com.chenyang.nse.bussiness.tools.xml.xmlclass.product;
+
+public class DmainsInfa {
+   private String name;
+   private String value;
+
+   public String getName() {
+      return this.name;
+   }
+
+   public void setName(String name) {
+      this.name = name;
+   }
+
+   public String getValue() {
+      return this.value;
+   }
+
+   public void setValue(String value) {
+      this.value = value;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/tools/xml/xmlclass/product/DomainOptions.java

+package com.chenyang.nse.bussiness.tools.xml.xmlclass.product;
+
+public class DomainOptions {
+   private String name;
+   private String value;
+
+   public String getName() {
+      return this.name;
+   }
+
+   public void setName(String name) {
+      this.name = name;
+   }
+
+   public String getValue() {
+      return this.value;
+   }
+
+   public void setValue(String value) {
+      this.value = value;
+   }
+}

src/main/resources/sql/duty.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<sqls>
+	<!-- *****************查询****************  -->
+	<select id="selectDutyPerson">
+		select
+		id,
+		duty_id,
+		duty_name,
+		u.realname realname,
+		duty_scope,
+		duty_main,
+		datasystemid,
+		p.createtime,
+		p.updatetime
+		from t_duty_person p left join t_base_user u on u.tid = p.duty_id 
+		where duty_scope = :duty_scope
+		and datasystemid = :datasystemid and projectid = :projectid
+	</select>
+
+	<!-- *****************查询****************  -->
+	<select id="selectDutyPerson">
+		select
+		id,
+		duty_id,
+		duty_name,
+		u.realname realname,
+		duty_scope,
+		duty_main,
+		datasystemid,
+		p.createtime,
+		p.updatetime
+		from t_duty_person p left join t_base_user u on u.tid = p.duty_id 
+		where duty_scope = :duty_scope
+		and datasystemid = :datasystemid and projectid = :projectid
+	</select>
+
+	<select id="isExistPerson">
+		select
+		id,
+		duty_id,
+		duty_name,
+		duty_scope,
+		duty_main,
+		datasystemid,
+		createtime,
+		updatetime
+		from t_duty_person
+		where duty_scope = :duty_scope
+		and datasystemid = :datasystemid
+		and duty_id = :duty_id
+	</select>
+
+	<select id="saveDutyPerson">
+		INSERT INTO t_duty_person (
+		duty_id,
+		duty_name,
+		duty_scope,
+		duty_main,
+		datasystemid,
+		createtime,
+		updatetime,
+		projectid
+		)
+		VALUES
+		(
+		:duty_id,
+		:duty_name,
+		:duty_scope,
+		:duty_main,
+		:datasystemid,
+		current_timestamp(),
+		current_timestamp(),
+		:projectid
+		)
+	</select>
+
+	<select id="updateDutyPerson">
+		update t_duty_person
+		set duty_scope = :duty_scope,
+			duty_main = :duty_main,
+			duty_id = :duty_id,
+			duty_name = :duty_name
+		where id = :id
+	</select>
+
+	<select id="delDutyPersonById">
+		delete
+		from t_duty_person
+		where id = :id
+	</select>
+
+
+
+</sqls>
+