6 Commits

  1. 7
      src/main/java/com/example/demo/controller/ConsumeController.java
  2. 6
      src/main/java/com/example/demo/controller/GeneralController.java
  3. 93
      src/main/java/com/example/demo/controller/RechargeController.java
  4. 7
      src/main/java/com/example/demo/controller/RefundController.java
  5. 3
      src/main/java/com/example/demo/domain/vo/ConsumeUser.java
  6. 1
      src/main/java/com/example/demo/domain/vo/Page.java
  7. 51
      src/main/java/com/example/demo/domain/vo/RechargeUser.java
  8. 3
      src/main/java/com/example/demo/domain/vo/RefundUser.java
  9. 2
      src/main/java/com/example/demo/mapper/ConsumeMapper.java
  10. 1
      src/main/java/com/example/demo/mapper/GeneralMapper.java
  11. 27
      src/main/java/com/example/demo/mapper/RechargeMapper.java
  12. 2
      src/main/java/com/example/demo/mapper/RefundMapper.java
  13. 4
      src/main/java/com/example/demo/service/ConsumeService.java
  14. 3
      src/main/java/com/example/demo/service/GeneralService.java
  15. 26
      src/main/java/com/example/demo/service/RechargeService.java
  16. 4
      src/main/java/com/example/demo/service/RefundService.java
  17. 28
      src/main/java/com/example/demo/serviceImpl/ConsumeServiceImpl.java
  18. 7
      src/main/java/com/example/demo/serviceImpl/GeneralServiceImpl.java
  19. 131
      src/main/java/com/example/demo/serviceImpl/RechargeServiceImpl.java
  20. 22
      src/main/java/com/example/demo/serviceImpl/RefundServiceImpl.java
  21. 70
      src/main/resources/mapper/ConsumeMapper.xml
  22. 3
      src/main/resources/mapper/GeneralMapper.xml
  23. 183
      src/main/resources/mapper/RechargeMapper.xml
  24. 68
      src/main/resources/mapper/RefundMapper.xml

7
src/main/java/com/example/demo/controller/ConsumeController.java

