2.1需求

yujian

2020-05-09 7e7db2fa55a9a3af46d4fd8ede0dee147f101d64

 fanli/src/main/java/com/yeshi/fanli/dao/user/ThreeSaleFocusInfoDao.java

@@ -1,6 +1,7 @@
package com.yeshi.fanli.dao.user;



import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import java.util.regex.Pattern;

@@ -35,7 +36,6 @@
      }

      mongoTemplate.save(record);

   }



   

   /**

    * 更新标签

@@ -83,6 +83,7 @@
   

   /**

    * 更新昵称

    * 
    * @param workerId

    * @param nickName

    */

@@ -97,9 +98,9 @@
      mongoTemplate.updateFirst(query, update, ThreeSaleFocusInfo.class);

   }

   

	
   /**

    * 更新是否有效粉丝

    * 
    * @param workerId

    * @param stateValid

    */

@@ -112,6 +113,7 @@
   

   /**

    * 更新淘宝绑定

    * 
    * @param workerId

    * @param taobaoBind

    */

@@ -124,6 +126,7 @@
   

   /**

    * 更新微信绑定

    * 
    * @param workerId

    * @param weixinBind

    */

@@ -136,6 +139,7 @@


   /**

    * 更新活跃时间

    * 
    * @param workerId

    * @param activeTime

    */

@@ -148,6 +152,7 @@


   /**

    * 更新粉丝数量

    * 
    * @param workerId

    * @param fansNum

    */

@@ -158,9 +163,9 @@
      mongoTemplate.updateFirst(query, update, ThreeSaleFocusInfo.class);

   }





   /**

    * 更新收入

    * 
    * @param workerId

    * @param income

    */

