windy/msgexchange-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add CminmsgHstDao to CminmsgsHisScheduled

Browse Source
This commit is contained in:
zhiqiang feng
2024-02-22 01:17:45 +00:00
parent c419ccc638
commit bf63730afe
1 changed files with 34 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/CminmsgsHisScheduled.java
+34 -29
View File
@@ -16,6 +16,7 @@ import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import com.gzzn.omms.msgexchangeapi.dao.CminmsgDao;
import com.gzzn.omms.msgexchangeapi.dao.CminmsgHstDao;
import com.gzzn.omms.msgexchangeapi.entity.Cminmsg;
import com.gzzn.omms.msgexchangeapi.entity.CminmsgHst;
import com.gzzn.omms.msgexchangeapi.service.ICminmsgHstService;
@@ -35,45 +36,49 @@ public class CminmsgsHisScheduled {
@Autowired
CminmsgDao cminmsgDao;
@Autowired
private CminmsgHstDao cminmsgHstdDao;
private static Logger logger = LoggerFactory.getLogger(CminmsgsHisScheduled.class);
@Scheduled(cron = "${scheduled.cminmsgHisCron}")
public void scheduled()
{
logger.info("开始cminmsgs消息转历史..");
cminmsgHstdDao.moveToHistory();
List<Cminmsg> lsCminmsg = null;
do
{
Date dateNow = new Date();
lsCminmsg = cminmsgDao.findByCminmsgsDateProcessedIsNotNullAndCminmsgsDateReceivedBefore
(
dateNow,new PageRequest(0,300)
);
if(CollectionUtils.isEmpty(lsCminmsg))
{
continue;
}
// List<Cminmsg> lsCminmsg = null;
// do
// {
// Date dateNow = new Date();
// lsCminmsg = cminmsgDao.findByCminmsgsDateProcessedIsNotNullAndCminmsgsDateReceivedBefore
// (
// dateNow,new PageRequest(0,300)
// );
// if(CollectionUtils.isEmpty(lsCminmsg))
// {
// continue;
// }
List<CminmsgHst> successLs = cminmsgHstService.insert(
cminmsgHstService.toCminmsgHstLs(lsCminmsg)
);
// List<CminmsgHst> successLs = cminmsgHstService.insert(
// cminmsgHstService.toCminmsgHstLs(lsCminmsg)
// );
//从原始表删除成功列表
if(!CollectionUtils.isEmpty(successLs))
{
List<Cminmsg> waitDeleteLs = successLs.stream()
.map(node->{
Cminmsg cminmsg = new Cminmsg();
BeanUtils.copyProperties(node, cminmsg);
return cminmsg;
})
.collect(Collectors.toList());
// //从原始表删除成功列表
// if(!CollectionUtils.isEmpty(successLs))
// {
// List<Cminmsg> waitDeleteLs = successLs.stream()
// .map(node->{
// Cminmsg cminmsg = new Cminmsg();
// BeanUtils.copyProperties(node, cminmsg);
// return cminmsg;
// })
// .collect(Collectors.toList());
cminmsgDao.delete(waitDeleteLs);
}
}
while(!CollectionUtils.isEmpty(lsCminmsg));
// cminmsgDao.delete(waitDeleteLs);
// }
// }
// while(!CollectionUtils.isEmpty(lsCminmsg));
logger.info("结束本次cminmsgs消息转历史..");
}//end shceduled