From e030255c23c7ba3e2cbad1036a810d6d72fa864f Mon Sep 17 00:00:00 2001
From: liujie <liujie>
Date: 星期四, 26 十月 2023 18:04:58 +0800
Subject: [PATCH] 修改bug

---
 cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java |  208 ++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 184 insertions(+), 24 deletions(-)

diff --git a/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java b/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java
index ec78a66..9b003a2 100644
--- a/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java
+++ b/cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java
@@ -1,6 +1,16 @@
 package com.dsh.account.service.impl;
 
 
+import com.alipay.api.AlipayApiException;
+import com.alipay.api.AlipayClient;
+import com.alipay.api.DefaultAlipayClient;
+import com.alipay.api.domain.AlipayTradeOrderSettleModel;
+import com.alipay.api.domain.OpenApiRoyaltyDetailInfoPojo;
+import com.alipay.api.domain.RoyaltyDetailInfos;
+import com.alipay.api.request.AlipayTradeOrderSettleRequest;
+import com.alipay.api.request.AlipayTradeRoyaltyRelationBindRequest;
+import com.alipay.api.response.AlipayTradeOrderSettleResponse;
+import com.alipay.api.response.AlipayTradeRoyaltyRelationBindResponse;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -156,6 +166,16 @@
 
     @Autowired
     private IntroduceRewardsClient introduceRewardsClient;
