任务相关

This commit is contained in:
李玉东 2025-09-21 02:50:53 +08:00
parent 7859078d72
commit dc3c091a7c
4 changed files with 18 additions and 13 deletions

View File

@ -391,14 +391,14 @@ public abstract class AbtParentTask implements TaskAction {
private RedisUtil redisUtil; private RedisUtil redisUtil;
protected EditScenarioInfo getEditScenarioInfo(String resourceId) { protected EditScenarioInfo getEditScenarioInfo(String resourceId) {
String updJsonStr = (String) redisUtil.hget( String updJsonStr = (String) SpringUtil.getBean(RedisUtil.class).hget(
this.scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), this.scenarioTask.getScenarioId() + "-" + roomId + "-" + resourceId,
"updScenarioInfo"); "updScenarioInfo");
return JSON.parseObject(updJsonStr, EditScenarioInfo.class); return JSON.parseObject(updJsonStr, EditScenarioInfo.class);
} }
protected void setEditScenarioInfo(EditScenarioInfo editScenarioInfo) { protected void setEditScenarioInfo(EditScenarioInfo editScenarioInfo) {
redisUtil.hset( SpringUtil.getBean(RedisUtil.class).hset(
this.scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), this.scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
"updScenarioInfo", JSON.toJSONString(editScenarioInfo)); "updScenarioInfo", JSON.toJSONString(editScenarioInfo));
} }

View File

@ -11,6 +11,7 @@ import com.hivekion.room.func.TaskAction;
import com.hivekion.scenario.entity.BattleConsume; import com.hivekion.scenario.entity.BattleConsume;
import com.hivekion.scenario.entity.ScenarioTask; import com.hivekion.scenario.entity.ScenarioTask;
import com.hivekion.scenario.service.impl.BattleConsumeServiceImpl; import com.hivekion.scenario.service.impl.BattleConsumeServiceImpl;
import com.hivekion.statistic.bean.EditScenarioInfo;
import com.hivekion.statistic.bean.ScenarioInfo; import com.hivekion.statistic.bean.ScenarioInfo;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.HashMap; import java.util.HashMap;
@ -41,11 +42,8 @@ public class MoveTask extends AbtParentTask implements TaskAction {
/** /**
* 消耗任务间隔 * 消耗任务间隔
*/ */
private final int consumptionTaskInterval = 10; private final int consumptionTaskInterval = 5;
/**
* redis 服务类
*/
private final RedisUtil redis = SpringUtil.getBean(RedisUtil.class);
@ -105,13 +103,17 @@ public class MoveTask extends AbtParentTask implements TaskAction {
log.info("{}-当前消耗油料::{},当前剩余油料::{}", scenarioTask.getResourceId(), log.info("{}-当前消耗油料::{},当前剩余油料::{}", scenarioTask.getResourceId(),
currentUseUp, currentFuel); currentUseUp, currentFuel);
//修改油料
EditScenarioInfo editScenarioInfo = getEditScenarioInfo(
this.scenarioTask.getResourceId());
editScenarioInfo.getJbxx().getFuel().setCurrent(editScenarioInfo.getJbxx().getFuel().getCurrent()-currentUseUp);
setEditScenarioInfo(editScenarioInfo);
//插入消耗表 //插入消耗表
insertConsumption(currentUseUp); insertConsumption(currentUseUp);
pushStatus(scenarioTask.getResourceId());
setCurrentFuel(currentUseUp);
setCurrentFuel(currentUseUp);
pushStatus(scenarioTask.getResourceId());
} }
@ -148,13 +150,13 @@ public class MoveTask extends AbtParentTask implements TaskAction {
private void setCurrentFuel(double num) { private void setCurrentFuel(double num) {
Object statisticObj = redis.hget( Object statisticObj = SpringUtil.getBean(RedisUtil.class).hget(
scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
"scenarioInfo"); "scenarioInfo");
if (statisticObj != null) { if (statisticObj != null) {
ScenarioInfo scenarioInfo = JSON.parseObject(statisticObj.toString(), ScenarioInfo.class); ScenarioInfo scenarioInfo = JSON.parseObject(statisticObj.toString(), ScenarioInfo.class);
scenarioInfo.getFuel().setCurrent(scenarioInfo.getFuel().getCurrent() - num); scenarioInfo.getFuel().setCurrent(scenarioInfo.getFuel().getCurrent() - num);
redis.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), SpringUtil.getBean(RedisUtil.class).hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
"scenarioInfo", JSON.toJSONString(scenarioInfo)); "scenarioInfo", JSON.toJSONString(scenarioInfo));
} }
} }

View File

@ -44,5 +44,7 @@ public class Teaminfo extends SearchInputVo {
private String iconId; private String iconId;
@TableField(value="team_type") @TableField(value="team_type")
private Integer teamType; private Integer teamType;
@TableField(value="role_code")
private String roleCode;
} }

View File

@ -9,6 +9,7 @@
<result property="mappingguid" column="mappingguid"/> <result property="mappingguid" column="mappingguid"/>
<result property="iconId" column="icon_id"/> <result property="iconId" column="icon_id"/>
<result property="teamType" column="team_type"/> <result property="teamType" column="team_type"/>
<result property="roleCode" column="role_code"/>
<!-- 其他字段 --> <!-- 其他字段 -->
</resultMap> </resultMap>
<select id="list" resultMap="DMTeamInfo" parameterType="com.hivekion.team.entity.Teaminfo" databaseId="dm"> <select id="list" resultMap="DMTeamInfo" parameterType="com.hivekion.team.entity.Teaminfo" databaseId="dm">