删除 HousePriceDaoImpl.java

mhotel/src/com/happy/dao/impl/HousePriceDaoImpl.java

@@ -1,247 +0,0 @@
-package com.happy.dao.impl;
-
-import com.happy.Model.HousePrice;
-import com.happy.Until.BeanMapTool;
-import com.happy.Until.TimeExchange;
-import com.happy.dao.HousePriceDao;
-import com.happy.dto.HousePriceDto;
-import com.happy.vo.HotelPriceDataVo;
-import com.happy.vo.HousePriceDataVo;
-import org.apache.commons.lang.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.jdbc.core.BeanPropertyRowMapper;
-import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
-import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
-import org.springframework.jdbc.core.namedparam.SqlParameterSourceUtils;
-import org.springframework.stereotype.Repository;
-
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-
-@Repository("housePriceDao")
-public class HousePriceDaoImpl implements HousePriceDao {
-    @Autowired
-    private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
-
-    static final String KEY_START_SET_DATE = "startSetDate";
-    static final String KEY_END_SET_DATE = "endSetDate";
-    private final String KEY_START_OPERATION_TIME = "startOperationTime";
-    private final String KEY_END_OPERATION_TIME = "endOperationTime";
-    private static final String KEY_PAGE_NUMBER = "pageNumber";
-    private static final String KEY_PAGE_SIZE = "pageSize";
-
-    @Override
-    public void insertBatch(List<HousePrice> housePriceList) {
-        final String sql = "insert into house_price values (:id, :managerId, :houseId, :price, :remark, :setDate, :createId, :createDate, :modifyDate, :status)";
-        namedParameterJdbcTemplate.batchUpdate(sql, SqlParameterSourceUtils.createBatch(housePriceList.toArray()));
-    }
-
-    @Override
-    public List<HousePriceDto> queryListOne(HousePriceDto housePriceDto, Integer pageNumber, Integer pageSize) {
-        final String SQL_HEAD = "select t1.id as houseId, t1.h_name as houseName, t1.price as originalPrice, t1.create_date from house t1 where t1.status = 1";
-        final String SQL_TAIL = " order by t1.create_date desc";
-        Map<String, Object> paramMap = buildParamMap(housePriceDto, pageNumber, pageSize);
-        StringBuilder sql = buildSqlHouse(SQL_HEAD, SQL_TAIL, housePriceDto, pageNumber, pageSize);
-        return namedParameterJdbcTemplate.query(sql.toString(), paramMap, new BeanPropertyRowMapper<>(HousePriceDto.class));
-    }
-
-    @Override
-    public int queryTotalOne(HousePriceDto housePriceDto) {
-        final String SQL_HEAD = "select count(1) from house t1 where t1.status = 1";
-        Map<String, Object> paramMap = buildParamMap(housePriceDto, null, null);
-        StringBuilder sql = buildSqlHouse(SQL_HEAD, "", housePriceDto, null, null);
-        return namedParameterJdbcTemplate.queryForObject(sql.toString(), paramMap, Integer.class);
-    }
-
-    @Override
-    public List<HousePriceDto> queryListTwo(HousePriceDto housePriceDto) {
-        final String SQL_HEAD = "select t1.id, t1.manager_id, t1.house_id, t1.price, t1.remark, t1.set_date, t1.create_id, t1.create_date, t1.modify_date, t1.status from house_price t1 where t1.status = 1";
-        final String SQL_TAIL = " order by create_date desc";
-        Map<String, Object> paramMap = buildParamMap(housePriceDto, null, null);
-        StringBuilder sql = buildSqlHousePrice(SQL_HEAD, SQL_TAIL, housePriceDto, null, null);
-        return namedParameterJdbcTemplate.query(sql.toString(), paramMap, new BeanPropertyRowMapper<>(HousePriceDto.class));
-    }
-
-    @Override
-    public List<HousePriceDto> queryListThree(HousePriceDto housePriceDto, Integer pageNumber, Integer pageSize) {
-        final String SQL_HEAD = "select t.* from(select t1.id, t1.house_id, t2.h_name as houseName, group_concat(replace(t1.set_date, ',', ' 至 ')) as set_date, t1.price, t3.corpn_name as operationName, date_format(t1.create_date, '%Y-%m-%d %H:%i:%s') as operationTime from house_price t1 left join house t2 on t1.status = t2.status and t1.manager_id = t2.manager_id and t1.house_id = t2.id left join admin_manager t3 on t1.create_id = t3.id where t1.status = 1";
-        StringBuilder sql = new StringBuilder(SQL_HEAD);
-        if (StringUtils.isNotBlank(housePriceDto.getOperationName())) {
-            sql.append(" and t3.corpn_name like concat('%', :operationName, '%')");
-        }
-        final String SQL_TAIL = " group by t1.id) t order by t.operationTime desc";
-        Map<String, Object> paramMap = buildParamMap(housePriceDto, pageNumber, pageSize);
-        StringBuilder sqlLast = buildSqlHousePrice(sql.toString(), SQL_TAIL, housePriceDto, pageNumber, pageSize);
-        return namedParameterJdbcTemplate.query(sqlLast.toString(), paramMap, new BeanPropertyRowMapper<>(HousePriceDto.class));
-    }
-
-    @Override
-    public int queryTotalThree(HousePriceDto housePriceDto) {
-        final String SQL_HEAD = "select count(1) from (select 1 from house_price t1 left join house t2 on t1.status = t2.status and t1.manager_id = t2.manager_id and t1.house_id = t2.id left join admin_manager t3 on t1.create_id = t3.id where t1.status = 1";
-        StringBuilder sql = new StringBuilder(SQL_HEAD);
-        if (StringUtils.isNotBlank(housePriceDto.getOperationName())) {
-            sql.append(" and t3.corpn_name like concat('%', :operationName, '%')");
-        }
-        final String SQL_TAIL = ") t";
-        Map<String, Object> paramMap = buildParamMap(housePriceDto, null, null);
-        StringBuilder sqlLast = buildSqlHousePrice(sql.toString(), SQL_TAIL, housePriceDto, null, null);
-        return namedParameterJdbcTemplate.queryForObject(sqlLast.toString(), paramMap, Integer.class);
-    }
-
-    /**
-     * 构建主表t1为house_price的sql查询条件
-     */
-    private StringBuilder buildSqlHousePrice(String sqlHead, String sqlTail, HousePriceDto housePriceDto, Integer pageNumber, Integer pageSize) {
-        StringBuilder sql = new StringBuilder(sqlHead);
-        if (StringUtils.isNotBlank(housePriceDto.getManagerId())) {
-            sql.append(" and t1.manager_id=:managerId");
-        }
-        if (housePriceDto.getHouseIdList() != null && !housePriceDto.getHouseIdList().isEmpty()) {
-            sql.append(" and t1.house_id in (:houseIdList)");
-        }
-        if (StringUtils.isNotBlank(housePriceDto.getHouseId())) {
-            sql.append(" and t1.house_id=:houseId");
-        }
-        if (StringUtils.isNotBlank(housePriceDto.getOperationTime())) {
-            sql.append(String.format(" and t1.create_date between :%s and :%s", KEY_START_OPERATION_TIME, KEY_END_OPERATION_TIME));
-        }
-        String setDate = housePriceDto.getSetDate();
-        if (StringUtils.isNotBlank(setDate) && setDate.split(",").length == 2) {
-            sql.append(String.format(" and(substring_index(t1.set_date, ',', 1) between :%s and :%s", KEY_START_SET_DATE, KEY_END_SET_DATE))
-                    .append(String.format(" or substring_index(t1.set_date, ',', -1) between :%s and :%s)", KEY_START_SET_DATE, KEY_END_SET_DATE));
-        }
-        sql.append(sqlTail).append(buildSqlPage(pageNumber, pageSize));
-        return sql;
-    }
-
-    /**
-     * 构建主表t1为house的sql查询条件
-     */
-    private StringBuilder buildSqlHouse(String sqlHead, String sqlTail, HousePriceDto housePriceDto, Integer pageNumber, Integer pageSize) {
-        StringBuilder sql = new StringBuilder(sqlHead);
-        if (StringUtils.isNotBlank(housePriceDto.getManagerId())) {
-            sql.append(" and t1.manager_id=:managerId");
-        }
-        if (StringUtils.isNotBlank(housePriceDto.getHouseId())) {
-            sql.append(" and t1.id=:houseId");
-        }
-        sql.append(sqlTail).append(buildSqlPage(pageNumber, pageSize));
-        return sql;
-    }
-
-    /**
-     * 构建分页查询条件
-     */
-    static String buildSqlPage(Integer pageNumber, Integer pageSize) {
-        String result = "";
-        if (pageNumber != null && pageSize != null) {
-            result = String.format(" limit :%s, :%s", KEY_PAGE_NUMBER, KEY_PAGE_SIZE);
-        } else if (pageSize != null) {
-            result = String.format(" limit :%s", KEY_PAGE_SIZE);
-        }
-        return result;
-    }
-
-    /**
-     * 获取价格日历数据
-     * @param managerId 商家ID
-     * @param startTime 入住时间
-     * @param endTime 离店时间
-     * @return
-     */
-    @Override
-    public List<HousePriceDataVo> queryHousePriceDatas(Integer managerId, String startTime, String endTime) {
-        String sql = "select * from (SELECT house_id,price,SUBSTRING_INDEX(set_date,',',1) as start_time,SUBSTRING_INDEX(set_date,',',-1) as end_time,create_date from house_price\n" +
-                     "where status = 1 and manager_id =:managerId) t\n" +
-                     "where (t.start_time <=:startTime and t.end_time >=:endTime) \n" +
-                     "or (t.start_time >=:startTime and t.start_time <=:endTime and t.end_time >=:endTime) \n" +
-                     "or (t.start_time <=:startTime and t.end_time >=:startTime and t.end_time <=:endTime)\n" +
-                     "or (t.start_time >=:startTime and t.end_time <=:endTime)";
-        MapSqlParameterSource sps = new MapSqlParameterSource();
-        sps.addValue("managerId", managerId);
-        sps.addValue("startTime", startTime);
-        sps.addValue("endTime", endTime);
-        List<HousePriceDataVo> list = namedParameterJdbcTemplate.query(sql, sps, new BeanPropertyRowMapper<>(HousePriceDataVo.class));
-
-        return list;
-    }
-
-    /**
-     * 批量获取民宿的价格设置数据
-     * @param managerIds 商家ID集合
-     * @param startTime 当天时间
-     * @return
-     */
-    @Override
-    public List<HotelPriceDataVo> queryHotelPriceDatas(String managerIds, String startTime) {
-        String sql = "select * from (SELECT manager_id,price,SUBSTRING_INDEX(set_date,',',1) as start_time,SUBSTRING_INDEX(set_date,',',-1) as end_time,create_date from house_price\n" +
-                "where status = 1 and manager_id in ("+managerIds +")) t\n" +
-                "where (t.start_time <=:startTime and t.end_time >=:startTime) \n" +
-                "or (t.start_time >=:startTime and t.start_time <=:startTime and t.end_time >=:startTime) \n" +
-                "or (t.start_time <=:startTime and t.end_time >=:startTime and t.end_time <=:startTime)\n" +
-                "or (t.start_time >=:startTime and t.end_time <=:startTime)";
-        MapSqlParameterSource sps = new MapSqlParameterSource();
-        sps.addValue("startTime", startTime);
-        List<HotelPriceDataVo> list = namedParameterJdbcTemplate.query(sql, sps, new BeanPropertyRowMapper<>(HotelPriceDataVo.class));
-
-        return list;
-    }
-
-    /**
-     * 获取价格日历数据
-     * @param houseId 房型ID
-     * @param startTime 入住时间
-     * @param endTime 离店时间
-     * @return
-     */
-    @Override
-    public List<HousePriceDataVo> queryPriceByHouseId(Integer houseId, String startTime, String endTime) {
-        String sql = "select * from (SELECT house_id,price,SUBSTRING_INDEX(set_date,',',1) as start_time,SUBSTRING_INDEX(set_date,',',-1) as end_time,create_date from house_price\n" +
-                "where status = 1 and house_id =:houseId) t\n" +
-                "where (t.start_time <=:startTime and t.end_time >=:endTime) \n" +
-                "or (t.start_time >=:startTime and t.start_time <=:endTime and t.end_time >=:endTime) \n" +
-                "or (t.start_time <=:startTime and t.end_time >=:startTime and t.end_time <=:endTime)\n" +
-                "or (t.start_time >=:startTime and t.end_time <=:endTime)";
-        MapSqlParameterSource sps = new MapSqlParameterSource();
-        sps.addValue("houseId", houseId);
-        sps.addValue("startTime", startTime);
-        sps.addValue("endTime", endTime);
-        List<HousePriceDataVo> list = namedParameterJdbcTemplate.query(sql, sps, new BeanPropertyRowMapper<>(HousePriceDataVo.class));
-
-        return list;
-    }
-
-    /**
-     * 构建sql查询参数
-     */
-    private Map<String, Object> buildParamMap(HousePriceDto housePriceDto, Integer pageNumber, Integer pageSize) {
-        Map<String, Object> paramMap = BeanMapTool.beanToMap(housePriceDto);
-        String operationTime = housePriceDto.getOperationTime();
-        if (StringUtils.isNotBlank(operationTime)) {
-            String[] operationTimeArr = operationTime.split(",");
-            paramMap.put(KEY_START_OPERATION_TIME, operationTimeArr[0]);
-            paramMap.put(KEY_END_OPERATION_TIME, operationTimeArr[1]);
-        }
-        String setDate = housePriceDto.getSetDate();
-        if (StringUtils.isNotBlank(setDate) && setDate.split(",").length == 2) {
-            String[] setDateArr = setDate.split(",");
-            paramMap.put(KEY_START_SET_DATE, setDateArr[0]);
-            paramMap.put(KEY_END_SET_DATE, setDateArr[1]);
-        }
-        return putPageParams(pageNumber, pageSize, paramMap);
-    }
-
-    /**
-     * 追加sql查询分页参数
-     */
-    static Map<String, Object> putPageParams(Integer pageNumber, Integer pageSize, Map<String, Object> paramMap) {
-        if (pageNumber != null && pageSize != null) {
-            paramMap.put(KEY_PAGE_NUMBER, (pageNumber - 1) * pageSize);
-            paramMap.put(KEY_PAGE_SIZE, pageSize);
-        } else if (pageSize != null) {
-            paramMap.put(KEY_PAGE_SIZE, pageSize);
-        }
-        return paramMap;
-    }
-}