认筹接口

src/main/java/com/huiju/estateagents/common/CommConstant.java

@@ -651,6 +651,11 @@ public class CommConstant {
      */
     public static final String HOUSE_LOCKING_TYPE_AUTO = "auto";
 
+    /**
+     * 手动锁房
+     */
+    public static final String HOUSE_LOCKING_TYPE_MANUAL = "manual";
+
     /**
      * 正在缴费
      */

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

@@ -411,4 +411,23 @@ public class TaRaiseRecordController extends BaseController {
         }
         return responseBean;
     }
+
+    /**
+     * 微信端下认筹单
+     *
+     * @param taRaiseRecord 实体对象
+     * @return
+     */
+    @RequestMapping(value = "/wx/taRaiseRecord", method = RequestMethod.POST)
+    public ResponseBean wxRaiseRecordAdd(@RequestBody TaRaiseRecord taRaiseRecord,HttpServletRequest request) {
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            responseBean.addSuccess(iTaRaiseRecordService.saveRaiseInfo(taRaiseRecord,getOrgId(request),getPersonId(request)));
+        } catch (Exception e) {
+            e.printStackTrace();
+            logger.error("taRaiseRecordAdd -=- {}", e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
 }

src/main/java/com/huiju/estateagents/entity/TaRaiseRecord.java

@@ -9,6 +9,8 @@ import lombok.experimental.Accessors;
 
 import java.io.Serializable;
 import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * <p>
@@ -171,4 +173,10 @@ public class TaRaiseRecord implements Serializable {
      */
     @TableField(exist = false)
     private String totalFee;
+
+    /**
+     *  小程序端提交的房源的id的集合
+     */
+    @TableField(exist = false)
+    private List<Integer> houseList = new ArrayList<>();
 }

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

@@ -51,4 +51,13 @@ public interface ITaRaiseRecordService extends IService<TaRaiseRecord> {
      * @return
      */
     ResponseBean listRaiseOrderByCondition(RaiseOrderRequestBO orderRequestBO, Integer pageNumber, Integer pageSize);
+
+    /**
+     * 小程序端保存认筹单信息
+     * @param taRaiseRecord
+     * @param orgId
+     * @param personId
+     * @return
+     */
+    TaRaiseRecord saveRaiseInfo(TaRaiseRecord taRaiseRecord, Integer orgId, String personId) throws Exception;
 }

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

@@ -8,8 +8,9 @@ import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.bo.request.HousingRaiseRequestBO;
 import com.huiju.estateagents.bo.request.RaiseOrderRequestBO;
 import com.huiju.estateagents.bo.request.RaiseRecordRequestBO;
-import com.huiju.estateagents.entity.TaRaiseRecord;
-import com.huiju.estateagents.mapper.TaRaiseRecordMapper;
+import com.huiju.estateagents.common.CommConstant;
+import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.mapper.*;
 import com.huiju.estateagents.po.TaHousingResourcesPO;
 import com.huiju.estateagents.service.ITaRaiseRecordService;
 import org.slf4j.Logger;
@@ -17,6 +18,9 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
+import java.util.List;
+
 /**
  * <p>
  * 认筹单(认筹记录表)  服务实现类
@@ -33,6 +37,21 @@ public class TaRaiseRecordServiceImpl extends ServiceImpl<TaRaiseRecordMapper, T
     @Autowired
     private TaRaiseRecordMapper taRaiseRecordMapper;
 
+    @Autowired
+    private TaRaiseMapper taRaiseMapper;
+
+    @Autowired
+    private TaHousingResourcesMapper taHousingResourcesMapper;
+
+    @Autowired
+    private TaSalesBatchMapper taSalesBatchMapper;
+
+    @Autowired
+    private TaPersonMapper taPersonMapper;
+
+    @Autowired
+    private TaRaiseHouseMapper taRaiseHouseMapper;
+
     @Override
     public ResponseBean listHousingRaiseByCondition(HousingRaiseRequestBO requestBO, Integer pageNumber, Integer pageSize) {
         logger.info("TaRaiseRecordServiceImpl.listRaiseRecordByCondition 接收参数：bo:{},pageNumber:{},pageSize:{}", JSONObject.toJSONString(requestBO), pageNumber, pageSize);
@@ -62,4 +81,92 @@ public class TaRaiseRecordServiceImpl extends ServiceImpl<TaRaiseRecordMapper, T
         responseBean.addSuccess(taRaiseRecordMapper.listRaiseOrderByCondition(pg, orderRequestBO));
         return responseBean;
     }
+
+    /**
+     * 小程序端保存认筹单信息
+     *
+     * @param taRaiseRecord
+     * @param orgId
+     * @param personId
+     * @return
+     */
+    @Override
+    public TaRaiseRecord saveRaiseInfo(TaRaiseRecord taRaiseRecord, Integer orgId, String personId) throws Exception {
+        List<Integer> houseList = taRaiseRecord.getHouseList();
+        if (houseList.size() < 1){
+            throw new Exception("请选择房源！");
+        }
+        //获取认筹信息
+        TaRaise taRaise = taRaiseMapper.selectById(taRaiseRecord.getRaiseId());
+        //如果是自动锁房就要判断里面的房源有没有被锁住
+        if (taRaise.getHouseLockingType().equals(CommConstant.HOUSE_LOCKING_TYPE_AUTO)){
+            if (houseList.size() > 0){
+                throw new Exception("此认筹为自动锁房只能选择一个房源！");
+            }
+            //获取房源详细信息
+            TaHousingResources taHousingResources = taHousingResourcesMapper.selectById(houseList.get(0));
+            if (null == taHousingResources){
+                throw new Exception("此房源不存在！");
+            }
+            if (taHousingResources.getHouseLockingStatus().equals(CommConstant.HOUSE_LOCKING_STATUS_LOCKED)){
+                throw new Exception("此房源已被锁定！");
+            }
+            //检验成功的话先锁定房源
+            lockedHouseResources(taHousingResources);
+        }
+        //插入认筹单
+        saveRaiseRecord(taRaiseRecord,orgId,personId,taRaise);
+
+        return taRaiseRecord;
+    }
+
+    /**
+     * 插入认筹单
+     * @param taRaiseRecord
+     */
+    private void saveRaiseRecord(TaRaiseRecord taRaiseRecord, Integer orgId, String personId,TaRaise taRaise) {
+        List<Integer> houseList = taRaiseRecord.getHouseList();
+        //销售批次信息
+        TaSalesBatch taSalesBatch = taSalesBatchMapper.selectById(taRaiseRecord.getSalesBatchId());
+        //获取用户信息
+
+        taRaiseRecord.setOrgId(orgId);
+        taRaiseRecord.setBuildingId(taSalesBatch.getBuildingId());
+        taRaiseRecord.setPersonId(personId);
+        taRaiseRecord.setHouseNum(houseList.size());
+        if (taRaise.getHouseLockingType().equals(CommConstant.HOUSE_LOCKING_TYPE_AUTO)){
+            taRaiseRecord.setHouseLockingStatus(CommConstant.HOUSE_LOCKING_STATUS_LOCKED);
+        }
+        taRaiseRecord.setStatus(CommConstant.STATUS_NORMAL);
+        taRaiseRecord.setPayStatus(CommConstant.PAY_STATUS_UNPAID);
+        taRaiseRecord.setPayType(taRaise.getPayType());
+        taRaiseRecord.setCreateDate(LocalDateTime.now());
+        //插入认筹单信息
+        taRaiseRecordMapper.insert(taRaiseRecord);
+        
+        //插入房源与认筹单关系表
+        TaPerson taPerson = taPersonMapper.selectById(personId);
+        houseList.forEach(e -> {
+            TaRaiseHouse taRaiseHouse = new TaRaiseHouse();
+            taRaiseHouse.setHouseId(e);
+            taRaiseHouse.setCreateDate(LocalDateTime.now());
+            if (taRaise.getHouseLockingType().equals(CommConstant.HOUSE_LOCKING_TYPE_AUTO)){
+                taRaiseHouse.setHouseLockingStatus(CommConstant.HOUSE_LOCKING_STATUS_LOCKED);
+            }
+            taRaiseHouse.setOrgId(orgId);
+            taRaiseHouse.setPersonId(personId);
+            taRaiseHouse.setPersonName(taPerson.getName());
+            taRaiseHouse.setRaiseRecordId(taRaiseRecord.getRaiseRecordId());
+            taRaiseHouseMapper.insert(taRaiseHouse);
+        });
+    }
+
+    /**
+     * 锁定房源
+     * @param taHousingResources
+     */
+    private synchronized void lockedHouseResources(TaHousingResources taHousingResources) {
+        taHousingResources.setHouseLockingStatus(CommConstant.HOUSE_LOCKING_STATUS_LOCKED);
+        taHousingResourcesMapper.updateById(taHousingResources);
+    }
 }