private def logOffState: Receive = {
    case RunPOSCommand(LogOn(opr, _)) =>
          persistEvent(LogOned(opr,vchState)) { evt =>
            val sts = updateState(evt, vchState, vchItems)
//starting seqenceNr for any voucher. no action logged before login
            vchState = sts._1.copy(jseq = lastSequenceNr + 1);
            vchItems = sts._2
            sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 用户{$opr}成功登陆。", vchState, List(vchItems.txnitems.head))
            context.become(logOnState)
          }
    case PassivatePOS =>
      log.info(s"**********${persistenceId} got passivate message and stopping  ... ***********")
      context.parent ! PoisonPill
    case _ =>
      sender() ! POSResponse(STATUS.FAIL, s"操作失败！终端 ${persistenceId} 用户未登陆。", vchState, List())
  }

  private def logOnState: Receive = {
    case RunPOSCommand(LogOff) =>
          persistEvent(LogOffed(vchState)) { evt =>
            val user = vchState.opr
            val sts = updateState(evt,vchState,vchItems)
            vchState = sts._1; vchItems = sts._2
            saveSnapshot(vchState)     //state of last voucher
          //手工passivate         shard ! ShardRegion.Passivate(PassivatePOS)
            sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 用户 $user 成功退出。", vchState, List(vchItems.txnitems.head))
            context.unbecome()    //switch to logOffState
          }
    case RunPOSCommand(SuperOn(su,_)) =>
      persistEvent(SuperOned(su,vchState)) { evt =>
        val sts = updateState(evt, vchState, vchItems)
        vchState = sts._1
        vchItems = sts._2
        sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 转到管理模式{$su}。", vchState, List(vchItems.txnitems.head))
      }
  private def logOnState: Receive = {
    case RunPOSCommand(LogOff) =>
          persistEvent(LogOffed(vchState)) { evt =>
            val user = vchState.opr
            val sts = updateState(evt,vchState,vchItems)
            vchState = sts._1; vchItems = sts._2
            saveSnapshot(vchState)     //state of last voucher
          //手工passivate         shard ! ShardRegion.Passivate(PassivatePOS)
            sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 用户 $user 成功退出。", vchState, List(vchItems.txnitems.head))
            context.unbecome()    //switch to logOffState
          }
    case RunPOSCommand(SuperOn(su,_)) =>
      persistEvent(SuperOned(su,vchState)) { evt =>
        val sts = updateState(evt, vchState, vchItems)
        vchState = sts._1
        vchItems = sts._2
        sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 转到管理模式{$su}。", vchState, List(vchItems.txnitems.head))
      }
  private def logOnState: Receive = {
    case RunPOSCommand(LogOff) =>
          persistEvent(LogOffed(vchState)) { evt =>
            val user = vchState.opr
            val sts = updateState(evt,vchState,vchItems)
            vchState = sts._1; vchItems = sts._2
            saveSnapshot(vchState)     //state of last voucher
          //手工passivate         shard ! ShardRegion.Passivate(PassivatePOS)
            sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 用户 $user 成功退出。", vchState, List(vchItems.txnitems.head))
            context.unbecome()    //switch to logOffState
          }
    case RunPOSCommand(SuperOn(su,_)) =>
      persistEvent(SuperOned(su,vchState)) { evt =>
        val sts = updateState(evt, vchState, vchItems)
        vchState = sts._1
        vchItems = sts._2
        sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 转到管理模式{$su}。", vchState, List(vchItems.txnitems.head))
      }
    //first payment in a voucher
    case RunPOSCommand(OfflinePay(acct,num, amount)) =>
      persistEvent(Payment(acct,num,vchState)) { evt =>
        val sts = updateState(evt, vchState, vchItems)
        vchState = sts._1
        vchItems = sts._2
        if (vchItems.totalSales > 0)
          sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}支付。", vchState, List(vchItems.txnitems.head))
        else
          sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}退款。", vchState, List(vchItems.txnitems.head))
        if (!vchState.due) {  //completed voucher. mark end of voucher and move next. stay in logOnState
          persistEvent(EndVoucher(vchState.num)) { evt =>
            val sts = updateState(evt, vchState, vchItems)
            vchState = sts._1
            vchItems = sts._2
            saveSnapshot(vchState)     //recovery to next voucher
          }
        }
        else context.become(paymentState)     //switch into paymentState
      }
...
}
 private def paymentState: Receive = {
    case RunPOSCommand(OfflinePay(acct,num, amount)) =>
           persistEvent(Payment(acct,num,vchState)) { evt =>
             val sts = updateState(evt, vchState, vchItems)
             vchState = sts._1
             vchItems = sts._2
             if (vchItems.totalSales > 0)
               sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}支付。", vchState, List(vchItems.txnitems.head))
             else
               sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}退款。", vchState, List(vchItems.txnitems.head))
             if (!vchState.due) {  //completed voucher. mark end of voucher and move next. return to logOnState
               persistEvent(EndVoucher(vchState.num)) { evt =>
                 val sts = updateState(evt, vchState, vchItems)
                 vchState = sts._1
                 vchItems = sts._2
                 saveSnapshot(vchState)     //recovery to next voucher
                 context.unbecome()    //logOnState
               }
             }
             // else wait for other payments and stay in logOnState
           }
