divwaron.go 6.1 KB

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