divwaron.go 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185
  1. package divwaron
  2. import (
  3. "context"
  4. "fmt"
  5. "strings"
  6. "time"
  7. "wartank/pkg/components/safebool"
  8. "wartank/pkg/components/section"
  9. "wartank/pkg/components/sectionnet"
  10. "wartank/pkg/types"
  11. "wartank/server/serv_bots/warbot/angar/division/divwar/divwaron/health"
  12. "wartank/server/serv_bots/warbot/angar/division/divwar/divwaron/manevr"
  13. "wartank/server/serv_bots/warbot/angar/division/divwar/divwaron/shot"
  14. )
  15. /*
  16. Предоставляет сетевой компонент при непосредственном сражении
  17. */
  18. // DivWarOn -- непосредственно танкует в сражении
  19. type DivWarOn struct {
  20. *section.Section
  21. bot types.ИБот
  22. net *sectionnet.SectionNet
  23. ctxDivWar context.Context // Контекст сражения
  24. fnCancelDivWar func() // Функция отмены сражения
  25. shot *shot.Shot // Объект выстрела
  26. health *health.Health // Текущее здоровье танка
  27. manevr *manevr.Manevr // Возможность маневрирования
  28. login string
  29. isMasking *safebool.SafeBool // Признак необходимости маскирования (запрет стрельбы, когда слабое здоровье)
  30. chTick chan int // Ежесекудная проверка на окончание сражения
  31. isEnd *safebool.SafeBool
  32. }
  33. // NewDivWarOn -- возвращает новый *DivWarOn
  34. func NewDivWarOn(bot types.ИБот) (*DivWarOn, error) {
  35. if bot == nil {
  36. return nil, fmt.Errorf("NewDivWarOn(): IBot == nil")
  37. }
  38. ctxDivWar, fnCancelDivWar := context.WithTimeout(bot.Кнт(), time.Second*305)
  39. sf := &DivWarOn{
  40. bot: bot,
  41. ctxDivWar: ctxDivWar,
  42. fnCancelDivWar: fnCancelDivWar,
  43. login: bot.Имя(),
  44. isMasking: safebool.NewSafeBool(),
  45. isEnd: safebool.NewSafeBool(),
  46. }
  47. var err error
  48. { // ISection (ожидание)
  49. sf.Section, err = section.NewSection(bot, "Ожидание битвы дивизий", `<title>Сражения</title>`)
  50. if err != nil {
  51. return nil, fmt.Errorf("NewDivWarOn(): in create *Section, err=\n\t%w", err)
  52. }
  53. }
  54. // sf.net = sectionnet.NewSectionNet(server, bot, "http://wartank.ru/pve")
  55. if sf.checkEnd() {
  56. return nil, fmt.Errorf("NewDivWarOn(): нет страницы для сражения")
  57. }
  58. go sf.makeTick()
  59. go sf.run()
  60. return sf, nil
  61. }
  62. // Ежесекудный тик
  63. func (sf *DivWarOn) makeTick() {
  64. defer func() {
  65. close(sf.chTick)
  66. sf.isEnd.Уст()
  67. }()
  68. for !sf.isEnd.Получ() {
  69. select {
  70. case <-sf.bot.Кнт().Done(): // Отмена контекста приложения
  71. return
  72. case <-sf.ctxDivWar.Done(): // Битва закончилась
  73. return
  74. default:
  75. if sf.isEnd.Получ() {
  76. return
  77. }
  78. sf.chTick <- 1
  79. time.Sleep(time.Second * 1)
  80. }
  81. }
  82. }
  83. // запускает сражение
  84. func (sf *DivWarOn) run() {
  85. // defer log._rintf("DivWarOn.run(): сражение завершено\n")
  86. { // Подготовка к сражению
  87. var err error
  88. sf.shot, err = shot.NewShot(sf, sf.login) // Объект выстрела
  89. if err != nil {
  90. // log._rintf("ERRO DivWarOn.Run(): при создании выстрела танка, err=\n\t%v\n", err)
  91. return
  92. }
  93. sf.health, err = health.NewHealth(sf, sf.shot.IsEnd(), sf.login)
  94. if err != nil {
  95. // log._rintf("ERRO DivWarOn.Run(): при создании здоровья танка, err=\n\t%v\n", err)
  96. sf.shot.IsEnd().Сброс()
  97. return
  98. }
  99. sf.manevr, err = manevr.NewManevr(sf, sf.shot.IsEnd())
  100. if err != nil {
  101. // log._rintf("ERRO DivWarOn.Run(): при создании маневра танка, err=\n\t%v\n", err)
  102. sf.shot.IsEnd().Сброс()
  103. return
  104. }
  105. }
  106. for { // Рабочий цикл сражения
  107. select {
  108. case <-sf.ctxDivWar.Done():
  109. return
  110. case <-sf.ВремяОпрос().КаналСиг():
  111. if sf.checkEnd() {
  112. return
  113. }
  114. }
  115. }
  116. }
  117. // Сеть -- возвращает сетевой компонент секции
  118. func (sf *DivWarOn) Сеть() types.ISectionNet {
  119. return sf.net
  120. }
  121. // Проверяет окончание сражения
  122. func (sf *DivWarOn) checkEnd() bool {
  123. defer func() {
  124. if sf.isEnd.Получ() {
  125. sf.fnCancelDivWar()
  126. // log._rintf("DivWarOn.checkEnd(): сражение завершено\n")
  127. }
  128. }()
  129. if err := sf.net.UpdateLst(); err != nil {
  130. // log._rintf("WARN DivWarOn.checkEnd(): при обновлении lstDivWarOn, err=\n\t%v\n", err)
  131. sf.isEnd.Уст()
  132. sf.fnCancelDivWar()
  133. return true
  134. }
  135. lstDivWarOn := sf.СписПолучить()
  136. for _, strOut := range lstDivWarOn {
  137. if strings.Contains(strOut, `" class="simple-but gray"><span><span>ОБЫЧНЫЕ</span></span></a>`) {
  138. sf.isEnd.Сброс()
  139. return false
  140. }
  141. }
  142. sf.isEnd.Уст()
  143. sf.fnCancelDivWar()
  144. return true
  145. }
  146. // ЕслиКонец -- возвращает признак окончания сражения (интерфейс)
  147. func (sf *DivWarOn) ЕслиКонец() *safebool.SafeBool {
  148. return sf.isEnd
  149. }
  150. func (sf *DivWarOn) Манёвр() {
  151. if sf.manevr == nil {
  152. return
  153. }
  154. if sf.manevr.IsReady() {
  155. sf.manevr.Manevr()
  156. }
  157. }
  158. // ВыстрелБлок -- признак запрета стрельбы при слабом здоровье
  159. func (sf *DivWarOn) ВыстрелБлок() *safebool.SafeBool {
  160. return sf.isMasking
  161. }
  162. // Ctx -- возвращает контекст отмены сражения
  163. func (sf *DivWarOn) Ctx() context.Context {
  164. return sf.ctxDivWar
  165. }
  166. // CancelBattle - -вызов функции отмены контекста сражения
  167. func (sf *DivWarOn) CancelBattle() {
  168. sf.fnCancelDivWar()
  169. }