copy from service-community/src/main/java/com/java110/community/cmd/room/ListRoomCmd.java
copy to service-community/src/main/java/com/java110/community/cmd/community/ListCommunityCmd.java
| File was copied from service-community/src/main/java/com/java110/community/cmd/room/ListRoomCmd.java |
| | |
| | | * See the License for the specific language governing permissions and |
| | | * limitations under the License. |
| | | */ |
| | | package com.java110.community.cmd.room; |
| | | package com.java110.community.cmd.community; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.java110.core.annotation.Java110Cmd; |
| | |
| | | import com.java110.core.event.cmd.AbstractServiceCmdListener; |
| | | import com.java110.core.event.cmd.CmdEvent; |
| | | import com.java110.core.factory.GenerateCodeFactory; |
| | | import com.java110.dto.RoomDto; |
| | | import com.java110.intf.community.IRoomV1InnerServiceSMO; |
| | | import com.java110.po.room.RoomPo; |
| | | import com.java110.intf.community.ICommunityV1InnerServiceSMO; |
| | | import com.java110.po.community.CommunityPo; |
| | | 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 com.java110.dto.community.CommunityDto; |
| | | import java.util.List; |
| | | import java.util.ArrayList; |
| | | import org.springframework.http.ResponseEntity; |
| | |
| | | |
| | | /** |
| | | * 类表述:查询 |
| | | * 服务编码:room.listRoom |
| | | * 请求路劲:/app/room.ListRoom |
| | | * add by 吴学文 at 2021-09-14 14:28:56 mail: 928255095@qq.com |
| | | * 服务编码:community.listCommunity |
| | | * 请求路劲:/app/community.ListCommunity |
| | | * add by 吴学文 at 2021-09-18 12:54:57 mail: 928255095@qq.com |
| | | * open source address: https://gitee.com/wuxw7/MicroCommunity |
| | | * 官网:http://www.homecommunity.cn |
| | | * 温馨提示:如果您对此文件进行修改 请不要删除原有作者及注释信息,请补充您的 修改的原因以及联系邮箱如下 |
| | | * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复,注释10至20行 加入 20行至30行 |
| | | */ |
| | | @Java110Cmd(serviceCode = "room.ListRoom") |
| | | public class ListRoomCmd extends AbstractServiceCmdListener { |
| | | @Java110Cmd(serviceCode = "community.listCommunity") |
| | | public class ListCommunityCmd extends AbstractServiceCmdListener { |
| | | |
| | | private static Logger logger = LoggerFactory.getLogger(ListRoomCmd.class); |
| | | private static Logger logger = LoggerFactory.getLogger(ListCommunityCmd.class); |
| | | @Autowired |
| | | private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl; |
| | | private ICommunityV1InnerServiceSMO communityV1InnerServiceSMOImpl; |
| | | |
| | | @Override |
| | | public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) { |
| | |
| | | } |
| | | |
| | | @Override |
| | | @Java110Transactional |
| | | public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { |
| | | |
| | | RoomDto roomDto = BeanConvertUtil.covertBean(reqJson, RoomDto.class); |
| | | CommunityDto communityDto = BeanConvertUtil.covertBean(reqJson, CommunityDto.class); |
| | | |
| | | int count = roomV1InnerServiceSMOImpl.queryRoomsCount(roomDto); |
| | | int count = communityV1InnerServiceSMOImpl.queryCommunitysCount(communityDto); |
| | | |
| | | List<RoomDto> roomDtos = null; |
| | | List<CommunityDto> communityDtos = null; |
| | | |
| | | if (count > 0) { |
| | | roomDtos = roomV1InnerServiceSMOImpl.queryRooms(roomDto); |
| | | communityDtos = communityV1InnerServiceSMOImpl.queryCommunitys(communityDto); |
| | | } else { |
| | | roomDtos = new ArrayList<>(); |
| | | communityDtos = new ArrayList<>(); |
| | | } |
| | | |
| | | ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, roomDtos); |
| | | ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, communityDtos); |
| | | |
| | | ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK); |
| | | |