Przeglądaj źródła

修改分析状态-1:未分析 10:排队中 20:分析中 30:分析完成

chenhongyan1989 11 miesięcy temu
rodzic
commit
a2ac74f061

+ 1 - 1
energy-manage-common/src/main/java/com/energy/manage/common/po/analysis/AnalysisResultPo.java

@@ -28,7 +28,7 @@ public class AnalysisResultPo {
     private String batchCode ;
 
     /**
-     * 分析状态
+     * 分析状态 -1:未分析 10:排队中  20:分析中 30:分析完成
      */
     private Integer analysisState ;
 

+ 1 - 1
energy-manage-service/src/main/java/com/energy/manage/service/domain/dto/analysis/AnalysisResultDto.java

@@ -33,7 +33,7 @@ public class AnalysisResultDto extends BaseDto {
     private String batchName ;
 
     /**
-     * 分析状态
+     * 分析状态 -1:未分析 10:排队中  20:分析中 30:分析完成
      */
     private Integer analysisState ;
 

+ 1 - 1
energy-manage-service/src/main/java/com/energy/manage/service/domain/vo/analysis/AnalysisResultVo.java

@@ -37,7 +37,7 @@ public class AnalysisResultVo {
     private String batchName;
 
     /**
-     * 分析状态
+     * 分析状态 -1:未分析 10:排队中  20:分析中 30:分析完成
      */
     private Integer analysisState ;
 

+ 7 - 0
energy-manage-service/src/main/java/com/energy/manage/service/mappers/analysis/AnalysisResultMapper.java

@@ -52,4 +52,11 @@ public interface AnalysisResultMapper extends MyMapper<AnalysisResultPo> {
      */
     int updateOnOffCall(@Param("batchCode")String batchCode, @Param("onOffCall") Integer onOffCall);
 
+    /**
+     * 更新为排队中状态
+     * @param batchCode
+     * @return
+     */
+    int updateAnalysisState(@Param("batchCode") String batchCode);
+
 }

+ 2 - 0
energy-manage-service/src/main/java/com/energy/manage/service/service/analysis/impl/AnalysisServiceImpl.java

@@ -142,6 +142,8 @@ public class AnalysisServiceImpl implements AnalysisService {
             //调用算法
             String result = HttpUtils.doPost(algorithmProperties.getAnalysisUrl(),mapper.writeValueAsString(rootNode));
             log.info("调用算法分析返回结果:{}",result);
+            //调用分析算法接口后直接更新分析状态为排队中
+            analysisResultMapper.updateAnalysisState(analysisDto.getDataBatchNum());
             //手动操作进行操作记录添加
             if(analysisDto.getAutoOrManual().equals(AnalysisConstants.MANUAL_ANALYSIS)){
                 addOptionRecords(analysisDto.getPowerFarmID(),null,OPTION_CONTENT);

+ 9 - 1
energy-manage-service/src/main/resources/mybatis/analysis/AnalysisResultMapper.xml

@@ -41,11 +41,13 @@
         </if>
         order by result.update_time desc
     </select>
+
     <select id="selectAlasisingCount" resultType="int">
         select count(*)
         from analysis_result
-        where analysis_state = 0
+        where analysis_state in (10,20)
     </select>
+
     <select id="selectLastBatchResultByFieldCode" parameterType="java.lang.String" resultType="com.energy.manage.service.domain.vo.analysis.AnalysisResultVo">
         select result.*
         from analysis_result result
@@ -75,4 +77,10 @@
         set call_status = 1
         where batch_code = #{batchCode,jdbcType=VARCHAR}
     </update>
+
+    <update id="updateAnalysisState" parameterType="java.lang.String">
+        update analysis_result
+        set analysis_state = 10
+        where batch_code = #{batchCode,jdbcType=VARCHAR}
+    </update>
 </mapper>