#! /bin/R

### Script to download and process the NDP-026D station cloud dataset

library(multicore)

library(latticeExtra)

library(doMC)

library(raster)

library(rgdal)

## register parallel processing

registerDoMC(20)

## available here http://cdiac.ornl.gov/epubs/ndp/ndp026d/ndp026d.html

## Get station locations

colnames(st)=c("StaID","LAT","LON","ELEV","ny1","fy1","ly1","ny7","fy7","ly7","SDC","b5c")

st$lat=st$LAT/100

st$lon=st$LON/100

st$lon[st$lon>180]=st$lon[st$lon>180]-360

system("gunzip data/*.Z")

#system("wget -N -nd ftp://cdiac.ornl.gov/pub/ndp026d/cat08_09/* -A '.tc.Z' -P data/")

#system("gunzip data/*.Z")

#c121=c("StaID","NobD","AvgDy","NobN","AvgNt","NobDN","AvgDN","Acode")

#  d=read.fwf(list.files("data",pattern=paste("MMCA.",m,".tc",sep=""),full=T),skip=1,widths=f162)

#  colnames(d)=c121

#  d$month=as.numeric(m)

#  return(d)}

#  ))

## define FWF widths

f162=c(5,5,4,7,7,7,4) #format 162

cld=do.call(rbind.data.frame,mclapply(sprintf("%02d",1:12),function(m) {

  colnames(d)=c162

  d$month=as.numeric(m)

  ))

cld[,c("lat","lon")]=st[match(cld$StaID,st$StaID),c("lat","lon")]

cld$Fq[cld$Fq<0]=NA

cld$AWP[cld$AWP<0]=NA

cld$NC[cld$NC<0]=NA

             month=x$month[1],

             StaID=x$StaID[1],

             cld=mean(x$Amt[x$Nobs>10]/100,na.rm=T),

             cldsd=sd(x$Amt[x$Nobs>10]/100,na.rm=T))}))

cldm[,c("lat","lon")]=st[match(cldm$StaID,st$StaID),c("lat","lon")]

cldy=do.call(rbind.data.frame,by(cld,list(year=as.factor(cld$YR),StaID=as.factor(cld$StaID)),function(x){

  data.frame(

             year=x$YR[1],

             StaID=x$StaID[1],

             cld=mean(x$Amt[x$Nobs>10]/100,na.rm=T),

             cldsd=sd(x$Amt[x$Nobs>10]/100,na.rm=T))}))

cldy[,c("lat","lon")]=st[match(cldy$StaID,st$StaID),c("lat","lon")]

#  foreach(s=unique(cld$StaID),.combine="rbind") %dopar% {

#    x=cld[cld$month==m&cld$StaID==s,]

#    data.frame(

#               month=x$month[1],

#               StaID=x$StaID[1],

#               Amt=mean(x$Amt[x$Nobs>10],na.rm=T)/100)}

write.csv(cldy,file="cldy.csv")

##################

###

cldm=read.csv("cldm.csv")

cldms=cldm

coordinates(cldms)=c("lon","lat")

projection(cldms)=CRS("+proj=longlat +ellps=WGS84 +datum=WGS84 +no_defs")

#### Evaluate MOD35 Cloud data

mod35=brick("../modis/mod35/MOD35_h11v08.nc",varname="CLD01")

mod35sd=brick("../modis/mod35/MOD35_h11v08.nc",varname="CLD_sd")

projection(mod35)="+proj=sinu +lon_0=0 +x_0=0 +y_0=0 +a=6371007.181 +b=6371007.181 +units=m +no_defs"

### use data from google earth engine

mod35=brick("../modis/mod09/global_2009/")

mod09=raster("../modis/mod09/global_2009/MOD09_2009.tif")

n=100

at=seq(0,100,length=n)

colr=colorRampPalette(c("black","green","red"))

cols=colr(n)

levelplot(mod09,col.regions=cols,at=at)

