修改bug
This commit is contained in:
parent
9c6ae5a93e
commit
022482ac23
|
@ -49,10 +49,25 @@ public class SyncTBks extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbbks.class)));
|
||||
|
||||
//保存到胃
|
||||
xxhbbksService.syncList(outDataList);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
xxhbbksService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbbks xxhbbks = xxhbbksService.getSumnum();
|
||||
int mysqlnum=xxhbbks.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
xxhbsynclog.setOratabname("T_BKS");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog,Xxhbbks.class);
|
||||
}
|
||||
|
||||
|
|
|
@ -51,10 +51,25 @@ public class SyncTDw extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbdw.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbdw xxhbdw = impService.getSumnum();
|
||||
int mysqlnum=xxhbdw.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
xxhbsynclog.setOratabname("T_DW");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog,Xxhbdw.class);
|
||||
}
|
||||
|
||||
|
|
|
@ -7,6 +7,7 @@ import org.apache.commons.compress.utils.Lists;
|
|||
import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
|
||||
import org.jeecg.modules.kc.grab.exports.entity.TFwdtShryxx;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITFwdtShryxxService;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbshryxx;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
|
||||
import org.jeecg.modules.kc.grab.imports.service.IXxhbshryxxService;
|
||||
|
@ -69,7 +70,34 @@ public class SyncTFwdtShryxx extends BaseSync {
|
|||
});
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
//保存到胃
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbshryxx xxhbshryxx = impService.getSumnum();
|
||||
int mysqlnum=xxhbshryxx.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
xxhbsynclog.setOratabname("t_fwdt_shryxx");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog,Xxhbshryxx.class);
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
//删除旧数据
|
||||
|
||||
QueryWrapper<KcTksfrzb> rqw = new QueryWrapper<>();
|
||||
|
@ -78,9 +106,9 @@ public class SyncTFwdtShryxx extends BaseSync {
|
|||
|
||||
kcTksfrzbService.saveBatch(saveList);
|
||||
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
saveLog(xxhbsynclog, Xxhbshryxx.class);
|
||||
// Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
// xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
// saveLog(xxhbsynclog, Xxhbshryxx.class);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -8,6 +8,7 @@ import org.jeecg.modules.kc.grab.exports.entity.TJwJsjbxx;
|
|||
import org.jeecg.modules.kc.grab.exports.entity.TJwKckb;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITJwJsjbxxService;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITJwKckbService;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbjsjbxx;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbkckb;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
|
||||
|
@ -52,12 +53,28 @@ public class SyncTJwJsjbxxb extends BaseSync {
|
|||
//清洗数据
|
||||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbjsjbxx.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
//保存到胃
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbjsjbxx Xxhbjsjbxx = impService.getSumnum();
|
||||
int mysqlnum=Xxhbjsjbxx.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
saveLog(xxhbsynclog, Xxhbkckb.class);
|
||||
xxhbsynclog.setOratabname("TJwJsjbxx");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog,Xxhbbks.class);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -6,9 +6,7 @@ import org.apache.commons.compress.utils.Lists;
|
|||
import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
|
||||
import org.jeecg.modules.kc.grab.exports.entity.TJwJxljbxx;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITJwJxljbxxService;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbjxljbxx;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbkckb;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.*;
|
||||
import org.jeecg.modules.kc.grab.imports.service.IXxhbjxljbxxService;
|
||||
import org.quartz.JobExecutionContext;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
@ -50,11 +48,26 @@ public class SyncTJwJxljbxxb extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbjxljbxx.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbjxljbxx Xxhbjxljbxx = impService.getSumnum();
|
||||
int mysqlnum=Xxhbjxljbxx.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
saveLog(xxhbsynclog, Xxhbkckb.class);
|
||||
xxhbsynclog.setOratabname("TJwJxljbxx");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog, Xxhbjxljbxx.class);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -6,6 +6,8 @@ import org.apache.commons.compress.utils.Lists;
|
|||
import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
|
||||
import org.jeecg.modules.kc.grab.exports.entity.TJwKcapzb;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITJwKcapzbService;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbjsjbxx;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbkcapzb;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
|
||||
import org.jeecg.modules.kc.grab.imports.service.IXxhbkcapzbService;
|
||||
|
@ -49,11 +51,26 @@ public class SyncTJwKcapzb extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbkcapzb.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbkcapzb Xxhbkcapzb = impService.getSumnum();
|
||||
int mysqlnum=Xxhbkcapzb.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
saveLog(xxhbsynclog,Xxhbkcapzb.class);
|
||||
xxhbsynclog.setOratabname("T_JW_KCAPZB");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog, Xxhbbks.class);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -6,6 +6,8 @@ import org.apache.commons.compress.utils.Lists;
|
|||
import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
|
||||
import org.jeecg.modules.kc.grab.exports.entity.TJwKckb;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITJwKckbService;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbjsjbxx;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbkckb;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
|
||||
import org.jeecg.modules.kc.grab.imports.service.IXxhbkckbService;
|
||||
|
@ -49,10 +51,25 @@ public class SyncTJwKckb extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbkckb.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbkckb Xxhbkckb = impService.getSumnum();
|
||||
int mysqlnum=Xxhbkckb.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
xxhbsynclog.setOratabname("T_JW_KCKB");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog, Xxhbkckb.class);
|
||||
}
|
||||
|
||||
|
|
|
@ -6,6 +6,8 @@ import org.apache.commons.compress.utils.Lists;
|
|||
import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
|
||||
import org.jeecg.modules.kc.grab.exports.entity.TJwKcxxb;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITJwKcxxbService;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbjsjbxx;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbkcxxb;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
|
||||
import org.jeecg.modules.kc.grab.imports.service.IXxhbkcxxbService;
|
||||
|
@ -49,10 +51,25 @@ public class SyncTJwKcxxb extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbkcxxb.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbkcxxb Xxhbjsjbxx = impService.getSumnum();
|
||||
int mysqlnum=Xxhbjsjbxx.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
xxhbsynclog.setOratabname("T_JW_KCXXB");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog, Xxhbkcxxb.class);
|
||||
}
|
||||
|
||||
|
|
|
@ -6,6 +6,8 @@ import org.apache.commons.compress.utils.Lists;
|
|||
import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
|
||||
import org.jeecg.modules.kc.grab.exports.entity.TJwTkkcb;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITJwTkkcbService;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbjsjbxx;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbtkkcb;
|
||||
import org.jeecg.modules.kc.grab.imports.service.IXxhbtkkcbService;
|
||||
|
@ -49,11 +51,26 @@ public class SyncTJwTkkcb extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbtkkcb.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbtkkcb Xxhbtkkcb = impService.getSumnum();
|
||||
int mysqlnum=Xxhbtkkcb.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
saveLog(xxhbsynclog,Xxhbtkkcb.class);
|
||||
xxhbsynclog.setOratabname("T_JW_TKKCB");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog, Xxhbtkkcb.class);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -6,6 +6,7 @@ import org.apache.commons.compress.utils.Lists;
|
|||
import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
|
||||
import org.jeecg.modules.kc.grab.exports.entity.TJwTkxx;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITJwTkxxService;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbdw;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbtkxx;
|
||||
import org.jeecg.modules.kc.grab.imports.service.IXxhbtkxxService;
|
||||
|
@ -49,11 +50,26 @@ public class SyncTJwTkxx extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbtkxx.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbtkxx Xxhbtkxx = impService.getSumnum();
|
||||
int mysqlnum=Xxhbtkxx.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
saveLog(xxhbsynclog, Xxhbtkxx.class);
|
||||
xxhbsynclog.setOratabname("T_JW_TKXX");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog,Xxhbtkxx.class);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -8,6 +8,7 @@ import org.apache.commons.compress.utils.Lists;
|
|||
import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
|
||||
import org.jeecg.modules.kc.grab.exports.entity.TJwXsxkb;
|
||||
import org.jeecg.modules.kc.grab.exports.service.ITJwXsxkbService;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbdw;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbsynclog;
|
||||
import org.jeecg.modules.kc.grab.imports.entity.Xxhbxsxkb;
|
||||
import org.jeecg.modules.kc.grab.imports.service.IXxhbxsxkbService;
|
||||
|
@ -76,11 +77,26 @@ public class SyncTJwXsxkb extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbxsxkb.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList,dqw,isDelete);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbxsxkb Xxhbxsxkb = impService.getSumnum();
|
||||
int mysqlnum=Xxhbxsxkb.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
saveLog(xxhbsynclog, Xxhbxsxkb.class);
|
||||
xxhbsynclog.setOratabname("T_JW_XSXKB");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("1");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog,Xxhbxsxkb.class);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -57,10 +57,25 @@ public class SyncTZzbLdxx extends BaseSync {
|
|||
inDataList.forEach(x -> outDataList.add(BeanUtil.toBean(x, Xxhbldxx.class)));
|
||||
|
||||
//保存到胃
|
||||
impService.syncList(outDataList);
|
||||
|
||||
int syncnum=0;
|
||||
String errorMessage = "";
|
||||
try {
|
||||
impService.syncList(outDataList);
|
||||
syncnum = outDataList.size();
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
errorMessage = e.getMessage();
|
||||
}
|
||||
Xxhbldxx Xxhbldxx = impService.getSumnum();
|
||||
int mysqlnum=Xxhbldxx.getMysqlnum();
|
||||
Xxhbsynclog xxhbsynclog = new Xxhbsynclog();
|
||||
xxhbsynclog.setSyncRowNum(String.valueOf(outDataList.size()));
|
||||
xxhbsynclog.setOratabname("T_ZZB_LDXX");//oracle表名
|
||||
xxhbsynclog.setOratabnum(inDataList.size());//oracle表数量
|
||||
xxhbsynclog.setTablenum(mysqlnum);//mysql表数量
|
||||
xxhbsynclog.setSyncnum(syncnum);//本次同步数据量
|
||||
xxhbsynclog.setSynctype("0");//同步类型 0全量 1增量
|
||||
xxhbsynclog.setErrormessage(errorMessage);
|
||||
saveLog(xxhbsynclog,Xxhbldxx.class);
|
||||
}
|
||||
|
||||
|
|
|
@ -1,6 +1,7 @@
|
|||
package org.jeecg.modules.kc.grab.imports.entity;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
|
@ -82,4 +83,7 @@ public class Xxhbbks implements Serializable {
|
|||
@DateTimeFormat(pattern="yyyy-MM-dd")
|
||||
@ApiModelProperty(value = "timestamps")
|
||||
private java.util.Date timestamps;
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -96,4 +94,6 @@ public class Xxhbdw implements Serializable {
|
|||
@Excel(name = "yjbmdwh", width = 15)
|
||||
@ApiModelProperty(value = "yjbmdwh")
|
||||
private java.lang.String yjbmdwh;
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -130,4 +128,8 @@ public class Xxhbjsjbxx implements Serializable {
|
|||
@Excel(name = "是否可重复利用", width = 15)
|
||||
@ApiModelProperty(value = "是否可重复利用")
|
||||
private java.lang.String sfkcfly;
|
||||
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -78,4 +76,7 @@ public class Xxhbjxljbxx implements Serializable {
|
|||
@DateTimeFormat(pattern="yyyy-MM-dd")
|
||||
@ApiModelProperty(value = "时间戳")
|
||||
private java.util.Date timestamps;
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -144,4 +142,7 @@ public class Xxhbkcapzb implements Serializable {
|
|||
@Excel(name = "选课标志", width = 15)
|
||||
@ApiModelProperty(value = "选课标志")
|
||||
private java.lang.String xkbz;
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -221,4 +219,7 @@ public class Xxhbkckb implements Serializable {
|
|||
@ApiModelProperty(value = "是否需要线上")
|
||||
private java.lang.String sfxsk;
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -148,4 +146,7 @@ public class Xxhbkcxxb implements Serializable {
|
|||
@Excel(name = "素质课程分类代码", width = 15)
|
||||
@ApiModelProperty(value = "素质课程分类代码")
|
||||
private java.lang.String szkcfldm;
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -64,4 +62,7 @@ public class Xxhbldxx implements Serializable {
|
|||
@Excel(name = "时间戳", width = 15)
|
||||
@ApiModelProperty(value = "时间戳")
|
||||
private java.lang.String timestamps;
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -1,5 +1,6 @@
|
|||
package org.jeecg.modules.kc.grab.imports.entity;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.TableField;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import io.swagger.annotations.ApiModel;
|
||||
|
@ -56,4 +57,8 @@ public class Xxhbshryxx implements Serializable {
|
|||
@DateTimeFormat(pattern="yyyy-MM-dd")
|
||||
@ApiModelProperty(value = "时间戳")
|
||||
private java.util.Date timestamps;
|
||||
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -57,4 +57,13 @@ public class Xxhbsynclog implements Serializable {
|
|||
@Excel(name = "同步行数量", width = 15)
|
||||
@ApiModelProperty(value = "同步行数量")
|
||||
private java.lang.String errormessage;
|
||||
|
||||
private java.lang.String oratabname;
|
||||
private Integer tablenum;
|
||||
private Integer oratabnum;
|
||||
private Integer syncnum;
|
||||
private java.lang.String synctype;
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -140,4 +138,7 @@ public class Xxhbtkkcb implements Serializable {
|
|||
@Excel(name = "timestamps", width = 15)
|
||||
@ApiModelProperty(value = "timestamps")
|
||||
private java.lang.String timestamps;
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -136,4 +134,6 @@ public class Xxhbtkxx implements Serializable {
|
|||
@Excel(name = "1-调整时间,2-调整地点,3-更换教师,4-其他", width = 15)
|
||||
@ApiModelProperty(value = "1-调整时间,2-调整地点,3-更换教师,4-其他")
|
||||
private java.lang.String tklx;
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -4,10 +4,8 @@ import java.io.Serializable;
|
|||
import java.io.UnsupportedEncodingException;
|
||||
import java.util.Date;
|
||||
import java.math.BigDecimal;
|
||||
import com.baomidou.mybatisplus.annotation.IdType;
|
||||
import com.baomidou.mybatisplus.annotation.TableId;
|
||||
import com.baomidou.mybatisplus.annotation.TableName;
|
||||
import com.baomidou.mybatisplus.annotation.TableLogic;
|
||||
|
||||
import com.baomidou.mybatisplus.annotation.*;
|
||||
import lombok.Data;
|
||||
import com.fasterxml.jackson.annotation.JsonFormat;
|
||||
import org.springframework.format.annotation.DateTimeFormat;
|
||||
|
@ -80,4 +78,7 @@ public class Xxhbxsxkb implements Serializable {
|
|||
@Excel(name = "课程总表编号", width = 15)
|
||||
@ApiModelProperty(value = "课程总表编号")
|
||||
private java.lang.String kcapzbbh;
|
||||
|
||||
@TableField(exist = false)
|
||||
private Integer mysqlnum;
|
||||
}
|
||||
|
|
|
@ -11,4 +11,5 @@ import org.jeecg.modules.kc.grab.imports.entity.Xxhbbks;
|
|||
*/
|
||||
public interface XxhbbksMapper extends BaseMapper<Xxhbbks> {
|
||||
|
||||
Xxhbbks getSumnum();
|
||||
}
|
||||
|
|
|
@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
*/
|
||||
public interface XxhbdwMapper extends BaseMapper<Xxhbdw> {
|
||||
|
||||
Xxhbdw getSumnum();
|
||||
}
|
||||
|
|
|
@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
*/
|
||||
public interface XxhbjsjbxxMapper extends BaseMapper<Xxhbjsjbxx> {
|
||||
|
||||
Xxhbjsjbxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
*/
|
||||
public interface XxhbjxljbxxMapper extends BaseMapper<Xxhbjxljbxx> {
|
||||
|
||||
Xxhbjxljbxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
*/
|
||||
public interface XxhbkcapzbMapper extends BaseMapper<Xxhbkcapzb> {
|
||||
|
||||
Xxhbkcapzb getSumnum();
|
||||
}
|
||||
|
|
|
@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
*/
|
||||
public interface XxhbkckbMapper extends BaseMapper<Xxhbkckb> {
|
||||
|
||||
Xxhbkckb getSumnum();
|
||||
}
|
||||
|
|
|
@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
*/
|
||||
public interface XxhbkcxxbMapper extends BaseMapper<Xxhbkcxxb> {
|
||||
|
||||
Xxhbkcxxb getSumnum();
|
||||
}
|
||||
|
|
|
@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
*/
|
||||
public interface XxhbldxxMapper extends BaseMapper<Xxhbldxx> {
|
||||
|
||||
Xxhbldxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -11,4 +11,5 @@ import org.jeecg.modules.kc.grab.imports.entity.Xxhbshryxx;
|
|||
*/
|
||||
public interface XxhbshryxxMapper extends BaseMapper<Xxhbshryxx> {
|
||||
|
||||
Xxhbshryxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
*/
|
||||
public interface XxhbtkkcbMapper extends BaseMapper<Xxhbtkkcb> {
|
||||
|
||||
Xxhbtkkcb getSumnum();
|
||||
}
|
||||
|
|
|
@ -16,4 +16,6 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
public interface XxhbtkxxMapper extends BaseMapper<Xxhbtkxx> {
|
||||
|
||||
boolean updateToKeTang(Wrapper<Xxhbtkxx> queryWrapper);
|
||||
|
||||
Xxhbtkxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -14,4 +14,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|||
*/
|
||||
public interface XxhbxsxkbMapper extends BaseMapper<Xxhbxsxkb> {
|
||||
|
||||
Xxhbxsxkb getSumnum();
|
||||
}
|
||||
|
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbbksMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbbks">
|
||||
select count(*) as mysqlnum from xxhbbks
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbdwMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbdw">
|
||||
select count(*) as mysqlnum from xxhbdw
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbjsjbxxMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbjsjbxx">
|
||||
select count(*) as mysqlnum from xxhbjsjbxx
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbjxljbxxMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbjxljbxx">
|
||||
select count(*) as mysqlnum from xxhbjxljbxx
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbkcapzbMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbkcapzb">
|
||||
select count(*) as mysqlnum from xxhbkcapzb
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbkckbMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbkckb">
|
||||
select count(*) as mysqlnum from xxhbkckb
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbkcxxbMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbkcxxb">
|
||||
select count(*) as mysqlnum from xxhbkcxxb
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbldxxMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbldxx">
|
||||
select count(*) as mysqlnum from xxhbldxx
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbshryxxMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbshryxx">
|
||||
select count(*) as mysqlnum from xxhbshryxx
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbtkkcbMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbtkkcb">
|
||||
select count(*) as mysqlnum from xxhbtkkcb
|
||||
</select>
|
||||
</mapper>
|
|
@ -12,4 +12,9 @@
|
|||
AND tk.sqrdw = kt.kkdw
|
||||
AND tk.jc = kt.hh
|
||||
</update>
|
||||
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbtkxx">
|
||||
select count(*) as mysqlnum from xxhbtkxx
|
||||
</select>
|
||||
</mapper>
|
|
@ -2,4 +2,7 @@
|
|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="org.jeecg.modules.kc.grab.imports.mapper.XxhbxsxkbMapper">
|
||||
|
||||
<select id="getSumnum" resultType="org.jeecg.modules.kc.grab.imports.entity.Xxhbxsxkb">
|
||||
select count(*) as mysqlnum from xxhbxsxkb
|
||||
</select>
|
||||
</mapper>
|
|
@ -28,4 +28,5 @@ public interface IXxhbbksService extends IService<Xxhbbks> {
|
|||
*/
|
||||
boolean syncList(Collection<Xxhbbks> entityList, boolean isDelete);
|
||||
|
||||
Xxhbbks getSumnum();
|
||||
}
|
||||
|
|
|
@ -28,4 +28,5 @@ public interface IXxhbdwService extends IService<Xxhbdw> {
|
|||
*/
|
||||
boolean syncList(Collection<Xxhbdw> entityList, boolean isDelete);
|
||||
|
||||
Xxhbdw getSumnum();
|
||||
}
|
||||
|
|
|
@ -18,4 +18,6 @@ public interface IXxhbjsjbxxService extends IService<Xxhbjsjbxx> {
|
|||
boolean syncList(List<Xxhbjsjbxx> outDataList);
|
||||
|
||||
boolean syncList(Collection<Xxhbjsjbxx> entityList, boolean isDelete);
|
||||
|
||||
Xxhbjsjbxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -18,4 +18,6 @@ public interface IXxhbjxljbxxService extends IService<Xxhbjxljbxx> {
|
|||
boolean syncList(List<Xxhbjxljbxx> outDataList);
|
||||
|
||||
boolean syncList(Collection<Xxhbjxljbxx> entityList, boolean isDelete);
|
||||
|
||||
Xxhbjxljbxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -28,4 +28,5 @@ public interface IXxhbkcapzbService extends IService<Xxhbkcapzb> {
|
|||
*/
|
||||
boolean syncList(Collection<Xxhbkcapzb> entityList, boolean isDelete);
|
||||
|
||||
Xxhbkcapzb getSumnum();
|
||||
}
|
||||
|
|
|
@ -28,4 +28,5 @@ public interface IXxhbkckbService extends IService<Xxhbkckb> {
|
|||
*/
|
||||
boolean syncList(Collection<Xxhbkckb> entityList, boolean isDelete);
|
||||
|
||||
Xxhbkckb getSumnum();
|
||||
}
|
||||
|
|
|
@ -28,4 +28,5 @@ public interface IXxhbkcxxbService extends IService<Xxhbkcxxb> {
|
|||
*/
|
||||
boolean syncList(Collection<Xxhbkcxxb> entityList, boolean isDelete);
|
||||
|
||||
Xxhbkcxxb getSumnum();
|
||||
}
|
||||
|
|
|
@ -28,4 +28,5 @@ public interface IXxhbldxxService extends IService<Xxhbldxx> {
|
|||
*/
|
||||
boolean syncList(Collection<Xxhbldxx> entityList, boolean isDelete);
|
||||
|
||||
Xxhbldxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -27,4 +27,5 @@ public interface IXxhbshryxxService extends IService<Xxhbshryxx> {
|
|||
*/
|
||||
boolean syncList(Collection<Xxhbshryxx> entityList, boolean isDelete);
|
||||
|
||||
Xxhbshryxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -28,4 +28,5 @@ public interface IXxhbtkkcbService extends IService<Xxhbtkkcb> {
|
|||
*/
|
||||
boolean syncList(Collection<Xxhbtkkcb> entityList, boolean isDelete);
|
||||
|
||||
Xxhbtkkcb getSumnum();
|
||||
}
|
||||
|
|
|
@ -36,4 +36,5 @@ public interface IXxhbtkxxService extends IService<Xxhbtkxx> {
|
|||
*/
|
||||
boolean updateToKeTang(Wrapper<Xxhbtkxx> queryWrapper);
|
||||
|
||||
Xxhbtkxx getSumnum();
|
||||
}
|
||||
|
|
|
@ -28,4 +28,6 @@ public interface IXxhbxsxkbService extends IService<Xxhbxsxkb> {
|
|||
* @return
|
||||
*/
|
||||
boolean syncList(Collection<Xxhbxsxkb> entityList, QueryWrapper queryWrapper, boolean isDelete);
|
||||
|
||||
Xxhbxsxkb getSumnum();
|
||||
}
|
||||
|
|
|
@ -34,4 +34,9 @@ public class XxhbbksServiceImpl extends ServiceImpl<XxhbbksMapper, Xxhbbks> impl
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbbks getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -34,4 +34,9 @@ public class XxhbdwServiceImpl extends ServiceImpl<XxhbdwMapper, Xxhbdw> impleme
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbdw getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -35,4 +35,9 @@ public class XxhbjsjbxxServiceImpl extends ServiceImpl<XxhbjsjbxxMapper, Xxhbjsj
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbjsjbxx getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -33,4 +33,9 @@ public class XxhbjxljbxxServiceImpl extends ServiceImpl<XxhbjxljbxxMapper, Xxhbj
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbjxljbxx getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -34,4 +34,9 @@ public class XxhbkcapzbServiceImpl extends ServiceImpl<XxhbkcapzbMapper, Xxhbkca
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbkcapzb getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -34,4 +34,9 @@ public class XxhbkckbServiceImpl extends ServiceImpl<XxhbkckbMapper, Xxhbkckb> i
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbkckb getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -34,4 +34,9 @@ public class XxhbkcxxbServiceImpl extends ServiceImpl<XxhbkcxxbMapper, Xxhbkcxxb
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbkcxxb getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -36,4 +36,9 @@ public class XxhbldxxServiceImpl extends ServiceImpl<XxhbldxxMapper, Xxhbldxx> i
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbldxx getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -34,4 +34,9 @@ public class XxhbshryxxServiceImpl extends ServiceImpl<XxhbshryxxMapper, Xxhbshr
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbshryxx getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -36,4 +36,9 @@ public class XxhbtkkcbServiceImpl extends ServiceImpl<XxhbtkkcbMapper, Xxhbtkkcb
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbtkkcb getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -69,4 +69,9 @@ public class XxhbtkxxServiceImpl extends ServiceImpl<XxhbtkxxMapper, Xxhbtkxx> i
|
|||
public boolean updateToKeTang(Wrapper<Xxhbtkxx> queryWrapper) {
|
||||
return baseMapper.updateToKeTang(queryWrapper);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbtkxx getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -34,4 +34,9 @@ public class XxhbxsxkbServiceImpl extends ServiceImpl<XxhbxsxkbMapper, Xxhbxsxkb
|
|||
}
|
||||
return this.saveBatch(entityList, 1000);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Xxhbxsxkb getSumnum() {
|
||||
return baseMapper.getSumnum();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -243,7 +243,7 @@ public class KcZzYbtkbController extends JeecgController<KcZzYbtkb, IKcZzYbtkbSe
|
|||
QueryWrapper<KcKetangbiao> kcKetangbiaoQueryWrapper = new QueryWrapper<>();
|
||||
kcKetangbiaoQueryWrapper.eq(StringUtils.isNotBlank(KcZzYbtkbPar.getKcbh()),"kcbh",KcZzYbtkbPar.getKcbh());
|
||||
kcKetangbiaoQueryWrapper.eq(StringUtils.isNotBlank(KcZzYbtkbPar.getKcmc()),"kcmc",KcZzYbtkbPar.getKcmc());
|
||||
kcKetangbiaoQueryWrapper.eq(StringUtils.isNotBlank(KcZzYbtkbPar.getSkdd()),"skdd",KcZzYbtkbPar.getSkdd());
|
||||
// kcKetangbiaoQueryWrapper.eq(StringUtils.isNotBlank(KcZzYbtkbPar.getSkdd()),"skdd",KcZzYbtkbPar.getSkdd());
|
||||
kcKetangbiaoQueryWrapper.like("skrq",DateUtil.format(KcZzYbtkbPar.getSkrq(),"yyyy-MM-dd"));
|
||||
kcKetangbiaoQueryWrapper.eq("skjs",KcZzYbtkbPar.getSkjs());
|
||||
List<KcKetangbiao> kcKetangBiaoList = kcKetangbiaoService.list(kcKetangbiaoQueryWrapper);
|
||||
|
|
|
@ -405,4 +405,14 @@ public class KcTingkeController extends JeecgController<KcTingke, IKcTingkeServi
|
|||
|
||||
|
||||
|
||||
@GetMapping(value = "/getSftk")
|
||||
public Result<List<KcTingke>> getSftk(KcTingke kcTingke) {
|
||||
QueryWrapper<KcTingke> queryWrapper = new QueryWrapper<>();
|
||||
queryWrapper.eq("kechengbiaoid",kcTingke.getKechengbiaoid());
|
||||
queryWrapper.eq("userid",kcTingke.getUserid());
|
||||
List<KcTingke> list = kcTingkeService.getSftk(queryWrapper);
|
||||
return Result.OK(list);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
|
|
@ -41,4 +41,6 @@ public interface KcTingkeMapper extends BaseMapper<KcTingke> {
|
|||
List<KcKkdw> selectKkdwExportList(KcKkdw kcKkdw);
|
||||
|
||||
List<KcTkmx> selectTkmxExportList(KcTkmx kcTkmx);
|
||||
|
||||
List<KcTingke> getSftk(@Param(Constants.WRAPPER) QueryWrapper<KcTingke> queryWrapper);
|
||||
}
|
||||
|
|
|
@ -45,6 +45,9 @@
|
|||
<if test="kcTingke.username!=null and kcTingke.username!=''">
|
||||
AND (tk.username like CONCAT('%',#{kcTingke.username},'%') or tk.userid like CONCAT('%',#{kcTingke.username},'%'))
|
||||
</if>
|
||||
<if test="kcTingke.userid!=null and kcTingke.userid!=''">
|
||||
AND tk.userid =#{userid}
|
||||
</if>
|
||||
GROUP BY tk.userid, tk.username, college
|
||||
) tk LEFT JOIN (
|
||||
SELECT usercode, username, GROUP_CONCAT( assess1 SEPARATOR ',' ) tksf1, GROUP_CONCAT( assess2 SEPARATOR ',' ) tksf2, max( tkyq ) tkyq,assesscode,dwmc
|
||||
|
@ -766,4 +769,10 @@
|
|||
ORDER BY
|
||||
tingketime DESC
|
||||
</select>
|
||||
|
||||
|
||||
<select id="getSftk" resultType="org.jeecg.modules.kc.tktj.entity.KcTingke">
|
||||
select * from kc_tingke
|
||||
${ew.customSqlSegment}
|
||||
</select>
|
||||
</mapper>
|
|
@ -38,4 +38,6 @@ public interface IKcTingkeService extends IService<KcTingke> {
|
|||
List<KcKkdw> selectKkdwExportList(KcKkdw kcKkdw);
|
||||
|
||||
List<KcTkmx> selectTkmxExportList(KcTkmx kcTkmx);
|
||||
|
||||
List<KcTingke> getSftk(QueryWrapper<KcTingke> queryWrapper);
|
||||
}
|
||||
|
|
|
@ -74,4 +74,9 @@ public class KcTingkeServiceImpl extends ServiceImpl<KcTingkeMapper, KcTingke> i
|
|||
public List<KcTkmx> selectTkmxExportList(KcTkmx kcTkmx) {
|
||||
return baseMapper.selectTkmxExportList(kcTkmx);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<KcTingke> getSftk(QueryWrapper<KcTingke> queryWrapper) {
|
||||
return baseMapper.getSftk(queryWrapper);
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue