diff --git a/mall-account/src/main/java/com/suisung/mall/account/controller/LoginController.java b/mall-account/src/main/java/com/suisung/mall/account/controller/LoginController.java index 1b249e76..fd429e25 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/controller/LoginController.java +++ b/mall-account/src/main/java/com/suisung/mall/account/controller/LoginController.java @@ -28,7 +28,6 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.util.Pair; import org.springframework.web.bind.annotation.*; -import javax.servlet.http.HttpServletRequest; import java.util.ArrayList; import java.util.HashMap; import java.util.List; @@ -234,9 +233,9 @@ public class LoginController extends BaseControllerImpl { return CommonResult.success(accountUserBaseService.doAppConnectLogin(bind_name, code)); } - @ApiOperation(value = "商家版注册与登录") + @ApiOperation(value = "商家(代理商)注册与登录") @RequestMapping(value = "/doMerchSmsRegisterAndLogin", method = RequestMethod.POST) - public CommonResult doMerchSmsRegisterAndLogin(HttpServletRequest request, @RequestBody JSONObject paramJSON) { + public CommonResult doMerchSmsRegisterAndLogin(@RequestBody(required = false) JSONObject paramJSON) { if (paramJSON == null) { return CommonResult.failed("缺少必要参数!"); } @@ -256,8 +255,10 @@ public class LoginController extends BaseControllerImpl { String cid = paramJSON.getStr("cid"); String osType = paramJSON.getStr("os_type"); + // 用户类型:0-普通买家; 1-管理员;2-入驻商家;3-代理商; + Integer userType = paramJSON.getInt("user_type"); - return accountUserBaseService.doMerchSmsRegisterAndLogin(userMobile, randKey, verifyCode, cid, osType); + return accountUserBaseService.doMerchSmsRegisterAndLogin(userMobile, randKey, verifyCode, userType, cid, osType); } @ApiOperation(value = "微信用户一键登录与注册") @@ -288,9 +289,11 @@ public class LoginController extends BaseControllerImpl { @ApiOperation(value = "忘记密码-更改新密码") @RequestMapping(value = "/edit/forgetPassword", method = RequestMethod.POST) public CommonResult editForgetPassword(@RequestBody JSONObject paramJSON) { + // TODO 这个方法肯定有问题,待修改 return accountUserBaseService.doMerchSmsRegisterAndLogin(paramJSON.getStr("user_mobile"), paramJSON.getStr("rand_key"), paramJSON.getStr("verify_code"), + paramJSON.getInt("user_type"), paramJSON.getStr("cid"), paramJSON.getStr("os_type")); } 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 d45acea5..efbf0a85 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 @@ -142,11 +142,12 @@ public interface AccountUserBaseService extends IBaseService { * @param user_mobile * @param rand_key 防机器人刷验证码 * @param verify_code + * @param userType 用户类型:0-普通买家; 1-管理员;2-入驻商家;3-代理商; * @param cid 推送 cid * @param osType 手机系统类型 :1-Android;2-iOS;3-微信小程序; * @return */ - CommonResult doMerchSmsRegisterAndLogin(String user_mobile, String rand_key, String verify_code, String cid, String osType); + CommonResult doMerchSmsRegisterAndLogin(String user_mobile, String rand_key, String verify_code, Integer userType, String cid, String osType); /** * 微信小程序一键登录注册接口 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 8c8550ce..cf5a2eef 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 @@ -51,7 +51,6 @@ import com.suisung.mall.common.modules.distribution.ShopDistributionUserCommissi import com.suisung.mall.common.modules.pay.PayUserResource; import com.suisung.mall.common.modules.plantform.ShopPlantformSubsiteUser; import com.suisung.mall.common.modules.store.ShopStoreBase; -import com.suisung.mall.common.modules.store.ShopStoreInfo; import com.suisung.mall.common.modules.store.ShopStoreMember; import com.suisung.mall.common.modules.store.ShopStoreMemberLevel; import com.suisung.mall.common.pojo.dto.SmsDto; @@ -1682,8 +1681,8 @@ public class AccountUserBaseServiceImpl extends BaseServiceImpl shopStoreMembers= shopService.findShopStoreMemberList(params); - ShopStoreBase shopStoreBase= shopService.getShopStoreBase(Convert.toInt(wxUserInfoReq.getStoreId())); - if(shopStoreMembers.isEmpty()&&shopStoreBase!=null){ + List shopStoreMembers = shopService.findShopStoreMemberList(params); + ShopStoreBase shopStoreBase = shopService.getShopStoreBase(Convert.toInt(wxUserInfoReq.getStoreId())); + if (shopStoreMembers.isEmpty() && shopStoreBase != null) { ShopStoreMember shopStoreMember = new ShopStoreMember(); shopStoreMember.setStoreName(shopStoreBase.getStore_name()); shopStoreMember.setStoreId(shopStoreBase.getStore_id()); @@ -3169,13 +3171,13 @@ public class AccountUserBaseServiceImpl extends BaseServiceImpl userInfo = new HashMap<>(); userInfo.put("user_account", user_mobile); userInfo.put("user_mobile", user_mobile); - userInfo.put("user_is_admin", userType); // 商家入驻注册 + userInfo.put("user_is_admin", userType); // 商家或代理商入驻注册 String user_password = regPwd; if (StrUtil.isBlank(user_password)) { // 随机数明文密码 @@ -3330,7 +3333,8 @@ public class AccountUserBaseServiceImpl extends BaseServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.eq("market_id", marketId).eq("status", CommonConstant.Enable).orderByDesc("version_key"); - AdminAppMarketUpdate adminAppMarketUpdate = findOne(queryWrapper); + AdminAppMarketUpdate adminAppMarketUpdate = getOne(queryWrapper, false); if (adminAppMarketUpdate == null) { return CommonResult.success(null, "没有找到最新版本"); } @@ -285,6 +285,6 @@ public class AdminAppMarketUpdateServiceImpl extends BaseServiceImpl commentQueryWrapper = new QueryWrapper<>(); commentQueryWrapper.eq("comment_id", cmsArticleCommentHelpful.getComment_id()); commentQueryWrapper.eq("article_id", cmsArticleCommentHelpful.getArticle_id()); commentQueryWrapper.eq("user_id", user.getId()); - CmsArticleComment dbArticleComment = cmsArticleCommentService.findOne(commentQueryWrapper); + CmsArticleComment dbArticleComment = cmsArticleCommentService.getOne(commentQueryWrapper, false); if (null == dbArticleCommentHelpful) { cmsArticleCommentHelpful.setUser_id(user.getId()); diff --git a/mall-common/src/main/java/com/suisung/mall/common/constant/CommonConstant.java b/mall-common/src/main/java/com/suisung/mall/common/constant/CommonConstant.java index b0934eb8..57e987da 100644 --- a/mall-common/src/main/java/com/suisung/mall/common/constant/CommonConstant.java +++ b/mall-common/src/main/java/com/suisung/mall/common/constant/CommonConstant.java @@ -20,11 +20,12 @@ public class CommonConstant { public static final Integer Delivery_Amount_Comput_Type_Payment = 3; /** - * 用户类型:0-普通用户;1-管理员;2-入驻商户 + * 用户类型:0-普通买家; 1-管理员;2-入驻商家;3-代理商; */ public static final Integer USER_TYPE_NORMAL = 0; public static final Integer USER_TYPE_ADMIN = 1; public static final Integer USER_TYPE_MCH = 2; + public static final Integer USER_TYPE_AGENT = 3; // 国际电话区号 public static final String IDD_ZH_CN = "+86"; //中国 diff --git a/mall-pay/src/main/java/com/suisung/mall/pay/controller/mobile/IndexController.java b/mall-pay/src/main/java/com/suisung/mall/pay/controller/mobile/IndexController.java index 0938a9c0..c8a4c74a 100644 --- a/mall-pay/src/main/java/com/suisung/mall/pay/controller/mobile/IndexController.java +++ b/mall-pay/src/main/java/com/suisung/mall/pay/controller/mobile/IndexController.java @@ -264,7 +264,7 @@ public class IndexController extends BaseControllerImpl { QueryWrapper tradeQueryWrapper = new QueryWrapper<>(); tradeQueryWrapper.eq("order_id", order_id); tradeQueryWrapper.eq("buyer_id", userDto.getId()); - PayConsumeTrade payConsumeTrade = payConsumeTradeService.findOne(tradeQueryWrapper); + PayConsumeTrade payConsumeTrade = payConsumeTradeService.getOne(tradeQueryWrapper, false); Integer trade_is_paid = payConsumeTrade.getTrade_is_paid(); if (trade_is_paid.equals(StateCode.ORDER_PAID_STATE_YES)) { return CommonResult.success("订单已支付"); diff --git a/mall-pay/src/main/java/com/suisung/mall/pay/service/impl/PayConsumeDepositServiceImpl.java b/mall-pay/src/main/java/com/suisung/mall/pay/service/impl/PayConsumeDepositServiceImpl.java index 8543c023..fb32f90d 100644 --- a/mall-pay/src/main/java/com/suisung/mall/pay/service/impl/PayConsumeDepositServiceImpl.java +++ b/mall-pay/src/main/java/com/suisung/mall/pay/service/impl/PayConsumeDepositServiceImpl.java @@ -229,7 +229,7 @@ public class PayConsumeDepositServiceImpl extends BaseServiceImpl tradeQueryWrapper = new QueryWrapper<>(); tradeQueryWrapper.eq("order_id", order_id); - PayConsumeTrade trade_row_tmp = payConsumeTradeService.findOne(tradeQueryWrapper); + PayConsumeTrade trade_row_tmp = payConsumeTradeService.getOne(tradeQueryWrapper, false); // 固定死, 是门店收银还是店铺收银。, 统一店铺收银 if (true) { @@ -1296,7 +1296,7 @@ public class PayUserPayServiceImpl extends BaseServiceImpl channelQueryWrapper = new QueryWrapper<>(); channelQueryWrapper.eq("payment_channel_code", payment_channel_code); - PayPaymentChannel payPaymentChannel = payPaymentChannelService.findOne(channelQueryWrapper); + PayPaymentChannel payPaymentChannel = payPaymentChannelService.getOne(channelQueryWrapper, false); Integer payment_channel_id = payPaymentChannel.getPayment_channel_id(); // 插入充值记录 @@ -1416,7 +1416,7 @@ public class PayUserPayServiceImpl extends BaseServiceImpl tradeQueryWrapper = new QueryWrapper<>(); tradeQueryWrapper.eq("order_id", orderId); - PayConsumeTrade trade_row_tmp = payConsumeTradeService.findOne(tradeQueryWrapper); + PayConsumeTrade trade_row_tmp = payConsumeTradeService.getOne(tradeQueryWrapper, false); Integer payment_store_id = trade_row_tmp != null ? trade_row_tmp.getStore_id() : 0; String orderSubject = trade_row_tmp != null ? trade_row_tmp.getTrade_title() : ""; @@ -1437,7 +1437,7 @@ public class PayUserPayServiceImpl extends BaseServiceImpl channelQueryWrapper = new QueryWrapper<>(); channelQueryWrapper.eq("payment_channel_code", "lakala"); - PayPaymentChannel payPaymentChannel = payPaymentChannelService.findOne(channelQueryWrapper); + PayPaymentChannel payPaymentChannel = payPaymentChannelService.getOne(channelQueryWrapper, false); if (payPaymentChannel == null) { logger.error("[拉卡拉支付通知] 支付渠道不存在: channelCode=lakala"); diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/api/service/impl/KdApiExpressSearchServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/api/service/impl/KdApiExpressSearchServiceImpl.java index eb26e14d..d976b90c 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/api/service/impl/KdApiExpressSearchServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/api/service/impl/KdApiExpressSearchServiceImpl.java @@ -251,7 +251,7 @@ public class KdApiExpressSearchServiceImpl implements KdApiExpressSearchService queryWrapper.eq("order_id", orderId); queryWrapper.eq("logistics_enable", CommonConstant.Enable); - ShopOrderLogistics shopOrderLogistic = shopOrderLogisticsService.findOne(queryWrapper); + ShopOrderLogistics shopOrderLogistic = shopOrderLogisticsService.getOne(queryWrapper, false); if (ObjectUtil.isEmpty(shopOrderLogistic)) { logger.warn(I18nUtil._("未找到发货记录")); return null; @@ -313,7 +313,7 @@ public class KdApiExpressSearchServiceImpl implements KdApiExpressSearchService public CommonResult returnLogistics(String return_tracking_name, String return_tracking_number, String order_id) { QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq("express_name", return_tracking_name); - ShopBaseExpress shopBaseExpress = shopBaseExpressService.findOne(wrapper); + ShopBaseExpress shopBaseExpress = shopBaseExpressService.getOne(wrapper, false); if (shopBaseExpress == null) { throw new ApiException(I18nUtil._("系统中未配置该物流信息,请检查发货信息是否正确!")); } @@ -331,7 +331,7 @@ public class KdApiExpressSearchServiceImpl implements KdApiExpressSearchService QueryWrapper orderReturnQueryWrapper = new QueryWrapper<>(); orderReturnQueryWrapper.eq("return_tracking_number", return_tracking_number); orderReturnQueryWrapper.eq("return_tracking_name", return_tracking_name); - ShopOrderReturn orderReturn = shopOrderReturnService.findOne(orderReturnQueryWrapper); + ShopOrderReturn orderReturn = shopOrderReturnService.getOne(orderReturnQueryWrapper, false); if (orderReturn == null) { throw new ApiException(I18nUtil._("退款退货信息不存在!")); diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/base/service/impl/ShopBaseCurrencyServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/base/service/impl/ShopBaseCurrencyServiceImpl.java index 8082b80d..d3ae0d90 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/base/service/impl/ShopBaseCurrencyServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/base/service/impl/ShopBaseCurrencyServiceImpl.java @@ -30,14 +30,12 @@ import java.util.Map; @Service public class ShopBaseCurrencyServiceImpl extends BaseServiceImpl implements ShopBaseCurrencyService { + private final Logger logger = LoggerFactory.getLogger(ShopBaseCurrencyServiceImpl.class); @Autowired private AccountBaseConfigService accountBaseConfigService; - @Autowired private HttpServletRequest servletRequest; - private Logger logger = LoggerFactory.getLogger(ShopBaseCurrencyServiceImpl.class); - /** * 获取当前汇率 */ @@ -62,7 +60,7 @@ public class ShopBaseCurrencyServiceImpl extends BaseServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.eq("currency_is_default", 1); - user_currency_row = findOne(queryWrapper); + user_currency_row = getOne(queryWrapper, false); } if (user_currency_row != null) { currency_exchange_rate = user_currency_row.getCurrency_exchange_rate(); @@ -94,7 +92,7 @@ public class ShopBaseCurrencyServiceImpl extends BaseServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.eq("currency_is_default", 1); - user_currency_row = findOne(queryWrapper); + user_currency_row = getOne(queryWrapper, false); } if (user_currency_row != null) { diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/esign/service/impl/EsignPlatformInfoServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/esign/service/impl/EsignPlatformInfoServiceImpl.java index 6c3d3c7a..7bcb20f6 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/esign/service/impl/EsignPlatformInfoServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/esign/service/impl/EsignPlatformInfoServiceImpl.java @@ -9,6 +9,7 @@ package com.suisung.mall.shop.esign.service.impl; import cn.hutool.core.collection.CollectionUtil; +import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.suisung.mall.common.constant.CommonConstant; @@ -83,8 +84,8 @@ public class EsignPlatformInfoServiceImpl extends BaseServiceImpl 0) { queryWrapper.eq("id", shopMchEntry.getDistributor_id()); - result = findOne(queryWrapper); + result = getOne(queryWrapper, false); log.debug("[获取二级代理] 使用指定分销商ID查询,distributorId={}", shopMchEntry.getDistributor_id()); @@ -264,7 +264,7 @@ public class EsignPlatformInfoServiceImpl extends BaseServiceImpl existsRecordList = list(queryWrapper); - if (CollectionUtil.isNotEmpty(existsRecordList) - && existsRecordList.get(0) != null - && existsRecordList.get(0).getId() > 0) { + LklLedgerReceiver existsRecord = getOne(queryWrapper, false); + if (ObjectUtil.isNotEmpty(existsRecord)) { // 更新记录 - record.setId(existsRecordList.get(0).getId()); + record.setId(existsRecord.getId()); return updateById(record); } @@ -147,7 +145,6 @@ public class LklLedgerReceiverServiceImpl extends BaseServiceImpl