gold-java/src/main/java/com/example/demo/controller/coin/ConsumeController.java

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.example.demo.service.coin.TranslationService;
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;

    @Autowired
    private TranslationService translationService;

    //消耗明细
    @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<String> 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 {
                // 解析语言参数，提取语言代码
                String languageCode = parseLanguageCode(lang);

                // 如果不是中文，则尝试将查询条件中的翻译文本转换为中文简体
                if (!"zh".equalsIgnoreCase(languageCode) && !"zh_cn".equalsIgnoreCase(languageCode)) {
                    convertTranslatedFieldsToChinese(page.getConsumeUser(), languageCode);
                }

                //解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<String> 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<ConsumeUser> pageInfo = (PageInfo<ConsumeUser>) 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<String> 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, @RequestHeader(defaultValue = "zh_CN") String lang) {
        try {
            // 解析语言参数，提取语言代码
            String languageCode = parseLanguageCode(lang);

            // 如果不是中文，则尝试将输入的翻译文本转换为中文简体
            if (!"zh".equalsIgnoreCase(languageCode) && !"zh_cn".equalsIgnoreCase(languageCode)) {
                convertTranslatedFieldsToChinese(consumeUser, languageCode);
            }

            Result result = consumeService.add(consumeUser);

            // 如果操作成功，对返回消息进行多语言转换
            if (result.getCode() == 200) {
                String translatedMsg = languageTranslationUtil.translate("添加成功", lang);
                return Result.success(translatedMsg);
            } else {
                // 对错误消息进行多语言转换
                String translatedErrorMsg = languageTranslationUtil.translate(result.getMsg(), lang);
                return Result.error(translatedErrorMsg);
            }
//            if(consumeUser.getJwcode().equals(94226013))
//            {
//                return consumeService.add(consumeUser);
//            }else {
//                return Result.error("不是测试的精网号，无法添加消费");
//            }
//
        } catch (Exception e) {
            e.printStackTrace();
            String translatedErrorMsg = languageTranslationUtil.translate("请查看后端报错信息", lang);
            return Result.error(translatedErrorMsg);
        }
    }

//    //消耗金币增加
//    @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<ConsumeUser> 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));
                    }
                }
            }
        }
    }
    /**
     * 解析语言代码
     */
    private String parseLanguageCode(String langHeader) {
        if (langHeader == null || langHeader.isEmpty()) {
            return "zh_CN";
        }
        // 处理类似 "en-US" 或 "zh-TW" 的情况
        if (langHeader.contains("-")) {
            String[] parts = langHeader.split("-");
            // 特殊处理中文繁体
            if ("zh".equalsIgnoreCase(parts[0]) && "TW".equalsIgnoreCase(parts[1])) {
                return "zh_TW";
            }
            return parts[0].toLowerCase();
        }
        return langHeader.toLowerCase();
    }

    /**
     * 将翻译后的字段转换为中文简体用于查询
     */
    private void convertTranslatedFieldsToChinese(ConsumeUser consumeUser, String languageCode) {
        if (consumeUser != null) {
            // 转换商品名称
            if (consumeUser.getGoodsName() != null && !consumeUser.getGoodsName().isEmpty()) {
                String chineseName = translationService.findChineseSimplifiedByTranslation(
                        consumeUser.getGoodsName(), languageCode);
                consumeUser.setGoodsName(chineseName);
            }

            // 转换市场名称
            if (consumeUser.getMarket() != null && !consumeUser.getMarket().isEmpty()) {
                String chineseMarket = translationService.findChineseSimplifiedByTranslation(
                        consumeUser.getMarket(), languageCode);
                consumeUser.setMarket(chineseMarket);
            }

//            // 转换支付平台
//            if (consumeUser.getPayPlatform() != null && !consumeUser.getPayPlatform().isEmpty()) {
//                String chinesePlatform = translationService.findChineseSimplifiedByTranslation(
//                        consumeUser.getPayPlatform(), languageCode);
//                consumeUser.setPayPlatform(chinesePlatform);
//            }
        }
    }

}