账户增加 商户渠道新增用户

client/pom.xml

@@ -11,7 +11,7 @@
 
     <groupId>com.pica.cloud.account</groupId>
     <artifactId>pica-cloud-account-client</artifactId>
-    <version>1.0.3.6</version>
+    <version>1.0.3.7</version>
     <name>pica-cloud-account-client</name>
     <packaging>jar</packaging>
 
@@ -28,7 +28,7 @@
         <dependency>
             <groupId>com.pica.cloud.account</groupId>
             <artifactId>pica-cloud-account-common</artifactId>
-            <version>1.0.1.6</version>
+            <version>1.0.1.7</version>
         </dependency>
         <dependency>
             <groupId>org.springframework.cloud</groupId>

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

@@ -4,6 +4,7 @@ import com.pica.cloud.account.account.common.req.EncryptEntity;
 import com.pica.cloud.account.account.common.req.LoginResult;
 import com.pica.cloud.account.account.common.req.OCINRequest;
 import com.pica.cloud.account.account.common.req.circle.CircleAcctInitReq;
+import com.pica.cloud.account.account.common.req.shop.ShopAcctInitReq;
 import com.pica.cloud.foundation.entity.PicaResponse;
 import org.springframework.cloud.netflix.feign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -29,5 +30,8 @@ public interface RegisterClient {
     @PostMapping(value = "/account/circle/acct")
     PicaResponse<List<Integer>> register(@RequestBody CircleAcctInitReq circleAcctInitReq, @RequestHeader(value = "token") String token);
 
+    @PostMapping(value = "/account/shop/acct")
+    PicaResponse<List<Integer>> shopRegister(@RequestBody ShopAcctInitReq shopAcctInitReq, @RequestHeader(value = "token") String token);
+
 
 }
\ No newline at end of file

common/pom.xml

@@ -11,7 +11,7 @@
 
     <groupId>com.pica.cloud.account</groupId>
     <artifactId>pica-cloud-account-common</artifactId>
-    <version>1.0.1.6</version>
+    <version>1.0.1.7</version>
     <name>pica-cloud-account-common</name>
     <packaging>jar</packaging>
 

common/src/main/java/com/pica/cloud/account/account/common/req/shop/ShopAcctInit.java

+package com.pica.cloud.account.account.common.req.shop;
+
+/**
+ * @DESCRIPTOIN:
+ * @AUTHOR: joy
+ * @DATE:2020/6/21 11:01 上午
+ */
+public class ShopAcctInit {
+
+    private String userName;
+
+    public String getUserName() {
+        return userName;
+    }
+
+    public void setUserName(String userName) {
+        this.userName = userName;
+    }
+
+    private String mobile;
+
+    public String getMobile() {
+        return mobile;
+    }
+
+    public void setMobile(String mobile) {
+        this.mobile = mobile;
+    }
+}

common/src/main/java/com/pica/cloud/account/account/common/req/shop/ShopAcctInitReq.java

+package com.pica.cloud.account.account.common.req.shop;
+
+import java.util.List;
+
+/**
+ * @DESCRIPTOIN:
+ * @AUTHOR: joy
+ * @DATE:2020/6/21 11:02 上午
+ */
+public class ShopAcctInitReq {
+
+    private List<ShopAcctInit> shopAcctInitList;
+
+    private Integer registerSource; // 1 安卓 2 ios 3 web 4 h5 5 admin
+
+    public Integer getRegisterSource() {
+        return registerSource;
+    }
+
+    public void setRegisterSource(Integer registerSource) {
+        this.registerSource = registerSource;
+    }
+
+    public List<ShopAcctInit> getShopAcctInitList() {
+        return shopAcctInitList;
+    }
+
+    public void setShopAcctInitList(List<ShopAcctInit> shopAcctInitList) {
+        this.shopAcctInitList = shopAcctInitList;
+    }
+}
+

server/pom.xml

@@ -138,7 +138,7 @@
         <dependency>
             <groupId>com.pica.cloud.account</groupId>
             <artifactId>pica-cloud-account-common</artifactId>
-            <version>1.0.1.6</version>
+            <version>1.0.1.7</version>
         </dependency>
 
         <dependency>

server/src/main/java/com/pica/cloud/account/account/server/controller/ShopUserController.java

