基于Java及Shell脚本技术的橘子影视平台设计源码

package com.joker.web.controller.orange; import cn.hutool.core.util.ObjectUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.joker.common.constant.CacheConstants; import com.joker.common.core.domain.entity.SysUser; import com.joker.common.utils.redis.RedisUtils; import com.joker.orange.domain.*; import com.joker.orange.mapper.*; import com.joker.system.mapper.SysUserMapper; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.List; /** * 扣单逻辑 */ @RequiredArgsConstructor @Service @Transactional public class AppDeductionOrderService { private final UserInfoMapper userInfoMapper; private final SysUserMapper sysUserMapper; private final UserOrderRecordMapper userOrderRecordMapper; private final MemberOrderMapper orderMapper; private final UserDeductionMapper deductionMapper; private final AgentUserStatisticsMapper agentUserStatisticsMapper; /** * 扣单逻辑 * * @param userId 用户ID * @param orderNo 订单编号 */ public void DeductionRegister(String userId, String orderNo) { MemberOrder order = orderMapper.selectOne( new LambdaUpdateWrapper<MemberOrder>().eq( MemberOrder::getOrderNo, orderNo )); UserInfo userInfo = userInfoMapper.selectById(userId); // 上级类型（0-用户、1-平台、2-代理） if ("2".equals(userInfo.getSuperiorType())) { // 查询出上级 SysUser sysUser = sysUserMapper.selectUserById(Long.valueOf(userInfo.getSpreadId())); if (ObjectUtil.isNotNull(sysUser)) { // 查询代理的订单数量 Integer orderCount = getOrderCount(sysUser.getUserId()) + 1; // 判断上级的代理等级 代理等级==1、2、3 if ("1".equals(sysUser.getAgentLevel())) { // 查询平台的扣单比例，判断平台是否扣单 UserDeduction deduction = deductionMapper.selectOne(new LambdaUpdateWrapper<UserDeduction>() .eq(UserDeduction::getDeductionType, "0")); // 订单数量满足平台扣单，此单扣除，更新代理订单数量表为空 if (ObjectUtil.equals(orderCount, deduction.getOrderCount())) { RedisUtils.setCacheObject(CacheConstants.USER_ORDER_KEY + sysUser.getUserId(), "0"); userOrderRecordMapper.update(null, new LambdaUpdateWrapper<UserOrderRecord>() .set(UserOrderRecord::getOrderCount, "0") .eq(UserOrderRecord::getUserId, sysUser.getUserId())); // todo 记录扣单 } else { // 不满足扣单，按照分成比例进行分配 BigDecimal commissionRatio = sysUser.getCommissionRatio(); BigDecimal divideMoney = commissionRatio.multiply(order.getOrderAmount()).setScale(2, RoundingMode.HALF_UP); sysUser.setBalance(sysUser.getBalance().add(divideMoney)); sysUserMapper.updateById(sysUser); // 更新订单数量 RedisUtils.setCacheObject(CacheConstants.USER_ORDER_KEY + sysUser.getUserId(), orderCount); userOrderRecordMapper.update(null, new LambdaUpdateWrapper<UserOrderRecord>() .set(UserOrderRecord::getOrderCount, orderCount) .eq(UserOrderRecord::getUserId, sysUser.getUserId())); // 记录代理统计 AgentUserStatistics(divideMoney, sysUser, userInfo.getAppType(), order.getOrderType()); } } else if ("2".equals(sysUser.getAgentLevel())) { // 代理等级是2级，查询2级代理的上级 SysUser firstUser = sysUserMapper.selectVoOne(new LambdaUpdateWrapper<SysUser>() .eq(SysUser::getSuperiorAgent, sysUser.getUserId())); // 2级代理的上级是平台 if ("0".equals(firstUser.getAgentLevel())) { // 查询平台的扣单比例，判断平台是否扣单 UserDeduction deduction = deductionMapper.selectOne(new LambdaUpdateWrapper<UserDeduction>() .eq(UserDeduction::getDeductionType, "0")); // 订单数量满足平台扣单，此单扣除，更新代理订单数量表为空 if (ObjectUtil.equals(orderCount, deduction.getOrderCount())) { RedisUtils.setCacheObject(CacheConstants.USER_ORDER_KEY + sysUser.getUserId(), "0"); userOrderRecordMapper.update(null, new LambdaUpdateWrapper<UserOrderRecord>() .set(UserOrderRecord::getOrderCount, "0") .eq(UserOrderRecord::getUserId, sysUser.getUserId())); // todo 记录扣单 } else { // 不满足扣单，按照分成比例进行分配 BigDecimal commissionRatio = sysUser.getCommissionRatio(); BigDecimal divideMoney = commissionRatio.multiply(order.getOrderAmount()).setScale(2, RoundingMode.HALF_UP); sysUser.setBalance(sysUser.getBalance().add(divideMoney)); sysUserMapper.updateById(sysUser); // 更新订单数量 RedisUtils.setCacheObject(CacheConstants.USER_ORDER_KEY + sysUser.getUserId(), orderCount); userOrderRecordMapper.update(null, new LambdaUpdateWrapper<UserOrderRecord>() .set(UserOrderRecord::getOrderCount, orderCount) .eq(UserOrderRecord::getUserId, sysUser.getUserId())); // 记录代理统计 AgentUserStatistics(divideMoney, sysUser, userInfo.getAppType(), order.getOrderType()); } // 2级代理的上级是1级代理 } else if ("1".equals(firstUser.getAgentLevel())) { // 查询平台的扣单比例，判断平台是否扣单 UserDeduction deduction = deductionMapper.selectOne(new LambdaUpdateWrapper<UserDeduction>() .eq(UserDeduction::getDeductionType, "0")); // 订单数量满足平台扣单，此单扣除，更新代理订单数量表为空 if (ObjectUtil.equals(orderCount, deduction.getOrderCount())) { RedisUtils.setCacheObject(CacheConstants.USER_ORDER_KEY + sysUser.getUserId(), orderCount); userOrderRecordMapper.update(null, new LambdaUpdateWrapper<UserOrderRecord>() .set(UserOrderRecord::getOrderCount, "0") .eq(UserOrderRecord::getUserId, sysUser.getUserId())); // todo 记录扣单 } else { // 平台不扣单，查询一级代理是否扣单 UserDeduction firstDeduction = deductionMapper.selectOne(new LambdaUpdateWrapper<UserDeduction>() .eq(UserDeduction::getDeductionType, "1") .eq(UserDeduction::getUserId, firstUser.getUserId())); // 一级代理