package com.java110.report.cmd.owner; import com.alibaba.fastjson.JSONObject; import com.java110.core.annotation.Java110Cmd; import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.dto.owner.OwnerDto; import com.java110.intf.report.IReportOrderStatisticsInnerServiceSMO; import com.java110.utils.exception.CmdException; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import com.java110.vo.ResultVo; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.ResponseEntity; import java.text.ParseException; import java.util.ArrayList; import java.util.List; import java.util.Map; /** * 业主 家庭成员 就餐明细 */ @Java110Cmd(serviceCode = "owner.queryOwnerDining") public class QueryOwnerDiningCmd extends Cmd { @Autowired private IReportOrderStatisticsInnerServiceSMO reportOrderStatisticsInnerServiceSMOImpl; @Override public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException { Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区"); if(reqJson.containsKey("startDate") && reqJson.containsKey("endDate")) { String startDate = reqJson.getString("startDate"); String endDate = reqJson.getString("endDate"); if (!startDate.contains(":")) { startDate += " 00:00:00"; reqJson.put("startDate", startDate); } if (!endDate.contains(":")) { endDate += " 23:59:59"; reqJson.put("endDate", endDate); } } } @Override public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException { int row = reqJson.getInteger("row"); OwnerDto ownerDto = BeanConvertUtil.covertBean(reqJson, OwnerDto.class); // todo 查询总数量 int total = reportOrderStatisticsInnerServiceSMOImpl.getOwnerDiningCount(ownerDto); // int count = 0; List infos = null; if (total > 0) { infos = reportOrderStatisticsInnerServiceSMOImpl.getOwnerDinings(ownerDto); } else { infos = new ArrayList<>(); } ResponseEntity responseEntity = ResultVo.createResponseEntity((int) Math.ceil((double) total / (double) row), total, infos); context.setResponseEntity(responseEntity); } }