wuxw
2022-11-01 334fabfc24a0e8a24b4f7a9034349fd1f070956c
service-store/src/main/java/com/java110/store/cmd/scheduleClasses/DeleteScheduleClassesCmd.java
@@ -22,8 +22,12 @@
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.intf.store.IScheduleClassesDayV1InnerServiceSMO;
import com.java110.intf.store.IScheduleClassesTimeV1InnerServiceSMO;
import com.java110.intf.store.IScheduleClassesV1InnerServiceSMO;
import com.java110.po.scheduleClasses.ScheduleClassesPo;
import com.java110.po.scheduleClassesDay.ScheduleClassesDayPo;
import com.java110.po.scheduleClassesTime.ScheduleClassesTimePo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
@@ -49,6 +53,13 @@
    @Autowired
    private IScheduleClassesV1InnerServiceSMO scheduleClassesV1InnerServiceSMOImpl;
    @Autowired
    private IScheduleClassesDayV1InnerServiceSMO scheduleClassesDayV1InnerServiceSMOImpl;
    @Autowired
    private IScheduleClassesTimeV1InnerServiceSMO scheduleClassesTimeV1InnerServiceSMOImpl;
    @Override
    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
        Assert.hasKeyAndValue(reqJson, "scheduleId", "scheduleId不能为空");
@@ -66,6 +77,23 @@
            throw new CmdException("删除数据失败");
        }
        ScheduleClassesDayPo scheduleClassesDayPo = new ScheduleClassesDayPo();
        scheduleClassesDayPo.setScheduleId(scheduleClassesPo.getScheduleId());
        flag = scheduleClassesDayV1InnerServiceSMOImpl.deleteScheduleClassesDay(scheduleClassesDayPo);
        if (flag < 1) {
            throw new CmdException("更新数据失败");
        }
        ScheduleClassesTimePo scheduleClassesTimePo = new ScheduleClassesTimePo();
        scheduleClassesTimePo.setScheduleId(scheduleClassesPo.getScheduleId());
        flag = scheduleClassesTimeV1InnerServiceSMOImpl.deleteScheduleClassesTime(scheduleClassesTimePo);
        if (flag < 1) {
            throw new CmdException("更新数据失败");
        }
        cmdDataFlowContext.setResponseEntity(ResultVo.success());
    }
}