Commit bbc068c4 by hzc

修改短板运算为异步(增加了日志)

parent 8a063d84
......@@ -148,7 +148,9 @@ public class ShortboardUnitCtrl {
@ApiOperation(value = "保存预览数据生成短板预警池数据", notes = "保存预览数据生成短板预警池数据")
@PostMapping(value = "/getShortboardWarnning")
public String getShortboardWarnning(@RequestBody ShortBoardWarnData shortBoardWarnData)throws Exception{
return shortboardUnitService.getShortboardObjFromUnit(shortBoardWarnData);
shortboardUnitService.getShortboardObjFromUnit(shortBoardWarnData);
return "运算成功";
}
@ApiOperation(value = "分页获取短板预警池数据", notes = "分页获取短板预警池数据")
......
......@@ -3,7 +3,10 @@ package com.keymobile.indicators.model.mapper.indmapper;
import com.keymobile.indicators.model.entity.shortboard.ShortBoardTaskVal;
import org.apache.ibatis.annotations.Mapper;
import tk.mybatis.mapper.common.BaseMapper;
import java.util.List;
@Mapper
public interface ShortboardTaskValMapper extends BaseMapper<ShortBoardTaskVal> {
ShortBoardTaskVal selectBYShortBoardTaskId(Integer shortBoardTaskId);
List<ShortBoardTaskVal> selectBYShortBoardTaskId(Integer shortBoardTaskId);
}
......@@ -149,7 +149,12 @@ public class ShortboardTaskService {
}
public ShortBoardTaskVal selectShortBoardTaskValByTaskIdId(Integer shortBoardTaskId) {
return shortboardTaskValMapper.selectBYShortBoardTaskId(shortBoardTaskId);
List<ShortBoardTaskVal> shortBoardTaskVals = shortboardTaskValMapper.selectBYShortBoardTaskId(shortBoardTaskId);
ShortBoardTaskVal shortBoardTaskVal = new ShortBoardTaskVal();
if(!shortBoardTaskVals.isEmpty()){
shortBoardTaskVal=shortBoardTaskVals.get(0);
}
return shortBoardTaskVal;
}
public ShortBoardTask selectShortBoardTaskById(Integer id) {
......
......@@ -7,12 +7,15 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.keymobile.indicators.constant.Constants;
import com.keymobile.indicators.model.entity.shortboard.ShortBoardWarnData;
import com.keymobile.indicators.utils.LogManager;
import com.keymobile.indicators.utils.SystemUserUtil;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import com.keymobile.indicators.model.entity.shortboard.ShortboardRecord;
......@@ -85,7 +88,11 @@ public class ShortboardUnitService {
}
//保存预览数据生成短板预警池数据
public String getShortboardObjFromUnit(ShortBoardWarnData shortBoardWarnData) throws Exception{
@Async
public void getShortboardObjFromUnit(ShortBoardWarnData shortBoardWarnData) throws Exception{
LogManager.logInfo(Constants.LOG_INDICATOR_SHORTBOARD_UNIT_API,"短板运算id={},开始运算StartTime={}",shortBoardWarnData.getId(),new Date());
List<ShortboardRecord> result = new ArrayList<>();
//ShortboardUnit shortboardUnit = this.getById(id);//根据短板单元id获取短板单元
if(shortBoardWarnData!=null) {
......@@ -128,7 +135,9 @@ public class ShortboardUnitService {
}
}
return "保存成功";
LogManager.logInfo(Constants.LOG_INDICATOR_SHORTBOARD_UNIT_API,"短板运算id={},结束运算endTime={},产生预警数据:{}条",shortBoardWarnData.getId(),new Date(),result.size());
return ;
}
//根据标识编码分页获取预警池短板数据
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment