Liu Haoyu / vehicle-simple

  package com.objecteye.service.impl;
  
  import cn.hutool.core.date.DateUtil;

  import com.objecteye.entity.FeatureResultMsg;
  import com.objecteye.entity.PageResult;
  import com.objecteye.entity.SyFeature;
  import com.objecteye.entity.SyPersonnel;

  import com.objecteye.service.DeployService;
  import com.objecteye.service.FeatureService;

  import org.springframework.beans.factory.annotation.Autowired;

  import org.springframework.data.mongodb.core.MongoTemplate;
  import org.springframework.data.mongodb.core.query.Criteria;
  import org.springframework.data.mongodb.core.query.Query;

  import org.springframework.data.mongodb.core.query.Update;

  import org.springframework.data.redis.core.RedisTemplate;
  import org.springframework.stereotype.Service;
  

  import java.util.*;

  
  /**
   * 服务实现层
   *
   * @author Administrator
   */
  @Service
  public class FeatureServiceImpl implements FeatureService {
  
      @Autowired

      private DeployService deployService;
      @Autowired
      private RedisTemplate redisTemplate;

      @Autowired
      private MongoTemplate mongoTemplate;

  
      @Override
      public List<SyFeature> findAll() {

          return mongoTemplate.find(Query.query(Criteria.where("isDelete").is(0).and("isSingle").is(0)), SyFeature.class);

      }
  
      /**
       * 按分页查询
       */
      @Override
      public PageResult findPage(int pageNum, int pageSize) {

          List<SyFeature> result = mongoTemplate.find(Query.query(Criteria.where("isDelete").is(0).and("isSingle").is(0))
                  .limit(pageSize).skip((pageNum - 1) * pageSize), SyFeature.class);
          long count = mongoTemplate.count(Query.query(Criteria.where("isDelete").is(0).and("isSingle").is(0)), SyFeature.class);

          List<FeatureResultMsg> featureResultMsgs = new ArrayList<>();

          for (SyFeature feature : result) {
              FeatureResultMsg featureResultMsg = new FeatureResultMsg();
              featureResultMsg.setId(feature.getId());
              featureResultMsg.setName(feature.getName());
              featureResultMsg.setCount(feature.getCount());
              featureResultMsg.setCreateDate(feature.getCreateDate());
              featureResultMsgs.add(featureResultMsg);

          }

          return new PageResult<>((long) Math.ceil((double) count / pageSize), featureResultMsgs);

      }
  
      /**
       * 增加

       *
       * @return

       */
      @Override

      public String add(SyFeature feature) {

          String strDate = DateUtil.now();
          feature.setCount(0);
          feature.setCreateDate(strDate);
          feature.setUpdateDate(strDate);
          feature.setIsDelete(0);
          feature.setIsSingle(0);

          feature = mongoTemplate.insert(feature);
          return feature.getId();

      }
  
  
      /**
       * 修改

       *
       * @return

       */
      @Override

      public String update(SyFeature feature) {

          String now = DateUtil.now();
          feature.setUpdateDate(now);

          mongoTemplate.save(feature);
          return feature.getId();

      }
  
      /**
       * 根据ID获取实体
       *
       * @param id
       * @return
       */
      @Override

      public SyFeature findOne(String id) {
          return mongoTemplate.findOne(Query.query(Criteria.where("id").is(id)), SyFeature.class);

      }
  
      /**
       * 批量删除

       *
       * @param ids

       */
      @Override

      public void delete(List<String> ids) {

          for (String id : ids) {
              List<String> deployList = deployService.getDeployListByLibAndDeployType(id, 2);

              List<SyPersonnel> syPersonnels = mongoTemplate.find(Query.query(Criteria.where("fid").is(id)), SyPersonnel.class);

              mongoTemplate.updateMulti(Query.query(Criteria.where("fid").is(id)), Update.update("status", 1), SyPersonnel.class);

              if (syPersonnels.size() > 0) {

                  for (SyPersonnel syPersonnel : syPersonnels) {

                      redisTemplate.opsForHash().delete("personUrl", syPersonnel.getId());
                  }
              }
              if (deployList != null && deployList.size() > 0) {

                  for (String deployId : deployList) {

                      String key = deployId + "|" + id;
                      redisTemplate.opsForHash().delete(key);

                      String[] deploy = {deployId};

                      deployService.delete(Arrays.asList(deploy));

                  }
              }

          }

          mongoTemplate.updateMulti(Query.query(Criteria.where("id").in(ids)), Update.update("isDelete", 1), SyFeature.class);

      }
  
  
      @Override
      public PageResult findPage(SyFeature feature, int pageNum, int pageSize) {

          Criteria criteria = Criteria.where("isDelete").is(0);

          if (feature != null) {
              if (feature.getName() != null && feature.getName().length() > 0) {

                  criteria.and("name").regex(".*" + feature.getName() + ".*");

              }
              if (feature.getCreateDate() != null && feature.getCreateDate().length() > 0) {

                  criteria.and("createDate").regex(".*" + feature.getCreateDate() + ".*");

              }
              if (feature.getUpdateDate() != null && feature.getUpdateDate().length() > 0) {

                  criteria.and("updateDate").regex(".*" + feature.getUpdateDate() + ".*");

              }
              if (feature.getDescription() != null && feature.getDescription().length() > 0) {

                  criteria.and("description").regex(".*" + feature.getDescription() + ".*");

              }
          }

          List<SyFeature> syFeatures = mongoTemplate.find(Query.query(criteria).limit(pageSize).skip((pageNum - 1) * pageSize), SyFeature.class);
          long total = mongoTemplate.count(Query.query(criteria), SyFeature.class);
          return new PageResult<>((long) Math.ceil((double) total / pageSize), syFeatures);

      }
  
      /**
       * @param feature
       * @return
       */
      @Override

      public String updateCountById(SyFeature feature) {
          mongoTemplate.save(feature);
          return feature.getId();

      }
  
      @Override
      public List<Map<String, String>> findAllName() {
          List<Map<String, String>> list = new ArrayList<>();
          List<SyFeature> syFeatures = findAll();

          for (SyFeature feature : syFeatures) {
              Map<String, String> map = new HashMap<>(16);
              String name = feature.getName();
              String id = feature.getId();
              map.put("value", id + "");
              map.put("name", name);
              list.add(map);

          }

          return list;

      }
  }