芝麻分从本地mongo中获取有效数据工具

###引言： 　　起因：java接入芝麻分，接口数据为了提高效率，需要储存在mongo中，若接口调用则优先从本地mongo库中查询是否存在有效数据。 ###mongo查询：

import com.alibaba.fastjson.util.TypeUtils;
import com.lemon.datamarket.dao.mongo.ManageRepository;
import com.lemon.datamarket.model.DataTransferObject;
import com.lemon.datamarket.utils.MongoDBUtils;
import com.lemon.datamarket.utils.zhima.AliConstants;
import com.lemon.datamarket.utils.zhima.DateUtils;
import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoCursor;
import org.bson.Document;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.text.ParseException;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.Map;

/**
 * Created by zhoudazhuang
 * Date: 17-1-13
 * Time: 下午3:14
 * Description : ali Mongo 仓库操作
 */
@Component
public class AliRepository {

    @Autowired
    private MongoDBUtils mongoDBUtils;

    @Value("${mongo.db_name}")
    private String databaseName;

    @Resource
    private ManageRepository manageRepository;

    /**
     * 保存集合
     * @param collectionName
     * @param poJo
     */
    public void save(String collectionName,Object poJo){
        TypeUtils.compatibleWithJavaBean = true;
        manageRepository.save(collectionName,poJo);
    }

    /**
     * 芝麻信用分接口本地查询
     * @param dataTransferObject
     * @param type 0 手机号入参 1 姓名 身份证入参
     * @return
     */
    public Map<String,Object> zhimaCreditScoreQuery(DataTransferObject dataTransferObject,int type) throws ParseException {
        //实例化mongoClient
        MongoClient mongoClient = mongoDBUtils.getMongoClient();
        //获取mongo集合入口
        MongoCollection<Document> mongoCollection = mongoClient.getDatabase(databaseName).getCollection(AliConstants.MARKET_ALI_ZHIMACREDITSCOREQUERY_MONGOCOLLECTION_NAME);
        //芝麻信用分的数据最大有效期一个月
        long threshold = System.currentTimeMillis() - 30 * 24 * 60 * 60 * 1000L;
        //实例化查询对象 并组装查询参数
        Document queryDocument = new Document();
        if(0 == type){//要求手机号进行查询
            queryDocument.append("phone", dataTransferObject.getPhone()).append("createTime", new Document().append("$gt", threshold));
        }else if(1 == type){
            queryDocument.append("name",dataTransferObject.getName()).append("idCard",dataTransferObject.getIdCard()).append("createTime",new Document().append("$gt", threshold));
        }
        //获得FindIterable
        FindIterable<Document> findIterable = mongoCollection.find(queryDocument).limit(1);//只使用第一条记录
        MongoCursor<Document> mongoCursor = findIterable.iterator();
        Map<String,Object> data = null;
        //遍历FindIterable并组装对象
        if (mongoCursor.hasNext()) {
            //如果存在则实例化过滤规则
            Date starttime = DateUtils.getMonthByNow(-1);//获取上个月6号 2016-12-06 00:00:00
            Date thisdate = DateUtils.getMonthByNow(0); //获取当前月6号  2016-1-06 00:00:00
            Date deadline = DateUtils.getMonthByNow(+1);//获取下一个6号  2016-2-06 00:00:00
            //判断当前时间区间范围
            Boolean bone =DateUtils.isBetweenDate(starttime,thisdate);
            Boolean btwo =DateUtils.isBetweenDate(thisdate,deadline);
            if(bone == true){//当前时间未超过当月6号
                Document document = mongoCursor.next();
                data = new LinkedHashMap<String,Object>();
                data.put("result", document.get("result"));
                data.put("openId", document.get("open_id"));
            }
            if(btwo == true){//当前时间已超过当月6号
                Document document = mongoCursor.next();
                //获取数据存储时间
                Date datatime = new Date(document.getLong("createTime"));
                if(DateUtils.isBetweenDateplus(thisdate,datatime,deadline)){
                    data = new LinkedHashMap<String,Object>();
                    data.put("result", document.get("result"));
                    data.put("openId", document.get("open_id"));
                }
            }
        }
        mongoCursor.close();

        return data;
    }

}

