/* * Copyright 2017-2020 吴学文 and java110 team. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.java110.community.cmd.notice; import com.alibaba.fastjson.JSONObject; import com.java110.core.annotation.Java110Cmd; import com.java110.core.annotation.Java110Transactional; import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.core.factory.GenerateCodeFactory; import com.java110.dto.community.CommunityDto; import com.java110.dto.notice.NoticeDto; import com.java110.dto.org.OrgCommunityDto; import com.java110.dto.org.OrgDto; import com.java110.dto.org.OrgStaffRelDto; import com.java110.intf.community.ICommunityInnerServiceSMO; import com.java110.intf.community.INoticeV1InnerServiceSMO; import com.java110.intf.user.IOrgCommunityInnerServiceSMO; import com.java110.intf.user.IOrgInnerServiceSMO; import com.java110.intf.user.IOrgStaffRelInnerServiceSMO; import com.java110.po.notice.NoticePo; import com.java110.utils.constant.StateConstant; import com.java110.utils.exception.CmdException; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import com.java110.utils.util.StringUtil; import com.java110.vo.ResultVo; import com.java110.vo.api.community.ApiCommunityDataVo; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import java.util.List; /** * 类表述：保存 * 服务编码：notice.saveNotice * 请求路劲：/app/notice.SaveNotice * add by 吴学文 at 2022-07-22 19:20:18 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 = "notice.saveNotice") public class SaveNoticeCmd extends Cmd { private static Logger logger = LoggerFactory.getLogger(SaveNoticeCmd.class); public static final String CODE_PREFIX_ID = "10"; @Autowired private ICommunityInnerServiceSMO communityInnerServiceSMOImpl; @Autowired private IOrgStaffRelInnerServiceSMO orgStaffRelInnerServiceSMOImpl; @Autowired private IOrgCommunityInnerServiceSMO orgCommunityInnerServiceSMOImpl; @Autowired private IOrgInnerServiceSMO orgInnerServiceSMOImpl; @Autowired private INoticeV1InnerServiceSMO noticeV1InnerServiceSMOImpl; @Override public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) { Assert.hasKeyAndValue(reqJson, "title", "必填，请填写标题"); Assert.hasKeyAndValue(reqJson, "noticeTypeCd", "必填，请选择公告类型"); Assert.hasKeyAndValue(reqJson, "context", "必填，请填写公告内容"); Assert.hasKeyAndValue(reqJson, "startTime", "必选，请填写开始时间 "); Assert.hasKeyAndValue(reqJson, "endTime", "必选，请填写结束时间 "); } @Override @Java110Transactional public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { if (!reqJson.containsKey("isAll") || StringUtil.isEmpty(reqJson.getString("isAll")) || "N".equals(reqJson.getString("isAll"))) { addNotice(reqJson); return; } //查询当前员工 的小区 //1.0 先查询 员工对应的部门 OrgStaffRelDto orgStaffRelDto = new OrgStaffRelDto(); orgStaffRelDto.setStoreId(reqJson.getString("storeId")); orgStaffRelDto.setStaffId(reqJson.getString("userId")); List orgStaffRelDtos = orgStaffRelInnerServiceSMOImpl.queryOrgStaffRels(orgStaffRelDto); Assert.listOnlyOne(orgStaffRelDtos, "未查询到相应员工对应的部门信息或查询到多条"); //2.0 再根据 部门对应的 小区ID查询小区信息 OrgDto orgDto = new OrgDto(); orgDto.setOrgId(orgStaffRelDtos.get(0).getParentOrgId()); orgDto.setStoreId(reqJson.getString("storeId")); orgDto.setOrgLevel("2"); List orgDtos = orgInnerServiceSMOImpl.queryOrgs(orgDto); Assert.listOnlyOne(orgDtos, "根据组织ID未查询到员工对应部门信息或查询到多条数据"); List communitys = null; if ("9999".equals(orgDtos.get(0).getBelongCommunityId())) { CommunityDto communityDto = new CommunityDto(); communityDto.setMemberId(reqJson.getString("storeId")); communityDto.setAuditStatusCd(StateConstant.AGREE_AUDIT); communitys = BeanConvertUtil.covertBeanList(communityInnerServiceSMOImpl.queryCommunitys(communityDto), ApiCommunityDataVo.class); } else { String companyOrgId = orgDtos.get(0).getOrgId(); OrgCommunityDto orgCommunityDto = BeanConvertUtil.covertBean(reqJson, OrgCommunityDto.class); orgCommunityDto.setOrgId(companyOrgId); List orgCommunityDtos = orgCommunityInnerServiceSMOImpl.queryOrgCommunitys(orgCommunityDto); communitys = BeanConvertUtil.covertBeanList(orgCommunityDtos, ApiCommunityDataVo.class); } if (communitys == null || communitys.size() < 1) { return; } for (ApiCommunityDataVo apiCommunityDataVo : communitys) { reqJson.put("communityId", apiCommunityDataVo.getCommunityId()); if (reqJson.containsKey("objType") && "001".equals(reqJson.getString("objType"))) { reqJson.put("objId", apiCommunityDataVo.getCommunityId()); } addNotice(reqJson); } cmdDataFlowContext.setResponseEntity(ResultVo.success()); } public void addNotice(JSONObject paramInJson) { JSONObject businessNotice = new JSONObject(); businessNotice.putAll(paramInJson); if (!paramInJson.containsKey("state")) { businessNotice.put("state", NoticeDto.STATE_FINISH); } NoticePo noticePo = BeanConvertUtil.covertBean(businessNotice, NoticePo.class); noticePo.setNoticeId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID)); int flag = noticeV1InnerServiceSMOImpl.saveNotice(noticePo); if (flag < 1) { throw new CmdException("保存数据失败"); } } }