Jelajahi Sumber

Merge branch 'master' of https://git.steerinfo.com/XTEMS/xt-ems-datasource

lirl 3 tahun lalu
induk
melakukan
ca204650b3
21 mengubah file dengan 1385 tambahan dan 2 penghapusan
  1. 29 0
      src/main/java/com/steerinfo/config/druidConfig/DruidConfig.java
  2. 28 0
      src/main/java/com/steerinfo/lgReal/controller/LgRealController.java
  3. 16 0
      src/main/java/com/steerinfo/lgReal/mapper/LgRealMapper.java
  4. 49 0
      src/main/java/com/steerinfo/lgReal/mapper/LgRealMapper.xml
  5. 15 0
      src/main/java/com/steerinfo/lgReal/model/LgReal.java
  6. 16 0
      src/main/java/com/steerinfo/lgReal/service/ILgRealService.java
  7. 30 0
      src/main/java/com/steerinfo/lgReal/service/impl/LgRealImpl.java
  8. 37 0
      src/main/java/com/steerinfo/product/dzmaterialsf/controller/DzMaterialSfController.java
  9. 13 0
      src/main/java/com/steerinfo/product/dzmaterialsf/mapper/DzMaterialSfMapper.java
  10. 533 0
      src/main/java/com/steerinfo/product/dzmaterialsf/mapper/DzMaterialSfMapper.xml
  11. 303 0
      src/main/java/com/steerinfo/product/dzmaterialsf/model/DzMaterialSf.java
  12. 24 0
      src/main/java/com/steerinfo/product/dzmaterialsf/service/IDzMaterialSfService.java
  13. 53 0
      src/main/java/com/steerinfo/product/dzmaterialsf/service/impl/DzMaterialSfServiceImpl.java
  14. 35 0
      src/main/java/com/steerinfo/weight/lgmes/controller/LgReportController.java
  15. 0 1
      src/main/java/com/steerinfo/weight/lgmes/controller/LgWeightController.java
  16. 13 0
      src/main/java/com/steerinfo/weight/lgmes/mapper/LgReportMapper.java
  17. 29 0
      src/main/java/com/steerinfo/weight/lgmes/mapper/LgReportMapper.xml
  18. 123 0
      src/main/java/com/steerinfo/weight/lgmes/model/EmsScqkLg.java
  19. 13 0
      src/main/java/com/steerinfo/weight/lgmes/service/ILgReportService.java
  20. 21 0
      src/main/java/com/steerinfo/weight/lgmes/service/impl/LgReportImpl.java
  21. 5 1
      src/main/resources/bootstrap.properties

+ 29 - 0
src/main/java/com/steerinfo/config/druidConfig/DruidConfig.java

