Parcourir la source

添加通过人员更新人群、应用接口

zhaoxian il y a 4 ans
Parent
commit
2ab29afe8f

+ 99 - 4
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/controller/BatchController.java

@@ -5,17 +5,47 @@ import cn.com.ctop.common.module.entity.CtopOauthToken;
 import cn.com.ctop.common.module.entity.MaterialInfo;
 import cn.com.ctop.common.module.mapper.MaterialInfoMapper;
 import cn.com.ctop.common.module.service.ICtopOauthTokenService;
+import cn.com.ctop.common.module.service.IUserAllocationService;
 import cn.com.ctop.common.module.utils.BigDecimalUtil;
 import cn.com.ctop.common.module.utils.Check;
 import cn.com.ctop.common.module.utils.QueryGenerator;
 import cn.com.ctop.common.module.utils.RandomUtil;
-import cn.com.ctop.kuaishou.modules.batch.entity.*;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouActionBarText;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouAdvertiserBaseInfo;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouAppInfo;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouAppList;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouCampaign;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouCreative;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouDirectionalTemplate;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouGroup;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouGroupTarget;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouImageGet;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouRegionListParent;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouTargetingTags;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaiShouVideoGet;
+import cn.com.ctop.kuaishou.modules.batch.entity.KuaishouPopulation;
 import cn.com.ctop.kuaishou.modules.batch.entity.vo.ConvertVo;
 import cn.com.ctop.kuaishou.modules.batch.entity.vo.SpendVo;
 import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouCampaignMapper;
 import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouGroupMapper;
 import cn.com.ctop.kuaishou.modules.batch.mapper.KuaiShouTargetingTagsMapper;
-import cn.com.ctop.kuaishou.modules.batch.service.*;
+import cn.com.ctop.kuaishou.modules.batch.service.IBatchService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouActionBarTextService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouAdvertiserBaseInfoService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouAppInfoService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouAppListService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouCampaignService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouCreativeService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouDirectionalTemplateService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouGroupService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouGroupTargetService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouImageGetService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouRegionListParentService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouUpdateService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaiShouVideoGetService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouInterfaceService;
+import cn.com.ctop.kuaishou.modules.batch.service.IKuaishouPopulationService;
+import cn.com.ctop.kuaishou.modules.batch.service.ISyncPullMaterialService;
 import cn.com.ctop.kuaishou.modules.report.service.IEtlKuaiShouGroupDailyReportService;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
@@ -27,7 +57,14 @@ import lombok.extern.slf4j.Slf4j;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.util.DateUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletRequest;
 import java.math.BigDecimal;
@@ -89,7 +126,8 @@ public class BatchController {
     private ISyncPullMaterialService syncPullMaterialService;
     @Autowired
     private IKuaiShouAdvertiserBaseInfoService KuaiShouAdvertiserBaseInfoService;
-
+    @Autowired
+    private IUserAllocationService userAllocationService;
 
     /**
      * 获取花费信息
@@ -2291,6 +2329,63 @@ public class BatchController {
         return result;
     }
 
+    /**
+     * 同步人员应用
+     *
+     * @param accountId
+     * @return
+     */
+    @GetMapping(value = "/syncUserAppList")
+    public Result<Object> syncUserAppList(Long userId, Integer type) {
+        if (Check.isNull(type) || Check.isNull(userId)) {
+            return Result.error("缺失参数");
+        }
+        //0管理员更新所有账户
+        if (0 == type) {
+            List<CtopOauthToken> ctopOauthTokens = oauthTokenService.selectKuaiShouToken();
+            for (CtopOauthToken oauthToken : ctopOauthTokens) {
+                iKuaishouInterfaceService.getAppList(oauthToken.getAccountId(), oauthToken.getAccessToken());
+            }
+        } else {
+            List<JSONObject> list = userAllocationService.getAccountIdListByUserId(userId);
+            for (JSONObject obj : list) {
+                CtopOauthToken oauthToken = oauthTokenService.getTokenByAccountId(obj.getLong("accountId"));
+                if (!Check.isNull(oauthToken)) {
+                    iKuaishouInterfaceService.getAppList(obj.getLong("accountId"), oauthToken.getAccessToken());
+                }
+            }
+        }
+        return Result.ok("success");
+    }
+
+    /**
+     * 同步人员的人群包列表
+     *
+     * @param accountId
+     * @return
+     */
+    @GetMapping(value = "/syncUserPopulationList")
+    public Result<Object> syncUserPopulationList(Long userId, Integer type) {
+        if (Check.isNull(type) || Check.isNull(userId)) {
+            return Result.error("缺失参数");
+        }
+        //0管理员更新所有账户
+        if (0 == type) {
+            List<CtopOauthToken> ctopOauthTokens = oauthTokenService.selectKuaiShouToken();
+            for (CtopOauthToken oauthToken : ctopOauthTokens) {
+                iKuaishouInterfaceService.getPopulationList(oauthToken.getAccountId(), oauthToken.getAccessToken(), 1);
+            }
+        } else {
+            List<JSONObject> list = userAllocationService.getAccountIdListByUserId(userId);
+            for (JSONObject obj : list) {
+                CtopOauthToken oauthToken = oauthTokenService.getTokenByAccountId(obj.getLong("accountId"));
+                if (!Check.isNull(oauthToken)) {
+                    iKuaishouInterfaceService.getPopulationList(obj.getLong("accountId"), oauthToken.getAccessToken(), 1);
+                }
+            }
+        }
+        return Result.ok("success");
+    }
 
     /**
      * 同步应用