From 7088afc56b7e08d69b5b470b123e95e2b49d5d17 Mon Sep 17 00:00:00 2001
From: huanghongfa <huanghongfa123456>
Date: 星期二, 29 六月 2021 10:17:51 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/test' into test

---
 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java |   34 ++++++++++++++++++++++------------
 1 files changed, 22 insertions(+), 12 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java
index 8aea961..bcf663a 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java
@@ -229,18 +229,26 @@
     @Transactional(rollbackFor = Exception.class)
     @Override
     public R add(IdDTO idDTO, Long communityId, Long userId) throws Exception {
-        Map<String,Object> map = eventVisitingTasksMapper.findUserByCommunityId(communityId,6);
-        if(CollectionUtils.isEmpty(map)){
-            return R.fail("网格员不存在");
-        }
+
+//        Map<String,Object> map = eventVisitingTasksMapper.findUserByCommunityId(communityId,6);
+//        if(CollectionUtils.isEmpty(map)){
+//            return R.fail("网格员不存在");
+//        }
+
+        StringBuilder rt = new StringBuilder();
         String[] id = idDTO.getId().split(",");
         for(String idstr:id){
             if(StringUtils.isEmpty(idstr)){
                 continue;
             }
-            addVisitingTask(Long.valueOf(idstr),map,communityId,userId);
+            String error = addVisitingTask(Long.valueOf(idstr),communityId,userId);
+            if(!StringUtils.isEmpty(error)){
+                rt.append(error);
+            }
         }
-
+        if(!StringUtils.isEmpty(rt)){
+            return R.fail("部分新增失败"+rt.toString());
+        }
         return R.ok();
     }
 
@@ -250,15 +258,16 @@
         return page.getRecords();
     }
 
-    private void addVisitingTask(Long id, Map<String, Object> gridMap,Long communityId,Long userId) throws Exception{
+    private String addVisitingTask(Long id, Long communityId,Long userId) throws Exception{
+
+        Map<String,Object> map = eventVisitingTasksMapper.findPopulationById(id);
+        if(CollectionUtils.isEmpty(map)){
+            return "被访问人ID["+id+"]不存在;";
+        }
 
         Integer count = eventVisitingTasksMapper.countNoneComplete(id);
         if(count > 0){
-            return;
-        }
-        Map<String,Object> map = eventVisitingTasksMapper.findPopulationById(id);
-        if(CollectionUtils.isEmpty(map)){
-            return ;
+            return "被访问人["+map.get("name")+"]只能同时存在一条待走访任务;";
         }
         EventVisitingTasksDO visitingTasksDO = new EventVisitingTasksDO();
 //        visitingTasksDO.setGridMemberStreet(Long.valueOf(gridMap.get("street_id").toString()));
@@ -296,6 +305,7 @@
         }
 
         eventVisitingTasksMapper.insert(visitingTasksDO);
+        return null;
     }
 
     private List<String> getOption(String label) {

--
Gitblit v1.7.1