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

Commit 606353b8 authored by 姜秀龙's avatar 姜秀龙

platform prod + admin审核演出后报错处理

parent 733d7898
...@@ -143,6 +143,7 @@ global-auth: ...@@ -143,6 +143,7 @@ global-auth:
# 场地摄像头列表 # 场地摄像头列表
- ${liquidnet.info.context}/camera/list - ${liquidnet.info.context}/camera/list
- ${liquidnet.info.context}/inner/** - ${liquidnet.info.context}/inner/**
- ${liquidnet.info.context}/performance-data/fskfsfs
oncheck-url-pattern: oncheck-url-pattern:
- ${liquidnet.info.context}/order/details - ${liquidnet.info.context}/order/details
- ${liquidnet.info.context}/order/transfer* - ${liquidnet.info.context}/order/transfer*
......
liquidnet:
system:
updating:
switch: false
info:
port: 9003
context: /platform
name: liquidnet-service-platform
logfile:
path: /data/logs
name: service-platform
max-history: 180
level: info
# rabbitmq:
# connection-timeout: 5000
mysql:
database-name: prod_ln_scene
mongodb:
sslEnabled: false
database: prod_ln_scene
#以下为spring各环境个性配置
...@@ -196,6 +196,7 @@ spring: ...@@ -196,6 +196,7 @@ spring:
global-auth: global-auth:
exclude-url-pattern: # 模式I(与模式II互斥) exclude-url-pattern: # 模式I(与模式II互斥)
# - ${liquidnet.info.context}/** # - ${liquidnet.info.context}/**
- ${liquidnet.info.context}/performance-data/fskfsfs
include-url-pattern: # 模式II(与模式I互斥) include-url-pattern: # 模式II(与模式I互斥)
# - ${liquidnet.info.context}/** # - ${liquidnet.info.context}/**
# ----------------------------------------------------------- # -----------------------------------------------------------
......
package com.liquidnet.service.platform.controller.data;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.liquidnet.commons.lang.util.DateUtil;
import com.liquidnet.commons.lang.util.IDGenerator;
import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.kylin.dto.param.PerformancePartnerVo;
import com.liquidnet.service.kylin.dto.vo.partner.KylinPerformanceMisVo;
import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketPartnerVo;
import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo;
import com.liquidnet.service.kylin.entity.KylinTicketRelations;
import com.liquidnet.service.kylin.entity.KylinTicketStatus;
import com.liquidnet.service.kylin.mapper.KylinTicketRelationsMapper;
import com.liquidnet.service.kylin.mapper.KylinTicketStatusMapper;
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.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
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;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.util.List;
/**
* <p>
* 演出 前端控制器
* </p>
*
* @author jiangxiulong
* @since 2021-05-11
*/
@Api(tags = "临时数据处理")
@RestController
@RequestMapping("performance-data")
@Slf4j
public class JxlDataController {
@Autowired
private KylinTicketRelationsMapper ticketRelationsMapper;
@Autowired
private KylinTicketStatusMapper ticketStatusMapper;
@Autowired
private MongoTemplate mongoTemplate;
@GetMapping("fskfsfs")
@ApiOperation("dfsfsfs")
@ApiImplicitParams({
@ApiImplicitParam(type = "query", dataType = "String", name = "performancesId", value = "演出id", required = true),
})
public ResponseDto sfsfs(
@RequestParam("performancesId") String performancesId
) {
LocalDateTime createdAt = LocalDateTime.now();
List<KylinTicketTimesPartnerVo> voTimes = mongoTemplate.find(Query.query(Criteria.where("performancesId").is(performancesId)),
KylinTicketTimesPartnerVo.class, KylinTicketTimesPartnerVo.class.getSimpleName());
Integer num = 1;
for (KylinTicketTimesPartnerVo voTime : voTimes) {
List<KylinTicketPartnerVo> timesIdVo = mongoTemplate.find(Query.query(
Criteria.where("timesId").is(voTime.getTicketTimesId())),
KylinTicketPartnerVo.class,
KylinTicketPartnerVo.class.getSimpleName());
for (KylinTicketPartnerVo ticketVo : timesIdVo) {
LocalDateTime timeC = null;
LocalDateTime timeU = null;
try {
timeC = DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(ticketVo.getCreatedAt()));
} catch (Exception e) {
e.printStackTrace();
}
try {
timeU = DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(ticketVo.getUpdatedAt()));
} catch (Exception e) {
e.printStackTrace();
}
String ticketsId = ticketVo.getTicketsId();
KylinTicketRelations ticketRelations = new KylinTicketRelations();
BeanUtils.copyProperties(ticketVo, ticketRelations);
ticketRelations.setCreatedAt(timeC);
ticketRelations.setUpdatedAt(timeU);
ticketRelations.setTicketRelationsId(IDGenerator.nextSnowId());
ticketRelations.setTicketId(ticketsId);
// 场次与票种关联表
ticketRelationsMapper.insert(ticketRelations);
KylinTicketStatus ticketStatusNew = new KylinTicketStatus();
BeanUtils.copyProperties(ticketVo, ticketStatusNew);
ticketStatusNew.setTicketId(ticketsId);
ticketStatusNew.setStatusExchange(7);
if(ticketVo.getExpressType()==null){
ticketStatusNew.setExpressType(0);
}
PerformancePartnerVo performanceData = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performancesId)), PerformancePartnerVo.class, PerformancePartnerVo.class.getSimpleName());
ticketStatusNew.setIsTrueName(performanceData.getIsTrueName());
ticketStatusNew.setMemberLimitCount(1);
ticketStatusNew.setCreatedAt(timeC);
ticketStatusNew.setUpdatedAt(timeU);
if (ticketVo.getIsShowCode() == 1) {
try {
ticketStatusNew.setQrCodeShowTime(DateUtil.asLocalDateTime(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(ticketVo.getQrCodeShowTime())));
} catch (Exception e) {
e.printStackTrace();
}
}
KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(
Wrappers.lambdaQuery(KylinTicketStatus.class)
.eq(KylinTicketStatus::getTicketId, ticketsId)
);
if (null == ticketStatus) {// 添加
ticketStatusNew.setTicketStatusId(IDGenerator.nextSnowId());
ticketStatusMapper.insert(ticketStatusNew);
System.out.println("新增---------------------------------");
System.out.println(ticketsId);
System.out.println(ticketStatusNew);
} else {// 编辑
ticketStatusMapper.update(ticketStatusNew,
new UpdateWrapper<KylinTicketStatus>().
eq("ticket_id", ticketsId)
);
System.out.println("编辑---------------------------------");
System.out.println(ticketsId);
System.out.println(ticketStatusNew);
}
}
}
// dataUtils.delPerformanceRedis(performancesId);
// System.out.println(voTimes);
return ResponseDto.success();
}
}
# begin-dev-这里是配置信息基本值 # begin-dev-这里是配置信息基本值
liquidnet: liquidnet:
cloudConfig: cloudConfig:
profile: dev profile: prod
security: security:
username: user username: user
password: user123 password: user123
eureka: eureka:
host: 39.107.71.112:7001 host: 127.0.0.1:7001
# end-dev-这里是配置信息基本值 # end-dev-这里是配置信息基本值
spring: spring:
......
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