需求

src/main/java/com/huiju/estateagents/controller/TaRaiseRecordController.java

@@ -189,6 +189,8 @@ public class TaRaiseRecordController extends BaseController {
                 record.setInvalidReason(raiseRecord.getInvalidReason());
                 record.setUpdateDate(LocalDateTime.now());
                 record.setStatus(0);
+                //发送订阅消息
+                iTaRaiseRecordService.sendRaiseMsg(record.getRaiseRecordId(),record.getRaiseId(),"在线选房认筹通知","认筹单已作废","点击详情查看认筹单","具体原因查看详情",false);
             });
 
             if (iTaRaiseRecordService.updateBatchById(raiseRecord.getTaRaiseRecords())) {
@@ -230,6 +232,8 @@ public class TaRaiseRecordController extends BaseController {
                 }
                 record.setStatus(CommConstant.STATUS_DELETE);
                 record.setUpdateDate(LocalDateTime.now());
+                //发送订阅消息
+                iTaRaiseRecordService.sendRaiseMsg(record.getRaiseRecordId(),record.getRaiseId(),"在线选房认筹通知","认筹单已作废","点击详情查看认筹单","具体原因查看详情",false);
             });
 
             if (iTaRaiseRecordService.updateBatchById(raiseRecord.getTaRaiseRecords())) {
@@ -294,6 +298,8 @@ public class TaRaiseRecordController extends BaseController {
                 }
                 record.setPayStatus(CommConstant.PAY_STATUS_PAID);
                 record.setUpdateDate(LocalDateTime.now());
+                //发送订阅消息
+                iTaRaiseRecordService.sendRaiseMsg(record.getRaiseRecordId(),record.getRaiseId(),"在线选房认筹通知","认筹已缴费","点击详情查看认筹单","您的认筹已成功缴费",false);
             });
 
             if (iTaRaiseRecordService.updateBatchById(raiseRecord.getTaRaiseRecords())) {
@@ -364,6 +370,8 @@ public class TaRaiseRecordController extends BaseController {
                 record.setPayStatus(CommConstant.PAY_STATUS_REFUNDED);
                 record.setRefundReason(refundReason);
                 record.setUpdateDate(LocalDateTime.now());
+                //发送订阅消息
+                iTaRaiseRecordService.sendRaiseMsg(record.getRaiseRecordId(),record.getRaiseId(),"在线选房认筹通知","认筹已退费","点击详情查看认筹单","您的认筹已成功退费",false);
             });
 
             if (iTaRaiseRecordService.updateBatchById(raiseRecord.getTaRaiseRecords())) {

src/main/java/com/huiju/estateagents/service/ITaRaiseRecordService.java

@@ -80,4 +80,9 @@ public interface ITaRaiseRecordService extends IService<TaRaiseRecord> {
      * @return
      */
     Boolean addHouseNum(Integer raiseRecordId, Integer orgId, Integer userId);
+
+    /**
+     * 发送认筹消息
+     */
+    void sendRaiseMsg(Integer raiseRecordId, String personId, String title, String result, String reason,String remark, Boolean isSuccess);
 }

src/main/java/com/huiju/estateagents/service/impl/TaRaiseRecordServiceImpl.java

@@ -140,6 +140,9 @@ public class TaRaiseRecordServiceImpl extends ServiceImpl<TaRaiseRecordMapper, T
         //插入认筹单
         saveRaiseRecord(taRaiseRecord, orgId, personId, taRaise);
 
+        //发送订阅消息
+        sendRaiseMsg(taRaiseRecord.getRaiseRecordId(),personId,"在线选房认筹通知","已提交认筹","点击详情查看认筹单","房源紧俏，请赶紧缴费",true);
+
         return taRaiseRecord;
     }
 
@@ -232,6 +235,15 @@ public class TaRaiseRecordServiceImpl extends ServiceImpl<TaRaiseRecordMapper, T
             taRaiseHouse.setOrgId(orgId);
             taRaiseHouse.setRaiseRecordId(taRaiseRecord.getRaiseRecordId());
             taRaiseHouseMapper.insert(taRaiseHouse);
+
+            //更新房源的实际热度
+            TaHousingResources taHousingResources = taHousingResourcesMapper.selectById(e);
+            Integer raiseRealHeat = taHousingResources.getRaiseRealHeat();
+            if (null == raiseRealHeat){
+                raiseRealHeat = 0;
+            }
+            taHousingResources.setRaiseRealHeat(raiseRealHeat+1);
+            taHousingResourcesMapper.updateById(taHousingResources);
         });
 
         //把idcard字断更新进person表
