| package com.xzx.gc.user.controller;  | 
|   | 
|   | 
| import cn.hutool.core.collection.CollUtil;  | 
| import cn.hutool.core.convert.Convert;  | 
| import cn.hutool.core.date.DateUtil;  | 
| import com.xzx.gc.common.Result;  | 
| import com.xzx.gc.common.annotations.PassToken;  | 
| import com.xzx.gc.common.constant.Constants;  | 
| import com.xzx.gc.common.dto.log.OperationAppLog;  | 
| import com.xzx.gc.common.request.BaseController;  | 
| import com.xzx.gc.common.utils.MqUtil;  | 
| import com.xzx.gc.entity.AddressLevelInfo;  | 
| import com.xzx.gc.entity.PartnerTarget;  | 
| import com.xzx.gc.user.mapper.PartnerTargetMapper;  | 
| import com.xzx.gc.user.service.AddressLevelService;  | 
| import com.xzx.gc.user.service.UserService;  | 
| import io.swagger.annotations.Api;  | 
| import io.swagger.annotations.ApiOperation;  | 
| import lombok.extern.slf4j.Slf4j;  | 
| import org.springframework.beans.factory.annotation.Autowired;  | 
| import org.springframework.validation.annotation.Validated;  | 
| 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 javax.servlet.http.HttpServletRequest;  | 
| import java.util.List;  | 
|   | 
| @Api(tags = "意向合伙人管理")  | 
| @RestController  | 
| @Slf4j  | 
| @Validated  | 
| public class PartnerTargetController extends BaseController {  | 
|   | 
|   | 
|     @Autowired  | 
|     private PartnerTargetMapper partnerTargetMapper;  | 
|   | 
|     @Autowired  | 
|     private AddressLevelService addressLevelService;  | 
|   | 
|     @Autowired  | 
|     private UserService userService;  | 
|   | 
|     @Autowired  | 
|     private MqUtil mqUtil;  | 
|   | 
|   | 
|   | 
|     @ApiOperation( value = "新增意向合伙人")  | 
|     @PostMapping("/partnerTarget/add")  | 
|     @PassToken  | 
|     public Result partnerTargetAdd(HttpServletRequest request, @RequestBody PartnerTarget partnerTarget) {  | 
|   | 
|   | 
|         //根据名字和手机号去重  | 
|         PartnerTarget partnerTarget1=new PartnerTarget();  | 
|         partnerTarget1.setName(partnerTarget.getName());  | 
|         partnerTarget1.setMobile(partnerTarget.getMobile());  | 
|         int i = partnerTargetMapper.selectCount(partnerTarget1);  | 
|   | 
|         if(i==0) {  | 
|             partnerTarget.setCreateTime(DateUtil.now());  | 
|             AddressLevelInfo addressLevelInfo = new AddressLevelInfo();  | 
|             addressLevelInfo.setLevel1Name(partnerTarget.getProviceName());  | 
|             addressLevelInfo.setLevel2Name(partnerTarget.getCityName());  | 
|             List<AddressLevelInfo> byAny = addressLevelService.findByAny(addressLevelInfo);  | 
|             if (CollUtil.isNotEmpty(byAny)) {  | 
|                 partnerTarget.setProviceId(Convert.toInt(byAny.get(0).getLevel1Id()));  | 
|                 partnerTarget.setCityId(Convert.toInt(byAny.get(0).getLevel2Id()));  | 
|             }  | 
|             partnerTargetMapper.insertSelective(partnerTarget);  | 
|   | 
|             String mobilePhone = userService.findOtherByUserId(getUserId(request), 0);  | 
|             OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)  | 
|                     .methodName(Constants.USER_MODUL_NAME).operateAction("新增意向合伙人-" + partnerTarget.getId()).build();  | 
|             mqUtil.sendApp(build);  | 
|         }  | 
|         return Result.success(null);  | 
|     }  | 
| }  |