编写http被动接收user

collect-sdry/src/main/java/com/docus/server/collect/user/http/HttpUserResultImpl.java

@@ -0,0 +1,22 @@
+package com.docus.server.collect.user.http;
+
+import com.docus.core.util.json.JSON;
+import com.docus.infrastructure.web.api.CommonResult;
+import com.docus.server.ws.IHttpResult;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+@Component("httpUserResultImpl")
+public class HttpUserResultImpl implements IHttpResult {
+
+    @Override
+    public String ok(Map<String, Object> params) {
+        return JSON.toJSON(CommonResult.success("ok"));
+    }
+
+    @Override
+    public String fail(Map<String, Object> params) {
+        return JSON.toJSON(CommonResult.failed("fail"));
+    }
+}

common-collect/src/main/java/com/docus/server/collect/controller/PowerUserController.java

@@ -0,0 +1,54 @@
+package com.docus.server.collect.controller;
+
+import com.docus.core.util.json.JSON;
+import com.docus.log.annotation.TrackGroup;
+import com.docus.log.context.TrackHelper;
+import com.docus.server.collect.service.CollectService;
+import com.docus.server.sys.common.pojo.dto.UserDTO;
+import com.docus.server.visitor.VisitorProcessor;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+/**
+ * @author wen yongbin
+ * @date 2023年2月25日21:56:33
+ * @see com.docus.server.collect.infrastructure.dao.CollectTypeEnum 枚举
+ * @see com.docus.server.ws.convert.IConverter 通用转化器
+ * @see com.docus.server.ws.IWsResult 通用返回结果
+ * @see VisitorProcessor 通用处理器
+ */
+@Slf4j
+@RestController
+@Api(value = "用户管理接口", tags = "用户管理接口")
+@RequestMapping("/api/http/user")
+public class PowerUserController {
+    protected final static String DEL_TYPE = "D";
+    @Resource
+    private CollectService collectService;
+
+    /**
+     * 被动http 用户信息接收，进行操作
+     *
+     * @param message 接收到的用户参数
+     * @return 返回结果
+     */
+    @ApiOperation("新增/编辑用户(根据id)")
+    @PostMapping("/update")
+    @TrackGroup(
+        group = "HTTP_PASSIVE_USER",
+        beanNames = {"powerUserConverter", "httpResultAdapter"},
+        processor = VisitorProcessor.class)
+    public String httpPassiveUser(String message) {
+        log.debug("新增/修改用户数据：{}", message);
+        collectService.insertOrUpdateUser(JSON.fromJSON((String) TrackHelper.getValue("jsonStr"), UserDTO.class));
+        return null;
+    }
+
+
+}

common-collect/src/main/java/com/docus/server/collect/infrastructure/dao/CollectTypeEnum.java

@@ -11,7 +11,9 @@ public enum CollectTypeEnum implements IIntegerEnum {
     WEBSERVICE_XML_ICU_REPORT(4, "WEBSERVICE_XML_ICU_REPORT", "新增-重症报告信息"),
     WEBSERVICE_XML_EXAMINATION_REPORT(5, "WEBSERVICE_XML_EXAMINATION_REPORT", "新增-检验报告信息"),
     WEBSERVICE_XML_INSERT_INSPECTION_REPORT(6, "WEBSERVICE_XML_INSERT_INSPECTION_REPORT", "新增-检查报告的信息"),
-    WEBSERVICE_XML_UPDATE_INSPECTION_REPORT(7, "WEBSERVICE_XML_UPDATE_INSPECTION_REPORT", "更新-检查报告的信息");
+    WEBSERVICE_XML_UPDATE_INSPECTION_REPORT(7, "WEBSERVICE_XML_UPDATE_INSPECTION_REPORT", "更新-检查报告的信息"),
+
+    HTTP_PASSIVE_USER(8, "HTTP_PASSIVE_USER", "新增/修改-用户信息");
 
     private Integer value;
     private String display;

common-collect/src/main/java/com/docus/server/visitor/VisitorProcessor.java

@@ -8,6 +8,8 @@ import com.docus.server.collect.infrastructure.dao.CollectTypeEnum;
 import com.docus.server.collect.infrastructure.dao.StateEnum;
 import com.docus.server.collect.infrastructure.enums.IIntegerEnum;
 import com.docus.server.tool.SpringUtils;
+import com.docus.server.ws.HttpResultAdapter;
+import com.docus.server.ws.IHttpResult;
 import com.docus.server.ws.ITaskOriginalMessageService;
 import com.docus.server.ws.IWsResult;
 import com.docus.server.ws.convert.IConverter;
@@ -41,6 +43,7 @@ public class VisitorProcessor extends AbstractProcessor {
         Map<String, Object> params = context.getParams();
         params.put("taskId", taskId);
         params.put("jsonStr", jsonStr);
+        params.put("methodName", context.getMethodName());
         return null;
     }
 
@@ -79,6 +82,8 @@ public class VisitorProcessor extends AbstractProcessor {
      * 初始化bean
      */
     private void initBeans(String[] beanNames) {
+        HttpResultAdapter httpResultAdapter = new HttpResultAdapter((IHttpResult) SpringUtils.getBean(beanNames[0]));
+        SpringUtils.initializeBean(httpResultAdapter);
         this.converter = (IConverter) SpringUtils.getBean(beanNames[0]);
         this.wsResult = (IWsResult) SpringUtils.getBean(beanNames[1]);
         this.messageService = SpringUtils.getBean(ITaskOriginalMessageService.class);

common-collect/src/main/java/com/docus/server/ws/IHttpResult.java

@@ -0,0 +1,6 @@
+package com.docus.server.ws;
+
+public interface IHttpResult extends IResult {
+
+
+}

common-collect/src/main/java/com/docus/server/ws/IResult.java

@@ -0,0 +1,11 @@
+package com.docus.server.ws;
+
+import java.util.Map;
+
+public interface IResult {
+
+    String ok(Map<String, Object> params);
+
+    String fail(Map<String, Object> params);
+
+}

common-collect/src/main/java/com/docus/server/ws/IWsResult.java

@@ -1,11 +1,6 @@
 package com.docus.server.ws;
 
-import java.util.Map;
+public interface IWsResult extends IResult {
 
-public interface IWsResult {
-
-    String ok(Map<String, Object> params);
-
-    String fail(Map<String, Object> params);
 
 }

common-collect/src/main/java/com/docus/server/ws/impl/UserServerImpl.java

@@ -27,7 +27,7 @@ public class UserServerImpl implements IUserServer {
     private CollectService collectService;
 
     /**
-     * 用户信息接收，进行操作
+     * ws 用户信息接收，进行操作
      *
      * @param message 接收到的用户参数
      * @return 返回结果