|
@@ -1,7 +1,11 @@
|
|
|
package com.jyxt.thridparty.exchange.bx.repository;
|
|
package com.jyxt.thridparty.exchange.bx.repository;
|
|
|
|
|
|
|
|
|
|
+import com.jyxt.thridparty.exchange.ExchangeApplication;
|
|
|
import com.jyxt.thridparty.exchange.bx.VendorBinxiang;
|
|
import com.jyxt.thridparty.exchange.bx.VendorBinxiang;
|
|
|
|
|
+import org.slf4j.Logger;
|
|
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
|
import org.springframework.jdbc.core.RowMapper;
|
|
import org.springframework.jdbc.core.RowMapper;
|
|
|
import org.springframework.stereotype.Repository;
|
|
import org.springframework.stereotype.Repository;
|
|
@@ -11,13 +15,17 @@ import java.sql.SQLException;
|
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
@Repository
|
|
@Repository
|
|
|
public class VendorBinxiangRepository {
|
|
public class VendorBinxiangRepository {
|
|
|
-
|
|
|
|
|
|
|
+ private static final Logger log = LoggerFactory.getLogger(VendorBinxiangRepository.class);
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private JdbcTemplate jdbcTemplate;
|
|
private JdbcTemplate jdbcTemplate;
|
|
|
|
|
|
|
|
|
|
+ @Value("${fetch.sql}")
|
|
|
|
|
+ private String sql;
|
|
|
|
|
+
|
|
|
public List<VendorBinxiang> query() {
|
|
public List<VendorBinxiang> query() {
|
|
|
|
|
+ log.info(sql);
|
|
|
return jdbcTemplate.query(
|
|
return jdbcTemplate.query(
|
|
|
- "select * from jyk1.v_get_ref_temperature where TO_CHAR(采集时间,'YYYY-MM-DD')=TO_CHAR(SYSDATE,'YYYY-MM-DD')",new RowMapper<VendorBinxiang>(){
|
|
|
|
|
|
|
+ sql,new RowMapper<VendorBinxiang>(){
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public VendorBinxiang mapRow(ResultSet rs, int rowNum) throws SQLException {
|
|
public VendorBinxiang mapRow(ResultSet rs, int rowNum) throws SQLException {
|