新版本

src/main/java/com/chenyang/nse/bussiness/controller/aop/DesensitizationStrategyLogController.java

+package com.chenyang.nse.bussiness.controller.aop;
+
+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.entity.vo.desensitization.DesensitizationStrategyLogVO;
+import com.chenyang.nse.bussiness.service.console.DesensitizationStrategyLogService;
+import java.io.BufferedOutputStream;
+import java.nio.charset.StandardCharsets;
+import java.text.SimpleDateFormat;
+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.HSSFCell;
+import org.apache.poi.hssf.usermodel.HSSFCellStyle;
+import org.apache.poi.hssf.usermodel.HSSFFont;
+import org.apache.poi.hssf.usermodel.HSSFRichTextString;
+import org.apache.poi.hssf.usermodel.HSSFRow;
+import org.apache.poi.hssf.usermodel.HSSFSheet;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.CrossOrigin;
+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({"/aop/DesensitizationStrategyLog"})
+public class DesensitizationStrategyLogController {
+   @Autowired
+   DesensitizationStrategyLogService desensitizationStrategyLogService;
+
+   @ResponseBody
+   @PostMapping({"/queryDesensitizationStrategyLog"})
+   @CrossOrigin
+   public Response<DesensitizationStrategyLogVO> desensitizationStrategyLog(@RequestBody Map<String, Object> vo) {
+      PageInfo pageInfo = new PageInfo();
+      pageInfo.setPageno((Integer)vo.get("page"));
+      pageInfo.setPagesize((Integer)vo.get("rows"));
+      String module = vo.get("module").toString();
+      String range = vo.get("range").toString();
+      String user = vo.get("user").toString();
+      String projectId = "";
+      if (null != vo.get("projectId")) {
+         projectId = vo.get("projectId").toString();
+      }
+
+      List<DesensitizationStrategyLogVO> data = this.desensitizationStrategyLogService.queryRow(pageInfo, module, range, user, projectId);
+      return RespHelper.updateResp(pageInfo, data);
+   }
+
+   @ResponseBody
+   @PostMapping({"/checkEnc"})
+   @CrossOrigin
+   public Response checkEnc(@RequestBody Map<String, Object> vo) {
+      String module = vo.get("module").toString();
+      String range = vo.get("range").toString();
+      String user = vo.get("user").toString();
+      String projectId = "";
+      if (null != vo.get("projectId")) {
+         projectId = vo.get("projectId").toString();
+      }
+
+      boolean check = this.desensitizationStrategyLogService.checkEnc(module, range, user, projectId);
+      return check ? RespHelper.successResp() : RespHelper.errRespStr("校验失败");
+   }
+
+   @ResponseBody
+   @PostMapping({"/getdesensitizationStrategyLog"})
+   @CrossOrigin
+   public Response getdesensitizationStrategyLog(@RequestBody Map<String, Object> vo, HttpServletRequest request, HttpServletResponse response) {
+      String module = vo.get("module").toString();
+      String range = vo.get("range").toString();
+      String user = vo.get("user").toString();
+      String projectId = "";
+      if (null != vo.get("projectId")) {
+         projectId = vo.get("projectId").toString();
+      }
+
+      List<Map<String, Object>> dataList = this.desensitizationStrategyLogService.queryList(module, range, user, projectId);
+      String[] headers = new String[]{"用户", "时间", "操作代码", "操作信息"};
+      if (dataList.size() < 65536) {
+         this.xls("脱敏日志", dataList, headers, request, response);
+         return null;
+      } else {
+         return RespHelper.successResp("数据量太大暂不支持");
+      }
+   }
+
+   private void xls(String name, List<Map<String, Object>> dataList, String[] headers, HttpServletRequest request, HttpServletResponse response) {
+      Date date = new Date();
+      String sdate = (new SimpleDateFormat("yyyyMMdd")).format(date);
+      String fileName = name + "_" + sdate + ".xls";
+      HSSFWorkbook workbook = new HSSFWorkbook();
+      HSSFSheet sheet = null;
+
+      try {
+         sheet = workbook.createSheet("脱敏日志");
+         HSSFCellStyle columnTopStyle = this.getColumnTopStyle(workbook);
+         HSSFCellStyle style = this.getStyle(workbook);
+         int columnNum = headers.length;
+         HSSFRow headLine = sheet.createRow(0);
+         sheet.setDefaultColumnWidth(15);
+
+         for(int n = 0; n < columnNum; ++n) {
+            HSSFCell cellRowName = headLine.createCell(n);
+            cellRowName.setCellType(1);
+            HSSFRichTextString text = new HSSFRichTextString(headers[n]);
+            cellRowName.setCellValue(text);
+            cellRowName.setCellStyle(columnTopStyle);
+         }
+
+         if (dataList.size() != 0) {
+            HSSFCellStyle lockstyle = this.getStyle(workbook);
+            lockstyle.setAlignment((short)2);
+            lockstyle.setVerticalAlignment((short)1);
+            HSSFRow dataRow = null;
+            int index = 0;
+
+            for(Map<String, Object> mapx : dataList) {
+               ++index;
+               dataRow = sheet.createRow(index);
+
+               for(int i = 0; i < headers.length; ++i) {
+                  HSSFCell cell = dataRow.createCell(i);
+                  String value;
+                  if ("时间".equals(headers[i])) {
+                     value = mapx.get(headers[i]) == null ? null : (new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")).format(mapx.get(headers[i]));
+                  } else {
+                     value = (String)mapx.get(headers[i]);
+                  }
+
+                  cell.setCellValue(value);
+                  cell.setCellStyle(style);
+               }
+            }
+         }
+
+         try {
+            this.getExportedField(workbook, fileName, response);
+         } catch (Exception e) {
+            e.printStackTrace();
+         }
+      } catch (Exception e) {
+         e.printStackTrace();
+      }
+
+   }
+
+   public HSSFCellStyle getStyle(HSSFWorkbook workbook) {
+      HSSFFont font = workbook.createFont();
+      font.setFontHeightInPoints((short)10);
+      font.setBoldweight((short)400);
+      font.setFontName("微软雅黑");
+      HSSFCellStyle style = workbook.createCellStyle();
+      style.setBorderBottom((short)1);
+      style.setBottomBorderColor((short)8);
+      style.setBorderLeft((short)1);
+      style.setLeftBorderColor((short)8);
+      style.setBorderRight((short)1);
+      style.setRightBorderColor((short)8);
+      style.setBorderTop((short)1);
+      style.setTopBorderColor((short)8);
+      style.setFont(font);
+      style.setWrapText(false);
+      style.setAlignment((short)2);
+      style.setVerticalAlignment((short)1);
+      return style;
+   }
+
+   public HSSFCellStyle getColumnTopStyle(HSSFWorkbook workbook) {
+      HSSFFont font = workbook.createFont();
+      font.setFontHeightInPoints((short)11);
+      font.setBoldweight((short)700);
+      font.setFontName("微软雅黑");
+      HSSFCellStyle style = workbook.createCellStyle();
+      style.setBorderBottom((short)1);
+      style.setBottomBorderColor((short)8);
+      style.setBorderRight((short)1);
+      style.setTopBorderColor((short)8);
+      style.setTopBorderColor((short)8);
+      style.setFont(font);
+      style.setWrapText(false);
+      style.setAlignment((short)2);
+      style.setVerticalAlignment((short)1);
+      return style;
+   }
+
+   public void getExportedField(Workbook workbook, String name, HttpServletResponse response) throws Exception {
+      BufferedOutputStream fos = null;
+
+      try {
+         response.setContentType("application/x-download");
+         response.setHeader("Content-Disposition", "attachment;filename=" + new String(name.getBytes(StandardCharsets.UTF_8), "ISO8859-1"));
+         fos = new BufferedOutputStream(response.getOutputStream());
+         workbook.write(fos);
+      } catch (Exception e) {
+         e.printStackTrace();
+      } finally {
+         if (fos != null) {
+            fos.close();
+         }
+
+      }
+
+   }
+}

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

+package com.chenyang.nse.bussiness.controller.core;
+
+import cn.hutool.core.util.ObjectUtil;
+import com.chenyang.nse.bussiness.commmon.json.RespHelper;
+import com.chenyang.nse.bussiness.commmon.json.Response;
+import com.chenyang.nse.bussiness.entity.orm.table.core.dataproject.TCoreDataArea;
+import com.chenyang.nse.bussiness.entity.orm.table.core.masking.TCoreDesensitizationRule;
+import com.chenyang.nse.bussiness.service.core.DesensitizationRuleService;
+import com.chenyang.nse.bussiness.service.core.encryption.DesensitizationStrategyService;
+import com.chenyang.nse.bussiness.tools.msg.MesUtil;
+import java.util.List;
+import java.util.Map;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.util.ObjectUtils;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+@Controller
+@RequestMapping({"/core/desensitizationrule"})
+public class DesensitizationRuleController {
+   @Autowired
+   DesensitizationRuleService desensitizationRuleService;
+   @Autowired
+   DesensitizationStrategyService desensitizationStrategyService;
+
+   @ResponseBody
+   @RequestMapping({"/save"})
+   public Response save(@RequestBody TCoreDesensitizationRule rule) {
+      if (!ObjectUtil.isEmpty(rule.getExpression())) {
+         String expression = rule.getExpression();
+         String s = expression.replaceAll("\"", "'");
+         rule.setExpression(s);
+      }
+
+      return RespHelper.successResp(this.desensitizationRuleService.save(rule));
+   }
+
+   @ResponseBody
+   @RequestMapping({"/delete"})
+   public Response delete(@RequestBody Map<String, String> map) {
+      String ruleId = (String)map.get("ruleId");
+      if (!ObjectUtils.isEmpty(ruleId) && this.desensitizationStrategyService.checkStrategy(ruleId)) {
+         return RespHelper.createResp(false, "pop_00032", MesUtil.getMsg("pop_00032", new String[0]));
+      } else {
+         this.desensitizationRuleService.delete(ruleId);
+         return RespHelper.successResp();
+      }
+   }
+
+   @ResponseBody
+   @RequestMapping({"/query"})
+   public Response query(String dataarea) {
+      List<TCoreDataArea> list = this.desensitizationRuleService.queryRuleList(dataarea);
+      return RespHelper.successResp(list);
+   }
+
+   @ResponseBody
+   @RequestMapping({"/test"})
+   public Response test(@RequestBody Map<String, String> map) {
+      String param = (String)map.get("param");
+      String expression = (String)map.get("expression");
+      if (!"".equals(param.trim()) && !"".equals(expression.trim())) {
+         String result = this.desensitizationRuleService.test(param, expression);
+         return "表达式错误!".equals(result) ? RespHelper.paramErrResp() : RespHelper.successResp(result);
+      } else {
+         return RespHelper.paramErrResp();
+      }
+   }
+
+   @ResponseBody
+   @RequestMapping({"/setdefault"})
+   public Response setdefault(@RequestBody Map<String, String> map) {
+      String ruleId = (String)map.get("ruleId");
+      this.desensitizationRuleService.setdefault(ruleId);
+      return RespHelper.successResp();
+   }
+}

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

+package com.chenyang.nse.bussiness.dao.table.core.desensitizationimgtask;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationimgtask.DesensitizationImgInfo;
+import com.chenyang.nse.bussiness.entity.vo.dataproject.ImgTaskVO;
+import java.util.List;
+import org.hibernate.transform.Transformers;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationImgInfoDao extends BaseDao<DesensitizationImgInfo, String> {
+   public List<ImgTaskVO> editInitQuery(String taskid) {
+      String sql = "select a.taskname taskname,a.remark remark,b.sourceDirPath sourceDirPath,b.maskingImgType maskingImgType,b.maskingContent maskingContent,b.targetDirPath targetDirPath,b.taskid taskid from DESENSITIZATIONIMGTASK a left outer join DESENSITIZATIONIMGINFO b on a.id = b.taskid where b.taskid='" + taskid + "'";
+      List<ImgTaskVO> list = this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.aliasToBean(ImgTaskVO.class)).getResultList();
+      return list;
+   }
+}

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

