fix 加粉回传取消异步

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

@@ -723,9 +723,7 @@ public class CorpEventActionServiceImpl implements CorpEventActionService {
 		//加粉深度回传逻辑.
 		if(StrUtil.isNotBlank(message.getState()) && message.getState().contains(Constant.ACQUISTION_LINK_STATE_KEY)){
 			String customer = message.getState().replaceAll("customer_", "");
-			THREAD_POOL.execute(()->{
-				saveAcqusitionCallback(customer, corpUser, message);
-			});
+			saveAcqusitionCallback(customer, corpUser, message);
 			isSendWelcomeMsg.set(true);
 		}
 
@@ -1020,18 +1018,20 @@ public class CorpEventActionServiceImpl implements CorpEventActionService {
 		Long linkId = customerAcquisitionSaveClickId(customer, corpUser.getUnionid());
 		CorpCustomerAcquisitionLink customerAcquisitionLink;
 		if (linkId != null) {
+			log.info("加粉链接linkid:{}", linkId);
 			customerAcquisitionLink = corpCustomerAcquisitionLinkMapper.getByLinkPopularizeId(linkId);
 		} else {
 			//直接使用获客链接
 			customerAcquisitionLink = corpCustomerAcquisitionLinkMapper.selectById(customer);
 		}
 		if (customerAcquisitionLink == null) {
+			log.info("未找到对应获客链接:{}", customer);
 			return;
 		}
 		corpUser.setCustomerAcquisitionLinkId(customerAcquisitionLink.getId());
 		if (StringUtils.isNotBlank(customerAcquisitionLink.getTags())){
 			try {
-				log.info("处理获客链接客户标签");
+				log.info("处理获客链接客户标签,标签id:{}", customerAcquisitionLink.getTags());
 				List<Long> tags = Jsons.parseList(customerAcquisitionLink.getTags(), Long.class);
 				if (CollectionUtil.isEmpty(tags)) {
 					log.info("获客链接id为：{},无标签处理", customerAcquisitionLink.getId());