道闸开闸 发送营销信息

java110-bean/src/main/java/com/java110/dto/marketPic/MarketPicDto.java

@@ -1,6 +1,7 @@
 package com.java110.dto.marketPic;
 
 import com.java110.dto.PageDto;
+
 import java.io.Serializable;
 import java.util.Date;
 
@@ -15,10 +16,10 @@ import java.util.Date;
 public class MarketPicDto extends PageDto implements Serializable {
 
     private String picUrl;
-private String name;
-private String picLink;
-private String remark;
-private String picId;
+    private String name;
+    private String picLink;
+    private String remark;
+    private String picId;
 
 
     private Date createTime;
@@ -29,31 +30,40 @@ private String picId;
     public String getPicUrl() {
         return picUrl;
     }
-public void setPicUrl(String picUrl) {
+
+    public void setPicUrl(String picUrl) {
         this.picUrl = picUrl;
     }
-public String getName() {
+
+    public String getName() {
         return name;
     }
-public void setName(String name) {
+
+    public void setName(String name) {
         this.name = name;
     }
-public String getPicLink() {
+
+    public String getPicLink() {
         return picLink;
     }
-public void setPicLink(String picLink) {
+
+    public void setPicLink(String picLink) {
         this.picLink = picLink;
     }
-public String getRemark() {
+
+    public String getRemark() {
         return remark;
     }
-public void setRemark(String remark) {
+
+    public void setRemark(String remark) {
         this.remark = remark;
     }
-public String getPicId() {
+
+    public String getPicId() {
         return picId;
     }
-public void setPicId(String picId) {
+
+    public void setPicId(String picId) {
         this.picId = picId;
     }
 

service-api/src/main/java/com/java110/api/configuration/ServiceConfiguration.java

@@ -79,7 +79,8 @@ public class ServiceConfiguration {
         exclusions.append("/app/alipay.payTempCarFee,");
         exclusions.append("/app/alipay/notify/receive,");
         exclusions.append("/app/parkingCoupon.listParkingCouponCar,");
-
+        exclusions.append("/app/marketPic.listCommunityMarketPic,");
+        exclusions.append("/app/marketGoods.listCommunityMarketGoods,");
         exclusions.append("/app/reportInfoAnswer/queryReportInfoAnswerByOpenId");
 
 

service-common/src/main/java/com/java110/common/cmd/marketGoods/ListCommunityMarketGoodsCmd.java

@@ -0,0 +1,126 @@
+/*
+ * 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.common.cmd.marketGoods;
+
+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.dto.marketGoodsItem.MarketGoodsItemDto;
+import com.java110.dto.marketRuleCommunity.MarketRuleCommunityDto;
+import com.java110.dto.marketRuleObj.MarketRuleObjDto;
+import com.java110.dto.marketRuleWay.MarketRuleWayDto;
+import com.java110.intf.common.*;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.vo.ResultVo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+
+import java.util.ArrayList;
+import java.util.List;
+
+
+/**
+ * 类表述：查询
+ * 服务编码：marketGoods.listMarketGoods
+ * 请求路劲：/app/marketGoods.ListMarketGoods
+ * add by 吴学文 at 2022-10-25 10:58:15 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 = "marketGoods.listCommunityMarketGoods")
+public class ListCommunityMarketGoodsCmd extends Cmd {
+
+  private static Logger logger = LoggerFactory.getLogger(ListCommunityMarketGoodsCmd.class);
+    @Autowired
+    private IMarketGoodsV1InnerServiceSMO marketGoodsV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketRuleCommunityV1InnerServiceSMO marketRuleCommunityV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketTextV1InnerServiceSMO marketTextV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketRuleObjV1InnerServiceSMO marketRuleObjV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketRuleWayV1InnerServiceSMO marketRuleWayV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketGoodsItemV1InnerServiceSMO marketGoodsItemV1InnerServiceSMOImpl;
+
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson,"communityId","未包含小区");
+        Assert.hasKeyAndValue(reqJson,"objType","未包含类型");
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+
+        MarketRuleCommunityDto marketRuleCommunityDto = new MarketRuleCommunityDto();
+        marketRuleCommunityDto.setCommunityId(reqJson.getString("communityId"));
+        List<MarketRuleCommunityDto> marketRuleCommunityDtos = marketRuleCommunityV1InnerServiceSMOImpl.queryMarketRuleCommunitys(marketRuleCommunityDto);
+
+        if(marketRuleCommunityDtos == null || marketRuleCommunityDtos.size()<1){
+            return;
+        }
+
+        List<String> ruleIds = new ArrayList<>();
+        for(MarketRuleCommunityDto tmpMarketRuleCommunityDto: marketRuleCommunityDtos){
+            ruleIds.add(tmpMarketRuleCommunityDto.getRuleId());
+        }
+
+        MarketRuleObjDto marketRuleObjDto = new MarketRuleObjDto();
+        marketRuleObjDto.setRuleIds(ruleIds.toArray(new String[ruleIds.size()]));
+        marketRuleObjDto.setObjType(reqJson.getString("objType"));
+        long count = marketRuleObjV1InnerServiceSMOImpl.queryMarketRuleObjsCount(marketRuleObjDto);
+
+        if(count <1){
+            return ;
+        }
+
+
+        MarketRuleWayDto marketRuleWayDto = new MarketRuleWayDto();
+        marketRuleWayDto.setRuleIds(ruleIds.toArray(new String[ruleIds.size()]));
+        marketRuleWayDto.setWayType(MarketRuleWayDto.WAY_TYPE_PIC);
+        List<MarketRuleWayDto> marketRuleWayDtos = marketRuleWayV1InnerServiceSMOImpl.queryMarketRuleWays(marketRuleWayDto);
+
+        if(marketRuleWayDtos == null || marketRuleWayDtos.size()<1){
+            return;
+        }
+
+        MarketGoodsItemDto  marketGoodsItemDto = new MarketGoodsItemDto();
+        marketGoodsItemDto.setGoodsId(marketRuleWayDtos.get(0).getWayObjId());
+
+        List<MarketGoodsItemDto> marketGoodsItemDtos = marketGoodsItemV1InnerServiceSMOImpl.queryMarketGoodsItems(marketGoodsItemDto);
+
+        ResultVo resultVo = new ResultVo(marketGoodsItemDtos);
+
+        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
+
+        cmdDataFlowContext.setResponseEntity(responseEntity);
+    }
+}

service-common/src/main/java/com/java110/common/cmd/marketPic/ListCommunityMarketPicCmd.java

@@ -0,0 +1,121 @@
+/*
+ * 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.common.cmd.marketPic;
+
+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.dto.marketPic.MarketPicDto;
+import com.java110.dto.marketRuleCommunity.MarketRuleCommunityDto;
+import com.java110.dto.marketRuleObj.MarketRuleObjDto;
+import com.java110.dto.marketRuleWay.MarketRuleWayDto;
+import com.java110.intf.common.*;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.vo.ResultVo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+
+import java.util.ArrayList;
+import java.util.List;
+
+
+/**
+ * 类表述：根据小区查询图片
+ * 服务编码：marketPic.listMarketPic
+ * 请求路劲：/app/marketPic.ListMarketPic
+ * add by 吴学文 at 2022-10-25 01:55:58 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 = "marketPic.listCommunityMarketPic")
+public class ListCommunityMarketPicCmd extends Cmd {
+
+  private static Logger logger = LoggerFactory.getLogger(ListCommunityMarketPicCmd.class);
+    @Autowired
+    private IMarketPicV1InnerServiceSMO marketPicV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketRuleCommunityV1InnerServiceSMO marketRuleCommunityV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketTextV1InnerServiceSMO marketTextV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketRuleObjV1InnerServiceSMO marketRuleObjV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMarketRuleWayV1InnerServiceSMO marketRuleWayV1InnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson,"communityId","未包含小区");
+        Assert.hasKeyAndValue(reqJson,"objType","未包含类型");
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+
+        MarketRuleCommunityDto marketRuleCommunityDto = new MarketRuleCommunityDto();
+        marketRuleCommunityDto.setCommunityId(reqJson.getString("communityId"));
+        List<MarketRuleCommunityDto> marketRuleCommunityDtos = marketRuleCommunityV1InnerServiceSMOImpl.queryMarketRuleCommunitys(marketRuleCommunityDto);
+
+        if(marketRuleCommunityDtos == null || marketRuleCommunityDtos.size()<1){
+            return;
+        }
+
+        List<String> ruleIds = new ArrayList<>();
+        for(MarketRuleCommunityDto tmpMarketRuleCommunityDto: marketRuleCommunityDtos){
+            ruleIds.add(tmpMarketRuleCommunityDto.getRuleId());
+        }
+
+        MarketRuleObjDto marketRuleObjDto = new MarketRuleObjDto();
+        marketRuleObjDto.setRuleIds(ruleIds.toArray(new String[ruleIds.size()]));
+        marketRuleObjDto.setObjType(reqJson.getString("objType"));
+        long count = marketRuleObjV1InnerServiceSMOImpl.queryMarketRuleObjsCount(marketRuleObjDto);
+
+        if(count <1){
+            return ;
+        }
+
+
+        MarketRuleWayDto marketRuleWayDto = new MarketRuleWayDto();
+        marketRuleWayDto.setRuleIds(ruleIds.toArray(new String[ruleIds.size()]));
+        marketRuleWayDto.setWayType(MarketRuleWayDto.WAY_TYPE_PIC);
+        List<MarketRuleWayDto> marketRuleWayDtos = marketRuleWayV1InnerServiceSMOImpl.queryMarketRuleWays(marketRuleWayDto);
+
+        if(marketRuleWayDtos == null || marketRuleWayDtos.size()<1){
+            return;
+        }
+
+        MarketPicDto marketPicDto = new MarketPicDto();
+        marketPicDto.setPicId(marketRuleWayDto.getWayObjId());
+        List<MarketPicDto> marketPicDtos = marketPicV1InnerServiceSMOImpl.queryMarketPics(marketPicDto);
+
+        ResultVo resultVo = new ResultVo(marketPicDtos);
+
+        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
+
+        cmdDataFlowContext.setResponseEntity(responseEntity);
+    }
+}

springboot/src/main/java/com/java110/boot/configuration/ServiceConfiguration.java

@@ -80,6 +80,11 @@ public class ServiceConfiguration {
         exclusions.append("/app/alipay/notify/receive,");
         exclusions.append("/app/parkingCoupon.listParkingCouponCar,");
 
+        exclusions.append("/app/marketPic.listCommunityMarketPic,");
+        exclusions.append("/app/marketGoods.listCommunityMarketGoods,");
+
+
+
 
         exclusions.append("/app/reportInfoAnswer/queryReportInfoAnswerByOpenId");