publish 0.9.7
This commit is contained in:
@@ -17,8 +17,8 @@ import com.tiesheng.core.pojos.dao.CoreLogOperation;
|
|||||||
import com.tiesheng.core.pojos.dao.CoreLogProcess;
|
import com.tiesheng.core.pojos.dao.CoreLogProcess;
|
||||||
import com.tiesheng.core.pojos.dao.CorePlatformUnique;
|
import com.tiesheng.core.pojos.dao.CorePlatformUnique;
|
||||||
import com.tiesheng.core.pojos.vo.ProcessDetailVo;
|
import com.tiesheng.core.pojos.vo.ProcessDetailVo;
|
||||||
import com.tiesheng.core.util.ProcessListConsumer;
|
import com.tiesheng.core.util.ProcessImportConsumer;
|
||||||
import com.tiesheng.core.util.ProcessPageConsumer;
|
import com.tiesheng.core.util.ProcessSyncConsumer;
|
||||||
import com.tiesheng.login.config.token.TsTokenConfig;
|
import com.tiesheng.login.config.token.TsTokenConfig;
|
||||||
import com.tiesheng.login.config.token.bean.TokenBean;
|
import com.tiesheng.login.config.token.bean.TokenBean;
|
||||||
import com.tiesheng.util.ServletKit;
|
import com.tiesheng.util.ServletKit;
|
||||||
@@ -64,20 +64,19 @@ public class CoreLogService extends TsServiceBase<CoreLogOperationMapper, CoreLo
|
|||||||
///////////////////////////////////////////////////////////////////////////
|
///////////////////////////////////////////////////////////////////////////
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 添加空的过程 返回id 用于更新
|
* 添加导入过程
|
||||||
*
|
*
|
||||||
* @param title 标题
|
* @param title 标题
|
||||||
* @param type 类型 import-导入,sync-同步
|
|
||||||
* @param list 要导入的数据
|
* @param list 要导入的数据
|
||||||
*/
|
*/
|
||||||
public <T> CoreLogProcess addProcess(String title, String type, List<T> list, ProcessListConsumer consumer) {
|
public <T> CoreLogProcess addProcess(String title, List<T> list, ProcessImportConsumer consumer) {
|
||||||
if (CollUtil.isEmpty(list)) {
|
if (CollUtil.isEmpty(list)) {
|
||||||
throw new ApiException("文件中不存在数据");
|
throw new ApiException("文件中不存在数据");
|
||||||
}
|
}
|
||||||
CoreLogProcess coreLogProcess = new CoreLogProcess();
|
CoreLogProcess coreLogProcess = new CoreLogProcess();
|
||||||
coreLogProcess.setTitle(title);
|
coreLogProcess.setTitle(title);
|
||||||
coreLogProcess.setTotal(list.size());
|
coreLogProcess.setTotal(list.size());
|
||||||
coreLogProcess.setType(type);
|
coreLogProcess.setType("import");
|
||||||
coreLogProcess.setSuccessNum(0);
|
coreLogProcess.setSuccessNum(0);
|
||||||
coreLogProcess.setFailNum(0);
|
coreLogProcess.setFailNum(0);
|
||||||
coreLogProcessMapper.insert(coreLogProcess);
|
coreLogProcessMapper.insert(coreLogProcess);
|
||||||
@@ -101,11 +100,19 @@ public class CoreLogService extends TsServiceBase<CoreLogOperationMapper, CoreLo
|
|||||||
return coreLogProcess;
|
return coreLogProcess;
|
||||||
}
|
}
|
||||||
|
|
||||||
public CoreLogProcess addProcess(String title, String type, ProcessPageConsumer consumer) {
|
|
||||||
|
/**
|
||||||
|
* 添加同步过程
|
||||||
|
*
|
||||||
|
* @param title
|
||||||
|
* @param consumer
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
public CoreLogProcess addProcess(String title, ProcessSyncConsumer consumer) {
|
||||||
CoreLogProcess coreLogProcess = new CoreLogProcess();
|
CoreLogProcess coreLogProcess = new CoreLogProcess();
|
||||||
coreLogProcess.setTitle(title);
|
coreLogProcess.setTitle(title);
|
||||||
coreLogProcess.setTotal(0);
|
coreLogProcess.setTotal(0);
|
||||||
coreLogProcess.setType(type);
|
coreLogProcess.setType("sync");
|
||||||
coreLogProcess.setSuccessNum(0);
|
coreLogProcess.setSuccessNum(0);
|
||||||
coreLogProcess.setFailNum(0);
|
coreLogProcess.setFailNum(0);
|
||||||
coreLogProcessMapper.insert(coreLogProcess);
|
coreLogProcessMapper.insert(coreLogProcess);
|
||||||
|
|||||||
@@ -1,10 +1,8 @@
|
|||||||
package com.tiesheng.core.util;
|
package com.tiesheng.core.util;
|
||||||
|
|
||||||
import com.tiesheng.core.pojos.dao.CoreLogProcess;
|
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
public interface ProcessListConsumer {
|
public interface ProcessImportConsumer {
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -1,10 +1,6 @@
|
|||||||
package com.tiesheng.core.util;
|
package com.tiesheng.core.util;
|
||||||
|
|
||||||
import com.tiesheng.core.pojos.dao.CoreLogProcess;
|
public interface ProcessSyncConsumer {
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
public interface ProcessPageConsumer {
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
Reference in New Issue
Block a user