From 93c5fd918d5584f4dea767fcc20b832467c4b4f1 Mon Sep 17 00:00:00 2001
From: rk <94314517@qq.com>
Date: 星期四, 20 十一月 2025 18:02:10 +0800
Subject: [PATCH] 钥匙柜大屏

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkSketchServiceImpl.java |   78 +++++++++++++++++++-------------------
 1 files changed, 39 insertions(+), 39 deletions(-)

diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkSketchServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkSketchServiceImpl.java
index 2c34d74..cf239d5 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkSketchServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkSketchServiceImpl.java
@@ -129,8 +129,7 @@
         if(Constants.equalsInteger(Constants.ZERO,jkSketch.getForceUpdate()) && Constants.equalsInteger(model.getStatus(),Constants.ONE)){
             throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璇ョ嚎璺瓨鍦ㄦ鍦ㄤ紭鍖栦腑锛岃鑰愬績绛夊緟浼樺寲瀹屾垚鎴栬�呴�夋嫨寮哄埗浼樺寲鎿嶄綔锛�");
         }
-
-        if(  jkSketch.getLineIdList() ==null || jkSketch.getLineIdList().size()==0 ){
+        if( jkSketch.getLineIdList() ==null || jkSketch.getLineIdList().size()==0 ){
             throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"璇烽�夋嫨鏈夋晥鍚堢悊鐨勭嚎璺繘琛屼紭鍖栨搷浣滐紒");
         }
         //褰撳墠鎵�鏈夌嚎璺�(绗﹀悎鏉′欢鐨勭嚎璺級
@@ -256,7 +255,8 @@
     @Async
     public  void distanceCustomer( Category cate) {
         try {
-            List<JkCustomer> customerList = cate.getCustomerList();
+            List<JkCustomer> allList = cate.getCustomerList();
+            List<JkCustomer> customerList = cate.getNeedList();
             String url = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.GAODE_DISTANCE_GEOAPI_URL).getCode();
             Date date = new Date();
             BigDecimal cLatitude =new BigDecimal(0);
@@ -288,7 +288,7 @@
                         for (int j = start; j < end; j++) {
                             try {
                                 log.error("浜ら�氳鍒�========"+cate.getId()+"/"+cate.getName()+"/"+customerList.get(j).getName()+"=======cirle/index:"+finalI+"/"+index++);
-                                dealDistancePerCustomer(customerList.get(j),url,date, finalCLatitude, finalCLongitude,customerList);
+                                dealDistancePerCustomer(customerList.get(j),url,date, finalCLatitude, finalCLongitude,allList);
                             }catch (Exception e){
 
                             }
@@ -429,8 +429,10 @@
             }
         }
         if(navigationList.size()>0){
-            jkCustomerNavigationMapper.delete(new UpdateWrapper<JkCustomerNavigation>().lambda()
-                    .eq(JkCustomerNavigation::getStartId,c.getId()));//鍒犻櫎鍘嗗彶鏁版嵁
+            for (JkCustomerNavigation navigation:navigationList) {
+                jkCustomerNavigationMapper.delete(new UpdateWrapper<JkCustomerNavigation>().lambda()
+                        .eq(JkCustomerNavigation::getIdIndex,navigation.getIdIndex()));//鍒犻櫎鍘嗗彶鏁版嵁
+            }
             jkCustomerNavigationMapper.insert(navigationList);//鎻掑叆鏈�鏂版暟鎹�
         }
     }
@@ -493,7 +495,8 @@
         }
         c.setStatus(Constants.TWO);
         categoryMapper.updateById(c);//鏇存柊浠诲姟鎵ц鐘舵��
-        c.setCustomerList(Constants.equalsInteger(model.getForceUpdate(),0)?needList:customerList);
+        c.setCustomerList(customerList);
+        c.setNeedList(Constants.equalsInteger(model.getForceUpdate(),0)?needList:customerList);
         return  c;
     }
 
