SampleTest.java 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. package org.jeecg;
  2. import cn.com.ctop.bytedance.service.IReportService;
  3. import cn.com.ctop.common.module.entity.CtopOauthToken;
  4. import cn.com.ctop.common.module.service.ICtopOauthTokenService;
  5. import cn.com.ctop.common.module.service.IFileInfoService;
  6. import cn.com.ctop.common.module.utils.CtopAdConstant;
  7. import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouInterfaceService;
  8. import com.alibaba.fastjson.JSONObject;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.jeecg.common.util.DateUtils;
  11. import org.jeecg.modules.ctop.service.ICreateInternalService;
  12. import org.junit.Test;
  13. import org.junit.runner.RunWith;
  14. import org.springframework.beans.factory.annotation.Autowired;
  15. import org.springframework.boot.test.context.SpringBootTest;
  16. import org.springframework.test.context.junit4.SpringRunner;
  17. import java.io.IOException;
  18. import java.util.Date;
  19. import java.util.List;
  20. @RunWith(SpringRunner.class)
  21. @SpringBootTest
  22. @Slf4j
  23. public class SampleTest {
  24. @Autowired
  25. private ICreateInternalService createInternalService;
  26. @Autowired
  27. private IKuaishouInterfaceService kuaishouInterfaceService;
  28. @Autowired
  29. private IReportService reportService;
  30. @Test
  31. public void testJob() {
  32. Date getDate = DateUtils.addDay(new Date(), -1);
  33. //1:查询当日数据
  34. List<CtopOauthToken> tokens = tokenService.getTokenListByType(2 + "");
  35. if (null == tokens || tokens.size() <= 0) {
  36. log.info("定时获取头条数据异常:为获取到可用的token");
  37. return;
  38. }
  39. tokens.forEach(token -> {
  40. // //2:获取广告计划信息数据
  41. kuaishouInterfaceService.getAdvertiserCampaignReportHourly(token, getDate, getDate);
  42. // //3:获取广告组信息数据
  43. kuaishouInterfaceService.getAdvertiserGroupReportHourly(token, getDate, getDate);
  44. // //4: 获取广告创意信息数据
  45. kuaishouInterfaceService.getAdvertiserCreativeReportHourly(token, getDate, getDate);
  46. });
  47. }
  48. @Autowired
  49. IFileInfoService fileInfoService;
  50. @Test
  51. public void testVideoList() throws IOException {
  52. CtopOauthToken token = tokenService.getOauthTokenByAccountId("1232598");
  53. kuaishouInterfaceService.getVideoList(token);
  54. }
  55. @Test
  56. public void testNg() {
  57. JSONObject json = new JSONObject();
  58. createInternalService.createInternal(json);
  59. }
  60. @Test
  61. public void loadAllMetiaralInfo() {
  62. Date getDate = DateUtils.addDay(new Date(), -1);
  63. List<CtopOauthToken> tokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_KUAISHOU);
  64. if (null == tokens || tokens.size() <= 0) {
  65. log.info("定时获取头条数据异常:为获取到可用的token");
  66. return;
  67. }
  68. tokens.forEach(token -> {
  69. //1:获取全量广告计划数据
  70. kuaishouInterfaceService.getCampaignList(token);
  71. //1:获取全量广告组数据
  72. kuaishouInterfaceService.getGroupList(token);
  73. //1:获取全量创意数据
  74. kuaishouInterfaceService.getCreativeList(token);
  75. //2:获取全量视频素材数据
  76. kuaishouInterfaceService.getVideoList(token);
  77. });
  78. log.info("快手物料数据同步完成");
  79. tokens.forEach(token -> {
  80. //1: 获取广告主信息数据
  81. kuaishouInterfaceService.getAdvertiserReportDaily(token, getDate, getDate);
  82. //2:获取广告计划信息数据
  83. kuaishouInterfaceService.getAdvertiserCampaignReportDaily(token, getDate, getDate);
  84. //3:获取广告组信息数据
  85. kuaishouInterfaceService.getAdvertiserGroupReportDaily(token, getDate, getDate);
  86. //4: 获取广告创意信息数据
  87. kuaishouInterfaceService.getAdvertiserCreativeReportDaily(token, getDate, getDate);
  88. });
  89. }
  90. @Autowired
  91. private ICtopOauthTokenService tokenService;
  92. }