新版本

src/main/java/com/chenyang/nse/bussiness/controller/console/DictionaryController.java

+package com.chenyang.nse.bussiness.controller.console;
+
+import com.chenyang.nse.bussiness.commmon.json.RespHelper;
+import com.chenyang.nse.bussiness.commmon.json.Response;
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.engine.infa.powercenter961.pubtool.StringUtil;
+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.vo.ComboboxVO;
+import com.chenyang.nse.bussiness.service.console.DictionaryService;
+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.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+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.stereotype.Controller;
+import org.springframework.ui.Model;
+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({"/console/dictionary"})
+public class DictionaryController {
+   @Autowired
+   private DictionaryService dictionaryService;
+   private static final Logger ddmauditLogger = LoggerFactory.getLogger("ddmauditLogger");
+   private static final Logger operationLogger = LoggerFactory.getLogger("operationLogger");
+
+   @RequestMapping
+   public String index(HttpServletRequest request, HttpServletResponse response, Model model) {
+      return "console/dictionary";
+   }
+
+   @GetMapping({"/getDictinaryTypes"})
+   @ResponseBody
+   public Response getDictinaryTypes(@RequestBody(required = false) Map<String, Object> params) {
+      List<ComboboxVO> list = new ArrayList();
+
+      for(TConsoleDictionarytype type : this.dictionaryService.getDictinaryTypes()) {
+         list.add(new ComboboxVO(type.getTypecode() + "", type.getTypename()));
+      }
+
+      return RespHelper.successResp(list);
+   }
+
+   @PostMapping({"/addDictionaryType"})
+   @ResponseBody
+   public Response addDictionaryType(@RequestBody(required = false) Map<String, Object> params) {
+      TConsoleDictionarytype dictionaryType = null;
+      if (null != params) {
+         dictionaryType = (TConsoleDictionarytype)ObjectTool.getObjectByMap(TConsoleDictionarytype.class, (Map)params.get("dictionaryType"));
+      } else {
+         dictionaryType = new TConsoleDictionarytype();
+         dictionaryType.setTypename("test分类");
+         dictionaryType.setRemark("asfdasdf");
+      }
+
+      new HashMap();
+      long typeCount = this.dictionaryService.queryDictionaryTypeCount(dictionaryType.getTypename());
+      if (StringUtil.isBlank(dictionaryType.getId())) {
+         ddmauditLogger.info(MesUtil.getMsg("DDM_00810", new String[]{CommonUtils.loginUsername(), dictionaryType.getTypename()}));
+      } else {
+         ddmauditLogger.info(MesUtil.getMsg("DDM_00811", new String[]{CommonUtils.loginUsername(), dictionaryType.getTypename()}));
+      }
+
+      this.dictionaryService.addDictionaryType(dictionaryType);
+      return RespHelper.successResp();
+   }
+
+   @PostMapping({"/delDictionaryType"})
+   @ResponseBody
+   public Response delDictionaryType(@RequestBody(required = false) Map<String, Object> params) {
+      List<String> idlist = new ArrayList();
+      String dictionaryTypeCode = "";
+      String dictionaryTypeName = "";
+      if (null != params) {
+         dictionaryTypeCode = (String)params.get("dictionaryTypeCode");
+         dictionaryTypeName = (String)params.get("dictionaryTypeName");
+      } else if (StringUtil.isBlank(dictionaryTypeCode)) {
+         dictionaryTypeCode = "28";
+         dictionaryTypeName = "402882eb70f190c80170f19b23e40002";
+      }
+
+      ddmauditLogger.info(MesUtil.getMsg("DDM_00812", new String[]{CommonUtils.loginUsername(), dictionaryTypeName}));
+      idlist.add(dictionaryTypeCode);
+      this.dictionaryService.removeDictionaryType(idlist);
+      return RespHelper.successResp();
+   }
+
+   @PostMapping({"/query"})
+   @ResponseBody
+   public Response query(@RequestBody(required = false) Map<String, Object> params) {
+      PageInfo pageInfo = new PageInfo();
+      String typecode = "";
+      String typename = "";
+      if (null != params) {
+         Integer page = (Integer)params.get("pageno");
+         Integer rows = (Integer)params.get("pagesize");
+         System.out.println();
+         pageInfo.setPageno(page);
+         pageInfo.setPagesize(rows);
+         pageInfo.setPageno(1);
+         pageInfo.setPagesize(10);
+         typecode = (String)params.get("typecode");
+         typename = (String)params.get("typename");
+      } else {
+         pageInfo.setPageno(1);
+         pageInfo.setPagesize(10);
+         typecode = "21";
+         typename = "test";
+      }
+
+      ddmauditLogger.info(MesUtil.getMsg("DDM_00813", new String[]{CommonUtils.loginUsername(), "code:" + typename}));
+      List<TConsoleDictionary> list = this.dictionaryService.queryDictionaryByTypeCode(typecode, pageInfo, params);
+      return RespHelper.updateResp(pageInfo, list);
+   }
+
+   @RequestMapping({"/add"})
+   public void add(TConsoleDictionary dictionary, HttpServletRequest request, HttpServletResponse response, Model model) {
+      this.dictionaryService.save(dictionary);
+   }
+
+   @RequestMapping({"/remove"})
+   public void remove(@RequestParam("idlist[]") List<String> idlist, HttpServletRequest request, HttpServletResponse response, Model model) {
+   }
+}