+
+    private String aliAppid = "2021004105665036";//支付宝appid
+
+    private String appPrivateKey = "MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQCi5i9nW/hGLJ3A06cZxTQdviFC7THpdSihoTYGLr9q006hu0V26ecBMY/o4w5bvIX0Ok/yofmZsVcCJpAPvbXL/uqVrIjnRRxXiaeBFThlxoBUTdunvbUSDYfzlEhJr5NvUKI6H6lz2niXlQGx4qy8Hau4ccWit9kM8jwUvsBVQoFgJA+xrjMvooA7YLopQtpOD+UJr5thApTSf1xrnr1W12yolTLEH15JmNV372cqXrYUuqnY0QsaPtxeqJUGAOcGdVLllQ7easEznP8DFBvDdHATcmp2SHNQDUEWN6MCVPbMgY06NQVqAXxqjTAYSVh+6TRu6bofPmpYC3TZB003AgMBAAECggEBAJAcR2+PA3NBYUYHeFrqBRMS8uX8ZR19kjZ7IgoSLTFaQsP9opRylPSPXhrPVBKAE5leRQAHn4MCSlESwHvMfxo7KFjFTFAc6dffZZpipYQUOc9bGampwJh58/3e/pyBgVMG6J23CPf/HJQtNFSkjd/V9+ayb/9l2dUEL3bC0fAZ/dbx8HsxdLw8wn3fLlWLj68hOMqa2deCZe3JdSVsPbeWqkh56FFsMLug0Nd+Ar4TgRl9/jnhXF0JWiD0LmPUYLhboY7EfUBzN4w1iYbDi1P+3zvoOYsiVKAXox9GMhQ2VzOO2UcSTuizSza2e98mGpabl/GpKmCz+RDFjtkX6eECgYEA2MyCij65eO3aGIm3FUe93DULRBYTfX8qJQSJq2WOWA3mmQlEW6L3O2B5/lG2h+8WmN6iLEs9eHpgycGYp7vAqgrANEn16ACVcuyx0scFtrZfZ+kmHMzFfiUWxJjVYk/6YngsGVBLdw6ueM42C8TTP67X9tU5TdVGoGWuqEj4W98CgYEAwFqwprXOch5Pqk/RPbb49r0Ou03K/UbciWnWWKzUhFFNS8MdlQPoDvQZbMwHLeWsa2VhaKITK3x5biLQb3U+0GLOn6lTvEyrEUH+ucREyLgVYTRAvwBPtnvlrzpyxPk2HnslQjju8WrvvLLBMKWUjlTrTOzhaHT21gz3pHMiOakCgYEAhLmfaXdBITGshb054sNLDtdCkGpbgEcrzAHdLps769iGxkYQHXHFngpQZUwtTUcoNGqIKknd1jZFrv7gsD+XkgKG7PwimehRlkwmCX5ilxtLiVgJRzRt6+5U5AMVD90a0tHzXYP0z2yjj73fBJF5KtGl0a10KZxaYrQdm1UhB00CgYBZZgzx/k9rtHC8LAqIj1CYhHejT92G53c6Gkl3vyOqN4sgKhfGmSEySfrDGPRBPZxr8ZtbIPCd5mUdberH0osWGMYFaJI1UsCy7aQwvGpniz7MhZeN7dweaOjwDs8mgtjHQ96mL4XGCDhR0BZ/wIURvZ/6iaGdhbbu9unlsWj3uQKBgQCmZYdsbbZkd3ev6f8rwyvMz+DrCQyYpY44cegBYuJgrZiQnL2fJioeN7ixX0UM48SfwsZEIrzshP/LGAwnc2MdjxKUl4jLN8SEe0NAjXOnz9Zaw740+aOmLpXcLWdP4uM2gIhWsvW1tEkQZCXmm7c9s/RsU8Pmzv+YL3+fSijOzA==";//支付宝开发者应用私钥
+
+    private String alipayPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAouYvZ1v4RiydwNOnGcU0Hb4hQu0x6XUooaE2Bi6/atNOobtFdunnATGP6OMOW7yF9DpP8qH5mbFXAiaQD721y/7qlayI50UcV4mngRU4ZcaAVE3bp721Eg2H85RISa+Tb1CiOh+pc9p4l5UBseKsvB2ruHHForfZDPI8FL7AVUKBYCQPsa4zL6KAO2C6KULaTg/lCa+bYQKU0n9ca569VtdsqJUyxB9eSZjVd+9nKl62FLqp2NELGj7cXqiVBgDnBnVS5ZUO3mrBM5z/AxQbw3RwE3JqdkhzUA1BFjejAlT2zIGNOjUFagF8ao0wGElYfuk0bum6Hz5qWAt02QdNNwIDAQAB";//支付宝应用公钥
+
+    private String alipay_public_key = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAmu8n/4yTHWbn7VOrNc9OsLtDL1bEQ8gC1dHkj8Wy5z0mkaOsjJRIG/28ze12M0V8jdCKuuDr5Z1OPKiqf+XO3ypguEh+mYUVMBM/cZodDFQfTY1TKLWjvQCuaqlA+QUTCK6f7T7stsgyQ1o9Jj0rXZDz6PM4QHSTzjrLIBaeqM5WIBvH+fy/X+QG5Utd+/UT0kc0JyvuKhZ65yVUd/C9VcwJJAPliRsAQNrqYterwAJ9zvw9tF11wj9W0XgJ8Ccu4x3gR1vrlLRJJo/OA97RmxPQ+5hSacWQZCUd1dwiBq+YCrKVHGTj14izRHXrLc0yBlRXo7tBOIqcy3IsvKVthQIDAQAB";//支付宝支付公钥
+
+
     @Override
     public List<QueryAppUserVO> listAll(QueryAppUser query) {
        return appUserMapper.listAll(query);
@@ -281,9 +301,10 @@
 
                 }
                 classInfoVo.setCourseList(courseList);
