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

日志修改

Browse Source
This commit is contained in:
GYJ
2024-12-04 17:28:19 +08:00
parent 149eec4363
commit e8a2e9bee1
5 changed files with 139 additions and 124 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
src/main/java/com/sqx/common/exception/SqxExceptionHandler.java
View File

@@ -7,49 +7,59 @@ import org.slf4j.LoggerFactory;
import org.springframework.dao.DuplicateKeyException; import org.springframework.dao.DuplicateKeyException;
import org.springframework.web.bind.annotation.ExceptionHandler; import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice; import org.springframework.web.bind.annotation.RestControllerAdvice;
import org.springframework.web.context.request.WebRequest;
import org.springframework.web.servlet.NoHandlerFoundException; import org.springframework.web.servlet.NoHandlerFoundException;
/** /**
* 异常处理器 * 异常处理器
* *
* @author GYJ
*/ */
@RestControllerAdvice @RestControllerAdvice
public class SqxExceptionHandler { public class SqxExceptionHandler {
private Logger logger = LoggerFactory.getLogger(getClass()); private final Logger logger = LoggerFactory.getLogger(getClass());
/** /**
* 处理自定义异常 * 处理自定义异常
*/ */
@ExceptionHandler(SqxException.class) @ExceptionHandler(SqxException.class)
public Result handleException(SqxException e){ public Result handleException(SqxException e) {
Result r = new Result(); Result r = new Result();
r.put("code", e.getCode()); r.put("code", e.getCode());
r.put("msg", e.getMessage()); r.put("msg", e.getMessage());
return r; return r;
} }
@ExceptionHandler(NoHandlerFoundException.class) @ExceptionHandler(NoHandlerFoundException.class)
public Result handlerNoFoundException(Exception e) { public Result handlerNoFoundException(Exception e, WebRequest webRequest) {
logger.error(e.getMessage(), e); String requestUrl = webRequest.getDescription(false).split(" ")[1];
return Result.error(404, "路径不存在，请检查路径是否正确"); logger.error("请求路径不存在：{}", requestUrl);
} logger.error(e.getMessage(), e);
return Result.error(404, "路径不存在，请检查路径是否正确");
}
@ExceptionHandler(DuplicateKeyException.class) @ExceptionHandler(DuplicateKeyException.class)
public Result handleDuplicateKeyException(DuplicateKeyException e){ public Result handleDuplicateKeyException(DuplicateKeyException e, WebRequest webRequest) {
logger.error(e.getMessage(), e); String requestUrl = webRequest.getDescription(false).split(" ")[1];
return Result.error("数据库中已存在该记录"); logger.error("请求路径：{}，数据库中已存在该记录", requestUrl);
} logger.error(e.getMessage(), e);
return Result.error("数据库中已存在该记录");
}
@ExceptionHandler(AuthorizationException.class) @ExceptionHandler(AuthorizationException.class)
public Result handleAuthorizationException(AuthorizationException e){ public Result handleAuthorizationException(AuthorizationException e, WebRequest webRequest) {
logger.error(e.getMessage(), e); String requestUrl = webRequest.getDescription(false).split(" ")[1];
return Result.error("没有权限，请联系管理员授权"); logger.error("请求路径：{}，没有权限", requestUrl);
} logger.error(e.getMessage(), e);
return Result.error("没有权限，请联系管理员授权");
}
@ExceptionHandler(Exception.class) @ExceptionHandler(Exception.class)
public Result handleException(Exception e){ public Result handleException(Exception e, WebRequest webRequest) {
logger.error(e.getMessage(), e); String requestUrl = webRequest.getDescription(false).split(" ")[1];
return Result.error(); logger.error("请求路径：{}，发生异常", requestUrl);
} logger.error(e.getMessage(), e);
return Result.error();
}
} }

2
src/main/java/com/sqx/modules/app/service/impl/UserServiceImpl.java
View File

