From a1e9550b8ecc956bbb4071bae986c13daee319a3 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 28 Dec 2023 12:35:15 +0800
Subject: [PATCH] 直推奖励,冻结的用户,则直推奖励销毁,用户未冻结才能领取成功

---
 src/test/java/cc/mrbird/febs/ProfitTest.java |  201 ++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 146 insertions(+), 55 deletions(-)

diff --git a/src/test/java/cc/mrbird/febs/ProfitTest.java b/src/test/java/cc/mrbird/febs/ProfitTest.java
index ed8ba71..fa3a8ef 100644
--- a/src/test/java/cc/mrbird/febs/ProfitTest.java
+++ b/src/test/java/cc/mrbird/febs/ProfitTest.java
@@ -5,14 +5,17 @@
 import cc.mrbird.febs.common.enumerates.FlowTypeEnum;
 import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum;
 import cc.mrbird.febs.common.enumerates.OrderStatusEnum;
+import cc.mrbird.febs.common.exception.FebsException;
 import cc.mrbird.febs.common.utils.HttpCurlUtil;
 import cc.mrbird.febs.common.utils.MallUtils;
 import cc.mrbird.febs.common.utils.RedisUtils;
 import cc.mrbird.febs.mall.dto.AdminLeaderAddFenceDto;
 import cc.mrbird.febs.mall.dto.ApiLeaderRefundOrderDto;
+import cc.mrbird.febs.mall.dto.ApiRechargeWalletDto;
 import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.mapper.*;
 import cc.mrbird.febs.mall.service.*;
+import cc.mrbird.febs.pay.model.BrandWCPayRequestData;
 import cc.mrbird.febs.pay.model.WxGenerateQrCodeDto;
 import cc.mrbird.febs.pay.service.IXcxPayService;
 import cc.mrbird.febs.pay.util.WechatConfigure;
@@ -216,8 +219,70 @@
 //        FebsResponse febsResponse = iXcxPayService.generateQrCode(wxGenerateQrCodeDto);
 //        String data = febsResponse.get("data").toString();
 //        System.out.println(data);
-        trackServiceInfo("e024c63342930addc57189c8608cdb01",null);
+//        trackServiceInfo("e024c63342930addc57189c8608cdb01",null);
+//        String e024c63342930addc57189c8608cdb01 = trackServiceDel("e024c63342930addc57189c8608cdb01", "792477");
+//        System.out.println(e024c63342930addc57189c8608cdb01);
+        String ss = fenceDel("95ede7157929f5f6b6c758971be924b1", "795278","795554");
+        System.out.println(ss);
     }