...
}

  case class TxnItem(
                      txndate: String = LocalDate.now.format(DateTimeFormatter.ofPattern("yyyyMMdd"))
                      ,txntime: String = LocalDateTime.now.format(dateTimeFormatter).substring(11)
                      ,opr: String = ""//工号
                      ,num: Int = 0 //销售单号
                      ,seq: Int = 1 //交易序号
                      ,txntype: Int = TXNTYPE.sales//交易类型
                      ,salestype: Int = SALESTYPE.plu //销售类型
                      ,qty: Int =  1 //交易数量
                      ,price: Int = 0 //单价（分）
                      ,amount: Int = 0 //码洋（分）
                      ,dscamt: Int = 0 //折扣：负值  net实洋 = amount + dscamt
                      ,member: String = "" //会员卡号
                      ,code: String = "" //编号（商品、账号...）
                      ,desc: String = "" //项目名称
                      ,dpt: String = ""
                      ,department: String = ""
                      ,cat: String = ""
                      ,category: String = ""
                      ,brd: String = ""
                      ,brand: String = ""
                    )

object Commands {
  case object PassivatePOS    //passivate message
  case class DebugMode(debug: Boolean)
  sealed trait POSCommand {}
  case class LogOn(opr: String, passwd: String) extends POSCommand
  case object LogOff extends POSCommand
  case class SuperOn(su: String, passwd: String) extends POSCommand
  case object SuperOff extends POSCommand
  case class MemberOn(cardnum: String, passwd: String) extends POSCommand
  case object MemberOff extends POSCommand   //remove member status for the voucher
  case object RefundOn extends POSCommand
  case object RefundOff extends POSCommand
  case object VoidOn extends POSCommand
  case object VoidOff extends POSCommand
  case object VoidAll extends POSCommand
  case object Suspend extends POSCommand
  case class VoucherNum(vnum: Int) extends POSCommand
  case class LogSales(salesType: Int, dpt: String, code: String, qty: Int, price: Int) extends POSCommand
  case object Subtotal extends POSCommand
  case class Discount(code: String, percent: Int) extends POSCommand
  case class OfflinePay(acct: String, num: String, amount: Int) extends POSCommand          //settlement   结算支付
 //read only command, no event process
  case class VCBalance(acct: String, num: String, passwd: String) extends POSCommand
  case class VCPay(acct: String, num: String, passwd: String, amount: Int) extends POSCommand
  case class AliPay(acct: String, num: String, amount: Int) extends POSCommand
  case class WxPay(acct: String, num: String, amount: Int) extends POSCommand
  // read only command, no update event
  case class Plu(itemCode: String) extends POSCommand  //read only
}
object Events {
  sealed trait POSEvent {}
  case class LogOned(txnItem: TxnItem) extends POSEvent
  object LogOned {
    def apply(op: String, vs: VchStates): LogOned = LogOned(TxnItem(vs).copy(
      txntype = TXNTYPE.logon,
      salestype = SALESTYPE.crd,
      opr = op,
      code = op
    ))
  }
  case class LogOffed(txnItem: TxnItem) extends POSEvent
  object LogOffed {
    def apply(vs: VchStates): LogOffed = LogOffed(TxnItem(vs).copy(
      txntype = TXNTYPE.logon,
      salestype = SALESTYPE.crd,
    ))
  }
  case class SuperOned(txnItem: TxnItem) extends POSEvent
  object SuperOned {
    def apply(su: String, vs: VchStates): SuperOned = SuperOned(TxnItem(vs).copy(
      txntype = TXNTYPE.supon,
      salestype = SALESTYPE.crd,
      code = su
    ))
  }
  case class SuperOffed(txnItem: TxnItem) extends POSEvent
  object SuperOffed {
    def apply(vs: VchStates): SuperOffed = SuperOffed(TxnItem(vs).copy(
      txntype = TXNTYPE.supon,
      salestype = SALESTYPE.crd
    ))
  }
  case class MemberOned(txnItem: TxnItem) extends POSEvent
  object MemberOned {
    def apply(cardnum: String,vs: VchStates): MemberOned = MemberOned(TxnItem(vs).copy(
      txntype = TXNTYPE.sales,
      salestype = SALESTYPE.crd,
      member = cardnum
    ))
  }
  case class MemberOffed(txnItem: TxnItem) extends POSEvent   //remove member status for the voucher
  object MemberOffed {
    def apply(vs: VchStates): MemberOffed = MemberOffed(TxnItem(vs).copy(
      txntype = TXNTYPE.sales,
      salestype = SALESTYPE.crd,
      member = vs.mbr
    ))
  }
  case class RefundOned(txnItem: TxnItem) extends POSEvent
  object RefundOned {
    def apply(vs: VchStates): RefundOned = RefundOned(TxnItem(vs).copy(
      txntype = TXNTYPE.refund
    ))
  }
  case class RefundOffed(txnItem: TxnItem) extends POSEvent
  object RefundOffed {
    def apply(vs: VchStates): RefundOffed = RefundOffed(TxnItem(vs).copy(
      txntype = TXNTYPE.refund
    ))
  }
  case class VoidOned(txnItem: TxnItem) extends POSEvent
  object VoidOned {
    def apply(vs: VchStates): VoidOned = VoidOned(TxnItem(vs).copy(
      txntype = TXNTYPE.void
    ))
  }
  case class VoidOffed(txnItem: TxnItem) extends POSEvent
  object VoidOffed {
    def apply(vs: VchStates): VoidOffed = VoidOffed(TxnItem(vs).copy(
      txntype = TXNTYPE.void
    ))
  }
  case class NewVoucher(vnum: Int) extends POSEvent     //新单, reminder for read-side to set new vnum
  case class EndVoucher(vnum: Int) extends POSEvent     //单据终结标示
  case class VoidVoucher(txnItem: TxnItem) extends POSEvent
  object VoidVoucher {
    def apply(vs: VchStates): VoidVoucher = VoidVoucher(TxnItem(vs).copy(
      txntype = TXNTYPE.voidall
    ))
  }
  case class SuspVoucher(txnItem: TxnItem) extends POSEvent
  object SuspVoucher {
    def apply(vs: VchStates): SuspVoucher = SuspVoucher(TxnItem(vs).copy(
      txntype = TXNTYPE.suspend
    ))
  }
  case class VoucherNumed(fnum: Int, tnum: Int) extends POSEvent
  case class SalesLogged(txnItem: TxnItem) extends POSEvent
  case class Subtotaled(txnItem: TxnItem) extends POSEvent
  object Subtotaled {
    def apply(vs: VchStates, vi: VchItems): Subtotaled = {
      val (cnt,tqty,tamt,tdsc) = vi.subTotal
      Subtotaled(TxnItem(vs).copy(
        txntype = TXNTYPE.sales,
        salestype = SALESTYPE.sub,
        qty = tqty,
        amount = tamt,
        dscamt = tdsc,
        price = cnt
      ))
    }
  }
  case class Discounted(txnItem: TxnItem) extends POSEvent
  case class Payment(txnItem: TxnItem) extends POSEvent          //settlement   结算支付
  object Payment {
    def apply(acct: String, num: String, vs: VchStates): Payment = Payment(TxnItem(vs).copy(
      txntype = TXNTYPE.sales,
      salestype = SALESTYPE.ttl,
      dpt = acct,
      code = num
    ))
  }
}

