feat():行数据测试

master
yuan 2024-09-08 11:16:30 +08:00
parent b68987ed06
commit ba6c7e09b9
5 changed files with 13 additions and 47 deletions

View File

@ -1,7 +1,7 @@
package com.muyu.engine.basic; package com.muyu.engine.basic;
import com.muyu.common.domain.DataValue; import com.muyu.common.domain.DataValue;
import com.muyu.engine.basic.handler.DataEngineValueHandler; import com.muyu.engine.basic.handler.DataEngineHandler;
/** /**
* @Author * @Author
@ -19,7 +19,7 @@ public interface BasicEngine<V> {
public V get(); public V get();
public default void remove(){ public default void remove(){
DataEngineValueHandler.remove(); DataEngineHandler.remove();
} }
public void execution(); public void execution();

View File

@ -1,27 +0,0 @@
package com.muyu.engine.basic;
import com.muyu.common.domain.DataValue;
import com.muyu.engine.basic.handler.DataEngineRecordHandler;
import com.muyu.engine.basic.handler.DataEngineValueHandler;
/**
* @Author
* @Packagecom.muyu.engine.basic
* @Projectcloud-rule
* @nameBasicEngin
* @Date2024/8/29 3:13
* @Description:
*/
public interface BasicRecordEngine<V> {
public void set(DataValue[] dataValue);
//获取原始值
public V get();
public default void remove(){
DataEngineRecordHandler.remove();
}
public void execution();
}

View File

@ -2,7 +2,6 @@ package com.muyu.engine.basic.abstracts;
import com.muyu.common.domain.DataValue; import com.muyu.common.domain.DataValue;
import com.muyu.engine.basic.BasicEngine; import com.muyu.engine.basic.BasicEngine;
import com.muyu.engine.basic.BasicRecordEngine;
import com.muyu.engine.basic.handler.DataEngineRecordHandler; import com.muyu.engine.basic.handler.DataEngineRecordHandler;
/** /**
@ -13,13 +12,15 @@ import com.muyu.engine.basic.handler.DataEngineRecordHandler;
* @Date2024/8/30 11:13 * @Date2024/8/30 11:13
* @Description: * @Description:
*/ */
public abstract class DataEngineRecordActuator implements BasicRecordEngine<DataValue[]> { public abstract class DataEngineRecordActuator implements BasicEngine<DataValue[]> {
public void set(DataValue[] dataValue){ @Override
public void set(DataValue dataValue){
DataEngineRecordHandler.set(dataValue); DataEngineRecordHandler.set(dataValue);
} }
//获取原始值 //获取原始值
@Override
public DataValue[] get(){ public DataValue[] get(){
return DataEngineRecordHandler.get(); return DataEngineRecordHandler.get();
} }
@ -27,7 +28,6 @@ public abstract class DataEngineRecordActuator implements BasicRecordEngine<Data
@Override @Override
public void execution() { public void execution() {
this.run(); this.run();
this.remove();
} }
public abstract void run(); public abstract void run();

View File

@ -15,21 +15,12 @@ public class DataEngineRecordHandler {
private static final ThreadLocal<DataValue[]> dataEngineRecordHandler = new ThreadLocal<>(); private static final ThreadLocal<DataValue[]> dataEngineRecordHandler = new ThreadLocal<>();
public static void set(DataValue[] dataValue){ public static void set(DataValue[] dataValue){
DataEngineHandler.set(dataValue); dataEngineRecordHandler.set(dataValue);
} }
public static DataValue[] get() { public static DataValue[] get() {
return DataEngineHandler.get(); return dataEngineRecordHandler.get();
}
public static void remove(){
DataEngineHandler.remove();
}
public static Object getValue(){
return get().getClass();
} }
} }

View File

@ -13,8 +13,10 @@ import com.muyu.engine.basic.abstracts.DataEngineRecordActuator;
public class GenerateRecordQWEQWE extends DataEngineRecordActuator { public class GenerateRecordQWEQWE extends DataEngineRecordActuator {
@Override @Override
public void run() { public void run() {
DataValue[] record = get(); DataRecord record = new DataRecord();
for (DataValue dataValue : record) { DataValue[] dataValues = record.getDataValues();
dataValues = get();
for (DataValue dataValue : dataValues) {
if (dataValue.getKey()!=null && dataValue.getValue()!=null && dataValue.getType() != null && dataValue.getLabel() != null) { if (dataValue.getKey()!=null && dataValue.getValue()!=null && dataValue.getType() != null && dataValue.getLabel() != null) {
System.out.println("数据正常:" + dataValue); System.out.println("数据正常:" + dataValue);
} else { } else {