CityService.java

package com.viontech.service.impl;

import com.viontech.model.City;
import com.viontech.model.Mall;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.stereotype.Service;

import java.time.LocalDate;
import java.time.ZoneId;
import java.util.*;
import java.util.stream.Collectors;

/**
 * @author zhaibolin
 */
@Service
public class CityService {

    @Autowired
    private  JdbcTemplate jdbcTemplate;
    @Autowired
    private NamedParameterJdbcTemplate namedParameterJdbcTemplate;

    @Autowired
    private JsonService jsonService;

    private String SQL_SELECT_MALL="select name,status,province_id,city_id from b_mall";
    private String SQL_SELECT_CITY="select area_name as cityName,province_id,weather_code,city_id from b_city where city_id in (:cityIds)";
    private String SQL_SELECT_WEATHER="select city_id from d_weather where data_date=?";

    public List<Mall> selectMallList(){
        List<Mall> mallList= jdbcTemplate.query(SQL_SELECT_MALL,new BeanPropertyRowMapper<>(Mall.class));
        return mallList;
    }
    public List<City> selectCityList(List<Mall> mallList){
        if(mallList.isEmpty()){
            System.out.println("获取不到商场列表");
            return null;
        }
        List<Integer> cityIdList = mallList.stream().filter(x -> x.getCity_id() != null).map(Mall::getCity_id).collect(Collectors.toList());
        Map<String, Object> paramMap = new HashMap<>();
        paramMap.put("cityIds", cityIdList);
        return namedParameterJdbcTemplate.query(SQL_SELECT_CITY, paramMap, new BeanPropertyRowMapper<>(City.class));
    }

    public List<Integer> selectTodayWeather(Date date){
        List<Integer> cityIdList=jdbcTemplate.queryForList(SQL_SELECT_WEATHER,new Object[]{date},Integer.class);
        return cityIdList;
    }

}