|
@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONObject;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import org.apache.http.client.ClientProtocolException;
|
|
import org.apache.http.client.ClientProtocolException;
|
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
|
import org.apache.http.client.methods.HttpPost;
|
|
import org.apache.http.client.methods.HttpPost;
|
|
@@ -16,12 +17,13 @@ import org.apache.shiro.SecurityUtils;
|
|
import org.jeecg.common.api.vo.Result;
|
|
import org.jeecg.common.api.vo.Result;
|
|
import org.jeecg.common.system.query.QueryGenerator;
|
|
import org.jeecg.common.system.query.QueryGenerator;
|
|
import org.jeecg.common.system.vo.LoginUser;
|
|
import org.jeecg.common.system.vo.LoginUser;
|
|
|
|
+import org.jeecg.common.util.ResultMapUtils;
|
|
|
|
+import org.jeecg.common.util.StatusCode;
|
|
import org.jeecg.modules.ctop.entity.ByteDanceCampaign;
|
|
import org.jeecg.modules.ctop.entity.ByteDanceCampaign;
|
|
import org.jeecg.modules.ctop.entity.ByteDanceCampaignTemplate;
|
|
import org.jeecg.modules.ctop.entity.ByteDanceCampaignTemplate;
|
|
import org.jeecg.modules.ctop.entity.CTopOauthToken;
|
|
import org.jeecg.modules.ctop.entity.CTopOauthToken;
|
|
import org.jeecg.modules.ctop.mapper.ByteDanceCampaignMapper;
|
|
import org.jeecg.modules.ctop.mapper.ByteDanceCampaignMapper;
|
|
import org.jeecg.modules.ctop.mapper.ByteDanceCampaignTemplateMapper;
|
|
import org.jeecg.modules.ctop.mapper.ByteDanceCampaignTemplateMapper;
|
|
-import org.jeecg.modules.ctop.service.IByteDanceAdvertiserDataService;
|
|
|
|
import org.jeecg.modules.ctop.service.IByteDanceCampaignTemplateService;
|
|
import org.jeecg.modules.ctop.service.IByteDanceCampaignTemplateService;
|
|
import org.jeecg.modules.ctop.service.ICTopOauthTokenService;
|
|
import org.jeecg.modules.ctop.service.ICTopOauthTokenService;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.Logger;
|
|
@@ -29,8 +31,6 @@ import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
|
-
|
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import java.io.BufferedReader;
|
|
import java.io.BufferedReader;
|
|
import java.io.IOException;
|
|
import java.io.IOException;
|
|
@@ -39,7 +39,6 @@ import java.text.SimpleDateFormat;
|
|
import java.util.Date;
|
|
import java.util.Date;
|
|
import java.util.HashMap;
|
|
import java.util.HashMap;
|
|
import java.util.Map;
|
|
import java.util.Map;
|
|
-import java.util.logging.SimpleFormatter;
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
* @Description: 今日头条广告组模板信息
|
|
* @Description: 今日头条广告组模板信息
|
|
@@ -53,24 +52,36 @@ public class ByteDanceCampaignTemplateServiceImpl extends ServiceImpl<ByteDanceC
|
|
@Override
|
|
@Override
|
|
public Map<String, Object> insertTemplate(ByteDanceCampaignTemplate template) {
|
|
public Map<String, Object> insertTemplate(ByteDanceCampaignTemplate template) {
|
|
Map<String, Object> resultMap = new HashMap<>();
|
|
Map<String, Object> resultMap = new HashMap<>();
|
|
|
|
+ String name = template.getCampaignName();
|
|
|
|
+ Long id = template.getId();
|
|
|
|
+ if (null == name || "".equals(name)) {
|
|
|
|
+ ResultMapUtils.setResultMap(resultMap, StatusCode.TEMPLATE_NAME_IS_NULL.getCode());
|
|
|
|
+ return resultMap;
|
|
|
|
+ }
|
|
|
|
+ QueryWrapper<ByteDanceCampaignTemplate> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ queryWrapper.eq("campaign_name", template.getCampaignName());
|
|
|
|
+ if (null != template.getId() && template.getId() != 0) {
|
|
|
|
+ queryWrapper.ne("id", template.getId());
|
|
|
|
+ }
|
|
|
|
+ ByteDanceCampaignTemplate templateExist = getOne(queryWrapper);
|
|
|
|
+ if (null != templateExist) {
|
|
|
|
+ ResultMapUtils.setResultMap(resultMap, StatusCode.TEMPLATE_NAME_HAS_EXIST.getCode());
|
|
|
|
+ return resultMap;
|
|
|
|
+ }
|
|
|
|
+ template.setStatus(1);
|
|
LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
- CTopOauthToken token = tokenService.getOAuthTokenByAccountId(user.getId());
|
|
|
|
- campaignTemplateMapper.insert(template);
|
|
|
|
- //新增数据
|
|
|
|
- // return advertiserDataService.campaignCreate(token, template);
|
|
|
|
- resultMap.put("success", true);
|
|
|
|
- resultMap.put("message", "广告组模板创建成功");
|
|
|
|
- resultMap.put("code", 0);
|
|
|
|
|
|
+ template.setAdvertiserId(user.getId());
|
|
|
|
+ this.saveOrUpdate(template);
|
|
|
|
+ ResultMapUtils.setResultMap(resultMap, StatusCode.COMMON_SUCCESS.getCode());
|
|
return resultMap;
|
|
return resultMap;
|
|
}
|
|
}
|
|
-
|
|
|
|
- @Autowired
|
|
|
|
- private IByteDanceAdvertiserDataService advertiserDataService;
|
|
|
|
@Override
|
|
@Override
|
|
public Result<IPage<ByteDanceCampaignTemplate>> getList(ByteDanceCampaignTemplate template, Integer pageNo, Integer pageSize, HttpServletRequest req) {
|
|
public Result<IPage<ByteDanceCampaignTemplate>> getList(ByteDanceCampaignTemplate template, Integer pageNo, Integer pageSize, HttpServletRequest req) {
|
|
Result<IPage<ByteDanceCampaignTemplate>> result = new Result<>();
|
|
Result<IPage<ByteDanceCampaignTemplate>> result = new Result<>();
|
|
QueryWrapper<ByteDanceCampaignTemplate> queryWrapper = QueryGenerator.initQueryWrapper(template, req.getParameterMap());
|
|
QueryWrapper<ByteDanceCampaignTemplate> queryWrapper = QueryGenerator.initQueryWrapper(template, req.getParameterMap());
|
|
- queryWrapper.orderByDesc("create_time");
|
|
|
|
|
|
+ LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
|
|
|
+ String advertiserId = user.getId();
|
|
|
|
+ queryWrapper.eq("advertiser_id", advertiserId).orderByDesc("create_time");
|
|
Page<ByteDanceCampaignTemplate> page = new Page<>(pageNo, pageSize);
|
|
Page<ByteDanceCampaignTemplate> page = new Page<>(pageNo, pageSize);
|
|
IPage<ByteDanceCampaignTemplate> pageList = this.page(page, queryWrapper);
|
|
IPage<ByteDanceCampaignTemplate> pageList = this.page(page, queryWrapper);
|
|
result.setSuccess(true);
|
|
result.setSuccess(true);
|
|
@@ -107,7 +118,6 @@ public class ByteDanceCampaignTemplateServiceImpl extends ServiceImpl<ByteDanceC
|
|
}
|
|
}
|
|
Long id = data.getLong("campaign_id");
|
|
Long id = data.getLong("campaign_id");
|
|
ByteDanceCampaign campaign = new ByteDanceCampaign(id, token, campaignName, budgetMode, budget, landingType);
|
|
ByteDanceCampaign campaign = new ByteDanceCampaign(id, token, campaignName, budgetMode, budget, landingType);
|
|
- //清除清数据,插入新数据
|
|
|
|
campaignMapper.insert(campaign);
|
|
campaignMapper.insert(campaign);
|
|
resultMap.put("code", 0);
|
|
resultMap.put("code", 0);
|
|
resultMap.put("message", "广告组创建成功");
|
|
resultMap.put("message", "广告组创建成功");
|