新增ajxx表

mq-crj-service/src/main/java/cn/com/taiji/mqcrj/entity/AjxxBean.java

@@ -0,0 +1,21 @@
+package cn.com.taiji.mqcrj.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+/**
+ * @author chen mh
+ * @date 2023/8/7 15:35
+ */
+@Data
+@TableName(value = "s_vg_")
+public class AjxxBean {
+    @TableField(value = "CASE_TYPE")
+    private String CASE_TYPE;
+    @TableField(value = "CASE_NAME")
+    private String CASE_NAME;
+
+    @TableField(value = "TRANSACT_CASE_CODE")
+    private String TRANSACT_CASE_CODE;
+}

mq-crj-service/src/main/java/cn/com/taiji/mqcrj/mapper/AjxxMapper.java

@@ -0,0 +1,13 @@
+package cn.com.taiji.mqcrj.mapper;
+
+import cn.com.taiji.mqcrj.entity.AjxxBean;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author chen mh
+ * @date 2023/7/26 16:36
+ */
+@Mapper
+public interface AjxxMapper extends BaseMapper<AjxxBean> {
+}

mq-crj-service/src/main/java/cn/com/taiji/mqcrj/mapper/BaseCreateNewTableMapper.java

@@ -18,6 +18,8 @@ public interface BaseCreateNewTableMapper {
 
     void createTableMqwgr(String tableName);
 
+    void createTableAjxx(String tableName);
+
     /**
      * 修改表名
      * @param newTable

mq-crj-service/src/main/java/cn/com/taiji/mqcrj/service/AjxxService.java

@@ -0,0 +1,11 @@
+package cn.com.taiji.mqcrj.service;
+
+import cn.com.taiji.mqcrj.entity.AjxxBean;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * @author chen mh
+ * @date 2023/7/27 10:43
+ */
+public interface AjxxService extends IService<AjxxBean> {
+}

mq-crj-service/src/main/java/cn/com/taiji/mqcrj/service/impl/AjxxServiceImpl.java

@@ -0,0 +1,15 @@
+package cn.com.taiji.mqcrj.service.impl;
+
+import cn.com.taiji.mqcrj.entity.AjxxBean;
+import cn.com.taiji.mqcrj.mapper.AjxxMapper;
+import cn.com.taiji.mqcrj.service.AjxxService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author chen mh
+ * @date 2023/7/27 10:44
+ */
+@Service
+public class AjxxServiceImpl extends ServiceImpl<AjxxMapper, AjxxBean> implements AjxxService {
+}

mq-crj-service/src/main/java/cn/com/taiji/mqcrj/task/OracleScheduleTask.java

@@ -1,10 +1,11 @@
 package cn.com.taiji.mqcrj.task;
 
 import cn.com.taiji.mqcrj.config.RequestDataHelper;
+import cn.com.taiji.mqcrj.entity.AjxxBean;
 import cn.com.taiji.mqcrj.entity.AjxyrBean;
 import cn.com.taiji.mqcrj.entity.MqwgrBean;
 import cn.com.taiji.mqcrj.mapper.BaseCreateNewTableMapper;
-import cn.com.taiji.mqcrj.mapper.MqwgrMapper;
+import cn.com.taiji.mqcrj.service.AjxxService;
 import cn.com.taiji.mqcrj.service.AjxyrService;
 import cn.com.taiji.mqcrj.service.MqwgrService;
 import cn.com.taiji.mqcrj.utils.JDBCUtils;
@@ -37,10 +38,13 @@ public class OracleScheduleTask {
     private AjxyrService ajxyrService;
 
     @Resource
+    private AjxxService ajxxService;
+
+    @Resource
     private MqwgrService mqwgrService;
 
     @Scheduled(cron = "2 55 2 * * ?")
-    public void AjxyrTask() {
+    public void ajxyrTask() {
         log.info("执行定时任务 AjxyrTask -{}",DateUtil.date());
         Connection connection = JDBCUtils.getConnection();
         String sqlCount = "select count(*) from hndmc.v_ajxyr";
@@ -87,7 +91,7 @@ public class OracleScheduleTask {
                     AjxyrBean objectBean = JSONObject.parseObject(jsonStr, AjxyrBean.class);
                     objectBeanList.add(objectBean);
                 }
-                RequestDataHelper.setRequestData(new HashMap<String, Object>() {{
+                RequestDataHelper.setRequestData(new HashMap<String, Object>(16) {{
                     put("v_sg_", "v_sg_ajxyr_"+DateUtil.format(DateUtil.yesterday(), "YYYYMMdd"));
                 }});
                 ajxyrService.saveBatch(objectBeanList);
@@ -111,7 +115,7 @@ public class OracleScheduleTask {
 
 
     @Scheduled(cron = "25 53 1 * * ?")
-    public void MqwgrTask() {
+    public void mqwgrTask() {
         log.info("执行定时任务 MqwgrTask -{}",DateUtil.date());
         Connection connection = JDBCUtils.getConnection();
         String sqlCount = "select count(*) from hndmc.v_sg_mqwgr";
@@ -157,7 +161,7 @@ public class OracleScheduleTask {
                     MqwgrBean objectBean = JSONObject.parseObject(jsonStr, MqwgrBean.class);
                     mqwgrBeans.add(objectBean);
                 }
-                RequestDataHelper.setRequestData(new HashMap<String, Object>() {{
+                RequestDataHelper.setRequestData(new HashMap<String, Object>(16) {{
                     put("v_sg_", "v_sg_mqwgr_" + DateUtil.format(DateUtil.yesterday(), "YYYYMMdd"));
                 }});
                 mqwgrService.saveBatch(mqwgrBeans);
@@ -178,4 +182,74 @@ public class OracleScheduleTask {
             JDBCUtils.closeResource(connection,preparedStatement,resultSet);
         }
     }
+
+
+    @Scheduled(cron = "25 23 1 * * ?")
+    public void ajxxTask() {
+        log.info("执行定时任务 AjxxTask -{}",DateUtil.date());
+        Connection connection = JDBCUtils.getConnection();
+        String sqlCount = "select count(*) from hndmc.v_sg_ajxx";
+        PreparedStatement ps = null;
+        ResultSet rs = null;
+        PreparedStatement preparedStatement = null;
+        ResultSet resultSet = null;
+        try {
+            ps = connection.prepareStatement(sqlCount);
+            rs = ps.executeQuery();
+            int count;
+            if(rs.next()){
+                count = rs.getInt(1);
+                log.info("AjxxTask-数据总量是：{}",count);
+                if(count>0){
+                    //创建新表
+                    String format = DateUtil.format(DateUtil.yesterday(), "YYYYMMdd");
+                    baseCreateNewTableMapper.createTableAjxx("v_sg_ajxx_"+format);
+                }else {
+                    return;
+                }
+            }else {
+                return;
+            }
+            for(int x = 0;x<count/10000+1;x++) {
+                int max = (x + 1) * 10000;
+                int min = x * 10000;
+                String sql = "select * from (select v.*,rownum rn from hndmc.v_sg_ajxx v where ROWNUM <= "+max+") where rn>"+min;
+                preparedStatement = connection.prepareStatement(sql);
+                resultSet = preparedStatement.executeQuery();
+
+                // 获取ResultSet对象的列的数量、类型和属性。
+                ResultSetMetaData md = resultSet.getMetaData();
+                int columnCount = md.getColumnCount();
+                // 将ResultSet对象的列名和值存到map中，再将map转换为json字符串，最后将json字符串转换为实体类对象
+                List<AjxxBean> ajxxBeans = new ArrayList<>();
+                Map<String, Object> rowData = new HashMap<>(16);
+                while (resultSet.next()) {
+                    for (int i = 1; i <= columnCount; i++) {
+                        rowData.put(md.getColumnLabel(i), resultSet.getObject(i));
+                    }
+                    String jsonStr = JSONObject.toJSONString(rowData);
+                    AjxxBean objectBean = JSONObject.parseObject(jsonStr, AjxxBean.class);
+                    ajxxBeans.add(objectBean);
+                }
+                RequestDataHelper.setRequestData(new HashMap<String, Object>(16) {{
+                    put("v_sg_", "v_sg_ajxx_" + DateUtil.format(DateUtil.yesterday(), "YYYYMMdd"));
+                }});
+                ajxxService.saveBatch(ajxxBeans);
+                preparedStatement.close();
+                resultSet.close();
+            }
+            log.info("数据导入结束后表名修改");
+            //数据导入结束后表名修改
+            baseCreateNewTableMapper.modifyTableName("v_sg_ajxx_his"+DateUtil.format(DateUtil.yesterday(), "YYYYMMdd"),"v_sg_ajxx");
+            baseCreateNewTableMapper.modifyTableName("v_sg_ajxx","v_sg_ajxx_"+DateUtil.format(DateUtil.yesterday(), "YYYYMMdd"));
+
+            //删除七天前的数据表
+            baseCreateNewTableMapper.dropTable("v_sg_ajxx_his"+DateUtil.format(DateUtil.offsetDay(DateUtil.date(),-8), "YYYYMMdd"));
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }finally {
+            JDBCUtils.closeResource(connection,ps,rs);
+            JDBCUtils.closeResource(connection,preparedStatement,resultSet);
+        }
+    }
 }

mq-crj-service/src/main/resources/mapper/CreateNewTableMapper.xml

@@ -93,6 +93,15 @@
                                      )
     </update>
 
+    <update id="createTableAjxx" parameterType="string">
+        CREATE TABLE `${tableName}` (
+                                        `CASE_TYPE` VARCHAR(50),
+                                        `CASE_NAME` VARCHAR(255),
+                                        `TRANSACT_CASE_CODE` VARCHAR(100),
+                                        INDEX INDEX_SFHM(`TRANSACT_CASE_CODE`)
+        )
+    </update>
+
     <update id="modifyTableName" parameterType="string">
         RENAME TABLE ${oldTable} TO ${newTable}
     </update>