3.9.0bug修改

admin

2021-04-02 2a593ddac16e06f1ff55edca22ea568f07b068ba

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

@@ -25,6 +25,8 @@
import com.yeshi.buwan.service.imp.VideoTypeService;
import com.yeshi.buwan.service.inter.juhe.PPTVService;
import com.yeshi.buwan.util.mq.CMQManager;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
@@ -223,12 +225,12 @@
                    CMQManager.getInstance().addPPTVSeriesUpdateMsg(new PPTVMQMsg(series.getInfoID(), PPTVMQMsg.TYPE_ADD_OR_UPDATE));
                }

                System.out.println("addorupdate:"+series.getName());
                System.out.println("addorupdate:" + series.getName());

                break;
            //删除
            case "del":
                System.out.println("delete:"+series.getName());
                System.out.println("delete:" + series.getName());
                deleteSeries(series);
                infoIds.add(series.getInfoID());
                break;
@@ -281,6 +283,13 @@
        return videoPPTVMapDao.selectByInfoId(infoId);
    }

    @Override
    public PPTVSeries selectSeriesBySeriesCode(String cid) {
        Query query = new Query();
        query.addCriteria(new Criteria().where("seriesCode").is(cid));
        return pptvSeriesDao.findOne(query);
    }

    /**
     * 删除剧集
     *