添加定时任务

meter-reading-sishui/read-sqlSever/src/main/java/com/zcxk/config/MysqlDataSourceConfig.java

@@ -25,10 +25,17 @@ public class MysqlDataSourceConfig {
         return DataSourceBuilder.create().build();
     }
 
+    @Bean
+    @ConfigurationProperties(prefix = "mybatis.configuration")
+    public org.apache.ibatis.session.Configuration gloabalConfiguration() {
+        return new org.apache.ibatis.session.Configuration();
+    }
+
     @Bean(name = "mysqlSqlSessionFactory")
-    public SqlSessionFactory testSqlSessionFactory(@Qualifier("mysqlDataSource") DataSource dataSource) throws Exception {
+    public SqlSessionFactory testSqlSessionFactory(@Qualifier("mysqlDataSource") DataSource dataSource, org.apache.ibatis.session.Configuration config) throws Exception {
         SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
         bean.setDataSource(dataSource);
+        bean.setConfiguration(config);
         bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("mysql-mapper/*.xml"));
         return bean.getObject();
     }

meter-reading-sishui/read-sqlSever/src/main/java/com/zcxk/config/SqlServerDataSourceConfig.java

@@ -16,8 +16,8 @@ import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 
 import javax.sql.DataSource;
 
-@Configuration
-@MapperScan(basePackages = "com.zcxk.dao.sqlserver", sqlSessionTemplateRef  = "sqlServerSqlSessionTemplate")
+//@Configuration
+//@MapperScan(basePackages = "com.zcxk.dao.sqlserver", sqlSessionTemplateRef  = "sqlServerSqlSessionTemplate")
 public class SqlServerDataSourceConfig {
 
     @Bean(name = "sqlServerDataSource")

meter-reading-sishui/read-sqlSever/src/main/java/com/zcxk/controller/DemoController.java

@@ -24,7 +24,7 @@ import java.util.*;
 
 @RestController
 public class DemoController {
-    @Autowired
+   // @Autowired
     ReceiveDao receiveDao;
     @Autowired
     SendDao sendDao;
@@ -172,7 +172,13 @@ public class DemoController {
             cron.append(" ");
             cron.append(dateTime.getMonth());
             cron.append(" ? *");
-            quartzManager.addJob("test", SyncMeterDataJob.class,cron.toString(),666);
+            Map<String,Object>args=new HashMap<>();
+        args.put("readDate","20210107");
+        args.put("customerId",customerId);
+        List<DeviceType> deviceTypes = sendDao.selectDeviceType();
+        List<MeterReadRecord> meterReadRecords = sendDao.selectDeviceMeterReader(args);
+        System.out.println(1);
+            //quartzManager.addJob("test", SyncMeterDataJob.class,cron.toString(),666);
 
 
    }

meter-reading-sishui/read-sqlSever/src/main/resources/application-dev.properties

@@ -13,7 +13,6 @@ spring.datasource.sqlsever.username=LoginNo_MaiTuo
 spring.datasource.sqlsever.password=maituo@OKM123
 spring.datasource.sqlsever.driver-class-name=com.microsoft.sqlserver.jdbc.SQLServerDriver
 mybatis.configuration.map-underscore-to-camel-case=true
-
 mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
 mybatis.configuration.use-column-label=true
 

meter-reading-sishui/read-sqlSever/src/main/resources/mysql-mapper/SendDao.xml

@@ -23,7 +23,8 @@
         </foreach>
     </insert>
     <select id="selectDeviceMeterReader" resultType="com.zcxk.entity.MeterReadRecord">
-      select device_no deviceNo,read_time readTime,read_data readDatafrom sc_meter_read_record where customer_id=#{customerId}
+      select device_no, read_time ,read_data
+      from sc_meter_read_record where customer_id=#{customerId}
       and read_date=#{readDate}
     </select>
     <select id="selectDevice" resultType="string">