package foundation.monitor;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Stack;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
import foundation.json.IJSONProvider;
|
import foundation.json.IJSONWriter;
|
import foundation.translator.Translator;
|
|
public class Progressor implements Iterable<MessageLine>, IJSONProvider {
|
|
private static Logger logger;
|
private String taskName;
|
private Stack<Phase> phaseStack;
|
private List<MessageLine> messageList;
|
private Phase priorPhase;
|
|
private long max;
|
private long min;
|
private long step;
|
private long position;
|
private long stepBuffer;
|
private String stepMessage;
|
private boolean debug;
|
|
|
static {
|
logger = LogManager.getLogger(Progressor.class);
|
}
|
|
public Progressor(String taskName) {
|
super();
|
this.taskName = taskName;
|
}
|
|
public Progressor() {
|
messageList = new ArrayList<MessageLine>(100);
|
phaseStack = new Stack<Phase>();
|
|
max = 0;
|
min = 0;
|
step = 0;
|
position = 0;
|
stepBuffer = 0;
|
stepMessage = "0%--------0/0";
|
|
debug = true;
|
}
|
|
public void clear() {
|
priorPhase = null;
|
phaseStack.clear();
|
clearMessages();
|
clearStep();
|
}
|
|
public void clearStep() {
|
max = 0;
|
min = 0;
|
step = 0;
|
position = 0;
|
stepBuffer = 0;
|
stepMessage = "0%--------0/0";
|
}
|
|
public void stepIt() {
|
if (position < max) {
|
position++;
|
stepBuffer++;
|
|
if (stepBuffer >= step) {
|
double percent = position * 100 / max;
|
stepBuffer = 0;
|
stepMessage = Math.round(percent) + "%" + "--------" + position + "/" + max;
|
}
|
}
|
else {
|
stepMessage = "100%" + "--------" + max + "/" + max;
|
}
|
}
|
|
public void stepIt(int aStep) {
|
if (position < max) {
|
position = Math.min(position + aStep, max);
|
stepBuffer = stepBuffer + aStep;
|
|
if (stepBuffer >= step) {
|
double percent = position * 100 / max;
|
stepBuffer = 0;
|
stepMessage = Math.round(percent) + "%" + "--------" + position + "/" + max;
|
}
|
}
|
else {
|
stepMessage = "100%" + "--------" + max + "/" + max;
|
}
|
}
|
|
public long getMax() {
|
return max;
|
}
|
|
public void setMax(long max) {
|
clearStep();
|
this.max = max;
|
}
|
|
public long getMin() {
|
return min;
|
}
|
|
public void setMin(int min) {
|
this.min = min;
|
}
|
|
public String getStepMsg() {
|
return stepMessage;
|
}
|
|
public void newTask(String name) {
|
taskName = name;
|
|
clear();
|
|
Date datetime = new Date();
|
String text = "【" + name + "】 开始... " + Translator.toString(datetime);
|
|
appendLine(text);
|
}
|
|
public void endTask() {
|
String text = "【" + taskName + "】 结束";
|
appendLine(text);
|
}
|
|
public void newPhase(String code, String phaseName) {
|
Phase phase = new Phase(code, phaseName);
|
phase.setNo(priorPhase, phaseStack);
|
|
String indent = "";
|
for (int i = 0; i < phaseStack.size(); i++) {
|
indent = indent + " ";
|
}
|
|
String text = indent + phase.getNoString() + phaseName;
|
appendLine(text);
|
|
phaseStack.push(phase);
|
priorPhase = null;
|
}
|
|
public void newPhase(String phaseName) {
|
Phase phase = new Phase(null, phaseName);
|
phase.setNo(priorPhase, phaseStack);
|
|
String indent = "";
|
for (int i = 0; i < phaseStack.size(); i++) {
|
indent = indent + " ";
|
}
|
|
String text = indent + phase.getNoString() + phaseName;
|
appendLine(text);
|
|
phaseStack.push(phase);
|
priorPhase = null;
|
}
|
|
public void endPhase() {
|
clearStep();
|
priorPhase = phaseStack.pop();
|
}
|
|
public void clearMessages() {
|
messageList.clear();
|
}
|
|
public void appendLine(String message) {
|
int stackSize = phaseStack.size();
|
|
//1.
|
MessageLine line = new MessageLine(stackSize, message);
|
messageList.add(line);
|
|
//2.
|
if (debug) {
|
String indent = "";
|
for (int i = 0; i <= stackSize; i++) {
|
indent = indent + " ";
|
}
|
|
String text = indent + message;
|
logger.debug(text);
|
}
|
}
|
|
public void appendInlineMessage(String message) {
|
if (message != null) {
|
MessageLine line = null;
|
int stackSize = phaseStack.size();
|
|
if (messageList.isEmpty()) {
|
line = new MessageLine(stackSize, message);
|
messageList.add(line);
|
}
|
else {
|
int max = messageList.size() - 1;
|
line = messageList.get(max);
|
line.appendValue(message);
|
}
|
}
|
|
if (debug) {
|
logger.debug(message);
|
}
|
}
|
|
public void setStepName(String step) {
|
MessageLine line = new MessageLine(phaseStack.size(), step);
|
messageList.add(line);
|
}
|
|
public List<MessageLine> getMessageList() {
|
return messageList;
|
}
|
|
public void terminate(String error) {
|
MessageLine line = new MessageLine(phaseStack.size(), error);
|
messageList.add(line);
|
}
|
|
public Boolean isEmpty() {
|
return messageList.size() == 0;
|
}
|
|
public List<Phase> getCurrentPhases() {
|
List<Phase> resultList = new ArrayList<Phase>();
|
|
for (Phase phase : phaseStack) {
|
resultList.add(phase);
|
}
|
|
return resultList;
|
}
|
|
public String getTaskName() {
|
return taskName;
|
}
|
|
public void setStepLength(int batch_Write) {
|
// TODO Auto-generated method stub
|
|
}
|
|
public void setDebug(boolean debug) {
|
this.debug = debug;
|
}
|
|
@Override
|
public Iterator<MessageLine> iterator() {
|
return messageList.iterator();
|
}
|
|
@Override
|
public void writeJSON(IJSONWriter writer) {
|
writer.beginArray();
|
|
for (MessageLine line: messageList) {
|
writer.beginObject();
|
writer.write("placeHolder", line.getPlaceHolder());
|
writer.write("value", line.getValue());
|
writer.endObject();
|
}
|
|
writer.endArray();
|
}
|
|
}
|
