feature(审批消息中心配置修改): 审批消息中心配置修改

审批消息中心配置修改

dcuc-auth-model/src/main/java/com/dragoninfo/dcuc/auth/auth/dto/WorkFlowDTO.java

@@ -79,6 +79,9 @@ public class WorkFlowDTO {
     /** 权限结束时间 */
     private Date endTime;
 
+    /**创建时间*/
+    private Date createTime;
+
     /** 附件id */
     private String fileId;
 

dcuc-auth-service/src/main/java/com/dragoninfo/dcuc/auth/config/DcucAuthServiceAuthKafkaConfig.java → dcuc-auth-service/src/main/java/com/dragoninfo/dcuc/auth/config/DcucAuthApprovalKafkaConfig.java

@@ -11,8 +11,8 @@ import org.springframework.context.annotation.Configuration;
  * 用户中心配置
  */
 @Configuration
-@ConditionalOnProperty(name = "dcuc.auth.service-auth.kafka", havingValue = "true")
-public class DcucAuthServiceAuthKafkaConfig {
+@ConditionalOnProperty(name = "dcuc.auth.approval-center.kafka", havingValue = "true")
+public class DcucAuthApprovalKafkaConfig {
 
     @Bean
     public WorkFlowResultListener workFlowResultListener() {

dcuc-auth-service/src/main/java/com/dragoninfo/dcuc/auth/msg/WorkFlowResultListener.java

@@ -43,7 +43,7 @@ public class WorkFlowResultListener {
     @Autowired
     private DcucAuthConfig config;
 
-    @KafkaListener(topics = "${dcuc.auth.service-auth.topic}",containerFactory = "kafkaListenerContainerFactory")
+    @KafkaListener(topics = "${dcuc.auth.approval-center.topic}",containerFactory = "kafkaListenerContainerFactory")
     public void receiveMessage(ConsumerRecord<String, byte[]> record) {
         try {
             byte[] value = record.value();