修改刷数据逻辑

server/src/main/java/com/pica/cloud/wechat/yunqueyilian/server/controller/refresh/RefreshServiceImpl.java

@@ -107,6 +107,8 @@ public class RefreshServiceImpl implements RefreshService {
                     String[] strIds = repeat.getIds().split(",");
                     List<PatPatient> patPatients = refreshMapper.queryListPatByIds(strIds);
                     if (CollectionUtils.isNotEmpty(patPatients)) {
+                        List<PatPatient> wechatPats = new ArrayList<>();
+                        List<PatPatient> importPats = new ArrayList<>();
                         for (PatPatient pat : patPatients) {
                             /**校验是否有已存在业务，商城、服务包、微信绑定*/
                             if (refreshMapper.validateTradeOrder(pat.getId()) > 0 || refreshMapper.validateAddress(pat.getId()) > 0
@@ -114,12 +116,39 @@ public class RefreshServiceImpl implements RefreshService {
                                 continue;
                             } else {
                                 if (refreshMapper.validateWechat(pat.getId()) > 0 && StringUtil.isNull(pat.getMobilePhone())) {
-                                    refreshMapper.updateRatient(pat.getId());
-                                    refreshMapper.updateRatientInfo(pat.getId());
-                                    refreshMapper.updateRepeatById(repeat.getId());
+                                    wechatPats.add(pat);
+                                } else {
+                                    if (StringUtil.isNull(pat.getMobilePhone())) {
+                                        importPats.add(pat);
+                                    }
                                 }
                             }
                         }
+
+                        if (CollectionUtils.isNotEmpty(wechatPats) && wechatPats.size() == patPatients.size()) {
+                            for (PatPatient pat : wechatPats) {
+                                refreshMapper.updateRatient(pat.getId());
+                                refreshMapper.updateRatientInfo(pat.getId());
+                            }
+                            refreshMapper.updateRepeatById(repeat.getId());
+                        }
+
+                        if (CollectionUtils.isNotEmpty(wechatPats) && importPats.size() == importPats.size()) {
+                            importPats.remove(0);
+                            if (CollectionUtils.isNotEmpty(wechatPats)) {
+                                for (PatPatient pat : wechatPats) {
+                                    if (pat.getId() != null) {
+                                        refreshMapper.deletePat(pat.getId());
+                                        refreshMapper.deletePatInfo(pat.getId());
+                                        refreshMapper.deleteDocPat(pat.getId());
+                                        refreshMapper.deleteDocPatInfo(pat.getId());
+                                        refreshIndex++;
+                                    }
+                                }
+                                refreshMapper.updateRepeatById(repeat.getId());
+                            }
+                        }
+
                     }
                 }
             }