redis关键词

yujian

2020-01-03 c9cbdfa41d645d42eeaa7e06d550d4ef8ac328e7

redis关键词

 fanli/src/main/java/com/yeshi/fanli/controller/AuthCallBackController.java

@@ -27,6 +27,7 @@
import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;

import com.yeshi.fanli.util.AESUtil;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TaoBaoConstant;

@@ -78,7 +79,7 @@
        }



        try {

            String key = StringUtil.Md5("taobao-code-" + code);

            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoCode, code);

            if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key)))

                return;

            redisManager.cacheCommonString(key, 1 + "", 5);


 fanli/src/main/java/com/yeshi/fanli/controller/admin/UploadController.java

@@ -28,6 +28,7 @@
import com.yeshi.fanli.util.CMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.FilePathEnum;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

@@ -149,7 +150,7 @@
                while (its.hasNext()) {

                    String key = its.next();

                    List<TaoBaoOrder> orders = map.get(key);

                    String redisKey = "addorderqueue-" + key;

                    String redisKey = RedisKeyEnum.getRedisKey(RedisKeyEnum.addOrderQueue, key);

                    // redis做频率限制

                    if (Constant.IS_OUTNET) {

                        try {


 fanli/src/main/java/com/yeshi/fanli/controller/client/v1/GoodsClassController.java

@@ -50,6 +50,7 @@
import com.yeshi.fanli.service.inter.monitor.MonitorService;

import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

@@ -795,7 +796,7 @@
        if (id == null)

            return;

        page = page < 1 ? 1 : page;

        String key = String.format("getCouponListByClass-%s-%s", id + "", page + "");

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.couponByClass, id + "-" + page);

        String resultStr = "";



        if (Constant.IS_OUTNET)


 fanli/src/main/java/com/yeshi/fanli/controller/client/v1/RecommendController.java

@@ -111,6 +111,7 @@
import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TaoBaoConstant;

@@ -1305,8 +1306,7 @@
         * 

         */

        // if (Constant.IS_OUTNET) {

        String key = "linkParse-" + acceptData.getDevice() + "-" + id;



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaolinkParse, acceptData.getDevice() + "-" + id);

        String value = redisManager.getCommonString(key);

        if (!StringUtil.isNullOrEmpty(value)) {

            out.print(JsonUtil.loadFalseResult(11, "请求频率限制"));

@@ -1827,8 +1827,8 @@
        nextTime.set(Calendar.MILLISECOND, 0);



        JSONArray array = null;

        String timekey = String.format("spikeGoods_hour-%s-%s", acceptData.getPlatform(), acceptData.getVersion());

        String cachekey = String.format("spikeGoodsList-%s-%s", acceptData.getPlatform(), acceptData.getVersion());

        String timekey = RedisKeyEnum.getRedisKey(RedisKeyEnum.spikeGoodsHour,acceptData.getPlatform() +"-"+acceptData.getVersion());

        String cachekey = RedisKeyEnum.getRedisKey(RedisKeyEnum.spikeGoodsList,acceptData.getPlatform() +"-"+acceptData.getVersion());



        String timeValue = redisManager.getCommonString(timekey);

        if (timeValue == null || !timeValue.equals(hour + "")) {


 fanli/src/main/java/com/yeshi/fanli/controller/client/v1/SMSController.java

@@ -16,6 +16,7 @@
import com.yeshi.fanli.service.inter.user.SMSService;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.annotation.RequestSerializableByKey;

@@ -143,10 +144,10 @@
            String cachekey = null;

            if (type == 1) {

                // 登录验证码

                cachekey = "sendMSNLoginCount" + phone;

                cachekey = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSLoginCount, phone + "" );

            } else if (type == 2) {

                // 绑定验证码

                cachekey = "sendMSNBindCount" + phone;

                cachekey = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSBindCount, phone + "" );

            }



            if (cachekey == null) {


 fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserAccountController.java

@@ -65,6 +65,7 @@
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.GsonUtil;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.ThreadUtil;

@@ -796,8 +797,7 @@
            return;

        }



        String key = "bindalipay-" + uid;



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.bindAlipay, uid + "");

        if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {

            out.print(JsonUtil.loadFalseResult(2, "服务器繁忙，请稍后重试"));

            return;

@@ -852,8 +852,7 @@
            return;

        }



        String key = "bindalipay-" + uid;



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.bindAlipay, uid + "");

        if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {

            out.print(JsonUtil.loadFalseResult(1001, "服务器繁忙，请稍后重试"));

            return;

@@ -943,8 +942,7 @@
            return;

        }



        String key = "bindalipay-" + uid;



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.bindAlipay, uid + "");

        if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {

            out.print(JsonUtil.loadFalseResult(1001, "服务器繁忙，请稍后重试"));

            return;


 fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserMsgController.java

@@ -76,6 +76,7 @@
import com.yeshi.fanli.service.inter.user.invite.MsgInviteDetailService;

import com.yeshi.fanli.service.inter.user.msg.MsgAccountDetailService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

@@ -519,7 +520,7 @@
            }



            // String key = "recommend-goods-user-" + uid;

            String key = "recommend-goods-user-" + device;

            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.recommendGoodsUser, device);

            if (Constant.IS_OUTNET) {

                if (canAdd && StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {

                    if (Constant.IS_OUTNET)


 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ConfigControllerV2.java

@@ -35,6 +35,7 @@
import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;

import com.yeshi.fanli.util.AESUtil;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TaoBaoConstant;

@@ -501,12 +502,13 @@
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult(1001, "请绑定淘宝")));

            return;

        }

        String elmeLink = redisManager.getCommonString("elme-link-" + uid);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.elmeLink, uid + "");

        String elmeLink = redisManager.getCommonString(key);

        if (StringUtil.isNullOrEmpty(elmeLink)) {

            elmeLink = TaoKeApiUtil.officialActivityConvert(TaoBaoConstant.TAOBAO_ELEME_PID.split("_")[3],

                    "1571715733668", userInfoExtra.getRelationId());

            if (!StringUtil.isNullOrEmpty(elmeLink)) {

                redisManager.cacheCommonString("elme-link-" + uid, elmeLink, 60 * 60);// 缓存1个小时

                redisManager.cacheCommonString(key, elmeLink, 60 * 60);// 缓存1个小时

            }

        }




 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/InviteControllerV2.java

