package com.panzhihua.serviceapi.biz.impl;
|
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.HttpResponse;
|
import cn.hutool.http.HttpUtil;
|
import com.alibaba.fastjson.JSONArray;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.panzhihua.common.api.LangchaoApiConstants;
|
import com.panzhihua.common.constants.TokenConstant;
|
import com.panzhihua.common.enums.LocalEventToLangChaoEventTypeEnum;
|
import com.panzhihua.common.model.dtos.api.EventFile;
|
import com.panzhihua.common.model.dtos.api.EventInfo;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.model.vos.grid.EventDetailsVO;
|
import com.panzhihua.common.model.vos.grid.EventGridDataDetailsVO;
|
import com.panzhihua.common.model.vos.grid.EventResourceVO;
|
import com.panzhihua.common.service.grid.GridService;
|
import com.panzhihua.serviceapi.biz.LcApiService;
|
import com.panzhihua.serviceapi.model.dto.LcGridData;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
import org.springframework.data.redis.core.ValueOperations;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.io.File;
|
import java.io.FileOutputStream;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* program 攀枝花智慧社区项目
|
* description 第三方浪潮市平台对接接口管理API
|
*
|
* @author manailin
|
* Date 2021-01-22 15:30
|
**/
|
@Slf4j
|
@Service
|
public class LcApiServiceImpl implements LcApiService {
|
|
@Resource
|
private GridService gridService;
|
|
@Autowired
|
private StringRedisTemplate redisTemplate;
|
|
/**
|
* 从redis获取token
|
*
|
* @return String 浪潮对接的token
|
*/
|
private String getAuthToken() {
|
ValueOperations<String, String> valueOperations = redisTemplate.opsForValue();
|
if(valueOperations.get(LangchaoApiConstants.LANG_CHAO_TOKEN) ==null){
|
saveTokenFromRemoteRequest("18080799023", "123456");
|
}
|
return valueOperations.get(LangchaoApiConstants.LANG_CHAO_TOKEN);
|
}
|
|
@Override
|
public String saveTokenFromRemoteRequest(String name, String password) {
|
if (redisTemplate.hasKey(LangchaoApiConstants.LANG_CHAO_TOKEN)) {
|
//如果redis存在token,直接返回redis存储的token
|
ValueOperations<String, String> valueOperations = redisTemplate.opsForValue();
|
return valueOperations.get(LangchaoApiConstants.LANG_CHAO_TOKEN);
|
} else {
|
//如果第一次请求浪潮的token请求,请求完成后，保存对于的token到数据库中。便于12小时内重复调用
|
HttpRequest request = HttpUtil.createPost(LangchaoApiConstants.GRID_GET_TOKEN_URL.replace("#username", name).replace("#password", password));
|
HttpResponse result = request.execute();
|
ValueOperations<String, String> valueOperations = redisTemplate.opsForValue();
|
valueOperations.set(LangchaoApiConstants.LANG_CHAO_TOKEN, result.body(), TokenConstant.EXPIRETIME, TimeUnit.MINUTES);
|
return result.toString();
|
}
|
}
|
|
@Override
|
public String getAllEventTypeList() {
|
HttpRequest request = HttpUtil.createPost(LangchaoApiConstants.GRID_EVENT_CATEGORY_URL);
|
request.auth(getAuthToken());
|
HttpResponse result = request.execute();
|
return result.body();
|
}
|
|
@Override
|
public String submitEventRegister(EventInfo eventInfo) {
|
HttpRequest request = HttpUtil.createPost(LangchaoApiConstants.GRID_REGIST_EVENT_URL);
|
request.auth(getAuthToken());
|
ObjectMapper mapper = new ObjectMapper();
|
try {
|
//对象转map
|
Map m = mapper.readValue(mapper.writeValueAsString(eventInfo), Map.class);
|
request.form(m);
|
} catch (JsonProcessingException e) {
|
log.info("方法submitEventRegister发生错误：{}",e.getMessage());
|
}
|
HttpResponse result = request.execute();
|
log.info(result.body());
|
return result.body();
|
}
|
|
@Override
|
public R submitEventRelationFile(EventFile eventFile) {
|
HttpRequest request = HttpUtil.createPost(LangchaoApiConstants.GRID_EVENT_FILE_UPLOAD_URL);
|
request.auth(getAuthToken());
|
try {
|
HttpURLConnection httpUrl = (HttpURLConnection) new URL(eventFile.getFiles()).openConnection();
|
httpUrl.connect();
|
File file = inputStreamToFile(httpUrl.getInputStream(), eventFile.getFileName());
|
request.form("files", file);
|
httpUrl.disconnect();
|
request.form("dataId", eventFile.getDataId());
|
request.form("type", eventFile.getType());
|
request.form("module", eventFile.getModule());
|
HttpResponse result = request.execute();
|
file.delete();
|
return R.ok(result.body());
|
} catch (Exception e) {
|
log.info("方法submitEventRelationFile发生错误：{}",e.getMessage());
|
}
|
return R.fail();
|
}
|
|
@Override
|
public String getEventInfoById(String eventId) {
|
HttpRequest request = HttpUtil.createPost(LangchaoApiConstants.GRID_APP_EVENT_INFO_DETAIL_URL);
|
request.auth(getAuthToken());
|
request.form("eventId", eventId);
|
HttpResponse result = request.execute();
|
return result.body();
|
}
|
|
@Override
|
public List<LcGridData> getGridListByAreaId(String areaId) {
|
HttpRequest request = HttpUtil.createPost(LangchaoApiConstants.GRID_GET_EVENT_INFO_AREA_ID_URL);
|
request.auth(getAuthToken());
|
request.form("areaId", areaId);
|
HttpResponse result = request.execute();
|
return JSONArray.parseArray(result.body(), LcGridData.class);
|
}
|
|
@Override
|
public String getGridMemberListByAreaIdOrName(String areaId) {
|
HttpRequest request = HttpUtil.createPost(LangchaoApiConstants.GRID_GET_GETALL_SEARCH_PAGE_URL);
|
request.auth(getAuthToken());
|
request.form("areaId", areaId);
|
HttpResponse result = request.execute();
|
return result.body();
|
}
|
|
@Override
|
public void automationUploadEventAndFile() {
|
List<EventDetailsVO> unUploadEventList = gridService.getUnUploadEvent();
|
unUploadEventList.forEach(eventInfoVo -> {
|
log.info("定时向浪潮服务器提交网格事件登记开始");
|
EventInfo eventInfo = new EventInfo();
|
String lcGrid = gridService.getLcGridIdByLocal(eventInfoVo.getGridId());
|
String lcGridUserId = gridService.getLcUserIdByLocalUserId(eventInfoVo.getGridMemberId().toString());
|
eventInfo.setGridId(lcGrid);
|
R grid = gridService.eventGridDataDetails(eventInfoVo.getGridId());
|
EventGridDataDetailsVO gridData = (EventGridDataDetailsVO) grid.getData();
|
eventInfo.setGridName(gridData.getGridName());
|
eventInfo.setCaseTypeCode(LocalEventToLangChaoEventTypeEnum.getCodeByName(eventInfoVo.getEventType()));
|
eventInfo.setCaseTypeName(LocalEventToLangChaoEventTypeEnum.getEventNameByCode(eventInfoVo.getEventType()));
|
eventInfo.setHappenTime(String.valueOf(eventInfoVo.getHappenTime().getTime()));
|
eventInfo.setHappenAddress(eventInfoVo.getHappenAddress());
|
String[] data = eventInfoVo.getHappentLatLng().split(",");
|
eventInfo.setLongitude(data[0]);
|
eventInfo.setLatitude(data[1]);
|
eventInfo.setCaseDescription(eventInfoVo.getEventDes());
|
eventInfo.setCaseRecordTime(String.valueOf(eventInfoVo.getCreateAt().getTime()));
|
eventInfo.setHandleType("REPORT");
|
eventInfo.setHandleDescription(eventInfoVo.getProcessDesc());
|
eventInfo.setDataId(eventInfoVo.getId().toString());
|
//获取系统网格员映射的浪潮网格员对于的用户ID
|
eventInfo.setUserId(lcGridUserId);
|
eventInfo.setHandleTime(String.valueOf(eventInfoVo.getHappenTime().getTime()));
|
eventInfo.setCaseName(eventInfoVo.getEventTitle());
|
submitEventRegister(eventInfo);
|
log.info("定时向浪潮服务器提交网格事件登记结束");
|
log.info("开始上传附件信息");
|
List<EventResourceVO> picsList = eventInfoVo.getPics();
|
uploadLcApiEventFile(eventInfoVo, picsList, "png");
|
List<EventResourceVO> audiosList = eventInfoVo.getAudios();
|
uploadLcApiEventFile(eventInfoVo, audiosList, "mp3");
|
List<EventResourceVO> videoList = eventInfoVo.getVideos();
|
uploadLcApiEventFile(eventInfoVo, videoList, "mp4");
|
log.info("结束上传附件信息");
|
gridService.updateLcUploadFlag(eventInfoVo.getId());
|
});
|
}
|
|
private void uploadLcApiEventFile(EventDetailsVO eventInfoVo, List<EventResourceVO> picsList, String type) {
|
picsList.forEach(eventResourceVO -> {
|
EventFile eventFile = new EventFile();
|
eventFile.setDataId(eventInfoVo.getId().toString());
|
eventFile.setFiles(eventResourceVO.getUrl());
|
eventFile.setType(type);
|
eventFile.setModule("event");
|
eventFile.setFileName(eventResourceVO.getResourceName());
|
submitEventRelationFile(eventFile);
|
});
|
}
|
|
/**
|
* 工具方法
|
* inputStream 转 File
|
*/
|
public static File inputStreamToFile(InputStream ins, String name) throws Exception {
|
File file = new File(System.getProperty("java.io.tmpdir") + File.separator + name);
|
log.info(System.getProperty("java.io.tmpdir") + File.separator + name);
|
if (file.exists()) {
|
return file;
|
}
|
OutputStream os = new FileOutputStream(file);
|
int bytesRead;
|
int len = 8192;
|
byte[] buffer = new byte[len];
|
while ((bytesRead = ins.read(buffer, 0, len)) != -1) {
|
os.write(buffer, 0, bytesRead);
|
}
|
os.close();
|
ins.close();
|
return file;
|
}
|
}
|