+package com.chenyang.nse.bussiness.dao.table.core.desensitizationimgtask;
+
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationimgtask.DesensitizationImgtask;
+import java.util.List;
+import java.util.Map;
+import org.hibernate.transform.Transformers;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationImgtaskDao extends BaseDao<DesensitizationImgtask, String> {
+   public List<Map<String, Object>> selectImgTaskCount(String id) {
+      String sql = "SELECT COUNT(id) AS s FROM desensitizationimgtask WHERE projectid = '" + id + "'";
+      List<Map<String, Object>> vo = this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP).getResultList();
+      return vo;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/desensitizationtask/DesensitizationMonitorDao.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.DesensitizationMonitor;
+import com.chenyang.nse.bussiness.tools.xml.XmlTool;
+import java.util.List;
+import org.hibernate.criterion.Order;
+import org.hibernate.criterion.SimpleExpression;
+import org.hibernate.transform.Transformers;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationMonitorDao extends BaseDao<DesensitizationMonitor, String> {
+   public int saveDesensitizationMonitor(StringBuilder sql) {
+      return this.getSession().createNativeQuery(sql.toString()).executeUpdate();
+   }
+
+   public List<DesensitizationMonitor> queryMonitorByIsimport() {
+      List<DesensitizationMonitor> list = null;
+      String sql = XmlTool.getSql("desensitizationmonitor", "queryImportData");
+      list = this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.aliasToBean(DesensitizationMonitor.class)).getResultList();
+      return list;
+   }
+
+   public List<DesensitizationMonitor> queryAll(Order desc, Order asc, SimpleExpression eq) {
+      return null;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/desensitizationtask/DesensitizationMonitorInfoDao.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.DesensitizationMonitorInfo;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationMonitorInfoDao extends BaseDao<DesensitizationMonitorInfo, String> {
+   public int saveDesensitizationMonitorInfo(StringBuilder sql) {
+      return this.getSession().createNativeQuery(sql.toString()).executeUpdate();
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/desensitizationtask/DesensitizationSelfTaskDao.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.desensitizationselftask.DesensitizationSelfTask;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.Desensitizationtask;
+import com.chenyang.nse.bussiness.tools.xml.XmlTool;
+import java.math.BigInteger;
+import java.util.List;
+import java.util.Map;
+import org.hibernate.criterion.Criterion;
+import org.hibernate.criterion.Restrictions;
+import org.hibernate.transform.Transformers;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationSelfTaskDao extends BaseDao<DesensitizationSelfTask, String> {
+   static final String CACHE_NAME = "DesensitizationSelfTask";
+
+   public long getExeTaskNum() {
+      String sql = "select  count(*) from desensitization_table as a,desensitization_self_task as b  where a.taskid = b.id and taskstatus = 1";
+      BigInteger count = (BigInteger)this.getSession().createNativeQuery(sql).uniqueResult();
+      return count.longValue();
+   }
+
+   public long getTableNum(String taskid) {
+      String sql = "select count(*) as count from desensitization_table    where taskid = '" + taskid + "'";
+      BigInteger count = (BigInteger)this.getSession().createNativeQuery(sql).uniqueResult();
+      return count.longValue();
+   }
+
+   public long getTableNumByAll(String sqls) {
+      String sql = "select count(*) as count from desensitization_table    where taskid  in (" + sqls + ")";
+      BigInteger count = (BigInteger)this.getSession().createNativeQuery(sql).uniqueResult();
+      return count.longValue();
+   }
+
+   public List<Map<String, Object>> selectCodatabaseDataCount(String id) {
+      String sql = "SELECT count(1) as s FROM DESENSITIZATION_SELF_TASK where projectid ='" + id + "'";
+      List<Map<String, Object>> vo = this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.ALIAS_TO_ENTITY_MAP).getResultList();
+      return vo;
+   }
+
+   public List<DesensitizationSelfTask> queryTaskAll() {
+      String sql = XmlTool.getSql("getalltask", "selectSelfTaskAllList");
+      List<DesensitizationSelfTask> vo = this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.aliasToBean(Desensitizationtask.class)).getResultList();
+      return vo;
+   }
+
+   public List<DesensitizationSelfTask> queryTaskAllbyprojectid(String projectid) {
+      String sql = XmlTool.getSql("getalltask", "selectSelfTaskAllListByProjectid");
+      List<DesensitizationSelfTask> vo = this.getSession().createNativeQuery(sql).setParameter("projectid", projectid).setResultTransformer(Transformers.aliasToBean(DesensitizationSelfTask.class)).getResultList();
+      return vo;
+   }
+
+   @Cacheable(
+      cacheNames = {"DesensitizationSelfTask"},
+      key = "'DESENSITIZATIONTASK_' + #taskid",
+      unless = "#result == null"
+   )
+   public DesensitizationSelfTask getById(String taskid) {
+      DesensitizationSelfTask desensitizationtask = (DesensitizationSelfTask)this.queryUnique(new Criterion[]{Restrictions.eq("id", taskid)});
+      return desensitizationtask;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/dao/table/core/desensitizationtask/DesensitizationsourceDao.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.Desensitizationsource;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public class DesensitizationsourceDao extends BaseDao<Desensitizationsource, String> {
+}

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

+package com.chenyang.nse.bussiness.dao.table.core.encryption;
+
+import com.chenyang.nse.bussiness.config.HibernateConfig;
+import com.chenyang.nse.bussiness.dao.BaseDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreDesensitizationStrategy;
+import java.util.Arrays;
+import java.util.List;
+import java.util.stream.Collectors;
+import org.hibernate.transform.Transformers;
+import org.springframework.stereotype.Repository;
+import org.springframework.util.StringUtils;
+
+@Repository
+public class DesensitizationStrategyDao extends BaseDao<TCoreDesensitizationStrategy, String> {
+   public List<TCoreDesensitizationStrategy> queryDesenStrategylist(String projectId, String strategyName, String remarks, String roleGroup, String state) {
+      StringBuffer sqlBuffer = new StringBuffer("SELECT DISTINCT datasystem_id,strategyid,strategyname,rolegroup,remarks,createtime,createuser,state FROM T_CORE_Desensitization_Strategy WHERE projectid = '" + projectId + "'");
+      if (HibernateConfig.PEIZHIKUDBTYPE.equals("3")) {
+         sqlBuffer = new StringBuffer("SELECT DISTINCT datasystem_id as \"datasystem_id\",strategyid as \"strategyid\",strategyname as \"strategyname\",rolegroup as \"rolegroup\",remarks as \"remarks\",createtime as \"createtime\",createuser as \"createuser\",state as \"state\" FROM T_CORE_Desensitization_Strategy WHERE projectid = '" + projectId + "'");
+      }
+
+      if (StringUtils.hasText(strategyName)) {
+         sqlBuffer.append(" and strategyname like '%" + strategyName + "%'");
+      }
+
+      if (StringUtils.hasText(remarks)) {
+         sqlBuffer.append(" and remarks like '%" + remarks + "%'");
+      }
+
+      if (StringUtils.hasText(state)) {
+         sqlBuffer.append(" and state = '" + state + "'");
+      }
+
+      sqlBuffer.append(" ORDER BY createtime DESC");
+      String sql = sqlBuffer.toString();
+      List<TCoreDesensitizationStrategy> list = this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.aliasToBean(TCoreDesensitizationStrategy.class)).getResultList();
+      if (StringUtils.hasText(roleGroup)) {
+         list = (List)list.stream().filter((e) -> e != null && e.getRolegroup() != null && Arrays.asList(e.getRolegroup().split(",")).contains(roleGroup)).collect(Collectors.toList());
+      }
+
+      return list;
+   }
+
+   public List<TCoreDesensitizationStrategy> queryDesenStrategyDetails(String projectId, String strategyId) {
+      String sql = "SELECT id as id,strategyid,strategyname,rolegroup,remarks,projectid,datasystem_id,tschemas,names,table_field_id,dataareaid,dataareaname,ruleid,rulename,state,createuser,createtime FROM T_CORE_Desensitization_Strategy WHERE projectid = '" + projectId + "' and strategyid = '" + strategyId + "'";
+      if (HibernateConfig.PEIZHIKUDBTYPE.equals("3")) {
+         sql = "SELECT id as \"id\",strategyid as \"strategyid\",strategyname as \"strategyname\",rolegroup as \"rolegroup\",remarks as \"remarks\",projectid as \"projectid\",datasystem_id as \"datasystem_id\",tschemas as \"tschemas\",names as \"names\",table_field_id as \"table_field_id\",dataareaid as \"dataareaid\",dataareaname as \"dataareaname\",ruleid as \"ruleid\",rulename as \"rulename\",state as \"state\",createuser as \"createuser\",createtime as \"createtime\" FROM T_CORE_Desensitization_Strategy WHERE projectid = '" + projectId + "' and strategyid = '" + strategyId + "'";
+      }
+
+      return this.getSession().createNativeQuery(sql).setResultTransformer(Transformers.aliasToBean(TCoreDesensitizationStrategy.class)).getResultList();
+   }
+}

src/main/java/com/chenyang/nse/bussiness/engine/ghca/webservice/DesensitizationEngineInterfaceImpl.java

+package com.chenyang.nse.bussiness.engine.ghca.webservice;
+
+import java.util.List;
+import javax.jws.WebMethod;
+import javax.jws.WebParam;
+import javax.jws.WebResult;
+import javax.jws.WebService;
+import javax.xml.bind.annotation.XmlSeeAlso;
+import javax.xml.ws.Action;
+import javax.xml.ws.RequestWrapper;
+import javax.xml.ws.ResponseWrapper;
+
+@WebService(
+   name = "DesensitizationEngineInterfaceImpl",
+   targetNamespace = "http://webservice/"
+)
+@XmlSeeAlso({ObjectFactory.class})
+public interface DesensitizationEngineInterfaceImpl {
+   @WebMethod
+   @WebResult(
+      targetNamespace = ""
+   )
+   @RequestWrapper(
+      localName = "dataMaskingByRuleName",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.DataMaskingByRuleName"
+   )
+   @ResponseWrapper(
+      localName = "dataMaskingByRuleNameResponse",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.DataMaskingByRuleNameResponse"
+   )
+   @Action(
+      input = "http://webservice/DesensitizationEngineInterfaceImpl/dataMaskingByRuleNameRequest",
+      output = "http://webservice/DesensitizationEngineInterfaceImpl/dataMaskingByRuleNameResponse"
+   )
+   Object dataMaskingByRuleName(@WebParam(name = "arg0",targetNamespace = "") String arg0, @WebParam(name = "arg1",targetNamespace = "") Object arg1);
+
+   @WebMethod
+   @WebResult(
+      targetNamespace = ""
+   )
+   @RequestWrapper(
+      localName = "dataMaskingListByRuleName",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.DataMaskingListByRuleName"
+   )
+   @ResponseWrapper(
+      localName = "dataMaskingListByRuleNameResponse",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.DataMaskingListByRuleNameResponse"
+   )
+   @Action(
+      input = "http://webservice/DesensitizationEngineInterfaceImpl/dataMaskingListByRuleNameRequest",
+      output = "http://webservice/DesensitizationEngineInterfaceImpl/dataMaskingListByRuleNameResponse"
+   )
+   List<Object> dataMaskingListByRuleName(@WebParam(name = "arg0",targetNamespace = "") String arg0, @WebParam(name = "arg1",targetNamespace = "") List<Object> arg1);
+
+   @WebMethod
+   @WebResult(
+      targetNamespace = ""
+   )
+   @RequestWrapper(
+      localName = "executeMappletDesignerSerialize",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.ExecuteMappletDesignerSerialize"
+   )
+   @ResponseWrapper(
+      localName = "executeMappletDesignerSerializeResponse",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.ExecuteMappletDesignerSerializeResponse"
+   )
+   @Action(
+      input = "http://webservice/DesensitizationEngineInterfaceImpl/executeMappletDesignerSerializeRequest",
+      output = "http://webservice/DesensitizationEngineInterfaceImpl/executeMappletDesignerSerializeResponse"
+   )
+   String executeMappletDesignerSerialize(@WebParam(name = "arg0",targetNamespace = "") String arg0);
+
+   @WebMethod
+   @WebResult(
+      targetNamespace = ""
+   )
+   @RequestWrapper(
+      localName = "startWorkflowEx",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.StartWorkflowEx"
+   )
+   @ResponseWrapper(
+      localName = "startWorkflowExResponse",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.StartWorkflowExResponse"
+   )
+   @Action(
+      input = "http://webservice/DesensitizationEngineInterfaceImpl/startWorkflowExRequest",
+      output = "http://webservice/DesensitizationEngineInterfaceImpl/startWorkflowExResponse"
+   )
+   EngineResult startWorkflowEx(@WebParam(name = "arg0",targetNamespace = "") EngineParameter arg0);
+
+   @WebMethod
+   @WebResult(
+      targetNamespace = ""
+   )
+   @RequestWrapper(
+      localName = "readFileToPage",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.ReadFileToPage"
+   )
+   @ResponseWrapper(
+      localName = "readFileToPageResponse",
+      targetNamespace = "http://webservice/",
+      className = "com.chenyang.nse.bussiness.engine.ghca.webservice.ReadFileToPageResponse"
+   )
+   @Action(
+      input = "http://webservice/DesensitizationEngineInterfaceImpl/readFileToPageRequest",
+      output = "http://webservice/DesensitizationEngineInterfaceImpl/readFileToPageResponse"
+   )
+   List<Object> readFileToPage(@WebParam(name = "arg0",targetNamespace = "") String arg0, @WebParam(name = "arg1",targetNamespace = "") String arg1, @WebParam(name = "arg2",targetNamespace = "") String arg2, @WebParam(name = "arg3",targetNamespace = "") Long arg3);
+}

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

+package com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationselftask;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import java.io.Serializable;
+import java.util.Date;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+import javax.persistence.Transient;
+
+@Entity
+@Table(
+   name = "DESENSITIZATION_SELF_TASK"
+)
+public class DesensitizationSelfTask extends TBaseEntity implements Serializable {
+   private String taskname;
+   private String tasknamereal;
+   private Date createtime;
+   private Date updatetime;
+   private String userid;
+   private String foldername;
+   private String tableprefix;
+   private String tablesuffix;
+   private String username;
+   private String taskstatus;
+   private String batchnumber;
+   private String remark;
+   private String isengine;
+   private String isSynXml;
+   private int type;
+   private String tasktype;
+   private String save_state;
+   private String count_exe;
+   private String projectid;
+   private String fastexecution;
+   private String version;
+   private String isrecover;
+   @Transient
+   private String projectname;
+   @Transient
+   private String removePercent;
+   private String executeStatus;
+
+   public String getRemovePercent() {
+      return this.removePercent;
+   }
+
+   public void setRemovePercent(String removePercent) {
+      this.removePercent = removePercent;
+   }
+
+   public String getExecuteStatus() {
+      return this.executeStatus;
+   }
+
+   public void setExecuteStatus(String executeStatus) {
+      this.executeStatus = executeStatus;
+   }
+
+   public String getCount_exe() {
+      return this.count_exe;
+   }
+
+   public void setCount_exe(String count_exe) {
+      this.count_exe = count_exe;
+   }
+
+   public String getSave_state() {
+      return this.save_state;
+   }
+
+   public void setSave_state(String save_state) {
+      this.save_state = save_state;
+   }
+
+   public String getTaskname() {
+      return this.taskname;
+   }
+
+   public void setTaskname(String taskname) {
+      this.taskname = taskname;
+   }
+
+   public String getTasktype() {
+      return this.tasktype;
+   }
+
+   public void setTasktype(String tasktype) {
+      this.tasktype = tasktype;
+   }
+
+   public String getTasknamereal() {
+      return this.tasknamereal;
+   }
+
+   public void setTasknamereal(String tasknamereal) {
+      this.tasknamereal = tasknamereal;
+   }
+
+   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 getUserid() {
+      return this.userid;
+   }
+
+   public void setUserid(String userid) {
+      this.userid = userid;
+   }
+
+   public String getFoldername() {
+      return this.foldername;
+   }
+
+   public void setFoldername(String foldername) {
+      this.foldername = foldername;
+   }
+
+   public String getName() {
+      return this.username;
+   }
+
+   public void setName(String name) {
+      this.username = name;
+   }
+
+   public String getTaskstatus() {
+      return this.taskstatus;
+   }
+
+   public void setTaskstatus(String taskstatus) {
+      this.taskstatus = taskstatus;
+   }
+
+   public String getBatchnumber() {
+      return this.batchnumber;
+   }
+
+   public void setBatchnumber(String batchnumber) {
+      this.batchnumber = batchnumber;
+   }
+
+   public int getType() {
+      return this.type;
+   }
+
+   public void setType(int type) {
+      this.type = type;
+   }
+
+   public String getUsername() {
+      return this.username;
+   }
+
+   public void setUsername(String username) {
+      this.username = username;
+   }
+
+   public String getProjectid() {
+      return this.projectid;
+   }
+
+   public void setProjectid(String projectid) {
+      this.projectid = projectid;
+   }
+
+   public String getRemark() {
+      return this.remark;
+   }
+
+   public void setRemark(String remark) {
+      this.remark = remark;
+   }
+
+   public String getIsengine() {
+      return this.isengine;
+   }
+
+   public void setIsengine(String isengine) {
+      this.isengine = isengine;
+   }
+
+   public String getIsSynXml() {
+      return this.isSynXml;
+   }
+
+   public void setIsSynXml(String isSynXml) {
+      this.isSynXml = isSynXml;
+   }
+
+   public String getTableprefix() {
+      return this.tableprefix;
+   }
+
+   public void setTableprefix(String tableprefix) {
+      this.tableprefix = tableprefix;
+   }
+
+   public String getTablesuffix() {
+      return this.tablesuffix;
+   }
+
+   public void setTablesuffix(String tablesuffix) {
+      this.tablesuffix = tablesuffix;
+   }
+
+   public String getFastexecution() {
+      return this.fastexecution;
+   }
+
+   public void setFastexecution(String fastexecution) {
+      this.fastexecution = fastexecution;
+   }
+
+   public String getVersion() {
+      return this.version;
+   }
+
+   public void setVersion(String version) {
+      this.version = version;
+   }
+
+   public String getIsrecover() {
+      return this.isrecover;
+   }
+
+   public void setIsrecover(String isrecover) {
+      this.isrecover = isrecover;
+   }
+
+   public String getProjectname() {
+      return this.projectname;
+   }
+
+   public void setProjectname(String projectname) {
+      this.projectname = projectname;
+   }
+
+   public String toString() {
+      return "DesensitizationSelfTask [taskname=" + this.taskname + ", tasknamereal=" + this.tasknamereal + ", createtime=" + this.createtime + ", updatetime=" + this.updatetime + ", userid=" + this.userid + ", foldername=" + this.foldername + ", tableprefix=" + this.tableprefix + ", tablesuffix=" + this.tablesuffix + ", username=" + this.username + ", taskstatus=" + this.taskstatus + ", batchnumber=" + this.batchnumber + ", remark=" + this.remark + ", isengine=" + this.isengine + ", isSynXml=" + this.isSynXml + ", type=" + this.type + ", tasktype=" + this.tasktype + ", save_state=" + this.save_state + ", count_exe=" + this.count_exe + ", projectid=" + this.projectid + ", fastexecution=" + this.fastexecution + ", version=" + this.version + ", isrecover=" + this.isrecover + "]";
+   }
+}

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

+package com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import java.math.BigInteger;
+import java.util.Date;
+import javax.persistence.Entity;
+import javax.persistence.Index;
+import javax.persistence.Table;
+import javax.persistence.Transient;
+
+@Entity
+@Table(
+   name = "DESENSITIZATION_MONITOR",
+   indexes = {@Index(
+   name = "monitor_sourcename_Index",
+   columnList = "sourcename"
+), @Index(
+   name = "monitor_taskid_Index",
+   columnList = "taskid"
+)}
+)
+public class DesensitizationMonitor extends TBaseEntity {
+   private String taskid;
+   @Transient
+   private String tasknamereal;
+   private String tasktype;
+   private String sourcename;
+   private String targetname;
+   private Date executetime;
+   private int runstatus;
+   private String runid;
+   private BigInteger groupid;
+   private String isimport;
+
+   public String getTaskid() {
+      return this.taskid;
+   }
+
+   public String getIsimport() {
+      return this.isimport;
+   }
+
+   public void setIsimport(String isimport) {
+      this.isimport = isimport;
+   }
+
+   public void setTaskid(String taskid) {
+      this.taskid = taskid;
+   }
+
+   public String getTasknamereal() {
+      return this.tasknamereal;
+   }
+
+   public void setTasknamereal(String tasknamereal) {
+      this.tasknamereal = tasknamereal;
+   }
+
+   public String getTasktype() {
+      return this.tasktype;
+   }
+
+   public void setTasktype(String tasktype) {
+      this.tasktype = tasktype;
+   }
+
+   public String getSourcename() {
+      return this.sourcename;
+   }
+
+   public void setSourcename(String sourcename) {
+      this.sourcename = sourcename;
+   }
+
+   public String getTargetname() {
+      return this.targetname;
+   }
+
+   public void setTargetname(String targetname) {
+      this.targetname = targetname;
+   }
+
+   public Date getExecutetime() {
+      return this.executetime;
+   }
+
+   public void setExecutetime(Date executetime) {
+      this.executetime = executetime;
+   }
+
+   public int getRunstatus() {
+      return this.runstatus;
+   }
+
+   public void setRunstatus(int runstatus) {
+      this.runstatus = runstatus;
+   }
+
+   public String getRunid() {
+      return this.runid;
+   }
+
+   public void setRunid(String runid) {
+      this.runid = runid;
+   }
+
+   public BigInteger getGroupid() {
+      return this.groupid;
+   }
+
+   public void setGroupid(BigInteger groupid) {
+      this.groupid = groupid;
+   }
+
+   public String toString() {
+      return "DesensitizationMonitor [taskid=" + this.taskid + ", tasktype=" + this.tasktype + ", sourcename=" + this.sourcename + ", targetname=" + this.targetname + ", executetime=" + this.executetime + ", runstatus=" + this.runstatus + ", runid=" + this.runid + ", groupid=" + this.groupid + ", isimport=" + this.isimport + "]";
+   }
+}

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

+package com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask;
+
+import com.chenyang.nse.bussiness.entity.orm.table.TBaseEntity;
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Entity
+@Table(
+   name = "DESENSITIZATION_TABLE"
+)
+public class DesensitizationTable extends TBaseEntity implements Comparable<DesensitizationTable> {
+   private String taskid;
+   private String tablename;
+   private String mappingkey;
+   private String status;
+   private String filestructureid;
+   private String filename;
+   private String filepath;
+   private String sqlFilter;
+   private String t_tablename;
+   @Column(
+      length = 5000
+   )
+   private String create_sql;
+
+   public String getT_tablename() {
+      return this.t_tablename;
+   }
+
+   public void setT_tablename(String t_tablename) {
+      this.t_tablename = t_tablename;
+   }
+
+   public String getSqlFilter() {
+      return this.sqlFilter;
+   }
+
+   public void setSqlFilter(String sqlFilter) {
+      this.sqlFilter = sqlFilter;
+   }
+
+   public String getStatus() {
+      return this.status;
+   }
+
+   public void setStatus(String status) {
+      this.status = status;
+   }
+
+   public String getCreate_sql() {
+      return this.create_sql;
+   }
+
+   public void setCreate_sql(String create_sql) {
+      this.create_sql = create_sql;
+   }
+
+   public String getTaskid() {
+      return this.taskid;
+   }
+
+   public void setTaskid(String taskid) {
+      this.taskid = taskid;
+   }
+
+   public String getTablename() {
+      return this.tablename;
+   }
+
+   public void setTablename(String tablename) {
+      this.tablename = tablename;
+   }
+
+   public String getMappingkey() {
+      return this.mappingkey;
+   }
+
+   public void setMappingkey(String mappingkey) {
+      this.mappingkey = mappingkey;
+   }
+
+   public String getFilestructureid() {
+      return this.filestructureid;
+   }
+
+   public void setFilestructureid(String filestructureid) {
+      this.filestructureid = filestructureid;
+   }
+
+   public String getFilename() {
+      return this.filename;
+   }
+
+   public void setFilename(String filename) {
+      this.filename = filename;
+   }
+
+   public String getFilepath() {
+      return this.filepath;
+   }
+
+   public void setFilepath(String filepath) {
+      this.filepath = filepath;
+   }
+
+   public String toString() {
+      return "DesensitizationTable [taskid=" + this.taskid + ", tablename=" + this.tablename + ", mappingkey=" + this.mappingkey + ", status=" + this.status + ", filestructureid=" + this.filestructureid + ", filename=" + this.filename + ", filepath=" + this.filepath + ", create_sql=" + this.create_sql + "]";
+   }
+
+   public int compareTo(DesensitizationTable dt) {
+      int i = Integer.parseInt(this.getNote()) - Integer.parseInt(dt.getNote());
+      return i == 0 ? Integer.parseInt(this.getNote()) - Integer.parseInt(dt.getNote()) : i;
+   }
+}

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

+package com.chenyang.nse.bussiness.entity.vo;
+
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationMonitor;
+
+public class DesensitizationMonitorVO extends DesensitizationMonitor {
+   private String isRecoverState;
+   private int fieldcount;
+   private int maskingfieldcount;
+
+   public String getIsRecoverState() {
+      return this.isRecoverState;
+   }
+
+   public void setIsRecoverState(String isRecoverState) {
+      this.isRecoverState = isRecoverState;
+   }
+
+   public int getFieldcount() {
+      return this.fieldcount;
+   }
+
+   public void setFieldcount(int fieldcount) {
+      this.fieldcount = fieldcount;
+   }
+
+   public int getMaskingfieldcount() {
+      return this.maskingfieldcount;
+   }
+
+   public void setMaskingfieldcount(int maskingfieldcount) {
+      this.maskingfieldcount = maskingfieldcount;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/vo/desensitization/DesensitizationStrategyLogVO.java

+package com.chenyang.nse.bussiness.entity.vo.desensitization;
+
+import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreDesensitizationStrategyLog;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+public class DesensitizationStrategyLogVO extends TCoreDesensitizationStrategyLog {
+   private int rows;
+   private int page;
+   private String range;
+   private Set<String> head;
+   private List<Map<String, Object>> data;
+
+   public int getRows() {
+      return this.rows;
+   }
+
+   public void setRows(int rows) {
+      this.rows = rows;
+   }
+
+   public int getPage() {
+      return this.page;
+   }
+
+   public void setPage(int page) {
+      this.page = page;
+   }
+
+   public Set<String> getHead() {
+      return this.head;
+   }
+
+   public void setHead(Set<String> head) {
+      this.head = head;
+   }
+
+   public List<Map<String, Object>> getData() {
+      return this.data;
+   }
+
+   public void setData(List<Map<String, Object>> data) {
+      this.data = data;
+   }
+
+   public String getRange() {
+      return this.range;
+   }
+
+   public void setRange(String range) {
+      this.range = range;
+   }
+}

src/main/java/com/chenyang/nse/bussiness/entity/vo/maskingrule/DesensitizationRuleVO.java

+package com.chenyang.nse.bussiness.entity.vo.maskingrule;
+
+public class DesensitizationRuleVO {
+   private String dataareaId;
+   private String dataarea;
+   private String ruleId;
+   private String ruleName;
+   private String defaultType;
+   private String expression;
+
+   public String getDataareaId() {
+      return this.dataareaId;
+   }
+
+   public void setDataareaId(String dataareaId) {
+      this.dataareaId = dataareaId;
+   }
+
+   public String getDataarea() {
+      return this.dataarea;
+   }
+
+   public void setDataarea(String dataarea) {
+      this.dataarea = dataarea;
+   }
+
+   public String getRuleId() {
+      return this.ruleId;
+   }
+
+   public void setRuleId(String ruleId) {
+      this.ruleId = ruleId;
+   }
+
+   public String getRuleName() {
+      return this.ruleName;
+   }
+
+   public void setRuleName(String ruleName) {
+      this.ruleName = ruleName;
+   }
+
+   public String getDefaultType() {
+      return this.defaultType;
+   }
+
+   public void setDefaultType(String defaultType) {
+      this.defaultType = defaultType;
+   }
+
+   public String getExpression() {
+      return this.expression;
+   }
+
+   public void setExpression(String expression) {
+      this.expression = expression;
+   }
+}

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

+package com.chenyang.nse.bussiness.service.core;
+
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationimgtask.DesensitizationImgInfo;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationimgtask.DesensitizationImgtask;
+import com.chenyang.nse.bussiness.entity.vo.dataproject.ImgTaskVO;
+import java.util.List;
+
+public interface DesensitizationImgtaskService {
+   void saveDesensitizationImgtask(DesensitizationImgtask desensitizationImgtask);
+
+   void saveDesensitizationImgInfo(DesensitizationImgInfo desensitizationImgInfo);
+
+   List<DesensitizationImgtask> queryImgtask(String projectid, PageInfo pageInfo);
+
+   List<DesensitizationImgInfo> queryImgInfo(String taskid);
+
+   List<DesensitizationImgtask> queryImgtaskByid(String taskid);
+
+   void removeTask(String taskid);
+
+   void removeInfoByTaskid(String taskid);
+
+   DesensitizationImgtask queryTaskByName(String taskname, String projectid);
+
+   List<ImgTaskVO> queryImgByid(String id);
+}

src/main/java/com/chenyang/nse/bussiness/service/core/DesensitizationMonitorService.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.engine.infa.basic.webservice.SessionBean;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationselftask.TCoreMonitorTmporary;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationtask.DesensitizationMonitor;
+import java.util.List;
+
+public interface DesensitizationMonitorService {
+   List queryTaskVersionList(String taskId);
+
+   List<DesensitizationMonitor> queryTaskMonitor(String taskid, String groupid, PageInfo pageInfo, int index);
+
+   List<DesensitizationMonitor> queryTaskLogMonitor(String taskid, String groupid, PageInfo pageInfo, int index);
+
+   List<TCoreMonitorTmporary> queryTaskLogMonitors(String taskid, String groupid, PageInfo pageInfo, int index);
+
+   List<DesensitizationMonitor> queryImportTaskMonitor(String taskid, String groupid, PageInfo pageInfo, int index);
+
+   DesensitizationMonitor getMonitorById(String id);
+
+   SessionBean getLogForTaskMapping(String folderName, InfoProperty engine, String name) throws Exception;
+
+   SessionBean getLogForMappingByInstantFile(String folderName, InfoProperty engine, String name, Long countdata) throws Exception;
+
+   List<DesensitizationMonitor> queryDesensitizationMonitorList(String taskid);
+
+   void update(DesensitizationMonitor desensitizationMonitor);
+
+   SessionBean getSessionLog(String folderName, String wfname, InfoProperty engine);
+
+   String stopWorkflow(InfoProperty infoProperty, String name, String folderName);
+
+   void toExcel(String taskid);
+
+   String recoverWorkflow(InfoProperty infoProperty, String name, String folderName);
+
+   List<DesensitizationMonitor> queryTaskLogMonitorEM(String groupid);
+
+   List<TCoreMonitorTmporary> querySelfTaskVersionList(String taskId);
+}

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

+package com.chenyang.nse.bussiness.service.core.encryption;
+
+import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreDesensitizationStrategy;
+import java.lang.reflect.InvocationTargetException;
+import java.text.ParseException;
+import java.util.List;
+
+public interface DesensitizationStrategyService {
+   void saveDesensitizationStrategy(List<String> parameter) throws IllegalAccessException, IllegalArgumentException, InvocationTargetException, ParseException;
+
+   void saveDesensitizationStrategyDel(List<String> parameter) throws IllegalAccessException, IllegalArgumentException, InvocationTargetException, ParseException;
+
+   List<TCoreDesensitizationStrategy> queryDesenStrategylist(String projectId, String strategyName, String remarks, String roleGroup, String state);
+
+   List<TCoreDesensitizationStrategy> queryDesenStrategyDetails(String projectId, String strategyId);
+
+   void updateRoleGroup(List<TCoreDesensitizationStrategy> tcoreJiaMiDulist, String roleGroup);
+
+   void remove(List<TCoreDesensitizationStrategy> tcoreJiaMiDulist);
+
+   void disableOrEnable(List<TCoreDesensitizationStrategy> tcoreJiaMiDulist, String state);
+
+   boolean checkStrategy(String ruleId);
+
+   int checkRepeatName(String strategyname, String id, String projectid);
+}

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

+package com.chenyang.nse.bussiness.service.core.impl;
+
+import com.chenyang.nse.bussiness.dao.PageInfo;
+import com.chenyang.nse.bussiness.dao.table.core.desensitizationimgtask.DesensitizationImgInfoDao;
+import com.chenyang.nse.bussiness.dao.table.core.desensitizationimgtask.DesensitizationImgtaskDao;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationimgtask.DesensitizationImgInfo;
+import com.chenyang.nse.bussiness.entity.orm.table.core.desensitizationimgtask.DesensitizationImgtask;
+import com.chenyang.nse.bussiness.entity.vo.dataproject.ImgTaskVO;
+import com.chenyang.nse.bussiness.service.core.DesensitizationImgtaskService;
+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.Repository;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Repository
+@Transactional
+public class DesensitizationImgtaskServiceImpl implements DesensitizationImgtaskService {
+   @Autowired
+   DesensitizationImgtaskDao desensitizationImgtaskDao;
+   @Autowired
+   DesensitizationImgInfoDao desensitizationImgInfoDao;
+
+   public void saveDesensitizationImgtask(DesensitizationImgtask desensitizationImgtask) {
+      this.desensitizationImgtaskDao.saveOrUpdate(desensitizationImgtask);
+   }
+
+   public void saveDesensitizationImgInfo(DesensitizationImgInfo desensitizationImgInfo) {
+      this.desensitizationImgInfoDao.saveOrUpdate(desensitizationImgInfo);
+   }
+
+   public List<DesensitizationImgtask> queryImgtask(String projectid, PageInfo pageInfo) {
+      List<DesensitizationImgtask> list = this.desensitizationImgtaskDao.queryByPageInfo(pageInfo, Order.desc("createtime"), new Criterion[]{Restrictions.eq("projectid", projectid)});
+      return list;
+   }
+
+   public List<DesensitizationImgtask> queryImgtaskByid(String taskid) {
+      List<DesensitizationImgtask> list = this.desensitizationImgtaskDao.queryAll(new Criterion[]{Restrictions.eq("id", taskid)});
+      return list;
+   }
+
+   public List<DesensitizationImgInfo> queryImgInfo(String taskid) {
+      List<DesensitizationImgInfo> list = this.desensitizationImgInfoDao.queryAll(new Criterion[]{Restrictions.eq("taskid", taskid)});
+      return list;
+   }
+
+   public List<ImgTaskVO> queryImgByid(String taskid) {
+      return this.desensitizationImgInfoDao.editInitQuery(taskid);
+   }
+
+   public void removeTask(String taskid) {
+      this.desensitizationImgtaskDao.removeById(taskid);
+   }
+
+   public void removeInfoByTaskid(String taskid) {
+      this.desensitizationImgInfoDao.remove(new Criterion[]{Restrictions.eq("taskid", taskid)});
+   }
+
+   public DesensitizationImgtask queryTaskByName(String taskname, String projectid) {
+      List<DesensitizationImgtask> desensitizationtasklist = this.desensitizationImgtaskDao.queryAll(Order.desc("createtime"), new Criterion[]{Restrictions.eq("taskname", taskname), Restrictions.eq("projectid", projectid)});
+      return desensitizationtasklist != null && desensitizationtasklist.size() > 0 ? (DesensitizationImgtask)desensitizationtasklist.get(0) : null;
+   }
+}

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

+package com.chenyang.nse.bussiness.service.core.impl.encryption;
+
+import com.chenyang.nse.bussiness.config.HibernateConfig;
+import com.chenyang.nse.bussiness.dao.table.base.TBaseRoleDao;
+import com.chenyang.nse.bussiness.dao.table.core.encryption.DesensitizationStrategyDao;
+import com.chenyang.nse.bussiness.entity.orm.table.base.TBaseRole;
+import com.chenyang.nse.bussiness.entity.orm.table.core.encryption.TCoreDesensitizationStrategy;
+import com.chenyang.nse.bussiness.service.core.encryption.DesensitizationStrategyService;
+import java.lang.reflect.InvocationTargetException;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.UUID;
+import org.apache.commons.lang.StringUtils;
+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.util.ObjectUtils;
+
+@Service
+public class DesensitizationStrategyServiceImpl implements DesensitizationStrategyService {
+   @Autowired
+   DesensitizationStrategyDao desensitizationStrategyDao;
+   @Autowired
+   private TBaseRoleDao tBaseRoleDao;
+
+   public void saveDesensitizationStrategy(List<String> parameter) throws IllegalAccessException, IllegalArgumentException, InvocationTargetException, ParseException {
+      String datasystemid = (String)parameter.get(0);
+      String field = (String)parameter.get(1);
+      String table = (String)parameter.get(2);
+      String schema = (String)parameter.get(3);
+      String state = (String)parameter.get(4);
+      String projectId = (String)parameter.get(5);
+      String username = (String)parameter.get(6);
+      String dataareaid = (String)parameter.get(7);
+      String dataareaname = (String)parameter.get(8);
+      String ruleid = (String)parameter.get(9);
+      String rulename = (String)parameter.get(10);
+      String finalStrategyId = (String)parameter.get(11);
+      String strategyName = (String)parameter.get(12);
+      String roleGroup = (String)parameter.get(13);
+      String remarks = (String)parameter.get(14);
+      String createtimeString = (String)parameter.get(15);
+      TCoreDesensitizationStrategy tCoreDesensitizationStrategy = new TCoreDesensitizationStrategy();
+      List<TBaseRole> tBaseRoles = this.tBaseRoleDao.queryAll(new Criterion[]{Restrictions.ne("id", "1")});
+      StringBuilder stringBuilder = new StringBuilder();
+
+      for(int i = 0; i < tBaseRoles.size(); ++i) {
+         if (i != 0) {
+            stringBuilder.append(",").append(((TBaseRole)tBaseRoles.get(i)).getRolename());
+         } else {
+            stringBuilder.append(((TBaseRole)tBaseRoles.get(i)).getRolename());
+         }
+      }
+
+      String roles = stringBuilder.toString();
+      if (null != dataareaid && !dataareaid.equals("")) {
+         this.desensitizationStrategyDao.remove(new Criterion[]{Restrictions.eq("strategyid", finalStrategyId), Restrictions.eq("projectid", projectId), Restrictions.eq("datasystem_id", datasystemid), Restrictions.eq("tschemas", schema), Restrictions.eq("names", table), Restrictions.eq("table_field_id", field)});
+         tCoreDesensitizationStrategy.setId(UUID.randomUUID().toString().replace("-", ""));
+         tCoreDesensitizationStrategy.setDatasystem_id(datasystemid);
+         tCoreDesensitizationStrategy.setTschemas(schema);
+         tCoreDesensitizationStrategy.setTable_field_id(field);
+         tCoreDesensitizationStrategy.setNames(table);
+         tCoreDesensitizationStrategy.setProjectid(projectId);
+         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+         Date finalCreatetime = sdf.parse(createtimeString);
+         tCoreDesensitizationStrategy.setCreatetime(finalCreatetime);
+         tCoreDesensitizationStrategy.setCreateuser(username);
+         tCoreDesensitizationStrategy.setRemarks(remarks);
+         tCoreDesensitizationStrategy.setDataareaid(dataareaid);
+         tCoreDesensitizationStrategy.setDataareaname(dataareaname);
+         tCoreDesensitizationStrategy.setState(state);
+         tCoreDesensitizationStrategy.setRuleid(ruleid);
+         tCoreDesensitizationStrategy.setRulename(rulename);
+         tCoreDesensitizationStrategy.setStrategyid(finalStrategyId);
+         tCoreDesensitizationStrategy.setStrategyname(strategyName);
+         tCoreDesensitizationStrategy.setRolegroup(roles);
+         this.desensitizationStrategyDao.save(tCoreDesensitizationStrategy);
+      }
+
+   }
+
+   public void saveDesensitizationStrategyDel(List<String> parameter) throws IllegalAccessException, IllegalArgumentException, InvocationTargetException, ParseException {
+      String datasystemid = (String)parameter.get(0);
+      String field = (String)parameter.get(1);
+      String table = (String)parameter.get(2);
+      String schema = (String)parameter.get(3);
+      String state = (String)parameter.get(4);
+      String projectId = (String)parameter.get(5);
+      String username = (String)parameter.get(6);
+      String dataareaid = (String)parameter.get(7);
+      String dataareaname = (String)parameter.get(8);
+      String ruleid = (String)parameter.get(9);
+      String rulename = (String)parameter.get(10);
+      String finalStrategyId = (String)parameter.get(11);
+      String strategyName = (String)parameter.get(12);
+      String roleGroup = (String)parameter.get(13);
+      String remarks = (String)parameter.get(14);
+      if (null != dataareaid && !dataareaid.equals("")) {
+         String stragegy = null;
+         if (HibernateConfig.PEIZHIKUDBTYPE.equals("1")) {
+            stragegy = "strategyid";
+         } else {
+            stragegy = "strategyid";
+         }
+
+         this.desensitizationStrategyDao.remove(new Criterion[]{Restrictions.eq(stragegy, finalStrategyId), Restrictions.eq("projectid", projectId), Restrictions.eq("datasystem_id", datasystemid), Restrictions.eq("tschemas", schema), Restrictions.eq("names", table)});
+      }
+
+   }
+
+   public List<TCoreDesensitizationStrategy> queryDesenStrategylist(String projectId, String strategyName, String remarks, String roleGroup, String state) {
+      List<TCoreDesensitizationStrategy> desenStrategylist = this.desensitizationStrategyDao.queryDesenStrategylist(projectId, strategyName, remarks, roleGroup, state);
+      return desenStrategylist;
+   }
+
+   public List<TCoreDesensitizationStrategy> queryDesenStrategyDetails(String projectId, String strategyId) {
+      List<TCoreDesensitizationStrategy> desenStrategylist = this.desensitizationStrategyDao.queryDesenStrategyDetails(projectId, strategyId);
+      return desenStrategylist;
+   }
+
+   public void updateRoleGroup(List<TCoreDesensitizationStrategy> tcoreJiaMiDulist, String roleGroup) {
+      int cpp = tcoreJiaMiDulist.size();
+
+      for(int i = 0; i < cpp; ++i) {
+         TCoreDesensitizationStrategy tCoreDesensitizationStrategy = (TCoreDesensitizationStrategy)tcoreJiaMiDulist.get(i);
+         tCoreDesensitizationStrategy.setRolegroup(roleGroup);
+         this.desensitizationStrategyDao.update(tCoreDesensitizationStrategy);
+      }
+
+   }
+
+   public void remove(List<TCoreDesensitizationStrategy> tcoreJiaMiDulist) {
+      int cpp = tcoreJiaMiDulist.size();
+
+      for(int i = 0; i < cpp; ++i) {
+         TCoreDesensitizationStrategy tCoreDesensitizationStrategy = (TCoreDesensitizationStrategy)tcoreJiaMiDulist.get(i);
+         if (null != tCoreDesensitizationStrategy) {
+            this.desensitizationStrategyDao.remove(tCoreDesensitizationStrategy);
+         }
+      }
+
+   }
+
+   public void disableOrEnable(List<TCoreDesensitizationStrategy> tcoreJiaMiDulist, String state) {
+      int cpp = tcoreJiaMiDulist.size();
+
+      for(int i = 0; i < cpp; ++i) {
+         TCoreDesensitizationStrategy tCoreDesensitizationStrategy = (TCoreDesensitizationStrategy)tcoreJiaMiDulist.get(i);
+         tCoreDesensitizationStrategy.setState(state);
+         this.desensitizationStrategyDao.update(tCoreDesensitizationStrategy);
+      }
+
+   }
+
+   public boolean checkStrategy(String ruleId) {
+      List<TCoreDesensitizationStrategy> strategyList = this.desensitizationStrategyDao.queryAll(new Criterion[]{Restrictions.eq("ruleid", ruleId)});
+      return !ObjectUtils.isEmpty(strategyList);
+   }
+
+   public int checkRepeatName(String strategyname, String id, String projectid) {
+      new ArrayList();
+      List list;
+      if (StringUtils.isBlank(id)) {
+         list = this.desensitizationStrategyDao.queryAll(new Criterion[]{Restrictions.eq("strategyname", strategyname), Restrictions.eq("projectid", projectid)});
+      } else {
+         list = this.desensitizationStrategyDao.queryAll(new Criterion[]{Restrictions.eq("strategyname", strategyname), Restrictions.eq("projectid", projectid), Restrictions.ne("id", id)});
+      }
+
+      return list.size();
+   }
+}