@@ -44,6 +44,7 @@
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.VersionUtil;

@@ -135,8 +136,8 @@
            if (wxUnionId == null || wxUnionId.trim().length() == 0)

                throw new UserInfoExtraException(1, "微信授权失败");



            String activeWX = StringUtil.Md5("activeWX:" + weiXinUser.getUnionid());

            redisManager.cacheCommonString(activeWX, JsonUtil.getSimpleGson().toJson(weiXinUser), 60 * 20);

            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, StringUtil.Md5("activeWX:" + weiXinUser.getUnionid()));

            redisManager.cacheCommonString(key, JsonUtil.getSimpleGson().toJson(weiXinUser), 60 * 20);



            // 邀请关系用户信息

            UserInfo userInfo = userInfoExtraService.getInviterInfo(uid, wxUnionId);

@@ -145,7 +146,7 @@
            data.put("nickName", userInfo.getNickName());

            data.put("portrait", userInfo.getPortrait());

            data.put("tips", "确认要成为TA的直接粉丝吗？邀请关系一旦建立不可更改。");

            data.put("key", activeWX);

            data.put("key", key);

            out.print(JsonUtil.loadTrueResult(data));

        } catch (UserInfoExtraException e) {

            out.print(JsonUtil.loadFalseResult(e.getMsg()));


 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/RecommendControllerV2.java

@@ -50,6 +50,7 @@
import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsService;

import com.yeshi.fanli.tag.PageEntity;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TaoBaoConstant;

@@ -232,8 +233,10 @@
        }



        JSONArray array = null;

        String timekey = String.format("spikeGoods_hour_new-%s-%s", acceptData.getPlatform(), acceptData.getVersion());

        String cachekey = String.format("spikeGoodsList_new-%s-%s", acceptData.getPlatform(), acceptData.getVersion());

        String timekey = RedisKeyEnum.getRedisKey(RedisKeyEnum.spikeGoodsHourNew,acceptData.getPlatform() +"-"+acceptData.getVersion());

        String cachekey = RedisKeyEnum.getRedisKey(RedisKeyEnum.spikeGoodsListNew,acceptData.getPlatform() +"-"+acceptData.getVersion());



		
        Calendar nowCalendar = Calendar.getInstance();

        nowCalendar.setTimeInMillis(nowTime);

        int hour = nowCalendar.get(Calendar.HOUR_OF_DAY);


 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/S11Controller.java

@@ -13,6 +13,7 @@
import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

@@ -56,7 +57,7 @@
            return;

        }



        String key = "s11-superhongbao-" + info.getRelationId();

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.S11SuperHongBao, info.getRelationId() +"");

        String token = redisManager.getCommonString(key);

        if (StringUtil.isNullOrEmpty(token)) {

            try {


 fanli/src/main/java/com/yeshi/fanli/controller/h5/H5S11Controller.java

@@ -13,6 +13,7 @@
import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

@@ -56,7 +57,7 @@
            return;

        }



        String key = "s11-superhongbao-" + info.getRelationId();

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.S11SuperHongBao, info.getRelationId() +"");

        String token = null;

        token = redisManager.getCommonString(key);

        if (StringUtil.isNullOrEmpty(token)) {

@@ -107,7 +108,7 @@
            return;

        }



        String key = "s11-yushou-" + info.getRelationId();

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.S11YuShou, info.getRelationId() + "");

        String token = null;

        if (Constant.IS_OUTNET)

            token = redisManager.getCommonString(key);


 fanli/src/main/java/com/yeshi/fanli/controller/wxmp/v1/InviteController.java

