门户修改校稿文件发送协同消息

src/main/java/com/seeyon/ctp/rest/resources/CollaborationResource.java

@@ -8357,7 +8357,67 @@ public class CollaborationResource  extends BaseResource {
 
         return ok(map);
     }
+    /**
+     * <pre>
+     *      门户修改文件发送协同消息
+     *
+     * @Pathparam source  门户ID
+     * </pre>
+     */
+    @POST
+    @Consumes(MediaType.APPLICATION_JSON)
+    @Path("sendmessage/{source}")
+    @RestInterfaceAnnotation
+    public Response sendmessage(@PathParam("source") String source) throws BusinessException,Exception {
+        Map<String, Object> map = new HashMap<>();
+        if(isNull(source)) {
+            map.put("success", false);
+            map.put("msg", "source不能为空.");
+            map.put("oaId", "");
+            return ok(map);
+        }
+        List<ColSummary> data=colManager.getSourceData(source);
+        if(data!=null && !data.isEmpty()){
+            for(ColSummary ids : data){
+                Map<String, Object> message=new HashMap<String, Object>();
+                Long Ids=ids.getId();
+                String subject=ids.getSubject();
+                List<CtpAffair> ctpaffairs=affairManager.getAffairs(Ids,StateEnum.col_pending);
+                if(ctpaffairs==null | ctpaffairs.size()==0){
+                    map.put("success", false);
+                    map.put("msg", "无此条待办数据.");
+                    map.put("oaId", "");
+                    return ok(map);
+                }
+                Long senderid=-1L;
+                String content="null";
+                List<Long> member=new ArrayList<Long>();
+                for(CtpAffair affair : ctpaffairs){
+                    senderid=affair.getSenderId();
+                    member.add( affair.getMemberId());
+                }
+                Long[] userIds2 = new Long[member.size()];
+                userIds2 = (Long[])((Long[])member.toArray(userIds2));
+                long[] userIds = new long[userIds2.length];
 
+                for(int i = 0; i < userIds2.length; ++i) {
+                    userIds[i] = userIds2[i];
+                }
+                content=subject+"用户上传新文件，请注意查看";
+                String[] url=null;
+                MessageExporter messageExporter = new MessageExporter();
+                messageExporter.sendMessage(senderid, userIds, content,url);
+            }
+            map.put("success", true);
+            map.put("msg", "文件修改成功.");
+            map.put("门户Id", source);
+        }else{
+            map.put("success", false);
+            map.put("msg", "查询不到此id.");
+            map.put("门户Id", source);
+        }
+        return ok(map);
+    }
 //    @POST
 //    @Consumes(MediaType.APPLICATION_XML)
 //    @Path("test")