package com.gear.customer.swx.biz.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.gear.common.constant.SwxConstons;
|
import com.gear.common.core.redis.RedisCache;
|
import com.gear.customer.swx.biz.SwxBizIndex;
|
import com.gear.customer.swx.vo.response.SwxContentsVo;
|
import com.gear.customer.swx.vo.response.SwxIndexMarketInfoVo;
|
import com.gear.customer.swx.vo.response.SwxIndexQueryMarketVo;
|
import com.gear.swx.domain.*;
|
import com.gear.swx.service.*;
|
import com.gear.swx.vo.SyncKValueFromLdVo;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Component
|
public class SwxBizIndexImpl implements SwxBizIndex {
|
@Autowired
|
private ISwxMarketService swxMarketService;
|
|
@Autowired
|
private RedisCache redisCache;
|
|
@Autowired
|
private ISwxMarketContractsService swxMarketContractsService;
|
|
@Autowired
|
private ISwxMarketOptionsService swxMarketOptionsService;
|
|
@Autowired
|
private ISwxMarketSmartService swxMarketSmartService;
|
|
@Autowired
|
private ISwxSettingsService swxSettingsService;
|
|
@Autowired
|
private ISwxContentsService swxContentsService;
|
|
@Autowired
|
private ISwxNftService swxNftService;
|
|
@Override
|
public List<SwxIndexQueryMarketVo> listMarketByType(Integer type, Integer canSamrt) {
|
QueryWrapper<SwxMarket> queryWrapper = new QueryWrapper<>();
|
if(type == null){
|
queryWrapper.lambda().eq(SwxMarket::getShowIndex, SwxConstons.NOMARL_STATUS_YES);
|
}else{
|
queryWrapper.lambda().eq(SwxMarket::getType,type);
|
}
|
if(canSamrt != null){
|
queryWrapper.lambda().eq(SwxMarket::getCanSmart,SwxConstons.NOMARL_STATUS_YES);
|
}
|
queryWrapper.lambda().orderByAsc(SwxMarket::getSortNum);
|
List<SwxMarket> list = swxMarketService.list(queryWrapper);
|
List<SwxIndexQueryMarketVo> result = new ArrayList<>();
|
for (SwxMarket item : list){
|
SwxIndexQueryMarketVo vo = new SwxIndexQueryMarketVo();
|
BeanUtils.copyProperties(item,vo);
|
vo.setZdf(redisCache.getCacheObject(vo.getCode()+"CurrZdf") == null ? BigDecimal.ZERO : new BigDecimal(redisCache.getCacheObject(vo.getCode()+"CurrZdf")+""));
|
vo.setPrice(redisCache.getCacheObject(vo.getCode()+"CurrPrice") == null ? BigDecimal.ZERO : new BigDecimal(redisCache.getCacheObject(vo.getCode()+"CurrPrice")+""));
|
vo.setHundred(redisCache.getCacheList(item.getCode()+"Hundred"));
|
result.add(vo);
|
}
|
return result;
|
}
|
|
@Override
|
public SwxIndexMarketInfoVo getMarketInfo(String id) {
|
SwxMarket market = swxMarketService.getById(id);
|
SwxIndexMarketInfoVo result = new SwxIndexMarketInfoVo();
|
BeanUtils.copyProperties(market,result);
|
|
if(market != null){
|
if (market.getCanContracts() == SwxConstons.NOMARL_STATUS_YES){
|
SwxMarketContracts contracts = swxMarketContractsService.getOne(new QueryWrapper<SwxMarketContracts>().lambda().eq(SwxMarketContracts::getMId,market.getId()));
|
result.setContractsInfo(contracts);
|
}
|
if (market.getCanOptions() == SwxConstons.NOMARL_STATUS_YES){
|
SwxMarketOptions options = swxMarketOptionsService.getOne(new QueryWrapper<SwxMarketOptions>().lambda().eq(SwxMarketOptions::getMId,market.getId()));
|
result.setOptionsInfo(options);
|
}
|
if (market.getCanSmart() == SwxConstons.NOMARL_STATUS_YES){
|
SwxMarketSmart contracts = swxMarketSmartService.getOne(new QueryWrapper<SwxMarketSmart>().lambda().eq(SwxMarketSmart::getMId,market.getId()));
|
result.setSmartInfo(contracts);
|
}
|
result.setZdf(redisCache.getCacheObject(result.getCode()+"CurrZdf") == null ? BigDecimal.ZERO : new BigDecimal(redisCache.getCacheObject(result.getCode()+"CurrZdf")+""));
|
result.setPrice(redisCache.getCacheObject(result.getCode()+"CurrPrice") == null ? BigDecimal.ZERO : new BigDecimal(redisCache.getCacheObject(result.getCode()+"CurrPrice")+""));
|
result.setHundred(redisCache.getCacheList(market.getCode()+"Hundred"));
|
}
|
return result;
|
}
|
|
@Override
|
public SwxMarketContracts getContractsByMarket(String mId) {
|
QueryWrapper<SwxMarketContracts> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(SwxMarketContracts::getMId,mId);
|
return swxMarketContractsService.getOne(queryWrapper);
|
}
|
|
@Override
|
public SwxMarketOptions getOptionsByMarket(String mId) {
|
QueryWrapper<SwxMarketOptions> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(SwxMarketOptions::getMId,mId);
|
return swxMarketOptionsService.getOne(queryWrapper);
|
}
|
|
@Override
|
public SwxMarketSmart getSmartByMarket(String mId) {
|
QueryWrapper<SwxMarketSmart> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(SwxMarketSmart::getMId,mId);
|
return swxMarketSmartService.getOne(queryWrapper);
|
}
|
|
@Override
|
public List<SyncKValueFromLdVo> getKValueByCodeAndDate(String code, String dateType) {
|
return redisCache.getCacheList(code+dateType+"KValue");
|
}
|
|
@Override
|
public SwxSettings getParamByKey(String key) {
|
return swxSettingsService.getOne(new QueryWrapper<SwxSettings>().lambda().eq(SwxSettings::getParamKey,key));
|
}
|
|
@Override
|
public List<SwxContentsVo> listContents(Integer language) {
|
QueryWrapper<SwxContents> queryWrapper = new QueryWrapper<>();
|
queryWrapper.lambda().eq(SwxContents::getStatus,SwxConstons.NOMARL_STATUS_YES);
|
queryWrapper.lambda().eq(SwxContents::getLanguage,language);
|
queryWrapper.lambda().orderByAsc(SwxContents::getSortNum);
|
List<SwxContents> list = swxContentsService.list(queryWrapper);
|
List<SwxContentsVo> result = new ArrayList<>();
|
for (SwxContents item :list){
|
SwxContentsVo vo = new SwxContentsVo();
|
BeanUtils.copyProperties(item,vo);
|
result.add(vo);
|
}
|
return result;
|
}
|
|
@Override
|
public SwxContents getContentsById(String id) {
|
return swxContentsService.getById(id);
|
}
|
|
@Override
|
public List<SwxNft> listNft() {
|
return swxNftService.list(new QueryWrapper<SwxNft>().lambda().eq(SwxNft::getStatus,SwxConstons.NOMARL_STATUS_YES));
|
}
|
}
|
