|
@@ -131,7 +131,7 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
|
|
|
|
|
|
|
|
|
// 先同步有效的数据
|
|
|
- if (CollectionUtils.isNotEmpty(recs)){
|
|
|
+ if (CollectionUtils.isNotEmpty(sfzs)){
|
|
|
recs = itfTblWangdianWxgDownloadService.lambdaQuery()
|
|
|
.in(ItfTblWangdianWxgDownload::getSfzen,sfzs).list();
|
|
|
// 新增或修改师傅数据 worker:师傅信息表
|
|
@@ -155,7 +155,7 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
|
|
|
// 有效
|
|
|
recs = itfTblWangdianWxgDownloadService.lambdaQuery()
|
|
|
.select(ItfTblWangdianWxgDownload::getSfzen)
|
|
|
- // .eq(ItfTblWangdianWxgDownload::getSfzen,"421022197809157619")// 测试用
|
|
|
+ .eq(ItfTblWangdianWxgDownload::getSfzen,"421022197809157619")// 测试用
|
|
|
.ne(ItfTblWangdianWxgDownload::getFlag, "无效").list();
|
|
|
recs.stream().forEach(wba -> {
|
|
|
recins.add(wba.getSfzen());
|
|
@@ -166,7 +166,7 @@ public class GLPPGFWebsitWorkerServiceImpl implements GLPPGFWebsitWorkerService
|
|
|
//无效
|
|
|
recs = itfTblWangdianWxgDownloadService.lambdaQuery()
|
|
|
.select(ItfTblWangdianWxgDownload::getSfzen)
|
|
|
- // .eq(ItfTblWangdianWxgDownload::getSfzen,"421022197809157619")// 测试用
|
|
|
+ .eq(ItfTblWangdianWxgDownload::getSfzen,"421022197809157619")// 测试用
|
|
|
.eq(ItfTblWangdianWxgDownload::getFlag, "无效").list();
|
|
|
recs.stream().forEach(wba -> {
|
|
|
recouts.add(wba.getSfzen());
|