@@ -58,7 +58,7 @@
    private ThreeSaleExtraInfoSerivce threeSaleExtraInfoSerivce;



    /**

     * 站内信提醒队员添加微信号

     * 专属邀请码条件

     * 

     * @param acceptData

     * @param uid

@@ -72,9 +72,32 @@
            return;

        }



        JSONArray array1 = new JSONArray();

        array1.add("1.邀请码可帮助好友激活邀请功能；");

        array1.add("2.好友通过你的邀请码激活邀请功能后，将成为你的直接粉丝，未来产生的订单你都有奖金；");

        array1.add("3.邀请码具有唯一性。");

		
        JSONObject desc1 = new JSONObject();

        desc1.put("title", "邀请码的作用");

        desc1.put("content",array1);

		
        JSONArray array2 = new JSONArray();

        array2.add("1.你可以自由设置4~12位简单易记的邀请码；");

        array2.add("2.专属邀请码是对你和你的团队尊贵身份的彰显。");

		
        JSONObject desc2 = new JSONObject();

        desc2.put("title", "专属邀请码优势");

        desc2.put("content",array2);

		
        JSONArray array = new JSONArray();

        array.add(desc1);

        array.add(desc2);

		
        JSONObject data = new JSONObject();

        data.put("desc", array);

        data.put("num", threeSaleSerivce.countFirstTeam(uid, 1));

        data.put("limit", Constant.INVITE_CODRE_TAILOR_LIMIT);

		
        out.print(JsonUtil.loadTrueResult(data));

    }




 fanli/src/main/java/com/yeshi/fanli/controller/wxmp/v1/UserAccountController.java

@@ -55,6 +55,7 @@
import com.yeshi.fanli.service.inter.user.wx.WXMPUserLoginService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.ThreadUtil;

@@ -183,8 +184,8 @@


        UserInfo lastUserInfo = null;

        if (!StringUtil.isNullOrEmpty(userData)) {

            String key = StringUtil.Md5("wxmp-user-login-" + acceptData.getAppId() + "-" + acceptData.getOpenId());

            String data = redisManager.getCommonString(key);

            String redisKey = RedisKeyEnum.getRedisKey(RedisKeyEnum.wxmpUserLogin, StringUtil.Md5(acceptData.getAppId() + "-" + acceptData.getOpenId()));

            String data = redisManager.getCommonString(redisKey);

            if (!StringUtil.isNullOrEmpty(data)) {

                lastUserInfo = new Gson().fromJson(data, UserInfo.class);

            }

@@ -251,7 +252,8 @@
            return;

        }



        String key = StringUtil.Md5("wxmp-user-login-" + acceptData.getAppId() + "-" + acceptData.getOpenId());

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.wxmpUserLogin, StringUtil.Md5(acceptData.getAppId() + "-" + acceptData.getOpenId()));



        UserInfo user = new Gson().fromJson(redisManager.getCommonString(key), UserInfo.class);

        if (user == null) {

            out.print(JsonUtil.loadFalseResult("用户数据为空"));

@@ -286,7 +288,8 @@
    private void printWXMPLoginResult(String appId, String openId, WXMPLoginResult result, HttpServletRequest request,

            PrintWriter out) {

        JSONObject data = new JSONObject();

        String key = StringUtil.Md5("wxmp-user-login-" + appId + "-" + openId);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.wxmpUserLogin, StringUtil.Md5(appId + "-" + openId));



        switch (result.getCode()) {

        case WXMPLoginResult.CODE_SUCCESS:

            UserInfo user = userInfoService.selectAvailableByPrimaryKey(result.getUser().getId());


 fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java

@@ -15,6 +15,7 @@
import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.order.jd.JDOrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.cmq.JDOrderCMQManager;

@@ -52,7 +53,7 @@
                /**

                 * 做频率限制

                 */

                String key = "jd-order-" + order.getOrderId();

                String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.JDOrder,  order.getOrderId() + "" );

                String result = redisManager.getCommonString(key);

                // 判断




 fanli/src/main/java/com/yeshi/fanli/job/order/pdd/UpdatePDDOrderJob.java

@@ -14,6 +14,7 @@
import com.yeshi.fanli.exception.pdd.PDDOrderException;

import com.yeshi.fanli.service.inter.order.pdd.PDDOrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.cmq.PDDOrderCMQManager;

import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;

@@ -44,7 +45,7 @@
                /**

                 * 做频率限制

                 */

                String key = "pdd-order-" + order.getOrderSn();

                String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.PDDOrder, order.getOrderSn() + "" );

                String result = redisManager.getCommonString(key);

                // if (!StringUtil.isNullOrEmpty(result))

                // continue;


 fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateOrderJob.java

@@ -35,6 +35,7 @@
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;

import com.yeshi.fanli.util.CMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

