package com.nova.sankuai.service.impl;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.nova.sankuai.domain.dto.RechargePageDto;
|
import com.nova.sankuai.domain.entity.CustomerPushRecord;
|
import com.nova.sankuai.domain.enums.UserTypeEnum;
|
import com.nova.sankuai.domain.vo.CustomerPushRecordVo;
|
import com.nova.sankuai.infra.mapper.CustomerPushRecordMapper;
|
import com.nova.sankuai.infra.utils.PageRequest;
|
import com.nova.sankuai.infra.utils.PageUtil;
|
import com.nova.sankuai.security.UserDetail;
|
import com.nova.sankuai.service.ICustomerPushRecordService;
|
import lombok.AllArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @author weikangdi
|
* @create 2021/11/5
|
*/
|
@Service
|
@AllArgsConstructor
|
public class CustomerPushRecordServiceImpl extends ServiceImpl<CustomerPushRecordMapper, CustomerPushRecord> implements ICustomerPushRecordService {
|
|
private final CustomerPushRecordMapper mapper;
|
|
private final PageUtil pageUtil;
|
|
@Override
|
public IPage<CustomerPushRecordVo> pageModel(PageRequest pageRequest, RechargePageDto pageDto, UserDetail user) {
|
IPage<CustomerPushRecordVo> page = mapper.pageModel(pageUtil.getPage(pageRequest), pageDto);
|
if (UserTypeEnum.USER.getCode().equals(user.getType())) {
|
List<CustomerPushRecordVo> records = page.getRecords();
|
List<CustomerPushRecordVo> newRecords = new ArrayList<>();
|
for (CustomerPushRecordVo record : records) {
|
if (CustomerPushRecord.STATUS_INVALID == record.getStatus()) {
|
record.setCustomerRecordName("***");
|
record.setPhone("***");
|
record.setCustomerRecordId(null);
|
}
|
newRecords.add(record);
|
}
|
page = page.setRecords(newRecords);
|
}
|
return page;
|
}
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class})
|
public void createRecord(Long customerRecordId, Long mechanismId, Long deductionId, Integer status, String memo) {
|
CustomerPushRecord pushRecord = new CustomerPushRecord();
|
pushRecord.setMechanismId(mechanismId);
|
pushRecord.setDeductionId(deductionId);
|
pushRecord.setCustomerRecordId(customerRecordId);
|
pushRecord.setStatus(status);
|
pushRecord.setMemo(memo);
|
pushRecord.setCreationDate(new Date());
|
save(pushRecord);
|
}
|
}
|