@@ -29,12 +29,15 @@ public class DruidConfig {
     private String jdbcUrl1;//ds1数据源
     private String jdbcUrl2;//ds2数据源
     private String jdbcUrl3;
+    private String jdbcUrl4;
     private String username1;
     private String password1;
     private String username2;
     private String username3;
     private String password2;
     private String password3;
+    private String username4;
+    private String password4;
     private int maxActive;
     private int minIdle;
     private int initialSize;
@@ -124,21 +127,47 @@ public class DruidConfig {
         return druidDataSource;
     }
 
+    public DataSource getDs4() {
+        DruidDataSource druidDataSource = new DruidDataSource();
+        druidDataSource.setDriverClassName(driverClassNameSqlserver);
+        druidDataSource.setUrl(jdbcUrl4);
+        druidDataSource.setUsername(username4);
+        druidDataSource.setPassword(password4);
+        druidDataSource.setMaxActive(maxActive);
+        druidDataSource.setInitialSize(initialSize);
+        druidDataSource.setTimeBetweenConnectErrorMillis(timeBetweenEvictionRunsMillis);
+        druidDataSource.setValidationQuery(validationQuery);
+        druidDataSource.setTestWhileIdle(testWhileIdle);
+        druidDataSource.setTestOnBorrow(testOnBorrow);
+        druidDataSource.setTestOnReturn(testOnReturn);
+        druidDataSource.setPoolPreparedStatements(poolPreparedStatements);
+        druidDataSource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
+        try {
+            druidDataSource.setFilters(filters);
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        return druidDataSource;
+    }
+
     @Bean
     public DataSource dynamicDataSource() {
         Map<Object, Object> targetDataSources = new HashMap<>();
         DataSource ds1 = getDs1();
         DataSource ds2 = getDs2();
         DataSource ds3 = getDs3();
+        DataSource ds4 = getDs4();
         targetDataSources.put("ds1", ds1);
         targetDataSources.put("ds2", ds2);
         targetDataSources.put("ds3", ds3);
+        targetDataSources.put("ds4", ds4);
         DynamicDataSource dynamicDataSource = new DynamicDataSource();
         dynamicDataSource.setTargetDataSources(targetDataSources);
         dynamicDataSource.setDefaultTargetDataSource(ds1);
         DynamicDataSourceContextHolder.dataSourceIds.add("ds1");
         DynamicDataSourceContextHolder.dataSourceIds.add("ds2");
         DynamicDataSourceContextHolder.dataSourceIds.add("ds3");
+        DynamicDataSourceContextHolder.dataSourceIds.add("ds4");
         return dynamicDataSource;
     }
 

+ 28 - 0
src/main/java/com/steerinfo/lgReal/controller/LgRealController.java

@@ -0,0 +1,28 @@
+package com.steerinfo.lgReal.controller;
+
+import com.steerinfo.lgReal.model.LgReal;
+import com.steerinfo.lgReal.service.ILgRealService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/${api.version}/lgReal")
+public class LgRealController {
+      @Autowired
+      private ILgRealService lgRealService;
+
+
+    @GetMapping("/queryReals1")
+    public List<LgReal> QueryReals1(){
+        return lgRealService.QueryLgReals1();
+    }
+    @GetMapping("/queryReals2")
+    public List<LgReal> QueryReals2(){
+        return lgRealService.QueryLgReals2();
+    }
+
+}

+ 16 - 0
src/main/java/com/steerinfo/lgReal/mapper/LgRealMapper.java

@@ -0,0 +1,16 @@
+package com.steerinfo.lgReal.mapper;
+
+import com.steerinfo.lgReal.model.LgReal;
+
+import java.util.List;
+
+/**
+ * @author Shadow
+ * @create 2021-10-19 9:42
+ * @project xt-ems-datasource
+ */
+public interface LgRealMapper {
+   public List<LgReal> QueryLgReals1();
+
+   public List<LgReal> QueryLgReals2();
+}

+ 49 - 0
src/main/java/com/steerinfo/lgReal/mapper/LgRealMapper.xml

@@ -0,0 +1,49 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.steerinfo.lgReal.mapper.LgRealMapper">
+    <resultMap id="BaseResultMap" type="com.steerinfo.lgReal.model.LgReal">
+        <id column="ALTID" jdbcType="VARCHAR" property="altId"/>
+<!--        <id column="TSRCL" jdbcType="VARCHAR" property="rcl"/>-->
+<!--        <id column="ZT" jdbcType="VARCHAR" property="zt"/>-->
+        <id column="ENG" jdbcType="VARCHAR" property="eng"/>
+<!--        <id column="GPYLJ" jdbcType="VARCHAR" property="gpYlj"/>-->
+<!--        <id column="GPNLJ" jdbcType="VARCHAR" property="gpNlj"/>-->
+<!--        <id column="TSYLJ" jdbcType="VARCHAR" property="tsYlj"/>-->
+<!--        <id column="TSNLJ" jdbcType="VARCHAR" property="tsYlj"/>-->
+    </resultMap>
+    <select id="QueryLgReals1"  resultMap="BaseResultMap" >
+        SELECT ALTID, ENG
+        FROM JYMES.V_EMS_LG_CAS01 UNPIVOT ( ENG FOR ALTID IN ( LG_MES_1ZL_REAL001 AS '0x0001:2a6b:33', LG_MES_1ZL_REAL002,
+LG_MES_1ZL_REAL003, LG_MES_1ZL_REAL004, LG_MES_1ZL_REAL005 AS '0x0014:7160:33', LG_MES_1ZL_REAL006, LG_MES_1ZL_REAL007,
+LG_MES_1ZL_REAL008, LG_MES_1ZL_REAL009 AS '0x0024:5203:33', LG_MES_1ZL_REAL010 AS '0x0021:53ed:33',
+LG_MES_1ZL_REAL011 AS '0x0026:0362:33', LG_MES_1ZL_REAL012 AS '0x0012:622d:33', LG_MES_1ZL_REAL013 AS '0x0011:72d8:33',
+LG_MES_1ZL_REAL014, LG_MES_1ZL_REAL015, LG_MES_1ZL_REAL016, LG_MES_1ZL_REAL017, LG_MES_1ZL_REAL018, LG_MES_1ZL_REAL019,
+LG_MES_1ZL_REAL020) )
+        UNION ALL SELECT ALTID, ENG
+        FROM JYMES.V_EMS_LG_BOF01 UNPIVOT( ENG FOR ALTID IN ( LG_MES_1ZL_REAL021 AS '0x0015:5708:33',
+LG_MES_1ZL_REAL022 AS '0x0013:2a60:33', LG_MES_1ZL_REAL023 AS '0x0025:394f:33', LG_MES_1ZL_REAL024 AS '0x001b:687c:33',
+LG_MES_1ZL_REAL026, LG_MES_1ZL_REAL027, LG_MES_1ZL_REAL028 AS '0x001d:1590:33', LG_MES_1ZL_REAL029 AS '0x001c:448a:33',
+LG_MES_1ZL_REAL030, LG_MES_1ZL_REAL031 AS '0x001a:77cf:33', LG_MES_1ZL_REAL032 AS '0x0019:4ee9:33', LG_MES_1ZL_REAL033,
+LG_MES_1ZL_REAL034 AS '0x0017:4b62:33', LG_MES_1ZL_REAL035 AS '0x0016:69c5:33', LG_MES_1ZL_REAL036,
+LG_MES_1ZL_REAL037 AS '0x0020:072e:33', LG_MES_1ZL_REAL038 AS '0x001e:649d:33', LG_MES_1ZL_REAL039 AS '0x001f:1c0b:33',
+LG_MES_1ZL_REAL040, LG_MES_1ZL_REAL041, LG_MES_1ZL_REAL042, LG_MES_1ZL_REAL043, LG_MES_1ZL_REAL044 AS '0x0022:3bee:33',
+LG_MES_1ZL_REAL045, LG_MES_1ZL_REAL046, LG_MES_1ZL_REAL047, LG_MES_1ZL_REAL048, LG_MES_1ZL_REAL049) )
+        UNION ALL SELECT ALTID, ENG
+        FROM JYMES.V_EMS_LG_BOF02 UNPIVOT ( ENG FOR ALTID IN ( LG_MES_2ZL_REAL021, LG_MES_2ZL_REAL022, LG_MES_2ZL_REAL023, LG_MES_2ZL_REAL024, LG_MES_2ZL_REAL026, LG_MES_2ZL_REAL027, LG_MES_2ZL_REAL028, LG_MES_2ZL_REAL029, LG_MES_2ZL_REAL030, LG_MES_2ZL_REAL031, LG_MES_2ZL_REAL032, LG_MES_2ZL_REAL033, LG_MES_2ZL_REAL034, LG_MES_2ZL_REAL035, LG_MES_2ZL_REAL036, LG_MES_2ZL_REAL037, LG_MES_2ZL_REAL038, LG_MES_2ZL_REAL039, LG_MES_2ZL_REAL040, LG_MES_2ZL_REAL041, LG_MES_2ZL_REAL042, LG_MES_2ZL_REAL043, LG_MES_2ZL_REAL044, LG_MES_2ZL_REAL045, LG_MES_2ZL_REAL046, LG_MES_2ZL_REAL047, LG_MES_2ZL_REAL048, LG_MES_2ZL_REAL049 ) )
+        UNION ALL SELECT ALTID, ENG
+        FROM JYMES.V_EMS_LG_LFS01 UNPIVOT ( ENG FOR ALTID IN ( LG_MES_1LF_REAL001, LG_MES_1LF_REAL002, LG_MES_1LF_REAL003, LG_MES_1LF_REAL005, LG_MES_1LF_REAL006, LG_MES_1LF_REAL007, LG_MES_1LF_REAL008, LG_MES_1LF_REAL009, LG_MES_1LF_REAL011, LG_MES_1LF_REAL012, LG_MES_1LF_REAL013, LG_MES_1LF_REAL014, LG_MES_1LF_REAL015, LG_MES_1LF_REAL016, LG_MES_1LF_REAL017, LG_MES_1LF_REAL018, LG_MES_1LF_REAL019, LG_MES_1LF_REAL020, LG_MES_1LF_REAL021, LG_MES_1LF_REAL022, LG_MES_1LF_REAL023, LG_MES_1LF_REAL024, LG_MES_1LF_REAL025, LG_MES_1LF_REAL026, LG_MES_1LF_REAL027, LG_MES_1LF_REAL029 ))
+        UNION ALL SELECT ALTID, ENG
+        FROM JYMES.V_EMS_LG_LFS02 UNPIVOT ( ENG FOR ALTID IN ( LG_MES_2LF_REAL001, LG_MES_2LF_REAL002, LG_MES_2LF_REAL003, LG_MES_2LF_REAL005, LG_MES_2LF_REAL006, LG_MES_2LF_REAL007, LG_MES_2LF_REAL008, LG_MES_2LF_REAL009, LG_MES_2LF_REAL011, LG_MES_2LF_REAL012, LG_MES_2LF_REAL013, LG_MES_2LF_REAL014, LG_MES_2LF_REAL015, LG_MES_2LF_REAL016, LG_MES_2LF_REAL017, LG_MES_2LF_REAL018, LG_MES_2LF_REAL019, LG_MES_2LF_REAL020, LG_MES_2LF_REAL021, LG_MES_2LF_REAL022, LG_MES_2LF_REAL023, LG_MES_2LF_REAL024, LG_MES_2LF_REAL025, LG_MES_2LF_REAL026, LG_MES_2LF_REAL027, LG_MES_2LF_REAL029 ))
+    </select>
+
+    <select id="QueryLgReals2"  resultMap="BaseResultMap" >
+        SELECT ALTID, ENG
+        FROM JYMES.V_EMS_LG_BOF02 UNPIVOT ( ENG FOR ALTID IN ( LG_MES_2ZL_REAL021, LG_MES_2ZL_REAL022, LG_MES_2ZL_REAL023, LG_MES_2ZL_REAL024, LG_MES_2ZL_REAL026, LG_MES_2ZL_REAL027, LG_MES_2ZL_REAL028, LG_MES_2ZL_REAL029, LG_MES_2ZL_REAL030, LG_MES_2ZL_REAL031, LG_MES_2ZL_REAL032, LG_MES_2ZL_REAL033, LG_MES_2ZL_REAL034, LG_MES_2ZL_REAL035, LG_MES_2ZL_REAL036, LG_MES_2ZL_REAL037, LG_MES_2ZL_REAL038, LG_MES_2ZL_REAL039, LG_MES_2ZL_REAL040, LG_MES_2ZL_REAL041, LG_MES_2ZL_REAL042, LG_MES_2ZL_REAL043, LG_MES_2ZL_REAL044, LG_MES_2ZL_REAL045, LG_MES_2ZL_REAL046, LG_MES_2ZL_REAL047, LG_MES_2ZL_REAL048, LG_MES_2ZL_REAL049 ) )
+        UNION ALL SELECT ALTID, ENG
+        FROM JYMES.V_EMS_LG_CCM01 UNPIVOT ( ENG FOR ALTID IN (LG_MES_1LZ_REAL001, LG_MES_1LZ_REAL002, LG_MES_1LZ_REAL003, LG_MES_1LZ_REAL004, LG_MES_1LZ_REAL005, LG_MES_1LZ_REAL006, LG_MES_1LZ_REAL007, LG_MES_1LZ_REAL008, LG_MES_1LZ_REAL009, LG_MES_1LZ_REAL010, LG_MES_1LZ_REAL011, LG_MES_1LZ_REAL012, LG_MES_1LZ_REAL014, LG_MES_1LZ_REAL016, LG_MES_1LZ_REAL017, LG_MES_1LZ_REAL018, LG_MES_1LZ_REAL019, LG_MES_1LZ_REAL020, LG_MES_1LZ_REAL026, LG_MES_1LZ_REAL027, LG_MES_1LZ_REAL028, LG_MES_1LZ_REAL029, LG_MES_1LZ_REAL030, LG_MES_1LZ_REAL031, LG_MES_1LZ_REAL032, LG_MES_1LZ_REAL033, LG_MES_1LZ_REAL034, LG_MES_1LZ_REAL035, LG_MES_1LZ_REAL036, LG_MES_1LZ_REAL037, LG_MES_1LZ_REAL038, LG_MES_1LZ_REAL039, LG_MES_1LZ_REAL040, LG_MES_1LZ_REAL041, LG_MES_1LZ_REAL042, LG_MES_1LZ_REAL043, LG_MES_1LZ_REAL044, LG_MES_1LZ_REAL045, LG_MES_1LZ_REAL046, LG_MES_1LZ_REAL048, LG_MES_1LZ_REAL049, LG_MES_1LZ_REAL051, LG_MES_1LZ_REAL052, LG_MES_1LZ_REAL053, LG_MES_1LZ_REAL054, LG_MES_1LZ_REAL055, LG_MES_1LZ_REAL056, LG_MES_1LZ_REAL060, LG_MES_1LZ_REAL061, LG_MES_1LZ_REAL062, LG_MES_1LZ_REAL064, LG_MES_1LZ_REAL065, LG_MES_1LZ_REAL067, LG_MES_1LZ_REAL068, LG_MES_1LZ_REAL069, LG_MES_1LZ_REAL070, LG_MES_1LZ_REAL071, LG_MES_1LZ_REAL072, LG_MES_1LZ_REAL076, LG_MES_1LZ_REAL077, LG_MES_1LZ_REAL078, LG_MES_1LZ_REAL080, LG_MES_1LZ_REAL081, LG_MES_1LZ_REAL083, LG_MES_1LZ_REAL084, LG_MES_1LZ_REAL085, LG_MES_1LZ_REAL086, LG_MES_1LZ_REAL087, LG_MES_1LZ_REAL088, LG_MES_1LZ_REAL092, LG_MES_1LZ_REAL093, LG_MES_1LZ_REAL094, LG_MES_1LZ_REAL096, LG_MES_1LZ_REAL097, LG_MES_1LZ_REAL099, LG_MES_1LZ_REAL100, LG_MES_1LZ_REAL101, LG_MES_1LZ_REAL102, LG_MES_1LZ_REAL103, LG_MES_1LZ_REAL104, LG_MES_1LZ_REAL108, LG_MES_1LZ_REAL109, LG_MES_1LZ_REAL110, LG_MES_1LZ_REAL112, LG_MES_1LZ_REAL113, LG_MES_1LZ_REAL115, LG_MES_1LZ_REAL116, LG_MES_1LZ_REAL117, LG_MES_1LZ_REAL118, LG_MES_1LZ_REAL119, LG_MES_1LZ_REAL120, LG_MES_1LZ_REAL124, LG_MES_1LZ_REAL125 ) )
+        UNION ALL SELECT ALTID, ENG
+        FROM JYMES.V_EMS_LG_CCM02 UNPIVOT ( ENG FOR ALTID IN (LG_MES_2LZ_REAL001, LG_MES_2LZ_REAL002, LG_MES_2LZ_REAL003, LG_MES_2LZ_REAL004, LG_MES_2LZ_REAL005, LG_MES_2LZ_REAL006, LG_MES_2LZ_REAL007, LG_MES_2LZ_REAL008, LG_MES_2LZ_REAL009, LG_MES_2LZ_REAL010, LG_MES_2LZ_REAL011, LG_MES_2LZ_REAL012, LG_MES_2LZ_REAL014, LG_MES_2LZ_REAL016, LG_MES_2LZ_REAL017, LG_MES_2LZ_REAL018, LG_MES_2LZ_REAL019, LG_MES_2LZ_REAL020, LG_MES_2LZ_REAL026, LG_MES_2LZ_REAL027, LG_MES_2LZ_REAL028, LG_MES_2LZ_REAL029, LG_MES_2LZ_REAL030, LG_MES_2LZ_REAL031, LG_MES_2LZ_REAL032, LG_MES_2LZ_REAL033, LG_MES_2LZ_REAL034, LG_MES_2LZ_REAL035, LG_MES_2LZ_REAL036, LG_MES_2LZ_REAL037, LG_MES_2LZ_REAL038, LG_MES_2LZ_REAL039, LG_MES_2LZ_REAL040, LG_MES_2LZ_REAL041, LG_MES_2LZ_REAL042, LG_MES_2LZ_REAL043, LG_MES_2LZ_REAL044, LG_MES_2LZ_REAL045, LG_MES_2LZ_REAL046, LG_MES_2LZ_REAL048, LG_MES_2LZ_REAL049, LG_MES_2LZ_REAL051, LG_MES_2LZ_REAL052, LG_MES_2LZ_REAL053, LG_MES_2LZ_REAL054, LG_MES_2LZ_REAL055, LG_MES_2LZ_REAL056, LG_MES_2LZ_REAL060, LG_MES_2LZ_REAL061, LG_MES_2LZ_REAL062, LG_MES_2LZ_REAL064, LG_MES_2LZ_REAL065, LG_MES_2LZ_REAL067, LG_MES_2LZ_REAL068, LG_MES_2LZ_REAL069, LG_MES_2LZ_REAL070, LG_MES_2LZ_REAL071, LG_MES_2LZ_REAL072, LG_MES_2LZ_REAL076, LG_MES_2LZ_REAL077, LG_MES_2LZ_REAL078, LG_MES_2LZ_REAL080, LG_MES_2LZ_REAL081, LG_MES_2LZ_REAL083, LG_MES_2LZ_REAL084, LG_MES_2LZ_REAL085, LG_MES_2LZ_REAL086, LG_MES_2LZ_REAL087, LG_MES_2LZ_REAL088, LG_MES_2LZ_REAL092, LG_MES_2LZ_REAL093, LG_MES_2LZ_REAL094, LG_MES_2LZ_REAL096, LG_MES_2LZ_REAL097, LG_MES_2LZ_REAL099, LG_MES_2LZ_REAL100, LG_MES_2LZ_REAL101, LG_MES_2LZ_REAL102, LG_MES_2LZ_REAL103, LG_MES_2LZ_REAL104, LG_MES_2LZ_REAL108, LG_MES_2LZ_REAL109, LG_MES_2LZ_REAL110, LG_MES_2LZ_REAL112, LG_MES_2LZ_REAL113, LG_MES_2LZ_REAL115, LG_MES_2LZ_REAL116, LG_MES_2LZ_REAL117, LG_MES_2LZ_REAL118, LG_MES_2LZ_REAL119, LG_MES_2LZ_REAL120, LG_MES_2LZ_REAL124, LG_MES_2LZ_REAL125 ))
+        UNION ALL SELECT ALTID, ENG
+        FROM JYMES.V_EMS_LG_CCM03 UNPIVOT ( ENG FOR ALTID IN (LG_MES_3LZ_REAL001, LG_MES_3LZ_REAL002, LG_MES_3LZ_REAL003, LG_MES_3LZ_REAL004, LG_MES_3LZ_REAL005, LG_MES_3LZ_REAL006, LG_MES_3LZ_REAL007, LG_MES_3LZ_REAL008, LG_MES_3LZ_REAL009, LG_MES_3LZ_REAL010, LG_MES_3LZ_REAL011, LG_MES_3LZ_REAL012, LG_MES_3LZ_REAL014, LG_MES_3LZ_REAL016, LG_MES_3LZ_REAL017, LG_MES_3LZ_REAL018, LG_MES_3LZ_REAL019, LG_MES_3LZ_REAL020, LG_MES_3LZ_REAL026, LG_MES_3LZ_REAL027, LG_MES_3LZ_REAL028, LG_MES_3LZ_REAL029, LG_MES_3LZ_REAL030, LG_MES_3LZ_REAL031, LG_MES_3LZ_REAL032, LG_MES_3LZ_REAL033, LG_MES_3LZ_REAL034, LG_MES_3LZ_REAL035, LG_MES_3LZ_REAL036, LG_MES_3LZ_REAL037, LG_MES_3LZ_REAL038, LG_MES_3LZ_REAL039, LG_MES_3LZ_REAL040, LG_MES_3LZ_REAL041, LG_MES_3LZ_REAL042, LG_MES_3LZ_REAL043, LG_MES_3LZ_REAL044, LG_MES_3LZ_REAL045, LG_MES_3LZ_REAL046, LG_MES_3LZ_REAL048, LG_MES_3LZ_REAL049, LG_MES_3LZ_REAL051, LG_MES_3LZ_REAL052, LG_MES_3LZ_REAL053, LG_MES_3LZ_REAL054, LG_MES_3LZ_REAL055, LG_MES_3LZ_REAL056, LG_MES_3LZ_REAL060, LG_MES_3LZ_REAL061, LG_MES_3LZ_REAL062, LG_MES_3LZ_REAL064, LG_MES_3LZ_REAL065, LG_MES_3LZ_REAL067, LG_MES_3LZ_REAL068, LG_MES_3LZ_REAL069, LG_MES_3LZ_REAL070, LG_MES_3LZ_REAL071, LG_MES_3LZ_REAL072, LG_MES_3LZ_REAL076, LG_MES_3LZ_REAL077 ))
+    </select>
+</mapper>

+ 15 - 0
src/main/java/com/steerinfo/lgReal/model/LgReal.java

@@ -0,0 +1,15 @@
+package com.steerinfo.lgReal.model;
+
+import lombok.Data;
+
+/**
+ * @author Shadow
+ * @create 2021-10-27 21:56
+ * @project xt-ems-datasource
+ */
+@Data
+public class LgReal {
+
+        private String altId;
+        private String eng;
+}

+ 16 - 0
src/main/java/com/steerinfo/lgReal/service/ILgRealService.java

@@ -0,0 +1,16 @@
+package com.steerinfo.lgReal.service;
+
+import com.steerinfo.lgReal.model.LgReal;
+
+import java.util.List;
+
+public interface ILgRealService {
+
+    /**
+     *     获取炼钢实时数据
+     */
+    public List<LgReal> QueryLgReals1();
+
+    public List<LgReal> QueryLgReals2();
+
+}

+ 30 - 0
src/main/java/com/steerinfo/lgReal/service/impl/LgRealImpl.java

@@ -0,0 +1,30 @@
+package com.steerinfo.lgReal.service.impl;
+
+import com.steerinfo.config.dynamicDataSource.TargetDataSource;
+import com.steerinfo.lgReal.mapper.LgRealMapper;
+import com.steerinfo.lgReal.model.LgReal;
+import com.steerinfo.lgReal.service.ILgRealService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service("lgRealService")
+public class LgRealImpl implements ILgRealService {
+
+    @Autowired
+    private LgRealMapper lgRealMapper;
+
+    @Override
+    @TargetDataSource(name = "ds2")
+    public List<LgReal> QueryLgReals1() {
+        return lgRealMapper.QueryLgReals1();
+    }
+
+    @Override
+    @TargetDataSource(name = "ds2")
+    public List<LgReal> QueryLgReals2() {
+        return lgRealMapper.QueryLgReals2();
+    }
+
+}

+ 37 - 0
src/main/java/com/steerinfo/product/dzmaterialsf/controller/DzMaterialSfController.java

@@ -0,0 +1,37 @@
+package com.steerinfo.product.dzmaterialsf.controller;
+
+import com.steerinfo.product.dzmaterialsf.model.DzMaterialSf;
+import com.steerinfo.product.dzmaterialsf.service.IDzMaterialSfService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * DzMaterialSf RESTful接口:
+ * @author generator
+ * @version 1.0-SNAPSHORT 2021-10-15 03:25
+ * 类描述
+ * 修订历史:
+ * 日期:2021-10-15
+ * 作者:generator
+ * 参考:
+ * 描述:DzMaterialSf RESTful接口
+ * @see null
+ * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
+ */
+@RestController
+@RequestMapping("/${api.version}/dematerialSfDb")
+public class DzMaterialSfController  {
+
+    @Autowired
+    IDzMaterialSfService dzMaterialSfService;
+
+    @GetMapping("/getDzMaterialSf")
+    public List<DzMaterialSf> getDzMaterialSf(){
+        List<DzMaterialSf> all = dzMaterialSfService.getDzMaterialSf();
+        return all;
+    }
+}

+ 13 - 0
src/main/java/com/steerinfo/product/dzmaterialsf/mapper/DzMaterialSfMapper.java

@@ -0,0 +1,13 @@
+package com.steerinfo.product.dzmaterialsf.mapper;
+
+import com.steerinfo.product.dzmaterialsf.model.DzMaterialSf;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@Mapper
+public interface DzMaterialSfMapper  {
+
+    List<DzMaterialSf> getDzMaterialSf(@Param("gbsj") String gbsj);
+}

+ 533 - 0
src/main/java/com/steerinfo/product/dzmaterialsf/mapper/DzMaterialSfMapper.xml

@@ -0,0 +1,533 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.steerinfo.product.dzmaterialsf.mapper.DzMaterialSfMapper">
+  <resultMap id="BaseResultMap" type="com.steerinfo.product.dzmaterialsf.model.DzMaterialSf">
+    <id column="GBSJ" jdbcType="VARCHAR" property="gbsj" />
+    <result column="CINVCCODE" jdbcType="VARCHAR" property="cinvccode" />
+    <result column="CINVCNAME" jdbcType="VARCHAR" property="cinvcname" />
+    <result column="CINVCODE" jdbcType="VARCHAR" property="cinvcode" />
+    <result column="CINVNAME" jdbcType="VARCHAR" property="cinvname" />
+    <result column="CINVSTD" jdbcType="VARCHAR" property="cinvstd" />
+    <result column="CWHCODE" jdbcType="VARCHAR" property="cwhcode" />
+    <result column="CWHNAME" jdbcType="VARCHAR" property="cwhname" />
+    <result column="MZ" jdbcType="DECIMAL" property="mz" />
+    <result column="PZ" jdbcType="DECIMAL" property="pz" />
+    <result column="JZ" jdbcType="DECIMAL" property="jz" />
+    <result column="TAB" jdbcType="VARCHAR" property="tab" />
+    <result column="CREATEMAN" jdbcType="VARCHAR" property="createman" />
+    <result column="CREATETIME" jdbcType="VARCHAR" property="createtime" />
+    <result column="UPDATEMAN" jdbcType="VARCHAR" property="updateman" />
+    <result column="UPDATETIME" jdbcType="VARCHAR" property="updatetime" />
+    <result column="READTIME" jdbcType="VARCHAR" property="readtime" />
+    <result column="DJLX" jdbcType="VARCHAR" property="djlx" />
+    <result column="PZDL" jdbcType="VARCHAR" property="pzdl" />
+  </resultMap>
+  <sql id="columns">
+    GBSJ, CINVCCODE, CINVCNAME, CINVCODE, CINVNAME, CINVSTD, CWHCODE, CWHNAME, MZ, PZ, 
+    JZ, TAB, CREATEMAN, CREATETIME, UPDATEMAN, UPDATETIME, READTIME, DJLX, PZDL
+  </sql>
+  <sql id="columns_alias">
+    t.GBSJ, t.CINVCCODE, t.CINVCNAME, t.CINVCODE, t.CINVNAME, t.CINVSTD, t.CWHCODE, t.CWHNAME, 
+    t.MZ, t.PZ, t.JZ, t.TAB, t.CREATEMAN, t.CREATETIME, t.UPDATEMAN, t.UPDATETIME, t.READTIME,
+    t.DJLX, t.PZDL
+  </sql>
+  <sql id="select">
+    SELECT <include refid="columns"/> FROM DZ_MATERIAL_SF
+  </sql>
+  <sql id="select_alias">
+    SELECT <include refid="columns_alias"/> FROM DZ_MATERIAL_SF t
+  </sql>
+  <sql id="where">
+    <where> 
+      <if test="gbsj != null and gbsj != ''">
+        and GBSJ = #{gbsj}
+      </if>
+      <if test="cinvccode != null and cinvccode != ''">
+        and CINVCCODE = #{cinvccode}
+      </if>
+      <if test="cinvcname != null and cinvcname != ''">
+        and CINVCNAME = #{cinvcname}
+      </if>
+      <if test="cinvcode != null and cinvcode != ''">
+        and CINVCODE = #{cinvcode}
+      </if>
+      <if test="cinvname != null and cinvname != ''">
+        and CINVNAME = #{cinvname}
+      </if>
+      <if test="cinvstd != null and cinvstd != ''">
+        and CINVSTD = #{cinvstd}
+      </if>
+      <if test="cwhcode != null and cwhcode != ''">
+        and CWHCODE = #{cwhcode}
+      </if>
+      <if test="cwhname != null and cwhname != ''">
+        and CWHNAME = #{cwhname}
+      </if>
+      <if test="mz != null">
+        and MZ = #{mz}
+      </if>
+      <if test="pz != null">
+        and PZ = #{pz}
+      </if>
+      <if test="jz != null">
+        and JZ = #{jz}
+      </if>
+      <if test="tab != null and tab != ''">
+        and TAB = #{tab}
+      </if>
+      <if test="createman != null and createman != ''">
+        and CREATEMAN = #{createman}
+      </if>
+      <if test="createtime != null and createtime != ''">
+        and CREATETIME = #{createtime}
+      </if>
+      <if test="updateman != null and updateman != ''">
+        and UPDATEMAN = #{updateman}
+      </if>
+      <if test="updatetime != null and updatetime != ''">
+        and UPDATETIME = #{updatetime}
+      </if>
+      <if test="readtime != null and readtime != ''">
+        and READTIME = #{readtime}
+      </if>
+    </where>
+  </sql>
+  <sql id="whereLike">
+    <where> 
+      <if test="gbsj != null and gbsj != ''">
+        and GBSJ LIKE '%${gbsj}%'
+      </if>
+      <if test="cinvccode != null and cinvccode != ''">
+        and CINVCCODE LIKE '%${cinvccode}%'
+      </if>
+      <if test="cinvcname != null and cinvcname != ''">
+        and CINVCNAME LIKE '%${cinvcname}%'
+      </if>
+      <if test="cinvcode != null and cinvcode != ''">
+        and CINVCODE LIKE '%${cinvcode}%'
+      </if>
+      <if test="cinvname != null and cinvname != ''">
+        and CINVNAME LIKE '%${cinvname}%'
+      </if>
+      <if test="cinvstd != null and cinvstd != ''">
+        and CINVSTD LIKE '%${cinvstd}%'
+      </if>
+      <if test="cwhcode != null and cwhcode != ''">
+        and CWHCODE LIKE '%${cwhcode}%'
+      </if>
+      <if test="cwhname != null and cwhname != ''">
+        and CWHNAME LIKE '%${cwhname}%'
+      </if>
+      <if test="mz != null">
+        and MZ = #{mz}
+      </if>
+      <if test="pz != null">
+        and PZ = #{pz}
+      </if>
+      <if test="jz != null">
+        and JZ = #{jz}
+      </if>
+      <if test="tab != null and tab != ''">
+        and TAB LIKE '%${tab}%'
+      </if>
+      <if test="createman != null and createman != ''">
+        and CREATEMAN LIKE '%${createman}%'
+      </if>
+      <if test="createtime != null and createtime != ''">
+        and CREATETIME LIKE '%${createtime}%'
+      </if>
+      <if test="updateman != null and updateman != ''">
+        and UPDATEMAN LIKE '%${updateman}%'
+      </if>
+      <if test="updatetime != null and updatetime != ''">
+        and UPDATETIME LIKE '%${updatetime}%'
+      </if>
+      <if test="readtime != null and readtime != ''">
+        and READTIME LIKE '%${readtime}%'
+      </if>
+    </where>
+  </sql>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.String">
+    delete from DZ_MATERIAL_SF
+    where GBSJ = #{gbsj,jdbcType=VARCHAR}
+  </delete>
+  <delete id="deleteBySelectiveElement" parameterType="java.util.HashMap">
+    delete from DZ_MATERIAL_SF
+    where 1!=1 
+      <if test="cinvccode != null and cinvccode != ''">
+        or CINVCCODE = #{cinvccode}
+      </if>
+      <if test="cinvcname != null and cinvcname != ''">
+        or CINVCNAME = #{cinvcname}
+      </if>
+      <if test="cinvcode != null and cinvcode != ''">
+        or CINVCODE = #{cinvcode}
+      </if>
+      <if test="cinvname != null and cinvname != ''">
+        or CINVNAME = #{cinvname}
+      </if>
+      <if test="cinvstd != null and cinvstd != ''">
+        or CINVSTD = #{cinvstd}
+      </if>
+      <if test="cwhcode != null and cwhcode != ''">
+        or CWHCODE = #{cwhcode}
+      </if>
+      <if test="cwhname != null and cwhname != ''">
+        or CWHNAME = #{cwhname}
+      </if>
+      <if test="mz != null">
+        or MZ = #{mz}
+      </if>
+      <if test="pz != null">
+        or PZ = #{pz}
+      </if>
+      <if test="jz != null">
+        or JZ = #{jz}
+      </if>
+      <if test="tab != null and tab != ''">
+        or TAB = #{tab}
+      </if>
+      <if test="createman != null and createman != ''">
+        or CREATEMAN = #{createman}
+      </if>
+      <if test="createtime != null and createtime != ''">
+        or CREATETIME = #{createtime}
+      </if>
+      <if test="updateman != null and updateman != ''">
+        or UPDATEMAN = #{updateman}
+      </if>
+      <if test="updatetime != null and updatetime != ''">
+        or UPDATETIME = #{updatetime}
+      </if>
+      <if test="readtime != null and readtime != ''">
+        or READTIME = #{readtime}
+      </if>
+  </delete>
+  <insert id="insert" parameterType="com.steerinfo.product.dzmaterialsf.model.DzMaterialSf">
+    insert into DZ_MATERIAL_SF (GBSJ, CINVCCODE, CINVCNAME, 
+      CINVCODE, CINVNAME, CINVSTD, 
+      CWHCODE, CWHNAME, MZ, 
+      PZ, JZ, TAB, CREATEMAN, 
+      CREATETIME, UPDATEMAN, UPDATETIME, 
+      READTIME)
+    values (#{gbsj,jdbcType=VARCHAR}, #{cinvccode,jdbcType=VARCHAR}, #{cinvcname,jdbcType=VARCHAR}, 
+      #{cinvcode,jdbcType=VARCHAR}, #{cinvname,jdbcType=VARCHAR}, #{cinvstd,jdbcType=VARCHAR}, 
+      #{cwhcode,jdbcType=VARCHAR}, #{cwhname,jdbcType=VARCHAR}, #{mz,jdbcType=DECIMAL}, 
+      #{pz,jdbcType=DECIMAL}, #{jz,jdbcType=DECIMAL}, #{tab,jdbcType=VARCHAR}, #{createman,jdbcType=VARCHAR}, 
+      #{createtime,jdbcType=VARCHAR}, #{updateman,jdbcType=VARCHAR}, #{updatetime,jdbcType=VARCHAR}, 
+      #{readtime,jdbcType=VARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.steerinfo.product.dzmaterialsf.model.DzMaterialSf">
+    insert into DZ_MATERIAL_SF
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="gbsj != null">
+        GBSJ,
+      </if>
+      <if test="cinvccode != null">
+        CINVCCODE,
+      </if>
+      <if test="cinvcname != null">
+        CINVCNAME,
+      </if>
+      <if test="cinvcode != null">
+        CINVCODE,
+      </if>
+      <if test="cinvname != null">
+        CINVNAME,
+      </if>
+      <if test="cinvstd != null">
+        CINVSTD,
+      </if>
+      <if test="cwhcode != null">
+        CWHCODE,
+      </if>
+      <if test="cwhname != null">
+        CWHNAME,
+      </if>
+      <if test="mz != null">
+        MZ,
+      </if>
+      <if test="pz != null">
+        PZ,
+      </if>
+      <if test="jz != null">
+        JZ,
+      </if>
+      <if test="tab != null">
+        TAB,
+      </if>
+      <if test="createman != null">
+        CREATEMAN,
+      </if>
+      <if test="createtime != null">
+        CREATETIME,
+      </if>
+      <if test="updateman != null">
+        UPDATEMAN,
+      </if>
+      <if test="updatetime != null">
+        UPDATETIME,
+      </if>
+      <if test="readtime != null">
+        READTIME,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="gbsj != null">
+        #{gbsj,jdbcType=VARCHAR},
+      </if>
+      <if test="cinvccode != null">
+        #{cinvccode,jdbcType=VARCHAR},
+      </if>
+      <if test="cinvcname != null">
+        #{cinvcname,jdbcType=VARCHAR},
+      </if>
+      <if test="cinvcode != null">
+        #{cinvcode,jdbcType=VARCHAR},
+      </if>
+      <if test="cinvname != null">
+        #{cinvname,jdbcType=VARCHAR},
+      </if>
+      <if test="cinvstd != null">
+        #{cinvstd,jdbcType=VARCHAR},
+      </if>
+      <if test="cwhcode != null">
+        #{cwhcode,jdbcType=VARCHAR},
+      </if>
+      <if test="cwhname != null">
+        #{cwhname,jdbcType=VARCHAR},
+      </if>
+      <if test="mz != null">
+        #{mz,jdbcType=DECIMAL},
+      </if>
+      <if test="pz != null">
+        #{pz,jdbcType=DECIMAL},
+      </if>
+      <if test="jz != null">
+        #{jz,jdbcType=DECIMAL},
+      </if>
+      <if test="tab != null">
+        #{tab,jdbcType=VARCHAR},
+      </if>
+      <if test="createman != null">
+        #{createman,jdbcType=VARCHAR},
+      </if>
+      <if test="createtime != null">
+        #{createtime,jdbcType=VARCHAR},
+      </if>
+      <if test="updateman != null">
+        #{updateman,jdbcType=VARCHAR},
+      </if>
+      <if test="updatetime != null">
+        #{updatetime,jdbcType=VARCHAR},
+      </if>
+      <if test="readtime != null">
+        #{readtime,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKey" parameterType="com.steerinfo.product.dzmaterialsf.model.DzMaterialSf">
+    update DZ_MATERIAL_SF
+    set CINVCCODE = #{cinvccode,jdbcType=VARCHAR},
+      CINVCNAME = #{cinvcname,jdbcType=VARCHAR},
+      CINVCODE = #{cinvcode,jdbcType=VARCHAR},
+      CINVNAME = #{cinvname,jdbcType=VARCHAR},
+      CINVSTD = #{cinvstd,jdbcType=VARCHAR},
+      CWHCODE = #{cwhcode,jdbcType=VARCHAR},
+      CWHNAME = #{cwhname,jdbcType=VARCHAR},
+      MZ = #{mz,jdbcType=DECIMAL},
+      PZ = #{pz,jdbcType=DECIMAL},
+      JZ = #{jz,jdbcType=DECIMAL},
+      TAB = #{tab,jdbcType=VARCHAR},
+      CREATEMAN = #{createman,jdbcType=VARCHAR},
+      CREATETIME = #{createtime,jdbcType=VARCHAR},
+      UPDATEMAN = #{updateman,jdbcType=VARCHAR},
+      UPDATETIME = #{updatetime,jdbcType=VARCHAR},
+      READTIME = #{readtime,jdbcType=VARCHAR}
+    where GBSJ = #{gbsj,jdbcType=VARCHAR}
+  </update>
+  <update id="updateByPrimaryKeySelective" parameterType="com.steerinfo.product.dzmaterialsf.model.DzMaterialSf">
+    update DZ_MATERIAL_SF
+    <set>
+      <if test="cinvccode != null">
+        CINVCCODE = #{cinvccode,jdbcType=VARCHAR},
+      </if>
+      <if test="cinvcname != null">
+        CINVCNAME = #{cinvcname,jdbcType=VARCHAR},
+      </if>
+      <if test="cinvcode != null">
+        CINVCODE = #{cinvcode,jdbcType=VARCHAR},
+      </if>
+      <if test="cinvname != null">
+        CINVNAME = #{cinvname,jdbcType=VARCHAR},
+      </if>
+      <if test="cinvstd != null">
+        CINVSTD = #{cinvstd,jdbcType=VARCHAR},
+      </if>
+      <if test="cwhcode != null">
+        CWHCODE = #{cwhcode,jdbcType=VARCHAR},
+      </if>
+      <if test="cwhname != null">
+        CWHNAME = #{cwhname,jdbcType=VARCHAR},
+      </if>
+      <if test="mz != null">
+        MZ = #{mz,jdbcType=DECIMAL},
+      </if>
+      <if test="pz != null">
+        PZ = #{pz,jdbcType=DECIMAL},
+      </if>
+      <if test="jz != null">
+        JZ = #{jz,jdbcType=DECIMAL},
+      </if>
+      <if test="tab != null">
+        TAB = #{tab,jdbcType=VARCHAR},
+      </if>
+      <if test="createman != null">
+        CREATEMAN = #{createman,jdbcType=VARCHAR},
+      </if>
+      <if test="createtime != null">
+        CREATETIME = #{createtime,jdbcType=VARCHAR},
+      </if>
+      <if test="updateman != null">
+        UPDATEMAN = #{updateman,jdbcType=VARCHAR},
+      </if>
+      <if test="updatetime != null">
+        UPDATETIME = #{updatetime,jdbcType=VARCHAR},
+      </if>
+      <if test="readtime != null">
+        READTIME = #{readtime,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where GBSJ = #{gbsj,jdbcType=VARCHAR}
+  </update>
+  <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
+    <include refid="select"/>
+    where GBSJ = #{gbsj,jdbcType=VARCHAR}
+  </select>
+  <select id="selectByParameters" parameterType="java.util.HashMap" resultMap="BaseResultMap">
+    <include refid="select"/>
+    <include refid="where"/>
+  </select>
+  <select id="selectLikeByParameters" parameterType="java.util.HashMap" resultMap="BaseResultMap">
+    <include refid="select"/>
+    <include refid="whereLike"/>
+  </select>
+  <insert id="batchInsert" parameterType="java.util.List">
+    insert into DZ_MATERIAL_SF 
+      (GBSJ, 
+      CINVCCODE, CINVCNAME, CINVCODE, 
+      CINVNAME, CINVSTD, CWHCODE, 
+      CWHNAME, MZ, PZ, 
+      JZ, TAB, CREATEMAN, 
+      CREATETIME, UPDATEMAN, UPDATETIME, 
+      READTIME)
+    ( <foreach collection="list" item="item" separator="union all"> 
+   select  
+      #{item.gbsj,jdbcType=VARCHAR}, 
+      #{item.cinvccode,jdbcType=VARCHAR}, #{item.cinvcname,jdbcType=VARCHAR}, #{item.cinvcode,jdbcType=VARCHAR}, 
+      #{item.cinvname,jdbcType=VARCHAR}, #{item.cinvstd,jdbcType=VARCHAR}, #{item.cwhcode,jdbcType=VARCHAR}, 
+      #{item.cwhname,jdbcType=VARCHAR}, #{item.mz,jdbcType=DECIMAL}, #{item.pz,jdbcType=DECIMAL}, 
+      #{item.jz,jdbcType=DECIMAL}, #{item.tab,jdbcType=VARCHAR}, #{item.createman,jdbcType=VARCHAR}, 
+      #{item.createtime,jdbcType=VARCHAR}, #{item.updateman,jdbcType=VARCHAR}, #{item.updatetime,jdbcType=VARCHAR}, 
+      #{item.readtime,jdbcType=VARCHAR} from dual  
+   </foreach> )
+  </insert>
+  <update id="batchUpdate" parameterType="java.util.List">
+     update DZ_MATERIAL_SF
+     set
+       GBSJ=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.gbsj,jdbcType=VARCHAR}
+       </foreach>
+       ,CINVCCODE=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.cinvccode,jdbcType=VARCHAR}
+       </foreach>
+       ,CINVCNAME=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.cinvcname,jdbcType=VARCHAR}
+       </foreach>
+       ,CINVCODE=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.cinvcode,jdbcType=VARCHAR}
+       </foreach>
+       ,CINVNAME=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.cinvname,jdbcType=VARCHAR}
+       </foreach>
+       ,CINVSTD=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.cinvstd,jdbcType=VARCHAR}
+       </foreach>
+       ,CWHCODE=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.cwhcode,jdbcType=VARCHAR}
+       </foreach>
+       ,CWHNAME=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.cwhname,jdbcType=VARCHAR}
+       </foreach>
+       ,MZ=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.mz,jdbcType=DECIMAL}
+       </foreach>
+       ,PZ=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.pz,jdbcType=DECIMAL}
+       </foreach>
+       ,JZ=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.jz,jdbcType=DECIMAL}
+       </foreach>
+       ,TAB=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.tab,jdbcType=VARCHAR}
+       </foreach>
+       ,CREATEMAN=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.createman,jdbcType=VARCHAR}
+       </foreach>
+       ,CREATETIME=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.createtime,jdbcType=VARCHAR}
+       </foreach>
+       ,UPDATEMAN=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.updateman,jdbcType=VARCHAR}
+       </foreach>
+       ,UPDATETIME=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.updatetime,jdbcType=VARCHAR}
+       </foreach>
+       ,READTIME=
+       <foreach collection="list" item="item" index="index" separator=" " open="case GBSJ" close="end">
+          when #{item.gbsj,jdbcType=VARCHAR} then #{item.readtime,jdbcType=VARCHAR}
+       </foreach>
+     where GBSJ in 
+     <foreach collection="list" index="index" item="item" separator="," open="(" close=")">
+    #{item.gbsj,jdbcType=VARCHAR}
+     </foreach> 
+  </update>
+  <delete id="batchDelete" parameterType="java.util.List">
+    delete from DZ_MATERIAL_SF
+    where GBSJ in 
+    <foreach collection="list" item="id" open="(" close=")" separator=",">
+      #{id}
+    </foreach>
+  </delete>
+  <!-- 友情提示!!!-->
+  <!-- 请将自己写的代码放在此标签之下,方便以后粘贴复制。-->
+<!--  &#45;&#45;cInvCName in('合金材料','国内矿粉','过滤材料','进口矿粉','原煤','外购精煤','国内球团','高炉干渣','进口块矿','石料')-->
+  <select id="getDzMaterialSf" resultMap="BaseResultMap" parameterType="java.lang.String" >
+    select * from (
+    SELECT CONVERT(varchar(100), gbsj, 23) as gbsj, cInvCCode, cInvCName, cInvCode, cInvName,
+    cInvStd, cWhCode, cWhName, sum(mz) as mz, sum(pz) as pz, sum(jz) as jz, djlx, pzdl, 'sh' as tab
+    FROM v_nyjk_sh where gbsj >= #{gbsj,jdbcType=VARCHAR} and pzdl IS NOT NULL
+    group by cInvCCode, cInvCName, cInvCode, cInvName, cInvStd, cWhCode, cWhName, CONVERT(varchar(100), gbsj, 23),djlx, pzdl
+    ) as sh union all (
+    SELECT CONVERT(varchar(100), gbsj, 23) as gbsj, cInvCCode, cInvCName, cInvCode, cInvName,
+    cInvStd, cWhCode, cWhName, sum(mz) as mz, sum(pz) as pz, sum(jz) as jz, djlx, pzdl, 'fh' as tab
+    FROM v_nyjk_fh where gbsj >= #{gbsj,jdbcType=VARCHAR} and pzdl IS NOT NULL
+    group by cInvCCode, cInvCName, cInvCode, cInvName, cInvStd, cWhCode, cWhName, CONVERT(varchar(100), [gbsj], 23),djlx, pzdl)
+  </select>
+</mapper>

