浏览代码

是否延后回传都直接记录,只看是否直接回传.

chenbiao 2 年之前
父节点
当前提交
96c2e048e0
共有 1 个文件被更改,包括 15 次插入15 次删除
  1. 15 15
      netflix-service/src/main/java/com/cyksj/service/corp/impl/CorpEventActionServiceImpl.java

+ 15 - 15
netflix-service/src/main/java/com/cyksj/service/corp/impl/CorpEventActionServiceImpl.java

@@ -620,22 +620,22 @@ public class CorpEventActionServiceImpl implements CorpEventActionService {
 						postData(callback, corpCustomerAcquisitionLinkPopularize.getAddEvent());
 					}
 				}
-
-				if (corpCustomerAcquisitionLinkPopularize.getDelayedPost()) {
-					CorpCustomerAcquistionCallback corpCustomerAcquistionCallback =
-							corpCustomerAcquistionCallbackMapper.selectOne(Wrappers.lambdaQuery(CorpCustomerAcquistionCallback.class).eq(CorpCustomerAcquistionCallback::getCallback, callback).eq(CorpCustomerAcquistionCallback::getUnionId, unionId));
-					if (corpCustomerAcquistionCallback == null) {
-						corpCustomerAcquistionCallback = new CorpCustomerAcquistionCallback();
-					}
-					corpCustomerAcquistionCallback.setCallback(callback);
-					corpCustomerAcquistionCallback.setEvent(corpCustomerAcquisitionLinkPopularize.getEvent());
-					corpCustomerAcquistionCallback.setUnionId(unionId);
-					if (corpCustomerAcquistionCallback.getId() != null) {
-						corpCustomerAcquistionCallbackMapper.updateById(corpCustomerAcquistionCallback);
-					} else {
-						corpCustomerAcquistionCallbackMapper.insert(corpCustomerAcquistionCallback);
-					}
+				// 是否延后回传都记录,只看是否直接回传.
+				CorpCustomerAcquistionCallback corpCustomerAcquistionCallback =
+						corpCustomerAcquistionCallbackMapper.selectOne(Wrappers.lambdaQuery(CorpCustomerAcquistionCallback.class).eq(CorpCustomerAcquistionCallback::getCallback, callback).eq(CorpCustomerAcquistionCallback::getUnionId, unionId));
+				if (corpCustomerAcquistionCallback == null) {
+					corpCustomerAcquistionCallback = new CorpCustomerAcquistionCallback();
 				}
+				corpCustomerAcquistionCallback.setCallback(callback);
+				corpCustomerAcquistionCallback.setEvent(corpCustomerAcquisitionLinkPopularize.getEvent());
+				corpCustomerAcquistionCallback.setUnionId(unionId);
+				corpCustomerAcquistionCallback.setStatus(!corpCustomerAcquisitionLinkPopularize.getDelayedPost());
+				if (corpCustomerAcquistionCallback.getId() != null) {
+					corpCustomerAcquistionCallbackMapper.updateById(corpCustomerAcquistionCallback);
+				} else {
+					corpCustomerAcquistionCallbackMapper.insert(corpCustomerAcquistionCallback);
+				}
+
 			}
 		}
 		return null;