记得上下班打卡 | git大法好,push需谨慎

Commit 431a92e3 authored by GaoHu's avatar GaoHu

exit

parent 1634ab34
package com.liquidnet.client.admin.zhengzai.smile.dto;
import lombok.Data;
import java.util.List;
/**
* @author TT
*/
@Data
public class SaleDataVo {
/**
* 演出id
*/
private String performancesId;
/**
* 票提设置集合
*/
private List<ShowAgentVo> showAgentVoList;
/**
* 代理数据
*/
private List<UserData> userDataList;
}
package com.liquidnet.client.admin.zhengzai.smile.dto;
import lombok.Data;
import java.util.List;
/**
* @author TT
*/
@Data
public class UserData {
/**
* 用户uid
*/
private String uid;
/**
* 用户名称
*/
private String username;
/**
* 城市名称
*/
private String cityName;
/**
* 身份 1。总代 2.普代
*/
private Integer type;
private List<
}
package com.liquidnet.client.admin.zhengzai.smile.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.liquidnet.service.smile.entity.SmilePrice;
/**
* <p>
* 服务类
* </p>
*
* @author liquidnet
* @since 2022-03-22
*/
public interface ISmilePriceService extends IService<SmilePrice> {
}
package com.liquidnet.client.admin.zhengzai.smile.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.liquidnet.client.admin.zhengzai.smile.service.ISmilePriceService;
import com.liquidnet.service.smile.entity.SmilePrice;
import com.liquidnet.service.smile.mapper.SmilePriceMapper;
import org.springframework.stereotype.Service;
/**
* <p>
* 服务实现类
* </p>
*
* @author liquidnet
* @since 2022-03-22
*/
@Service
public class SmilePriceServiceImpl extends ServiceImpl<SmilePriceMapper, SmilePrice> implements ISmilePriceService {
}
......@@ -53,7 +53,7 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
try {
Map<String,Object> map = BeanUtil.convertBeanToMap(smileSchoolParam);
List<SmileSchool> smileSchools = smileSchoolMapper.selectSchoolList(map);
pageInfo = new PageInfo<SmileSchool>(smileSchools);
pageInfo = new PageInfo<>(smileSchools);
} catch (Exception e) {
e.printStackTrace();
return null;
......
......@@ -54,9 +54,6 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
@Autowired
SmileRedisUtils smileRedisUtils;
@Autowired
private KylinPerformancesMapper performancesMapper;
@Autowired
MongoTemplate mongoTemplate;
......@@ -104,9 +101,9 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
int num = kylinOrderTicketAndAgentVo.getNumber() - kylinOrderTicketAndAgentVo.getRefundNumber();
if (num > 0){
open +=num;
totalSalePrice = totalSalePrice.add((kylinOrderTicketAndAgentVo.getPriceActual()).subtract(kylinOrderTicketAndAgentVo.getPriceRefund()).multiply(BigDecimal.valueOf(num)));
//实付价格-退款价格
totalSalePrice = totalSalePrice.add((kylinOrderTicketAndAgentVo.getPriceActual()).subtract(kylinOrderTicketAndAgentVo.getPriceRefund()));
}
}
vo.setOpen(open);
//缓存redis
......@@ -123,7 +120,7 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
return vo;
}).collect(Collectors.toList());
pageInfo = new PageInfo<ShowVo>(showVoList);
pageInfo = new PageInfo<>(showVoList);
return pageInfo;
}
......@@ -142,18 +139,20 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
}
@Override
public AjaxResult make(String performancesId) {
public AjaxResult price(String performancesId) {
if (!smileRedisUtils.hasKey(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId))) {
smileRedisUtils.set(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId), 1);
} else {
smileRedisUtils.del(SmileRedisConst.SELL_SHOW_PAYMENT.concat(performancesId));
}
//TODO:持久化存儲操作
return AjaxResult.success();
}
@Override
public AjaxResult getShowById(String performancesId) {
if (StringUtils.isEmpty(performancesId)) {
if (!StringUtils.isEmpty(performancesId)) {
ShowVoById showVoById = new ShowVoById();
//根据演出ID查询演出数据演出数据
KylinPerformanceVo kylinPerformanceVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performancesId)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
......@@ -174,14 +173,11 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
//票提集合 根据演出id查询票提id
List<ShowAgentVo> showAgentVoList = new ArrayList<>();
List<ShowTicketVo> showTicketVoList = new ArrayList<>();
LambdaQueryWrapper<SmileAgent> queryWrapper = Wrappers.lambdaQuery(SmileAgent.class);
queryWrapper.eq(SmileAgent::getPerformanceId, performancesId);
List<SmileAgent> smileAgents = smileAgentMapper.selectList(queryWrapper);
Map<String, SmileAgent> map = new HashMap<>();
smileAgents.forEach(smileAgent -> {
map.put(smileAgent.getTicketId(), smileAgent);
});
Map<String, SmileAgent> map = new HashMap<>(smileAgents.size());
smileAgents.forEach(smileAgent -> map.put(smileAgent.getTicketId(), smileAgent));
List<String> ticketsIdList = smileAgents.stream().map(SmileAgent::getTicketId).collect(Collectors.toList());
//根据票提IDs查询票信息
......@@ -190,15 +186,7 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
for (TicketAndStatusDao ticketAndStatusDao : ticketAndStatusDaoList) {
SmileAgent smileAgent = map.get(ticketAndStatusDao.getTicketsId());
ShowAgentVo showAgentVo = new ShowAgentVo();
showAgentVo.setId(ticketAndStatusDao.getMid());
showAgentVo.setPerformanceId(performancesId);
showAgentVo.setTicketId(ticketAndStatusDao.getTicketsId());
showAgentVo.setTitle(ticketAndStatusDao.getTitle());
//总代票提
showAgentVo.setTotalCarry(smileAgent.getTotalCarry());
//普代票提
showAgentVo.setOrdCarry(smileAgent.getOrdCarry());
ShowAgentVo showAgentVo = getShowAgentVo(performancesId, ticketAndStatusDao, smileAgent);
ShowTicketVo showTicketVo = new ShowTicketVo();
showTicketVo.setTitle(ticketAndStatusDao.getTitle());
......@@ -220,13 +208,14 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
int num = kylinOrderTicketAndAgentVo.getNumber() - kylinOrderTicketAndAgentVo.getRefundNumber();
if (num > 0) {
agentSaleNum+=num;
//单价*票提*数量
totalPrice = totalPrice.add(
(ticketAndStatusDao.getPrice().multiply(kylinOrderTicketAndAgentVo.getAgentDistributions()))
.multiply(BigDecimal.valueOf(num)));
}
}
showTicketVo.setAgentSaleNum(agentSaleNum);
showAgentVo.setTotalCarry(totalPrice);
showTicketVo.setTotalPrice(totalPrice);
showAgentVoList.add(showAgentVo);
showTicketVoList.add(showTicketVo);
......@@ -251,5 +240,52 @@ public class SmileShowServiceImpl extends ServiceImpl<SmileSchoolMapper, SmileSc
return null;
}
@Override
public AjaxResult saleData(String performancesId) {
if (!StringUtils.isEmpty(performancesId)){
SaleDataVo saleDataVo = new SaleDataVo();
LambdaQueryWrapper<SmileAgent> queryWrapper = Wrappers.lambdaQuery(SmileAgent.class);
queryWrapper.eq(SmileAgent::getPerformanceId, performancesId);
List<SmileAgent> smileAgents = smileAgentMapper.selectList(queryWrapper);
Map<String, SmileAgent> map = new HashMap<>(smileAgents.size());
smileAgents.forEach(smileAgent -> map.put(smileAgent.getTicketId(), smileAgent));
List<String> ticketsIdList = smileAgents.stream().map(SmileAgent::getTicketId).collect(Collectors.toList());
List<ShowAgentVo> showAgentVoList = new ArrayList<>();
//根据票提IDs查询票信息
List<TicketAndStatusDao> ticketAndStatusDaoList = kylinTicketsMapper.selectTicketsByIds(ticketsIdList);
for (TicketAndStatusDao ticketAndStatusDao : ticketAndStatusDaoList) {
SmileAgent smileAgent = map.get(ticketAndStatusDao.getTicketsId());
ShowAgentVo showAgentVo = getShowAgentVo(performancesId, ticketAndStatusDao, smileAgent);
showAgentVoList.add(showAgentVo);
}
saleDataVo.setShowAgentVoList(showAgentVoList);
}
return null;
}
private ShowAgentVo getShowAgentVo(String performancesId, TicketAndStatusDao ticketAndStatusDao, SmileAgent smileAgent) {
ShowAgentVo showAgentVo = new ShowAgentVo();
showAgentVo.setId(ticketAndStatusDao.getMid());
showAgentVo.setPerformanceId(performancesId);
showAgentVo.setTicketId(ticketAndStatusDao.getTicketsId());
showAgentVo.setTitle(ticketAndStatusDao.getTitle());
//总代票提
showAgentVo.setTotalCarry(smileAgent.getTotalCarry());
//普代票提
showAgentVo.setOrdCarry(smileAgent.getOrdCarry());
return showAgentVo;
}
}
package com.liquidnet.service.smile.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.math.BigDecimal;
import java.time.LocalDateTime;
/**
* <p>
*
* </p>
*
* @author liquidnet
* @since 2022-03-22
*/
@Data
@EqualsAndHashCode(callSuper = false)
public class SmilePrice implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键
*/
@TableId(value = "id", type = IdType.AUTO)
private Long id;
/**
* 演出id
*/
private String performancesId;
/**
* 票id
*/
private String ticketsId;
/**
* 用户id
*/
private String uid;
/**
* 打款金额
*/
private BigDecimal price;
/**
* 创建时间
*/
private LocalDateTime createdAt;
}
package com.liquidnet.service.smile.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.liquidnet.service.smile.entity.SmilePrice;
/**
* <p>
* Mapper 接口
* </p>
*
* @author liquidnet
* @since 2022-03-22
*/
public interface SmilePriceMapper extends BaseMapper<SmilePrice> {
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment