suzhuhong/zxjp-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加稽核脚本执行日志

Browse Source
This commit is contained in:
xiaodong.hu
2023-07-25 13:54:40 +08:00
parent d6a5630697
commit 94984cd5d3
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
coolstore-partner-service/src/main/java/com/cool/store/job/EcSyncDataJob.java
View File

@@ -7,6 +7,7 @@ import com.cool.store.mapper.HyPartnerUserInfoMapper;
import com.cool.store.sdk.ec.EcClient; import com.cool.store.sdk.ec.EcClient;
import com.cool.store.sdk.ec.request.SyncEcCustomerRequest; import com.cool.store.sdk.ec.request.SyncEcCustomerRequest;
import com.cool.store.service.EcSyncService; import com.cool.store.service.EcSyncService;
import com.cool.store.utils.StringUtil;
import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@@ -59,8 +60,18 @@ public class EcSyncDataJob {
//定时同步小程序数据到ec //定时同步小程序数据到ec
private void syncAppletToEcExecute() { private void syncAppletToEcExecute() {
// 获取参数
String param = XxlJobHelper.getJobParam();
String startTime = "";
if (StringUtil.isNotEmpty(param)) {
XxlJobHelper.log("输入参数为：" + param);
startTime = param;
} else {
startTime = getHourDayDate(-5, 0);
}
String endTime = DateUtil.now();
//获取总数 //获取总数
int size = hyPartnerUserInfoMapper.selectByHourDateCount(getHourDayDate(-5, 0), DateUtil.now()); int size = hyPartnerUserInfoMapper.selectByHourDateCount(startTime, endTime);
//执行数 //执行数
int counts = size / count; int counts = size / count;
//取余，如果大于1，就再加一 //取余，如果大于1，就再加一
@@ -68,8 +79,10 @@ public class EcSyncDataJob {
if (yu > 0) { if (yu > 0) {
counts += 1; counts += 1;
} }
XxlJobHelper.log("开始时间为：" + startTime+"，结束时间为："+endTime);
for (int i = 1; i <= counts; i++) { for (int i = 1; i <= counts; i++) {
List<SyncEcCustomerDO> list = hyPartnerUserInfoMapper.selectByHourDate(getHourDayDate(-5, 0), DateUtil.now(),count * (i - 1),count); XxlJobHelper.log("执行limit1：" + count * (i - 1)+"，执行limit2："+count);
List<SyncEcCustomerDO> list = hyPartnerUserInfoMapper.selectByHourDate(startTime, endTime,count * (i - 1),count);
SyncEcCustomerRequest syncEcCustomerRequest = new SyncEcCustomerRequest(); SyncEcCustomerRequest syncEcCustomerRequest = new SyncEcCustomerRequest();
syncEcCustomerRequest.setParameter(list); syncEcCustomerRequest.setParameter(list);
EcClient ecClient = new EcClient(); EcClient ecClient = new EcClient();