object Responses {
  object STATUS {
    val OK: Int = 0
    val FAIL: Int = -1
  }
  case class POSResponse (sts: Int, msg: String, voucher: VchStates, txnItems: List[TxnItem])
}

package pos.dao
import java.time.LocalDate
import java.time.format.DateTimeFormatter
case class Item(
                 brd: String
                 ,dpt: String
                 ,cat: String
                 ,code: String
                 ,name: String
                 ,price: Int
               )
object Items {
  val apple = Item("01","02","01","001", "green apple", 820)
  val grape = Item("01","02","01","002", "red grape", 1050)
  val orage = Item("01","02","01","003", "sunkist orage", 350)
  val banana = Item("01","02","01","004", "demon banana", 300)
  val pineapple = Item("01","02","01","005", "hainan pineapple", 1300)
  val peach = Item("01","02","01","006", "xinjiang peach", 2390)
  val tblItems = List(apple, grape, orage, banana, pineapple, peach)
  sealed trait QueryItemsResult {}
  case class QueryItemsOK(items: List[Item]) extends QueryItemsResult
  case class QueryItemsFail(msg: String) extends QueryItemsResult
}
object Codes {
  case class User(code: String, name: String, passwd: String)
  case class Department(code: String, name: String)
  case class Category(code: String, name: String)
  case class Brand(code: String, name: String)
  case class Ra(code: String, name: String)
  case class Account(code: String, name: String)
  case class Disc(code: String, best: Boolean, aggr: Boolean, group: Boolean)
  val ras = List(Ra("01","Delivery"),Ra("02","Cooking"))
  val dpts = List(Department("01","Fruit"),Department("02","Grocery"))
  val cats = List(Category("0101","Fresh Fruit"),Category("0201","Dry Grocery"))
  val brds = List(Brand("01","Sunkist"),Brand("02","Demon"))
  val accts = List(Account("001","Cash"),Account("002","Value Card"), Account("003", "Visa")
    ,Account("004","Alipay"),Account("005","WXPay"))
  val users = List(User("1001","Tiger", "123"),User("1002","John", "123"),User("1003","Maria", "123"))
  def getDpt(code: String) = dpts.find(d => d.code == code)
  def getCat(code: String) = cats.find(d => d.code == code)
  def getBrd(code: String) = brds.find(b => b.code == code)
  def getAcct(code: String) = accts.find(a => a.code == code)
  def getRa(code: String) = ras.find(a => a.code == code)
}
object DAO {
  import Items._
  import Codes._
  def getItem(code: String): QueryItemsResult = {
    val optItem = tblItems.find(it => it.code == code)
    optItem match {
      case Some(item) => QueryItemsOK(List(item))
      case None => QueryItemsFail("Invalid item code!")
    }
  }
  def validateDpt(code: String) = dpts.find(d => d.code == code)
  def validateCat(code: String) = cats.find(d => d.code == code)
  def validateBrd(code: String) = brds.find(b => b.code == code)
  def validateRa(code: String) = ras.find(ac => ac.code == code)
  def validateAcct(code: String) = accts.find(ac => ac.code == code)
  def validateUser(userid: String, passwd: String) = users.find(u => (u.code == userid && u.passwd == passwd))
  def lastSecOfDateStr(ldate: LocalDate): String = {
    ldate.format(DateTimeFormatter.ofPattern( "yyyy-MM-dd"))+" 23:59:59"
  }
}

