Преглед на файлове

********************WX***********************
添加微服务和数据中台通讯方式

zhangweixin преди 4 години
родител
ревизия
4b33727a75

+ 19 - 0
datasyn/src/main/kotlin/com/persagy/server/syn/WebMvcConfg.kt

@@ -26,9 +26,13 @@
 
 package com.persagy.server.syn
 
+import com.alibaba.fastjson.PropertyNamingStrategy
 import com.persagy.service.interceptors.SPageInterceptor
+import com.persagy.service.json.SJsonHttpMessageConverter
 import org.slf4j.LoggerFactory
 import org.springframework.context.annotation.Configuration
+import org.springframework.http.converter.HttpMessageConverter
+import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter
 import org.springframework.web.servlet.config.annotation.InterceptorRegistry
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter
 
@@ -49,4 +53,19 @@ open class WebMvcConfg: WebMvcConfigurerAdapter() {
         super.addInterceptors(registry)
 
     } // Function addInterceptors()
+
+    /**
+     * 配置 json 转换使用 FastJson
+     *
+     * @param   converterList       转换器列表
+     */
+    override fun configureMessageConverters(converterList: MutableList<HttpMessageConverter<*>>) {
+        // 先把JackSon的消息转换器删除.
+        converterList.removeIf { item -> item is MappingJackson2HttpMessageConverter }
+
+        val converter = SJsonHttpMessageConverter()
+        // 设置 Json 序列化,属性首字母小写
+        converter.propertyNamingStrategy = PropertyNamingStrategy.CamelCase
+        converterList.add(converter)
+    }
 } // Class WebMvcConf()

+ 14 - 0
datasyn/src/main/kotlin/com/persagy/server/syn/controllers/journal/JournalController.kt

@@ -26,8 +26,11 @@
 
 package com.persagy.server.syn.controllers.journal
 
+import com.persagy.database.SFilter
 import com.persagy.server.datacenter.models.entities.dictnew.DefClass
+import com.persagy.server.datacenter.models.entities.objects.Project
 import com.persagy.server.datacenter.models.jms.SynchronousMessage
+import com.persagy.server.syn.services.BaseDataService
 import com.persagy.server.syn.services.journal.SynchronousMessageService
 import com.persagy.service.models.requests.SQueryRequest
 import com.persagy.service.models.requests.SUpdateRequest
@@ -94,4 +97,15 @@ class JournalController {
         return SynchronousMessageService.isOnline(groupCode,projectId)
     }
 
+    @Operation(summary = "查询项目信息", description = "groupCode 集团编码")
+    @GetMapping(value = ["/query/project"])
+    fun queryProject(@RequestParam projectId: String): SQueryResponse<Project>{
+        val request = SQueryRequest()
+        return BaseDataService.projectService.pageQuery(request, arrayListOf(SFilter.eq("id",projectId!!)))
+    }
+
+
+
+
+
 }