From 7793e8c88dcff6471e977920187cc58b6036278d Mon Sep 17 00:00:00 2001 From: liyj <1617420630@qq.com> Date: Fri, 26 Dec 2025 15:12:44 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E4=BC=9A=E5=91=98=E6=96=B0?= =?UTF-8?q?=E5=A2=9Euser=5Flongin=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/admin/AccountController.java | 5 +++++ .../service/AccountUserBaseService.java | 8 ++++++++ .../impl/AccountUserBaseServiceImpl.java | 17 +++++++++++++++++ .../common/feignService/AccountService.java | 9 +++++++++ .../service/impl/SyncBaseThirdSxAbstract.java | 18 +++++++++++++++++- 5 files changed, 56 insertions(+), 1 deletion(-) diff --git a/mall-account/src/main/java/com/suisung/mall/account/controller/admin/AccountController.java b/mall-account/src/main/java/com/suisung/mall/account/controller/admin/AccountController.java index 246e153f..f8eda61b 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/controller/admin/AccountController.java +++ b/mall-account/src/main/java/com/suisung/mall/account/controller/admin/AccountController.java @@ -467,6 +467,11 @@ public class AccountController { return accountUserBaseService.saveBatchAccountInfo(accountUserInfoList); } + @RequestMapping(value = "/saveBatchAccountUserLogin", method = RequestMethod.POST) + public ThirdApiRes saveBatchAccountUserLogin(@RequestBody List accountUserLoginList) { + return accountUserBaseService.saveBatchAccountUserLogin(accountUserLoginList); + } + @RequestMapping(value = "/findOneAccountUserBase", method = RequestMethod.POST) public AccountUserBase findOneAccountUserBase(@RequestBody AccountUserBase accountUserBase) { diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserBaseService.java b/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserBaseService.java index 596db891..c11c71aa 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserBaseService.java +++ b/mall-account/src/main/java/com/suisung/mall/account/service/AccountUserBaseService.java @@ -4,6 +4,7 @@ import com.suisung.mall.common.api.CommonResult; import com.suisung.mall.common.domain.UserDto; import com.suisung.mall.common.modules.account.AccountUserBase; import com.suisung.mall.common.modules.account.AccountUserInfo; +import com.suisung.mall.common.modules.account.AccountUserLogin; import com.suisung.mall.common.pojo.req.WxUserInfoReq; import com.suisung.mall.common.pojo.res.ThirdApiRes; import com.suisung.mall.core.web.service.IBaseService; @@ -296,4 +297,11 @@ public interface AccountUserBaseService extends IBaseService { * @return */ ThirdApiRes saveBatchAccountInfo(List accountUserInfoList); + + /** + * 批量保存accountInfo + * + * @return + */ + ThirdApiRes saveBatchAccountUserLogin(List accountUserLoginList); } diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBaseServiceImpl.java b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBaseServiceImpl.java index 3954baf6..e4567a8f 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBaseServiceImpl.java +++ b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBaseServiceImpl.java @@ -3803,6 +3803,23 @@ public class AccountUserBaseServiceImpl extends BaseServiceImpl accountUserLoginList) { + boolean result = false; + if (!accountUserLoginList.isEmpty()) { + try { + result = accountUserLoginService.saveBatch(accountUserLoginList, accountUserLoginList.size()); + } catch (Exception e) { + throw new RuntimeException("保存AccountUserLogin报错：" + e.getMessage()); + } + } + if (result) { + return new ThirdApiRes().success("成功"); + } + return new ThirdApiRes().fail(250, "保存异常"); + } + + /** * 检查并修复商户店铺信息 * 重要（补偿机制），检查修复商户入驻店铺信息(商家账号关联入驻店铺Id，给商家账户创立公司员工账号和权限) diff --git a/mall-common/src/main/java/com/suisung/mall/common/feignService/AccountService.java b/mall-common/src/main/java/com/suisung/mall/common/feignService/AccountService.java index f29a63ba..9301e019 100644 --- a/mall-common/src/main/java/com/suisung/mall/common/feignService/AccountService.java +++ b/mall-common/src/main/java/com/suisung/mall/common/feignService/AccountService.java @@ -278,6 +278,15 @@ public interface AccountService { @PostMapping(value = "/admin/account/accountController/saveBatchAccountInfo") ThirdApiRes saveBatchAccountInfo(@RequestBody List accountUserInfoList); + /** + * 批量保存accountUserLogin + * + * @return + */ + @PostMapping(value = "/admin/account/accountController/saveBatchAccountUserLogin") + ThirdApiRes saveBatchAccountUserLogin(@RequestBody List accountUserLoginList); + + /** * 批量保存accountInfo * diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncBaseThirdSxAbstract.java b/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncBaseThirdSxAbstract.java index 71c85633..32f9292d 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncBaseThirdSxAbstract.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/sync/service/impl/SyncBaseThirdSxAbstract.java @@ -22,6 +22,7 @@ import com.suisung.mall.common.feignService.AccountService; import com.suisung.mall.common.feignService.PayService; import com.suisung.mall.common.modules.account.AccountUserBase; import com.suisung.mall.common.modules.account.AccountUserInfo; +import com.suisung.mall.common.modules.account.AccountUserLogin; import com.suisung.mall.common.modules.base.ShopBaseProductBrand; import com.suisung.mall.common.modules.base.ShopBaseProductCategory; import com.suisung.mall.common.modules.base.ShopBaseProductSpec; @@ -608,6 +609,8 @@ public abstract class SyncBaseThirdSxAbstract{ List addAccountUserBases=new ArrayList<>(); List addAcountUserInfo=new ArrayList<>(); List addPayUserResource=new ArrayList<>(); + List accountUserLogins=new ArrayList<>(); + Date today=new Date(); for (int i = 0; i < accountBaseIds.size(); i++) { // account_user_base SyncThirdMemberReq syncThirdMemberReq=addMemberList.get(i); @@ -648,6 +651,14 @@ public abstract class SyncBaseThirdSxAbstract{ accountUserInfo.setUser_birthday(DateTimeUtils.parseDate(syncThirdMemberReq.getUser_birthday(), "yyyy-MM-dd")); } addAcountUserInfo.add(accountUserInfo); + + //account + AccountUserLogin accountUserLogin = new AccountUserLogin(); + accountUserLogin.setUser_id(userId); + accountUserLogin.setUser_active_time(today); + accountUserLogin.setUser_reg_date(today); + accountUserLogin.setUser_reg_time(today.getTime()); + accountUserLogins.add(accountUserLogin); if (syncThirdMemberReq.getUser_money() != null || syncThirdMemberReq.getUser_points() != null) { // pay_user_resource 用户支付资源，积分，余额 PayUserResource payUserResource = new PayUserResource(); @@ -673,13 +684,18 @@ public abstract class SyncBaseThirdSxAbstract{ throw new ApiException(ResultCode.FAILED,"addAcountUserInfo保存异常"); } } - if(!addPayUserResource.isEmpty()){ ThirdApiRes thirdApiRes= payService.saveBatchPayUserResources(addPayUserResource); if(thirdApiRes.getError_code()!=0){ throw new ApiException(ResultCode.FAILED); } } + if(!accountUserLogins.isEmpty()){ + ThirdApiRes thirdApiRes= accountService.saveBatchAccountUserLogin(accountUserLogins); + if(thirdApiRes.getError_code()!=0){ + throw new ApiException(ResultCode.FAILED,"accountUserLogin保存异常"); + } + } return count; }