-                List<ExerciseVideo> stuCourseOfVideoList = voclClient.getStuCourseOfVideoList(coursePackIds);
-                System.out.println(stuCourseOfVideoList);
-                classInfoVo.setExerciseVideoList(stuCourseOfVideoList);
+//                List<ExerciseVideo> stuCourseOfVideoList = voclClient.getStuCourseOfVideoList(coursePackIds);
+                List<ExerciseVideo> query = voclClient.query(id);
+                System.out.println("======queryqueryqueryquery=================="+query);
+                classInfoVo.setExerciseVideoList(query);
             }else {
                 classInfoVo.setIsThere(2);
                 List<TImgConfig> tImgConfigs = configClient.getNoneStuImgs();
@@ -556,6 +577,9 @@
             return ResultUtil.error("验证码无效");
         }
         TAppUser tAppUser = this.baseMapper.selectOne(new QueryWrapper<TAppUser>().eq("phone", phone).ne("state", 3));
+        if(tAppUser==null){
+            return ResultUtil.error("该账号未注册", "");
+        }
         if(tAppUser.getState() == 2){
             return ResultUtil.error("您的账号已被冻结", "");
         }
@@ -616,7 +640,7 @@
             for (Store store : stores) {
                 Map<String, Double> distance = GeodesyUtil.getDistance(lon + "," + lat, store.getLon() + "," + store.getLat());
                 Double wgs84 = distance.get("WGS84");
-                if(s == null || d.compareTo(wgs84) < 0){
+                if(s == null || d>wgs84){
                     s = store;
                     d = wgs84;
                 }
@@ -626,6 +650,10 @@
             joinPlayPaiVo.setLat(s.getLat());
             joinPlayPaiVo.setStoreId(s.getId());
             joinPlayPaiVo.setPhone(s.getPhone());
+            joinPlayPaiVo.setProvince(s.getProvince());
+            joinPlayPaiVo.setProvinceCode(s.getProvinceCode());
+            joinPlayPaiVo.setCity(s.getCity());
+            joinPlayPaiVo.setCityCode(s.getCityCode());
         }
         return joinPlayPaiVo;
     }
@@ -835,7 +863,7 @@
                         if (vicinityGood.getRedemptionMethod() == 1) {
                             commodity.setIntegral(vicinityGood.getIntegral().intValue());
                         } else {
-                            commodity.setIntegral(vicinityGood.getIntegral().intValue());
+                            commodity.setIntegral(ToolUtil.isEmpty(vicinityGood.getIntegral())?0:vicinityGood.getIntegral());
                             commodity.setAmount(vicinityGood.getCash());
                         }
                         commodity.setBelongsType(vicinityGood.getUserPopulation());
@@ -869,7 +897,7 @@
                         if (vicinityGood.getRedemptionMethod() == 1) {
                             commodity.setIntegral(vicinityGood.getIntegral().intValue());
                         } else {
-                            commodity.setIntegral(vicinityGood.getIntegral().intValue());
+                            commodity.setIntegral(ToolUtil.isEmpty(vicinityGood.getIntegral())?0:vicinityGood.getIntegral());
                             commodity.setAmount(vicinityGood.getCash());
                         }
                         commodity.setBelongsType(vicinityGood.getUserPopulation());
@@ -983,6 +1011,10 @@
         detailsVo.setGoodId(goodId);
         return mcClient.getGoodDetailsWithId(detailsVo);
     }
+    @Override
+    public ProductDetailsVo goodsDetailsOne(Integer goodId ) {
+        return mcClient.getGoodDetailsWithIdOne(goodId);
+    }
 
     @Override
     public StuAndStoreResponse queryAppUserDefaultStuAndStore(Integer userIdFormRedis,Integer pointsMerId, String lat, String lon,Integer isCourse) {
@@ -1032,7 +1064,27 @@
         if (ToolUtil.isEmpty(merchandise)){
             return ResultUtil.error("商品不存在");
         }
+
+
         TAppUser tAppUser = this.baseMapper.selectById(userIdFormRedis);
+
+
+        if(merchandise.getUserPopulation()==2){
+            if(tAppUser.getIsVip()==0){
+                return ResultUtil.error("该商品只能年度会员购买");
+            }
+        }
+
+
+
+        if(merchandise.getUserPopulation()==3){
+            List<TStudent> students = tsmapper.selectList(new LambdaQueryWrapper<TStudent>().eq(TStudent::getAppUserId, userIdFormRedis));
+            if(students.size()==0){
+                return ResultUtil.error("该商品只能已有学员用户购买");
+            }
+        }
+
+
         if (ToolUtil.isEmpty(tAppUser)){
             return ResultUtil.error("用户不存在");
         }
@@ -1049,25 +1101,12 @@
         if (ToolUtil.isNotEmpty(count) && count >= merchandise.getPickUpQuantity()){
             return ResultUtil.error("超过限领数量");
         }
-
-        for (int i = 0; i < goodsNums; i++) {
-//            新增积分商品兑换记录
-            UserPointsMerchandise pointsMerchandise = new UserPointsMerchandise();
-            pointsMerchandise.setPointsMerchandiseId(exchangeType.getGoodId());
-            pointsMerchandise.setUserId(userIdFormRedis);
-            pointsMerchandise.setStatus(1);
-            pointsMerchandise.setState(1);
-            if (merchandise.getUseScope() == 3){
-                if (exchangeType.getGoodsType() == 2){
-                    CoursePackage coursePackage = cpageClient.queryCoursePackageById(merchandise.getCoursePackageId());
-                    pointsMerchandise.setStoreId(coursePackage.getStoreId());
-                }else {
-                    pointsMerchandise.setStoreId(exchangeType.getStoreId());
-                }
-            }
-            pointsMerchandise.setCode(code);
-            mcClient.saveDetailsUserPointMercase(pointsMerchandise);
+        int count1 = mcClient.queryUserHasGoodsNums1(goodResp);
+        if (ToolUtil.isNotEmpty(count1) && count1 >= merchandise.getQuantityIssued()){
+            return ResultUtil.error("超过发放数量");
         }
+
+
 
         switch (exchangeType.getExchangeType()){
 //            积分
@@ -1173,6 +1212,26 @@
             default:
                 break;
         }
+
+        for (int i = 0; i < goodsNums; i++) {
+//            新增积分商品兑换记录
+            UserPointsMerchandise pointsMerchandise = new UserPointsMerchandise();
+            pointsMerchandise.setPointsMerchandiseId(exchangeType.getGoodId());
+            pointsMerchandise.setUserId(userIdFormRedis);
+            pointsMerchandise.setStatus(1);
+            pointsMerchandise.setState(1);
+            if (merchandise.getUseScope() == 3){
+                if (exchangeType.getGoodsType() == 2){
+                    CoursePackage coursePackage = cpageClient.queryCoursePackageById(merchandise.getCoursePackageId());
+                    pointsMerchandise.setStoreId(coursePackage.getStoreId());
+                }else {
+                    pointsMerchandise.setStoreId(exchangeType.getStoreId());
+                }
+            }
+            pointsMerchandise.setCode(code);
+            mcClient.saveDetailsUserPointMercase(pointsMerchandise);
+        }
+
         return ResultUtil.success();
     }
 
@@ -1239,6 +1298,7 @@
                                         userPointsMerchandise.setPayType(2);
                                         mcClient.updateDetailsUserPointMercase(userPointsMerchandise);
                                     }
+                                    moneyOut(tradeNo,tradeNo);
                                     break;
                                 }
                                 if("WAIT_BUYER_PAY".equals(s)){
@@ -1256,6 +1316,106 @@
         return alipay;
     }
 
