package fr.ifremer.quadrige3.synchro.server.rest.data.survey;
   
   /*-
    * #%L
    * Quadrige3 Core :: Quadrige3 Synchro server
    * $Id:$
    * $HeadURL:$
    * %%
    * Copyright (C) 2017 Ifremer
   * %%
   * This program is free software: you can redistribute it and/or modify
   * it under the terms of the GNU Affero General Public License as published by
   * the Free Software Foundation, either version 3 of the License, or
   * (at your option) any later version.
   * 
   * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU General Public License for more details.
   * 
   * You should have received a copy of the GNU Affero General Public License
   * along with this program.  If not, see <http://www.gnu.org/licenses/>.
   * #L%
   */
  
  import com.google.common.collect.ImmutableList;
  import fr.ifremer.quadrige3.core.exception.DeleteForbiddenException;
  import fr.ifremer.quadrige3.core.service.data.survey.CampaignService;
  import fr.ifremer.quadrige3.core.vo.data.survey.CampaignVO;
  import fr.ifremer.quadrige3.synchro.server.service.ServiceLocator;
  import fr.ifremer.quadrige3.synchro.server.service.synchro.ReferentialSynchroService;
  import org.apache.commons.collections4.CollectionUtils;
  import org.springframework.http.HttpStatus;
  import org.springframework.web.bind.annotation.*;
  
  import java.util.List;
  import java.util.stream.Collectors;
  
  @RestController
  @RequestMapping("/campaign")
  public class CampaignRestController {
  
      @RequestMapping(value = "/save/list/", method = RequestMethod.POST)
      public @ResponseBody
      List<CampaignVO> save(@RequestBody List<CampaignVO> campaigns) {
  
          CampaignService service = ServiceLocator.instance().getCampaignService();
  
          List<CampaignVO> savedCampaigns = service.save(campaigns);
  
          // clean cache on referential last update date
          ServiceLocator.instance().getCacheService()
                  .clearCache(ReferentialSynchroService.REFERENTIAL_UPDATE_DATE_CACHE);
  
          return savedCampaigns;
      }
  
      @RequestMapping(value = "/save", method = RequestMethod.POST)
      public @ResponseBody
      CampaignVO save(@RequestBody CampaignVO campaign) {
  
          CampaignService service = ServiceLocator.instance().getCampaignService();
  
          CampaignVO savedCampaign = service.save(campaign);
  
          // clean cache on referential last update date
          ServiceLocator.instance().getCacheService()
                  .clearCache(ReferentialSynchroService.REFERENTIAL_UPDATE_DATE_CACHE);
  
          return savedCampaign;
      }
  
      @RequestMapping(value = "/get/{campaignId}", method = RequestMethod.GET)
      public @ResponseBody
      CampaignVO get(@PathVariable(value = "campaignId") Integer campaignId) {
  
          CampaignService service = ServiceLocator.instance().getCampaignService();
          return service.getById(campaignId);
      }
  
      @ResponseStatus(value = HttpStatus.OK, reason = "Delete campaign successfully processed")
      @RequestMapping(value = "/delete/{campaignId}", method = RequestMethod.POST)
      public void delete(@PathVariable(value = "campaignId") Integer campaignId) {
  
          if (campaignId == null) return;
  
          List<Integer> campaignIds = ImmutableList.of(campaignId);
  
          // Delete the campaigns by their ids
          deleteCampaigns(campaignIds);
  
      }
  
      @ResponseStatus(value = HttpStatus.OK, reason = "Delete campaigns successfully processed")
      @RequestMapping(value = "/delete/list/", method = RequestMethod.POST)
      public void delete(@RequestBody List<Integer> campaignIds) {
  
          if (CollectionUtils.isEmpty(campaignIds)) return;
  
         deleteCampaigns(campaignIds);
     }
 
     private void deleteCampaigns(List<Integer> campaignIds) {
         if (campaignIds == null) return;
 
         CampaignService service = ServiceLocator.instance().getCampaignService();
         // Check campaigns are deletable
         List<String> forbiddenIds = campaignIds.stream()
                 .filter(campaignId -> campaignId != null && service.isCampaignUsedBySurvey(campaignId))
                 .map(Object::toString)
                 .collect(Collectors.toList());
 
         // throw exception if one is not deletable
         if (!forbiddenIds.isEmpty())
             throw new DeleteForbiddenException("A campaign is used by survey", forbiddenIds);
 
         // If ok, delete them
         service.delete(campaignIds);
     }
 
 }