From 3f45a4f6edaf1004c1e23e93da822ae4f0dbc707 Mon Sep 17 00:00:00 2001
From: "binquan.qiuu" <binquan.qiu@supwisdom.com>
Date: Tue, 7 Jul 2020 18:29:39 +0800
Subject: [PATCH] =?utf8?q?=E6=8F=90=E4=BA=A4=E6=89=8B=E6=9C=BA=E6=8E=A8?=
 =?utf8?q?=E9=80=81=E6=96=B0=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 .../api/bean/CommonSendMessageParam.java      | 28 +++++++++++++
 .../dlpay/paysdk/proxy/ApiCommonProxy.java    | 11 +++++
 .../api/controller/snedmsg_api_controller.kt  | 41 +++++++++++++++++++
 3 files changed, 80 insertions(+)
 create mode 100644 payapi-common/src/main/java/com/supwisdom/dlpay/api/bean/CommonSendMessageParam.java
 create mode 100644 payapi/src/main/kotlin/com/supwisdom/dlpay/api/controller/snedmsg_api_controller.kt

diff --git a/payapi-common/src/main/java/com/supwisdom/dlpay/api/bean/CommonSendMessageParam.java b/payapi-common/src/main/java/com/supwisdom/dlpay/api/bean/CommonSendMessageParam.java
new file mode 100644
index 00000000..f63b88f0
--- /dev/null
+++ b/payapi-common/src/main/java/com/supwisdom/dlpay/api/bean/CommonSendMessageParam.java
@@ -0,0 +1,28 @@
+package com.supwisdom.dlpay.api.bean;
+
+import com.supwisdom.dlpay.api.APIRequestParam;
+import com.supwisdom.dlpay.api.annotation.Sign;
+import com.supwisdom.dlpay.api.exception.RequestParamCheckException;
+import lombok.Getter;
+import lombok.Setter;
+import org.apache.commons.lang3.StringUtils;
+
+
+@Getter
+@Setter
+public class CommonSendMessageParam extends APIRequestParam {
+    @Sign
+    private String userid;
+    @Sign
+    private String content;
+    @Sign
+    private String title;
+
+    @Override
+    public boolean checkParam() throws RequestParamCheckException {
+        if (StringUtils.isEmpty(userid) && StringUtils.isEmpty(content)&& StringUtils.isEmpty(title) ) {
+            throw new RequestParamCheckException("用户唯一号不能为空");
+        }
+        return true;
+    }
+}
diff --git a/payapi-sdk/src/main/java/com/supwisdom/dlpay/paysdk/proxy/ApiCommonProxy.java b/payapi-sdk/src/main/java/com/supwisdom/dlpay/paysdk/proxy/ApiCommonProxy.java
index 47a8e53b..f273a3f4 100644
--- a/payapi-sdk/src/main/java/com/supwisdom/dlpay/paysdk/proxy/ApiCommonProxy.java
+++ b/payapi-sdk/src/main/java/com/supwisdom/dlpay/paysdk/proxy/ApiCommonProxy.java
@@ -1,11 +1,22 @@
 package com.supwisdom.dlpay.paysdk.proxy;
 
+import com.supwisdom.dlpay.api.bean.ApiResponse;
 import com.supwisdom.dlpay.api.bean.ApiVersionResponse;
+import com.supwisdom.dlpay.api.bean.CommonSendMessageParam;
+import com.supwisdom.dlpay.api.bean.UserResponse;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 
 @FeignClient(name = "apiCommonProxy", url = "${payapi.url}")
 public interface ApiCommonProxy {
   @GetMapping(value = "/api/common/version")
   ApiVersionResponse apiVersion();
+
+  @PostMapping("/api/common/sendmsg")
+  ApiResponse sendMsg(@RequestBody CommonSendMessageParam param);
+
+
+
 }
diff --git a/payapi/src/main/kotlin/com/supwisdom/dlpay/api/controller/snedmsg_api_controller.kt b/payapi/src/main/kotlin/com/supwisdom/dlpay/api/controller/snedmsg_api_controller.kt
new file mode 100644
index 00000000..69dff8be
--- /dev/null
+++ b/payapi/src/main/kotlin/com/supwisdom/dlpay/api/controller/snedmsg_api_controller.kt
@@ -0,0 +1,41 @@
+package com.supwisdom.dlpay.api.controller
+
+import com.supwisdom.dlpay.api.bean.*
+import com.supwisdom.dlpay.api.service.*
+import com.supwisdom.dlpay.framework.ResponseBodyBuilder
+import com.supwisdom.dlpay.framework.service.SystemUtilService
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.http.ResponseEntity
+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.RestController
+
+@RestController
+@RequestMapping("/api/common")
+class SendMessageAPIController {
+
+    @Autowired
+    lateinit var systemUtilService: SystemUtilService
+
+    @Autowired
+    lateinit var transactionService: TransactionServiceProxy
+
+    @Autowired
+    lateinit var kafkaSendMsgService: KafkaSendMsgService
+
+    /**
+     * ============================================================================
+     * 发送消息推送
+     * ============================================================================
+     * */
+    @PostMapping("/sendmsg")
+    fun doSend(@RequestBody param: ApiLoginResponse.CommonSendMessageParam): ResponseEntity<Any> {
+        kafkaSendMsgService.sendJpushMessage(param.userid,param.title,param.content,"",mutableMapOf(),"")
+
+        return ResponseEntity.ok(ResponseBodyBuilder.create()
+                .success("发送成功"))
+    }
+
+
+}
\ No newline at end of file
-- 
2.17.1