@@ -875,7 +875,7 @@ public class UserServiceImpl extends ServiceImpl<UserDao, UserEntity> implements
return getResult(userInfo); return getResult(userInfo);
} else { } else {
if(StringUtils.isEmpty(msg)){ if(StringUtils.isEmpty(msg)){
return Result.error("手机号未注册！"); return Result.error("验证码不能为空！");
} }
Msg msg1 = msgDao.findByPhoneAndCode(phone, msg); Msg msg1 = msgDao.findByPhoneAndCode(phone, msg);
if(msg1==null){ if(msg1==null){

183
src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java
View File

@@ -61,19 +61,19 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
private SysUserService sysUserService; private SysUserService sysUserService;
@Override @Override
public PageUtils selectInviteList(int page,int limit,Integer state,Long userId){ public PageUtils selectInviteList(int page, int limit, Integer state, Long userId) {
Page<Map<String,Object>> pages=new Page<>(page,limit); Page<Map<String, Object>> pages = new Page<>(page, limit);
if(state==null || state==-1){ if (state == null || state == -1) {
state=null; state = null;
} }
return new PageUtils(inviteDao.selectInviteList(pages,state,userId)); return new PageUtils(inviteDao.selectInviteList(pages, state, userId));
} }
@Override @Override
public PageUtils selectInviteUser(int page, int limit, Long userId, Integer state,Integer userType) { public PageUtils selectInviteUser(int page, int limit, Long userId, Integer state, Integer userType) {
Page<Map<String, Object>> pages = new Page<>(page, limit); Page<Map<String, Object>> pages = new Page<>(page, limit);
return new PageUtils(inviteDao.selectInviteUser(pages, userId, state,userType)); return new PageUtils(inviteDao.selectInviteUser(pages, userId, state, userType));
} }
@Override @Override
@@ -83,47 +83,47 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
@Override @Override
public Integer selectInviteByUserIdCount(Long userId, Date startTime, Date endTime) { public Integer selectInviteByUserIdCount(Long userId, Date startTime, Date endTime) {
return inviteDao.selectInviteByUserIdCount(userId,startTime,endTime); return inviteDao.selectInviteByUserIdCount(userId, startTime, endTime);
} }
@Override @Override
public Double selectInviteByUserIdSum(Long userId, Date startTime, Date endTime) { public Double selectInviteByUserIdSum(Long userId, Date startTime, Date endTime) {
return inviteDao.selectInviteByUserIdSum(userId,startTime,endTime); return inviteDao.selectInviteByUserIdSum(userId, startTime, endTime);
} }
@Override @Override
public Double sumInviteMoney(String time, Integer flag) { public Double sumInviteMoney(String time, Integer flag) {
return inviteDao.sumInviteMoney(time,flag); return inviteDao.sumInviteMoney(time, flag);
} }
@Override @Override
public PageUtils inviteAnalysis(int page,int limit, String time, Integer flag) { public PageUtils inviteAnalysis(int page, int limit, String time, Integer flag) {
Page<Map<String,Object>> pages=new Page<>(page,limit); Page<Map<String, Object>> pages = new Page<>(page, limit);
return new PageUtils(inviteDao.inviteAnalysis(pages,time,flag)); return new PageUtils(inviteDao.inviteAnalysis(pages, time, flag));
} }
@Override @Override
public Integer selectInviteCount(Integer state,Long userId){ public Integer selectInviteCount(Integer state, Long userId) {
if(state==null || state==-1){ if (state == null || state == -1) {
state=null; state = null;
} }
return inviteDao.selectInviteCount(state,userId); return inviteDao.selectInviteCount(state, userId);
} }
@Override @Override
public Double selectInviteSum(Integer state, Long userId) { public Double selectInviteSum(Integer state, Long userId) {
if(state==null || state==-1){ if (state == null || state == -1) {
state=null; state = null;
} }
return inviteDao.selectInviteSum(state,userId); return inviteDao.selectInviteSum(state, userId);
} }
@Override @Override
public int saveBody(Long userId, UserEntity userEntity){ public int saveBody(Long userId, UserEntity userEntity) {
SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String format = sdf.format(new Date()); String format = sdf.format(new Date());
Invite invite=new Invite(); Invite invite = new Invite();
invite.setState(0); invite.setState(0);
invite.setMoney(0.00); invite.setMoney(0.00);
invite.setUserId(userEntity.getUserId()); invite.setUserId(userEntity.getUserId());
@@ -133,8 +133,8 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
inviteDao.insert(invite); inviteDao.insert(invite);
//同步二级 //同步二级
UserEntity two = userService.queryByInvitationCode(userEntity.getInviterCode()); UserEntity two = userService.queryByInvitationCode(userEntity.getInviterCode());
if(two!=null){ if (two != null) {
invite=new Invite(); invite = new Invite();
invite.setState(0); invite.setState(0);
invite.setMoney(0.00); invite.setMoney(0.00);
invite.setUserId(two.getUserId()); invite.setUserId(two.getUserId());
@@ -143,44 +143,47 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
invite.setUserType(2); invite.setUserType(2);
inviteDao.insert(invite); inviteDao.insert(invite);
} }
UserEntity user=new UserEntity(); UserEntity user = new UserEntity();
user.setUserId(userId); user.setUserId(userId);
user.setInviterCode(userEntity.getInvitationCode()); user.setInviterCode(userEntity.getInvitationCode());
userService.updateById(user); userService.updateById(user);
String value = commonInfoService.findOne(813).getValue(); String value = commonInfoService.findOne(813).getValue();
if("是".equals(value)){ if (!"是".equals(value)) {
//获取邀请人的邀请数量 return 0;
int inviterCount = userService.queryInviterCount(userEntity.getInvitationCode()); }
InviteAward inviteAward = inviteAwardService.getOne(new QueryWrapper<InviteAward>().eq("invite_count", inviterCount)); //获取邀请人的邀请数量
if(inviteAward!=null){ int inviterCount = userService.queryInviterCount(userEntity.getInvitationCode());
if(inviteAward.getInviteMonth()==0){ InviteAward inviteAward = inviteAwardService.getOne(new QueryWrapper<InviteAward>().eq("invite_count", inviterCount));
userVipService.update(null, Wrappers.<UserVip>lambdaUpdate() if (inviteAward == null) {
.set(UserVip::getIsVip,2) return 0;
.set(UserVip::getEndTime,null) }
.set(UserVip::getVipType,1) if (inviteAward.getInviteMonth() == 0) {
.eq(UserVip::getUserId,userEntity.getUserId())); userVipService.update(null, Wrappers.<UserVip>lambdaUpdate()
}else{ .set(UserVip::getIsVip, 2)
UserVip userVip = userVipService.selectUserVipByUserId(userEntity.getUserId()); .set(UserVip::getEndTime, null)
Calendar calendar=Calendar.getInstance(); .set(UserVip::getVipType, 1)
if(userVip!=null && userVip.getIsVip()==2){ .eq(UserVip::getUserId, userEntity.getUserId()));
Date date = DateUtils.stringToDate(userVip.getEndTime(), DateUtils.DATE_TIME_PATTERN);
calendar.setTime(date); return 1;
}else{ }
userVip=new UserVip(); UserVip userVip = userVipService.selectUserVipByUserId(userEntity.getUserId());
userVip.setUserId(userEntity.getUserId()); Calendar calendar = Calendar.getInstance();
userVip.setCreateTime(DateUtils.format(new Date())); if (userVip != null && userVip.getIsVip() == 2) {
} Date date = DateUtils.stringToDate(userVip.getEndTime(), DateUtils.DATE_TIME_PATTERN);
userVip.setIsVip(2); calendar.setTime(date);
userVip.setVipType(1); } else {
calendar.add(Calendar.MONTH,inviteAward.getInviteMonth()); userVip = new UserVip();
userVip.setEndTime(DateUtils.format(calendar.getTime())); userVip.setUserId(userEntity.getUserId());
if(userVip.getVipId()!=null){ userVip.setCreateTime(DateUtils.format(new Date()));
userVipService.updateById(userVip); }
}else{ userVip.setIsVip(2);
userVipService.save(userVip); userVip.setVipType(1);
} calendar.add(Calendar.MONTH, inviteAward.getInviteMonth());
} userVip.setEndTime(DateUtils.format(calendar.getTime()));
} if (userVip.getVipId() != null) {
userVipService.updateById(userVip);
} else {
userVipService.save(userVip);
} }
return 1; return 1;
@@ -188,10 +191,10 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
@Override @Override
public Map<String,Object> updateInvite(UserEntity userEntity, String format, Long userId, BigDecimal price) { public Map<String, Object> updateInvite(UserEntity userEntity, String format, Long userId, BigDecimal price) {
Map<String,Object> result=new HashMap<>(); Map<String, Object> result = new HashMap<>();
if (userEntity != null && userId != null && price != null) { if (userEntity != null && userId != null && price != null) {
Invite invite1 = inviteDao.selectInviteByUser(userEntity.getUserId(), userId,1); Invite invite1 = inviteDao.selectInviteByUser(userEntity.getUserId(), userId, 1);
if (invite1 == null) { if (invite1 == null) {
Invite invite = new Invite(); Invite invite = new Invite();
invite.setState(0); invite.setState(0);
@@ -201,14 +204,14 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
invite.setCreateTime(format); invite.setCreateTime(format);
invite.setUserType(1); invite.setUserType(1);
inviteDao.insert(invite); inviteDao.insert(invite);
invite1 = inviteDao.selectInviteByUser(userEntity.getUserId(), userId,1); invite1 = inviteDao.selectInviteByUser(userEntity.getUserId(), userId, 1);
} }
UserEntity userEntity1 = userService.selectUserById(userId); UserEntity userEntity1 = userService.selectUserById(userId);
BigDecimal oneMoney=BigDecimal.ZERO; BigDecimal oneMoney = BigDecimal.ZERO;
BigDecimal twoMoney=BigDecimal.ZERO; BigDecimal twoMoney = BigDecimal.ZERO;
if (userEntity.getRate() != null && userEntity.getRate().doubleValue() > 0) { if (userEntity.getRate() != null && userEntity.getRate().doubleValue() > 0) {
BigDecimal rateMoney = price.multiply(userEntity.getRate()).setScale(2, BigDecimal.ROUND_HALF_UP); BigDecimal rateMoney = price.multiply(userEntity.getRate()).setScale(2, BigDecimal.ROUND_HALF_UP);
oneMoney=rateMoney; oneMoney = rateMoney;
Double money = rateMoney.doubleValue(); Double money = rateMoney.doubleValue();
invite1.setUserType(1); invite1.setUserType(1);
invite1.setState(1); invite1.setState(1);
@@ -222,15 +225,15 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
userMoneyDetails.setClassify(2); userMoneyDetails.setClassify(2);
userMoneyDetails.setMoney(new BigDecimal(money)); userMoneyDetails.setMoney(new BigDecimal(money));
userMoneyDetails.setCreateTime(format); userMoneyDetails.setCreateTime(format);
userMoneyDetails.setTitle("[邀请好友]好友名称："+userEntity1.getUserName()); userMoneyDetails.setTitle("[邀请好友]好友名称：" + userEntity1.getUserName());
userMoneyDetails.setContent("获取佣金:"+money); userMoneyDetails.setContent("获取佣金:" + money);
userMoneyDetailsService.save(userMoneyDetails); userMoneyDetailsService.save(userMoneyDetails);
result.put("oneUserId",userEntity.getUserId()); result.put("oneUserId", userEntity.getUserId());
result.put("oneMoney",money); result.put("oneMoney", money);
} }
UserEntity two = userService.queryByInvitationCode(userEntity.getInviterCode()); UserEntity two = userService.queryByInvitationCode(userEntity.getInviterCode());
if(two!=null){ if (two != null) {
Invite invite2 = inviteDao.selectInviteByUser(two.getUserId(), userId,2); Invite invite2 = inviteDao.selectInviteByUser(two.getUserId(), userId, 2);
if (invite2 == null) { if (invite2 == null) {
Invite invite = new Invite(); Invite invite = new Invite();
invite.setState(0); invite.setState(0);
@@ -240,11 +243,11 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
invite.setCreateTime(format); invite.setCreateTime(format);
invite.setUserType(2); invite.setUserType(2);
inviteDao.insert(invite); inviteDao.insert(invite);
invite2 = inviteDao.selectInviteByUser(two.getUserId(), userId,2); invite2 = inviteDao.selectInviteByUser(two.getUserId(), userId, 2);
} }
if (two.getTwoRate() != null && two.getTwoRate().doubleValue() > 0) { if (two.getTwoRate() != null && two.getTwoRate().doubleValue() > 0) {
BigDecimal rateMoney = price.multiply(two.getTwoRate()).setScale(2, RoundingMode.HALF_UP); BigDecimal rateMoney = price.multiply(two.getTwoRate()).setScale(2, RoundingMode.HALF_UP);
twoMoney=rateMoney; twoMoney = rateMoney;
Double money = rateMoney.doubleValue(); Double money = rateMoney.doubleValue();
invite2.setUserType(2); invite2.setUserType(2);
invite2.setState(1); invite2.setState(1);
@@ -258,39 +261,39 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
userMoneyDetails.setMoney(new BigDecimal(money)); userMoneyDetails.setMoney(new BigDecimal(money));
userMoneyDetails.setCreateTime(format); userMoneyDetails.setCreateTime(format);
userMoneyDetails.setClassify(2); userMoneyDetails.setClassify(2);
userMoneyDetails.setTitle("[邀请好友]好友名称："+userEntity1.getUserName()); userMoneyDetails.setTitle("[邀请好友]好友名称：" + userEntity1.getUserName());
userMoneyDetails.setContent("获取佣金:"+money); userMoneyDetails.setContent("获取佣金:" + money);
userMoneyDetailsService.save(userMoneyDetails); userMoneyDetailsService.save(userMoneyDetails);
result.put("twoUserId",two.getUserId()); result.put("twoUserId", two.getUserId());
result.put("twoMoney",money); result.put("twoMoney", money);
} }
} }
if(StringUtils.isNotEmpty(userEntity1.getQdCode())){ if (StringUtils.isNotEmpty(userEntity1.getQdCode())) {
SysUserEntity sysUserEntity = sysUserService.selectSysUserByQdCode(userEntity1.getQdCode()); SysUserEntity sysUserEntity = sysUserService.selectSysUserByQdCode(userEntity1.getQdCode());
if(sysUserEntity!=null){ if (sysUserEntity != null) {
BigDecimal rateMoney = price.multiply(sysUserEntity.getQdRate()).setScale(2, RoundingMode.HALF_UP); BigDecimal rateMoney = price.multiply(sysUserEntity.getQdRate()).setScale(2, RoundingMode.HALF_UP);
BigDecimal sumMoney = rateMoney.subtract(oneMoney); BigDecimal sumMoney = rateMoney.subtract(oneMoney);
sumMoney = sumMoney.subtract(twoMoney); sumMoney = sumMoney.subtract(twoMoney);
userMoneyService.updateSysMoney(1,sysUserEntity.getUserId(),sumMoney.doubleValue()); userMoneyService.updateSysMoney(1, sysUserEntity.getUserId(), sumMoney.doubleValue());
UserMoneyDetails userMoneyDetails = new UserMoneyDetails(); UserMoneyDetails userMoneyDetails = new UserMoneyDetails();
userMoneyDetails.setSysUserId(sysUserEntity.getUserId()); userMoneyDetails.setSysUserId(sysUserEntity.getUserId());
userMoneyDetails.setType(1); userMoneyDetails.setType(1);
userMoneyDetails.setMoney(sumMoney); userMoneyDetails.setMoney(sumMoney);
userMoneyDetails.setCreateTime(format); userMoneyDetails.setCreateTime(format);
userMoneyDetails.setClassify(10); userMoneyDetails.setClassify(10);
userMoneyDetails.setTitle("[渠道用户]用户名称："+userEntity1.getUserName()); userMoneyDetails.setTitle("[渠道用户]用户名称：" + userEntity1.getUserName());
String title="总佣金："+rateMoney; String title = "总佣金：" + rateMoney;
if(oneMoney.doubleValue()>0){ if (oneMoney.doubleValue() > 0) {
title=title+"，一级推广员扣除收益："+oneMoney; title = title + "，一级推广员扣除收益：" + oneMoney;
} }
if(twoMoney.doubleValue()>0){ if (twoMoney.doubleValue() > 0) {
title=title+"，二级推广员扣除收益："+twoMoney; title = title + "，二级推广员扣除收益：" + twoMoney;
} }
userMoneyDetails.setContent(title+"，到账佣金:"+sumMoney); userMoneyDetails.setContent(title + "，到账佣金:" + sumMoney);
userMoneyDetailsService.save(userMoneyDetails); userMoneyDetailsService.save(userMoneyDetails);
result.put("sysUserId",sysUserEntity.getUserId()); result.put("sysUserId", sysUserEntity.getUserId());
result.put("qdMoney",sumMoney); result.put("qdMoney", sumMoney);
return result; return result;
} }
} }

1
src/main/java/com/sqx/modules/pay/wuyou/Constants.java
View File

@@ -16,5 +16,6 @@ public class Constants {
final static String EXTRACT_QUERY_URL = BASE_URL + "/api/querySalary"; final static String EXTRACT_QUERY_URL = BASE_URL + "/api/querySalary";
final static String NOTIFY_URL = "https://video.hnsiyao.cn/sqx_fast/app/wuyou/notify"; final static String NOTIFY_URL = "https://video.hnsiyao.cn/sqx_fast/app/wuyou/notify";
final static String EXTRACT_NOTIFY_URL = "https://video.hnsiyao.cn/sqx_fast/app/wuyou/notify";
} }

5
src/main/java/com/sqx/modules/pay/wuyou/WuyouPay.java
View File

@@ -2,6 +2,7 @@ package com.sqx.modules.pay.wuyou;
import cn.hutool.http.HttpRequest; import cn.hutool.http.HttpRequest;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -53,7 +54,7 @@ public class WuyouPay {
params.put("bank_branch", "1"); params.put("bank_branch", "1");
params.put("province", "1"); params.put("province", "1");
params.put("city", "1"); params.put("city", "1");
params.put("notify_url", "1"); params.put("notify_url", Constants.EXTRACT_NOTIFY_URL);
String sign = Encrypt.getParamsSign(params); String sign = Encrypt.getParamsSign(params);
params.put("sign", sign); params.put("sign", sign);
@@ -93,7 +94,7 @@ public class WuyouPay {
.execute() .execute()
.body(); .body();
logger.info("request url: {}, params: {}, response: {}", url, params, body); logger.info("无忧支付 request url: {}, params: {}, response: {}", url, params, body);
return body; return body;
} }