| | |
| | | import com.java110.utils.util.BeanConvertUtil; |
| | | import com.java110.utils.util.DateUtil; |
| | | import com.java110.utils.util.StringUtil; |
| | | import com.java110.vo.ResultVo; |
| | | import org.slf4j.Logger; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.http.HttpStatus; |
| | |
| | | @Override |
| | | public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { |
| | | logger.debug("ServiceDataFlowEvent : {}", event); |
| | | String storeId = cmdDataFlowContext.getReqHeaders().get("store-id"); |
| | | // String storeId = cmdDataFlowContext.getReqHeaders().get("store-id"); |
| | | // String userId = cmdDataFlowContext.getReqHeaders().get("user-id"); |
| | | // reqJson.put("storeId", storeId); |
| | |
| | | } |
| | | |
| | | contractDto.setContractId(reqJson.getString("contractId")); |
| | | |
| | | contractDto.setCommunityId(reqJson.getString("communityId")); |
| | | contractDto.setStoreId(storeId); |
| | | //contractDto.setCommunityId(reqJson.getString("communityId")); |
| | | contractDtos = contractInnerServiceSMOImpl.queryContracts(contractDto); |
| | | |
| | | if (contractDtos == null || contractDtos.size() < 1) { |
| | |
| | | paramOut.put("totalRoom", contractDtos.size()); |
| | | paramOut.put("successRoom", contractDtos.size() - failRooms); |
| | | paramOut.put("errorRoom", failRooms); |
| | | responseEntity = new ResponseEntity<>(paramOut.toJSONString(), HttpStatus.OK); |
| | | context.setResponseEntity(responseEntity); |
| | | |
| | | context.setResponseEntity( ResultVo.createResponseEntity(paramOut)); |
| | | } |
| | | |
| | | |