+ 303 - 0
src/main/java/com/steerinfo/product/dzmaterialsf/model/DzMaterialSf.java

@@ -0,0 +1,303 @@
+package com.steerinfo.product.dzmaterialsf.model;
+
+import java.math.BigDecimal;
+import java.util.HashMap;
+import java.util.Map;
+
+public class DzMaterialSf {
+    /**
+     * 日期(GBSJ,VARCHAR,20)
+     */
+    private String gbsj;
+
+    /**
+     * 物料类型id(CINVCCODE,VARCHAR,20)
+     */
+    private String cinvccode;
+
+    /**
+     * 物料ID(CINVCODE,VARCHAR,20)
+     */
+    private String cinvcode;
+
+    /**
+     * 物料仓库ID(CWHCODE,VARCHAR,20)
+     */
+    private String cwhcode;
+
+    /**
+     * 物料类型名称(CINVCNAME,VARCHAR,20)
+     */
+    private String cinvcname;
+
+    /**
+     * 物料名称(CINVNAME,VARCHAR,50)
+     */
+    private String cinvname;
+
+    /**
+     * 物料规格(备注)(CINVSTD,VARCHAR,100)
+     */
+    private String cinvstd;
+
+    /**
+     * 物料仓库名称(CWHNAME,VARCHAR,100)
+     */
+    private String cwhname;
+
+    /**
+     * 毛重(MZ,DECIMAL,20)
+     */
+    private BigDecimal mz;
+
+    /**
+     * 皮重(PZ,DECIMAL,20)
+     */
+    private BigDecimal pz;
+
+    /**
+     * 净重(JZ,DECIMAL,20)
+     */
+    private BigDecimal jz;
+
+    /**
+     * 表标识(TAB,VARCHAR,10)
+     */
+    private String tab;
+
+    /**
+     * 创建人(CREATEMAN,VARCHAR,50)
+     */
+    private String createman;
+
+    /**
+     * 创建时间(CREATETIME,VARCHAR,50)
+     */
+    private String createtime;
+
+    /**
+     * 修改人(UPDATEMAN,VARCHAR,50)
+     */
+    private String updateman;
+
+    /**
+     * 修改时间(UPDATETIME,VARCHAR,50)
+     */
+    private String updatetime;
+
+    /**
+     * 读取时间(READTIME,VARCHAR,50)
+     */
+    private String readtime;
+
+    /**
+     * 单据类型(READTIME,VARCHAR,50)
+     */
+    private String djlx;
+
+    /**
+     * 品种(READTIME,VARCHAR,50)
+     */
+    private String pzdl;
+
+    private static final long serialVersionUID = 1L;
+
+    public Map<String, Object> getId() {
+        Map<String, Object> params = new HashMap<>();
+        params.put("gbsj",this.gbsj);
+        params.put("cinvccode",this.cinvccode);
+        params.put("cinvcode",this.cinvcode);
+        params.put("cwhcode",this.cwhcode);
+        params.put("tab",this.tab);
+        params.put("djlx",this.djlx);
+        return params;
+    }
+
+    public void setId(DzMaterialSf dzMaterialSf) {
+        this.gbsj = dzMaterialSf.getGbsj();
+        this.cinvccode = dzMaterialSf.getCinvccode();
+        this.cinvcode = dzMaterialSf.getCinvcode();
+        this.cwhcode = dzMaterialSf.getCwhcode();
+        this.tab = dzMaterialSf.getTab();
+        this.djlx = dzMaterialSf.getDjlx();
+    }
+
+    public String getGbsj() {
+        return gbsj;
+    }
+
+    public void setGbsj(String gbsj) {
+        this.gbsj = gbsj == null ? null : gbsj.trim();
+    }
+
+    public String getCinvccode() {
+        return cinvccode;
+    }
+
+    public void setCinvccode(String cinvccode) {
+        this.cinvccode = cinvccode == null ? null : cinvccode.trim();
+    }
+
+    public String getCinvcode() {
+        return cinvcode;
+    }
+
+    public void setCinvcode(String cinvcode) {
+        this.cinvcode = cinvcode == null ? null : cinvcode.trim();
+    }
+
+    public String getCwhcode() {
+        return cwhcode;
+    }
+
+    public void setCwhcode(String cwhcode) {
+        this.cwhcode = cwhcode == null ? null : cwhcode.trim();
+    }
+
+    public String getCinvcname() {
+        return cinvcname;
+    }
+
+    public void setCinvcname(String cinvcname) {
+        this.cinvcname = cinvcname == null ? null : cinvcname.trim();
+    }
+
+    public String getCinvname() {
+        return cinvname;
+    }
+
+    public void setCinvname(String cinvname) {
+        this.cinvname = cinvname == null ? null : cinvname.trim();
+    }
+
+    public String getCinvstd() {
+        return cinvstd;
+    }
+
+    public void setCinvstd(String cinvstd) {
+        this.cinvstd = cinvstd == null ? null : cinvstd.trim();
+    }
+
+    public String getCwhname() {
+        return cwhname;
+    }
+
+    public void setCwhname(String cwhname) {
+        this.cwhname = cwhname == null ? null : cwhname.trim();
+    }
+
+    public BigDecimal getMz() {
+        return mz;
+    }
+
+    public void setMz(BigDecimal mz) {
+        this.mz = mz;
+    }
+
+    public BigDecimal getPz() {
+        return pz;
+    }
+
+    public void setPz(BigDecimal pz) {
+        this.pz = pz;
+    }
+
+    public BigDecimal getJz() {
+        return jz;
+    }
+
+    public void setJz(BigDecimal jz) {
+        this.jz = jz;
+    }
+
+    public String getTab() {
+        return tab;
+    }
+
+    public void setTab(String tab) {
+        this.tab = tab == null ? null : tab.trim();
+    }
+
+    public String getCreateman() {
+        return createman;
+    }
+
+    public void setCreateman(String createman) {
+        this.createman = createman == null ? null : createman.trim();
+    }
+
+    public String getCreatetime() {
+        return createtime;
+    }
+
+    public void setCreatetime(String createtime) {
+        this.createtime = createtime == null ? null : createtime.trim();
+    }
+
+    public String getUpdateman() {
+        return updateman;
+    }
+
+    public void setUpdateman(String updateman) {
+        this.updateman = updateman == null ? null : updateman.trim();
+    }
+
+    public String getUpdatetime() {
+        return updatetime;
+    }
+
+    public void setUpdatetime(String updatetime) {
+        this.updatetime = updatetime == null ? null : updatetime.trim();
+    }
+
+    public String getReadtime() {
+        return readtime;
+    }
+
+    public void setReadtime(String readtime) {
+        this.readtime = readtime == null ? null : readtime.trim();
+    }
+
+    public String getDjlx() { return djlx; }
+
+    public void setDjlx(String djlx) {
+        this.djlx = djlx;
+    }
+
+    public String getPzdl() {
+        return pzdl;
+    }
+
+    public void setPzdl(String pzdl) {
+        this.pzdl = pzdl;
+    }
+    @Override
+    public String toString() {
+        StringBuilder sb = new StringBuilder();
+        sb.append(getClass().getSimpleName());
+        sb.append(" [");
+        sb.append("Hash = ").append(hashCode());
+        sb.append(", gbsj=").append(gbsj);
+        sb.append(", cinvccode=").append(cinvccode);
+        sb.append(", cinvcode=").append(cinvcode);
+        sb.append(", cwhcode=").append(cwhcode);
+        sb.append(", cinvcname=").append(cinvcname);
+        sb.append(", cinvname=").append(cinvname);
+        sb.append(", cinvstd=").append(cinvstd);
+        sb.append(", cwhname=").append(cwhname);
+        sb.append(", mz=").append(mz);
+        sb.append(", pz=").append(pz);
+        sb.append(", jz=").append(jz);
+        sb.append(", tab=").append(tab);
+        sb.append(", createman=").append(createman);
+        sb.append(", createtime=").append(createtime);
+        sb.append(", updateman=").append(updateman);
+        sb.append(", updatetime=").append(updatetime);
+        sb.append(", readtime=").append(readtime);
+        sb.append(", djlx=").append(djlx);
+        sb.append(", pzdl=").append(pzdl);
+        sb.append(", serialVersionUID=").append(serialVersionUID);
+        sb.append("]");
+        return sb.toString();
+    }
+}

