分销记录

This commit is contained in:
张松 2025-10-30 11:33:40 +08:00
parent 9ed1548487
commit 8bd9b29b7a
1 changed files with 5 additions and 4 deletions

View File

@ -24,6 +24,7 @@ import com.czg.service.market.mapper.MkDistributionFlowMapper;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Map;
@ -47,12 +48,12 @@ public class MkDistributionFlowServiceImpl extends ServiceImpl<MkDistributionFlo
List<MkDistributionFlowVO> list = mapper.pageInfo(shopId, startTime, endTime, status, key, id, null);
Page<MkDistributionFlowVO> page = PageUtil.convert(new PageInfo<>(list));
Map<String, Object> map = BeanUtil.beanToMap(page);
map.put("successAmount", getOne(new QueryWrapper().eq(MkDistributionFlow::getShopId, shopId)
map.put("successAmount", getOneAs(new QueryWrapper().eq(MkDistributionFlow::getShopId, shopId)
.eq(MkDistributionFlow::getStatus, TableValueConstant.DistributionFlow.Status.SUCCESS.getCode())
.select("sum(reward_amount)")));
map.put("pendingAmount", getOne(new QueryWrapper().eq(MkDistributionFlow::getShopId, shopId)
.select("sum(reward_amount)"), BigDecimal.class));
map.put("pendingAmount", getOneAs(new QueryWrapper().eq(MkDistributionFlow::getShopId, shopId)
.eq(MkDistributionFlow::getStatus, TableValueConstant.DistributionFlow.Status.PENDING.getCode())
.select("sum(reward_amount)")));
.select("sum(reward_amount)"), BigDecimal.class));
map.put("balanceAmount", shopInfoService.getById(shopId).getAmount());
return map;
}