czg_team/video_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

生成订单 已存在的情况

Browse Source
This commit is contained in:
wangw
2024-12-23 16:30:21 +08:00
parent f11ae848b0
commit e738d98948
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/com/sqx/modules/orders/service/impl/OrdersServiceImpl.java
View File

@@ -37,6 +37,7 @@ import com.sqx.modules.orders.service.OrdersService;
import com.sqx.modules.pay.controller.app.AliPayController; import com.sqx.modules.pay.controller.app.AliPayController;
import com.sqx.modules.pay.service.DyService; import com.sqx.modules.pay.service.DyService;
import com.sqx.modules.pay.service.WxService; import com.sqx.modules.pay.service.WxService;
import com.sqx.modules.sdk.entity.SdkInfo;
import com.sqx.modules.utils.AliPayOrderUtil; import com.sqx.modules.utils.AliPayOrderUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
@@ -248,10 +249,20 @@ public class OrdersServiceImpl extends ServiceImpl<OrdersDao, Orders> implements
log.info("生成商品订单信息接口入参为：{},{}", courseId, userId); log.info("生成商品订单信息接口入参为：{},{}", courseId, userId);
reentrantReadWriteLock.writeLock().lock(); reentrantReadWriteLock.writeLock().lock();
try { try {
/*CourseUser courseUser1 = courseUserDao.selectCourseUser(courseId, userId); CourseUser courseUser1 = courseUserDao.selectCourseUser(courseId, userId);
if(courseUser1!=null){ if (courseUser1 != null) {
return Result.error("您已经购买过了，请不要重复点击！"); return Result.success().put("status", 1);
}*/ }
QueryWrapper<CourseUser> courseUserQueryWrapper = new QueryWrapper<>();
courseUserQueryWrapper.eq("user_id", userId);
courseUserQueryWrapper.eq("course_id", courseId);
courseUserQueryWrapper.eq("course_details_id", courseDetailsId);
courseUserQueryWrapper.eq("classify", 2);
//加入我的列表
int count1 = courseUserService.count(courseUserQueryWrapper);
if (count1 > 0) {
return Result.success().put("status", 1);
}
//返回的类型 //返回的类型
Map<String, Object> result = new HashMap<>(); Map<String, Object> result = new HashMap<>();
//查询会员信息 //查询会员信息
@@ -314,7 +325,6 @@ public class OrdersServiceImpl extends ServiceImpl<OrdersDao, Orders> implements
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace();
log.error("生成商品订单错误！！！" + e.getMessage()); log.error("生成商品订单错误！！！" + e.getMessage());
} finally { } finally {
reentrantReadWriteLock.writeLock().unlock(); reentrantReadWriteLock.writeLock().unlock();