+ 24 - 0
src/main/java/com/steerinfo/product/dzmaterialsf/service/IDzMaterialSfService.java

@@ -0,0 +1,24 @@
+package com.steerinfo.product.dzmaterialsf.service;
+
+import com.steerinfo.product.dzmaterialsf.model.DzMaterialSf;
+
+import java.util.List;
+
+/**
+ * DzMaterialSf服务接口:
+ * @author generator
+ * @version 1.0-SNAPSHORT 2021-10-15 03:25
+ * 类描述
+ * 修订历史:
+ * 日期:2021-10-15
+ * 作者:generator
+ * 参考:
+ * 描述:DzMaterialSf服务接口
+ * @see null
+ * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
+ */
+public interface IDzMaterialSfService {
+
+    List<DzMaterialSf> getDzMaterialSf();
+
+}

+ 53 - 0
src/main/java/com/steerinfo/product/dzmaterialsf/service/impl/DzMaterialSfServiceImpl.java

@@ -0,0 +1,53 @@
+package com.steerinfo.product.dzmaterialsf.service.impl;
+
+import com.steerinfo.config.dynamicDataSource.TargetDataSource;
+import com.steerinfo.product.dzmaterialsf.mapper.DzMaterialSfMapper;
+import com.steerinfo.product.dzmaterialsf.model.DzMaterialSf;
+import com.steerinfo.product.dzmaterialsf.service.IDzMaterialSfService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.List;
+
+/**
+ * DzMaterialSf服务实现:
+ * @author generator
+ * @version 1.0-SNAPSHORT 2021-10-15 03:25
+ * 类描述
+ * 修订历史:
+ * 日期:2021-10-15
+ * 作者:generator
+ * 参考:
+ * 描述:DzMaterialSf服务实现
+ * @see null
+ * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
+ */
+@Service(value = "dzMaterialSfService")
+public class DzMaterialSfServiceImpl  implements IDzMaterialSfService {
+
+    private static final Logger logger = LoggerFactory.getLogger(DzMaterialSfServiceImpl.class);
+
+    @Autowired
+    private DzMaterialSfMapper dzMaterialSfMapper;
+
+
+    @Override
+    //@TargetDataSource(dataSourceKey = DataSourceKey.DB_SLAVE1)
+    @TargetDataSource(name = "ds3")
+    public List<DzMaterialSf> getDzMaterialSf() {
+
+        Calendar calendar = Calendar.getInstance(); //创建Calendar 的实例
+//可以转成你想要的格式 yyyy/MM/dd HH:mm:ss 等等
+        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+        calendar.add(Calendar.DAY_OF_MONTH,-1);
+        String gbsj= format.format(calendar.getTime());
+
+        List<DzMaterialSf> dzMaterialSfList = dzMaterialSfMapper.getDzMaterialSf(gbsj);
+        return dzMaterialSfList;
+    }
+
+}