+package com.pica.cloud.account.account.server.controller;
+
+import com.pica.cloud.account.account.common.req.circle.CircleAcctInitReq;
+import com.pica.cloud.account.account.common.req.shop.ShopAcctInitReq;
+import com.pica.cloud.account.account.server.service.CircleAccountService;
+import com.pica.cloud.foundation.entity.PicaResponse;
+import com.pica.cloud.foundation.service.starter.interceptor.EnabledLoginValidate;
+import io.swagger.annotations.Api;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@Api(description = "")
+@RestController
+@RequestMapping("/shop")
+public class ShopUserController {
+
+    private Logger logger = LoggerFactory.getLogger(ShopUserController.class);
+
+    @Autowired
+    private CircleAccountService circleAccountService;
+
+    @PostMapping("/acct")
+    @EnabledLoginValidate
+    public PicaResponse<List<Integer>> shopUserInit(@RequestBody ShopAcctInitReq shopAcctInitReq) {
+        return PicaResponse.toResponse(circleAccountService.createShopAccount(shopAcctInitReq));
+    }
+
+}

server/src/main/java/com/pica/cloud/account/account/server/service/CircleAccountService.java

@@ -2,6 +2,7 @@ package com.pica.cloud.account.account.server.service;
 
 
 import com.pica.cloud.account.account.common.req.circle.CircleAcctInitReq;
+import com.pica.cloud.account.account.common.req.shop.ShopAcctInitReq;
 import com.pica.cloud.account.account.server.entity.Account;
 import com.pica.cloud.account.account.server.entity.AccountInfoEntity;
 
@@ -18,4 +19,6 @@ public interface CircleAccountService {
     List<Integer> createCircleAccount(CircleAcctInitReq circleAcctInitReq);
 
 
+    List<Integer> createShopAccount(ShopAcctInitReq shopAcctInitReq);
+
 }

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

@@ -3,11 +3,15 @@ package com.pica.cloud.account.account.server.service.impl;
 import com.alibaba.fastjson.JSONObject;
 import com.pica.cloud.account.account.common.req.circle.CircleAcctInit;
 import com.pica.cloud.account.account.common.req.circle.CircleAcctInitReq;
+import com.pica.cloud.account.account.common.req.shop.ShopAcctInit;
+import com.pica.cloud.account.account.common.req.shop.ShopAcctInitReq;
 import com.pica.cloud.account.account.server.entity.Account;
 import com.pica.cloud.account.account.server.enums.AccountTypeEnum;
 import com.pica.cloud.account.account.server.mapper.AccountMapper;
 import com.pica.cloud.account.account.server.service.AccountService;
 import com.pica.cloud.account.account.server.service.CircleAccountService;
+import com.pica.cloud.foundation.encryption.common.constants.EncryptConstants;
+import com.pica.cloud.foundation.encryption.util.EncryptUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -65,4 +69,35 @@ public class CircleAccountServiceImpl implements CircleAccountService {
         return savedIds;
     }
 
+    @Override
+    public List<Integer> createShopAccount(ShopAcctInitReq shopAcctInitReq) {
+        logger.info("createShopAccount:{}", JSONObject.toJSONString(shopAcctInitReq));
+        List<ShopAcctInit> shopAcctInits = shopAcctInitReq.getShopAcctInitList();
+        List<Integer> savedIds = new ArrayList<>();
+        try {
+            for(ShopAcctInit acct : shopAcctInits){
+                String encryMobile = EncryptUtils.encryptContent(acct.getMobile(), EncryptConstants.ENCRYPT_TYPE_MOBILE);
+                Account dbAcct = accountMapper.getByMobilePhone(encryMobile);  //获取医生表账号信息
+                if(null == dbAcct){
+                    Account account = new Account();
+                    account.setName(acct.getUserName());
+                    account.setNickname(acct.getUserName());
+                    account.setMobilePhone(encryMobile);
+                    account.setRegisterSource(shopAcctInitReq.getRegisterSource());
+                    accountService.createAccount(account,AccountTypeEnum.PRODUCT_TYPE_DOCTOR.getCode());
+                    savedIds.add(account.getId().intValue());
+                    logger.info("createShopAccount insert {}",account.getId().intValue());
+                }else {
+                    savedIds.add(dbAcct.getId().intValue());
+                    logger.info("createShopAccount exist {}",dbAcct.getId().intValue());
+                }
+            }
+        }catch (Exception e){
+            logger.error("createShopAccount error:{}",e.getMessage());
+            throw e;
+        }
+
+        return savedIds;
+    }
+
 }