命名重构

master
xuxueli 3 months ago
parent 6ef78c62b5
commit 3ff307180d

@ -9,15 +9,15 @@ public class CallbackRequest implements Serializable {
private static final long serialVersionUID = 42L; private static final long serialVersionUID = 42L;
private long logId; private long logId;
private long logDateTim; private long logDateTime;
private int handleCode; private int handleCode;
private String handleMsg; private String handleMsg;
public CallbackRequest(){} public CallbackRequest(){}
public CallbackRequest(long logId, long logDateTim, int handleCode, String handleMsg) { public CallbackRequest(long logId, long logDateTime, int handleCode, String handleMsg) {
this.logId = logId; this.logId = logId;
this.logDateTim = logDateTim; this.logDateTime = logDateTime;
this.handleCode = handleCode; this.handleCode = handleCode;
this.handleMsg = handleMsg; this.handleMsg = handleMsg;
} }
@ -30,12 +30,12 @@ public class CallbackRequest implements Serializable {
this.logId = logId; this.logId = logId;
} }
public long getLogDateTim() { public long getLogDateTime() {
return logDateTim; return logDateTime;
} }
public void setLogDateTim(long logDateTim) { public void setLogDateTime(long logDateTime) {
this.logDateTim = logDateTim; this.logDateTime = logDateTime;
} }
public int getHandleCode() { public int getHandleCode() {
@ -56,9 +56,9 @@ public class CallbackRequest implements Serializable {
@Override @Override
public String toString() { public String toString() {
return "HandleCallbackParam{" + return "CallbackRequest{" +
"logId=" + logId + "logId=" + logId +
", logDateTim=" + logDateTim + ", logDateTime=" + logDateTime +
", handleCode=" + handleCode + ", handleCode=" + handleCode +
", handleMsg='" + handleMsg + '\'' + ", handleMsg='" + handleMsg + '\'' +
'}'; '}';

@ -45,7 +45,7 @@ public class RegistryRequest implements Serializable {
@Override @Override
public String toString() { public String toString() {
return "RegistryParam{" + return "RegistryRequest{" +
"registryGroup='" + registryGroup + '\'' + "registryGroup='" + registryGroup + '\'' +
", registryKey='" + registryKey + '\'' + ", registryKey='" + registryKey + '\'' +
", registryValue='" + registryValue + '\'' + ", registryValue='" + registryValue + '\'' +

@ -10,22 +10,22 @@ public class LogRequest implements Serializable {
public LogRequest() { public LogRequest() {
} }
public LogRequest(long logDateTim, long logId, int fromLineNum) { public LogRequest(long logDateTime, long logId, int fromLineNum) {
this.logDateTim = logDateTim; this.logDateTime = logDateTime;
this.logId = logId; this.logId = logId;
this.fromLineNum = fromLineNum; this.fromLineNum = fromLineNum;
} }
private long logDateTim; private long logDateTime;
private long logId; private long logId;
private int fromLineNum; private int fromLineNum;
public long getLogDateTim() { public long getLogDateTime() {
return logDateTim; return logDateTime;
} }
public void setLogDateTim(long logDateTim) { public void setLogDateTime(long logDateTime) {
this.logDateTim = logDateTim; this.logDateTime = logDateTime;
} }
public long getLogId() { public long getLogId() {

@ -8,6 +8,11 @@ import java.io.Serializable;
public class LogResult implements Serializable { public class LogResult implements Serializable {
private static final long serialVersionUID = 42L; private static final long serialVersionUID = 42L;
private int fromLineNum;
private int toLineNum;
private String logContent;
private boolean isEnd;
public LogResult() { public LogResult() {
} }
public LogResult(int fromLineNum, int toLineNum, String logContent, boolean isEnd) { public LogResult(int fromLineNum, int toLineNum, String logContent, boolean isEnd) {
@ -17,11 +22,6 @@ public class LogResult implements Serializable {
this.isEnd = isEnd; this.isEnd = isEnd;
} }
private int fromLineNum;
private int toLineNum;
private String logContent;
private boolean isEnd;
public int getFromLineNum() { public int getFromLineNum() {
return fromLineNum; return fromLineNum;
} }

@ -130,7 +130,7 @@ public class TriggerRequest implements Serializable{
@Override @Override
public String toString() { public String toString() {
return "TriggerParam{" + return "TriggerRequest{" +
"jobId=" + jobId + "jobId=" + jobId +
", executorHandler='" + executorHandler + '\'' + ", executorHandler='" + executorHandler + '\'' +
", executorParams='" + executorParams + '\'' + ", executorParams='" + executorParams + '\'' +

@ -174,7 +174,7 @@ public class ExecutorBizImpl implements ExecutorBiz {
@Override @Override
public Response<LogResult> log(LogRequest logRequest) { public Response<LogResult> log(LogRequest logRequest) {
// log filename: logPath/yyyy-MM-dd/9999.log // log filename: logPath/yyyy-MM-dd/9999.log
String logFileName = XxlJobFileAppender.makeLogFileName(new Date(logRequest.getLogDateTim()), logRequest.getLogId()); String logFileName = XxlJobFileAppender.makeLogFileName(new Date(logRequest.getLogDateTime()), logRequest.getLogId());
LogResult logResult = XxlJobFileAppender.readLog(logFileName, logRequest.getFromLineNum()); LogResult logResult = XxlJobFileAppender.readLog(logFileName, logRequest.getFromLineNum());
return Response.ofSuccess(logResult); return Response.ofSuccess(logResult);

@ -183,7 +183,7 @@ public class TriggerCallbackThreadHelper {
*/ */
private void appendCallbackResult(List<CallbackRequest> callbackParamList, String logContent){ private void appendCallbackResult(List<CallbackRequest> callbackParamList, String logContent){
for (CallbackRequest callbackParam: callbackParamList) { for (CallbackRequest callbackParam: callbackParamList) {
String logFileName = XxlJobFileAppender.makeLogFileName(new Date(callbackParam.getLogDateTim()), callbackParam.getLogId()); String logFileName = XxlJobFileAppender.makeLogFileName(new Date(callbackParam.getLogDateTime()), callbackParam.getLogId());
XxlJobContext.setXxlJobContext(new XxlJobContext( XxlJobContext.setXxlJobContext(new XxlJobContext(
-1, -1,
null, null,

Loading…
Cancel
Save