yangjun
/
dbsd_kczx_java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

2023年6月1日 修改政务大厅同步方法

This commit is contained in:
bai 2023-06-01 01:08:02 +08:00
parent 9628774517
commit 3ecbf71bee
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/SyncZwdtEvaluation.java
View File

@ -1,5 +1,6 @@
package org.jeecg.modules.kc.grab.SynchronizationService; package org.jeecg.modules.kc.grab.SynchronizationService;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.google.common.collect.Maps; import com.google.common.collect.Maps;
@ -173,20 +174,30 @@ public class SyncZwdtEvaluation extends BaseSync {
public void washOldData(Map<String, Object> param) { public void washOldData(Map<String, Object> param) {
DateTime now = DateUtil.date();
if(param != null){
if(StringUtils.isNotBlank((String)param.get("nowDay"))){
now = DateUtil.parse((String)param.get("nowDay"), "yyyy-MM-dd");
}
}
int source = 2; int source = 2;
//删除旧数据 //删除旧数据
QueryWrapper<KcEvaluation> kcEvaluation = new QueryWrapper<>(); QueryWrapper<KcEvaluation> kcEvaluation = new QueryWrapper<>();
kcEvaluation.eq("source",source); kcEvaluation.eq("source",source);
kcEvaluation.eq("up_timestamp",now);
kcEvaluationService.remove(kcEvaluation); kcEvaluationService.remove(kcEvaluation);
QueryWrapper<KcEvaluations> kcEvaluations = new QueryWrapper<>(); QueryWrapper<KcEvaluations> kcEvaluations = new QueryWrapper<>();
kcEvaluations.eq("source",source); kcEvaluations.eq("source",source);
kcEvaluations.eq("up_timestamp",now);
kcEvaluationsService.remove(kcEvaluations); kcEvaluationsService.remove(kcEvaluations);
//查询数据 //查询数据
List<Xxhbbkjxtkpj> inDataList = xxhbbkjxtkpjService.list(); QueryWrapper inQw = new QueryWrapper<>();
inQw.eq("timestamps",now);
List<Xxhbbkjxtkpj> inDataList = xxhbbkjxtkpjService.list(inQw);
List<KcEvaluation> saveMainList = Lists.newArrayList(); List<KcEvaluation> saveMainList = Lists.newArrayList();
List<KcEvaluations> saveChildList = Lists.newArrayList(); List<KcEvaluations> saveChildList = Lists.newArrayList();