package com.tcm.training.admin.points.service;
|
|
import cn.idev.excel.FastExcel;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.tcm.training.admin.common.DateTimes;
|
import com.tcm.training.admin.common.PhoneMasker;
|
import com.tcm.training.admin.points.entity.PointsLedger;
|
import com.tcm.training.admin.points.excel.PointsLedgerExcelRow;
|
import com.tcm.training.admin.points.mapper.PointsLedgerMapper;
|
import com.tcm.training.admin.points.row.PointsLedgerRow;
|
import com.tcm.training.admin.points.row.PointsLedgerSummaryRow;
|
import com.tcm.training.admin.points.row.PointsLedgerSyncExchangeRow;
|
import com.tcm.training.admin.points.row.PointsLedgerSyncQuizRow;
|
import com.tcm.training.admin.points.row.PointsRegionOptionRow;
|
import com.tcm.training.admin.points.vo.PointsLedgerItemVO;
|
import com.tcm.training.admin.points.vo.PointsLedgerPageVO;
|
import com.tcm.training.admin.points.vo.PointsLedgerSummaryVO;
|
import com.tcm.training.admin.points.vo.PointsRegionOptionVO;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.net.URLEncoder;
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service
|
public class PointsLedgerAppService {
|
|
public static final String TYPE_INCOME = "INCOME";
|
public static final String TYPE_EXPENSE = "EXPENSE";
|
public static final String BUSINESS_LIVE_WATCH = "LIVE_WATCH";
|
public static final String BUSINESS_POINTS_EXCHANGE = "POINTS_EXCHANGE";
|
public static final String BUSINESS_POINTS_SETTLEMENT = "POINTS_SETTLEMENT";
|
public static final String SOURCE_LIVE_QUIZ = "LIVE_QUIZ";
|
public static final String SOURCE_EXCHANGE_ITEM = "EXCHANGE_ITEM";
|
public static final String SOURCE_POINTS_SETTLEMENT = "POINTS_SETTLEMENT";
|
public static final String REF_LIVE_COURSE = "LIVE_COURSE";
|
public static final String REF_EXCHANGE_ITEM = "EXCHANGE_ITEM";
|
public static final String REF_POINTS_CONFIG = "POINTS_CONFIG";
|
|
private final PointsLedgerMapper pointsLedgerMapper;
|
|
public PointsLedgerAppService(PointsLedgerMapper pointsLedgerMapper) {
|
this.pointsLedgerMapper = pointsLedgerMapper;
|
}
|
|
public PointsLedgerPageVO page(int page,
|
int pageSize,
|
String userPhone,
|
String regionCode,
|
String clinicName,
|
String incomeExpenseType,
|
String businessType,
|
String contentKeyword,
|
String referenceNo,
|
LocalDateTime operatedFrom,
|
LocalDateTime operatedTo) {
|
syncLedger();
|
IPage<PointsLedgerRow> result = pointsLedgerMapper.selectLedgerPage(
|
new Page<PointsLedgerRow>(page, pageSize),
|
trimToNull(userPhone),
|
trimToNull(regionCode),
|
trimToNull(clinicName),
|
trimToNull(incomeExpenseType),
|
trimToNull(businessType),
|
trimToNull(contentKeyword),
|
trimToNull(referenceNo),
|
operatedFrom,
|
operatedTo
|
);
|
PointsLedgerPageVO vo = new PointsLedgerPageVO();
|
vo.setList(toItems(result.getRecords()));
|
vo.setTotal(result.getTotal());
|
vo.setPage(result.getCurrent());
|
vo.setPageSize(result.getSize());
|
vo.setSummary(buildSummary(userPhone, regionCode, clinicName, incomeExpenseType, businessType, contentKeyword, referenceNo, operatedFrom, operatedTo));
|
return vo;
|
}
|
|
public void export(HttpServletResponse response,
|
String userPhone,
|
String regionCode,
|
String clinicName,
|
String incomeExpenseType,
|
String businessType,
|
String contentKeyword,
|
String referenceNo,
|
LocalDateTime operatedFrom,
|
LocalDateTime operatedTo) throws IOException {
|
syncLedger();
|
response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
|
response.setCharacterEncoding("utf-8");
|
String filename = URLEncoder.encode("积分收支明细", "UTF-8").replace("+", "%20");
|
response.setHeader("Content-Disposition", "attachment;filename*=utf-8''" + filename + ".xlsx");
|
List<PointsLedgerRow> rows = pointsLedgerMapper.selectLedgerList(
|
trimToNull(userPhone),
|
trimToNull(regionCode),
|
trimToNull(clinicName),
|
trimToNull(incomeExpenseType),
|
trimToNull(businessType),
|
trimToNull(contentKeyword),
|
trimToNull(referenceNo),
|
operatedFrom,
|
operatedTo
|
);
|
List<PointsLedgerExcelRow> exports = new ArrayList<PointsLedgerExcelRow>();
|
for (int i = 0; i < rows.size(); i++) {
|
PointsLedgerRow row = rows.get(i);
|
PointsLedgerExcelRow export = new PointsLedgerExcelRow();
|
export.setSerialNo(i + 1);
|
export.setUserNickname(defaultText(row.getUserNickname()));
|
export.setUserPhone(PhoneMasker.mask(row.getUserPhone()));
|
export.setClinicRegion(defaultText(row.getClinicRegion()));
|
export.setClinicName(defaultText(row.getClinicName()));
|
export.setIncomeExpenseType(incomeExpenseText(row.getIncomeExpenseType()));
|
export.setBusinessType(businessTypeText(row.getBusinessType()));
|
export.setContentName(defaultText(row.getContentName()));
|
export.setReferenceNo(defaultText(row.getReferenceNo()));
|
export.setPointsDelta(formatSignedPoints(row.getPointsDelta()));
|
export.setOperatedAt(formatMinute(row.getOperatedAt()));
|
exports.add(export);
|
}
|
FastExcel.write(response.getOutputStream(), PointsLedgerExcelRow.class)
|
.sheet("积分收支明细")
|
.doWrite(exports);
|
}
|
|
public List<PointsRegionOptionVO> regionOptions() {
|
List<PointsRegionOptionRow> rows = pointsLedgerMapper.selectRegionOptions();
|
List<PointsRegionOptionVO> list = new ArrayList<PointsRegionOptionVO>();
|
for (PointsRegionOptionRow row : rows) {
|
list.add(new PointsRegionOptionVO(row.getRegionCode(), row.getRegionName()));
|
}
|
return list;
|
}
|
|
@Transactional
|
public void syncLedger() {
|
syncQuizLedgers();
|
syncExchangeLedgers();
|
}
|
|
@Transactional
|
public void createExchangeExpenseLedger(Long sourceId,
|
Long appUserId,
|
String userNickname,
|
String userPhone,
|
Long clinicId,
|
String clinicName,
|
String provinceCode,
|
String provinceName,
|
String cityCode,
|
String cityName,
|
String districtCode,
|
String districtName,
|
String contentName,
|
Long referenceId,
|
String referenceNo,
|
Integer pointsDelta,
|
LocalDateTime operatedAt) {
|
if (sourceId == null) {
|
return;
|
}
|
PointsLedger exists = pointsLedgerMapper.selectOne(new LambdaQueryWrapper<PointsLedger>()
|
.eq(PointsLedger::getDeleted, 0)
|
.eq(PointsLedger::getSourceType, SOURCE_EXCHANGE_ITEM)
|
.eq(PointsLedger::getSourceId, sourceId)
|
.last("limit 1"));
|
if (exists != null) {
|
return;
|
}
|
PointsLedger ledger = buildBaseLedger(appUserId, userNickname, userPhone, clinicId, clinicName,
|
provinceCode, provinceName, cityCode, cityName, districtCode, districtName);
|
ledger.setIncomeExpenseType(TYPE_EXPENSE);
|
ledger.setBusinessType(BUSINESS_POINTS_EXCHANGE);
|
ledger.setContentName(contentName);
|
ledger.setReferenceType(REF_EXCHANGE_ITEM);
|
ledger.setReferenceId(referenceId);
|
ledger.setReferenceNo(referenceNo);
|
ledger.setPointsDelta(pointsDelta == null ? 0 : -Math.abs(pointsDelta));
|
ledger.setOperatedAt(operatedAt == null ? LocalDateTime.now() : operatedAt);
|
ledger.setSourceType(SOURCE_EXCHANGE_ITEM);
|
ledger.setSourceId(sourceId);
|
pointsLedgerMapper.insert(ledger);
|
}
|
|
/**
|
* 记录积分活动结束后未达标用户被系统清零的支出流水。
|
*/
|
@Transactional
|
public void createSettlementClearLedger(Long sourceId,
|
Long appUserId,
|
String userNickname,
|
String userPhone,
|
Long clinicId,
|
String clinicName,
|
String provinceCode,
|
String provinceName,
|
String cityCode,
|
String cityName,
|
String districtCode,
|
String districtName,
|
String contentName,
|
Long referenceId,
|
String referenceNo,
|
Integer pointsDelta,
|
LocalDateTime operatedAt) {
|
if (sourceId == null) {
|
return;
|
}
|
PointsLedger exists = pointsLedgerMapper.selectOne(new LambdaQueryWrapper<PointsLedger>()
|
.eq(PointsLedger::getDeleted, 0)
|
.eq(PointsLedger::getSourceType, SOURCE_POINTS_SETTLEMENT)
|
.eq(PointsLedger::getSourceId, sourceId)
|
.last("limit 1"));
|
if (exists != null) {
|
return;
|
}
|
PointsLedger ledger = buildBaseLedger(appUserId, userNickname, userPhone, clinicId, clinicName,
|
provinceCode, provinceName, cityCode, cityName, districtCode, districtName);
|
ledger.setIncomeExpenseType(TYPE_EXPENSE);
|
ledger.setBusinessType(BUSINESS_POINTS_SETTLEMENT);
|
ledger.setContentName(contentName);
|
ledger.setReferenceType(REF_POINTS_CONFIG);
|
ledger.setReferenceId(referenceId);
|
ledger.setReferenceNo(referenceNo);
|
ledger.setPointsDelta(pointsDelta == null ? 0 : -Math.abs(pointsDelta));
|
ledger.setOperatedAt(operatedAt == null ? LocalDateTime.now() : operatedAt);
|
ledger.setSourceType(SOURCE_POINTS_SETTLEMENT);
|
ledger.setSourceId(sourceId);
|
pointsLedgerMapper.insert(ledger);
|
}
|
|
private void syncQuizLedgers() {
|
List<PointsLedgerSyncQuizRow> rows = pointsLedgerMapper.selectMissingQuizLedgerRows();
|
for (PointsLedgerSyncQuizRow row : rows) {
|
PointsLedger ledger = buildBaseLedger(row.getAppUserId(), row.getUserNickname(), row.getUserPhone(),
|
row.getClinicId(), row.getClinicName(), row.getProvinceCode(), row.getProvinceName(),
|
row.getCityCode(), row.getCityName(), row.getDistrictCode(), row.getDistrictName());
|
ledger.setIncomeExpenseType(TYPE_INCOME);
|
ledger.setBusinessType(BUSINESS_LIVE_WATCH);
|
ledger.setContentName(row.getContentName());
|
ledger.setReferenceType(REF_LIVE_COURSE);
|
ledger.setReferenceId(row.getReferenceId());
|
ledger.setReferenceNo(row.getReferenceNo());
|
ledger.setPointsDelta(Math.abs(row.getPointsDelta() == null ? 0 : row.getPointsDelta()));
|
ledger.setOperatedAt(row.getOperatedAt());
|
ledger.setSourceType(SOURCE_LIVE_QUIZ);
|
ledger.setSourceId(row.getSourceId());
|
pointsLedgerMapper.insert(ledger);
|
}
|
}
|
|
private void syncExchangeLedgers() {
|
List<PointsLedgerSyncExchangeRow> rows = pointsLedgerMapper.selectMissingExchangeLedgerRows();
|
for (PointsLedgerSyncExchangeRow row : rows) {
|
createExchangeExpenseLedger(
|
row.getSourceId(),
|
row.getAppUserId(),
|
row.getUserNickname(),
|
row.getUserPhone(),
|
row.getClinicId(),
|
row.getClinicName(),
|
row.getProvinceCode(),
|
row.getProvinceName(),
|
row.getCityCode(),
|
row.getCityName(),
|
row.getDistrictCode(),
|
row.getDistrictName(),
|
row.getContentName(),
|
row.getReferenceId(),
|
row.getReferenceNo(),
|
row.getPointsDelta(),
|
row.getOperatedAt()
|
);
|
}
|
}
|
|
private PointsLedgerSummaryVO buildSummary(String userPhone,
|
String regionCode,
|
String clinicName,
|
String incomeExpenseType,
|
String businessType,
|
String contentKeyword,
|
String referenceNo,
|
LocalDateTime operatedFrom,
|
LocalDateTime operatedTo) {
|
PointsLedgerSummaryRow row = pointsLedgerMapper.selectLedgerSummary(
|
trimToNull(userPhone),
|
trimToNull(regionCode),
|
trimToNull(clinicName),
|
trimToNull(incomeExpenseType),
|
trimToNull(businessType),
|
trimToNull(contentKeyword),
|
trimToNull(referenceNo),
|
operatedFrom,
|
operatedTo
|
);
|
PointsLedgerSummaryVO vo = new PointsLedgerSummaryVO();
|
vo.setIncomeTotal(row == null || row.getIncomeTotal() == null ? 0 : row.getIncomeTotal());
|
vo.setExpenseTotal(row == null || row.getExpenseTotal() == null ? 0 : row.getExpenseTotal());
|
vo.setLiveWatchIncomeTotal(row == null || row.getLiveWatchIncomeTotal() == null ? 0 : row.getLiveWatchIncomeTotal());
|
vo.setExchangeExpenseTotal(row == null || row.getExchangeExpenseTotal() == null ? 0 : row.getExchangeExpenseTotal());
|
return vo;
|
}
|
|
private List<PointsLedgerItemVO> toItems(List<PointsLedgerRow> rows) {
|
List<PointsLedgerItemVO> list = new ArrayList<PointsLedgerItemVO>();
|
for (PointsLedgerRow row : rows) {
|
PointsLedgerItemVO item = new PointsLedgerItemVO();
|
item.setId(row.getId());
|
item.setUserNickname(row.getUserNickname());
|
item.setUserPhone(PhoneMasker.mask(row.getUserPhone()));
|
item.setClinicRegion(row.getClinicRegion());
|
item.setClinicName(row.getClinicName());
|
item.setIncomeExpenseType(incomeExpenseText(row.getIncomeExpenseType()));
|
item.setBusinessType(businessTypeText(row.getBusinessType()));
|
item.setContentName(row.getContentName());
|
item.setReferenceNo(row.getReferenceNo());
|
item.setPointsDelta(row.getPointsDelta());
|
item.setOperatedAt(row.getOperatedAt());
|
item.setReferencePath(row.getReferencePath());
|
item.setCanJump(row.getCanJump() != null && row.getCanJump() == 1);
|
list.add(item);
|
}
|
return list;
|
}
|
|
private PointsLedger buildBaseLedger(Long appUserId,
|
String userNickname,
|
String userPhone,
|
Long clinicId,
|
String clinicName,
|
String provinceCode,
|
String provinceName,
|
String cityCode,
|
String cityName,
|
String districtCode,
|
String districtName) {
|
PointsLedger ledger = new PointsLedger();
|
ledger.setAppUserId(appUserId);
|
ledger.setUserNickname(userNickname);
|
ledger.setUserPhone(userPhone);
|
ledger.setClinicId(clinicId);
|
ledger.setClinicName(clinicName);
|
ledger.setProvinceCode(provinceCode);
|
ledger.setProvinceName(provinceName);
|
ledger.setCityCode(cityCode);
|
ledger.setCityName(cityName);
|
ledger.setDistrictCode(districtCode);
|
ledger.setDistrictName(districtName);
|
return ledger;
|
}
|
|
private String incomeExpenseText(String value) {
|
if (TYPE_INCOME.equals(value)) {
|
return "收入";
|
}
|
if (TYPE_EXPENSE.equals(value)) {
|
return "支出";
|
}
|
return "-";
|
}
|
|
private String businessTypeText(String value) {
|
if (BUSINESS_LIVE_WATCH.equals(value)) {
|
return "观看直播";
|
}
|
if (BUSINESS_POINTS_EXCHANGE.equals(value)) {
|
return "积分兑换";
|
}
|
if (BUSINESS_POINTS_SETTLEMENT.equals(value)) {
|
return "活动结算";
|
}
|
return "-";
|
}
|
|
private String formatSignedPoints(Integer value) {
|
int points = value == null ? 0 : value;
|
return points > 0 ? "+" + points : String.valueOf(points);
|
}
|
|
private String formatMinute(LocalDateTime value) {
|
if (value == null) {
|
return "-";
|
}
|
return value.format(DateTimes.localDateTimeFormatter()).substring(0, 16);
|
}
|
|
private String trimToNull(String text) {
|
if (text == null) {
|
return null;
|
}
|
String value = text.trim();
|
return value.isEmpty() ? null : value;
|
}
|
|
private String defaultText(String text) {
|
if (text == null || text.trim().isEmpty()) {
|
return "-";
|
}
|
return text;
|
}
|
}
|
