初始化修改

zyy

2025-09-03 41b107ba7acd40fa32ce9ec8f103dfe1061ecf4e

 trading-order-admin/src/main/java/com/yami/trading/api/controller/ApiIcoController.java

@@ -4,12 +4,15 @@
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.bean.ico.domain.Ico;
import com.yami.trading.bean.ico.domain.UserSubscription;
import com.yami.trading.bean.ico.dto.UserSubscriptionDTO;
import com.yami.trading.bean.ico.query.IcoQuery;
import com.yami.trading.bean.item.query.ItemQuery;
import com.yami.trading.common.domain.Result;
import com.yami.trading.common.exception.YamiShopBindException;
import com.yami.trading.common.query.QueryWrapperGenerator;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.ico.IcoService;
import com.yami.trading.service.ico.UserSubscriptionService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
@@ -30,6 +33,9 @@

    @Autowired
    IcoService icoService;

    @Autowired
    UserSubscriptionService userSubscriptionService;

    @Autowired
    private RedissonClient redissonClient;
@@ -60,7 +66,7 @@
                throw new YamiShopBindException("请稍后再试");
            }
            model.setUserId(partyId);
            icoService.subscribe(model);
            return icoService.subscribe(model);
        } catch (YamiShopBindException e) {
            log.error("错误信息: {}", e.getMessage(), e);
            throw e; // 重新抛出自定义异常
@@ -73,7 +79,19 @@
                rLock.unlock();
            }
        }
        return Result.succeed(null, "ok");
    }

    @ApiOperation(value = "新币申购记录列表")
    @GetMapping("recordList")
    public Result<Page<UserSubscriptionDTO>> recordList(IcoQuery icoQuery, Page<UserSubscriptionDTO> page) throws Exception {
        QueryWrapper queryWrapper = QueryWrapperGenerator.buildQueryCondition (icoQuery, IcoQuery.class);
        String partyId = SecurityUtils.getUser().getUserId();
        if (StringUtils.isEmpty(partyId)) {
            throw new YamiShopBindException("请重新登录");
        }
        queryWrapper.eq("u.user_id", partyId);
        Page<UserSubscriptionDTO> result = userSubscriptionService.findPage(page, queryWrapper);
        return Result.ok(result);
    }

}