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

Skip to content

L
liquidnet-bus-v1
Commit b9b8478b authored by 胡佳晨's avatar 胡佳晨
Browse files
Options

order相关 sql 提交

parent b33cc117
Hide whitespace changes
Inline Side-by-side
Showing with 511 additions and 1007 deletions
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/admin/IKylinPerformancesAdminService.java
View file @ b9b8478b
......@@ -84,6 +84,14 @@ public interface IKylinPerformancesAdminService extends IService<KylinPerformanc
*/
boolean setRecommend(List<PerformanceRecommendAdminParam> performancesId);
/**
* 设置 演出推荐 关联
*
* @param performancesId 相关参数
* @return boolean
*/
Integer setIsShow(String performancesId,Integer isShow);
/**
* 查询 推荐演出列表
*
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/java/com/liquidnet/client/admin/web/controller/zhengzai/kylin/KylinPerformancesController.java
View file @ b9b8478b
......@@ -2,6 +2,7 @@ package com.liquidnet.client.admin.web.controller.zhengzai.kylin;
import com.github.pagehelper.PageInfo;
import com.liquidnet.client.admin.common.core.controller.BaseController;
import com.liquidnet.client.admin.common.core.domain.AjaxResult;
import com.liquidnet.client.admin.common.core.page.TableDataInfo;
import com.liquidnet.client.admin.zhengzai.kylin.service.impl.KylinPerformancesAdminServiceImpl;
import com.liquidnet.service.kylin.dao.PerformanceAdminListDao;
......@@ -16,14 +17,13 @@ import org.springframework.web.bind.annotation.*;
/**
* 演出Controller
*
*
* @author anjiabin
* @date 2021-05-24
*/
@Controller
@RequestMapping("/kylin/performances")
public class KylinPerformancesController extends BaseController
{
public class KylinPerformancesController extends BaseController {
private String prefix = "zhengzai/kylin/performances";
@Autowired
......@@ -31,8 +31,7 @@ public class KylinPerformancesController extends BaseController
@RequiresPermissions("kylin:performances:view")
@GetMapping()
public String performances()
{
public String performances() {
return prefix + "/performances";
}
......@@ -42,8 +41,7 @@ public class KylinPerformancesController extends BaseController
@RequiresPermissions("kylin:performances:list")
@PostMapping("/list")
@ResponseBody
public TableDataInfo list(PerformanceAdminListParam performanceAdminListParam)
{
public TableDataInfo list(PerformanceAdminListParam performanceAdminListParam) {
startPage();/**/
PageInfo<PerformanceAdminListDao> result = kylinPerformancesService.getList(performanceAdminListParam);
return getDataTable(result.getList());
......@@ -56,12 +54,13 @@ public class KylinPerformancesController extends BaseController
result = kylinPerformancesService.performanceDetails(performancesId);
mmap.put("kylinPerformanceMisVo", result);
return prefix + "/details";
// if (null != result) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("获取演出详情失败");
// }
}
@RequiresPermissions("kylin:performances:change")
@PostMapping(value = "/isShow")
@ResponseBody
public AjaxResult setIsShow(String performancesId, Integer isShow) {
return toAjax(kylinPerformancesService.setIsShow(performancesId,isShow));
}
//
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/application-client-admin-web.yml
View file @ b9b8478b
......@@ -91,7 +91,7 @@ spring:
# MyBatis
mybatis:
# 搜索指定包别名
typeAliasesPackage: com.liquidnet.service.kylin.entity,com.liquidnet.client.admin.**.domain
typeAliasesPackage: com.liquidnet.service.kylin.**.entity,com.liquidnet.client.admin.**.domain
# 配置mapper的扫描，找到所有的mapper.xml映射文件
mapperLocations: classpath*:mapper/**/*Mapper.xml,classpath:com.liquidnet.service.kylin.mapper/*Mapper.xml,classpath:com.liquidnet.service.adam.mapper/*Mapper.xml
# 加载全局的配置文件
......
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-web/src/main/resources/templates/zhengzai/kylin/performances/details.html
View file @ b9b8478b
<!DOCTYPE html>
<html lang="zh">
<html lang="zh" xmlns:th="http://www.thymeleaf.org" xmlns:shiro="http://www.pollix.at/thymeleaf/shiro">
<head>
<th:block th:include="include :: header('选项卡 & 面板')" />
<th:block th:include="include :: header('选项卡 & 面板')"/>
</head>
<body class="gray-bg">
<div class="wrapper wrapper-content animated fadeIn">
......@@ -36,11 +36,141 @@
</div>
</div>
<div id="tab-2" class="tab-pane">
<div class="panel-body">
<strong>移动设备优先</strong>
<p>在 Bootstrap 2 中，我们对框架中的某些关键部分增加了对移动设备友好的样式。而在 Bootstrap 3 中，我们重写了整个框架，使其一开始就是对移动设备友好的。这次不是简单的增加一些可选的针对移动设备的样式，而是直接融合进了框架的内核中。也就是说，Bootstrap 是移动设备优先的。针对移动设备的样式融合进了框架的每个角落，而不是增加一个额外的文件。</p>
<div class="panel-body" id="performance_config">
<strong>相关配置</strong>
<div th:width="max" style="margin-top: 10px">
<strong>是否显示当前演出</strong>
<div class="radio check-box">
<input type="radio" value="1" name="isShowCheck"> 显示</label>
</div>
<div class="radio check-box">
<input type="radio" value="0" name="isShowCheck"> 不显示</label>
</div>
<button type="button" class="btn btn-w-m btn-success" name="isShowBtn"
onclick="submitHandler()">保存配置
</button>
</div>
</div>
<div class="panel-body" th:width="max" style="margin-top: 10px">
<form class="form-horizontal m" id="form-performances-edit"
th:object="${kylinPerformanceMisVo}">
<div>
<p>演出封面：</p>
<img name="img" th:src="*{imgPoster}">
</div>
<div>
<label>演出名称：</label>
<span th:text="*{title}"></span>
</div>
<div>
<label>时间：</label>
<span th:text="*{timeStart}"></span>
<span> - </span>
<span th:text="*{timeEnd}"></span>
</div>
<div>
<label>演出类型：</label>
<span id="type"></span>
</div>
<div>
<label>场地：</label>
<span th:text="*{fieldName}"></span>
</div>
<div>
<label>价格：</label>
<span th:text="*{price}"></span>
</div>
<div>
<label>停售时间：</label>
<span th:text="*{stopSellTime}"></span>
</div>
<div>
<label>主办方：</label>
<span th:text="*{sponsor}"></span>
</div>
<div>
<label>联系人：</label>
<span th:text="*{contacts}"></span>
</div>
<div>
<label>联系电话：</label>
<span th:text="*{mobile}"></span>
</div>
<div>
<p>演出批文：</p>
<img name="img" th:src="*{approvalUrl}">
</div>
<div class="ibox-content" id="eg">
<div class="click2edit wrapper" id="subText">
</div>
</div>
<div id="noticeImg">
</div>
<div th:each="dict : ${kylinPerformanceMisVo.ticketTimes}">
<div th:each="dict2 : ${dict.ticket}">
<div>
<span>票种名称：</span>
<span th:text="${dict2.title}"></span>
</div>
<div>
<span>使用日期：</span>
<span th:text="${dict2.useStart}"></span>
<span> - </span>
<span th:text="${dict2.useEnd}"></span>
</div>
<div>
<span>价格：</span>
<span th:text="${dict2.price}"></span>
</div>
<div>
<span>票种说明：</span>
<span th:text="${dict2.title}"></span>
</div>
<div>
<span>电子票说明：</span>
<span th:text="${dict2.title}"></span>
</div>
<div>
<span>学生票说明说明：</span>
<span th:text="${dict2.title}"></span>
</div>
<div>
<span>限购：</span>
<span th:text="${dict2.limitCount}"></span>
</div>
<div>
<span>库存总量：</span>
<span th:text="${dict2.totalGeneral}"></span>
</div>
<div>
<span>售票状态：</span>
<span th:text="${dict2.status}"></span>
</div>
<div>
<span>开始售票时间：</span>
<span th:text="${dict2.timeStart}"></span>
</div>
<div>
<span>是否学生票：</span>
<span th:text="${dict2.isStudent}"></span>
</div>
<div>
<span>取票方式：</span>
<span th:text="${dict2.title}"></span>
</div>
</div>
</div>
</form>
</div>
</div>
<button type="button" class="btn btn-w-m btn-success" name="isShowBtn"
onclick="">审核
</button>
</div>
......@@ -48,6 +178,42 @@
</div>
</div>
</div>
<th:block th:include="include :: footer" />
<th:block th:include="include :: footer"/>
<script th:inline="javascript">
var prefix = ctx + "kylin/performances"
const isShow = '[[${kylinPerformanceMisVo.isShow}]]';
if (isShow == 1) {
document.getElementsByName("isShowCheck")[0].checked = true;
} else {
document.getElementsByName("isShowCheck")[1].checked = true;
}
function submitHandler() {
var param = {
"isShow": document.getElementsByName("isShowCheck")[0].checked ? 1 : 0,
"performancesId": '[[${kylinPerformanceMisVo.performancesId}]]'.replaceAll("\"", "")
};
$.operate.post(prefix + "/isShow", param, function (res) {
});
}
//演出信息
const type = document.getElementById("type");
var typeInt = '[[${kylinPerformanceMisVo.type}]]';
if (typeInt == 101) {
type.textContent = '音乐节'
} else if (typeInt == 102) {
type.textContent = '小型演出'
} else if (typeInt == 103 || typeInt == 3) {
type.textContent = '巡演'
}
// 演出详情 购票须知
var subText = document.getElementById("subText")
subText.innerHTML = "演出详情：" + '[[${kylinPerformanceMisVo.details}]]'.replaceAll("\"", "");
var noticeImg = document.getElementById("noticeImg")
noticeImg.innerHTML = "购票须知：" + '[[${kylinPerformanceMisVo.noticeImage}]]'.replaceAll("\"", "");
</script>
</body>
</html>
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/pom.xml
View file @ b9b8478b
......@@ -52,7 +52,6 @@
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
</project>
\ No newline at end of file
liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinPerformancesAdminServiceImpl.java
View file @ b9b8478b
......@@ -13,6 +13,7 @@ import com.liquidnet.service.kylin.dto.vo.KylinPerformanceVo;
import com.liquidnet.service.kylin.dto.vo.KylinTicketVo;
import com.liquidnet.service.kylin.dto.vo.admin.KylinPerformanceMemberHistoryVo;
import com.liquidnet.service.kylin.dto.vo.partner.KylinPerformanceMisVo;
import com.liquidnet.service.kylin.dto.vo.partner.KylinPerformancePartnerListVo;
import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketPartnerVo;
import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo;
import com.liquidnet.service.kylin.entity.*;
......@@ -204,7 +205,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
PageHelper.startPage(performanceAdminListParam.getPageNum(), performanceAdminListParam.getPageSize());
List<PerformanceAdminListDao> newList = new ArrayList();
List<PerformanceAdminListDao> voList = performancesMapper.misPerformanceList(BeanUtil.convertBeanToMap(performanceAdminListParam));
for (PerformanceAdminListDao item:voList){
for (PerformanceAdminListDao item : voList) {
item.setStatus(item.getStatus());
newList.add(item);
}
......@@ -290,6 +291,34 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
}
}
@Override
public Integer setIsShow(String performancesId, Integer isShow) {
try {
Integer resultInt = 0;
if (isShow == 0) {
resultInt=performanceStatusMapper.hideIsShow(performancesId);
} else {
resultInt=performanceStatusMapper.showIsShow(performancesId);
}
HashMap<String, Object> map = new HashMap<>();
map.put("isShow", isShow);
BasicDBObject object = new BasicDBObject("$set", map);
mongoTemplate.getCollection(KylinPerformanceVo.class.getSimpleName()).updateMany(
Query.query(Criteria.where("performancesId").is(performancesId)).getQueryObject(),
object
);
mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateMany(
Query.query(Criteria.where("performancesId").is(performancesId)).getQueryObject(),
object
);
return 1;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
@Override
public PageInfo<PerformanceRecommendAdminDao> listRecommend() {
......
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/entity/KylinPerformanceStatus.java
View file @ b9b8478b
......@@ -35,7 +35,7 @@ public class KylinPerformanceStatus implements Serializable {
private String performanceId;
/**
* 是否显示 0全部用户可见 1白名单可见 2任何不显示
* 是否显示 0全部用户不可见 1全部可见 2白名单可见
*/
private Integer isShow;
......
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinPerformanceStatusMapper.java
View file @ b9b8478b
......@@ -13,4 +13,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
*/
public interface KylinPerformanceStatusMapper extends BaseMapper<KylinPerformanceStatus> {
Integer hideIsShow(String performancesId);
Integer showIsShow(String performancesId);
}
liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinPerformanceStatusMapper.xml 0 → 100644
View file @ b9b8478b
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.liquidnet.service.kylin.mapper.KylinPerformanceStatusMapper">
<select id="hideIsShow" resultType="java.lang.Boolean" parameterType="java.lang.String">
UPDATE kylin_performance_status
SET is_show = 0
WHERE performance_id = ${performancesId}
</select>
<select id="showIsShow" resultType="java.lang.Integer" parameterType="java.lang.String">
UPDATE kylin_performance_status
SET is_show = 1
WHERE performance_id = ${performancesId}
</select>
</mapper>
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/admin/KylinPerformancesAdminController.java
View file @ b9b8478b
......@@ -12,7 +12,6 @@ import com.liquidnet.service.kylin.dto.param.PerformanceMemberAuditParam;
import com.liquidnet.service.kylin.dto.param.PerformanceRecommendAdminParam;
import com.liquidnet.service.kylin.dto.param.SysDamaiParam;
import com.liquidnet.service.kylin.dto.vo.partner.KylinPerformanceMisVo;
import com.liquidnet.service.kylin.service.impl.admin.KylinPerformancesAdminServiceImpl;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiResponse;
......@@ -36,205 +35,205 @@ import java.util.List;
@RequestMapping("admin/performance")
public class KylinPerformancesAdminController {
@Autowired
private KylinPerformancesAdminServiceImpl performancesAdminService;
@PostMapping(value = "list")
@ApiOperation(value = "获取列表", position = 1)
@ApiResponse(response = PerformanceAdminListDao.class, code = 200, message = "接口返回对象参数")
public ResponseDto<PageInfo<PerformanceAdminListDao>> getList(@RequestBody @Valid PerformanceAdminListParam performanceAdminListParam) {
PageInfo<PerformanceAdminListDao> result = null;
result = performancesAdminService.getList(performanceAdminListParam);
if (null != result) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("获取演出详情失败");
}
}
@GetMapping(value = "details")
@ApiOperation(value = "获取演出详情", position = 2)
@ApiResponse(response = KylinPerformanceMisVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<KylinPerformanceMisVo> performanceDetails(@RequestParam("performancesId") String performancesId) {
KylinPerformanceMisVo result = null;
result = performancesAdminService.performanceDetails(performancesId);
if (null != result) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("获取演出详情失败");
}
}
@PostMapping(value = "audit")
@ApiOperation(value = "演出审核", position = 3)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> performanceAudit(@RequestParam("performancesId") String performancesId, @RequestParam("status") int status, @RequestParam(value = "rejectTxt", required = false) String rejectTxt) {
boolean result = performancesAdminService.performanceAudit(performancesId, status, rejectTxt);
if (result) {
return ResponseDto.success("审核完成");
} else {
return ResponseDto.failure("审核失败");
}
}
@GetMapping(value = "list/roadshow")
@ApiOperation(value = "列表根据巡演id", position = 4)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<List<PerformanceTitleDao>> getListByRoadShowId(@RequestParam("roadShowId") String roadShowId) {
List<PerformanceTitleDao> result = performancesAdminService.getListByRoadShowId(roadShowId);
if (result.size() > 0) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("查询失败");
}
}
@GetMapping(value = "list/status")
@ApiOperation(value = "列表根据演出状态", position = 5)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<List<PerformanceTitleDao>> getListByStatus(@RequestParam("status") String status) {
List<PerformanceTitleDao> result = performancesAdminService.getListByStatus(status);
if (result.size() > 0) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("查询失败");
}
}
@GetMapping(value = "roadShow/relation")
@ApiOperation(value = "修改演出巡演关联", position = 6)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> changeRoadShowId(@RequestParam("performanceId") String performanceId, @RequestParam("roadShowId") String roadShowId) {
boolean result = performancesAdminService.changeRoadShowId(performanceId, roadShowId);
if (result) {
return ResponseDto.success("操作成功");
} else {
return ResponseDto.failure("操作失败");
}
}
@PutMapping(value = "recommend")
@ApiOperation(value = "演出推荐编辑", position = 7)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> setRecommend(@RequestBody @Valid List<PerformanceRecommendAdminParam> performanceRecommendAdminParam) {
boolean result = performancesAdminService.setRecommend(performanceRecommendAdminParam);
if (result) {
return ResponseDto.success("操作成功");
} else {
return ResponseDto.failure("操作失败");
}
}
@GetMapping(value = "recommend/list")
@ApiOperation(value = "演出推荐列表", position = 8)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PageInfo<PerformanceRecommendAdminDao>> listRecommend() {
PageInfo<PerformanceRecommendAdminDao> result = performancesAdminService.listRecommend();
if (result != null) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("获取失败");
}
}
@GetMapping(value = "member/details")
@ApiOperation(value = "演出会员信息", position = 9)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PerformanceMemberAuditDao> performanceMemberInfo(@RequestParam("performanceId") @NotNull String performanceId) {
PerformanceMemberAuditDao result = performancesAdminService.performanceMemberInfo(performanceId);
if (result != null) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("获取失败");
}
}
@PutMapping(value = "member/change")
@ApiOperation(value = "修改演出会员数据", position = 10)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> performanceMemberChange(@RequestBody PerformanceMemberAuditParam performanceMemberAuditParam) {
boolean result = performancesAdminService.performanceMemberChange(performanceMemberAuditParam);
if (result) {
return ResponseDto.success("操作成功");
} else {
return ResponseDto.failure("操作失败");
}
}
@GetMapping(value = "member/list")
@ApiOperation(value = "待审核会员演出列表", position = 11)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PageInfo<PerformanceTitleDao>> performanceMemberList(@RequestParam(value = "title" , required=false) String title,
@RequestParam("page") @NotNull int page,
@RequestParam("size") @NotNull int size) {
PageInfo<PerformanceTitleDao> result = performancesAdminService.performanceMemberList(title, page, size);
if (result != null) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("操作失败");
}
}
@GetMapping(value = "member/details/audit")
@ApiOperation(value = "演出会员信息(根据status 1待审核 2已拒绝 3已通过)", position = 12)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PerformanceMemberAuditDao> performanceMemberAuditInfo(@RequestParam("performanceId") @NotNull String performanceId,
@RequestParam(value = "status") @NotNull int status) {
PerformanceMemberAuditDao result = performancesAdminService.performanceMemberAuditInfo(performanceId, status);
if (result != null) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("获取失败");
}
}
@PostMapping(value = "member/audit")
@ApiOperation(value = "审核演出会员信息", position = 13)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> performanceMemberAudit(@RequestParam("performanceId") @NotNull String performanceId,
@RequestParam("status") @NotNull int status,
@RequestParam(value = "rejectTxt", required = false) String rejectTxt) {
boolean result = performancesAdminService.performanceMemberAudit(performanceId, status, rejectTxt);
if (result) {
return ResponseDto.success("操作成功");
} else {
return ResponseDto.failure("操作失败");
}
}
@PostMapping(value = "member/history")
@ApiOperation(value = "会员审核记录")
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PageInfo<PerformanceMemberAuditParam>> performanceAuditHistory(@RequestParam("performanceId") @NotNull String performanceId) {
PageInfo<PerformanceMemberAuditParam> result = performancesAdminService.performanceAuditHistory(performanceId);
if (result != null) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("操作失败");
}
}
@PostMapping(value = "ticket/agent")
@ApiOperation(value = "修改票分销状态")
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> changeTicketAgent(@RequestParam("ticketId") @NotNull String ticketId, @RequestParam("status") @NotNull Integer status) {
boolean result = performancesAdminService.changeTicketAgent(ticketId, status);
if (result) {
return ResponseDto.success("修改完成");
} else {
return ResponseDto.failure("操作失败");
}
}
@PostMapping(value = "performance/sysDamai")
@ApiOperation(value = "修改大麦分销状态")
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> changeSysDamai(@RequestBody List<SysDamaiParam> params) {
boolean result = performancesAdminService.changeSysDamai(params);
if (result) {
return ResponseDto.success("修改完成");
} else {
return ResponseDto.failure("操作失败");
}
}
// @Autowired
// private KylinPerformancesAdminServiceImpl performancesAdminService;
//
// @PostMapping(value = "list")
// @ApiOperation(value = "获取列表", position = 1)
// @ApiResponse(response = PerformanceAdminListDao.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<PageInfo<PerformanceAdminListDao>> getList(@RequestBody @Valid PerformanceAdminListParam performanceAdminListParam) {
// PageInfo<PerformanceAdminListDao> result = null;
// result = performancesAdminService.getList(performanceAdminListParam);
// if (null != result) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("获取演出详情失败");
// }
// }
//
// @GetMapping(value = "details")
// @ApiOperation(value = "获取演出详情", position = 2)
// @ApiResponse(response = KylinPerformanceMisVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<KylinPerformanceMisVo> performanceDetails(@RequestParam("performancesId") String performancesId) {
// KylinPerformanceMisVo result = null;
// result = performancesAdminService.performanceDetails(performancesId);
// if (null != result) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("获取演出详情失败");
// }
// }
//
// @PostMapping(value = "audit")
// @ApiOperation(value = "演出审核", position = 3)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> performanceAudit(@RequestParam("performancesId") String performancesId, @RequestParam("status") int status, @RequestParam(value = "rejectTxt", required = false) String rejectTxt) {
// boolean result = performancesAdminService.performanceAudit(performancesId, status, rejectTxt);
// if (result) {
// return ResponseDto.success("审核完成");
// } else {
// return ResponseDto.failure("审核失败");
// }
// }
//
// @GetMapping(value = "list/roadshow")
// @ApiOperation(value = "列表根据巡演id", position = 4)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<List<PerformanceTitleDao>> getListByRoadShowId(@RequestParam("roadShowId") String roadShowId) {
// List<PerformanceTitleDao> result = performancesAdminService.getListByRoadShowId(roadShowId);
// if (result.size() > 0) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("查询失败");
// }
// }
//
// @GetMapping(value = "list/status")
// @ApiOperation(value = "列表根据演出状态", position = 5)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<List<PerformanceTitleDao>> getListByStatus(@RequestParam("status") String status) {
// List<PerformanceTitleDao> result = performancesAdminService.getListByStatus(status);
// if (result.size() > 0) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("查询失败");
// }
// }
//
// @GetMapping(value = "roadShow/relation")
// @ApiOperation(value = "修改演出巡演关联", position = 6)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> changeRoadShowId(@RequestParam("performanceId") String performanceId, @RequestParam("roadShowId") String roadShowId) {
// boolean result = performancesAdminService.changeRoadShowId(performanceId, roadShowId);
// if (result) {
// return ResponseDto.success("操作成功");
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
//
// @PutMapping(value = "recommend")
// @ApiOperation(value = "演出推荐编辑", position = 7)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> setRecommend(@RequestBody @Valid List<PerformanceRecommendAdminParam> performanceRecommendAdminParam) {
// boolean result = performancesAdminService.setRecommend(performanceRecommendAdminParam);
// if (result) {
// return ResponseDto.success("操作成功");
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
//
// @GetMapping(value = "recommend/list")
// @ApiOperation(value = "演出推荐列表", position = 8)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PageInfo<PerformanceRecommendAdminDao>> listRecommend() {
// PageInfo<PerformanceRecommendAdminDao> result = performancesAdminService.listRecommend();
// if (result != null) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("获取失败");
// }
// }
//
// @GetMapping(value = "member/details")
// @ApiOperation(value = "演出会员信息", position = 9)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PerformanceMemberAuditDao> performanceMemberInfo(@RequestParam("performanceId") @NotNull String performanceId) {
// PerformanceMemberAuditDao result = performancesAdminService.performanceMemberInfo(performanceId);
// if (result != null) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("获取失败");
// }
// }
//
// @PutMapping(value = "member/change")
// @ApiOperation(value = "修改演出会员数据", position = 10)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> performanceMemberChange(@RequestBody PerformanceMemberAuditParam performanceMemberAuditParam) {
// boolean result = performancesAdminService.performanceMemberChange(performanceMemberAuditParam);
// if (result) {
// return ResponseDto.success("操作成功");
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
//
// @GetMapping(value = "member/list")
// @ApiOperation(value = "待审核会员演出列表", position = 11)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PageInfo<PerformanceTitleDao>> performanceMemberList(@RequestParam(value = "title" , required=false) String title,
// @RequestParam("page") @NotNull int page,
// @RequestParam("size") @NotNull int size) {
// PageInfo<PerformanceTitleDao> result = performancesAdminService.performanceMemberList(title, page, size);
// if (result != null) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
//
// @GetMapping(value = "member/details/audit")
// @ApiOperation(value = "演出会员信息(根据status 1待审核 2已拒绝 3已通过)", position = 12)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PerformanceMemberAuditDao> performanceMemberAuditInfo(@RequestParam("performanceId") @NotNull String performanceId,
// @RequestParam(value = "status") @NotNull int status) {
// PerformanceMemberAuditDao result = performancesAdminService.performanceMemberAuditInfo(performanceId, status);
// if (result != null) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("获取失败");
// }
// }
//
// @PostMapping(value = "member/audit")
// @ApiOperation(value = "审核演出会员信息", position = 13)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> performanceMemberAudit(@RequestParam("performanceId") @NotNull String performanceId,
// @RequestParam("status") @NotNull int status,
// @RequestParam(value = "rejectTxt", required = false) String rejectTxt) {
// boolean result = performancesAdminService.performanceMemberAudit(performanceId, status, rejectTxt);
// if (result) {
// return ResponseDto.success("操作成功");
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
//
// @PostMapping(value = "member/history")
// @ApiOperation(value = "会员审核记录")
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PageInfo<PerformanceMemberAuditParam>> performanceAuditHistory(@RequestParam("performanceId") @NotNull String performanceId) {
// PageInfo<PerformanceMemberAuditParam> result = performancesAdminService.performanceAuditHistory(performanceId);
// if (result != null) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
//
// @PostMapping(value = "ticket/agent")
// @ApiOperation(value = "修改票分销状态")
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> changeTicketAgent(@RequestParam("ticketId") @NotNull String ticketId, @RequestParam("status") @NotNull Integer status) {
// boolean result = performancesAdminService.changeTicketAgent(ticketId, status);
// if (result) {
// return ResponseDto.success("修改完成");
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
//
// @PostMapping(value = "performance/sysDamai")
// @ApiOperation(value = "修改大麦分销状态")
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> changeSysDamai(@RequestBody List<SysDamaiParam> params) {
// boolean result = performancesAdminService.changeSysDamai(params);
// if (result) {
// return ResponseDto.success("修改完成");
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
}
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/admin/KylinRoadShowsAdminController.java
View file @ b9b8478b
......@@ -6,7 +6,6 @@ import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.kylin.dao.RoadShowAdminListDao;
import com.liquidnet.service.kylin.dto.param.CreateRoadShowParam;
import com.liquidnet.service.kylin.dto.vo.admin.KylinRoadShowAdminVo;
import com.liquidnet.service.kylin.service.impl.admin.KylinRoadShowsAdminServiceImpl;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiResponse;
......@@ -29,72 +28,72 @@ import java.util.Map;
@RequestMapping("/admin/roadshow")
public class KylinRoadShowsAdminController {
@Autowired
private KylinRoadShowsAdminServiceImpl roadShowsService;
@GetMapping(value = "list")
@ApiOperation(value = "获取列表",position = 1)
@ApiResponse(response = RoadShowAdminListDao.class, code = 200, message = "接口返回对象参数")
public ResponseDto<PageInfo<RoadShowAdminListDao>> listRoadShow(@RequestParam(value = "title",required = false) String title,
@RequestParam(value = "page") int page,
@RequestParam(value = "size") int size) {
PageInfo<RoadShowAdminListDao> result = null;
result = roadShowsService.listRoadShow(title, page, size);
if (null != result) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("获取演出详情失败");
}
}
@PostMapping(value = "")
@ApiOperation(value = "创建",position = 2)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<Map<String,String>> createRoadShow(@RequestBody CreateRoadShowParam createRoadShowParam) {
String result = roadShowsService.createRoadShow(createRoadShowParam);
if (!result.isEmpty()) {
Map<String,String> map = new HashMap<>();
map.put("roadShowId",result);
return ResponseDto.success(map);
} else {
return ResponseDto.failure("创建失败");
}
}
@PutMapping(value = "")
@ApiOperation(value = "修改",position = 3)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> updateRoadShow(@RequestBody CreateRoadShowParam createRoadShowParam) {
boolean result = roadShowsService.updateRoadShow(createRoadShowParam);
if (result) {
return ResponseDto.success("修改成功");
} else {
return ResponseDto.failure("修改失败");
}
}
@DeleteMapping(value = "")
@ApiOperation(value = "删除",position = 4)
@ApiResponse( code = 200, message = "接口返回对象参数")
public ResponseDto<String> deleteRoadShow(@RequestParam("roadShowId") String roadShowId, @RequestParam("status") int status) {
boolean result = roadShowsService.deleteRoadShow(roadShowId, status);
if (result) {
return ResponseDto.success("操作成功");
} else {
return ResponseDto.failure("操作失败");
}
}
@GetMapping(value = "details")
@ApiOperation(value = "详情",position = 5)
@ApiResponse(response = KylinRoadShowAdminVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<KylinRoadShowAdminVo> detailsRoadShow(@RequestParam("roadShowId") String roadShowId) {
KylinRoadShowAdminVo result = null;
result = roadShowsService.detailsRoadShow(roadShowId);
if (result != null) {
return ResponseDto.success(result);
} else {
return ResponseDto.failure("操作失败");
}
}
// @Autowired
// private KylinRoadShowsAdminServiceImpl roadShowsService;
//
// @GetMapping(value = "list")
// @ApiOperation(value = "获取列表",position = 1)
// @ApiResponse(response = RoadShowAdminListDao.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<PageInfo<RoadShowAdminListDao>> listRoadShow(@RequestParam(value = "title",required = false) String title,
// @RequestParam(value = "page") int page,
// @RequestParam(value = "size") int size) {
// PageInfo<RoadShowAdminListDao> result = null;
// result = roadShowsService.listRoadShow(title, page, size);
// if (null != result) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("获取演出详情失败");
// }
// }
//
// @PostMapping(value = "")
// @ApiOperation(value = "创建",position = 2)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<Map<String,String>> createRoadShow(@RequestBody CreateRoadShowParam createRoadShowParam) {
// String result = roadShowsService.createRoadShow(createRoadShowParam);
// if (!result.isEmpty()) {
// Map<String,String> map = new HashMap<>();
// map.put("roadShowId",result);
// return ResponseDto.success(map);
// } else {
// return ResponseDto.failure("创建失败");
// }
// }
//
// @PutMapping(value = "")
// @ApiOperation(value = "修改",position = 3)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> updateRoadShow(@RequestBody CreateRoadShowParam createRoadShowParam) {
// boolean result = roadShowsService.updateRoadShow(createRoadShowParam);
// if (result) {
// return ResponseDto.success("修改成功");
// } else {
// return ResponseDto.failure("修改失败");
// }
// }
//
// @DeleteMapping(value = "")
// @ApiOperation(value = "删除",position = 4)
// @ApiResponse( code = 200, message = "接口返回对象参数")
// public ResponseDto<String> deleteRoadShow(@RequestParam("roadShowId") String roadShowId, @RequestParam("status") int status) {
// boolean result = roadShowsService.deleteRoadShow(roadShowId, status);
// if (result) {
// return ResponseDto.success("操作成功");
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
//
// @GetMapping(value = "details")
// @ApiOperation(value = "详情",position = 5)
// @ApiResponse(response = KylinRoadShowAdminVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<KylinRoadShowAdminVo> detailsRoadShow(@RequestParam("roadShowId") String roadShowId) {
// KylinRoadShowAdminVo result = null;
// result = roadShowsService.detailsRoadShow(roadShowId);
// if (result != null) {
// return ResponseDto.success(result);
// } else {
// return ResponseDto.failure("操作失败");
// }
// }
}
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/admin/KylinPerformancesAdminServiceImpl.java deleted 100644 → 0
View file @ b33cc117
package com.liquidnet.service.kylin.service.impl.admin;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.liquidnet.common.cache.redis.util.RedisUtil;
import com.liquidnet.commons.lang.util.BeanUtil;
import com.liquidnet.service.kylin.constant.KylinRedisConst;
import com.liquidnet.service.kylin.dao.*;
import com.liquidnet.service.kylin.dto.param.*;
import com.liquidnet.service.kylin.dto.vo.KylinPerformanceVo;
import com.liquidnet.service.kylin.dto.vo.KylinTicketVo;
import com.liquidnet.service.kylin.dto.vo.admin.KylinPerformanceMemberHistoryVo;
import com.liquidnet.service.kylin.dto.vo.partner.*;
import com.liquidnet.service.kylin.entity.*;
import com.liquidnet.service.kylin.mapper.*;
import com.liquidnet.service.kylin.service.admin.IKylinPerformancesAdminService;
import com.liquidnet.service.kylin.service.impl.partner.KylinTicketTimesPartnerServiceImpl;
import com.liquidnet.service.kylin.service.impl.partner.KylinTicketsPartnerServiceImpl;
import com.liquidnet.service.kylin.timerTask.PerformanceVoTask;
import com.liquidnet.service.kylin.utils.DataUtils;
import com.mongodb.BasicDBObject;
import com.mongodb.client.model.FindOneAndUpdateOptions;
import com.mongodb.client.model.ReturnDocument;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.bson.Document;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.convert.MongoConverter;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
/**
* <p>
* 演出 服务实现类
* </p>
*
* @author liquidnet
* @since 2021-05-05
*/
@Service
@Slf4j
public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerformancesMapper, KylinPerformances> implements IKylinPerformancesAdminService {
@Autowired
MongoTemplate mongoTemplate;
@Autowired
private MongoConverter mongoConverter;
@Autowired
private PerformanceVoTask performanceVoTask;
@Autowired
private DataUtils dataUtils;
@Autowired
private KylinPerformancesMapper performancesMapper;
@Autowired
private KylinPerformanceStatusMapper performanceStatusMapper;
@Autowired
private KylinPerformanceRelationsMapper performanceRelationsMapper;
@Autowired
private KylinTicketTimesPartnerServiceImpl ticketTimesPartnerService;
@Autowired
private KylinTicketsMapper ticketsMapper;
@Autowired
private KylinTicketStatusMapper ticketStatusMapper;
@Autowired
private KylinTicketRelationsMapper ticketRelationsMapper;
@Autowired
private KylinTicketTimesMapper ticketTimesMapper;
@Autowired
private KylinTicketTimeRelationMapper ticketTimeRelationMapper;
@Autowired
private KylinTicketsPartnerServiceImpl ticketsPartnerService;
@Override
public KylinPerformanceMisVo performanceDetails(String performancesId) {
log.info(" PERFORMANCE mis演出详情");
KylinPerformanceMisVo createMisVo = performanceVoTask.getPerformanceMisVo(performancesId);
return createMisVo;
}
@Override
public boolean performanceAudit(String performancesId, int status, String rejectTxt) {
try {
LocalDateTime updatedAt = LocalDateTime.now();
HashMap<String, Object> map = new HashMap<>();
int auditStatus = 0;
if (status == 3) {
log.info(" PERFORMANCE 演出审核 通过");
rejectTxt = "";
auditStatus = 1;
//修改演出
map.put("rejectTxt", rejectTxt);
map.put("status", status);
map.put("auditStatus", auditStatus);
map.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
BasicDBObject objectPerformanceVo = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
Document doc = mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).findOneAndUpdate(
Query.query(Criteria.where("performancesId").is(performancesId)).getQueryObject(),
objectPerformanceVo,
new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)
);
KylinPerformanceStatus sqlStatus = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
if (sqlStatus.getStatus() == 1) {
log.info(" PERFORMANCE 演出审核 第一次");
//修改
KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus();
performanceStatus.setStatus(status);
performanceStatus.setAuditStatus(auditStatus);
performanceStatus.setUpdatedAt(updatedAt);
performanceStatusMapper.update(performanceStatus, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
KylinPerformances performances = new KylinPerformances();
performances.setUpdatedAt(updatedAt);
performances.setRejectTxt(rejectTxt);
performancesMapper.update(performances, new UpdateWrapper<KylinPerformances>().eq("performances_id", performancesId));
List<KylinTicketTimesPartnerVo> kylinTicketTimesPartnerVos = ticketTimesPartnerService.getTimesMongoList(performancesId);
for (KylinTicketTimesPartnerVo ticketTimeItem : kylinTicketTimesPartnerVos) {
for (KylinTicketPartnerVo ticketItem : ticketsPartnerService.getTicketMongoList(ticketTimeItem.getTicketTimesId())) {
BasicDBObject objectTicketVo = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("ticketsId").is(ticketItem.getTicketsId())).getQueryObject(),
objectTicketVo
);
KylinTickets tickets = new KylinTickets();
tickets.setUpdatedAt(updatedAt);
ticketsMapper.update(tickets, new UpdateWrapper<KylinTickets>().eq("tickets_id", ticketItem.getTicketsId()));
KylinTicketStatus ticketStatus = new KylinTicketStatus();
ticketStatus.setUpdatedAt(updatedAt);
ticketStatus.setStatus(status);
ticketStatusMapper.update(ticketStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketItem.getTicketsId()));
}
}
} else { //只修改演出相关 场次 票 (不包括 库存 售卖时间 限购)
log.info(" PERFORMANCE 演出审核 修改");
HashMap<String, Object> mapSql = new HashMap<>();
mapSql.put("status", 9);
mapSql.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
performanceVoTask.updatePerformanceMySql(performancesId, mapSql, performanceVoTask.getPerformanceMisVo(performancesId), updatedAt, auditStatus);
if (sqlStatus.getStatus() == 6) {//若 演出上 则 线判断状态
performanceVoTask.performanceVoStatus(performancesId);
}
}
dataUtils.delPerformanceRedis(performancesId);
} else if (status == 4) {
log.info(" PERFORMANCE 演出审核 拒绝");
auditStatus = 2;
map.put("rejectTxt", rejectTxt);
map.put("auditStatus", auditStatus);
map.put("status", status);
map.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(performancesId)).getQueryObject(),
object
);
KylinPerformanceStatus statusData = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus();
if (statusData.getStatus() == 1 || statusData.getStatus() == 4) {
performanceStatus.setStatus(status);
}
performanceStatus.setAuditStatus(auditStatus);
performanceStatus.setUpdatedAt(updatedAt);
performanceStatusMapper.update(performanceStatus, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
KylinPerformances performances = new KylinPerformances();
performances.setRejectTxt(rejectTxt);
performances.setUpdatedAt(updatedAt);
performancesMapper.update(performances, new UpdateWrapper<KylinPerformances>().eq("performances_id", performancesId));
} else {
return false;
}
return true;
} catch (Exception e) {
System.out.println("ERROR DATA = " + e.getMessage());
e.printStackTrace();
return false;
}
}
@Override
public PageInfo<PerformanceAdminListDao> getList(PerformanceAdminListParam performanceAdminListParam) {
PageInfo<PerformanceAdminListDao> pageInfoTmp = null;
try {
PageHelper.startPage(performanceAdminListParam.getPage(), performanceAdminListParam.getSize());
List<PerformanceAdminListDao> voList = performancesMapper.misPerformanceList(BeanUtil.convertBeanToMap(performanceAdminListParam));
pageInfoTmp = new PageInfo(voList);
} catch (Exception e) {
return null;
}
return pageInfoTmp;
}
@Override
public List<PerformanceTitleDao> getListByRoadShowId(String roadShowId) {
try {
List<PerformanceTitleDao> voList = performancesMapper.misTitleByRoadShowIdList(roadShowId);
return voList;
} catch (Exception e) {
return new ArrayList<>();
}
}
@Override
public List<PerformanceTitleDao> getListByStatus(String status) {
List<PerformanceTitleDao> voList = performancesMapper.misTitleByStatusList(status);
return voList;
}
@Override
public boolean changeRoadShowId(String performancesId, String roadShowId) {
try {
//mysql
KylinPerformanceRelations performanceRelations = new KylinPerformanceRelations();
performanceRelations.setRoadShowId(roadShowId);
performanceRelationsMapper.update(performanceRelations, new UpdateWrapper<KylinPerformanceRelations>().eq("performance_id", performancesId));
//mongodb
HashMap<String, Object> map = new HashMap<>();
map.put("roadShowId", roadShowId);
BasicDBObject object = new BasicDBObject("$set", map);
mongoTemplate.getCollection(KylinPerformanceVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(performancesId)).getQueryObject(),
object
);
dataUtils.delPerformanceRedis(performancesId);
return true;
} catch (Exception e) {
return false;
}
}
@Override
public boolean setRecommend(List<PerformanceRecommendAdminParam> performancesIdList) {
try {
KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus();
performanceStatus.setIsRecommend(0);
performanceStatus.setStatus(null);
performanceStatusMapper.update(performanceStatus, new UpdateWrapper<KylinPerformanceStatus>().gt("is_recommend", 0));
HashMap<String, Object> map = new HashMap<>();
map.put("isRecommend", 0);
BasicDBObject object = new BasicDBObject("$set", map);
mongoTemplate.getCollection(KylinPerformanceVo.class.getSimpleName()).updateMany(
Query.query(Criteria.where("isRecommend").gt(0)).getQueryObject(),
object
);
for (PerformanceRecommendAdminParam item : performancesIdList) {
performanceStatus.setIsRecommend(item.getIsRecommend());
performanceStatusMapper.update(performanceStatus, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", item.getPerformanceId()));
HashMap<String, Object> map2 = new HashMap<>();
map2.put("isRecommend", item.getIsRecommend());
BasicDBObject object2 = new BasicDBObject("$set", map2);
mongoTemplate.getCollection(KylinPerformanceVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(item.getPerformanceId())).getQueryObject(),
object2
);
}
// dataUtils.delPerformanceRecommendRedis(item.getPerformanceId());
return true;
} catch (Exception e) {
return false;
}
}
@Override
public PageInfo<PerformanceRecommendAdminDao> listRecommend() {
PageInfo<PerformanceRecommendAdminDao> pageInfoTmp = null;
try {
PageHelper.startPage(1, 10);
List<PerformanceRecommendAdminDao> voList = performancesMapper.reCommendPerformanceList();
pageInfoTmp = new PageInfo(voList);
} catch (Exception e) {
return null;
}
return pageInfoTmp;
}
@Override
public PerformanceMemberAuditDao performanceMemberInfo(String performanceId) {
PerformanceMemberAuditDao performanceMemberAuditDao = new PerformanceMemberAuditDao();
PerformanceTitleDao data = performancesMapper.misPerformanceMemberInfo(performanceId);
List<TicketMemberAuditDao> ticketData = performancesMapper.misTicketMemberInfo(performanceId);
performanceMemberAuditDao.setPerformancesId(data.getPerformancesId());
performanceMemberAuditDao.setTitle(data.getTitle());
performanceMemberAuditDao.setIsExclusive(0);
performanceMemberAuditDao.setIsMember(0);
performanceMemberAuditDao.setTicketMemberAudit(ticketData);
for (TicketMemberAuditDao item : ticketData) {
if (item.getIsMember() == 1) {
performanceMemberAuditDao.setIsMember(1);
}
if (item.getIsExclusive() == 1) {
performanceMemberAuditDao.setIsExclusive(1);
}
}
PerformanceMemberAuditParam memberAuditVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)), PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
if (memberAuditVo != null) {
if (memberAuditVo.getStatus() == 1) {
performanceMemberAuditDao.setIsSubmit(1);
} else {
performanceMemberAuditDao.setIsSubmit(0);
}
} else {
performanceMemberAuditDao.setIsSubmit(0);
}
return performanceMemberAuditDao;
}
@Override
public boolean performanceMemberChange(PerformanceMemberAuditParam performanceMemberAuditParam) {
try {
performanceMemberAuditParam.setStatus(1);
mongoTemplate.insert(performanceMemberAuditParam, PerformanceMemberAuditParam.class.getSimpleName());
return true;
} catch (Exception e) {
return false;
}
}
@Override
public PageInfo<PerformanceTitleDao> performanceMemberList(String title, int page, int size) {
PageInfo<PerformanceTitleDao> pageInfoTmp = null;
// 排序 分页
Pageable pageable = PageRequest.of(page, size, Sort.by(Sort.Direction.DESC, "createdAt"));
//条件
Criteria criteria = Criteria.where("status").is(1);
if (!title.isEmpty()) {
criteria.and("title").regex(".*?\\" + title);
}
Query query = Query.query(criteria);
// 查询总数
long count = mongoTemplate.count(query, PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
List<PerformanceMemberAuditParam> paramList = mongoTemplate.find(query, PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
query.with(pageable);
//处理Vo
List<PerformanceTitleDao> voList = new ArrayList<>();
for (PerformanceMemberAuditParam item : paramList) {
PerformanceTitleDao voData = new PerformanceTitleDao();
voData.setPerformancesId(item.getPerformancesId());
voData.setTitle(item.getTitle());
voList.add(voData);
}
pageInfoTmp = new PageInfo(voList);
pageInfoTmp.setTotal(count);
return pageInfoTmp;
}
@Override
public PerformanceMemberAuditDao performanceMemberAuditInfo(String performanceId, int status) {
PerformanceMemberAuditParam memberAuditVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId).and("status").is(status)), PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
if (memberAuditVo == null) {
return null;
}
PerformanceMemberAuditDao performanceMemberAuditDao = new PerformanceMemberAuditDao();
PerformanceTitleDao data = performancesMapper.misPerformanceMemberInfo(performanceId);
List<TicketMemberAuditDao> ticketData = performancesMapper.misTicketMemberInfo(performanceId);
performanceMemberAuditDao.setPerformancesId(data.getPerformancesId());
performanceMemberAuditDao.setTitle(data.getTitle());
performanceMemberAuditDao.setIsExclusive(0);
performanceMemberAuditDao.setIsMember(0);
for (TicketMemberAuditDao item : ticketData) {
if (memberAuditVo.getIsMember() == 1) {
performanceMemberAuditDao.setIsMember(1);
}
if (memberAuditVo.getIsExclusive() == 1) {
performanceMemberAuditDao.setIsExclusive(1);
}
}
for (TicketMemberAuditParam item : memberAuditVo.getTicketMemberAudit()) {
for (TicketMemberAuditDao item2 : ticketData) {
if (item.getTicketsId().equals(item2.getTicketsId())) {
item2.setAdvanceMinuteMember(item.getAdvanceMinuteMember());
item2.setPriceDiscountMember(item.getPriceDiscountMember());
item2.setMemberLimitCount(item.getMemberLimitCount());
item2.setIsMember(performanceMemberAuditDao.getIsMember());
item2.setIsExclusive(performanceMemberAuditDao.getIsExclusive());
break;
}
}
}
performanceMemberAuditDao.setTicketMemberAudit(ticketData);
return performanceMemberAuditDao;
}
@Override
public boolean performanceMemberAudit(String performanceId, int status, String rejectTxt) {
try {
LocalDateTime updatedAt = LocalDateTime.now();
if (status == 3) {
PerformanceMemberAuditParam memberAuditVo = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId).and("status").is(1)), PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
int isAdvance = 0;
int isDiscount = 0;
for (TicketMemberAuditParam item : memberAuditVo.getTicketMemberAudit()) {
if (item.getPriceDiscountMember().compareTo(new BigDecimal("0")) == 1) {
isDiscount = 1;
}
if (item.getAdvanceMinuteMember() > 0) {
isAdvance = 1;
}
//修改数据库
KylinTicketStatus ticketStatus = new KylinTicketStatus();
ticketStatus.setMemberLimitCount(item.getMemberLimitCount());
ticketStatus.setIsMember(memberAuditVo.getIsMember());
ticketStatus.setIsExclusive(memberAuditVo.getIsExclusive());
ticketStatus.setUpdatedAt(updatedAt);
ticketStatusMapper.update(ticketStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", item.getTicketsId()));
KylinTickets tickets = new KylinTickets();
tickets.setAdvanceMinuteMember(item.getAdvanceMinuteMember());
tickets.setPriceDiscountMember(item.getPriceDiscountMember());
tickets.setUpdatedAt(updatedAt);
ticketsMapper.update(tickets, new UpdateWrapper<KylinTickets>().eq("tickets_id", item.getTicketsId()));
KylinTickets ticketsTime = ticketsMapper.selectOne(new UpdateWrapper<KylinTickets>().eq("tickets_id", item.getTicketsId()));
//修改mongo
HashMap<String, Object> map = new HashMap<>();
map.put("isMember", memberAuditVo.getIsMember());
map.put("isExclusive", memberAuditVo.getIsExclusive());
map.put("updatedAt", updatedAt);
map.put("memberPrice", ticketsTime.getPrice().subtract(item.getPriceDiscountMember()));
map.put("memberTimeStart", ticketsTime.getTimeStart().plusMinutes(-ticketsTime.getAdvanceMinuteMember()).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
map.put("limitCountMember", item.getMemberLimitCount());
BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
mongoTemplate.getCollection(KylinTicketVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("ticketsId").is(item.getTicketsId())).getQueryObject(),
object);
}
//修改 演出vo
HashMap<String, Object> mapPerformanceVo = new HashMap<>();
mapPerformanceVo.put("isMember", memberAuditVo.getIsMember());
mapPerformanceVo.put("isExclusive", memberAuditVo.getIsExclusive());
mapPerformanceVo.put("isAdvance", isAdvance);
mapPerformanceVo.put("isDiscount", isDiscount);
BasicDBObject objectPerformanceVo = new BasicDBObject("$set", mongoConverter.convertToMongoType(mapPerformanceVo));
mongoTemplate.getCollection(KylinPerformanceVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
objectPerformanceVo);
HashMap<String, Object> map2 = new HashMap<>();
map2.put("status", 3);
map2.put("updatedAt", updatedAt);
map2.put("rejectTxt", "");
BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map2));
mongoTemplate.getCollection(PerformanceMemberAuditParam.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
object);
performanceVoTask.performanceVoStatus(performanceId);
dataUtils.delPerformanceRedis(performanceId);
} else {
HashMap<String, Object> map2 = new HashMap<>();
map2.put("status", 2);
map2.put("updatedAt", updatedAt);
map2.put("rejectTxt", rejectTxt);
BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map2));
mongoTemplate.getCollection(PerformanceMemberAuditParam.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
object);
}
return true;
} catch (Exception e) {
return false;
}
}
@Override
public PageInfo<PerformanceMemberAuditParam> performanceAuditHistory(String performanceId) {
PageInfo<PerformanceMemberAuditParam> pageInfoTmp = null;
// 排序 分页
Pageable pageable = PageRequest.of(1, 100, Sort.by(Sort.Direction.DESC, "createdAt"));
//条件
Query query = Query.query(Criteria.where("status").ne(1).and("status").ne(0));
// 查询总数
long count = mongoTemplate.count(query, PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
List<PerformanceMemberAuditParam> paramList = mongoTemplate.find(query, PerformanceMemberAuditParam.class, PerformanceMemberAuditParam.class.getSimpleName());
query.with(pageable);
//处理Vo
List<KylinPerformanceMemberHistoryVo> voList = new ArrayList<>();
for (PerformanceMemberAuditParam item : paramList) {
KylinPerformanceMemberHistoryVo voData = new KylinPerformanceMemberHistoryVo();
voData.setAuditTime(item.getUpdatedAt());
voData.setRejectTxt(item.getRejectTxt());
voData.setStatus(item.getStatus());
voList.add(voData);
}
pageInfoTmp = new PageInfo(paramList);
pageInfoTmp.setTotal(count);
return pageInfoTmp;
}
@Override
public boolean changeTicketAgent(String ticketId, Integer status) {
try {
LocalDateTime updatedAt = LocalDateTime.now();
if (status != 0 && status != 1) {
return false;
}
//修改 mysql
KylinTicketStatus ticketStatus = new KylinTicketStatus();
ticketStatus.setUpdatedAt(updatedAt);
ticketStatus.setIsAgent(status);
ticketStatusMapper.update(ticketStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketId));
//修改 mongo
HashMap<String, Object> map = new HashMap<>();
map.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
map.put("isAgent", status);
BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
mongoTemplate.getCollection(KylinTicketVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("ticketsId").is(ticketId)).getQueryObject(),
object);
dataUtils.delTicketRedis(ticketId);
return true;
} catch (Exception e) {
return false;
}
}
@Override
public boolean changeSysDamai(List<SysDamaiParam> params) {
try {
LocalDateTime updatedAt = LocalDateTime.now();
for (SysDamaiParam item : params) {
if (item.getStatus() != 0 && item.getStatus() != 1) {
return false;
}
//修改 mysql
if (item.getType().equals("ticket")) {
KylinTicketStatus ticketStatus = new KylinTicketStatus();
ticketStatus.setUpdatedAt(updatedAt);
ticketStatus.setSyncDamai(item.getStatus());
ticketStatusMapper.update(ticketStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", item.getId()));
} else if (item.getType().equals("performance")) {
KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus();
performanceStatus.setUpdatedAt(updatedAt);
performanceStatus.setSyncDamai(item.getStatus());
performanceStatusMapper.update(performanceStatus, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", item.getId()));
}
}
return true;
} catch (Exception e) {
return false;
}
}
}
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/admin/KylinRoadShowsAdminServiceImpl.java deleted 100644 → 0
View file @ b33cc117
package com.liquidnet.service.kylin.service.impl.admin;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.liquidnet.commons.lang.util.IDGenerator;
import com.liquidnet.service.kylin.dao.RoadShowAdminListDao;
import com.liquidnet.service.kylin.dto.param.CreateRoadShowParam;
import com.liquidnet.service.kylin.dto.vo.KylinRoadShowVo;
import com.liquidnet.service.kylin.dto.vo.admin.KylinRoadShowAdminVo;
import com.liquidnet.service.kylin.entity.KylinRoadShows;
import com.liquidnet.service.kylin.mapper.KylinRoadShowsMapper;
import com.liquidnet.service.kylin.service.admin.IKylinRoadShowsAdminService;
import com.mongodb.BasicDBObject;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.convert.MongoConverter;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
import java.util.HashMap;
import java.util.List;
/**
* <p>
* 巡演 服务实现类
* </p>
*
* @author liquidnet
* @since 2021-05-11
*/
@Service
public class KylinRoadShowsAdminServiceImpl extends ServiceImpl<KylinRoadShowsMapper, KylinRoadShows> implements IKylinRoadShowsAdminService {
@Autowired
private MongoTemplate mongoTemplate;
@Autowired
private MongoConverter mongoConverter;
@Autowired
private KylinRoadShowsMapper kylinRoadShowsMapper;
@Override
public String createRoadShow(CreateRoadShowParam createRoadShowParam) {
try {
String roadShowId = IDGenerator.nextSnowId().toString();
createRoadShowParam.setStatus(1);
createRoadShowParam.setRoadShowsId(roadShowId);
createRoadShowParam.setCreatedAt(LocalDateTime.now());
KylinRoadShows roadShows = new KylinRoadShows();
BeanUtils.copyProperties(createRoadShowParam, roadShows);
kylinRoadShowsMapper.insert(roadShows);
KylinRoadShowVo kylinRoadShowVo = new KylinRoadShowVo();
BeanUtils.copyProperties(createRoadShowParam, kylinRoadShowVo);
mongoTemplate.insert(roadShows, KylinRoadShowVo.class.getSimpleName());
return roadShowId;
} catch (Exception e) {
return "";
}
}
@Override
public boolean updateRoadShow(CreateRoadShowParam createRoadShowParam) {
try {
KylinRoadShows roadShows = new KylinRoadShows();
createRoadShowParam.setUpdatedAt(LocalDateTime.now());
createRoadShowParam.setStatus(null);
BeanUtils.copyProperties(createRoadShowParam, roadShows);
kylinRoadShowsMapper.update(roadShows, new UpdateWrapper<KylinRoadShows>().eq("road_shows_id", createRoadShowParam.getRoadShowsId()));
KylinRoadShowVo kylinRoadShowVo = new KylinRoadShowVo();
BeanUtils.copyProperties(createRoadShowParam, kylinRoadShowVo);
BasicDBObject objectRoadShowVo = new BasicDBObject("$set", mongoConverter.convertToMongoType(roadShows));
mongoTemplate.getCollection(KylinRoadShows.class.getSimpleName()).updateOne(
Query.query(Criteria.where("roadShowsId").is(createRoadShowParam.getRoadShowsId())).getQueryObject(),
objectRoadShowVo);
return true;
} catch (Exception e) {
return false;
}
}
@Override
public boolean deleteRoadShow(String roadShowId, int status) {
KylinRoadShows roadShows = new KylinRoadShows();
roadShows.setStatus(status);
roadShows.setUpdatedAt(LocalDateTime.now());
kylinRoadShowsMapper.update(roadShows, new UpdateWrapper<KylinRoadShows>().eq("road_shows_id", roadShowId));
BasicDBObject objectRoadShowVo = new BasicDBObject("$set", mongoConverter.convertToMongoType(roadShows));
mongoTemplate.getCollection(KylinRoadShows.class.getSimpleName()).updateOne(
Query.query(Criteria.where("roadShowsId").is(roadShowId)).getQueryObject(),
objectRoadShowVo);
return false;
}
@Override
public KylinRoadShowAdminVo detailsRoadShow(String roadShowId) {
KylinRoadShows data = kylinRoadShowsMapper.selectOne(new UpdateWrapper<KylinRoadShows>().eq("road_shows_id", roadShowId));
KylinRoadShowAdminVo vo = new KylinRoadShowAdminVo();
vo.setTitle(data.getTitle());
vo.setRoadShowId(data.getRoadShowsId());
vo.setStatus(data.getStatus());
return vo;
}
@Override
public PageInfo<RoadShowAdminListDao> listRoadShow(String title, int page, int size) {
PageInfo<RoadShowAdminListDao> pageInfoTmp = null;
try {
HashMap<String, Object> map = new HashMap<>();
map.put("title", title);
PageHelper.startPage(page, size);
List<RoadShowAdminListDao> voList = kylinRoadShowsMapper.misRoadShowList(map);
pageInfoTmp = new PageInfo(voList);
} catch (Exception e) {
return null;
}
return pageInfoTmp;
}
}
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