eats

src/main/java/com/yunzhi/marketing/broker/controller/BkInviteRecordController.java

+package com.yunzhi.marketing.broker.controller;
+
+import com.yunzhi.marketing.broker.service.IBkInviteRecordService;
+import io.swagger.annotations.Api;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Api(tags = "经济人邀请记录对象功能接口")
+@RestController
+@RequestMapping("/")
+public class BkInviteRecordController {
+    @Autowired
+    private IBkInviteRecordService bkInviteRecordService;
+}

src/main/java/com/yunzhi/marketing/broker/controller/BrokerController.java

 import com.yunzhi.marketing.base.BaseController;
 import com.yunzhi.marketing.base.ResponseBean;
 import com.yunzhi.marketing.broker.service.IBkBankCardService;
+import com.yunzhi.marketing.broker.service.IBkInviteRecordService;
 import com.yunzhi.marketing.broker.vo.BrokerSummery;
 import com.yunzhi.marketing.broker.vo.BrokerVO;
 import com.yunzhi.marketing.common.CommConstant;
     @Autowired
     IBkBankCardService iBkBankCardService;
 
+    @Autowired
+    IBkInviteRecordService iBkInviteRecordService;
+
 
     @RequestMapping(value="/admin/broker",method= RequestMethod.GET)
     @ApiOperation(value="经纪人列表", notes = "经纪人列表", httpMethod = "GET", response = ResponseBean.class)
         taPerson.setSettledCommission(null);
         taPerson.setUnsettledCommission(null);
 
+
         // 更新数据
         if (!iTaPersonService.updateById(taPerson)) {
 
-            // 如果是有人推荐的, 那么需要给予推荐人一定的奖励
+            // 如果是有人推荐的, 那么需要生成推荐记录
             if (!StringUtils.isEmpty(brokerVO.getRecommendAgent())) {
-                // TODO
+                iBkInviteRecordService.createBy(brokerVO.getRecommendAgent(), brokerVO.getPersonId());
             }
 
             return ResponseBean.error("操作失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);

src/main/java/com/yunzhi/marketing/broker/entity/BkAgentRule.java

 import com.baomidou.mybatisplus.annotation.TableId;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
+import io.swagger.models.auth.In;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
     @ApiModelProperty(value = "规则内容")
     private String content;
 
+    @ApiModelProperty(value = "推荐金额")
+    private Integer referralFee;
+
     @ApiModelProperty(value = "机构ID")
     private Integer orgId;
 

src/main/java/com/yunzhi/marketing/broker/entity/BkInviteRecord.java

+package com.yunzhi.marketing.broker.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="BkInviteRecord对象", description="经济人邀请记录")
+public class BkInviteRecord implements Serializable {
+    /** ID */
+    @ApiModelProperty(name = "ID",notes = "")
+    @TableId(value = "invite_id", type = IdType.AUTO)
+    private Integer inviteId ;
+    /** 经纪人ID */
+    @ApiModelProperty(name = "经纪人ID",notes = "")
+    private String personId ;
+    /** 经纪人名称 */
+    @ApiModelProperty(name = "经纪人名称",notes = "")
+    private String personName ;
+    /** 被邀请人ID */
+    @ApiModelProperty(name = "被邀请人ID",notes = "")
+    private String invitePersonId ;
+    /** 被邀请人名称 */
+    @ApiModelProperty(name = "被邀请人名称",notes = "")
+    private String invitePersonName ;
+    /** 推荐金额 */
+    @ApiModelProperty(name = "推荐金额",notes = "")
+    private Integer referralFee ;
+    /** 状态 */
+    @ApiModelProperty(name = "状态",notes = "")
+    private Integer status;
+    /** 创建时间 */
+    @ApiModelProperty(name = "创建时间",notes = "")
+    private LocalDateTime createDate ;
+}

src/main/java/com/yunzhi/marketing/broker/mapper/BkAgentRuleMapper.java

 
     BkAgentRule getByOrgId(@Param("orgId") Integer orgId,
                            @Param("status") Integer status);
+
+    BkAgentRule getByCity(@Param("cityId") Integer cityId);
 }

src/main/java/com/yunzhi/marketing/broker/mapper/BkInviteRecordMapper.java