@@ -206,7 +207,7 @@
                Iterator<String> its = map.keySet().iterator();

                while (its.hasNext()) {

                    String key = its.next();

                    String redisKey = "addorderqueue-" + key;

                    String redisKey = RedisKeyEnum.getRedisKey(RedisKeyEnum.addOrderQueue, key);

                    // redis做频率限制

                    try {

                        if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(redisKey))) {

@@ -412,7 +413,8 @@
                List<TaoBaoOrder> taoBaoOrderList = taoBaoOrderService.getTaoBaoOrderByOrderId(lo.getOrderId());

                // 清除频率限制

                if (taoBaoOrderList != null && taoBaoOrderList.size() > 0) {

                    String key = "addorderqueue-" + lo.getOrderId();

                    String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.addOrderQueue, lo.getOrderId());



                    redisManager.removeCommonString(key);

                    addOrder(taoBaoOrderList);

                    LogHelper.test("自动处理淘宝订单:" + lo.getOrderId());


 fanli/src/main/java/com/yeshi/fanli/job/order/taobao/UpdateTBRelationAndSpecialOrderJob.java

@@ -15,6 +15,7 @@
import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;

import com.yeshi.fanli.util.CMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

@@ -106,8 +107,7 @@
                while (its.hasNext()) {

                    String key = its.next();

                    List<TaoBaoOrder> orders = map.get(key);

                    String redisKey = "addorderqueue-" + TaoBaoOrderUtil.getOrderDataHashCode(orders);

                    ;

                    String redisKey = RedisKeyEnum.getRedisKey(RedisKeyEnum.addOrderQueue, TaoBaoOrderUtil.getOrderDataHashCode(orders));

                    // redis做频率限制

                    try {

                        if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(redisKey))) {


 fanli/src/main/java/com/yeshi/fanli/service/impl/goods/TaoBaoCouponServiceImpl.java

@@ -23,6 +23,7 @@
import com.yeshi.fanli.service.inter.goods.TaoBaoCouponService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.taobao.TaoBaoCouponUtil;

@@ -114,7 +115,7 @@
    @Override

    public List<TaoBaoGoodsBrief> getTaoBaoCouponList(int page) {

        System.out.println("进入了方法");

        String key = "cachecoupon-" + page;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoCachecoupon, page +"");

        String resultStr = "";

        try {

            resultStr = redisManager.getCommonString(key);


 fanli/src/main/java/com/yeshi/fanli/service/impl/lable/QualityFactoryServiceImpl.java

@@ -32,6 +32,7 @@
import com.yeshi.fanli.service.inter.lable.QualityFlashSaleService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

@@ -329,7 +330,7 @@
     * @return

     */

    public String getLabelIdByRedis(String key, String title) throws Exception {



        key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, key);

        String value = redisManager.getCommonString(key);



        if (StringUtil.isNullOrEmpty(value)) {


 fanli/src/main/java/com/yeshi/fanli/service/impl/order/tb/TaoBaoOrderServiceImpl.java

@@ -22,6 +22,7 @@
import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;

@@ -56,7 +57,7 @@
        Iterator<String> its = map.keySet().iterator();

        while (its.hasNext()) {

            String orderId = its.next();

            String key = "addorder-" + TaoBaoOrderUtil.getOrderDataHashCode(map.get(orderId));

            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.addOrder, TaoBaoOrderUtil.getOrderDataHashCode(map.get(orderId)));

            // redis做频率限制

            try {

                if (Constant.IS_OUTNET) {


 fanli/src/main/java/com/yeshi/fanli/service/impl/special/S11ServiceImpl.java

@@ -21,6 +21,7 @@
import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.special.S11Service;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

@@ -91,7 +92,7 @@
    @Cacheable(value = "s11Cache", key = "'getPreSaleGoodsCache'+#page")

    @Override

    public List<TaoBaoGoodsBrief> getPreSaleGoodsCache(int page) {

        String key = "s11_presale_goods-" + page;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.S11PresaleGoods, page +"");

        try {

            String resultStr = redisManager.getCommonString(key);

            if (!StringUtil.isNullOrEmpty(resultStr)) {

@@ -105,8 +106,7 @@
        TaoBaoSearchResult result = TaoKeApiUtil.getMaterialByMaterialId(8452, page, Constant.PAGE_SIZE);

        if (result != null && result.getTaoBaoGoodsBriefs() != null && result.getTaoBaoGoodsBriefs().size() > 0) {

            try {

                redisManager.cacheCommonString("s11_presale_goods-" + page,

                        new Gson().toJson(result.getTaoBaoGoodsBriefs()), 60 * 60);// 缓存1小时

                redisManager.cacheCommonString(key,    new Gson().toJson(result.getTaoBaoGoodsBriefs()), 60 * 60);// 缓存1小时

            } catch (Exception e) {

            }

            return result.getTaoBaoGoodsBriefs();

@@ -156,7 +156,7 @@
        sf.setPage(page);

        sf.setPageSize(Constant.PAGE_SIZE);



        String key = "s11_presale_goods-type-" + type + "-" + page;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.S11PresaleGoodsType, type + "-" + page);

        try {

            String resultStr = redisManager.getCommonString(key);

            if (!StringUtil.isNullOrEmpty(resultStr)) {


 fanli/src/main/java/com/yeshi/fanli/service/impl/user/SMSServiceImpl.java

@@ -13,6 +13,7 @@
import com.yeshi.fanli.service.inter.user.SMSService;

import com.yeshi.fanli.util.AliyunSMSUtil;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TencentSMSUtil;

@@ -34,7 +35,7 @@
        if (limit)

            throw new SMSException(1001, "请过60秒再试");



        String key = StringUtil.Md5("sms-login-tencent-latest-" + phone);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, StringUtil.Md5("sms-login-tencent-latest-" + phone));



        String msgCode = StringUtil.getVerifyCode(codeLength);

        // 验证码模板


 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserAccountServiceImpl.java

@@ -62,6 +62,7 @@
import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.FilePathEnum;

import com.yeshi.fanli.util.FileUtil;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.ThreadUtil;

@@ -1019,7 +1020,9 @@
        // 清空限制

        redisManager.clearSMSFrequencyLimit(phone, SMSHistory.TYPE_LOGIN);

        // 清理次数

        redisManager.removeCommonString("sendMSNLoginCount" + phone);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSLoginCount, phone);

        redisManager.removeCommonString(key);





        // 采用redis事务防止一个手机号多次注册问题

        String watchKey = StringUtil.Md5("REGISTER:" + phone);

@@ -1206,9 +1209,9 @@


        UserInfo userInfo = userInfoMapper.getEffectiveUserInfoByWXUnionId(weiXinUser.getUnionid());

        if (userInfo == null) {

            String longinKey = StringUtil.Md5("WXLogin:" + weiXinUser.getUnionid());

            redisManager.cacheCommonString(longinKey, JsonUtil.getSimpleGson().toJson(weiXinUser), 60 * 20);

            throw new UserAccountException(101, longinKey);

            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, StringUtil.Md5("WXLogin:" + weiXinUser.getUnionid()));

            redisManager.cacheCommonString(key, JsonUtil.getSimpleGson().toJson(weiXinUser), 60 * 20);

            throw new UserAccountException(101, key);

        }

        // 更新账户登录信息

        updateLonginInfo(userInfo, loginType, request);


 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java

@@ -52,6 +52,7 @@
import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.FilePathEnum;

import com.yeshi.fanli.util.ImageUtil;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.factory.CommonGoodsFactory;

@@ -677,7 +678,7 @@
        recordDTO.setSource(ShareSourceTypeEnum.goodsDetail);



        // 分享id

        String key = StringUtil.Md5(uid + "#GoodsDetail#" + auctionId + "#Type#" + goodsType);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, StringUtil.Md5(uid + "#GoodsDetail#" + auctionId + "#Type#" + goodsType));

        redisManager.cacheCommonString(key, JsonUtil.getSimpleGson().toJson(recordDTO), 60 * 20);

        recordDTO.setRedisKey(key);



@@ -720,7 +721,7 @@
        recordDTO.setSource(ShareSourceTypeEnum.storage);



        // 缓存分享商品信息

        String key = StringUtil.Md5(uid + "#GoodsStorage#" + id);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, StringUtil.Md5(uid + "#GoodsStorage#" + id));

        recordDTO.setRedisKey(key);



        redisManager.cacheCommonString(key, JsonUtil.getSimpleGson().toJson(recordDTO), 60 * 20);

@@ -761,7 +762,7 @@
        recordDTO.setSource(ShareSourceTypeEnum.storage);



        // 缓存分享商品信息

        String key = StringUtil.Md5(uid + "#GoodsStorage#" + id);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey,StringUtil.Md5(uid + "#GoodsStorage#" + id));

        recordDTO.setRedisKey(key);



        redisManager.cacheCommonString(key, JsonUtil.getSimpleGson().toJson(recordDTO), 60 * 20);

@@ -805,7 +806,7 @@
        recordDTO.setSharePictureUrl(uploadResult.getUrl());

        recordDTO.setSource(ShareSourceTypeEnum.activity);

        // 缓存分享商品信息

        String key = StringUtil.Md5(uid + "#Activity#" + id);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, StringUtil.Md5(uid + "#Activity#" + id));

        recordDTO.setRedisKey(key);



        redisManager.cacheCommonString(key, JsonUtil.getSimpleGson().toJson(recordDTO), 60 * 20);

@@ -846,7 +847,7 @@
        recordDTO.setSource(ShareSourceTypeEnum.activity);



        // 缓存分享商品信息

        String key = StringUtil.Md5(uid + "#Dynamic#" + id);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, StringUtil.Md5(uid + "#Dynamic#" + id));

        recordDTO.setRedisKey(key);



        redisManager.cacheCommonString(key, JsonUtil.getSimpleGson().toJson(recordDTO), 60 * 20);

@@ -860,7 +861,8 @@
            throw new UserShareGoodsRecordException(1, "传递参数不正确");

        }

        ShareGoodsRecordDTO recordDTO = null;

        String value = redisManager.getCommonString(shareKey);

        String redisKey = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, shareKey);

        String value = redisManager.getCommonString(redisKey);

        if (!StringUtil.isNullOrEmpty(value)) {

            recordDTO = JsonUtil.getSimpleGson().fromJson(value, ShareGoodsRecordDTO.class);

        }

