package com.example.demo.controller.coin; import com.example.demo.Util.JWTUtil; import com.example.demo.Util.LanguageTranslationUtil; import com.example.demo.config.interfac.Log; import com.example.demo.domain.entity.Admin; import com.example.demo.domain.vo.coin.ConsumeUser; import com.example.demo.domain.vo.coin.Gold; import com.example.demo.domain.vo.coin.Page; import com.example.demo.domain.vo.coin.Result; import com.example.demo.service.coin.ConsumeService; import com.github.pagehelper.PageInfo; import jakarta.servlet.http.HttpServletRequest; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.ObjectUtils; import org.springframework.web.bind.annotation.*; import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.ServletRequestAttributes; import java.util.Arrays; import java.util.List; /** * @program: gold-java * @ClassName ConsumeController * @description:消费模块 * @author: Double * @create: 2025−06-23 13:06 * @Version 1.0 **/ @RestController @RequestMapping("/consume") @RequiredArgsConstructor @Slf4j @CrossOrigin public class ConsumeController { @Autowired private ConsumeService consumeService; // 注入多语言转换工具类 @Autowired private LanguageTranslationUtil languageTranslationUtil; //消耗明细 @Log("查看所有消耗明细") @PostMapping("/selectAll") public Result selectAll(@RequestBody Page page) { try { //页码校验 if (ObjectUtils.isEmpty(page.getPageNum())) { return Result.error("页码数为空!"); } //页面大小校验 if (ObjectUtils.isEmpty(page.getPageSize())) { return Result.error("页大小为空!"); } else { //解token权限 HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); String token = request.getHeader("token"); Admin admin = (Admin) JWTUtil.getUserDetailsList(String.valueOf(token), Admin.class); if (admin != null) { List list = Arrays.asList(admin.getMarkets().split(",")); page.getConsumeUser().setMarkets(list); } else{ return Result.error("角色为空"); } return Result.success(consumeService.selectAll(page.getPageNum(), page.getPageSize(),page.getConsumeUser())); } } catch (Exception e) { e.printStackTrace(); return Result.error("请检查筛选数据的格式"); } } //消耗明细筛选 @Log("筛选查询消耗明细") @PostMapping("/selectBy") public Result selectBy(@RequestBody Page page, @RequestHeader(defaultValue = "zh_CN") String lang) { try { //页码校验 if (ObjectUtils.isEmpty(page.getPageNum())) { return Result.error("页码数为空!"); } //页面大小校验 if (ObjectUtils.isEmpty(page.getPageSize())) { return Result.error("页大小为空!"); } else { //解token权限 if(page.getConsumeUser().getMarkets()==null||page.getConsumeUser().getMarkets().isEmpty()) { HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); String token = request.getHeader("token"); Admin admin = (Admin) JWTUtil.getUserDetailsList(String.valueOf(token), Admin.class); if (admin != null) { List list = Arrays.asList(admin.getMarkets().split(",")); page.getConsumeUser().setMarkets(list); } else{ return Result.error("角色为空"); } } Result result = Result.success(consumeService.selectBy(page.getPageNum(), page.getPageSize(), page.getConsumeUser())); // 对返回结果进行多语言转换 if (result.getCode() == 200 && result.getData() instanceof PageInfo) { PageInfo pageInfo = (PageInfo) result.getData(); translateConsumeUsers(pageInfo, lang); } return result; } } catch (Exception e) { e.printStackTrace(); return Result.error("请检查筛选数据的格式"); } } //消耗金币统计 @Log("消耗金币合计数统计") @PostMapping("/statsGold") public Result statsGold(@RequestBody ConsumeUser consumeUser) { try { if(consumeUser.getMarkets()==null||consumeUser.getMarkets().isEmpty()) { HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); String token = request.getHeader("token"); Admin admin = (Admin) JWTUtil.getUserDetailsList(String.valueOf(token), Admin.class); if (admin != null) { List list = Arrays.asList(admin.getMarkets().split(",")); consumeUser.setMarkets(list); } else{ return Result.error("角色为空"); } } Gold gold = consumeService.statsGold(consumeUser); return Result.success(gold); } catch (Exception e) { e.printStackTrace(); return Result.error("请检查数据的格式"); } } //消耗金币增加 @Log("新增金币消耗") @PostMapping("/add") public Result add(@RequestBody ConsumeUser consumeUser) { try { return consumeService.add(consumeUser); // if(consumeUser.getJwcode().equals(94226013)) // { // return consumeService.add(consumeUser); // }else { // return Result.error("不是测试的精网号,无法添加消费"); // } // } catch (Exception e) { e.printStackTrace(); return Result.error("请查看后端报错信息"); } } // //消耗金币增加 // @Log("充值退款(消耗版)") // @PostMapping("/addRefund") // public Result addRefund(@RequestBody ConsumeUser consumeUser) { // try { // return consumeService.addRefund(consumeUser); //// if(consumeUser.getJwcode().equals(94226013)) //// { //// return consumeService.add(consumeUser); //// }else { //// return Result.error("不是测试的精网号,无法添加消费"); //// } //// // } catch (Exception e) { // e.printStackTrace(); // return Result.error("请检查数据的格式"); // } // } public Result select(@RequestBody Page page) { try { //页码校验 if (ObjectUtils.isEmpty(page.getPageNum())) { return Result.error("页码数为空!"); } //页面大小校验 if (ObjectUtils.isEmpty(page.getPageSize())) { return Result.error("页大小为空!"); } else { return Result.success(consumeService.selectBy(page.getPageNum(), page.getPageSize(), page.getConsumeUser())); } } catch (Exception e) { e.printStackTrace(); return Result.error("请检查筛选数据的格式"); } } /** * 转换消费用户信息的多语言字段 */ private void translateConsumeUsers(PageInfo pageInfo, String lang) { if (pageInfo != null && pageInfo.getList() != null) { for (ConsumeUser user : pageInfo.getList()) { // 翻译市场名称 if (user.getMarket() != null) { user.setMarket(languageTranslationUtil.translate(user.getMarket(), lang)); } // 翻译商品名称 if (user.getGoodsName() != null) { user.setGoodsName(languageTranslationUtil.translate(user.getGoodsName(), lang)); } // 翻译支付平台 if (user.getPayPlatform() != null) { user.setPayPlatform(languageTranslationUtil.translate(user.getPayPlatform(), lang)); } // 翻译退款状态 if (user.getIsRefund() != null) { if (user.getIsRefund() == 1) { user.setIsRefundDesc(languageTranslationUtil.translate("已退款", lang)); } else if (user.getIsRefund() == 0) { user.setIsRefundDesc(languageTranslationUtil.translate("正常", lang)); } } } } } }