|
@@ -2,6 +2,7 @@ package com.liangjian.dataplatform.member.service.impl;
|
|
|
|
|
|
import com.liangjian.dataplatform.member.dao.elasticsearch.UserPointLogRepository;
|
|
|
import com.liangjian.dataplatform.member.dao.secondary.WeixinUserInfoRepository;
|
|
|
+import com.liangjian.dataplatform.member.entity.genernator.SnowflakeIdWorker;
|
|
|
import com.liangjian.dataplatform.member.entity.po.elasticsearch.UserPointLog;
|
|
|
import com.liangjian.dataplatform.member.entity.po.secondary.WeixinUserInfo;
|
|
|
import com.liangjian.dataplatform.member.entity.pojo.BirdGirdFilter;
|
|
@@ -92,6 +93,10 @@ public class WeixinUserInfoQueryService implements IWeixinUserInfoQueryService,
|
|
|
success = res == 1;
|
|
|
}
|
|
|
if(success) {
|
|
|
+ Long workId = Long.valueOf(System.getenv("workerid"));
|
|
|
+ Long datacenterId = Long.valueOf(System.getenv("datacenterid"));
|
|
|
+ SnowflakeIdWorker worker = new SnowflakeIdWorker(workId,datacenterId);
|
|
|
+ log.setId(worker.nextId().toString());
|
|
|
userPointLogRepository.save(log);
|
|
|
return true;
|
|
|
} else {
|