root/ludu-cloud
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases 2 Wiki Activity

使用从库注解（读数据）

Browse Source
This commit is contained in:
XinWei 2024-07-24 11:10:06 +08:00
parent d87d9ba6b9
commit 7ac24d8509
5 changed files with 28 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ludu-module-datacenter/ludu-module-datacenter-biz/src/main/java/cn/iocoder/yudao/module/datacenter/service/asset/AssetServiceImpl.java
View File

@ -3,6 +3,7 @@ package cn.iocoder.yudao.module.datacenter.service.asset;
import cn.iocoder.yudao.module.datacenter.controller.admin.asset.vo.AssetRespVO;
import cn.iocoder.yudao.module.datacenter.dal.dataobject.asset.Asset;
import cn.iocoder.yudao.module.datacenter.dal.mongodb.asset.AssetRepository;
import com.baomidou.dynamic.datasource.annotation.Slave;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;

5
ludu-module-ticketing/ludu-module-ticketing-biz/src/main/java/cn/iocoder/yudao/module/ticket/service/asset/AssetServiceImpl.java
View File

@ -1,6 +1,7 @@
package cn.iocoder.yudao.module.ticket.service.asset;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import com.baomidou.dynamic.datasource.annotation.Slave;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import org.springframework.validation.annotation.Validated;
@ -63,16 +64,19 @@ public class AssetServiceImpl implements AssetService {
}
@Override
@Slave
public AssetDO getAsset(Long id) {
return assetMapper.selectById(id);
}
@Override
@Slave
public PageResult<AssetDO> getAssetPage(AssetPageReqVO pageReqVO) {
return assetMapper.selectPage(pageReqVO);
}
@Override
@Slave
public List<Map<String, String>> countAsset() {
List<AssetDO> assetList = assetMapper.selectList();
int[] assetTypeCounts = new int[3];
@ -107,6 +111,7 @@ public class AssetServiceImpl implements AssetService {
}
@Override
@Slave
public List<AssetDO> nameAsset(String assettypename) {
LambdaQueryWrapperX<AssetDO> wrapperX = new LambdaQueryWrapperX<>();
wrapperX.eq(AssetDO::getAssettypename, assettypename);

5
ludu-module-ticketing/ludu-module-ticketing-biz/src/main/java/cn/iocoder/yudao/module/ticket/service/checkticket/CheckTicketServiceImpl.java
View File

@ -6,6 +6,7 @@ import cn.iocoder.yudao.module.ticket.controller.admin.checkticket.vo.vo.CheckTi
import cn.iocoder.yudao.module.ticket.controller.admin.checkticket.vo.vo.CheckTicketSaveReqVO;
import cn.iocoder.yudao.module.ticket.dal.dataobject.checkticket.CheckTicket;
import cn.iocoder.yudao.module.ticket.dal.mongodb.checkticket.CheckTicketRepository;
import com.baomidou.dynamic.datasource.annotation.Slave;
import com.mongodb.MongoException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -77,16 +78,19 @@ public class CheckTicketServiceImpl implements CheckTicketService {
}
@Override
@Slave
public CheckTicketDO getCheckTicket(Long id) {
return checkTicketMapper.selectById(id);
}
@Override
@Slave
public PageResult<CheckTicketDO> getCheckTicketPage(CheckTicketPageReqVO pageReqVO) {
return checkTicketMapper.selectPage(pageReqVO);
}
@Override
@Slave
public List<Map<String, String>> findbytimetemp(String day) {
LocalDateTime startTime = LocalDateTime.now();
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("HH:mm:ss");
@ -110,6 +114,7 @@ public class CheckTicketServiceImpl implements CheckTicketService {
}
@Override
@Slave
public long checkTicketTotal(String day) {
LambdaQueryWrapperX<CheckTicketDO> wrapperX = new LambdaQueryWrapperX<>();
wrapperX.eq(CheckTicketDO::getCheckticketdate, day);

15
ludu-module-ticketing/ludu-module-ticketing-biz/src/main/java/cn/iocoder/yudao/module/ticket/service/saledata/SaleDataServiceImpl.java
View File

@ -5,6 +5,7 @@ import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.ticket.api.saledata.dto.SaleDataSaveReqDTO;
import cn.iocoder.yudao.module.ticket.dal.dataobject.saledata.SaleData;
import cn.iocoder.yudao.module.ticket.dal.mongodb.saledata.SaleDataRepository;
import com.baomidou.dynamic.datasource.annotation.Slave;
import com.mongodb.MongoException;
import kotlin.jvm.internal.Lambda;
import org.springframework.beans.factory.annotation.Autowired;
@ -76,16 +77,19 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public SaleDataDO getSaleData(Long id) {
return saleDataMapper.selectById(id);
}
@Override
@Slave
public PageResult<SaleDataDO> getSaleDataPage(SaleDataPageReqVO pageReqVO) {
return saleDataMapper.selectPage(pageReqVO);
}
@Override
@Slave
public long countBySddate(String day) {
LambdaQueryWrapperX<SaleDataDO> wrapperX = new LambdaQueryWrapperX<>();
wrapperX.eq(SaleDataDO::getSddate, day);
@ -93,6 +97,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public List<Map<String, String>> findCheckticketcountBytime(String startTime) {
SimpleDateFormat inputFormat = new SimpleDateFormat("yyyyMMdd");
SimpleDateFormat outputFormat = new SimpleDateFormat("yyyy-MM-dd");
@ -118,6 +123,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public List<Map<String, String>> findByGender() {
List<Map<String, String>> allByCertificateno = saleDataMapper.findByGender();
List<Map<String, String>> map = new ArrayList<>();
@ -138,6 +144,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public List<Map<String, String>> findByAge() {
List<Map<String, String>> ageRangeList = saleDataMapper.findByAge();
List<Map<String, String>> map = new ArrayList<>();
@ -179,6 +186,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public List<SaleDataDO> findEventsLastYear() {
DateTimeFormatter date = DateTimeFormatter.ofPattern("yyyyMMdd");
LocalDate lastYear = LocalDate.now().minusYears(1);
@ -192,6 +200,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public List<SaleDataDO> findEventsThisYear() {
DateTimeFormatter date = DateTimeFormatter.ofPattern("yyyyMMdd");
LocalDate thisYear = LocalDate.now().minusYears(0);
@ -205,6 +214,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public List<Map<String, String>> findByregion(List<SaleDataDO> list) {
// 初始化每个省市的计数器
Map<String, Integer> regionCounts = new LinkedHashMap<>();
@ -245,6 +255,7 @@ public class SaleDataServiceImpl implements SaleDataService {
@Override
@Slave
public List<Map<String, String>> findBySaleMethod() {
List<SaleDataDO> saleDataList = saleDataMapper.selectList(new LambdaQueryWrapperX<SaleDataDO>().select(SaleDataDO::getTransactiontypeno));
int[] saleMethodCounts = new int[5];
@ -287,6 +298,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public List<Map<String, String>> findWuyi(int x) {
DateTimeFormatter date = DateTimeFormatter.ofPattern("yyyyMMdd");
LocalDate xYear = LocalDate.now().minusYears(x);
@ -339,6 +351,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public List<Map<String, String>> findGuoqing(int x) {
DateTimeFormatter date = DateTimeFormatter.ofPattern("yyyyMMdd");
LocalDate xYear = LocalDate.now().minusYears(x);
@ -399,6 +412,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public String findrijun(String startTime) {
SimpleDateFormat inputFormat = new SimpleDateFormat("yyyyMMdd");
Calendar calendar = Calendar.getInstance();
@ -424,6 +438,7 @@ public class SaleDataServiceImpl implements SaleDataService {
}
@Override
@Slave
public BigDecimal findyearJun(List<SaleDataDO> list) {
BigDecimal total = new BigDecimal(0);
for (SaleDataDO saleData : list) {

4
ludu-module-ticketing/ludu-module-ticketing-biz/src/main/resources/application-local.yaml
View File

@ -59,9 +59,9 @@ spring:
# password: SYSDBA # DM 连接的示例
slave: # 模拟从库，可根据自己需要修改
lazy: true # 开启懒加载，保证启动速度
url: jdbc:mysql://127.0.0.1:3306/ruoyi-vue-pro?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true
url: jdbc:mysql://120.46.37.243:3306/ludu_ticketing?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true
username: root
password: 123456
password: xpower1234
# Redis 配置。Redisson 默认的配置足够使用，一般不需要进行调优
redis: