package com.yami.trading.service.dz.impl;
|
|
|
import cn.hutool.core.date.DatePattern;
|
import cn.hutool.core.date.DateUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.yami.trading.bean.dz.StockDz;
|
import com.yami.trading.common.domain.Result;
|
import com.yami.trading.dao.dz.StockDzMapper;
|
import com.yami.trading.service.dz.StockDzService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.math.BigDecimal;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
@Slf4j
|
public class StockDzServiceImpl extends ServiceImpl<StockDzMapper, StockDz> implements StockDzService {
|
|
@Resource
|
private StockDzMapper stockDzMapper;
|
|
@Override
|
public Result getDzList(int pageNum, int pageSize, String orderBy, String keyWords, HttpServletRequest request) {
|
try {
|
String formatDate = DateUtil.format(new Date(), DatePattern.NORM_DATETIME_PATTERN);
|
Page page = new Page(pageNum, pageSize);
|
stockDzMapper.findStockTypeDz(page,orderBy,keyWords,formatDate);
|
return Result.succeed(page);
|
} catch (Exception e) {
|
log.error(e.getMessage());
|
}
|
return Result.failed("获取失败");
|
}
|
|
@Override
|
public Result addByAdmin(String stockCode, String stockNum, String password, String startTime, String endTime, String discount,Integer period,String nowPrice,Integer switchType) {
|
if (stockCode == null || stockCode.isEmpty() ||stockNum == null || stockNum.isEmpty() || startTime == null || startTime.isEmpty() ||endTime == null || endTime.isEmpty() || period == null || nowPrice == null){
|
return Result.failed("参数不能为空");
|
}
|
|
Long count = stockDzMapper.selectCount(new LambdaQueryWrapper<StockDz>()
|
.eq(StockDz::getStockCode,stockCode));
|
if(count > 0){
|
return Result.failed("股票代码已存在");
|
}
|
|
|
|
StockDz stockDz = new StockDz();
|
/*stockDz.setStockName(stock.getStockName());
|
stockDz.setStockCode(stock.getStockCode());
|
stockDz.setStockType(stock.getStockType());
|
stockDz.setStockGid(stock.getStockGid());
|
stockDz.setStockSpell(stock.getStockSpell());
|
stockDz.setIsLock(stock.getIsLock());
|
stockDz.setSpreadRate(stock.getSpreadRate());*/
|
|
stockDz.setStockCode(stockCode);
|
stockDz.setIsShow(1);
|
stockDz.setAddTime(new Date());
|
stockDz.setIncreaseRatio(BigDecimal.ZERO);
|
stockDz.setStockNum(Integer.valueOf(stockNum));
|
stockDz.setPassword(password);
|
stockDz.setStartTime(DateUtil.parseDateTime(startTime));
|
stockDz.setEndTime(DateUtil.parseDateTime(endTime));
|
// stockDz.setDiscount(new BigDecimal(discount));
|
stockDz.setPeriod(period);
|
stockDz.setSwitchType(switchType);
|
stockDz.setNowPrice(new BigDecimal(nowPrice));
|
if (save(stockDz)) {
|
return Result.succeed("添加成功");
|
}
|
return Result.failed("添加失败");
|
}
|
|
@Override
|
public Result getDzListByAdmin(int pageNum, int pageSize, String Keywords) {
|
try {
|
Page page = new Page(pageNum, pageSize);
|
stockDzMapper.getDzListByAdmin(page, Keywords);
|
return Result.succeed(page);
|
} catch (Exception e) {
|
log.error(e.getMessage());
|
}
|
return Result.failed("获取失败");
|
}
|
|
@Override
|
public Result updByAdmin(StockDz model) {
|
Long count = stockDzMapper.selectCount(new LambdaQueryWrapper<StockDz>()
|
.eq(StockDz::getStockCode, model.getStockCode())
|
.ne(StockDz::getUuid, model.getUuid()));
|
if(count > 0){
|
return Result.failed("股票代码已存在");
|
}
|
return stockDzMapper.updateById(model) > 0 ? Result.succeed("修改成功") : Result.failed("修改失败");
|
}
|
|
@Override
|
public Result deleteByAdmin(String id) {
|
int res = stockDzMapper.deleteById(id);
|
if (res > 0) {
|
return Result.succeed();
|
}
|
return Result.failed("删除失败");
|
}
|
|
|
|
}
|
