package com.nova.sankuai.infra.utils.weike;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.nova.sankuai.domain.api.zcy.ZcyResponse;
|
import com.nova.sankuai.domain.dto.zcy.CustomerZcyDto;
|
import com.nova.sankuai.domain.entity.CustomerZcy;
|
import com.nova.sankuai.service.ICustomerZcyService;
|
import lombok.RequiredArgsConstructor;
|
import org.jetbrains.annotations.NotNull;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Objects;
|
|
@Component
|
@RequiredArgsConstructor
|
public class WeikeUtil {
|
|
private static final Logger log = LoggerFactory.getLogger("capitalLogger");
|
private final ICustomerZcyService customerZcyService;
|
|
public ZcyResponse callback(CustomerZcyDto body) {
|
String logNumber = IdUtil.randomUUID();
|
try {
|
if (Objects.isNull(body)) {
|
ZcyResponse resp = getZcyResponse(400, "请求体为空");
|
log.error("日志编号：{} 微客数据入库失败，错误原因：随易花资方回调请求体为空!", logNumber);
|
return resp;
|
}
|
// 获取电话
|
String phone = body.getPhone();
|
|
// 判断数据库是否有数据，有数据，则说明以前有推送过来过
|
CustomerZcy customer = customerZcyService.getOne(new LambdaQueryWrapper<CustomerZcy>().eq(CustomerZcy::getPhone, phone));
|
if (!Objects.isNull(customer)) {
|
ZcyResponse resp = getZcyResponse(400, "电话号码为" + phone + " 已推送过数据!");
|
log.error("日志编号：{} 手机号为:{} 微客数据入库失败，传入参数:{} 错误原因：已推送过数据!", logNumber, phone, body);
|
return resp;
|
}
|
|
// 开始录入数据
|
CustomerZcy customerZcy = new CustomerZcy();
|
BeanUtils.copyProperties(body, customerZcy);
|
customerZcy.setMark(1);
|
customerZcyService.save(customerZcy);
|
|
ZcyResponse resp = getZcyResponse(200, "成功!");
|
log.info("日志编号：{} 手机号为:{} 微客数据入库成功", logNumber, phone);
|
return resp;
|
} catch (Exception e) {
|
ZcyResponse resp = getZcyResponse(500, e.getMessage());
|
log.error("日志编号：{} 微客数据入库失败，传入参数:{} 错误原因：{}", logNumber, body, e);
|
return resp;
|
}
|
}
|
|
@NotNull
|
private ZcyResponse getZcyResponse(Integer code, String msg) {
|
ZcyResponse resp = new ZcyResponse();
|
resp.setCode(code);
|
resp.setMsg(msg);
|
return resp;
|
}
|
|
|
}
|
