报名联建活动

epmet-module/epmet-heart/epmet-heart-client/src/main/java/com/epmet/dto/form/SignUpParyActFormDTO.java

@@ -0,0 +1,25 @@
+package com.epmet.dto.form;
+
+import com.epmet.commons.tools.validator.group.QueryGroup;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+
+/**
+ * @Description
+ * @Author yzm
+ * @Date 2023/3/29 15:27
+ */
+@Data
+public class SignUpParyActFormDTO {
+    /**
+     *
+     */
+    @NotBlank(message = "userId不能为空", groups = QueryGroup.class)
+    private String userId;
+    @NotBlank(message = "activityId不能为空", groups = QueryGroup.class)
+    private String activityId;
+    @NotBlank(message = "gridId不能为空", groups = QueryGroup.class)
+    private String gridId;
+}
+

epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/controller/IcPartyActivityController.java

@@ -36,11 +36,13 @@ import com.epmet.commons.tools.utils.poi.excel.handler.FreezeAndFilter;
 import com.epmet.commons.tools.validator.ValidatorUtils;
 import com.epmet.commons.tools.validator.group.AddGroup;
 import com.epmet.commons.tools.validator.group.DefaultGroup;
+import com.epmet.commons.tools.validator.group.QueryGroup;
 import com.epmet.constants.ImportTaskConstants;
 import com.epmet.dto.IcPartyActivityDTO;
 import com.epmet.dto.form.ImportTaskCommonFormDTO;
 import com.epmet.dto.form.PartyActivityFormDTO;
 import com.epmet.dto.form.PartyActivitySignUpRecordFormDTO;
+import com.epmet.dto.form.SignUpParyActFormDTO;
 import com.epmet.dto.result.ImportTaskCommonResultDTO;
 import com.epmet.dto.result.PartyActivitySignUpRecordResDTO;
 import com.epmet.dto.result.demand.OptionDTO;
@@ -63,9 +65,7 @@ import java.io.IOException;
 import java.io.InputStream;
 import java.net.URLEncoder;
 import java.nio.file.Path;
-import java.util.Date;
-import java.util.List;
-import java.util.UUID;
+import java.util.*;
 
 
 /**
@@ -268,6 +268,19 @@ public class IcPartyActivityController implements ResultDataResolver {
         return new Result<PageData<PartyActivitySignUpRecordResDTO>>().ok(icPartyActivityService.querySignUpRecord(formDTO.getActivityId(),formDTO.getPageNo(),formDTO.getPageSize()));
     }
 
-
+    /**
+     * 居民端钉钉，报名联建活动
+     *
+     * @param formDTO
+     * @return
+     */
+    @PostMapping("signUp")
+    public Result signUp(@RequestBody SignUpParyActFormDTO formDTO) {
+        ValidatorUtils.validateEntity(formDTO, QueryGroup.class);
+        String signUpId = icPartyActivityService.signUp(formDTO.getActivityId(), formDTO.getUserId(), formDTO.getGridId());
+        Map resultMap = new HashMap<>();
+        resultMap.put("signUpId", signUpId);
+        return new Result().ok(resultMap);
+    }
 
 }

epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/IcPartyActivityService.java

@@ -135,4 +135,12 @@ public interface IcPartyActivityService extends BaseService<IcPartyActivityEntit
      * @return
      */
     PageData<PartyActivitySignUpRecordResDTO> querySignUpRecord(String activityId,Integer pageNo,Integer pageSize);
+
+    /**
+     * 居民端钉钉，报名联建活动
+     * @param activityId
+     * @param userId
+     * @param gridId
+     */
+    String signUp(String activityId, String userId, String gridId);
 }

epmet-module/epmet-heart/epmet-heart-server/src/main/java/com/epmet/service/impl/IcPartyActivityServiceImpl.java

@@ -24,6 +24,8 @@ import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.constant.StrConstant;
 import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult;
+import com.epmet.commons.tools.exception.EpmetErrorCode;
+import com.epmet.commons.tools.exception.EpmetException;
 import com.epmet.commons.tools.exception.ExceptionUtils;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.redis.common.CustomerOrgRedis;