@@ -918,7 +920,7 @@
        }



        // 清理缓存

        redisManager.removeCommonString(shareKey);

        redisManager.removeCommonString(redisKey);



        if (singleGoods) {

            if (taolijin) {


 fanli/src/main/java/com/yeshi/fanli/service/manger/goods/jd/JDGoodsLinkParseManager.java

@@ -4,6 +4,7 @@


import org.springframework.stereotype.Component;



import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.jd.JDUtil;

@@ -27,7 +28,7 @@
     * @return

     */

    public String parseGoodsIdByJDShortUrl(String shortLink) {

        String key = "jd-link-to-goods-" + StringUtil.Md5(shortLink);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.JDShortUrl, StringUtil.Md5(shortLink));

        String value = redisManager.getCommonString(key);

        if (!StringUtil.isNullOrEmpty(value)) {

            return value;


 fanli/src/main/java/com/yeshi/fanli/util/RedisManager.java

@@ -151,7 +151,7 @@
    public void saveTaoBaoGoodsBriefTemp(TaoBaoGoodsBrief goods) {

        if (goods == null)

            return;

        String key = "taobao-goods-temp-" + goods.getAuctionId();

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsTemp, goods.getAuctionId() + "");

        if (Constant.IS_OUTNET) {

            // 暂存4个小时的分享

            cacheCommonString(key, JsonUtil.getSimpleGson().toJson(goods), 60 * 60 * 4);

@@ -159,7 +159,7 @@
    }



    public TaoBaoGoodsBrief getTaoBaoGoodsTemp(Long auctionId) {

        String key = "taobao-goods-temp-" + auctionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsTemp, auctionId + "");

        String value = getCommonString(key);

        if (!StringUtil.isNullOrEmpty(value)) {

            return JsonUtil.getSimpleGson().fromJson(value, TaoBaoGoodsBrief.class);

@@ -173,14 +173,14 @@
     * @param auctionId

     */

    public void deleteTaoBaoGoodsBrief(Long auctionId) {

        String key = "taobao-goods-" + auctionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoods, auctionId + "");

        if (Constant.IS_OUTNET)

            removeKey(key);

    }



    public TaoBaoGoodsBrief getTaoBaoGoodsBrief(long auctionId) throws TaobaoGoodsDownException {

        long startTime = System.currentTimeMillis();

        String key = "taobao-goods-" + auctionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoods, auctionId + "");

        String value = "";

        if (Constant.IS_OUTNET)

            value = getCommonString(key);

@@ -202,7 +202,7 @@
    }



    public List<ImageInfo> getTaoBaoGoodsDetailImgs(long auctionId) {

        String key = "taobao-goods-detailimgs-size-" + auctionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsDetailimgs, auctionId + "");

        String value = "";

        if (Constant.IS_OUTNET)

            value = getCommonString(key);

@@ -231,7 +231,7 @@


    public String getXCXCouponToken(TaoBaoGoodsBrief tb) {

        List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);

        String key = "taobao-couple-xcx-" + tb.getAuctionId();

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoCoupleXCX, tb.getAuctionId() + "");

        String value = "";

        if (Constant.IS_OUTNET)

            value = getCommonString(key);

@@ -254,7 +254,7 @@
     * @param ip

     */

    public boolean ipFrequencyLimit(String ip, String apiName) {

        String key = ip + "-" + StringUtil.Md5(apiName);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, ip + "-" + StringUtil.Md5(apiName));

        Jedis jedis = jedisPool.getResource();

        try {

            long count = jedis.incr(key);

@@ -270,7 +270,7 @@
    }



    public boolean frequencyLimit(String key, int timeS, int num) {

        key = "frequency-" + key;

        key = RedisKeyEnum.getRedisKey(RedisKeyEnum.frequencyLimit, key);

        Jedis jedis = jedisPool.getResource();

        try {

            long count = jedis.incr(key);

@@ -292,7 +292,7 @@
     * @return

     */

    public List<String> getTBImg(Long auctionId) {

        String key = "taobao-img-" + auctionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoImgs, auctionId + "");

        String value = "";

        if (Constant.IS_OUTNET)

            value = getCommonString(key);

@@ -321,7 +321,7 @@
     * @return

     */

    public TaoBaoShopInfo getTBShopInfo(String shopTitle, Long sellerId, Long auctionId) {

        String key = "taobao-shop-" + sellerId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoShop, sellerId +"");

        String value = "";

        if (Constant.IS_OUTNET)

            value = getCommonString(key);

@@ -370,7 +370,7 @@
    public boolean isSmsFrequencyLimit(String phone, int type) {

        if (!Constant.IS_OUTNET)

            return false;

        String key = "sms-" + phone + "-" + type;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMS,  phone + "-" + type);

        String value = getCommonString(key);

        if (StringUtil.isNullOrEmpty(value))

            return false;

@@ -387,14 +387,14 @@
    public void sendSms(String phone, int type) {

        if (!Constant.IS_OUTNET)

            return;

        String key = "sms-" + phone + "-" + type;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMS,  phone + "-" + type);

        setString(key, "1", 10);

    }



    public void clearSMSFrequencyLimit(String phone, int type) {

        if (!Constant.IS_OUTNET)

            return;

        String key = "sms-" + phone + "-" + type;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMS,  phone + "-" + type);

        removeKey(key);

    }



@@ -407,7 +407,7 @@
     */



    public void saveSMSVCode(String phone, int type, String code) {

        String key = "smscode-" + phone + "-" + type;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSVCode, phone + "-" + type);

        // 保存2分钟

        setString(key, code, 120);

    }

