@@ -68,37 +68,47 @@ module.exports = {
6868 let data = {
6969 'id' : Number ( message . author . id ) ,
7070 'user' : String ( message . author . username ) ,
71- 'invent ' : String ( earnCsv [ i ] )
71+ 'inventory ' : String ( earnCsv [ i ] )
7272 } ;
7373
7474 dataUser . push ( data ) ;
7575 } ;
7676
7777 fs . exists ( filePath , ( e ) => {
78- fs . createReadStream ( filePath )
79- . pipe ( csvParse . parse ( { delimiter : ',' } ) )
80- . on ( 'error' , err => `[${ getCurrentDatetime ( 'comm' ) } ] ${ message . guild . name } / ${ message . channel . name } # ${ message . author . username } 's inventory error save ${ err } ` )
81- . on ( 'data' , function ( csvrow ) {
82- if ( csvrow [ 0 ] == 'id' ) return ;
83-
84- let data = {
85- 'id' : Number ( csvrow [ 0 ] ) ,
86- 'user' : String ( csvrow [ 1 ] ) ,
87- 'invent' : String ( csvrow [ 2 ] )
88- } ;
89-
90- dataUser . push ( data ) ;
91-
92- fs . writeFileSync ( filePath , parse ( dataUser ) , function ( err ) {
93- if ( err ) {
94- message . channel . send ( `${ language . errorRoll } ` ) ;
95- console . log ( `[${ getCurrentDatetime ( 'comm' ) } ] ${ message . guild . name } / ${ message . channel . name } # ${ message . author . username } 's inventory error save ${ err } ` ) ;
96- throw err ;
97- } else {
98- console . log ( `[${ getCurrentDatetime ( 'comm' ) } ] ${ message . guild . name } / ${ message . channel . name } # ${ message . author . username } 's inventory save` ) ;
78+ if ( e ) {
79+ fs . createReadStream ( filePath )
80+ . pipe ( csvParse . parse ( { headers : true , delimiter : ',' } ) )
81+ . on ( 'data' , row => {
82+ if ( row . id != 'id' ) {
83+ dataUser . push ( {
84+ 'id' : Number ( row . id ) ,
85+ 'user' : String ( row . user ) ,
86+ 'inventory' : String ( row . inventory )
87+ } ) ;
9988 } ;
89+ } )
90+ . on ( 'end' , ( ) => {
91+ fs . writeFileSync ( filePath , parse ( dataUser ) , function ( err ) {
92+ if ( err ) {
93+ message . channel . send ( `${ language . errorRoll } ` ) ;
94+ console . log ( `[${ getCurrentDatetime ( 'comm' ) } ] ${ message . guild . name } / ${ message . channel . name } # ${ message . author . username } 's inventory error save ${ err } ` ) ;
95+ throw err ;
96+ } else {
97+ console . log ( `[${ getCurrentDatetime ( 'comm' ) } ] ${ message . guild . name } / ${ message . channel . name } # ${ message . author . username } 's inventory save` ) ;
98+ } ;
99+ } ) ;
100100 } ) ;
101+ } else {
102+ fs . writeFileSync ( filePath , parse ( dataUser ) , function ( err ) {
103+ if ( err ) {
104+ message . channel . send ( `${ language . errorRoll } ` ) ;
105+ console . log ( `[${ getCurrentDatetime ( 'comm' ) } ] ${ message . guild . name } / ${ message . channel . name } # ${ message . author . username } 's inventory error save ${ err } ` ) ;
106+ throw err ;
107+ } else {
108+ console . log ( `[${ getCurrentDatetime ( 'comm' ) } ] ${ message . guild . name } / ${ message . channel . name } # ${ message . author . username } 's inventory save` ) ;
109+ } ;
101110 } ) ;
111+ } ;
102112 } ) ;
103113 } ;
104114
0 commit comments