@@ -701,6 +704,15 @@
 
     private void initCustomerDistance( List<JkSketchLine> lineList,JkSketch model,boolean updateLineDistance) {
         List<JkSketchCustomer> customerList = model.getCustomerList();
+        BigDecimal cLatitude =new BigDecimal(0);
+        BigDecimal cLongitude =new BigDecimal(0);
+        String comLocation = systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.COMPANY_LOCATION).getCode();
+        try {
+            String[] ss = comLocation.split(",");
+            cLongitude = new BigDecimal(ss[0]);
+            cLatitude =  new BigDecimal(ss[1]);
+        }catch (Exception e){
+        }
         for(JkSketchCustomer c : customerList){
             List<DistanceMapParam> tmpList = new ArrayList<>();
             List<DistanceMapParam> distanceMapParamList  = getListFromJsonStr(c.getDistanceJson());
@@ -709,18 +721,21 @@
             t0.setDistance(Constants.formatLongNum(c.getStartDistance()) );
             if(Constants.formatLongNum(c.getStartDistance()) <= 0){
                 //鍥尯鍓嶅線璇ュ鎴风殑璺濈锛屽鏋滀箣鍓嶆湭鑾峰彇杩�
-                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璇ョ嚎璺鎴�:"+c.getName()+"浜ら�氳鍒掑皻鏈畬鎴愶紝涓嶆弧瓒充紭鍖栨潯浠讹紒");
+                t0.setDistance(DistanceCalculator.calculateDistanceDecinal(cLatitude,cLongitude,c.getLatitude(),c.getLongitude()));
+//                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璇ョ嚎璺鎴�:"+c.getName()+"浜ら�氳鍒掑皻鏈畬鎴愶紝涓嶆弧瓒充紭鍖栨潯浠讹紒");
             }
             tmpList.add(t0);
             for(JkSketchCustomer cm : customerList){
                 //瀹㈡埛鍜屽鎴蜂箣闂寸殑璺濈淇℃伅
                 DistanceMapParam t = new DistanceMapParam();
                 t.setId(cm.getCustomerId());
-                DistanceMapParam param = getParamByCustomerIds( cm.getCustomerId(),distanceMapParamList);
+                 DistanceMapParam param = getParamByCustomerIds( cm.getCustomerId(),distanceMapParamList);
                 if(param!=null){//濡傛灉涔嬪墠宸茬粡鑾峰彇杩�
                     t = param;
                 }else{
-                    throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璇ョ嚎璺鎴�:"+c.getName()+"浜ら�氳鍒掑皻鏈畬鎴愶紝涓嶆弧瓒宠矾绋嬭绠楁潯浠讹紒");
+                    //濡傛灉鏈鍒掞紝鎸夌収鐩寸嚎璺濈
+                    t.setDistance(DistanceCalculator.calculateDistanceDecinal(cm.getLatitude(),cm.getLongitude(),c.getLatitude(),c.getLongitude()));
+//                    throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璇ョ嚎璺鎴�:"+c.getName()+"涓庡鎴�:"+cm.getName()+"绠�浜ら�氳鍒掑皻鏈畬鎴愶紝涓嶆弧瓒宠矾绋嬭绠楁潯浠讹紒");
                 }
                 tmpList.add(t);
             }
@@ -729,7 +744,8 @@
             tt.setDistance(Constants.formatLongNum(c.getEndDistance()));
             if(Constants.formatLongNum(c.getEndDistance()) <= 0){
                 //璇ュ鎴疯繑鍥炲洯鍖虹殑璺濈 ,濡傛灉涔嬪墠鏈幏鍙栬繃
-                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璇ョ嚎璺鎴�:"+c.getName()+"浜ら�氳鍒掑皻鏈畬鎴愶紝涓嶆弧瓒宠矾绋嬭绠楁潯浠讹紒");
+                tt.setDistance(DistanceCalculator.calculateDistanceDecinal(cLatitude,cLongitude,c.getLatitude(),c.getLongitude()));
+//                throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璇ョ嚎璺鎴�:"+c.getName()+"涓庤捣鐐逛氦閫氳鍒掑皻鏈畬鎴愶紝涓嶆弧瓒宠矾绋嬭绠楁潯浠讹紒");
             }
             tmpList.add(tt);
             c.setDistanceMapParamList(tmpList);
@@ -779,7 +795,7 @@
         return list;
     }
 
-    private DistanceMapParam getParamByCustomerIds(  Integer id1, List<DistanceMapParam> distanceMapParamList) {
+    public static DistanceMapParam getParamByCustomerIds(  Integer id1, List<DistanceMapParam> distanceMapParamList) {
         if(distanceMapParamList!=null){
             for(DistanceMapParam p :distanceMapParamList){
                 if(Constants.equalsInteger(p.getId(),id1)){
@@ -791,7 +807,7 @@
         return null;
     }
 
-    private List<DistanceMapParam> getListFromJsonStr(String distanceJson) {
+    public static List<DistanceMapParam> getListFromJsonStr(String distanceJson) {
         try {
             return  JSONObject.parseObject(distanceJson, new TypeReference<List<DistanceMapParam>>(){}.getType());
         }catch (Exception e){
@@ -923,11 +939,11 @@
         String errorMsg1 ="";
         for(JkSketchCustomer c : customerList){
             if(c.getLatitude()==null || c.getLongitude() ==null){
-                errorMsg += c.getName()+"-"+c.getName()+" | ";
+                errorMsg +=  c.getName()+" | ";
             }
-            if(!Constants.equalsInteger(c.getDistanceStatus(),Constants.ONE)){
-                errorMsg1 += c.getName()+"-"+c.getName()+" | ";
-            }
+        /*    if(!Constants.equalsInteger(c.getDistanceStatus(),Constants.ONE)){
+                errorMsg1 +=  c.getName()+" | ";
+            }*/
         }
         if(StringUtils.isNotBlank(errorMsg)){
             throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璇ョ嚎璺鎴�:銆�"+errorMsg+"銆戝畾浣嶄俊鎭笉瀹屾暣锛屼笉婊¤冻浼樺寲鏉′欢锛�");
@@ -1506,26 +1522,6 @@
         List<JkSketchLine> jkSketchLineList = jkSketchLineMapper.selectJoinList(JkSketchLine.class,queryWrapper);
 
         List<TelecomCategoryDataVO> telecomCategoryDataVOList = new ArrayList<>();
-        for (JkSketch jkSketch:sketchList) {
-            TelecomCategoryDataVO telecomCategoryDataVO = new TelecomCategoryDataVO();
-            telecomCategoryDataVO.setId(jkSketch.getCategoryId());
-            telecomCategoryDataVO.setName(jkSketch.getCategoryName());
-            //浼樺寲鍓嶆暟鎹�
-            List<JkSketchLine> beforeList = jkSketchLineList.stream()
-                    .filter(i->Constants.equalsInteger(i.getSketchId(),jkSketch.getId())
-                            && Objects.nonNull(i.getDistance())
-                            &&Constants.equalsInteger(i.getType(),Constants.ZERO)).collect(Collectors.toList());
-            telecomCategoryDataVO.setDistance(
-                    beforeList.stream().map(i->i.getDistance()).reduce(Long.valueOf(0),Long::sum)
-            );
-            if(Constants.equalsInteger(jkSketch.getOptStatus(),Constants.ZERO)){
-                telecomCategoryDataVO.setDistanceAfter(telecomCategoryDataVO.getDistance());
-            }else{
-                //浼樺寲鍚庢暟鎹�
-                List<JkSketchLine> afterList = jkSketchLineList.stream()
-                        .filter(i->Constants.equalsInteger(i.getSketchId(),jkSketch.getId())
-                                && Objects.nonNull(i.getDistance())
-                                &&Constants.equalsInteger(i.getType(),Constants.ONE)&&Constants.equalsInteger(i.getIsdeleted(),Constants.ZERO)).collect(Collectors.toList());
         if(sketchList!=null){
             for (JkSketch jkSketch:sketchList) {
                 TelecomCategoryDataVO telecomCategoryDataVO = new TelecomCategoryDataVO();
@@ -1533,7 +1529,9 @@
                 telecomCategoryDataVO.setName(jkSketch.getCategoryName());
                 //浼樺寲鍓嶆暟鎹�
                 List<JkSketchLine> beforeList = jkSketchLineList.stream()
-                        .filter(i->Constants.equalsInteger(i.getSketchId(),jkSketch.getId())&&Constants.equalsInteger(i.getType(),Constants.ZERO)).collect(Collectors.toList());
+                        .filter(i->Constants.equalsInteger(i.getSketchId(),jkSketch.getId())
+                                && Objects.nonNull(i.getDistance())
+                                &&Constants.equalsInteger(i.getType(),Constants.ZERO)).collect(Collectors.toList());
                 telecomCategoryDataVO.setDistance(
                         beforeList.stream().map(i->i.getDistance()).reduce(Long.valueOf(0),Long::sum)
                 );
@@ -1542,7 +1540,9 @@
                 }else{
                     //浼樺寲鍚庢暟鎹�
                     List<JkSketchLine> afterList = jkSketchLineList.stream()
-                            .filter(i->Constants.equalsInteger(i.getSketchId(),jkSketch.getId())&&Constants.equalsInteger(i.getType(),Constants.ONE)&&Constants.equalsInteger(i.getIsdeleted(),Constants.ZERO)).collect(Collectors.toList());
+                            .filter(i->Constants.equalsInteger(i.getSketchId(),jkSketch.getId())
+                                    && Objects.nonNull(i.getDistance())
+                                    &&Constants.equalsInteger(i.getType(),Constants.ONE)&&Constants.equalsInteger(i.getIsdeleted(),Constants.ZERO)).collect(Collectors.toList());
 
                     Long distanceAfter = 0L;
                     for (JkSketchLine jkSketchLine:afterList) {

--
Gitblit v1.9.3