Commit 940e04ed authored by 赵啸非's avatar 赵啸非

添加定时删除七天前的人流数据

parent f8003c14
package com.mortals.xhx.daemon.task; package com.mortals.xhx.daemon.task;
import cn.hutool.core.date.DateUtil;
import cn.hutool.http.HttpUtil; import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.TypeReference; import com.alibaba.fastjson.TypeReference;
...@@ -51,14 +52,14 @@ public class SyncSubmitAppointTaskImpl implements ITaskExcuteService { ...@@ -51,14 +52,14 @@ public class SyncSubmitAppointTaskImpl implements ITaskExcuteService {
private void syncSubmitAppoint() { private void syncSubmitAppoint() {
String registerPath = "/inter/Actuary/orderTakebusiness"; String registerPath = "/inter/Actuary/orderTakebusiness";
String url = host + registerPath; String url = host + registerPath;
AppointmentRecordsQuery appointmentRecordsQuery = new AppointmentRecordsQuery(); AppointmentRecordsQuery appointmentRecordsQuery = new AppointmentRecordsQuery();
appointmentRecordsQuery.setAppointmentStatus(AppointmentStatusEnum.未取号.getValue()); appointmentRecordsQuery.setAppointmentStatus(AppointmentStatusEnum.未取号.getValue());
appointmentRecordsQuery.setCreateTime(DateUtils.getCurrDate()); appointmentRecordsQuery.setCreateTimeStart(DateUtil.today());
appointmentRecordsQuery.setCreateTimeEnd(DateUtil.today());
List<AppointmentRecordsEntity> appointmentRecordsList = appointmentRecordsService.find(appointmentRecordsQuery); List<AppointmentRecordsEntity> appointmentRecordsList = appointmentRecordsService.find(appointmentRecordsQuery);
for (AppointmentRecordsEntity appointmentRecordsEntity : appointmentRecordsList) { for (AppointmentRecordsEntity appointmentRecordsEntity : appointmentRecordsList) {
doTakeNum(url, appointmentRecordsEntity); doTakeNum(url, appointmentRecordsEntity);
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment