556,11 → 556,10 |
|
} |
|
public static void main(String[] args) throws IOException, JSONException, TransformationException, JAXBException { |
AbstractDao.getCurrentSession().beginTransaction(); |
String system = args.length > 0 ? args[0] : "http://localhost/baco"; |
public String sincronizeCoursesStudiesPlans(String systemUrl,boolean setActive) throws IOException, JSONException, TransformationException, JAXBException { |
|
URL url = new URL(system + "/wsjson/api?service=listCourses"); |
StringBuilder log = new StringBuilder(); |
URL url = new URL(systemUrl + "/wsjson/api?service=listCourses"); |
InputStream is = url.openStream(); |
String str = StreamsUtils.readString(is); |
JSONObject obj = new JSONObject(str); |
572,34 → 571,55 |
Course c = DaoFactory.getCourseDaoImpl().findCourseByCode(code); |
if(c == null) |
{ |
logger.info("SKIPING - Course " + code + " " + course.getString("name") + " does not exist in this system" ); |
String msg = "SKIPING - Course " + code + " " + course.getString("name") + " does not exist in this system"; |
log.append("<info>" + msg+"</info>"); |
logger.info(msg); |
} |
else |
{ |
logger.info("UPDATING - Course " + code + " " + course.getString("name") + " exist in this system" ); |
InputStream stream = new URL(system + "/wsjson/api?service=getStudiesPlanXml&code=" + code).openStream(); |
String msg = "UPDATING - Course " + code + " " + course.getString("name") + " exist in this system"; |
log.append("<info>" + msg+"</info>"); |
logger.info(msg); |
InputStream stream = new URL(systemUrl + "/wsjson/api?service=getStudiesPlanXml&code=" + code).openStream(); |
String studiesPlan = StreamsUtils.readString(stream); |
int len = studiesPlan.length(); |
if(studiesPlan == null || studiesPlan.trim().length() == 0 || studiesPlan.contains("<error>")) |
{ |
logger.error("Course " + code + " " + course.getString("name") + " dont has studies plan"); |
msg = "Course " + code + " " + course.getString("name") + " dont has studies plan"; |
log.append("<warn>" + msg+"</warn>"); |
logger.warn(msg); |
} |
else |
{ |
logger.info("Found studies plan for " + code + " " + course.getString("name") + " will update "); |
msg = "Found studies plan for " + code + " " + course.getString("name") + " will update "; |
log.append("<info>" + msg+"</info>"); |
logger.info(msg); |
if(setActive) |
{ |
msg = "Setting course to active"; |
log.append("<info>" + msg+"</info>"); |
logger.info(msg); |
c.setStatus(true); |
} |
//System.out.println(studiesPlan); |
logger.info("GENERATING COURSE JSON ...."); |
msg = "GENERATING COURSE JSON ...."; |
log.append("<info>" + msg+"</info>"); |
logger.info(msg); |
new CoursesService().generateCourseJson(c); |
logger.info("GENERATING COURSE STUDIES PLAN JSON ...."); |
|
msg="GENERATING COURSE STUDIES PLAN JSON ...."; |
log.append("<info>" + msg+"</info>"); |
logger.info(msg); |
stream.close(); |
stream = new URL(system + "/wsjson/api?service=getStudiesPlanXml&code=" + code).openStream(); |
stream = new URL(systemUrl + "/wsjson/api?service=getStudiesPlanXml&code=" + code).openStream(); |
UserSession userSession = DomainObjectFactory.createUserSessionImpl(); |
userSession.setUser(DaoFactory.getUserDaoImpl().load(new Long(1))); |
new CoursesService().uploadStudiesPlan(stream, "curso_" + code + ".xml", len,"appication/xml", userSession,c,true,"http://www.estgp.pt"); |
} |
} |
} |
AbstractDao.getCurrentSession().getTransaction().commit(); |
return log.toString(); |
|
} |
|
|