feats

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

@@ -27,14 +27,29 @@ public class BkNotice implements Serializable {
     private static final long serialVersionUID = 1L;
 
     @ApiModelProperty(value = "公告ID")
-    @TableId(value = "notice_id", type = IdType.INPUT)
-    private String noticeId;
+    @TableId(value = "notice_id", type = IdType.AUTO)
+    private Integer noticeId;
+
+    @ApiModelProperty(value = "消息类型")
+    private String noticeType;
 
     @ApiModelProperty(value = "楼盘ID")
     private String buildingId;
 
     @ApiModelProperty(value = "楼盘名称")
-    private String builidngName;
+    private String buildingName;
+
+    @ApiModelProperty(value = "经纪人ID")
+    private String personId;
+
+    @ApiModelProperty(value = "经纪人名称")
+    private String personName;
+
+    @ApiModelProperty(value = "客户ID")
+    private String customerId;
+
+    @ApiModelProperty(value = "客户名称")
+    private String customerName;
 
     @ApiModelProperty(value = "公告内容")
     private String content;

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

@@ -3,6 +3,7 @@ package com.yunzhi.marketing.broker.mapper;
 import com.yunzhi.marketing.broker.entity.BkNotice;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * <p>
@@ -15,4 +16,7 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface BkNoticeMapper extends BaseMapper<BkNotice> {
 
+    BkNotice getByPerson(@Param("noticeType") String noticeType,
+                         @Param("personId") String personId,
+                         @Param("customerId") String customerId);
 }

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

@@ -958,8 +958,8 @@ public class CommConstant {
      * 课程授权人员类型
      */
     public static final String CURRICULUM_TYPE_AGENT = "1";
-    public static final String CURRICULUM_TYPE_COUSULTANT = "2";
-    public static final String CURRICULUM_TYPE_COUSULTANT_AND_AGENT = "3";
+    public static final String CURRICULUM_TYPE_CONSULTANT = "2";
+    public static final String CURRICULUM_TYPE_CONSULTANT_AND_AGENT = "3";
 
     /**
      * 渠道报备客户审核结果
@@ -971,5 +971,10 @@ public class CommConstant {
      * 根机构ID
      */
     public static final String ROOT_INSTITUTION = "1"; // 原来是 01 估计是个 bug
+
+    /** 成交喜报 **/
+    public static final String NOTICE_TYPE_DEAL = "deal";
+    /** 客户状态变成 **/
+    public static final String NOTICE_TYPE_STATUS_CHANGE = "status-change";
 }
 

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

@@ -298,9 +298,9 @@ public class CurriculumController extends BaseController {
         }
 
         switch (requireRole) {
-            case CommConstant.CURRICULUM_TYPE_COUSULTANT_AND_AGENT:
+            case CommConstant.CURRICULUM_TYPE_CONSULTANT_AND_AGENT:
                 return CommConstant.PERSON_ESTATE_CHANNEL.equals(personType) || CommConstant.PERSON_REALTY_CONSULTANT.equals(personType);
-            case CommConstant.CURRICULUM_TYPE_COUSULTANT:
+            case CommConstant.CURRICULUM_TYPE_CONSULTANT:
                 return CommConstant.PERSON_REALTY_CONSULTANT.equals(personType);
             case CommConstant.CURRICULUM_TYPE_AGENT:
                 return CommConstant.PERSON_ESTATE_CHANNEL.equals(personType);

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

@@ -8,9 +8,11 @@ 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.entity.BkNotice;
 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.broker.mapper.BkNoticeMapper;
 import com.yunzhi.marketing.center.taUser.entity.TaUser;
 import com.yunzhi.marketing.center.taUser.mapper.TaUserMapper;
 import com.yunzhi.marketing.common.CommConstant;
@@ -81,6 +83,9 @@ public class ChannelCustomerServiceImpl extends ServiceImpl<ChannelCustomerMappe
     @Autowired
     private BkAccountRecordMapper bkAccountRecordMapper;
 
+    @Autowired
+    private BkNoticeMapper bkNoticeMapper;
+
     /**
      * 审核
      *
@@ -632,6 +637,39 @@ public class ChannelCustomerServiceImpl extends ServiceImpl<ChannelCustomerMappe
             bkAccountRecord.setCreateDate(LocalDateTime.now());
             bkAccountRecordMapper.insert(bkAccountRecord);
         }
+
+        // 生成节点变更通知
+        BkNotice changeNotice = new BkNotice();
+        changeNotice.setOrgId(taBuilding.getOrgId().toString());
+        changeNotice.setInstitutionId(taBuilding.getInstitutionId());
+        changeNotice.setBuildingId(taBuilding.getBuildingId());
+        changeNotice.setBuildingName(taBuilding.getBuildingName());
+        changeNotice.setPersonId(recommendPerson.getPersonId());
+        changeNotice.setPersonName(StringUtils.ifNull(recommendPerson.getName(), recommendPerson.getNickname()));
+        changeNotice.setCustomerId(customer.getCustomerId());
+        changeNotice.setCustomerName(customer.getName());
+        changeNotice.setNoticeType(CommConstant.NOTICE_TYPE_STATUS_CHANGE);
+        changeNotice.setContent(String.format("状态 %s", getStatusDesc(bizType)));
+        bkNoticeMapper.insert(changeNotice);
+
+
+        // 生成成交喜报
+        BkNotice bkNotice = bkNoticeMapper.getByPerson(CommConstant.NOTICE_TYPE_DEAL, recommendPerson.getName(), customer.getCustomerId());
+        if (null == bkNotice) {
+            bkNotice = new BkNotice();
+            bkNotice.setOrgId(taBuilding.getOrgId().toString());
+            bkNotice.setInstitutionId(taBuilding.getInstitutionId());
+            bkNotice.setBuildingId(taBuilding.getBuildingId());
+            bkNotice.setBuildingName(taBuilding.getBuildingName());
+            bkNotice.setPersonId(recommendPerson.getPersonId());
+            bkNotice.setPersonName(StringUtils.ifNull(recommendPerson.getName(), recommendPerson.getNickname()));
+            bkNotice.setCustomerId(customer.getCustomerId());
+            bkNotice.setCustomerName(customer.getName());
+            // 佣金消息
+            bkNotice.setNoticeType(CommConstant.NOTICE_TYPE_DEAL);
+            bkNotice.setContent(String.format("佣金 %d", params.getTotalCommission()));
+            bkNoticeMapper.insert(bkNotice);
+        }
     }
 
     /**
@@ -660,5 +698,19 @@ public class ChannelCustomerServiceImpl extends ServiceImpl<ChannelCustomerMappe
 
         bkInviteRecord.setReferralFee(agentRule.getReferralFee());
         bkInviteRecordMapper.updateById(bkInviteRecord);
+
+    }
+
+    private String getStatusDesc(String bizType) {
+        switch (bizType) {
+            case "commission":
+                return "结佣";
+            case "signatory":
+                return "签约";
+            case "all-payment":
+                return "全款到账";
+            default:
+                return "未知";
+        }
     }
 }

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

@@ -44,11 +44,11 @@ public class CurriculumServiceImpl extends ServiceImpl<CurriculumMapper, Curricu
     public IPage<Curriculum> getWxList(IPage<Curriculum> pg, String name, TaPerson person) {
         List<String> roleList = new ArrayList<>();
         if (CommConstant.PERSON_REALTY_CONSULTANT.equals(person.getPersonType())) {
-            roleList.add(CommConstant.CURRICULUM_TYPE_COUSULTANT);
-            roleList.add(CommConstant.CURRICULUM_TYPE_COUSULTANT_AND_AGENT);
+            roleList.add(CommConstant.CURRICULUM_TYPE_CONSULTANT);
+            roleList.add(CommConstant.CURRICULUM_TYPE_CONSULTANT_AND_AGENT);
         } else if (CommConstant.PERSON_ESTATE_CHANNEL.equals(person.getPersonType())) {
             roleList.add(CommConstant.CURRICULUM_TYPE_AGENT);
-            roleList.add(CommConstant.CURRICULUM_TYPE_COUSULTANT_AND_AGENT);
+            roleList.add(CommConstant.CURRICULUM_TYPE_CONSULTANT_AND_AGENT);
         } else {
             roleList.add("*");
         }

src/main/resources/mapper/BkNoticeMapper.xml

@@ -2,4 +2,14 @@
 <!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.BkNoticeMapper">
 
+    <select id="getByPerson" resultType="com.yunzhi.marketing.broker.entity.BkNotice">
+        SELECT
+            *
+        FROM
+            bk_notice t
+        WHERE
+            t.notice_type = #{noticeType}
+          AND t.person_id = #{personId}
+          AND t.customer_id = #{customerId}
+    </select>
 </mapper>