class WriterActor extends PersistentActor with LogSupport {
  val cluster = Cluster(context.system)
  // shopdptId-posId
  // self.path.parent.name is the type name (utf-8 URL-encoded)
  // self.path.name is the entry identifier (utf-8 URL-encoded)  but entity has a supervisor
  // override def persistenceId: String = self.path.parent.parent.name + "-" + self.path.parent.name
  override def persistenceId: String = self.path.parent.name
  override def preRestart(reason: Throwable, message: Option[Any]): Unit = {
    super.preRestart(reason, message)
    log.info(s"Restarting terminal $persistenceId on ${cluster.selfAddress} for $message")
  }
  override def postRestart(reason: Throwable): Unit = {
    super.postRestart(reason)
    log.info(s"terminal $persistenceId on ${cluster.selfAddress} restarted for ${reason.getMessage}")
  }
  override def postStop(): Unit = {
    log.info(s"terminal $persistenceId on ${cluster.selfAddress} stopped!")
  }
  override def preStart(): Unit = {
    log.info(s"terminal $persistenceId on ${cluster.selfAddress} starting...")
  }
  //helper functions
  object RunPOSCommand {
    def unapply(arg: POSCommand) = if (cmdFilter(persistenceId,arg,vchState,vchItems,sender())) Some(arg) else None
  }
  def persistEvent[E](evt: E)(f: E => Unit)(implicit dm: DebugMode) = {
    if (dm.debug)
      log.info(s"********** $persistenceId: persisted event: {$evt} **********")
    else {
      try {
        persist(evt)(f)
        log.debug(s"终端-$persistenceId：event: [$evt] state: [$vchState] : [${vchItems.txnitems.reverse}]")
      }
      catch {
        case err: Throwable =>
          sender() ! POSResponse(STATUS.FAIL, s"终端-$persistenceId： 操作失败！[${err.getMessage}]。", vchState, vchItems.txnitems.reverse)
          log.error(s"终端-$persistenceId： 操作失败！[${err.getMessage}] current state: [$vchState],[${vchItems.txnitems.reverse}]")
      }
    }
  }
  var debugConfig: com.typesafe.config.Config = _
  var debug: Boolean = _
  try {
    debugConfig = ConfigFactory.load("pos.conf").getConfig("pos.server")
    debug = debugConfig.getBoolean("debug")
  }
  catch {
    case _ : Throwable => debug = false
  }
  log.info(s"********** $persistenceId: debug mode = $debug **********")
  implicit val debugMode = DebugMode(debug)
//actor state
  var vchState = VchStates()
  var vchItems = VchItems()
  override def receiveRecover: Receive = {
    case evt: POSEvent =>    //incompleted voucher play back events
      val (vs,vi) =  updateState(evt,vchState,vchItems)
      vchState = vs; vchItems = vi
    case SnapshotOffer(_,vs: VchStates) => vchState = vs  //restore num,seq ...
  }
  
