refactor(workorder): 重构工单状态聚合逻辑-只处理撤回任务状态

linwei

3 days ago 92dc5972adbd94d47c0e6501ce4a7b51af09e3c3

 drone-service/drone-gd/src/main/java/org/sxkj/gd/workorder/service/impl/GdWorkOrderServiceImpl.java

@@ -1,7 +1,6 @@
package org.sxkj.gd.workorder.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -13,11 +12,10 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.sxkj.common.constant.CommonConstant;
import org.sxkj.common.constant.WordOrderConstant;
import org.sxkj.common.utils.AmapUtils;
import org.sxkj.common.utils.GeomUtils;
import org.sxkj.common.utils.OrderNumUtils;
import org.sxkj.gd.utils.GdGeoAddressUtil;
import org.sxkj.gd.workorder.entity.GdPatrolTaskEntity;
import org.sxkj.gd.workorder.entity.GdWorkOrderEntity;
import org.sxkj.gd.workorder.entity.GdWorkOrderFlowEntity;
@@ -35,7 +33,9 @@
import org.sxkj.gd.workorder.vo.GdWorkOrderVO;
import org.sxkj.system.cache.SysCache;

import java.util.*;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 工单任务表 服务实现类
@@ -61,7 +61,7 @@
   public IPage<GdWorkOrderVO> selectGdWorkOrderPage(IPage<GdWorkOrderVO> page, WorkOrderPageParam gdWorkOrder) {
      if (gdWorkOrder.getIsQueryAll()) {
         List<Long> deptList = new ArrayList<>();
         if (!AuthUtil.isAdministrator() || !AuthUtil.isAdmin()) {
         if (!(AuthUtil.isAdministrator() || AuthUtil.isAdmin())) {
            deptList = SysCache.getDeptChildIds(Long.valueOf(AuthUtil.getDeptId()));
         }
         gdWorkOrder.setDeptList(deptList);
@@ -97,8 +97,8 @@
      if (centerCoords == null || centerCoords.length < 2) {
         return false;
      }
      String areaCodePrefix = getDistrictCodeByLocation(centerCoords[0], centerCoords[1]);
      entity.setAreaCode(areaCodePrefix);
      String countyCode = GdGeoAddressUtil.getTownCode(centerCoords[0], centerCoords[1]);
      entity.setAreaCode(countyCode);
      // 生成工单编号
      if (StringUtils.isBlank(entity.getWorkOrderCode())) {
         String timestamp = OrderNumUtils.initOrderNum(WordOrderConstant.ORDER_REDIS_KEY);
@@ -269,52 +269,5 @@
      }

      return false;
   }

   /**
    * 根据经纬度获取行政区划编码
    *
    * @param longitude 经度
    * @param latitude  纬度
    * @return 行政区划编码
    */
   public String getDistrictCodeByLocation(double longitude, double latitude) {
      Map<String, String> districtInfo = getDistrictInfoByLocation(longitude, latitude);
      String adcode = districtInfo.get("adcode");
      log.info("行政区划信息：{}", adcode);
      // if (adcode != null && adcode.length() >= 3) {
      //    return adcode.substring(0, 2);
      // }
      return adcode;
   }

   /**
    * 根据经纬度获取行政区划信息
    *
    * @param longitude 经度
    * @param latitude  纬度
    * @return 行政区划信息
    */
   public Map<String, String> getDistrictInfoByLocation(double longitude, double latitude) {
      // 使用高德地图工具类获取行政区划信息
      String location = longitude + "," + latitude;
      JSONObject result = AmapUtils.searchByLatLng(location);

      Map<String, String> districtInfo = new HashMap<>();
      if (result != null && "1".equals(result.getString("status"))) {
         JSONObject regeocode = result.getJSONObject("regeocode");
         if (regeocode != null) {
            JSONObject addressComponent = regeocode.getJSONObject("addressComponent");
            if (addressComponent != null) {
               districtInfo.put("province", addressComponent.getString("province"));
               districtInfo.put("city", addressComponent.getString("city"));
               districtInfo.put("district", addressComponent.getString("district"));
               districtInfo.put("adcode", addressComponent.getString("adcode"));
               districtInfo.put("township", addressComponent.getString("township"));
               districtInfo.put("formatted_address", regeocode.getString("formatted_address"));
            }
         }
      }
      return districtInfo;
   }
}