Commit f79a83ad authored by litengwei's avatar litengwei

双规优化

parent 8735ef8f
......@@ -269,6 +269,8 @@ public interface PlanTaskMapper extends BaseMapper {
int deleteDate(String table);
int deleteOne(String table, String checkDate);
Long selectRoutId(String id);
List<String> selectPlanTaskIdLists(long planId, int status, int status1);
......
......@@ -693,6 +693,9 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
//2.5.插入planTask及planTaskDetail
insertPlanTaskAndDetNew(list, plan, XJConstant.SCHED_FLAG, now, null);
// 更新统计表
taskStaticExecution(null);
}
}
......@@ -746,6 +749,9 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
}
}
planTaskMapper.deleteOne(P_STATIC_DAY, runDate);
planTaskMapper.deleteOne(P_STATIC_WEEK, runDate);
planTaskMapper.deleteOne(P_STATIC_MONTH, runDate);
// 插入日统计表
List<Map<String, Object>> listDay = checkMapper.planCount(runDate, null, String.valueOf(PlanTaskTypeStatusEnum.day.getValue()), null,null,null);
List<StaticDay> staticDays = listDay.stream().map(e->{
......@@ -836,7 +842,6 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
* @param plan
* @param flag 是否初始状态0-初始 1-非初始
*/
@Async("asyncServiceExecutor")
public void insertPlanTaskAndDetNew(List<HashMap<String, Object>> list, Plan plan, String flag, Date now, List<ESPlanTaskListDto> oldEsPlanTaskListDtos) {
if (list == null || list.size() <= 0) {
HashMap<String, Object> paramMap = new HashMap<String, Object>();
......
......@@ -1732,6 +1732,10 @@
delete from ${table} where 1=1;
</delete>
<delete id="deleteOne">
delete from ${table} where check_time = #{checkDate};
</delete>
<select id="selectRoutId" resultType="java.lang.Long">
select route_id from p_plan_task where id = #{id}
</select>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment