xjm
/
ssjygl-xsct-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

调整job

dev
lisai17@sina.com 2020-09-01 13:38:33 +08:00
parent 3b90eb0ca9
commit d3323126b7
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/CheckUndonOrderclusterJob.java
View File

@ -10,6 +10,7 @@ import com.jfinal.plugin.activerecord.IAtom;
import org.quartz.Job; import org.quartz.Job;
import org.quartz.JobExecutionContext; import org.quartz.JobExecutionContext;
import java.util.Calendar;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -20,11 +21,17 @@ public class CheckUndonOrderclusterJob implements Job {
@Override @Override
public void execute(JobExecutionContext jobExecutionContext) { public void execute(JobExecutionContext jobExecutionContext) {
try { try {
Calendar c = Calendar.getInstance();
c.set(Calendar.HOUR_OF_DAY, 0);
c.set(Calendar.MINUTE, 0);
c.set(Calendar.SECOND, 0);
c.set(Calendar.MILLISECOND, 0);
List<Ordercluster> undonlist = Ordercluster.dao.find( List<Ordercluster> undonlist = Ordercluster.dao.find(
"select * from ordercluster t \n" + "select * from ordercluster t \n" +
" where t.state < ? \n" + " where t.state < ? \n" +
" and t.cutoff_time < now() ", " and t.cutoff_time < ? ",
OrderStateEnum.RECEIVED.getStateid()); OrderStateEnum.RECEIVED.getStateid(), c.getTime());
if (undonlist != null && !undonlist.isEmpty()) { if (undonlist != null && !undonlist.isEmpty()) {
log.debug("完成未执行完的订单 %d", undonlist.size()); log.debug("完成未执行完的订单 %d", undonlist.size());