851 lines
38 KiB
Java
851 lines
38 KiB
Java
package com.xkrs.service.impl;
|
||
|
||
import com.xkrs.common.encapsulation.PromptMessageEnum;
|
||
import com.xkrs.common.tool.TokenUtil;
|
||
import com.xkrs.dao.*;
|
||
import com.xkrs.model.entity.*;
|
||
import com.xkrs.model.qo.FirePointQo;
|
||
import com.xkrs.model.vo.AppPhotoVo;
|
||
import com.xkrs.model.vo.AppTaskBodyVo;
|
||
import com.xkrs.model.vo.GaoDeIgGeocodeVo;
|
||
import com.xkrs.service.FirePointService;
|
||
import com.xkrs.utils.*;
|
||
import org.slf4j.Logger;
|
||
import org.slf4j.LoggerFactory;
|
||
import org.springframework.cache.annotation.CacheConfig;
|
||
import org.springframework.cache.annotation.CacheEvict;
|
||
import org.springframework.cache.annotation.Cacheable;
|
||
import org.springframework.cglib.beans.BeanCopier;
|
||
import org.springframework.context.i18n.LocaleContextHolder;
|
||
import org.springframework.stereotype.Service;
|
||
import org.springframework.web.multipart.MultipartFile;
|
||
|
||
import javax.annotation.Resource;
|
||
import javax.servlet.http.HttpServletRequest;
|
||
import javax.servlet.http.HttpServletResponse;
|
||
import javax.transaction.Transactional;
|
||
import java.io.IOException;
|
||
import java.net.URLEncoder;
|
||
import java.nio.charset.StandardCharsets;
|
||
import java.text.DecimalFormat;
|
||
import java.time.LocalDate;
|
||
import java.time.LocalDateTime;
|
||
import java.time.LocalTime;
|
||
import java.util.*;
|
||
import java.util.stream.Collectors;
|
||
|
||
import static com.xkrs.common.encapsulation.OutputEncapsulation.outputEncapsulationObject;
|
||
import static com.xkrs.utils.DateTimeUtil.dateTimeToString;
|
||
import static com.xkrs.utils.XlsxUtil.downloadXlsx;
|
||
|
||
/**
|
||
* @author XinYi Song
|
||
*/
|
||
@CacheConfig(cacheNames = "FirePointServiceCache")
|
||
@Service
|
||
public class FirePointServiceImpl implements FirePointService {
|
||
|
||
public static Logger log = LoggerFactory.getLogger(FirePointServiceImpl.class);
|
||
|
||
@Resource
|
||
private FirePointDao firePointDao;
|
||
|
||
@Resource
|
||
private SettingDao settingDao;
|
||
|
||
@Resource
|
||
private ShanDongFirePointDao shanDongFirePointDao;
|
||
|
||
@Resource
|
||
private SysUserDao sysUserDao;
|
||
|
||
@Resource
|
||
private FireAndRangerDao fireAndRangerDao;
|
||
|
||
@Resource
|
||
private ForestRangerDao forestRangerDao;
|
||
|
||
@Resource
|
||
private FireTaskDao fireTaskDao;
|
||
|
||
@Resource
|
||
private JdbcUtils jdbcUtils;
|
||
|
||
@Resource
|
||
private FireTaskPhotoDao fireTaskPhotoDao;
|
||
|
||
@Resource
|
||
private CityDao cityDao;
|
||
|
||
@Resource
|
||
private CountyDao countyDao;
|
||
|
||
@Resource
|
||
private StreetDao streetDao;
|
||
|
||
@Resource
|
||
private NationwideDao nationwideDao;
|
||
|
||
@Resource
|
||
private CountyCodeWeiXinDao countyCodeWeiXinDao;
|
||
|
||
@Resource
|
||
private RelRoleAuthorityDao relRoleAuthorityDao;
|
||
|
||
@Resource
|
||
private FirePointQueryHelper firePointQueryHelper;
|
||
|
||
/**
|
||
* 添加火点信息
|
||
*
|
||
* @param firePointQo
|
||
* @return
|
||
*/
|
||
@CacheEvict(value = "FirePointServiceCache", allEntries = true)
|
||
@Override
|
||
public FirePointEntity insertFirePoint(FirePointQo firePointQo) {
|
||
if (firePointQo.getLandtype().equals("水体")) {
|
||
return null;
|
||
}
|
||
if ("Himawari 8".equals(firePointQo.getSatelliteType()) && "L".equals(firePointQo.getConfidence())) {
|
||
return null;
|
||
}
|
||
if ("Himawari 8".equals(firePointQo.getSatelliteType()) && "N".equals(firePointQo.getConfidence())) {
|
||
return null;
|
||
}
|
||
FirePointEntity firePointEntity = new FirePointEntity();
|
||
firePointEntity.setFireCode(firePointQo.getFireCode());
|
||
firePointEntity.setCountyCode(firePointQo.getCountyCode().toString());
|
||
firePointEntity.setCountyName(firePointQo.getCountyName());
|
||
firePointEntity.setSatelliteTime(DateTimeUtil.timeMillisToString(firePointQo.getSatelliteTimeTs().longValue()));
|
||
firePointEntity.setLongitude(firePointQo.getLongitude());
|
||
firePointEntity.setLatitude(firePointQo.getLatitude());
|
||
firePointEntity.setFirePointAddress(AddressUtils.getLocal(firePointQo.getLatitude().toString(), firePointQo.getLongitude().toString()));
|
||
firePointEntity.setSatelliteType(firePointQo.getSatelliteType());
|
||
firePointEntity.setLandType(firePointQo.getLandtype());
|
||
firePointEntity.setConfidence(firePointQo.getConfidence());
|
||
firePointEntity.setAddTime(dateTimeToString(LocalDateTime.now()));
|
||
firePointEntity.setFireType("0");
|
||
firePointEntity.setFireImage(firePointQo.getFireImage());
|
||
firePointEntity.setSatelliteImage(firePointQo.getSatelliteImage());
|
||
firePointEntity.setAuditFireType("0");//初始化火点为未审核状态
|
||
try {
|
||
bindStreetCodeName(firePointEntity);
|
||
} catch (Exception e) {
|
||
e.printStackTrace();
|
||
System.out.println("添加火点信息 逆地理编码请求街道编号失败：" + e.getMessage());
|
||
}
|
||
if (firePointEntity.getCountyCode().startsWith("37")) {
|
||
return null;
|
||
}
|
||
FirePointEntity existFireCode = firePointDao.findByFireCode(firePointEntity.getFireCode());
|
||
if (existFireCode != null) {
|
||
return null;
|
||
}
|
||
log.info("-------发现新火点");
|
||
return firePointDao.save(firePointEntity);
|
||
}
|
||
|
||
/**
|
||
* 添加火点信息
|
||
*
|
||
* @param firePointQo
|
||
* @return
|
||
*/
|
||
@CacheEvict(value = "FirePointServiceCache", allEntries = true)
|
||
@Override
|
||
public ShanDongFirePointEntity insertFirePointChannelTwo(FirePointQo firePointQo) {
|
||
if (firePointQo.getLandtype().equals("水体")) {
|
||
return null;
|
||
}
|
||
if ("Himawari 8".equals(firePointQo.getSatelliteType()) && "L".equals(firePointQo.getConfidence())) {
|
||
return null;
|
||
}
|
||
if ("Himawari 8".equals(firePointQo.getSatelliteType()) && "N".equals(firePointQo.getConfidence())) {
|
||
return null;
|
||
}
|
||
ShanDongFirePointEntity shanDongFirePoint = new ShanDongFirePointEntity();
|
||
shanDongFirePoint.setFireCode(firePointQo.getFireCode());
|
||
shanDongFirePoint.setCountyCode(firePointQo.getCountyCode().toString());
|
||
shanDongFirePoint.setCountyName(firePointQo.getCountyName());
|
||
shanDongFirePoint.setSatelliteTime(DateTimeUtil.timeMillisToString(firePointQo.getSatelliteTimeTs().longValue()));
|
||
shanDongFirePoint.setLongitude(firePointQo.getLongitude());
|
||
shanDongFirePoint.setLatitude(firePointQo.getLatitude());
|
||
shanDongFirePoint.setFirePointAddress(AddressUtils.getLocal(firePointQo.getLatitude().toString(), firePointQo.getLongitude().toString()));
|
||
shanDongFirePoint.setSatelliteType(firePointQo.getSatelliteType());
|
||
shanDongFirePoint.setLandType(firePointQo.getLandtype());
|
||
shanDongFirePoint.setConfidence(firePointQo.getConfidence());
|
||
shanDongFirePoint.setAddTime(dateTimeToString(LocalDateTime.now()));
|
||
shanDongFirePoint.setFireType("0");
|
||
shanDongFirePoint.setFireImage(firePointQo.getFireImage());
|
||
shanDongFirePoint.setSatelliteImage(firePointQo.getSatelliteImage());
|
||
shanDongFirePoint.setVerifyState("0");
|
||
try {
|
||
bindStreetCodeName(shanDongFirePoint);
|
||
} catch (Exception e) {
|
||
e.printStackTrace();
|
||
System.out.println("添加山东火点信息 逆地理编码请求街道编号失败：" + e.getMessage());
|
||
}
|
||
//如果是山东的点，就入库
|
||
if (shanDongFirePoint.getCountyCode().startsWith("37")) {
|
||
if (isSwitchStateOpen()) {
|
||
//如果开关已打开，就只将未审核的火点添加到山东临时表
|
||
if (shanDongFirePointDao.findByFireCode(shanDongFirePoint.getFireCode()) != null) {
|
||
//山东临时表已经有编号相同的火点存在，返回添加失败
|
||
return null;
|
||
}
|
||
log.info("-------发现新山东火点");
|
||
ShanDongFirePointEntity savedShanDongFirePoint = shanDongFirePointDao.save(shanDongFirePoint);
|
||
try {//微信消息通知火点审核工作组
|
||
String messageContent = getMessageContent(savedShanDongFirePoint);
|
||
WDWxSendMsgUtil.sendMsg("18447024917@chatroom", messageContent, 0);
|
||
} catch (Exception e) {
|
||
e.printStackTrace();
|
||
}
|
||
return savedShanDongFirePoint;
|
||
} else {
|
||
//如果开关已关闭，就将火点添加到山东临时表，同时自动审核通过添加到全国火点表
|
||
if (shanDongFirePointDao.findByFireCode(shanDongFirePoint.getFireCode()) != null) {
|
||
//山东临时表已经有编号相同的火点存在，返回添加失败
|
||
return null;
|
||
}
|
||
if (firePointDao.findByFireCode(shanDongFirePoint.getFireCode()) != null) {
|
||
//全国火点表已经有编号相同的火点存在，返回添加失败
|
||
return null;
|
||
}
|
||
log.info("-------发现新火点");
|
||
shanDongFirePoint.setVerifyState("1");
|
||
ShanDongFirePointEntity savedShanDongFirePoint = shanDongFirePointDao.save(shanDongFirePoint);
|
||
|
||
FirePointEntity firePoint = getFirePointByShanDongFirePoint(shanDongFirePoint);
|
||
log.info("-------转存新火点");
|
||
firePointDao.save(firePoint);
|
||
//发送消息通知
|
||
sendBroadcast(firePoint);
|
||
return savedShanDongFirePoint;
|
||
}
|
||
}
|
||
return null;
|
||
}
|
||
|
||
/**
|
||
* 根据山东火点生成全国火点
|
||
*/
|
||
private FirePointEntity getFirePointByShanDongFirePoint(ShanDongFirePointEntity shanDongFirePoint) {
|
||
FirePointEntity firePoint = new FirePointEntity();
|
||
firePoint.setFireCode(shanDongFirePoint.getFireCode());
|
||
firePoint.setCountyCode(shanDongFirePoint.getCountyCode());
|
||
firePoint.setCountyName(shanDongFirePoint.getCountyName());
|
||
firePoint.setSatelliteTime(shanDongFirePoint.getSatelliteTime());
|
||
firePoint.setLongitude(shanDongFirePoint.getLongitude());
|
||
firePoint.setLatitude(shanDongFirePoint.getLatitude());
|
||
firePoint.setFirePointAddress(shanDongFirePoint.getFirePointAddress());
|
||
firePoint.setSatelliteType(shanDongFirePoint.getSatelliteType());
|
||
firePoint.setLandType(shanDongFirePoint.getLandType());
|
||
firePoint.setConfidence(shanDongFirePoint.getConfidence());
|
||
firePoint.setAddTime(shanDongFirePoint.getAddTime());
|
||
firePoint.setFireType(shanDongFirePoint.getFireType());
|
||
firePoint.setFireImage(shanDongFirePoint.getFireImage());
|
||
firePoint.setSatelliteImage(shanDongFirePoint.getSatelliteImage());
|
||
firePoint.setStreetCode(shanDongFirePoint.getStreetCode());
|
||
firePoint.setStreetName(shanDongFirePoint.getStreetName());
|
||
firePoint.setAuditFireType("0");//初始化火点为未审核状态
|
||
return firePoint;
|
||
}
|
||
|
||
/**
|
||
* 返回开关是否为打开状态
|
||
*
|
||
* @return true：已打开，false：已关闭
|
||
*/
|
||
private boolean isSwitchStateOpen() {
|
||
List<SettingEntity> settingEntityList = settingDao.findAll();
|
||
if (settingEntityList.isEmpty()) {
|
||
return false;
|
||
}
|
||
SettingEntity settingEntity = settingEntityList.get(0);
|
||
return "1".equals(settingEntity.getSwitchState());
|
||
}
|
||
|
||
/**
|
||
* 为实体类设置街道编号和街道名称
|
||
*/
|
||
private void bindStreetCodeName(FirePointEntity firePointEntity) throws Exception {
|
||
List<String> locationList = new ArrayList<>();
|
||
locationList.add(firePointEntity.getLongitude() + "," + firePointEntity.getLatitude());
|
||
GaoDeIgGeocodeVo geocode = GaoDeApiUtil.geocode(locationList);
|
||
String townCode = geocode.getRegeocodes().get(0).getAddressComponent().get(0).getTowncode();
|
||
if (townCode.length() > 9) {
|
||
townCode = townCode.substring(0, 9);
|
||
}
|
||
firePointEntity.setStreetCode(townCode);
|
||
List<StreetEntity> byStreetCode = streetDao.findByStreetCode(townCode);
|
||
if (byStreetCode != null && byStreetCode.size() > 0) {
|
||
firePointEntity.setStreetName(byStreetCode.get(0).getStreetName());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 为实体类设置街道编号和街道名称
|
||
*/
|
||
private void bindStreetCodeName(ShanDongFirePointEntity firePointEntity) throws Exception {
|
||
List<String> locationList = new ArrayList<>();
|
||
locationList.add(firePointEntity.getLongitude() + "," + firePointEntity.getLatitude());
|
||
GaoDeIgGeocodeVo geocode = GaoDeApiUtil.geocode(locationList);
|
||
String townCode = geocode.getRegeocodes().get(0).getAddressComponent().get(0).getTowncode();
|
||
if (townCode.length() > 9) {
|
||
townCode = townCode.substring(0, 9);
|
||
}
|
||
firePointEntity.setStreetCode(townCode);
|
||
List<StreetEntity> byStreetCode = streetDao.findByStreetCode(townCode);
|
||
if (byStreetCode != null && byStreetCode.size() > 0) {
|
||
firePointEntity.setStreetName(byStreetCode.get(0).getStreetName());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 根据火点编号更新审核状态
|
||
* 操作1：将火点编号对应的火点从山东火点表转存到火点表
|
||
* 操作2：将山东火点表中的这个火点的审核状态更新
|
||
*/
|
||
@Transactional(rollbackOn = Exception.class)
|
||
@Override
|
||
public String updateVerifyStateByFireCode(String fireCode, String verifyState) {
|
||
// 获取区域信息
|
||
Locale locale = LocaleContextHolder.getLocale();
|
||
if ((!"0".equals(verifyState)) && (!"1".equals(verifyState)) && (!"2".equals(verifyState))) {
|
||
return outputEncapsulationObject(PromptMessageEnum.PARAM_ILLEGAL, "审核失败，审核状态参数错误", locale);
|
||
}
|
||
ShanDongFirePointEntity existShanDongFirePoint = shanDongFirePointDao.findByFireCode(fireCode);
|
||
//山东火点表找不到这个火点，返回失败
|
||
if (existShanDongFirePoint == null) {
|
||
return outputEncapsulationObject(PromptMessageEnum.PROCESS_FAIL, "审核失败，没有指定的火点编号", locale);
|
||
}
|
||
if ("0".equals(existShanDongFirePoint.getVerifyState())) {
|
||
if ("0".equals(verifyState)) {
|
||
return outputEncapsulationObject(PromptMessageEnum.PROCESS_FAIL, "审核失败，审核状态不能被设置为未审核", locale);
|
||
}
|
||
if ("1".equals(verifyState)) {
|
||
//火点表能找到这个火点，返回失败
|
||
FirePointEntity existFirePoint = firePointDao.findByFireCode(fireCode);
|
||
if (existFirePoint != null) {
|
||
return outputEncapsulationObject(PromptMessageEnum.PROCESS_FAIL, "修改失败，火点库已存在指定的火点编号", locale);
|
||
}
|
||
//操作1：将火点编号对应的火点从山东火点表转存到火点表
|
||
FirePointEntity firePoint = getFirePointByShanDongFirePoint(existShanDongFirePoint);
|
||
log.info("-------转存新火点");
|
||
firePointDao.save(firePoint);
|
||
//发送消息通知
|
||
sendBroadcast(firePoint);
|
||
}
|
||
//操作2：将山东火点表中的这个火点的审核状态更新
|
||
shanDongFirePointDao.updateVerifyStateByFireCode(fireCode, verifyState);
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, "修改成功", locale);
|
||
}
|
||
return outputEncapsulationObject(PromptMessageEnum.PROCESS_FAIL, "审核失败，火点不能被重复审核", locale);
|
||
}
|
||
|
||
private void sendBroadcast(FirePointEntity firePointEntity) {
|
||
//发送微信消息
|
||
sendWeiXinMessage(firePointEntity);
|
||
//发送短信消息
|
||
sendSMSMessage(firePointEntity);
|
||
}
|
||
|
||
/**
|
||
* 发送微信消息
|
||
*
|
||
* @param firePointEntity
|
||
*/
|
||
private void sendWeiXinMessage(FirePointEntity firePointEntity) {
|
||
List<CountyCodeWeiXinEntity> countyCodeWeiXinList = countyCodeWeiXinDao.findAll();
|
||
if (countyCodeWeiXinList.isEmpty()) {
|
||
return;
|
||
}
|
||
List<String> weixinIdList = new ArrayList<>();
|
||
for (CountyCodeWeiXinEntity countyCodeWeiXin : countyCodeWeiXinList) {
|
||
try {
|
||
String codeNotZeroEnd = FirePointCodeUtils.getCodeNotZeroEnd(countyCodeWeiXin.getCountyCode());
|
||
if (firePointEntity.getStreetCode().startsWith(codeNotZeroEnd)) {
|
||
weixinIdList.add(countyCodeWeiXin.getWeixinId());
|
||
}
|
||
} catch (Exception e) {
|
||
e.printStackTrace();
|
||
}
|
||
}
|
||
if (weixinIdList.size() > 0) {
|
||
String messageContent = getMessageContent(firePointEntity);
|
||
for (String weixinId : weixinIdList) {
|
||
try {
|
||
WDWxSendMsgUtil.sendMsg(weixinId, messageContent, 0);
|
||
} catch (Exception e) {
|
||
e.printStackTrace();
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
private String getMessageContent(FirePointEntity firePointEntity) {
|
||
java.text.DecimalFormat decimalFormat = new DecimalFormat("#.000000");
|
||
String satelliteTime = firePointEntity.getSatelliteTime();
|
||
String formatLongitude = decimalFormat.format(firePointEntity.getLongitude());
|
||
String formatLatitude = decimalFormat.format(firePointEntity.getLatitude());
|
||
String countyName = firePointEntity.getCountyName();
|
||
String streetName = firePointEntity.getStreetName();
|
||
String content = firePointEntity.getSatelliteType() + "发现1个火点。\n卫星时间：" + satelliteTime + "；\nlongitude：" + formatLongitude + "；\nlatitude：" + formatLatitude + "；\ncountyName：" + countyName + "；\nstreetName：" + streetName;
|
||
return content;
|
||
}
|
||
|
||
private String getMessageContent(ShanDongFirePointEntity firePointEntity) {
|
||
java.text.DecimalFormat decimalFormat = new DecimalFormat("#.000000");
|
||
String satelliteTime = firePointEntity.getSatelliteTime();
|
||
String formatLongitude = decimalFormat.format(firePointEntity.getLongitude());
|
||
String formatLatitude = decimalFormat.format(firePointEntity.getLatitude());
|
||
String countyName = firePointEntity.getCountyName();
|
||
String streetName = firePointEntity.getStreetName();
|
||
String content = firePointEntity.getSatelliteType() + "发现1个待审核火点。\n卫星时间：" + satelliteTime + "；\nlongitude：" + formatLongitude + "；\nlatitude：" + formatLatitude + "；\ncountyName：" + countyName + "；\nstreetName：" + streetName;
|
||
return content;
|
||
}
|
||
|
||
/**
|
||
* 发送短信消息
|
||
*
|
||
* @param firePointEntity
|
||
*/
|
||
private void sendSMSMessage(FirePointEntity firePointEntity) {
|
||
List<SysUserEntity> sysUserList = sysUserDao.findAll();
|
||
if (sysUserList.isEmpty()) {
|
||
return;
|
||
}
|
||
List<RelRoleAuthorityEntity> administratorList = relRoleAuthorityDao.selectByAuthorityId(1);
|
||
List<String> telephoneList = new ArrayList<>();
|
||
for (SysUserEntity sysUser : sysUserList) {
|
||
try {
|
||
String codeNotZeroEnd = FirePointCodeUtils.getCodeNotZeroEnd(sysUser.getCountyCode());
|
||
if (firePointEntity.getStreetCode().startsWith(codeNotZeroEnd)) {
|
||
if (sysUser.getDeleteFlag() != 0) {//被删除的用户不发短信
|
||
continue;
|
||
}
|
||
if (sysUser.getActiveFlag() != 0) {//被禁用的用户不发短信
|
||
continue;
|
||
}
|
||
if (sysUser.getReceiveSms() != 1) {//关掉开关的用户不发短信
|
||
continue;
|
||
}
|
||
LocalDateTime sysUserOverDateTime = DateTimeUtil.stringToDateTimeFormatter(sysUser.getOverTime(), DateTimeUtil.COMMON_FORMATTER_DATETIME);
|
||
if (sysUserOverDateTime.isBefore(DateTimeUtil.getNowTime())) {//过期用户不发短信
|
||
continue;
|
||
}
|
||
if (isAdministrator(administratorList, sysUser)) {//管理员用户不发短信
|
||
continue;
|
||
}
|
||
telephoneList.add("86" + sysUser.getUserName());
|
||
}
|
||
} catch (Exception e) {
|
||
e.printStackTrace();
|
||
}
|
||
}
|
||
if (telephoneList.size() > 0) {
|
||
String[] telephoneArray = telephoneList.toArray(new String[]{});
|
||
SendSms.sendSmsToUser(telephoneArray, "1425995", new String[]{firePointEntity.getFirePointAddress()});
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 判断是否是管理员
|
||
*/
|
||
private boolean isAdministrator(List<RelRoleAuthorityEntity> administratorList, SysUserEntity sysUser) {
|
||
if (administratorList == null || administratorList.size() == 0) {
|
||
return false;
|
||
}
|
||
for (RelRoleAuthorityEntity administrator : administratorList) {
|
||
if (administrator.getUserId().intValue() == sysUser.getId().intValue()) {
|
||
return true;
|
||
}
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 下载VIP用户火点数据
|
||
*/
|
||
@Override
|
||
public String downloadVipUserFilePoint(HttpServletRequest request, HttpServletResponse response) {
|
||
LocalDate now = LocalDate.now();
|
||
List<Map<String, String>> list = firePointDao.downloadFirePointByVip(dateTimeToString(LocalDateTime.of(now.minusDays(1), LocalTime.MIN)));
|
||
if (list.size() == 0) {
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, "无数据!", LocaleContextHolder.getLocale());
|
||
}
|
||
int year = now.getYear();
|
||
int month = now.getMonth().getValue();
|
||
int day = now.getDayOfMonth();
|
||
String fileName = String.format("%s_%s_%s_VIP用户火点信息列表.xlsx", year, month, day);
|
||
response.setContentType("application/octet-stream; charset=UTF8");
|
||
response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(fileName, StandardCharsets.UTF_8));
|
||
response.setHeader("Access-Control-Expose-Headers", "Content-Disposition");
|
||
try {
|
||
downloadXlsx(list, response.getOutputStream());
|
||
} catch (IOException e) {
|
||
log.error("download vip user's fire point fail: {}", e.getMessage());
|
||
}
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, "ok", LocaleContextHolder.getLocale());
|
||
}
|
||
|
||
/**
|
||
* 查询今天的火点信息
|
||
*/
|
||
@Cacheable(keyGenerator = "keyGenerator", unless = "#result == null")
|
||
@Override
|
||
public List<FirePointEntity> selectTodayFirePoint(String countyCode) {
|
||
|
||
LocalDateTime startTime1 = LocalDateTime.now();
|
||
LocalDateTime startTime2 = LocalDateTime.of(startTime1.getYear(), startTime1.getMonth(), startTime1.getDayOfMonth(), 0, 0, 0, 0);
|
||
String startTimeString = DateTimeUtils.localDateTimeToString(startTime2);
|
||
|
||
LocalDateTime endTime1 = LocalDateTime.now();
|
||
LocalDateTime endTime2 = LocalDateTime.of(endTime1.getYear(), endTime1.getMonth(), endTime1.getDayOfMonth() + 1, 0, 0, 0, 0);
|
||
String endTimeString = DateTimeUtils.localDateTimeToString(endTime2);
|
||
|
||
return firePointQueryHelper.queryFirePoint(countyCode, startTimeString, endTimeString, null, null);
|
||
}
|
||
|
||
/**
|
||
* 查询近一周的火点信息
|
||
*/
|
||
@Cacheable(keyGenerator = "keyGenerator", unless = "#result == null")
|
||
@Override
|
||
public List<FirePointEntity> selectFirePointBetweenSeven() {
|
||
|
||
LocalDateTime startTime1 = LocalDateTime.now().minusDays(7);
|
||
LocalDateTime startTime2 = LocalDateTime.of(startTime1.getYear(), startTime1.getMonth(), startTime1.getDayOfMonth(), 0, 0, 0, 0);
|
||
String startTimeString = DateTimeUtils.localDateTimeToString(startTime2);
|
||
|
||
LocalDateTime endTime1 = LocalDateTime.now();
|
||
LocalDateTime endTime2 = LocalDateTime.of(endTime1.getYear(), endTime1.getMonth(), endTime1.getDayOfMonth() + 1, 0, 0, 0, 0);
|
||
String endTimeString = DateTimeUtils.localDateTimeToString(endTime2);
|
||
|
||
return firePointQueryHelper.queryFirePoint(null, startTimeString, endTimeString, null, null);
|
||
}
|
||
|
||
/**
|
||
* 查询近一个月的火点信息
|
||
*/
|
||
@Cacheable(keyGenerator = "keyGenerator", unless = "#result == null")
|
||
@Override
|
||
public List<FirePointEntity> selectFirePointByMonth(String countyCode) {
|
||
|
||
LocalDateTime startTime1 = LocalDateTime.now().minusMonths(1);
|
||
LocalDateTime startTime2 = LocalDateTime.of(startTime1.getYear(), startTime1.getMonth(), startTime1.getDayOfMonth(), 0, 0, 0, 0);
|
||
String startTimeString = DateTimeUtils.localDateTimeToString(startTime2);
|
||
|
||
LocalDateTime endTime1 = LocalDateTime.now();
|
||
LocalDateTime endTime2 = LocalDateTime.of(endTime1.getYear(), endTime1.getMonth(), endTime1.getDayOfMonth() + 1, 0, 0, 0, 0);
|
||
String endTimeString = DateTimeUtils.localDateTimeToString(endTime2);
|
||
|
||
return firePointQueryHelper.queryFirePoint(countyCode, startTimeString, endTimeString, null, null);
|
||
}
|
||
|
||
/**
|
||
* 根据火点编码修改火点的状态（预警）
|
||
*
|
||
* @param fireCode
|
||
* @param fireType
|
||
* @param token
|
||
* @return
|
||
*/
|
||
@Transactional(rollbackOn = Exception.class)
|
||
@Override
|
||
public String updateTypeByFireCode(String fireCode, String fireType, String token) {
|
||
// 获取区域信息
|
||
Locale locale = LocaleContextHolder.getLocale();
|
||
String tokenUserName = TokenUtil.getTokenUserName(token);
|
||
SysUserEntity sysUserEntity = sysUserDao.selectByUserName(tokenUserName);
|
||
FirePointEntity byFireCode = firePointDao.findByFireCode(fireCode);
|
||
if ("3".equals(byFireCode.getFireType()) || "-1".equals(byFireCode.getFireType())) {
|
||
return outputEncapsulationObject(PromptMessageEnum.PROCESS_FAIL, "该火点已经结案，请勿进行有关状态操作", locale);
|
||
}
|
||
if (fireType.equals(byFireCode.getFireType())) {
|
||
return outputEncapsulationObject(PromptMessageEnum.PROCESS_FAIL, "您正处于当前的状态，请勿进行该操作", locale);
|
||
}
|
||
firePointDao.updateFireTypeByFireCode(fireCode, fireType);
|
||
if ("1".equals(fireType)) {
|
||
FirePointEntity byFireCode1 = firePointDao.findByFireCode(fireCode);
|
||
// 预警
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, byFireCode1, locale);
|
||
} else if ("2".equals(fireType)) {
|
||
FirePointEntity byFireCode3 = firePointDao.findByFireCode(fireCode);
|
||
// 核查
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, byFireCode3, locale);
|
||
} else {
|
||
String rangerType = "0";
|
||
FireAndRanger byFireCode1 = fireAndRangerDao.findByFireCode(fireCode);
|
||
if (byFireCode1 == null) {
|
||
FirePointEntity byFireCode4 = firePointDao.findByFireCode(fireCode);
|
||
String time = dateTimeToString(LocalDateTime.now());
|
||
FireAndRanger fireAndRanger = new FireAndRanger();
|
||
fireAndRanger.setFireCode(fireCode);
|
||
// 由于测试阶段先用用户账号代替，后期换成getReallyName(用户真实姓名)
|
||
fireAndRanger.setHandler(sysUserEntity.getReallyName());
|
||
fireAndRanger.setEndTime(time);
|
||
fireAndRangerDao.save(fireAndRanger);
|
||
// 结案
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, byFireCode4, locale);
|
||
}
|
||
// 火点结案，将护林员的状态修改为0 表示该护林员没有在执行任务，处于空闲状态
|
||
forestRangerDao.updateRangerTypeByPhone(byFireCode1.getRangerName(), rangerType);
|
||
String time = dateTimeToString(LocalDateTime.now());
|
||
fireAndRangerDao.updateEndTimeByFireCode(fireCode, time);
|
||
fireAndRangerDao.updateProgressTypeByFireCode(fireCode, "0");
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, "结案", locale);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 提交核查任务
|
||
*
|
||
* @param files
|
||
* @param appTaskBodyVo
|
||
* @return
|
||
*/
|
||
@Transactional(rollbackOn = Exception.class)
|
||
@Override
|
||
public String insertAppTask(MultipartFile[] files, AppTaskBodyVo appTaskBodyVo) throws IOException {
|
||
// 获取区域信息
|
||
Locale locale = LocaleContextHolder.getLocale();
|
||
FirePointEntity byFireCode = firePointDao.findByFireCode(appTaskBodyVo.getFireCode());
|
||
if (byFireCode == null) {
|
||
return outputEncapsulationObject(PromptMessageEnum.DATA_WRONG, "火点编码错误，请重新输入", locale);
|
||
}
|
||
FireTask byTaskFireCode = fireTaskDao.findByTaskFireCode(appTaskBodyVo.getFireCode());
|
||
if (byTaskFireCode != null) {
|
||
return outputEncapsulationObject(PromptMessageEnum.PROCESS_FAIL, "该火点的任务已经提交，请勿重复提交", locale);
|
||
}
|
||
String s = dateTimeToString(LocalDateTime.now());
|
||
FireTask fireTask = new FireTask();
|
||
fireTask.setTaskFireCode(appTaskBodyVo.getFireCode());
|
||
fireTask.setTaskInformation(appTaskBodyVo.getTaskInformation());
|
||
fireTask.setTaskTime(s);
|
||
FireTask save = fireTaskDao.save(fireTask);
|
||
if (save == null) {
|
||
return outputEncapsulationObject(PromptMessageEnum.PROCESS_FAIL, "任务提交失败", locale);
|
||
}
|
||
List<FireTaskPhoto> fireTaskPhotos = PhotoUtil.uploadImage(files, appTaskBodyVo.getFireCode());
|
||
List<FireTaskPhoto> fireTaskPhotos1 = fireTaskPhotoDao.saveAll(fireTaskPhotos);
|
||
if (fireTaskPhotos1 == null || fireTaskPhotos1.size() == 0) {
|
||
return outputEncapsulationObject(PromptMessageEnum.PROCESS_FAIL, "图片上传失败，任务提交失败", locale);
|
||
}
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, "任务提交成功", locale);
|
||
}
|
||
|
||
/**
|
||
* 根据火点编码查询任务信息
|
||
*
|
||
* @param fireCode
|
||
* @return
|
||
* @throws Exception
|
||
*/
|
||
@Override
|
||
public String selectAppTask(String fireCode) throws Exception {
|
||
// 获取区域信息
|
||
Locale locale = LocaleContextHolder.getLocale();
|
||
FireTask byTaskFireCode = fireTaskDao.findByTaskFireCode(fireCode);
|
||
if (byTaskFireCode == null) {
|
||
return outputEncapsulationObject(PromptMessageEnum.DATA_NONE, "暂时还没有该火点的任务信息", locale);
|
||
}
|
||
AppTaskBodyVo appTaskBodyVo = new AppTaskBodyVo();
|
||
// 做映射，返回vo类对象
|
||
BeanCopier beanCopier = BeanCopier.create(FireTask.class, AppTaskBodyVo.class, false);
|
||
beanCopier.copy(byTaskFireCode, appTaskBodyVo, null);
|
||
|
||
List<Object[]> photoPath = fireTaskPhotoDao.findPhotoPath(fireCode);
|
||
List<AppPhotoVo> appPhotoVos = ObjectToBeanUtils.objectToBean(photoPath, AppPhotoVo.class);
|
||
appTaskBodyVo.setTaskFirePhoto(appPhotoVos);
|
||
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, appTaskBodyVo, locale);
|
||
}
|
||
|
||
/**
|
||
* 查询近一个月的火点数量
|
||
*
|
||
* @return
|
||
*/
|
||
@Cacheable(keyGenerator = "keyGenerator", unless = "#result == null")
|
||
@Override
|
||
public String selectFirePointNumMonth() {
|
||
// 获取区域信息
|
||
Locale locale = LocaleContextHolder.getLocale();
|
||
Map map = new HashMap(3);
|
||
LocalDateTime localDateTime = LocalDateTime.now();
|
||
LocalDateTime localDateTime2 = localDateTime.plusDays(1);
|
||
String endTime = dateTimeToString(localDateTime2);
|
||
// 当前时间减30
|
||
LocalDateTime localDateTime1 = localDateTime.minusDays(30);
|
||
String startTime = dateTimeToString(localDateTime1);
|
||
// 查询近一个月各植被类型的火点数量
|
||
List<Map<String, Object>> maps = firePointDao.selectNumByLandType(startTime, endTime);
|
||
map.put("land", maps);
|
||
// 查询近一个月各地区火点数量
|
||
List<Map<String, Object>> maps1 = firePointDao.selectNumByArea(startTime, endTime);
|
||
map.put("area", maps1);
|
||
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, map, locale);
|
||
}
|
||
|
||
/**
|
||
* 查询近一天的火点数量
|
||
*
|
||
* @return
|
||
*/
|
||
@Cacheable(keyGenerator = "keyGenerator", unless = "#result == null")
|
||
@Override
|
||
public String selectFirePointNumDay() {
|
||
// 获取区域信息
|
||
Locale locale = LocaleContextHolder.getLocale();
|
||
Map map = new HashMap(3);
|
||
LocalDateTime localDateTime = LocalDateTime.now();
|
||
LocalDateTime localDateTime2 = localDateTime.plusDays(1);
|
||
String endTime = dateTimeToString(localDateTime2);
|
||
// 当前时间减1
|
||
LocalDateTime localDateTime1 = localDateTime.minusDays(1);
|
||
String startTime = dateTimeToString(localDateTime1);
|
||
// 查询近一个月各植被类型的火点数量
|
||
List<Map<String, Object>> maps = firePointDao.selectNumByLandType(startTime, endTime);
|
||
map.put("land", maps);
|
||
// 查询近一个月各地区火点数量
|
||
List<Map<String, Object>> maps1 = firePointDao.selectNumByArea(startTime, endTime);
|
||
map.put("area", maps1);
|
||
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, map, locale);
|
||
}
|
||
|
||
/**
|
||
* 查询近一周的火点数量
|
||
*
|
||
* @return
|
||
*/
|
||
@Cacheable(keyGenerator = "keyGenerator", unless = "#result == null")
|
||
@Override
|
||
public String selectFirePointNumWeek() {
|
||
// 获取区域信息
|
||
Locale locale = LocaleContextHolder.getLocale();
|
||
Map map = new HashMap(3);
|
||
LocalDateTime localDateTime = LocalDateTime.now();
|
||
LocalDateTime localDateTime2 = localDateTime.plusDays(1);
|
||
String endTime = dateTimeToString(localDateTime2);
|
||
// 当前时间减7
|
||
LocalDateTime localDateTime1 = localDateTime.minusDays(7);
|
||
String startTime = dateTimeToString(localDateTime1);
|
||
// 查询近一个月各植被类型的火点数量
|
||
List<Map<String, Object>> maps = firePointDao.selectNumByLandType(startTime, endTime);
|
||
map.put("land", maps);
|
||
// 查询近一个月各地区火点数量
|
||
List<Map<String, Object>> maps1 = firePointDao.selectNumByArea(startTime, endTime);
|
||
map.put("area", maps1);
|
||
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, map, locale);
|
||
}
|
||
|
||
/**
|
||
* 查询该省所有的市
|
||
*
|
||
* @param code
|
||
* @return
|
||
*/
|
||
@Override
|
||
public List<Map<String, Object>> selectCityName(String code) {
|
||
return cityDao.selectCityName(code);
|
||
}
|
||
|
||
/**
|
||
* 查询市包含的区县和编码
|
||
*
|
||
* @param code
|
||
* @return
|
||
*/
|
||
@Override
|
||
public List<Map<String, Object>> selectCountyName(String code) {
|
||
return countyDao.selectCountyName(code);
|
||
}
|
||
|
||
/**
|
||
* 导入全国省市区
|
||
*
|
||
* @param file
|
||
* @throws Exception
|
||
*/
|
||
@Transactional(rollbackOn = Exception.class)
|
||
@Override
|
||
public void importCityExcel(MultipartFile file) throws Exception {
|
||
//调用封装好的工具
|
||
ExcelImportUtil importUtil = new ExcelImportUtil(file);
|
||
//调用导入的方法，获取sheet表的内容
|
||
List<Map<String, String>> maps = importUtil.readExcelContent();
|
||
//导入订单详情表
|
||
List<Nationwide> orderDetails = maps.stream().filter(Objects::nonNull).map(map -> {
|
||
Nationwide nationwide = new Nationwide();
|
||
nationwide.setProName(map.get("pro_name"));
|
||
nationwide.setProCode(map.get("pro_code"));
|
||
nationwide.setCityName(map.get("city_name"));
|
||
nationwide.setCityCode(map.get("city_code"));
|
||
nationwide.setCountyName(map.get("town_name"));
|
||
nationwide.setCountyCode(map.get("town_code"));
|
||
return nationwide;
|
||
}).collect(Collectors.toList());
|
||
//批量添加到订单详情
|
||
nationwideDao.saveAll(orderDetails);
|
||
}
|
||
|
||
/**
|
||
* 更新火点的街道编号数据
|
||
*
|
||
* @return
|
||
*/
|
||
@Override
|
||
public String updateFirePointStreetCode() {
|
||
System.out.println("开始格式化街道编号");
|
||
List<FirePointEntity> firePointEntityList = firePointDao.selectAbnormalStreetCode();
|
||
long startTimeMillis = System.currentTimeMillis();
|
||
int listSize = firePointEntityList.size();
|
||
for (int i = 0; i < listSize; i++) {
|
||
try {
|
||
FirePointEntity firePointEntity = firePointEntityList.get(i);
|
||
List<String> locationList = new ArrayList<>();
|
||
locationList.add(firePointEntity.getLongitude() + "," + firePointEntity.getLatitude());
|
||
GaoDeIgGeocodeVo geocode = GaoDeApiUtil.geocode(locationList);
|
||
String townCode = geocode.getRegeocodes().get(0).getAddressComponent().get(0).getTowncode();
|
||
if (townCode.length() > 9) {
|
||
townCode = townCode.substring(0, 9);
|
||
}
|
||
firePointDao.updateStreetCodeById(firePointEntity.getId(), townCode);
|
||
if (i % 10 == 0) {
|
||
long spendTimeMillis = System.currentTimeMillis() - startTimeMillis;
|
||
double remainTimeMillis = (listSize - i) * spendTimeMillis * 1D / i;
|
||
System.out.println("已完成（" + i + "/" + listSize + "），用时" + formatDuring(spendTimeMillis) + "，剩余" + formatDuring((long) remainTimeMillis));
|
||
}
|
||
} catch (Exception e) {
|
||
e.printStackTrace();
|
||
System.out.println("街道编号格式化出现错误：" + e.getMessage());
|
||
}
|
||
}
|
||
Locale locale = LocaleContextHolder.getLocale();
|
||
return outputEncapsulationObject(PromptMessageEnum.SUCCESS, "街道编号格式化完毕", locale);
|
||
}
|
||
|
||
public static String formatDuring(long mss) {
|
||
long days = mss / (1000 * 60 * 60 * 24);
|
||
long hours = (mss % (1000 * 60 * 60 * 24)) / (1000 * 60 * 60);
|
||
long minutes = (mss % (1000 * 60 * 60)) / (1000 * 60);
|
||
long seconds = (mss % (1000 * 60)) / 1000;
|
||
if (days <= 0 && hours <= 0 && minutes <= 0) {
|
||
return seconds + " 秒 ";
|
||
}
|
||
if (days <= 0 && hours <= 0) {
|
||
return minutes + " 分钟 " + seconds + " 秒 ";
|
||
}
|
||
if (days <= 0) {
|
||
return hours + " 小时 " + minutes + " 分钟 " + seconds + " 秒 ";
|
||
}
|
||
return days + " 天 " + hours + " 小时 " + minutes + " 分钟 " + seconds + " 秒 ";
|
||
}
|
||
}
|