From 25e68ab1d0edce33111d95cad8d90d14b3abd954 Mon Sep 17 00:00:00 2001
From: theluyuan <1162963624@qq.com>
Date: Wed, 12 Jul 2023 20:41:05 +0800
Subject: [PATCH] =?UTF-8?q?add=20=E6=B7=BB=E5=8A=A0=E8=AE=A2=E9=98=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 db/database.db                           | Bin 16384 -> 32768 bytes
 router/videoInfo.js                      |  13 +++++-
 util/sql/video.js                        |  16 ++++++-
 view/src/api/Video.js                    |   4 +-
 view/src/page/subscribe/addSubscribe.vue |  52 +++++++++++++++++++----
 5 files changed, 72 insertions(+), 13 deletions(-)

diff --git a/db/database.db b/db/database.db
index e54188a9b52f4f7ad57b86c5beca359aeac126c3..70ce26c66d2c6dbbaa7c9ac4979d27f8e16fc352 100644
GIT binary patch
literal 32768
zcmeHP+fN%;8aL21ffdcRtKDdK73GL(l|)ML4Re#KuA9&;%B3x#7usD_1D?Rd*h77R
zg0!l+gj)!Z1i~GYki;Y*ToO`@&E=s_`&eoJg5Wckr>ZaevM>9c8QU0N2&|gjwmHr?
zV`jej&Ub#_WzL!TzH{Njvz&`X7kP(`aUrAT*P666&7Tp{Xf#In9)RzD_`U+)*TZ|*
zDW9~+j~(_#P3}cGJNq?FMwVUktAAvV!H#|?0u%v?07ZZzKoOt_Py}8Y1X@1L*njBA
zk+in2T})*y>vUH-s~lYA){j?Cm6e#wOHjG_owFq<CrXfmj%8<M=5UrARC>O=<S!*<
z==}TT==?`#&z>MB?2L`gK_8pTPQ7O?J7zGMjz`a<(<SekKRR2EjviG=Ev&OD2bGt6
z3YUjj#FI3#jAM(NNtc?LlVzN|{rR-e6&K?I5u?%*$x#kl7jr1mA(Z2G)Nb+I)*I4=
z56Vi<nae8BnUV^0j9_v+JL`DMJ8An59X_1a_K5<mg>SIe@{A?2Pu~t~<nZ%wb#boR
z1Ykk*C}L3!BoR3&os+5G9YZ4G=>*IY8|IwvTVp^>XcXntZ!;SLd@2yZ5w8;aY_<Lb
z?6a*hU2&GK-zdU-%vo5z)P9kV{>a#_)9CT%DRmFd0uETt?b@{*>>gMHErfs=&BZ&T
zPH|VKl}q9yQ8Q49cJyi8QE;>*=DFo=(97K!I?CZ})hRqPDiXvQl(RjAY<FRl<Jujj
z5H-T_B^ovoK>{LT-`itff)}K+_-ruwjMsWJ2ip!FfF1o%1SkR&0g3=cfFeK<pa@U|
zC;}7#iU396g(J|Ev0roQ>$mr13b*ft{Ex)ZHo0Y5?CKDnE+cVvR%evQ+G|{{I%ly~
zTc7*om$_BEP5YI$imzuKT3b_<PG`{R3hL{OrY|pPEjnFZepS_14fad9H7;ANrC7@_
zj5d*VT37n-{`uFY^qt!_?78jg2A7kq*+tv$Hl^*{wtg>dJ4wH71z#04u)ApcPh|d|
zuK7;0FI)57!G9n8*TElNxSC&V1D!?buWL>nHD_k_e0b#V&D^2GnTLhpUSa62aC1fK
z^nSlOirZ)9(SE#kU0R;k=NA^~^G${VlOa!Mc3ACPb&bnej6Pr;oU;aTcJ!`;ce*}@
z=RSXn*dF}W=URAoC1dA!#R%&;wn1B0!@GEG?H3Nl#qnR%!Bt?Eb?(Yqu1Z^HfM&ov
z^G!v$m+GoN*AjkNS<i-grTJ@{9uI7||0?{ygQ(in;t@vRD6xz-TW)W*u5Px>Z?<-C
zw%pllZ9^B7he^mlsPW2@N*xML!w-YbU?hh_0biKO_yYVOsEyB_0B6KwYxs^&9%)ya
zS`3D%Iv>Ih+&v=>1jz|${*ih@nju|+%i+igVX+H#!pNNL8I|TIly>~x!tj*B-V21v
zwTtcIjcIAV4R^M~A+27AE;@J{(jm8#bvU<3<QwZk?_D5?=)=YX{$YhE>VW5Ym)I(o
z)|js^EXvC_YRSdmL~spk!XW8dp(;kWBf{zc91{l~3pe}4fd#zcM-^@>ht4pZg~?K{
zQ~yT@_Hyu=@MKLGzY_A_MCH7VZ{*P#Hy8@jkc|4_FrJ*oYxm{hC&=8$)NrVru`<<+
zl}ltTdY^>+-SWhUd~XC@sNtI2RtA+iYq)C0mW(_ivNS!2AN8Y(Z-Z8lMG>3yP@E%O
zhAkAlk`-+Yz~AzSO%HS<C<ZoEJ>t1xJU1N*^a$f#-1$vtZ5+2h!E>YEuQubZd10zU
zzC9fB2T-gRZF*Yt2BW&gvW{~$q(!N1m}nCMyWUWctAl^~Vx!Ka)2eP(YO8)5p5VR}
z(fE!Y=-iD5B4Y6dU9mB*SXUIWlfk;QHz0Prm6_>#^GNd_lLikt*b6<xU03nlzDV#e
z6&iI#F+D3|;rT9yK4a}p-W?x0iuN8l3U!61f;_!xPoX1LQ0=xqVkG^*!PdGhEOPPa
zG}B;LEarJ}gb*c$4<)Mn$l+sq+&H0z6V-3Gg%8lB;iO)7(ol3PHdGxaq^0LhSE@k;
zq5NE9G^`kOg<FAz5UF7Wp@@w&G&JOLHcO=vQIyvMT9?aU$jdVp8VyQBk+w&y{M^DA
z?mFWZdzEkxam$o%EYcebQ^u`mtd|Ejz_$%~5HscLUPUwWtE$7RAx-e#lGazmfkiR!
zKn-c1FfImOy|Cbn(%lWbJb@S5rKP9n9OHyD5NyuFjgPZJBm)Y$<!NYr0yb2^HF6M-
z7#@y-^^+iZxm9>Hjn2Vc&j!~51J**W0Tl=n*WeWHd#rE;cIZ5Cwz(bTyfE_s_f6yL
zJ;KyAh*S{ZI8?z~d3RL}rz-b<5tK#WRlL+I4Bivhdy(1YblXT&wzEx1qjG4iKNP$n
z1|P~^C4}2qbb+x#f1)9k#8~Ctu*U$7=ep#MUhMCITS;i86`kQ4c{`6P7^mCLCvwN#
zQ}SqMC@?DBnnq@FgR;79$)y0*g5DL~xjE$)LX?`w5(Jif%~I#2)HhCUI;9P8rvb&;
zL1js(2Nr}bk8t}2GB>$F>*b6EbmvGSDj*D2BHW%49*>|hPNB7fi6rs_#};R&;O?m0
z!GIll4-C+mjB;WfFD}X}3wUD)ng$}Ut#b^huaQXxgB%Eg-h^ANV5T-6nVl(=h8OyT
z$sv5TRTybSr)oGb0(6G2WEx2Wi2{QRcs_vV`a*sWI`i!k2c`=uvoRJnnMn}7<Fmr}
z42%J!?nN-2Mi3pwWA;kkUY(5po%_T%gI###3E^J@cM~&lvScF$JmnD<z2f97dXIN-
zV3;*-dlHc+T0jPI+zUnwh=Bwk2KXd+Zz8cUu@0(}r>_eOOF*W2hXQj_^(oZ2^FD50
zQWVWX18_|;TJhnEw7w2F;Jck<EMzAZWMv^a!s$+wL*C2CNqBl0OkQZ2f;gvWI;pkG
z!*iivuRL)bB{l~mTw(D+k`vOvEn#+A49q7v2WpkaE{oSD!GM$zeX=1J449<AW4U=l
z7@CrNZFv0(?z<)qcwvr<@7x!g*S}xwf!6VzQ5c;HPZoqLU7<h#2!y2|9-k3?K^UB2
zFT{x!2(K{QQm>LWI&gn)XmwN^90~caNP|n#P#<2N0ajA$n%vO`{DnY2csTHvHbw}m
z;7BOYDctOUQH(r2DJ{238)L$wyF`-y9%1MkpbV{e@#-K*7z(rtlg;?@a%go*@ZJzS
zJ|GMEuL_TYp_MD*P{%XR0BoXn1DX(rE`wlF#}e)y3k7;5-!vIGD!mK&d!sbie@~bo
z%}Miq=&w992LnoIR9qXv>&y7@nCP2_Mg_lLdb$97R5TRvpy>ya@4D2#Mi5Y>l{y}X
zzJ+I=aX?sT^Ma6)=W-~}h3^EgH$c2@q7^LjnP&nx2!l(wzf;=i2QZ;UMD9`GluB3O
zo<`!@_yc(;NE!nKeQm<bEnyV;GxN-I54Kce+}P0-xoO4>5#i6&!>v6Ic~g%ZQx17!
zM~-C3Ylsec!$S-*|A(Z1`k@F=1SkR&0g3=cfFeK<pa@U|C;}7#iU3967mNUz|EKMH
zLjxQAPy{Ff6oHo<fkEr5(IkN1?m7t|FJEUe>P<1vdT9~>{!wy>Xc9n*<RzK}kmLpN
z-ZHaj5<pDW0!;#-NdVzwK_!ueCIP64R1p`UNdPnnAe;mcm*X1u!awfMm@#2oy5;}p
z{lCEgS+B;J_y6gdA2j=3ga2NJPv;*FkotgZQXh~_>I43?oB9BKk<nl>#;5YqDgd=|
zfmQ*~DgdaZfuyXsz!+O25SIzHy}o9TkubI6rObqiEx%Ec|4Z%lOf6@DymuEHEdb#6
zt8@P}-<!Wz=l*H&)kCq-JzM~wFVI6gjfwNy=KksNVIy@OSIXj{*gURX7Z1fsN-F>$
zMV?jwC`C=Q0zggFrxgHOB@1-&PbdF$^6#M)0JH+&xfKBVxKVEGIO}JS{;x0A8`2~5
z|L~MQ1NLOC|9$X%HGGWjC;}7#ioi>Pz@RgOJQ!4p{|_m1|F;h85a`vZzp)6Oq!t#Y
zn)=h3e{4NIDee|`yL1SB?N49(zo-RS=xhJTJ55^q56c(PnLnNR)0sc5{ok?n-=K%}
zt#%j>{^TeA2IEOx!AZTLTyH4W8;kQ`ku9C>Gj;tx`u?9RMYqHHfb{)8T?H_j4Hg+Z
z?Jd`IPixu0xa?=S3SeA-r0@S>0YLix|G!^Als*NZPXXvt042*Va@V0N0MZoz!}Im1
ZNzfGl)rtkW0w7%h@WrnH_)B{K{~z(4R`mb?

delta 120
zcmZo@U}|V!oFFYI!@$760>m)DGf~GFD5w`N!^_LZz|57$z<rW;)5d~@JnT!v<>eWh
zvnN+@&E#%r@n&KN@jFr{FXg>DxsXR>@@+10u9EzsqSU;S;KZ`Yr?@mGSMmMY{DNOb
OU@?n<z-AVMKl}hIc_3c^

diff --git a/router/videoInfo.js b/router/videoInfo.js
index 97b2643..e291972 100644
--- a/router/videoInfo.js
+++ b/router/videoInfo.js
@@ -1,7 +1,8 @@
 const Router = require("koa-router")
 const { serach, gen_douban } = require("../util/ptgen")
 const axios = require("axios")
-const cheerio = require("cheerio"); // HTML页面解析
+const cheerio = require("cheerio");
+const {addSub} = require("../util/sql/video"); // HTML页面解析
 
 const router = new Router({
     prefix: "/videoInfo"
@@ -38,6 +39,16 @@ router.get("/getVideoInfo", async (ctx) => {
 router.post("/addSubscribe", async (ctx) => {
     // console.log(ctx.request.body)
     let data = ctx.request.body
+    try {
+        let r = await addSub(data)
+        if(r){
+            ctx.body = "订阅已存在"
+        }else{
+            ctx.body = "添加成功"
+        }
+    }catch {
+        ctx.body = "添加失败"
+    }
 
 })
 
diff --git a/util/sql/video.js b/util/sql/video.js
index ba9a851..a0edda3 100644
--- a/util/sql/video.js
+++ b/util/sql/video.js
@@ -1,6 +1,18 @@
 const { run, getAll } = require("./base");
+const dayjs = require("dayjs");
 
-function addSub(info){
-    let sql = `insert into download(name,rename,skip,desc,url,subtitle,img) values(?,?,?,?,?,?)`
+async function addSub(info){
 
+    let selSql = `select * from VideoInfo where sid='${info.sid}' and season=${info.season}`
+    let list = await getAll(selSql)
+    if(list.length != 0){
+        return "订阅已存在"
+    }
+    let sql = `insert into VideoInfo(name,rename,skip,desc,url,subtitle,img,year,time,subTime,enable,season,sid) values(?,?,?,?,?,?,?,?,?,${new Date().getTime()},1,?,?)`
+    await run(sql,info.name,info.rename,info.skip,info.desc,info.url,info.subtitle,info.img,info.year,info.time,info.season,info.sid)
+}
+
+
+module.exports = {
+    addSub
 }
\ No newline at end of file
diff --git a/view/src/api/Video.js b/view/src/api/Video.js
index 7e3442a..993960d 100644
--- a/view/src/api/Video.js
+++ b/view/src/api/Video.js
@@ -25,6 +25,6 @@ export async function getImdbName(url) {
     })
 }
 
-export async function addSubscribe({name, desc, year, season, ep, url}) {
-    return await base.post("/videoInfo/addSubscribe", {name, desc, year, season, ep, url})
+export async function addSubscribe({name, rename, desc, year, season, ep, url, img, subtitle, time,skip,sid}) {
+    return await base.post("/videoInfo/addSubscribe", {name, rename, desc, year, season, ep, url, img, subtitle, time,skip,sid})
 }
\ No newline at end of file
diff --git a/view/src/page/subscribe/addSubscribe.vue b/view/src/page/subscribe/addSubscribe.vue
index a2103a3..947309d 100644
--- a/view/src/page/subscribe/addSubscribe.vue
+++ b/view/src/page/subscribe/addSubscribe.vue
@@ -36,6 +36,10 @@
                 地址:
                 <el-input style="width: 80%" v-model="url"></el-input>
             </div>
+            <div style="display: flex;align-items: center;padding: 5px">
+                检查更新时间:
+                <el-time-picker v-model="time" placeholder="Arbitrary time"/>
+            </div>
             <template #footer>
                 <span class="dialog-footer">
                     <el-button @click="dialogFormVisible = false">关闭</el-button>
@@ -52,7 +56,8 @@
 import {ref} from 'vue';
 import {addSubscribe, getImdbName, getVideoInfo, searchVideo} from '../../api/Video.js'
 import {onBeforeRouteUpdate, useRoute} from "vue-router";
-import {ElLoading} from "element-plus";
+import {ElLoading, ElMessage} from "element-plus";
+import dayjs from "dayjs";
 
 let list = ref([])
 const info = ref("")
@@ -63,6 +68,8 @@ const season = ref(1)
 const url = ref("")
 const subtitle = ref("")
 const img = ref("")
+const time = ref("")
+const name = ref("")
 async function onSubmit(name) {
     let res = await searchVideo(name)
     list.value = res.data.data
@@ -79,7 +86,7 @@ let vid = "";
 const dialogFormVisible = ref(false)
 
 
-async function getInfo(id,i) {
+async function getInfo(id, i) {
     const loadingInstance = ElLoading.service({fullscreen: true})
     vid = id
     img.value = i
@@ -87,7 +94,11 @@ async function getInfo(id,i) {
     info.value = res.data.format
     year.value = res.data.year
     subtitle.value = res.data.trans_title.join(" / ")
-    await subscribe(res.data.imdb_link)
+    name.value = res.data.chinese_title
+    enName.value = ""
+    if(res.data.imdb_link){
+        await subscribe(res.data.imdb_link)
+    }
     dialogFormVisible.value = true
     loadingInstance.close()
 }
@@ -100,16 +111,41 @@ async function subscribe(url) {
 }
 
 async function addsubscribe() {
-    addSubscribe({
-        name: enName.value,
+    let data = {
+        name: name.value,
+        rename: enName.value,
         desc: info.value,
         year: year.value,
         season: season.value,
         ep: ep.value,
         url: url.value,
-        img:img.value,
-        subtitle:subtitle.value
-    })
+        img: img.value,
+        subtitle: subtitle.value,
+        time: dayjs(time.value).format("HH:mm:ss"),
+        skip:season.value,
+        sid:vid
+    }
+    for(let i in data){
+        if(!data[i]){
+            ElMessage({
+                message: '请完整填写内容！',
+                type: 'error',
+            })
+            return
+        }
+    }
+    let res = await addSubscribe(data)
+    if(res.data == "添加成功"){
+        ElMessage({
+            message: res.data,
+            type: 'success',
+        })
+    }else{
+        ElMessage({
+            message: res.data,
+            type: 'error',
+        })
+    }
 }
 
 </script>