From 0100793bc419cd6cb30ed8ab2de154e293764bb6 Mon Sep 17 00:00:00 2001
From: yechenhao <yechenhao>
Date: Mon, 18 May 2020 00:03:34 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=A7=E5=B1=8F=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../customer/service/CustomerViewService.java | 111 +++++++++---------
 1 file changed, 58 insertions(+), 53 deletions(-)

diff --git a/src/main/java/com/kiisoo/ic/customer/service/CustomerViewService.java b/src/main/java/com/kiisoo/ic/customer/service/CustomerViewService.java
index 82ade94..0f71931 100644
--- a/src/main/java/com/kiisoo/ic/customer/service/CustomerViewService.java
+++ b/src/main/java/com/kiisoo/ic/customer/service/CustomerViewService.java
@@ -722,61 +722,66 @@ public class CustomerViewService {
 
         //查询企业微信已配置联系我的用户
         int i = 0;
-        for (OpCustomer customer : customers) {
+        List<OpCustomer> opCustomers = customers.subList(132800, customers.size());
+        for (OpCustomer customer : opCustomers) {
             i++;
-            String wechatUniId = customer.getWechatUniId();
-            if (StringUtils.isBlank(wechatUniId)){
-                continue;
-            }
-            if (customer.getMemberId() != 0L){
-                continue;
-            }
-            String url = "";
-            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
-            Map<String, Object> params = new HashMap<>();
-            params.put("unionId", wechatUniId);
-            String message = HttpClientUtil.httpPost(vipBsdUrl + MD5FileUtil.getMD5String("BOSIDENG" + sdf.format(new Date())), JSONObject.toJSONString(params)).getMessage();
-            if (StringUtils.isBlank(message)){
-                continue;
-            }
-            System.out.println(i+"/"+customers.size()+"------"+message);
-            JSONObject vipJson = JSONObject.parseObject(message);
-            BsdVipResponse bsdResponse = vipJson.toJavaObject(BsdVipResponse.class);
-            if (bsdResponse.getSuccess() && bsdResponse.getData() != null){
-                MemberDtlDTO data = bsdResponse.getData();
-
-                OpCustomer opCustomer = new OpCustomer(data.getMemberName(), data.getMobileNo());
-                opCustomer.setUpdateBy(Constants.SYS_OPERATION);
-
-                // 根据手机号码去重
-                QueryWrapper<OpVip> wrapper = new QueryWrapper<>();
-                wrapper.eq("phone", data.getMobileNo()).last("limit 1");
-                OpVip opVip = opVipDOMapper.selectOne(wrapper);
-                OpVip opVip1 = new OpVip();
-                opVip1.setStatus(1L);
-                opVip1.setLevel(data.getMemberLevel().toString());
-                opVip1.setPhone(data.getMobileNo());
-                opVip1.setName(data.getMemberName());
-                opVip1.setBirthday(data.getBirthday());
-                opVip1.setRegisterTime(data.getCreateDate());
-                if (opVip == null) {
-                    //数据库没有这个数据--新建数据
-                    opVip1.setCreateBy(Constants.SYS_OPERATION);
-                    opVip1.setCreateTime(new Date());
-                    opVipDOMapper.insert(opVip1);
-                    //有vip信息就绑定信息
-                    opCustomer.setMemberId(opVip1.getId());
-                } else {
-                    opVip1.setId(opVip.getId());
-                    opVip1.setUpdateTime(new Date());
-                    opVip1.setUpdateBy(Constants.SYS_OPERATION);
-                    opVipDOMapper.updateById(opVip1);
-                    //有vip信息就绑定信息
-                    opCustomer.setMemberId(opVip.getId());
+            try{
+                String wechatUniId = customer.getWechatUniId();
+                if (StringUtils.isBlank(wechatUniId)){
+                    continue;
+                }
+                if (customer.getMemberId() != 0L){
+                    continue;
+                }
+                String url = "";
+                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+                Map<String, Object> params = new HashMap<>();
+                params.put("unionId", wechatUniId);
+                String message = HttpClientUtil.httpPost(vipBsdUrl + MD5FileUtil.getMD5String("BOSIDENG" + sdf.format(new Date())), JSONObject.toJSONString(params)).getMessage();
+                if (StringUtils.isBlank(message)){
+                    continue;
+                }
+                System.out.println(i+"/"+customers.size()+"------"+message);
+                JSONObject vipJson = JSONObject.parseObject(message);
+                BsdVipResponse bsdResponse = vipJson.toJavaObject(BsdVipResponse.class);
+                if (bsdResponse.getSuccess() && bsdResponse.getData() != null){
+                    MemberDtlDTO data = bsdResponse.getData();
+
+                    OpCustomer opCustomer = new OpCustomer(data.getMemberName(), data.getMobileNo());
+                    opCustomer.setUpdateBy(Constants.SYS_OPERATION);
+
+                    // 根据手机号码去重
+                    QueryWrapper<OpVip> wrapper = new QueryWrapper<>();
+                    wrapper.eq("phone", data.getMobileNo()).last("limit 1");
+                    OpVip opVip = opVipDOMapper.selectOne(wrapper);
+                    OpVip opVip1 = new OpVip();
+                    opVip1.setStatus(1L);
+                    opVip1.setLevel(data.getMemberLevel().toString());
+                    opVip1.setPhone(data.getMobileNo());
+                    opVip1.setName(data.getMemberName());
+                    opVip1.setBirthday(data.getBirthday());
+                    opVip1.setRegisterTime(data.getCreateDate());
+                    if (opVip == null) {
+                        //数据库没有这个数据--新建数据
+                        opVip1.setCreateBy(Constants.SYS_OPERATION);
+                        opVip1.setCreateTime(new Date());
+                        opVipDOMapper.insert(opVip1);
+                        //有vip信息就绑定信息
+                        opCustomer.setMemberId(opVip1.getId());
+                    } else {
+                        opVip1.setId(opVip.getId());
+                        opVip1.setUpdateTime(new Date());
+                        opVip1.setUpdateBy(Constants.SYS_OPERATION);
+                        opVipDOMapper.updateById(opVip1);
+                        //有vip信息就绑定信息
+                        opCustomer.setMemberId(opVip.getId());
+                    }
+                    QueryWrapper<OpCustomer> wrapper1 = new QueryWrapper<>();
+                    wrapper1.eq("wechat_uni_id", wechatUniId);
+                    opCustomerDOMapper.update(opCustomer, wrapper1);
                 }
-                QueryWrapper<OpCustomer> wrapper1 = new QueryWrapper<>();
-                wrapper1.eq("wechat_uni_id", wechatUniId);
-                opCustomerDOMapper.update(opCustomer, wrapper1);
+            }catch (Exception e){
+                log.error("同步vip出错",e);
             }
         }
     }