src/main/java/com/chenyang/nse/bussiness/controller/core/DgCommandRuleController.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.dao.PageInfo;
+import com.chenyang.nse.bussiness.service.core.DgCommandRuleService;
+import java.util.List;
+import java.util.Map;
+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.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/dbrulelog"})
+public class DgCommandRuleController {
+   private static Logger logger = LoggerFactory.getLogger(ControlledAssetController.class);
+   @Autowired
+   private DgCommandRuleService dgCommandRuleService;
+   private static final Logger ddmauditLogger = LoggerFactory.getLogger("ddmauditLogger");
+   private static final Logger operationLogger = LoggerFactory.getLogger("operationLogger");
+
+   @RequestMapping({"/queryAll"})
+   @ResponseBody
+   public Response query(@RequestParam Map<String, String> params, Integer pageno, Integer pagesize, PageInfo pageInfo, HttpServletRequest request, HttpServletResponse response, Model model) {
+      pageInfo.setPageno(pageno);
+      pageInfo.setPagesize(pagesize);
+      String ruletype = (String)params.get("ruletype");
+      String createuser = (String)params.get("createuser");
+      String datasourceid = (String)params.get("datasourceid");
+      List<Map<String, Object>> list = this.dgCommandRuleService.queryAll(pageInfo, ruletype, createuser, datasourceid);
+      return RespHelper.successResp(list, pageInfo.getCount().intValue());
+   }
+}

