publish 0.9.7

This commit is contained in:
曾文豪
2023-04-06 00:05:49 +08:00
parent 47c9251389
commit 24629f06b4
3 changed files with 17 additions and 16 deletions

View File

@@ -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);

View File

@@ -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 {
/** /**

View File

@@ -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 {
/** /**