@@ -41,13 +43,16 @@ import com.epmet.dto.form.PartyActivityFormDTO;
 import com.epmet.dto.result.ActivityStatisticsDTO;
 import com.epmet.dto.result.PartyActivitySignUpRecordResDTO;
 import com.epmet.dto.result.UploadImgResultDTO;
+import com.epmet.dto.result.UserBaseInfoResultDTO;
 import com.epmet.dto.result.demand.OptionDTO;
 import com.epmet.entity.IcActivityServiceRelationEntity;
 import com.epmet.entity.IcActivityUnitRelationEntity;
 import com.epmet.entity.IcPartyActivityEntity;
+import com.epmet.entity.IcPartyActivitySignUpRecordEntity;
 import com.epmet.excel.IcPartyActivityImportExcel;
 import com.epmet.excel.handler.IcPartyActivityImportListener;
 import com.epmet.feign.EpmetCommonServiceOpenFeignClient;
+import com.epmet.feign.EpmetUserOpenFeignClient;
 import com.epmet.feign.OssFeignClient;
 import com.epmet.service.*;
 import com.github.pagehelper.PageHelper;
@@ -98,6 +103,8 @@ public class IcPartyActivityServiceImpl extends BaseServiceImpl<IcPartyActivityD
     private EpmetCommonServiceOpenFeignClient commonServiceOpenFeignClient;
     @Autowired
     private IcPartyActivitySignUpRecordDao partyActivitySignUpRecordDao;
+    @Autowired
+    private EpmetUserOpenFeignClient epmetUserOpenFeignClient;
 
 
     @Override
@@ -528,4 +535,51 @@ public class IcPartyActivityServiceImpl extends BaseServiceImpl<IcPartyActivityD
         PageInfo<PartyActivitySignUpRecordResDTO> pageInfo = new PageInfo<>(list);
         return new PageData<>(list, pageInfo.getTotal(), pageSize);
     }
+
+    /**
+     * 居民端钉钉，报名联建活动
+     *
+     * @param activityId
+     * @param userId
+     * @param gridId
+     */
+    @Override
+    public String signUp(String activityId, String userId, String gridId) {
+        LambdaQueryWrapper<IcPartyActivitySignUpRecordEntity> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(IcPartyActivitySignUpRecordEntity::getActivityId, activityId)
+                .eq(IcPartyActivitySignUpRecordEntity::getUserId, userId)
+                .select(IcPartyActivitySignUpRecordEntity::getId);
+        IcPartyActivitySignUpRecordEntity entity = partyActivitySignUpRecordDao.selectOne(queryWrapper);
+        if (null != entity) {
+            return entity.getId();
+        }
+        // 查询网格名称
+        GridInfoCache gridInfoCache = CustomerOrgRedis.getGridInfo(gridId);
+        if (null == gridInfoCache) {
+            throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "网格信息查询异常gridId:" + gridId, "网格信息查询异常");
+        }
+        // 查询用户姓名和手机号
+        List<String> userIdList=new ArrayList<>();
+        userIdList.add(userId);
+        Result<List<UserBaseInfoResultDTO>> userRes = epmetUserOpenFeignClient.queryUserBaseInfo(userIdList);
+        if (!userRes.success() || CollectionUtils.isEmpty(userRes.getData())) {
+            throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "网格信息查询异常gridId:" + gridId, "查询用户信息异常");
+        }
+        UserBaseInfoResultDTO userBaseInfoResultDTO=userRes.getData().get(NumConstant.ZERO);
+        IcPartyActivitySignUpRecordEntity insert = new IcPartyActivitySignUpRecordEntity();
+        insert.setActivityId(activityId);
+        insert.setCustomerId(EpmetRequestHolder.getLoginUserCustomerId());
+        insert.setGridId(gridId);
+        insert.setGridName(gridInfoCache.getGridNamePath());
+        insert.setUserId(userId);
+        insert.setUserName(userBaseInfoResultDTO.getRealName());
+        insert.setMobile(userBaseInfoResultDTO.getMobile());
+        insert.setSignUpTime(new Date());
+        partyActivitySignUpRecordDao.insert(insert);
+        return insert.getId();
+    }
+
+
+
+
 }