将CMQ替换为rabbitmq

admin

2024-10-15 4995469ae28ce99f5e682895c0708d15f4dc63cd

 fanli/src/main/java/com/yeshi/fanli/service/impl/ad/DouYinClickEventServiceImpl.java

@@ -2,6 +2,7 @@

import javax.annotation.Resource;

import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.springframework.stereotype.Service;

import com.yeshi.fanli.dao.ad.DouYinClickEventDao;
@@ -15,13 +16,16 @@
   @Resource
   private DouYinClickEventDao douYinClickEventDao;

   @Resource
   private DouYinDeviceActiveCMQManager douYinDeviceActiveCMQManager;

   @Override
   public void save(DouYinClickEvent event) {
      // 查询
      DouYinClickEvent old = douYinClickEventDao.selectByCallBack(event.getCallback());
      if (old == null) {
         douYinClickEventDao.save(event);
         DouYinDeviceActiveCMQManager.getInstance().addAdActive(event.getCallback());
         douYinDeviceActiveCMQManager.addAdActive(event.getCallback());
      }
   }