傅行帆 5 年之前
父節點
當前提交
ab1752869a

+ 2
- 0
src/main/java/com/huiju/estateagents/common/CommConstant.java 查看文件

631
      */
631
      */
632
     public static final String HOUSE_DETAIL_PATH = "onlineSelling/pages/detail/index?id=%s";
632
     public static final String HOUSE_DETAIL_PATH = "onlineSelling/pages/detail/index?id=%s";
633
 
633
 
634
+    public static final String RAISE_DETAIL_PATH = "/onlineSelling/pages/raiseProfile/index?id=%s";
635
+
634
     /**
636
     /**
635
      * 已锁定
637
      * 已锁定
636
      */
638
      */

+ 52
- 0
src/main/java/com/huiju/estateagents/service/impl/TaRaiseRecordServiceImpl.java 查看文件

14
 import com.huiju.estateagents.common.CommConstant;
14
 import com.huiju.estateagents.common.CommConstant;
15
 import com.huiju.estateagents.entity.*;
15
 import com.huiju.estateagents.entity.*;
16
 import com.huiju.estateagents.mapper.*;
16
 import com.huiju.estateagents.mapper.*;
17
+import com.huiju.estateagents.po.TaHousingResourcesPO;
17
 import com.huiju.estateagents.service.ITaRaiseRecordService;
18
 import com.huiju.estateagents.service.ITaRaiseRecordService;
18
 import com.huiju.estateagents.service.ITaUvService;
19
 import com.huiju.estateagents.service.ITaUvService;
19
 import jodd.util.StringUtil;
20
 import jodd.util.StringUtil;
21
+import org.apache.commons.lang3.StringUtils;
20
 import org.slf4j.Logger;
22
 import org.slf4j.Logger;
21
 import org.slf4j.LoggerFactory;
23
 import org.slf4j.LoggerFactory;
22
 import org.springframework.beans.factory.annotation.Autowired;
24
 import org.springframework.beans.factory.annotation.Autowired;
24
 
26
 
25
 import java.time.LocalDateTime;
27
 import java.time.LocalDateTime;
26
 import java.util.List;
28
 import java.util.List;
29
+import java.util.concurrent.ExecutorService;
30
+import java.util.concurrent.Executors;
27
 
31
 
28
 /**
32
 /**
29
  * <p>
33
  * <p>
59
     @Autowired
63
     @Autowired
60
     private TaUserServiceImpl taUserService;
64
     private TaUserServiceImpl taUserService;
61
 
65
 
66
+    @Autowired
67
+    private MiniAppServiceImpl miniAppService;
68
+
69
+    @Autowired
70
+    private TaPersonServiceImpl taPersonService;
71
+
72
+    @Autowired
73
+    private TaBuildingMapper taBuildingMapper;
74
+
62
     @Override
75
     @Override
63
     public ResponseBean listHousingRaiseByCondition(HousingRaiseRequestBO requestBO, Integer pageNumber, Integer pageSize) {
76
     public ResponseBean listHousingRaiseByCondition(HousingRaiseRequestBO requestBO, Integer pageNumber, Integer pageSize) {
64
         logger.info("TaRaiseRecordServiceImpl.listRaiseRecordByCondition 接收参数:bo:{},pageNumber:{},pageSize:{}", JSONObject.toJSONString(requestBO), pageNumber, pageSize);
77
         logger.info("TaRaiseRecordServiceImpl.listRaiseRecordByCondition 接收参数:bo:{},pageNumber:{},pageSize:{}", JSONObject.toJSONString(requestBO), pageNumber, pageSize);
238
         taHousingResources.setHouseLockingStatus(CommConstant.HOUSE_LOCKING_STATUS_LOCKED);
251
         taHousingResources.setHouseLockingStatus(CommConstant.HOUSE_LOCKING_STATUS_LOCKED);
239
         taHousingResourcesMapper.updateById(taHousingResources);
252
         taHousingResourcesMapper.updateById(taHousingResources);
240
     }
253
     }
254
+
255
+
256
+    /**
257
+     * 发送认筹订阅消息
258
+     *
259
+     * @param raiseRecordId  认筹单ID
260
+     * @param personId   用户ID
261
+     * @param title  审核类型
262
+     * @param result     审核结果
263
+     * @param failReason 失败原因
264
+     * @param isSuccess  是否成功 true是(只有成功才发送短信)
265
+     */
266
+    public void sendRaiseMsg(Integer raiseRecordId, String personId, String title, String result, String failReason,String remark, Boolean isSuccess) {
267
+        logger.info("sendSubscribeMsg 接收参数:houseId:{},checkType:{},result:{},failReason:{}",
268
+                raiseRecordId, title, result, failReason);
269
+
270
+        ExecutorService threadPool = Executors.newCachedThreadPool();
271
+        threadPool.execute(() -> {
272
+            logger.info("sendSubscribeMsg 开始");
273
+
274
+            // 获取房源详情
275
+            TaRaiseRecord taRaiseRecord = taRaiseRecordMapper.selectById(raiseRecordId);
276
+            if (null == taRaiseRecord) {
277
+                logger.info("sendSubscribeMsg 未找到认筹单。");
278
+                return;
279
+            }
280
+            TaBuilding taBuilding = taBuildingMapper.selectById(taRaiseRecord.getBuildingId());
281
+            // 获取用户信息
282
+            TaPerson toUser = taPersonService.getById(personId);
283
+            if (toUser == null) {
284
+                return;
285
+            }
286
+
287
+            String link = String.format(CommConstant.RAISE_DETAIL_PATH, raiseRecordId);
288
+
289
+            miniAppService.sendCheckMessage(toUser, link, title, result, taBuilding.getBuildingName(), failReason, remark, LocalDateTime.now(), isSuccess);
290
+            logger.info("sendSubscribeMsg 结束");
291
+        });
292
+    }
241
 }
293
 }

+ 5
- 5
src/main/java/com/huiju/estateagents/service/impl/WxPayServiceImpl.java 查看文件

375
             throw new Exception("自动锁房只能认筹一个房源。");
375
             throw new Exception("自动锁房只能认筹一个房源。");
376
         }
376
         }
377
         //判断此房源有没有被锁定
377
         //判断此房源有没有被锁定
378
-        TaHousingResources taHousingResources = getHousingResourcesById(taRaiseHouseList.get(0).getHouseId());
379
-        if (taHousingResources.getHouseLockingStatus().equals(CommConstant.HOUSE_LOCKING_STATUS_LOCKED)){
380
-            throw new Exception("改房源已被锁定暂时无法认筹。");
381
-        }
378
+//        TaHousingResources taHousingResources = getHousingResourcesById(taRaiseHouseList.get(0).getHouseId());
379
+//        if (taHousingResources.getHouseLockingStatus().equals(CommConstant.HOUSE_LOCKING_STATUS_LOCKED)){
380
+//            throw new Exception("改房源已被锁定暂时无法认筹。");
381
+//        }
382
         //锁定此房源并且更改认筹单的锁定状态
382
         //锁定此房源并且更改认筹单的锁定状态
383
-        changeLockingStatus(taRaiseRecord,taRaiseHouseList.get(0),taHousingResources);
383
+//        changeLockingStatus(taRaiseRecord,taRaiseHouseList.get(0),taHousingResources);
384
     }
384
     }
385
 
385
 
386
     /**
386
     /**