Mercurial > lada > lada-server
comparison src/main/java/de/intevation/lada/lock/TimestampLocker.java @ 1028:1c41c7b8f7c2 schema-update
Updated server application to new database model. THIS IS STILL WIP!!!
| author | Raimund Renkert <raimund.renkert@intevation.de> |
|---|---|
| date | Fri, 08 Jul 2016 15:32:36 +0200 |
| parents | 9a6d8c174e78 |
| children | 67a85c6a7474 |
comparison
equal
deleted
inserted
replaced
| 1027:9971471d562c | 1028:1c41c7b8f7c2 |
|---|---|
| 13 | 13 |
| 14 import javax.inject.Inject; | 14 import javax.inject.Inject; |
| 15 | 15 |
| 16 import org.apache.log4j.Logger; | 16 import org.apache.log4j.Logger; |
| 17 | 17 |
| 18 import de.intevation.lada.model.land.LMessung; | 18 import de.intevation.lada.model.land.Messung; |
| 19 import de.intevation.lada.model.land.LProbe; | 19 import de.intevation.lada.model.land.Probe; |
| 20 import de.intevation.lada.util.annotation.RepositoryConfig; | 20 import de.intevation.lada.util.annotation.RepositoryConfig; |
| 21 import de.intevation.lada.util.data.Repository; | 21 import de.intevation.lada.util.data.Repository; |
| 22 import de.intevation.lada.util.data.RepositoryType; | 22 import de.intevation.lada.util.data.RepositoryType; |
| 23 import de.intevation.lada.util.rest.Response; | 23 import de.intevation.lada.util.rest.Response; |
| 24 | 24 |
| 49 * @param o The object to test. | 49 * @param o The object to test. |
| 50 * @return True if the object is locked else false. | 50 * @return True if the object is locked else false. |
| 51 */ | 51 */ |
| 52 @Override | 52 @Override |
| 53 public boolean isLocked(Object o) { | 53 public boolean isLocked(Object o) { |
| 54 if (o instanceof LProbe) { | 54 if (o instanceof Probe) { |
| 55 LProbe newProbe = (LProbe)o; | 55 Probe newProbe = (Probe)o; |
| 56 LProbe oldProbe = (LProbe)repository.getById( | 56 Probe oldProbe = (Probe)repository.getById( |
| 57 LProbe.class, | 57 Probe.class, |
| 58 newProbe.getId(), | 58 newProbe.getId(), |
| 59 "land").getData(); | 59 "land").getData(); |
| 60 logger.debug("old: " + oldProbe.getTreeModified().getTime()); | 60 logger.debug("old: " + oldProbe.getTreeModified().getTime()); |
| 61 logger.debug("new: " + newProbe.getTreeModified().getTime()); | 61 logger.debug("new: " + newProbe.getTreeModified().getTime()); |
| 62 if (oldProbe.getTreeModified().getTime() > | 62 if (oldProbe.getTreeModified().getTime() > |
| 74 } catch (IllegalAccessException | IllegalArgumentException | 74 } catch (IllegalAccessException | IllegalArgumentException |
| 75 | InvocationTargetException e) { | 75 | InvocationTargetException e) { |
| 76 return true; | 76 return true; |
| 77 } | 77 } |
| 78 Response response = | 78 Response response = |
| 79 repository.getById(LProbe.class, id, "land"); | 79 repository.getById(Probe.class, id, "land"); |
| 80 LProbe probe = (LProbe)response.getData(); | 80 Probe probe = (Probe)response.getData(); |
| 81 return isNewer(o, probe.getTreeModified()); | 81 return isNewer(o, probe.getTreeModified()); |
| 82 } | 82 } |
| 83 if (m.getName().equals("getMessungsId")) { | 83 if (m.getName().equals("getMessungsId")) { |
| 84 Integer id; | 84 Integer id; |
| 85 try { | 85 try { |
| 87 } catch (IllegalAccessException | IllegalArgumentException | 87 } catch (IllegalAccessException | IllegalArgumentException |
| 88 | InvocationTargetException e) { | 88 | InvocationTargetException e) { |
| 89 return true; | 89 return true; |
| 90 } | 90 } |
| 91 Response mResponse = | 91 Response mResponse = |
| 92 repository.getById(LMessung.class, id, "land"); | 92 repository.getById(Messung.class, id, "land"); |
| 93 LMessung messung = (LMessung)mResponse.getData(); | 93 Messung messung = (Messung)mResponse.getData(); |
| 94 boolean newerMessung = isNewer(o, messung.getTreeModified()); | 94 boolean newerMessung = isNewer(o, messung.getTreeModified()); |
| 95 return newerMessung; | 95 return newerMessung; |
| 96 } | 96 } |
| 97 } | 97 } |
| 98 } | 98 } |