implemented remote indexes related services

src/main/java/net/irext/server/service/businesslogic/IndexingLogic.java

@@ -83,4 +83,14 @@ public class IndexingLogic {
     public List<StbOperator> listOperators(String cityCode) {
         return operatorMapper.listOperators(cityCode);
     }
+
+    public List<RemoteIndex> listRemoteIndexes(int categoryId, int brandId, String cityCode, int from, int count) {
+        List<RemoteIndex> remoteIndexList;
+        if (categoryId == Constants.CategoryID.STB.getValue()) {
+            remoteIndexList = remoteIndexMapper.listRemoteIndexByCity(cityCode, from, count);
+        } else {
+            remoteIndexList = remoteIndexMapper.listRemoteIndexByBrand(categoryId, brandId, from, count);
+        }
+        return remoteIndexList;
+    }
 }

src/main/java/net/irext/server/service/mapper/RemoteIndexMapper.java

@@ -22,4 +22,13 @@ public interface RemoteIndexMapper {
     @Select("SELECT * FROM remote_index WHERE id = #{id}")
     @ResultMap("BaseResultMap")
     List<RemoteIndex> getRemoteIndexById(int id);
+
+    @Select("SELECT * FROM remote_index WHERE city_code = #{cityCode} ORDER BY priority LIMIT #{from}, #{count}")
+    @ResultMap("BaseResultMap")
+    List<RemoteIndex> listRemoteIndexByCity(String cityCode, int from, int count);
+
+    @Select("SELECT * FROM remote_index WHERE category_id = #{categoryId} AND brand_id = #{brandId} " +
+            "ORDER BY priority LIMIT #{from}, #{count}")
+    @ResultMap("BaseResultMap")
+    List<RemoteIndex> listRemoteIndexByBrand(int categoryId, int brandId, int from, int count);
 }

src/main/java/net/irext/server/service/response/IndexesResponse.java

@@ -0,0 +1,37 @@
+package net.irext.server.service.response;
+
+import net.irext.server.service.model.RemoteIndex;
+
+import java.util.List;
+
+/**
+ * Filename:       IndexesResponse.java
+ * Revised:        Date: 2019-06-21
+ * Revision:       Revision: 1.0
+ * <p>
+ * Description:    IndexesResponse
+ * <p>
+ * Revision log:
+ * 2019-06-21: created by strawmanbobi
+ */
+public class IndexesResponse extends ServiceResponse {
+
+    private List<RemoteIndex> entity;
+
+    public IndexesResponse(Status status, List<RemoteIndex> remoteIndexes) {
+        super(status);
+        this.entity = remoteIndexes;
+    }
+
+    public IndexesResponse() {
+
+    }
+
+    public List<RemoteIndex> getEntity() {
+        return entity;
+    }
+
+    public void setEntity(List<RemoteIndex> entity) {
+        this.entity = entity;
+    }
+}

src/main/java/net/irext/server/service/restapi/IRIndexingService.java

@@ -3,10 +3,7 @@ package net.irext.server.service.restapi;
 import net.irext.server.service.Constants;
 import net.irext.server.service.businesslogic.IndexingLogic;
 import net.irext.server.service.mapper.RemoteIndexMapper;
-import net.irext.server.service.model.Brand;
+import net.irext.server.service.model.*;
-import net.irext.server.service.model.Category;
-import net.irext.server.service.model.City;
-import net.irext.server.service.model.StbOperator;
 import net.irext.server.service.request.*;
 import net.irext.server.service.response.*;
 import net.irext.server.service.restapi.base.AbstractBaseService;
