提交 0631831e 编写于 作者:  Peijun.zhao's avatar Peijun.zhao

接口批量初始化医生(姓名+手机明文)

上级 839066c9
流水线 #31368 已失败 于阶段
in 0 second
...@@ -6,6 +6,16 @@ public class DiyAcctInitReq { ...@@ -6,6 +6,16 @@ public class DiyAcctInitReq {
private List<String> decryMobileList; private List<String> decryMobileList;
private List<DiyAcctInit> diyAcctInitList;
public List<DiyAcctInit> getDiyAcctInitList() {
return diyAcctInitList;
}
public void setDiyAcctInitList(List<DiyAcctInit> diyAcctInitList) {
this.diyAcctInitList = diyAcctInitList;
}
public List<String> getDecryMobileList() { public List<String> getDecryMobileList() {
return decryMobileList; return decryMobileList;
} }
......
...@@ -3,9 +3,9 @@ package com.pica.cloud.account.account.server.service.impl; ...@@ -3,9 +3,9 @@ package com.pica.cloud.account.account.server.service.impl;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.pica.cloud.account.account.common.req.circle.CircleAcctInit; 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.circle.CircleAcctInitReq;
import com.pica.cloud.account.account.common.req.circle.DiyAcctInit;
import com.pica.cloud.account.account.common.req.shop.ShopAcctInit; 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.common.req.shop.ShopAcctInitReq;
import com.pica.cloud.account.account.common.req.circle.DiyAcctInit;
import com.pica.cloud.account.account.common.req.circle.DiyAcctInitReq; import com.pica.cloud.account.account.common.req.circle.DiyAcctInitReq;
import com.pica.cloud.account.account.server.entity.Account; 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.enums.AccountTypeEnum;
...@@ -14,6 +14,7 @@ import com.pica.cloud.account.account.server.service.AccountService; ...@@ -14,6 +14,7 @@ import com.pica.cloud.account.account.server.service.AccountService;
import com.pica.cloud.account.account.server.service.CircleAccountService; import com.pica.cloud.account.account.server.service.CircleAccountService;
import com.pica.cloud.foundation.encryption.common.constants.EncryptConstants; import com.pica.cloud.foundation.encryption.common.constants.EncryptConstants;
import com.pica.cloud.foundation.encryption.util.EncryptUtils; import com.pica.cloud.foundation.encryption.util.EncryptUtils;
import org.apache.commons.collections.CollectionUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -78,20 +79,40 @@ public class CircleAccountServiceImpl implements CircleAccountService { ...@@ -78,20 +79,40 @@ public class CircleAccountServiceImpl implements CircleAccountService {
logger.info("createDiyAccount:{}", JSONObject.toJSONString(diyAcctInitReq)); logger.info("createDiyAccount:{}", JSONObject.toJSONString(diyAcctInitReq));
List<Integer> savedIds = new ArrayList<>(); List<Integer> savedIds = new ArrayList<>();
try { try {
for(String decryMobile : diyAcctInitReq.getDecryMobileList()){ if(CollectionUtils.isNotEmpty(diyAcctInitReq.getDecryMobileList())){
String encryMobile = EncryptUtils.encryptContent(decryMobile, EncryptConstants.ENCRYPT_TYPE_MOBILE); for(String decryMobile : diyAcctInitReq.getDecryMobileList()){
String encryMobile = EncryptUtils.encryptContent(decryMobile, EncryptConstants.ENCRYPT_TYPE_MOBILE);
Account dbAcct = accountMapper.getByMobilePhone(encryMobile); //获取医生表账号信息 Account dbAcct = accountMapper.getByMobilePhone(encryMobile); //获取医生表账号信息
if(null == dbAcct){ if(null == dbAcct){
Account account = new Account(); Account account = new Account();
account.setMobilePhone(encryMobile); account.setMobilePhone(encryMobile);
account.setRegisterSource(5); //admin account.setRegisterSource(5); //admin
accountService.createAccount(account,AccountTypeEnum.PRODUCT_TYPE_ECO_LIVE.getCode()); accountService.createAccount(account,AccountTypeEnum.PRODUCT_TYPE_ECO_LIVE.getCode());
savedIds.add(account.getId().intValue()); savedIds.add(account.getId().intValue());
logger.info("createDiyAccount insert {}",account.getId().intValue()); logger.info("createDiyAccount insert {}",account.getId().intValue());
}else { }else {
savedIds.add(dbAcct.getId().intValue()); savedIds.add(dbAcct.getId().intValue());
logger.info("createDiyAccount exist {}",dbAcct.getId().intValue()); logger.info("createDiyAccount exist {}",dbAcct.getId().intValue());
}
}
}else {
if(CollectionUtils.isNotEmpty(diyAcctInitReq.getDiyAcctInitList())){
for(DiyAcctInit acctInit : diyAcctInitReq.getDiyAcctInitList()){
String encryMobile = EncryptUtils.encryptContent(acctInit.getDecryMobile(), EncryptConstants.ENCRYPT_TYPE_MOBILE);
Account dbAcct = accountMapper.getByMobilePhone(encryMobile); //获取医生表账号信息
if(null == dbAcct){
Account account = new Account();
account.setName(acctInit.getUserName());
account.setMobilePhone(encryMobile);
account.setRegisterSource(5); //admin
accountService.createAccount(account,AccountTypeEnum.PRODUCT_TYPE_ECO_LIVE.getCode());
savedIds.add(account.getId().intValue());
logger.info("createDiyAccount insert {}",account.getId().intValue());
}else {
savedIds.add(dbAcct.getId().intValue());
logger.info("createDiyAccount exist {}",dbAcct.getId().intValue());
}
}
} }
} }
}catch (Exception e){ }catch (Exception e){
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册