upgrade version

client/src/main/java/com/pica/cloud/account/account/client/RegisterClient.java

@@ -9,6 +9,8 @@ import org.springframework.cloud.netflix.feign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 
+import java.util.List;
+
 /**
  * Created on 2019/10/16 17:28
  * author:crs
@@ -24,7 +26,7 @@ public interface RegisterClient {
     PicaResponse register(@RequestBody OCINRequest ocinRequest);
 
     @PostMapping(value = "/account/circle/acct")
-    PicaResponse register(@RequestBody CircleAcctInitReq circleAcctInitReq);
+    PicaResponse<List<Integer>> register(@RequestBody CircleAcctInitReq circleAcctInitReq);
 
 
-}
+}
\ No newline at end of file

server/src/main/java/com/pica/cloud/account/account/server/service/impl/CircleAccountServiceImpl.java

@@ -6,8 +6,13 @@ import com.pica.cloud.account.account.server.entity.Account;
 import com.pica.cloud.account.account.server.mapper.AccountMapper;
 import com.pica.cloud.account.account.server.service.CircleAccountService;
 import com.pica.cloud.account.account.server.service.AccountService;
+import groovy.util.logging.Log;
+import groovy.util.logging.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -21,6 +26,8 @@ import java.util.List;
 @Service
 public class CircleAccountServiceImpl implements CircleAccountService {
 
+    private static Logger logger = LoggerFactory.getLogger(CircleAccountServiceImpl.class);
+
     @Autowired
     private AccountService accountService;
 
@@ -28,22 +35,29 @@ public class CircleAccountServiceImpl implements CircleAccountService {
     private AccountMapper accountMapper;
 
     @Override
+    @Transactional
     public List<Integer> createCircleAccount(CircleAcctInitReq circleAcctInitReq) {
         List<CircleAcctInit> circleAcctInits = circleAcctInitReq.getCircleAcctInitList();
         List<Integer> savedIds = new ArrayList<>();
-        for(CircleAcctInit acct : circleAcctInits){
-            Account dbAcct = accountMapper.getByMobilePhone(acct.getEncryMobile());  //获取医生表账号信息
-            if(null == dbAcct){
-                Account account = new Account();
-                account.setNickname(acct.getUserName());
-                account.setMobilePhone(acct.getEncryMobile());
-                account.setRegisterSource(circleAcctInitReq.getRegisterSource());
-                accountService.createAccount(account);
-                savedIds.add(account.getId().intValue());
-            }else {
-                savedIds.add(dbAcct.getId().intValue());
+        try {
+            for(CircleAcctInit acct : circleAcctInits){
+                Account dbAcct = accountMapper.getByMobilePhone(acct.getEncryMobile());  //获取医生表账号信息
+                if(null == dbAcct){
+                    Account account = new Account();
+                    account.setNickname(acct.getUserName());
+                    account.setMobilePhone(acct.getEncryMobile());
+                    account.setRegisterSource(circleAcctInitReq.getRegisterSource());
+                    accountService.createAccount(account);
+                    savedIds.add(account.getId().intValue());
+                }else {
+                    savedIds.add(dbAcct.getId().intValue());
+                }
             }
+        }catch (Exception e){
+            logger.error("createCircleAccount error:{}",e.getMessage());
+            throw e;
         }
+
         return savedIds;
     }