@@ -37,7 +37,7 @@ export class BookService {
3737 private cate : CateService
3838 ) {
3939 this . crud . getItems ( { table : 'Book' } )
40- . then ( ( res : IQueryResult ) => {
40+ . subscribe ( ( res : IQueryResult ) => {
4141 this . opMessage . newMsg ( res . message ) ;
4242 const books = res . data as Book [ ] ;
4343 this . list = books . slice ( ) ;
@@ -79,6 +79,7 @@ export class BookService {
7979 let rawRepo : object ;
8080 if ( / g i t e e / . test ( site ) ) {
8181 rawRepo = await this . fetchService . getRepoProfile ( site , newBook . name , writerName ) ;
82+
8283 newBook . writer = await this . writer . newWriter ( writerName , newBook , rawRepo [ 'owner' ] [ 'login' ] ) ;
8384 }
8485 else {
@@ -110,9 +111,11 @@ export class BookService {
110111 item : newBook
111112 }
112113
113- const queryRes :IQueryResult = await this . crud . addItem ( query ) ;
114- this . opMessage . newMsg ( queryRes . message ) ;
115- this . listUpdated ( queryRes . data as Book ) ;
114+ this . crud . addItem ( query )
115+ . subscribe ( res => {
116+ this . opMessage . newMsg ( res . message ) ;
117+ this . listUpdated ( res . data as Book ) ;
118+ } ) ;
116119 }
117120
118121 open = async ( book : Book ) => {
@@ -124,23 +127,23 @@ export class BookService {
124127 item : book
125128 }
126129
127- const res : IQueryResult = await this . crud . updateItem ( query ) ;
128- this . opMessage . newMsg ( res . message ) ;
129- this . listUpdated ( res . data as Book ) ;
130+ this . crud . updateItem ( query ) . subscribe ( res => {
131+ this . opMessage . newMsg ( res . message ) ;
132+ this . listUpdated ( res . data as Book ) ;
133+ } ) ;
130134 }
131135
132136 update = async ( book : Book ) => {
133- let query : IQuery ;
134-
135137 book . cateList = await this . cate . saveList ( book . cateList ) ;
136138
137- query = {
139+ const query : IQuery = {
138140 table : 'Book' ,
139141 item : book
140142 }
141- const queryRes : IQueryResult = await this . crud . updateItem ( query ) ;
142- this . opMessage . newMsg ( queryRes . message ) ;
143- this . listUpdated ( queryRes . data as Book ) ;
143+ this . crud . updateItem ( query ) . subscribe ( queryRes => {
144+ this . opMessage . newMsg ( queryRes . message ) ;
145+ this . listUpdated ( queryRes . data as Book ) ;
146+ } ) ;
144147 }
145148
146149 recycleRecoverDelete = async ( res : IDeleteBookDialogResData ) => {
@@ -152,8 +155,9 @@ export class BookService {
152155 item : res . book
153156 }
154157
155- const queryRes : IQueryResult = await this . crud . deleteItem ( query ) ;
156- this . opMessage . newMsg ( queryRes . message ) ;
158+ this . crud . deleteItem ( query ) . subscribe ( queryRes => {
159+ this . opMessage . newMsg ( queryRes . message ) ;
160+ } ) ;
157161 }
158162
159163 if ( ! res . recycled && res . remove ) {
@@ -162,9 +166,10 @@ export class BookService {
162166 item : res . book
163167 }
164168
165- const queryRes :IQueryResult = await this . crud . deleteItem ( query ) ;
166- this . opMessage . newMsg ( queryRes . message ) ;
167- this . listUpdated ( res . book , true ) ;
169+ this . crud . deleteItem ( query ) . subscribe ( queryRes => {
170+ this . opMessage . newMsg ( queryRes . message ) ;
171+ this . listUpdated ( res . book , true ) ;
172+ } ) ;
168173
169174 return ;
170175 }
@@ -178,8 +183,9 @@ export class BookService {
178183 item : res . book
179184 }
180185
181- const queryRes :IQueryResult = await this . crud . updateItem ( query ) ;
182- this . opMessage . newMsg ( queryRes . message ) ;
183- this . listUpdated ( queryRes . data as Book ) ;
186+ this . crud . updateItem ( query ) . subscribe ( queryRes => {
187+ this . opMessage . newMsg ( queryRes . message ) ;
188+ this . listUpdated ( queryRes . data as Book ) ;
189+ } ) ;
184190 }
185191}
0 commit comments