bug修复

admin

2022-04-16 04f09e52ffd4681bdfd85e51acd3da0d1280c3d3

 src/main/java/com/yeshi/buwan/service/imp/juhe/IqiyiService.java

@@ -9,6 +9,8 @@

import javax.annotation.Resource;

import com.yeshi.buwan.dto.mq.VideoDataChangeMQMsg;
import com.yeshi.buwan.util.mq.CMQManager;
import org.apache.log4j.Logger;
import org.hibernate.HibernateException;
import org.hibernate.Session;
@@ -290,6 +292,7 @@
                     String id = "";
                     if (same == null) {
                        id = session.save(vi).toString();
                                CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, id, VideoDataChangeMQMsg.ACTION_ADD));
                        // if(id!=null)
                        // session.createSQLQuery(String.format("CALL
                        // copyvideotemp(%s)",id)).executeUpdate();
@@ -320,6 +323,7 @@
                        }

                        session.update(same);// 更新原来的视频
                                CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, same.getId(), VideoDataChangeMQMsg.ACTION_UPDATE));

                        Object obj = session
                              .createQuery(
@@ -332,6 +336,7 @@
                           rv.setResource(new VideoResource("13"));
                           rv.setVideo(new VideoInfo(same.getId()));
                           session.persist(rv);
                                    CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
                        }

                     }
@@ -347,6 +352,7 @@
                        rv.setResource(new VideoResource("13"));
                        rv.setVideo(new VideoInfo(id));
                        session.persist(rv);
                                CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
                     }

                     VideoIqiyi vii = new VideoIqiyi();
@@ -396,6 +402,8 @@
                     }
                     session.update(list.get(0).getVideo());
                     vid = list.get(0).getVideo().getId();
                            CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, vid, VideoDataChangeMQMsg.ACTION_UPDATE));

                     Object obj = session
                           .createQuery(
                                 "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
@@ -408,6 +416,7 @@
                        rv.setResource(new VideoResource("13"));
                        rv.setVideo(new VideoInfo(list.get(0).getVideo().getId()));
                        session.persist(rv);
                                CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
                     }
                  }
                  // 更新tag
@@ -434,6 +443,7 @@
                     if (same == null) {
                        vi.setVideocount(videoDetailCount);
                        videoid = session.save(vi).toString();
                                CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoid, VideoDataChangeMQMsg.ACTION_ADD));
                     } else
                        videoid = same.getId();

@@ -454,6 +464,7 @@
                        rv.setResource(new VideoResource("13"));
                        rv.setVideo(new VideoInfo(videoid));
                        session.persist(rv);
                                CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
                     }

                     if (same != null)// 更新内容
@@ -478,6 +489,8 @@
                                    + "");
                        session.update(same);

                                CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_INFO, videoid, VideoDataChangeMQMsg.ACTION_UPDATE));

                        obj = session
                              .createQuery(
                                    "select count(*) from ResourceVideo rv where rv.resource.id=? and rv.video.id=?")
@@ -490,6 +503,7 @@
                           rv.setResource(new VideoResource("13"));
                           rv.setVideo(same);
                           session.persist(rv);
                                    CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
                        }

                     }
@@ -553,6 +567,7 @@
                        rv.setResource(new VideoResource("13"));
                        rv.setVideo(list.get(0).getVideo());
                        session.persist(rv);
                                CMQManager.getInstance().addVideoDataChanged(new VideoDataChangeMQMsg(VideoDataChangeMQMsg.TYPE_VIDEO_RESOURCE, rv.getVideo().getId(), VideoDataChangeMQMsg.ACTION_ADD));
                     }
                     vid = list.get(0).getVideo().getId();
                  }