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

Skip to content

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

暂时提交一部分

parent c849d1a7
Hide whitespace changes
Inline Side-by-side
Showing with 45 additions and 43 deletions
liquidnet-bus-service/liquidnet-service-slime/liquidnet-service-slime-impl/src/main/java/com/liquidnet/service/slime/service/impl/KylinPerformancesPartnerServiceImpl.java
View file @ 490d1654
...@@ -871,52 +871,54 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa ...@@ -871,52 +871,54 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
LocalDateTime now = LocalDateTime.now(); LocalDateTime now = LocalDateTime.now();
KylinPerformanceVo vo = redisSlimeUtils.getPerformanceVo(performancesId); KylinPerformanceVo vo = redisSlimeUtils.getPerformanceVo(performancesId);
Integer auditStatus = 0; Integer auditStatus = 0;
// if (vo.getFieldAuditStatus() == 0) { if (vo.getFieldAuditStatus() == 0) {
// return ResponseDto.failure("演出不需要审核"); return ResponseDto.failure("演出不需要审核");
// } else if (vo.getFieldAuditStatus() == 1) { } else if (vo.getFieldAuditStatus() == 1) {
KylinPerformanceVo changeVo = KylinPerformanceVo.getNew(); KylinPerformanceVo changeVo = KylinPerformanceVo.getNew();
changeVo.setFieldAuditStatus(status); changeVo.setFieldAuditStatus(status);
changeVo.setRejectTxt(rejectTxt); changeVo.setRejectTxt(rejectTxt);
changeVo.setPerformancesId(performancesId); changeVo.setPerformancesId(performancesId);
if(status==0){ if (status == 0) {
auditStatus=0; auditStatus = 0;
} } else if (status == 2) {
if (status == 2) { auditStatus = -1;
if (vo.getAppStatus() == 1) {
changeVo.setAppStatus(0);
} }
changeVo.setAuditStatus(auditStatus); if (status == 2) {
} if (vo.getAppStatus() == 1) {
mongoSlimeUtils.updateKylinPerformanceVoById(changeVo); changeVo.setAppStatus(0);
redisSlimeUtils.delPerformanceVo(performancesId); }
changeVo.setAuditStatus(auditStatus);
PerformancePartnerVo changePartnerVo = PerformancePartnerVo.getNew(); }
changePartnerVo.setPerformancesId(performancesId); mongoSlimeUtils.updateKylinPerformanceVoById(changeVo);
changePartnerVo.setFieldAuditStatus(status); redisSlimeUtils.delPerformanceVo(performancesId);
changePartnerVo.setRejectTxt(rejectTxt);
changePartnerVo.setUpdatedAt(now.format(DateUtil.DTF_YMD_HMS)); PerformancePartnerVo changePartnerVo = PerformancePartnerVo.getNew();
if (status == 2) { changePartnerVo.setPerformancesId(performancesId);
if (vo.getAppStatus() == 0) { changePartnerVo.setFieldAuditStatus(status);
changePartnerVo.setStatus(0); changePartnerVo.setRejectTxt(rejectTxt);
changePartnerVo.setUpdatedAt(now.format(DateUtil.DTF_YMD_HMS));
if (status == 2) {
if (vo.getAppStatus() == 0) {
changePartnerVo.setStatus(0);
}
changePartnerVo.setAuditStatus(auditStatus);
} }
changePartnerVo.setAuditStatus(auditStatus); mongoSlimeUtils.updatePerformancePartnerVoById(changePartnerVo);
LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("kylin_performance_status.fieldsStatus"));
sqls.add(SqlMapping.get("kylin_performances_reject_txt.fieldsStatus"));
LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
sqlsDataA.add(new Object[]{
status, auditStatus, vo.getAppStatus(), performancesId, now, now
});
sqlsDataB.add(new Object[]{
rejectTxt, performancesId, now, now
});
String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB);
queueUtil.sendMsgByRedis(MQConst.SlimeQueue.SQL_SLIME_PERFORMANCE_UPDATE.getKey(),
sqlData);
} }
mongoSlimeUtils.updatePerformancePartnerVoById(changePartnerVo);
LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("kylin_performance_status.fieldsStatus"));
sqls.add(SqlMapping.get("kylin_performances_reject_txt.fieldsStatus"));
LinkedList<Object[]> sqlsDataA = CollectionUtil.linkedListObjectArr();
LinkedList<Object[]> sqlsDataB = CollectionUtil.linkedListObjectArr();
sqlsDataA.add(new Object[]{
status, auditStatus, vo.getAppStatus(), performancesId, now, now
});
sqlsDataB.add(new Object[]{
rejectTxt, performancesId, now, now
});
String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB);
queueUtil.sendMsgByRedis(MQConst.SlimeQueue.SQL_SLIME_PERFORMANCE_UPDATE.getKey(),
sqlData);
// }
return ResponseDto.success("审核完成"); return ResponseDto.success("审核完成");
} }
......
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