###java处理时间的工具类：

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;

/**
 * Created by zhoudazhuang
 * Date: 17-1-17
 * Time: 上午10:54
 * Description :阿里时间处理
 */
public class DateUtils {
    public static void main(String[] args) {
        Date starttime = DateUtils.getMonthByNow(-1);//获取上个月6号 2016-12-06 00:00:00
        Date thisdate = DateUtils.getMonthByNow(0); //获取当前月6号  2016-1-06 00:00:00
        Date deadline = DateUtils.getMonthByNow(+1);//获取下一个6号  2016-2-06 00:00:00
        Boolean b1 = DateUtils.isBetweenDate(starttime,thisdate);
        Boolean b2 = DateUtils.isBetweenDate(thisdate,deadline);
        System.out.println(b1);
        System.out.println(b2);
    }

    /**
     * 对比当前时间是否在指定区间内
     * @param starttime  starttime < now time < deadline
     * @param deadline
     * @return
     */
    public static boolean isBetweenDate(Date starttime,Date deadline){
        Date date = new Date();//需要修改这里为mongo拿出的芝麻数据存入时间
        if(date.after(starttime) && date.before(deadline)){
            return true;
        }
        return false;
    }

    /**
     * 对比第二个时间是否在指定第一个和最后一个区间内
     * @param starttime  starttime < now time < deadline
     * @param deadline
     * @return
     */
    public static boolean isBetweenDateplus(Date starttime,Date standertime,Date deadline){
        if(standertime.after(starttime) && standertime.before(deadline)){
            return true;
        }
        return false;
    }

    /**
     * 获取指定月的6号
     * @param month -1 从当前月减一月 +1 从当前月加一月
     * @return
     */
    public static Date getMonthByNow(int month){
        SimpleDateFormat simpleDateFormatMM = new SimpleDateFormat("yyyy-MM");
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Calendar c = Calendar.getInstance();

        c.setTime(new Date());
        c.add(Calendar.MONTH, month);
        Date mb = c.getTime();
        String mon = simpleDateFormatMM.format(mb);

        StringBuffer stringBuffer = new StringBuffer();
        stringBuffer.append(mon).append("-06 0:0:0");

        System.out.println(stringBuffer.toString());
        Date date = null;
        try {
            date = simpleDateFormat.parse(stringBuffer.toString());
        } catch (ParseException e) {
            e.printStackTrace();
        }
        return date;
    }


}

###附录 这里记录下mysql的时间以及order by，包括int,varchar,timestamp,data 表：

DROP TABLE IF EXISTS `test`;
/*!40101 SET @saved_cs_client     = @@character_set_client */;
/*!40101 SET character_set_client = utf8 */;
CREATE TABLE `test` (
  `id` int(11) NOT NULL,
  `time` varchar(45) DEFAULT NULL,
  `timestamp` timestamp NULL DEFAULT NULL,
  `date` date DEFAULT NULL,
  `str` varchar(45) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

测试sql

SELECT * FROM chargeManager.test;
set sql_safe_updates = 0;
select unix_timestamp('2009-10-26 10-06-07');
UPDATE `chargeManager`.`test` SET `timestamp`=1256522767 WHERE `id`='1';
SELECT * FROM chargeManager.test where str >2 order by id desc;#int
SELECT * FROM chargeManager.test where date > '2009-10-26' order by time desc;#varchar date > 需要 ‘’
SELECT * FROM chargeManager.test where time > 100 order by test.timestamp desc;#timestamp
SELECT * FROM chargeManager.test where id>1 order by test.date desc;

注：varchar中若为”123”等数字类型字符串，则类int排序，而timestamp插入时间戳，由于在时间戳的存储中常用int或varchar，所以注意若使用sql操作timestamp时，传入的需为datatime类型，既不是int，也不是varchar.