@@ -421,7 +421,7 @@
    public String getSMSVCode(String phone, int type) {

        // if (!Constant.IS_OUTNET)

        // return "";

        String key = "smscode-" + phone + "-" + type;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSVCode, phone + "-" + type);

        // 保存2分钟

        return getString(key);

    }

@@ -436,7 +436,7 @@
    public void clearSMSVCode(String phone, int type) {

        // if (!Constant.IS_OUTNET)

        // return;

        String key = "smscode-" + phone + "-" + type;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSVCode, phone + "-" + type);

        removeKey(key);

    }



@@ -444,8 +444,7 @@
     * 保存绑定支付宝短信验证码的正确性

     */

    public void saveBindAlipayAccountSMSState(String phone) {

        String key = "smsstate-alipay-" + phone;



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSStateAlipay, phone + "" );

        // 验证后十分钟有效

        setString(key, "1", 10 * 60);

    }

@@ -457,7 +456,7 @@
     * @return

     */

    public boolean isBindAlipayAccountSMSStateValid(String phone) {

        String key = "smsstate-alipay-" + phone;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.SMSStateAlipay, phone + "" );

        return !StringUtil.isNullOrEmpty(getString(key));

    }



@@ -469,8 +468,7 @@
     */

    public void setInviteShortLink(long uid, String shortlink) {

        String value = "";

        String key = "invite-shortlink-" + uid;



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.inviteShortLink, uid + "" );

        if (Constant.IS_OUTNET) {



            value = getCommonString(key);

@@ -489,10 +487,8 @@
     * @return

     */

    public String getInviteShortLink(long uid) {



        String value = "";

        String key = "invite-shortlink-" + uid;



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.inviteShortLink, uid + "" );

        if (Constant.IS_OUTNET)

            value = getCommonString(key);



@@ -506,7 +502,7 @@
     * @param token

     */

    public void saveCommonTaoToken(Long auctionId, String token) {

        String key = "taobao-common-token-" + auctionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenCommon, auctionId + "" );

        if (Constant.IS_OUTNET) {

            if (!StringUtil.isNullOrEmpty(token)) {

                // 口令缓存10天

@@ -522,8 +518,7 @@
     * @return

     */

    public String getCommonTaoToken(Long auctionId) {

        String key = "taobao-common-token-" + auctionId;



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenCommon, auctionId + "" );

        if (Constant.IS_OUTNET) {

            return getCommonString(key);

        }

@@ -537,7 +532,7 @@
     * @param token

     */

    public void saveTLJToken(String url, String token) {

        String key = "taobao-tlj-token-" + StringUtil.Md5(url);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenTLJ, StringUtil.Md5(url));

        if (Constant.IS_OUTNET) {

            if (!StringUtil.isNullOrEmpty(token)) {

                // 口令缓存10天

@@ -553,8 +548,7 @@
     * @return

     */

    public String getTLJToken(String url) {

        String key = "taobao-common-token-" + StringUtil.Md5(url);



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoTokenTLJ, StringUtil.Md5(url));

        if (Constant.IS_OUTNET) {

            return getCommonString(key);

        }

@@ -621,8 +615,7 @@
    }



    public JDGoods getJDGoods(long goodsId) {

        String key = "jingdong-goods-" + goodsId;



        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.jingDongGoods, goodsId +"");

        String value = getCommonString(key);

        if (StringUtil.isNullOrEmpty(value)) {

            JDGoods jdGoods = JDApiUtil.queryGoodsDetail(goodsId);

@@ -641,7 +634,7 @@
    }



    public PDDGoodsDetail getPDDGoodsDetail(long goodsId) {

        String key = "pinduoduo-goods-" + goodsId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.pinDuoDuoGoods, goodsId +"");



        String value = getCommonString(key);

        if (StringUtil.isNullOrEmpty(value)) {


 fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java

@@ -327,7 +327,7 @@
                                try {

                                    HongBaoV2 hongbao = map.get(handler);

                                    if (hongbao != null) {

                                        String key = "hongbao-fanli-" + hongbao.getId();

                                        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.hongBaoFanLi, hongbao.getId() + "");

                                        if (StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {

                                            // 处理之后要隔2小时再次进行处理

                                            redisManager.cacheCommonString(key, "1", 60 * 60 * 2);


 fanli/src/main/java/com/yeshi/fanli/util/cache/IntegralGetCacheManager.java

@@ -4,6 +4,7 @@


import org.springframework.stereotype.Component;



import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;



@@ -26,7 +27,8 @@
     * @param time

     */

    public void cacheSearchGoods(String device, Long time) {

        redisManager.cacheCommonString("integral-seacrh-goods-" + device, time + "", 60 * 5);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.seacrhGoods, device);

        redisManager.cacheCommonString(key, time + "", 60 * 5);

    }



    /**

@@ -36,7 +38,8 @@
     * @return

     */

    public Long getLastSearchTime(String device) {

        String value = redisManager.getCommonString("integral-seacrh-goods-" + device);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.seacrhGoods, device);

        String value = redisManager.getCommonString(key);

        if (StringUtil.isNullOrEmpty(value))

            return null;

        return Long.parseLong(value);

@@ -47,7 +50,8 @@
     * @param device

     */

    public void clearSearchTime(String device) {

        redisManager.removeCommonString("integral-seacrh-goods-" + device);

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.seacrhGoods, device);

        redisManager.removeCommonString(key);

    }



}


 fanli/src/main/java/com/yeshi/fanli/util/cache/JDGoodsCacheUtil.java

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


import com.google.gson.Gson;

import com.yeshi.fanli.entity.jd.JDGoods;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.jd.JDApiUtil;

@@ -27,7 +28,7 @@
            return;

        }

        // 保存20分钟

        String key = "JD-goods-" + goods.getSkuId();

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.JDGoods, goods.getSkuId() + "" );

        redisManager.cacheCommonString(key, new Gson().toJson(goods), 60 * 20);

    }



@@ -38,7 +39,7 @@
     * @return

     */

    public JDGoods getGoodsInfo(long goodsId){

        String key = "JD-goods-" + goodsId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.JDGoods, goodsId + "");

        String value = redisManager.getCommonString(key);

        if (!StringUtil.isNullOrEmpty(value)) {

            return JsonUtil.getSimpleGson().fromJson(value, JDGoods.class);


 fanli/src/main/java/com/yeshi/fanli/util/cache/PinDuoDuoCacheUtil.java

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


import com.google.gson.Gson;

import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;

@@ -25,7 +26,7 @@
            return;

        }

        // 保存20分钟

        String key = "PDD-goods-" + goods.getGoodsId();

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.PDDGoods, goods.getGoodsId() + "" );

        redisManager.cacheCommonString(key, new Gson().toJson(goods), 60 * 20);

    }



