From a04129405c79496236fff3b1fd8de5b70c5b3fda Mon Sep 17 00:00:00 2001
From: ZY <zc857179121@qq.com>
Date: 星期一, 28 四月 2025 08:49:55 +0800
Subject: [PATCH] 双数据源
---
src/main/java/com/zy/nc/entity/NccSaleXsckmx.java | 134 +++++++++++++++++++++++++++++++++
/dev/null | 0
src/main/java/com/zy/common/config/ds/SecondaryDataSourceConfig.java | 4
src/main/java/com/zy/nc/task/PlanOrderTask.java | 25 ++++++
src/main/resources/mapper/nc/NccSaleXsckmxMapper.xml | 7 +
src/main/java/com/zy/Boot.java | 1
src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java | 25 ++++++
src/main/resources/application.yml | 5 +
src/main/java/com/zy/common/config/ds/PrimaryDataSourceConfig.java | 2
src/main/java/com/zy/nc/mapper/NccSaleXsckmxMapper.java | 12 +++
10 files changed, 211 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/zy/Boot.java b/src/main/java/com/zy/Boot.java
index c2e5b78..8d8702a 100644
--- a/src/main/java/com/zy/Boot.java
+++ b/src/main/java/com/zy/Boot.java
@@ -1,6 +1,7 @@
package com.zy;
import com.zy.common.utils.RandomValidateCodeUtil;
+import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
diff --git a/src/main/java/com/zy/common/config/ds/PrimaryDataSourceConfig.java b/src/main/java/com/zy/common/config/ds/PrimaryDataSourceConfig.java
index f6f5cb3..3471cac 100644
--- a/src/main/java/com/zy/common/config/ds/PrimaryDataSourceConfig.java
+++ b/src/main/java/com/zy/common/config/ds/PrimaryDataSourceConfig.java
@@ -13,7 +13,7 @@
import javax.sql.DataSource;
@Configuration
-@MapperScan(basePackages = {"com.zy.asrs.*.*", "com.zy.system.*.*"}, sqlSessionFactoryRef = "primarySqlSessionFactory")
+@MapperScan(basePackages = {"com.zy.asrs.mapper", "com.zy.system.mapper"}, sqlSessionFactoryRef = "primarySqlSessionFactory")
public class PrimaryDataSourceConfig {
@Bean(name = "primarySqlSessionFactory")
diff --git a/src/main/java/com/zy/common/config/ds/SecondaryDataSourceConfig.java b/src/main/java/com/zy/common/config/ds/SecondaryDataSourceConfig.java
index b03cd82..1327441 100644
--- a/src/main/java/com/zy/common/config/ds/SecondaryDataSourceConfig.java
+++ b/src/main/java/com/zy/common/config/ds/SecondaryDataSourceConfig.java
@@ -12,7 +12,7 @@
import javax.sql.DataSource;
@Configuration
-@MapperScan(basePackages = "com.zy.nc", sqlSessionFactoryRef = "secondarySqlSessionFactory")
+@MapperScan(basePackages = "com.zy.nc.mapper", sqlSessionFactoryRef = "secondarySqlSessionFactory")
public class SecondaryDataSourceConfig {
@Bean(name = "secondarySqlSessionFactory")
@@ -21,7 +21,7 @@
sessionFactory.setDataSource(dataSource);
// 璁剧疆MyBatis鐨凪apper XML鏂囦欢璺緞
sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
- .getResources("classpath:mapper2/*.xml"));
+ .getResources("classpath:mapper/**/*.xml"));
return sessionFactory.getObject();
}
diff --git a/src/main/java/com/zy/nc/entity/NccSaleXsckmx.java b/src/main/java/com/zy/nc/entity/NccSaleXsckmx.java
new file mode 100644
index 0000000..20d36cc
--- /dev/null
+++ b/src/main/java/com/zy/nc/entity/NccSaleXsckmx.java
@@ -0,0 +1,134 @@
+package com.zy.nc.entity;
+
+import com.baomidou.mybatisplus.annotations.TableId;
+import com.baomidou.mybatisplus.annotations.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+@Data
+@TableName("ncc_sale_xsckmx")
+public class NccSaleXsckmx implements Serializable {
+
+ @TableId
+ private String cgeneralbid;
+
+ private String cszzbm;
+
+ private String xxzzmc;
+
+ private String xsbmbm;
+
+ private String xsbmmc;
+
+ private String billcode;
+
+ private String hts;
+
+ private String billdate;
+
+ private BigDecimal hdr;
+
+ private String approdate;
+
+ private String saler;
+
+ private String djlx;
+
+ private String storname;
+
+ private String storcode;
+
+ private String sssyb;
+
+ private String custcode;
+
+ private String custname;
+
+ private String maker;
+
+ private String approver;
+
+ private String taudittime;
+
+ private String status;
+
+ private String crowno;
+
+ private BigDecimal bdr;
+
+ private String bts;
+
+ private String mlbm;
+
+ private String mlmc;
+
+ private String wlu8Name;
+
+ private String mlgg;
+
+ private String mlxh;
+
+ private String mlflbm;
+
+ private String mlflmc;
+
+ private String zsjflbm;
+
+ private String zsjflmc;
+
+ private String mlzdw;
+
+ private String mlfdw;
+
+ private BigDecimal sffsl;
+
+ private BigDecimal sfzsl;
+
+ private BigDecimal norigtaxnetprice;
+
+ private BigDecimal ntaxprice;
+
+ private BigDecimal norigprice;
+
+ private BigDecimal nprice;
+
+ private BigDecimal ntaxmny;
+
+ private BigDecimal nmny;
+
+ private BigDecimal ntax;
+
+ private String vbatchcode;
+
+ private String jt1;
+
+ private String jt2;
+
+ private String jt3;
+
+ private String gx;
+
+ private String clcj;
+
+ private String ytdjh;
+
+ private String lydjh;
+
+ private String xsqy;
+
+ private String xsflbm;
+
+ private String xsflmc;
+
+ private String ckbm;
+
+ private String ckmc;
+
+ private String sjflbm;
+
+ private String sjflmc;
+
+
+}
diff --git a/src/main/java/com/zy/nc/mapper/NccSaleXsckmxMapper.java b/src/main/java/com/zy/nc/mapper/NccSaleXsckmxMapper.java
new file mode 100644
index 0000000..6121ff9
--- /dev/null
+++ b/src/main/java/com/zy/nc/mapper/NccSaleXsckmxMapper.java
@@ -0,0 +1,12 @@
+package com.zy.nc.mapper;
+
+import com.baomidou.mybatisplus.mapper.BaseMapper;
+import com.zy.nc.entity.NccSaleXsckmx;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+
+@Mapper
+@Repository
+public interface NccSaleXsckmxMapper extends BaseMapper<NccSaleXsckmx> {
+
+}
diff --git a/src/main/java/com/zy/nc/task/PlanOrderTask.java b/src/main/java/com/zy/nc/task/PlanOrderTask.java
new file mode 100644
index 0000000..6ccbf79
--- /dev/null
+++ b/src/main/java/com/zy/nc/task/PlanOrderTask.java
@@ -0,0 +1,25 @@
+package com.zy.nc.task;
+
+import com.zy.asrs.task.core.ReturnT;
+import com.zy.nc.task.handler.PlanOrderHandler;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class PlanOrderTask {
+
+ @Autowired
+ private PlanOrderHandler planOrderHandler;
+
+ @Scheduled(cron = "0/3 * * * * ? ")
+ public void execute() {
+ ReturnT<String> returnT = planOrderHandler.start();
+ if (!returnT.isSuccess()) {
+ log.error(returnT.getMsg());
+ }
+ }
+
+}
diff --git a/src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java b/src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java
new file mode 100644
index 0000000..f7b25ce
--- /dev/null
+++ b/src/main/java/com/zy/nc/task/handler/PlanOrderHandler.java
@@ -0,0 +1,25 @@
+package com.zy.nc.task.handler;
+
+import com.alibaba.fastjson.JSONObject;
+import com.zy.asrs.task.AbstractHandler;
+import com.zy.asrs.task.core.ReturnT;
+import com.zy.nc.entity.NccSaleXsckmx;
+import com.zy.nc.mapper.NccSaleXsckmxMapper;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+@Slf4j
+public class PlanOrderHandler extends AbstractHandler<String> {
+
+ @Autowired
+ private NccSaleXsckmxMapper nccSaleXsckmxMapper;
+
+ public ReturnT<String> start() {
+ NccSaleXsckmx nccSaleXsckmx = nccSaleXsckmxMapper.selectById("1001A1100000000H9KKJ");
+ log.info("shuju:{}", JSONObject.toJSON(nccSaleXsckmx));
+ return SUCCESS;
+ }
+
+}
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 6ab51fd..93d46fb 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -34,7 +34,10 @@
driver-class-name: com.mysql.cj.jdbc.Driver
mybatis-plus:
- mapper-locations: classpath:mapper/*.xml
+ mapper-locations:
+ - classpath:mapper/*.xml
+ - classpath*:mapper2/*.xml
+ type-aliases-package: com.zy.**
logging:
path: /stock/out/@pom.build.finalName@/logs
diff --git a/src/main/resources/mapper/nc/NccSaleXsckmxMapper.xml b/src/main/resources/mapper/nc/NccSaleXsckmxMapper.xml
new file mode 100644
index 0000000..7998479
--- /dev/null
+++ b/src/main/resources/mapper/nc/NccSaleXsckmxMapper.xml
@@ -0,0 +1,7 @@
+<?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.zy.nc.mapper.NccSaleXsckmxMapper">
+
+
+
+</mapper>
diff --git a/src/main/resources/mapper2/test b/src/main/resources/mapper2/test
deleted file mode 100644
index e69de29..0000000
--- a/src/main/resources/mapper2/test
+++ /dev/null
--
Gitblit v1.9.1