浏览代码

Merge branch 'hotfix_2023_08_30' into 'master'

bug修复

See merge request fhl/std-news-process!7
master
Arthur Qin 1年前
父节点
当前提交
c06abc53e3
共有 100 个文件被更改,包括 197 次插入198 次删除
  1. +1
    -1
      common/pom.xml
  2. +3
    -3
      common/src/main/java/tech/deepq/common/advice/ControllerAdvice.java
  3. +2
    -2
      common/src/main/java/tech/deepq/common/advice/ExceptionControllerAdvice.java
  4. +1
    -1
      common/src/main/java/tech/deepq/common/alert/DingMessage.java
  5. +6
    -7
      common/src/main/java/tech/deepq/common/alert/ExceptionAspect.java
  6. +1
    -1
      common/src/main/java/tech/deepq/common/annotation/ResponseBodyEnhanceController.java
  7. +1
    -1
      common/src/main/java/tech/deepq/common/bean/SerializeConfiguration.java
  8. +2
    -2
      common/src/main/java/tech/deepq/common/cache/CacheConfig.java
  9. +1
    -1
      common/src/main/java/tech/deepq/common/config/ContainerCustomizer.java
  10. +1
    -1
      common/src/main/java/tech/deepq/common/config/Knife4jConfiguration.java
  11. +1
    -1
      common/src/main/java/tech/deepq/common/config/MybatisPlusConfiguration.java
  12. +1
    -1
      common/src/main/java/tech/deepq/common/constant/BindingConstants.java
  13. +1
    -1
      common/src/main/java/tech/deepq/common/constant/CacheConstants.java
  14. +1
    -1
      common/src/main/java/tech/deepq/common/constant/CommonConstants.java
  15. +1
    -1
      common/src/main/java/tech/deepq/common/constant/ContextVariableConstants.java
  16. +1
    -1
      common/src/main/java/tech/deepq/common/constant/CustomerDateTimeFormatter.java
  17. +1
    -1
      common/src/main/java/tech/deepq/common/constant/MessageConstants.java
  18. +1
    -1
      common/src/main/java/tech/deepq/common/constant/RawDataFiledKey.java
  19. +1
    -1
      common/src/main/java/tech/deepq/common/constant/RegexConstants.java
  20. +1
    -1
      common/src/main/java/tech/deepq/common/constant/SnapshotConstants.java
  21. +1
    -1
      common/src/main/java/tech/deepq/common/constant/StageConstants.java
  22. +4
    -4
      common/src/main/java/tech/deepq/common/controller/ConfigController.java
  23. +1
    -1
      common/src/main/java/tech/deepq/common/controller/IndexController.java
  24. +4
    -4
      common/src/main/java/tech/deepq/common/controller/RedisController.java
  25. +1
    -1
      common/src/main/java/tech/deepq/common/db/entity/Datasource.java
  26. +2
    -2
      common/src/main/java/tech/deepq/common/db/entity/Mapping.java
  27. +2
    -2
      common/src/main/java/tech/deepq/common/db/entity/Sql.java
  28. +1
    -1
      common/src/main/java/tech/deepq/common/db/entity/Store.java
  29. +7
    -7
      common/src/main/java/tech/deepq/common/db/entity/Task.java
  30. +2
    -2
      common/src/main/java/tech/deepq/common/db/entity/Template.java
  31. +1
    -1
      common/src/main/java/tech/deepq/common/db/entity/vo/Dispatcher.java
  32. +1
    -1
      common/src/main/java/tech/deepq/common/db/entity/vo/MessageMapping.java
  33. +3
    -3
      common/src/main/java/tech/deepq/common/db/entity/vo/MessageTemplate.java
  34. +1
    -1
      common/src/main/java/tech/deepq/common/db/entity/vo/ParseParams.java
  35. +3
    -3
      common/src/main/java/tech/deepq/common/db/entity/vo/SinkParams.java
  36. +3
    -3
      common/src/main/java/tech/deepq/common/db/entity/vo/SqlResult.java
  37. +1
    -1
      common/src/main/java/tech/deepq/common/db/entity/vo/SqlStatements.java
  38. +3
    -3
      common/src/main/java/tech/deepq/common/db/entity/vo/TableTemplate.java
  39. +1
    -1
      common/src/main/java/tech/deepq/common/db/entity/vo/TaskMiniVO.java
  40. +1
    -1
      common/src/main/java/tech/deepq/common/db/entity/vo/TransformParams.java
  41. +1
    -1
      common/src/main/java/tech/deepq/common/db/handler/MybatisMetaObjectHandler.java
  42. +2
    -2
      common/src/main/java/tech/deepq/common/db/mapper/DatasourceMapper.java
  43. +2
    -2
      common/src/main/java/tech/deepq/common/db/mapper/MappingMapper.java
  44. +2
    -2
      common/src/main/java/tech/deepq/common/db/mapper/SqlMapper.java
  45. +2
    -2
      common/src/main/java/tech/deepq/common/db/mapper/StoreMapper.java
  46. +2
    -2
      common/src/main/java/tech/deepq/common/db/mapper/TaskMapper.java
  47. +2
    -2
      common/src/main/java/tech/deepq/common/db/mapper/TemplateMapper.java
  48. +3
    -3
      common/src/main/java/tech/deepq/common/db/service/DatasourceService.java
  49. +3
    -3
      common/src/main/java/tech/deepq/common/db/service/MappingService.java
  50. +3
    -3
      common/src/main/java/tech/deepq/common/db/service/SqlManager.java
  51. +3
    -3
      common/src/main/java/tech/deepq/common/db/service/SqlService.java
  52. +3
    -3
      common/src/main/java/tech/deepq/common/db/service/StoreManager.java
  53. +3
    -3
      common/src/main/java/tech/deepq/common/db/service/StoreService.java
  54. +8
    -8
      common/src/main/java/tech/deepq/common/db/service/TaskManager.java
  55. +3
    -3
      common/src/main/java/tech/deepq/common/db/service/TaskService.java
  56. +3
    -3
      common/src/main/java/tech/deepq/common/db/service/TemplateService.java
  57. +3
    -3
      common/src/main/java/tech/deepq/common/dto/HttpRequestParams.java
  58. +2
    -2
      common/src/main/java/tech/deepq/common/dto/HttpRes.java
  59. +1
    -1
      common/src/main/java/tech/deepq/common/dto/R.java
  60. +1
    -1
      common/src/main/java/tech/deepq/common/dto/SignatureConfig.java
  61. +1
    -1
      common/src/main/java/tech/deepq/common/dto/SignatureContext.java
  62. +3
    -3
      common/src/main/java/tech/deepq/common/dto/TaskVO.java
  63. +1
    -1
      common/src/main/java/tech/deepq/common/enums/DMLResultEnum.java
  64. +1
    -1
      common/src/main/java/tech/deepq/common/enums/DbFieldType.java
  65. +1
    -1
      common/src/main/java/tech/deepq/common/enums/DeleteCheckMode.java
  66. +1
    -1
      common/src/main/java/tech/deepq/common/enums/MessageFieldType.java
  67. +1
    -1
      common/src/main/java/tech/deepq/common/enums/MessageType.java
  68. +1
    -1
      common/src/main/java/tech/deepq/common/enums/ProcessMode.java
  69. +1
    -1
      common/src/main/java/tech/deepq/common/enums/ProcessReason.java
  70. +1
    -1
      common/src/main/java/tech/deepq/common/enums/RequestMode.java
  71. +1
    -1
      common/src/main/java/tech/deepq/common/enums/ResourceStatus.java
  72. +1
    -1
      common/src/main/java/tech/deepq/common/enums/SignatureEnumGroup.java
  73. +1
    -1
      common/src/main/java/tech/deepq/common/enums/Status.java
  74. +1
    -1
      common/src/main/java/tech/deepq/common/enums/UpdateStrategy.java
  75. +1
    -1
      common/src/main/java/tech/deepq/common/enums/VariableType.java
  76. +1
    -1
      common/src/main/java/tech/deepq/common/properties/AlertProperties.java
  77. +1
    -1
      common/src/main/java/tech/deepq/common/properties/CommonProperties.java
  78. +1
    -1
      common/src/main/java/tech/deepq/common/properties/RedisProperties.java
  79. +2
    -2
      common/src/main/java/tech/deepq/common/properties/YueKeProperties.java
  80. +5
    -5
      common/src/main/java/tech/deepq/common/service/MessageService.java
  81. +2
    -2
      common/src/main/java/tech/deepq/common/service/RedisService.java
  82. +4
    -4
      common/src/main/java/tech/deepq/common/service/UrlMD5Service.java
  83. +6
    -6
      common/src/main/java/tech/deepq/common/spel/CustomFunction.java
  84. +1
    -1
      common/src/main/java/tech/deepq/common/spel/JsonPathHandler.java
  85. +1
    -1
      common/src/main/java/tech/deepq/common/spel/SPelConfiguration.java
  86. +4
    -4
      common/src/main/java/tech/deepq/common/spel/SpringExpressionLanguageEvaluator.java
  87. +2
    -2
      common/src/main/java/tech/deepq/common/store/MessageMD5Store.java
  88. +3
    -3
      common/src/main/java/tech/deepq/common/store/MySQLCachedNsKVMapStore.java
  89. +1
    -1
      common/src/main/java/tech/deepq/common/store/NsKVMapStore.java
  90. +2
    -2
      common/src/main/java/tech/deepq/common/store/UrlMD5MapStore.java
  91. +5
    -5
      common/src/main/java/tech/deepq/common/utils/DebugUtil.java
  92. +1
    -1
      common/src/main/java/tech/deepq/common/utils/HttpUtil.java
  93. +1
    -1
      common/src/main/java/tech/deepq/common/utils/ID.java
  94. +1
    -1
      common/src/main/java/tech/deepq/common/utils/JsonPathUtil.java
  95. +1
    -1
      common/src/main/java/tech/deepq/common/utils/MessageUtil.java
  96. +1
    -1
      common/src/main/java/tech/deepq/common/utils/SpEL.java
  97. +3
    -3
      common/src/main/java/tech/deepq/common/utils/signature/AbstractSignatureService.java
  98. +3
    -3
      common/src/main/java/tech/deepq/common/utils/signature/RSASignatureService.java
  99. +3
    -3
      common/src/main/java/tech/deepq/common/utils/signature/SignatureFactory.java
  100. +1
    -1
      common/src/main/resources/mapper/DatasourceMapper.xml

