add(backend) [消息处理 1.0]

operation-backend/src/main/java/com/idiot/operationbackend/controller/fans/FansMsgController.java

@@ -50,6 +50,7 @@ public class FansMsgController {
     @Autowired
     private AccountFansService fansService;
 
+
     @GetMapping("/msgRead")
     @ApiOperation(value = "查询公众号未读粉丝消息数量")
     public ResponseEntity<JsonResult<List<AccountMsgData>>> getFansMsgReadNum(@RequestHeader String token,

operation-backend/src/main/java/com/idiot/operationbackend/service/impl/EventMessageServiceImpl.java

@@ -1,7 +1,5 @@
 package com.idiot.operationbackend.service.impl;
 
-
-
 import com.idiot.operationbackend.entity.*;
 import com.idiot.operationbackend.handler.ScanQrHandler;
 import com.idiot.operationbackend.handler.WeChatMessageFactory;
@@ -9,15 +7,11 @@ import com.idiot.operationbackend.service.facade.*;
 import com.idiot.operationbackend.support.Constants;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
 
-import java.time.LocalTime;
 import java.util.HashMap;
-import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.function.Function;

operation-backend/src/main/java/com/idiot/operationbackend/service/impl/FansMsgServiceImpl.java

@@ -21,8 +21,6 @@ import java.util.List;
 public class FansMsgServiceImpl extends ServiceImpl<FansMsgMapper, FansMsg>
         implements FansMsgService {
 
-    private final int pageSize = 20;
-
     @Override
     public List<AccountMsgData> countFansMsgNumber(List<String> accountIds) {
 
@@ -35,7 +33,8 @@ public class FansMsgServiceImpl extends ServiceImpl<FansMsgMapper, FansMsg>
 
     @Override
     public List<FansMsg> queryFansMsg(String accountId, int page) {
-        int limitPre = (page-1)*pageSize;
+        int pageSize = 20;
+        int limitPre = (page-1)* pageSize;
         LambdaQueryWrapper<FansMsg> wrapper = Wrappers.<FansMsg>lambdaQuery()
                 .eq(FansMsg::getAccountId,accountId)
                 .eq(FansMsg::getRead,0)

operation-backend/src/main/java/com/idiot/operationbackend/service/impl/TextMessageServiceImpl.java

@@ -1,8 +1,5 @@
 package com.idiot.operationbackend.service.impl;
 
-
-
-import com.idiot.operationbackend.entity.Account;
 import com.idiot.operationbackend.entity.FansActionStat;
 import com.idiot.operationbackend.entity.FansMsg;
 import com.idiot.operationbackend.handler.WeChatMessageFactory;

operation-backend/src/main/java/com/idiot/operationbackend/service/impl/VideoMessageServiceImpl.java

@@ -0,0 +1,42 @@
+package com.idiot.operationbackend.service.impl;
+
+import com.idiot.operationbackend.entity.FansActionStat;
+import com.idiot.operationbackend.handler.WeChatMessageFactory;
+import com.idiot.operationbackend.service.facade.FansActionStatService;
+import com.idiot.operationbackend.service.facade.WeChatMessageService;
+import com.idiot.operationbackend.service.facade.WeChatService;
+import com.idiot.operationbackend.support.Constants;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
+
+/**
+ * 视频消息
+ * @author wang xiao
+ * @date Created in 9:54 2020/9/25
+ */
+@Service
+public class VideoMessageServiceImpl  implements WeChatMessageService {
+
+    @Autowired
+    private WeChatService weChatService;
+
+    @Autowired
+    private FansActionStatService fansActionStatService;
+
+    @Override
+    public String processMessage(Map<String, String> param) {
+        String accountId = param.get("accountId");
+        String openId = param.get("FromUserName");
+        FansActionStat var2 = new FansActionStat(accountId,openId,0);
+        fansActionStatService.saveBatchFansActionStat(var2);
+        weChatService.sendPushMessage(accountId,openId,1);
+        return Constants.SUCCESS;
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        WeChatMessageFactory.addService("voice",this);
+    }
+}

operation-backend/src/main/java/com/idiot/operationbackend/service/impl/VoiceMessageServiceImpl.java

@@ -0,0 +1,42 @@
+package com.idiot.operationbackend.service.impl;
+
+import com.idiot.operationbackend.entity.FansActionStat;
+import com.idiot.operationbackend.handler.WeChatMessageFactory;
+import com.idiot.operationbackend.service.facade.FansActionStatService;
+import com.idiot.operationbackend.service.facade.WeChatMessageService;
+import com.idiot.operationbackend.service.facade.WeChatService;
+import com.idiot.operationbackend.support.Constants;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
+
+/**
+ * 音频消息
+ * @author wang xiao
+ * @date Created in 9:49 2020/9/25
+ */
+@Service
+public class VoiceMessageServiceImpl implements WeChatMessageService {
+
+    @Autowired
+    private WeChatService weChatService;
+
+    @Autowired
+    private FansActionStatService fansActionStatService;
+
+    @Override
+    public String processMessage(Map<String, String> param) {
+        String accountId = param.get("accountId");
+        String openId = param.get("FromUserName");
+        FansActionStat var2 = new FansActionStat(accountId,openId,0);
+        fansActionStatService.saveBatchFansActionStat(var2);
+        weChatService.sendPushMessage(accountId,openId,1);
+        return Constants.SUCCESS;
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        WeChatMessageFactory.addService("voice",this);
+    }
+}