From 503da018813cb8f2e01ff27016b7b0f056b000ad Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 21 Jul 2023 15:53:20 +0800
Subject: [PATCH] 订单支付后生成对应的课程单

---
 src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java |  101 ++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 81 insertions(+), 20 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
index 59f271a..d76f35a 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
@@ -10,6 +10,9 @@
 import cc.mrbird.febs.mall.mapper.*;
 import cc.mrbird.febs.mall.service.*;
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateField;
+import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.crypto.SecureUtil;
@@ -52,6 +55,8 @@
     private final IApiMallMemberWalletService memberWalletService;
     private final MallRollPerkMapper mallRollPerkMapper;
     private final IMallMoneyFlowService mallMoneyFlowService;
+    private final MallMemberClassMapper mallMemberClassMapper;
+    private final MallMemberHouseMapper mallMemberHouseMapper;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -405,28 +410,84 @@
         }
     }
 
+    @Override
+    public void rollSendMsg(Long orderId) {
+        MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectById(orderId);
+        if(ObjectUtil.isEmpty(mallOrderInfo)){
+            return;
+        }
+        Long memberId = mallOrderInfo.getMemberId();
+        MallMember mallMember = memberMapper.selectById(memberId);
+        if(ObjectUtil.isEmpty(mallMember)){
+            return;
+        }
+
+        List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(orderId);
+        if(CollUtil.isEmpty(mallOrderItemList)){
+            return;
+        }
+        MallOrderItem mallOrderItem = mallOrderItemList.get(0);
+        String goodsName = mallOrderItem.getGoodsName();
+        String skuImage = mallOrderItem.getSkuImage();
+        Long goodsId = mallOrderItem.getGoodsId();
+        MallGoods mallGoods = mallGoodsMapper.selectById(goodsId);
+        if(ObjectUtil.isEmpty(mallGoods)){
+            return;
+        }
+        Integer isNormal = mallGoods.getIsNormal();
+        if(4 == isNormal){
+            //课程卷
+            MallMemberClass mallMemberClass = new MallMemberClass();
+            mallMemberClass.setMemberId(mallMember.getId());
+            mallMemberClass.setOrderId(orderId);
+            mallMemberClass.setClassName(goodsName);
+            mallMemberClass.setClassPic(skuImage);
+            mallMemberClass.setClassUrl(skuImage);
+            mallMemberClassMapper.insert(mallMemberClass);
+            return;
+        }else if(5 == isNormal){
+            //课程卷
+            MallMemberHouse mallMemberHouse = new MallMemberHouse();
+            mallMemberHouse.setOrderId(orderId);
+            mallMemberHouse.setMemberId(memberId);
+            mallMemberHouse.setState(1);
+            mallMemberHouse.setCreateTime(DateUtil.date());
+            mallMemberHouse.setUpdateTime(mallOrderInfo.getUseTime());
+            mallMemberHouse.setUnuseTime(DateUtil.date().offset(DateField.HOUR_OF_DAY,48));
+            mallMemberHouse.setHouseName(mallGoods.getHouseName());
+            mallMemberHouse.setHouseAddress(mallGoods.getHouseAddress());
+            mallMemberHouseMapper.insert(mallMemberHouse);
+            return;
+        }else{
+            return;
+        }
+    }
+
     public static void main(String[] args) {
 
-        RestTemplate restTemplate = new RestTemplate();
-        String accessToken = "70__DR_q_qmjcMfPQEBwmjdfJFWnpml55Bq6JK2vt9MMdcRLsHaYM1BQGFWzLUISjcFC8HAYTKOaPJH93KHNvo4KIeMZkxFF2qP66nAdygUQ6c";
-        String openId = "oXL7Y6LW5KGQTbmmP5W3JljjApSo";
-        String requrl = "https://api.weixin.qq.com/sns/userinfo?access_token="+accessToken+"&openid="+openId+"&lang=zh_CN";
-        // 创建一个StringHttpMessageConverter,并设置字符集为UTF-8
-        StringHttpMessageConverter stringConverter = new StringHttpMessageConverter(Charset.forName("UTF-8"));
-        stringConverter.setSupportedMediaTypes(Collections.singletonList(MediaType.TEXT_PLAIN));
-        // 将StringHttpMessageConverter添加到RestTemplate的消息转换器列表中
-        restTemplate.getMessageConverters().add(0, stringConverter);
-        // 创建HttpHeaders对象,设置Accept头部的值为"text/plain;charset=UTF-8"
-        HttpHeaders headers = new HttpHeaders();
-        headers.setAccept(Collections.singletonList(MediaType.TEXT_PLAIN));
-        headers.set(HttpHeaders.ACCEPT_CHARSET, "UTF-8");
+        DateTime offset = DateUtil.date().offset(DateField.HOUR_OF_DAY, 48);
+        System.out.println(offset);
 
-        String responseStr = restTemplate.getForObject(requrl, String.class);
-        net.sf.json.JSONObject json = net.sf.json.JSONObject.fromObject(responseStr);
-        log.info("微信获取用户信息={}", json);
-        String nickname = json.getString("nickname");
-        String headImgUrl = json.getString("headimgurl");
-        System.out.println(nickname);
-        System.out.println(headImgUrl);
+//        RestTemplate restTemplate = new RestTemplate();
+//        String accessToken = "70__DR_q_qmjcMfPQEBwmjdfJFWnpml55Bq6JK2vt9MMdcRLsHaYM1BQGFWzLUISjcFC8HAYTKOaPJH93KHNvo4KIeMZkxFF2qP66nAdygUQ6c";
+//        String openId = "oXL7Y6LW5KGQTbmmP5W3JljjApSo";
+//        String requrl = "https://api.weixin.qq.com/sns/userinfo?access_token="+accessToken+"&openid="+openId+"&lang=zh_CN";
+//        // 创建一个StringHttpMessageConverter,并设置字符集为UTF-8
+//        StringHttpMessageConverter stringConverter = new StringHttpMessageConverter(Charset.forName("UTF-8"));
+//        stringConverter.setSupportedMediaTypes(Collections.singletonList(MediaType.TEXT_PLAIN));
+//        // 将StringHttpMessageConverter添加到RestTemplate的消息转换器列表中
+//        restTemplate.getMessageConverters().add(0, stringConverter);
+//        // 创建HttpHeaders对象,设置Accept头部的值为"text/plain;charset=UTF-8"
+//        HttpHeaders headers = new HttpHeaders();
+//        headers.setAccept(Collections.singletonList(MediaType.TEXT_PLAIN));
+//        headers.set(HttpHeaders.ACCEPT_CHARSET, "UTF-8");
+//
+//        String responseStr = restTemplate.getForObject(requrl, String.class);
+//        net.sf.json.JSONObject json = net.sf.json.JSONObject.fromObject(responseStr);
+//        log.info("微信获取用户信息={}", json);
+//        String nickname = json.getString("nickname");
+//        String headImgUrl = json.getString("headimgurl");
+//        System.out.println(nickname);
+//        System.out.println(headImgUrl);
     }
 }

--
Gitblit v1.9.1