ExternalChannelTest.java 1.1 KB

12345678910111213141516171819202122232425262728293031
  1. package com.tzld.piaoquan.api;
  2. import com.tzld.piaoquan.api.dao.mapper.contentplatform.ExternalChannelMapper;
  3. import com.tzld.piaoquan.api.job.ExternalChannelProcessJob;
  4. import com.tzld.piaoquan.api.model.po.contentplatform.ExternalChannel;
  5. import com.tzld.piaoquan.api.model.po.contentplatform.ExternalChannelExample;
  6. import lombok.extern.slf4j.Slf4j;
  7. import org.junit.jupiter.api.Test;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.boot.test.context.SpringBootTest;
  10. import java.util.List;
  11. @SpringBootTest(classes = GrowthServerApplication.class)
  12. @Slf4j
  13. public class ExternalChannelTest {
  14. @Autowired
  15. ExternalChannelProcessJob job;
  16. @Autowired
  17. ExternalChannelMapper externalChannelMapper;
  18. @Test
  19. public void testSyncContentPlatformQwDatastatReplyTotalJob() {
  20. ExternalChannelExample example = new ExternalChannelExample();
  21. example.createCriteria().andRootSourceIdEqualTo("fwhtouliu_tencentgzh_20260320_49679899_1847006a");
  22. List<ExternalChannel> externalChannels = externalChannelMapper.selectByExample(example);
  23. job.processSingleRecord(externalChannels.get(0));
  24. }
  25. }