From 9d8a0576205ab71216780cbf75ada995d9721e14 Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Mon, 6 Jan 2025 15:47:23 +0800 Subject: [PATCH 1/8] =?UTF-8?q?=E6=94=B6=E8=97=8F=20=E7=82=B9=E8=B5=9E=20?= =?UTF-8?q?=E8=A7=82=E7=9C=8B=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../app/AppCourseCollectController.java | 10 +- .../modules/course/entity/CourseCollect.java | 3 + .../impl/CourseCollectServiceImpl.java | 92 +++++++++++-------- 3 files changed, 64 insertions(+), 41 deletions(-) diff --git a/src/main/java/com/sqx/modules/course/controller/app/AppCourseCollectController.java b/src/main/java/com/sqx/modules/course/controller/app/AppCourseCollectController.java index a4401c1a..32bc329b 100644 --- a/src/main/java/com/sqx/modules/course/controller/app/AppCourseCollectController.java +++ b/src/main/java/com/sqx/modules/course/controller/app/AppCourseCollectController.java @@ -1,5 +1,6 @@ package com.sqx.modules.course.controller.app; +import com.sqx.common.annotation.Debounce; import com.sqx.common.utils.Result; import com.sqx.modules.app.annotation.Login; import com.sqx.modules.course.entity.CourseCollect; @@ -21,7 +22,8 @@ public class AppCourseCollectController extends AbstractController { @Login @PostMapping("/insertCourseCollect") @ApiOperation("app收藏短剧信息") - public Result insertCourseCollect(@RequestBody CourseCollect courseCollect,@RequestAttribute("userId") Long userId){ + @Debounce(interval = 3000, value = "#userId,#courseCollect.courseId,#courseCollect.classify,#courseCollect.type") + public Result insertCourseCollect(@RequestBody CourseCollect courseCollect, @RequestAttribute("userId") Long userId) { courseCollect.setUserId(userId); return courseCollectService.insertCourseCollect(courseCollect); } @@ -29,13 +31,13 @@ public class AppCourseCollectController extends AbstractController { @Login @GetMapping("/selectByUserId") @ApiOperation("app查询收藏短剧信息") - public Result selectByUserId(Integer page, Integer limit,@RequestAttribute("userId") Long userId,Integer classify){ - return courseCollectService.selectByUserId(page,limit,userId,classify); + public Result selectByUserId(Integer page, Integer limit, @RequestAttribute("userId") Long userId, Integer classify) { + return courseCollectService.selectByUserId(page, limit, userId, classify); } @Login @GetMapping("/collectVideoSummary") - public Result collectVideoSummary(@RequestAttribute("userId") Long userId){ + public Result collectVideoSummary(@RequestAttribute("userId") Long userId) { return courseCollectService.collectVideoSummary(userId); } diff --git a/src/main/java/com/sqx/modules/course/entity/CourseCollect.java b/src/main/java/com/sqx/modules/course/entity/CourseCollect.java index e4837766..81de92f4 100644 --- a/src/main/java/com/sqx/modules/course/entity/CourseCollect.java +++ b/src/main/java/com/sqx/modules/course/entity/CourseCollect.java @@ -61,6 +61,9 @@ public class CourseCollect implements Serializable { * 更新时间 */ private String updateTime; + /** + * 1 写入 2 删除 + */ @TableField(exist = false) private Integer type; diff --git a/src/main/java/com/sqx/modules/course/service/impl/CourseCollectServiceImpl.java b/src/main/java/com/sqx/modules/course/service/impl/CourseCollectServiceImpl.java index 574927b4..8ca6f91c 100644 --- a/src/main/java/com/sqx/modules/course/service/impl/CourseCollectServiceImpl.java +++ b/src/main/java/com/sqx/modules/course/service/impl/CourseCollectServiceImpl.java @@ -1,8 +1,10 @@ package com.sqx.modules.course.service.impl; import cn.hutool.core.collection.CollectionUtil; +import cn.hutool.core.date.DateUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; @@ -21,6 +23,7 @@ import com.sqx.modules.course.service.CourseDetailsService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CachePut; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import java.text.SimpleDateFormat; @@ -48,23 +51,20 @@ public class CourseCollectServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("user_id", courseCollect.getUserId()).eq("classify", 3).eq("course_id", courseCollect.getCourseId()); - queryWrapper.orderByDesc("create_time"); - PageHelper.startPage(1, 1); - List courseCollects = baseMapper.selectList(queryWrapper); - CourseCollect collect; - if (CollectionUtil.isNotEmpty(courseCollects)) { - collect = courseCollects.get(0); - if (collect != null) { - collect.setUpdateTime(DateUtils.format(new Date())); - collect.setCourseCollectId(courseCollect.getCourseCollectId()); - baseMapper.updateById(collect); - return Result.success("操作成功！"); - } + queryWrapper.eq("user_id", courseCollect.getUserId()) + .eq("classify", 3) + .eq("course_id", courseCollect.getCourseId()); + queryWrapper.orderByDesc("create_time").last("limit 1"); + CourseCollect collect = baseMapper.selectOne(queryWrapper); + if (collect != null) { + collect.setUpdateTime(DateUtils.format(new Date())); + collect.setCourseDetailsId(courseCollect.getCourseDetailsId()); + baseMapper.updateById(collect); + return Result.success("操作成功！"); } collect = new CourseCollect() .setUserId(courseCollect.getUserId()) @@ -76,43 +76,58 @@ public class CourseCollectServiceImpl extends ServiceImpl queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(CourseCollect::getCourseCollectId, courseCollect1.getCourseCollectId()); + queryWrapper.eq(CourseCollect::getCourseId, courseCollect1.getCourseId()); + baseMapper.delete(queryWrapper); } } + upGoodNum(courseCollect, courseCollect.getType()); return Result.success("操作成功！"); } catch (Exception e) { - e.printStackTrace(); +// e.printStackTrace(); log.error("收藏短剧出错了！" + e.getMessage()); - } finally { - reentrantReadWriteLock.writeLock().unlock(); } +// finally { +// reentrantReadWriteLock.writeLock().unlock(); +// } return Result.error("系统繁忙,请稍后再试！"); } + /** + * 更新点赞数量 + * + * @param collect courseId 和 courseDetailsId 必须有值 + * @param isGood 1为加一 其它为 减一 + */ + @Async + public void upGoodNum(CourseCollect collect, Integer isGood) { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper() + .eq(CourseDetails::getCourseId, collect.getCourseId()) + .eq(CourseDetails::getCourseDetailsId, collect.getCourseDetailsId()); + CourseDetails courseDetails = courseDetailsService.getOne(queryWrapper); + + LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper() + .eq(CourseDetails::getCourseId, collect.getCourseId()) + .eq(CourseDetails::getCourseDetailsId, collect.getCourseDetailsId()) + .set(CourseDetails::getGoodNum, courseDetails.getGoodNum() == null ? 0 : courseDetails.getGoodNum() - (isGood.equals(1) ? 1 : -1)); + courseDetailsService.update(updateWrapper); + } + @Override @CachePut(value = "app:courseCollect", key = "#userId") public Result selectByUserId(Integer page, Integer limit, Long userId, Integer classify) { @@ -131,11 +146,10 @@ public class CourseCollectServiceImpl extends ServiceImpl courseList = courseIdList.isEmpty() ? new ArrayList<>() : courseDao.selectList(new LambdaQueryWrapper().in(Course::getCourseId, courseIdList)); -// List courseList = baseMapper.selectCourseByCollect(userId, classify); Set detailIdList = courseCollectList.stream().map(CourseCollect::getCourseDetailsId).collect(Collectors.toSet()); Map courseDetailsMap = detailIdList.isEmpty() ? new HashMap<>() : courseDetailsService.list(new LambdaQueryWrapper() .in(CourseDetails::getCourseDetailsId, detailIdList)).stream() - .collect(Collectors.toMap(CourseDetails::getCourseDetailsId, item->item)); + .collect(Collectors.toMap(CourseDetails::getCourseDetailsId, item -> item)); Map countMap = courseDetailsDao.countByCourseId().stream().collect(Collectors.toMap(CourseDetails::getCourseId, CourseDetails::getCourseDetailsCount)); @@ -146,7 +160,7 @@ public class CourseCollectServiceImpl extends ServiceImpl().eq(courseDetailsId != null, "course_details_id", courseDetailsId).eq("user_id", userId).eq("classify", classify).eq("course_id", courseId)); + return baseMapper.selectOne(new QueryWrapper() + .eq(courseDetailsId != null, "course_details_id", courseDetailsId) + .eq("user_id", userId) + .eq("classify", classify) + .eq("course_id", courseId)); } From 0af9d06de6328c3e6a8949fd23a9d847e1d2aee8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Mon, 6 Jan 2025 16:00:35 +0800 Subject: [PATCH 2/8] =?UTF-8?q?1.=E5=9B=9E=E8=B0=83=E4=BA=8B=E5=8A=A1?= =?UTF-8?q?=E8=AE=B0=E5=BD=95=E9=82=80=E8=AF=B7=E9=87=91=E9=A2=9D=E5=AF=BC?= =?UTF-8?q?=E8=87=B4=E7=9C=9F=E5=AE=9E=E5=A5=96=E5=8A=B1=E8=A2=AB=E8=A6=86?= =?UTF-8?q?=E7=9B=96=E9=97=AE=E9=A2=98=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/sqx/modules/job/task/TempOrdersTask.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java index a39781e4..dcbeb31b 100644 --- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java +++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java @@ -6,6 +6,7 @@ import cn.hutool.core.thread.ThreadUtil; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.sqx.common.utils.DateUtils; @@ -297,9 +298,11 @@ public class TempOrdersTask { UserMoney userMoney = userMoneyService.selectUserMoneyByUserId(sourceUser.getUserId()); userMoney.setInviteIncomeCoin(userMoney.getInviteIncomeCoin() == null ? incomeCoin : userMoney.getInviteIncomeCoin().add(incomeCoin)); userMoney.setInviteIncomeMoney(userMoney.getInviteIncomeMoney() == null ? incomeMoney : userMoney.getInviteIncomeMoney().add(incomeMoney)); - userMoneyService.update(userMoney, new LambdaQueryWrapper() + userMoneyService.update(null, new LambdaUpdateWrapper() .eq(UserMoney::getUserId, userMoney.getUserId()) - .eq(UserMoney::getId, userMoney.getId())); + .eq(UserMoney::getId, userMoney.getId()) + .eq(UserMoney::getInviteIncomeCoin, userMoney.getInviteIncomeCoin()) + .set(UserMoney::getInviteIncomeMoney, userMoney.getInviteIncomeMoney())); } } From 156784f20bd43c5e862509e5af8eaace1ca402be Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Mon, 6 Jan 2025 16:00:46 +0800 Subject: [PATCH 3/8] =?UTF-8?q?1.=E5=9B=9E=E8=B0=83=E4=BA=8B=E5=8A=A1?= =?UTF-8?q?=E8=AE=B0=E5=BD=95=E9=82=80=E8=AF=B7=E9=87=91=E9=A2=9D=E5=AF=BC?= =?UTF-8?q?=E8=87=B4=E7=9C=9F=E5=AE=9E=E5=A5=96=E5=8A=B1=E8=A2=AB=E8=A6=86?= =?UTF-8?q?=E7=9B=96=E9=97=AE=E9=A2=98=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/sqx/modules/job/task/TempOrdersTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java index dcbeb31b..4f521bb0 100644 --- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java +++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java @@ -301,7 +301,7 @@ public class TempOrdersTask { userMoneyService.update(null, new LambdaUpdateWrapper() .eq(UserMoney::getUserId, userMoney.getUserId()) .eq(UserMoney::getId, userMoney.getId()) - .eq(UserMoney::getInviteIncomeCoin, userMoney.getInviteIncomeCoin()) + .set(UserMoney::getInviteIncomeCoin, userMoney.getInviteIncomeCoin()) .set(UserMoney::getInviteIncomeMoney, userMoney.getInviteIncomeMoney())); } From a16e632e98602ae14b3d31fa0ed28f5104bac29a Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Mon, 6 Jan 2025 16:24:46 +0800 Subject: [PATCH 4/8] =?UTF-8?q?=E8=A7=82=E5=BD=B1=E8=AE=B0=E5=BD=95=20?= =?UTF-8?q?=E5=BC=80=E5=A7=8B=E7=BB=93=E6=9D=9F=20=E5=85=A8=E9=9B=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/course/dao/CourseDetailsDao.java | 9 ++ .../service/impl/CourseServiceImpl.java | 15 ++-- .../mapper/course/CourseDetailsDao.xml | 86 +++++++++++-------- 3 files changed, 68 insertions(+), 42 deletions(-) diff --git a/src/main/java/com/sqx/modules/course/dao/CourseDetailsDao.java b/src/main/java/com/sqx/modules/course/dao/CourseDetailsDao.java index ff89c12b..b9c5a2e2 100644 --- a/src/main/java/com/sqx/modules/course/dao/CourseDetailsDao.java +++ b/src/main/java/com/sqx/modules/course/dao/CourseDetailsDao.java @@ -31,6 +31,15 @@ public interface CourseDetailsDao extends BaseMapper { List findByCourseIdNotUrl(@Param("id") Long id, @Param("userId") Long userId); + /** + * 更新播放数量 + * + * @param courseId courseId 必须有值 + * @param courseDetailsId courseDetailsId 必须有值 + * @param state 1为 ViewCount 其它 为 PlayCompleteCount + */ + void updateViewCount(@Param("courseId") Long courseId,@Param("courseDetailsId") Long courseDetailsId, @Param("state") int state); + int deleteCourseDetails(String[] ids); diff --git a/src/main/java/com/sqx/modules/course/service/impl/CourseServiceImpl.java b/src/main/java/com/sqx/modules/course/service/impl/CourseServiceImpl.java index 01efa8b7..cea19ce5 100644 --- a/src/main/java/com/sqx/modules/course/service/impl/CourseServiceImpl.java +++ b/src/main/java/com/sqx/modules/course/service/impl/CourseServiceImpl.java @@ -32,6 +32,7 @@ import com.sqx.modules.course.dao.CourseDao; import com.sqx.modules.course.dao.CourseDetailsDao; import com.sqx.modules.course.dao.CourseUserDao; import com.sqx.modules.course.entity.Course; +import com.sqx.modules.course.entity.CourseCollect; import com.sqx.modules.course.entity.CourseDetails; import com.sqx.modules.course.entity.CourseUser; import com.sqx.modules.course.service.CourseService; @@ -1287,21 +1288,21 @@ public class CourseServiceImpl extends ServiceImpl implements if (course == null) { return Result.error("短剧不存在"); } - - CourseDetails details = courseDetailsDao.selectById(courseDetailsId); + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(CourseDetails::getCourseId, courseId); + queryWrapper.eq(CourseDetails::getCourseDetailsId, courseDetailsId); + queryWrapper.orderByDesc(CourseDetails::getCreateTime).last("limit 1"); + CourseDetails details = courseDetailsDao.selectOne(queryWrapper); if (details == null) { return Result.error("短剧集不存在"); } if ("start".equals(type)) { //开始播放 - details.setViewCount(details.getViewCount() + 1); - courseDetailsDao.updateById(details); - baseMapper.updateById(course); + courseDetailsDao.updateViewCount(details.getCourseId(),details.getCourseDetailsId(), 1); } else if ("end".equals(type)) { //播放完成 - details.setPlayCompleteCount(details.getPlayCompleteCount() + 1); - courseDetailsDao.updateById(details); + courseDetailsDao.updateViewCount(details.getCourseId(),details.getCourseDetailsId(), 2); } return Result.success(); diff --git a/src/main/resources/mapper/course/CourseDetailsDao.xml b/src/main/resources/mapper/course/CourseDetailsDao.xml index f49e8d58..229a948b 100644 --- a/src/main/resources/mapper/course/CourseDetailsDao.xml +++ b/src/main/resources/mapper/course/CourseDetailsDao.xml @@ -22,12 +22,16 @@ - + + update course_details + set + + view_count = view_count + 1 + + + play_complete_count = play_complete_count + 1 + + where + course_id=#{courseId} + and course_details_id =#{courseDetailsId} + DELETE FROM course_details WHERE course_details_id IN @@ -71,31 +92,26 @@ From 859a62330bcd1065e48e10e1bdfc70800e92c06e Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Mon, 6 Jan 2025 16:26:53 +0800 Subject: [PATCH 5/8] =?UTF-8?q?=E7=A7=BB=E9=99=A4=20=E4=BB=A3=E7=90=86=20?= =?UTF-8?q?=E5=85=B3=E4=BA=8E=E9=92=B1=E7=9A=84=E6=93=8D=E4=BD=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../resources/mapper/app/UserMoneyDao.xml | 22 ------------------- 1 file changed, 22 deletions(-) diff --git a/src/main/resources/mapper/app/UserMoneyDao.xml b/src/main/resources/mapper/app/UserMoneyDao.xml index c0a797fa..f378f0c0 100644 --- a/src/main/resources/mapper/app/UserMoneyDao.xml +++ b/src/main/resources/mapper/app/UserMoneyDao.xml @@ -25,27 +25,5 @@ where user_id=#{userId} - - update user_money set - - money=money+#{money} - - - money=money-#{money} - - where sys_user_id=#{sysUserId} - - - - update user_money set - - amount=amount+#{amount} - - - amount=amount-#{amount} - - where sys_user_id=#{sysUserId} - - From 1fdda30ed0361f98059dbcdd6fbd63699e43fac3 Mon Sep 17 00:00:00 2001 From: GYJ <1157756119@qq.com> Date: Mon, 6 Jan 2025 16:29:38 +0800 Subject: [PATCH 6/8] bug fix --- .../com/sqx/modules/invite/service/impl/InviteServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java b/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java index 9c0251cc..7d51a06d 100644 --- a/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java +++ b/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java @@ -225,7 +225,7 @@ public class InviteServiceImpl extends ServiceImpl implements UserMoney userMoney = userMoneyService.selectUserMoneyByUserId(userEntity.getUserId()); userMoney.setMoney(userMoney.getMoney() == null ? BigDecimal.valueOf(money) : userMoney.getMoney().add(BigDecimal.valueOf(money))); userMoney.setInviteIncomeCoin(userMoney.getInviteIncomeCoin() == null ? new BigDecimal(money) : userMoney.getInviteIncomeCoin().add(new BigDecimal(money))); - userMoneyService.update(null, new LambdaQueryWrapper().eq(UserMoney::getUserId, userMoney.getUserId()).eq(UserMoney::getId, userMoney.getId())); + userMoneyService.update(userMoney, new LambdaQueryWrapper().eq(UserMoney::getUserId, userMoney.getUserId()).eq(UserMoney::getId, userMoney.getId())); } //助力活动 From d000da2210051d145e1da6c353e4b311c2dcbb76 Mon Sep 17 00:00:00 2001 From: wangw <1594593906@qq.com> Date: Mon, 6 Jan 2025 16:30:45 +0800 Subject: [PATCH 7/8] =?UTF-8?q?=E9=98=B2=E6=8A=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../course/controller/app/AppCourseCollectController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/sqx/modules/course/controller/app/AppCourseCollectController.java b/src/main/java/com/sqx/modules/course/controller/app/AppCourseCollectController.java index 32bc329b..81c132e2 100644 --- a/src/main/java/com/sqx/modules/course/controller/app/AppCourseCollectController.java +++ b/src/main/java/com/sqx/modules/course/controller/app/AppCourseCollectController.java @@ -22,7 +22,7 @@ public class AppCourseCollectController extends AbstractController { @Login @PostMapping("/insertCourseCollect") @ApiOperation("app收藏短剧信息") - @Debounce(interval = 3000, value = "#userId,#courseCollect.courseId,#courseCollect.classify,#courseCollect.type") + @Debounce(interval = 1000, value = "#userId,#courseCollect.courseId,#courseCollect.classify,#courseCollect.type") public Result insertCourseCollect(@RequestBody CourseCollect courseCollect, @RequestAttribute("userId") Long userId) { courseCollect.setUserId(userId); return courseCollectService.insertCourseCollect(courseCollect); From d4b2a355910c3943f52c17a7e8326ced24dc015d Mon Sep 17 00:00:00 2001 From: GYJ <1157756119@qq.com> Date: Mon, 6 Jan 2025 16:37:50 +0800 Subject: [PATCH 8/8] bug fix2 --- .../com/sqx/modules/pay/controller/app/WuyouController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java b/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java index 5c0b0c41..227d4996 100644 --- a/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java +++ b/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java @@ -113,7 +113,7 @@ public class WuyouController { payDetailsDao.insert(payDetails); } else { payDetails.setTradeNo(AliPayOrderUtil.createOrderId()); - payDetailsDao.updateById(payDetails); + payDetailsDao.update(payDetails, new LambdaQueryWrapper().eq(PayDetails::getId, payDetails.getId()).eq(PayDetails::getUserId, payDetails.getUserId())); } if (order.getPayMoney().compareTo(BigDecimal.ZERO) == 0) {