Voomra/trader
Archived
0
Fork 0
Code Activity

EDCE checker fixes

Browse Source
This commit is contained in:
Mo
2015-08-08 21:36:26 +03:00
parent 0bf70f06a5
commit 4bede77b42
15 changed files with 255 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
client/src/main/java/ru/trader/EDCE.java
View File

@@ -15,6 +15,8 @@ import ru.trader.model.*;
import ru.trader.model.support.StationUpdater;
import java.io.IOException;
import java.util.LinkedList;
import java.util.List;
import java.util.Optional;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
@@ -26,6 +28,9 @@ public class EDCE {
private static ScheduledExecutorService executor;
private static ScheduledFuture<?> checker;
private final static int CACHE_LIMIT = 8;
private List<EDPacket> cache = new LinkedList<>();
private final ProfileModel profile;
private final MarketModel world;
private final StationUpdater updater;
@@ -38,18 +43,37 @@ public class EDCE {
this.world = world;
this.session = new EDSession();
this.updater = new StationUpdater(world);
interval = 5;
forceUpdate = true;
interval = 20;
}
public void setForceUpdate(boolean forceUpdate) {
this.forceUpdate = forceUpdate;
}
private void parseAndCheck(String json) {
try {
EDPacket packet = EDCEParser.parseJSON(json);
if (cache.contains(packet)){
if (!forceUpdate) {
LOG.debug("Is old packet, skip");
return;
}
} else {
cache.add(packet);
}
if (cache.size() > CACHE_LIMIT){
cache.remove(0);
}
checkCmd(packet.getCommander());
if (checkSystem(packet.getLastSystem())){
checkStarport(packet.getLastStarport());
if (profile.isDocked()) {
checkStarport(packet.getLastStarport());
} else {
profile.setSystem(ModelFabric.NONE_SYSTEM);
}
}
checkShip(packet.getShip());
forceUpdate = false;
} catch (IOException e) {
LOG.warn("Error on parse json:");
LOG.warn("{}", json);
@@ -75,9 +99,10 @@ public class EDCE {
boolean found = sModel != ModelFabric.NONE_SYSTEM;
if (!found){
LOG.warn("Not found system {}", system.getName());
sModel = world.add(system.getName(), 0,0,0);
}
profile.setSystem(sModel);
return found;
return true;
}
private void checkStarport(Starport starport){
@@ -89,17 +114,13 @@ public class EDCE {
StationModel station = sModel.get(starport.getName());
boolean found = station != ModelFabric.NONE_STATION;
if (!found){
forceUpdate = false;
LOG.info("Not found station {}, adding", starport.getName());
updater.create(sModel);
updater.setName(starport.getName());
station = updateStation(starport);
} else {
if (!profile.getStation().equals(station) || forceUpdate){
forceUpdate = false;
updater.edit(station);
updateStation(starport);
}
updater.edit(station);
updateStation(starport);
}
profile.setStation(station);
}
@@ -107,7 +128,12 @@ public class EDCE {
private StationModel updateStation(Starport starport) {
updater.setName(starport.getName());
for (Commodity commodity : starport.getCommodities()) {
Optional<ItemModel> item = world.getItem(Converter.getItemId(commodity.getId()));
String id = Converter.getItemId(commodity);
if (id.isEmpty()){
LOG.debug("{} is ignored, skip", commodity.getName());
continue;
}
Optional<ItemModel> item = world.getItem(id);
if (item.isPresent()){
Optional<StationUpdater.FakeOffer> offer = updater.getOffer(item.get());
if (offer.isPresent()){
@@ -116,7 +142,7 @@ public class EDCE {
LOG.error("Not found offer in updater, item: {}", item.get());
}
} else {
LOG.warn("Not found item id: {}, name: {}, group: {}", commodity.getId(), commodity.getName(), commodity.getCategoryname());
LOG.warn("Not found {}, id={}", commodity, id);
}
}
StationModel res = updater.commit();
@@ -125,8 +151,8 @@ public class EDCE {
}
private void fillOffers(StationUpdater.FakeOffer offer, Commodity commodity){
offer.setBprice(commodity.getBuyPrice());
offer.setSprice(commodity.getSellPrice());
offer.setSprice(commodity.getBuyPrice());
offer.setBprice(commodity.getSellPrice());
offer.setDemand(commodity.getDemand());
offer.setSupply(commodity.getStock());
}
@@ -142,8 +168,8 @@ public class EDCE {
public void run(){
if (executor == null) executor = Executors.newSingleThreadScheduledExecutor();
LOG.debug("Start EDCE checker each {} sec", interval);
checker = executor.scheduleAtFixedRate(new EDCEChecker(), interval, interval, TimeUnit.SECONDS);
LOG.info("Start EDCE checker each {} sec", interval);
checker = executor.scheduleAtFixedRate(new EDCEChecker(), 1, interval, TimeUnit.SECONDS);
}
public void shutdown() throws IOException {
@@ -169,7 +195,7 @@ public class EDCE {
LOG.trace("Read profile from ED");
session.readProfile(EDCE.this::parseAndCheck);
}
if (session.getLastStatus() == ED_SESSION_STATUS.LOGIN_REQUIRED) {
if (session.getLastStatus() == ED_SESSION_STATUS.LOGIN_REQUIRED || session.getLastStatus() == ED_SESSION_STATUS.LOGIN_FAILED) {
waiting = true;
Platform.runLater(() -> {
Optional<Pair<String, String>> login = Screeners.showLogin();
@@ -194,6 +220,17 @@ public class EDCE {
}
);
}
if (session.getLastStatus() == ED_SESSION_STATUS.VERIFICATION_REQUIRED){
waiting = true;
Platform.runLater(() -> {
LOG.trace("Verification required, send request");
Optional<String> code = Screeners.showVerifyCodeDialog();
if (code.isPresent()) {
session.submitVerifyCode(code.get());
}
waiting = false;
});
}
} catch (Exception ex){
LOG.error("",ex);
}

32
client/src/main/java/ru/trader/controllers/OffersController.java
View File

@@ -3,17 +3,21 @@ package ru.trader.controllers;
import javafx.application.Platform;
import javafx.collections.FXCollections;
import javafx.event.ActionEvent;
import javafx.fxml.FXML;
import javafx.geometry.Insets;
import javafx.scene.control.*;
import javafx.scene.input.MouseButton;
import org.controlsfx.control.SegmentedButton;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javafx.fxml.FXML;
import ru.trader.core.SERVICE_TYPE;
import ru.trader.model.*;
import ru.trader.model.MarketModel;
import ru.trader.model.OfferModel;
import ru.trader.model.StationModel;
import ru.trader.model.SystemModel;
import ru.trader.model.support.BindingsHelper;
import ru.trader.model.support.ChangeMarketListener;
import ru.trader.view.support.ViewUtils;
import java.util.List;
@@ -220,37 +224,41 @@ public class OffersController {
@Override
public void priceChange(OfferModel offer, double oldPrice, double newPrice) {
if (station.hasBuy(offer.getItem()) || station.hasSell(offer.getItem())){
sort();
ViewUtils.doFX(OffersController.this::sort);
}
}
@Override
public void add(OfferModel offer) {
if (offer.getStation().equals(station)){
addOffer(offer);
ViewUtils.doFX(()-> addOffer(offer));
}
}
@Override
public void add(StationModel station) {
stationsBar.getButtons().add(buildStationNode(station));
refresh();
sort();
ViewUtils.doFX(() -> {
stationsBar.getButtons().add(buildStationNode(station));
refresh();
sort();
});
}
@Override
public void remove(OfferModel offer) {
if (offer.getStation().equals(station)){
removeOffer(offer);
ViewUtils.doFX(() -> removeOffer(offer));
}
}
@Override
public void remove(StationModel station) {
stationsBar.getToggleGroup().getSelectedToggle().setSelected(false);
stationsBar.getButtons().removeIf(b -> b.getUserData().equals(station));
refresh();
sort();
ViewUtils.doFX(() -> {
stationsBar.getToggleGroup().getSelectedToggle().setSelected(false);
stationsBar.getButtons().removeIf(b -> b.getUserData().equals(station));
refresh();
sort();
});
}
}

2
client/src/main/java/ru/trader/model/ProfileModel.java
View File

@@ -131,7 +131,7 @@ public class ProfileModel {
this.station.set(station);
}
public boolean getDocked() {
public boolean isDocked() {
return docked.get();
}