@ -41,7 +41,7 @@ public class ConsumeController {
if (ObjectUtils.isEmpty(page.getPageSize())) { if (ObjectUtils.isEmpty(page.getPageSize())) {
return Result.error("页大小为空!"); return Result.error("页大小为空!");
} else { } else {
return Result.success(consumeService.selectAll(page.getPageNum(), page.getPageSize()));
return Result.success(consumeService.selectAll(page.getPageNum(), page.getPageSize(),page.getConsumeUser()));
} }
} catch (Exception e) { } catch (Exception e) {
return Result.error("接口调用失败"); return Result.error("接口调用失败");
@ -50,6 +50,7 @@ public class ConsumeController {
} }
//消耗明细筛选 //消耗明细筛选
@PostMapping("/selectBy") @PostMapping("/selectBy")
public Result selcetBy(@RequestBody Page page) { public Result selcetBy(@RequestBody Page page) {
@ -70,9 +71,9 @@ public class ConsumeController {
//消耗金币统计 //消耗金币统计
@PostMapping("/statsGold") @PostMapping("/statsGold")
public Result statsGold() {
public Result statsGold(@RequestBody ConsumeUser consumeUser) {
try { try {
Gold gold = consumeService.statsGold();
Gold gold = consumeService.statsGold(consumeUser);
return Result.success(gold); return Result.success(gold);
} catch (Exception e) { } catch (Exception e) {
return Result.error("接口调用失败"); return Result.error("接口调用失败");

6
src/main/java/com/example/demo/controller/GeneralController.java

@ -47,4 +47,10 @@ public class GeneralController {
List<String> list = generalService.getGoods(); List<String> list = generalService.getGoods();
return Result.success(list); return Result.success(list);
} }
@PostMapping("/activity")
public Result getActivity()
{
List<String> list = generalService.getActivity();
return Result.success(list);
}
} }

93
src/main/java/com/example/demo/controller/RechargeController.java

@ -0,0 +1,93 @@
package com.example.demo.controller;
import com.example.demo.domain.vo.*;
import com.example.demo.service.ConsumeService;
import com.example.demo.service.RechargeService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.ObjectUtils;
import org.springframework.web.bind.annotation.*;
/**
* @program: gold-java
* @ClassName RechargeController
* @description:
* @author: Double
* @create: 202506-29 13:01
* @Version 1.0
**/
@RestController
@RequestMapping("/recharge")
@RequiredArgsConstructor
@Slf4j
@CrossOrigin
public class RechargeController {
@Autowired
private RechargeService rechargeService;
//消耗明细
@PostMapping("/selectAll")
public Result selcetAll(@RequestBody Page page) {
try {
if (ObjectUtils.isEmpty(page.getPageNum())) {
return Result.error("页码数为空!");
}
if (ObjectUtils.isEmpty(page.getPageSize())) {
return Result.error("页大小为空!");
} else {
return Result.success(rechargeService.selectAll(page.getPageNum(), page.getPageSize(),page.getRechargeUser()));
}
} catch (Exception e) {
return Result.error("接口调用失败");
}
}
//消耗明细筛选
@PostMapping("/selectBy")
public Result selcetBy(@RequestBody Page page) {
try {
if (ObjectUtils.isEmpty(page.getPageNum())) {
return Result.error("页码数为空!");
}
if (ObjectUtils.isEmpty(page.getPageSize())) {
return Result.error("页大小为空!");
} else {
return Result.success(rechargeService.selectBy(page.getPageNum(), page.getPageSize(), page.getRechargeUser()));
}
} catch (Exception e) {
return Result.error("接口调用失败");
}
}
//消耗金币统计
@PostMapping("/statsGold")
public Result statsGold(@RequestBody RechargeUser rechargeUser) {
try {
Gold gold = rechargeService.statsGold(rechargeUser);
return Result.success(gold);
} catch (Exception e) {
return Result.error("接口调用失败");
}
}
//消耗金币增加
@PostMapping("/add")
public Result add(@RequestBody RechargeUser rechargeUser) {
try {
return rechargeService.add(rechargeUser);
} catch (Exception e) {
return Result.error("接口调用失败");
}
}
}

7
src/main/java/com/example/demo/controller/RefundController.java

@ -2,6 +2,7 @@ package com.example.demo.controller;
import com.example.demo.domain.vo.Gold; import com.example.demo.domain.vo.Gold;
import com.example.demo.domain.vo.Page; import com.example.demo.domain.vo.Page;
import com.example.demo.domain.vo.RefundUser;
import com.example.demo.domain.vo.Result; import com.example.demo.domain.vo.Result;
import com.example.demo.service.ConsumeService; import com.example.demo.service.ConsumeService;
import com.example.demo.service.RefundService; import com.example.demo.service.RefundService;
@ -40,7 +41,7 @@ public class RefundController {
if (ObjectUtils.isEmpty(page.getPageSize())) { if (ObjectUtils.isEmpty(page.getPageSize())) {
return Result.error("页大小为空!"); return Result.error("页大小为空!");
} else { } else {
return Result.success(refundService.selectAll(page.getPageNum(), page.getPageSize()));
return Result.success(refundService.selectAll(page.getPageNum(), page.getPageSize(), page.getRefundUser()));
} }
} catch (Exception e) { } catch (Exception e) {
return Result.error("接口调用失败"); return Result.error("接口调用失败");
@ -66,9 +67,9 @@ public class RefundController {
} }
@PostMapping("/statsGold") @PostMapping("/statsGold")
public Result statsGold() {
public Result statsGold(@RequestBody RefundUser refundUser) {
try { try {
Gold gold = refundService.statsGold();
Gold gold = refundService.statsGold(refundUser);
return Result.success(gold); return Result.success(gold);
} catch (Exception e) { } catch (Exception e) {
return Result.error("接口调用失败"); return Result.error("接口调用失败");

3
src/main/java/com/example/demo/domain/vo/ConsumeUser.java

@ -43,4 +43,7 @@ public class ConsumeUser implements Serializable {
private Date startTime; // 开始时间 private Date startTime; // 开始时间
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
private Date endTime; // 结束时间 private Date endTime; // 结束时间
private String sortField; //排序字段
private String sortOrder; //排序顺序
} }

1
src/main/java/com/example/demo/domain/vo/Page.java

@ -24,4 +24,5 @@ public class Page {
private User user; private User user;
private RefundUser refundUser; private RefundUser refundUser;
private Permission permission; private Permission permission;
private RechargeUser rechargeUser;
} }

51
src/main/java/com/example/demo/domain/vo/RechargeUser.java

@ -0,0 +1,51 @@
package com.example.demo.domain.vo;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.Date;
/**
* @program: gold-java
* @ClassName Recharge
* @description:
* @author: Double
* @create: 202506-29 13:18
* @Version 1.0
**/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class RechargeUser {
private static final long serialVersionUID = 1L;
private String name; // 客户姓名
private Integer jwcode; // 精网号
private String market; // 所属地区
private String activity; // 活动名称
private Integer rateId; // 汇率ID
private String rateName; // 汇率名称
private Integer money; // 金额[]
private Integer permanentGold; // 永久金币
private Integer freeGold; // 免费金币
private String payModel; // 支付方式
private String payPlatform; // 支付平台
private String voucher; // 支付凭证
private String remark; // 备注
private Integer adminId; //提交人Id
private String adminName; //提交人姓名
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
private Date payTime; // 创建时间
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
private Date startTime; // 开始时间
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
private Date endTime; // 结束时间
private String sortField; //排序字段
private String sortOrder; //排序顺序
}

3
src/main/java/com/example/demo/domain/vo/RefundUser.java

@ -43,4 +43,7 @@ public class RefundUser {
private Date startTime; // 开始时间 private Date startTime; // 开始时间
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
private Date endTime; // 结束时间 private Date endTime; // 结束时间
private String sortField; //排序字段
private String sortOrder; //排序顺序
} }

2
src/main/java/com/example/demo/mapper/ConsumeMapper.java

@ -18,7 +18,7 @@ import java.util.List;
@Mapper @Mapper
public interface ConsumeMapper { public interface ConsumeMapper {
List<ConsumeUser> selectAll();
List<ConsumeUser> selectAll(ConsumeUser consumeUser);
List<ConsumeUser> selectBy(ConsumeUser consumeUser); List<ConsumeUser> selectBy(ConsumeUser consumeUser);

1
src/main/java/com/example/demo/mapper/GeneralMapper.java

@ -17,4 +17,5 @@ public interface GeneralMapper {
List<String> getMarket(); List<String> getMarket();
List<String> getPlatform(); List<String> getPlatform();
List<String> getGoods(); List<String> getGoods();
List<String> getActivity();
} }

27
src/main/java/com/example/demo/mapper/RechargeMapper.java

@ -0,0 +1,27 @@
package com.example.demo.mapper;
import com.example.demo.domain.entity.UserGoldRecord;
import com.example.demo.domain.vo.RechargeUser;
import com.example.demo.domain.vo.RefundUser;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* @program: gold-java
* @ClassName RechargeMapper
* @description:
* @author: Double
* @create: 202506-29 13:41
* @Version 1.0
**/
@Mapper
public interface RechargeMapper {
List<RechargeUser> selectAll(RechargeUser rechargeUser);
List<RechargeUser> selectBy(RechargeUser rechargeUser);
void add(UserGoldRecord userGoldRecord);
}

2
src/main/java/com/example/demo/mapper/RefundMapper.java

@ -19,7 +19,7 @@ import java.util.List;
@Mapper @Mapper
public interface RefundMapper { public interface RefundMapper {
List<RefundUser> selectAll();
List<RefundUser> selectAll(RefundUser refundUser);
List<RefundUser> selectBy(RefundUser refundUser); List<RefundUser> selectBy(RefundUser refundUser);

4
src/main/java/com/example/demo/service/ConsumeService.java

@ -18,9 +18,9 @@ import com.github.pagehelper.PageInfo;
public interface ConsumeService { public interface ConsumeService {
PageInfo<ConsumeUser> selectAll(Integer pageNum, Integer pageSize);
PageInfo<ConsumeUser> selectAll(Integer pageNum, Integer pageSize, ConsumeUser consumeUser);
Gold statsGold();
Gold statsGold(ConsumeUser consumeUser);
PageInfo<ConsumeUser> selectBy(Integer pageNum, Integer pageSize, ConsumeUser consumeUser); PageInfo<ConsumeUser> selectBy(Integer pageNum, Integer pageSize, ConsumeUser consumeUser);

3
src/main/java/com/example/demo/service/GeneralService.java

@ -20,7 +20,10 @@ public interface GeneralService {
List<String> getMarket(); List<String> getMarket();
//获取平台 //获取平台
List<String> getPlatform(); List<String> getPlatform();
//获取商品
List<String> getGoods(); List<String> getGoods();
//获取活动
List<String> getActivity();
//获取昨天的日期 //获取昨天的日期
Date getYesterday(); Date getYesterday();
//获取某天的开始时间(00:00:00) //获取某天的开始时间(00:00:00)

26
src/main/java/com/example/demo/service/RechargeService.java

@ -0,0 +1,26 @@
package com.example.demo.service;
import com.example.demo.domain.vo.ConsumeUser;
import com.example.demo.domain.vo.Gold;
import com.example.demo.domain.vo.RechargeUser;
import com.example.demo.domain.vo.Result;
import com.github.pagehelper.PageInfo;
/**
* @program: gold-java
* @ClassName RechargeService
* @description:
* @author: Double
* @create: 202506-29 13:39
* @Version 1.0
**/
public interface RechargeService {
PageInfo<RechargeUser> selectAll(Integer pageNum, Integer pageSize, RechargeUser rechargeUser);
Gold statsGold(RechargeUser rechargeUser);
PageInfo<RechargeUser> selectBy(Integer pageNum, Integer pageSize, RechargeUser rechargeUser);
Result add(RechargeUser rechargeUser);
}

4
src/main/java/com/example/demo/service/RefundService.java

@ -18,9 +18,9 @@ import com.github.pagehelper.PageInfo;
public interface RefundService { public interface RefundService {
PageInfo<RefundUser> selectAll(Integer pageNum, Integer pageSize);
PageInfo<RefundUser> selectAll(Integer pageNum, Integer pageSize, RefundUser refundUser);
Gold statsGold();
Gold statsGold(RefundUser refundUser);
PageInfo<RefundUser> selectBy(Integer pageNum, Integer pageSize, RefundUser refundUser); PageInfo<RefundUser> selectBy(Integer pageNum, Integer pageSize, RefundUser refundUser);

28
src/main/java/com/example/demo/serviceImpl/ConsumeServiceImpl.java

@ -42,17 +42,17 @@ public class ConsumeServiceImpl implements ConsumeService {
//消耗明细 //消耗明细
@Override @Override
public PageInfo<ConsumeUser> selectAll(Integer pageNum, Integer pageSize) {
public PageInfo<ConsumeUser> selectAll(Integer pageNum, Integer pageSize, ConsumeUser consumeUser) {
PageHelper.startPage(pageNum, pageSize); PageHelper.startPage(pageNum, pageSize);
List<ConsumeUser> consumeUsers = consumeMapper.selectAll();
List<ConsumeUser> consumeUsers = consumeMapper.selectAll(consumeUser);
return new PageInfo<>(consumeUsers); return new PageInfo<>(consumeUsers);
} }
//消耗金币统计 //消耗金币统计
@Override @Override
public Gold statsGold() {
public Gold statsGold(ConsumeUser consumeUser) {
Gold gold = new Gold(); Gold gold = new Gold();
List<ConsumeUser> consumeUsers = consumeMapper.selectAll();
List<ConsumeUser> consumeUsers = consumeMapper.selectBy(consumeUser);
// 初始化累加器 // 初始化累加器
int permanentGoldSum = 0; int permanentGoldSum = 0;
@ -60,18 +60,18 @@ public class ConsumeServiceImpl implements ConsumeService {
int taskGoldSum = 0; int taskGoldSum = 0;
// 遍历消费记录并累加金币 // 遍历消费记录并累加金币
for (ConsumeUser consumeUser : consumeUsers) {
for (ConsumeUser user : consumeUsers) {
// 累加永久金币 // 累加永久金币
if (consumeUser.getPermanentGold() != null) {
permanentGoldSum += consumeUser.getPermanentGold();
if (user.getPermanentGold() != null) {
permanentGoldSum += user.getPermanentGold();
} }
// 累加免费金币 // 累加免费金币
if (consumeUser.getFreeGold() != null) {
freeGoldSum += consumeUser.getFreeGold();
if (user.getFreeGold() != null) {
freeGoldSum += user.getFreeGold();
} }
// 累加任务金币 // 累加任务金币
if (consumeUser.getTaskGold() != null) {
taskGoldSum += consumeUser.getTaskGold();
if (user.getTaskGold() != null) {
taskGoldSum += user.getTaskGold();
} }
} }
@ -105,12 +105,9 @@ public class ConsumeServiceImpl implements ConsumeService {
int count = atomicInteger.getAndUpdate(c -> (c >= 999) ? 0 : c + 1); int count = atomicInteger.getAndUpdate(c -> (c >= 999) ? 0 : c + 1);
String counterPart = String.format("%03d", count); String counterPart = String.format("%03d", count);
// 生成随机数部分四位数
Random RANDOM = new Random();
int randomNum = RANDOM.nextInt(9000) + 1000;
//订单号生成 //订单号生成
userGoldRecord.setOrderCode(timestampPart + counterPart + randomNum);
userGoldRecord.setOrderCode("XF" + timestampPart + counterPart);
userGoldRecord.setJwcode(consumeUser.getJwcode()); userGoldRecord.setJwcode(consumeUser.getJwcode());
userGoldRecord.setGoodsName(consumeUser.getGoodsName()); userGoldRecord.setGoodsName(consumeUser.getGoodsName());
userGoldRecord.setSumGold(consumeUser.getSumGold()); userGoldRecord.setSumGold(consumeUser.getSumGold());
@ -148,6 +145,7 @@ public class ConsumeServiceImpl implements ConsumeService {
userGoldRecord.setIsRefund((byte) 0); userGoldRecord.setIsRefund((byte) 0);
userGoldRecord.setPayPlatform("金币系统"); userGoldRecord.setPayPlatform("金币系统");
userGoldRecord.setAdminId(consumeUser.getAdminId()); userGoldRecord.setAdminId(consumeUser.getAdminId());
userGoldRecord.setAuditStatus(1);
userGoldRecord.setCreateTime(new Date()); userGoldRecord.setCreateTime(new Date());
userGoldRecord.setPayTime(new Date()); userGoldRecord.setPayTime(new Date());
consumeMapper.add(userGoldRecord); consumeMapper.add(userGoldRecord);

7
src/main/java/com/example/demo/serviceImpl/GeneralServiceImpl.java

@ -45,6 +45,13 @@ public class GeneralServiceImpl implements GeneralService {
return list; return list;
} }
@Override
public List<String> getActivity() {
List<String> list = generalMapper.getActivity();
return list;
}
/* /*
获取昨天的日期 获取昨天的日期
*/ */

131
src/main/java/com/example/demo/serviceImpl/RechargeServiceImpl.java

@ -0,0 +1,131 @@
package com.example.demo.serviceImpl;
import com.example.demo.domain.entity.User;
import com.example.demo.domain.entity.UserGoldRecord;
import com.example.demo.domain.vo.*;
import com.example.demo.mapper.ConsumeMapper;
import com.example.demo.mapper.RechargeMapper;
import com.example.demo.mapper.UserMapper;
import com.example.demo.service.RechargeService;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.Date;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
/**
* @program: gold-java
* @ClassName RechrageServceImpl
* @description:
* @author: Double
* @create: 202506-29 13:40
* @Version 1.0
**/
@Service
public class RechargeServiceImpl implements RechargeService {
@Autowired
private RechargeMapper rechargeMapper;
@Autowired
private UserMapper userMapper;
@Override
public PageInfo<RechargeUser> selectAll(Integer pageNum, Integer pageSize, RechargeUser rechargeUser) {
PageHelper.startPage(pageNum, pageSize);
List<RechargeUser> rechargeUsers = rechargeMapper.selectAll(rechargeUser);
return new PageInfo<>(rechargeUsers);
}
@Override
public PageInfo<RechargeUser> selectBy(Integer pageNum, Integer pageSize, RechargeUser rechargeUser) {
PageHelper.startPage(pageNum, pageSize);
List<RechargeUser> rechargeUsers = rechargeMapper.selectBy(rechargeUser);
return new PageInfo<>(rechargeUsers);
}
@Override
public Gold statsGold(RechargeUser rechargeUser) {
Gold gold = new Gold();
List<RechargeUser> rechargeUsers = rechargeMapper.selectBy(rechargeUser);
// 初始化累加器
int permanentGoldSum = 0;
int freeGoldSum = 0;
// 遍历充值记录并累加金币
for (RechargeUser user : rechargeUsers) {
// 累加永久金币
if (user.getPermanentGold() != null) {
permanentGoldSum += user.getPermanentGold();
}
// 累加免费金币
if (user.getFreeGold() != null) {
freeGoldSum += user.getFreeGold();
}
}
// 将累加结果设置到Gold对象
gold.setPermanentGolds(permanentGoldSum);
gold.setFreeGolds(freeGoldSum);
return gold;
}
@Override
public Result add(RechargeUser rechargeUser) {
UserGoldRecord userGoldRecord = new UserGoldRecord();
// 获取当前时间戳部分
String timestampPart = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS"));
// 获取自增计数器部分三位数不足补零
AtomicInteger atomicInteger = new AtomicInteger(0);
int count = atomicInteger.getAndUpdate(c -> (c >= 999) ? 0 : c + 1);
String counterPart = String.format("%03d", count);
//订单号生成
userGoldRecord.setOrderCode("CZ" + timestampPart + counterPart);
userGoldRecord.setJwcode(rechargeUser.getJwcode());
userGoldRecord.setActivity(rechargeUser.getActivity());
userGoldRecord.setPermanentGold(rechargeUser.getPermanentGold());
// 获取当前月份1-12
int currentMonth = LocalDate.now().getMonthValue();
// 根据当前月份设置对应字段
if (currentMonth >= 1 && currentMonth <= 6) {
// 1-6月设置6月额度12月保持默认值
userGoldRecord.setFreeJune(0);
userGoldRecord.setFreeDecember(rechargeUser.getFreeGold());
} else {
// 7-12月设置12月额度6月保持默认值
userGoldRecord.setFreeJune(rechargeUser.getFreeGold());
userGoldRecord.setFreeDecember(0);
}
userGoldRecord.setSumGold(rechargeUser.getFreeGold()+rechargeUser.getPermanentGold());
userGoldRecord.setRateId(rechargeUser.getRateId());
userGoldRecord.setMoney(rechargeUser.getMoney());
userGoldRecord.setVoucher(rechargeUser.getVoucher());
userGoldRecord.setPayPlatform("金币系统");
userGoldRecord.setPayModel(rechargeUser.getPayModel());
userGoldRecord.setPayTime(rechargeUser.getPayTime());
userGoldRecord.setRemark(rechargeUser.getRemark());
userGoldRecord.setAdminId(rechargeUser.getAdminId());
userGoldRecord.setType((byte) 0);
userGoldRecord.setAuditStatus(0);
userGoldRecord.setCreateTime(new Date());
rechargeMapper.add(userGoldRecord);
return Result.success();
}
}

22
src/main/java/com/example/demo/serviceImpl/RefundServiceImpl.java

@ -34,16 +34,16 @@ public class RefundServiceImpl implements RefundService {
private UserMapper userMapper; private UserMapper userMapper;
@Override @Override
public PageInfo<RefundUser> selectAll(Integer pageNum, Integer pageSize) {
public PageInfo<RefundUser> selectAll(Integer pageNum, Integer pageSize, RefundUser refundUser) {
PageHelper.startPage(pageNum, pageSize); PageHelper.startPage(pageNum, pageSize);
List<RefundUser> refundUsers = refundMapper.selectAll();
List<RefundUser> refundUsers = refundMapper.selectAll(refundUser);
return new PageInfo<>(refundUsers); return new PageInfo<>(refundUsers);
} }
@Override @Override
public Gold statsGold() {
public Gold statsGold(RefundUser refundUser) {
Gold gold = new Gold(); Gold gold = new Gold();
List<RefundUser> refundUsers = refundMapper.selectAll();
List<RefundUser> refundUsers = refundMapper.selectBy(refundUser);
// 初始化累加器 // 初始化累加器
int permanentGoldSum = 0; int permanentGoldSum = 0;
@ -51,18 +51,18 @@ public class RefundServiceImpl implements RefundService {
int taskGoldSum = 0; int taskGoldSum = 0;
// 遍历推开记录并累加金币 // 遍历推开记录并累加金币
for (RefundUser refundUser : refundUsers) {
for (RefundUser user : refundUsers) {
// 累加永久金币 // 累加永久金币
if (refundUser.getPermanentGold() != null) {
permanentGoldSum += refundUser.getPermanentGold();
if (user.getPermanentGold() != null) {
permanentGoldSum += user.getPermanentGold();
} }
// 累加免费金币 // 累加免费金币
if (refundUser.getFreeGold() != null) {
freeGoldSum += refundUser.getFreeGold();
if (user.getFreeGold() != null) {
freeGoldSum += user.getFreeGold();
} }
// 累加任务金币 // 累加任务金币
if (refundUser.getTaskGold() != null) {
taskGoldSum += refundUser.getTaskGold();
if (user.getTaskGold() != null) {
taskGoldSum += user.getTaskGold();
} }
} }

70
src/main/resources/mapper/ConsumeMapper.xml

@ -22,6 +22,40 @@
JOIN JOIN
admin a ON ugr.admin_id = a.id admin a ON ugr.admin_id = a.id
WHERE ugr.type = 1 WHERE ugr.type = 1
<trim prefix="ORDER BY" suffixOverrides=",">
<choose>
<!-- 当指定排序字段时使用指定字段排序 -->
<when test="sortField != null and sortField != ''">
<choose>
<!-- 对三种金币数量的排序处理 -->
<when test="sortField == 'taskGold'">ugr.task_gold</when>
<when test="sortField == 'permanentGold'">ugr.permanent_gold</when>
<when test="sortField == 'freeGold'">(COALESCE(ugr.free_june, 0) + COALESCE(ugr.free_december, 0))</when>
<!-- 对时间字段的排序处理 -->
<when test="sortField == 'createTime'">ugr.create_time</when>
<!-- 其他字段不支持排序,使用默认排序 -->
<otherwise>ugr.create_time</otherwise>
</choose>
<!-- 排序方向处理 -->
<if test="sortOrder != null and sortOrder != ''">
<choose>
<when test="sortOrder == 'ASC'">ASC</when>
<when test="sortOrder == 'DESC'">DESC</when>
<otherwise>DESC</otherwise>
</choose>
</if>
<if test="sortOrder == null or sortOrder == ''">
DESC
</if>
</when>
<!-- 未指定排序字段时,使用默认的时间降序排序 -->
<otherwise>
ugr.create_time DESC
</otherwise>
</choose>
</trim>
</select> </select>
<!-- 查询筛选后消费记录 --> <!-- 查询筛选后消费记录 -->
@ -61,6 +95,40 @@
AND ugr.create_time BETWEEN #{startTime} AND #{endTime} AND ugr.create_time BETWEEN #{startTime} AND #{endTime}
</if> </if>
</where> </where>
<trim prefix="ORDER BY" suffixOverrides=",">
<choose>
<!-- 当指定排序字段时使用指定字段排序 -->
<when test="sortField != null and sortField != ''">
<choose>
<!-- 对三种金币数量的排序处理 -->
<when test="sortField == 'taskGold'">ugr.task_gold</when>
<when test="sortField == 'permanentGold'">ugr.permanent_gold</when>
<when test="sortField == 'freeGold'">(COALESCE(ugr.free_june, 0) + COALESCE(ugr.free_december, 0))</when>
<!-- 对时间字段的排序处理 -->
<when test="sortField == 'createTime'">ugr.create_time</when>
<!-- 其他字段不支持排序,使用默认排序 -->
<otherwise>ugr.create_time</otherwise>
</choose>
<!-- 排序方向处理 -->
<if test="sortOrder != null and sortOrder != ''">
<choose>
<when test="sortOrder == 'ASC'">ASC</when>
<when test="sortOrder == 'DESC'">DESC</when>
<otherwise>DESC</otherwise>
</choose>
</if>
<if test="sortOrder == null or sortOrder == ''">
DESC
</if>
</when>
<!-- 未指定排序字段时,使用默认的时间降序排序 -->
<otherwise>
ugr.create_time DESC
</otherwise>
</choose>
</trim>
</select> </select>
<insert id="add" parameterType="com.example.demo.domain.entity.UserGoldRecord" useGeneratedKeys="true" keyProperty="id"> <insert id="add" parameterType="com.example.demo.domain.entity.UserGoldRecord" useGeneratedKeys="true" keyProperty="id">
@ -79,6 +147,7 @@
pay_platform, pay_platform,
is_refund, is_refund,
admin_id, admin_id,
audit_status,
create_time, create_time,
pay_time pay_time
</trim> </trim>
@ -97,6 +166,7 @@
#{payPlatform}, #{payPlatform},
#{isRefund}, #{isRefund},
#{adminId}, #{adminId},
#{auditStatus},
#{createTime}, #{createTime},
#{payTime} #{payTime}
</trim> </trim>

3
src/main/resources/mapper/GeneralMapper.xml

@ -11,4 +11,7 @@
<select id="getGoods" resultType="java.lang.String"> <select id="getGoods" resultType="java.lang.String">
select DISTINCT goods_name from user_gold_record select DISTINCT goods_name from user_gold_record
</select> </select>
<select id="getActivity" resultType="java.lang.String">
select DISTINCT activity from user_gold_record
</select>
</mapper> </mapper>

183
src/main/resources/mapper/RechargeMapper.xml

@ -0,0 +1,183 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.demo.mapper.RechargeMapper">
<!-- 查询所有充值记录 -->
<select id="selectAll" resultType="com.example.demo.domain.vo.RechargeUser">
SELECT
u.name AS name,
u.jwcode AS jwcode,
u.market AS market,
ugr.activity AS activity,
ugr.rate_id AS rateId,
r.rate_name AS rateName,
ugr.money AS money,
ugr.permanent_gold AS permanentGold,
(COALESCE(ugr.free_june, 0) + COALESCE(ugr.free_december, 0)) AS freeGold,
ugr.pay_model AS payModel,
ugr.pay_platform AS payPlatform,
ugr.remark AS remark,
ugr.admin_id AS adminId,
a.admin_name AS adminName,
ugr.create_time AS createTime
FROM user u
JOIN user_gold_record ugr ON u.jwcode = ugr.jwcode
JOIN admin a ON ugr.admin_id = a.id
JOIN rate r ON ugr.rate_id = r.id
WHERE ugr.type = 0
<trim prefix="ORDER BY" suffixOverrides=",">
<choose>
<!-- 当指定排序字段时使用指定字段排序 -->
<when test="sortField != null and sortField != ''">
<choose>
<!-- 对金币数量的排序处理 -->
<when test="sortField == 'permanentGold'">ugr.permanent_gold</when>
<when test="sortField == 'freeGold'">(COALESCE(ugr.free_june, 0) + COALESCE(ugr.free_december, 0))</when>
<!-- 对时间字段的排序处理 -->
<when test="sortField == 'createTime'">ugr.create_time</when>
<!-- 其他字段不支持排序,使用默认排序 -->
<otherwise>ugr.create_time</otherwise>
</choose>
<!-- 排序方向处理 -->
<if test="sortOrder != null and sortOrder != ''">
<choose>
<when test="sortOrder == 'ASC'">ASC</when>
<when test="sortOrder == 'DESC'">DESC</when>
<otherwise>DESC</otherwise>
</choose>
</if>
<if test="sortOrder == null or sortOrder == ''">
DESC
</if>
</when>
<!-- 未指定排序字段时,使用默认的时间降序排序 -->
<otherwise>
ugr.create_time DESC
</otherwise>
</choose>
</trim>
</select>
<!-- 查询筛选后充值记录 -->
<select id="selectBy" resultType="com.example.demo.domain.vo.RechargeUser">
SELECT
u.name AS name,
u.jwcode AS jwcode,
u.market AS market,
ugr.activity AS activity,
ugr.rate_id AS rateId,
r.rate_name AS rateName,
ugr.money AS money,
ugr.permanent_gold AS permanentGold,
(COALESCE(ugr.free_june, 0) + COALESCE(ugr.free_december, 0)) AS freeGold,
ugr.pay_model AS payModel,
ugr.pay_platform AS payPlatform,
ugr.remark AS remark,
ugr.admin_id AS adminId,
a.admin_name AS adminName,
ugr.create_time AS createTime
FROM user u
JOIN user_gold_record ugr ON u.jwcode = ugr.jwcode
JOIN admin a ON ugr.admin_id = a.id
JOIN rate r ON ugr.rate_id = r.id
<where>
ugr.type = 0
<if test="jwcode != null and jwcode != ''">
AND ugr.jwcode = #{jwcode}
</if>
<if test="activity != null and activity != ''">
AND ugr.activity = #{activity}
</if>
<if test="market != null and market != ''">
AND u.market = #{market}
</if>
<if test="payPlatform != null and payPlatform != ''">
AND ugr.pay_platform = #{payPlatform}
</if>
<if test="startTime != null and endTime != null">
AND ugr.create_time BETWEEN #{startTime} AND #{endTime}
</if>
</where>
<trim prefix="ORDER BY" suffixOverrides=",">
<choose>
<!-- 当指定排序字段时使用指定字段排序 -->
<when test="sortField != null and sortField != ''">
<choose>
<!-- 对金币数量的排序处理 -->
<when test="sortField == 'permanentGold'">ugr.permanent_gold</when>
<when test="sortField == 'freeGold'">(COALESCE(ugr.free_june, 0) + COALESCE(ugr.free_december, 0))</when>
<!-- 对时间字段的排序处理 -->
<when test="sortField == 'createTime'">ugr.create_time</when>
<!-- 其他字段不支持排序,使用默认排序 -->
<otherwise>ugr.create_time</otherwise>
</choose>
<!-- 排序方向处理 -->
<if test="sortOrder != null and sortOrder != ''">
<choose>
<when test="sortOrder == 'ASC'">ASC</when>
<when test="sortOrder == 'DESC'">DESC</when>
<otherwise>DESC</otherwise>
</choose>
</if>
<if test="sortOrder == null or sortOrder == ''">
DESC
</if>
</when>
<!-- 未指定排序字段时,使用默认的时间降序排序 -->
<otherwise>
ugr.create_time DESC
</otherwise>
</choose>
</trim>
</select>
<insert id="add" parameterType="com.example.demo.domain.entity.UserGoldRecord" useGeneratedKeys="true" keyProperty="id">
INSERT INTO user_gold_record
<trim prefix="(" suffix=")" suffixOverrides=",">
order_code,
jwcode,
activity,
sum_gold,
permanent_gold,
free_june,
free_december,
rate_id,
money,
voucher,
pay_platform,
pay_model,
pay_time,
remark,
admin_id,
type,
audit_status,
create_time
</trim>
VALUES
<trim prefix="(" suffix=")" suffixOverrides=",">
#{orderCode},
#{jwcode},
#{activity},
#{sumGold},
#{permanentGold},
#{freeJune},
#{freeDecember},
#{rateId},
#{money},
#{voucher},
#{payPlatform},
#{payModel},
#{payTime},
#{remark},
#{adminId},
#{type},
#{auditStatus},
#{createTime}
</trim>
</insert>
</mapper>

68
src/main/resources/mapper/RefundMapper.xml

@ -23,6 +23,40 @@
JOIN JOIN
admin a ON ugr.admin_id = a.id admin a ON ugr.admin_id = a.id
WHERE ugr.type = 2 WHERE ugr.type = 2
<trim prefix="ORDER BY" suffixOverrides=",">
<choose>
<!-- 当指定排序字段时使用指定字段排序 -->
<when test="sortField != null and sortField != ''">
<choose>
<!-- 对三种金币数量的排序处理 -->
<when test="sortField == 'taskGold'">ugr.task_gold</when>
<when test="sortField == 'permanentGold'">ugr.permanent_gold</when>
<when test="sortField == 'freeGold'">(COALESCE(ugr.free_june, 0) + COALESCE(ugr.free_december, 0))</when>
<!-- 对时间字段的排序处理 -->
<when test="sortField == 'createTime'">ugr.create_time</when>
<!-- 其他字段不支持排序,使用默认排序 -->
<otherwise>ugr.create_time</otherwise>
</choose>
<!-- 排序方向处理 -->
<if test="sortOrder != null and sortOrder != ''">
<choose>
<when test="sortOrder == 'ASC'">ASC</when>
<when test="sortOrder == 'DESC'">DESC</when>
<otherwise>DESC</otherwise>
</choose>
</if>
<if test="sortOrder == null or sortOrder == ''">
DESC
</if>
</when>
<!-- 未指定排序字段时,使用默认的时间降序排序 -->
<otherwise>
ugr.create_time DESC
</otherwise>
</choose>
</trim>
</select> </select>
<!-- 查询筛选后消费记录 --> <!-- 查询筛选后消费记录 -->
@ -63,6 +97,40 @@
AND ugr.create_time BETWEEN #{startTime} AND #{endTime} AND ugr.create_time BETWEEN #{startTime} AND #{endTime}
</if> </if>
</where> </where>
<trim prefix="ORDER BY" suffixOverrides=",">
<choose>
<!-- 当指定排序字段时使用指定字段排序 -->
<when test="sortField != null and sortField != ''">
<choose>
<!-- 对三种金币数量的排序处理 -->
<when test="sortField == 'taskGold'">ugr.task_gold</when>
<when test="sortField == 'permanentGold'">ugr.permanent_gold</when>
<when test="sortField == 'freeGold'">(COALESCE(ugr.free_june, 0) + COALESCE(ugr.free_december, 0))</when>
<!-- 对时间字段的排序处理 -->
<when test="sortField == 'createTime'">ugr.create_time</when>
<!-- 其他字段不支持排序,使用默认排序 -->
<otherwise>ugr.create_time</otherwise>
</choose>
<!-- 排序方向处理 -->
<if test="sortOrder != null and sortOrder != ''">
<choose>
<when test="sortOrder == 'ASC'">ASC</when>
<when test="sortOrder == 'DESC'">DESC</when>
<otherwise>DESC</otherwise>
</choose>
</if>
<if test="sortOrder == null or sortOrder == ''">
DESC
</if>
</when>
<!-- 未指定排序字段时,使用默认的时间降序排序 -->
<otherwise>
ugr.create_time DESC
</otherwise>
</choose>
</trim>
</select> </select>
<insert id="add" parameterType="com.example.demo.domain.entity.UserGoldRecord" useGeneratedKeys="true" keyProperty="id"> <insert id="add" parameterType="com.example.demo.domain.entity.UserGoldRecord" useGeneratedKeys="true" keyProperty="id">

Loading…
Cancel
Save