H5额外活动助力接口

src/main/java/com/huiju/estateagents/common/CommConstant.java

@@ -857,4 +857,20 @@ public class CommConstant {
      * 明细类型--红包
      */
     public static final String ITEM_TYPE_REDPACKAGE = "redPackage";
+
+    /**
+     * 交易状态 成功
+     */
+    public static final String TRADING_STATUS_SUCCESS = "success";
+
+    /**
+     * 交易状态 失败
+     */
+    public static final String TRADING_STATUS_FAIL = "fail";
+
+    /**
+     * 交易状态 进行中
+     */
+    public static final String TRADING_STATUS_PROCESSING = "processing";
+
 }

src/main/java/com/huiju/estateagents/common/WxMpUtils.java

@@ -1,41 +0,0 @@
-package com.huiju.estateagents.common;
-
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.huiju.estateagents.third.entity.TaMpInfo;
-import com.huiju.estateagents.third.service.ITaMpInfoService;
-import me.chanjar.weixin.mp.api.WxMpService;
-import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
-import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.PostConstruct;
-import java.util.List;
-import java.util.stream.Collectors;
-
-@Component
-public class WxMpUtils {
-
-    @Autowired
-    public ITaMpInfoService iTaMpInfoService;
-
-    @PostConstruct
-    public WxMpService wxMpService() {
-        //从数据库读取公众号信息
-        QueryWrapper<TaMpInfo> queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq("status", CommConstant.STATUS_NORMAL);
-        List<TaMpInfo> mplist = iTaMpInfoService.list(queryWrapper);
-
-        WxMpService service = new WxMpServiceImpl();
-        service.setMultiConfigStorages(mplist
-                .stream().map(a -> {
-                    WxMpDefaultConfigImpl configStorage = new WxMpDefaultConfigImpl();
-                    configStorage.setAppId(a.getAppid());
-                    configStorage.setSecret(a.getSecret());
-                    configStorage.setToken(a.getToken());
-                    configStorage.setAesKey(a.getAesKey());
-                    return configStorage;
-                }).collect(Collectors.toMap(WxMpDefaultConfigImpl::getAppId, a -> a, (o, n) -> o)));
-        return service;
-    }
-}

src/main/java/com/huiju/estateagents/third/controller/WxRedpackController.java

@@ -2,20 +2,26 @@ package com.huiju.estateagents.third.controller;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.huiju.estateagents.base.ResponseBean;
-import com.huiju.estateagents.common.WxMpUtils;
+import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.redpack.entity.TaMpPerson;
+import com.huiju.estateagents.third.entity.TaMpInfo;
 import com.huiju.estateagents.third.entity.TaThirdPartyMiniappConfig;
+import com.huiju.estateagents.third.service.ITaMpInfoService;
 import com.huiju.estateagents.third.service.ITaThirdPartyMiniappConfigService;
 import lombok.AllArgsConstructor;
 import me.chanjar.weixin.common.error.WxErrorException;
 import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
 import me.chanjar.weixin.mp.bean.result.WxMpOAuth2AccessToken;
 import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * @author Edward
