package com.swpu.uchain.takeawayapplet.service.impl;
import com.swpu.uchain.takeawayapplet.VO.ResultVO;
import com.swpu.uchain.takeawayapplet.config.UrlProperties;
import com.swpu.uchain.takeawayapplet.config.WeChatProperties;
import com.swpu.uchain.takeawayapplet.dto.OrderDTO;
import com.swpu.uchain.takeawayapplet.enums.ResultEnum;
import com.swpu.uchain.takeawayapplet.exception.GlobalException;
import com.swpu.uchain.takeawayapplet.form.PayForm;
import com.swpu.uchain.takeawayapplet.form.RefundForm;
import com.swpu.uchain.takeawayapplet.service.MessageService;
import com.swpu.uchain.takeawayapplet.service.OrderService;
import com.swpu.uchain.takeawayapplet.service.PayService;
import com.swpu.uchain.takeawayapplet.util.GetOpenIdUtil;
import com.swpu.uchain.takeawayapplet.util.PayUtil;
import com.swpu.uchain.takeawayapplet.util.RandomUtil;
import com.swpu.uchain.takeawayapplet.util.ResultUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;
//import com.swpu.uchain.takeawayapplet.service.MessageService;
/**
* @ClassName PayServiceImpl
* @Author hobo
* @Date 19-3-21 下午8:11
* @Description
**/
@Service
@Slf4j
public class PayServiceImpl implements PayService {
@Autowired
private WeChatProperties weChatProperties;
@Autowired
private UrlProperties urlProperties;
@Autowired
private OrderService orderService;
@Autowired
private MessageService messageService;
/**
* @return void
* @Author hobo
* @Description : 创建预支付请求
* @Param [orderDTO]
**/
@Override
public ResultVO creat(PayForm payForm, String code, HttpServletRequest request) {
try {
//生成随机字符串
String nonceStr = RandomUtil.getRandomStringByLength(32);
//商品简介
String body = new String(weChatProperties.getTitle().getBytes("ISO-8859-1"), "UTF-8");
//获得本机的ip地址
String spbillCreatIp = PayUtil.getIpAddr(request);
String ordNo = payForm.getId() + "";
//支付金额 单位：分 转为元
String totalFee = payForm.getOrderAmount().multiply(new BigDecimal(100)) + "";
String openId = GetOpenIdUtil.getOpenId(code);
//生成预支付订单
Map<String, String> packageParams = new HashMap<String, String>();
packageParams.put("appid", weChatProperties.getAppid());
packageParams.put("mch_id", weChatProperties.getMchId());
packageParams.put("nonce_str", nonceStr);
packageParams.put("body", body);
packageParams.put("out_trade_no", ordNo);
packageParams.put("totalFee", totalFee);
packageParams.put("spbill_create_ip", spbillCreatIp);
packageParams.put("notify_url", weChatProperties.getNotifyUrl());
packageParams.put("trade_type", weChatProperties.getTradeType());
packageParams.put("open_id", openId);
//除去数组中的空值和签名参数
packageParams = PayUtil.paraFileter(packageParams);
String preStr = PayUtil.createLinkString(packageParams);
//MD5运算生成签名，第一次签名 调用统一下单接口
String mySign = PayUtil.sign(preStr, weChatProperties.getMchKey(), "utf-8").toUpperCase();
log.info("====================第一次签名" + mySign + "====================");
//连同生成的签名一起拼接成xml数据
String xml = "</xml version='1.0' encoding='gdk'>"
+ "<appid>" + weChatProperties.getAppid() + "</appid>"
+ "<body><![CDATA]" + body + "]]></body>"
+ "<mch_id>" + weChatProperties.getMchId() + "</mch_id>"
+ "<nonce_str>" + nonceStr + "</nonce_str>"
+ "<openid>" + openId + "</openid>"
+ "<out_trade_no>" + ordNo + "<out_trade_no>"
+ "<spbill_create_ip>" + spbillCreatIp + "</spbill_create_ip>"
+ "<total_fee>" + totalFee + "</total_fee>"
+ "<trade_type>" + weChatProperties.getTradeType() + "</trade_type>"
+ "<sign>" + mySign + "</sign>"
+ "</xml>";
log.info("====================调试请求XML数据====================");
System.out.println(xml);
//调用统一下单接口
String result = PayUtil.httpRequest(urlProperties.getPayUrl(), "POST", xml);
log.info("====================调试返回XML数据====================");
System.out.println(result);
// 将解析结果放入HashMap中
Map map = PayUtil.doXMLParse(result);
String return_code = (String) map.get("return_code");
//返回移动端需要的参数
Map<String, Object> response = new HashMap<String, Object>();
//return_code 为成功 return_msg 为失败
if ("SUCCESS".equals(return_code)) {
//业务结果
String prepay_id = (String) map.get("prepay_id");
response.put("nonceStr", nonceStr);
response.put("package", "prepay_id" + prepay_id);
Long timeStamp = System.currentTimeMillis() / 1000;
//时间 类型转换为微信官方要求的String
response.put("time_stamp", timeStamp + "");
String stringSignTemp = "appId=" + weChatProperties.getAppid() + "&nonceStr=" + nonceStr
+ "&package=prepay_id" + prepay_id + "&signType=MD5" + "&timeStamp=" + timeStamp;
//再次签名 用于小程序端调用wx.requestPayment方法
String paySign = PayUtil.sign(stringSignTemp, weChatProperties.getMchKey(), "utf-8").toUpperCase();
log.info("===================第二次签名：" + paySign + "====================");
response.put("paySign", paySign);
}
response.put("appid", weChatProperties.getAppid());
return ResultUtil.success(response);
} catch (Exception e) {
e.printStackTrace();
return ResultUtil.error(ResultEnum.PAY_REQUEST_FAIL);
}
}
/**
* @return void
* @Author hobo
* @Description : 异步通知判断签名
* @Param [notifyData]
**/
@Override
public ResultVO notify(HttpServletRequest request, HttpServletResponse response) throws Exception {
BufferedReader br = new BufferedReader(new InputStreamReader((ServletInputStream) request.getInputStream()));
String line = null;
StringBuffer sb = new StringBuffer();
while ((line = br.readLine()) != null) {
sb.append(line);
}
br.close();
String notifyXml = sb.toString();
String resXml = "";
log.info("接收到的报文 notifyXml={}", notifyXml);
Map map = PayUtil.doXMLParse(notifyXml);
//从报文中获取值
String returnCode = (String) map.get("return_code");
String outTradeNo = (String) map.get("out_trade_no");
String totalFee = (String) map.get("total_fee");
Long orderId = Long.parseLong(outTradeNo);
OrderDTO orderDTO = orderService.findOrder(orderId);
if (!(orderDTO.getOrderAmount() + "").equals(totalFee)) {
throw new GlobalException(ResultEnum.AMOUNT_ERROR);
}
if ("SUCCESS".equals(returnCode)) {
//验证签名是�
SSM--外卖点餐微信小程序.zip
版权申诉
172 浏览量
2024-03-11
10:05:35
上传
评论
收藏 2.68MB ZIP 举报
SSM--外卖点餐微信小程序.zip （118个子文件） 
mvnw.cmd 6KB .gitignore 277B
jdom-2.0.6-javadoc.jar 984KB jdom-2.0.6-sources.jar 840KB jdom-2.0.6-junit.jar 483KB jdom-2.0.6.jar 298KB jdom-2.0.6-contrib.jar 163KB maven-wrapper.jar 47KB PayServiceImpl.java 13KB OrderServiceImpl.java 10KB PayUtil.java 7KB UserServiceImpl.java 6KB RedisService.java 6KB PrinterUtil.java 6KB JwtTokenUtil.java 6KB ProductServiceImpl.java 5KB MavenWrapperDownloader.java 5KB WebSecurityConfig.java 4KB CategoryServiceImpl.java 4KB OrderDetail.java 3KB JwtAuthenticationTokenFilter.java 3KB OrderMaster.java 3KB ProductInfo.java 3KB WechatSendMessageUtil.java 3KB GlobalExceptionHandler.java 3KB SwaggerConfig.java 3KB MessageServiceImpl.java 3KB AesCbcUtil.java 3KB WeChatController.java 2KB BuyerOrderController.java 2KB SellerOrderController.java 2KB AuthRoleInterceptor.java 2KB SellerCategoryController.java 2KB PayController.java 2KB ProductSpecifications.java 2KB ProductCategory.java 2KB BuyerProductController.java 2KB SellerProductController.java 2KB ResultEnum.java 2KB AdminController.java 2KB ControllerLog.java 2KB UploadIconUtil.java 2KB RandomUtil.java 1KB JwtUserDetailServiceImpl.java 1KB LoginController.java 1KB JwtUser.java 1KB JwtAuthenticationEntryPoint.java 1KB User.java 1KB ServiceLog.java 1KB WeChatProperties.java 1KB ResultUtil.java 1KB OrderDTO.java 1KB OrderFormConversionDTOUtil.java 1KB RoleEnum.java 1KB OrderMasterConversionDTOUtil.java 1KB RedisPoolFactory.java 1012B WebConfig.java 974B PayForm.java 941B OrderService.java 854B TimeUtil.java 841B RefundForm.java 816B OrderForm.java 810B ProductInfoForm.java 804B ProductService.java 784B UserService.java 720B CategoryService.java 714B BasePrefix.java 680B WechatMsgVO.java 677B PayService.java 596B MessageService.java 544B CategoryForm.java 525B RedisConfig.java 508B LoginForm.java 508B JwtProperties.java 505B UserForm.java 505B ProductInfoMapper.java 502B OrderKey.java 499B EnumUtil.java 488B ProductCategoryMapper.java 464B GlobalException.java 457B TemplateProperties.java 451B TakeawayAppletApplication.java 450B UploadIconConfig.java 450B CategoryKey.java 449B RoleContro.java 447B UrlProperties.java 438B ProductSpecificationsMapper.java 436B OrderMasterMapper.java 427B OrderDetailMapper.java 424B ProductVO.java 386B GetOpenIdUtil.java 378B UserMapper.java 375B OrderStatusEnum.java 375B PayStatusEnum.java 368B TakeawayAppletApplicationTests.java 364B TokenKey.java 359B UserKey.java 351B ProductKey.java 337B KeyPrefix.java 296B AccessTokenVO.java 288B共 118 条
- 1
- 2
资源评论
