SampleTest.java 6.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187
  1. package org.jeecg;
  2. import cn.com.ctop.common.module.entity.BindAccountLogin;
  3. import cn.com.ctop.common.module.entity.CtopOauthToken;
  4. import cn.com.ctop.common.module.service.IBindAccountLoginService;
  5. import cn.com.ctop.common.module.service.ICtopOauthTokenService;
  6. import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouInterfaceService;
  7. import cn.com.ctop.common.module.utils.CtopAdConstant;
  8. import cn.com.ctop.common.module.utils.HttpUtils;
  9. import cn.com.ctop.crawler.modules.pangolin.entity.PangolinApp;
  10. import cn.com.ctop.crawler.modules.pangolin.service.PangolinAppService;
  11. import cn.com.ctop.crawler.modules.pangolin.service.PangolinCrawlerService;
  12. import cn.com.ctop.crawler.modules.pangolin.service.PangolinLoginService;
  13. import cn.com.ctop.kuaishou.modules.graphql.service.IKuaishouWebInterfaceService;
  14. import cn.com.ctop.toutiao.modules.material.service.IByteDanceAdvertiserDataService;
  15. import cn.com.ctop.toutiao.modules.material.service.IByteDanceCampaignService;
  16. import cn.com.ctop.toutiao.modules.report.service.IReportService;
  17. import cn.com.ctop.toutiao.modules.material.service.IByteDanceCreativeService;
  18. import com.alibaba.fastjson.JSONObject;
  19. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  20. import lombok.extern.slf4j.Slf4j;
  21. import org.jeecg.common.util.DateUtils;
  22. import org.jeecg.modules.ctop.entity.KuaishouEffectVideoInfo;
  23. import org.jeecg.modules.ctop.service.IKuaishouEffectVideoInfoService;
  24. import org.jeecg.modules.demo.mock.MockController;
  25. import org.jeecg.modules.demo.test.entity.JeecgDemo;
  26. import org.jeecg.modules.demo.test.mapper.JeecgDemoMapper;
  27. import org.jeecg.modules.demo.test.service.IJeecgDemoService;
  28. import org.jeecg.modules.system.service.ISysDataLogService;
  29. import org.junit.Assert;
  30. import org.jeecg.modules.ctop.service.IRuleEngineService;
  31. import org.jeecg.modules.ctop.vo.QueryParam;
  32. import org.jeecg.modules.ctop.vo.RuleResult;
  33. import org.junit.Test;
  34. import org.junit.runner.RunWith;
  35. import org.kie.api.runtime.KieSession;
  36. import org.springframework.beans.factory.annotation.Autowired;
  37. import org.springframework.boot.test.context.SpringBootTest;
  38. import org.springframework.test.context.junit4.SpringRunner;
  39. import javax.annotation.Resource;
  40. import javax.annotation.Resource;
  41. import java.util.HashMap;
  42. import java.util.List;
  43. import java.util.concurrent.CountDownLatch;
  44. import java.util.concurrent.ExecutorService;
  45. import java.util.concurrent.Executors;
  46. @RunWith(SpringRunner.class)
  47. @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  48. public class SampleTest {
  49. @Autowired
  50. private ICtopOauthTokenService oauthTokenService;
  51. @Autowired
  52. private IByteDanceAdvertiserDataService advertiserDataService;
  53. @Autowired
  54. private IReportService reportService;
  55. @Autowired
  56. private IKuaishouInterfaceService interfaceService;
  57. @Resource
  58. private JeecgDemoMapper jeecgDemoMapper;
  59. @Resource
  60. private IJeecgDemoService jeecgDemoService;
  61. @Resource
  62. private ISysDataLogService sysDataLogService;
  63. @Resource
  64. private MockController mock;
  65. private IByteDanceCreativeService creativeService;
  66. @Test
  67. public void loadBytedanceCreativeData() {
  68. /**
  69. *
  70. */
  71. CtopOauthToken token = oauthTokenService.getTokenByAccountId(1649600126891015L);
  72. creativeService.getAdvertiserCreative(token,null,null);
  73. // advertiserDataService.getMaterialList(token);
  74. }
  75. @Autowired
  76. private IBindAccountLoginService bindAccountLoginService;
  77. @Autowired
  78. private IKuaishouWebInterfaceService kuaishouWebInterfaceService;
  79. @Test
  80. public void testSelect() {
  81. System.out.println(("----- selectAll method test ------"));
  82. List<JeecgDemo> userList = jeecgDemoMapper.selectList(null);
  83. Assert.assertEquals(5, userList.size());
  84. userList.forEach(System.out::println);
  85. }
  86. @Test
  87. public void testXmlSql() {
  88. System.out.println(("----- selectAll method test ------"));
  89. List<JeecgDemo> userList = jeecgDemoMapper.getDemoByName("Sandy12");
  90. userList.forEach(System.out::println);
  91. }
  92. /**
  93. * 测试事务
  94. */
  95. @Test
  96. public void testTran() {
  97. jeecgDemoService.testTran();
  98. }
  99. //author:lvdandan-----date:20190315---for:添加数据日志测试----
  100. /**
  101. * 测试数据日志添加
  102. */
  103. @Test
  104. public void testDataLogSave() {
  105. System.out.println(("----- datalog test ------"));
  106. String tableName = "jeecg_demo";
  107. String dataId = "4028ef81550c1a7901550c1cd6e70001";
  108. String dataContent = mock.sysDataLogJson();
  109. sysDataLogService.addDataLog(tableName, dataId, dataContent);
  110. }
  111. //author:lvdandan-----date:20190315---for:添加数据日志测试----
  112. @Autowired
  113. private IByteDanceCampaignService campaignService;
  114. @Test
  115. public void testGetCampaign(){
  116. CtopOauthToken token = oauthTokenService.getOauthTokenByAccountId("1649600126891015");
  117. campaignService.getAdvertiserCampaign(token,"1672261893872756",null);
  118. }
  119. @Autowired
  120. private IKuaishouEffectVideoInfoService effectVideoInfoService;
  121. @Test
  122. public void loadKuaishouEffectVideoInfo(){
  123. List<KuaishouEffectVideoInfo>videoInfos = effectVideoInfoService.list();
  124. for (KuaishouEffectVideoInfo video:videoInfos) {
  125. if(null!=video.getSignature()&&!"".equals(video.getSignature())){
  126. effectVideoInfoService.updateFinalCostDateBySignature(video.getSignature());
  127. effectVideoInfoService.updateInitialCostDateBySignature(video.getSignature());
  128. effectVideoInfoService.updateTotalCostBySignature(video.getSignature());
  129. // effectVideoInfoService.updateTowWeekCostBySignature(video.getSignature());
  130. }
  131. }
  132. }
  133. @Test
  134. public void getIndustryInfo(){
  135. String access_token = "cbdf6502c04978ae401cb92a64530fb73a8c7dbe";
  136. // 请求地址
  137. String url = "https://ad.oceanengine.com/open_api/2/tools/industry/get/";
  138. JSONObject jsonObject = HttpUtils.bytedanceGetRequest(access_token, url, new JSONObject());
  139. System.out.println(jsonObject.toJSONString());
  140. }
  141. @Test
  142. public void loadImageInfo()throws Exception{
  143. List<CtopOauthToken>tokens = oauthTokenService.selectToutiaoToken();
  144. for (CtopOauthToken token:tokens) {
  145. advertiserDataService.getImageByPage(token,null,1);
  146. Thread.sleep(1000L);
  147. }
  148. }
  149. @Resource
  150. private KieSession kieSession;
  151. @Autowired
  152. private IRuleEngineService ruleEngineService ;
  153. @Test
  154. public void testEngine(){
  155. QueryParam queryParam1 = new QueryParam() ;
  156. queryParam1.setParamId("1");
  157. queryParam1.setParamSign("+");
  158. QueryParam queryParam2 = new QueryParam() ;
  159. queryParam2.setParamId("2");
  160. queryParam2.setParamSign("-");
  161. // 入参
  162. kieSession.insert(queryParam1);
  163. kieSession.insert(queryParam2);
  164. kieSession.insert(this.ruleEngineService);
  165. // 返参
  166. RuleResult resultParam = new RuleResult();
  167. kieSession.insert(resultParam);
  168. kieSession.fireAllRules();
  169. System.out.println(resultParam.isPostCodeResult());
  170. }
  171. }