@@ -260,12 +272,13 @@ public class TaRaiseRecordServiceImpl extends ServiceImpl<TaRaiseRecordMapper, T
      * @param personId   用户ID
      * @param title  审核类型
      * @param result     审核结果
-     * @param failReason 失败原因
+     * @param remark 失败原因
      * @param isSuccess  是否成功 true是(只有成功才发送短信)
      */
-    public void sendRaiseMsg(Integer raiseRecordId, String personId, String title, String result, String failReason,String remark, Boolean isSuccess) {
-        logger.info("sendSubscribeMsg 接收参数：houseId:{},checkType:{},result:{}，failReason:{}",
-                raiseRecordId, title, result, failReason);
+    @Override
+    public void sendRaiseMsg(Integer raiseRecordId, String personId, String title, String result, String reason,String remark, Boolean isSuccess) {
+        logger.info("sendSubscribeMsg 接收参数：houseId:{},checkType:{},result:{}，reason:{}, remark:{}",
+                raiseRecordId, title, result, reason, remark);
 
         ExecutorService threadPool = Executors.newCachedThreadPool();
         threadPool.execute(() -> {
@@ -286,7 +299,7 @@ public class TaRaiseRecordServiceImpl extends ServiceImpl<TaRaiseRecordMapper, T
 
             String link = String.format(CommConstant.RAISE_DETAIL_PATH, raiseRecordId);
 
-            miniAppService.sendCheckMessage(toUser, link, title, result, taBuilding.getBuildingName(), failReason, remark, LocalDateTime.now(), isSuccess);
+            miniAppService.sendCheckMessage(toUser, link, title, result, taBuilding.getBuildingName(), reason, remark, LocalDateTime.now(), isSuccess);
             logger.info("sendSubscribeMsg 结束");
         });
     }

src/main/java/com/huiju/estateagents/service/impl/WxPayServiceImpl.java

@@ -9,6 +9,7 @@ import com.huiju.estateagents.common.wxpay.WXPayUtil;
 import com.huiju.estateagents.common.wxpay.WxConfig;
 import com.huiju.estateagents.entity.*;
 import com.huiju.estateagents.mapper.*;
+import com.huiju.estateagents.service.ITaRaiseRecordService;
 import com.huiju.estateagents.service.IWxPayService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -58,6 +59,9 @@ public class WxPayServiceImpl implements IWxPayService {
     @Autowired
     private TaPersonMapper taPersonMapper;
 
+    @Autowired
+    private ITaRaiseRecordService taRaiseRecordService;
+
     /**
      * 微信支付-统一下单
      *
@@ -204,6 +208,8 @@ public class WxPayServiceImpl implements IWxPayService {
                 taRaiseRecordMapper.updateById(taRaiseRecord);
                 //更新退款时间
                 e.setPayTime(LocalDateTime.now());
+                //发送订阅消息
+                taRaiseRecordService.sendRaiseMsg(taRaiseRecord.getRaiseRecordId(),taRaiseRecord.getRaiseId(),"在线选房认筹通知","线上退费成功","点击详情查看认筹单","线上退费成功",false);
             }
             taOrderMapper.updateById(e);
         });
@@ -266,6 +272,8 @@ public class WxPayServiceImpl implements IWxPayService {
         TaRaiseRecord taRaiseRecord = taRaiseRecordMapper.selectById(taOrder.getTargetId());
         taRaiseRecord.setRefundReason(taOrder.getRefundReason());
         taRaiseRecordMapper.updateById(taRaiseRecord);
+        //发送订阅消息
+        taRaiseRecordService.sendRaiseMsg(taRaiseRecord.getRaiseRecordId(),taRaiseRecord.getRaiseId(),"在线选房认筹通知","认筹正在退费","点击详情查看认筹单","正在等待微信或银行到账",false);
     }
 
     /**
@@ -321,6 +329,9 @@ public class WxPayServiceImpl implements IWxPayService {
         TaRaiseRecord taRaiseRecord = taRaiseRecordMapper.selectById(taOrder.getTargetId());
         taRaiseRecord.setPayStatus(CommConstant.PAY_STATUS_PAID);
         taRaiseRecordMapper.updateById(taRaiseRecord);
+
+        //发送订阅消息
+        taRaiseRecordService.sendRaiseMsg(taRaiseRecord.getRaiseRecordId(),taRaiseRecord.getRaiseId(),"在线选房认筹通知","认筹支付成功","点击详情查看认筹单","已付款成功",false);
     }
 
     /**