  override def receiveCommand: Receive = logOffState
...
}

  private def logOffState: Receive = {
    case RunPOSCommand(LogOn(opr, _)) =>
          persistEvent(LogOned(opr,vchState)) { evt =>
            val sts = updateState(evt, vchState, vchItems)
//starting seqenceNr for any voucher. no action logged before login
            vchState = sts._1.copy(jseq = lastSequenceNr + 1);
            vchItems = sts._2
            sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 用户{$opr}成功登陆。", vchState, List(vchItems.txnitems.head))
            context.become(logOnState)
          }
      
    case PassivatePOS =>
      log.info(s"**********${persistenceId} got passivate message and stopping  ... ***********")
      context.parent ! PoisonPill
    case _ =>
      sender() ! POSResponse(STATUS.FAIL, s"操作失败！终端 ${persistenceId} 用户未登陆。", vchState, List())
  }

  private def logOnState: Receive = {
...
    //first payment in a voucher
    case RunPOSCommand(OfflinePay(acct,num, amount)) =>
      persistEvent(Payment(acct,num,vchState)) { evt =>
        val sts = updateState(evt, vchState, vchItems)
        vchState = sts._1
        vchItems = sts._2
        if (vchItems.totalSales > 0)
          sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}支付。", vchState, List(vchItems.txnitems.head))
        else
          sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}退款。", vchState, List(vchItems.txnitems.head))
        if (!vchState.due) {  //completed voucher. mark end of voucher and move next. stay in logOnState
          persistEvent(EndVoucher(vchState.num)) { evt =>
            val sts = updateState(evt, vchState, vchItems)
            vchState = sts._1
            vchItems = sts._2
            saveSnapshot(vchState)     //recovery to next voucher
          }
        }
        else context.become(paymentState)     //switch into paymentState
      }
