package com.ks.push.manager;
|
|
import com.ks.push.mapper.BPushTaskExcuteResultMapper;
|
import com.ks.push.pojo.DO.BPushTaskExcuteResult;
|
import com.ks.push.pojo.DO.PushPlatform;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
|
@Component
|
public class PushExcuteResultManager {
|
@Resource
|
private BPushTaskExcuteResultMapper bPushTaskExcuteResultMapper;
|
|
@Transactional(rollbackFor = Exception.class)
|
public void initPushExcuteResult(String taskId, PushPlatform pushPlatform, long deviceCount) {
|
BPushTaskExcuteResult result = new BPushTaskExcuteResult();
|
result.setCreateTime(new Date());
|
result.setFinish(false);
|
result.setPushPlatform(pushPlatform);
|
result.setPushSuccessDeviceCount(0L);
|
result.setTaskId(taskId);
|
result.setTotalDeviceCount(deviceCount);
|
result.setId(BPushTaskExcuteResult.createId(taskId, pushPlatform));
|
//初始化
|
bPushTaskExcuteResultMapper.insertSelective(result);
|
}
|
|
|
}
|
