提交 b5d56aff authored 作者: 孙于凯's avatar 孙于凯

多数据源完成

上级 7ff70a05
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**
!**/src/test/**
# Log file
*.log
.log
**/.log
*.gz
C:/*
# BlueJ files
*.ctxt
# Mobile Tools for Java (J2ME)
.mtj.tmp/
# Package Files #
*.jar
*.war
*.nar
*.ear
*.zip
*.tar.gz
*.rar
*/target
log
### STS ###
\~*.xlsx
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
### VS Code ###
.vscode/
/dev-union/src/main/resources/excelTemplate/~$finalCheck.xlsx
......@@ -7,16 +7,16 @@
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="demo2" />
<module name="transfer" />
</profile>
</annotationProcessing>
<bytecodeTargetLevel>
<module name="demo2" target="8" />
<module name="transfer" target="8" />
</bytecodeTargetLevel>
</component>
<component name="JavacSettings">
<option name="ADDITIONAL_OPTIONS_OVERRIDE">
<module name="demo2" options="-parameters" />
<module name="transfer" options="-parameters" />
</option>
</component>
</project>
\ No newline at end of file
<component name="libraryTable">
<library name="Maven: com.alibaba:druid:1.1.18">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/com/alibaba/druid/1.1.18/druid-1.1.18.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/com/alibaba/druid/1.1.18/druid-1.1.18-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/com/alibaba/druid/1.1.18/druid-1.1.18-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
<component name="libraryTable">
<library name="Maven: com.alibaba:druid-spring-boot-starter:1.1.18">
<CLASSES>
<root url="jar://$MAVEN_REPOSITORY$/com/alibaba/druid-spring-boot-starter/1.1.18/druid-spring-boot-starter-1.1.18.jar!/" />
</CLASSES>
<JAVADOC>
<root url="jar://$MAVEN_REPOSITORY$/com/alibaba/druid-spring-boot-starter/1.1.18/druid-spring-boot-starter-1.1.18-javadoc.jar!/" />
</JAVADOC>
<SOURCES>
<root url="jar://$MAVEN_REPOSITORY$/com/alibaba/druid-spring-boot-starter/1.1.18/druid-spring-boot-starter-1.1.18-sources.jar!/" />
</SOURCES>
</library>
</component>
\ No newline at end of file
......@@ -2,7 +2,7 @@
<project version="4">
<component name="ProjectModuleManager">
<modules>
<module fileurl="file://$PROJECT_DIR$/demo2.iml" filepath="$PROJECT_DIR$/demo2.iml" />
<module fileurl="file://$PROJECT_DIR$/transfer.iml" filepath="$PROJECT_DIR$/transfer.iml" />
</modules>
</component>
</project>
\ No newline at end of file
差异被折叠。
......@@ -44,6 +44,12 @@
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-typehandlers-jsr310</artifactId>
<version>1.0.2</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
......@@ -57,7 +63,7 @@
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.18</version>
<version>1.1.21</version>
</dependency>
<!--Mybatis分页插件-->
<dependency>
......
......@@ -17,9 +17,9 @@ public class SlaveActivitiesController {
@Autowired
private MasterActivitiesService hpActivitiesService;
@GetMapping("/transfer")
@GetMapping("/transActivities")
public String transferData(){
hpActivitiesService.transfer();
hpActivitiesService.transActivities();
return "完成";
}
......
package com.example.controller;
import com.example.service.MasterActivitiesService;
import com.example.service.MasterBranchesService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class SlaveBranchesController {
@Autowired
private MasterBranchesService masterBranchesService;
@GetMapping("/transBranches")
public String transferData(){
masterBranchesService.transBranches();
return "完成";
}
}
package com.example.controller;
import com.example.service.MasterBranchesService;
import com.example.service.MasterTextbooksService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class SlaveTextbooksController {
@Autowired
private MasterTextbooksService masterTextbooksService;
@GetMapping("/transTextbooks")
public String transferData(){
masterTextbooksService.transTextbooks();
return "完成";
}
}
package com.example.controller;
import com.example.service.MasterVolunteerApplysService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class SlaveVolunteerApplysController {
@Autowired
private MasterVolunteerApplysService masterVolunteerApplyesService;
@GetMapping("/transVolunteerApplyes")
public String transferData(){
masterVolunteerApplyesService.transVolunteerApplyes();
return "完成";
}
}
package com.example.mapper;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.pojo.MasterShareYlActivities;
import com.example.pojo.MasterShareYlBranches;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("master")
public interface MasterBranchesMapper extends BaseMapper<MasterShareYlBranches> {
}
package com.example.mapper;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.pojo.MasterShareYlBranches;
import com.example.pojo.MasterShareYlTextbooks;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("master")
public interface MasterTextbooksMapper extends BaseMapper<MasterShareYlTextbooks> {
}
package com.example.mapper;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.pojo.MasterShareYlVolunteerApplys;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("master")
public interface MasterVolunteerApplysMapper extends BaseMapper<MasterShareYlVolunteerApplys> {
}
package com.example.mapper;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.pojo.SlaveShareYlActivities;
import com.example.pojo.SlaveShareYlBranches;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("slave")
public interface SlaveBranchesMapper extends BaseMapper<SlaveShareYlBranches> {
}
package com.example.mapper;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.pojo.SlaveShareYlBranches;
import com.example.pojo.SlaveShareYlTextbooks;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("slave")
public interface SlaveTextbooksMapper extends BaseMapper<SlaveShareYlTextbooks> {
}
package com.example.mapper;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.pojo.SlaveShareYlVolunteerApplys;
import org.apache.ibatis.annotations.Mapper;
@Mapper
@DS("slave")
public interface SlaveVolunteerApplysMapper extends BaseMapper<SlaveShareYlVolunteerApplys> {
}
package com.example.pojo;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable;
import java.time.LocalDate;
import java.time.LocalDateTime;
/**
* @author syk
......@@ -29,11 +32,11 @@ public class MasterShareYlActivities implements Serializable {
private String organizer;
private String contractor;
private String sponsor;
private LocalDate releaseTime;
private LocalDate recruitTime;
private LocalDateTime releaseTime;
private LocalDateTime recruitTime;
private Integer recruitNumber;
private LocalDate activityTime;
private LocalDate activityTimeEnd;
private LocalDateTime activityTime;
private LocalDateTime activityTimeEnd;
private String introduction;
private String claim;
private String adscriptionOrg;
......@@ -47,11 +50,11 @@ public class MasterShareYlActivities implements Serializable {
private String latitude;
private String longitude;
private Integer peopleNumber;
private LocalDate createdAt;
private LocalDate updatedAt;
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private Integer adminId;
private String dataActiveStatus;
private String dataException;
private String dataState;
private LocalDate dataUpdateTime;
private LocalDateTime dataUpdateTime;
}
package com.example.pojo;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.LocalDateTime;
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("share_yl_branches")
public class MasterShareYlBranches {
private Long id;
private Integer uid;
private String name;
private String address;
private String contactPerson;
private String contactPhone;
private Integer unitType;
private String unitName;
private String capacity;
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private String cover;
private String latitude;
private String longitude;
private String street;
private String area;
private String leaderName;
private String leaderPhone;
private LocalDateTime foundDate;
private String fullAddress;
private String dataActiveStatus;
private String dataException;
private String dataState;
private LocalDateTime dataUpdateTime;
}
package com.example.pojo;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.LocalDateTime;
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("share_yl_textbooks")
public class MasterShareYlTextbooks {
private Long id;
private String name;
private String unit;
private Integer type;
private String file;
private String remarks;
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private String cover;
private Integer status;
private String area;
private Integer adminId;
private String dataActiveStatus;
private String dataException;
private String dataState;
private LocalDateTime dataUpdateTime;
}
package com.example.pojo;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.LocalDateTime;
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("share_yl_volunteer_applys")
public class MasterShareYlVolunteerApplys {
private Long id;
private Integer userId;
private String phone;
private String name;
private String idCard;
private String area;
private String gender;
private Integer face;
private String nation;
private String edu;
private String jobTitle;
private Integer workType;
private String work;
private String serviceType;
private String serviceDomain;
private String isExp;
private String exp;
private Integer status;
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private Integer branchId;
private String dataActiveStatus;
private String dataException;
private String dataState;
private LocalDateTime dataUpdateTime;
}
package com.example.pojo;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
@Data
@AllArgsConstructor
@NoArgsConstructor
......@@ -24,11 +28,11 @@ public class SlaveShareYlActivities {
private String organizer;
private String contractor;
private String sponsor;
private LocalDate releaseTime;
private LocalDate recruitTime;
private LocalDateTime releaseTime;
private LocalDateTime recruitTime;
private Integer recruitNumber;
private LocalDate activityTime;
private LocalDate activityTimeEnd;
private LocalDateTime activityTime;
private LocalDateTime activityTimeEnd;
private String introduction;
private String claim;
private String adscriptionOrg;
......@@ -42,11 +46,11 @@ public class SlaveShareYlActivities {
private String latitude;
private String longitude;
private Integer peopleNumber;
private LocalDate createdAt;
private LocalDate updatedAt;
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private Integer adminId;
private String dataActiveStatus;
private String dataException;
private String dataState;
private LocalDate dataUpdateTime;
private LocalDateTime dataUpdateTime;
}
package com.example.pojo;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.LocalDateTime;
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("share_yl_branches")
public class SlaveShareYlBranches {
private Long id;
private Integer uid;
private String name;
private String address;
private String contactPerson;
private String contactPhone;
private Integer unitType;
private String unitName;
private String capacity;
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private String cover;
private String latitude;
private String longitude;
private String street;
private String area;
private String leaderName;
private String leaderPhone;
private LocalDateTime foundDate;
private String fullAddress;
private String dataActiveStatus;
private String dataException;
private String dataState;
private LocalDateTime dataUpdateTime;
}
package com.example.pojo;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.LocalDateTime;
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("share_yl_textbooks")
public class SlaveShareYlTextbooks {
private Long id;
private String name;
private String unit;
private Integer type;
private String file;
private String remarks;
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private String cover;
private Integer status;
private String area;
private Integer adminId;
private String dataActiveStatus;
private String dataException;
private String dataState;
private LocalDateTime dataUpdateTime;
}
package com.example.pojo;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.LocalDateTime;
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("share_yl_volunteer_applys")
public class SlaveShareYlVolunteerApplys {
private Long id;
private Integer userId;
private String phone;
private String name;
private String idCard;
private String area;
private String gender;
private Integer face;
private String nation;
private String edu;
private String jobTitle;
private Integer workType;
private String work;
private String serviceType;
private String serviceDomain;
private String isExp;
private String exp;
private Integer status;
private LocalDateTime createdAt;
private LocalDateTime updatedAt;
private Integer branchId;
private String dataActiveStatus;
private String dataException;
private String dataState;
private LocalDateTime dataUpdateTime;
}
......@@ -10,6 +10,6 @@ import java.util.List;
*/
public interface MasterActivitiesService extends IService<MasterShareYlActivities> {
void transfer();
void transActivities();
List<MasterShareYlActivities> transfer2();
}
package com.example.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.mapper.MasterBranchesMapper;
import com.example.pojo.MasterShareYlActivities;
import com.example.pojo.MasterShareYlBranches;
import java.util.List;
public interface MasterBranchesService extends IService<MasterShareYlBranches> {
void transBranches();
List<MasterShareYlBranches> transfer2();
}
package com.example.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.pojo.MasterShareYlBranches;
import com.example.pojo.MasterShareYlTextbooks;
import java.util.List;
public interface MasterTextbooksService extends IService<MasterShareYlTextbooks> {
void transTextbooks();
List<MasterShareYlTextbooks> transfer2();
}
package com.example.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.pojo.MasterShareYlVolunteerApplys;
import java.util.List;
public interface MasterVolunteerApplysService extends IService<MasterShareYlVolunteerApplys> {
void transVolunteerApplyes();
List<MasterShareYlVolunteerApplys> transfer2();
}
......@@ -30,7 +30,7 @@ public class MasterActivitiesServiceImpl extends ServiceImpl<MasterActivitiesMap
@Override
@DS("slave_1")
public void transfer() {
public void transActivities() {
List<MasterShareYlActivities> dataList = transfer2();
for (MasterShareYlActivities data : dataList) {
SlaveShareYlActivities mybatisData = new SlaveShareYlActivities();
......@@ -79,8 +79,10 @@ public class MasterActivitiesServiceImpl extends ServiceImpl<MasterActivitiesMap
@Override
public List<MasterShareYlActivities> transfer2() {
QueryWrapper<MasterShareYlActivities> queryWrapper = new QueryWrapper<>();
LocalDateTime startTime = LocalDateTime.now().minusMinutes(1);
queryWrapper.ge("updated_at", startTime.toInstant(ZoneOffset.of("+8")).toEpochMilli());
LocalDateTime now = LocalDateTime.now();
LocalDateTime startTime = now.minusDays(210);
queryWrapper.ge("updated_at",startTime);
queryWrapper.le("updated_at",now);
return hpActivitiesMapper.selectList(queryWrapper);
}
......
package com.example.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.mapper.MasterActivitiesMapper;
import com.example.mapper.MasterBranchesMapper;
import com.example.mapper.SlaveActivitiesMapper;
import com.example.mapper.SlaveBranchesMapper;
import com.example.pojo.MasterShareYlActivities;
import com.example.pojo.MasterShareYlBranches;
import com.example.pojo.SlaveShareYlActivities;
import com.example.pojo.SlaveShareYlBranches;
import com.example.service.MasterActivitiesService;
import com.example.service.MasterBranchesService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
import java.util.List;
@Service
@DS("master")
public class MasterBranchesServiceImpl extends ServiceImpl<MasterBranchesMapper, MasterShareYlBranches> implements MasterBranchesService {
@Autowired
private MasterBranchesMapper masterBranchesMapper;
@Autowired
private SlaveBranchesMapper slaveBranchesMapper;
@Override
@DS("slave_1")
public void transBranches() {
List<MasterShareYlBranches> dataList = transfer2();
for (MasterShareYlBranches data : dataList) {
SlaveShareYlBranches mybatisData = new SlaveShareYlBranches();
mybatisData.setId(data.getId());
mybatisData.setUid(data.getUid());
mybatisData.setName(data.getName());
mybatisData.setUnitType(data.getUnitType());
mybatisData.setUnitName(data.getUnitName());
mybatisData.setCapacity(data.getCapacity());
mybatisData.setLatitude(data.getLatitude());
mybatisData.setStreet(data.getStreet());
mybatisData.setCover(data.getCover());
mybatisData.setArea(data.getArea());
mybatisData.setLeaderName(data.getLeaderName());
mybatisData.setLeaderPhone(data.getLeaderPhone());
mybatisData.setFullAddress(data.getFullAddress());
mybatisData.setAddress(data.getAddress());
mybatisData.setContactPerson(data.getContactPerson());
mybatisData.setContactPhone(data.getContactPhone());
mybatisData.setLatitude(data.getLatitude());
mybatisData.setLongitude(data.getLongitude());
mybatisData.setCreatedAt(data.getCreatedAt());
mybatisData.setUpdatedAt(data.getUpdatedAt());
mybatisData.setDataActiveStatus(data.getDataActiveStatus());
mybatisData.setDataException(data.getDataException());
mybatisData.setDataState(data.getDataState());
mybatisData.setDataUpdateTime(data.getDataUpdateTime());
slaveBranchesMapper.insert(mybatisData);
}
}
@Override
public List<MasterShareYlBranches> transfer2() {
QueryWrapper<MasterShareYlBranches> queryWrapper = new QueryWrapper<>();
LocalDateTime now = LocalDateTime.now();
LocalDateTime startTime = now.minusDays(250);
queryWrapper.ge("updated_at",startTime);
queryWrapper.le("updated_at",now);
return masterBranchesMapper.selectList(queryWrapper);
}
}
package com.example.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.mapper.MasterTextbooksMapper;
import com.example.mapper.SlaveTextbooksMapper;
import com.example.pojo.MasterShareYlBranches;
import com.example.pojo.MasterShareYlTextbooks;
import com.example.pojo.SlaveShareYlBranches;
import com.example.pojo.SlaveShareYlTextbooks;
import com.example.service.MasterTextbooksService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
import java.util.List;
@Service
@DS("master")
public class MasterTextbooksServiceImpl extends ServiceImpl<MasterTextbooksMapper, MasterShareYlTextbooks> implements MasterTextbooksService {
@Autowired
private MasterTextbooksMapper masterTextbooksMapper;
@Autowired
private SlaveTextbooksMapper slaveTextbooksMapper;
@Override
@DS("slave_1")
public void transTextbooks() {
List<MasterShareYlTextbooks> dataList = transfer2();
for (MasterShareYlTextbooks data : dataList) {
SlaveShareYlTextbooks mybatisData = new SlaveShareYlTextbooks();
mybatisData.setId(data.getId());
mybatisData.setName(data.getName());
mybatisData.setUnit(data.getUnit());
mybatisData.setType(data.getType());
mybatisData.setRemarks(data.getRemarks());
mybatisData.setCreatedAt(data.getCreatedAt());
mybatisData.setUpdatedAt(data.getUpdatedAt());
mybatisData.setCover(data.getCover());
mybatisData.setStatus(data.getStatus());
mybatisData.setArea(data.getArea());
mybatisData.setFile(data.getFile());
mybatisData.setAdminId(data.getAdminId());
mybatisData.setDataActiveStatus(data.getDataActiveStatus());
mybatisData.setDataException(data.getDataException());
mybatisData.setDataState(data.getDataState());
mybatisData.setDataUpdateTime(data.getDataUpdateTime());
slaveTextbooksMapper.insert(mybatisData);
}
}
@Override
public List<MasterShareYlTextbooks> transfer2() {
QueryWrapper<MasterShareYlTextbooks> queryWrapper = new QueryWrapper<>();
LocalDateTime now = LocalDateTime.now();
LocalDateTime startTime = now.minusDays(280);
queryWrapper.ge("updated_at",startTime);
queryWrapper.le("updated_at",now);
return masterTextbooksMapper.selectList(queryWrapper);
}
}
package com.example.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.mapper.MasterVolunteerApplysMapper;
import com.example.mapper.SlaveVolunteerApplysMapper;
import com.example.pojo.MasterShareYlVolunteerApplys;
import com.example.pojo.SlaveShareYlVolunteerApplys;
import com.example.service.MasterVolunteerApplysService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
import java.util.List;
@Service
@DS("master")
public class MasterVolunteerApplysServiceImpl extends ServiceImpl<MasterVolunteerApplysMapper, MasterShareYlVolunteerApplys> implements MasterVolunteerApplysService {
@Autowired
private MasterVolunteerApplysMapper masterVolunteerApplyesMapper;
@Autowired
private SlaveVolunteerApplysMapper slaveVolunteerApplyesMapper;
@Override
@DS("slave_1")
public void transVolunteerApplyes() {
List<MasterShareYlVolunteerApplys> dataList = transfer2();
for (MasterShareYlVolunteerApplys data : dataList) {
SlaveShareYlVolunteerApplys mybatisData = new SlaveShareYlVolunteerApplys();
mybatisData.setId(data.getId());
mybatisData.setName(data.getName());
mybatisData.setUserId(data.getUserId());
mybatisData.setPhone(data.getPhone());
mybatisData.setIdCard(data.getIdCard());
mybatisData.setArea(data.getArea());
mybatisData.setGender(data.getGender());
mybatisData.setFace(data.getFace());
mybatisData.setNation(data.getNation());
mybatisData.setEdu(data.getEdu());
mybatisData.setJobTitle(data.getJobTitle());
mybatisData.setWorkType(data.getWorkType());
mybatisData.setWork(data.getWork());
mybatisData.setServiceType(data.getServiceType());
mybatisData.setServiceDomain(data.getServiceDomain());
mybatisData.setIsExp(data.getIsExp());
mybatisData.setExp(data.getExp());
mybatisData.setStatus(data.getStatus());
mybatisData.setUpdatedAt(data.getUpdatedAt());
mybatisData.setCreatedAt(data.getCreatedAt());
mybatisData.setBranchId(data.getBranchId());
mybatisData.setDataActiveStatus(data.getDataActiveStatus());
mybatisData.setDataException(data.getDataException());
mybatisData.setDataState(data.getDataState());
mybatisData.setDataUpdateTime(data.getDataUpdateTime());
slaveVolunteerApplyesMapper.insert(mybatisData);
}
}
@Override
public List<MasterShareYlVolunteerApplys> transfer2() {
QueryWrapper<MasterShareYlVolunteerApplys> queryWrapper = new QueryWrapper<>();
LocalDateTime now = LocalDateTime.now();
LocalDateTime startTime = now.minusDays(250);
queryWrapper.ge("updated_at",startTime);
queryWrapper.le("updated_at",now);
return masterVolunteerApplyesMapper.selectList(queryWrapper);
}
}
package com.example.task;
import com.example.service.MasterActivitiesService;
import com.example.service.MasterBranchesService;
import com.example.service.MasterTextbooksService;
import com.example.service.MasterVolunteerApplysService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Component
@Slf4j
public class task {
@Autowired
private MasterActivitiesService hpActivitiesService;
@Autowired
private MasterBranchesService masterBranchesService;
@Autowired
private MasterTextbooksService masterTextbooksService;
@Autowired
private MasterVolunteerApplysService masterVolunteerApplyesService;
@Scheduled(cron = "0 * * * * ?")
public void transferData() {
hpActivitiesService.transfer();
hpActivitiesService.transActivities();
log.info("share_yl_activities转移完成");
masterBranchesService.transBranches();
log.info("share_yl_branches转移完成");
masterTextbooksService.transTextbooks();
log.info("share_yl_textbooks转移完成");
masterVolunteerApplyesService.transVolunteerApplyes();
log.info("share_yl_textbooks转移完成");
}
......
......@@ -2,7 +2,7 @@
#spring.datasource.url=jdbc:mysql://192.168.0.232:3307/hp_kjgzzqz?useSSL=false&serverTimezone=UTC&characterEncoding=utf-8
#spring.datasource.username=root
#spring.datasource.password=tykj@2022
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.dynamic.primary=master
spring.datasource.dynamic.strict=false
......@@ -18,7 +18,7 @@ spring.datasource.dynamic.datasource.slave_1.password=root
spring.datasource.dynamic.datasource.slave_1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.autoconfigure.exclude=com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure
## ShardingSphere数据源配置
#sharding.shardingsphere.datasource.names=ds0,ds1
#sharding.shardingsphere.datasource.ds0.type=com.alibaba.druid.pool.DruidDataSource
......
......@@ -17,6 +17,8 @@ spring.datasource.dynamic.datasource.slave_1.username=root
spring.datasource.dynamic.datasource.slave_1.password=root
spring.datasource.dynamic.datasource.slave_1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.autoconfigure.exclude=com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure
## ShardingSphere数据源配置
#sharding.shardingsphere.datasource.names=ds0,ds1
#sharding.shardingsphere.datasource.ds0.type=com.alibaba.druid.pool.DruidDataSource
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论