+
+
+    @Resource
+    private  MerChandiseClient merChandiseClient;
+
+
+    public void moneyOut(String outNum,String tradeNo) throws AlipayApiException {
+
+
+        AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", aliAppid, appPrivateKey, "json", "UTF-8", alipay_public_key, "RSA2");
+        AlipayTradeOrderSettleRequest request = new AlipayTradeOrderSettleRequest();
+        AlipayTradeOrderSettleModel model = new AlipayTradeOrderSettleModel();
+        model.setOutRequestNo(outNum);
+        model.setTradeNo(tradeNo);
+        List<RoyaltyDetailInfos> royaltyDetailInfos = new ArrayList<>();
+//
+
+        AlipayTradeRoyaltyRelationBindRequest request1 = new AlipayTradeRoyaltyRelationBindRequest();
+
+
+        request1.setBizContent("{" +
+                "  \"receiver_list\":[" +
+                "    {" +
+                "      \"type\":\"loginName\"," +
+                "      \"account\":\"19522115070\"," +
+                "      \"name\":\"罗易胜\"," +
+                "      \"memo\":\"分账给测试商户\"," +
+                "    }" +
+                "  ]," +
+                "  \"out_request_no\":\""+tradeNo+"\"" +
+                "}");
+        AlipayTradeRoyaltyRelationBindResponse response = alipayClient.execute(request1);
+        if(response.isSuccess()){
+            System.out.println("绑定调用成功");
+        } else {
+            System.out.println("调用失败");
+        }
+
+
+
+//        RoyaltyDetailInfos royaltyDetailInfos1 = new RoyaltyDetailInfos();
+//        royaltyDetailInfos1.setTransOutType("loginName");
+//        royaltyDetailInfos1.setTransOut("happysports@weparklife.com");
+//        royaltyDetailInfos1.setTransInType("loginName");
+//        royaltyDetailInfos1.setTransIn("19522115070");
+////        royaltyDetailInfos1.setAmount("0.01");
+//        royaltyDetailInfos1.setAmountPercentage("100");
+
+//        royaltyDetailInfos.add(royaltyDetailInfos1);
+
+
+        List<UserPointsMerchandise> userPointsMerchandises = merChandiseClient.queryUserPointMerchaseByCode(outNum);
+//        PaymentCompetition code = paymentCompetitionService.getOne(new QueryWrapper<PaymentCompetition>().eq("code", outNum));
+        Integer storeId = userPointsMerchandises.get(0).getStoreId();
+
+//        Competition byId1 = competitionService.getById(code.getCompetitionId());
+
+
+//        TCoursePackage byId = coursePackageService.getById(one.getCoursePackageId());
+
+
+
+        OperatorUser operatorUser =  storeClient.queryByStoreId(storeId);
+
+
+
+//        Integer paymentCompetitions = competitionsClient.queryByCode(outTradeNo);
+//        Integer siteBookings = siteClient.queryByCode(outTradeNo);
+//        List<Integer> stores = new ArrayList<>();
+//        stores.add(coursePackagePayments);
+//        stores.add(paymentCompetitions);
+//        stores.add(siteBookings);
+//        OperatorUser operatorUser = siteClient.queryOperator(stores);
+
+
+
+
+        OpenApiRoyaltyDetailInfoPojo op = new OpenApiRoyaltyDetailInfoPojo();
+        op.setTransOutType("loginName");
+        op.setTransOut("happysports@weparklife.com");
+        op.setTransInType("userId");
+        op.setTransIn(operatorUser.getAlipayNum());
+        op.setAmountPercentage(Long.valueOf(operatorUser.getAlipayProportion()));
+
+        List<OpenApiRoyaltyDetailInfoPojo> ops = new ArrayList<>();
+        ops.add(op);
+        model.setRoyaltyParameters(ops);
+
+        request.setBizModel(model);
+
+
+        AlipayTradeOrderSettleResponse response1 = alipayClient.execute(request);
+        if(response1.isSuccess()){
+            System.out.println("调用成功");
+        } else {
+            System.out.println("调用失败");
+        }
+    }
+
+
     private ResultUtil WechatPayment(BigDecimal cash, String code) throws Exception {
         ResultUtil weixinpay = payMoneyUtil.weixinpay("课包", "", code, cash.toString(),
                 "/base/pointMer/exchangeGoodPaymentWeChatCallback", "APP", "");

--
Gitblit v1.7.1