+package com.yunzhi.marketing.broker.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yunzhi.marketing.broker.entity.BkInviteRecord;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+
+/**
+ * 经济人邀请记录;(bk_invite_record)表数据库访问层
+ * @author : http://www.chiner.pro
+ * @date : 2022-8-4
+ */
+@Mapper
+public interface BkInviteRecordMapper  extends BaseMapper<BkInviteRecord>{
+    BkInviteRecord getByPerson(@Param("personId") String personId, @Param("invitePersonId") String invitePersonId);
+
+    int createBy(@Param("personId") String personId, @Param("invitePersonId") String invitePersonId);
+}

src/main/java/com/yunzhi/marketing/broker/service/IBkInviteRecordService.java

+package com.yunzhi.marketing.broker.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.marketing.broker.entity.BkInviteRecord;
+
+public interface IBkInviteRecordService  extends IService<BkInviteRecord> {
+    void createBy(String personId, String invitePersonId);
+}

src/main/java/com/yunzhi/marketing/broker/service/impl/BkInviteRecordServiceImpl.java

+package com.yunzhi.marketing.broker.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yunzhi.marketing.broker.entity.BkInviteRecord;
+import com.yunzhi.marketing.broker.mapper.BkInviteRecordMapper;
+import com.yunzhi.marketing.broker.service.IBkInviteRecordService;
+import com.yunzhi.marketing.common.StringUtils;
+import com.yunzhi.marketing.entity.TaPerson;
+import com.yunzhi.marketing.mapper.TaPersonMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class BkInviteRecordServiceImpl extends ServiceImpl<BkInviteRecordMapper, BkInviteRecord> implements IBkInviteRecordService {
+    @Autowired
+    TaPersonMapper taPersonMapper;
+
+    @Override
+    public void createBy(String personId, String invitePersonId) {
+        // 先查询是否已经有记录了
+        BkInviteRecord bkInviteRecord = baseMapper.getByPerson(personId, invitePersonId);
+        if (null != bkInviteRecord) return;
+
+        baseMapper.createBy(personId, invitePersonId);
+    }
+}

src/main/java/com/yunzhi/marketing/common/CommConstant.java

      */
     public static final Integer CUSTOMER_COMMISSION = 5;
 
+    /**
+     * 全款到账
+     */
+    public static final Integer CUSTOMER_ALL_PAYMENT = 6;
+
     /**
      * 待审核
      */

src/main/java/com/yunzhi/marketing/xlk/controller/ChannelCustomerController.java

             bizStatus = CommConstant.CUSTOMER_COMMISSION;
         } else if ("signatory".equals(bizType)) {
             bizStatus = CommConstant.CUSTOMER_SIGNED;
+        } else if ("all-payment".equals(bizType)) {
+            bizStatus = CommConstant.CUSTOMER_ALL_PAYMENT;
         }
 
 //        return iChannelCustomerService.commissionCustomer(params);

src/main/java/com/yunzhi/marketing/xlk/service/impl/ChannelCustomerServiceImpl.java

 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.yunzhi.marketing.base.ResponseBean;
+import com.yunzhi.marketing.broker.entity.BkAgentRule;
+import com.yunzhi.marketing.broker.entity.BkInviteRecord;
+import com.yunzhi.marketing.broker.mapper.BkAgentRuleMapper;
+import com.yunzhi.marketing.broker.mapper.BkInviteRecordMapper;
 import com.yunzhi.marketing.center.taUser.entity.TaUser;
 import com.yunzhi.marketing.center.taUser.mapper.TaUserMapper;
 import com.yunzhi.marketing.common.CommConstant;
 
     @Autowired
     private InstitutionMapper institutionMapper;
