import com.typesafe.scalalogging.Logger
import org.slf4j.LoggerFactory
import java.io.PrintWriter
import java.nio.charset.Charset
import java.text.DecimalFormatSymbols
import java.util.Locale
import scala.io.Source
object Tax   {
  def main(args: Array[String]): Unit = {
    implicit val logger = Logger(LoggerFactory.getLogger(this.getClass))
    import java.text.DecimalFormat
    val df = new DecimalFormat("0.00")
    val dfRate = new DecimalFormat("0.0000")
    df.setDecimalFormatSymbols(DecimalFormatSymbols.getInstance(Locale.ENGLISH))
    dfRate.setDecimalFormatSymbols(DecimalFormatSymbols.getInstance(Locale.ENGLISH))
    val str = (Source.fromFile("d:\\tax\\1.csv","UTF-8").getLines().toSeq ++ Source.fromFile("d:\\tax\\2.csv","UTF-8").getLines().toSeq)
      .map(_.split(",(?=(?:[^"]*"[^"]*")*[^"]*$)", -1).toList)
    val rates = Source.fromFile("d:\\tax\\r.csv","windows-1252").getLines().map(_.split(';')).toSeq
      .map(e1=>e1.updated(1,e1(1).split('.').reverse.mkString("-")))
    def rate(d:String)={
      rates.sortBy(_(1)).findLast(e=>e(1)<=d).map{x=>
        if (x(1)!=d) logger.debug(s"Нет курса на дату $d, последний ${x(1)}")
        BigDecimal(x(2).replaceAll(",","."))
      }.get
    }
    val str1 = str.filter(_.length > 15).filter(e => e(0) == "Сделки" && e(1) == "Data").filter{e=> e(13)!=""}
      .map(e=>(e,{
        val date = e(6).replaceAll(""","" ).split(',')(0)
        val rt = rate(date)
        val sumR = (rt * BigDecimal(e(13)))
        val codes = e(3).trim match {
          case "Контракты на разницу (CFD)" => ("893","06")//1532
          case "Опционы на акции и индексы" => ("893","06")//1532
          case "Варранты" => ("893","06")//1532
          case "Акции" => ("79","01")//1530
        }
        val xml = s"""<РасчДохНалИно ОКСМ="840" НаимИстДох="${e(5)}" КодВалют="840" КодВидДох="32" ДатаДох="${
          date.split('-').reverse.mkString(".")
        }" КурсВалютДох="${dfRate.format(rt)}" ДоходИноВал="${df.format(BigDecimal(e(13)))}" ДоходИноРуб="${df.format(sumR)}" НалЗачРФОбщ="${codes._1}"/>"""
        (xml,sumR,codes)
      }))
    val txt = str1.filter(_._2._2>0).map(_._2._1).mkString("") +
      str1.groupBy(_._2._3).map(e=>(e._1,{
        val x = e._2.map(_._2._2)
        (x.filter(_ >0).sum,-x.filter(_ <0).sum)
      })).map(e=>
        s"""<ДохОперЦБ ВидОпер="${e._1._2}" ДохСовОпер="${df.format(e._2._1)}" РасхРеалЦБ="${df.format(e._2._2)}" РасхУмДохОпер="${df.format(e._2._2)}" ПризУчетУбыт="0"/>"""
      ).mkString("\n") match {
      case e=> new PrintWriter("d:\\tax\\tax_xml.txt", Charset.forName("UTF-8")) { write(e); close }
    }
    logger.debug(s"Дох=${str1.map(e=>e._2._2).filter(_ >0 ).sum} " +
      s"Расх=${str1.map(e=>e._2._2).filter(_ <0 ).sum}" +
      s"База=${str1.map(e=>e._2._2).sum}")
  }
}