package com.nq.service.impl;
|
|
|
import com.github.pagehelper.PageHelper;
|
|
import com.github.pagehelper.PageInfo;
|
|
import com.google.common.collect.Lists;
|
|
import com.nq.common.ServerResponse;
|
|
import com.nq.dao.StockCoinMapper;
|
|
import com.nq.pojo.StockCoin;
|
|
import com.nq.service.IStockCoinService;
|
|
import com.nq.service.IStockFuturesService;
|
|
import com.nq.vo.foreigncurrency.ExchangeVO;
|
|
import com.nq.vo.stockfutures.CoinAdminListVO;
|
|
import java.math.BigDecimal;
|
import java.util.Date;
|
|
import java.util.List;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
|
@Service("iStockCoinService")
|
|
public class StockCoinServiceImpl implements IStockCoinService {
|
|
@Autowired
|
StockCoinMapper stockCoinMapper;
|
|
@Autowired
|
IStockFuturesService iStockFuturesService;
|
|
|
public ServerResponse<PageInfo> listByAdmin(String coinName, String coinCode, int pageNum, int pageSize) {
|
|
PageHelper.startPage(pageNum, pageSize);
|
|
List<StockCoin> stockCoins = this.stockCoinMapper.listByAdmin(coinName, coinCode);
|
|
|
List<CoinAdminListVO> coinAdminListVOS = Lists.newArrayList();
|
|
for (StockCoin stockCoin : stockCoins) {
|
|
CoinAdminListVO coinAdminListVO = assembleCoinAdminListVO(stockCoin);
|
|
coinAdminListVOS.add(coinAdminListVO);
|
|
}
|
|
|
PageInfo pageInfo = new PageInfo(stockCoins);
|
|
pageInfo.setList(coinAdminListVOS);
|
|
|
return ServerResponse.createBySuccess(pageInfo);
|
|
}
|
|
private CoinAdminListVO assembleCoinAdminListVO(StockCoin stockCoin) {
|
|
CoinAdminListVO coinAdminListVO = new CoinAdminListVO();
|
|
|
coinAdminListVO.setId(stockCoin.getId());
|
|
coinAdminListVO.setCoinName(stockCoin.getCoinName());
|
|
coinAdminListVO.setCoinCode(stockCoin.getCoinCode());
|
|
coinAdminListVO.setCoinGid(stockCoin.getCoinGid());
|
|
coinAdminListVO.setDynamicRate(stockCoin.getDynamicRate());
|
|
coinAdminListVO.setDefaultRate(stockCoin.getDefaultRate());
|
|
coinAdminListVO.setIsUse(stockCoin.getIsUse());
|
|
coinAdminListVO.setAddTime(stockCoin.getAddTime());
|
|
coinAdminListVO.setTDesc(stockCoin.gettDesc());
|
|
|
String nowPrice = "";
|
|
ExchangeVO exchangeVO = null;
|
|
|
ServerResponse serverResponse = this.iStockFuturesService.queryExchangeVO(stockCoin.getCoinCode());
|
|
if (serverResponse.isSuccess()) {
|
|
exchangeVO = (ExchangeVO) serverResponse.getData();
|
|
if (exchangeVO != null) {
|
|
nowPrice = exchangeVO.getNowPrice();
|
|
}
|
|
}
|
|
coinAdminListVO.setNowPrice(nowPrice);
|
|
/*查询新浪实时汇率*/
|
ServerResponse serverResponse1 = iStockFuturesService.getExchangeRate(coinAdminListVO.getCoinCode());
|
if (serverResponse1.isSuccess()) {
|
coinAdminListVO.setDefaultRate((BigDecimal) serverResponse1.getData());
|
}
|
|
|
return coinAdminListVO;
|
|
}
|
|
|
public ServerResponse add(StockCoin stockCoin) {
|
|
if (StringUtils.isBlank(stockCoin.getCoinName()) ||
|
|
StringUtils.isBlank(stockCoin.getCoinCode()) ||
|
|
StringUtils.isBlank(stockCoin.getCoinGid())) {
|
|
return ServerResponse.createByErrorMsg("参数不能为空");
|
|
}
|
|
|
StockCoin coinName = this.stockCoinMapper.selectCoinByName(stockCoin.getCoinName());
|
|
if (coinName != null) {
|
|
return ServerResponse.createByErrorMsg("名称不能重复");
|
|
}
|
|
StockCoin coinCode = this.stockCoinMapper.selectCoinByCode(stockCoin.getCoinCode());
|
|
if (coinCode != null) {
|
|
return ServerResponse.createByErrorMsg("代码不能重复");
|
|
}
|
|
StockCoin coinGid = this.stockCoinMapper.selectCoinByCode(stockCoin.getCoinGid());
|
|
if (coinGid != null) {
|
|
return ServerResponse.createByErrorMsg("gid不能重复");
|
|
}
|
|
|
stockCoin.setAddTime(new Date());
|
|
|
int insertCount = this.stockCoinMapper.insert(stockCoin);
|
|
if (insertCount > 0) {
|
|
return ServerResponse.createBySuccessMsg("添加成功");
|
|
}
|
|
return ServerResponse.createByErrorMsg("添加失败");
|
|
}
|
|
|
public ServerResponse update(StockCoin stockCoin) {
|
|
if (stockCoin.getId() == null) {
|
|
return ServerResponse.createByErrorMsg("修改id不能为空");
|
|
}
|
|
|
StockCoin dbCoin = this.stockCoinMapper.selectByPrimaryKey(stockCoin.getId());
|
|
if (dbCoin == null) {
|
|
return ServerResponse.createByErrorMsg("基币不存在");
|
|
}
|
|
|
if (stockCoin.getCoinName() != null) {
|
|
StockCoin coinName = this.stockCoinMapper.selectCoinByName(stockCoin.getCoinName());
|
|
if (coinName != null && coinName.getId() != dbCoin.getId()) {
|
|
return ServerResponse.createByErrorMsg("名称已存在");
|
|
}
|
|
}
|
|
if (stockCoin.getCoinCode() != null) {
|
|
StockCoin coinCode = this.stockCoinMapper.selectCoinByCode(stockCoin.getCoinCode());
|
|
if (coinCode != null && coinCode.getId() != dbCoin.getId()) {
|
|
return ServerResponse.createByErrorMsg("代码已存在");
|
|
}
|
|
}
|
|
if (stockCoin.getCoinGid() != null) {
|
|
StockCoin coinGid = this.stockCoinMapper.selectCoinByCode(stockCoin.getCoinGid());
|
|
if (coinGid != null && coinGid.getId() != dbCoin.getId()) {
|
|
return ServerResponse.createByErrorMsg("gid已存在");
|
|
}
|
|
}
|
|
|
int updateCount = this.stockCoinMapper.updateByPrimaryKeySelective(stockCoin);
|
|
if (updateCount > 0) {
|
|
return ServerResponse.createBySuccessMsg("修改成功");
|
|
}
|
|
return ServerResponse.createByErrorMsg("修改失败");
|
|
}
|
|
|
public StockCoin selectCoinByCode(String coinCode) {
|
return this.stockCoinMapper.selectCoinByCode(coinCode);
|
}
|
|
|
public List getSelectCoin() {
|
return this.stockCoinMapper.getSelectCoin();
|
}
|
|
}
|
