From 7865a1010be2f95faab151d99ecdb095f44c2a08 Mon Sep 17 00:00:00 2001 From: lisy <linlangsur163@163.com> Date: 星期五, 14 七月 2023 16:30:34 +0800 Subject: [PATCH] 修复了积分商城详情页面的门店列表查询;兑换支付todo --- cloud-server-account/src/main/java/com/dsh/account/service/impl/TAppUserServiceImpl.java | 228 +++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 215 insertions(+), 13 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 5119fd7..840eb67 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 @@ -3,16 +3,12 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.dsh.account.entity.RechargeRecords; -import com.dsh.account.entity.TAppUser; -import com.dsh.account.entity.TStudent; -import com.dsh.account.entity.VipPayment; +import com.dsh.account.entity.*; import com.dsh.account.enums.RechargeRecordEnum; import com.dsh.account.feignclient.activity.MerChandiseClient; +import com.dsh.account.feignclient.activity.MerChandiseStoreClient; import com.dsh.account.feignclient.activity.UserConponClient; -import com.dsh.account.feignclient.activity.model.CommodityRequest; -import com.dsh.account.feignclient.activity.model.PointsMerchandise; -import com.dsh.account.feignclient.activity.model.ProductDetailRequest; +import com.dsh.account.feignclient.activity.model.*; import com.dsh.account.feignclient.competition.DeductionCompetitionsClient; import com.dsh.account.feignclient.competition.model.PaymentCompetition; import com.dsh.account.feignclient.course.CoursePackageClient; @@ -21,12 +17,8 @@ import com.dsh.account.feignclient.other.ImgConfigClient; import com.dsh.account.feignclient.other.RechargeConfigClient; import com.dsh.account.feignclient.other.StoreClient; -import com.dsh.account.feignclient.other.model.Store; -import com.dsh.account.feignclient.other.model.TImgConfig; -import com.dsh.account.mapper.RechargeRecordsMapper; -import com.dsh.account.mapper.TAppUserMapper; -import com.dsh.account.mapper.TStudentMapper; -import com.dsh.account.mapper.VipPaymentMapper; +import com.dsh.account.feignclient.other.model.*; +import com.dsh.account.mapper.*; import com.dsh.account.model.AddAppUserVo; import com.dsh.account.model.JoinPlayPaiVo; import com.dsh.account.model.LoginSMSCodeVo; @@ -50,6 +42,7 @@ import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.io.IOException; +import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; @@ -113,6 +106,12 @@ @Resource private DeductionCompetitionsClient deducClient; + + @Resource + private UserIntegralChangesMapper uicMapper; + + @Resource + private MerChandiseStoreClient mcsClient; @Override public ClassInfoVo queryUserOfStus(Integer id,String latitude,String longitude) { @@ -748,4 +747,207 @@ return mcClient.getGoodDetailsWithId(detailsVo); } + @Override + public StuAndStoreResponse queryAppUserDefaultStuAndStore(Integer userIdFormRedis,Integer pointsMerId, String lat, String lon,Integer isCourse) { + StuAndStoreResponse response = new StuAndStoreResponse(); + if (isCourse == 1){ + List<TStudent> tStudents = tsmapper.selectList(new QueryWrapper<TStudent>() + .eq("appUserId",userIdFormRedis) + .eq("state",1) + .eq("isDefault",1)); + if (tStudents.size() > 0 ){ + response.setStuId(tStudents.get(0).getId()); + response.setStuName(tStudents.get(0).getName()); + response.setStuPhone(tStudents.get(0).getPhone()); + response.setStuAge(DateUtil.age(tStudents.get(0).getBirthday())); + } + return response; + }else { + PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerId); + if (pointsMerchandise.getType() == 4){ + List<Integer> couponStoreIds = ucponClient.getCouponStoreIds(pointsMerId); + StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(couponStoreIds.get(0)); + if(ToolUtil.isNotEmpty(courseOfStore)){ + response.setStoreId(couponStoreIds.get(0)); + response.setStoreName(courseOfStore.getStoreName()); + } + }else { + List<Integer> integers = mcsClient.queryPointMerStoreIds(pointsMerId); + StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(integers.get(0)); + if(ToolUtil.isNotEmpty(courseOfStore)){ + response.setStoreId(integers.get(0)); + response.setStoreName(courseOfStore.getStoreName()); + } + } + return response; + } + } + + @Override + public ResultUtil productRedemptionOperation(Integer userIdFormRedis, Integer goodId, Integer goodsType,Integer nums,Integer exchangeType,Integer payType) { + PointsMerchandise merchandise = mcClient.selectPointsMerchandiseById(goodId); + SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); + String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5); + for (int i = 0; i < nums; i++) { + UserPointsMerchandise pointsMerchandise = new UserPointsMerchandise(); + pointsMerchandise.setPointsMerchandiseId(goodId); + pointsMerchandise.setUserId(userIdFormRedis); + pointsMerchandise.setCode(code); + mcClient.saveDetailsUserPointMercase(pointsMerchandise); + } + +// 扣减积分 + TAppUser tAppUser = this.baseMapper.selectById(userIdFormRedis); + + +// 积分变更记录 + UserIntegralChanges userIntegralChanges = new UserIntegralChanges(); + userIntegralChanges.setAppUserId(userIdFormRedis); + userIntegralChanges.setOldIntegral(tAppUser.getIntegral()); + userIntegralChanges.setType(2); + tAppUser.setIntegral(null == tAppUser.getIntegral() ? merchandise.getIntegral() : tAppUser.getIntegral() +merchandise.getIntegral()); + userIntegralChanges.setNewIntegral(tAppUser.getIntegral()); + userIntegralChanges.setInsertTime(new Date()); + uicMapper.insert(userIntegralChanges); + + this.baseMapper.updateById(tAppUser); +// 现金支付 + if (exchangeType == 1){ +// 积分兑换 + switch (goodsType){ + case 2: + for (int i = 0; i < nums; i++) { + TCoursePackagePayment packagePayment = new TCoursePackagePayment(); +// packagePayment.setAppUserId(); + // TODO: 2023/7/14 + paymentClient.savePaymentCoursePackage(packagePayment); + } + break; + case 4: + for (int i = 0; i < nums; i++) { + UserCoupon coupon = new UserCoupon(); + coupon.setCouponId(goodId); + coupon.setUserId(userIdFormRedis); + coupon.setStatus(1); + coupon.setInsertTime(new Date()); + ucponClient.insertToAppuserCoupon(coupon); + } + break; + default: + break; + } + }else { + switch (payType){ + case 1: + return WechatPayment(merchandise.getCash(),code); + case 2: + return AlipayPayment(merchandise.getCash(),code); + default: + break; + } + } + + return null; + } + + + private ResultUtil AlipayPayment(BigDecimal cash, String code) { + + return ResultUtil.success(); + } + + private ResultUtil WechatPayment(BigDecimal cash, String code) { + + return ResultUtil.success(); + } + + @Override + public ResultUtil exchangeAddPaymentCallback(String code, String orderNumber,Integer payType) { + List<UserPointsMerchandise> userPointsMerchandises = mcClient.queryUserPointMerchaseByCode(code); + if (userPointsMerchandises.size() > 1){ + for (int i = 0; i < userPointsMerchandises.size(); i++) { + userPointsMerchandises.get(i).setOrderNumber(orderNumber+ "-" + (i+1)); + mcClient.updateDetailsUserPointMercase(userPointsMerchandises.get(i)); + + Integer pointsMerchandiseId = userPointsMerchandises.get(i).getPointsMerchandiseId(); + PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerchandiseId); + switch (pointsMerchandise.getType()){ + case 2: + TCoursePackagePayment packagePayment = new TCoursePackagePayment(); + +// packagePayment.setAppUserId(); + + paymentClient.savePaymentCoursePackage(packagePayment); + break; + case 4: + UserCoupon coupon = new UserCoupon(); + coupon.setCouponId(userPointsMerchandises.get(0).getPointsMerchandiseId()); + coupon.setUserId(userPointsMerchandises.get(0).getUserId()); + coupon.setStatus(1); + coupon.setInsertTime(new Date()); + ucponClient.insertToAppuserCoupon(coupon); + break; + default: + break; + } + } + }else { + userPointsMerchandises.get(0).setOrderNumber(orderNumber); + mcClient.updateDetailsUserPointMercase(userPointsMerchandises.get(0)); + Integer pointsMerchandiseId = userPointsMerchandises.get(0).getPointsMerchandiseId(); + PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerchandiseId); + switch (pointsMerchandise.getType()){ + case 2: + TCoursePackagePayment packagePayment = new TCoursePackagePayment(); + +// packagePayment.setAppUserId(); + + paymentClient.savePaymentCoursePackage(packagePayment); + break; + case 4: + UserCoupon coupon = new UserCoupon(); + coupon.setCouponId(userPointsMerchandises.get(0).getPointsMerchandiseId()); + coupon.setUserId(userPointsMerchandises.get(0).getUserId()); + coupon.setStatus(1); + coupon.setInsertTime(new Date()); + ucponClient.insertToAppuserCoupon(coupon); + break; + default: + break; + } + + } + return ResultUtil.success(); + } + + @Override + public List<StoreResponse> queryStoresOfExchange(Integer goodsType,Integer pointsMerId) { + List<StoreResponse> responses = new ArrayList<>(); + if (goodsType == 4){ + List<Integer> couponStoreIds = ucponClient.getCouponStoreIds(pointsMerId); + for (Integer couponStoreId : couponStoreIds) { + StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(couponStoreId); + if(ToolUtil.isNotEmpty(courseOfStore)){ + StoreResponse response = new StoreResponse(); + response.setStoreId(couponStoreId); + response.setStoreName(courseOfStore.getStoreName()); + responses.add(response); + } + } + }else { + List<Integer> integers = mcsClient.queryPointMerStoreIds(pointsMerId); + for (Integer integer : integers) { + StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(integer); + if(ToolUtil.isNotEmpty(courseOfStore)){ + StoreResponse response = new StoreResponse(); + response.setStoreId(integer); + response.setStoreName(courseOfStore.getStoreName()); + responses.add(response); + } + } + } + return responses; + } + + } -- Gitblit v1.7.1