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

Commit 8b4f85bb authored by 胡佳晨's avatar 胡佳晨

Merge branch 'dev_sweet01' into dev_goblin

# Conflicts:
#	liquidnet-bus-service/liquidnet-service-sweet/pom.xml
parents 1b42b4d0 dd95495b
...@@ -93,4 +93,6 @@ public class SweetConstant { ...@@ -93,4 +93,6 @@ public class SweetConstant {
public final static String REDIS_KEY_QRCODE_READ_NUM = QRCODE.concat("readNum:"); //读取次数 :type:mid public final static String REDIS_KEY_QRCODE_READ_NUM = QRCODE.concat("readNum:"); //读取次数 :type:mid
public final static String REDIS_KEY_QRCODE_LIST = QRCODE.concat("list:"); //二维码实体类 :type public final static String REDIS_KEY_QRCODE_LIST = QRCODE.concat("list:"); //二维码实体类 :type
//AR
public final static String REDIS_KEY_SWEET_PERFORMANCE_AR = "sweet:performance:ar";
} }
...@@ -4,6 +4,12 @@ import com.baomidou.mybatisplus.extension.service.IService; ...@@ -4,6 +4,12 @@ import com.baomidou.mybatisplus.extension.service.IService;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.sweet.entity.SweetArtists; import com.liquidnet.service.sweet.entity.SweetArtists;
import com.liquidnet.service.sweet.entity.SweetArtistsList;
import com.liquidnet.service.sweet.entity.SweetArtistsUrl;
import com.liquidnet.service.sweet.param.SweetArtistsListParam;
import com.liquidnet.service.sweet.vo.SweetArtistsVo;
import java.util.List;
/** /**
* <p> * <p>
...@@ -15,12 +21,14 @@ import com.liquidnet.service.sweet.entity.SweetArtists; ...@@ -15,12 +21,14 @@ import com.liquidnet.service.sweet.entity.SweetArtists;
*/ */
public interface ISweetArtistsService extends IService<SweetArtists> { public interface ISweetArtistsService extends IService<SweetArtists> {
ResponseDto<PageInfo<SweetArtists>> getList(int page, int size,String name); ResponseDto<PageInfo<SweetArtists>> getList(int page, int size, String name);
ResponseDto<Boolean> add(SweetArtistsListParam sweetArtistsList);
ResponseDto<Boolean> add(String picUrl,String name,String pinyin,String describe); ResponseDto<SweetArtistsVo> detail(String artistsId);
ResponseDto<SweetArtists> detail(String artistsId); ResponseDto<Boolean> change(String artistsId, SweetArtistsListParam sweetArtistsList);
ResponseDto<Boolean> change(String artistsId,String picUrl,String name,String pinyin,String describe); ResponseDto<SweetArtists> del(String artistsId);
} }
package com.liquidnet.service.sweet.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.github.pagehelper.PageInfo;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.sweet.entity.SweetPerformanceShow;
import com.liquidnet.service.sweet.vo.SweetPerformanceShowVo;
public interface ISweetPerformanceAppService extends IService<SweetPerformanceShow> {
ResponseDto<PageInfo<SweetPerformanceShowVo>> getlistInTime(Integer page, Integer size);
}
package com.liquidnet.service.sweet.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.github.pagehelper.PageInfo;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.sweet.entity.SweetPerformanceShow;
import com.liquidnet.service.sweet.param.SweetPerformanceShowParam;
import com.liquidnet.service.sweet.vo.SweetPerformanceShowVo;
public interface ISweetPerformanceService extends IService<SweetPerformanceShow> {
ResponseDto<Boolean> add(String performanceId, String performanceName, String picOne, String picTwo, String arUrl, String timeStart, String timeEnd);
ResponseDto<Boolean> change(SweetPerformanceShowParam show);
ResponseDto<Boolean> del(String performanceId);
ResponseDto<PageInfo<SweetPerformanceShowVo>> getList(Integer page, Integer size, String performanceName);
ResponseDto<SweetPerformanceShowVo> details(String arId);
ResponseDto<Boolean> changeStatus(String arId,Integer status);
}
package com.liquidnet.service.sweet.entity; package com.liquidnet.service.sweet.entity;
import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import java.io.Serializable; import java.io.Serializable;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.List;
/** /**
* <p> * <p>
...@@ -31,10 +35,11 @@ public class SweetArtists implements Serializable,Cloneable { ...@@ -31,10 +35,11 @@ public class SweetArtists implements Serializable,Cloneable {
private String artistsId; private String artistsId;
/** /**
* 图片地址 * pic_url
*/ */
private String picUrl; private String picUrl;
/** /**
* 艺人名称 * 艺人名称
*/ */
......
package com.liquidnet.service.sweet.entity;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
@Data
@EqualsAndHashCode(callSuper = false)
public class SweetArtistsList implements Serializable,Cloneable{
private static final long serialVersionUID = 1L;
/**
* 艺人名称
*/
private String name;
/**
* 拼音
*/
private String pinyin;
/**
* 艺人简介
*/
private String describes;
/**
* 图
*/
private String[] picArray;
/**
* 视频
*/
private String[] videoArray;
}
package com.liquidnet.service.sweet.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.time.LocalDateTime;
@Data
@EqualsAndHashCode(callSuper = false)
public class SweetArtistsUrl implements Serializable, Cloneable {
private static final long serialVersionUID = 1L;
@TableId(value = "mid", type = IdType.AUTO)
private Long mid;
/**
* artists_id
*/
private String artistsId;
/**
* url
*/
private String url;
/**
* 类型 1图片 2视频
*/
private String type;
/**
* 创建时间
*/
private LocalDateTime createdAt;
private static final SweetArtistsUrl obj = new SweetArtistsUrl();
public static SweetArtistsUrl getNew() {
try {
return (SweetArtistsUrl) obj.clone();
} catch (CloneNotSupportedException e) {
return new SweetArtistsUrl();
}
}
}
package com.liquidnet.service.sweet.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
@Data
public class SweetPerformanceShow implements Serializable,Cloneable{
private static final long serialVersionUID = 1L;
@TableId(value = "mid", type = IdType.AUTO)
private Long mid;
/**
* 主键id
*/
private String arId;
private String performanceId;
/**
* 演出名
*/
private String performanceName;
/**
* 图片地址1
*/
private String picOne;
/**
* 图片地址2
*/
private String picTwo;
/**
* AR地址
*/
private String arUrl;
/**
* 离线地址
*/
private String offlineUrl;
/**
* 状态 1可用 0不可用
*/
private Integer status;
/**
* 开始时间
*/
private LocalDateTime timeStart;
/**
* 结束时间
*/
private LocalDateTime timeEnd;
private static final SweetPerformanceShow obj = new SweetPerformanceShow();
public static SweetPerformanceShow getNew() {
try {
return (SweetPerformanceShow) obj.clone();
} catch (CloneNotSupportedException e) {
return new SweetPerformanceShow();
}
}
}
package com.liquidnet.service.sweet.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.liquidnet.service.sweet.entity.SweetArtistsUrl;
public interface SweetArtistsUrlMapper extends BaseMapper<SweetArtistsUrl> {
}
package com.liquidnet.service.sweet.mapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.liquidnet.service.sweet.entity.SweetPerformanceShow;
public interface SweetPerformanceMapper extends BaseMapper<SweetPerformanceShow> {
}
package com.liquidnet.service.sweet.param;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
@Data
@EqualsAndHashCode(callSuper = false)
public class SweetArtistsListParam implements Serializable, Cloneable {
private static final long serialVersionUID = 1L;
/**
* 艺人名称
*/
private String name;
/**
* 拼音
*/
private String pinyin;
/**
* 封面图
*/
private String picUrl;
/**
* 艺人简介
*/
private String describes;
/**
* 图
*/
private String[] picArray;
/**
* 视频
*/
private String[] videoArray;
}
package com.liquidnet.service.sweet.param;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import java.io.Serializable;
@Data
public class SweetPerformanceShowParam implements Serializable,Cloneable{
private static final long serialVersionUID = 1L;
/**
* 主键id
*/
private String arId;
private String performanceId;
/**
* 演出名
*/
private String performanceName;
/**
* 图片地址1
*/
private String picOne;
/**
* 图片地址2
*/
private String picTwo;
/**
* AR地址
*/
private String arUrl;
/**
* 开始时间
*/
private String timeStart;
/**
* 结束时间
*/
private String timeEnd;
private static final SweetPerformanceShowParam obj = new SweetPerformanceShowParam();
public static SweetPerformanceShowParam getNew() {
try {
return (SweetPerformanceShowParam) obj.clone();
} catch (CloneNotSupportedException e) {
return new SweetPerformanceShowParam();
}
}
}
package com.liquidnet.service.sweet.vo;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.liquidnet.service.sweet.entity.SweetArtistsUrl;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.List;
/**
* <p>
* 艺人表
* </p>
*
* @author liquidnet
* @since 2021-07-23
*/
@Data
@EqualsAndHashCode(callSuper = false)
public class SweetArtistsVo implements Serializable,Cloneable {
private static final long serialVersionUID = 1L;
@TableId(value = "mid", type = IdType.AUTO)
private Long mid;
/**
* artists_id
*/
private String artistsId;
/**
* 艺人名称
*/
private String name;
/**
* 拼音
*/
private String pinyin;
/**
* 艺人简介
*/
private String describes;
/**
* 状态 1可用 0不可用
*/
private Integer status;
/**
* 创建时间
*/
private LocalDateTime createdAt;
/**
* 更新时间
*/
private LocalDateTime updatdAt;
private List<SweetArtistsUrl> sweetArtistsUrl;
private static final SweetArtistsVo obj = new SweetArtistsVo();
public static SweetArtistsVo getNew() {
try {
return (SweetArtistsVo) obj.clone();
} catch (CloneNotSupportedException e) {
return new SweetArtistsVo();
}
}
}
package com.liquidnet.service.sweet.vo;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;
import java.io.Serializable;
@Data
public class SweetPerformanceShowVo implements Serializable,Cloneable{
private static final long serialVersionUID = 1L;
/**
* 主键id
*/
private String arId;
private String performanceId;
/**
* 演出名
*/
private String performanceName;
/**
* 图片地址1
*/
private String picOne;
/**
* 图片地址2
*/
private String picTwo;
/**
* AR地址
*/
private String arUrl;
/**
* 离线地址
*/
private String offlineUrl;
/**
* 状态 1可用 0不可用
*/
private Integer status;
/**
* 开始时间
*/
private String timeStart;
/**
* 结束时间
*/
private String timeEnd;
private static final SweetPerformanceShowVo obj = new SweetPerformanceShowVo();
public static SweetPerformanceShowVo getNew() {
try {
return (SweetPerformanceShowVo) obj.clone();
} catch (CloneNotSupportedException e) {
return new SweetPerformanceShowVo();
}
}
}
DROP TABLE IF EXISTS `sweet_performance_show`;
CREATE TABLE `sweet_performance_show`
(
`mid` bigint AUTO_INCREMENT,
`ar_id` varchar(64) DEFAULT '' COMMENT '主键id',
`performance_id` varchar(255) DEFAULT '' COMMENT '演出id',
`performance_name` varchar(255) DEFAULT '' COMMENT '演出名',
`pic_one` varchar(255) DEFAULT '' COMMENT '图片1',
`pic_two` varchar(255) DEFAULT '' COMMENT '图片2',
`ar_url` varchar(255) DEFAULT '' COMMENT 'AR地址',
`offline_url` varchar(255) DEFAULT '' COMMENT '离线地址',
`time_start` datetime DEFAULT NULL COMMENT '开始时间',
`time_end` datetime DEFAULT NULL COMMENT '结束时间',
`status` tinyint NOT NULL DEFAULT 0 COMMENT '状态 1可用 0不可用',
PRIMARY KEY (`mid`) USING BTREE,
KEY `sweet_performance_ar_id_index` (`ar_id`),
KEY `sweet_performance_performance_name_index` (`performance_name`)
) ENGINE = InnoDB comment 'ar活动表';
DROP TABLE IF EXISTS `sweet_artists_url`;
CREATE TABLE `sweet_artists_url`
(
`mid` bigint NOT NULL AUTO_INCREMENT,
`artists_id` varchar(255) NOT NULL COMMENT 'artists_id',
`url` varchar(255) NULL DEFAULT NULL COMMENT 'url',
`type` varchar(255) NOT NULL COMMENT '类型1:图片 2:视频',
`created_at` datetime NULL DEFAULT NULL,
PRIMARY KEY (`mid`) USING BTREE,
KEY `sweet_artists_url_artists_id_index` (`artists_id`)
) ENGINE = InnoDB comment 'ar资源表';
\ No newline at end of file
...@@ -4,9 +4,13 @@ package com.liquidnet.service.sweet.controller; ...@@ -4,9 +4,13 @@ package com.liquidnet.service.sweet.controller;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.sweet.entity.SweetArtists; import com.liquidnet.service.sweet.entity.SweetArtists;
import com.liquidnet.service.sweet.entity.SweetArtistsList;
import com.liquidnet.service.sweet.entity.SweetArtistsUrl;
import com.liquidnet.service.sweet.entity.SweetStage; import com.liquidnet.service.sweet.entity.SweetStage;
import com.liquidnet.service.sweet.param.SweetArtistsListParam;
import com.liquidnet.service.sweet.service.ISweetArtistsService; import com.liquidnet.service.sweet.service.ISweetArtistsService;
import com.liquidnet.service.sweet.service.ISweetStageService; import com.liquidnet.service.sweet.service.ISweetStageService;
import com.liquidnet.service.sweet.vo.SweetArtistsVo;
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;
...@@ -14,6 +18,8 @@ import io.swagger.annotations.ApiOperation; ...@@ -14,6 +18,8 @@ import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.List;
/** /**
* <p> * <p>
* 艺人表 前端控制器 * 艺人表 前端控制器
...@@ -46,16 +52,15 @@ public class SweetArtistsController { ...@@ -46,16 +52,15 @@ public class SweetArtistsController {
@PostMapping("add") @PostMapping("add")
@ApiOperation("添加艺人") @ApiOperation("添加艺人")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "picUrl", value = "图片", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "picUrl", value = "封面图片", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "name", value = "艺人姓名", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "name", value = "艺人姓名", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "pinyin", value = "姓名拼音", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "pinyin", value = "姓名拼音", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "describe", value = "艺人简介", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "describes", value = "艺人简介", required = true),
@ApiImplicitParam(type = "query", dataType = "String[]", name = "picArray", value = "图片数组", required = true),
@ApiImplicitParam(type = "query", dataType = "String[]", name = "videoArray", value = "视频数组", required = true)
}) })
public ResponseDto<Boolean> add(@RequestParam() String picUrl, public ResponseDto<Boolean> add(SweetArtistsListParam sweetArtistsList) {
@RequestParam() String name, return sweetArtistsService.add(sweetArtistsList);
@RequestParam() String pinyin,
@RequestParam() String describe) {
return sweetArtistsService.add(picUrl, name, pinyin, describe);
} }
@GetMapping("detail") @GetMapping("detail")
...@@ -63,25 +68,31 @@ public class SweetArtistsController { ...@@ -63,25 +68,31 @@ public class SweetArtistsController {
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "artistsId", value = "艺人Id", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "artistsId", value = "艺人Id", required = true),
}) })
public ResponseDto<SweetArtists> detail(@RequestParam() String artistsId) { public ResponseDto<SweetArtistsVo> detail(@RequestParam() String artistsId) {
return sweetArtistsService.detail(artistsId); return sweetArtistsService.detail(artistsId);
} }
@PostMapping("change") @PostMapping("change")
@ApiOperation("修改艺人") @ApiOperation("修改艺人")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "picUrl", value = "封面图片", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "artistsId", value = "艺人Id", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "artistsId", value = "艺人Id", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "picUrl", value = "图片", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "name", value = "艺人姓名", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "name", value = "艺人姓名", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "pinyin", value = "姓名拼音", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "pinyin", value = "姓名拼音", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "describe", value = "艺人简介", required = true), @ApiImplicitParam(type = "query", dataType = "String", name = "describes", value = "艺人简介", required = true),
@ApiImplicitParam(type = "query", dataType = "String[]", name = "picArray", value = "图片数组", required = true),
@ApiImplicitParam(type = "query", dataType = "String[]", name = "videoArray", value = "视频数组", required = true)
}) })
public ResponseDto<Boolean> change(@RequestParam() String artistsId, public ResponseDto<Boolean> change(@RequestParam() String artistsId, SweetArtistsListParam sweetArtistsList) {
@RequestParam() String picUrl, return sweetArtistsService.change(artistsId, sweetArtistsList);
@RequestParam() String name,
@RequestParam() String pinyin,
@RequestParam() String describe) {
return sweetArtistsService.change(artistsId, picUrl, name, pinyin, describe);
} }
@GetMapping("del")
@ApiOperation("删除艺人")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "artistsId", value = "艺人Id", required = true),
})
public ResponseDto<SweetArtists> del(@RequestParam() String artistsId) {
return sweetArtistsService.del(artistsId);
}
} }
package com.liquidnet.service.sweet.controller;
import com.github.pagehelper.PageInfo;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.sweet.entity.SweetPerformanceShow;
import com.liquidnet.service.sweet.service.ISweetPerformanceAppService;
import com.liquidnet.service.sweet.vo.SweetPerformanceShowVo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
@Api(tags = "演出AR")
@RestController
@RequestMapping("/sweet-App")
public class SweetPerformanceAppController {
@Autowired
private ISweetPerformanceAppService sweetPerformanceAppService;
@GetMapping("listInTime")
@ApiOperation("ar列表-移动端")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "Integer", name = "page", value = "页数", required = true),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "size", value = "数量", required = true),
})
public ResponseDto<PageInfo<SweetPerformanceShowVo>> getlistInTime(@RequestParam() Integer page,
@RequestParam() Integer size) {
return sweetPerformanceAppService.getlistInTime(page, size);
}
}
package com.liquidnet.service.sweet.controller;
import com.github.pagehelper.PageInfo;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.sweet.param.SweetPerformanceShowParam;
import com.liquidnet.service.sweet.vo.SweetPerformanceShowVo;
import com.liquidnet.service.sweet.service.ISweetPerformanceService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@Api(tags = "演出AR")
@RestController
@RequestMapping("/sweet-ar")
public class SweetPerformanceController {
@Autowired
private ISweetPerformanceService sweetPerformanceService;
@GetMapping("list")
@ApiOperation("ar列表")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "Integer", name = "page", value = "页数", required = true),
@ApiImplicitParam(type = "query", dataType = "Integer", name = "size", value = "数量", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "performanceName", value = "演出名", required = false),
})
public ResponseDto<PageInfo<SweetPerformanceShowVo>> getList(@RequestParam() Integer page,
@RequestParam() Integer size,
@RequestParam(required = false) String performanceName) {
return sweetPerformanceService.getList(page, size, performanceName);
}
@GetMapping("details")
@ApiOperation("ar详情")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "arId", value = "主键id", required = true),
})
public ResponseDto<SweetPerformanceShowVo> details(@RequestParam("arId") String arId) {
return sweetPerformanceService.details(arId);
}
@GetMapping("changeStatus")
@ApiOperation("ar修改活动状态")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "arId", value = "主键id", required = true),
@ApiImplicitParam(type = "query", dataType = "int", name = "status", value = "状态[1-启用|0-不可用]", required = true),
})
public ResponseDto<Boolean> changeStatus(@RequestParam("arId") String arId, @RequestParam("status") Integer status) {
return sweetPerformanceService.changeStatus(arId, status);
}
@PostMapping("add")
@ApiOperation("添加")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "performanceId", value = "演出id", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "performanceName", value = "演出名", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "picOne", value = "图片1", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "picTwo", value = "图片2", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "arUrl", value = "AR地址", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "timeStart", value = "开始时间", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "timeEnd", value = "结束时间", required = true)
})
public ResponseDto<Boolean> add(@RequestParam() String performanceId,
@RequestParam() String performanceName,
@RequestParam() String picOne,
@RequestParam() String picTwo,
@RequestParam() String arUrl,
@RequestParam() String timeStart,
@RequestParam() String timeEnd) {
return sweetPerformanceService.add(performanceId, performanceName, picOne, picTwo, arUrl, timeStart, timeEnd);
}
@PostMapping("change")
@ApiOperation("修改")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "performanceId", value = "演出id", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "picOne", value = "图片1", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "picTwo", value = "图片2", required = true),
@ApiImplicitParam(type = "query", dataType = "String", name = "arUrl", value = "AR地址", required = true),
@ApiImplicitParam(type = "query", dataType = "LocalDateTime", name = "timeStart", value = "开始时间", required = true),
@ApiImplicitParam(type = "query", dataType = "LocalDateTime", name = "timeEnd", value = "结束时间", required = true)
})
public ResponseDto<Boolean> change(SweetPerformanceShowParam show) {
return sweetPerformanceService.change(show);
}
@PostMapping("del")
@ApiOperation("删除")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "arId", value = "主键id", required = true)
})
public ResponseDto<Boolean> del(@RequestParam() String arId) {
return sweetPerformanceService.del(arId);
}
}
package com.liquidnet.service.sweet.service.impl; package com.liquidnet.service.sweet.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.liquidnet.commons.lang.util.BeanUtil;
import com.liquidnet.commons.lang.util.IDGenerator; import com.liquidnet.commons.lang.util.IDGenerator;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.sweet.dto.SweetManualArtistList2Dto; import com.liquidnet.service.sweet.dto.SweetManualArtistList2Dto;
import com.liquidnet.service.sweet.dto.SweetManualArtistListDto; import com.liquidnet.service.sweet.dto.SweetManualArtistListDto;
import com.liquidnet.service.sweet.dto.SweetManualArtistStageListDto; import com.liquidnet.service.sweet.dto.SweetManualArtistStageListDto;
import com.liquidnet.service.sweet.entity.SweetArtists; import com.liquidnet.service.sweet.entity.*;
import com.liquidnet.service.sweet.entity.SweetManualArtists;
import com.liquidnet.service.sweet.entity.SweetStage;
import com.liquidnet.service.sweet.mapper.SweetArtistsMapper; import com.liquidnet.service.sweet.mapper.SweetArtistsMapper;
import com.liquidnet.service.sweet.mapper.SweetArtistsUrlMapper;
import com.liquidnet.service.sweet.mapper.SweetManualArtistsMapper; import com.liquidnet.service.sweet.mapper.SweetManualArtistsMapper;
import com.liquidnet.service.sweet.mapper.SweetStageMapper; import com.liquidnet.service.sweet.mapper.SweetStageMapper;
import com.liquidnet.service.sweet.param.SweetArtistsListParam;
import com.liquidnet.service.sweet.service.ISweetArtistsService; import com.liquidnet.service.sweet.service.ISweetArtistsService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.liquidnet.service.sweet.utils.RedisDataUtils; import com.liquidnet.service.sweet.utils.RedisDataUtils;
import com.liquidnet.service.sweet.vo.SweetArtistsVo;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.List; import java.util.List;
...@@ -40,6 +45,9 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe ...@@ -40,6 +45,9 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe
private SweetManualArtistsMapper sweetManualArtistsMapper; private SweetManualArtistsMapper sweetManualArtistsMapper;
@Autowired @Autowired
private RedisDataUtils redisDataUtils; private RedisDataUtils redisDataUtils;
@Autowired
private SweetArtistsUrlMapper sweetArtistsUrlMapper;
@Override @Override
public ResponseDto<PageInfo<SweetArtists>> getList(int page, int size, String name) { public ResponseDto<PageInfo<SweetArtists>> getList(int page, int size, String name) {
...@@ -47,10 +55,10 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe ...@@ -47,10 +55,10 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe
try { try {
List<SweetArtists> data; List<SweetArtists> data;
PageHelper.startPage(page, size); PageHelper.startPage(page, size);
if(name!=null){ if (name != null) {
data = sweetArtistsMapper.selectList(Wrappers.lambdaQuery(SweetArtists.class).like(SweetArtists::getName, name)); data = sweetArtistsMapper.selectList(Wrappers.lambdaQuery(SweetArtists.class).like(SweetArtists::getName, name));
}else{ } else {
data = sweetArtistsMapper.selectList(Wrappers.lambdaQuery(SweetArtists.class)); data = sweetArtistsMapper.selectList(Wrappers.lambdaQuery(SweetArtists.class));
} }
pageInfo = new PageInfo(data); pageInfo = new PageInfo(data);
return ResponseDto.success(pageInfo); return ResponseDto.success(pageInfo);
...@@ -60,16 +68,33 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe ...@@ -60,16 +68,33 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe
} }
@Override @Override
public ResponseDto<Boolean> add(String picUrl, String name, String pinyin, String describe) { @Transactional
public ResponseDto<Boolean> add(SweetArtistsListParam sweetArtistsList) {
try { try {
String mid = IDGenerator.nextSnowId();
LocalDateTime time = LocalDateTime.now();
SweetArtistsUrl sweetArtistsUrl = SweetArtistsUrl.getNew();
SweetArtists sweetArtists = SweetArtists.getNew(); SweetArtists sweetArtists = SweetArtists.getNew();
sweetArtists.setArtistsId(IDGenerator.nextSnowId()); sweetArtists.setArtistsId(mid);
sweetArtists.setPicUrl(picUrl); sweetArtists.setName(sweetArtistsList.getName());
sweetArtists.setName(name); sweetArtists.setPinyin(sweetArtistsList.getPinyin());
sweetArtists.setPinyin(pinyin); sweetArtists.setDescribes(sweetArtistsList.getDescribes());
sweetArtists.setDescribes(describe); sweetArtists.setPicUrl(sweetArtistsList.getPicUrl());
sweetArtists.setCreatedAt(LocalDateTime.now()); sweetArtists.setCreatedAt(time);
sweetArtists.setUpdatdAt(time);
sweetArtistsMapper.insert(sweetArtists); sweetArtistsMapper.insert(sweetArtists);
sweetArtistsUrl.setArtistsId(mid);
sweetArtistsUrl.setCreatedAt(time);
for (String img : sweetArtistsList.getPicArray()) {
sweetArtistsUrl.setUrl(img);
sweetArtistsUrl.setType("1");
sweetArtistsUrlMapper.insert(sweetArtistsUrl);
}
for (String video : sweetArtistsList.getVideoArray()) {
sweetArtistsUrl.setUrl(video);
sweetArtistsUrl.setType("2");
sweetArtistsUrlMapper.insert(sweetArtistsUrl);
}
return ResponseDto.success(); return ResponseDto.success();
} catch (Exception e) { } catch (Exception e) {
return ResponseDto.failure(); return ResponseDto.failure();
...@@ -77,25 +102,49 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe ...@@ -77,25 +102,49 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe
} }
@Override @Override
public ResponseDto<SweetArtists> detail(String artistsId) { public ResponseDto<SweetArtistsVo> detail(String artistsId) {
try { try {
return ResponseDto.success(sweetArtistsMapper.selectOne(Wrappers.lambdaQuery(SweetArtists.class).eq(SweetArtists::getArtistsId, artistsId))); SweetArtistsVo vo = SweetArtistsVo.getNew();
SweetArtists sweetArtists = sweetArtistsMapper.selectOne(Wrappers.lambdaQuery(SweetArtists.class).eq(SweetArtists::getArtistsId, artistsId));
BeanUtils.copyProperties(sweetArtists, vo);
List<SweetArtistsUrl> sweetArtistsUrl = sweetArtistsUrlMapper.selectList(Wrappers.lambdaQuery(SweetArtistsUrl.class).eq(SweetArtistsUrl::getArtistsId, artistsId));
vo.setSweetArtistsUrl(sweetArtistsUrl);
return ResponseDto.success(vo);
} catch (Exception e) { } catch (Exception e) {
log.error("==", e);
return ResponseDto.failure(); return ResponseDto.failure();
} }
} }
@Override @Override
public ResponseDto<Boolean> change(String artistsId, String picUrl, String name, String pinyin, String describe) { @Transactional
public ResponseDto<Boolean> change(String artistsId, SweetArtistsListParam sweetArtistsList) {
try { try {
LocalDateTime time = LocalDateTime.now();
SweetArtists sweetArtists = SweetArtists.getNew(); SweetArtists sweetArtists = SweetArtists.getNew();
sweetArtists.setPicUrl(picUrl); sweetArtists.setName(sweetArtistsList.getName());
sweetArtists.setName(name); sweetArtists.setPinyin(sweetArtistsList.getPinyin());
sweetArtists.setPinyin(pinyin); sweetArtists.setPicUrl(sweetArtistsList.getPicUrl());
sweetArtists.setDescribes(describe); sweetArtists.setDescribes(sweetArtistsList.getDescribes());
sweetArtists.setUpdatdAt(LocalDateTime.now()); sweetArtists.setUpdatdAt(time);
SweetArtistsUrl sweetArtistsUrl = SweetArtistsUrl.getNew();
sweetArtistsUrl.setCreatedAt(time);
sweetArtistsMapper.update(sweetArtists, Wrappers.lambdaUpdate(SweetArtists.class).eq(SweetArtists::getArtistsId, artistsId)); sweetArtistsMapper.update(sweetArtists, Wrappers.lambdaUpdate(SweetArtists.class).eq(SweetArtists::getArtistsId, artistsId));
//更新关联表
sweetArtistsUrlMapper.delete(Wrappers.lambdaQuery(SweetArtistsUrl.class).eq(SweetArtistsUrl::getArtistsId, artistsId));
sweetArtistsUrl.setArtistsId(artistsId);
sweetArtistsUrl.setCreatedAt(time);
for (String img : sweetArtistsList.getPicArray()) {
sweetArtistsUrl.setUrl(img);
sweetArtistsUrl.setType("1");
sweetArtistsUrlMapper.insert(sweetArtistsUrl);
}
for (String video : sweetArtistsList.getVideoArray()) {
sweetArtistsUrl.setUrl(video);
sweetArtistsUrl.setType("2");
sweetArtistsUrlMapper.insert(sweetArtistsUrl);
}
List<SweetManualArtists> data = sweetManualArtistsMapper.selectList(Wrappers.lambdaQuery(SweetManualArtists.class).eq(SweetManualArtists::getArtistsId, artistsId)); List<SweetManualArtists> data = sweetManualArtistsMapper.selectList(Wrappers.lambdaQuery(SweetManualArtists.class).eq(SweetManualArtists::getArtistsId, artistsId));
for (SweetManualArtists item : data) { for (SweetManualArtists item : data) {
redisDataUtils.deleteTimeListRedisData(item.getManualId()); redisDataUtils.deleteTimeListRedisData(item.getManualId());
...@@ -105,4 +154,18 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe ...@@ -105,4 +154,18 @@ public class SweetArtistsServiceImpl extends ServiceImpl<SweetArtistsMapper, Swe
return ResponseDto.failure(); return ResponseDto.failure();
} }
} }
@Override
@Transactional
public ResponseDto<SweetArtists> del(String artistsId) {
try {
sweetArtistsMapper.delete(Wrappers.lambdaQuery(SweetArtists.class).eq(SweetArtists::getArtistsId, artistsId));
sweetArtistsUrlMapper.delete(Wrappers.lambdaQuery(SweetArtistsUrl.class).eq(SweetArtistsUrl::getArtistsId, artistsId));
return ResponseDto.success();
} catch (Exception e) {
return ResponseDto.failure();
}
}
} }
package com.liquidnet.service.sweet.service.impl;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.liquidnet.commons.lang.util.DateUtil;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.sweet.entity.SweetPerformanceShow;
import com.liquidnet.service.sweet.mapper.SweetPerformanceMapper;
import com.liquidnet.service.sweet.service.ISweetPerformanceAppService;
import com.liquidnet.service.sweet.utils.RedisDataUtils;
import com.liquidnet.service.sweet.vo.SweetPerformanceShowVo;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;
import static com.liquidnet.commons.lang.util.DateUtil.DTF_YMD_HMS;
@Service
public class SweetPerformanceAppServiceImpl extends ServiceImpl<SweetPerformanceMapper, SweetPerformanceShow> implements ISweetPerformanceAppService {
@Autowired
private RedisDataUtils redisUtils;
@Override
public ResponseDto<PageInfo<SweetPerformanceShowVo>> getlistInTime(Integer page, Integer size) {
PageInfo<SweetPerformanceShowVo> pageInfo = null;
try {
size = 20;
List<SweetPerformanceShowVo> data = new ArrayList<>();
PageHelper.startPage(page, size);
LocalDateTime time = LocalDateTime.now();
List<SweetPerformanceShow> performanceARList = redisUtils.getPerformanceAR();
for (SweetPerformanceShow performanceShow : performanceARList) {
if (time.isBefore(performanceShow.getTimeEnd()) && time.isAfter(performanceShow.getTimeStart()) && performanceShow.getStatus() == 1) {
SweetPerformanceShowVo vo = SweetPerformanceShowVo.getNew();
BeanUtils.copyProperties(performanceShow, vo);
vo.setTimeStart(DateUtil.Formatter.yyyyMMddHHmmss.format(performanceShow.getTimeStart()));
vo.setTimeEnd(DateUtil.Formatter.yyyyMMddHHmmss.format(performanceShow.getTimeEnd()));
data.add(vo);
}
}
pageInfo = new PageInfo(data);
return ResponseDto.success(pageInfo);
} catch (Exception e) {
e.printStackTrace();
return ResponseDto.success(pageInfo);
}
}
}
package com.liquidnet.service.sweet.service.impl;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.liquidnet.commons.lang.util.*;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderRefundsVo;
import com.liquidnet.service.sweet.entity.SweetPerformanceShow;
import com.liquidnet.service.sweet.mapper.SweetPerformanceMapper;
import com.liquidnet.service.sweet.param.SweetPerformanceShowParam;
import com.liquidnet.service.sweet.vo.SweetPerformanceShowVo;
import com.liquidnet.service.sweet.service.ISweetPerformanceService;
import com.liquidnet.service.sweet.utils.RedisDataUtils;
import com.mongodb.BasicDBObject;
import org.bson.Document;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.convert.MongoConverter;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Service;
import org.springframework.beans.factory.annotation.Value;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import static com.liquidnet.commons.lang.util.DateUtil.DTF_YMD_HMS;
@Service
public class SweetPerformanceServiceImpl extends ServiceImpl<SweetPerformanceMapper, SweetPerformanceShow> implements ISweetPerformanceService {
@Value("${liquidnet.service.goblin.url}")
private String goblinUrl;
@Autowired
private SweetPerformanceMapper sweetPerformanceMapper;
@Autowired
private RedisDataUtils redisUtils;
@Autowired
private MongoTemplate mongoTemplate;
@Autowired
private MongoConverter mongoConverter;
@Autowired
Environment environment;
@Override
public ResponseDto<Boolean> add(String performanceId, String performanceName, String picOne, String picTwo, String arUrl, String timeStart, String timeEnd) {
try {
String offlineUrl = goblinUrl + "/goblin/inner/ar/data"; //离线地址
SweetPerformanceShow show = SweetPerformanceShow.getNew();
show.setArId(IDGenerator.nextTimeId2());
show.setPerformanceId(performanceId);
show.setPerformanceName(performanceName);
show.setPicOne(picOne);
show.setPicTwo(picTwo);
show.setArUrl(arUrl);
show.setOfflineUrl(offlineUrl);
show.setTimeStart(LocalDateTime.parse(timeStart));
show.setTimeEnd(LocalDateTime.parse(timeEnd));
//redis
List<SweetPerformanceShow> performanceARList = redisUtils.getPerformanceAR();
performanceARList.add(show);
redisUtils.setPerformanceAR(performanceARList);
//新增 mongo数据
mongoTemplate.insert(show, SweetPerformanceShow.class.getSimpleName());
//mysql
sweetPerformanceMapper.insert(show);
return ResponseDto.success();
} catch (Exception e) {
return ResponseDto.failure();
}
}
@Override
public ResponseDto<Boolean> change(SweetPerformanceShowParam show) {
try {
String id = show.getArId();
//修改redis
List<SweetPerformanceShow> performanceARList = redisUtils.getPerformanceAR();
SweetPerformanceShow data = SweetPerformanceShow.getNew();
for (int i = 0; i < performanceARList.size(); i++) {
if (performanceARList.get(i).getArId().equals(id)) {
//覆盖要修改的原数据
BeanUtils.copyProperties(show, data);
data.setTimeStart(LocalDateTime.parse(show.getTimeStart(),DTF_YMD_HMS));
data.setTimeEnd(LocalDateTime.parse(show.getTimeEnd(),DTF_YMD_HMS));
data.setStatus(performanceARList.get(i).getStatus());
data.setOfflineUrl(performanceARList.get(i).getOfflineUrl());
performanceARList.set(i, data);
redisUtils.setPerformanceAR(performanceARList);
break;
}
}
if (data.getArId() == null || data.getArId().equals("")) {
return ResponseDto.failure();
}
//修改 mongo数据
Query query = Query.query(Criteria.where("arId").is(id));
Update update = Update.fromDocument(Document.parse(JsonUtils.toJson(data)));
mongoTemplate.updateFirst(query, update, SweetPerformanceShow.class, SweetPerformanceShow.class.getSimpleName());
//修改mysql
sweetPerformanceMapper.update(data, Wrappers.lambdaUpdate(SweetPerformanceShow.class).eq(SweetPerformanceShow::getArId, id));
return ResponseDto.success();
} catch (Exception e) {
e.printStackTrace();
return ResponseDto.failure();
}
}
@Override
public ResponseDto<Boolean> del(String arId) {
//删除
List<SweetPerformanceShow> performanceARList = redisUtils.getPerformanceAR();
for (SweetPerformanceShow performanceShow : performanceARList) {
if (performanceShow.getArId().equals(arId)) {
//删除要修改的原数据
performanceARList.remove(performanceShow);
redisUtils.setPerformanceAR(performanceARList);
break;
}
}
mongoTemplate.remove(Query.query(Criteria.where("arId").is(arId)), SweetPerformanceShow.class.getSimpleName());
sweetPerformanceMapper.delete(Wrappers.lambdaQuery(SweetPerformanceShow.class).eq(SweetPerformanceShow::getArId, arId));
return ResponseDto.success();
}
//ar列表
@Override
public ResponseDto<PageInfo<SweetPerformanceShowVo>> getList(Integer page, Integer size, String performanceName) {
PageInfo<SweetPerformanceShowVo> pageInfo = null;
try {
List<SweetPerformanceShow> data;
PageHelper.startPage(page, size);
List<SweetPerformanceShowVo> listData = new ArrayList();
if (performanceName != null) {
data = sweetPerformanceMapper.selectList(Wrappers.lambdaQuery(SweetPerformanceShow.class).like(SweetPerformanceShow::getPerformanceName, performanceName));
} else {
data = sweetPerformanceMapper.selectList(Wrappers.lambdaQuery(SweetPerformanceShow.class));
}
for (SweetPerformanceShow entity : data) {
SweetPerformanceShowVo rdata = SweetPerformanceShowVo.getNew();
BeanUtils.copyProperties(entity, rdata);
rdata.setTimeStart(DateUtil.Formatter.yyyyMMddHHmmss.format(entity.getTimeStart()));
rdata.setTimeEnd(DateUtil.Formatter.yyyyMMddHHmmss.format(entity.getTimeEnd()));
listData.add(rdata);
}
pageInfo = new PageInfo(listData);
return ResponseDto.success(pageInfo);
} catch (Exception e) {
return ResponseDto.success(pageInfo);
}
}
@Override
public ResponseDto<SweetPerformanceShowVo> details(String arId) {
SweetPerformanceShow entity = sweetPerformanceMapper.selectOne(Wrappers.lambdaQuery(SweetPerformanceShow.class).eq(SweetPerformanceShow::getArId, arId));
SweetPerformanceShowVo rdata = SweetPerformanceShowVo.getNew();
BeanUtils.copyProperties(entity, rdata);
rdata.setTimeStart(DateUtil.Formatter.yyyyMMddHHmmss.format(entity.getTimeStart()));
rdata.setTimeEnd(DateUtil.Formatter.yyyyMMddHHmmss.format(entity.getTimeEnd()));
return ResponseDto.success(rdata);
}
@Override
public ResponseDto<Boolean> changeStatus(String arId, Integer status) {
List<SweetPerformanceShow> performanceARList = redisUtils.getPerformanceAR();
SweetPerformanceShow data = null;
for (int i = 0; i < performanceARList.size(); i++) {
SweetPerformanceShow performanceShow = performanceARList.get(i);
if (performanceShow.getArId().equals(arId)) {
//覆盖要修改的原数据\
performanceShow.setStatus(status);
performanceARList.set(i, performanceShow);
redisUtils.setPerformanceAR(performanceARList);
data = performanceShow;
break;
}
}
//修改 mongo数据
BasicDBObject cv = new BasicDBObject("$set", mongoConverter.convertToMongoType(data));
mongoTemplate.getCollection(KylinOrderRefundsVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("arId").is("arId")).getQueryObject(),
cv
);
//修改mysql
sweetPerformanceMapper.update(data, Wrappers.lambdaUpdate(SweetPerformanceShow.class).eq(SweetPerformanceShow::getArId, arId));
return ResponseDto.success();
}
}
...@@ -850,4 +850,35 @@ public class RedisDataUtils { ...@@ -850,4 +850,35 @@ public class RedisDataUtils {
return (int) obj; return (int) obj;
} }
} }
public void setPerformanceAR(List<SweetPerformanceShow> data) {
String redisKey = SweetConstant.REDIS_KEY_SWEET_PERFORMANCE_AR;
redisUtil.set(redisKey, data);
}
public List<SweetPerformanceShow> getPerformanceAR() {
String redisKey = SweetConstant.REDIS_KEY_SWEET_PERFORMANCE_AR;
Object obj = redisUtil.get(redisKey);
if (obj == null) {
return new ArrayList<>();
} else {
return (List<SweetPerformanceShow>) obj;
}
}
public void delPerformanceARById(String performanceId){
String redisKey = SweetConstant.REDIS_KEY_SWEET_PERFORMANCE_AR.concat(performanceId + "");
redisUtil.del(redisKey);
}
public List<SweetPerformanceShow> getPerformanceListInApp(){
String redisKey = SweetConstant.REDIS_KEY_SWEET_PERFORMANCE_AR.concat("*");
Object obj = redisUtil.get(redisKey);
if (obj == null) {
return new ArrayList<>();
} else {
return (List<SweetPerformanceShow>) obj;
}
}
} }
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