三色任务和自查任务

linwe

2024-08-02 a1eede2f9f7c2590952ab1bdf34210020cdde7c6

 src/main/java/org/springblade/modules/eCallEventTwo/service/impl/EcOrderServiceImpl.java

@@ -1,11 +1,17 @@
package org.springblade.modules.eCallEventTwo.service.impl;

import cn.hutool.core.convert.Convert;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import liquibase.repackaged.org.apache.commons.lang3.StringUtils;
import org.jetbrains.annotations.NotNull;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springblade.common.utils.SpringUtils;
import org.springblade.core.tool.utils.BeanUtil;
import org.springblade.modules.eCallEventTwo.dto.*;
import org.springblade.modules.eCallEventTwo.entity.ECallEventTwoEntity;
@@ -13,11 +19,16 @@
import org.springblade.modules.eCallEventTwo.mapper.EcOrderMapper;
import org.springblade.modules.eCallEventTwo.service.EcOrderService;
import org.springblade.modules.eCallEventTwo.service.IECallEventTwoService;
import org.springblade.modules.grid.entity.GridEntity;
import org.springblade.modules.grid.service.IGridService;
import org.springblade.modules.police.entity.PoliceAffairsGridEntity;
import org.springblade.modules.police.service.IPoliceAffairsGridService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
@@ -36,6 +47,7 @@
   @Autowired
   private IECallEventTwoService ecOrderService;

   protected static final Logger log = LoggerFactory.getLogger(EcOrderServiceImpl.class);
   /**
    * 查询工单
    *
@@ -109,21 +121,85 @@
   }

   public void processPages(int pageSize, EcOrderParamDTO ecOrderParamDTO) {
      long count = count(new QueryWrapper<>());
      QueryWrapper<EcOrder> ecOrderQueryWrapper = new QueryWrapper<>();
      if (StringUtils.isNotBlank(ecOrderParamDTO.getStartTime()) && StringUtils.isNotEmpty(ecOrderParamDTO.getEndTime())) {
         ecOrderQueryWrapper.between("import_time", ecOrderParamDTO.getStartTime(), ecOrderParamDTO.getEndTime());
      }
      // System.out.println("**********参数**************************" + JSON.toJSONString(ecOrderParamDTO));
      long count = count(ecOrderQueryWrapper);
      System.out.println("**********总数**************************" + count);
      int totalPages = (int) Math.ceil((double) count / pageSize); // 计算总页数

      for (int pageNum = 1; pageNum <= totalPages; pageNum++) {
         Page<EcOrder> page = new Page<>(pageNum, pageSize);
         IPage<EcOrder> resultPage = baseMapper.selectPage(page, new QueryWrapper<>());
         IPage<EcOrder> resultPage = baseMapper.selectPage(page, ecOrderQueryWrapper);
         List<EcOrder> records = resultPage.getRecords();
         List<ECallEventTwoEntity> recordEntityList = BeanUtil.copy(records, ECallEventTwoEntity.class);
         boolean b = ecOrderService.saveOrUpdateBatch(recordEntityList);
         List<ECallEventTwoEntity> addList = new ArrayList<>();
         List<ECallEventTwoEntity> updateList = new ArrayList<>();
         // 过滤出已同步的订单
         recordEntityList.forEach(record -> {
            long count1 = ecOrderService.count(Wrappers.<ECallEventTwoEntity>lambdaQuery().eq(ECallEventTwoEntity::getOrderCode, record.getOrderCode()));
            if (count1 == 0) {
               setGridInfo(record);
               addList.add(record);
            } else {
               updateList.add(record);
            }
         });
         // 同步订单
         boolean b = false;
         if (addList.size() > 0) {
            b = ecOrderService.saveBatch(addList);
         }
         if (updateList.size() > 0) {
            b = ecOrderService.saveOrUpdateBatch(updateList);
         }
         System.out.println("更新第" + pageNum + "页" + b);
      }
   }

   @Override
   @DS("master")
   public boolean saveEcOrder(List<ECallEventTwoEntity> recordEntityList) {
      return false;
   }


   /**
    * 设置警格网格信息
    *
    * @param ecOrderEntity
    */
   public void setGridInfo(ECallEventTwoEntity ecOrderEntity) {
      try {
         if (ecOrderEntity.getSceneGeoLng() == null || ecOrderEntity.getSceneGeoLat() == null) {
            return;
         }
         // 根据位置设置网格，警格编号
         IGridService gridService = SpringUtils.getBean(IGridService.class);
         IPoliceAffairsGridService policeAffairsGridService = SpringUtils.getBean(IPoliceAffairsGridService.class);
         String point = "'POINT(" + ecOrderEntity.getSceneGeoLng().toString() + " " + ecOrderEntity.getSceneGeoLat().toString() + ")'";
         // 点坐标解析网格
         List<GridEntity> gridEntityList = gridService.spatialAnalysis(point);
         if (gridEntityList.size() > 0) {
            GridEntity gridEntity = gridEntityList.get(0);
            ecOrderEntity.setGridCode(gridEntity.getGridCode());
         }
         // 点坐标解析警格
         List<PoliceAffairsGridEntity> policeAffairsGridEntityList = policeAffairsGridService.spatialAnalysis(point);
         if (policeAffairsGridEntityList.size() > 0) {
            PoliceAffairsGridEntity policeAffairsGridEntity = policeAffairsGridEntityList.get(0);
            ecOrderEntity.setJwGridCode(policeAffairsGridEntity.getJwGridCode());
         }
      } catch (Exception e) {
         System.out.println("获取警格网格信息失败" + e);
      }
   }

   /**
    * 获取单位考核指标
    *
    * @return
    */
   @Override