package com.ld.igds;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.bstek.bdf2.core.controller.IController;
|
import com.ld.igds.constant.RedisConst;
|
import com.ld.igds.gas.CoreGasService;
|
import com.ld.igds.gas.dto.GasData;
|
import com.ld.igds.gas.dto.GasParam;
|
import com.ld.igds.grain.dto.GrainData;
|
import com.ld.igds.grain.dto.GrainParam;
|
import com.ld.igds.grain.service.CoreGrainService;
|
import com.ld.igds.models.WeatherConf;
|
import com.ld.igds.models.WeatherInfo;
|
import com.ld.igds.timer.WeatherScheduled;
|
import com.ld.igds.util.RedisUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 测试Action接口，支持匿名访问 方位路径：http://127.0.0.1:8080/igds/test.action?t=timer
|
*/
|
@Slf4j
|
@Component
|
public class TestAction implements IController {
|
|
@Autowired
|
private CoreGasService gasService;
|
@Autowired
|
private CoreGrainService grainService;
|
@Autowired
|
private RedisUtil redisUtil;
|
@Autowired
|
private WeatherScheduled weatherScheduled;
|
|
@Override
|
public String getUrl() {
|
return "/test";
|
}
|
|
/**
|
* 测试调用
|
*/
|
@Override
|
public void execute(HttpServletRequest request, HttpServletResponse response) {
|
String companyId = request.getParameter("companyId");
|
String t = request.getParameter("t");
|
String p1 = request.getParameter("p1");
|
String p2 = request.getParameter("p2");
|
log.debug("p1={},p2={}", p1, p2);
|
|
if (StringUtils.isEmpty(t)) {
|
return;
|
}
|
|
if ("weather".equals(t)) {
|
doTestWeather(companyId, p1, p2, response);
|
return;
|
}
|
|
// 重新更新缓存中气体信息
|
if (t.equals("cache-gas")) {
|
GasParam param = new GasParam();
|
param.setCompanyId(companyId);
|
List<GasData> list = gasService.pageQueryList(param);
|
|
if (null == list)
|
return;
|
|
for (GasData data : list) {
|
|
String key = RedisConst.buildKey(param.getCompanyId(),
|
RedisConst.KEY_GAS_DATA, data.getDepotId());
|
|
redisUtil.set(key, data);
|
}
|
|
log.info("手动执行了刷新气体缓存");
|
}
|
|
if (t.equals("cache-grain")) {
|
|
GrainParam param = new GrainParam();
|
param.setCompanyId(companyId);
|
param.setLimit(100);
|
param.setTagUpdate(false);
|
|
List<GrainData> list = grainService.listGrainData(param);
|
if (null == list || list.isEmpty())
|
return;
|
|
String key;
|
GrainData grainData;
|
for (int i = list.size() - 1; i >= 0; i--) {
|
|
grainData = list.get(i);
|
grainData.setListRows(null);
|
grainData.setListLays(null);
|
grainData.setListPoints(null);
|
|
key = RedisConst.buildKey(param.getCompanyId(),
|
RedisConst.KEY_GRAIN, grainData.getDepotId());
|
|
redisUtil.set(key, grainData);
|
}
|
|
log.info("手动执行了刷新粮情缓存");
|
}
|
if (t.equals("pressure")) {
|
// DeviceSer ser = serService.getCacheSer(companyId, p1);
|
// pressureManager.checkPressureBySer(ser);
|
}
|
|
if (t.equals("reset-out-storage")) {
|
if (null == p1) {// 仓库编码
|
return;
|
}
|
if (null == p2) {// 开始时间
|
return;
|
}
|
log.info("------initRecordCurStorageOUT--------");
|
}
|
|
if (t.equals("reset-in-storage")) {
|
if (null == p1) {// 仓库编码
|
return;
|
}
|
if (null == p2) {// 开始时间
|
return;
|
}
|
}
|
|
if (t.equals("weather11")) {
|
weatherScheduled.scheduled();
|
}
|
}
|
|
|
/**
|
* 测试气象信息
|
*
|
* @param companyId
|
* @param deptId
|
* @param response
|
* @throws IOException
|
*/
|
private void doTestWeather(String companyId, String deptId, String cityId, HttpServletResponse response) {
|
try {
|
|
if (StringUtils.isEmpty(companyId)) {
|
response.getWriter().print("MSG:ERROR,param {companyId} is null");
|
}
|
if (StringUtils.isEmpty(deptId)) {
|
response.getWriter().print("MSG:ERROR,param {deptId} is null");
|
}
|
if (StringUtils.isEmpty(cityId)) {
|
response.getWriter().print("MSG:ERROR,param {cityId} is null");
|
}
|
|
WeatherConf conf = new WeatherConf(companyId, deptId, cityId);
|
|
log.info("-----测试调用气象----deptId={},cityId={}", deptId, cityId);
|
|
Date date = new Date();
|
WeatherInfo info = weatherScheduled.getWeatherByWeb(date, conf);
|
if (null == info) {
|
response.getWriter().print("MSG:ERROR");
|
} else {
|
response.getWriter().print("MSG:SUCCESS:" + JSONObject.toJSONString(info));
|
}
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
@Override
|
public boolean anonymousAccess() {
|
return false;
|
}
|
|
@Override
|
public boolean isDisabled() {
|
return false;
|
}
|
|
}
|
