Skip to content

D
dev_move
提交 c542f9d7 authored 作者: zjm's avatar zjm
浏览文件
操作

[添加了所有实体以及dao]

上级 13b89d8f
显示空白字符变更
内嵌 并排
正在显示 包含 732 行增加 和 4 行删除
src/main/java/com/example/removetolocal/newtrain/dao/TrainThemeDao.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.newtrain.dao;
import com.example.removetolocal.newtrain.entity.TrainTheme;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import java.util.List;
/**
* @author zjm
* @version 1.0.0
* @ClassName TrainDao.java
* @Description TODO
* @createTime 2020年08月13日 15:19:00
*/
public interface TrainThemeDao extends JpaRepository<TrainTheme, Integer>, JpaSpecificationExecutor<TrainTheme> {
List<TrainTheme> findAllByTrainStatus(Integer status);
}
src/main/java/com/example/removetolocal/newtrain/dao/TrainUserDao.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.newtrain.dao;
import com.example.removetolocal.newtrain.entity.TrainUser;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import java.util.List;
/**
* @author zjm
* @version 1.0.0
* @ClassName TrainUserDao.java
* @Description TODO
* @createTime 2020年12月01日 13:55:00
*/
public interface TrainUserDao extends JpaRepository<TrainUser, Integer>, JpaSpecificationExecutor<TrainUser> {
TrainUser findByUserIdAndTrainId(Integer userId,Integer trainId);
List<TrainUser> findAllByIsSignUpAndTrainId(Integer IsSignUp,Integer trainId);
List<TrainUser> findAllByTrainId(Integer trainId);
List<TrainUser> findAllByUnitsIdAndTrainId(Integer unitId,Integer userId);
}
src/main/java/com/example/removetolocal/newtrain/dao/WorkHandoverDao.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.newtrain.dao;
import com.example.removetolocal.newentity.WorkHandover;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
/**
* @author zjm
* @version 1.0.0
* @ClassName WorkHandoverDao.java
* @Description 工作交接dao层
* @createTime 2020年09月17日 16:14:00
*/
public interface WorkHandoverDao extends JpaRepository<WorkHandover, Integer>, JpaSpecificationExecutor<WorkHandover> {
}
src/main/java/com/example/removetolocal/newtrain/entity/TrainTheme.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.newtrain.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import javax.persistence.*;
import java.util.Date;
/**
* entity class for train_theme
*/
@Data
@Entity
@AllArgsConstructor
@NoArgsConstructor
@Table(name = "train_theme")
public class TrainTheme {
/**
* trainId
*/
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "train_id")
private Integer trainId;
/**
* endTime
*/
@Column(name = "end_time")
private Date endTime;
/**
* good
*/
@Column(name = "good")
private Integer good;
/**
* isCertificate
*/
@Column(name = "is_certificate")
private Integer isCertificate;
/**
* joinUserId
*/
@Column(name = "join_user_id")
private String joinUserId;
/**
* name
*/
@Column(name = "name")
private String name;
/**
* noJoinUserId
*/
@Column(name = "no_join_user_id")
private String noJoinUserId;
/**
* originatorId
*/
@Column(name = "originator_id")
private Integer originatorId;
/**
* originatorName
*/
@Column(name = "originator_name")
private String originatorName;
/**
* pass
*/
@Column(name = "pass")
private Integer pass;
/**
* signUp
*/
@Column(name = "sign_up")
private String signUp;
/**
* speakerUserId
*/
@Column(name = "speaker_user_id")
private String speakerUserId;
/**
* startTime
*/
@Column(name = "start_time")
private Date startTime;
/**
* trainDataName
*/
@Column(name = "train_data_name")
private String trainDataName;
/**
* trainDataUrl
*/
@Column(name = "train_data_url")
private String trainDataUrl;
/**
* trainLocation
*/
@Column(name = "train_location")
private String trainLocation;
/**
* trainStatus
*/
@Column(name = "train_status")
private Integer trainStatus;
/**
* trainSynopsis
*/
@Column(name = "train_synopsis")
private String trainSynopsis;
/**
* trainTime
*/
@Column(name = "train_time")
private Date trainTime;
/**
* trainingResults
*/
@Column(name = "training_results")
private String trainingResults;
/**
* unitsId
*/
@Column(name = "units_id")
private Integer unitsId;
/**
* unitsName
*/
@Column(name = "units_name")
private String unitsName;
/**
* trainPapersName
*/
@Column(name = "train_papers_name")
private String trainPapersName;
/**
* trainPapersUrl
*/
@Column(name = "train_papers_url")
private String trainPapersUrl;
/**
* recordId
*/
@Column(name = "record_id")
private String recordId;
public TrainTheme( String name, Date trainTime, String originatorName, Integer originatorId, String unitsName, Integer unitsId, Date startTime, Date endTime, String trainLocation, String speakerUserId, String trainDataName, String trainDataUrl, String trainSynopsis, String trainingResults, Integer trainStatus, Integer isCertificate, Integer pass, Integer good, String trainPapersUrl, String trainPapersName, String recordId) {
this.name = name;
this.trainTime = trainTime;
this.originatorName = originatorName;
this.originatorId = originatorId;
this.unitsName = unitsName;
this.unitsId = unitsId;
this.startTime = startTime;
this.endTime = endTime;
this.trainLocation = trainLocation;
this.speakerUserId = speakerUserId;
this.trainDataName = trainDataName;
this.trainDataUrl = trainDataUrl;
this.trainSynopsis = trainSynopsis;
this.trainingResults = trainingResults;
this.trainStatus = trainStatus;
this.isCertificate = isCertificate;
this.pass = pass;
this.good = good;
this.trainPapersUrl = trainPapersUrl;
this.trainPapersName = trainPapersName;
this.recordId = recordId;
}
}
src/main/java/com/example/removetolocal/newtrain/entity/TrainUser.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.newtrain.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import javax.persistence.*;
/**
* entity class for train_user
*/
@Data
@Entity
@AllArgsConstructor
@NoArgsConstructor
@Table(name = "train_user")
public class TrainUser {
/**
* id
*/
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
private Integer id;
/**
* attendance
*/
@Column(name = "attendance")
private String attendance;
/**
* certificate
*/
@Column(name = "certificate")
private Integer certificate;
/**
* evaluation
*/
@Column(name = "evaluation")
private String evaluation;
/**
* idCard
*/
@Column(name = "id_card")
private String idCard;
/**
* isNotJoinUserId
*/
@Column(name = "is_not_join_user_id")
private Integer isNotJoinUserId;
/**
* isSignUp
*/
@Column(name = "is_sign_up")
private Integer isSignUp;
/**
* mobile
*/
@Column(name = "mobile")
private String mobile;
/**
* name
*/
@Column(name = "name")
private String name;
/**
* note
*/
@Column(name = "note")
private String note;
/**
* position
*/
@Column(name = "position")
private Integer position;
/**
* recordId
*/
@Column(name = "record_id")
private String recordId;
/**
* score
*/
@Column(name = "score")
private String score;
/**
* sex
*/
@Column(name = "sex")
private Integer sex;
/**
* trainId
*/
@Column(name = "train_id")
private Integer trainId;
/**
* unitsId
*/
@Column(name = "units_id")
private Integer unitsId;
/**
* unitsName
*/
@Column(name = "units_name")
private String unitsName;
/**
* userId
*/
@Column(name = "user_id")
private Integer userId;
}
src/main/java/com/example/removetolocal/newtrain/entity/WorkHandover.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.newtrain.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.CreatedDate;
import org.springframework.data.annotation.LastModifiedDate;
import javax.persistence.*;
/**
* entity class for work_handover
*/
@Data
@Entity
@AllArgsConstructor
@NoArgsConstructor
@Table(name = "work_handover")
public class WorkHandover {
/**
* workHandoverId
*/
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "work_handover_id")
private Integer workHandoverId;
/**
* commissionWord
*/
@Column(name = "commission_word")
private String commissionWord;
/**
* fileLists
*/
@Column(name = "file_lists")
private String fileLists;
/**
* handoverUserId
*/
@Column(name = "handover_user_id")
private Integer handoverUserId;
/**
* inUserName
*/
@Column(name = "in_user_name")
private String inUserName;
/**
* trackingWord
*/
@Column(name = "tracking_word")
private String trackingWord;
/**
* turnOverUserId
*/
@Column(name = "turn_over_user_id")
private Integer turnOverUserId;
/**
* createTime
*/
@Column(name = "create_time")
@CreatedDate
private Integer createTime;
/**
* status
*/
@Column(name = "status")
private Integer status;
/**
* updateTime
*/
@Column(name = "update_time")
@LastModifiedDate
private Integer updateTime;
/**
* recordId
*/
@Column(name = "record_id")
private String recordId;
}
src/main/java/com/example/removetolocal/oldtrain/DevTrain.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.oldtrain;
import com.example.removetolocal.newtrain.entity.TrainTheme;
import lombok.Data;
import javax.persistence.*;
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
import java.util.Date;
import org.springframework.data.annotation.CreatedBy;
import org.springframework.data.annotation.CreatedDate;
import org.springframework.data.annotation.LastModifiedBy;
import org.springframework.data.annotation.LastModifiedDate;
/**
* entity class for dev_train
* 专管员培训
*/
@Data
@Entity
@Table(name = "dev_train")
public class DevTrain {
/**
* 主键
*/
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
private Integer id;
/**
* 培训主题
*/
@Column(name = "theme")
private String theme;
/**
* 地点
*/
@Column(name = "address")
private String address;
/**
* 主办方
*/
@Column(name = "host")
private String host;
/**
* 培训开始时间
*/
@Column(name = "start_time")
private java.util.Date startTime;
/**
* 培训结束时间
*/
@Column(name = "end_time")
private java.util.Date endTime;
/**
* 培训内容
*/
@Column(name = "content")
private String content;
/**
* 通知单位
*/
@Column(name = "notice_org")
private String noticeOrg;
/**
* 培训状态：1.报名中 2.截止报名 3.结束 4.撤销
*/
@Column(name = "status")
private Boolean status;
/**
* 创建用户
*/
@Column(name = "createuser")
private String createuser;
/**
* 创建单位
*/
@Column(name = "create_org")
private String createOrg;
/**
* 创建时间
*/
@Column(name = "createtime")
private java.util.Date createtime;
/**
* 更新用户
*/
@Column(name = "updateuser")
private String updateuser;
/**
* 更新时间
*/
@Column(name = "updatetime")
private java.util.Date updatetime;
/**
* 合格分数
*/
@Column(name = "passScore")
private Double passScore;
/**
* 考试附件
*/
@Column(name = "examFile")
private String examFile;
public TrainTheme toTrainTheme(){
return new TrainTheme(
theme,
startTime,
null,
null,
null,
null,
startTime,
endTime,
address,
host,
null,
null,
null,
null,
null,
null,
Integer.valueOf(String.valueOf(passScore)),
null,
null,
null,
null
);
}
}
src/main/java/com/example/removetolocal/oldtrain/DevTrainEnroll.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.oldtrain;
import lombok.Data;
import javax.persistence.*;
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
import org.hibernate.annotations.SQLDelete;
import org.hibernate.annotations.Where;
import java.util.Date;
import org.springframework.data.annotation.CreatedBy;
import org.springframework.data.annotation.CreatedDate;
import org.springframework.data.annotation.LastModifiedBy;
import org.springframework.data.annotation.LastModifiedDate;
/**
* entity class for dev_train_enroll
* 培训报名
*/
@Data
@Entity
@Table(name = "dev_train_enroll")
public class DevTrainEnroll {
/**
* 主键
*/
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
@Column(name = "id")
private Integer id;
/**
* 培训id
*/
@Column(name = "train_id")
private Integer trainId;
/**
* 培训主办方
*/
@Column(name = "host")
private String host;
/**
* 培训主题
*/
@Column(name = "theme")
private String theme;
/**
* 专管员id
*/
@Column(name = "vmanager_id")
private String vmanagerId;
/**
* 专管员姓名
*/
@Column(name = "vmanager_name")
private String vmanagerName;
/**
* 所在组织
*/
@Column(name = "ownsup")
private String ownsup;
/**
* 所属组织名称
*/
@Column(name = "ownsup_name")
private String ownsupName;
/**
* 状态:1.任务未读 2.已报名 3.忽略报名 4.参加考试 5.缺席考试
*/
@Column(name = "status")
private Boolean status;
/**
* 报名时间
*/
@Column(name = "enroll_time")
private java.util.Date enrollTime;
/**
* 得分
*/
@Column(name = "score")
private Double score;
}
src/main/java/com/example/removetolocal/oldtrain/dao/DevTrainDao.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.oldtrain.dao;
import com.example.removetolocal.oldtrain.DevTrain;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
/**
* @author dengdiyi
*/
public interface DevTrainDao extends JpaRepository<DevTrain, Integer>, JpaSpecificationExecutor<DevTrain> {
}
src/main/java/com/example/removetolocal/oldtrain/dao/DevTrainEnrollDao.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.oldtrain.dao;
import com.example.removetolocal.oldtrain.DevTrainEnroll;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
/**
* @author dengdiyi
*/
public interface DevTrainEnrollDao extends JpaRepository<DevTrainEnroll, Integer>, JpaSpecificationExecutor<DevTrainEnroll> {
}
src/main/java/com/example/removetolocal/service/TrainService.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.service;/**
* @Author zjm
* @Description 培训业务迁移service
* @Date 2020/12/25 下午3:37
* @Version 1.0
*/
public interface TrainService {
void trainDcToNew();
}
src/main/java/com/example/removetolocal/service/UserService.java
浏览文件 @ c542f9d7
package com.example.removetolocal.service;
import com.example.removetolocal.newuser.domin.Units;
import com.example.removetolocal.newuser.domin.User;
public interface UserService {
......@@ -14,4 +15,6 @@ public interface UserService {
String getUserNameByOldId(String oldId);
String getUnitNameByOldId(String oldId);
Units getUnitByOldId(String oldId);
}
src/main/java/com/example/removetolocal/service/impl/TrainServiceImpl.java 0 → 100644
浏览文件 @ c542f9d7
package com.example.removetolocal.service.impl;
import com.example.removetolocal.newtrain.dao.TrainThemeDao;
import com.example.removetolocal.newtrain.dao.TrainUserDao;
import com.example.removetolocal.newtrain.entity.TrainTheme;
import com.example.removetolocal.newuser.domin.Units;
import com.example.removetolocal.newuser.domin.User;
import com.example.removetolocal.oldtrain.dao.DevTrainDao;
import com.example.removetolocal.oldtrain.dao.DevTrainEnrollDao;
import com.example.removetolocal.service.TrainService;
import com.example.removetolocal.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
/**
* @Author zjm
* @Description TODO
* @Date 2020/12/25 下午3:39
* @Version 1.0
*/
public class TrainServiceImpl implements TrainService {
@Autowired
TrainThemeDao trainThemeDao;
@Autowired
TrainUserDao trainUserDao;
@Autowired
DevTrainDao devTrainDao;
@Autowired
DevTrainEnrollDao devTrainEnrollDao;
@Autowired
UserService userService;
@Override
public void trainDcToNew() {
devTrainDao.findAll().forEach(
devTrain -> {
TrainTheme trainTheme=devTrain.toTrainTheme();
User user= userService.getUserByOldId(devTrain.getCreateuser());
trainTheme.setOriginatorId(user.getUserId());
trainTheme.setOriginatorName(user.getName());
Units units= userService.getUnitByOldId(devTrain.getHost());
trainTheme.setUnitsId(units.getUnitId());
trainTheme.setUnitsName(units.getName());
TrainTheme trainTheme1= trainThemeDao.save(trainTheme);
}
);
}
}
src/main/java/com/example/removetolocal/service/impl/UserServiceImpl.java
浏览文件 @ c542f9d7
......@@ -83,6 +83,11 @@ public class UserServiceImpl implements UserService {
}
}
@Override
public Units getUnitByOldId(String oldId) {
return unitsDao.findByOldId(oldId);
}
/**
* @param oldFatherId 旧表父类Id
* @param newFatherId 新表父类id
......
src/main/java/com/example/removetolocal/task/changeRun.java
浏览文件 @ c542f9d7
......@@ -29,10 +29,10 @@ public class changeRun implements CommandLineRunner {
*/
@Override
public void run(String... args) throws Exception {
// userService.changeEntity();
// log.info("用户模块数据迁移完成");
// deviceService.deviceChange();
// log.info("zb模块数据迁移完成");
userService.changeEntity();
log.info("用户模块数据迁移完成");
deviceService.deviceChange();
log.info("zb模块数据迁移完成");
storageService.moveStorage();;
log.info("入库业务数据迁移完成");
}
......
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论