Przeglądaj źródła

监测链接-预警修改

yangzian 3 lat temu
rodzic
commit
9e04083b1f

+ 1 - 1
jeecg-boot-bytedance/src/main/java/org/jeecg/modules/bytedance/advertise/dockapi/MarketingServiceImpl.java

@@ -1007,7 +1007,7 @@ public class MarketingServiceImpl implements MarketingService{
             log.info("查询查询转化目标详细信息不存在==》accountId:{},message:{}", token.getAccountId(), message);
             return Result.error("查询转化目标详细信息不存在!");
         }
-        return Result.successMsg("查询转化目标详细信息不存在",dataList);
+        return Result.successMsg("查询转化目标详细信息成功。",dataList);
     }
 
 

+ 1 - 1
jeecg-boot-bytedance/src/main/java/org/jeecg/modules/bytedance/advertise/service/IMonitorBytedanceService.java

@@ -16,7 +16,7 @@ public interface IMonitorBytedanceService{
 
     Result insertAccountTrackUrl(MonitorBytedanceAdVo monitorBytedanceAdVo);
 
-    Result monitorBytedanceActionTrackUrl();
+    Result monitorBytedanceActionTrackUrl(String accountId);
 
     Result updAccountActionTrackUrl(MonitorBytedanceAdVo monitorBytedanceAdVo);
 

+ 24 - 44
jeecg-boot-bytedance/src/main/java/org/jeecg/modules/bytedance/advertise/service/impl/MonitorBytedanceServiceImpl.java

@@ -65,26 +65,6 @@ public class MonitorBytedanceServiceImpl implements IMonitorBytedanceService {
      * @time: 2022/1/11
      */
     public Result insertAccountTrackUrl(MonitorBytedanceAdVo monitorBytedanceAdVo){
-        //账户 查询 第三方监测链接
-        List<MonitorBytedanceAdVo> trackUrl = monitorBytedanceActionTrackUrlMapper.getAccountActionTrackUrl(monitorBytedanceAdVo.getAccountId(), null,null);
-        if (!Check.isNull(trackUrl)){
-            return Result.errorMsg("账户已存在第三方监测链接,请重新编辑。");
-        }
-        //查询账户配置中的 转化id
-        List<MonitorBytedanceAdVo> accountList = monitorBytedanceActionTrackUrlMapper.getBytedancStrategyAcctionId(monitorBytedanceAdVo.getAccountId());
-        if (!Check.isNull(accountList)){
-            // 账户id  和 转化id 查询 第三方监测链接
-            Result resultConvert = aiBytedanceAdvertiserStrategyService.readToolConvertInfo(accountList.get(0).getAccountId(),accountList.get(0).getConvertId());
-            if (!resultConvert.isSuccess()){
-                return  Result.errorMsg(resultConvert.getMessage());
-            }
-            JSONObject jsonObject = (JSONObject) JSONObject.toJSON(resultConvert.getResult());
-            String action_track_url = jsonObject.getString("action_track_url");
-            if (!StringUtils.equals(action_track_url,monitorBytedanceAdVo.getActionTrackUrl())){
-                return Result.errorMsg("输入的第三方监测链接与账户下转化目标所属的第三方监测链接不一致,请重新输入。");
-            }
-        }
-        //新增 第三方监测链接
         monitorBytedanceActionTrackUrlMapper.insertAccountTrackUrl(monitorBytedanceAdVo);
         return Result.successMsg("成功。",null);
     }
@@ -101,24 +81,6 @@ public class MonitorBytedanceServiceImpl implements IMonitorBytedanceService {
      */
     @Override
     public Result updAccountActionTrackUrl(MonitorBytedanceAdVo monitorBytedanceAdVo) {
-
-        //链接不为空 修改 内容 否则 修改状态
-        if (!Check.isNull(monitorBytedanceAdVo.getActionTrackUrl())){
-            //查询账户配置中的 转化id
-            List<MonitorBytedanceAdVo> accountList = monitorBytedanceActionTrackUrlMapper.getBytedancStrategyAcctionId(monitorBytedanceAdVo.getAccountId());
-            if (!Check.isNull(accountList)){
-                // 账户id  和 转化id 查询 第三方监测链接
-                Result resultConvert = aiBytedanceAdvertiserStrategyService.readToolConvertInfo(accountList.get(0).getAccountId(),accountList.get(0).getConvertId());
-                if (!resultConvert.isSuccess()){
-                    return  Result.errorMsg(resultConvert.getMessage());
-                }
-                JSONObject jsonObject = (JSONObject) JSONObject.toJSON(resultConvert.getResult());
-                String action_track_url = jsonObject.getString("action_track_url");
-                if (!StringUtils.equals(action_track_url,monitorBytedanceAdVo.getActionTrackUrl())){
-                    return Result.errorMsg("输入的第三方监测链接与账户下转化目标所属的第三方监测链接不一致,请重新输入。");
-                }
-            }
-        }
         monitorBytedanceActionTrackUrlMapper.updAccountActionTrackUrl(monitorBytedanceAdVo);
         return Result.successMsg("修改成功。", null);
     }
@@ -138,7 +100,6 @@ public class MonitorBytedanceServiceImpl implements IMonitorBytedanceService {
      */
     @Override
     public Result selectAccountActionTrackUrlList(String accountId, String warningFlag, Set<String> operatorUserIds,Integer pageNum,Integer pageSize) {
-
         PageHelper.startPage(pageNum,pageSize);
         List<MonitorBytedanceAdVo> list = monitorBytedanceActionTrackUrlMapper.getAccountActionTrackUrl(accountId,warningFlag,operatorUserIds);
         PageInfo<MonitorBytedanceAdVo> pageInfo = new PageInfo<MonitorBytedanceAdVo>(list);
@@ -179,10 +140,30 @@ public class MonitorBytedanceServiceImpl implements IMonitorBytedanceService {
      * @author: zianY
      * @time: 2021/12/28
      */
-    public Result monitorBytedanceActionTrackUrl(){
+    public Result monitorBytedanceActionTrackUrl(String accountId){
         //查询 配置的点击监测链接
-        List<MonitorBytedanceAdVo> accountList = monitorBytedanceActionTrackUrlMapper.getAccountActionTrackUrl(null,"1",null);
-        accountList.forEach(accountInfo ->{
+        List<MonitorBytedanceAdVo> accountList = monitorBytedanceActionTrackUrlMapper.getAccountActionTrackUrl(accountId,"1",null);
+        for (MonitorBytedanceAdVo accountInfo : accountList) {
+            //1:校验 账户自动投放配置中 监测链接
+            //查询账户配置中的 转化id
+            List<MonitorBytedanceAdVo> converId = monitorBytedanceActionTrackUrlMapper.getBytedancStrategyAcctionId(accountInfo.getAccountId());
+            if (!Check.isNull(converId)){
+                // 账户id  和 转化id 查询 第三方监测链接
+                Result resultConvert = aiBytedanceAdvertiserStrategyService.readToolConvertInfo(converId.get(0).getAccountId(),converId.get(0).getConvertId());
+                if (!resultConvert.isSuccess()){
+                    return  Result.errorMsg(resultConvert.getMessage());
+                }
+                JSONObject jsonObject = (JSONObject) JSONObject.toJSON(resultConvert.getResult());
+                String action_track_url = jsonObject.getString("action_track_url");
+                //自动投放账户配置中的链接 != 监测链接配置
+                if (!StringUtils.equals(action_track_url,accountInfo.getActionTrackUrl())){
+                    //发送预警消息
+                    sendEnterpriseWeiXinMessage(accountInfo);
+                    log.info("accountId:=={}==目标转化id:{}=====第三方点击监测链接与自动投放配置不一致,已发送企业微信通知============",accountInfo.getAccountId(),converId.get(0).getConvertId());
+                }
+            }
+
+            //2:校验 拉取后台计划 监测链接
             //根据账户 查询头条计划中的 点击监测链接
             List<MonitorBytedanceAdVo> actionTrackUrlList = monitorBytedanceActionTrackUrlMapper.getBytedancPlanActionTrackUrl(Long.valueOf(accountInfo.getAccountId()));
             if (!Check.isNull(actionTrackUrlList)){
@@ -196,12 +177,11 @@ public class MonitorBytedanceServiceImpl implements IMonitorBytedanceService {
                         //发送预警消息
                         sendEnterpriseWeiXinMessage(accountInfo);
                         log.info("accountId:=={}==计划id:{}=====第三方点击监测链接不一致,已发送企业微信通知============",accountInfo.getAccountId(),actiontrackUrl.getPlanId());
-                        break;
                     }
                 }
             }
             log.info("accountId:=={}====已创建的计划暂时没有第三方点击监测链接============",accountInfo.getAccountId());
-        });
+        }
         return Result.successMsg("成功。",null);
     }
 

+ 2 - 2
jeecg-boot-module-system/src/main/java/org/jeecg/modules/bytedance/advertise/controller/BytedancePlanJobController.java

@@ -41,8 +41,8 @@ public class BytedancePlanJobController {
 
 	@ApiOperation(value = "监测预警-点击监测链接", notes = "监测预警-点击监测链接")
 	@GetMapping(value = "/monitorBytedanceActionTrackUrl")
-	public Result monitorBytedanceActionTrackUrl() {
-		return monitorBytedanceService.monitorBytedanceActionTrackUrl();
+	public Result monitorBytedanceActionTrackUrl(@RequestParam String accountId) {
+		return monitorBytedanceService.monitorBytedanceActionTrackUrl(accountId);
 	}