Skip to content

Commit 38a2a87

Browse files
author
xlinliu
committed
fix bug of msg.receive.use.rundate
1 parent ce661c9 commit 38a2a87

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

dss-appconn/appconns/dss-eventchecker-appconn/src/main/java/com/webank/wedatasphere/dss/appconn/eventchecker/service/DefaultEventcheckReceiver.java

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -78,17 +78,17 @@ private String[] createExecuteType(int jobId, Properties props, Logger log,Strin
7878
Boolean useRunDateFlag = receiveTodayFlag && (null != useRunDate && "true".equalsIgnoreCase(useRunDate.trim()));
7979
String[] executeType = null;
8080
try {
81-
if(receiveTodayFlag){
82-
if(afterSendFlag){
83-
executeType = new String[]{nowStartTime,todayEndTime,lastMsgId,useRunDateFlag.toString(),runDate};
84-
}else{
85-
executeType = new String[]{todayStartTime,todayEndTime,lastMsgId,useRunDateFlag.toString(),runDate};
81+
if (receiveTodayFlag && !useRunDateFlag) {
82+
if (afterSendFlag) {
83+
executeType = new String[]{nowStartTime, todayEndTime, lastMsgId, useRunDateFlag.toString(), runDate};
84+
} else {
85+
executeType = new String[]{todayStartTime, todayEndTime, lastMsgId, useRunDateFlag.toString(), runDate};
8686
}
87-
}else{
88-
if(afterSendFlag){
89-
executeType = new String[]{nowStartTime,allEndTime,lastMsgId,useRunDateFlag.toString(),runDate};
90-
}else{
91-
executeType = new String[]{allStartTime,allEndTime,lastMsgId,useRunDateFlag.toString(),runDate};
87+
} else {
88+
if (afterSendFlag) {
89+
executeType = new String[]{nowStartTime, allEndTime, lastMsgId, useRunDateFlag.toString(), runDate};
90+
} else {
91+
executeType = new String[]{allStartTime, allEndTime, lastMsgId, useRunDateFlag.toString(), runDate};
9292
}
9393
}
9494
}catch(Exception e){

0 commit comments

Comments
 (0)