...
}

 private def paymentState: Receive = {
    case RunPOSCommand(OfflinePay(acct,num, amount)) =>
           persistEvent(Payment(acct,num,vchState)) { evt =>
             val sts = updateState(evt, vchState, vchItems)
             vchState = sts._1
             vchItems = sts._2
             if (vchItems.totalSales > 0)
               sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}支付。", vchState, List(vchItems.txnitems.head))
             else
               sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}退款。", vchState, List(vchItems.txnitems.head))
             if (!vchState.due) {  //completed voucher. mark end of voucher and move next. return to logOnState
               persistEvent(EndVoucher(vchState.num)) { evt =>
                 val sts = updateState(evt, vchState, vchItems, lastSeqenceNr)
                 vchState = sts._1
                 vchItems = sts._2
                 saveSnapshot(vchState)     //recovery to next voucher
                 context.unbecome()    //logOnState
               }
             }
             // else wait for other payments and stay in logOnState
           }
 /* strictly disallow any action other than payment till completion
    case RunPOSCommand(VoidAll) =>
      persistEvent(VoidVoucher(vchState)) { _ =>
        persistEvent(EndVoucher(vchState.num)) { evt =>
          updateState(evt,vchState,vchItems)
          context.unbecome()    //in paymentState, switch to logOnState
        }
      }
    case RunPOSCommand(Suspend) =>
      persistEvent(SuspVoucher(vchState)) { _ =>
        persistEvent(EndVoucher(vchState.num)) { evt =>
          updateState(evt,vchState,vchItems)
          context.unbecome()    //in paymentState, switch to logOnState
        }
      }
*/
    case RunPOSCommand(SuperOn(su,_)) =>
      persistEvent(SuperOned(su,vchState)) { evt =>
        val sts = updateState(evt, vchState, vchItems)
        vchState = sts._1
        vchItems = sts._2
      }
    case RunPOSCommand(SuperOff) =>
      persistEvent(SuperOffed(vchState)) { evt =>
        val sts = updateState(evt, vchState, vchItems)
        vchState = sts._1
        vchItems = sts._2
      }
    case RunPOSCommand(VCBalance(acct,num,passwd)) =>
      if (POSInterfaces.validateVC(acct,num,passwd)) {
        val res = POSInterfaces.getVCBalance(acct,num)
        if (res.sts == POSInterfaces.VCRESULT.OK)
          sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 储值卡余额{${res.amt}}。", vchState, List(TxnItem(vchState).copy(
            amount = (res.amt * 100).toInt,
            dpt = acct,
            code = num
          )))
        else
          sender() ! POSResponse(STATUS.FAIL, s"终端-$persistenceId： 储值卡[$num]余额读取错误！[${res.msg}]", vchState, List())
      } else {
        sender() ! POSResponse(STATUS.FAIL, s"终端-$persistenceId： 储值卡[$num]验证信息错误！", vchState, List())
      }
    case RunPOSCommand(VCPay(acct,num, passwd,amount)) =>
      if (POSInterfaces.validateVC(acct,num,passwd)) {
        val res = POSInterfaces.getVCBalance(acct,num)
        if (res.sts == POSInterfaces.VCRESULT.OK) {
          if ((res.amt * 100).toInt < amount)
            sender() ! POSResponse(STATUS.FAIL, s"终端-$persistenceId： 储值卡[$num]余额不足！", vchState,List(TxnItem(vchState).copy(
              amount = (res.amt * 100).toInt,
              dpt = acct,
              code = num
            )))
          else {
            val res = POSInterfaces.payByVC(acct,num,amount/100.00)
            if (res.sts == POSInterfaces.VCRESULT.OK) {
              persistEvent(Payment(acct,num,vchState)) { evt =>
                val sts = updateState(evt, vchState, vchItems)
                vchState = sts._1
                vchItems = sts._2
                if (vchItems.totalSales > 0)
                  sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}支付。", vchState, List(vchItems.txnitems.head))
                else
                  sender() ! POSResponse(STATUS.OK, s"终端-$persistenceId： 成功完成{${vchItems.txnitems.head.category} ${amount/100.0}退款。", vchState, List(vchItems.txnitems.head))
                if (!vchState.due) {  //completed voucher. mark end of voucher and move next. stay in logOnState
                  persistEvent(EndVoucher(vchState.num)) { evt =>
                    val sts = updateState(evt, vchState, vchItems, lastSeqenceNr)
                    vchState = sts._1
                    vchItems = sts._2
                    saveSnapshot(vchState)     //recovery to next voucher
                    context.unbecome()         //switch to logOnState
                  }
                }
              }
            }
          }
        }
        else
          sender() ! POSResponse(STATUS.FAIL, s"终端-$persistenceId： 储值卡[$num]余额读取错误！[${res.msg}]", vchState, List())
      } else {
        sender() ! POSResponse(STATUS.FAIL, s"终端-$persistenceId： 储值卡[$num]验证信息错误！", vchState, List())
      }
    case _ =>
      sender() ! POSResponse(STATUS.FAIL, s"操作失败！终端 ${persistenceId} 结算中不容许其它非支付操作！", vchState, List(vchItems.txnitems.head))
  }

  case class VchStates(
                        opr: String = "",      //收款员
                        jseq: BigInt = 0,      //begin journal sequence for read-side replay
                        num: Int = 0,          //当前单号
                        seq: Int = 1,          //当前序号
                        void: Boolean = false, //取消模式
                        refd: Boolean = false, //退款模式
                        due: Boolean = true,   //当前余额
                        su: String = "",
                        mbr: String = ""
                      ) {
    def nextVoucher : VchStates = VchStates().copy(
      opr = this.opr,
      jseq = this.jseq + 1,
      num = this.num + 1
    )
  }

 def updateState(evt: POSEvent, state: VchStates, items: VchItems, lastSeqNr: BigInt = 0): (VchStates, VchItems) = evt match {
    case LogOned(txn) => (state.copy(seq = txn.seq + 1,opr = txn.opr,jseq = lastSeqNr), items)
...
   case EndVoucher(vnum) => (state.nextVoucher.copy(jseq = lastSeqNr), VchItems())
...
}

