帮我买房

pom.xml

 	</parent>
 	<groupId>com.yunzhi</groupId>
 	<artifactId>marketing</artifactId>
-	<version>v1.0.18</version>
+	<version>v1.0.19</version>
 	<name>marketing-cloud</name>
 	<description>新联康营销云</description>
 

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

      */
     @ApiOperation(value = "wx-保存帮我找房需求", notes = "wx-保存帮我找房需求")
     @RequestMapping(value="/wx/searchHouse",method= RequestMethod.POST)
-    public ResponseBean searchHouseAdd(@RequestBody SearchHouseDTO searchHouseDTO, @RequestHeader("authorization") String token, HttpServletRequest request){
+    public ResponseBean searchHouseAdd(@RequestBody SearchHouseDTO searchHouseDTO,
+                                       @RequestHeader("authorization") String token,
+                                       HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
         String openid = getOpenId(request);
         Integer orgId = getOrgId(request);
         if (null == persons || persons.size() == 0) {
             return ResponseBean.error("当前账户信息异常, 清除缓存重试", ResponseBean.ERROR_UNAVAILABLE);
         }
+
+        if (StringUtils.isEmpty(searchHouseDTO.getMinPrice())) {
+            return ResponseBean.error("请选择预算价格", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
         TaPerson person = persons.get(0);
         try {
             SearchHouse searchHouse = new SearchHouse();
             searchHouse.setStatus("0");
             searchHouse.setCreatedTime(LocalDateTime.now());
             if (iSearchHouseService.save(searchHouse)){
-                SearchHouseVO searchHouseVO = new SearchHouseVO();
-                BeanUtils.copyProperties(searchHouse,searchHouseVO);
-                // 获取价格相近的楼盘
-                LambdaQueryWrapper<TaBuilding> lambdaQueryWrapper = new LambdaQueryWrapper<>();
-                lambdaQueryWrapper.eq(!StringUtils.isEmpty(searchHouseDTO.getIntentArea()),TaBuilding::getBuildingArea,searchHouseDTO.getIntentArea());
-                lambdaQueryWrapper.between(TaBuilding::getPrice,searchHouseDTO.getMinPrice(),searchHouseDTO.getMaxPrice());
-                lambdaQueryWrapper.ne(TaBuilding::getStatus,-1);
-                lambdaQueryWrapper.last(" limit 2");
-                List<TaBuilding> list = taBuildingService.list(lambdaQueryWrapper);
-                if (list.size() < 1){
-                    lambdaQueryWrapper = new LambdaQueryWrapper<>();
-                    lambdaQueryWrapper.eq(!StringUtils.isEmpty(searchHouseDTO.getIntentArea()),TaBuilding::getBuildingArea,searchHouseDTO.getIntentArea());
-                    lambdaQueryWrapper.ne(TaBuilding::getStatus,-1);
-                    lambdaQueryWrapper.last(" limit 2");
-                    list = taBuildingService.list(lambdaQueryWrapper);
+                if (null != searchHouseDTO.getNeedRecommend() && searchHouseDTO.getNeedRecommend()) {
+                    List<TaBuilding> buildingList = iSearchHouseService.getRecommendBuildings(getOrgId(request), searchHouseDTO);
+
+                    SearchHouseVO searchHouseVO = new SearchHouseVO();
+                    BeanUtils.copyProperties(searchHouse,searchHouseVO);
+                    searchHouseVO.setTaBuildingList(buildingList);
+                    responseBean.addSuccess(searchHouseVO);
+                } else {
+                    responseBean.addSuccess(null);
                 }
-                searchHouseVO.setTaBuildingList(list);
-                responseBean.addSuccess(searchHouseVO);
             }else {
                 responseBean.addError("fail");
             }

src/main/java/com/yunzhi/marketing/xlk/dto/SearchHouseDTO.java

      */
     private String questionnaire;
 
+    /**
+     * 是否需要智能推荐
+     */
+    @TableField(exist = false)
+    private Boolean needRecommend;
+
+    /**
+     * 当前人员所在城市
+     */
+    @TableField(exist = false)
+    private Integer cityId;
+
+    /**
+     * 当前人员所选的面积
+     */
+    @TableField(exist = false)
+    private Integer areaResultId;
 }

src/main/java/com/yunzhi/marketing/xlk/mapper/SearchHouseMapper.java

 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.yunzhi.marketing.entity.TaBuilding;
 import com.yunzhi.marketing.xlk.entity.SearchHouse;
 import com.yunzhi.marketing.xlk.vo.SearchHouseVO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.List;
+
 /**
  * <p>
  * 帮我找房  Mapper 接口
     IPage<SearchHouseVO> selectSearchHouseList(IPage<SearchHouseVO> pg,@Param("params") SearchHouseVO searchHouse);
 
     SearchHouseVO selectSearchHouseDetail(String id);
+
+    List<TaBuilding> getRecommendBuildings(@Param("orgId") Integer orgId,
+                                           @Param("cityId") Integer cityId,
+                                           @Param("areaId") Integer areaId,
+                                           @Param("minPriceW") Integer minPriceW,
+                                           @Param("maxPriceW") Integer maxPriceW,
+                                           @Param("minPrice") Integer minPrice,
+                                           @Param("maxPrice") Integer maxPrice);
 }

src/main/java/com/yunzhi/marketing/xlk/service/ISearchHouseService.java

 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.yunzhi.marketing.base.ResponseBean;
+import com.yunzhi.marketing.entity.TaBuilding;
+import com.yunzhi.marketing.xlk.dto.SearchHouseDTO;
 import com.yunzhi.marketing.xlk.entity.SearchHouse;
 import com.yunzhi.marketing.xlk.vo.SearchHouseVO;
 
+import java.util.List;
+
 /**
  * <p>
  * 帮我找房  服务类
     ResponseBean selectSearchHouseList(IPage<SearchHouseVO> pg, SearchHouseVO searchHouse);
 
     SearchHouseVO selectSearchHouseDetail(String id);
+
+    /**
+     * 推荐楼盘
+     * @param searchHouseDTO
+     * @return
+     */
+    List<TaBuilding> getRecommendBuildings(Integer orgId, SearchHouseDTO searchHouseDTO);
 }

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

 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.yunzhi.marketing.base.ResponseBean;
+import com.yunzhi.marketing.common.StringUtils;
+import com.yunzhi.marketing.entity.TaBuilding;
 import com.yunzhi.marketing.entity.TaCheckin;
+import com.yunzhi.marketing.entity.TdCity;
+import com.yunzhi.marketing.mapper.TdCityMapper;
+import com.yunzhi.marketing.xlk.dto.SearchHouseDTO;
 import com.yunzhi.marketing.xlk.entity.SearchHouse;
 import com.yunzhi.marketing.xlk.mapper.SearchHouseMapper;
 import com.yunzhi.marketing.xlk.service.ISearchHouseService;
 import com.yunzhi.marketing.xlk.vo.SearchHouseVO;
+import io.swagger.models.auth.In;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 帮我找房  服务实现类
     @Autowired
     private SearchHouseMapper searchHouseMapper;
 
+    @Autowired
+    private TdCityMapper tdCityMapper;
+
     /**
      * 查询我的找房需求列表
      *
     public SearchHouseVO selectSearchHouseDetail(String id) {
         return searchHouseMapper.selectSearchHouseDetail(id);
     }
+
+    /**
+     * 推荐逻辑如下
+     * 1、先判断区域+价格，如果有符合楼盘，则推荐，如无看2；
+     * 2、判断城市+价格，如过有符合楼盘，则推荐，如无看3；
+     * 3、如选择了“不限城市”，则判断价格，在当前城市内推荐一个符合的。
+     * @param searchHouseDTO
+     * @return
+     */
+    @Override
+    public List<TaBuilding> getRecommendBuildings(Integer orgId, SearchHouseDTO searchHouseDTO) {
+        // 区域
+        String area = searchHouseDTO.getIntentArea();
+        Integer areaId = StringUtils.isEmpty(area) ? null : Integer.valueOf(area);
+        // 区域所属城市
+        Integer areaCity = null;
+        if (null != areaId) {
+            TdCity city = tdCityMapper.selectById(areaId);
+            areaCity = city.getParentid();
+        }
+
+        // 当前城市
+        Integer cityId = searchHouseDTO.getCityId();
+        // 最小总价
+        Integer minPriceW = Integer.parseInt(searchHouseDTO.getMinPrice());
+        // 最大总价
+        Integer maxPriceW = Integer.parseInt(searchHouseDTO.getMaxPrice());
+        // 面积字典
+        Integer areaResultId = searchHouseDTO.getAreaResultId();
+        //
+        Integer[] unitPrice = getUnitPriceRange(minPriceW, maxPriceW, areaResultId);
+        // 最小单价
+        Integer minPrice = unitPrice[0];
+        // 最大单价
+        Integer maxPrice = unitPrice[1];
+
+        if (null != areaId) {
+            // 1、先判断区域+价格
+            List<TaBuilding> lst1 = searchHouseMapper.getRecommendBuildings(orgId, null, areaId, minPriceW, maxPriceW, minPrice, maxPrice);
+            if (null != lst1 && lst1.size() > 0) {
+                return lst1;
+            }
+
+            // 2、判断城市+价格
+            List<TaBuilding> lst2 = searchHouseMapper.getRecommendBuildings(orgId, areaCity, null, minPriceW, maxPriceW, minPrice, maxPrice);
+            if (null != lst2 && lst2.size() > 0) {
+                return lst2;
+            }
+        }
+
+        // 3、当前城市
+        return searchHouseMapper.getRecommendBuildings(orgId, cityId, null, minPriceW, maxPriceW, minPrice, maxPrice);
+    }
+
+    private Integer[] getUnitPriceRange(Integer minPriceW, Integer maxPriceW, Integer areaResultId) {
+        Integer minPrice = minPriceW * 10000;
+        Integer maxPrice = maxPriceW * 10000;
+
+        // 字典过滤 - 必须与小程序端保持一致
+        switch (areaResultId) {
+            case 1:
+                // 60㎡ 以下, 则按照 30 - 60 处理
+                minPrice = minPrice / 60;
+                maxPrice = maxPrice / 30;
+                break;
+            case 2:
+                // 60 - 90
+                minPrice = minPrice / 90;
+                maxPrice = maxPrice / 60;
+                break;
+            case 3:
+                // 90 - 110
+                minPrice = minPrice / 110;
+                maxPrice = maxPrice / 90;
+                break;
+            case 4:
+                // 110 - 130
+                minPrice = minPrice / 130;
+                maxPrice = maxPrice / 110;
+                break;
+            case 5:
+                // 130 - 150
+                minPrice = minPrice / 150;
+                maxPrice = maxPrice / 130;
+                break;
+            case 6:
+                // 150 - 200
+                minPrice = minPrice / 200;
+                maxPrice = maxPrice / 150;
+                break;
+            default:
+                // 200 以上
+                minPrice = minPrice / 200;
+                maxPrice = maxPrice / 200;
+                break;
+        }
+
+        return new Integer[] {minPrice, maxPrice};
+    }
 }

src/main/resources/mapper/xlk/SearchHouseMapper.xml

             LEFT JOIN ta_person p ON t.person_id = p.person_id
             WHERE t.id = #{id}
     </select>
+    <select id="getRecommendBuildings" resultType="com.yunzhi.marketing.entity.TaBuilding">
+        SELECT
+            DISTINCT t.*
+        FROM
+            ta_building t
+            INNER JOIN ta_building_project_type s ON t.building_id = s.building_id
+        WHERE
+            t.org_id = #{orgId}
+        <if test="cityId != null">
+            AND t.city_id = #{cityId}
+        </if>
+        <if test="areaId != null">
+            AND t.building_area = #{areaId}
+        </if>
+            AND (
+                ( s.start_price &gt;= #{minPriceW} AND s.end_price &lt;= #{maxPriceW} AND s.price_type = 'total' )
+                OR ( s.start_price &gt;= #{minPrice} AND s.end_price &lt;= #{maxPrice} AND s.price_type = 'average' )
+            )
+            AND t.`status` > - 1
+        ORDER BY
+            t.is_main ASC
+    </select>
 </mapper>