+
+    //电子围栏删除
+    public String fenceDel(String gaodeKey, String sid,String fenceId) {
+        String url = "https://tsapi.amap.com/v1/track/geofence/delete?key="+gaodeKey+"&sid="+sid+"&gfids="+fenceId;
+        HttpPost httpPost = new HttpPost(url);
+        Map<String,String> map = new HashMap<>();
+        map.put("key",gaodeKey);
+        map.put("sid",sid);
+        map.put("gfids",fenceId);
+        String  param= JSON.toJSONString(map);
+        String result = null;
+        try {
+            result = HttpCurlUtil.sendPostHttp(url, param);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        cn.hutool.json.JSONObject maps = JSONUtil.parseObj(result);
+        System.out.println(maps);
+        String errcode = maps.get("errcode").toString();
+        if(!"10000".equals(errcode)){
+            return "fail";
+        }else{
+            return maps.toString();
+        }
+    }
+    //服务删除
+    public String trackServiceDel(String gaodeKey, String sid) {
+        String url = "https://tsapi.amap.com/v1/track/service/delete?key="+gaodeKey+"&sid="+sid;
+        HttpPost httpPost = new HttpPost(url);
+        Map<String,String> map = new HashMap<>();
+        map.put("key",gaodeKey);
+        map.put("sid",sid);
+        String  param= JSON.toJSONString(map);
+        String result = null;
+        try {
+            result = HttpCurlUtil.sendPostHttp(url, param);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        cn.hutool.json.JSONObject maps = JSONUtil.parseObj(result);
+        System.out.println(maps);
+        String errcode = maps.get("errcode").toString();
+        if(!"10000".equals(errcode)){
+            return "fail";
+        }else{
+            return maps.toString();
+        }
+//        String str2 = maps.get("data").toString();
+//        cn.hutool.json.JSONObject maps2 = JSONUtil.parseObj(str2);
+//        String serviceId = maps2.get("sid").toString();
+//        if(null!=serviceId&&!"".equals(serviceId)){
+//            return serviceId;
+//        }else{
+//            return "fail";
+//        }
+    }
+
+
     public String trackServiceInfo(String gaodeKey, String serviceName) {
         String url = "https://tsapi.amap.com/v1/track/service/list";
         HttpPost httpPost = new HttpPost(url);
@@ -349,62 +414,88 @@
 
     @Test
     public void qrcode(){
-        MallMember member = mallMemberMapper.selectById(58L);
-        Long id = 320L;
+        MallMember member = mallMemberMapper.selectById(402L);
+        
+//        ApiRechargeWalletDto apiRechargeWalletDto = new ApiRechargeWalletDto();
+//        apiRechargeWalletDto.setAmount(new BigDecimal(1));
+//        apiRechargeWalletDto.setMemberId(402L);
+//        BrandWCPayRequestData brandWCPayRequestData = null;
+//        try {
+//            brandWCPayRequestData = iXcxPayService.startRechargeWallet(apiRechargeWalletDto);
+//        } catch (Exception e) {
+//            throw new FebsException("支付失败");
+//        }
+//        String wxResultStr = JSONUtil.toJsonStr(brandWCPayRequestData);
+//        String payResultStr = brandWCPayRequestData.getPrepay_id();
+//        Map<String, Object> map = new HashMap<>();
+//        map.put("orderInfo", payResultStr);
+//        map.put("wxResultStr", wxResultStr);
+        
+        Long id = 345417L;
         MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectById(id);
-        if(ObjectUtil.isEmpty(mallOrderInfo)){
+        BrandWCPayRequestData brandWCPayRequestData = null;
+        try {
+            brandWCPayRequestData = iXcxPayService.startPayment(mallOrderInfo);
+        } catch (Exception e) {
+            throw new FebsException("支付失败");
         }
-        Integer status = mallOrderInfo.getStatus();
-        if(OrderStatusEnum.WAIT_SHIPPING.getValue() != status){
-        }
-        Integer deliveryState = mallOrderInfo.getDeliveryState();
-        if(1 != deliveryState){
-        }
-        //根据子订单生成退款记录
-        List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(id);
-        if(CollUtil.isEmpty(mallOrderItemList)){
-        }
-        for(MallOrderItem mallOrderItem : mallOrderItemList){
-            QueryWrapper<MallRefundEntity> objectQueryWrapper = new QueryWrapper<>();
-            objectQueryWrapper.eq("member_id",member.getId());
-            objectQueryWrapper.eq("order_id",mallOrderInfo.getId());
-            objectQueryWrapper.eq("item_id",mallOrderItem.getId());
-            MallRefundEntity mallRefund = mallRefundMapper.selectOne(objectQueryWrapper);
-            MallRefundEntity mallRefundEntity = new MallRefundEntity();
-            if(ObjectUtil.isEmpty(mallRefund)){
-                mallRefundEntity.setRefundNo(mallOrderInfo.getOrderNo()+"_RITEM"+mallOrderItem.getId());
-                mallRefundEntity.setMemberId(member.getId());
-                mallRefundEntity.setOrderId(mallOrderInfo.getId());
-                mallRefundEntity.setItemId(mallOrderItem.getId());
-                if("余额支付".equals(mallOrderInfo.getPayMethod())){
-                    mallRefundEntity.setType(3);
-                }else if("微信支付".equals(mallOrderInfo.getPayMethod())){
-                    mallRefundEntity.setType(1);
-                }else{
-                    mallRefundEntity.setType(3);
-                }
-                mallRefundEntity.setState(3);
-                mallRefundEntity.setAmount(mallOrderItem.getAmount());
-                mallRefundMapper.insert(mallRefundEntity);
-            }else{
-                if(mallRefund.getState() == 2){
-                    mallRefundEntity.setId(mallRefund.getId());
-                    mallRefundEntity.setRefundNo(mallRefund.getRefundNo());
-                    mallRefundEntity.setMemberId(mallRefund.getMemberId());
-                    mallRefundEntity.setOrderId(mallRefund.getOrderId());
-                    mallRefundEntity.setItemId(mallRefund.getItemId());
-                    mallRefundEntity.setType(mallRefund.getType());
-                    mallRefundEntity.setState(3);
-                    mallRefundEntity.setAmount(mallRefund.getAmount());
-                    mallRefundMapper.updateById(mallRefundEntity);
-                }
-            }
-            ApiLeaderRefundOrderDto apiLeaderRefundOrderDto = new ApiLeaderRefundOrderDto();
-            apiLeaderRefundOrderDto.setOrderId(mallOrderInfo.getId());
-            apiLeaderRefundOrderDto.setItemId(mallOrderItem.getId());
-            apiLeaderRefundOrderDto.setAgreeState(1);
-            iApiMallTeamLeaderService.leaderRefundOrder(apiLeaderRefundOrderDto);
-        }
+        String s = JSONUtil.toJsonStr(brandWCPayRequestData);
+        String prepay_id = brandWCPayRequestData.getPrepay_id();
+        
+        
+//        if(ObjectUtil.isEmpty(mallOrderInfo)){
+//        }
+//        Integer status = mallOrderInfo.getStatus();
+//        if(OrderStatusEnum.WAIT_SHIPPING.getValue() != status){
+//        }
+//        Integer deliveryState = mallOrderInfo.getDeliveryState();
+//        if(1 != deliveryState){
+//        }
+//        //根据子订单生成退款记录
+//        List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(id);
+//        if(CollUtil.isEmpty(mallOrderItemList)){
+//        }
+//        for(MallOrderItem mallOrderItem : mallOrderItemList){
+//            QueryWrapper<MallRefundEntity> objectQueryWrapper = new QueryWrapper<>();
+//            objectQueryWrapper.eq("member_id",member.getId());
+//            objectQueryWrapper.eq("order_id",mallOrderInfo.getId());
+//            objectQueryWrapper.eq("item_id",mallOrderItem.getId());
+//            MallRefundEntity mallRefund = mallRefundMapper.selectOne(objectQueryWrapper);
+//            MallRefundEntity mallRefundEntity = new MallRefundEntity();
+//            if(ObjectUtil.isEmpty(mallRefund)){
+//                mallRefundEntity.setRefundNo(mallOrderInfo.getOrderNo()+"_RITEM"+mallOrderItem.getId());
+//                mallRefundEntity.setMemberId(member.getId());
+//                mallRefundEntity.setOrderId(mallOrderInfo.getId());
+//                mallRefundEntity.setItemId(mallOrderItem.getId());
+//                if("余额支付".equals(mallOrderInfo.getPayMethod())){
+//                    mallRefundEntity.setType(3);
+//                }else if("微信支付".equals(mallOrderInfo.getPayMethod())){
+//                    mallRefundEntity.setType(1);
+//                }else{
+//                    mallRefundEntity.setType(3);
+//                }
+//                mallRefundEntity.setState(3);
+//                mallRefundEntity.setAmount(mallOrderItem.getAmount());
+//                mallRefundMapper.insert(mallRefundEntity);
+//            }else{
+//                if(mallRefund.getState() == 2){
+//                    mallRefundEntity.setId(mallRefund.getId());
+//                    mallRefundEntity.setRefundNo(mallRefund.getRefundNo());
+//                    mallRefundEntity.setMemberId(mallRefund.getMemberId());
+//                    mallRefundEntity.setOrderId(mallRefund.getOrderId());
+//                    mallRefundEntity.setItemId(mallRefund.getItemId());
+//                    mallRefundEntity.setType(mallRefund.getType());
+//                    mallRefundEntity.setState(3);
+//                    mallRefundEntity.setAmount(mallRefund.getAmount());
+//                    mallRefundMapper.updateById(mallRefundEntity);
+//                }
+//            }
+//            ApiLeaderRefundOrderDto apiLeaderRefundOrderDto = new ApiLeaderRefundOrderDto();
+//            apiLeaderRefundOrderDto.setOrderId(mallOrderInfo.getId());
+//            apiLeaderRefundOrderDto.setItemId(mallOrderItem.getId());
+//            apiLeaderRefundOrderDto.setAgreeState(1);
+//            iApiMallTeamLeaderService.leaderRefundOrder(apiLeaderRefundOrderDto);
+//        }
     }
 
     /**

--
Gitblit v1.9.1