name := "akka-cluster-pos"
 
version := "0.2"
 
scalaVersion := "2.12.8"
 
libraryDependencies := Seq(
  "com.typesafe.akka" %% "akka-cluster-sharding" % "2.5.21",
  "com.typesafe.akka" %% "akka-persistence" % "2.5.21",
  "com.typesafe.akka" %% "akka-persistence-cassandra" % "0.92",
  "com.typesafe.akka" %% "akka-persistence-cassandra-launcher" % "0.92" % Test,
  "ch.qos.logback"  %  "logback-classic"   % "1.2.3"
)

akka.actor.warn-about-java-serializer-usage = off
akka.log-dead-letters-during-shutdown = off
akka.log-dead-letters = off
 
akka {
  loglevel = INFO
  actor {
    provider = "cluster"
  }
 
  remote {
    log-remote-lifecycle-events = off
    netty.tcp {
      hostname = "127.0.0.1"
      port = 0
    }
  }
 
  cluster {
    seed-nodes = [
      "akka.tcp://posSystem@127.0.0.1:2551"]
    log-info = off
    sharding {
      role = "shard"
      passivate-idle-entity-after = 10 s
    }
  }
 
  persistence {
    journal.plugin = "cassandra-journal"
    snapshot-store.plugin = "cassandra-snapshot-store"
  }
 
}
 
cassandra-journal {
  contact-points = ["192.168.1.18"]
}
 
cassandra-snapshot-store {
  contact-points = ["192.168.1.18"]
}