src/main/java/com/chenyang/nse/bussiness/controller/core/DictionartFileController.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.entity.orm.table.console.TConsoleDictionary;
+import com.chenyang.nse.bussiness.entity.orm.table.console.TConsoleDictionarytype;
+import com.chenyang.nse.bussiness.entity.vo.DictionartFileVO;
+import com.chenyang.nse.bussiness.entity.vo.ExportExcel;
+import com.chenyang.nse.bussiness.service.console.DictionaryService;
+import com.chenyang.nse.bussiness.service.core.DictionartFileService;
+import com.chenyang.nse.bussiness.tools.msg.MesUtil;
+import java.io.IOException;
+import java.io.InputStream;
+import java.lang.reflect.InvocationTargetException;
+import java.text.SimpleDateFormat;
+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.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.ss.usermodel.Row;
+import org.apache.poi.ss.usermodel.Sheet;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.util.ObjectUtils;
+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;
+import org.springframework.web.multipart.MultipartFile;
+
+@Controller
+@RequestMapping({"/core/dictionaryexcel"})
+public class DictionartFileController {
+   @Autowired
+   private DictionartFileService dictionartFileService;
+   @Autowired
+   private DictionaryService dictionaryService;
+
+   @PostMapping({"/export"})
+   @ResponseBody
+   public Response export(HttpServletResponse response, @RequestBody(required = false) Map typecode) {
+      List<DictionartFileVO> list = this.dictionartFileService.queryDictionaryFile((String)typecode.get("typecode"));
+      ExportExcel<DictionartFileVO> ee = new ExportExcel<DictionartFileVO>();
+      String[] headers = new String[]{"分类", "分类编码", "值", "名称", "父值"};
+      String fileName = "发现规则知识库";
+      ee.exportExcel(headers, list, fileName, response);
+      return RespHelper.successResp();
+   }
+
+   @PostMapping({"/importfile"})
+   @ResponseBody
+   public Response importfile(@RequestParam("fileUpload") MultipartFile excelFile, String smart, HttpServletRequest request) throws IllegalAccessException, IllegalArgumentException, InvocationTargetException {
+      InputStream in = null;
+      String fileName = excelFile.getOriginalFilename();
+      if (ObjectUtils.isEmpty(excelFile) && ObjectUtils.isEmpty(smart)) {
+         return RespHelper.createResp(false, "POP_00022", MesUtil.getMsg("POP_00022", new String[0]));
+      } else {
+         try {
+            in = excelFile.getInputStream();
+            Workbook wb = null;
+            String fileType = fileName.substring(fileName.lastIndexOf("."));
+            if (".xls".equals(fileType)) {
+               wb = new HSSFWorkbook(in);
+            } else if (".xlsx".equals(fileType)) {
+               wb = new XSSFWorkbook(in);
+            }
+
+            Sheet sheet = wb.getSheetAt(0);
+            int rowsNum = sheet.getLastRowNum();
+            int num = 0;
+            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            System.out.println("取文件时间：" + sdf.format(new Date()));
+            long startTime = System.currentTimeMillis();
+            List<TConsoleDictionary> list1 = new ArrayList();
+
+            for(int i = 1; i < rowsNum + 1; ++i) {
+               Row row = sheet.getRow(i);
+               TConsoleDictionary tConsoleDictionary = new TConsoleDictionary();
+               new TConsoleDictionarytype();
+               if (row != null) {
+                  String typeCode = row.getCell(1).toString();
+                  if (typeCode.indexOf(".") != -1) {
+                     tConsoleDictionary.setTypecode("".equals(typeCode.substring(0, typeCode.indexOf("."))) ? null : typeCode.substring(0, typeCode.indexOf(".")));
+                  } else {
+                     tConsoleDictionary.setTypecode("".equals(row.getCell(1).toString()) ? null : row.getCell(1).toString());
+                  }
+
+                  if (row.getCell(2) != null) {
+                     row.getCell(2).setCellType(1);
+                     tConsoleDictionary.setValue("".equals(row.getCell(2).toString()) ? null : row.getCell(2).toString());
+                  }
+
+                  if (row.getCell(3) != null) {
+                     row.getCell(3).setCellType(1);
+                     tConsoleDictionary.setName("".equals(row.getCell(3).toString()) ? null : row.getCell(3).toString());
+                  }
+
+                  list1.add(tConsoleDictionary);
+               }
+            }
+
+            long endTime = System.currentTimeMillis();
+            System.out.println("程序运行时间： " + (endTime - startTime) + "ms");
+            String typecode = ((TConsoleDictionary)list1.get(0)).getTypecode();
+            this.dictionartFileService.empty1(smart, typecode);
+            this.dictionartFileService.saveTableData(list1);
+         } catch (IOException e) {
+            e.printStackTrace();
+         }
+
+         return RespHelper.successResp();
+      }
+   }
+
+   public void empty(String smart) {
+   }
+
+   @ResponseBody
+   @RequestMapping({"/queryBycode"})
+   public List<TConsoleDictionarytype> queryBycode(String code, HttpServletRequest request, HttpServletResponse response, Model model) {
+      List<TConsoleDictionarytype> list = this.dictionaryService.queryBycode(code);
+      return list;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/DgCommandRuleDao.java

+package com.chenyang.nse.bussiness.dao.table.core;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.entity.orm.table.core.DgCommandRule;
+import java.math.BigInteger;
+import java.util.List;
+import java.util.Map;
+import org.apache.commons.lang.StringUtils;
+import org.hibernate.transform.Transformers;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DgCommandRuleDao extends BaseDao<DgCommandRule, String> {
+   public List<Map<String, Object>> queryAllDbRule(PageInfo pageInfo, String ruletype, String createuser, String datasourceid) {
+      StringBuilder sqlcount = new StringBuilder();
+      StringBuilder sql = new StringBuilder();
+      sqlcount.append("SELECT COUNT(1) from T_CORE_DG_COMMAND_RULE_CUSTOM t where 1 = 1 ");
+      sql.append("SELECT  t.id,t.name,t.rule_type,t.discription,t.create_time,t.database_id,t.rule_json,t.create_user,t.data_source_id,").append(" (select sysname from t_core_datasystem where id = t.data_source_id ) as sysname,(select dataarea from t_core_dataarea where id = t.data_area_id ) as dataarea ").append(" from T_CORE_DG_COMMAND_RULE_CUSTOM t where 1 = 1 ");
+      if (StringUtils.isNotBlank(ruletype)) {
+         sql.append(" AND t.rule_type = '").append(ruletype).append("'");
+         sqlcount.append(" AND t.rule_type = '").append(ruletype).append("'");
+      }
+
+      if (StringUtils.isNotBlank(createuser)) {
+         sql.append(" AND t.create_user like '%").append(createuser).append("%'");
+         sqlcount.append(" AND t.create_user like '%").append(createuser).append("%'");
+      }
+
+      if (StringUtils.isNotBlank(datasourceid)) {
+         sql.append(" AND t.data_source_id = '").append(datasourceid).append("'");
+         sqlcount.append(" AND t.data_source_id = '").append(datasourceid).append("'");
+      }
+
+      sql.append(" order by t.create_time desc");
+      long count = (long)((BigInteger)this.getSession().createNativeQuery(sqlcount.toString()).getSingleResult()).intValue();
+      pageInfo.setCount(count);
+      return this.getSession().createNativeQuery(sql.toString()).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP).setFirstResult(pageInfo.getOffset()).setMaxResults(pageInfo.getPagesize()).getResultList();
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/DgDefineRuleDao.java

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

src/main/java/com/chenyang/nse/bussiness/dao/table/core/desensitizationtask/DesensitizationTablecolumnDao.java

+package com.chenyang.nse.bussiness.dao.table.core.desensitizationtask;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationTablecolumn;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationTablecolumnDao extends BaseDao<DesensitizationTablecolumn, String> {
+   public void saveDesensitizationTablecolumn(StringBuilder sql) {
+      this.getSession().createNativeQuery(sql.toString()).executeUpdate();
+   }
+
+   public void delDesensitizationTablecolumn(String sql) {
+      this.getSession().createNativeQuery(sql).executeUpdate();
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/desensitizationtask/DesensitizationtableDao.java

+package com.chenyang.nse.bussiness.dao.table.core.desensitizationtask;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationTable;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationtableDao extends BaseDao<DesensitizationTable, String> {
+   public void saveDesensitizationtable(StringBuilder sql) {
+      this.getSession().createNativeQuery(sql.toString()).executeUpdate();
+   }
+
+   public void delDesensitizationtable(String sql) {
+      this.getSession().createNativeQuery(sql).executeUpdate();
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/desensitizationtask/DesensitizationtargetDao.java

+package com.chenyang.nse.bussiness.dao.table.core.desensitizationtask;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.Desensitizationtarget;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationtargetDao extends BaseDao<Desensitizationtarget, String> {
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/differentdb/DesensitizationTargerTypeConversionDao.java

+package com.chenyang.nse.bussiness.dao.table.core.differentdb;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.differentdb.DesensitizationTargerTypeConversion;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationTargerTypeConversionDao extends BaseDao<DesensitizationTargerTypeConversion, String> {
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/differentdb/DidderentdbJavaMappingTypeDao.java

+package com.chenyang.nse.bussiness.dao.table.core.differentdb;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.differentdb.DidderentdbJavaMappingType;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DidderentdbJavaMappingTypeDao extends BaseDao<DidderentdbJavaMappingType, String> {
+}

src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/DgCommandRule.java

+package com.chenyang.nse.bussiness.entity.orm.table.core;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TInitEntity;
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "T_CORE_DG_COMMAND_RULE_CUSTOM"
+)
+public class DgCommandRule extends TInitEntity {
+   @Column(
+      length = 100
+   )
+   private String name;
+   @Column(
+      length = 11
+   )
+   private String rule_type;
+   @Column(
+      length = 100
+   )
+   private String data_area_id;
+   @Column(
+      length = 100
+   )
+   private Integer data_source_id;
+   @Column(
+      length = 500
+   )
+   private String discription;
+   @Column(
+      length = 100
+   )
+   private String database_id;
+   @Column(
+      length = 100
+   )
+   private String create_time;
+   @Column(
+      length = 20000
+   )
+   private String rule_json;
+   @Column(
+      length = 255
+   )
+   private String create_user;
+
+   public String getName() {
+      return this.name;
+   }
+
+   public void setName(String name) {
+      this.name = name;
+   }
+
+   public String getRule_type() {
+      return this.rule_type;
+   }
+
+   public void setRule_type(String rule_type) {
+      this.rule_type = rule_type;
+   }
+
+   public String getData_area_id() {
+      return this.data_area_id;
+   }
+
+   public void setData_area_id(String data_area_id) {
+      this.data_area_id = data_area_id;
+   }
+
+   public Integer getData_source_id() {
+      return this.data_source_id;
+   }
+
+   public void setData_source_id(Integer data_source_id) {
+      this.data_source_id = data_source_id;
+   }
+
+   public String getDiscription() {
+      return this.discription;
+   }
+
+   public void setDiscription(String discription) {
+      this.discription = discription;
+   }
+
+   public String getDatabase_id() {
+      return this.database_id;
+   }
+
+   public void setDatabase_id(String database_id) {
+      this.database_id = database_id;
+   }
+
+   public String getCreate_time() {
+      return this.create_time;
+   }
+
+   public void setCreate_time(String create_time) {
+      this.create_time = create_time;
+   }
+
+   public String getRule_json() {
+      return this.rule_json;
+   }
+
+   public void setRule_json(String rule_json) {
+      this.rule_json = rule_json;
+   }
+
+   public String getCreate_user() {
+      return this.create_user;
+   }
+
+   public void setCreate_user(String create_user) {
+      this.create_user = create_user;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/desensitizationtask/Desensitizationtarget.java

+package com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import java.io.Serializable;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "DESENSITIZATIONTARGET"
+)
+public class Desensitizationtarget extends TBaseEntity implements Serializable {
+   private String datasourceid;
+   private String dataschema;
+   private String taskid;
+   private String execution_type;
+   private String dmpimport;
+   private String iskafka;
+   private String targetfiledir;
+   private String isrebuild;
+   private String isclear;
+   private String isindex;
+   private String isprimary;
+   private String istrigger;
+   private String isfunction;
+   private String isconstraint;
+   private String isview;
+   private String ispartition;
+   private String inserttype;
+   private String loadscripttype;
+   private String isassignspace;
+
+   public String getIstrigger() {
+      return this.istrigger;
+   }
+
+   public void setIstrigger(String istrigger) {
+      this.istrigger = istrigger;
+   }
+
+   public String getIsfunction() {
+      return this.isfunction;
+   }
+
+   public void setIsfunction(String isfunction) {
+      this.isfunction = isfunction;
+   }
+
+   public String getIsrebuild() {
+      return this.isrebuild;
+   }
+
+   public void setIsrebuild(String isrebuild) {
+      this.isrebuild = isrebuild;
+   }
+
+   public String getIsclear() {
+      return this.isclear;
+   }
+
+   public void setIsclear(String isclear) {
+      this.isclear = isclear;
+   }
+
+   public String getIsindex() {
+      return this.isindex;
+   }
+
+   public void setIsindex(String isindex) {
+      this.isindex = isindex;
+   }
+
+   public String getIsprimary() {
+      return this.isprimary;
+   }
+
+   public void setIsprimary(String isprimary) {
+      this.isprimary = isprimary;
+   }
+
+   public String getInserttype() {
+      return this.inserttype;
+   }
+
+   public void setInserttype(String inserttype) {
+      this.inserttype = inserttype;
+   }
+
+   public String getDatasourceid() {
+      return this.datasourceid;
+   }
+
+   public void setDatasourceid(String datasourceid) {
+      this.datasourceid = datasourceid;
+   }
+
+   public String getDataschema() {
+      return this.dataschema;
+   }
+
+   public void setDataschema(String dataschema) {
+      this.dataschema = dataschema;
+   }
+
+   public String getTaskid() {
+      return this.taskid;
+   }
+
+   public void setTaskid(String taskid) {
+      this.taskid = taskid;
+   }
+
+   public String getExecution_type() {
+      return this.execution_type;
+   }
+
+   public void setExecution_type(String execution_type) {
+      this.execution_type = execution_type;
+   }
+
+   public String getLoadscripttype() {
+      return this.loadscripttype;
+   }
+
+   public void setLoadscripttype(String loadscripttype) {
+      this.loadscripttype = loadscripttype;
+   }
+
+   public String getDmpimport() {
+      return this.dmpimport;
+   }
+
+   public void setDmpimport(String dmpimport) {
+      this.dmpimport = dmpimport;
+   }
+
+   public String getTargetfiledir() {
+      return this.targetfiledir;
+   }
+
+   public void setTargetfiledir(String targetfiledir) {
+      this.targetfiledir = targetfiledir;
+   }
+
+   public String getIsassignspace() {
+      return this.isassignspace;
+   }
+
+   public void setIsassignspace(String isassignspace) {
+      this.isassignspace = isassignspace;
+   }
+
+   public String getIsconstraint() {
+      return this.isconstraint;
+   }
+
+   public void setIsconstraint(String isconstraint) {
+      this.isconstraint = isconstraint;
+   }
+
+   public String getIsview() {
+      return this.isview;
+   }
+
+   public void setIsview(String isview) {
+      this.isview = isview;
+   }
+
+   public String getIspartition() {
+      return this.ispartition;
+   }
+
+   public void setIspartition(String ispartition) {
+      this.ispartition = ispartition;
+   }
+
+   public String getIskafka() {
+      return this.iskafka;
+   }
+
+   public void setIskafka(String iskafka) {
+      this.iskafka = iskafka;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/differentdb/DesensitizationTargerTypeConversion.java

+package com.chenyang.nse.bussiness.entity.orm.table.core.differentdb;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import java.util.Date;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "DESENSITIZATION_TARGERTYPE_CONVERSION"
+)
+public class DesensitizationTargerTypeConversion extends TBaseEntity {
+   private String datasystemtype;
+   private String targertype;
+   private String mappingtype;
+   private String javatype;
+   private String flag;
+   private String note;
+   private String createuserid;
+   private String updateuserid;
+   private Date createtime;
+   private Date updatetime;
+
+   public String getCreateuserid() {
+      return this.createuserid;
+   }
+
+   public void setCreateuserid(String createuserid) {
+      this.createuserid = createuserid;
+   }
+
+   public String getUpdateuserid() {
+      return this.updateuserid;
+   }
+
+   public void setUpdateuserid(String updateuserid) {
+      this.updateuserid = updateuserid;
+   }
+
+   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 getDatasystemtype() {
+      return this.datasystemtype;
+   }
+
+   public void setDatasystemtype(String datasystemtype) {
+      this.datasystemtype = datasystemtype;
+   }
+
+   public String getTargertype() {
+      return this.targertype;
+   }
+
+   public void setTargertype(String targertype) {
+      this.targertype = targertype;
+   }
+
+   public String getMappingtype() {
+      return this.mappingtype;
+   }
+
+   public void setMappingtype(String mappingtype) {
+      this.mappingtype = mappingtype;
+   }
+
+   public String getJavatype() {
+      return this.javatype;
+   }
+
+   public void setJavatype(String javatype) {
+      this.javatype = javatype;
+   }
+
+   public String getFlag() {
+      return this.flag;
+   }
+
+   public void setFlag(String flag) {
+      this.flag = flag;
+   }
+
+   public String getNote() {
+      return this.note;
+   }
+
+   public void setNote(String note) {
+      this.note = note;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/orm/table/core/differentdb/DifferetdbFieldMapping.java

+package com.chenyang.nse.bussiness.entity.orm.table.core.differentdb;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "DIFFERETDB_FIELD_MAPPING"
+)
+public class DifferetdbFieldMapping extends TBaseEntity {
+   private String dbid;
+   private String dbtype;
+   private String mappingtype;
+
+   public String getDbid() {
+      return this.dbid;
+   }
+
+   public void setDbid(String dbid) {
+      this.dbid = dbid;
+   }
+
+   public String getDbtype() {
+      return this.dbtype;
+   }
+
+   public void setDbtype(String dbtype) {
+      this.dbtype = dbtype;
+   }
+
+   public String getMappingtype() {
+      return this.mappingtype;
+   }
+
+   public void setMappingtype(String mappingtype) {
+      this.mappingtype = mappingtype;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/job/DigestThread.java

+package com.chenyang.nse.bussiness.job;
+
+import com.chenyang.nse.bussiness.service.core.impl.TCoreDigestMainServiceImpl;
+import com.chenyang.nse.bussiness.tools.dataprocess.ApplicationContextProvider;
+
+public class DigestThread implements Runnable {
+   public void run() {
+      try {
+         TCoreDigestMainServiceImpl tCoreDigestMainService = (TCoreDigestMainServiceImpl)ApplicationContextProvider.getBean(TCoreDigestMainServiceImpl.class);
+         tCoreDigestMainService.digesttask();
+      } catch (Exception e) {
+         e.printStackTrace();
+      }
+
+   }
+}

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

+package com.chenyang.nse.bussiness.service.core;
+
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationMonitor;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationMonitorInfo;
+import java.util.List;
+
+public interface DesensitizationtaskLogService {
+   List readFileToPage(String taskName, String taskTableName, String logType, Long groupid);
+
+   void saveMonitorInfo(DesensitizationMonitorInfo desensitizationMonitorInfo);
+
+   List<DesensitizationMonitor> queryImportData();
+}

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

+package com.chenyang.nse.bussiness.service.core;
+
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.engine.infa.InfoProperty;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationFile;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationTable;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationTablecolumn;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.Desensitizationsource;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.Desensitizationtarget;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.Desensitizationtask;
+import com.chenyang.nse.bussiness.thread.ExecuteParam;
+import java.util.List;
+import java.util.Map;
+
+public interface DesensitizationtaskSerialService {
+   List<Desensitizationtask> queryTask(String taskname, PageInfo pageInfo);
+
+   void updateTask(Desensitizationtask desensitizationtask);
+
+   String gettaskBytasknamereal(String tasknamereal);
+
+   Desensitizationtask savetask_info(String tasknamereal, Map<String, Object> map, String tableName);
+
+   Desensitizationsource querySourceInfo(String taskid);
+
+   Desensitizationtarget queryTargetInfo(String taskid);
+
+   List<DesensitizationTable> queryTableList(String taskid);
+
+   DesensitizationTable queryTableByTableName(String taskid, String tableName);
+
+   Desensitizationtask queryTaskById(String taskid);
+
+   void removeTask(String taskid);
+
+   Desensitizationtarget queryTargetById(String taskid);
+
+   InfoProperty getInfoProperty();
+
+   List<Desensitizationtask> queryTaskList(String taskid);
+
+   void executeDB_pwc_FILE_batchwrite_DB(ExecuteParam executeParam) throws Exception;
+
+   void executeFILE_pwc_FILE_batchwrite_DB(ExecuteParam executeParam) throws Exception;
+
+   void executeDB_batchread_FILE_pwc_FILE_batchwrite_DB(ExecuteParam executeParam) throws Exception;
+
+   void executeDB_batchread_FILE_pwc_FILE(ExecuteParam executeParam) throws Exception;
+
+   void executeDB_batchread_FILE_pwc_DB(ExecuteParam executeParam) throws Exception;
+
+   void executeTaskNormal(ExecuteParam executeParam) throws Exception;
+
+   List<Desensitizationtask> queryTaskAll();
+
+   long getExeTaskNum();
+
+   long getTableNum(String taskid);
+
+   int saveDesensitizationMonitor(StringBuilder sql);
+
+   long getTableNumByAll(String sql);
+
+   DesensitizationFile queryDesensitizationfileBytaskid(String taskid);
+
+   List<DesensitizationTablecolumn> queryColumInfo(String taskid, String table);
+}

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

+package com.chenyang.nse.bussiness.service.core;
+
+import com.alibaba.fastjson.JSONObject;
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.engine.infa.InfoProperty;
+import com.chenyang.nse.bussiness.entity.orm.table.core.dataproject.TCoreSecretkey;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationFile;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationMonitor;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationMonitorInfo;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationTable;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationTablecolumn;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.Desensitizationsource;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.Desensitizationtarget;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.Desensitizationtask;
+import com.chenyang.nse.bussiness.thread.ExecuteParam;
+import java.util.List;
+import java.util.Map;
+import javax.servlet.http.HttpServletRequest;
+
+public interface DesensitizationtaskService {
+   List<Desensitizationtask> queryTask(String projectid, String taskname, PageInfo pageInfo);
+
+   void updateTask(Desensitizationtask desensitizationtask);
+
+   String gettaskBytasknamereal(String tasknamereal, String projectId);
+
+   Desensitizationtask savetask_info(String tasknamereal, Map<String, Object> map);
+
+   boolean generate_xml(Map map, HttpServletRequest request) throws Exception;
+
+   Desensitizationsource querySourceInfo(String taskid);
+
+   Desensitizationtarget queryTargetInfo(String taskid);
+
+   List<DesensitizationTable> queryTableList(String taskid);
+
+   DesensitizationTable queryTableByTableName(String taskid, String tableName);
+
+   Desensitizationtask queryTaskById(String taskid);
+
+   Desensitizationtask queryTaskByIdRedis(String taskid);
+
+   Desensitizationtask queryTaskByName(String taskname, String project);
+
+   void removeTask(String taskid);
+
+   Desensitizationtarget queryTargetById(String taskid);
+
+   InfoProperty getInfoProperty();
+
+   List<Desensitizationtask> queryTaskList(String taskid);
+
+   void executeDB_pwc_FILE_batchwrite_DB(ExecuteParam executeParam) throws Exception;
+
+   void executeFILE_pwc_FILE_batchwrite_DB(ExecuteParam executeParam) throws Exception;
+
+   void executeDB_batchread_FILE_pwc_FILE_batchwrite_DB(ExecuteParam executeParam) throws Exception;
+
+   void executeDB_batchread_FILE_pwc_FILE(ExecuteParam executeParam) throws Exception;
+
+   void executeDB_batchread_FILE_pwc_DB(ExecuteParam executeParam) throws Exception;
+
+   void executeTask(ExecuteParam executeParam) throws Exception;
+
+   void executeTaskNormal(ExecuteParam executeParam) throws Exception;
+
+   List<Desensitizationtask> queryTaskAll();
+
+   long getExeTaskNum();
+
+   long getTableNum(String taskid);
+
+   int saveDesensitizationMonitor(StringBuilder sql);
+
+   long getTableNumByAll(String sql);
+
+   DesensitizationFile queryDesensitizationfileBytaskid(String taskid);
+
+   List<DesensitizationTablecolumn> queryColumInfo(String taskid, String table);
+
+   List<Desensitizationtask> queryTaskByPage(PageInfo pageInfo);
+
+   List<DesensitizationMonitorInfo> queryMonitorInfo(String taskid);
+
+   List<Desensitizationtask> queryEngineTaskAll();
+
+   void updateEngineMonitor(String taskid, String groupid, String status);
+
+   void updateTaskstaute(String taskid, String s);
+
+   boolean updateTask_isengine(ExecuteParam executeParam, String isengine);
+
+   String getTasknamereal(String taskid);
+
+   DesensitizationMonitor getMoniterBytaskid(String taskid);
+
+   List<Desensitizationtask> queryTaskAllbyprojectid(String projectid);
+
+   Map<String, String> callBackAll(JSONObject param);
+
+   List<TCoreSecretkey> selectSecretkeyByName(String secretkeyType);
+
+   void updateEngineStopFlag(String taskid, String tablename, String groupid, String status);
+}

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

+package com.chenyang.nse.bussiness.service.core;
+
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import java.util.List;
+import java.util.Map;
+
+public interface DgCommandRuleService {
+   List<Map<String, Object>> queryAll(PageInfo pageInfo, String ruletype, String createuser, String datasourceid);
+}

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

+package com.chenyang.nse.bussiness.service.core;
+
+import com.chenyang.nse.bussiness.entity.orm.table.console.TConsoleDictionary;
+import com.chenyang.nse.bussiness.entity.vo.DictionartFileVO;
+import java.lang.reflect.InvocationTargetException;
+import java.util.List;
+import org.springframework.web.multipart.MultipartFile;
+
+public interface DictionartFileService {
+   List<DictionartFileVO> queryDictionaryFile(String typecode);
+
+   String readExcelFile(MultipartFile file);
+
+   void delTableData();
+
+   void saveTableData(List<TConsoleDictionary> list1) throws IllegalAccessException, IllegalArgumentException, InvocationTargetException;
+
+   void empty1(String smart, String typecode);
+}

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

+package com.chenyang.nse.bussiness.service.core.impl;
+
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.dao.table.core.DgCommandRuleDao;
+import com.chenyang.nse.bussiness.service.core.DgCommandRuleService;
+import java.util.List;
+import java.util.Map;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class DgCommandRuleServiceImpl implements DgCommandRuleService {
+   @Autowired
+   private DgCommandRuleDao dgCommandRuleDao;
+
+   public List<Map<String, Object>> queryAll(PageInfo pageInfo, String ruletype, String createuser, String datasourceid) {
+      return this.dgCommandRuleDao.queryAllDbRule(pageInfo, ruletype, createuser, datasourceid);
+   }
+}

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

+package com.chenyang.nse.bussiness.service.core.impl;
+
+import com.chenyang.nse.bussiness.dao.table.core.DgDefineRuleDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.DgDefineRule;
+import com.chenyang.nse.bussiness.service.core.DgDefinedRuleService;
+import java.util.List;
+import org.hibernate.criterion.Criterion;
+import org.hibernate.criterion.MatchMode;
+import org.hibernate.criterion.Order;
+import org.hibernate.criterion.Restrictions;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class DgDefinedRuleServiceImpl implements DgDefinedRuleService {
+   @Autowired
+   private DgDefineRuleDao dgDefineRuleDao;
+
+   public List<DgDefineRule> queryAll(String type, String user) {
+      return this.dgDefineRuleDao.queryAll(Order.desc("operationtime"), new Criterion[]{Restrictions.eq("module", type), Restrictions.like("operationUser", user, MatchMode.ANYWHERE), Restrictions.eq("flag", "1")});
+   }
+
+   public List<DgDefineRule> queryAll(String user) {
+      return this.dgDefineRuleDao.queryAll(Order.desc("operationtime"), new Criterion[]{Restrictions.like("operationUser", user, MatchMode.ANYWHERE), Restrictions.eq("flag", "1")});
+   }
+
+   public List<DgDefineRule> queryLogByProjectId(String projectid) {
+      return this.dgDefineRuleDao.queryAll(Order.desc("operationtime"), new Criterion[]{Restrictions.eq("flag", "2"), Restrictions.eq("projectId", projectid)});
+   }
+}

src/main/resources/sql/desensitize.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<sqls>
+	<select id="queryTableMapping">
+		select t1.id as tablemappingid,
+		        t1.sourcetablename,
+		        t1.targettablename,
+		        t1.sqltext,
+		        t1.runflag,
+		        t3.sysname datasourcename,
+		        t4.sysname datatargetname,
+		        t5.enginename
+		        from t_core_maskingtablemapping t1 
+		   left join t_core_maskingtask t2 on t1.maskingtaskid=t2.id
+		   left join t_core_datasystem t3 on t1.datasourceid=t3.id and t3.flag='2'
+		   left join t_core_datasystem t4 on t1.datatargetid=t4.id and t4.flag='2'
+		   left join t_core_engine t5 on t2.engineid = t5.id
+		   where 1=1 and t2.id= :id
+		   <flag>
+		   and t1.flag= :flag
+		   </flag>
+	</select>
+	
+	<select id="querySensitiveColumnsByGroupId">
+		select t1.*, t2.rulename, t3.SYSNAME AS datasourcename from t_core_sensitivecolumn t1 
+        left join t_core_maskingrule t2 on t1.ruleid = t2.id
+        LEFT JOIN T_core_DATASYSTEM t3 ON t1.DATASOURCEID = t3.id
+        where t1.groupid =:groupid
+	</select>
+	
+	<select id="queryColumnMappingByTableMappingId">
+	   select t1.id columnmappingid,
+	              t1.sourcecolumnname,
+	              t1.targetcolumnname,
+	              t2.tid ruleid,
+	              t2.rulename,
+	              t2.mappletname
+	         from t_core_maskingcolumnmapping t1
+	    left join t_core_maskingrule t2 on t1.maskingruleid = t2.id
+			where t1.maskingtablemappingid=:mappingid
+	</select>
+	
+	<select id="querytaskforpage">
+		select id,flag,note,createtime,engineid,fdname,mpname,sqname,status,taskname,tnname,wfname,tname
+		from t_core_maskingtask 
+		where 1=1 and engineid = :engineid and flag in(:flag)
+		order by createtime desc
+	</select>
+</sqls>
+	
\ No newline at end of file

src/main/resources/sql/discovery.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<sqls>
+	<select id="queryAllDiscoverytask">
+SELECT
+	a.tname,
+	a.id,
+	b.createtime,
+	b.username,
+	a.isrelease,
+	d.dbtype as databasename,
+(CASE d.flag
+WHEN '1' THEN '关系数据库'
+WHEN '2' THEN '数据文件'
+WHEN '3' THEN 'hadoop' end) as datasourcetype
+FROM
+	t_core_discovery_task AS a
+LEFT JOIN t_core_discovery_versrion AS b ON a.curversion = b.taskversion and a.id = b.taskid
+LEFT JOIN t_core_discovery_condition AS c ON c.groupid = a.id
+AND c.parameterid = 1
+LEFT JOIN t_core_datasystem AS d ON d.id = c.parametercontent
+
+	</select>
+<select id="queryAllDiscoverytasktotname">
+	SELECT
+		a.tname,
+		a.id,
+		b.updatetime,
+		b.username,
+		a.isrelease,
+		d.dbtype as databasename,
+		d.sysname as sysname,
+	(CASE d.flag
+	WHEN '1' THEN '关系数据库'
+	WHEN '2' THEN '数据文件'
+	WHEN '3' THEN 'hadoop' end) as datasourcetype,
+		a.isdmpflag as isdmpflag,
+		a.dmptype as dmptype
+	FROM
+		t_core_discovery_task AS a
+	LEFT JOIN t_core_discovery_versrion AS b ON a.curversion = b.taskversion and a.id = b.taskid
+	LEFT JOIN t_core_discovery_condition AS c ON c.groupid = a.id
+	AND c.parameterid = 1
+	LEFT JOIN t_core_datasystem AS d ON d.id = c.parametercontent
+	where a.tname like :tname
+	order by updatetime desc
+</select>
+<select id="queryAllDiscoverytasktotnamecount">
+	SELECT
+		 count(0) as count
+	FROM
+		t_core_discovery_task AS a
+	
+	where a.tname like :tname
+
+</select>
+
+<select id="addtask">		
+	INSERT INTO t_core_discovery_task (
+    id,
+	createtime,
+	updatetime,
+	tname,
+	<!-- dmptype, -->
+	isdmpflag,
+	discoverytype,
+	cyfs,
+	cys,
+	ppl,
+	dbtype,
+	username,
+	projectid,
+	datasystemid,
+	resultid,
+	note,
+	flag,
+	alltableschema
+    )
+    VALUES
+	(
+	    :id,
+		:createtime,
+	    :updatetime,
+		:tname,
+		<!-- :dmptype, -->
+		:isdmpflag,
+		:discoverytype,
+		:cyfs,
+		:cys,
+		:ppl,
+		:dbtype,
+		:username,
+		:projectid,
+		:datasystemid,
+		:resultid,
+		:note,
+		:flag,
+	    :alltableschema
+	)	
+	
+	</select>
+<select id="edittask">		
+	update t_core_discovery_task set  
+	updatetime = :updatetime ,
+	tname = :tname,
+    isdmpflag = :isdmpflag , 
+	discoverytype = :discoverytype , 
+	 cyfs = :cyfs , 
+	 cys = :cys , 
+	 ppl = :ppl , 
+	 username = :username , 
+	 dbtype = :dbtype   ,
+	 note = :note,
+	 flag = :flag,
+	alltableschema = :alltableschema
+	 where id = :id
+	</select>
+	
+	<!-- 获取关系型数据库的任务信息 -->
+	<select id="queryAllDatasourceTask">
+	SELECT
+		b.tname,
+		b.id
+	FROM
+		t_core_discovery_sensitivecolumn AS a,t_core_discovery_task AS b 
+	WHERE a.groupid = b.id AND a.datasourceid = :datasourceid
+	GROUP BY b.tname
+	ORDER BY b.updatetime desc
+
+</select>
+	
+	<!-- 全局监控 获取关系型数据库的任务信息 -->
+	<select id="queryDiscoveryTaskforDB">
+	SELECT count(a.taskid) as tableCount,b.tname,b.taskstatus,b.discoverytype,b.dbtype,b.updatetime,c.sysname as sysschema
+	from t_core_discovery_column a
+	left join t_core_discovery_task b
+	on a.taskid=b.id
+	left join t_core_datasystem c
+	on a.datasourceid=c.id
+	where a.taskid=:taskid
+	GROUP BY a.taskid
+	</select>
+	
+	<!-- 全局监控 获取txt文件的任务信息 -->
+	<select id="queryDiscoveryTaskDetailforTxt">
+	select count(a.taskid) as tableCount,a.fileurl as sysschema,b.taskstatus, b.discoverytype,b.dbtype,b.updatetime
+	from t_core_project_file a
+	left JOIN t_core_discovery_task b
+	on a.taskid=b.id
+	where a.taskid=:taskid
+	GROUP BY a.taskid
+	</select>
+	
+	<!-- 全局监控 获取dmp文件的任务信息 -->
+	<select id="queryDiscoveryTaskDetailforDmp">
+	select a.taskid as id,a.fileurl as sysschema,b.taskstatus, b.discoverytype,b.dbtype,b.updatetime,a.dmptables
+	from t_core_project_file a
+	left JOIN t_core_discovery_task b
+	on a.taskid=b.id
+	where a.taskid=:taskid
+	</select>
+	
+	
+</sqls>
\ No newline at end of file