Commit ce32ee08 by chongli

资源同步过慢问题日志和加入性能日志

parent 150dbf52
...@@ -112,14 +112,19 @@ public class AsmCourseResourceDao extends GenericHibernateDao<AsmCourseresource, ...@@ -112,14 +112,19 @@ public class AsmCourseResourceDao extends GenericHibernateDao<AsmCourseresource,
} }
public void syncData() { public void syncData() {
logger.error("性能检测1:"+DateUtil.getDateTimeStr(new Date()));
Date now = new Date(); Date now = new Date();
Date insertDate = this.getMaxCreateDate("AsmCourseresource"); Date insertDate = this.getMaxCreateDate("AsmCourseresource");
Date updateDate = this.getMaxUpdateDate("AsmCourseresource"); Date updateDate = this.getMaxUpdateDate("AsmCourseresource");
logger.error("性能检测2:"+DateUtil.getDateTimeStr(new Date()));
updateDate = new Date(updateDate.getTime()-10*1000*60); updateDate = new Date(updateDate.getTime()-10*1000*60);
logger.error("性能检测3:"+DateUtil.getDateTimeStr(new Date()));
this.syncInsert(insertDate, now); this.syncInsert(insertDate, now);
logger.error("性能检测4:"+DateUtil.getDateTimeStr(new Date()));
if (insertDate.getTime() != 0) { if (insertDate.getTime() != 0) {
this.syncUpdate(updateDate, now); this.syncUpdate(updateDate, now);
} }
logger.error("性能检测5:"+DateUtil.getDateTimeStr(new Date()));
} }
...@@ -134,14 +139,22 @@ public class AsmCourseResourceDao extends GenericHibernateDao<AsmCourseresource, ...@@ -134,14 +139,22 @@ public class AsmCourseResourceDao extends GenericHibernateDao<AsmCourseresource,
} }
private void syncUpdate(Date date, Date now) { private void syncUpdate(Date date, Date now) {
logger.error("性能检测4-1:"+DateUtil.getDateTimeStr(new Date()));
this.updateCourseInfo(date, now); this.updateCourseInfo(date, now);
logger.error("性能检测4-2:"+DateUtil.getDateTimeStr(new Date()));
this.updateCourseProductInfo(date, now); this.updateCourseProductInfo(date, now);
logger.error("性能检测4-3:"+DateUtil.getDateTimeStr(new Date()));
this.updateCourseResourceInfo(date, now); this.updateCourseResourceInfo(date, now);
logger.error("性能检测4-4:"+DateUtil.getDateTimeStr(new Date()));
this.updateResourcePriceInfo(date, now); this.updateResourcePriceInfo(date, now);
logger.error("性能检测4-5:"+DateUtil.getDateTimeStr(new Date()));
this.updateCityNames(); this.updateCityNames();
logger.error("性能检测4-6:"+DateUtil.getDateTimeStr(new Date()));
this.updateSponsorInfo(); this.updateSponsorInfo();
logger.error("性能检测4-7:"+DateUtil.getDateTimeStr(new Date()));
// 必须在SponsorInfo更新完之后执行 // 必须在SponsorInfo更新完之后执行
this.updatePriceField(); this.updatePriceField();
logger.error("性能检测4-8:"+DateUtil.getDateTimeStr(new Date()));
} }
private void updateCourseInfo(Date date, Date now) { private void updateCourseInfo(Date date, Date now) {
...@@ -367,8 +380,8 @@ public class AsmCourseResourceDao extends GenericHibernateDao<AsmCourseresource, ...@@ -367,8 +380,8 @@ public class AsmCourseResourceDao extends GenericHibernateDao<AsmCourseresource,
return ids; return ids;
} }
private Date getMaxCreateDate(String entityName) { private Date getMaxCreateDate(String entityName) {
String hql = "select max(createdTime) from " + entityName; String hql = "select createdTime from " + entityName +" where id=( SELECT max(id) from "+entityName+")";
Object obj = this.getSession().createQuery(hql).uniqueResult(); Object obj = this.getSession().createQuery(hql).uniqueResult();
if (obj != null) { if (obj != null) {
......
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 sign in to comment