@@ -36,7 +37,7 @@
     * @return

     */

    public PDDGoodsDetail getGoodsInfo(long goodsId){

        String key = "PDD-goods-" + goodsId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.PDDGoods, goodsId + "");

        String value = redisManager.getCommonString(key);

        if (!StringUtil.isNullOrEmpty(value)) {

            return JsonUtil.getSimpleGson().fromJson(value, PDDGoodsDetail.class);


 fanli/src/main/java/com/yeshi/fanli/util/cache/TaoBaoGoodsCacheUtil.java

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


import com.google.gson.Gson;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;



@@ -22,7 +23,7 @@
    public void saveCommonTaoBaoGoodsInfo(TaoBaoGoodsBrief goods) {

        if (goods == null || goods.getAuctionId() == null)

            return;

        String key = "taobao-goods-common-" + goods.getAuctionId();

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsCommon, goods.getAuctionId() + "");

        // 保存20分钟

        redisManager.cacheCommonString(key, new Gson().toJson(goods), 60 * 20);

    }

@@ -34,7 +35,7 @@
     * @return

     */

    public TaoBaoGoodsBrief getCommonTaoBaoGoodsInfo(long auctionId) {

        String key = "taobao-goods-common-" + auctionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoGoodsCommon, auctionId + "");

        String value = redisManager.getCommonString(key);

        if (!StringUtil.isNullOrEmpty(value)) {

            return new Gson().fromJson(value, TaoBaoGoodsBrief.class);

@@ -49,7 +50,7 @@
     * @return

     */

    public boolean canAddToUpdateQueue(Long auctionId) {

        String key = "tb-u-q-" + auctionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoQueue, auctionId + "");

        String value = redisManager.getCommonString(key);

        if (StringUtil.isNullOrEmpty(value))

            return true;

@@ -63,7 +64,7 @@
     * @param auctionId

     */

    public void addAddToQueueHistory(Long auctionId) {

        String key = "tb-u-q-" + auctionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoQueue, auctionId + "");

        redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 有效期2个小时

    }



@@ -74,7 +75,7 @@
     * @return

     */

    public boolean needUpdate(Long actionId) {

        String key = "tb-u-" + actionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoUpdate, actionId + "");

        String value = redisManager.getCommonString(key);

        if (StringUtil.isNullOrEmpty(value))

            return true;

@@ -89,7 +90,7 @@
     * @return

     */

    public void addUpdateHistory(Long actionId) {

        String key = "tb-u-" + actionId;

        String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoUpdate, actionId + "");

        redisManager.cacheCommonString(key, "1", 60 * 60 * 1);// 有效期1个小时

    }