+ 1
- 1
common/pom.xml 查看文件

@@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>work.xuye</groupId>
<groupId>tech.deepq</groupId>
<artifactId>std-news-process</artifactId>
<version>0.0.19-SNAPSHOT</version>
</parent>


common/src/main/java/work/xuye/common/advice/ControllerAdvice.java → common/src/main/java/tech/deepq/common/advice/ControllerAdvice.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.advice;
package tech.deepq.common.advice;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -11,8 +11,8 @@ import org.springframework.lang.NonNull;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyAdvice;
import work.xuye.common.annotation.ResponseBodyEnhanceController;
import work.xuye.common.dto.R;
import tech.deepq.common.dto.R;
import tech.deepq.common.annotation.ResponseBodyEnhanceController;

import java.util.Objects;


common/src/main/java/work/xuye/common/advice/ExceptionControllerAdvice.java → common/src/main/java/tech/deepq/common/advice/ExceptionControllerAdvice.java 查看文件

@@ -1,9 +1,9 @@
package work.xuye.common.advice;
package tech.deepq.common.advice;

import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import work.xuye.common.dto.R;
import tech.deepq.common.dto.R;

/**
* @author xuye

common/src/main/java/work/xuye/common/alert/DingMessage.java → common/src/main/java/tech/deepq/common/alert/DingMessage.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.alert;
package tech.deepq.common.alert;

import com.dingtalk.api.DefaultDingTalkClient;
import com.dingtalk.api.DingTalkClient;

common/src/main/java/work/xuye/common/alert/ExceptionAspect.java → common/src/main/java/tech/deepq/common/alert/ExceptionAspect.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.alert;
package tech.deepq.common.alert;

import io.sentry.Sentry;
import lombok.RequiredArgsConstructor;
@@ -6,8 +6,8 @@ import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.annotation.AfterThrowing;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;
import work.xuye.common.enums.MessageType;
import work.xuye.common.service.MessageService;
import tech.deepq.common.enums.MessageType;
import tech.deepq.common.service.MessageService;

import java.util.List;

@@ -23,13 +23,12 @@ public class ExceptionAspect {

private final MessageService messageService;

@AfterThrowing(pointcut = "execution(* work.xuye..*(..))&& !execution(* work.xuye.common.service.MessageService.*(..))", throwing = "ex")
@AfterThrowing(pointcut = "execution(* tech.deepq..*(..))&& !execution(* tech.deepq.common.service.MessageService.*(..))", throwing = "ex")
public void handleGlobalException(Exception ex) {



List<StackTraceElement> stackTraceElements = new java.util.ArrayList<>(List.of(ex.getStackTrace()));
stackTraceElements.removeIf(stackTraceElement -> !stackTraceElement.getClassName().contains("work.xuye"));
stackTraceElements.removeIf(stackTraceElement -> !stackTraceElement.getClassName().contains("tech.deepq"));
StringBuilder traceString = new StringBuilder();
stackTraceElements.stream()
.filter(stackTraceElement -> stackTraceElement.getLineNumber() > 0)
@@ -40,7 +39,7 @@ public class ExceptionAspect {
.append(stackTraceElement.getLineNumber()).append(")\n"));
String traceStringString = traceString.toString();

if (traceStringString.contains("work.xuye.common.service.MessageService")){
if (traceStringString.contains("tech.deepq.common.service.MessageService")) {
return;
}


common/src/main/java/work/xuye/common/annotation/ResponseBodyEnhanceController.java → common/src/main/java/tech/deepq/common/annotation/ResponseBodyEnhanceController.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.annotation;
package tech.deepq.common.annotation;

import org.springframework.web.bind.annotation.RestController;


common/src/main/java/work/xuye/common/bean/SerializeConfiguration.java → common/src/main/java/tech/deepq/common/bean/SerializeConfiguration.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.bean;
package tech.deepq.common.bean;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;

common/src/main/java/work/xuye/common/cache/CacheConfig.java → common/src/main/java/tech/deepq/common/cache/CacheConfig.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.cache;
package tech.deepq.common.cache;

import lombok.RequiredArgsConstructor;
import org.springframework.cache.CacheManager;
@@ -11,7 +11,7 @@ import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import work.xuye.common.properties.RedisProperties;
import tech.deepq.common.properties.RedisProperties;

import java.time.Duration;


common/src/main/java/work/xuye/common/config/ContainerCustomizer.java → common/src/main/java/tech/deepq/common/config/ContainerCustomizer.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.config;
package tech.deepq.common.config;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;

common/src/main/java/work/xuye/common/config/Knife4jConfiguration.java → common/src/main/java/tech/deepq/common/config/Knife4jConfiguration.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.config;
package tech.deepq.common.config;

import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanPostProcessor;

common/src/main/java/work/xuye/common/config/MybatisPlusConfiguration.java → common/src/main/java/tech/deepq/common/config/MybatisPlusConfiguration.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.config;
package tech.deepq.common.config;

import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor;

common/src/main/java/work/xuye/common/constant/BindingConstants.java → common/src/main/java/tech/deepq/common/constant/BindingConstants.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

/**
* @author xuye

common/src/main/java/work/xuye/common/constant/CacheConstants.java → common/src/main/java/tech/deepq/common/constant/CacheConstants.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

/**
* @author xuye

common/src/main/java/work/xuye/common/constant/CommonConstants.java → common/src/main/java/tech/deepq/common/constant/CommonConstants.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

/**
* @author xuye

common/src/main/java/work/xuye/common/constant/ContextVariableConstants.java → common/src/main/java/tech/deepq/common/constant/ContextVariableConstants.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

/**
* @author xuye

common/src/main/java/work/xuye/common/constant/CustomerDateTimeFormatter.java → common/src/main/java/tech/deepq/common/constant/CustomerDateTimeFormatter.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

import java.time.format.DateTimeFormatter;


common/src/main/java/work/xuye/common/constant/MessageConstants.java → common/src/main/java/tech/deepq/common/constant/MessageConstants.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

/**
* @author xuye

common/src/main/java/work/xuye/common/constant/RawDataFiledKey.java → common/src/main/java/tech/deepq/common/constant/RawDataFiledKey.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

/**
* <a href="https://deepq.yuque.com/deepq/bur3gk/gkw4nxgvlel14v8t">...</a>

common/src/main/java/work/xuye/common/constant/RegexConstants.java → common/src/main/java/tech/deepq/common/constant/RegexConstants.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

import java.util.regex.Pattern;


common/src/main/java/work/xuye/common/constant/SnapshotConstants.java → common/src/main/java/tech/deepq/common/constant/SnapshotConstants.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

/**
* @author xuye

common/src/main/java/work/xuye/common/constant/StageConstants.java → common/src/main/java/tech/deepq/common/constant/StageConstants.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.constant;
package tech.deepq.common.constant;

/**
* @author xuye

common/src/main/java/work/xuye/common/controller/ConfigController.java → common/src/main/java/tech/deepq/common/controller/ConfigController.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.controller;
package tech.deepq.common.controller;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
@@ -7,9 +7,9 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import work.xuye.common.annotation.ResponseBodyEnhanceController;
import work.xuye.common.db.entity.*;
import work.xuye.common.db.service.*;
import tech.deepq.common.annotation.ResponseBodyEnhanceController;
import tech.deepq.common.db.entity.*;
import tech.deepq.common.db.service.*;

import java.util.List;


common/src/main/java/work/xuye/common/controller/IndexController.java → common/src/main/java/tech/deepq/common/controller/IndexController.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.controller;
package tech.deepq.common.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;

common/src/main/java/work/xuye/common/controller/RedisController.java → common/src/main/java/tech/deepq/common/controller/RedisController.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.controller;
package tech.deepq.common.controller;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
@@ -8,9 +8,9 @@ import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import work.xuye.common.annotation.ResponseBodyEnhanceController;
import work.xuye.common.properties.RedisProperties;
import work.xuye.common.service.RedisService;
import tech.deepq.common.properties.RedisProperties;
import tech.deepq.common.service.RedisService;
import tech.deepq.common.annotation.ResponseBodyEnhanceController;

import java.util.HashSet;
import java.util.Map;

common/src/main/java/work/xuye/common/db/entity/Datasource.java → common/src/main/java/tech/deepq/common/db/entity/Datasource.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity;
package tech.deepq.common.db.entity;

import com.baomidou.mybatisplus.annotation.*;
import com.fasterxml.jackson.annotation.JsonIgnore;

common/src/main/java/work/xuye/common/db/entity/Mapping.java → common/src/main/java/tech/deepq/common/db/entity/Mapping.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity;
package tech.deepq.common.db.entity;

import com.baomidou.mybatisplus.annotation.*;
import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
@@ -9,7 +9,7 @@ import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;
import work.xuye.common.db.entity.vo.MessageMapping;
import tech.deepq.common.db.entity.vo.MessageMapping;

import java.io.Serializable;
import java.time.LocalDateTime;

common/src/main/java/work/xuye/common/db/entity/Sql.java → common/src/main/java/tech/deepq/common/db/entity/Sql.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity;
package tech.deepq.common.db.entity;

import com.baomidou.mybatisplus.annotation.*;
import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
@@ -9,7 +9,7 @@ import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;
import work.xuye.common.db.entity.vo.SqlStatements;
import tech.deepq.common.db.entity.vo.SqlStatements;

import java.io.Serializable;
import java.time.LocalDateTime;

common/src/main/java/work/xuye/common/db/entity/Store.java → common/src/main/java/tech/deepq/common/db/entity/Store.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity;
package tech.deepq.common.db.entity;

import com.baomidou.mybatisplus.annotation.*;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;

common/src/main/java/work/xuye/common/db/entity/Task.java → common/src/main/java/tech/deepq/common/db/entity/Task.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity;
package tech.deepq.common.db.entity;

import com.baomidou.mybatisplus.annotation.*;
import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
@@ -9,12 +9,12 @@ import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;
import work.xuye.common.db.entity.vo.Dispatcher;
import work.xuye.common.db.entity.vo.ParseParams;
import work.xuye.common.db.entity.vo.SinkParams;
import work.xuye.common.db.entity.vo.TransformParams;
import work.xuye.common.dto.HttpRequestParams;
import work.xuye.common.enums.ProcessMode;
import tech.deepq.common.db.entity.vo.Dispatcher;
import tech.deepq.common.db.entity.vo.ParseParams;
import tech.deepq.common.db.entity.vo.SinkParams;
import tech.deepq.common.db.entity.vo.TransformParams;
import tech.deepq.common.dto.HttpRequestParams;
import tech.deepq.common.enums.ProcessMode;

import java.io.Serializable;
import java.time.LocalDateTime;

common/src/main/java/work/xuye/common/db/entity/Template.java → common/src/main/java/tech/deepq/common/db/entity/Template.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity;
package tech.deepq.common.db.entity;

import com.baomidou.mybatisplus.annotation.*;
import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
@@ -9,7 +9,7 @@ import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;
import work.xuye.common.db.entity.vo.TableTemplate;
import tech.deepq.common.db.entity.vo.TableTemplate;

import java.io.Serializable;
import java.time.LocalDateTime;

common/src/main/java/work/xuye/common/db/entity/vo/Dispatcher.java → common/src/main/java/tech/deepq/common/db/entity/vo/Dispatcher.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Data;

common/src/main/java/work/xuye/common/db/entity/vo/MessageMapping.java → common/src/main/java/tech/deepq/common/db/entity/vo/MessageMapping.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Data;

common/src/main/java/work/xuye/common/db/entity/vo/MessageTemplate.java → common/src/main/java/tech/deepq/common/db/entity/vo/MessageTemplate.java 查看文件

@@ -1,10 +1,10 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import work.xuye.common.enums.MessageFieldType;
import work.xuye.common.enums.VariableType;
import tech.deepq.common.enums.MessageFieldType;
import tech.deepq.common.enums.VariableType;

import java.util.List;


common/src/main/java/work/xuye/common/db/entity/vo/ParseParams.java → common/src/main/java/tech/deepq/common/db/entity/vo/ParseParams.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Data;

common/src/main/java/work/xuye/common/db/entity/vo/SinkParams.java → common/src/main/java/tech/deepq/common/db/entity/vo/SinkParams.java 查看文件

@@ -1,10 +1,10 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import work.xuye.common.enums.DeleteCheckMode;
import work.xuye.common.enums.Status;
import tech.deepq.common.enums.DeleteCheckMode;
import tech.deepq.common.enums.Status;

import java.util.List;


common/src/main/java/work/xuye/common/db/entity/vo/SqlResult.java → common/src/main/java/tech/deepq/common/db/entity/vo/SqlResult.java 查看文件

@@ -1,10 +1,10 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import work.xuye.common.db.entity.Sql;
import work.xuye.common.enums.DMLResultEnum;
import tech.deepq.common.enums.DMLResultEnum;
import tech.deepq.common.db.entity.Sql;

/**
* @author xuye

common/src/main/java/work/xuye/common/db/entity/vo/SqlStatements.java → common/src/main/java/tech/deepq/common/db/entity/vo/SqlStatements.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Data;

common/src/main/java/work/xuye/common/db/entity/vo/TableTemplate.java → common/src/main/java/tech/deepq/common/db/entity/vo/TableTemplate.java 查看文件

@@ -1,11 +1,11 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import work.xuye.common.enums.DbFieldType;
import work.xuye.common.enums.UpdateStrategy;
import tech.deepq.common.enums.DbFieldType;
import tech.deepq.common.enums.UpdateStrategy;

import java.util.List;


common/src/main/java/work/xuye/common/db/entity/vo/TaskMiniVO.java → common/src/main/java/tech/deepq/common/db/entity/vo/TaskMiniVO.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Builder;

common/src/main/java/work/xuye/common/db/entity/vo/TransformParams.java → common/src/main/java/tech/deepq/common/db/entity/vo/TransformParams.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.entity.vo;
package tech.deepq.common.db.entity.vo;

import lombok.AllArgsConstructor;
import lombok.Data;

common/src/main/java/work/xuye/common/db/handler/MybatisMetaObjectHandler.java → common/src/main/java/tech/deepq/common/db/handler/MybatisMetaObjectHandler.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.handler;
package tech.deepq.common.db.handler;


import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;

common/src/main/java/work/xuye/common/db/mapper/DatasourceMapper.java → common/src/main/java/tech/deepq/common/db/mapper/DatasourceMapper.java 查看文件

@@ -1,6 +1,6 @@
package work.xuye.common.db.mapper;
package tech.deepq.common.db.mapper;

import work.xuye.common.db.entity.Datasource;
import tech.deepq.common.db.entity.Datasource;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;


common/src/main/java/work/xuye/common/db/mapper/MappingMapper.java → common/src/main/java/tech/deepq/common/db/mapper/MappingMapper.java 查看文件

@@ -1,6 +1,6 @@
package work.xuye.common.db.mapper;
package tech.deepq.common.db.mapper;

import work.xuye.common.db.entity.Mapping;
import tech.deepq.common.db.entity.Mapping;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;


common/src/main/java/work/xuye/common/db/mapper/SqlMapper.java → common/src/main/java/tech/deepq/common/db/mapper/SqlMapper.java 查看文件

@@ -1,8 +1,8 @@
package work.xuye.common.db.mapper;
package tech.deepq.common.db.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import work.xuye.common.db.entity.Sql;
import tech.deepq.common.db.entity.Sql;

/**
* <p>

common/src/main/java/work/xuye/common/db/mapper/StoreMapper.java → common/src/main/java/tech/deepq/common/db/mapper/StoreMapper.java 查看文件

@@ -1,8 +1,8 @@
package work.xuye.common.db.mapper;
package tech.deepq.common.db.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import work.xuye.common.db.entity.Store;
import tech.deepq.common.db.entity.Store;

/**
* <p>

common/src/main/java/work/xuye/common/db/mapper/TaskMapper.java → common/src/main/java/tech/deepq/common/db/mapper/TaskMapper.java 查看文件

@@ -1,6 +1,6 @@
package work.xuye.common.db.mapper;
package tech.deepq.common.db.mapper;

import work.xuye.common.db.entity.Task;
import tech.deepq.common.db.entity.Task;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;


common/src/main/java/work/xuye/common/db/mapper/TemplateMapper.java → common/src/main/java/tech/deepq/common/db/mapper/TemplateMapper.java 查看文件

@@ -1,6 +1,6 @@
package work.xuye.common.db.mapper;
package tech.deepq.common.db.mapper;

import work.xuye.common.db.entity.Template;
import tech.deepq.common.db.entity.Template;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;


common/src/main/java/work/xuye/common/db/service/DatasourceService.java → common/src/main/java/tech/deepq/common/db/service/DatasourceService.java 查看文件

@@ -1,9 +1,9 @@
package work.xuye.common.db.service;
package tech.deepq.common.db.service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import work.xuye.common.db.entity.Datasource;
import work.xuye.common.db.mapper.DatasourceMapper;
import tech.deepq.common.db.mapper.DatasourceMapper;
import tech.deepq.common.db.entity.Datasource;

/**
* <p>

common/src/main/java/work/xuye/common/db/service/MappingService.java → common/src/main/java/tech/deepq/common/db/service/MappingService.java 查看文件

@@ -1,9 +1,9 @@
package work.xuye.common.db.service;
package tech.deepq.common.db.service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import work.xuye.common.db.entity.Mapping;
import work.xuye.common.db.mapper.MappingMapper;
import tech.deepq.common.db.mapper.MappingMapper;
import tech.deepq.common.db.entity.Mapping;

/**
* <p>

common/src/main/java/work/xuye/common/db/service/SqlManager.java → common/src/main/java/tech/deepq/common/db/service/SqlManager.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.service;
package tech.deepq.common.db.service;

import lombok.Getter;
import lombok.RequiredArgsConstructor;
@@ -6,8 +6,8 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.util.DigestUtils;
import org.springframework.util.ObjectUtils;
import work.xuye.common.db.entity.Sql;
import work.xuye.common.db.entity.vo.SqlStatements;
import tech.deepq.common.db.entity.Sql;
import tech.deepq.common.db.entity.vo.SqlStatements;

import java.util.List;


common/src/main/java/work/xuye/common/db/service/SqlService.java → common/src/main/java/tech/deepq/common/db/service/SqlService.java 查看文件

@@ -1,9 +1,9 @@
package work.xuye.common.db.service;
package tech.deepq.common.db.service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import work.xuye.common.db.entity.Sql;
import work.xuye.common.db.mapper.SqlMapper;
import tech.deepq.common.db.mapper.SqlMapper;
import tech.deepq.common.db.entity.Sql;

/**
* <p>

common/src/main/java/work/xuye/common/db/service/StoreManager.java → common/src/main/java/tech/deepq/common/db/service/StoreManager.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.service;
package tech.deepq.common.db.service;

import lombok.Getter;
import lombok.RequiredArgsConstructor;
@@ -6,8 +6,8 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;
import work.xuye.common.constant.CacheConstants;
import work.xuye.common.db.entity.Store;
import tech.deepq.common.constant.CacheConstants;
import tech.deepq.common.db.entity.Store;

/**
* @author xuye

common/src/main/java/work/xuye/common/db/service/StoreService.java → common/src/main/java/tech/deepq/common/db/service/StoreService.java 查看文件

@@ -1,9 +1,9 @@
package work.xuye.common.db.service;
package tech.deepq.common.db.service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import work.xuye.common.db.entity.Store;
import work.xuye.common.db.mapper.StoreMapper;
import tech.deepq.common.db.mapper.StoreMapper;
import tech.deepq.common.db.entity.Store;

/**
* <p>

common/src/main/java/work/xuye/common/db/service/TaskManager.java → common/src/main/java/tech/deepq/common/db/service/TaskManager.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.db.service;
package tech.deepq.common.db.service;

import lombok.Getter;
import lombok.RequiredArgsConstructor;
@@ -6,13 +6,13 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;
import org.springframework.util.Assert;
import work.xuye.common.constant.CacheConstants;
import work.xuye.common.db.entity.Mapping;
import work.xuye.common.db.entity.Task;
import work.xuye.common.db.entity.Template;
import work.xuye.common.db.entity.vo.SinkParams;
import work.xuye.common.dto.TaskVO;
import work.xuye.common.spel.CustomFunction;
import tech.deepq.common.db.entity.vo.SinkParams;
import tech.deepq.common.dto.TaskVO;
import tech.deepq.common.constant.CacheConstants;
import tech.deepq.common.db.entity.Mapping;
import tech.deepq.common.db.entity.Task;
import tech.deepq.common.db.entity.Template;
import tech.deepq.common.spel.CustomFunction;

import java.util.List;
import java.util.Map;

common/src/main/java/work/xuye/common/db/service/TaskService.java → common/src/main/java/tech/deepq/common/db/service/TaskService.java 查看文件

@@ -1,9 +1,9 @@
package work.xuye.common.db.service;
package tech.deepq.common.db.service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import work.xuye.common.db.entity.Task;
import work.xuye.common.db.mapper.TaskMapper;
import tech.deepq.common.db.mapper.TaskMapper;
import tech.deepq.common.db.entity.Task;

/**
* <p>

common/src/main/java/work/xuye/common/db/service/TemplateService.java → common/src/main/java/tech/deepq/common/db/service/TemplateService.java 查看文件

@@ -1,9 +1,9 @@
package work.xuye.common.db.service;
package tech.deepq.common.db.service;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import work.xuye.common.db.entity.Template;
import work.xuye.common.db.mapper.TemplateMapper;
import tech.deepq.common.db.entity.Template;
import tech.deepq.common.db.mapper.TemplateMapper;

/**
* <p>

common/src/main/java/work/xuye/common/dto/HttpRequestParams.java → common/src/main/java/tech/deepq/common/dto/HttpRequestParams.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.dto;
package tech.deepq.common.dto;

import cn.hutool.core.collection.CollUtil;
import com.baomidou.mybatisplus.annotation.TableField;
@@ -10,8 +10,8 @@ import org.springframework.expression.EvaluationContext;
import org.springframework.expression.spel.standard.SpelExpressionParser;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import work.xuye.common.enums.RequestMode;
import work.xuye.common.enums.SignatureEnumGroup;
import tech.deepq.common.enums.RequestMode;
import tech.deepq.common.enums.SignatureEnumGroup;

import java.util.Collections;
import java.util.HashMap;

common/src/main/java/work/xuye/common/dto/HttpRes.java → common/src/main/java/tech/deepq/common/dto/HttpRes.java 查看文件

@@ -1,11 +1,11 @@
package work.xuye.common.dto;
package tech.deepq.common.dto;

import com.fasterxml.jackson.annotation.JsonInclude;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.http.HttpStatus;
import work.xuye.common.enums.ResourceStatus;
import tech.deepq.common.enums.ResourceStatus;

import java.util.List;
import java.util.Map;

common/src/main/java/work/xuye/common/dto/R.java → common/src/main/java/tech/deepq/common/dto/R.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.dto;
package tech.deepq.common.dto;

import com.fasterxml.jackson.annotation.JsonIgnore;
import lombok.Data;

common/src/main/java/work/xuye/common/dto/SignatureConfig.java → common/src/main/java/tech/deepq/common/dto/SignatureConfig.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.dto;
package tech.deepq.common.dto;

import lombok.AllArgsConstructor;
import lombok.Data;

common/src/main/java/work/xuye/common/dto/SignatureContext.java → common/src/main/java/tech/deepq/common/dto/SignatureContext.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.dto;
package tech.deepq.common.dto;

import lombok.Data;


common/src/main/java/work/xuye/common/dto/TaskVO.java → common/src/main/java/tech/deepq/common/dto/TaskVO.java 查看文件

@@ -1,11 +1,11 @@
package work.xuye.common.dto;
package tech.deepq.common.dto;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import work.xuye.common.db.entity.Mapping;
import work.xuye.common.db.entity.Task;
import tech.deepq.common.db.entity.Mapping;
import tech.deepq.common.db.entity.Task;

import java.util.Map;


common/src/main/java/work/xuye/common/enums/DMLResultEnum.java → common/src/main/java/tech/deepq/common/enums/DMLResultEnum.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;


import com.baomidou.mybatisplus.annotation.EnumValue;

common/src/main/java/work/xuye/common/enums/DbFieldType.java → common/src/main/java/tech/deepq/common/enums/DbFieldType.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* @author xuye

common/src/main/java/work/xuye/common/enums/DeleteCheckMode.java → common/src/main/java/tech/deepq/common/enums/DeleteCheckMode.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* @author xuye

common/src/main/java/work/xuye/common/enums/MessageFieldType.java → common/src/main/java/tech/deepq/common/enums/MessageFieldType.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* @author xuye

common/src/main/java/work/xuye/common/enums/MessageType.java → common/src/main/java/tech/deepq/common/enums/MessageType.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* @author xuye

common/src/main/java/work/xuye/common/enums/ProcessMode.java → common/src/main/java/tech/deepq/common/enums/ProcessMode.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* @author xuye

common/src/main/java/work/xuye/common/enums/ProcessReason.java → common/src/main/java/tech/deepq/common/enums/ProcessReason.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

import lombok.Getter;


common/src/main/java/work/xuye/common/enums/RequestMode.java → common/src/main/java/tech/deepq/common/enums/RequestMode.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* @author xuye

common/src/main/java/work/xuye/common/enums/ResourceStatus.java → common/src/main/java/tech/deepq/common/enums/ResourceStatus.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

import lombok.Getter;


common/src/main/java/work/xuye/common/enums/SignatureEnumGroup.java → common/src/main/java/tech/deepq/common/enums/SignatureEnumGroup.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* @author yechuan

common/src/main/java/work/xuye/common/enums/Status.java → common/src/main/java/tech/deepq/common/enums/Status.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* @author xuye

common/src/main/java/work/xuye/common/enums/UpdateStrategy.java → common/src/main/java/tech/deepq/common/enums/UpdateStrategy.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* 修改时的策略

common/src/main/java/work/xuye/common/enums/VariableType.java → common/src/main/java/tech/deepq/common/enums/VariableType.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.enums;
package tech.deepq.common.enums;

/**
* @author xuye

common/src/main/java/work/xuye/common/properties/AlertProperties.java → common/src/main/java/tech/deepq/common/properties/AlertProperties.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.properties;
package tech.deepq.common.properties;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;

common/src/main/java/work/xuye/common/properties/CommonProperties.java → common/src/main/java/tech/deepq/common/properties/CommonProperties.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.properties;
package tech.deepq.common.properties;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;

common/src/main/java/work/xuye/common/properties/RedisProperties.java → common/src/main/java/tech/deepq/common/properties/RedisProperties.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.properties;
package tech.deepq.common.properties;

import lombok.AllArgsConstructor;
import lombok.Data;

common/src/main/java/work/xuye/common/properties/YueKeProperties.java → common/src/main/java/tech/deepq/common/properties/YueKeProperties.java 查看文件

@@ -1,10 +1,10 @@
package work.xuye.common.properties;
package tech.deepq.common.properties;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;
import work.xuye.common.constant.CommonConstants;
import tech.deepq.common.constant.CommonConstants;

/**
* @author xuye

common/src/main/java/work/xuye/common/service/MessageService.java → common/src/main/java/tech/deepq/common/service/MessageService.java 查看文件

@@ -1,13 +1,13 @@
package work.xuye.common.service;
package tech.deepq.common.service;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
import work.xuye.common.alert.DingMessage;
import work.xuye.common.enums.MessageType;
import work.xuye.common.properties.AlertProperties;
import work.xuye.common.store.MessageMD5Store;
import tech.deepq.common.alert.DingMessage;
import tech.deepq.common.enums.MessageType;
import tech.deepq.common.store.MessageMD5Store;
import tech.deepq.common.properties.AlertProperties;

import java.util.Objects;


common/src/main/java/work/xuye/common/service/RedisService.java → common/src/main/java/tech/deepq/common/service/RedisService.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.service;
package tech.deepq.common.service;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -6,7 +6,7 @@ import org.springframework.boot.CommandLineRunner;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
import work.xuye.common.properties.RedisProperties;
import tech.deepq.common.properties.RedisProperties;

import java.util.Map;


common/src/main/java/work/xuye/common/service/UrlMD5Service.java → common/src/main/java/tech/deepq/common/service/UrlMD5Service.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.service;
package tech.deepq.common.service;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -6,9 +6,9 @@ import org.springframework.messaging.Message;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
import org.springframework.util.StringUtils;
import work.xuye.common.constant.MessageConstants;
import work.xuye.common.enums.ResourceStatus;
import work.xuye.common.store.UrlMD5MapStore;
import tech.deepq.common.constant.MessageConstants;
import tech.deepq.common.enums.ResourceStatus;
import tech.deepq.common.store.UrlMD5MapStore;

import java.util.Set;


common/src/main/java/work/xuye/common/spel/CustomFunction.java → common/src/main/java/tech/deepq/common/spel/CustomFunction.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.spel;
package tech.deepq.common.spel;

import com.google.gson.JsonArray;
import com.google.gson.JsonObject;
@@ -15,11 +15,11 @@ import org.springframework.util.DigestUtils;
import org.springframework.util.MultiValueMap;
import org.springframework.util.ObjectUtils;
import org.springframework.web.util.UriComponentsBuilder;
import work.xuye.common.constant.CustomerDateTimeFormatter;
import work.xuye.common.constant.RawDataFiledKey;
import work.xuye.common.store.NsKVMapStore;
import work.xuye.common.utils.HttpUtil;
import work.xuye.common.utils.JsonPathUtil;
import tech.deepq.common.constant.CustomerDateTimeFormatter;
import tech.deepq.common.constant.RawDataFiledKey;
import tech.deepq.common.store.NsKVMapStore;
import tech.deepq.common.utils.HttpUtil;
import tech.deepq.common.utils.JsonPathUtil;

import java.time.Instant;
import java.time.LocalDateTime;

common/src/main/java/work/xuye/common/spel/JsonPathHandler.java → common/src/main/java/tech/deepq/common/spel/JsonPathHandler.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.spel;
package tech.deepq.common.spel;

import com.jayway.jsonpath.JsonPath;
import lombok.extern.slf4j.Slf4j;

common/src/main/java/work/xuye/common/spel/SPelConfiguration.java → common/src/main/java/tech/deepq/common/spel/SPelConfiguration.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.spel;
package tech.deepq.common.spel;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

common/src/main/java/work/xuye/common/spel/SpringExpressionLanguageEvaluator.java → common/src/main/java/tech/deepq/common/spel/SpringExpressionLanguageEvaluator.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.spel;
package tech.deepq.common.spel;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -7,9 +7,9 @@ import org.springframework.expression.spel.standard.SpelExpressionParser;
import org.springframework.expression.spel.support.StandardEvaluationContext;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Service;
import work.xuye.common.constant.ContextVariableConstants;
import work.xuye.common.constant.MessageConstants;
import work.xuye.common.db.entity.vo.MessageMapping;
import tech.deepq.common.db.entity.vo.MessageMapping;
import tech.deepq.common.constant.ContextVariableConstants;
import tech.deepq.common.constant.MessageConstants;

import java.util.HashMap;
import java.util.List;

common/src/main/java/work/xuye/common/store/MessageMD5Store.java → common/src/main/java/tech/deepq/common/store/MessageMD5Store.java 查看文件

@@ -1,11 +1,11 @@
package work.xuye.common.store;
package tech.deepq.common.store;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.DigestUtils;
import work.xuye.common.properties.RedisProperties;
import tech.deepq.common.properties.RedisProperties;

import java.util.concurrent.TimeUnit;


common/src/main/java/work/xuye/common/store/MySQLCachedNsKVMapStore.java → common/src/main/java/tech/deepq/common/store/MySQLCachedNsKVMapStore.java 查看文件

@@ -1,11 +1,11 @@
package work.xuye.common.store;
package tech.deepq.common.store;

import lombok.RequiredArgsConstructor;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
import work.xuye.common.db.entity.Store;
import work.xuye.common.db.service.StoreManager;
import tech.deepq.common.db.service.StoreManager;
import tech.deepq.common.db.entity.Store;

/**
* @author xuye

common/src/main/java/work/xuye/common/store/NsKVMapStore.java → common/src/main/java/tech/deepq/common/store/NsKVMapStore.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.store;
package tech.deepq.common.store;

/**
* @author xuye

common/src/main/java/work/xuye/common/store/UrlMD5MapStore.java → common/src/main/java/tech/deepq/common/store/UrlMD5MapStore.java 查看文件

@@ -1,10 +1,10 @@
package work.xuye.common.store;
package tech.deepq.common.store;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import work.xuye.common.properties.RedisProperties;
import tech.deepq.common.properties.RedisProperties;

import java.util.concurrent.TimeUnit;


common/src/main/java/work/xuye/common/utils/DebugUtil.java → common/src/main/java/tech/deepq/common/utils/DebugUtil.java 查看文件

@@ -1,12 +1,12 @@
package work.xuye.common.utils;
package tech.deepq.common.utils;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import work.xuye.common.db.entity.Task;
import work.xuye.common.db.entity.vo.TaskMiniVO;
import work.xuye.common.dto.TaskVO;
import work.xuye.common.properties.CommonProperties;
import tech.deepq.common.db.entity.vo.TaskMiniVO;
import tech.deepq.common.dto.TaskVO;
import tech.deepq.common.db.entity.Task;
import tech.deepq.common.properties.CommonProperties;

import java.util.Set;


common/src/main/java/work/xuye/common/utils/HttpUtil.java → common/src/main/java/tech/deepq/common/utils/HttpUtil.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.utils;
package tech.deepq.common.utils;

import lombok.extern.slf4j.Slf4j;


common/src/main/java/work/xuye/common/utils/ID.java → common/src/main/java/tech/deepq/common/utils/ID.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.utils;
package tech.deepq.common.utils;

import org.springframework.util.JdkIdGenerator;


common/src/main/java/work/xuye/common/utils/JsonPathUtil.java → common/src/main/java/tech/deepq/common/utils/JsonPathUtil.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.utils;
package tech.deepq.common.utils;

import com.google.gson.Gson;
import com.google.gson.JsonArray;

common/src/main/java/work/xuye/common/utils/MessageUtil.java → common/src/main/java/tech/deepq/common/utils/MessageUtil.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.utils;
package tech.deepq.common.utils;

import lombok.extern.slf4j.Slf4j;
import org.springframework.util.ObjectUtils;

common/src/main/java/work/xuye/common/utils/SpEL.java → common/src/main/java/tech/deepq/common/utils/SpEL.java 查看文件

@@ -1,4 +1,4 @@
package work.xuye.common.utils;
package tech.deepq.common.utils;

import org.springframework.expression.Expression;
import org.springframework.expression.ExpressionParser;

common/src/main/java/work/xuye/common/utils/signature/AbstractSignatureService.java → common/src/main/java/tech/deepq/common/utils/signature/AbstractSignatureService.java 查看文件

@@ -1,7 +1,7 @@
package work.xuye.common.utils.signature;
package tech.deepq.common.utils.signature;

import work.xuye.common.dto.SignatureConfig;
import work.xuye.common.dto.SignatureContext;
import tech.deepq.common.dto.SignatureConfig;
import tech.deepq.common.dto.SignatureContext;

import java.security.GeneralSecurityException;
import java.security.Signature;

common/src/main/java/work/xuye/common/utils/signature/RSASignatureService.java → common/src/main/java/tech/deepq/common/utils/signature/RSASignatureService.java 查看文件

@@ -1,9 +1,9 @@
package work.xuye.common.utils.signature;
package tech.deepq.common.utils.signature;

import org.apache.commons.codec.binary.Base64;
import org.springframework.util.DigestUtils;
import work.xuye.common.dto.SignatureConfig;
import work.xuye.common.enums.SignatureEnumGroup;
import tech.deepq.common.dto.SignatureConfig;
import tech.deepq.common.enums.SignatureEnumGroup;

import java.nio.charset.StandardCharsets;
import java.security.GeneralSecurityException;

common/src/main/java/work/xuye/common/utils/signature/SignatureFactory.java → common/src/main/java/tech/deepq/common/utils/signature/SignatureFactory.java 查看文件

@@ -1,7 +1,7 @@
package work.xuye.common.utils.signature;
package tech.deepq.common.utils.signature;

import work.xuye.common.dto.SignatureConfig;
import work.xuye.common.enums.SignatureEnumGroup;
import tech.deepq.common.dto.SignatureConfig;
import tech.deepq.common.enums.SignatureEnumGroup;

import java.security.GeneralSecurityException;


+ 1
- 1
common/src/main/resources/mapper/DatasourceMapper.xml 查看文件

@@ -1,5 +1,5 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="work.xuye.common.db.mapper.DatasourceMapper">
<mapper namespace="tech.deepq.common.db.mapper.DatasourceMapper">

</mapper>

部分文件因为文件数量过多而无法显示

正在加载...
取消
保存