|
|
|
@ -7,6 +7,7 @@ import com.logpm.factory.oupai.mapper.OpFailRetryPushPackageMapper;
|
|
|
|
|
import com.logpm.factory.oupai.service.OpPushFailedPackageRecordService; |
|
|
|
|
import lombok.AllArgsConstructor; |
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
|
import org.springblade.core.mp.base.BaseServiceImpl; |
|
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
|
|
import java.util.Date; |
|
|
|
@ -15,9 +16,8 @@ import java.util.HashMap;
|
|
|
|
|
@Slf4j |
|
|
|
|
@Service |
|
|
|
|
@AllArgsConstructor |
|
|
|
|
public class OpPushFailedPackageRecordServiceImpl implements OpPushFailedPackageRecordService { |
|
|
|
|
public class OpPushFailedPackageRecordServiceImpl extends BaseServiceImpl<OpFailRetryPushPackageMapper,OpFailRetryPushPackageEntity> implements OpPushFailedPackageRecordService { |
|
|
|
|
|
|
|
|
|
private OpFailRetryPushPackageMapper opFailRetryPushPackageMapper; |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 记录失败的数据 |
|
|
|
@ -41,8 +41,8 @@ public class OpPushFailedPackageRecordServiceImpl implements OpPushFailedPackage
|
|
|
|
|
// if (opFailRetryPushPackageMapper.selectByMap(queryMap) != null) {
|
|
|
|
|
// return;
|
|
|
|
|
// }
|
|
|
|
|
save(opFailRetryPushPackageEntity); |
|
|
|
|
|
|
|
|
|
opFailRetryPushPackageMapper.insert(opFailRetryPushPackageEntity); |
|
|
|
|
|
|
|
|
|
}catch (Exception e){ |
|
|
|
|
log.error(e.getMessage(),e); |
|
|
|
|