@@ -120,7 +117,7 @@ public class IRIndexingService extends AbstractBaseService {
     @PostMapping("/list_provinces")
     public CitiesResponse listProvinces(HttpServletRequest request,
                                         @HeaderParam("user-lang") String userLang,
-                                        ListCitiesRequest listCitiesRequest) {
+                                        @RequestBody ListCitiesRequest listCitiesRequest) {
         try {
             int id = listCitiesRequest.getId();
             String token = listCitiesRequest.getToken();
@@ -131,7 +128,12 @@ public class IRIndexingService extends AbstractBaseService {
             }
 
             List<City> cityList = indexingLogic.listProvinces();
-
+            if (cityList != null) {
+                response.getStatus().setCode(Constants.ERROR_CODE_SUCCESS);
+                response.setEntity(cityList);
+            } else {
+                response.getStatus().setCode(Constants.ERROR_CODE_NETWORK_ERROR);
+            }
             return response;
         } catch (Exception e) {
             e.printStackTrace();
@@ -142,7 +144,7 @@ public class IRIndexingService extends AbstractBaseService {
     @PostMapping("/list_cities")
     public CitiesResponse listCities(HttpServletRequest request,
                                      @HeaderParam("user-lang") String userLang,
-                                     ListCitiesRequest listCitiesRequest) {
+                                     @RequestBody ListCitiesRequest listCitiesRequest) {
         try {
             int id = listCitiesRequest.getId();
             String token = listCitiesRequest.getToken();
@@ -154,7 +156,12 @@ public class IRIndexingService extends AbstractBaseService {
             }
 
             List<City> cityList = indexingLogic.listCities(provincePrefix);
-
+            if (cityList != null) {
+                response.getStatus().setCode(Constants.ERROR_CODE_SUCCESS);
+                response.setEntity(cityList);
+            } else {
+                response.getStatus().setCode(Constants.ERROR_CODE_NETWORK_ERROR);
+            }
             return response;
         } catch (Exception e) {
             e.printStackTrace();
@@ -165,7 +172,7 @@ public class IRIndexingService extends AbstractBaseService {
     @PostMapping("/list_operators")
     public OperatorsResponse listOperators(HttpServletRequest request,
                                            @HeaderParam("user-lang") String userLang,
-                                           ListOperatorsRequest listOperatorsRequest) {
+                                           @RequestBody ListOperatorsRequest listOperatorsRequest) {
         try {
             int id = listOperatorsRequest.getId();
             String token = listOperatorsRequest.getToken();
@@ -177,7 +184,12 @@ public class IRIndexingService extends AbstractBaseService {
             }
 
             List<StbOperator> operatorList = indexingLogic.listOperators(cityCode);
-
+            if (operatorList != null) {
+                response.getStatus().setCode(Constants.ERROR_CODE_SUCCESS);
+                response.setEntity(operatorList);
+            } else {
+                response.getStatus().setCode(Constants.ERROR_CODE_NETWORK_ERROR);
+            }
             return response;
         } catch (Exception e) {
             e.printStackTrace();
@@ -185,6 +197,39 @@ public class IRIndexingService extends AbstractBaseService {
         }
     }
 
+    @PostMapping("/list_indexes")
+    public IndexesResponse listOperators(HttpServletRequest request,
+                                         @HeaderParam("user-lang") String userLang,
+                                         @RequestBody ListIndexesRequest listIndexesRequest) {
+        try {
+            int id = listIndexesRequest.getId();
+            String token = listIndexesRequest.getToken();
+            int categoryId = listIndexesRequest.getCategoryId();
+            int brandId = listIndexesRequest.getBrandId();
+            String cityCode = listIndexesRequest.getCityCode();
+            int from = listIndexesRequest.getFrom();
+            int count = listIndexesRequest.getCount();
+
+            IndexesResponse response = validateToken(id, token, IndexesResponse.class);
+            if (response.getStatus().getCode() == Constants.ERROR_CODE_AUTH_FAILURE) {
+                return response;
+            }
+
+            List<RemoteIndex> remoteIndexList =
+                    indexingLogic.listRemoteIndexes(categoryId, brandId, cityCode, from, count);
+            if (remoteIndexList != null) {
+                response.getStatus().setCode(Constants.ERROR_CODE_SUCCESS);
+                response.setEntity(remoteIndexList);
+            } else {
+                response.getStatus().setCode(Constants.ERROR_CODE_NETWORK_ERROR);
+            }
+            return response;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return getExceptionResponse(IndexesResponse.class);
+        }
+    }
+
     private int getLanguage(String userLang) {
         int lang = Constants.LANG_ZH_CN;
         if (null != userLang) {