+ 35 - 0
src/main/java/com/steerinfo/weight/lgmes/controller/LgReportController.java

@@ -0,0 +1,35 @@
+package com.steerinfo.weight.lgmes.controller;
+
+import com.steerinfo.weight.lgmes.model.EmsScqkLg;
+import com.steerinfo.weight.lgmes.service.ILgReportService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.List;
+
+@RestController
+@RequestMapping("/${api.version}/lgreport")
+public class LgReportController {
+      @Autowired
+      private ILgReportService lgReportService;
+
+
+    @GetMapping("/queryReportByTime")
+    public List<EmsScqkLg> QueryReportByTime(){
+        Calendar calendar = Calendar.getInstance(); //创建Calendar 的实例
+//可以转成你想要的格式 yyyy/MM/dd HH:mm:ss 等等
+        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+        List<EmsScqkLg> emsScqkLgs = new ArrayList<>();
+            calendar.add(Calendar.DAY_OF_MONTH,-1);
+            String clock= format.format(calendar.getTime());
+            emsScqkLgs.add(lgReportService.QueryReportByTime(clock));
+        return emsScqkLgs;
+    }
+
+
+}

+ 0 - 1
src/main/java/com/steerinfo/weight/lgmes/controller/LgWeightController.java

@@ -27,5 +27,4 @@ public class LgWeightController {
         return  lgWeights;
     }
 