+
+    @Autowired
+    private BkInviteRecordMapper bkInviteRecordMapper;
+
+    @Autowired
+    private BkAgentRuleMapper bkAgentRuleMapper;
+
     /**
      * 审核
      *
         }
         taRecommendCustomer.setStatus(bizStatus);
         taRecommendCustomerMapper.updateById(taRecommendCustomer);
+        //
+        customerSignatory.setOrgId(taRecommendCustomer.getOrgId());
+        customerSignatory.setBuildingId(taRecommendCustomer.getBuildingId());
+        TaBuilding taBuilding = taBuildingMapper.selectById(taRecommendCustomer.getBuildingId());
+        if (taBuilding == null) {
+            throw new Exception("校验客户及楼盘信息异常");
+        }
+
+        // 推荐人
+        customerSignatory.setRecommendPerson(taRecommendCustomer.getRecommendPerson());
+        TaPerson recommendPerson = taPersonMapper.getById(taRecommendCustomer.getRecommendPerson());
+        if (null != recommendPerson) {
+            customerSignatory.setRecommendName(recommendPerson.getName());
+        }
 
         // 更新报备记录
         LambdaQueryWrapper<ChannelCustomer> channelCustomerLambdaQueryWrapper = new LambdaQueryWrapper<>();
             // 全民经纪人佣金处理
             boolean isBroker = CommConstant.PERSON_BROKER.equals(customer.getRecommendPersonType());
             if (isBroker) {
-                
-            }
-        }
+                // 处理推荐金额问题
+                processInviteRecord(recommendPerson, taBuilding);
+                //
 
-        // 推荐人
-        customerSignatory.setRecommendPerson(taRecommendCustomer.getRecommendPerson());
-        TaPerson recommendPerson = taPersonMapper.getById(taRecommendCustomer.getRecommendPerson());
-        if (null != recommendPerson) {
-            customerSignatory.setRecommendName(recommendPerson.getName());
+            }
         }
 
-        // 职业顾问-接待人
+        // 置业顾问-接待人
         if (!StringUtils.isEmpty(customerSignatory.getRealtyConsultant())) {
             TaPerson realtyConsultant = taPersonMapper.getById(customerSignatory.getRealtyConsultant());
             if (null != realtyConsultant) {
             }
         }
 
-        //
-        customerSignatory.setOrgId(taRecommendCustomer.getOrgId());
-        customerSignatory.setBuildingId(taRecommendCustomer.getBuildingId());
-
         // 更新
         if (StringUtils.isEmpty(customerSignatory.getCustomerSignatoryId())){
             customerSignatoryMapper.insert(customerSignatory);
             customerSignatoryMapper.updateById(customerSignatory);
         }
     }
+
+    /**
+     * 处理推荐金
+     * @param recommendPerson
+     * @param taBuilding
+     */
+    private void processInviteRecord(TaPerson recommendPerson, TaBuilding taBuilding) {
+        // 推荐人员
+        String personId = recommendPerson.getRecommendAgent();
+        if (StringUtils.isEmpty(personId)) return;
+
+        // 查询推荐记录
+        BkInviteRecord bkInviteRecord = bkInviteRecordMapper.getByPerson(personId, recommendPerson.getPersonId());
+        if (null == bkInviteRecord) {
+            bkInviteRecordMapper.createBy(personId, recommendPerson.getPersonId());
+            bkInviteRecord = bkInviteRecordMapper.getByPerson(personId, recommendPerson.getPersonId());
+        }
+
+        // 大于0 代表已经计算过推荐费用
+        if (bkInviteRecord.getReferralFee() > 0) return;
+
+        // 查询推荐费用
+        BkAgentRule agentRule = bkAgentRuleMapper.getByCity(taBuilding.getCityId());
+        if (null == agentRule) return;
+
+        bkInviteRecord.setReferralFee(agentRule.getReferralFee());
+        bkInviteRecordMapper.updateById(bkInviteRecord);
+    }
 }

src/main/resources/mapper/BkAgentrRuleMapper.xml

             t.create_date DESC
             LIMIT 1
     </select>
+    <select id="getByCity" resultType="com.yunzhi.marketing.broker.entity.BkAgentRule">
+        SELECT
+            *
+        FROM
+            bk_agent_rule t
+        WHERE
+            t.city_id = #{cityId}
+            AND t.`status` &gt; -1
+        ORDER BY
+            t.create_date DESC
+            LIMIT 1
+    </select>
 </mapper>

src/main/resources/mapper/BkInviteRecordMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.yunzhi.marketing.broker.mapper.BkInviteRecordMapper">
+    <insert id="createBy">
+        INSERT bk_invite_record ( person_id, person_name, invite_person_id, invite_person_name )
+        SELECT
+            t.person_id,
+            IFNULL( t.NAME, t.nickname ),
+            s.person_id,
+            IFNULL( s.NAME, s.nickname )
+        FROM
+            ta_person t,
+            ta_person s
+        WHERE
+            t.person_id = #{personId}
+          AND s.person_id = #{invitePersonId}
+    </insert>
+    <select id="getByPerson" resultType="com.yunzhi.marketing.broker.entity.BkInviteRecord">
+        SELECT
+            *
+        FROM
+            bk_invite_record t
+        WHERE
+            t.person_id = #{personId}
+          AND t.invite_person_id = #{invitePersonId}
+          AND t.`status` &gt; -1
+    </select>
+</mapper>