爬单bug修改

admin

2019-03-11 b8e73209c3cb6a6467b4f9e7efa60287e6d9e3dc

爬单bug修改

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

@@ -1274,7 +1274,7 @@
        String[] orderArr = order.split(",");

        for (String tbOrder : orderArr) {

            Order or = new Order();

            or.setBeizhu("系统添加");

            or.setBeizhu("接口添加");

            or.setCreatetime(java.lang.System.currentTimeMillis());

            or.setDrawbackTime(0L);

            or.setOrderId(tbOrder.trim());


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

@@ -102,11 +102,15 @@


    @Override

    public UserExtraTaoBaoInfo getByRelationId(String relationId) {

        if (StringUtil.isNullOrEmpty(relationId))

            return null;

        return userExtraTaoBaoInfoMapper.selectByRelationIdWithUidNotNull(relationId);

    }



    @Override

    public UserExtraTaoBaoInfo getBySpecialId(String specialId) {

        if (StringUtil.isNullOrEmpty(specialId))

            return null;

        return userExtraTaoBaoInfoMapper.selectBySpecialIdWithUidNotNull(specialId);

    }




 fanli/src/main/java/com/yeshi/fanli/util/push/IOSPushUtil.java

@@ -103,6 +103,9 @@
        }

        // 分组推送 每50个设备为一组



        InputStream certificate = IOSPushUtil.class.getClassLoader()

                .getResourceAsStream("certificate/pushCertificate.p12"); // 读取.p12文件

        String certificatePassword = Constant.systemCommonConfig.getIosPushCertificatePwd();

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

            int pageSize = 50;

            int page = tokenList.size() % pageSize == 0 ? tokenList.size() / pageSize : tokenList.size() / pageSize + 1;

@@ -111,7 +114,7 @@
                int end = start + pageSize;

                if (end > tokenList.size())

                    end = tokenList.size();

                pushIOS(tokenList.subList(start, end), json);

                pushIOS(tokenList.subList(start, end), json,certificate,certificatePassword);

            }



        }

@@ -119,14 +122,11 @@
        return null;

    }



    private static String pushIOS(List<String> deviceTokenList, JSONObject json) throws Exception {

    public static String pushIOS(List<String> deviceTokenList, JSONObject json,InputStream certificate,String certificatePWD) throws Exception {

        List<String> tokenList = new ArrayList<String>();

        for (String deviceToken : deviceTokenList) {

            tokenList.add(deviceToken);

        }

        InputStream certificate = IOSPushUtil.class.getClassLoader()

                .getResourceAsStream("certificate/pushCertificate.p12"); // 读取.p12文件

        String certificatePassword = Constant.systemCommonConfig.getIosPushCertificatePwd();// 此处注意导出的证书密码不能为空因为空密码会报错

        while (json.toString().getBytes().length > 256) {

            // 首先削减内容，然后削减标题

            String title = json.optJSONObject("aps").optJSONObject("alert").optString("title");

@@ -152,10 +152,10 @@
        // true：表示的是产品线上发布推送服务 false：表示的是产品测试推送服务

        if (Constant.IS_TEST)

            pushManager.initializeConnection(

                    new AppleNotificationServerBasicImpl(certificate, certificatePassword, false));

                    new AppleNotificationServerBasicImpl(certificate, certificatePWD, false));

        else

            pushManager

                    .initializeConnection(new AppleNotificationServerBasicImpl(certificate, certificatePassword, true));

                    .initializeConnection(new AppleNotificationServerBasicImpl(certificate, certificatePWD, true));



        List<Device> deviceList = new ArrayList<Device>();

        for (String token : tokenList) {

@@ -219,7 +219,10 @@
     * @throws Exception

     */

    public static void executePushIOS(List<String> tokenList, JSONObject json) throws Exception {

        pushIOS(tokenList, json);

        InputStream certificate = IOSPushUtil.class.getClassLoader()

                .getResourceAsStream("certificate/pushCertificate.p12"); // 读取.p12文件

        String certificatePassword = Constant.systemCommonConfig.getIosPushCertificatePwd();

        pushIOS(tokenList, json,certificate,certificatePassword);

    }



    /**


 fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeOrderApiUtil.java

@@ -6,7 +6,6 @@
import java.util.List;

import java.util.Map;



import com.taobao.api.TaobaoObject;

import com.yeshi.fanli.dto.order.OrderQuery;

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

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

@@ -21,6 +20,13 @@


//淘宝客API接口

public class TaoKeOrderApiUtil {

	
    public static int TK_STATUS_ALL=1;

    public static int TK_STATUS_SETTLEMENT=3;

    public static int TK_STATUS_PAY=12;

    public static int TK_STATUS_SUCCESS=14;

    public static int TK_STATUS_INVALID=13;

	
    /**

     * 获取会员订单

     *