update 会员钱包

This commit is contained in:
2023-11-21 16:02:55 +08:00
parent 820fb203e1
commit 243981d81b
9 changed files with 30 additions and 5 deletions

View File

@@ -220,9 +220,12 @@ public class MemberController extends BaseController {
try { try {
String memberId = getMemberIdByAuthorization(request); String memberId = getMemberIdByAuthorization(request);
dto.setMemberId(memberId); dto.setMemberId(memberId);
if (StringUtils.isBlank(dto.getWalletCode())) {
throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
}
// PageResponse pageResponse = memberService.getMemberBalanceChanges(dto); // PageResponse pageResponse = memberService.getMemberBalanceChanges(dto);
// PageResponse pageResponse = memberService.getMemberWalletLog(dto); // PageResponse pageResponse = memberService.getMemberWalletLog(dto);
MemberWalletInfoVO memberWalletInfo = memberService.getMemberWalletInfo (dto); MemberWalletInfoVO memberWalletInfo = memberService.getMemberWalletInfo(dto);
response = new RestApiResponse<>(memberWalletInfo); response = new RestApiResponse<>(memberWalletInfo);
} catch (Exception e) { } catch (Exception e) {
logger.error("查询用户账户余额变动信息 error:", e); logger.error("查询用户账户余额变动信息 error:", e);

View File

@@ -326,7 +326,8 @@ public class MemberService {
dto.setEndDate(lastDay); dto.setEndDate(lastDay);
// 查询会员钱包信息表,获取 本金余额 // 查询会员钱包信息表,获取 本金余额
MemberWalletInfo memberWalletInfo = memberWalletInfoService.selectByMemberId(dto.getMemberId(), null); // MemberWalletInfo memberWalletInfo = memberWalletInfoService.selectByMemberId(dto.getMemberId(), null);
MemberWalletInfo memberWalletInfo = memberWalletInfoService.selectByWalletCode(dto.getWalletCode());
if (memberWalletInfo == null) { if (memberWalletInfo == null) {
// 用户未注册小程序 // 用户未注册小程序
throw new BusinessException(ReturnCodeEnum.CODE_AUTHENTICATION_ERROR); throw new BusinessException(ReturnCodeEnum.CODE_AUTHENTICATION_ERROR);

View File

@@ -161,8 +161,6 @@ public class MemberBasicInfoController extends BaseController {
throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR); throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
} }
int i = memberBasicInfoService.updateMemberBalance(dto); int i = memberBasicInfoService.updateMemberBalance(dto);
if (i > 0) { if (i > 0) {
ajaxResult = AjaxResult.success(ReturnCodeEnum.CODE_SUCCESS.getLabel()); ajaxResult = AjaxResult.success(ReturnCodeEnum.CODE_SUCCESS.getLabel());

View File

@@ -32,6 +32,11 @@ public class UniAppQueryMemberBalanceDTO extends BaseMemberDTO{
*/ */
private String endDate; private String endDate;
/**
* 钱包编号
*/
private String walletCode;
@Override @Override
public String toString() { public String toString() {
return new ToStringBuilder(this, ToStringStyle.JSON_STYLE) return new ToStringBuilder(this, ToStringStyle.JSON_STYLE)

View File

@@ -67,4 +67,6 @@ public interface MemberWalletInfoMapper {
MemberWalletInfo selectByMemberId(@Param("memberId") String memberId, @Param("merchantId") String merchantId); MemberWalletInfo selectByMemberId(@Param("memberId") String memberId, @Param("merchantId") String merchantId);
List<MemberWalletInfo> selectByMemberWalletList(@Param("memberId") String memberId); List<MemberWalletInfo> selectByMemberWalletList(@Param("memberId") String memberId);
MemberWalletInfo selectByWalletCode(@Param("walletCode") String walletCode);
} }

View File

@@ -16,6 +16,8 @@ public interface MemberWalletInfoService {
MemberWalletInfo selectByMemberId(String memberId, String merchantId); MemberWalletInfo selectByMemberId(String memberId, String merchantId);
MemberWalletInfo selectByWalletCode(String walletCode);
int updateByPrimaryKeySelective(MemberWalletInfo record); int updateByPrimaryKeySelective(MemberWalletInfo record);
int updateByPrimaryKey(MemberWalletInfo record); int updateByPrimaryKey(MemberWalletInfo record);

View File

@@ -48,6 +48,11 @@ public class MemberWalletInfoServiceImpl implements MemberWalletInfoService {
return memberWalletInfoMapper.selectByMemberId(memberId, merchantId); return memberWalletInfoMapper.selectByMemberId(memberId, merchantId);
} }
@Override
public MemberWalletInfo selectByWalletCode(String walletCode) {
return memberWalletInfoMapper.selectByWalletCode(walletCode);
}
@Override @Override
public int updateByPrimaryKeySelective(MemberWalletInfo record) { public int updateByPrimaryKeySelective(MemberWalletInfo record) {
return memberWalletInfoMapper.updateByPrimaryKeySelective(record); return memberWalletInfoMapper.updateByPrimaryKeySelective(record);

View File

@@ -193,4 +193,12 @@
and member_id = #{memberId,jdbcType=INTEGER} and member_id = #{memberId,jdbcType=INTEGER}
and merchant_id is not null and merchant_id is not null
</select> </select>
<select id="selectByWalletCode" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from member_wallet_info
where del_flag = '0'
and wallet_code = #{walletCode,jdbcType=VARCHAR}
</select>
</mapper> </mapper>

View File

@@ -461,6 +461,7 @@
left join order_basic_info t2 left join order_basic_info t2
on t1.related_order_code = t2.order_code on t1.related_order_code = t2.order_code
where t1.member_id = #{dto.memberId,jdbcType=VARCHAR} where t1.member_id = #{dto.memberId,jdbcType=VARCHAR}
and t1.wallet_code = #{dto.walletCode,jdbcType=VARCHAR}
and t1.create_time <![CDATA[ >= ]]> #{dto.tradeDate,jdbcType=VARCHAR} and t1.create_time <![CDATA[ >= ]]> #{dto.tradeDate,jdbcType=VARCHAR}
and t1.create_time <![CDATA[ < ]]> #{dto.endDate,jdbcType=VARCHAR} and t1.create_time <![CDATA[ < ]]> #{dto.endDate,jdbcType=VARCHAR}
and t1.sub_type != '12' and t1.sub_type != '12'