andyjk15/db-gateway
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[24.02.20] Reset replicas, changed to use LocalDateTime

Browse Source
This commit is contained in:
andyjk15 2020-02-24 17:42:37 +00:00
parent 1d4a0d12a7
commit ecb4b16be7
5 changed files with 28 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
configuration/kubernetes/deployment.yaml
View File

@ -6,7 +6,7 @@ metadata:
name: RESOURCE_NAME
namespace: default
spec:
replicas: 2
replicas: 0
selector:
matchLabels:
app: RESOURCE_NAME

4
src/main/java/cryptosky/me/graphql/pricing/models/entities/CryptoPriceModel.java
View File

@ -3,7 +3,7 @@ package cryptosky.me.graphql.pricing.models.entities;
import lombok.*;
import javax.persistence.*;
import java.util.Date;
import java.time.LocalDateTime;
@AllArgsConstructor
@NoArgsConstructor
@ -17,7 +17,7 @@ public class CryptoPriceModel {
private int id;
@Column(name = "timestamp", nullable = false)
private Date timestamp;
private LocalDateTime timestamp;
@Column(name = "symbol", nullable = false)
private String type;

4
src/main/java/cryptosky/me/graphql/pricing/mutations/BtcPriceMutation.java
View File

@ -7,15 +7,13 @@ import org.springframework.stereotype.Component;
import cryptosky.me.graphql.pricing.service.BtcPriceService;
import java.util.Date;
@Component
public class BtcPriceMutation implements GraphQLMutationResolver {
@Autowired
private BtcPriceService btcPriceService;
public BtcPriceModel createBtc(final Date createdDate, final String type, final float av_price,
public BtcPriceModel createBtc(final String createdDate, final String type, final float av_price,
final float h_price, final float l_price, final float o_price,
final float c_price, final float volume ) {
return this.btcPriceService.createBtc(createdDate, type, av_price, h_price, l_price, o_price, c_price, volume);

14
src/main/java/cryptosky/me/graphql/pricing/queries/BtcPriceQuery.java
View File

@ -27,11 +27,11 @@ public class BtcPriceQuery implements GraphQLQueryResolver {
return this.btcPriceService.getLatest();
}
// public Optional<BtcPriceModel> getPriceForCreatedDate( final String createdDate ) {
// return this.btcPriceService.getPriceForCreatedDate(createdDate);
// }
//
// public List<BtcPriceModel> getPriceBetweenDates(final String startDate, final String endDate ) {
// return this.btcPriceService.getPriceBetweenDates(startDate, endDate);
// }
public Optional<BtcPriceModel> getPriceForCreatedDate( final String createdDate ) {
return this.btcPriceService.getPriceForCreatedDate(createdDate);
}
public List<BtcPriceModel> getPriceBetweenDates(final String startDate, final String endDate ) {
return this.btcPriceService.getPriceBetweenDates(startDate, endDate);
}
}

33
src/main/java/cryptosky/me/graphql/pricing/service/BtcPriceService.java
View File

@ -5,11 +5,12 @@ import cryptosky.me.graphql.pricing.models.repositories.BtcPriceRepository;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.Date;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
import java.time.LocalDateTime;
import static cryptosky.me.helpers.Utils.format;
@Service
@ -22,12 +23,12 @@ public class BtcPriceService {
}
@Transactional
public BtcPriceModel createBtc(final Date createdDate, final String type, final float av_price,
public BtcPriceModel createBtc(final String createdDate, final String type, final float av_price,
final float h_price, final float l_price, final float o_price,
final float c_price, final float volume ) {
final BtcPriceModel btcPrice = new BtcPriceModel();
btcPrice.setTimestamp(createdDate);
btcPrice.setTimestamp(LocalDateTime.parse((createdDate)));
btcPrice.setType(type);
btcPrice.setAverage_price(av_price);
btcPrice.setHigh_price(h_price);
@ -59,20 +60,20 @@ public class BtcPriceService {
return this.btcPriceRepository.findAll().stream().findFirst();
}
// @Transactional(readOnly = true)
// public Optional<BtcPriceModel> getPriceForCreatedDate( final String createdDate ) {
// return this.btcPriceRepository.findAll().stream()
// .filter(createdDateList -> createdDateList.getTimestamp().equals(format(createdDate)))
// .findFirst();
// }
@Transactional(readOnly = true)
public Optional<BtcPriceModel> getPriceForCreatedDate( final String createdDate ) {
return this.btcPriceRepository.findAll().stream()
.filter(createdDateList -> createdDateList.getTimestamp().equals(format(createdDate)))
.findFirst();
}
// @Transactional(readOnly = true)
// public List<BtcPriceModel> getPriceBetweenDates( final String startDate, final String endDate ) {
// return this.btcPriceRepository.findAll().stream()
// .filter(createdDateList -> format(createdDateList.getTimestamp()).isBefore(format(endDate)))
// .filter(createdDateList -> format(createdDateList.getTimestamp()).isAfter(format(startDate)))
// .collect(Collectors.toList());
// }
@Transactional(readOnly = true)
public List<BtcPriceModel> getPriceBetweenDates( final String startDate, final String endDate ) {
return this.btcPriceRepository.findAll().stream()
.filter(createdDateList -> format(createdDateList.getTimestamp().toString()).isBefore(format(endDate)))
.filter(createdDateList -> format(createdDateList.getTimestamp().toString()).isAfter(format(startDate)))
.collect(Collectors.toList());
}
// @Transactional(readOnly = true)
// public List<BtcPriceModel> getAllLatest() {