add healthindex module Entity and DP

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/IWmsHealthIndexCron.java

@@ -0,0 +1,29 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+import java.util.Date;
+
+/**
+ * 计算周期
+ */
+public interface IWmsHealthIndexCron {
+    /**
+     * 根据CRON表达式，判断当前时间是否可以执行
+     * @param expectDifference 允许的时间差(秒)，即前后相差时间
+     *                         如 60 即推迟1分钟
+     *                         如 -60 即可以提前1分钟
+     */
+    boolean verify(int expectDifference);
+
+
+    /**
+     * 获取上一个计算周期
+     * @return
+     */
+    Date getPreviousDate();
+
+
+    /**
+     * 获取下一个计算周期
+     */
+    Date getNextDate();
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/WmsHealthIndexCalcWay.java

@@ -0,0 +1,26 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+/**
+ * 测算方式
+ * @author link
+ */
+public enum WmsHealthIndexCalcWay {
+    /**
+     * 数据库脚本
+     */
+    DATABSE("10"),
+    /**
+     * 本地函数
+     */
+    LOCALMETHOD("20"),
+    /**
+     * 脚本
+     */
+    SCRIPT("30");
+
+    private String value;
+
+    private WmsHealthIndexCalcWay(String value){
+        this.value = value;
+    }
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/WmsHealthIndexEntity.java

@@ -0,0 +1,86 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+import cn.estsh.i3plus.pojo.wms.bean.WmsHealthVariableResult;
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.expression.ExpressionParser;
+import org.springframework.expression.spel.standard.SpelExpressionParser;
+import org.springframework.expression.spel.support.StandardEvaluationContext;
+
+import java.util.Set;
+
+/**
+ * 指标代码业务对象
+ */
+@Getter
+@Setter
+public class WmsHealthIndexEntity {
+    /**
+     * 指标唯一标识(指标代码+工厂代码)
+     */
+    private final WmsHealthIndexId id;
+    /**
+     * 指标名称
+     */
+    private String name;
+    /**
+     * 对应模块
+     */
+    private String module;
+    /**
+     * 测算对象（测算公式封装）
+     */
+    private final WmsHealthIndexFormula formula;
+    /**
+     * 指标值（测算结果）
+     */
+    private WmsHealthIndexValue value;
+    /**
+     * 是否刷新数据
+     */
+    private Boolean refresh;
+
+    public WmsHealthIndexEntity(final WmsHealthIndexId id,
+                                final WmsHealthIndexFormula formula){
+        this.id = id;
+        this.formula = formula;
+    };
+
+    public static WmsHealthIndexEntity of(final String organizeCode,
+                                          final String indicatorCode,
+                                          final String calcFormula){
+        return new WmsHealthIndexEntity(WmsHealthIndexId.of(organizeCode,indicatorCode),
+                                        WmsHealthIndexFormula.of(organizeCode,indicatorCode));
+    }
+
+
+    public boolean isRefresh(){
+        return Boolean.TRUE.equals(refresh);
+    }
+
+
+    public void refresh(){
+        WmsHealthIndexValue value = generateWmsHealthIndexValue();
+        if(null != value) {
+            this.setValue(value);
+            this.setRefresh(true);
+        }
+    }
+
+
+    private WmsHealthIndexValue generateWmsHealthIndexValue(){
+        if(!formula.isEmpty()){
+            String result = null;
+            int size = formula.getResults().size();
+            if(size==1){
+                WmsHealthIndexVariableValue varValue = formula.getSingleValue();
+                result = String.valueOf(varValue.getDetail());
+            }else{
+                result = String.valueOf(formula.getSpelResult());
+            }
+            return new WmsHealthIndexValue(result);
+        }
+        return null;
+    }
+
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/WmsHealthIndexFormula.java

@@ -0,0 +1,131 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+import lombok.Getter;
+import org.springframework.expression.ExpressionParser;
+import org.springframework.expression.spel.standard.SpelExpressionParser;
+import org.springframework.expression.spel.support.StandardEvaluationContext;
+
+import java.util.*;
+
+/**
+ * 健康度测算公式
+ */
+@Getter
+public class WmsHealthIndexFormula {
+    /**
+     * 工厂代码
+     */
+    private final String organizeCode;
+    /**
+     * 健康度指标测算代码 (#VAR202201070002/#VAR456)/(#VAR123/#VAR456)*100%
+     */
+    private final String calcFormula;
+    /**
+     * 变量列表
+     */
+    private Set<WmsHealthIndexVariable> vars = new HashSet<>();
+    /**
+     * 变量对应的计算结果
+     */
+    private Map<WmsHealthIndexVariable, WmsHealthIndexVariableValue> results =
+            new HashMap<>();
+
+
+    public WmsHealthIndexFormula(final String organizeCode,final String calcFormula){
+        this.calcFormula = calcFormula;
+        this.organizeCode = organizeCode;
+        checkCode();
+        initVars();
+    }
+
+    /**
+     * 验证公式是否正常
+     */
+    private void checkCode(){
+    }
+
+    /**
+     * 根据配置拆分和初始化变量
+     * @return
+     */
+    private void initVars(){
+        Set<WmsHealthIndexVariable> vars = new HashSet<>();
+        final String [] varTemp = this.calcFormula.split("#");
+        for(String varStrItem : varTemp) {
+            if (!varStrItem.startsWith("VAR")||varStrItem.length()<15) {
+                continue;
+            }
+            String variableCode = varStrItem.substring(0, 15);
+            vars.add(new WmsHealthIndexVariable(organizeCode,variableCode));
+        }
+        this.vars = vars;
+    }
+
+    public void addResult(WmsHealthIndexVariable key, WmsHealthIndexVariableValue result){
+        if(null!=result) {
+            this.results.put(key, result);
+        }
+    }
+
+    public boolean isEmpty(){
+        return results.isEmpty();
+    }
+
+    /**
+     *  待执行变量结果和变量结果集是否相同
+     * @return
+     */
+    public boolean isResultSizeSameWithVarsSize(){
+        return results.size() == vars.size();
+    }
+
+    /**
+     * 获取单个值对象
+     */
+    public WmsHealthIndexVariableValue getSingleValue(){
+        if(!isEmpty()) {
+            WmsHealthIndexVariableValue variableValue = com.google.common.collect.Lists
+                    .newArrayList(results.values()).get(0);
+            return variableValue;
+        }
+        return null;
+    }
+
+    /**
+     * 根据健康度指标calcFormula，计算SPEL表达式的值
+     * @return
+     */
+    public Integer getSpelResult(){
+        if(results.isEmpty()) {
+            return -1;
+        }
+        Integer calcResult = 0;
+        int resultSize = results.size();
+        StandardEvaluationContext ctx = new StandardEvaluationContext();
+        ExpressionParser parser = new SpelExpressionParser();
+        //单个变量，特殊情况特殊处理
+        if(resultSize == 1){
+            calcResult = getSingleValue().getValue();
+        }else{
+            Set<WmsHealthIndexVariable> varKeys = results.keySet();
+            for (WmsHealthIndexVariable varKey : varKeys) {
+                // 取出该变量名称对应的计算结果
+                WmsHealthIndexVariableValue variableValue = results.get(varKey);
+                Integer value = variableValue.getValue();
+                ctx.setVariable(varKey.getId().getVariable(), value);
+            }
+            // 存在多个变量，则按照SPEL进行运算最后取值
+            try {
+                calcResult =  (Integer) parser.parseExpression(calcFormula)
+                        .getValue(ctx);
+            } catch (Exception e) {
+                calcResult = -1;
+            }
+        }
+        return calcResult;
+    }
+
+    public static WmsHealthIndexFormula of(String organizeCode,String calcFormula){
+        return new WmsHealthIndexFormula(organizeCode,calcFormula);
+    }
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/WmsHealthIndexId.java

@@ -0,0 +1,34 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+import lombok.Getter;
+
+/**
+ * 健康度指标标识
+ */
+@Getter
+public  class WmsHealthIndexId{
+
+    /**
+     * 工厂代码
+     */
+    private final String organizeCode;
+    /**
+     * 指标代码
+     */
+    private final String indicatorCode;
+
+    public WmsHealthIndexId(final String organizeCode,final String indicatorCode){
+        if(null==indicatorCode){
+            throw new IllegalArgumentException("indicatorCode can't be null");
+        }
+        if(null==organizeCode){
+            throw new IllegalArgumentException("organizeCode can't be null");
+        }
+        this.indicatorCode = indicatorCode;
+        this.organizeCode = indicatorCode;
+    }
+
+    public static WmsHealthIndexId of(String organizeCode,String indicatorCode){
+        return new WmsHealthIndexId(organizeCode,indicatorCode);
+    }
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/WmsHealthIndexQuery.java

@@ -0,0 +1,19 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 健康度指标查询
+ * @author link
+ */
+@Builder
+@Getter
+@Setter
+public class WmsHealthIndexQuery{
+    private Long beginTime;
+    private Long endTime;
+    private Integer pageIndex;
+    private Integer pageSize;
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/WmsHealthIndexValue.java

@@ -0,0 +1,26 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 健康度指标计算值
+ * @author link
+ */
+@Getter
+public class WmsHealthIndexValue{
+    /**
+     * 测算结果
+     */
+    private final String result;
+    @Setter
+    private Long time;
+
+    public WmsHealthIndexValue(final String result){
+        if(null==result){
+            throw new IllegalArgumentException("result can't be null");
+        }
+        this.result = result;
+        this.time =  System.currentTimeMillis();
+    }
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/WmsHealthIndexVariable.java

@@ -0,0 +1,108 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+import lombok.Getter;
+import lombok.Setter;
+
+
+/**
+ * 健康度指标变量
+ */
+@Getter
+public class WmsHealthIndexVariable {
+
+    /**
+     * 指标变量代码
+     */
+    private final WmsHealthIndexVariableId id;
+
+    /**
+     * 指标变量名称
+     */
+    @Setter
+    private String name;
+    /**
+     * 计算周期
+     */
+    @Setter
+    private IWmsHealthIndexCron cycleRange;
+
+    /**
+     * 计算频次
+     */
+    @Setter
+    private IWmsHealthIndexCron calcFrequency;
+
+    /**
+     * 计算方式
+     */
+    @Setter
+    private WmsHealthIndexCalcWay calcWay;
+
+    /**
+     * 适应存储区
+     */
+    @Setter
+    private String applyArea;
+
+    /**
+     * 适应物料组
+     */
+    @Setter
+    private String applyPartGroup;
+
+    @Setter
+    private String sqlStatement;
+
+    @Setter
+    private String className;
+
+    @Setter
+    private String functionName;
+
+    @Setter
+    private String scriptNo;
+    /**
+     * 计算值
+     */
+    @Setter
+    private Object value;
+
+    /**
+     * 修改CRON，计算周期、频次需要刷新数据
+     */
+    @Setter
+    private boolean refresh;
+
+    public WmsHealthIndexVariable(String organizeCode,String variable){
+        this(new WmsHealthIndexVariableId(organizeCode,variable));
+    }
+
+    public WmsHealthIndexVariable(WmsHealthIndexVariableId id){
+        this.id = id;
+    }
+
+    /**
+     * 是否需要计算（在CRON表达式内）
+     * @param expectDifference 期待的时间差，前后多少秒
+     * @return
+     */
+    public boolean isNeedCalc(int expectDifference){
+        boolean flag = calcFrequency.verify(expectDifference);
+                flag |= calcFrequency.verify(-expectDifference);
+        return flag;
+    }
+
+    public boolean checked(){
+        return null!=value;
+    }
+
+    public void changeCalcFrequency(IWmsHealthIndexCron cron){
+        setCalcFrequency(cron);
+        setRefresh(true);
+    }
+
+    public void changeCycleRange(IWmsHealthIndexCron cron){
+        setCycleRange(cron);
+        setRefresh(true);
+    }
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/WmsHealthIndexVariableId.java

@@ -0,0 +1,23 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+import lombok.Getter;
+import lombok.Value;
+
+/**
+ * 健康度指标变量
+ */
+@Getter
+@Value
+public class WmsHealthIndexVariableId {
+
+    /**
+     * 工厂代码
+     */
+    private final String organizeCode;
+    /**
+     * 指标变量代码
+     */
+    private final String variable;
+
+
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/health/WmsHealthIndexVariableValue.java

@@ -0,0 +1,27 @@
+package cn.estsh.i3plus.pojo.wms.bean.health;
+
+import lombok.Getter;
+import lombok.Value;
+
+/**
+ * 健康度变量计算结果
+ */
+@Getter
+@Value
+public class WmsHealthIndexVariableValue {
+
+    /**
+     * 指标变量代码值
+     */
+    private final Integer value;
+
+    /**
+     * 详细信息
+     */
+    private final Object detail;
+
+
+    public static WmsHealthIndexVariableValue empty(){
+        return new WmsHealthIndexVariableValue(-1,"");
+    }
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/IWmsHealthIndexRepository.java

@@ -0,0 +1,45 @@
+package cn.estsh.i3plus.pojo.wms.repository;
+
+import cn.estsh.i3plus.pojo.wms.bean.health.WmsHealthIndexEntity;
+import cn.estsh.i3plus.pojo.wms.bean.health.WmsHealthIndexId;
+import cn.estsh.i3plus.pojo.wms.bean.health.WmsHealthIndexQuery;
+
+import java.util.List;
+import java.util.Optional;
+
+/**
+ * 健康度指标
+ */
+public interface IWmsHealthIndexRepository {
+
+    /**
+     * 查找并初始化指标信息
+     * @param id
+     * @return
+     */
+    WmsHealthIndexEntity findAndInit(WmsHealthIndexId id);
+
+    /**
+     * 获取上一次记录的健康度指标值
+     * @param id
+     * @return
+     */
+    Optional<WmsHealthIndexEntity> getLastRecord(final WmsHealthIndexId id);
+
+    /**
+     * 保存查询记录
+     * @param wmsHealthIndexEntity
+     * @param source 统计渠道
+     */
+    void save(final WmsHealthIndexEntity wmsHealthIndexEntity,String source);
+
+
+    /**
+     * 获取查询记录
+     * @param id
+     * @param param
+     * @return
+     */
+    List<WmsHealthIndexEntity> query(final WmsHealthIndexId id,
+                                     final WmsHealthIndexQuery param);
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/WmsHealthQueryRecordRepository.java

@@ -17,8 +17,7 @@ public interface WmsHealthQueryRecordRepository extends BaseRepository<WmsHealth
 	
 	int countByOrganizeCodeAndIndicatorCodeAndQueryTimeBetween(String organizeCode,String indicatorCode, Long startTime,
 			Long endTime);
-	
-	
-	Optional<WmsHealthQueryRecord> findByOrganizeCodeAndIndicatorCodeOrderByQueryTimeDesc(String organizeCode,String indicatorCode);
+
+	Optional<WmsHealthQueryRecord> findFirstByOrganizeCodeAndIndicatorCodeOrderByQueryTimeDesc(String organizeCode,String indicatorCode);
 
 }