|
|
@@ -42,8 +42,26 @@ public class UpdatePanguDataTask {
|
|
|
List<PanCSLTRecord> panCSLTRecordList = panCSLTRecordService.getCustserviceLongTouchPv();
|
|
|
List<PanCSTQRecord> panCSTQRecordList = panCSTQRecordService.getCustserviceTakeQrcodePv();
|
|
|
|
|
|
- for (PanCSLTRecord panCSLTRecord : panCSLTRecordList) {
|
|
|
-// panCSLTRecord.getCustserviceId()
|
|
|
+ for (PanCSLTRecord record : panCSLTRecordList) {
|
|
|
+ Integer custserviceId = record.getCustserviceId();
|
|
|
+ Integer promoteId = record.getPromoteId();
|
|
|
+ if (custserviceId == null || promoteId == null){
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ Boolean hasRecord = this.checkHasRecord(promoteQrcodePoolRecordList,promoteId,custserviceId);
|
|
|
+ PromoteQrcodePoolRecord save = new PromoteQrcodePoolRecord();
|
|
|
+ save.setPromoteId(record.getPromoteId());
|
|
|
+ save.setCustserviceId(record.getCustserviceId());
|
|
|
+ //.记录表没有数据则新增空数据
|
|
|
+ if (hasRecord == false) {
|
|
|
+ promoteQrcodePoolRecordService.save(save);
|
|
|
+ }
|
|
|
+ //.更新扫码次数
|
|
|
+ save.setTakeQrcodePv(record.getLongTouchCnt());
|
|
|
+ promoteQrcodePoolRecordService.update(save, new QueryWrapper<PromoteQrcodePoolRecord>()
|
|
|
+ .eq("promote_id", record.getPromoteId())
|
|
|
+ .eq("custservice_id", record.getCustserviceId())
|
|
|
+ );
|
|
|
}
|
|
|
|
|
|
for (PanCSTQRecord record : panCSTQRecordList) {
|