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

Commit 2f318375 authored by anjiabin's avatar anjiabin

提交chime社交相关

parent 97f65d49
package com.liquidnet.service.chime.dto;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import java.io.Serializable;
@ApiModel(value = "ChimeTagVo", description = "标签库")
public class ChimeTagVo implements Serializable, Cloneable {
private static final long serialVersionUID = 5852327873275898342L;
@ApiModelProperty(position = 11, value = "标签Key")
private String val;
@ApiModelProperty(position = 12, value = "标签名称")
private String desc;
private static final ChimeTagVo obj = new ChimeTagVo();
public static ChimeTagVo getNew() {
try {
return (ChimeTagVo) obj.clone();
} catch (CloneNotSupportedException e) {
e.printStackTrace();
}
return new ChimeTagVo();
}
public String getVal() {
return val;
}
public ChimeTagVo setVal(String val) {
this.val = val;
return this;
}
public String getDesc() {
return desc;
}
public ChimeTagVo setDesc(String desc) {
this.desc = desc;
return this;
}
}
package com.liquidnet.service.chime.dto;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.List;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ChimeUserInfoDto
* @Package com.liquidnet.service.chime.dto
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/8 15:17
*/
@Data
public class ChimeUserInfoDto {
private static final long serialVersionUID = 5325511589667456213L;
@ApiModelProperty(position = 0, value = "用户ID[64]")
private String userId;
@ApiModelProperty(position = 1, value = "性别")
private String sex;
@ApiModelProperty(position = 2, value = "用户昵称")
private String userName;
@ApiModelProperty(position = 3, value = "用户手机号")
private String userMobile;
@ApiModelProperty(position = 4, value = "头像")
private String avatar;
@ApiModelProperty(position = 4, value = "封面")
private String userCover;
@ApiModelProperty(position = 5, value = "在场ID")
private String joinPerformanceId;
@ApiModelProperty(position = 5, value = "用户标签")
private List<ChimeTagVo> userTags;
}
package com.liquidnet.service.chime.dto;
import com.liquidnet.commons.lang.util.JsonUtils;
import lombok.Data;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ChimeUserRegisterReqDto
* @Package com.liquidnet.service.chime.dto
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/8 16:11
*/
@Data
public class ChimeUserRegisterReqDto {
private String userId;
private String nickName;
private String sex;
private String tags;
@Override
public String toString(){
return JsonUtils.toJson(this);
}
private static final ChimeUserRegisterReqDto obj = new ChimeUserRegisterReqDto();
public static ChimeUserRegisterReqDto getNew() {
try {
return (ChimeUserRegisterReqDto) obj.clone();
} catch (CloneNotSupportedException e) {
return new ChimeUserRegisterReqDto();
}
}
}
package com.liquidnet.service.chime.dto;
import com.liquidnet.commons.lang.util.JsonUtils;
import lombok.Data;
import java.time.LocalDateTime;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ChimeUserRegisterRespDto
* @Package com.liquidnet.service.chime.dto
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/8 16:11
*/
@Data
public class ChimeUserRegisterRespDto {
private String uuid;
private String type;
private LocalDateTime created; //1630929604985
private LocalDateTime modified;
private String username;
private Boolean activated;
private String nickname;
@Override
public String toString(){
return JsonUtils.toJson(this);
}
private static final ChimeUserRegisterRespDto obj = new ChimeUserRegisterRespDto();
public static ChimeUserRegisterRespDto getNew() {
try {
return (ChimeUserRegisterRespDto) obj.clone();
} catch (CloneNotSupportedException e) {
return new ChimeUserRegisterRespDto();
}
}
}
package com.liquidnet.service.chime.dto; package com.liquidnet.service.chime.dto;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/** /**
* @author AnJiabin <anjiabin@zhengzai.tv> * @author AnJiabin <anjiabin@zhengzai.tv>
...@@ -11,11 +12,20 @@ import io.swagger.annotations.ApiModelProperty; ...@@ -11,11 +12,20 @@ import io.swagger.annotations.ApiModelProperty;
* @Copyright: LightNet @ Copyright (c) 2021 * @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/3 18:26 * @date 2021/9/3 18:26
*/ */
@Data
public class PerformanceDto { public class PerformanceDto {
@ApiModelProperty(value = "演出id")
private String performancesId; private String performancesId;
@ApiModelProperty(value = "演出名称")
private String title; private String title;
@ApiModelProperty(value = "演出海报")
private String img_poster;
@ApiModelProperty(value = "演出开始时间") @ApiModelProperty(value = "演出开始时间")
private String timeStart; private String timeStart;
@ApiModelProperty(value = "演出结束时间") @ApiModelProperty(value = "演出结束时间")
private String timeEnd; private String timeEnd;
@ApiModelProperty(value = "演出地点")
private String cityName;
@ApiModelProperty(value = "在场人数")
private Integer joinUserCount;
} }
package com.liquidnet.service.chime.service;
import com.liquidnet.service.chime.dto.ChimeUserRegisterReqDto;
import com.liquidnet.service.chime.dto.ChimeUserRegisterRespDto;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: IChimeUserService
* @Package com.liquidnet.service.chime.service
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/8 16:14
*/
public interface IChimeUserService {
/**
* 社交用户注册
* @param reqDto
* @return
*/
ChimeUserRegisterRespDto register(ChimeUserRegisterReqDto reqDto);
}
package com.liquidnet.service.chime.vo.mongo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ChimeUserTagsMappingVo
* @Package com.liquidnet.service.chime.vo.mongo
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/3 16:50
*/
@ApiModel(value = "ChimeUserInfoVo", description = "社交用户信息")
@Data
public class ChimeUserInfoVo {
private Integer mid;
private static final long serialVersionUID = 5325511589667456213L;
@ApiModelProperty(position = 0, value = "用户ID[64]")
private String userId;
@ApiModelProperty(position = 1, value = "性别")
private String sex;
@ApiModelProperty(position = 2, value = "用户昵称")
private String userName;
@ApiModelProperty(position = 3, value = "用户手机号")
private String userMobile;
@ApiModelProperty(position = 4, value = "头像")
private String avatar;
@ApiModelProperty(position = 5, value = "在场ID")
private String joinPerformanceId;
private static final ChimeUserInfoVo obj = new ChimeUserInfoVo();
public static ChimeUserInfoVo getNew() {
try {
return (ChimeUserInfoVo) obj.clone();
} catch (CloneNotSupportedException e) {
return new ChimeUserInfoVo();
}
}
}
package com.liquidnet.service.chime.vo.mongo; package com.liquidnet.service.chime.vo.mongo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/** /**
* @author AnJiabin <anjiabin@zhengzai.tv> * @author AnJiabin <anjiabin@zhengzai.tv>
...@@ -11,21 +13,15 @@ import io.swagger.annotations.ApiModelProperty; ...@@ -11,21 +13,15 @@ import io.swagger.annotations.ApiModelProperty;
* @Copyright: LightNet @ Copyright (c) 2021 * @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/3 16:50 * @date 2021/9/3 16:50
*/ */
@ApiModel(value = "ChimeUserTagsMappingVo", description = "社交用户标签映射表")
@Data
public class ChimeUserTagsMappingVo { public class ChimeUserTagsMappingVo {
private Integer mid; private Integer mid;
private static final long serialVersionUID = 5325511589667456213L; private static final long serialVersionUID = 5325511589667456214L;
@ApiModelProperty(position = 0, value = "用户ID[64]") @ApiModelProperty(position = 0, value = "用户ID[64]")
private String userId; private String userId;
@ApiModelProperty(position = 1, value = "性别") @ApiModelProperty(position = 1, value = "标签")
private String sex; private String tag;
@ApiModelProperty(position = 2, value = "用户昵称")
private String userName;
@ApiModelProperty(position = 3, value = "用户手机号")
private String userMobile;
@ApiModelProperty(position = 4, value = "头像")
private String avatar;
@ApiModelProperty(position = 5, value = "在场ID")
private String joinPerformanceId;
private static final ChimeUserTagsMappingVo obj = new ChimeUserTagsMappingVo(); private static final ChimeUserTagsMappingVo obj = new ChimeUserTagsMappingVo();
public static ChimeUserTagsMappingVo getNew() { public static ChimeUserTagsMappingVo getNew() {
......
...@@ -14,6 +14,7 @@ public class EasemobConstant { ...@@ -14,6 +14,7 @@ public class EasemobConstant {
public static String GET_TOKEN_URL = "/token"; public static String GET_TOKEN_URL = "/token";
//api访问过期时间 //api访问过期时间
public static String API_ACCESS_TOKEN_REDIS_KEY = "chime:easemob:API_ACCESS_KEY"; public static String API_ACCESS_TOKEN_REDIS_KEY = "chime:easemob:API_ACCESS_KEY";
//单位 秒 默认30天
public static long API_ACCESS_TOKEN_EXPIRES_TIME_SECOND = 2592000; public static long API_ACCESS_TOKEN_EXPIRES_TIME_SECOND = 2592000;
//注册单个用户 //注册单个用户
public static String CREATE_USER_URL = "/users"; public static String CREATE_USER_URL = "/users";
......
...@@ -108,7 +108,6 @@ public class EasemobUtil{ ...@@ -108,7 +108,6 @@ public class EasemobUtil{
log.info("createUsers--->>> response : {} ",response); log.info("createUsers--->>> response : {} ",response);
ObjectNode jsonObject = JsonUtils.fromJson(response,ObjectNode.class); ObjectNode jsonObject = JsonUtils.fromJson(response,ObjectNode.class);
log.info("createUsers--->>> response : {} ",jsonObject.toString());
ArrayNode arrayNode = (ArrayNode)jsonObject.get("entities"); ArrayNode arrayNode = (ArrayNode)jsonObject.get("entities");
response = arrayNode.get(0).toString(); response = arrayNode.get(0).toString();
return response; return response;
......
use prod_ln_scene;
#创建集合
db.createCollection("KylinCheckUserVo");
db.createCollection("ChimeUserTagsMappingVo");
#创建索引
db.KylinCheckUserPerformanceVo.createIndex({checkUserId:"hashed"});
db.KylinCheckUserVo.createIndex({merchantId:"hashed"});
db.KylinCheckUserVo.createIndex({mobile:"hashed"});
db.KylinOrderRefundEntitiesVo.createIndex({orderRefundsId:"hashed"});
db.KylinOrderRefundEntitiesVo.createIndex({orderTicketEntitiesId:"hashed"});
db.KylinOrderRefundPicVo.createIndex({orderRefundsId:"hashed"});
db.KylinOrderRefundsVo.createIndex({orderRefundsId:"hashed"});
db.KylinOrderRefundsVo.createIndex({orderTicketsId:"hashed"});
db.KylinOrderTicketEntitiesVo.createIndex({orderTicketEntitiesId:"hashed"});
db.KylinOrderTicketEntitiesVo.createIndex({orderId:"hashed"});
db.KylinOrderTicketVo.createIndex({orderTicketsId:"hashed"});
db.KylinOrderTicketVo.createIndex({orderCode:"hashed"});
db.KylinOrderTicketVo.createIndex({userId:"hashed"});
db.KylinPerformanceVo.createIndex({performancesId:"hashed"});
db.KylinPerformanceMisVo.createIndex({performancesId:"hashed"});
db.KylinTicketPartnerVo.createIndex({ticketsId:"hashed"});
db.KylinTicketPartnerVo.createIndex({timesId:"hashed"});
db.KylinTicketTimesPartnerVo.createIndex({performancesId:"hashed"});
db.KylinTicketTimesPartnerVo.createIndex({ticketTimesId:"hashed"});
db.PerformanceMemberAuditParam.createIndex({performancesId:"hashed"});
db.AdminUpushVo.createIndex({upushId:"hashed"});
#创建分片
sh.enableSharding("prod_ln_scene");
sh.shardCollection("prod_ln_scene.KylinCheckUserPerformanceVo",{"checkUserId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinCheckUserVo",{"checkUserId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinOrderRefundEntitiesVo",{"orderRefundsEntitiesId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinOrderRefundPicVo",{"refundPicId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinOrderRefundsVo",{"orderRefundsId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinOrderTicketEntitiesVo",{"orderTicketEntitiesId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinOrderTicketVo",{"orderTicketsId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinPerformanceVo",{"performancesId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinRoadShowVo",{"roadShowsId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinPerformanceMisVo",{"performancesId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinTicketPartnerVo",{"ticketsId":"hashed"});
sh.shardCollection("prod_ln_scene.KylinTicketTimesPartnerVo",{"ticketTimesId":"hashed"});
sh.shardCollection("prod_ln_scene.PerformanceMemberAuditParam",{"performancesId":"hashed"});
sh.shardCollection("prod_ln_scene.AdminUpushVo",{"upushId":"hashed"});
...@@ -28,28 +28,40 @@ ...@@ -28,28 +28,40 @@
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<artifactId>liquidnet-service-kylin-api</artifactId> <artifactId>liquidnet-service-chime-api</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<artifactId>liquidnet-service-adam-api</artifactId> <artifactId>liquidnet-common-third-easemob</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<artifactId>liquidnet-service-chime-api</artifactId> <artifactId>liquidnet-common-third-shumei</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
<!-- 调用其他服务-->
<dependency> <dependency>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<artifactId>liquidnet-common-third-easemob</artifactId> <artifactId>liquidnet-api-feign-adam</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<artifactId>liquidnet-common-third-shumei</artifactId> <artifactId>liquidnet-api-feign-kylin</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-api-feign-dragon</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-api-feign-platform</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
<scope>compile</scope>
</dependency> </dependency>
</dependencies> </dependencies>
......
package com.liquidnet.service.chime.controller; package com.liquidnet.service.chime.controller;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.chime.dto.ChimeUserInfoDto;
import com.liquidnet.service.chime.dto.PerformanceDto;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiImplicitParams;
...@@ -11,8 +13,6 @@ import org.springframework.web.bind.annotation.RequestMapping; ...@@ -11,8 +13,6 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
/** /**
* @author AnJiabin <anjiabin@zhengzai.tv> * @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0 * @version V1.0
...@@ -22,35 +22,24 @@ import java.util.HashMap; ...@@ -22,35 +22,24 @@ import java.util.HashMap;
* @Copyright: LightNet @ Copyright (c) 2021 * @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/6 11:43 * @date 2021/9/6 11:43
*/ */
@Api(tags = "在场-演出列表") @Api(tags = "在场-演出相关")
@RestController @RestController
@RequestMapping("performance") @RequestMapping("performance")
@Validated @Validated
public class ChimePerformanceController { public class ChimePerformanceController {
@GetMapping("myList") @GetMapping("myPerformanceList")
@ApiOperation("已购票的演出") @ApiOperation("已购票的演出")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "cityName", value = "城市名称", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "userId", value = "用户id", required = true),
@ApiImplicitParam(type = "query", dataType = "int", name = "days", value = "时间范围 几天 今天1 三天3。。。"), @ApiImplicitParam(type = "query", dataType = "int", name = "page", value = "页码",required = true),
@ApiImplicitParam(type = "query", dataType = "int", name = "type", value = "演出类型 101音乐节 102小型演出(livehouse演出) 103巡演 演出类型只有这几个了"), @ApiImplicitParam(type = "query", dataType = "int", name = "size", value = "每页数量"),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "isDiscount", value = "是否会员优惠 0 1"),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "isAdvance", value = "是否优先 0 1"),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "isExclusive", value = "是否会员专属 0 1"),
@ApiImplicitParam(type = "query", dataType = "String", name = "orderBy", value = "排序字段 时间timeStart"), @ApiImplicitParam(type = "query", dataType = "String", name = "orderBy", value = "排序字段 时间timeStart"),
@ApiImplicitParam(type = "query", dataType = "String", name = "sort", value = "排序方式[DESC ASC]"), @ApiImplicitParam(type = "query", dataType = "String", name = "sort", value = "排序方式[DESC ASC]"),
}) })
public ResponseDto<HashMap<String, Object>> myList( public ResponseDto<PerformanceDto> myPerformanceList(
@RequestParam(defaultValue = "") String cityName, @RequestParam(defaultValue = "") String userId,
@RequestParam(defaultValue = "0") int days, @RequestParam(defaultValue = "1") int page,
@RequestParam(defaultValue = "0") int type, @RequestParam(defaultValue = "10") int size,
@RequestParam(defaultValue = "") Integer isDiscount,
@RequestParam(defaultValue = "") Integer isAdvance,
@RequestParam(defaultValue = "") Integer isExclusive,
// 排序
@RequestParam(defaultValue = "") String orderBy, @RequestParam(defaultValue = "") String orderBy,
@RequestParam(defaultValue = "") String sort @RequestParam(defaultValue = "") String sort
) { ) {
...@@ -63,30 +52,20 @@ public class ChimePerformanceController { ...@@ -63,30 +52,20 @@ public class ChimePerformanceController {
return null; return null;
} }
@GetMapping("localList") @GetMapping("localPerformanceList")
@ApiOperation("本地最近演出列表") @ApiOperation("本地最近演出列表")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "cityName", value = "城市名称", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "cityName", value = "城市名称", required = true),
@ApiImplicitParam(type = "query", dataType = "int", name = "days", value = "时间范围 几天 今天1 三天3。。。"), @ApiImplicitParam(type = "query", dataType = "int", name = "page", value = "页码",required = true),
@ApiImplicitParam(type = "query", dataType = "int", name = "type", value = "演出类型 101音乐节 102小型演出(livehouse演出) 103巡演 演出类型只有这几个了"), @ApiImplicitParam(type = "query", dataType = "int", name = "size", value = "每页数量"),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "isDiscount", value = "是否会员优惠 0 1"),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "isAdvance", value = "是否优先 0 1"),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "isExclusive", value = "是否会员专属 0 1"),
@ApiImplicitParam(type = "query", dataType = "String", name = "orderBy", value = "排序字段 时间timeStart"), @ApiImplicitParam(type = "query", dataType = "String", name = "orderBy", value = "排序字段 时间timeStart"),
@ApiImplicitParam(type = "query", dataType = "String", name = "sort", value = "排序方式[DESC ASC]"), @ApiImplicitParam(type = "query", dataType = "String", name = "sort", value = "排序方式[DESC ASC]"),
}) })
public ResponseDto<HashMap<String, Object>> localList( public ResponseDto<PerformanceDto> localPerformanceList(
@RequestParam(defaultValue = "") String cityName, @RequestParam(defaultValue = "") String cityName,
@RequestParam(defaultValue = "0") int days, @RequestParam(defaultValue = "") String userId,
@RequestParam(defaultValue = "0") int type, @RequestParam(defaultValue = "1") int page,
@RequestParam(defaultValue = "10") int size,
@RequestParam(defaultValue = "") Integer isDiscount,
@RequestParam(defaultValue = "") Integer isAdvance,
@RequestParam(defaultValue = "") Integer isExclusive,
// 排序
@RequestParam(defaultValue = "") String orderBy, @RequestParam(defaultValue = "") String orderBy,
@RequestParam(defaultValue = "") String sort @RequestParam(defaultValue = "") String sort
) { ) {
...@@ -103,26 +82,17 @@ public class ChimePerformanceController { ...@@ -103,26 +82,17 @@ public class ChimePerformanceController {
@ApiOperation("查询用户列表") @ApiOperation("查询用户列表")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "cityName", value = "城市名称", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "cityName", value = "城市名称", required = true),
@ApiImplicitParam(type = "query", dataType = "int", name = "days", value = "时间范围 几天 今天1 三天3。。。"), @ApiImplicitParam(type = "query", dataType = "String", name = "sex", value = "性别", required = true),
@ApiImplicitParam(type = "query", dataType = "int", name = "type", value = "演出类型 101音乐节 102小型演出(livehouse演出) 103巡演 演出类型只有这几个了"), @ApiImplicitParam(type = "query", dataType = "int", name = "page", value = "页码",required = true),
@ApiImplicitParam(type = "query", dataType = "int", name = "size", value = "每页数量"),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "isDiscount", value = "是否会员优惠 0 1"),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "isAdvance", value = "是否优先 0 1"),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "isExclusive", value = "是否会员专属 0 1"),
@ApiImplicitParam(type = "query", dataType = "String", name = "orderBy", value = "排序字段 时间timeStart"), @ApiImplicitParam(type = "query", dataType = "String", name = "orderBy", value = "排序字段 时间timeStart"),
@ApiImplicitParam(type = "query", dataType = "String", name = "sort", value = "排序方式[DESC ASC]"), @ApiImplicitParam(type = "query", dataType = "String", name = "sort", value = "排序方式[DESC ASC]"),
}) })
public ResponseDto<HashMap<String, Object>> getUserListByCon( public ResponseDto<ChimeUserInfoDto> getUserListByCon(
@RequestParam(defaultValue = "") String cityName, @RequestParam(defaultValue = "") String cityName,
@RequestParam(defaultValue = "0") int days, @RequestParam(defaultValue = "") String userId,
@RequestParam(defaultValue = "0") int type, @RequestParam(defaultValue = "1") int page,
@RequestParam(defaultValue = "10") int size,
@RequestParam(defaultValue = "") Integer isDiscount,
@RequestParam(defaultValue = "") Integer isAdvance,
@RequestParam(defaultValue = "") Integer isExclusive,
// 排序
@RequestParam(defaultValue = "") String orderBy, @RequestParam(defaultValue = "") String orderBy,
@RequestParam(defaultValue = "") String sort @RequestParam(defaultValue = "") String sort
) { ) {
......
package com.liquidnet.service.chime.controller;
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.chime.dto.ChimeUserRegisterReqDto;
import com.liquidnet.service.chime.dto.ChimeUserRegisterRespDto;
import com.liquidnet.service.chime.service.IChimeUserService;
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 org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: 社交用户控制类
* @class: ChimeUserController
* @Package com.liquidnet.service.chime.controller
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/8 15:43
*/
@Api(tags = "在场-用户相关")
@RestController
@RequestMapping("user")
@Validated
@Slf4j
public class ChimeUserController {
@Autowired
private IChimeUserService chimeUserService;
@ApiOperationSupport(order = 5)
@ApiOperation(value = "社交用户注册")
@ApiImplicitParams({
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "userId", value = "用户id"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "nickname", value = "昵称"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "sex", value = "性别"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "tags", value = "兴趣标签(多个用逗号隔开)")
})
@PostMapping(value = {"register"})
public ResponseDto<ChimeUserRegisterRespDto> register(@RequestParam @Validated String userId
, @RequestParam @Validated String nickname
, @RequestParam @Validated String sex
, @RequestParam @Validated String tags
) {
ChimeUserRegisterReqDto reqDto = ChimeUserRegisterReqDto.getNew();
reqDto.setUserId(userId);
reqDto.setNickName(nickname);
reqDto.setSex(sex);
reqDto.setTags(tags);
//获取等前登陆用户 CurrentUtil.getCurrentUid()
ChimeUserRegisterRespDto vo = chimeUserService.register(reqDto);
return ResponseDto.success(vo);
}
}
package com.liquidnet.service.order.controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* <p>
* 订单详情 前端控制器
* </p>
*
* @author liquidnet
* @since 2021-05-20
*/
@RestController
@RequestMapping("orderEnter")
public class KylinOrderTicketEntitiesController {
}
//package com.liquidnet.service.order.controller;
//
//
//import com.liquidnet.service.base.ErrorMapping;
//import com.liquidnet.service.base.ResponseDto;
//import com.liquidnet.service.base.codec.annotation.DecryptAndVerify;
//import com.liquidnet.service.base.codec.vo.EncryptedReq;
//import com.liquidnet.service.kylin.dto.param.PayAgainParam;
//import com.liquidnet.service.kylin.dto.param.PayOrderParam;
//import com.liquidnet.service.kylin.dto.param.SyncOrderParam;
//import com.liquidnet.service.kylin.dto.vo.returns.*;
//import com.liquidnet.service.kylin.service.IKylinOrderTicketsOrderService;
//import com.liquidnet.service.order.utils.ObjectUtil;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//import io.swagger.annotations.ApiResponse;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.validation.annotation.Validated;
//import org.springframework.web.bind.annotation.*;
//
//import javax.validation.Valid;
//import javax.validation.constraints.NotNull;
//import java.util.HashMap;
//
///**
// * <p>
// * 订单 前端控制器
// * </p>
// *
// * @author liquidnet
// * @since 2021-05-20
// */
//@Api(tags = "前端-订单相关")
//@RestController
//@RequestMapping("order")
//@Validated
//public class KylinOrderTicketsController {
//
// @Autowired
// IKylinOrderTicketsOrderService orderTicketsOrderService;
//
// @PostMapping("fc7bce6d6c2213b866f76493f92224b7")
// @ApiOperation("fc7bce6d6c2213b866f76493f92224b7")
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PayInnerResultVo> checkCanOrder(@RequestBody @Valid PayOrderParam payOrderParam) {
// return orderTicketsOrderService.checkCanOrder(payOrderParam);
// }
//
// @DecryptAndVerify(decryptedClass = PayOrderParam.class)
// @PostMapping("pre")
// @ApiOperation("下单")
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PayInnerResultVo> checkCanOrder(@RequestBody @Valid EncryptedReq<PayOrderParam> encryptedReq) {
// PayOrderParam payOrderParam = encryptedReq.getData();
// return orderTicketsOrderService.checkCanOrder(payOrderParam);
// }
//
// @PostMapping("payAgain")
// @ApiOperation("再次支付")
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<PayInnerResultVo> payAgain(@RequestBody @Valid PayAgainParam payAgainParam) {
// PayInnerResultVo vo = orderTicketsOrderService.payAgain(payAgainParam).getData();
// if (null == vo) {
// return ResponseDto.failure(ErrorMapping.get("20024"));
// } else {
// return ResponseDto.success(vo);
// }
// }
//
// @PostMapping("syncOrder")
// @ApiOperation("支付回调")
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public String syncOrder(@ModelAttribute @Valid SyncOrderParam syncOrderParam) {
// return orderTicketsOrderService.syncOrder(syncOrderParam);
// }
//
// @GetMapping("checkPayment")
// @ApiOperation("订单状态")
// @ApiResponse(code = 200, message = "接口返回对象参数")
// public ResponseDto<HashMap> checkOrderResult(@RequestParam("orderId") @NotNull(message = "订单ID不能为空") String orderId) {
// Integer status = orderTicketsOrderService.checkOrderResult(orderId).getData();
// if (null == status) {
// return ResponseDto.failure(ErrorMapping.get("20003"));
// } else {
// HashMap<String, Integer> map = ObjectUtil.cloneHashMapStringAndInteger();
// map.put("status", status);
// return ResponseDto.success(map);
// }
// }
//}
package com.liquidnet.service.chime.service.impl;
import com.liquidnet.common.third.easemob.util.EasemobUtil;
import com.liquidnet.service.chime.dto.ChimeUserRegisterReqDto;
import com.liquidnet.service.chime.dto.ChimeUserRegisterRespDto;
import com.liquidnet.service.chime.service.IChimeUserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ChimeUserServiceImpl
* @Package com.liquidnet.service.chime.service.impl
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2021/9/8 16:17
*/
@Slf4j
@Service
public class ChimeUserServiceImpl implements IChimeUserService {
@Autowired
private EasemobUtil easemobUtil;
@Override
public ChimeUserRegisterRespDto register(ChimeUserRegisterReqDto reqDto) {
String result = easemobUtil.createUser(reqDto.getUserId(),"123456",reqDto.getNickName());
log.info("chime easemobUtil.createUser res");
ChimeUserRegisterRespDto respDto = ChimeUserRegisterRespDto.getNew();
return respDto;
}
}
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