@@ -24,11 +30,13 @@ import javax.servlet.http.HttpServletRequest;
 @Controller
 @RequestMapping("/api")
 public class WxRedpackController {
-    public WxMpUtils wxMpUtils;
 
     @Autowired
     public ITaThirdPartyMiniappConfigService iTaThirdPartyMiniappConfigService;
 
+    @Autowired
+    public ITaMpInfoService iTaMpInfoService;
+
     /**
      * 换取openid接口并插入公众号人员表
      * @param mpAppid
@@ -38,7 +46,7 @@ public class WxRedpackController {
      */
     @GetMapping("/third/redirect/{mpAppid}/greet")
     public ResponseBean greetUser(@PathVariable String mpAppid, @RequestParam String code, @RequestParam String personId, HttpServletRequest request) {
-        WxMpService wxService = wxMpUtils.wxMpService();
+        WxMpService wxService = getWxMpService();
         if (!wxService.switchover(mpAppid)) {
             throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", mpAppid));
         }
@@ -60,6 +68,25 @@ public class WxRedpackController {
         return ResponseBean.success(taMpPerson);
     }
 
+    private WxMpService getWxMpService() {
+        //从数据库读取公众号信息
+        QueryWrapper<TaMpInfo> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("status", CommConstant.STATUS_NORMAL);
+        List<TaMpInfo> mplist = iTaMpInfoService.list(queryWrapper);
+
+        WxMpService service = new WxMpServiceImpl();
+        service.setMultiConfigStorages(mplist
+                .stream().map(a -> {
+                    WxMpDefaultConfigImpl configStorage = new WxMpDefaultConfigImpl();
+                    configStorage.setAppId(a.getAppid());
+                    configStorage.setSecret(a.getSecret());
+                    configStorage.setToken(a.getToken());
+                    configStorage.setAesKey(a.getAesKey());
+                    return configStorage;
+                }).collect(Collectors.toMap(WxMpDefaultConfigImpl::getAppId, a -> a, (o, n) -> o)));
+        return service;
+    }
+
     /**
      * 我要参加 活动接口
      * @param mpAppid
@@ -69,6 +96,10 @@ public class WxRedpackController {
      */
     @PostMapping("/third/activity/{mpAppid}/participate")
     public ResponseBean participateActivity(@PathVariable String mpAppid, @RequestParam String mpPersonId, HttpServletRequest request) {
+        WxMpService wxService = getWxMpService();
+        if (!wxService.switchover(mpAppid)) {
+            throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", mpAppid));
+        }
         //获取H5项目相关信息
         String xAppid = request.getHeader("x-appid");
         QueryWrapper<TaThirdPartyMiniappConfig> taThirdPartyMiniappConfigQueryWrapper = new QueryWrapper<>();
@@ -96,6 +127,10 @@ public class WxRedpackController {
      */
     @PostMapping("/third/activity/{mpAppid}/help")
     public ResponseBean helpActivity(@PathVariable String mpAppid, @RequestParam String mpPersonId, @RequestParam String parentMpPersonId ,HttpServletRequest request) {
+        WxMpService wxService = getWxMpService();
+        if (!wxService.switchover(mpAppid)) {
+            throw new IllegalArgumentException(String.format("未找到对应appid=[%s]的配置，请核实！", mpAppid));
+        }
         //获取H5项目相关信息
         String xAppid = request.getHeader("x-appid");
         QueryWrapper<TaThirdPartyMiniappConfig> taThirdPartyMiniappConfigQueryWrapper = new QueryWrapper<>();

src/main/java/com/huiju/estateagents/third/service/impl/TaThirdPartyMiniappConfigServiceImpl.java

@@ -2,22 +2,35 @@ package com.huiju.estateagents.third.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.binarywang.wxpay.bean.request.WxPaySendRedpackRequest;
+import com.github.binarywang.wxpay.bean.result.WxPaySendRedpackResult;
+import com.github.binarywang.wxpay.config.WxPayConfig;
+import com.github.binarywang.wxpay.exception.WxPayException;
+import com.github.binarywang.wxpay.service.WxPayService;
+import com.github.binarywang.wxpay.service.impl.WxPayServiceImpl;
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.common.MD5Utils;
 import com.huiju.estateagents.drainage.entity.TaDrainage;
 import com.huiju.estateagents.drainage.mapper.TaDrainageMapper;
+import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.entity.TaWxPayConfig;
+import com.huiju.estateagents.mapper.TaPersonMapper;
+import com.huiju.estateagents.mapper.TaWxPayConfigMapper;
 import com.huiju.estateagents.redpack.entity.*;
 import com.huiju.estateagents.redpack.mapper.*;
 import com.huiju.estateagents.third.entity.TaThirdPartyMiniappConfig;
 import com.huiju.estateagents.third.mapper.TaThirdPartyMiniappConfigMapper;
 import com.huiju.estateagents.third.service.ITaThirdPartyMiniappConfigService;
 import me.chanjar.weixin.mp.bean.result.WxMpUser;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.net.InetAddress;
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Random;
 import java.util.stream.Collectors;
 
 /**
@@ -58,6 +71,27 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 	@Autowired
 	private TaRedPacketMoneyMapper taRedPacketmonetMapper;
 
+	@Autowired
+	private TaWxPayConfigMapper taWxPayConfigMapper;
+
+	@Autowired
+	private TaRedPacketClientMapper taRedPacketClientMapper;
+
+	@Autowired
+	private TaOrgAccountMapper taOrgAccountMapper;
+
+	@Autowired
+	private TaOrgOrderMapper taOrgOrderMapper;
+
+	@Autowired
+	private TaOrgOrderDetailMapper taOrgOrderDetailMapper;
+
+	@Autowired
+	private TaOrgAccountDetailedListMapper taOrgAccountDetailedListMapper;
+
+	@Autowired
+	private TaPersonMapper taPersonMapper;
+
 	/**
 	 * 校验是否合法第三方接口调用
 	 *
@@ -230,7 +264,7 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 		TaRedPacketHelp taRedPacketHelp = taRedPacketHelpMapper.selectById(taDrainage.getActivityId());
 		
 		//助力
-		String result = saveRedPacketHistory(taMpMiniapp, parentMpMiniapp, taRedPacketHelp, orgId);
+		String result = saveRedPacketHistory(taMpMiniapp, parentMpMiniapp, taRedPacketHelp, orgId,mpAppid);
 		if (result.equals("success")){
 			ResponseBean.error(result,ResponseBean.ERROR_ILLEGAL_PARAMS);
 		}
@@ -238,7 +272,7 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 		return ResponseBean.success(taRedPacketHelp.getSuccessTip());
 	}
 
-	private synchronized String saveRedPacketHistory(TaMpMiniapp taMpMiniapp, TaMpMiniapp parentMpMiniapp, TaRedPacketHelp taRedPacketHelp, Integer orgId) {
+	private synchronized String saveRedPacketHistory(TaMpMiniapp taMpMiniapp, TaMpMiniapp parentMpMiniapp, TaRedPacketHelp taRedPacketHelp, Integer orgId, String mpAppid) {
 		//查看我是否助力过
 		QueryWrapper<TaRedPacketHistory> queryWrapper = new QueryWrapper();
 		queryWrapper.eq("activity_id",taRedPacketHelp.getActivityId());
@@ -268,8 +302,11 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 		parentRedPacketHistory.eq("target_mp_person",parentMpMiniapp.getMpPersonId());
 		parentRedPacketHistory.eq("target_miniapp_person",parentMpMiniapp.getMiniappPersonId());
 		List<TaRedPacketHistory> parentRedPacketHistories = taRedPacketHistoryMapper.selectList(parentRedPacketHistory);
-		Boolean redPackageState = parentRedPacketHistories.size() + 1 <= taRedPacketHelp.getHelpSuccesPersons();
 
+		//查看是否助力成功
+		if (parentRedPacketHistories.size() + 1 > taRedPacketHelp.getHelpSuccesPersons()){
+			return "助力已完成，无需助力。";
+		}
 
 		//助力
 		TaRedPacketHistory taRedPacketHistory = new TaRedPacketHistory();
@@ -281,10 +318,8 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 		taRedPacketHistory.setTargetMiniappPerson(parentMpMiniapp.getMiniappPersonId());
 		taRedPacketHistory.setTargetMpPerson(parentMpMiniapp.getMpPersonId());
 		taRedPacketHistoryMapper.insert(taRedPacketHistory);
-		if (redPackageState){
-			//发送红包
-			sendRedPackage(taMpMiniapp, parentMpMiniapp, taRedPacketHelp, orgId);
-		}
+		//发送红包
+		sendRedPackage(taMpMiniapp, parentMpMiniapp, taRedPacketHelp, orgId,mpAppid);
 		return "success";
 	}
 
@@ -294,9 +329,138 @@ public class TaThirdPartyMiniappConfigServiceImpl extends ServiceImpl<TaThirdPar
 	 * @param parentMpMiniapp
 	 * @param taRedPacketHelp
 	 * @param orgId
+	 * @param mpAppid
 	 */
-	private synchronized void sendRedPackage(TaMpMiniapp taMpMiniapp, TaMpMiniapp parentMpMiniapp, TaRedPacketHelp taRedPacketHelp, Integer orgId) {
+	private synchronized void sendRedPackage(TaMpMiniapp taMpMiniapp, TaMpMiniapp parentMpMiniapp, TaRedPacketHelp taRedPacketHelp, Integer orgId, String mpAppid) {
+		//红包金额设置相关信息
 		TaRedPacketMoney taRedPacketMoney = taRedPacketmonetMapper.selectById(taRedPacketHelp.getActivityId());
-		
+		//总账户金额
+		TaOrgAccount taOrgAccount = taOrgAccountMapper.selectOne(new QueryWrapper<TaOrgAccount>().eq("org_id", orgId).eq("status", CommConstant.STATUS_NORMAL));
+		//金额不足直接返回
+		if (taRedPacketMoney.getBalance() == 0){
+			return;
+		}
+		//账户余额不足
+		if (taOrgAccount.getRealBalance() == 0){
+			return;
+		}
+		//发送红包已达上限
+		if (taRedPacketMoney.getPacketSendedNum() + 1 > taRedPacketMoney.getLimitPacketNum()){
+			return;
+		}
+		//获取红包的随机数
+		int redPackageMoney = getRedPackageMoney(taRedPacketMoney.getMaxPacket(), taRedPacketMoney.getMinPacket());
+		redPackageMoney = taOrgAccount.getRealBalance() < redPackageMoney ? taOrgAccount.getRealBalance() : redPackageMoney;
+
+		//获取红包支付相关的配置
+		TaRedPacketClient taRedPacketClient = taRedPacketClientMapper.selectById(taRedPacketHelp.getActivityId());
+		//获取收红包人的openid
+		TaMpPerson parentMpPerson = taMpPersonMapper.selectById(parentMpMiniapp.getMpPersonId());
+		//发送红包
+		WxPayService wxPayService = getWxPayService();
+		WxPaySendRedpackRequest build = WxPaySendRedpackRequest.newBuilder()
+//				.consumeMchId(wxPayService.getConfig().getMchId())
+				.actName(taRedPacketClient.getActivityName())//活动名称
+				.clientIp(String.valueOf(InetAddress.getLoopbackAddress()))//Ip地址
+				.mchBillNo("HB123456")//商户订单号
+//				.msgAppid(mpAppid)
+				.remark(taRedPacketClient.getRemark())//备注
+				.reOpenid(parentMpPerson.getMpOpenid())//接受红包的用户openid
+
+				.sceneId("")//场景id
+				.sendName(taRedPacketClient.getMchName())//红包发送者名称
+				.totalAmount(redPackageMoney)//付款金额，单位分
+				.totalNum(1)//红包发放总人数
+				.wishing(taRedPacketClient.getBlessing())//红包祝福语
+				.wxAppid(mpAppid)//公众账号appid
+				.build();
+		try {
+			WxPaySendRedpackResult wxPaySendRedpackResult = wxPayService.sendRedpack(build);
+			String resultCode = wxPaySendRedpackResult.getResultCode();
+			if (resultCode.equals("SUCCESS")){
+				//插入订单表并扣钱反更新
+				saveRedpacketOrder("HB123456",wxPaySendRedpackResult,parentMpMiniapp,taRedPacketHelp,orgId,mpAppid);
+			}else {
+				return;
+			}
+		} catch (WxPayException e) {
+			e.printStackTrace();
+		}
+	}
+
+	private synchronized void saveRedpacketOrder(String tradeNo, WxPaySendRedpackResult wxPaySendRedpackResult, TaMpMiniapp parentMpMiniapp, TaRedPacketHelp taRedPacketHelp, Integer orgId, String mpAppid) {
+		//先扣钱
+		TaOrgAccount taOrgAccount = taOrgAccountMapper.selectOne(new QueryWrapper<TaOrgAccount>().eq("org_id", orgId).eq("status", CommConstant.STATUS_NORMAL));
+		taOrgAccount.setRealBalance(taOrgAccount.getRealBalance() - wxPaySendRedpackResult.getTotalAmount());
+		taOrgAccountMapper.updateById(taOrgAccount);
+		TaRedPacketMoney taRedPacketMoney = taRedPacketmonetMapper.selectById(taRedPacketHelp.getActivityId());
+		taRedPacketMoney.setBalance(taRedPacketMoney.getBalance()-wxPaySendRedpackResult.getTotalAmount());
+		taRedPacketmonetMapper.updateById(taRedPacketMoney);
+
+		//插入组织订单表
+		TaOrgOrder taOrgOrder = new TaOrgOrder();
+		taOrgOrder.setAmount(wxPaySendRedpackResult.getTotalAmount());
+		taOrgOrder.setCreateDate(LocalDateTime.now());
+		taOrgOrder.setOrgId(orgId);
+		taOrgOrder.setPayDate(LocalDateTime.now());
+		taOrgOrder.setStatus(CommConstant.STATUS_NORMAL);
+		taOrgOrder.setTradeNo(tradeNo);
+		taOrgOrder.setTradingStatus(CommConstant.TRADING_STATUS_SUCCESS);
+		taOrgOrderMapper.insert(taOrgOrder);
+
+		//插入组织订单明细表
+		TaOrgOrderDetail taOrgOrderDetail = new TaOrgOrderDetail();
+		taOrgOrderDetail.setAmount(wxPaySendRedpackResult.getTotalAmount());
+		taOrgOrderDetail.setItemType(CommConstant.ITEM_TYPE_REDPACKAGE);
+		taOrgOrderDetail.setOrderId(taOrgOrder.getOrderId());
+		taOrgOrderDetail.setOrgId(orgId);
+		taOrgOrderDetail.setQuantity(1);
+		taOrgOrderDetail.setReceiverId(parentMpMiniapp.getMiniappPersonId());
+		taOrgOrderDetail.setReceiverMpId(parentMpMiniapp.getMpPersonId());
+		TaPerson taPerson = taPersonMapper.selectById(parentMpMiniapp.getMiniappPersonId());
+		taOrgOrderDetail.setReceiverName(taPerson.getNickname());
+		taOrgOrderDetail.setStatus(CommConstant.STATUS_NORMAL);
+		taOrgOrderDetail.setTargetId(taRedPacketHelp.getActivityId());
+		taOrgOrderDetail.setTargetType(CommConstant.ITEM_TYPE_REDPACKAGE);
+		taOrgOrderDetailMapper.insert(taOrgOrderDetail);
+
+		//插入账户流水表
+		TaOrgAccountDetailedList taOrgAccountDetailedList = new TaOrgAccountDetailedList();
+		taOrgAccountDetailedList.setAccountId(taOrgAccount.getAccountId());
+		taOrgAccountDetailedList.setAmount(wxPaySendRedpackResult.getTotalAmount());
+		taOrgAccountDetailedList.setCreateDate(LocalDateTime.now());
+		taOrgAccountDetailedList.setOrderId(taOrgOrder.getOrderId());
+		taOrgAccountDetailedList.setOrgId(orgId);
+		taOrgAccountDetailedList.setSignType(-1);
+		taOrgAccountDetailedList.setStatus(CommConstant.STATUS_NORMAL);
+		taOrgAccountDetailedListMapper.insert(taOrgAccountDetailedList);
+
+	}
+
+	/**
+	 * 获取商户号信息
+	 * @return
+	 */
+	private WxPayService getWxPayService() {
+		TaWxPayConfig taWxPayConfig = taWxPayConfigMapper.selectOne(new QueryWrapper<TaWxPayConfig>().eq("org_id", 0));
+		WxPayConfig payConfig = new WxPayConfig();
+		payConfig.setAppId(StringUtils.trimToNull(taWxPayConfig.getAppid()));
+		payConfig.setMchId(StringUtils.trimToNull(taWxPayConfig.getMchId()));
+		payConfig.setMchKey(StringUtils.trimToNull(taWxPayConfig.getMchKey()));
+		payConfig.setKeyPath(StringUtils.trimToNull(taWxPayConfig.getApiPath()));
+		WxPayService wxPayService =new WxPayServiceImpl();
+		wxPayService.setConfig(payConfig);
+		return wxPayService;
+	}
+
+	/**
+	 * 获取范围值之内的红包的随机数
+	 * @param maxPacket
+	 * @param minPacket
+	 * @return
+	 */
+	private int getRedPackageMoney(Integer maxPacket, Integer minPacket) {
+		Random random = new Random();
+		return random.nextInt(maxPacket)%(maxPacket - minPacket + 1) + minPacket;
 	}
 }

src/test/java/com/huiju/estateagents/WxPayTest.java

@@ -6,7 +6,7 @@ import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.time.LocalDateTime;
+import java.util.Random;
 
 @RunWith(SpringJUnit4ClassRunner.class)
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@@ -28,8 +28,11 @@ public class WxPayTest {
 //        }catch (Exception e) {
 //            e.printStackTrace();
 //        }
+        Random random = new Random();
+        for (int i =0; i <100 ; i++){
+            System.out.println(random.nextInt(5)%(5-1 + 1) +1);
+        }
 
-        System.out.println(LocalDateTime.now().toLocalDate().equals(LocalDateTime.now().toLocalDate()));
 
     }
 }