From db2b30bbe239427a89521cd858b2b191d56086ef Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Tue, 14 Sep 2021 09:41:06 +0800
Subject: [PATCH] 获取有走航车数据日期,device修改,绑定国控站

---
 screen-manage/src/main/java/com/moral/api/service/impl/GovMonitorPointServiceImpl.java |  119 +++++++++++++++++++++++++++++++++--------------------------
 1 files changed, 66 insertions(+), 53 deletions(-)

diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/GovMonitorPointServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/GovMonitorPointServiceImpl.java
index 9cac6b4..add7e7a 100644
--- a/screen-manage/src/main/java/com/moral/api/service/impl/GovMonitorPointServiceImpl.java
+++ b/screen-manage/src/main/java/com/moral/api/service/impl/GovMonitorPointServiceImpl.java
@@ -15,6 +15,8 @@
 import com.moral.constant.Constants;
 import com.moral.constant.RedisConstants;
 import com.moral.constant.ResponseCodeEnum;
+import com.moral.util.RegionCodeUtils;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
@@ -23,13 +25,13 @@
 import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.servlet.http.HttpServletRequest;
-import java.lang.reflect.Field;
+
 import java.text.SimpleDateFormat;
 import java.util.*;
 
 /**
  * <p>
- *  ���������������
+ * ���������������
  * </p>
  *
  * @author moral
@@ -73,71 +75,71 @@
 
     @Override
     public Map<String, Object> getDataByCondition(Map map) {
-        Map<String,Object> resultMap = new HashMap<>();
-        if (!map.containsKey("current")||!map.containsKey("size")){
-            resultMap.put("code",ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode());
-            resultMap.put("msg",ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());
+        Map<String, Object> resultMap = new HashMap<>();
+        if (!map.containsKey("current") || !map.containsKey("size")) {
+            resultMap.put("code", ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode());
+            resultMap.put("msg", ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());
             return resultMap;
         }
         int current = Integer.parseInt(map.get("current").toString());
         int size = Integer.parseInt(map.get("size").toString());
-        Page<GovMonitorPoint> page = new Page<>(current,size);
+        Page<GovMonitorPoint> page = new Page<>(current, size);
         QueryWrapper<GovMonitorPoint> wrapper_Condition = new QueryWrapper<>();
-        wrapper_Condition.eq("is_delete",Constants.NOT_DELETE);
-        if (!ObjectUtils.isEmpty(map.get("name"))){
-            wrapper_Condition.like("name",map.get("name").toString());
+        wrapper_Condition.eq("is_delete", Constants.NOT_DELETE);
+        if (!ObjectUtils.isEmpty(map.get("name"))) {
+            wrapper_Condition.like("name", map.get("name").toString());
         }
-        if (!ObjectUtils.isEmpty(map.get("stationLevel"))){
-            wrapper_Condition.like("station_level",map.get("stationLevel").toString());
+        if (!ObjectUtils.isEmpty(map.get("stationLevel"))) {
+            wrapper_Condition.like("station_level", map.get("stationLevel").toString());
         }
         wrapper_Condition.orderByDesc("create_time");
-        Page resultPage = govMonitorPointMapper.selectPage(page,wrapper_Condition);
+        Page resultPage = govMonitorPointMapper.selectPage(page, wrapper_Condition);
         int totalNumber = govMonitorPointMapper.selectCount(wrapper_Condition);
         List<GovMonitorPoint> govMonitorPoints = resultPage.getRecords();
         SimpleDateFormat SDF = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        List<Map<String,Object>> govMonitorPointList = new ArrayList<>();
-        for (GovMonitorPoint govMonitorPoint:govMonitorPoints) {
-            Map govMonitorPointMap = JSON.parseObject(JSON.toJSONString(govMonitorPoint),Map.class);
+        List<Map<String, Object>> govMonitorPointList = new ArrayList<>();
+        for (GovMonitorPoint govMonitorPoint : govMonitorPoints) {
+            Map govMonitorPointMap = JSON.parseObject(JSON.toJSONString(govMonitorPoint), Map.class);
             String createTime = SDF.format(govMonitorPoint.getCreateTime());
             String updateTime = SDF.format(govMonitorPoint.getUpdateTime());
-            govMonitorPointMap.put("createTime",createTime);
-            govMonitorPointMap.put("updateTime",updateTime);
+            govMonitorPointMap.put("createTime", createTime);
+            govMonitorPointMap.put("updateTime", updateTime);
             String position = "";
-            if (!ObjectUtils.isEmpty(govMonitorPoint.getProvinceCode())){
+            if (!ObjectUtils.isEmpty(govMonitorPoint.getProvinceCode())) {
                 QueryWrapper<SysArea> wrapper_province = new QueryWrapper<>();
-                wrapper_province.eq("area_code",govMonitorPoint.getProvinceCode());
+                wrapper_province.eq("area_code", govMonitorPoint.getProvinceCode());
                 SysArea sysArea_provice = sysAreaMapper.selectOne(wrapper_province);
-                if (!ObjectUtils.isEmpty(sysArea_provice)){
-                    position = position+sysArea_provice.getAreaName();
-                    if (!ObjectUtils.isEmpty(govMonitorPoint.getCityCode())){
+                if (!ObjectUtils.isEmpty(sysArea_provice)) {
+                    position = position + sysArea_provice.getAreaName();
+                    if (!ObjectUtils.isEmpty(govMonitorPoint.getCityCode())) {
                         QueryWrapper<SysArea> wrapper_city = new QueryWrapper<>();
-                        wrapper_city.eq("area_code",govMonitorPoint.getCityCode());
+                        wrapper_city.eq("area_code", govMonitorPoint.getCityCode());
                         SysArea sysArea_city = sysAreaMapper.selectOne(wrapper_city);
-                        if (!ObjectUtils.isEmpty(sysArea_city)){
-                            position = position+"/"+sysArea_city.getAreaName();
-                            if (!ObjectUtils.isEmpty(govMonitorPoint.getAreaCode())){
+                        if (!ObjectUtils.isEmpty(sysArea_city)) {
+                            position = position + "/" + sysArea_city.getAreaName();
+                            if (!ObjectUtils.isEmpty(govMonitorPoint.getAreaCode())) {
                                 QueryWrapper<SysArea> wrapper_area = new QueryWrapper<>();
-                                wrapper_area.eq("area_code",govMonitorPoint.getAreaCode());
+                                wrapper_area.eq("area_code", govMonitorPoint.getAreaCode());
                                 SysArea sysArea_area = sysAreaMapper.selectOne(wrapper_area);
-                                if (!ObjectUtils.isEmpty(sysArea_area)){
-                                    position = position+"/"+sysArea_area.getAreaName();
+                                if (!ObjectUtils.isEmpty(sysArea_area)) {
+                                    position = position + "/" + sysArea_area.getAreaName();
                                 }
                             }
                         }
                     }
                 }
             }
-            govMonitorPointMap.put("position",position);
+            govMonitorPointMap.put("position", position);
             govMonitorPointList.add(govMonitorPointMap);
         }
-        resultMap.put("govMonitorPointList",govMonitorPointList);
-        resultMap.put("totalNumber",totalNumber);
-        resultMap.put("current",current);
-        int totalPageNumber = totalNumber/size;
-        if(totalNumber%size != 0){
+        resultMap.put("govMonitorPointList", govMonitorPointList);
+        resultMap.put("totalNumber", totalNumber);
+        resultMap.put("current", current);
+        int totalPageNumber = totalNumber / size;
+        if (totalNumber % size != 0) {
             totalPageNumber += 1;
         }
-        resultMap.put("totalPageNumber",totalPageNumber);
+        resultMap.put("totalPageNumber", totalPageNumber);
         return resultMap;
     }
 
@@ -146,12 +148,12 @@
     public void insert(GovMonitorPoint govMonitorPoint) {
         int count = govMonitorPointMapper.insert(govMonitorPoint);
         //������������redis
-        setGovMonitorPointInfoToRedis(govMonitorPoint.getId().toString(),selectGovMonitorPointInfoById(govMonitorPoint.getId()));
-        if (count > 0){
+        setGovMonitorPointInfoToRedis(govMonitorPoint.getId().toString(), selectGovMonitorPointInfoById(govMonitorPoint.getId()));
+        if (count > 0) {
             //������������������
             HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest();
             StringBuilder content = new StringBuilder();
-            content.append("������������������������").append("id:").append(govMonitorPoint.getId()+";").append(govMonitorPoint.getName()+";").append(":").append("guid���").append(govMonitorPoint.getGuid()+";");
+            content.append("������������������������").append("id:").append(govMonitorPoint.getId() + ";").append(govMonitorPoint.getName() + ";").append(":").append("guid���").append(govMonitorPoint.getGuid() + ";");
             logUtils.saveOperationForManage(request, content.toString(), Constants.INSERT_OPERATE_TYPE);
         }
     }
@@ -165,36 +167,36 @@
         //������redis
         delGovMonitorPointInfoFromRedis(id.toString());
         //������redis
-        setGovMonitorPointInfoToRedis(id.toString(),selectGovMonitorPointInfoById(id));
+        setGovMonitorPointInfoToRedis(id.toString(), selectGovMonitorPointInfoById(id));
         //������������������
         HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest();
         StringBuilder content = new StringBuilder();
-        content.append("������������������������").append("id:").append(govMonitorPoint.getId()+";");
-        if (!ObjectUtils.isEmpty(govMonitorPoint.getGuid())){
+        content.append("������������������������").append("id:").append(govMonitorPoint.getId() + ";");
+        if (!ObjectUtils.isEmpty(govMonitorPoint.getGuid())) {
             content.append("guid:").append(oldGovMonitorPoint.getGuid()).append("->").append(govMonitorPoint.getGuid()).append(";");
         }
-        if (!ObjectUtils.isEmpty(govMonitorPoint.getName())){
+        if (!ObjectUtils.isEmpty(govMonitorPoint.getName())) {
             content.append("name:").append(oldGovMonitorPoint.getName()).append("->").append(govMonitorPoint.getName()).append(";");
         }
-        if (!ObjectUtils.isEmpty(govMonitorPoint.getLongitude())){
+        if (!ObjectUtils.isEmpty(govMonitorPoint.getLongitude())) {
             content.append("longitude:").append(oldGovMonitorPoint.getLongitude()).append("->").append(govMonitorPoint.getLongitude()).append(";");
         }
-        if (!ObjectUtils.isEmpty(govMonitorPoint.getLatitude())){
+        if (!ObjectUtils.isEmpty(govMonitorPoint.getLatitude())) {
             content.append("latitude:").append(oldGovMonitorPoint.getLatitude()).append("->").append(govMonitorPoint.getLatitude()).append(";");
         }
-        if (!ObjectUtils.isEmpty(govMonitorPoint.getProvinceCode())){
+        if (!ObjectUtils.isEmpty(govMonitorPoint.getProvinceCode())) {
             content.append("provinceCode:").append(oldGovMonitorPoint.getProvinceCode()).append("->").append(govMonitorPoint.getProvinceCode()).append(";");
         }
-        if (!ObjectUtils.isEmpty(govMonitorPoint.getCityCode())){
+        if (!ObjectUtils.isEmpty(govMonitorPoint.getCityCode())) {
             content.append("cityCode:").append(oldGovMonitorPoint.getCityCode()).append("->").append(govMonitorPoint.getCityCode()).append(";");
         }
-        if (!ObjectUtils.isEmpty(govMonitorPoint.getAreaCode())){
+        if (!ObjectUtils.isEmpty(govMonitorPoint.getAreaCode())) {
             content.append("areaCode:").append(oldGovMonitorPoint.getAreaCode()).append("->").append(govMonitorPoint.getAreaCode()).append(";");
         }
-        if (!ObjectUtils.isEmpty(govMonitorPoint.getStationLevel())){
+        if (!ObjectUtils.isEmpty(govMonitorPoint.getStationLevel())) {
             content.append("stationLevel:").append(oldGovMonitorPoint.getStationLevel()).append("->").append(govMonitorPoint.getStationLevel()).append(";");
         }
-        if (!ObjectUtils.isEmpty(govMonitorPoint.getDesc())){
+        if (!ObjectUtils.isEmpty(govMonitorPoint.getDesc())) {
             content.append("desc:").append(oldGovMonitorPoint).append("->").append(govMonitorPoint.getDesc()).append(";");
         }
         logUtils.saveOperationForManage(request, content.toString(), Constants.UPDATE_OPERATE_TYPE);
@@ -203,8 +205,8 @@
     @Override
     public void delete(Integer id) {
         UpdateWrapper<GovMonitorPoint> wrapper_delete = new UpdateWrapper<>();
-        wrapper_delete.eq("id",id).set("is_delete",Constants.DELETE);
-        govMonitorPointMapper.update(null,wrapper_delete);
+        wrapper_delete.eq("id", id).set("is_delete", Constants.DELETE);
+        govMonitorPointMapper.update(null, wrapper_delete);
         //������redis
         delGovMonitorPointInfoFromRedis(id.toString());
         //������������������
@@ -219,4 +221,15 @@
         GovMonitorPoint govMonitorPoint = govMonitorPointMapper.selectById(id);
         return govMonitorPoint;
     }
+
+    @Override
+    public List<Map<String, Object>> selectGovMonitorPoints(String regionCode) {
+        QueryWrapper<GovMonitorPoint> queryWrapper = new QueryWrapper<>();
+        queryWrapper.select("guid", "name").eq("is_delete", Constants.NOT_DELETE);
+        if (!ObjectUtils.isEmpty(regionCode)) {
+            String regionName = RegionCodeUtils.regionCodeConvertToName(Integer.parseInt(regionCode));
+            queryWrapper.eq(regionName, regionCode);
+        }
+        return govMonitorPointMapper.selectMaps(queryWrapper);
+    }
 }

--
Gitblit v1.8.0