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