@@ -171,9 +176,9 @@
      mongoTemplate.updateMulti(query, update, ThreeSaleFocusInfo.class);

   }

   



   /**

    * 统计

    * 
    * @return

    */

   public ThreeSaleFocusInfo getbyWorkerId(Long workerId) {

@@ -196,6 +201,7 @@


   /**

    * 统计

    * 
    * @return

    */

   public long count(int type, Long uid, ThreeSaleFocusDTO focusDTO) {

@@ -203,65 +209,85 @@
      return mongoTemplate.count(query, ThreeSaleFocusInfo.class);

   }



	
   private Query createQuery(int type, Long uid, ThreeSaleFocusDTO focusDTO) {

      Query query = new Query();

      List<Criteria> list = new ArrayList<Criteria>();



      if (type == 1) {

         query.addCriteria(Criteria.where("bossId").is(uid));

         list.add(Criteria.where("bossId").is(uid));

      } else {

         query.addCriteria(Criteria.where("bossSuperId").is(uid));

         list.add(Criteria.where("bossSuperId").is(uid));

      }

      

      if (focusDTO == null) {

         return query;

      }

		
      if (focusDTO != null) {

      if (focusDTO.getStateValid() != null)

         query.addCriteria(Criteria.where("stateValid").is(focusDTO.getStateValid()));

            list.add(Criteria.where("stateValid").is(focusDTO.getStateValid()));

   

      if (focusDTO.getTaobaoBind() != null)

         query.addCriteria(Criteria.where("taobaoBind").is(focusDTO.getTaobaoBind()));

            list.add(Criteria.where("taobaoBind").is(focusDTO.getTaobaoBind()));

   

      if (focusDTO.getWeixinBind() != null)

         query.addCriteria(Criteria.where("weixinBind").is(focusDTO.getWeixinBind()));

            list.add(Criteria.where("weixinBind").is(focusDTO.getWeixinBind()));



         if (!StringUtil.isNullOrEmpty(focusDTO.getLevel()))

            list.add(Criteria.where("level").is(focusDTO.getLevel()));

   

      if (focusDTO.getMinFansNum() != null)

         query.addCriteria(Criteria.where("fansNum").lte(focusDTO.getMinFansNum()));

            list.add(Criteria.where("fansNum").lte(focusDTO.getMinFansNum()));

   

      if (focusDTO.getMinFansNum() != null)

         query.addCriteria(Criteria.where("fansNum").gte(focusDTO.getMinFansNum()));

         if (focusDTO.getMaxFansNum() != null)

            list.add(Criteria.where("fansNum").gte(focusDTO.getMaxFansNum()));

   

      if (focusDTO.getMinActiveTime() != null)

         query.addCriteria(Criteria.where("activeTime").lte(focusDTO.getMinActiveTime()));

         if (!StringUtil.isNullOrEmpty(focusDTO.getMinJoinTime()))

            list.add(Criteria.where("joinTime").lte(focusDTO.getMinJoinTime()));

   

      if (focusDTO.getMaxActiveTime() != null)

         query.addCriteria(Criteria.where("activeTime").gte(focusDTO.getMaxActiveTime()));

         if (!StringUtil.isNullOrEmpty(focusDTO.getMaxJoinTime()))

            list.add(Criteria.where("joinTime").gte(focusDTO.getMaxJoinTime()));



         if (!StringUtil.isNullOrEmpty(focusDTO.getMinActiveTime()))

            list.add(Criteria.where("activeTime").lte(focusDTO.getMinActiveTime()));



         if (!StringUtil.isNullOrEmpty(focusDTO.getMaxActiveTime()))

            list.add(Criteria.where("activeTime").gte(focusDTO.getMaxActiveTime()));

      

      if (focusDTO.getMinIncome() != null)

         query.addCriteria(Criteria.where("income").lte(focusDTO.getMinIncome()));

            list.add(Criteria.where("income").lte(focusDTO.getMinIncome()));

   

      if (focusDTO.getMaxIncome() != null)

         query.addCriteria(Criteria.where("income").gte(focusDTO.getMaxIncome()));

		
            list.add(Criteria.where("income").gte(focusDTO.getMaxIncome()));

      

      if (!StringUtil.isNullOrEmpty(focusDTO.getKey())) {

         if (type == 1) {

            query.addCriteria(new Criteria().orOperator(

                   Criteria.where("nickName").regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$", Pattern.CASE_INSENSITIVE)),

                         new Criteria().andOperator(Criteria.where("memoName").regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$", Pattern.CASE_INSENSITIVE))),

                         new Criteria().andOperator(Criteria.where("tags").regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$", Pattern.CASE_INSENSITIVE)))

                ));

               list.add(new Criteria().orOperator(   Criteria.where("nickName")

                                 .regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$",

                                       Pattern.CASE_INSENSITIVE)),

                           new Criteria().andOperator(Criteria.where("memoName")

                                 .regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$",

                                       Pattern.CASE_INSENSITIVE))),

                           new Criteria().andOperator(Criteria.where("tags").regex(Pattern

                                 .compile("^.*" + focusDTO.getKey() + ".*$", Pattern.CASE_INSENSITIVE)))));

         } else {

            query.addCriteria(new Criteria().orOperator(

                      Criteria.where("nickName").regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$", Pattern.CASE_INSENSITIVE)),

                            new Criteria().andOperator(Criteria.where("memoNameSup").regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$", Pattern.CASE_INSENSITIVE))),

                            new Criteria().andOperator(Criteria.where("tagsSup").regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$", Pattern.CASE_INSENSITIVE)))

                   ));

               list.add(new Criteria().orOperator(Criteria.where("nickName")

                                 .regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$",

                                       Pattern.CASE_INSENSITIVE)),

                           new Criteria().andOperator(Criteria.where("memoNameSup")

                                 .regex(Pattern.compile("^.*" + focusDTO.getKey() + ".*$",

                                       Pattern.CASE_INSENSITIVE))),

                           new Criteria().andOperator(Criteria.where("tagsSup").regex(Pattern

                                 .compile("^.*" + focusDTO.getKey() + ".*$", Pattern.CASE_INSENSITIVE)))));

         }

      }

      }



      if (list.size() > 0) {



         Criteria[] cas = new Criteria[list.size()];

         for (int i = 0; i < list.size(); i++)

            cas[i] = list.get(i);

         query.addCriteria(new Criteria().andOperator(cas));

      }



      return query;

   }

	
	
   

}