-
 }

+ 13 - 0
src/main/java/com/steerinfo/weight/lgmes/mapper/LgReportMapper.java

@@ -0,0 +1,13 @@
+package com.steerinfo.weight.lgmes.mapper;
+
+import com.steerinfo.weight.lgmes.model.EmsScqkLg;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * @author Shadow
+ * @create 2021-10-19 9:42
+ * @project xt-ems-datasource
+ */
+public interface LgReportMapper {
+    public EmsScqkLg QueryReportByTime(@Param("clock")String clock);
+}

+ 29 - 0
src/main/java/com/steerinfo/weight/lgmes/mapper/LgReportMapper.xml

@@ -0,0 +1,29 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.steerinfo.weight.lgmes.mapper.LgReportMapper">
+    <resultMap id="BaseResultMap" type="com.steerinfo.weight.lgmes.model.EmsScqkLg">
+        <id column="RQ" jdbcType="VARCHAR" property="dates"/>
+<!--        <id column="TSRCL" jdbcType="VARCHAR" property="rcl"/>-->
+<!--        <id column="ZT" jdbcType="VARCHAR" property="zt"/>-->
+        <id column="JRKC" jdbcType="VARCHAR" property="kcl"/>
+        <id column="GPRCL" jdbcType="VARCHAR" property="rcl"/>
+        <id column="SJCL" jdbcType="VARCHAR" property="sjyl"/>
+        <id column="SCLS" jdbcType="VARCHAR" property="scls"/>
+<!--        <id column="TH" jdbcType="VARCHAR" property="th"/>-->
+        <id column="NBHST" jdbcType="VARCHAR" property="fgzlNbhst"/>
+        <id column="LLDLYL" jdbcType="VARCHAR" property="lldlyl"/>
+        <id column="LLB" jdbcType="VARCHAR" property="llb"/>
+        <id column="JTL" jdbcType="VARCHAR" property="jtsl"/>
+        <id column="ZL1LL" jdbcType="VARCHAR" property="ll1"/>
+        <id column="ZL2LL" jdbcType="VARCHAR" property="ll2"/>
+<!--        <id column="GPYLJ" jdbcType="VARCHAR" property="gpYlj"/>-->
+<!--        <id column="GPNLJ" jdbcType="VARCHAR" property="gpNlj"/>-->
+<!--        <id column="TSYLJ" jdbcType="VARCHAR" property="tsYlj"/>-->
+<!--        <id column="TSNLJ" jdbcType="VARCHAR" property="tsYlj"/>-->
+        <id column="JS" jdbcType="VARCHAR" property="memo"/>
+        <id column="GSRCL" jdbcType="VARCHAR" property="gsrcl"/>
+    </resultMap>
+    <select id="QueryReportByTime"  resultMap="BaseResultMap" parameterType="java.lang.String">
+        select * from table(jymes.IMP_EMS_REPORT(#{clock}))
+    </select>
+</mapper>

+ 123 - 0
src/main/java/com/steerinfo/weight/lgmes/model/EmsScqkLg.java

@@ -0,0 +1,123 @@
+package com.steerinfo.weight.lgmes.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+/**
+ * @author Shadow
+ * @create 2021-10-19 9:21
+ * @project xt-ems-datasource
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class EmsScqkLg {
+    /**
+     * 生产日期(DATES,TIMESTAMP,7)
+     */
+    private String dates;
+
+    /**
+     * 钢坯日产量(RCL,DECIMAL,0)
+     */
+    private String rcl;
+
+    /**
+     * 进入炼钢铁水量(JTSL,DECIMAL,0)
+     */
+    private String jtsl;
+
+    /**
+     * 炼钢实际用量(SJYL,DECIMAL,0)
+     */
+    private String sjyl;
+
+    /**
+     * 库存量(铁水)(KCL,DECIMAL,0)
+     */
+    private String kcl;
+
+    /**
+     * 未浇钢水量(WJZL,DECIMAL,0)
+     */
+    private String wjzl;
+
+    /**
+     * 生产炉数(SCLS,DECIMAL,0)
+     */
+    private String scls;
+
+    /**
+     * 1#炉龄(LL_1,DECIMAL,0)
+     */
+    private String ll1;
+
+    /**
+     * 2#炉龄(LL_2,DECIMAL,0)
+     */
+    private String ll2;
+
+    /**
+     * 废钢总量_内部含生铁(FGZL_NBHST,DECIMAL,0)
+     */
+    private String fgzlNbhst;
+
+    /**
+     * 废钢总量_外购(FGZL_WG,DECIMAL,0)
+     */
+    private String fgzlWg;
+
+    /**
+     * 冷料单炉用量(LLDLYL,DECIMAL,0)
+     */
+    private String lldlyl;
+
+    /**
+     * 外购废钢_进废钢坑(WGFG_JFGK,DECIMAL,0)
+     */
+    private String wgfgJfgk;
+
+    /**
+     * 外购废钢_去席村废钢量(WGFG_QXC,DECIMAL,0)
+     */
+    private String wgfgQxc;
+
+    /**
+     * 席村返回废钢量(XCF,DECIMAL,0)
+     */
+    private String xcf;
+
+    /**
+     * 记事(MEMO,VARCHAR,500)
+     */
+    private String memo;
+
+    /**
+     * 操作人(CZR,VARCHAR,10)
+     */
+    private String czr;
+
+    /**
+     * 操作时间(CZSJ,TIMESTAMP,7)
+     */
+    private Date czsj;
+
+    /**
+     * 外销钢坯产量(WXGPCL,DECIMAL,0)
+     */
+    private String wxgpcl;
+
+    /**
+     * 冷料比(LLB,DECIMAL,0)
+     */
+    private Short llb;
+
+    /**
+     * 钢水日产量(GSRCL,DECIMAL,0)
+     */
+    private Short gsrcl;
+
+}

+ 13 - 0
src/main/java/com/steerinfo/weight/lgmes/service/ILgReportService.java

@@ -0,0 +1,13 @@
+package com.steerinfo.weight.lgmes.service;
+
+import com.steerinfo.weight.lgmes.model.EmsScqkLg;
+import org.apache.ibatis.annotations.Param;
+
+public interface ILgReportService {
+
+    /**
+     *     获取每日生产日报
+     */
+    public EmsScqkLg QueryReportByTime(@Param("clock")String clock);
+
+}

+ 21 - 0
src/main/java/com/steerinfo/weight/lgmes/service/impl/LgReportImpl.java

@@ -0,0 +1,21 @@
+package com.steerinfo.weight.lgmes.service.impl;
+import com.steerinfo.config.dynamicDataSource.TargetDataSource;
+import com.steerinfo.weight.lgmes.mapper.LgReportMapper;
+import com.steerinfo.weight.lgmes.model.EmsScqkLg;
+import com.steerinfo.weight.lgmes.service.ILgReportService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service("lgReportService")
+public class LgReportImpl implements ILgReportService {
+
+    @Autowired
+    private LgReportMapper lgReportMapper;
+
+    @Override
+    @TargetDataSource(name = "ds2")
+    public EmsScqkLg QueryReportByTime(String clock) {
+        return lgReportMapper.QueryReportByTime(clock);
+    }
+
+}

+ 5 - 1
src/main/resources/bootstrap.properties

@@ -1,4 +1,4 @@
-#Á¬½Ó³ØµÄÅäÖÃÐÅÏ¢
+#\uFFFD\uFFFD\uFFFD\u04F3\u0635\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\u03E2
 spring.druid.jdbcUrl1=jdbc:oracle:thin:@192.168.0.247:1521:antwms
 spring.druid.username1=atwms
 spring.druid.password1=atwms
@@ -11,6 +11,10 @@ spring.druid.jdbcUrl3=jdbc:sqlserver://192.168.0.224:1433;DatabaseName=bfgl_001_
 spring.druid.username3=meiqihyd
 spring.druid.password3=atjt@123
 
+spring.druid.jdbcUrl4=jdbc:sqlserver://192.168.0.224:1433;DatabaseName=bfgl_001_2018
+spring.druid.username4=nengyuanjiankong
+spring.druid.password4=nyjk_123
+
 ##oracle
 spring.druid.driver-class-name-oracle=oracle.jdbc.driver.OracleDriver
 ##sqlserver