联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
wuxw
2025-03-20 e40889177c25035496c526dbc12a9665d5b61ceb 
 service-report/src/main/java/com/java110/report/cmd/reportCustomComponent/ListReportCustomComponentDataCmd.java


@@ -15,20 +15,22 @@


 */


package com.java110.report.cmd.reportCustomComponent;




import com.alibaba.fastjson.JSONArray;


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.core.log.LoggerFactory;


import com.java110.dto.PageDto;


import com.java110.dto.reportCustomComponent.ReportCustomComponentDto;


import com.java110.dto.reportCustom.ReportCustomComponentDto;


import com.java110.intf.report.IReportCustomComponentV1InnerServiceSMO;


import com.java110.service.smo.IQueryServiceSMO;


import com.java110.utils.exception.CmdException;


import com.java110.utils.util.Assert;


import com.java110.utils.util.StringUtil;


import com.java110.vo.ResultVo;


import org.slf4j.Logger;


import com.java110.core.log.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.http.HttpStatus;


import org.springframework.http.ResponseEntity;


@@ -50,9 +52,9 @@


public class ListReportCustomComponentDataCmd extends Cmd {




    private static Logger logger = LoggerFactory.getLogger(ListReportCustomComponentDataCmd.class);




    @Autowired


    private IReportCustomComponentV1InnerServiceSMO reportCustomComponentV1InnerServiceSMOImpl;








    @Autowired


@@ -63,8 +65,12 @@


        super.validatePageInfo(reqJson);


        Assert.hasKeyAndValue(reqJson, "componentId", "未包含组件ID");


    }




    @Override


    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {




        String storeId = cmdDataFlowContext.getReqHeaders().get("store-id");


        reqJson.put("storeId", storeId);




        //查询组件是否存在


        ReportCustomComponentDto reportCustomComponentDto = new ReportCustomComponentDto();


@@ -91,7 +97,10 @@


            reqJson.put("page", (page - 1) * reqJson.getIntValue("row"));


        }


        JSONObject data = queryServiceSMOImpl.execJava(reqJson, javaScript);


        long total = data.getLong("total");


        long total = 0;


        if (data.getLong("total") != null) {


            total = data.getLong("total");


        }


        ResultVo resultVo = new ResultVo((int) Math.ceil((double) total / (double) reqJson.getInteger("row")), total, data);


        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);


        cmdDataFlowContext.setResponseEntity(responseEntity);


@@ -119,9 +128,15 @@


            reqJson.put("page", (page - 1) * reqJson.getIntValue("row"));


        }


        JSONObject data = queryServiceSMOImpl.execQuerySql(reqJson, sql);


        if (!sql.trim().contains("test=\"count")) {


            total = JSONArray.parseArray(data.getString("td")).size();


        }


        if (!StringUtil.isEmpty(sql) && !sql.contains("limit #page#,#row#")) {


            sql = sql + " limit #page#,#row#";


            data = queryServiceSMOImpl.execQuerySql(reqJson, sql);


        }


        ResultVo resultVo = new ResultVo((int) Math.ceil((double) total / (double) reqJson.getInteger("row")), total, data);


        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);


        cmdDataFlowContext.setResponseEntity(responseEntity);


    }




}