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

Commit 71addbf5 authored by 胡佳晨's avatar 胡佳晨

Merge branch 'dev_ticket_system' into dev_merchant

# Conflicts:
#	liquidnet-bus-config/liquidnet-config/application-test.yml
#	liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/partner/KylinTicketTimesPartnerController.java
#	liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/partner/KylinTicketsPartnerController.java
parents 8e8524df 393c483b
package com.liquidnet.commons.lang.util;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.liquidnet.commons.lang.util.spring.RestTemplateConfig;
import org.springframework.http.*;
......@@ -65,7 +66,7 @@ public class HttpUtil {
return request(url, params, headers, HttpMethod.POST);
}
public static String postJson(String url,String jsonStr) {
public static String postJson(String url, String jsonStr) {
MultiValueMap<String, String> headers = new LinkedMultiValueMap();
headers.add("Content-Type", "application/json;charset=UTF-8");
headers.add("Accept", "application/json;charset=UTF-8");
......@@ -82,11 +83,12 @@ public class HttpUtil {
HttpEntity<Object> httpEntity = new HttpEntity(jsonStr, httpHeaders);
// 提交方式:表单、json
Object respObj = restTemplate.postForEntity(url,httpEntity,Object.class).getBody();;
Object respObj = restTemplate.postForEntity(url, httpEntity, Object.class).getBody();
;
return JsonUtils.toJson(respObj);
}
public static String postJson(String url,String jsonStr,MultiValueMap<String, String> headers) {
public static String postJson(String url, String jsonStr, MultiValueMap<String, String> headers) {
MultiValueMap<String, String> commonHeader = new LinkedMultiValueMap();
commonHeader.add("Content-Type", "application/json;charset=UTF-8");
commonHeader.add("Accept", "application/json;charset=UTF-8");
......@@ -107,12 +109,13 @@ public class HttpUtil {
// 提交方式:表单、json
// ResponseEntity<String> response = restTemplate.exchange(url, method, httpEntity, String.class);
Object respObj = restTemplate.postForEntity(url,httpEntity,Object.class).getBody();;
Object respObj = restTemplate.postForEntity(url, httpEntity, Object.class).getBody();
return JsonUtils.toJson(respObj);
}
/**
* josn post提交
*
* @param url
* @param jsonParam
* @return
......@@ -144,12 +147,25 @@ public class HttpUtil {
} catch (Exception e) {
System.out.println("posturl:" + url + ", err=" + e.getMessage());
}
if(result!=null){
if (result != null) {
rsResultObj = JSONObject.parseObject(result);
}
return rsResultObj;
}
/**
* post请求
*
* @param url
* @param jsonString 请求参数
* @param headers 请求头
* @return
*/
public static String getRaw(String url, String jsonString, MultiValueMap<String, String> headers) {
return requestRaw(url, jsonString, headers, HttpMethod.GET);
}
/**
* post请求
*
......@@ -276,15 +292,19 @@ public class HttpUtil {
// header
HttpHeaders httpHeaders = new HttpHeaders();
httpHeaders.add("Accept", MediaType.APPLICATION_JSON.toString());
httpHeaders.set("Content-Type","application/json;charset=UTF-8");
httpHeaders.set("Content-Type", "application/json;charset=UTF-8");
if (headers != null) {
httpHeaders.addAll(headers);
}
HttpEntity<Object> httpEntity = new HttpEntity(params, httpHeaders);
// RestTemplate restTemplate = new RestTemplate();
// 提交方式:表单、json
ResponseEntity<String> response = restTemplate.postForEntity(url, httpEntity, String.class);
ResponseEntity<String> response = null;
HttpEntity httpEntity = new HttpEntity(params, httpHeaders);
if (HttpMethod.POST == method) {
response = restTemplate.postForEntity(url, httpEntity, String.class);
} else if (HttpMethod.GET == method) {
Map<String,Object> map = JSON.parseObject(params.toString());
response = restTemplate.exchange(url,method,httpEntity,String.class,map);
}
return response.getBody();
}
......
package com.liquidnet.commons.lang.util.spring;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpEntityEnclosingRequestBase;
import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.springframework.http.HttpMethod;
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.web.client.DefaultResponseErrorHandler;
import org.springframework.web.client.RestTemplate;
import java.net.URI;
import java.util.concurrent.TimeUnit;
/**
......@@ -27,9 +31,9 @@ public class RestTemplateConfig {
PoolingHttpClientConnectionManager poolConnManager =
new PoolingHttpClientConnectionManager(20, TimeUnit.SECONDS);
// 设置最大链接数
poolConnManager.setMaxTotal(500*getMaxCpuCore() + 500 );
poolConnManager.setMaxTotal(500 * getMaxCpuCore() + 500);
// 单路由的并发数
poolConnManager.setDefaultMaxPerRoute(500*getMaxCpuCore());
poolConnManager.setDefaultMaxPerRoute(500 * getMaxCpuCore());
HttpClientBuilder httpClientBuilder = HttpClients.custom();
httpClientBuilder.setConnectionManager(poolConnManager);
......@@ -40,8 +44,9 @@ public class RestTemplateConfig {
// // 保持长链接配置,keep-alive
// httpClientBuilder.setKeepAliveStrategy(new DefaultConnectionKeepAliveStrategy());
HttpComponentsClientHttpRequestFactory httpComponentsClientHttpRequestFactory = new HttpComponentsClientHttpRequestFactory(httpClient);
// HttpComponentsClientHttpRequestFactory httpComponentsClientHttpRequestFactory = new HttpComponentsClientHttpRequestFactory(httpClient);
HttpComponentsClientHttpRequestFactory httpComponentsClientHttpRequestFactory = new HttpComponentsClientRestfulHttpRequestFactory(httpClient);
// 链接超时配置 5秒
httpComponentsClientHttpRequestFactory.setConnectTimeout(5000);
// 连接读取超时配置
......@@ -57,12 +62,42 @@ public class RestTemplateConfig {
restTemplate.setErrorHandler(new DefaultResponseErrorHandler());
}
public static RestTemplate getRestTemplate(){
public static RestTemplate getRestTemplate() {
return restTemplate;
}
private static int getMaxCpuCore(){
private static int getMaxCpuCore() {
int cpuCore = Runtime.getRuntime().availableProcessors();
return cpuCore;
}
static class HttpComponentsClientRestfulHttpRequestFactory extends HttpComponentsClientHttpRequestFactory {
public HttpComponentsClientRestfulHttpRequestFactory(HttpClient httpClient) {
new HttpComponentsClientHttpRequestFactory(httpClient);
}
@Override
protected HttpUriRequest createHttpUriRequest(HttpMethod httpMethod, URI uri) {
if (httpMethod == HttpMethod.GET) {
return new HttpGetRequestWithEntity(uri);
}
return super.createHttpUriRequest(httpMethod, uri);
}
/**
* 定义HttpGetRequestWithEntity实现HttpEntityEnclosingRequestBase抽象类,以支持GET请求携带body数据
*/
private final class HttpGetRequestWithEntity extends HttpEntityEnclosingRequestBase {
public HttpGetRequestWithEntity(final URI uri) {
super.setURI(uri);
}
@Override
public String getMethod() {
return HttpMethod.GET.name();
}
}
}
}
......@@ -82,6 +82,10 @@ liquidnet:
url: http://devsweet.zhengzai.tv
chime:
url: http://devchime.zhengzai.tv
other:
ticketSystemUrl: http://dev-report.capapiao.com
appId: 11920532
secret: 0854C2FFE6BED88E1E21E7F5BAF988CDF9D81D38
executor-main:
xxl:
admin:
......
......@@ -84,6 +84,10 @@ liquidnet:
url: http://testsweet.zhengzai.tv
chime:
url: http://testchime.zhengzai.tv
other:
ticketSystemUrl: http://dev-report.capapiao.com/
appId: 11920532
secret: 0854C2FFE6BED88E1E21E7F5BAF988CDF9D81D38
executor-main:
xxl:
admin:
......
......@@ -25,70 +25,70 @@ import javax.validation.constraints.NotNull;
* @author liquidnet
* @since 2021-05-21
*/
@Api(tags = "第三方-验票账号")
@RestController
@RequestMapping("partner/checkUser")
@Validated
//@Api(tags = "第三方-验票账号")
//@RestController
//@RequestMapping("partner/checkUser")
//@Validated
public class KylinCheckUserPartnerController {
@Autowired
private IKylinCheckUserPartnerService checkUserPartnerService;
@PostMapping(value = "")
@ApiOperation(value = "创建验票账号", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> create(@RequestParam("merchantId") @NotNull String merchantId,
@RequestParam("name") @NotNull String name,
@RequestParam("pwd") @NotNull String pwd,
@RequestParam("mobile") @NotNull @Length(max = 11) String mobile) {
return checkUserPartnerService.create(merchantId, name, pwd, mobile);
}
@DeleteMapping(value = "")
@ApiOperation(value = "删除验票账号", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> del(@RequestParam("merchantId") @NotNull String merchantId,
@RequestParam("checkUserId") @NotNull String checkUserId) {
return checkUserPartnerService.del(merchantId, checkUserId);
}
@PostMapping(value = "change")
@ApiOperation(value = "修改验票账号", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> change(@RequestParam("merchantId") @NotNull String merchantId,
@RequestParam("checkUserId") @NotNull String checkUserId,
@RequestParam("name") @NotNull String name,
@RequestParam(value = "pwd",required = false) String pwd,
@RequestParam("mobile") @Length(max = 11) String mobile) {
return checkUserPartnerService.change(merchantId, checkUserId, name, pwd, mobile);
}
@GetMapping(value = "list")
@ApiOperation(value = "验票账号列表", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PageInfo<ChildListDao>> getCheckUserList(@RequestParam("merchantId") @NotNull String merchantId,
@RequestParam(value = "mobile" , required = false) @Length(max = 11) String mobile,
@RequestParam("page") @NotNull @Min(1) int page,
@RequestParam("size") @NotNull @Min(1)int size) {
PageInfo<ChildListDao> result = checkUserPartnerService.getCheckUserList(merchantId,mobile,page,size);
if (null == result) {
return ResponseDto.failure("查询失败");
} else {
return ResponseDto.success(result);
}
}
@GetMapping(value = "details")
@ApiOperation(value = "验票账号详情", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<ChildDetailsDao> details(@RequestParam("merchantId") @NotNull String merchantId,
@RequestParam("checkUserId") @NotNull String checkUserId) {
ResponseDto<ChildDetailsDao> result = checkUserPartnerService.details(merchantId,checkUserId);
if (null == result) {
return ResponseDto.failure("查询失败");
} else {
return result;
}
}
// @Autowired
// private IKylinCheckUserPartnerService checkUserPartnerService;
//
// @PostMapping(value = "")
// @ApiOperation(value = "创建验票账号", position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> create(@RequestParam("merchantId") @NotNull String merchantId,
// @RequestParam("name") @NotNull String name,
// @RequestParam("pwd") @NotNull String pwd,
// @RequestParam("mobile") @NotNull @Length(max = 11) String mobile) {
// return checkUserPartnerService.create(merchantId, name, pwd, mobile);
// }
//
// @DeleteMapping(value = "")
// @ApiOperation(value = "删除验票账号", position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> del(@RequestParam("merchantId") @NotNull String merchantId,
// @RequestParam("checkUserId") @NotNull String checkUserId) {
// return checkUserPartnerService.del(merchantId, checkUserId);
// }
//
// @PostMapping(value = "change")
// @ApiOperation(value = "修改验票账号", position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> change(@RequestParam("merchantId") @NotNull String merchantId,
// @RequestParam("checkUserId") @NotNull String checkUserId,
// @RequestParam("name") @NotNull String name,
// @RequestParam(value = "pwd",required = false) String pwd,
// @RequestParam("mobile") @Length(max = 11) String mobile) {
// return checkUserPartnerService.change(merchantId, checkUserId, name, pwd, mobile);
// }
//
// @GetMapping(value = "list")
// @ApiOperation(value = "验票账号列表", position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PageInfo<ChildListDao>> getCheckUserList(@RequestParam("merchantId") @NotNull String merchantId,
// @RequestParam(value = "mobile" , required = false) @Length(max = 11) String mobile,
// @RequestParam("page") @NotNull @Min(1) int page,
// @RequestParam("size") @NotNull @Min(1)int size) {
// PageInfo<ChildListDao> result = checkUserPartnerService.getCheckUserList(merchantId,mobile,page,size);
// if (null == result) {
// return ResponseDto.failure("查询失败");
// } else {
// return ResponseDto.success(result);
// }
// }
//
// @GetMapping(value = "details")
// @ApiOperation(value = "验票账号详情", position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<ChildDetailsDao> details(@RequestParam("merchantId") @NotNull String merchantId,
// @RequestParam("checkUserId") @NotNull String checkUserId) {
// ResponseDto<ChildDetailsDao> result = checkUserPartnerService.details(merchantId,checkUserId);
// if (null == result) {
// return ResponseDto.failure("查询失败");
// } else {
// return result;
// }
// }
}
......@@ -27,49 +27,49 @@ import java.util.List;
* @author liquidnet
* @since 2021-05-21
*/
@Api(tags = "第三方-验票账号关联演出")
@RestController
@RequestMapping("partner/checkUser/performance")
@Validated
//@Api(tags = "第三方-验票账号关联演出")
//@RestController
//@RequestMapping("partner/checkUser/performance")
//@Validated
public class KylinCheckUserPerformancesPartnerController {
@Autowired
private IKylinCheckUserPerformancesPartnerService userPerformancesPartnerService;
@PostMapping(value = "")
@ApiOperation(value = "添加关联关系", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> setPerformance(@RequestBody @Valid CheckUserParam param) {
return userPerformancesPartnerService.setPerformance(param);
}
@DeleteMapping(value = "")
@ApiOperation(value = "删除关联关系", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> delPerformance(@RequestParam("performanceIds") @Size(min = 1) @NotNull(message = "演出ID不能为空") List<String> performanceIds,
@RequestParam("checkUserId") String checkUserId) {
return userPerformancesPartnerService.delPerformance(performanceIds, checkUserId);
}
@GetMapping(value = "relation")
@ApiOperation(value = "关联演出列表", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PageInfo<ChildPerformanceDao>> childPerformanceList(@RequestParam("merchantId") @NotNull(message = "商户ID不能为空") String merchantId,
@RequestParam("checkUserId") @NotNull(message = "验票用户ID不能为空") String checkUserId,
@RequestParam("page") @NotNull(message = "页数不能为空") @Min(1) int page,
@RequestParam("size") @NotNull(message = "数量不能为空") @Min(1) int size,
@RequestParam("name") String name) {
return userPerformancesPartnerService.childPerformanceList(merchantId, checkUserId, page, size, name);
}
@GetMapping(value = "unRelation")
@ApiOperation(value = "未关联演出列表", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PageInfo<ChildPerformanceDao>> unChildPerformanceList(@RequestParam("merchantId") @NotNull(message = "商户ID不能为空") String merchantId,
@RequestParam("checkUserId") @NotNull(message = "验票用户ID不能为空") String checkUserId,
@RequestParam("page") @NotNull(message = "页数不能为空") @Min(1) int page,
@RequestParam("size") @NotNull(message = "数量不能为空") @Min(1) int size,
@RequestParam("name") String name) {
return userPerformancesPartnerService.unChildPerformanceList(merchantId, checkUserId, page, size, name);
}
// @Autowired
// private IKylinCheckUserPerformancesPartnerService userPerformancesPartnerService;
//
// @PostMapping(value = "")
// @ApiOperation(value = "添加关联关系", position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> setPerformance(@RequestBody @Valid CheckUserParam param) {
// return userPerformancesPartnerService.setPerformance(param);
// }
//
// @DeleteMapping(value = "")
// @ApiOperation(value = "删除关联关系", position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> delPerformance(@RequestParam("performanceIds") @Size(min = 1) @NotNull(message = "演出ID不能为空") List<String> performanceIds,
// @RequestParam("checkUserId") String checkUserId) {
// return userPerformancesPartnerService.delPerformance(performanceIds, checkUserId);
// }
//
// @GetMapping(value = "relation")
// @ApiOperation(value = "关联演出列表", position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PageInfo<ChildPerformanceDao>> childPerformanceList(@RequestParam("merchantId") @NotNull(message = "商户ID不能为空") String merchantId,
// @RequestParam("checkUserId") @NotNull(message = "验票用户ID不能为空") String checkUserId,
// @RequestParam("page") @NotNull(message = "页数不能为空") @Min(1) int page,
// @RequestParam("size") @NotNull(message = "数量不能为空") @Min(1) int size,
// @RequestParam("name") String name) {
// return userPerformancesPartnerService.childPerformanceList(merchantId, checkUserId, page, size, name);
// }
//
// @GetMapping(value = "unRelation")
// @ApiOperation(value = "未关联演出列表", position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PageInfo<ChildPerformanceDao>> unChildPerformanceList(@RequestParam("merchantId") @NotNull(message = "商户ID不能为空") String merchantId,
// @RequestParam("checkUserId") @NotNull(message = "验票用户ID不能为空") String checkUserId,
// @RequestParam("page") @NotNull(message = "页数不能为空") @Min(1) int page,
// @RequestParam("size") @NotNull(message = "数量不能为空") @Min(1) int size,
// @RequestParam("name") String name) {
// return userPerformancesPartnerService.unChildPerformanceList(merchantId, checkUserId, page, size, name);
// }
}
......@@ -23,49 +23,48 @@ import javax.validation.constraints.NotNull;
* @author liquidnet
* @since 2021-05-06
*/
@Api(tags = "第三方-场次",position = 1002)
@RestController
@RequestMapping("partner/times")
@Validated
//@Api(tags = "第三方-场次",position = 1002)
//@RestController
//@RequestMapping("partner/times")
//@Validated
public class KylinTicketTimesPartnerController {
@Autowired
private IKylinTicketTimesPartnerService ticketTimesPartnerService;
@PostMapping(value = "")
@ApiOperation(value = "创建场次",position = 1)
@ApiResponse(response = KylinTicketTimesPartnerVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<KylinTicketTimesPartnerVo> createTimesSummary(@RequestBody @Valid CreateTicketTimesParam createTicketTimesParam) {
return ticketTimesPartnerService.createTimesSummary(createTicketTimesParam);
}
@DeleteMapping(value = "")
@ApiOperation(value = "删除场次",position = 2)
@ApiResponse(response = KylinTicketTimesPartnerVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<String> deleteTimes(@RequestParam("ticketTimesId") @NotNull(message = "场次ID不能为空") String ticketTimesId,
@RequestParam("performanceId") @NotNull(message = "演出ID不能为空") String performanceId) {
return ticketTimesPartnerService.deleteTimes(ticketTimesId,performanceId);
}
@PutMapping(value = "")
@ApiOperation(value = "修改场次",position = 3)
@ApiResponse(response = KylinTicketTimesPartnerVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<KylinTicketTimesPartnerVo> changeTimes(@RequestBody @Valid CreateTicketTimesParam createTicketTimesParam) {
return ticketTimesPartnerService.changeTimes(createTicketTimesParam);
}
@GetMapping(value = "/details")
@ApiOperation(value = "获取场次详情",position = 4)
@ApiResponse(response = KylinTicketTimesPartnerVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<KylinTicketTimesPartnerVo> getTimesMongo(@RequestParam("ticketTimesId") @NotNull(message = "场次ID不能为空") String ticketTimesId) {
KylinTicketTimesPartnerVo result = null;
result = ticketTimesPartnerService.getTimesMongo(ticketTimesId);
if (null == result) {
return ResponseDto.failure("查询场次信息失败");
} else {
return ResponseDto.success(result);
}
}
// @Autowired
// private IKylinTicketTimesPartnerService ticketTimesPartnerService;
//
// @PostMapping(value = "")
// @ApiOperation(value = "创建场次",position = 1)
// @ApiResponse(response = KylinTicketTimesPartnerVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<KylinTicketTimesPartnerVo> createTimesSummary(@RequestBody @Valid CreateTicketTimesParam createTicketTimesParam) {
// return ticketTimesPartnerService.createTimesSummary(createTicketTimesParam);
// }
//
// @DeleteMapping(value = "")
// @ApiOperation(value = "删除场次",position = 2)
// @ApiResponse(response = KylinTicketTimesPartnerVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<String> deleteTimes(@RequestParam("ticketTimesId") @NotNull(message = "场次ID不能为空") String ticketTimesId) {
// return ticketTimesPartnerService.deleteTimes(ticketTimesId);
// }
//
// @PutMapping(value = "")
// @ApiOperation(value = "修改场次",position = 3)
// @ApiResponse(response = KylinTicketTimesPartnerVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<KylinTicketTimesPartnerVo> changeTimes(@RequestBody @Valid CreateTicketTimesParam createTicketTimesParam) {
// return ticketTimesPartnerService.changeTimes(createTicketTimesParam);
// }
//
// @GetMapping(value = "/details")
// @ApiOperation(value = "获取场次详情",position = 4)
// @ApiResponse(response = KylinTicketTimesPartnerVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<KylinTicketTimesPartnerVo> getTimesMongo(@RequestParam("ticketTimesId") @NotNull(message = "场次ID不能为空") String ticketTimesId) {
// KylinTicketTimesPartnerVo result = null;
// result = ticketTimesPartnerService.getTimesMongo(ticketTimesId);
// if (null == result) {
// return ResponseDto.failure("查询场次信息失败");
// } else {
// return ResponseDto.success(result);
// }
// }
//
}
......@@ -23,71 +23,70 @@ import javax.validation.constraints.NotNull;
* @author liquidnet
* @since 2021-05-06
*/
@Api(tags = "第三方-票",position = 1003)
@RestController
@RequestMapping("partner/ticket")
@Validated
//@Api(tags = "第三方-票",position = 1003)
//@RestController
//@RequestMapping("partner/ticket")
//@Validated
public class KylinTicketsPartnerController {
@Autowired
private IKylinTicketsPartnerService ticketsPartnerService;
@PostMapping(value = "")
@ApiOperation(value = "创建票务",position = 1 )
@ApiResponse(response = KylinTicketPartnerVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<KylinTicketPartnerVo> createTicketSummary(@RequestBody @Valid TicketCreateParam ticketCreateParam) {
return ticketsPartnerService.createTicketSummary(ticketCreateParam);
}
@PutMapping(value = "")
@ApiOperation(value = "修改票务",position = 2)
@ApiResponse(response = KylinTicketPartnerVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<KylinTicketPartnerVo> updateTicket(@RequestBody @Valid TicketCreateParam ticketCreateParam) {
return ticketsPartnerService.updateTicket(ticketCreateParam);
}
@DeleteMapping(value = "")
@ApiOperation(value = "删除票务",position = 3)
@ApiResponse( code = 200, message = "接口返回对象参数")
public ResponseDto<String> deleteTicket(@RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId,
@RequestParam("performanceId") @NotNull(message = "演出ID不能为空") String performanceId) {
return ticketsPartnerService.deleteTicket(ticketsId,performanceId);
}
@PostMapping(value = "/copy")
@ApiOperation(value = "复制票务",position = 4)
@ApiResponse(response = KylinTicketPartnerVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<KylinTicketPartnerVo> copyTicket(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId,
@RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId) {
return ticketsPartnerService.copyTicket(performancesId,ticketsId);
}
@GetMapping(value = "/details")
@ApiOperation(value = "获取票务详情",position = 5)
@ApiResponse(response = KylinTicketPartnerVo.class, code = 200, message = "接口返回对象参数")
public ResponseDto<KylinTicketPartnerVo> getTicketsMongo(@RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId) {
KylinTicketPartnerVo result = null;
result = ticketsPartnerService.getTicketsMongo(ticketsId);
if (null == result) {
return ResponseDto.failure("查询票务信息失败");
} else {
return ResponseDto.success(result);
}
}
@PostMapping(value = "/onLine")
@ApiOperation(value = "票上线",position = 6)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> onLine(@RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId,
@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
return ticketsPartnerService.onLine(ticketsId,performancesId);
}
@PostMapping(value = "/outLine")
@ApiOperation(value = "票下线",position = 7)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> outLine(@RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId,
@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
return ticketsPartnerService.outLine(ticketsId,performancesId);
}
// @Autowired
// private IKylinTicketsPartnerService ticketsPartnerService;
//
// @PostMapping(value = "")
// @ApiOperation(value = "创建票务",position = 1 )
// @ApiResponse(response = KylinTicketPartnerVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<KylinTicketPartnerVo> createTicketSummary(@RequestBody @Valid TicketCreateParam ticketCreateParam) {
// return ticketsPartnerService.createTicketSummary(ticketCreateParam);
// }
//
// @PutMapping(value = "")
// @ApiOperation(value = "修改票务",position = 2)
// @ApiResponse(response = KylinTicketPartnerVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<KylinTicketPartnerVo> updateTicket(@RequestBody @Valid TicketCreateParam ticketCreateParam) {
// return ticketsPartnerService.updateTicket(ticketCreateParam);
// }
//
// @DeleteMapping(value = "")
// @ApiOperation(value = "删除票务",position = 3)
// @ApiResponse( code = 200, message = "接口返回对象参数")
// public ResponseDto<String> deleteTicket(@RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId) {
// return ticketsPartnerService.deleteTicket(ticketsId);
// }
//
// @PostMapping(value = "/copy")
// @ApiOperation(value = "复制票务",position = 4)
// @ApiResponse(response = KylinTicketPartnerVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<KylinTicketPartnerVo> copyTicket(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId,
// @RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId) {
// return ticketsPartnerService.copyTicket(performancesId,ticketsId);
// }
//
// @GetMapping(value = "/details")
// @ApiOperation(value = "获取票务详情",position = 5)
// @ApiResponse(response = KylinTicketPartnerVo.class, code = 200, message = "接口返回对象参数")
// public ResponseDto<KylinTicketPartnerVo> getTicketsMongo(@RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId) {
// KylinTicketPartnerVo result = null;
// result = ticketsPartnerService.getTicketsMongo(ticketsId);
// if (null == result) {
// return ResponseDto.failure("查询票务信息失败");
// } else {
// return ResponseDto.success(result);
// }
// }
//
// @PostMapping(value = "/onLine")
// @ApiOperation(value = "票上线",position = 6)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> onLine(@RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId,
// @RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
// return ticketsPartnerService.onLine(ticketsId,performancesId);
// }
//
// @PostMapping(value = "/outLine")
// @ApiOperation(value = "票下线",position = 7)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> outLine(@RequestParam("ticketsId") @NotNull(message = "票务ID不能为空") String ticketsId,
// @RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
// return ticketsPartnerService.outLine(ticketsId,performancesId);
// }
}
......@@ -22,101 +22,101 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Api(tags = "第三方-演出",position = 1001)
@RestController
@RequestMapping("partner/performance")
@Validated
//@Api(tags = "第三方-演出",position = 1001)
//@RestController
//@RequestMapping("partner/performance")
//@Validated
public class PerformancePartnerController {
@Autowired
private IKylinPerformancesPartnerService performancesPartnerService;
@PostMapping(value = "list")
@ApiOperation(value = "演出列表",position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PageInfo<PerformancePartnerListDao>> getList(@RequestBody @Valid PerformancePartnerListParam performancePartnerListParam) {
return performancesPartnerService.getList(performancePartnerListParam);
}
@PostMapping(value = "copy")
@ApiOperation(value = "复制演出",position = 6)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<Map<String, String>> copyPerformance(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
String result = performancesPartnerService.copyPerformance(performancesId);
if (null == result) {
return ResponseDto.failure("复制失败");
} else {
Map<String, String> map = new HashMap<>();
map.put("performancesId", result);
return ResponseDto.success(map);
}
}
@GetMapping(value = "step1")
@ApiOperation(value = "获取演出第一步数据",position = 3)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PerformancePartnerVo> getStep1(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
return performancesPartnerService.getStep1(performancesId);
}
@PostMapping(value = "step1")
@ApiOperation(value = "操作演出第一步",position = 2)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<Map<String, String>> Step1(@RequestBody @Valid PerformanceStep1Param performanceStep1Param) {
String result = performancesPartnerService.step1(performanceStep1Param);
if (result.isEmpty()) {
return ResponseDto.failure("操作失败");
} else if (result.equals("不可修改")) {
return ResponseDto.failure(result);
} else {
Map<String, String> map = new HashMap<>();
map.put("performancesId", result);
return ResponseDto.success(map);
}
}
@PostMapping(value = "step2")
@ApiOperation(value = "操作演出第二步",position = 4)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> step2(@RequestBody @Valid PerformanceStep2Param performanceStep2Param) {
return performancesPartnerService.step2(performanceStep2Param);
}
@GetMapping(value = "step2")
@ApiOperation(value = "获取演出第二步数据",position = 5)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<PerformanceStep2Param> getStep2(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
return performancesPartnerService.getStep2(performancesId);
}
@PostMapping(value = "online")
@ApiOperation(value = "演出上线",position = 7)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> onLinePerformance(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
return performancesPartnerService.onLinePerformance(performancesId);
}
@PostMapping(value = "outline")
@ApiOperation(value = "演出下线",position = 8)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> outLinePerformance(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
return performancesPartnerService.outLinePerformance(performancesId);
}
@PostMapping(value = "withdraw")
@ApiOperation(value = "演出撤回",position = 9)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> withdraw(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
return performancesPartnerService.withdraw(performancesId);
}
@GetMapping(value = "orderStatistical")
@ApiOperation(value = "演出订单统计",position = 9)
@ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<List<PerformanceOrderStatisticalVo>> performanceOrderStatisticalList(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
List<PerformanceOrderStatisticalVo> list =performancesPartnerService.getPerformanceOrderStatisticalList(performancesId);
return ResponseDto.success(list);
}
// @Autowired
// private IKylinPerformancesPartnerService performancesPartnerService;
//
// @PostMapping(value = "list")
// @ApiOperation(value = "演出列表",position = 1)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PageInfo<PerformancePartnerListDao>> getList(@RequestBody @Valid PerformancePartnerListParam performancePartnerListParam) {
// return performancesPartnerService.getList(performancePartnerListParam);
// }
//
// @PostMapping(value = "copy")
// @ApiOperation(value = "复制演出",position = 6)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<Map<String, String>> copyPerformance(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
// String result = performancesPartnerService.copyPerformance(performancesId);
// if (null == result) {
// return ResponseDto.failure("复制失败");
// } else {
// Map<String, String> map = new HashMap<>();
// map.put("performancesId", result);
// return ResponseDto.success(map);
// }
// }
//
//
// @GetMapping(value = "step1")
// @ApiOperation(value = "获取演出第一步数据",position = 3)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PerformancePartnerVo> getStep1(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
// return performancesPartnerService.getStep1(performancesId);
// }
//
// @PostMapping(value = "step1")
// @ApiOperation(value = "操作演出第一步",position = 2)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<Map<String, String>> Step1(@RequestBody @Valid PerformanceStep1Param performanceStep1Param) {
// String result = performancesPartnerService.step1(performanceStep1Param);
// if (result.isEmpty()) {
// return ResponseDto.failure("操作失败");
// } else if (result.equals("不可修改")) {
// return ResponseDto.failure(result);
// } else {
// Map<String, String> map = new HashMap<>();
// map.put("performancesId", result);
// return ResponseDto.success(map);
// }
// }
//
//
// @PostMapping(value = "step2")
// @ApiOperation(value = "操作演出第二步",position = 4)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> step2(@RequestBody @Valid PerformanceStep2Param performanceStep2Param) {
// return performancesPartnerService.step2(performanceStep2Param);
// }
//
// @GetMapping(value = "step2")
// @ApiOperation(value = "获取演出第二步数据",position = 5)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PerformanceStep2Param> getStep2(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
// return performancesPartnerService.getStep2(performancesId);
// }
//
// @PostMapping(value = "online")
// @ApiOperation(value = "演出上线",position = 7)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> onLinePerformance(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
// return performancesPartnerService.onLinePerformance(performancesId);
// }
//
// @PostMapping(value = "outline")
// @ApiOperation(value = "演出下线",position = 8)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> outLinePerformance(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
// return performancesPartnerService.outLinePerformance(performancesId);
// }
//
// @PostMapping(value = "withdraw")
// @ApiOperation(value = "演出撤回",position = 9)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<String> withdraw(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
// return performancesPartnerService.withdraw(performancesId);
// }
//
// @GetMapping(value = "orderStatistical")
// @ApiOperation(value = "演出订单统计",position = 9)
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<List<PerformanceOrderStatisticalVo>> performanceOrderStatisticalList(@RequestParam("performancesId") @NotNull(message = "演出ID不能为空") String performancesId) {
// List<PerformanceOrderStatisticalVo> list =performancesPartnerService.getPerformanceOrderStatisticalList(performancesId);
// return ResponseDto.success(list);
// }
}
package com.liquidnet.service.platform.controller.ticketSystem;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.platform.param.ticketSystem.*;
import com.liquidnet.service.platform.service.ticketSystem.ITicketSystemService;
import com.liquidnet.service.platform.vo.ticketSystem.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import lombok.extern.slf4j.XSlf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.validation.constraints.NotNull;
import java.util.List;
@Api(tags = "票务平台")
@RestController
@RequestMapping("st")
@Slf4j
public class TicketSystemController {
@Autowired
ITicketSystemService ticketSystemService;
@GetMapping("type/list")
@ApiOperation("查询标准演出类型")
public ResponseDto<List<STPTListVo>> getPerformanceTypeList() {
try {
String accessToken = ticketSystemService.getAccessToken();
List<STPTListVo> vo = ticketSystemService.getPerformanceTypeList(accessToken);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("查询标准演出类型 ERROR : {}", e);
return ResponseDto.failure();
}
}
@GetMapping("field/list")
@ApiOperation("查询标准演出场所")
public ResponseDto<List<STFieldListVo>> getFieldList(STFieldListParam fieldListParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
List<STFieldListVo> vo = ticketSystemService.getFieldList(accessToken, fieldListParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("查询标准演出场所 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("field/insert")
@ApiOperation("新增演出场厅")
public ResponseDto<STFieldChangeVo> insertField(STInsertFieldParam insertFieldParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
STFieldChangeVo vo = ticketSystemService.insertField(accessToken, insertFieldParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("新增演出场厅 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("performance/insert")
@ApiOperation("上报演出场次")
public ResponseDto<String> insertPerformance(STInsertPerformanceParam insertPerformanceParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
String vo = ticketSystemService.insertPerformance(accessToken, insertPerformanceParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("上报演出场次 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("performance/update")
@ApiOperation("更新上报的演出项目数据")
public ResponseDto<Boolean> updatePerformance(STUpdatePerformanceParam updatePerformanceParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
boolean vo = ticketSystemService.updatePerformance(accessToken, updatePerformanceParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("更新上报的演出项目数据 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("times/update")
@ApiOperation("更新上报的场次数据")
public ResponseDto<Boolean> updateTimes(STUpdateTimesParam updateTimesParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
boolean vo = ticketSystemService.updateTimes(accessToken, updateTimesParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("更新上报的场次数据 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("ticketPrice/insert")
@ApiOperation("上报票价信息")
public ResponseDto<Boolean> insertTicketPrice(STInsertTicketPriceParam insertTicketPriceParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
boolean vo = ticketSystemService.insertTicketPrice(accessToken, insertTicketPriceParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("上报票价信息 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("ticketPrice/del")
@ApiOperation("删除票价信息")
public ResponseDto<Boolean> delTicketPrice(STDelTicketPriceParam delTicketPriceParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
boolean vo = ticketSystemService.delTicketPrice(accessToken, delTicketPriceParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("新增演出场厅 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("ticket/insert")
@ApiOperation("上报票信息")
public ResponseDto<Boolean> insertTicket(STInsertTicketParam insertTicketParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
boolean vo = ticketSystemService.insertTicket(accessToken, insertTicketParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("上报票信息 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("ticket/del")
@ApiOperation("删除票信息")
public ResponseDto<Boolean> delTicket(STDelTicketParam delTicketParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
boolean vo = ticketSystemService.delTicket(accessToken, delTicketParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("删除票信息 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("order/insert")
@ApiOperation("上报订单信息")
public ResponseDto<Boolean> insertOrder(STInsertOrderParam insertOrderParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
boolean vo = ticketSystemService.insertOrder(accessToken, insertOrderParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("上报订单信息 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("order/refund")
@ApiOperation("上报退票信息")
public ResponseDto<Boolean> refundOrder(STRefundOrderParam refundOrderParam) {
try {
String accessToken = ticketSystemService.getAccessToken();
Boolean vo = ticketSystemService.refundOrder(accessToken, refundOrderParam);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("上报退票信息 ERROR : {}", e);
return ResponseDto.failure();
}
}
@PostMapping("check/insert")
@ApiOperation("上报检票数据")
public ResponseDto<Boolean> insertCheck(List<CheckVo> ticketList) {
try {
String accessToken = ticketSystemService.getAccessToken();
boolean vo = ticketSystemService.insertCheck(accessToken, ticketList);
return ResponseDto.success(vo);
} catch (Exception e) {
log.error("上报检票数据 ERROR : {}", e);
return ResponseDto.failure();
}
}
}
package com.liquidnet.service.platform.param.ticketSystem;
import com.liquidnet.service.platform.vo.ticketSystem.TicketVo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
@Data
@ApiModel(value = "STDelTicketParam",description = "详情")
public class STDelTicketParam {
@ApiModelProperty(value = "演出id [必传]")
String performanceId;
@ApiModelProperty(value = "场次编码 [必传]")
String sessionCode;
@ApiModelProperty(value = "票价ID [必传]")
String priceId;
@ApiModelProperty(value = "票ID [必传]")
String ticketId;
}
\ No newline at end of file
package com.liquidnet.service.platform.param.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
@ApiModel(value = "STDelTicketPriceParam", description = "详情")
public class STDelTicketPriceParam {
@ApiModelProperty(value = "演出ID [必传]")
String performanceId;
@ApiModelProperty(value = "场次编码 [必传]")
String sessionCode;
@ApiModelProperty(value = "票价ID [必传]")
String priceId;
}
\ No newline at end of file
package com.liquidnet.service.platform.param.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
@ApiModel(value = "STFieldListParam", description = "详情")
public class STFieldListParam {
@ApiModelProperty(value = "省ID [非必传]")
long provinceId;
@ApiModelProperty(value = "市ID [非必传]")
long cityId;
@ApiModelProperty(value = "区ID [非必传]")
long districtId;
@ApiModelProperty(value = "页码,默认1 [必传]")
Integer pageNo;
@ApiModelProperty(value = "每页条数最大200 [必传]")
Integer pageSize;
@ApiModelProperty(value = "场所名称,支持模糊查询 [非必传]")
String venueName;
}
package com.liquidnet.service.platform.param.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
@ApiModel(value = "STInsertFieldParam", description = "详情")
public class STInsertFieldParam {
@ApiModelProperty(value = "场所编码 [为空会新增场所]")
String venueCode;
@ApiModelProperty(value = "省ID [新增场所时必填]")
Integer provinceId;
@ApiModelProperty(value = "市ID [新增场所时必填]")
Integer cityId;
@ApiModelProperty(value = "区ID [新增场所时必填]")
Integer districtId;
@ApiModelProperty(value = "场所名称 [新增场所时必填]")
String venueName;
@ApiModelProperty(value = "场所详细地址 [新增场所时必填]")
String venueAddress;
@ApiModelProperty(value = "经营单位 [非必传]")
String managementCompany;
@ApiModelProperty(value = "是否有场厅 [必传]")
Integer hasHall;
@ApiModelProperty(value = "场厅名称 [有场厅时必传]")
String hallName;
@ApiModelProperty(value = "是否有座 [必传]")
Integer hasSeat;
@ApiModelProperty(value = "场厅座位数量 [有座时必传]")
Integer seatNum;
@ApiModelProperty(value = "场厅可容纳人数 [无座时必传]")
Integer seatingCapacity;
}
package com.liquidnet.service.platform.param.ticketSystem;
import com.liquidnet.service.platform.vo.ticketSystem.OrderVo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.time.LocalDateTime;
import java.util.List;
@Data
@ApiModel(value = "STInsertOrderParam",description = "详情")
public class STInsertOrderParam {
@ApiModelProperty(value = "订单id [必传]")
String orderId;
@ApiModelProperty(value = "下单时间 [必传]")
LocalDateTime orderTime;
@ApiModelProperty(value = "渠道类型,1自销,2分销 [必传]")
Integer channelType;
@ApiModelProperty(value = "渠道名称 [必传]")
String channelName;
@ApiModelProperty(value = "购票数量 [必传]")
Integer ticketNum;
@ApiModelProperty(value = "订单总金额,单位分,订单实收金额 [必传]")
long totalAmount;
@ApiModelProperty(value = "出票类型1:正常票,2:工作票,3:赠票 [必传]")
Integer ticketType;
@ApiModelProperty(value = "出票方式, 1纸制票,2 电子票 [必传]")
Integer ticketMode;
@ApiModelProperty(value = "实名方式,1 非实名,2一单一证,3一票一证 [必传]")
Integer authMode;
@ApiModelProperty(value = "票单List,多个票用英文逗号分隔 [必传]")
List<OrderVo> ticketOrderList;
}
\ No newline at end of file
package com.liquidnet.service.platform.param.ticketSystem;
import com.liquidnet.service.platform.vo.ticketSystem.TimesVo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
@Data
@ApiModel(value = "STInsertPerformanceParam",description = "详情")
public class STInsertPerformanceParam {
@ApiModelProperty(value = "演出活动ID [如果不存在,则新增演出项目]")
String performanceId;
@ApiModelProperty(value = "演出活动名称 [必传]")
String performanceName;
@ApiModelProperty(value = "批文号 [有的话必传]")
String approval;
@ApiModelProperty(value = "演出类型编码,参考附录演出类型 [必传]")
Integer typeId;
@ApiModelProperty(value = "演出封面图 [非必传]")
String posterUrl;
@ApiModelProperty(value = "演出描述 [非必传]")
String performanceDesc;
@ApiModelProperty(value = "主办方,多个用英文逗号分隔 [非必传]")
String sponsor;
@ApiModelProperty(value = " 演员,多个用英文逗号分隔 [非必传]")
String performer;
@ApiModelProperty(value = "演出场次ID List,传多个场次时可以批量获取场次编码 [必传]")
List<TimesVo> sessionList;
}
package com.liquidnet.service.platform.param.ticketSystem;
import com.liquidnet.service.platform.vo.ticketSystem.TicketVo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
@Data
@ApiModel(value = "STInsertTicketParam", description = "详情")
public class STInsertTicketParam {
@ApiModelProperty(value = "演出ID [必传]")
String performanceId;
@ApiModelProperty(value = "场次id [必传]")
String sessionId;
@ApiModelProperty(value = "场次编码 [必传]")
String sessionCode;
@ApiModelProperty(value = "票价ID [必传]")
String priceId;
@ApiModelProperty(value = "票List [必传]")
List<TicketVo> ticketList;
}
\ No newline at end of file
package com.liquidnet.service.platform.param.ticketSystem;
import com.liquidnet.service.platform.vo.ticketSystem.TicketPriceVo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
@Data
@ApiModel(value = "STInsertTicketPriceParam", description = "详情")
public class STInsertTicketPriceParam {
@ApiModelProperty(value = "场次编码 [必传]")
String sessionCode;
@ApiModelProperty(value = "票价信息数组 [必传]")
List<TicketPriceVo> priceList;
}
\ No newline at end of file
package com.liquidnet.service.platform.param.ticketSystem;
import com.liquidnet.service.platform.vo.ticketSystem.RefundOrderVo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.time.LocalDateTime;
import java.util.List;
@Data
@ApiModel(value = "STRefundOrderParam", description = "详情")
public class STRefundOrderParam {
@ApiModelProperty(value = "退单订单id [必传]")
String refundOrderId;
@ApiModelProperty(value = "订单id [必传]")
String orderId;
@ApiModelProperty(value = "退单原因 [必传]")
String reason;
@ApiModelProperty(value = "退单时间 [必传]")
LocalDateTime refundOrderTime;
@ApiModelProperty(value = "票单List [必传]")
List<RefundOrderVo> ticketOrderList;
}
\ No newline at end of file
package com.liquidnet.service.platform.param.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
@ApiModel(value = "STUpdatePerformanceParam", description = "详情")
public class STUpdatePerformanceParam {
@ApiModelProperty(value = "演出ID [必传]")
String performanceId;
@ApiModelProperty(value = "演出名称 [非必传]")
String performanceName;
@ApiModelProperty(value = "演出描述 [非必传]")
String performanceDesc;
@ApiModelProperty(value = "演出类型 [非必传]")
Integer typeId;
@ApiModelProperty(value = "演出封面图 [非必传]")
String posterUrl;
@ApiModelProperty(value = "主办方,多个用英文逗号分隔 [非必传]")
String sponsor;
@ApiModelProperty(value = "演员,多个用英文逗号分隔 [非必传]")
String performer;
@ApiModelProperty(value = "批文号 [非必传]")
String approval;
}
package com.liquidnet.service.platform.param.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.time.LocalDateTime;
@Data
@ApiModel(value = "STUpdateTimesParam",description = "详情")
public class STUpdateTimesParam {
@ApiModelProperty(value = "演出场次ID [必传]")
String sessionId;
@ApiModelProperty(value = "演出场次编码 [必传]")
String sessionCode;
@ApiModelProperty(value = "场次名称 [必传]")
String sessionName;
@ApiModelProperty(value = "场次开始时间 [必传]")
LocalDateTime sessionStartTime;
@ApiModelProperty(value = "场次结束时间 [必传]")
java.time.LocalDateTime sessionEndTime;
@ApiModelProperty(value = "场厅编码 [必传]")
String hallCode;
@ApiModelProperty(value = " 是否有座,0:无座1:有座 [必传]")
Integer hasSeat;
@ApiModelProperty(value = "演出ID [必传]")
String performanceId;
@ApiModelProperty(value = "场次状态,1 正常,2 取消 [必传]")
Integer sessionStatus;
@ApiModelProperty(value = " 标记,0:正式,1:测试 [非必传]")
Integer tag;
@ApiModelProperty(value = "票图URL [有座场次必传]")
String seatingChart;
}
\ No newline at end of file
package com.liquidnet.service.platform.service.ticketSystem;
import com.liquidnet.service.platform.param.ticketSystem.*;
import com.liquidnet.service.platform.vo.ticketSystem.*;
import java.time.LocalDateTime;
import java.util.List;
/**
* <p>
* 票务对接平台 服务类
* </p>
*
* @author liquidnet
* @since 2021-07-20
*/
public interface ITicketSystemService {
/**
* 获取accessToken
*
* @return
*/
String getAccessToken();
/**
* 查询标准演出类型
*
* @param accessToken 访问令牌
* @return
*/
List<STPTListVo> getPerformanceTypeList(String accessToken);
/**
* 查询标准演出场所
*
* @param accessToken 访问令牌
* @return
*/
List<STFieldListVo> getFieldList(String accessToken, STFieldListParam fieldListParam);
/**
* 新增演出场厅
*
* @param accessToken 访问令牌
*/
STFieldChangeVo insertField(String accessToken, STInsertFieldParam insertFieldParam);
/**
* 上报演出场次接口
*
* @param accessToken 访问令牌
* @return {
* "sessionId1":"sessionCode1",
* "sessionId2":"sessionCode2"
* }
*/
String insertPerformance(String accessToken, STInsertPerformanceParam insertPerformanceParam);
/**
* 更新上报的演出项目数据
*
* @param accessToken 访问令牌
*/
boolean updatePerformance(String accessToken, STUpdatePerformanceParam updatePerformanceParam);
/**
* 更新上报的场次数据
*
* @param accessToken 访问令牌
* @return
*/
boolean updateTimes(String accessToken, STUpdateTimesParam updateTimesParam);
/**
* 上报票价信息
*
* @param accessToken 访问令牌
* @return
*/
boolean insertTicketPrice(String accessToken,STInsertTicketPriceParam insertTicketPriceParam );
/**
* 删除票价信息
*
* @param accessToken 访问令牌
* @return
*/
boolean delTicketPrice(String accessToken, STDelTicketPriceParam delTicketPriceParam);
/**
* 上报票信息
*
* @param accessToken 访问令牌
* @return
*/
boolean insertTicket(String accessToken, STInsertTicketParam insertTicketParam);
/**
* 删除票信息
*
* @param accessToken 访问令牌
* @return
*/
boolean delTicket(String accessToken,STDelTicketParam delTicketParam);
/**
* 上报订单信息
*
* @param accessToken 访问令牌
* @return
*/
boolean insertOrder(String accessToken, STInsertOrderParam insertOrderParam);
/**
* 上报退票信息
*
* @param accessToken 访问令牌
* @return
*/
boolean refundOrder(String accessToken, STRefundOrderParam refundOrderParam);
/**
* 上报检票数据
*
* @param accessToken 访问令牌
* @param ticketList 票信息List
* @return
*/
boolean insertCheck(String accessToken, List<CheckVo> ticketList);
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.apache.tomcat.jni.Local;
import java.io.Serializable;
import java.time.LocalDateTime;
@Data
@ApiModel
public class CheckVo implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "票ID [必传]")
private String ticketId;
@ApiModelProperty(value = "票价ID [必传]")
private String priceId;
@ApiModelProperty(value = "场次id [必传]")
private String sessionId;
@ApiModelProperty(value = "场次编码 [必传]")
private String sessionCode;
@ApiModelProperty(value = "检票时间 [必传]")
private LocalDateTime checkingTime;
@ApiModelProperty(value = "检票类型[必传 1 二维码电子票,2 身份证,3 纸质票]")
private Integer checkingType;
@ApiModelProperty(value = "是否实名[必传 1 实名,2 非实名]")
private Integer authType;
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
@Data
@ApiModel
public class HallListVo implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "场厅名称")
private String hallName;
@ApiModelProperty(value = "场厅编码[上报数据使用]")
private String hallCode;
@ApiModelProperty(value = "是否有座[是否有座,0:无座1:有座]")
private Integer hasSeat;
@ApiModelProperty(value = "场厅座位数量[有座时不为空]")
private Integer seatNum;
@ApiModelProperty(value = "可容纳人数[无座时不为空]")
private Integer seatingCapacity;
@ApiModelProperty(value = "经营状态[经营状态,1:经营中,2:装修中,3:已停运]")
private Integer managementStatus;
@ApiModelProperty(value = "可用状态[0:禁用,1:启用]")
private Integer enableState;
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
@Data
@ApiModel
public class ListVo<T> implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "数据")
private T dataList;
@ApiModelProperty(value = "页数")
private Integer page;
@ApiModelProperty(value = "每页数量")
private Integer pageSize;
@ApiModelProperty(value = "数据总量")
private Integer totalRow;
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
@Data
@ApiModel
public class OrderVo implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "票单id [必传]")
private String ticketOrderId;
@ApiModelProperty(value = "演出id [必传]")
private String performanceId;
@ApiModelProperty(value = "场次id [必传]")
private String sessionId;
@ApiModelProperty(value = "场次编码 [必传]")
private String sessionCode;
@ApiModelProperty(value = "票价id [必传]")
private String priceId;
@ApiModelProperty(value = "票价[必传 单位分]")
private long ticketPrice;
@ApiModelProperty(value = "票ID [必传]")
private String ticketId;
@ApiModelProperty(value = "票实收金额[必传 单位分]")
private long ticketOrderAmount;
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
@Data
@ApiModel
public class RefundOrderVo implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "票单id [必传]")
private String ticketOrderId;
@ApiModelProperty(value = "场次编码 [有座必传]")
private String sessionCode;
@ApiModelProperty(value = "票ID [有座必传]")
private String ticketId;
@ApiModelProperty(value = "退票金额[必传 单位分]")
private String refundAmount;
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
@Data
@ApiModel
public class ResponseDataVo<T> implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "状态码")
private String code;
@ApiModelProperty(value = "返回数据内容")
private T data;
@ApiModelProperty(value = "消息")
private String msg;
@ApiModelProperty(value = "接口是否成功")
private boolean success;
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
@Data
@ApiModel
public class ResponseListVo<T> implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "状态码")
private String code;
@ApiModelProperty(value = "返回数据内容")
private ListVo<T> data;
@ApiModelProperty(value = "消息")
private String msg;
@ApiModelProperty(value = "接口是否成功")
private boolean success;
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
@Data
@ApiModel
public class STAccessTokenVo implements Serializable, Cloneable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "获取到的访问令牌")
private String accessToken;
@ApiModelProperty(value = "令牌有效时间[失效时间为3600秒]")
private Integer expiresIn;
private static final STAccessTokenVo obj = new STAccessTokenVo();
public static STAccessTokenVo getNew() {
try {
return (STAccessTokenVo) obj.clone();
} catch (CloneNotSupportedException e) {
e.printStackTrace();
}
return new STAccessTokenVo();
}
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
@Data
@ApiModel
public class STFieldChangeVo implements Serializable, Cloneable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "场所编码")
private String venueCode;
@ApiModelProperty(value = "演出场厅编码")
private String hallCode;
private static final STFieldChangeVo obj = new STFieldChangeVo();
public static STFieldChangeVo getNew() {
try {
return (STFieldChangeVo) obj.clone();
} catch (CloneNotSupportedException e) {
e.printStackTrace();
}
return new STFieldChangeVo();
}
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
@Data
@ApiModel
public class STFieldListVo implements Serializable, Cloneable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "场所编码")
private String venueCode;
@ApiModelProperty(value = "场所名称")
private String venueName;
@ApiModelProperty(value = "场厅数量")
private Integer hallNum;
@ApiModelProperty(value = "省")
private Integer provinceId;
@ApiModelProperty(value = "市")
private Integer cityId;
@ApiModelProperty(value = "区")
private Integer districtId;
@ApiModelProperty(value = "详细地址")
private String venueAddress;
@ApiModelProperty(value = "场所类型")
private String venueType;
@ApiModelProperty(value = "场厅信息List")
private List<HallListVo> hallList;
private static final STFieldListVo obj = new STFieldListVo();
public static STFieldListVo getNew() {
try {
return (STFieldListVo) obj.clone();
} catch (CloneNotSupportedException e) {
e.printStackTrace();
}
return new STFieldListVo();
}
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.util.List;
@Data
@ApiModel
public class STPTListVo implements Serializable, Cloneable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "演出类型id")
private Integer typeId;
@ApiModelProperty(value = "演出类型名称]")
private String typeName;
@ApiModelProperty(value = "演出类型父id[10,一级类型父id为空]")
private Integer parentTypeId;
@ApiModelProperty(value = "层级[1:一级类型,2:二级类型]")
private Integer level;
@ApiModelProperty(value = "备注")
private Integer remark;
private List<STPTListVo> children;
private static final STPTListVo obj = new STPTListVo();
public static STPTListVo getNew() {
try {
return (STPTListVo) obj.clone();
} catch (CloneNotSupportedException e) {
e.printStackTrace();
}
return new STPTListVo();
}
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
@Data
@ApiModel
public class TicketPriceVo implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "演出场次ID [必传]")
private String performanceId;
@ApiModelProperty(value = "场次名称 [必传]")
private String sessionId;
@ApiModelProperty(value = "票价ID [必传]")
private String priceId;
@ApiModelProperty(value = "票价名称 [必传]")
private String priceName;
@ApiModelProperty(value = "票价,单位分 [必传]")
private long ticketPrice;
@ApiModelProperty(value = "可售库存 [必传]")
private Integer availableInventory;
@ApiModelProperty(value = "不可售库存 [必传]")
private Integer unavailableInventory;
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
@Data
@ApiModel
public class TicketVo implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "票ID [必传]")
private String ticketId;
@ApiModelProperty(value = "是否可售[必传 1:可售,2:不可售]")
private Integer availableSale;
@ApiModelProperty(value = "楼层 [有座必传]")
private String floorName;
@ApiModelProperty(value = "区域名称 [有座必传]")
private String areaName;
@ApiModelProperty(value = "排 [有座必传]")
private String rowName;
@ApiModelProperty(value = "座位号 [有座必传]")
private String seatNo;
}
package com.liquidnet.service.platform.vo.ticketSystem;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
@Data
@ApiModel
public class TimesVo implements Serializable {
private static final long serialVersionUID = 4073256621782131607L;
@ApiModelProperty(value = "演出场次ID [必传]")
private String sessionId;
@ApiModelProperty(value = "场次名称 [必传]")
private String sessionName;
@ApiModelProperty(value = "演出场所或场厅编码,兼容传递场所code [必传]")
private String hallCode;
@ApiModelProperty(value = "场次开始时间 [必传]")
private LocalDateTime sessionStartTime;
@ApiModelProperty(value = "场次演出结束时间 [必传]")
private LocalDateTime sessionEndTime;
@ApiModelProperty(value = "是否有座[必传 0:无座1:有座]")
private Integer hasSeat;
@ApiModelProperty(value = "票图URL [有座必传]")
private String seatingChart;
@ApiModelProperty(value = "标记[非必传 0:禁用,1:启用]")
private Integer tag;
}
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