campaign

pom.xml

@@ -92,8 +92,8 @@
         </dependency>
         <dependency>
             <groupId>com.oracle</groupId>
-            <artifactId>ojdbc6</artifactId>
-            <version>11.2.0.3</version>
+            <artifactId>ojdbc7</artifactId>
+            <version>1.0</version>
         </dependency>
         <dependency>
             <groupId>org.hibernate</groupId>

src/main/java/com/viettel/campaign/repository/CampaignRepository.java

+package com.viettel.campaign.repository;
+
+import com.viettel.campaign.model.Campaign;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface CampaignRepository extends JpaRepository<Campaign, Long> {
+}

src/main/java/com/viettel/campaign/repository/CampaignRepositoryCustom.java

+package com.viettel.campaign.repository;
+
+import com.viettel.campaign.dto.CampaignDTO;
+import com.viettel.campaign.model.Campaign;
+
+import java.util.List;
+
+public interface CampaignRepositoryCustom {
+
+    List<CampaignDTO> searchCampaignExecute(String agentId);
+}

src/main/java/com/viettel/campaign/repository/CampaignRepositoryImpl.java

+package com.viettel.campaign.repository;
+
+import com.viettel.campaign.dto.CampaignDTO;
+import com.viettel.campaign.model.Campaign;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.persistence.EntityManager;
+import javax.persistence.Query;
+import java.util.ArrayList;
+import java.util.List;
+
+public class CampaignRepositoryImpl implements CampaignRepositoryCustom {
+
+    @Autowired
+    EntityManager entityManager;
+
+    @Override
+    public List<CampaignDTO> searchCampaignExecute(String agentId) {
+        List<CampaignDTO> lst = new ArrayList<>();
+        String expression = new StringBuilder()
+                .append(" SELECT C.CAMPAIGN_ID, C.CAMPAIGN_NAME, C.STATUS ")
+                .append(" FROM CAMPAIGN C ")
+                .append(" INNER JOIN CAMPAIGN_AGENT CA ON C.CAMPAIGN_ID = CA.CAMPAIGN_ID ")
+                .append(" WHERE 1 = 1 ")
+                .append(" AND CA.AGENT_ID = :pAgentId ")
+                .append(" AND C.STATUS IN (2,3) ")
+                .toString();
+
+        Query query = entityManager.createNativeQuery(expression);
+        query.setParameter("pAgentId", agentId);
+
+        List<Object[]> data = query.getResultList();
+
+        for (Object[] obj : data) {
+            CampaignDTO item = new CampaignDTO();
+            item.setCampaignId((Long)obj[0]);
+            item.setCampaignName((String)obj[1]);
+            item.setStatus((Short) obj[0]);
+
+            lst.add(item);
+        }
+
+        return lst;
+    }
+}