feats

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

 import com.yunzhi.marketing.broker.entity.BkAccountRecord;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * <p>
 @Mapper
 public interface BkAccountRecordMapper extends BaseMapper<BkAccountRecord> {
 
+    Integer getTotalChargesBy(@Param("channelCustomerId") String channelCustomerId,
+                              @Param("chargeCode") String chargeCode);
+
+    BkAccountRecord getRecordBy(@Param("channelCustomerId") String channelCustomerId,
+                                @Param("chargeCode") String chargeCode);
 }

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.BkAccountRecord;
 import com.yunzhi.marketing.broker.entity.BkAgentRule;
 import com.yunzhi.marketing.broker.entity.BkInviteRecord;
+import com.yunzhi.marketing.broker.mapper.BkAccountRecordMapper;
 import com.yunzhi.marketing.broker.mapper.BkAgentRuleMapper;
 import com.yunzhi.marketing.broker.mapper.BkInviteRecordMapper;
 import com.yunzhi.marketing.center.taUser.entity.TaUser;
     @Autowired
     private BkAgentRuleMapper bkAgentRuleMapper;
 
+    @Autowired
+    private BkAccountRecordMapper bkAccountRecordMapper;
+
     /**
      * 审核
      *
                 customer.setRealtyConsultant(customerSignatory.getRealtyConsultant());
             }
 
-            channelCustomerMapper.updateById(customer);
-
             // 全民经纪人佣金处理
             boolean isBroker = CommConstant.PERSON_BROKER.equals(customer.getRecommendPersonType());
             if (isBroker) {
                 // 处理推荐金额问题
                 processInviteRecord(recommendPerson, taBuilding);
-                //
-
+                // 记录佣金金额
+                if (null != params.getTotalCommission() && params.getTotalCommission() > 0) {
+                    processCommission(params, customer, recommendPerson, bizType, taBuilding);
+                }
             }
+
+            channelCustomerMapper.updateById(customer);
         }
 
         // 置业顾问-接待人
         }
     }
 
+    private Integer intIfNvl(Integer i) {
+        return i == null ? 0 : i;
+    }
+
+    private void processCommission(MarkingSignatoryCustomerDTO params, ChannelCustomer customer, TaPerson recommendPerson, String bizType, TaBuilding taBuilding) {
+        if (null == recommendPerson) return;
+
+        // 为了防止数据有改动, 比如更新操作
+        // 那么需要把原来的值减掉,再使用新的值
+        Integer totalCommission = intIfNvl(recommendPerson.getTotalCommission()) -
+                intIfNvl(customer.getTotalCommission()) +
+                intIfNvl(params.getTotalCommission());
+        recommendPerson.setTotalCommission(totalCommission);
+        customer.setTotalCommission(intIfNvl(params.getTotalCommission()));
+
+        Integer settledCommission = intIfNvl(bkAccountRecordMapper.getTotalChargesBy(customer.getChannelCustomerId(), bizType));
+        settledCommission += intIfNvl(params.getSettledCommission()); // 最新的需要加上本次结算佣金
+        recommendPerson.setSettledCommission(intIfNvl(recommendPerson.getSettledCommission()) -
+                intIfNvl(customer.getSettledCommission()) +
+                settledCommission);
+        customer.setSettledCommission(settledCommission);
+        customer.setUnsettledCommission(customer.getTotalCommission() - customer.getSettledCommission());
+
+        // 更新记录, customer 在本函数外部更新
+        taPersonMapper.updateById(recommendPerson);
+
+        // 生成佣金记录
+        BkAccountRecord bkAccountRecord = bkAccountRecordMapper.getRecordBy(customer.getChannelCustomerId(), bizType);
+        if (bkAccountRecord != null) {
+            bkAccountRecord.setCharges(params.getSettledCommission());
+            bkAccountRecordMapper.updateById(bkAccountRecord);
+        } else {
+            bkAccountRecord = new BkAccountRecord();
+            bkAccountRecord.setChannelCustomerId(customer.getChannelCustomerId());
+            bkAccountRecord.setPersonId(recommendPerson.getPersonId());
+            bkAccountRecord.setBuildingId(taBuilding.getBuildingId());
+            bkAccountRecord.setBuildingName(StringUtils.ifNull(taBuilding.getName(), taBuilding.getBuildingName()));
+            bkAccountRecord.setCustomerName(customer.getName());
+            bkAccountRecord.setCharges(intIfNvl(params.getSettledCommission()));
+            bkAccountRecord.setChargeType(1);
+            bkAccountRecord.setChargeCode(bizType);
+            bkAccountRecord.setStatus(CommConstant.STATUS_NORMAL);
+            bkAccountRecord.setCreateDate(LocalDateTime.now());
+            bkAccountRecordMapper.insert(bkAccountRecord);
+        }
+    }
+
     /**
      * 处理推荐金
      * @param recommendPerson

src/main/resources/mapper/BkAccountRecordMapper.xml

 <!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.BkAccountRecordMapper">
 
+    <select id="getTotalChargesBy" resultType="java.lang.Integer">
+        SELECT
+            SUM( t.charges )
+        FROM
+            bk_account_record t
+        WHERE
+            t.channel_customer_id = #{channelCustomerId}
+          <if test="chargeCode != null and chargeCode != ''">
+              AND t.charge_code != #{chargeCode}
+          </if>
+          AND t.`status` &gt; -1
+    </select>
+    <select id="getRecordBy" resultType="com.yunzhi.marketing.broker.entity.BkAccountRecord">
+        SELECT
+            *
+        FROM
+            bk_account_record t
+        WHERE
+            t.channel_customer_id = #{channelCustomerId}
+            AND t.charge_code != #{chargeCode}
+            AND t.`status` &gt; -1
+    </select>
 </mapper>