Merge remote-tracking branch 'origin/meiteng' into meiteng

src/main/java/org/rcisoft/business/bdiscuss/controller/BDiscussController.java

@@ -47,9 +47,8 @@ public class BDiscussController extends PaginationController<BDiscuss> {
             @ApiImplicitParam(name = "pid", value = "上一级（评论别人的评论需要）", required = true, dataType = "varchar"),
             @ApiImplicitParam(name = "studentId", value = "评论人id", required = true, dataType = "varchar")})
     @PostMapping(value = "/add")
-    public Result add(@Valid BDiscuss bDiscuss, BindingResult bindingResult) {
-//        bDiscuss.setToken(getToken());
-        PersistModel data = bDiscussServiceImpl.save(bDiscuss);
+    public Result add(CurUser curUser, @Valid BDiscuss bDiscuss, BindingResult bindingResult) {
+        PersistModel data = bDiscussServiceImpl.save(curUser,bDiscuss);
         return Result.builder(data,
             MessageConstant.MESSAGE_ALERT_SUCCESS,
             MessageConstant.MESSAGE_ALERT_ERROR,

src/main/java/org/rcisoft/business/bdiscuss/service/BDiscussService.java

@@ -4,6 +4,7 @@ import org.rcisoft.business.bdiscuss.dto.BDiscussDto;
 import org.rcisoft.business.bdiscuss.entity.BDiscuss;
 import org.rcisoft.core.model.PersistModel;
 import org.rcisoft.core.aop.PageUtil;
+import org.rcisoft.sys.user.bean.CurUser;
 
 import java.util.List;
 
@@ -17,7 +18,7 @@ public interface BDiscussService {
     * @param bDiscuss
     * @return
     */
-    PersistModel save(BDiscuss bDiscuss);
+    PersistModel save(CurUser curUser, BDiscuss bDiscuss);
 
     /**
     * 逻辑删除 

src/main/java/org/rcisoft/business/bdiscuss/service/impl/BDiscussServiceImpl.java

@@ -12,6 +12,7 @@ import org.rcisoft.common.model.InfoTypeEnum;
 import org.rcisoft.common.util.feignDto.MTUserGetsReqDTO;
 import org.rcisoft.common.util.feignDto.MTUserInfoRspDTO;
 import org.rcisoft.common.util.outClient.MTCotactApiRequestClient;
+import org.rcisoft.common.util.outClient.MTMicroappApiRequestClient;
 import org.rcisoft.common.util.outClient.MTNotificationApiRequestClient;
 import org.rcisoft.core.util.IdGen;
 import org.rcisoft.core.util.UserUtil;
@@ -22,6 +23,7 @@ import org.rcisoft.business.bdiscuss.entity.BDiscuss;
 import org.rcisoft.business.bdiscuss.service.BDiscussService;
 
 
+import org.rcisoft.sys.user.bean.CurUser;
 import org.rcisoft.sys.user.service.SysUserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -66,6 +68,9 @@ public class BDiscussServiceImpl implements BDiscussService {
     @Autowired
     MTNotificationApiRequestClient client;
 
+    @Autowired
+    MTMicroappApiRequestClient microappApiRequestClient;
+
     /**
     * 保存 bDiscuss
     * @param bDiscuss
@@ -73,8 +78,8 @@ public class BDiscussServiceImpl implements BDiscussService {
     */
     @Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.DEFAULT)
     @Override
-    public PersistModel save(BDiscuss bDiscuss){
-        if (StringUtils.isNotBlank(bDiscuss.getReplyId())){
+    public PersistModel save(CurUser curUser,BDiscuss bDiscuss){
+        if (StringUtils.isNotBlank(bDiscuss.getReplyId()) && microappApiRequestClient.isHaveApps(Long.parseLong(curUser.getUserId()),Long.parseLong(curUser.getCorpId()))){
             BNotice bNotice = new BNotice();
 //            UserUtil.setCurrentPersistOperation(bNotice);
             bNotice.setRecipientId(bDiscuss.getReplyId());

src/main/java/org/rcisoft/common/util/feignClient/MicroappFeignClient.java

+package org.rcisoft.common.util.feignClient;
+
+import org.rcisoft.common.util.feignDto.MTNotificationSendReqDTO;
+import org.rcisoft.core.result.Ret;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+/**
+ * 智信消息客户端接口
+ */
+@FeignClient(value = "ZX-MICROAPP")
+public interface MicroappFeignClient {
+
+    /**
+     * 发送智信消息
+     * @return
+     */
+    @RequestMapping(value = "/micro_app/isHaveApps",method = RequestMethod.GET)
+    Ret isHaveApps(@RequestParam("UserId") Long UserId,
+                    @RequestParam("corpId") Long corpId,
+                    @RequestParam("appId") Long appId
+    );
+}

src/main/java/org/rcisoft/common/util/outClient/MTMicroappApiRequestClient.java

+package org.rcisoft.common.util.outClient;
+
+import lombok.extern.slf4j.Slf4j;
+import org.rcisoft.common.util.feignClient.FileFeignClient;
+import org.rcisoft.common.util.feignClient.MicroappFeignClient;
+import org.rcisoft.common.util.feignDto.MTOssRspDTO;
+import org.rcisoft.core.result.Ret;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * 消息通知接口调用
+ * @author David
+ */
+@Slf4j
+@Component
+public class MTMicroappApiRequestClient {
+
+    public static Long appId = (long)1;
+
+//    @Autowired
+    private MicroappFeignClient microappFeignClient;
+
+    public boolean isHaveApps(long userId, long corpId) {
+        Ret ret = microappFeignClient.isHaveApps(userId,corpId,appId);
+        if(ret != null && "M0000".equals(ret.getCode())){
+            return (boolean) ret.getData();
+        }
+        return false;
+    }
+
+}