取消延时客服0-6点不发的限制

src/main/java/com/yaoyaozw/customer/service/impl/CustomerDelayPublishServiceImpl.java

@@ -100,7 +100,7 @@ public class CustomerDelayPublishServiceImpl extends ServiceImpl<CustomerDelayPu
                         registerUserEntities.add(delayPublishFuture.get()) ;
 
                     } catch (InterruptedException | ExecutionException e) {
-                        e.printStackTrace();
+                        localLog.error("get future result error {}", e.getMessage(), e);
                     }
                 }
                 if (!registerUserEntities.isEmpty()){

src/main/java/com/yaoyaozw/customer/service/wechat/service/WeChatServiceImpl.java

@@ -64,51 +64,45 @@ public class WeChatServiceImpl implements WeChatService{
     public Future<CustomerDelayPublish> sendCustomerDelayMessage( String appid,String token , CustomerDelayPublish user,
                                                                   Map<Integer,List<CustomerDelayItemVO>> delaySortMap,
                                                                   Set<CustomerDelayItemVO> needUpdateVoList) {
-        //获取当前小时数
-        Calendar instance = Calendar.getInstance();
-        int i = instance.get(Calendar.HOUR_OF_DAY);
-        //早上0-6点不发
-        if (i>=FORBID_TIME){
-            //token
-            UriComponentsBuilder uriComponentsBuilder = UriComponentsBuilder.fromHttpUrl(customerPath).queryParam(ACCESS_TOKEN,token);
-            //找到延时序列
-            List<CustomerDelayItemVO> sendCustomerDelays = delaySortMap.get(user.getCustomerSort());
+        //token
+        UriComponentsBuilder uriComponentsBuilder = UriComponentsBuilder.fromHttpUrl(customerPath).queryParam(ACCESS_TOKEN,token);
+        //找到延时序列
+        List<CustomerDelayItemVO> sendCustomerDelays = delaySortMap.get(user.getCustomerSort());
 
-            if (sendCustomerDelays!=null){
-                //找付费类型
-                List<CustomerDelayItemVO> collect = sendCustomerDelays.stream().filter(a -> a.getIsPay().equals(-1)||user.getPayType().equals(a.getIsPay()) ).collect(Collectors.toList());
+        if (sendCustomerDelays!=null){
+            //找付费类型
+            List<CustomerDelayItemVO> collect = sendCustomerDelays.stream().filter(a -> a.getIsPay().equals(-1)||user.getPayType().equals(a.getIsPay()) ).collect(Collectors.toList());
 
-                if (!collect.isEmpty()){
+            if (!collect.isEmpty()){
 
-                    CustomerDelayItemVO sendCustomerDelay = collect.get(0);
+                CustomerDelayItemVO sendCustomerDelay = collect.get(0);
 
-                    needUpdateVoList.add(sendCustomerDelay);
-                    //构建请求参数
-                    WeChatCustomerRequestEntity customerRequest = buildCustomerRequest(sendCustomerDelay);
+                needUpdateVoList.add(sendCustomerDelay);
+                //构建请求参数
+                WeChatCustomerRequestEntity customerRequest = buildCustomerRequest(sendCustomerDelay);
 
-                    if (customerRequest!=null){
+                if (customerRequest!=null){
 
-                        customerRequest.setTouser(user.getOpenId());
+                    customerRequest.setTouser(user.getOpenId());
 
-                        try {
-                            WeChatResponseEntity response=(WeChatResponseEntity)weChatRestService.httpPostRequest(uriComponentsBuilder,  customerRequest,WeChatResponseEntity.class);
+                    try {
+                        WeChatResponseEntity response=(WeChatResponseEntity)weChatRestService.httpPostRequest(uriComponentsBuilder,  customerRequest,WeChatResponseEntity.class);
 
-                            if(SUCCESS_CODE.equals(response.getErrcode())){
-                                //发送成功计数
-                                sendCustomerDelay.updateSendNum();
+                        if(SUCCESS_CODE.equals(response.getErrcode())){
+                            //发送成功计数
+                            sendCustomerDelay.updateSendNum();
 
-                            }else if(EXPIRED_CODE.equals(response.getErrcode()) ){
+                        }else if(EXPIRED_CODE.equals(response.getErrcode()) ){
 
-                                Object tokenObject = redisTemplate.opsForHash().get(ACCESS_TOKEN_REDIS_KEY, appid);
+                            Object tokenObject = redisTemplate.opsForHash().get(ACCESS_TOKEN_REDIS_KEY, appid);
 
-                                if (tokenObject!=null){
+                            if (tokenObject!=null){
 
-                                    return sendCustomerDelayMessage(appid,tokenObject.toString(),user,delaySortMap,needUpdateVoList);
-                                }
+                                return sendCustomerDelayMessage(appid,tokenObject.toString(),user,delaySortMap,needUpdateVoList);
                             }
-                        } catch (Exception e) {
-                            e.printStackTrace();
                         }
+                    } catch (Exception e) {
+                        e.printStackTrace();
                     }
                 }
             }