From a2a27d09de45b6eb671bb50a25b6eb6d01902beb Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期六, 08 二月 2020 19:11:05 +0800
Subject: [PATCH] 优化修改密码功能

---
 AppFrontService/src/main/java/com/java110/app/smo/payment/impl/ToNotifySMOImpl.java |   21 +++++++--------------
 1 files changed, 7 insertions(+), 14 deletions(-)

diff --git a/AppFrontService/src/main/java/com/java110/app/smo/payment/impl/ToNotifySMOImpl.java b/AppFrontService/src/main/java/com/java110/app/smo/payment/impl/ToNotifySMOImpl.java
index 9a85e07..ebdc151 100644
--- a/AppFrontService/src/main/java/com/java110/app/smo/payment/impl/ToNotifySMOImpl.java
+++ b/AppFrontService/src/main/java/com/java110/app/smo/payment/impl/ToNotifySMOImpl.java
@@ -17,6 +17,7 @@
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.*;
+import org.springframework.stereotype.Service;
 import org.springframework.web.client.HttpStatusCodeException;
 import org.springframework.web.client.RestTemplate;
 
@@ -25,10 +26,11 @@
 import java.io.InputStream;
 import java.util.*;
 
+@Service("toNotifySMOImpl")
 public class ToNotifySMOImpl implements IToNotifySMO {
     private static final Logger logger = LoggerFactory.getLogger(AppAbstractComponentSMO.class);
 
-    private static final String APP_ID = "";
+    private static final String APP_ID = "992020011134400001";
 
 
     @Autowired
@@ -38,21 +40,12 @@
     private WechatAuthProperties wechatAuthProperties;
 
     @Override
-    public ResponseEntity<String> toNotify(HttpServletRequest request) {
+    public ResponseEntity<String> toNotify(String param, HttpServletRequest request) {
         String resXml = "";
         ResponseEntity responseEntity = null;
         try {
-            InputStream inputStream = request.getInputStream();
-//鑾峰彇璇锋眰杈撳叆娴�
-            ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
-            byte[] buffer = new byte[1024];
-            int len = 0;
-            while ((len = inputStream.read(buffer)) != -1) {
-                outputStream.write(buffer, 0, len);
-            }
-            outputStream.close();
-            inputStream.close();
-            Map<String, Object> map = PayUtil.getMapFromXML(new String(outputStream.toByteArray(), "utf-8"));
+
+            Map<String, Object> map = PayUtil.getMapFromXML(param);
             logger.info("銆愬皬绋嬪簭鏀粯鍥炶皟銆� 鍥炶皟鏁版嵁锛� \n" + map);
             String returnCode = (String) map.get("return_code");
             if ("SUCCESS".equalsIgnoreCase(returnCode)) {
@@ -162,7 +155,7 @@
         try {
             responseEntity = restTemplate.exchange(url, httpMethod, httpEntity, String.class);
         } catch (HttpStatusCodeException e) { //杩欓噷spring 妗嗘灦 鍦�4XX 鎴� 5XX 鏃舵姏鍑� HttpServerErrorException 寮傚父锛岄渶瑕侀噸鏂板皝瑁呬竴涓�
-            responseEntity = new ResponseEntity<String>("璇锋眰涓嬫父绯荤粺寮傚父锛�" + e.getResponseBodyAsString(), e.getStatusCode());
+            responseEntity = new ResponseEntity<String>( e.getResponseBodyAsString(), e.getStatusCode());
         } catch (Exception e) {
             responseEntity = new ResponseEntity<String>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR);
         } finally {

--
Gitblit v1.8.0