|
@@ -6,6 +6,9 @@ import com.ematou.wxservice.common.web.R;
|
|
|
import com.ematou.wxservice.mp.message.WeChatMessage;
|
|
|
import com.ematou.wxservice.mp.message.WeChatMpXmlOutMessage;
|
|
|
import com.ematou.wxservice.service.WeChatMessageService;
|
|
|
+import com.ematou.wxservice.utils.HttpUtils;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
|
|
@@ -21,7 +24,7 @@ import java.io.IOException;
|
|
|
*/
|
|
|
@RestController
|
|
|
public class WeChatMessageController {
|
|
|
-
|
|
|
+ private static final Logger log = LoggerFactory.getLogger(WeChatMessageController.class);
|
|
|
@Autowired
|
|
|
WeChatMessageService weChatMessageService;
|
|
|
|
|
@@ -52,14 +55,17 @@ public class WeChatMessageController {
|
|
|
*/
|
|
|
@PostMapping("/message")
|
|
|
public String handleMessage(HttpServletRequest request, HttpServletResponse response){
|
|
|
+ log.info("收到微信发来信息!");
|
|
|
try {
|
|
|
ServletInputStream inputStream = request.getInputStream();
|
|
|
|
|
|
WeChatMessage weChatMessage = WeChatMessage.fromXml(inputStream);
|
|
|
+ log.info("收到微信发来信息!"+ JSONObject.toJSON(weChatMessage));
|
|
|
//消息分发
|
|
|
WeChatMpXmlOutMessage outTextMessage = weChatMessageService.handleMessage(weChatMessage);
|
|
|
return null == outTextMessage ? "" : outTextMessage.toXml();
|
|
|
} catch (IOException e) {
|
|
|
+ log.error("微信信息处理异常:",e);
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
return "";
|