package com.nova.sankuai.controller.v1;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.nova.sankuai.domain.api.baidu.BaiduDto;
|
import com.nova.sankuai.domain.api.baidu.BaiduWrapperDto;
|
import com.nova.sankuai.domain.entity.ChannelLog;
|
import com.nova.sankuai.domain.entity.Customer;
|
import com.nova.sankuai.domain.enums.SourceTypeEnum;
|
import com.nova.sankuai.infra.constants.ResultCode;
|
import com.nova.sankuai.infra.utils.ResultJson;
|
import com.nova.sankuai.service.IChannelInfoService;
|
import com.nova.sankuai.service.IChannelLogService;
|
import com.nova.sankuai.service.ICustomerService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
|
/**
|
* @author weikangdi
|
*/
|
@Api(tags = "百度对接")
|
@RestController
|
@RequestMapping(value = "/api/v1/baidu")
|
@Slf4j
|
@AllArgsConstructor
|
public class BaiduController {
|
|
private final ICustomerService customerService;
|
|
private final IChannelLogService channelLogService;
|
|
private final IChannelInfoService channelInfoService;
|
|
|
@PostMapping(value = "/customerImport")
|
@ApiOperation(value = "获取百度推广数据")
|
public ResultJson customerImport(@RequestBody BaiduWrapperDto obj) {
|
String content = obj.getData().toString();
|
String appId = obj.getAppid().toString();
|
ResultJson checkResult = channelInfoService.checkChannel(appId, content);
|
if (checkResult != null) {
|
return checkResult;
|
}
|
log.info("百度推广数据:" + content);
|
String reg = "\\{([a-zA-Z]+)\\s*=\\s*([^={}]*?),\\s*([a-zA-Z]+)\\s*=\\s*(.*?),\\s*([a-zA-Z]+)\\s*=\\s*(.*?)}";
|
Pattern p = Pattern.compile(reg);
|
Matcher m = p.matcher(content);
|
StringBuilder sb = new StringBuilder();
|
sb.append("{'");
|
while (m.find()) {
|
String group = m.group().split("type=")[1];
|
sb.append(group.split(",")[0] + "':'");
|
sb.append(group.split("value=")[1].replace("}", "") + "','");
|
}
|
String jsonStr = sb.substring(0, sb.lastIndexOf(",")) + "}";
|
BaiduDto baiduDto = null;
|
try {
|
baiduDto = JSONObject.parseObject(jsonStr, BaiduDto.class);
|
Customer customer = customerService.addBaiDuCustomer(baiduDto);
|
channelLogService.createImportLog(SourceTypeEnum.BaiDu.getCode(), ChannelLog.SUCCESS, customer.getId(), jsonStr);
|
return ResultJson.success();
|
} catch (Exception e) {
|
log.error("Baidu数据失败");
|
log.error("获取到的百度推送数据：" + content);
|
channelLogService.createImportLog(SourceTypeEnum.BaiDu.getCode(), ChannelLog.FAIL, null, jsonStr);
|
return ResultJson.failure(ResultCode.BAD_REQUEST);
|
}
|
}
|
}
|