mod35v=foreach(m=unique(cldm$month),.combine="rbind") %do% {

  dr=subset(mod35,subset=m);projection(dr)=projection(mod35)

  dr2=subset(mod35sd,subset=m);projection(dr2)=projection(mod35)

  ds=cldms[cldms$month==m,]

  ds$mod35=unlist(extract(dr,ds,buffer=10,fun=mean,na.rm=T))

#  ds$mod35sd=extract(dr2,ds,buffer=10)

  print(m)

  return(ds@data[!is.na(ds$mod35),])}

## month factors

cldm$month2=factor(cldm$month,labels=month.name)

## add a color key

breaks=seq(0,100,by=25)

cldm$cut=cut(cldm$cld,breaks)

cp=colorRampPalette(c("blue","orange","red"))

cols=cp(length(at))

## read in global coasts for nice plotting

library(maptools)

data(wrld_simpl)

coast <- unionSpatialPolygons(wrld_simpl, rep("land",nrow(wrld_simpl)), threshold=5)

coast=as(coast,"SpatialLines")

#coast=spTransform(coast,CRS(projection(mod35)))

## write a pdf

#dir.create("output")

pdf("output/NDP026d.pdf",width=11,height=8.5)

## map of stations

 xyplot(lat~lon,data=st,pch=16,cex=.5,col="black",auto.key=T,

       main="NDP-026D Cloud Climatology Stations",ylab="Latitude",xlab="Longitude")+

  layer(sp.lines(coast,col="grey"),under=T)

xyplot(lat~lon|month2,groups=cut,data=cldm,pch=".",cex=.2,auto.key=T,

       main="Mean Monthly Cloud Coverage",ylab="Latitude",xlab="Longitude",

        par.settings = list(superpose.symbol= list(pch=16,col=c("blue","green","yellow","red"))))+

  layer(sp.lines(coast,col="grey"),under=T)

## Validation

m=10

zlim=c(40,100)

dr=subset(mod35,subset=m);projection(dr)=projection(mod35)

ds=cldms[cldms$month==m,]

plot(dr,col=cp(100),zlim=zlim,main="Comparison of MOD35 Cloud Frequency and NDP-026D Station Cloud Climatologies",

     ylab="Northing (m)",xlab="Easting (m)",sub="MOD35 is proportion of cloudy days, while NDP-026D is Mean Cloud Coverage")

plot(ds,add=T,pch=21,cex=3,lwd=2,fg="black",bg=as.character(cut(ds$cld,breaks=seq(zlim[1],zlim[2],len=5),labels=cp(4))))

#legend("topright",legend=seq(zlim[1],zlim[2],len=5),pch=16,col=cp(length(breaks)))

xyplot(mod35~cld,data=mod35v,subscripts=T,auto.key=T,panel=function(x,y,subscripts){

   td=mod35v[subscripts,]

#   panel.segments(x-td$cldsd[subscripts],y,x+td$cldsd[subscripts],y,subscripts=subscripts)

   panel.xyplot(x,y,subscripts=subscripts,type=c("p","smooth"),pch=16,col="black")

#   panel.segments(x-td$cldsd[subscripts],y,x+td$cldsd[subscripts],y,subscripts=subscripts)

 },ylab="MOD35 Proportion Cloudy Days",xlab="NDP-026D Mean Monthly Cloud Amount",

        main="Comparison of MOD35 Cloud Mask and Station Cloud Climatologies")

#xyplot(mod35~cld|month,data=mod35v,subscripts=T,auto.key=T,panel=function(x,y,subscripts){

#   td=mod35v[subscripts,]

#   panel.segments(x-td$cldsd[subscripts],y,x+td$cldsd[subscripts],y,subscripts=subscripts)

#   panel.xyplot(x,y,subscripts=subscripts,type=c("p","smooth"),pch=16,col="black")

#   panel.segments(x-td$cldsd[subscripts],y,x+td$cldsd[subscripts],y,subscripts=subscripts)

# },ylab="MOD35 Proportion Cloudy Days",xlab="NDP-026D Mean Monthly Cloud Amount",

#        main="Comparison of MOD35 Cloud Mask and Station Cloud Climatologies")

dev.off()

graphics.off()