From d4e8aa814b95a4b727d9ec9c88669e536ce54635 Mon Sep 17 00:00:00 2001
From: doum <doum>
Date: 星期一, 17 十一月 2025 09:18:10 +0800
Subject: [PATCH] 更改头部

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCustomerServiceImpl.java |   31 +++++++++++++++++++++++++------
 1 files changed, 25 insertions(+), 6 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCustomerServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCustomerServiceImpl.java
index acd94f9..145c710 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCustomerServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCustomerServiceImpl.java
@@ -111,6 +111,12 @@
                 .set(JkCustomer::getLatitude,jkCustomer.getLatitude())
                 .set(JkCustomer::getLongitude,jkCustomer.getLongitude())
                 .set(JkCustomer::getEditor,jkCustomer.getLoginUserInfo().getId())
+                .set(JkCustomer::getStartDistance,null)
+                .set(JkCustomer::getEndDistance,null)
+                .set(JkCustomer::getStartSteps,null)
+                .set(JkCustomer::getEndSteps,null)
+                .set(JkCustomer::getDistanceStatus,Constants.ZERO)
+                .set(JkCustomer::getDistance,null)
                 .set(JkCustomer::getEditDate,new Date())
                 .eq(JkCustomer::getId,jkCustomer.getId())
         );
@@ -233,14 +239,14 @@
         if(importing!=null && importing){
             throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝涓婃浠诲姟姝e湪鎵ц涓紝璇风◢鍚庡啀璇曪紒");
         }
-        redisTemplate.opsForValue().set(Constants.RedisKeys.CHECKING_JKCUSTOMER_LOCATION,true);
+        redisTemplate.opsForValue().set(Constants.RedisKeys.CHECKING_JKCUSTOMER_LOCATION,true,60,TimeUnit.MINUTES);
         try {
             LambdaQueryWrapper<JkCustomer> queryWrapper = new LambdaQueryWrapper<>();
             queryWrapper.isNotNull(JkCustomer::getLocation);
-            queryWrapper.isNotNull(JkCustomer::getLocation);
             queryWrapper.and(wrapper ->{
                 wrapper.isNull(JkCustomer::getLatitude)
-                        .or().isNull(JkCustomer::getLongitude); });
+                        .or().isNull(JkCustomer::getLongitude)
+                        .or().eq(JkCustomer::getDistanceStatus,Constants.TWO);});
             //鏌ヨ鍏ㄩ儴鏈夊湴鍧�锛屼絾鏄病鏈夌粡绾害鐨勫鎴蜂俊鎭�
             List<JkCustomer>  list = jkCustomerMapper.selectList(queryWrapper);
             if(list ==null || list.size()==0){
@@ -249,8 +255,9 @@
             String url = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.GAODE_LOCATION_GEOAPI_URL).getCode();
             for(JkCustomer c : list){
                 try {
+                    String addr =c.getLocation().replaceAll("[^a-zA-Z0-9\\u4e00-\\u9fa5]", "");
                     String urlStr =url.replace("${param}"
-                            ,c.getLocation().replaceAll("[^a-zA-Z0-9\\u4e00-\\u9fa5]", ""));
+                            ,addr);
                     String result = HttpsUtil.get(urlStr,true);
                     JSONObject json = JSONObject.parseObject(result);
                     if(json!=null
@@ -269,13 +276,18 @@
                             jkCustomerMapper.update(null,new UpdateWrapper<JkCustomer>().lambda()
                                     .set(JkCustomer::getLatitude,c.getLatitude())
                                     .set(JkCustomer::getLongitude,c.getLongitude())
+                                    .set(JkCustomer::getStartDistance,null)
+                                    .set(JkCustomer::getEndDistance,null)
+                                    .set(JkCustomer::getStartSteps,null)
+                                    .set(JkCustomer::getEndSteps,null)
+                                    .set(JkCustomer::getDistanceStatus,Constants.ZERO)
+                                    .set(JkCustomer::getDistance,null)
                                     .set(JkCustomer::getEditDate,new Date())
                                     .eq(JkCustomer::getId,c.getId())
                             );
                         }
                     }else{
-                        log.error("鏇存柊浜ゆ帶涓績瀹㈡埛缁忕含搴︿俊鎭�=====鑾峰彇json=========="+json);
-                        log.error("鏇存柊浜ゆ帶涓績瀹㈡埛缁忕含搴︿俊鎭�=====鑾峰彇澶辫触=========="+urlStr+c.getName()+"-"+c.getLocation());
+                        log.error("鏇存柊浜ゆ帶涓績瀹㈡埛缁忕含搴︿俊鎭�=====鑾峰彇json=========="+urlStr+"\n"+c.getName()+"\n"+json);
                     }
                 }catch (Exception e){
                     log.error("鏇存柊浜ゆ帶涓績瀹㈡埛缁忕含搴︿俊鎭�=====澶辫触=========="+c.getName()+"-"+c.getLocation());
@@ -394,10 +406,17 @@
             tModel.setCreator(loginUserInfo.getId());
             tModel.setCreateDate(new Date());
             tModel.setIsnew(Constants.ONE);
+            tModel.setDistanceStatus(Constants.TWO);//闇�瑕侀噸鏂板畾浣�
             tModel.setStatus(Constants.ZERO);
             tModel.setDistanceStatus(Constants.ZERO);
             newList.add(tModel);
         }else{
+            if(StringUtils.isBlank(model.getLocation()) ||
+                    StringUtils.equals(tModel.getLocation().replaceAll("[^a-zA-Z0-9\\u4e00-\\u9fa5]","")
+                    ,model.getLocation().replaceAll("[^a-zA-Z0-9\\u4e00-\\u9fa5]",""))){
+                //濡傛灉浣嶇疆淇℃伅鍙戠敓鍙樺寲
+                tModel.setDistanceStatus(Constants.TWO);//闇�瑕侀噸鏂板畾浣�
+            }
             tModel.setIsnew(Constants.ZERO);
             updateList.add(tModel);
         }

--
Gitblit v1.9.3