Merge remote-tracking branch 'origin/dev_screen_data' into dev_temp

epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenDifficultyDataDao.xml

@@ -22,7 +22,7 @@
             AND eve.DEL_FLAG = '0'
         WHERE
             diff.DEL_FLAG = '0'
-            AND diff.PARENT_ID = #{agencyId}
+            AND diff.ALL_PARENT_IDS LIKE CONCAT('%',#{agencyId},'%')
          ORDER BY
          CASE #{type}  WHEN 'timelongest' THEN diff.EVENT_COST_TIME
                        WHEN 'mosthandled' THEN diff.EVENT_HANDLED_COUNT

epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenOrgRankDataDao.xml

@@ -17,7 +17,7 @@
             screen_org_rank_data
         WHERE
             DEL_FLAG = '0'
-            AND PARENT_ID	= #{agencyId}
+            AND all_parent_ids LIKE  CONCAT('%',#{agencyId},'%')
             AND MONTH_ID = #{monthId}
             ORDER BY
             (PARTY_TOTAL + GROUP_TOTAL + ISSUE_TOTAL + PROJECT_TOTAL + CLOSE_PROJECT_RATIO + SATISFACTION_RATIO) DESC,

epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenPartyUserRankDataDao.xml

@@ -12,7 +12,7 @@
             screen_party_user_rank_data
         WHERE
             del_flag = '0'
-            AND org_id = #{agencyId}
+            AND all_parent_ids LIKE  CONCAT('%',#{agencyId},'%')
         ORDER BY
             point_total DESC,
             user_name
@@ -30,7 +30,7 @@
             screen_party_user_rank_data
         WHERE
             DEL_FLAG = '0'
-            AND ORG_ID = #{agencyId}
+            AND all_parent_ids LIKE  CONCAT('%',#{agencyId},'%')
             AND PARTY_FLAG = '1'
         ORDER BY
             POINT_TOTAL DESC

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/CustomerGridFormDTO.java

@@ -48,4 +48,9 @@ public class CustomerGridFormDTO implements Serializable {
      * 数据更新至: yyyy|yyyyMM|yyyyMMdd(08-21新增)
      */
     private String dataEndTime;
+
+    /**
+     * 所有上级ID，用英文逗号分开(8.26新增)
+     */
+    private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/DifficultyDataFormDTO.java

@@ -94,9 +94,13 @@ public class DifficultyDataFormDTO implements Serializable {
      */
     private Integer eventHandledCount;
 
-
     /**
      * 数据更新至: yyyy|yyyyMM|yyyyMMdd(08-21新增)
      */
     private String dataEndTime;
+
+    /**
+     * 所有上级ID，用英文逗号分开(8.26新增)
+     */
+    private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/EventDataFormDTO.java

@@ -121,4 +121,9 @@ public class EventDataFormDTO implements Serializable {
      * 数据更新至: yyyy|yyyMM|yyyyMMdd  8.21增加字段
      */
     private String dataEndTime;
+
+    /**
+     * 所有上级ID，用英文逗号分开(8.26新增)
+     */
+    private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/OrgRankDataFormDTO.java

@@ -79,4 +79,9 @@ public class OrgRankDataFormDTO implements Serializable {
      * 满意率，最大值100，保留小数点后四位
      */
     private BigDecimal satisfactionRatio;
+
+    /**
+     * 所有上级ID，用英文逗号分开(8.26新增)
+     */
+    private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-client/src/main/java/com/epmet/dto/screencoll/form/PartyUserRankDataFormDTO.java

@@ -73,4 +73,9 @@ public class PartyUserRankDataFormDTO implements Serializable {
      * 名
      */
     private String name;
+
+    /**
+     * 所有上级ID，用英文逗号分开(8.26新增)
+     */
+    private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/screen/ScreenCustomerGridEntity.java

@@ -78,4 +78,8 @@ public class ScreenCustomerGridEntity extends BaseEpmetEntity {
      */
 	private String dataEndTime;
 
+	/**
+	 * 所有上级ID，用英文逗号分开(8.26新增)
+	 */
+	private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/screen/ScreenDifficultyDataEntity.java

@@ -127,4 +127,8 @@ public class ScreenDifficultyDataEntity extends BaseEpmetEntity {
      */
 	private String dataEndTime;
 
+	/**
+	 * 所有上级ID，用英文逗号分开(8.26新增)
+	 */
+	private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/screen/ScreenEventDataEntity.java

@@ -144,4 +144,8 @@ public class ScreenEventDataEntity extends BaseEpmetEntity {
      */
 	private String dataEndTime;
 
+	/**
+	 * 所有上级ID，用英文逗号分开(8.26新增)
+	 */
+	private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/screen/ScreenOrgRankDataEntity.java

@@ -109,4 +109,8 @@ public class ScreenOrgRankDataEntity extends BaseEpmetEntity {
      */
 	private BigDecimal satisfactionRatio;
 
+	/**
+	 * 所有上级ID，用英文逗号分开(8.26新增)
+	 */
+	private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/entity/screen/ScreenPartyUserRankDataEntity.java

@@ -98,4 +98,8 @@ public class ScreenPartyUserRankDataEntity extends BaseEpmetEntity {
      */
 	private String dataEndTime;
 
+	/**
+	 * 所有上级ID，用英文逗号分开(8.26新增)
+	 */
+	private String allParentIds;
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/support/normalizing/ScoreCalculator.java

@@ -79,7 +79,7 @@ public abstract class ScoreCalculator<T> {
         if (correlation == Correlation.POSITIVE) {
             // 正相关
             BigDecimal x = coefficient.multiply(convertValue2BigDecimal(sourceValue).subtract(minValue));
-            BigDecimal score = minScore.add(x, MathContext.DECIMAL32);
+            BigDecimal score = minScore.add(x);
             return score;
         } else if (correlation == Correlation.NEGATIVE) {
             // 负相关

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/support/normalizing/ScoreConstants.java

@@ -0,0 +1,13 @@
+package com.epmet.support.normalizing;
+
+import java.math.BigDecimal;
+
+/**
+ * 分值常量
+ */
+public class ScoreConstants {
+
+    public static final BigDecimal MIN_SCORE = new BigDecimal(0);
+    public static final BigDecimal MAX_SCORE = new BigDecimal(100);
+
+}

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/support/normalizing/batch/BatchScoreCalculator.java

@@ -0,0 +1,35 @@
+package com.epmet.support.normalizing.batch;
+
+import com.epmet.support.normalizing.ScoreCalculator;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.stream.Collectors;
+
+public class BatchScoreCalculator {
+
+    /**
+     * 每个指标都是一条数据，每一条数据中包含该指标的一组样本
+     */
+    private List<IndexInputVO> indexVOS;
+
+    /**
+     * 执行计算
+     * @return 每一条都是一个指标的，所有样本对应的，得分值
+     */
+    public List<IndexOutputVO> exec(List<IndexInputVO> indexVOS) {
+        this.indexVOS = indexVOS;
+
+        return indexVOS.stream().map(i -> {
+            String indexId = i.getIndexId();
+            List indexValues = i.getIndexValues();
+            BigDecimal weight = i.getWeight();
+            ScoreCalculator scoreCalculator = i.getScoreCalculator();
+
+            List scores4OneIndex = scoreCalculator.normalize(indexValues, weight);
+
+            return new IndexOutputVO(indexId, scores4OneIndex);
+        }).collect(Collectors.toList());
+    }
+
+}

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/support/normalizing/batch/IndexInputVO.java

@@ -0,0 +1,39 @@
+package com.epmet.support.normalizing.batch;
+
+import com.epmet.support.normalizing.ScoreCalculator;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class IndexInputVO<T> {
+
+    /**
+     * 指标标记，由使用者传入，用以标记该条指标的独有特性，一般用id或者code
+     * 非必填
+     */
+    private String indexId;
+
+    /**
+     * 指标的样本值
+     */
+    private List<T> indexValues;
+
+    /**
+     * 权重
+     */
+    private BigDecimal weight;
+
+    private ScoreCalculator<T> scoreCalculator;
+
+    public IndexInputVO(List<T> indexValues, BigDecimal weight, ScoreCalculator<T> scoreCalculator) {
+        this.indexValues = indexValues;
+        this.weight = weight;
+        this.scoreCalculator = scoreCalculator;
+    }
+}

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/support/normalizing/batch/IndexOutputVO.java

@@ -0,0 +1,23 @@
+package com.epmet.support.normalizing.batch;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+@Data
+@AllArgsConstructor
+public class IndexOutputVO<T> {
+
+    /**
+     * 指标标记，由使用者传入，用以标记该条指标的独有特性，一般用id或者code
+     * 非必填
+     */
+    private String indexId;
+
+    /**
+     * 指标的样本值
+     */
+    private List<BigDecimal> indexScores;
+}

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/screen/ScreenCustomerGridDao.xml

@@ -29,7 +29,8 @@
         CREATED_TIME,
         UPDATED_BY,
         UPDATED_TIME,
-        DATA_END_TIME
+        DATA_END_TIME,
+        ALL_PARENT_IDS
         ) values
         <foreach collection="list" item="item" index="index" separator=",">
             (
@@ -47,7 +48,8 @@
             now(),
             'APP_USER',
             now(),
-            #{item.dataEndTime}
+            #{item.dataEndTime},
+            #{item.allParentIds}
             )
         </foreach>
     </insert>

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/screen/ScreenDifficultyDataDao.xml

@@ -35,7 +35,8 @@
         UPDATED_BY,
         UPDATED_TIME,
         LATEST_OPERATE_DESC,
-        DATA_END_TIME
+        DATA_END_TIME,
+        ALL_PARENT_IDS
         ) values
         <foreach collection="list" item="item" index="index" separator=",">
             (
@@ -63,7 +64,8 @@
             'APP_USER',
             now(),
             #{item.latestOperateDesc},
-            #{item.dataEndTime}
+            #{item.dataEndTime},
+            #{item.allParentIds}
             )
         </foreach>
     </insert>

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/screen/ScreenEventDataDao.xml

@@ -38,7 +38,8 @@
         EVENT_STATUS_CODE,
         EVENT_STATUS_DESC,
         LATEST_OPERATE_DESC,
-        DATA_END_TIME
+        DATA_END_TIME,
+        ALL_PARENT_IDS
         ) values
         <foreach collection="list" item="item" index="index" separator=",">
             (
@@ -69,7 +70,8 @@
             #{item.eventStatusCode},
             #{item.eventStatusDesc},
             #{item.latestOperateDesc},
-            #{item.dataEndTime}
+            #{item.dataEndTime},
+            #{item.allParentIds}
             )
         </foreach>
     </insert>

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/screen/ScreenOrgRankDataDao.xml

@@ -35,7 +35,8 @@
         CREATED_BY,
         CREATED_TIME,
         UPDATED_BY,
-        UPDATED_TIME
+        UPDATED_TIME,
+        ALL_PARENT_IDS
         ) values
         <foreach collection="list" item="item" index="index" separator=",">
             (
@@ -59,7 +60,8 @@
             'APP_USER',
             now(),
             'APP_USER',
-            now()
+            now(),
+            #{item.allParentIds}
             )
         </foreach>
     </insert>

epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/screen/ScreenPartyUserRankDataDao.xml

@@ -29,7 +29,8 @@
         CREATED_TIME,
         UPDATED_BY,
         UPDATED_TIME,
-        DATA_END_TIME
+        DATA_END_TIME,
+        ALL_PARENT_IDS
         ) values
         <foreach collection="list" item="item" index="index" separator=",">
             (
@@ -51,7 +52,8 @@
             now(),
             'APP_USER',
             now(),
-            #{item.dataEndTime}
+            #{item.dataEndTime},
+            #{item.allParentIds}
             )
         </foreach>
     </insert>

epmet-module/data-statistical/data-statistical-server/src/test/java/com/epmet/stats/test/normalizing/DemoScoreCal.java

@@ -1,26 +1,29 @@
 package com.epmet.stats.test.normalizing;
 
-import com.epmet.support.normalizing.Correlation;
+import com.epmet.support.normalizing.*;
-import com.epmet.support.normalizing.DoubleScoreCalculator;
+import com.epmet.support.normalizing.batch.BatchScoreCalculator;
-import com.epmet.support.normalizing.IntegerScoreCalculator;
+import com.epmet.support.normalizing.batch.IndexInputVO;
-import com.epmet.support.normalizing.ScoreCalculator;
+import com.epmet.support.normalizing.batch.IndexOutputVO;
+import org.junit.Test;
 
 import java.math.BigDecimal;
 import java.util.Arrays;
+import java.util.List;
 
 public class DemoScoreCal {
 
     public static void main(String[] args) {
         //demoInteger();
-        demoIntegerPartical();
+        //demoIntegerPartical();
         //demoDouble();
     }
 
     /**
      * 整数类型,完整源数据列表的归一算法
      */
-    public static void demoInteger() {
+    @Test
-        Integer[] iArray = {4,8,1,3,2};
+    public void demoInteger() {
+        Integer[] iArray = {4, 8, 1, 3, 2};
         BigDecimal minScore = new BigDecimal(5);
         BigDecimal maxScore = new BigDecimal(10);
 
@@ -32,12 +35,13 @@ public class DemoScoreCal {
     /**
      * 整数类型,基于边界值的部分列表的的归一算法
      */
-    public static void demoIntegerPartical() {
+    @Test
-        Integer[] iArray = {4,1,2};
+    public void demoIntegerPartical() {
+        Integer[] iArray = {4, 1, 8};
         BigDecimal minScore = new BigDecimal(5);
         BigDecimal maxScore = new BigDecimal(10);
 
-        ScoreCalculator sc = new IntegerScoreCalculator(1, 8 ,minScore, maxScore, Correlation.NEGATIVE);
+        ScoreCalculator sc = new IntegerScoreCalculator(1, 8, minScore, maxScore, Correlation.NEGATIVE);
         BigDecimal[] scores = sc.normalize(iArray);// 此处也可以直接使用list参数的重载方法，计算阶段没有任何区别，区别在于new IntegerScoreCalculator()阶段
         Arrays.stream(scores).forEach(s -> System.out.println(s));
     }
@@ -46,7 +50,7 @@ public class DemoScoreCal {
      * double类型归一算法
      */
     public static void demoDouble() {
-        Double[] iArray = {1.9,8.9,1.0,3.0,2.0};
+        Double[] iArray = {1.9, 8.9, 1.0, 3.0, 2.0};
         BigDecimal minScore = new BigDecimal(5);
         BigDecimal maxScore = new BigDecimal(10);
 
@@ -61,6 +65,31 @@ public class DemoScoreCal {
         System.out.println(normalize2);
     }
 
+    /**
+     * 批量计算demo
+     */
+    @Test
+    public void testBatchCalculate() throws InterruptedException {
+        //{4,8,1,3,2}
+
+        // 每个指标需要单独的分支计算器，因为每个指标的最大最小值是不同的
+        ScoreCalculator<Integer> sc1 = new IntegerScoreCalculator(1, 8, ScoreConstants.MIN_SCORE, ScoreConstants.MAX_SCORE, Correlation.NEGATIVE);
+        ScoreCalculator<Integer> sc2 = new IntegerScoreCalculator(1, 8, ScoreConstants.MIN_SCORE, ScoreConstants.MAX_SCORE, Correlation.NEGATIVE);
+
+        // 每个指标的信息，包括样本列表，权重，指标标记
+        IndexInputVO<Integer> index1VO = new IndexInputVO<>("aaa", Arrays.asList(4, 1, 8), new BigDecimal(1), sc1);
+        IndexInputVO<Integer> index2VO = new IndexInputVO<>("bbb", Arrays.asList(1, 8, 3), new BigDecimal(1), sc2);
+
+        List<IndexInputVO> indexInputVOS = Arrays.asList(index1VO, index2VO);
+
+        BatchScoreCalculator batchScoreCalculator = new BatchScoreCalculator();
+        List<IndexOutputVO> result = batchScoreCalculator.exec(indexInputVOS);
+
+        System.err.println("--------------------------------");
+        result.stream().forEach(r -> System.out.println(r));
+        Thread.sleep(10);
+        System.err.println("--------------------------------");
+    }
 
 
 }