拉新

yujian

2020-06-29 ec60e757d358636dcac1589c44a66f3e276fe58c

 fanli/src/main/java/com/yeshi/fanli/service/manger/alipay/UserCloudAlipayManager.java

@@ -1,22 +1,25 @@
package com.yeshi.fanli.service.manger.alipay;



import java.util.HashMap;

import java.util.Map;



import javax.annotation.Resource;



import org.springframework.stereotype.Component;

import org.springframework.transaction.annotation.Transactional;



import com.alipay.api.response.AlipayTradeQueryResponse;

import com.yeshi.fanli.dto.AlipayTradeWapPayDTO;

import com.yeshi.fanli.entity.bus.user.cloud.CloudOrderMenuEnum;

import com.yeshi.fanli.entity.bus.user.cloud.UserCloud;

import com.yeshi.fanli.entity.bus.user.cloud.UserCloudOrder;

import com.yeshi.fanli.entity.system.ConfigKeyEnum;

import com.yeshi.fanli.exception.user.cloud.UserCloudException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.user.cloud.UserCloudGroupService;

import com.yeshi.fanli.service.inter.user.cloud.UserCloudManageService;

import com.yeshi.fanli.service.inter.user.cloud.UserCloudOrderService;

import com.yeshi.fanli.service.inter.user.cloud.UserCloudService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.alipay.AlipayApi;

import com.yeshi.fanli.util.alipay.AlipayWapConfig;



/**

 *  云发单支付管理

@@ -26,6 +29,9 @@
@Component

public class UserCloudAlipayManager {



   @Resource

   private ConfigService configService;

	
   @Resource

   private UserCloudService userCloudService;



@@ -56,38 +62,36 @@
      if (menuEnum == null) 

         throw new UserCloudException(1, "套餐类型不匹配");

      

      UserCloud userCloud = userCloudService.getLastByUid(uid);

      if (userCloud != null) {

         // 续费

         boolean renew = false;

         if (userCloud.getEndTime().getTime() > java.lang.System.currentTimeMillis())

            renew = true;

         // 验证套餐是否相同

         if (renew && userCloud.getRobotType() != menuEnum.getRobotType()) {

            LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "]已有其他云发单套餐还未结束");

            throw new UserCloudException(1, "已有其他云发单套餐还未结束");

         }

      }

		
      // 订单信息

      UserCloudOrder cloudOrder = userCloudOrderService.addCloudOrder(uid, type); 

      if (cloudOrder == null || cloudOrder.getId() == null)

         throw new UserCloudException(1, "创建订单信息失败");

      

      // 待请求参数数组

      Map<String, String> map = new HashMap<String, String>();

      map.put("seller_id", AlipayWapConfig.SELLER_ID);// 收款方账号

      // 订单号

      map.put("out_trade_no", TRADE_INDEX + cloudOrder.getId());

      // 订单金额:0.01元，精准到分

      map.put("total_amount", menuEnum.getMoney() + "");

      // 订单标题

      map.put("subject", "云发单充值");

      // 销售产品码，商家和支付宝签约的产品码

      map.put("product_code", type);

      // 该笔订单允许的最晚付款时间，逾期将关闭交易  30分钟

      map.put("timeout_express", "90m");

      AlipayTradeWapPayDTO payDTO = new AlipayTradeWapPayDTO();

      payDTO.setSubject("云发单充值");

      payDTO.setSellerId(Constant.alipayWapConfig.getSellerId());

      payDTO.setOutTradeNo(TRADE_INDEX + cloudOrder.getId());

      payDTO.setProductCode(type);

      payDTO.setTotalAmount(menuEnum.getMoney() + "");

      payDTO.setTimeoutExpress("30m");

      payDTO.setReturnUrl(configService.get(ConfigKeyEnum.cloudAlipayReturnLink.getKey()) +"?id=" +cloudOrder.getId());

      payDTO.setNotifyUrl(configService.get(ConfigKeyEnum.cloudAlipayNotifyLink.getKey()) +"?id=" +cloudOrder.getId());

      

		
//      map.put("goods_id", cloudOrder.getId() +"");

//      map.put("goods_name", "云发单");

//      map.put("quantity", 1 +"");

//      map.put("price", menuEnum.getMoney() + "");

//		
		
      // 支付成功后返回哪个前端页面

      String returnUrl = "http://192.168.1.114:8848/flqFront/AppInside/cloudPushOrder/cloudPushOrderManage.html";

      // 支付成功后回调地址

      String notifyUrl = "http://192.168.1.200:8008/fanli/client/v1/cloud/callback/payEnd?id=" +cloudOrder.getId();

      // 获取支付form

      return AlipayApi.tradeWapPayRequest(map, returnUrl, notifyUrl);

      return AlipayApi.tradeWapPayRequest(payDTO);

   }



   

@@ -97,7 +101,17 @@
    * @throws Exception

    */

   public void tradeQueryByOrderId(Long orderId) throws Exception {

      boolean result = AlipayApi.tradeQuery(TRADE_INDEX + orderId, null, null, null);

      boolean result = false;

      AlipayTradeQueryResponse response =  AlipayApi.tradeQuery(TRADE_INDEX + orderId, null, null, null);

      if(response != null && response.isSuccess()){

         // 相应成功

         if ("TRADE_SUCCESS".equals(response.getTradeStatus())) { 
            result = true;

         } else if ("TRADE_FINISHED".equals(response.getTradeStatus())) {

            result = true; // （交易结束，不可退款）

         }			
      } 
		
      // 支付成功

      if (result) {

         userCloudOrderService.cloudPayCloudSuccess(orderId);