|
@ -11,6 +11,8 @@ import io.searchbox.core.*;
|
|
|
import org.elasticsearch.index.query.BoolQueryBuilder;
|
|
|
import org.elasticsearch.index.query.QueryBuilders;
|
|
|
import org.elasticsearch.search.builder.SearchSourceBuilder;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.jdbc.core.BeanPropertyRowMapper;
|
|
@ -41,10 +43,13 @@ public class ExtractDataService {
|
|
|
@Autowired
|
|
|
private JdbcTemplate jdbcTemplate;
|
|
|
|
|
|
private Logger logger= LoggerFactory.getLogger(ExtractDataService.class);
|
|
|
|
|
|
public void extractOneDate(String date) {
|
|
|
String sql = "select * from wlyy_quota_result w where w.level1_type=1 and w.quato_code !=18 and w.quato_code !=19 and quota_date='" + date + "' ";
|
|
|
List<WlyyQuotaResult> quotaResults = jdbcTemplate.query(sql, new BeanPropertyRowMapper(WlyyQuotaResult.class));
|
|
|
save2es(quotaResults, date, null);
|
|
|
logger.info("date:"+date+" all quota success");
|
|
|
}
|
|
|
|
|
|
|
|
@ -52,6 +57,7 @@ public class ExtractDataService {
|
|
|
String sql = "select * from wlyy_quota_result w where w.level1_type=1 and w.quato_code !=18 and w.quato_code !=19 and quota_date='" + date + "' and quato_code='" + quotaId + "'";
|
|
|
List<WlyyQuotaResult> quotaResults = jdbcTemplate.query(sql, new BeanPropertyRowMapper(WlyyQuotaResult.class));
|
|
|
save2es(quotaResults, date, quotaId);
|
|
|
logger.info("date:"+date+",quotaId:"+quotaId+" success");
|
|
|
}
|
|
|
|
|
|
public void extractDate2Date(String start, String end) throws Exception {
|