| | |
| | | import com.java110.core.annotation.Java110Cmd; |
| | | import com.java110.core.annotation.Java110Transactional; |
| | | import com.java110.core.context.ICmdDataFlowContext; |
| | | import com.java110.core.event.cmd.AbstractServiceCmdListener; |
| | | import com.java110.core.event.cmd.Cmd; |
| | | import com.java110.core.event.cmd.CmdEvent; |
| | | import com.java110.core.factory.GenerateCodeFactory; |
| | | import com.java110.dto.app.AppDto; |
| | |
| | | import com.java110.intf.store.ISmallWechatV1InnerServiceSMO; |
| | | import com.java110.po.smallWechat.SmallWechatPo; |
| | | import com.java110.po.smallWechatAttr.SmallWechatAttrPo; |
| | | import com.java110.utils.constant.BusinessTypeConstant; |
| | | import com.java110.utils.exception.CmdException; |
| | | import com.java110.utils.util.Assert; |
| | | import com.java110.utils.util.BeanConvertUtil; |
| | |
| | | * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复,注释10至20行 加入 20行至30行 |
| | | */ |
| | | @Java110Cmd(serviceCode = "smallWeChat.saveSmallWeChat") |
| | | public class SaveSmallWechatCmd extends AbstractServiceCmdListener { |
| | | public class SaveSmallWechatCmd extends Cmd { |
| | | |
| | | private static Logger logger = LoggerFactory.getLogger(SaveSmallWechatCmd.class); |
| | | |
| | |
| | | Assert.hasKeyAndValue(reqJson, "appId", "请求报文中未包含appId"); |
| | | Assert.hasKeyAndValue(reqJson, "appSecret", "请求报文中未包含appSecret"); |
| | | Assert.hasKeyAndValue(reqJson, "payPassword", "请求报文中未包含payPassword"); |
| | | Assert.hasKeyAndValue(reqJson, "weChatType", "请求报文中未包含weChatType"); |
| | | Assert.hasKeyAndValue(reqJson, "objId", "请求报文中未包含objId(小区id)"); |
| | | Assert.hasKeyAndValue(reqJson, "weChatType", "请求报文中未包含类型"); |
| | | |
| | |
| | | } |
| | | |
| | | String wechatId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_weChatId); |
| | | reqJson.put("weChatId", wechatId); |
| | | reqJson.put("wechatId", wechatId); |
| | | reqJson.put("objType", SmallWeChatDto.OBJ_TYPE_COMMUNITY); |
| | | SmallWechatPo smallWechatPo = BeanConvertUtil.covertBean(reqJson, SmallWechatPo.class); |
| | | smallWechatPo.setWechatId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID)); |
| | | smallWechatPo.setWechatId(wechatId); |
| | | smallWechatPo.setWechatType(reqJson.getString("weChatType")); |
| | | int flag = smallWechatV1InnerServiceSMOImpl.saveSmallWechat(smallWechatPo); |
| | | |
| | | if (flag < 1) { |