package com.nova.sankuai.controller.v1;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.nova.sankuai.domain.dto.CustomerPageDto;
|
import com.nova.sankuai.domain.dto.InletFlowProportionDto;
|
import com.nova.sankuai.domain.entity.Customer;
|
import com.nova.sankuai.domain.enums.UserTypeEnum;
|
import com.nova.sankuai.domain.vo.InletFlowProportionListVo;
|
import com.nova.sankuai.domain.vo.common.MapVo;
|
import com.nova.sankuai.domain.vo.customer.CustomerDetail;
|
import com.nova.sankuai.domain.vo.customer.CustomerMechanismConfigVo;
|
import com.nova.sankuai.domain.vo.customer.CustomerVo;
|
import com.nova.sankuai.infra.config.CommonException;
|
import com.nova.sankuai.infra.constants.ResultCode;
|
import com.nova.sankuai.infra.utils.MapUtil;
|
import com.nova.sankuai.infra.utils.PageRequest;
|
import com.nova.sankuai.infra.utils.ResultJson;
|
import com.nova.sankuai.security.UserDetail;
|
import com.nova.sankuai.service.*;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.AllArgsConstructor;
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.security.access.prepost.PreAuthorize;
|
import org.springframework.security.core.annotation.AuthenticationPrincipal;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
|
/**
|
* @author weikangdi
|
*/
|
@Api(tags = "客户管理")
|
@RestController
|
@RequestMapping(value = "/api/v1/customer")
|
@AllArgsConstructor
|
public class CustomerController {
|
|
private final ICustomerService customerService;
|
|
private final IChannelInfoService channelInfoService;
|
|
private final IYiXinService yiXinService;
|
|
private final IChannelLogService channelLogService;
|
|
private final IMemberRightService memberRightService;
|
|
@PostMapping(value = "/add")
|
@ApiOperation(value = "H5新增客户")
|
@PreAuthorize("hasAuthority('customer.add')")
|
public ResultJson<String> add(@RequestBody Customer customer, String appId) {
|
ResultJson checkResult = channelInfoService.checkChannel(appId, customer.toString());
|
if (checkResult != null) {
|
return checkResult;
|
}
|
String id = customerService.add(customer, appId);
|
return ResultJson.ok(id);
|
}
|
|
|
@PostMapping(value = "/calculateMechanism")
|
@ApiOperation(value = "获取匹配机构")
|
@PreAuthorize("hasAuthority('customer.calculateMechanism')")
|
public ResultJson<Customer> calculateMechanism(@RequestBody Customer customer) {
|
customer = customerService.calculate(customer);
|
return ResultJson.ok(customer);
|
}
|
|
@PostMapping("/uploadFile")
|
@ApiOperation(value = "上传图片")
|
@PreAuthorize("hasAuthority('customer.uploadFile')")
|
public ResultJson<String> uploadFile(@RequestBody MultipartFile file) {
|
String fileName = "";
|
return ResultJson.ok(fileName);
|
}
|
|
@GetMapping("/searchPlace")
|
@ApiOperation(value = "地址联想")
|
@PreAuthorize("hasAuthority('customer.searchPlace')")
|
public ResultJson<List<MapVo>> searchPlace(String query, String city) {
|
if (StringUtils.isEmpty(query)) {
|
return ResultJson.failure(ResultCode.SERVER_ERROR, "搜索关键字不能为空");
|
}
|
List<MapVo> place = MapUtil.searchPlace(query, city);
|
return ResultJson.ok(place);
|
}
|
|
@PostMapping(value = "/addLargeCustomer")
|
@ApiOperation(value = "新增大额H5客户")
|
public ResultJson<CustomerMechanismConfigVo> addLargeCustomer(@RequestBody Customer customer, String code, String appId) {
|
ResultJson checkResult = channelInfoService.checkChannel(appId, customer.toString());
|
if (checkResult != null) {
|
return checkResult;
|
}
|
CustomerMechanismConfigVo configVo = customerService.addLargeCustomer(customer, code, appId);
|
return ResultJson.ok(configVo);
|
}
|
|
|
@GetMapping(value = "/pageCustomers")
|
@ApiOperation(value = "分页查询客户信息")
|
@PreAuthorize("hasAuthority('customer.pageCustomers')")
|
public ResultJson<IPage<CustomerVo>> pageCustomers(CustomerPageDto customerPageDto, PageRequest pageRequest, @AuthenticationPrincipal UserDetail userDetail) {
|
if (UserTypeEnum.USER.getCode().equals(userDetail.getType())) {
|
customerPageDto.setMechanismId(userDetail.getId());
|
} else {
|
customerPageDto.setMechanismId(null);
|
}
|
IPage<CustomerVo> result = customerService.page(customerPageDto, pageRequest);
|
return ResultJson.ok(result);
|
}
|
|
@GetMapping(value = "/getCustomerDetail/{id}")
|
@ApiOperation(value = "获取客户详情")
|
@PreAuthorize("hasAuthority('customer.getCustomerDetail')")
|
public ResultJson<CustomerDetail> getCustomerDetail(@PathVariable("id") Long id) {
|
CustomerDetail detail = customerService.getCustomerDetail(id);
|
return ResultJson.ok(detail);
|
}
|
|
@GetMapping("/updateMatchMechanism")
|
@ApiOperation(value = "更新大额H5的匹配机构")
|
public ResultJson<Void> updateMatchMechanism(Long customerId, Long mechanismId) {
|
if (customerId == null || mechanismId == null) {
|
throw new CommonException("客户Id和机构Id不能为空");
|
}
|
customerService.updateMatchMechanism(customerId, mechanismId);
|
return ResultJson.success();
|
}
|
|
@GetMapping("/assignMechanism")
|
@ApiOperation(value = "重新分配机构")
|
@PreAuthorize("hasAuthority('customer.assignMechanism')")
|
public ResultJson<Void> assignMechanism(Long customerId, Long mechanismId) {
|
if (customerId == null || mechanismId == null) {
|
throw new CommonException("客户Id和机构Id不能为空");
|
}
|
customerService.assignMechanism(customerId, mechanismId);
|
return ResultJson.success();
|
}
|
|
@GetMapping("/checkMechanism")
|
@ApiOperation(value = "检测机构是否达到上限")
|
@PreAuthorize("hasAuthority('customer.checkMechanism')")
|
public ResultJson<Void> checkMechanism(Long mechanismId) {
|
Set<String> result = customerService.checkMechanism(mechanismId);
|
if (result != null && result.size() > 0) {
|
return ResultJson.failure(ResultCode.SERVER_ERROR, result);
|
}
|
return ResultJson.success();
|
}
|
|
@PostMapping(value = "/yxAuditCallback")
|
@ApiOperation(value = "绿地授信审批结果通知")
|
public String yxAuditCallback(@RequestBody Map<String, String> request) throws Exception {
|
String result = yiXinService.yxAuditCallback(request);
|
return result;
|
}
|
|
@PostMapping(value = "/getInletFlowProportion")
|
@ApiOperation(value = "查看入口流量占比")
|
@PreAuthorize("hasAuthority('inletFlowProportion.getInletFlowProportion')")
|
public ResultJson<List<InletFlowProportionListVo>> getInletFlowProportion(@RequestBody InletFlowProportionDto inletFlowProportionDto) {
|
List<InletFlowProportionListVo> inletFlowProportion = channelLogService.getInletFlowProportion(inletFlowProportionDto);
|
return ResultJson.ok(inletFlowProportion);
|
}
|
|
|
@ApiOperation(value = "会员权益兑换")
|
@GetMapping("/membershipInterests")
|
@PreAuthorize("hasAuthority('customer.membershipInterests')")
|
public ResultJson<String> backTongBaoMembershipInterests(@RequestParam String phone) {
|
String result = memberRightService.manualMembershipInterests(phone);
|
return ResultJson.ok(result);
|
}
|
|
@PostMapping(value = "/yxLoanApplyCallback")
|
@ApiOperation(value = "绿地用信结果通知")
|
public String yxLoanApplyCallback(@RequestBody Map<String, String> request) throws Exception {
|
String result = yiXinService.yxLoanApplyCallback(request);
|
return result;
|
}
|
|
@PostMapping(value = "/yxRepayPlanCallback")
|
@ApiOperation(value = "绿地还款计划变动通知")
|
public String yxRepayApplyCallback(@RequestBody Map<String, String> request) throws Exception {
|
String result = yiXinService.yxRepayPlanCallback(request);
|
return result;
|
}
|
|
|
@PostMapping(value = "/yxRepayResultCallback")
|
@ApiOperation(value = "绿地还款结果通知")
|
public String yxRepayResultCallback(@RequestBody Map<String, String> request) throws Exception {
|
String result = yiXinService.yxRepayResultCallback(request);
|
return result;
|
}
|
|
}
|
