84 lines
3.3 KiB
Java
84 lines
3.3 KiB
Java
|
package de.hsadmin.mods.pac;
|
||
|
|
|
||
|
|
import java.util.Date;
|
||
|
|
import java.util.HashSet;
|
||
|
|
import java.util.List;
|
||
|
|
import java.util.Set;
|
||
|
|
|
||
|
|
import javax.persistence.EntityManager;
|
||
|
|
import javax.persistence.Query;
|
||
|
|
|
||
|
|
import de.hsadmin.core.model.AbstractEntity;
|
||
|
|
import de.hsadmin.core.model.AbstractModuleImpl;
|
||
|
|
import de.hsadmin.core.model.HSAdminException;
|
||
|
|
import de.hsadmin.mods.cust.Customer;
|
||
|
|
|
||
|
|
public class PacModuleImpl extends AbstractModuleImpl {
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public List<AbstractEntity> search(Class<? extends AbstractEntity> entityClass,
|
||
|
|
String condition, String orderBy) throws HSAdminException {
|
||
|
|
if (orderBy == null || orderBy.length() == 0) {
|
||
|
|
orderBy = "ORDER BY obj.name ASC";
|
||
|
|
}
|
||
|
|
return super.search(entityClass, condition, orderBy);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public AbstractEntity add(AbstractEntity newEntity) throws HSAdminException {
|
||
|
|
Date now = new Date();
|
||
|
|
EntityManager em = getTransaction().getEntityManager();
|
||
|
|
Pac pac = (Pac) newEntity;
|
||
|
|
BasePac basepac = pac.getBasepac();
|
||
|
|
if (basepac == null || basepac.getName() == null || basepac.getName().length() == 0) {
|
||
|
|
throw new HSAdminException("basepac required");
|
||
|
|
}
|
||
|
|
Query qBasepac = em.createQuery("SELECT b FROM BasePacs b WHERE b.name = :basepacName AND b.valid = :valid");
|
||
|
|
qBasepac.setParameter("basepacName", basepac.getName());
|
||
|
|
qBasepac.setParameter("valid", Boolean.TRUE);
|
||
|
|
basepac = (BasePac) qBasepac.getSingleResult();
|
||
|
|
pac.setBasepac(basepac);
|
||
|
|
Query qComponents = em.createQuery("SELECT c FROM Components c WHERE c.basePacId = :basepac");
|
||
|
|
qComponents.setParameter("basepac", basepac.id());
|
||
|
|
INetAddress curINetAddr = pac.getCurINetAddr();
|
||
|
|
if (curINetAddr == null || curINetAddr.getInetAddr() == null || curINetAddr.getInetAddr().length() == 0) {
|
||
|
|
throw new HSAdminException("curinetaddr required");
|
||
|
|
}
|
||
|
|
Query qINetAddr = em.createNativeQuery("SELECT * FROM inet_addr WHERE inet_addr = inet '" + curINetAddr.getInetAddr() + "'", INetAddress.class);
|
||
|
|
curINetAddr = (INetAddress) qINetAddr.getSingleResult();
|
||
|
|
pac.setCurINetAddr(curINetAddr);
|
||
|
|
Customer customer = pac.getCustomer();
|
||
|
|
if (customer == null || customer.getName() == null || customer.getName().length() == 0) {
|
||
|
|
throw new HSAdminException("customer required");
|
||
|
|
}
|
||
|
|
Query qCustomer = em.createQuery("SELECT c FROM Customers c WHERE c.name = :name");
|
||
|
|
qCustomer.setParameter("name", customer.getName());
|
||
|
|
customer = (Customer) qCustomer.getSingleResult();
|
||
|
|
pac.setCustomer(customer);
|
||
|
|
Hive hive = pac.getHive();
|
||
|
|
if (hive == null || hive.getName() == null || hive.getName().length() == 0) {
|
||
|
|
throw new HSAdminException("hive required");
|
||
|
|
}
|
||
|
|
Query qHive = em.createQuery("SELECT h FROM Hives h WHERE h.name = :name");
|
||
|
|
qHive.setParameter("name", hive.getName());
|
||
|
|
hive = (Hive) qHive.getSingleResult();
|
||
|
|
pac.setHive(hive);
|
||
|
|
// em.persist(newEntity);
|
||
|
|
List<?> componentsList = qComponents.getResultList();
|
||
|
|
Set<PacComponent> pacComponents = new HashSet<PacComponent>();
|
||
|
|
for (Object cObj : componentsList) {
|
||
|
|
Component comp = (Component) cObj;
|
||
|
|
PacComponent pacComponent = new PacComponent();
|
||
|
|
pacComponent.setBaseComponent(comp.getBaseComponent());
|
||
|
|
pacComponent.setbasePac(comp.getBasePac());
|
||
|
|
pacComponent.setCreated(now);
|
||
|
|
pacComponent.setPac(pac);
|
||
|
|
pacComponent.setQuantity(comp.getDefaultQuantity());
|
||
|
|
// em.persist(pacComponent);
|
||
|
|
}
|
||
|
|
pac.setPacComponents(pacComponents);
|
||
|
|
return super.add(newEntity);
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|