Merge remote-tracking branch 'origin/dev' into dev

This commit is contained in:
cabbage 2025-09-26 17:54:37 +08:00
commit 1595f11723
10 changed files with 44 additions and 27 deletions

View File

@ -180,7 +180,9 @@ public class BonusSettleServiceImpl implements IBonusSettleService {
public void calculateCuMemberRetailRangeBySaOrder(SaOrderExt orderExt) {
Integer updateType = null;
String symbol = orderExt.getCancelBool() ? "-" : "+";
if (orderExt.getOrderType().equals(EOrderType.RETAIL_REGISTER.getValue())) {
if (orderExt.getOrderType().equals(EOrderType.RETAIL_REGISTER.getValue())
|| orderExt.getOrderType().equals(EOrderType.RETAIL_UPGRADE.getValue())
) {
updateType = 1;
} else if (orderExt.getOrderType().equals(EOrderType.RETAIL_REPURCHASE.getValue())) {
updateType = 2;

View File

@ -467,12 +467,11 @@ public class ApiMemberController extends BaseController {
}
List<memberPointVO> list = iCuMemberRetailService.getMemberPointByUserId(settleTableName,userId);
if (CollectionUtil.isEmpty(list)) {
return null;
return AjaxResult.success();
}
list.forEach(item -> {
item.setMemberSettlePeriod(csPeriod.getSettleDate());
});
memberPointVO memberPointVO = list.get(0);
memberPointVO.setMemberSettlePeriod(csPeriod.getSettleDate());
startPage();
return AjaxResult.success(getDataTable(list));
return AjaxResult.success(memberPointVO);
}
}

View File

@ -22,7 +22,6 @@ import com.hzs.common.core.web.domain.AjaxResult;
import com.hzs.common.core.web.page.TableDataInfo;
import com.hzs.common.domain.member.achieve.CuMemberSettlePeriod;
import com.hzs.common.domain.member.base.CuMember;
import com.hzs.common.domain.member.base.CuMemberRetail;
import com.hzs.common.domain.member.ext.CuMemberExt;
import com.hzs.common.domain.system.config.BdAwards;
import com.hzs.common.security.service.MemberTokenService;
@ -797,10 +796,10 @@ public class CuMemberController extends BaseController {
*/
@Log(module = EOperationModule.MEMBER_POINT, business = EOperationBusiness.MEMBER_POINT, method = EOperationMethod.SELECT)
@GetMapping("/member-point")
public AjaxResult memberPoint(String memberCode,Long memberSettlePeriodId) {
public AjaxResult memberPoint(String memberCode,Long memberSettlePeriodId,String sort,String sortColumn) {
if (memberSettlePeriodId == null) {
log.error("参数错误{}", memberSettlePeriodId);
return AjaxResult.error(MemberMsgConstants.REQUIRED_NOT_EMPTY);
return AjaxResult.error();
}
CuMemberSettlePeriod csPeriod = iCuMemberSettlePeriodService.getById(memberSettlePeriodId);
log.info("会员结算表信息{}",csPeriod);
@ -810,9 +809,9 @@ public class CuMemberController extends BaseController {
Integer isFind = iCuMemberRetailService.getFindCuMemberRetailDetail(settleTableName);
if (isFind == null || isFind != 1) {
log.error("当前表名不存在{}",settleTableName);
return AjaxResult.error("当前会员结算表不存在",settleTableName);
return AjaxResult.error();
}
List<memberPointVO> list = iCuMemberRetailService.getMemberPointByMemberCode(settleTableName,memberCode);
List<memberPointVO> list = iCuMemberRetailService.getMemberPointByMemberCode(settleTableName,memberCode,sort,sortColumn);
list.forEach(item -> {
item.setMemberSettlePeriod(csPeriod.getSettleDate());
});
@ -822,18 +821,16 @@ public class CuMemberController extends BaseController {
/**
*
* @param memberCode
* @param memberSettlePeriodId
* @return
*/
@Log(module = EOperationModule.MEMBER_POINT, business = EOperationBusiness.MEMBER_POINT, method = EOperationMethod.SELECT)
@PostMapping("/member-point-export")
public void memberPointExport(@RequestParam String memberCode,@RequestParam Long memberSettlePeriodId, HttpServletResponse response) {
CuMemberSettlePeriod csPeriod = iCuMemberSettlePeriodService.getById(memberSettlePeriodId);
public void memberPointExport(MemberPointExportParam param, HttpServletResponse response) {
CuMemberSettlePeriod csPeriod = iCuMemberSettlePeriodService.getById(param.getMemberSettlePeriodId());
log.info("会员结算表信息{}",csPeriod);
String settleTableName = TableNameConstants.CU_MEMBER_RETAIL_RANGE + csPeriod.getPkId();
log.info("会员结算表名称{}",settleTableName);
List<memberPointVO> list = iCuMemberRetailService.getMemberPointByMemberCode(settleTableName,memberCode);
List<memberPointVO> list = iCuMemberRetailService.getMemberPointByMemberCode(settleTableName,param.getMemberCode(),param.getSort(),param.getSortColumn());
list.forEach(item -> {
item.setMemberSettlePeriod(csPeriod.getSettleDate());
});

View File

@ -20,7 +20,7 @@ public interface CuMemberRetailMapper extends BaseMapper<CuMemberRetail> {
Integer getFindCumemberRetailDetail(@Param("settleTableName") String settleTableName);
List<memberPointVO> getMemberPointByMemberCode(@Param("settleTableName") String settleTableName, @Param("memberCode") String memberCode);
List<memberPointVO> getMemberPointByMemberCode(@Param("settleTableName") String settleTableName, @Param("memberCode") String memberCode,@Param("sort") String sort,@Param("sortColumn") String sortColumn);
List<memberPointVO> getMemberPointByUserId(@Param("settleTableName") String settleTableName, @Param("userId") Long userId);
}

View File

@ -0,0 +1,17 @@
package com.hzs.member.base.param;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.web.bind.annotation.RequestParam;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class MemberPointExportParam {
private String memberCode;
private Long memberSettlePeriodId;
private String sort;
private String sortColumn;
}

View File

@ -17,7 +17,7 @@ public interface ICuMemberRetailService{
Integer getFindCuMemberRetailDetail(String settleTableName);
List<memberPointVO> getMemberPointByMemberCode(String settleTableName, String memberCode);
List<memberPointVO> getMemberPointByMemberCode(String settleTableName, String memberCode,String sort,String sortColumn);
List<memberPointVO> getMemberPointByUserId(String settleTableName, Long userId);
}

View File

@ -7,7 +7,6 @@ import com.hzs.member.base.service.ICuMemberRetailService;
import com.hzs.member.base.vo.memberPointVO;
import org.springframework.stereotype.Service;
import java.util.Collections;
import java.util.List;
/**
@ -27,8 +26,8 @@ public class CuMemberRetailServiceImpl extends ServiceImpl<CuMemberRetailMapper,
}
@Override
public List<memberPointVO> getMemberPointByMemberCode(String settleTableName, String memberCode) {
return baseMapper.getMemberPointByMemberCode(settleTableName,memberCode);
public List<memberPointVO> getMemberPointByMemberCode(String settleTableName, String memberCode, String sort, String sortColumn) {
return baseMapper.getMemberPointByMemberCode(settleTableName,memberCode,sort,sortColumn);
}
@Override

View File

@ -7,6 +7,7 @@ import com.hzs.common.core.constant.msg.CommonMsgConstants;
import com.hzs.common.core.enums.*;
import com.hzs.common.core.web.controller.BaseController;
import com.hzs.common.core.web.domain.AjaxResult;
import com.hzs.common.core.web.page.TableDataInfo;
import com.hzs.common.domain.member.achieve.CuMemberRetailDetail;
import com.hzs.common.domain.member.achieve.CuMemberSettlePeriod;
import com.hzs.common.domain.member.base.CuMember;
@ -141,7 +142,7 @@ public class ApiMemberStructureController extends BaseController {
Integer isFind = iCumemberRetailDetailService.getFindCumemberRetailDetail(settleTableName);
if (isFind == null || isFind != 1) {
log.error("当前会员日结信息不存在{}",settleTableName);
return AjaxResult.error("数据查询错误,请联系客服处理");
return AjaxResult.error();
}
startPage();
// 查询当前会员所有子点位信息

View File

@ -22,6 +22,7 @@ import com.hzs.common.core.utils.StringUtils;
import com.hzs.common.core.utils.sign.Base64Util;
import com.hzs.common.core.web.controller.BaseController;
import com.hzs.common.core.web.domain.AjaxResult;
import com.hzs.common.core.web.page.TableDataInfo;
import com.hzs.common.domain.member.achieve.CuMemberRetailDetail;
import com.hzs.common.domain.member.achieve.CuMemberSettlePeriod;
import com.hzs.common.domain.member.achieve.ext.CuMemberRetailSExt;
@ -267,7 +268,7 @@ public class MemberStructureController extends BaseController {
Integer isFind = iCumemberRetailDetailService.getFindCumemberRetailDetail(settleTableName);
if (isFind == null || isFind != 1) {
log.error("当前表名不存在{}",settleTableName);
return AjaxResult.error("当前日结信息表不存在",settleTableName);
return AjaxResult.error();
}
startPage();
// 查询当前会员所有子点位信息

View File

@ -83,8 +83,9 @@
<if test="memberCode != null and memberCode != ''">
AND cmr.MEMBER_CODE = #{memberCode}
</if>
ORDER BY
cu.CREATION_TIME
<if test="sort != null and sort != '' and sortColumn != null and sortColumn != ''">
ORDER BY cmr.${sortColumn} ${sort}
</if>
</select>
<select id="getMemberPointByUserId" resultType="com.hzs.member.base.vo.memberPointVO">
SELECT