hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

日志明细公用接口调整

This commit is contained in:
yuqh 2024-05-16 09:43:50 +08:00
parent c64b37ac9c
commit fcec924c63
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/service/impl/IntegrationTaskLivingDetailsServiceImpl.java
View File

@ -67,6 +67,8 @@ public class IntegrationTaskLivingDetailsServiceImpl extends BaseService<Integra
@Override @Override
public JsonResultEntity saveLogToSuccess(IntegrationTaskLivingDetailsEntity entity)throws Exception { public JsonResultEntity saveLogToSuccess(IntegrationTaskLivingDetailsEntity entity)throws Exception {
checkDate(entity); checkDate(entity);
entity.setNewState("Y");
entity.setRepairPust("N");
try { try {
entity = integrationTaskLivingDetailsDao.saveSuccessLog(entity); entity = integrationTaskLivingDetailsDao.saveSuccessLog(entity);
return BaseResult.getSuccessMessageEntity(entity); return BaseResult.getSuccessMessageEntity(entity);
@ -89,6 +91,8 @@ public class IntegrationTaskLivingDetailsServiceImpl extends BaseService<Integra
public JsonResultEntity saveLogToFail(IntegrationTaskLivingDetailsEntity entity)throws Exception { public JsonResultEntity saveLogToFail(IntegrationTaskLivingDetailsEntity entity)throws Exception {
//验证必填字段如果不满足返回数据 //验证必填字段如果不满足返回数据
checkDate(entity); checkDate(entity);
entity.setNewState("N");
entity.setRepairPust("Y");
try { try {
entity = integrationTaskLivingDetailsDao.save(entity); entity = integrationTaskLivingDetailsDao.save(entity);
return BaseResult.getSuccessMessageEntity(entity); return BaseResult.getSuccessMessageEntity(entity);
@ -108,6 +112,8 @@ public class IntegrationTaskLivingDetailsServiceImpl extends BaseService<Integra
public JsonResultEntity saveLogFailToSuccess(IntegrationTaskLivingDetailsEntity entity)throws Exception { public JsonResultEntity saveLogFailToSuccess(IntegrationTaskLivingDetailsEntity entity)throws Exception {
//验证必填字段如果不满足返回数据 //验证必填字段如果不满足返回数据
checkDate(entity); checkDate(entity);
entity.setNewState("Y");
entity.setRepairPust("N");
try { try {
//先根据主键删除错误日志表数据，在进行成功表写入 //先根据主键删除错误日志表数据，在进行成功表写入
integrationTaskLivingDetailsDao.delete(entity.getId()); integrationTaskLivingDetailsDao.delete(entity.getId());
@ -130,6 +136,8 @@ public class IntegrationTaskLivingDetailsServiceImpl extends BaseService<Integra
public JsonResultEntity updateLogFailToSuccess(IntegrationTaskLivingDetailsEntity entity)throws Exception { public JsonResultEntity updateLogFailToSuccess(IntegrationTaskLivingDetailsEntity entity)throws Exception {
//验证必填字段如果不满足返回数据 //验证必填字段如果不满足返回数据
checkDate(entity); checkDate(entity);
entity.setNewState("N");
entity.setRepairPust("Y");
try { try {
//将数据写入成功日志表 //将数据写入成功日志表
entity = integrationTaskLivingDetailsDao.update(entity); entity = integrationTaskLivingDetailsDao.update(entity);
@ -174,14 +182,14 @@ public class IntegrationTaskLivingDetailsServiceImpl extends BaseService<Integra
if (StrUtil.isEmpty(newTransmitInfo)) { if (StrUtil.isEmpty(newTransmitInfo)) {
throw new BaseSystemException("三方系统返回数据不可为空，请传入"); throw new BaseSystemException("三方系统返回数据不可为空，请传入");
} }
String repairPust = entity.getRepairPust();//是否补推(Y是N不是) 成功情况下默认N不需要补退 // String repairPust = entity.getRepairPust();//是否补推(Y是N不是) 成功情况下默认N不需要补退
if (StrUtil.isEmpty(repairPust)) { // if (StrUtil.isEmpty(repairPust)) {
throw new BaseSystemException("是否补推不可为空，请传入"); // throw new BaseSystemException("是否补推不可为空，请传入");
} // }
String newState = entity.getNewState();//推送状态 成功情况下默认Y // String newState = entity.getNewState();//推送状态 成功情况下默认Y
if (StrUtil.isEmpty(newState)) { // if (StrUtil.isEmpty(newState)) {
throw new BaseSystemException("推送状态不可为空，请传入"); // throw new BaseSystemException("推送状态不可为空，请传入");
} // }
} }
} }