@ -558,30 +558,34 @@ public class FlowTaskServiceImpl extends FlowServiceFactory implements IFlowTask
//发送消息
public void sendMsg ( OcrTaskchildPicture model , UserToken userToken ) {
cn . jyjz . xiaoyao . common . base . vo . User byLoginname = userTokenService . findByLoginname ( model . getAssignee ( ) ) ;
OcrMsg msg = new OcrMsg ( ) ;
msg . setCreateTime ( System . currentTimeMillis ( ) ) ;
msg . setSendTime ( System . currentTimeMillis ( ) ) ;
msg . setReceiveUserIds ( byLoginname . getId ( ) . toString ( ) ) ;
msg . setTitile ( model . getFromtaskname ( ) ) ;
msg . setSender ( Long . valueOf ( userToken . getUserid ( ) ) ) ;
JSONObject jsonObject = new JSONObject ( ) ;
jsonObject . put ( "taskId" , model . getFromtaskid ( ) ) ;
jsonObject . put ( "nodeName" , model . getTaskname ( ) ) ;
jsonObject . put ( "states" , 1 ) ;
jsonObject . put ( "statesName" , "待审批" ) ;
jsonObject . put ( "sendUserId" , userToken . getUserid ( ) ) ;
jsonObject . put ( "sendUserName" , userToken . getUsername ( ) ) ;
jsonObject . put ( "sendTime" , System . currentTimeMillis ( ) ) ;
jsonObject . put ( "fromId" , model . getId ( ) . toString ( ) ) ;
jsonObject . put ( "taskName" , model . getFromtaskname ( ) ) ;
jsonObject . put ( "pictureId" , model . getPictureid ( ) ) ;
jsonObject . put ( "packageId" , model . getPackageid ( ) ) ;
msg . setBusJson ( jsonObject . toJSONString ( ) ) ;
msg . setCreateBy ( Long . valueOf ( userToken . getUserid ( ) ) ) ;
msg . setCreateTime ( System . currentTimeMillis ( ) ) ;
msg . setSendStatus ( "1" ) ;
ocrMsgService . save ( msg ) ;
String [ ] split = model . getAssignee ( ) . split ( "," ) ;
List < cn . jyjz . xiaoyao . common . base . vo . User > userList = userTokenService . findByLoginNameList ( split ) ;
for ( cn . jyjz . xiaoyao . common . base . vo . User user : userList ) {
OcrMsg msg = new OcrMsg ( ) ;
msg . setCreateTime ( System . currentTimeMillis ( ) ) ;
msg . setSendTime ( System . currentTimeMillis ( ) ) ;
msg . setReceiveUserIds ( user . getId ( ) . toString ( ) ) ;
msg . setTitile ( model . getFromtaskname ( ) ) ;
msg . setSender ( Long . valueOf ( userToken . getUserid ( ) ) ) ;
JSONObject jsonObject = new JSONObject ( ) ;
jsonObject . put ( "taskId" , model . getFromtaskid ( ) ) ;
jsonObject . put ( "nodeName" , model . getTaskname ( ) ) ;
jsonObject . put ( "states" , 1 ) ;
jsonObject . put ( "statesName" , "待审批" ) ;
jsonObject . put ( "sendUserId" , userToken . getUserid ( ) ) ;
jsonObject . put ( "sendUserName" , userToken . getUsername ( ) ) ;
jsonObject . put ( "sendTime" , System . currentTimeMillis ( ) ) ;
jsonObject . put ( "fromId" , model . getId ( ) . toString ( ) ) ;
jsonObject . put ( "taskName" , model . getFromtaskname ( ) ) ;
jsonObject . put ( "pictureId" , model . getPictureid ( ) ) ;
jsonObject . put ( "packageId" , model . getPackageid ( ) ) ;
msg . setBusJson ( jsonObject . toJSONString ( ) ) ;
msg . setCreateBy ( Long . valueOf ( userToken . getUserid ( ) ) ) ;
msg . setCreateTime ( System . currentTimeMillis ( ) ) ;
msg . setSendStatus ( "1" ) ;
ocrMsgService . save ( msg ) ;
}
}
/ * *