金汇社区模块

lidongdong

2023-10-11 2af69b8d4e804397799c89e2aa0d837c6de738a8

金汇社区模块

 springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommonApi.java

@@ -1,23 +1,26 @@
package com.panzhihua.applets.api;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.time.LocalDateTime;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import com.alibaba.fastjson.JSONObject;
import cn.binarywang.wx.miniapp.api.WxMaSecCheckService;
import com.alibaba.fastjson.JSON;
import com.panzhihua.applets.config.MinioUtil;
import com.panzhihua.applets.config.WxMaConfiguration;
import com.panzhihua.applets.umf.UmfPayUtil;
import com.panzhihua.applets.unionpay.*;
import com.panzhihua.common.constants.Constants;
import com.panzhihua.common.constants.FtpConstants;
import com.panzhihua.common.constants.UserConstants;
import com.panzhihua.common.controller.BaseController;
import com.panzhihua.common.model.dtos.wx.UnionpayCarWash;
import com.panzhihua.common.model.dtos.bracelet.BraceletEarlyWarningDO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.Base64File;
import com.panzhihua.common.model.vos.community.WeatherVO;
import com.panzhihua.common.model.vos.user.UserPhoneVO;
import com.panzhihua.common.service.bracelet.CommunityBraceletService;
import com.panzhihua.common.service.community.CommunityService;
import com.panzhihua.common.utlis.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import net.coobird.thumbnailator.Thumbnails;
import org.apache.commons.io.FilenameUtils;
import org.apache.commons.lang3.RandomUtils;
@@ -27,19 +30,16 @@
import org.springframework.util.ObjectUtils;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import com.alibaba.fastjson.JSON;
import com.panzhihua.applets.config.WxMaConfiguration;
import com.panzhihua.common.constants.Constants;
import com.panzhihua.common.constants.FtpConstants;
import com.panzhihua.common.constants.UserConstants;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.WeatherVO;
import com.panzhihua.common.model.vos.user.UserPhoneVO;
import com.panzhihua.common.service.community.CommunityService;
import cn.binarywang.wx.miniapp.api.WxMaSecCheckService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.time.LocalDateTime;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;

import static com.panzhihua.common.utlis.FileTypeUploadUtils.assertAllowed;
import static com.panzhihua.common.utlis.PayUtil.makeUUID;
@@ -85,6 +85,9 @@
    private WxMaConfiguration wxMaConfiguration;
    @Resource
    private CommunityService communityService;

    @Resource
    private CommunityBraceletService communityBraceletService;
    @Resource
    private MinioUtil minioUtil;
    @Resource
@@ -314,6 +317,37 @@
    }


    /**
     * 获取预警数据
     * @param communityId
     * @return
     */
    @ApiOperation("微信手环人员处理工单列表")
    @GetMapping("bracelet/getEarlyWarningList")
    public R getList(@RequestParam("pageNum") Integer pageNum,
                     @RequestParam("pageSize") Integer pageSize,
                     @RequestParam("communityId") String communityId,
                     @RequestParam("disposeUserId") String disposeUserId,
                     @RequestParam("type") String type)
    {
        return communityBraceletService.getList(pageNum,pageSize,communityId,"",disposeUserId,type,"","");
    }

    /**
     * 微信处理接口
     * @param braceletEarlyWarningDO
     * @return
     */
    @PostMapping("bracelet/WXdispose")
    public R  WXdispose(@RequestBody BraceletEarlyWarningDO braceletEarlyWarningDO)
    {
        if(StringUtils.isEmpty(braceletEarlyWarningDO.getDisposeText()))
        {
            return R.fail("处理内容不能为空");
        }
        braceletEarlyWarningDO.setDisposeType("2");
        return communityBraceletService.WXdispose(braceletEarlyWarningDO);
    }




 springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/JinHuiCommnuityApi.java

New file
@@ -0,0 +1,86 @@
package com.panzhihua.applets.api;


import com.alibaba.fastjson.JSONObject;
import com.panzhihua.common.controller.BaseController;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.ComActActivityVO;
import com.panzhihua.common.model.vos.community.SignactivityVO;
import com.panzhihua.common.model.vos.user.SysUserNoticeVO;
import com.panzhihua.common.service.community.CommunityService;
import com.panzhihua.common.service.jinhui.JinhuiCommunityService;
import com.panzhihua.common.service.user.UserService;
import com.panzhihua.common.validated.AddGroup;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.Date;

@Slf4j
@RestController
@RequestMapping("/JinHui/")
@Api(tags = {"金汇社区api"})
public class JinHuiCommnuityApi  extends BaseController
{

    @Resource
    private CommunityService communityService;

    @Resource
    private JinhuiCommunityService jinhuiCommunityService;

    @Resource
    private UserService userService;

    @ApiOperation(value = "新增服务活动")
    @PostMapping("add/activity")
    public R addActivity(@RequestBody @Validated(AddGroup.class) ComActActivityVO comActActivityVO) {
        Long communityId = this.getCommunityId();
        comActActivityVO.setCommunityId(communityId);
        comActActivityVO.setUserId(this.getLoginUserInfo().getUserId());
        comActActivityVO.setStatus(2);
        comActActivityVO.setHasPrize(0);
        comActActivityVO.setHaveIntegralReward(0);
        return communityService.addActivity(comActActivityVO);
    }


    @ApiOperation(value = "报名/取消报名社区活动")
    @PutMapping("signactivity")
    public R signActivity(@RequestBody @Validated(AddGroup.class) SignactivityVO signactivityVO) {
        Long userId = this.getUserId();
        Long activityId = signactivityVO.getActivityId();
        signactivityVO.setUserId(userId);
        R r = jinhuiCommunityService.signActivity(signactivityVO);
        if (R.isOk(r) && signactivityVO.getType().intValue() == 1) {
            R r2 = communityService.detailActivity(activityId, userId, null, null);
            ComActActivityVO comActActivityVO =
                    JSONObject.parseObject(JSONObject.toJSONString(r2.getData()), ComActActivityVO.class);
            Integer isVolunteer = JSONObject.parseObject(JSONObject.toJSONString(r.getData()), Integer.class);
            SysUserNoticeVO sysUserNoticeVO = new SysUserNoticeVO();
            sysUserNoticeVO.setUserId(userId);
            sysUserNoticeVO.setType(1);
            sysUserNoticeVO.setTitle("报名成功");
            sysUserNoticeVO.setBusinessType(1);
            sysUserNoticeVO.setBusinessTitle(comActActivityVO.getActivityName());
            Date beginAt = comActActivityVO.getBeginAt();
            sysUserNoticeVO.setBusinessContent(String.format("活动将于%tF %tT  开始，请按时参加", beginAt, beginAt));
            sysUserNoticeVO.setBusinessId(activityId);
            sysUserNoticeVO.setStatus(0);
            sysUserNoticeVO.setActivityType(comActActivityVO.getType());
            sysUserNoticeVO.setBusinessStatus(2);
            R r1 = userService.addNotice(sysUserNoticeVO);
            if (R.isOk(r1)) {
                log.info("新增用户报名社区活动通知成功【{}】", JSONObject.toJSONString(sysUserNoticeVO));
            }
        }
        return r;
    }



}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/community/ComActActivityVO.java

@@ -336,4 +336,10 @@

    @ApiModelProperty("清单信息")
    private ComActNeighborCircleDetailAppVO listDetail;

    @ApiModelProperty("奖励金汇币")
    private String jinhuiCoinAward;

    @ApiModelProperty("惩罚金汇币")
    private String jinhuiCoinPunishment;
}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/jinhui/JinhuiCoinGeneralTableVO.java

New file
@@ -0,0 +1,44 @@
package com.panzhihua.common.model.vos.jinhui;

import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.util.Date;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("金汇社区用户金汇币总表")
public class JinhuiCoinGeneralTableVO
{
    private static final long serialVersionUID = -70884515430727555L;


    @ApiModelProperty(value = "主键")
    private String id;

    @ApiModelProperty(value = "用户id")
    private String userId;

    @ApiModelProperty(value = "金币总额")
    private String goldCoin="0";

    @ApiModelProperty(value = "创建时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date creationTime;


    @ApiModelProperty(value = "更新时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date updateTime;

    @ApiModelProperty(value = "社区id")
    private String communityId;

}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/jinhui/JinhuiGoldCoinRecordVO.java

New file
@@ -0,0 +1,53 @@
package com.panzhihua.common.model.vos.jinhui;

import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.util.Date;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("金汇币明细")
public class JinhuiGoldCoinRecordVO
{
    private static final long serialVersionUID = -70884515430727555L;


    @ApiModelProperty(value = "主键")
    private String id;

    @ApiModelProperty(value = "用户id")
    private String userId;

    @ApiModelProperty(value = "金币总额")
    private String goldCoin="0";

    @ApiModelProperty(value = "创建时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date creationTime;


    @ApiModelProperty(value = "更新时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date updateTime;

    @ApiModelProperty(value = "社区id")
    private String communityId;

    @ApiModelProperty(value = "标题")
    private String title;

    @ApiModelProperty(value = "备注")
    private String remark;

    @ApiModelProperty(value = "状态")
    private String type;

}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/jinhui/JinhuiCommunityService.java

New file
@@ -0,0 +1,23 @@
package com.panzhihua.common.service.jinhui;

import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.SignactivityVO;
import io.swagger.annotations.ApiOperation;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;

/**
 * 川工之家
 */
@FeignClient(name = "huacheng-jinhui-community")
public interface JinhuiCommunityService
{

    @ApiOperation(value = "金汇社区报名/取消活动接口")
    @PostMapping("/jinhuiActivity/signActivity")
    public R signActivity(@RequestBody SignactivityVO signactivityVO);



}

 springcloud_k8s_panzhihuazhihuishequ/pom.xml

@@ -232,6 +232,7 @@
        <module>service_property</module>
        <module>service_dlz</module>
        <module>service_bracelet</module>
        <module>service_jinhui_commynty</module>
    </modules>
    <packaging>pom</packaging>


 springcloud_k8s_panzhihuazhihuishequ/service_bracelet/src/main/java/com/panzhihua/service_bracelet/api/BraceletUserDataApi.java

@@ -40,11 +40,12 @@
        braceletUserDataDO.setIsAbnormal("0");
        braceletUserDataDO.setOnoff("1");

        BraceletUserDataDO data=null;

        if(!StringUtils.isEmpty(braceletUserDataDO.getDeviceId()))
        {

            data=braceletUserDataService.getDetails(braceletUserDataDO.getDeviceId());
        }
        BraceletUserDataDO data=braceletUserDataService.getDetails(braceletUserDataDO.getDeviceId());

        if(data==null || StringUtils.isEmpty(data.getDeviceId()))
        {

 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/model/dos/ComActActivityDO.java

@@ -283,4 +283,8 @@
    private Long checkUnitId;

    private Long topicId;

    private String jinhuiCoinAward;

    private String jinhuiCoinPunishment;
}

 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActActivityServiceImpl.java

@@ -691,6 +691,7 @@
            comActActSignDO.setStatus(0);
            comActActSignDO.setReason(signactivityVO.getReason());
            num = comActActSignDAO.updateById(comActActSignDO);
            //计算用户积分
            if (num > 0) {
                AddComActIntegralUserDTO addComActIntegralUserDTO = new AddComActIntegralUserDTO();
                addComActIntegralUserDTO.setUserId(userId);

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/RoomckWebApi.java

@@ -2,7 +2,6 @@

import com.panzhihua.common.model.vos.ResultData;
import com.panzhihua.common.model.vos.union.StructuredVO;
import com.panzhihua.service_equipment.model.dos.Structured;
import io.swagger.annotations.Api;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionExchangeRecordApi.java

@@ -1,13 +1,11 @@
package com.panzhihua.service_equipment.api;

import com.panzhihua.common.model.dtos.equipment.UnionExchangeRecordDto;
import com.panzhihua.common.model.dtos.equipment.UnionIntegralRecordDto;
import com.panzhihua.common.model.dtos.equipment.UnionUserDto;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.utlis.StringUtils;
import com.panzhihua.service_equipment.annotation.CurrentUser;
import com.panzhihua.service_equipment.service.UnionExchangeRecordService;
import com.panzhihua.service_equipment.service.UnionIntegralRecordService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;


 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionInspectionApi.java

@@ -2,13 +2,11 @@

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.panzhihua.common.model.dtos.equipment.UnionInspectionDto;
import com.panzhihua.common.model.dtos.equipment.UnionReportDto;
import com.panzhihua.common.model.dtos.equipment.UnionUserDto;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.service_equipment.annotation.CurrentUser;
import com.panzhihua.service_equipment.model.dos.UnionReport;
import com.panzhihua.service_equipment.service.UnionInspectionService;
import com.panzhihua.service_equipment.service.UnionReportService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionIntegralRecordApi.java

@@ -1,12 +1,10 @@
package com.panzhihua.service_equipment.api;

import com.panzhihua.common.model.dtos.equipment.UnionIntegralRecordDto;
import com.panzhihua.common.model.dtos.equipment.UnionStoreDto;
import com.panzhihua.common.model.dtos.equipment.UnionUserDto;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.service_equipment.annotation.CurrentUser;
import com.panzhihua.service_equipment.service.UnionIntegralRecordService;
import com.panzhihua.service_equipment.service.UnionStoreService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;


 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionOutdoorLaborDynamicApi.java

@@ -2,10 +2,7 @@

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.panzhihua.common.model.dtos.equipment.UnionOutdoorLaborDynamicDto;
import com.panzhihua.common.model.dtos.grid.PageEventApplicationAppReleaseDTO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.grid.EventApplicationAppReleaseVO;
import com.panzhihua.common.model.vos.grid.EventMainMemberDetailsVO;
import com.panzhihua.service_equipment.model.dos.UnionOutdoorLaborDynamic;
import com.panzhihua.service_equipment.service.UnionOutdoorLaborDynamicService;
import lombok.extern.slf4j.Slf4j;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/api/UnionOutdoorSiteApi.java

@@ -1,10 +1,8 @@
package com.panzhihua.service_equipment.api;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.panzhihua.common.model.dtos.equipment.UnionOutdoorLaborDynamicDto;
import com.panzhihua.common.model.dtos.equipment.UnionOutdoorSiteDto;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.service_equipment.model.dos.UnionOutdoorLaborDynamic;
import com.panzhihua.service_equipment.model.dos.UnionOutdoorSite;
import com.panzhihua.service_equipment.service.UnionOutdoorSiteService;
import lombok.extern.slf4j.Slf4j;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/AccessConfig.java

@@ -4,7 +4,6 @@
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;

@ApiModel("门禁账号密码")

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/MyMetaObjectHandler.java

@@ -1,4 +1,4 @@
package com.panzhihua.service_grid.config;
package com.panzhihua.service_equipment.config;

import java.util.Date;


 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/MybatisHmkInterceptor.java

@@ -1,4 +1,4 @@
package com.panzhihua.service_grid.config;
package com.panzhihua.service_equipment.config;

import com.baomidou.mybatisplus.core.toolkit.PluginUtils;
import com.baomidou.mybatisplus.extension.plugins.inner.InnerInterceptor;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/config/MybatisPlusConfig.java

@@ -1,4 +1,4 @@
package com.panzhihua.service_grid.config;
package com.panzhihua.service_equipment.config;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.context.annotation.Bean;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/dao/UnionShippingAddressMapper.java

@@ -4,9 +4,7 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.panzhihua.common.model.dtos.equipment.UnionExchangeRecordDto;
import com.panzhihua.common.model.dtos.equipment.UnionShippingAddressDto;
import com.panzhihua.service_equipment.model.dos.UnionExchangeRecord;
import com.panzhihua.service_equipment.model.dos.UnionShippingAddress;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/Structured.java

@@ -5,8 +5,6 @@
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.util.List;

@ApiModel("结构化数据类")
@Data
public class Structured {

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionIntegralSummarize.java

@@ -1,7 +1,6 @@
package com.panzhihua.service_equipment.model.dos;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionStore.java

@@ -1,8 +1,6 @@
package com.panzhihua.service_equipment.model.dos;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/model/dos/UnionUser.java

@@ -3,8 +3,6 @@
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/resolvers/CurrentUserMethodArgumentResolver.java

@@ -1,11 +1,8 @@
package com.panzhihua.service_equipment.resolvers;

import com.panzhihua.common.model.dtos.equipment.UnionUserDto;
import com.panzhihua.common.service.community.ComEquipmentUnionUserFeign;
import com.panzhihua.common.utlis.Constant;
import com.panzhihua.service_equipment.annotation.CurrentUser;
import com.panzhihua.service_equipment.model.dos.UnionUser;
import com.panzhihua.service_equipment.service.UnionInspectionService;
import com.panzhihua.service_equipment.service.UnionUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionExchangeRecordService.java

@@ -2,10 +2,8 @@

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.panzhihua.common.model.dtos.equipment.UnionExchangeRecordDto;
import com.panzhihua.common.model.dtos.equipment.UnionIntegralRecordDto;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.service_equipment.model.dos.UnionExchangeRecord;
import org.apache.ibatis.annotations.Param;

public interface UnionExchangeRecordService
{

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionStoreService.java

@@ -4,7 +4,6 @@
import com.panzhihua.common.model.dtos.equipment.UnionStoreDto;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.service_equipment.model.dos.UnionStore;
import org.apache.ibatis.annotations.Param;

public interface UnionStoreService
{

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/UnionUserService.java

@@ -1,11 +1,8 @@
package com.panzhihua.service_equipment.service;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.panzhihua.common.model.dtos.equipment.UnionReportDto;
import com.panzhihua.common.model.dtos.equipment.UnionUserDto;
import com.panzhihua.common.model.vos.LoginUserInfoVO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.service_equipment.model.dos.UnionReport;
import com.panzhihua.service_equipment.model.dos.UnionUser;

import java.util.Map;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionIntegralSummarizeServiceImpl.java

@@ -2,7 +2,6 @@

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.dtos.equipment.UnionIntegralRecordDto;
import com.panzhihua.common.model.dtos.equipment.UnionIntegralSummarizeDto;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.service_equipment.dao.UnionIntegralSummarizeMapper;

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/service/impl/UnionStoreServiceImpl.java

@@ -5,14 +5,10 @@
import com.panzhihua.common.model.dtos.equipment.UnionStoreDto;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.service_equipment.dao.UnionStoreMapper;
import com.panzhihua.service_equipment.model.dos.UnionIntegralSummarize;
import com.panzhihua.service_equipment.model.dos.UnionStore;
import com.panzhihua.service_equipment.service.UnionIntegralSummarizeService;
import com.panzhihua.service_equipment.service.UnionStoreService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;


@Service

 springcloud_k8s_panzhihuazhihuishequ/service_equipment/src/main/java/com/panzhihua/service_equipment/until/MonitorUtil.java

@@ -1,7 +1,5 @@
package com.panzhihua.service_equipment.until;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@@ -12,10 +10,7 @@
import java.security.NoSuchAlgorithmException;
import java.util.Base64;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import static com.panzhihua.common.utlis.HttpClientUtil.httpPostAndToken;

@Slf4j
@Service

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/pom.xml

New file
@@ -0,0 +1,178 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.panzhihua</groupId>
        <artifactId>zhihuishequ</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <groupId>com.panzhihua</groupId>
    <artifactId>service_jinhui_commynty</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>service_jinhui_commynty</name>
    <description>金汇社区</description>


    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>com.netflix.hystrix</groupId>
            <artifactId>hystrix-javanica</artifactId>
        </dependency>
        <!--jsoup爬虫爬取网页 -->
        <dependency>
            <groupId>org.jsoup</groupId>
            <artifactId>jsoup</artifactId>
            <version>1.13.1</version>
        </dependency>

        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>com.panzhihua</groupId>
            <artifactId>common</artifactId>
        </dependency>
        <dependency>
            <groupId>com.panzhihua</groupId>
            <artifactId>service_community</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.data</groupId>
            <artifactId>spring-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>commons-lang</groupId>
            <artifactId>commons-lang</artifactId>
            <version>2.6</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <!--添加监控依赖包-->
        <dependency>
            <groupId>io.micrometer</groupId>
            <artifactId>micrometer-registry-prometheus</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <!-- zxing生成二维码 -->
        <dependency>
            <groupId>com.google.zxing</groupId>
            <artifactId>core</artifactId>
            <version>3.3.3</version>
        </dependency>
        <!-- lbs附近定位 -->
        <dependency>
            <groupId>com.spatial4j</groupId>
            <artifactId>spatial4j</artifactId>
            <version>0.5</version>
        </dependency>
        <!--        微信小程序-->
        <dependency>
            <groupId>com.github.binarywang</groupId>
            <artifactId>weixin-java-miniapp</artifactId>
            <version>3.9.9.B</version>
        </dependency>

        <dependency>
            <groupId>com.google.zxing</groupId>
            <artifactId>javase</artifactId>
            <version>3.3.3</version>
        </dependency>
        <dependency>
            <groupId>com.panzhihua</groupId>
            <artifactId>service_community</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>


    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <mainClass>com.panzhihua.service_jinhui_commynty.ServiceJinHuiCommunityApplication</mainClass>
                </configuration>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>

            <plugin>
                <groupId>com.spotify</groupId>
                <artifactId>docker-maven-plugin</artifactId>
                <version>1.2.0</version>
                <configuration>
                    <imageName>registry.cn-chengdu.aliyuncs.com/panzhihua/service_jinhui_commynty:v1</imageName>
                    <serverId></serverId>
                    <baseImage>java</baseImage>
                    <entryPoint>["java", "-jar", "/${project.build.finalName}.jar"]</entryPoint>
                    <resources>
                        <resource>
                            <targetPath>/</targetPath>
                            <directory>${project.build.directory}</directory>
                            <include>${project.build.finalName}.jar</include>
                        </resource>
                    </resources>
                </configuration>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
        </repository>
    </repositories>

</project>

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/ServiceJinHuiCommunityApplication.java

New file
@@ -0,0 +1,26 @@
package com.panzhihua.service_jinhui_community;

import org.springframework.boot.SpringApplication;
import org.springframework.cloud.client.SpringCloudApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.scheduling.annotation.EnableScheduling;
import springfox.documentation.swagger2.annotations.EnableSwagger2;


@EnableSwagger2
@SpringCloudApplication
@EnableFeignClients(basePackages = {"com.panzhihua.common.service"})
@EnableEurekaClient
@EnableCircuitBreaker
@ComponentScan({"com.panzhihua.service_jinhui_community", "com.panzhihua.common"})
@EnableScheduling
public class ServiceJinHuiCommunityApplication {

    public static void main(String[] args) {
        SpringApplication.run(ServiceJinHuiCommunityApplication.class, args);
    }

}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/api/jinhuiActivityApi.java

New file
@@ -0,0 +1,53 @@
package com.panzhihua.service_jinhui_community.api;

import com.panzhihua.common.controller.BaseController;
import com.panzhihua.common.model.dtos.community.PageComActDynTypeDTO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.ComActActRegistVO;
import com.panzhihua.common.model.vos.community.ComActDynTypeVO;
import com.panzhihua.common.model.vos.community.SignactivityVO;
import com.panzhihua.common.service.community.CommunityService;
import com.panzhihua.service_jinhui_community.service.JinhuiActActivityService;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;


/**
 * @auther llming
 * @describe 办事指南
 */
@Slf4j
@RestController
@RequestMapping("/jinhuiActivity")
public class jinhuiActivityApi extends BaseController
{
    @Resource
    private JinhuiActActivityService jinhuiActActivityService;

    @ApiOperation(value = "金汇社区报名/取消活动接口")
    @PostMapping("/signActivity")
    public R signActivity(@RequestBody SignactivityVO signactivityVO)
    {
        return jinhuiActActivityService.signActivity(signactivityVO);
    }


    @ApiOperation(value = "金汇社区报名/取消活动接口")
    @PostMapping("/signActivity")
    public R activitySignIn(@RequestBody ComActActRegistVO comActActRegistVO)
    {
        return jinhuiActActivityService.activitySignIn(comActActRegistVO);
    }






}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/config/JacksonConfig.java

New file
@@ -0,0 +1,31 @@
package com.panzhihua.service_jinhui_community.config;


import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.http.converter.json.Jackson2ObjectMapperBuilder;

@Configuration
public class JacksonConfig {

    @Bean
    @Primary
    @ConditionalOnMissingBean(ObjectMapper.class)
    public ObjectMapper jacksonObjectMapper(Jackson2ObjectMapperBuilder builder)
    {
        ObjectMapper objectMapper = builder.createXmlMapper(false).build();

        // 全局配置序列化返回 JSON 处理
        SimpleModule simpleModule = new SimpleModule();
        //JSON Long ==> String
        simpleModule.addSerializer(Long.class, ToStringSerializer.instance);
        objectMapper.registerModule(simpleModule);
        return objectMapper;
    }

}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/config/MyMetaObjectHandler.java

New file
@@ -0,0 +1,44 @@
package com.panzhihua.service_jinhui_community.config;

import java.util.Date;

import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;

import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;

import lombok.extern.slf4j.Slf4j;

/**
 * @program: springcloud_k8s_panzhihuazhihuishequ
 * @description: 自动填充
 * @author: huang.hongfa weixin hhf9596 qq 959656820
 * @create: 2020-12-11 14:23
 **/
@Slf4j
@Component
public class MyMetaObjectHandler implements MetaObjectHandler {
    @Override
    public void insertFill(MetaObject metaObject) {
        log.info("start insert fill ....");
        // this.strictInsertFill(metaObject, "createTime", Date.class, new Date()); // 起始版本 3.3.0(推荐使用)
        // 或者
        this.strictInsertFill(metaObject, "createAt", () -> new Date(), Date.class); // 起始版本 3.3.3(推荐)
        this.strictInsertFill(metaObject, "updateAt", () -> new Date(), Date.class); // 起始版本 3.3.3(推荐)
        // 或者
        // this.fillStrategy(metaObject, "createTime", LocalDateTime.now()); // 也可以使用(3.3.0 该方法有bug)
        this.strictInsertFill(metaObject, "createdAt", () -> new Date(), Date.class); // 起始版本 3.3.3(推荐)
        this.strictInsertFill(metaObject, "updatedAt", () -> new Date(), Date.class); // 起始版本 3.3.3(推荐)
    }

    @Override
    public void updateFill(MetaObject metaObject) {
        log.info("start update fill ....");
        // this.strictUpdateFill(metaObject, "updateTime", LocalDateTime.class, LocalDateTime.now()); // 起始版本 3.3.0(推荐)
        // 或者
        this.strictUpdateFill(metaObject, "updateAt", () -> new Date(), Date.class); // 起始版本 3.3.3(推荐)
        this.strictUpdateFill(metaObject, "updatedAt", () -> new Date(), Date.class); // 起始版本 3.3.3(推荐)
        // 或者
        // this.fillStrategy(metaObject, "updateTime", LocalDateTime.now()); // 也可以使用(3.3.0 该方法有bug)
    }
}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/config/SwaggerConfig.java

New file
@@ -0,0 +1,34 @@
package com.panzhihua.service_jinhui_community.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.service.Contact;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;

/**
 * @program: springcloud_k8s_panzhihuazhihuishequ
 * @description: swagger3
 * @author: huang.hongfa weixin hhf9596 qq 959656820
 * @create: 2020-11-19 16:08
 **/
@Configuration
@EnableSwagger2
public class SwaggerConfig {
    @Bean
    public Docket createRestApi() {
        return new Docket(DocumentationType.SWAGGER_2).apiInfo(apiInfo()).enable(true).select()
//            .apis(RequestHandlerSelectors.withMethodAnnotation(ApiOperation.class))
            .apis(RequestHandlerSelectors.basePackage("com.chuangongzhijia.service_jinhui_community")).build();
    }

    private ApiInfo apiInfo() {
        return new ApiInfoBuilder().title("金汇社区开发文档").description("。")
                .contact(new Contact("李东栋", "", ""))
            .version("1.0").build();
    }
}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/dao/JinhuiCoinGeneralTableDao.java

New file
@@ -0,0 +1,39 @@
package com.panzhihua.service_jinhui_community.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.panzhihua.common.model.vos.jinhui.JinhuiCoinGeneralTableVO;
import com.panzhihua.service_jinhui_community.entity.JinhuiCoinGeneralTable;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

@Mapper
public interface JinhuiCoinGeneralTableDao extends BaseMapper<JinhuiCoinGeneralTable>
{
    /**
     * 分页查询
     * @param
     * @return
     */
    IPage<JinhuiCoinGeneralTable> getList(Page page,@Param("type") String type);



    JinhuiCoinGeneralTable getDetails(@Param("userId") String userId);

    /**
     * 新增
     * @param
     * @return
     */
    int addData(@Param("item") JinhuiCoinGeneralTableVO item);


    int editData(@Param("item") JinhuiCoinGeneralTableVO item);


    int expurgateData(@Param("id") String id);


}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/dao/JinhuiGoldCoinRecordDao.java

New file
@@ -0,0 +1,41 @@
package com.panzhihua.service_jinhui_community.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.panzhihua.common.model.vos.jinhui.JinhuiCoinGeneralTableVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiGoldCoinRecordVO;
import com.panzhihua.service_jinhui_community.entity.JinhuiCoinGeneralTable;
import com.panzhihua.service_jinhui_community.entity.JinhuiGoldCoinRecord;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

@Mapper
public interface JinhuiGoldCoinRecordDao extends BaseMapper<JinhuiGoldCoinRecord>
{
    /**
     * 分页查询
     * @param
     * @return
     */
    IPage<JinhuiGoldCoinRecord> getList(Page page,@Param("type") String type);



    JinhuiGoldCoinRecord getDetails(@Param("userId") String userId);

    /**
     * 新增
     * @param
     * @return
     */
    int addData(@Param("item") JinhuiGoldCoinRecordVO item);


    int editData(@Param("item") JinhuiGoldCoinRecordVO item);


    int expurgateData(@Param("id") String id);


}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/entity/JinhuiCoinGeneralTable.java

New file
@@ -0,0 +1,49 @@
package com.panzhihua.service_jinhui_community.entity;


import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.util.Date;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("金汇社区用户金汇币总表")
public class JinhuiCoinGeneralTable implements Serializable {
    private static final long serialVersionUID = -70884515430727555L;


    @ApiModelProperty(value = "主键")
    private String id;

    @ApiModelProperty(value = "用户id")
    private String userId;

    @ApiModelProperty(value = "金币总额")
    private String goldCoin="0";

    @ApiModelProperty(value = "创建时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date creationTime;


    @ApiModelProperty(value = "更新时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date updateTime;

    @ApiModelProperty(value = "社区id")
    private String communityId;





}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/entity/JinhuiGoldCoinRecord.java

New file
@@ -0,0 +1,56 @@
package com.panzhihua.service_jinhui_community.entity;


import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;
import java.util.Date;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@ApiModel("金汇币明细表")
public class JinhuiGoldCoinRecord implements Serializable {
    private static final long serialVersionUID = -70884515430727555L;


    @ApiModelProperty(value = "主键")
    private String id;

    @ApiModelProperty(value = "用户id")
    private String userId;

    @ApiModelProperty(value = "金币总额")
    private String goldCoin="0";

    @ApiModelProperty(value = "创建时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date creationTime;


    @ApiModelProperty(value = "更新时间")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date updateTime;

    @ApiModelProperty(value = "社区id")
    private String communityId;

    @ApiModelProperty(value = "标题")
    private String title;

    @ApiModelProperty(value = "备注")
    private String remark;

    @ApiModelProperty(value = "状态")
    private String type;



}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/service/JinhuiActActivityService.java

New file
@@ -0,0 +1,31 @@
package com.panzhihua.service_jinhui_community.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.ComActActRegistVO;
import com.panzhihua.common.model.vos.community.SignactivityVO;
import com.panzhihua.service_community.model.dos.ComActActivityDO;

public interface JinhuiActActivityService  extends IService<ComActActivityDO>
{

    /**
     * 报名/取消报名社区活动
     *
     * @param signactivityVO
     *            报名参数
     * @return 报名 取消报名 结果
     */
    R signActivity(SignactivityVO signactivityVO);



    /**
     * 用户签到
     *
     * @param comActActRegistVO 签到参数
     * @return 签到结果
     */
    R activitySignIn(ComActActRegistVO comActActRegistVO);

}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/service/JinhuiCoinGeneralTableService.java

New file
@@ -0,0 +1,28 @@
package com.panzhihua.service_jinhui_community.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.jinhui.JinhuiCoinGeneralTableVO;
import com.panzhihua.service_jinhui_community.entity.JinhuiCoinGeneralTable;

public interface JinhuiCoinGeneralTableService extends IService<JinhuiCoinGeneralTable>
{
    /**
     * 分页查询
     * @param
     * @return
     */
    R getList(int pageNum,int pageSize,String type);

    JinhuiCoinGeneralTable getDetails(String userId);
    /**
     * 新增
     * @param
     * @return
     */
    R addData(JinhuiCoinGeneralTableVO jinhuiCoinGeneralTableVO);

    R editData(JinhuiCoinGeneralTableVO jinhuiCoinGeneralTableVO);

    R expurgateData(String id);
}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/service/JinhuiGoldCoinRecordService.java

New file
@@ -0,0 +1,30 @@
package com.panzhihua.service_jinhui_community.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.jinhui.JinhuiCoinGeneralTableVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiGoldCoinRecordVO;
import com.panzhihua.service_jinhui_community.entity.JinhuiCoinGeneralTable;
import com.panzhihua.service_jinhui_community.entity.JinhuiGoldCoinRecord;

public interface JinhuiGoldCoinRecordService extends IService<JinhuiGoldCoinRecord>
{
    /**
     * 分页查询
     * @param
     * @return
     */
    R getList(int pageNum,int pageSize,String type);

    JinhuiGoldCoinRecord getDetails(String userId);
    /**
     * 新增
     * @param
     * @return
     */
    R addData(JinhuiGoldCoinRecordVO jinhuiGoldCoinRecordVO);

    R editData(JinhuiGoldCoinRecordVO jinhuiGoldCoinRecordVO);

    R expurgateData(String id);
}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/service/impl/JinhuiActActivityServiceImpl.java

New file
@@ -0,0 +1,354 @@
package com.panzhihua.service_jinhui_community.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.constants.HttpStatus;
import com.panzhihua.common.model.dtos.community.integral.admin.AddComActIntegralUserDTO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.ComActActRegistVO;
import com.panzhihua.common.model.vos.community.SignactivityVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiCoinGeneralTableVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiGoldCoinRecordVO;
import com.panzhihua.common.utlis.StringUtils;
import com.panzhihua.service_community.dao.ComActActRegistDAO;
import com.panzhihua.service_community.dao.ComActActSignDAO;
import com.panzhihua.service_community.dao.ComActActivityDAO;
import com.panzhihua.service_community.dao.ComPbMemberDAO;
import com.panzhihua.service_community.entity.ComActActivityInvite;
import com.panzhihua.service_community.model.dos.ComActActRegistDO;
import com.panzhihua.service_community.model.dos.ComActActSignDO;
import com.panzhihua.service_community.model.dos.ComActActivityDO;
import com.panzhihua.service_community.service.ComActActivityInviteService;
import com.panzhihua.service_community.service.ComActIntegralUserTradeService;
import com.panzhihua.service_jinhui_community.entity.JinhuiCoinGeneralTable;
import com.panzhihua.service_jinhui_community.service.JinhuiActActivityService;
import com.panzhihua.service_jinhui_community.service.JinhuiCoinGeneralTableService;
import com.panzhihua.service_jinhui_community.service.JinhuiGoldCoinRecordService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;

import static java.util.Objects.isNull;
import static java.util.Objects.nonNull;

/**
 * @program: springcloud_k8s_panzhihuazhihuishequ
 * @description: 金汇社区活动
 * @author: huang.hongfa weixin hhf9596 qq 959656820
 * @create: 2020-12-07 14:35
 **/
@Slf4j
@Service
public class JinhuiActActivityServiceImpl extends ServiceImpl<ComActActivityDAO, ComActActivityDO>
        implements JinhuiActActivityService
{
    @Resource
    private ComActActivityDAO comActActivityDAO;
    @Resource
    private ComActActSignDAO comActActSignDAO;
    @Resource
    private ComActActRegistDAO comActActRegistDAO;
    @Resource
    private ComActIntegralUserTradeService comActIntegralUserTradeService;
    @Resource
    private ComPbMemberDAO pbMemberDAO;
    @Resource
    private ComActActivityInviteService comActActivityInviteService;

    @Resource
    private JinhuiCoinGeneralTableService jinhuiCoinGeneralTableService;

    @Resource
    private JinhuiGoldCoinRecordService jinhuiGoldCoinRecordService;



    @Override
    public R signActivity(SignactivityVO signactivityVO) {
        Long activityId = signactivityVO.getActivityId();
        Integer type = signactivityVO.getType();
        Long userId = signactivityVO.getUserId();
        Integer isVolunteer = 0;
        // 查询社区活动
        ComActActivityDO actActivityDO = this.baseMapper.selectById(activityId);
        if (isNull(actActivityDO)) {
            return R.fail("活动不存在");
        }
        if(actActivityDO.getSignUpBegin().after(new Date())){
            return R.fail("未到报名时间");
        }
        int num = 0;
        ComActActSignDO comActActSignDO = comActActSignDAO.selectOne(new QueryWrapper<ComActActSignDO>()
                .lambda().eq(ComActActSignDO::getActivityId, activityId).eq(ComActActSignDO::getUserId, userId));
        Integer signIdentity = signactivityVO.getSignIdentity();
        if (1 == type) {
            if (nonNull(comActActSignDO) && comActActSignDO.getStatus().equals(1)) {
                return R.fail("已经报名过了，请勿重复提交");
            }
            Integer activityType = actActivityDO.getType();
            Boolean isInvite = false;
            if (activityType == 1) {
                if (signIdentity == 1) {
                    //以居民身份参与活动
                    Integer residentMax = actActivityDO.getParticipantMax();
                    if (residentMax == null) {
                        return R.fail("活动暂未对居民开放");
                    }
                    // 查询当前活动下参与居民
                    Integer residentCount = comActActSignDAO.selectCount(new QueryWrapper<ComActActSignDO>().lambda()
                            .eq(ComActActSignDO::getActivityId, activityId).eq(ComActActSignDO::getSignIdentity, 1).eq(ComActActSignDO::getStatus, 1));
                    if (residentMax != -1 && residentMax <= residentCount) {
                        return R.fail("报名人数已满");
                    }
                } else if (signIdentity == 2) {
                    //以党员身份参与活动
                    Integer partyMemberMax = actActivityDO.getPartyMemberMax();
                    if (partyMemberMax == null) {
                        return R.fail("活动暂未对党员开放");
                    }
                    ComActActivityInvite activityInvite = comActActivityInviteService.getBaseMapper().selectOne(new LambdaQueryWrapper<ComActActivityInvite>()
                            .eq(ComActActivityInvite::getActivityId, activityId).eq(ComActActivityInvite::getUserId, userId));
                    if (isNull(activityInvite)) {
                        int count = pbMemberDAO.checkIsPbMember(userId);
                        if (count < 1) {
                            return R.fail(HttpStatus.NOT_ACCEPTABLE, "您还不是党员");
                        }
                        // 查询当前活动下参与志愿者
                        Integer partyMemberCount = comActActSignDAO.selectCount(new QueryWrapper<ComActActSignDO>().lambda()
                                .eq(ComActActSignDO::getActivityId, activityId).eq(ComActActSignDO::getSignIdentity, 2)
                                .eq(ComActActSignDO::getStatus, 1).eq(ComActActSignDO::getIsInvite, false));
                        if (partyMemberMax != -1 && partyMemberMax <= partyMemberCount) {
                            return R.fail("报名人数已满");
                        }
                    } else {
                        isInvite = true;
                    }
                } else {
                    //以志愿者身份参与活动
                    Integer volunteerMax = actActivityDO.getVolunteerMax();
                    if (volunteerMax == null) {
                        return R.fail("活动暂未对志愿者开放");
                    }
                    int count = pbMemberDAO.checkIsVolunteer(userId);
                    if (count < 1) {
                        return R.fail(HttpStatus.NOT_ACCEPTABLE, "您还不是志愿者");
                    }
                    // 查询当前活动下参与志愿者
                    Integer volunteerCount = comActActSignDAO.selectCount(new QueryWrapper<ComActActSignDO>().lambda()
                            .eq(ComActActSignDO::getActivityId, activityId).eq(ComActActSignDO::getSignIdentity, 3).eq(ComActActSignDO::getStatus, 1));
                    if (volunteerMax != -1 && volunteerMax <= volunteerCount) {
                        return R.fail("报名人数已满");
                    }
                }
            }
            if (nonNull(comActActSignDO)) {
                comActActSignDO.setStatus(1);
                comActActSignDO.setCreateAt(new Date());
                comActActSignDO.setReason(null);
                comActActSignDO.setSignIdentity(signIdentity);
                comActActSignDO.setTimes(comActActSignDO.getTimes()+1);
                comActActSignDO.setIsInvite(isInvite);
                comActActSignDO.setCheckUnitId(signactivityVO.getCheckUnitId());
                num = comActActSignDAO.updateById(comActActSignDO);
            } else {
                comActActSignDO = new ComActActSignDO();
                comActActSignDO.setActivityId(activityId);
                comActActSignDO.setUserId(userId);
                comActActSignDO.setSignIdentity(signIdentity);
                comActActSignDO.setTimes(1);
                comActActSignDO.setIsInvite(isInvite);
                comActActSignDO.setCheckUnitId(signactivityVO.getCheckUnitId());
                num = comActActSignDAO.insert(comActActSignDO);
            }
        } else {
            Integer regTimes = comActActRegistDAO.selectCount(new QueryWrapper<ComActActRegistDO>().lambda()
                    .eq(ComActActRegistDO::getActivityId, activityId).eq(ComActActRegistDO::getUserId, userId).eq(ComActActRegistDO::getType, 1));
            Integer canCancel = actActivityDO.getCanCancel();
            if (nonNull(canCancel) && canCancel.equals(2)) {
                return R.fail("该活动暂不支持取消");
            }
            if (regTimes > 0) {
                return R.fail("您已参与活动，不可取消");
            }
            if (isNull(signactivityVO.getReason())) {
                return R.fail("缺少取消原因");
            }
            if (isNull(comActActSignDO)) {
                return R.fail("未报名");
            }
            comActActSignDO.setStatus(0);
            comActActSignDO.setReason(signactivityVO.getReason());
            num = comActActSignDAO.updateById(comActActSignDO);
            //计算用户金汇币
            if (num > 0)
            {
                if(!StringUtils.isEmpty(actActivityDO.getJinhuiCoinPunishment()) && !StringUtils.equals(actActivityDO.getJinhuiCoinPunishment(),"0"))
                {
                    //查询个人金汇币总额
                    JinhuiCoinGeneralTable jinhuiCoinGeneralTable=jinhuiCoinGeneralTableService.getDetails(userId+"");
                    if(jinhuiCoinGeneralTable!=null)
                    {
                        if (!StringUtils.isEmpty(jinhuiCoinGeneralTable.getGoldCoin()))
                        {
                            JinhuiCoinGeneralTableVO jinhuiVO=new JinhuiCoinGeneralTableVO();
                            jinhuiVO.setId(jinhuiCoinGeneralTable.getId());

                            int punishmentGold=Integer.valueOf(actActivityDO.getJinhuiCoinPunishment());
                            int allGold=Integer.valueOf(jinhuiCoinGeneralTable.getGoldCoin());
                            if(punishmentGold>=allGold)
                            {
                                jinhuiVO.setGoldCoin("0");
                            }
                            else
                            {
                                allGold=allGold-punishmentGold;
                                jinhuiVO.setGoldCoin(allGold+"");
                            }
                            jinhuiCoinGeneralTableService.editData(jinhuiVO);
                        }
                    }

                    JinhuiGoldCoinRecordVO jVo=new JinhuiGoldCoinRecordVO();
                    jVo.setCommunityId(actActivityDO.getCommunityId()+"");
                    jVo.setTitle("取消志愿者活动");
                    jVo.setUserId(userId+"");
                    jVo.setRemark("取消志愿者活动");
                    jVo.setType("2");
                    jVo.setGoldCoin(actActivityDO.getJinhuiCoinPunishment());
                    jinhuiGoldCoinRecordService.addData(jVo);


                }
            }
        }
        if (num > 0) {
            return R.ok(isVolunteer);
        }
        return R.fail();
    }


    @Override
    public R activitySignIn(ComActActRegistVO comActActRegistVO) {
        Long activityId = comActActRegistVO.getActivityId();
        Long userId = comActActRegistVO.getUserId();
        if (isNull(activityId)) {
            return R.fail("签到所属活动id不能为空！");
        }
        ComActActivityDO comActActivityDO = comActActivityDAO.selectById(activityId);
        if (isNull(comActActivityDO)) {
            return R.fail("活动不存在！");
        }

        ComActActSignDO comActActSignDO = comActActSignDAO
                .selectOne(new QueryWrapper<ComActActSignDO>().lambda().eq(ComActActSignDO::getActivityId, activityId)
                        .eq(ComActActSignDO::getUserId, userId).eq(ComActActSignDO::getStatus, 1));
        if (isNull(comActActSignDO)) {
            return R.fail("活动未报名");
        }

        Date beginAt = comActActivityDO.getBeginAt();
        Date endAt = comActActivityDO.getEndAt();
        Date nowDate = new Date();
        if (nowDate.before(beginAt) || nowDate.after(endAt)) {
            return R.fail("不在活动时间范围内");
        }
        //奖励的金汇币
        Integer rewardIntegral = Integer.valueOf(comActActivityDO.getJinhuiCoinAward());
        boolean isHave = rewardIntegral > 0;
        ComActActRegistDO comActActRegistDO = new ComActActRegistDO();
        if (comActActRegistVO.getSignType() != null && comActActRegistVO.getSignType() == 2) {
            ComActActRegistDO comActActActRegistDO = comActActRegistDAO.selectOne(new QueryWrapper<ComActActRegistDO>()
                    .lambda().eq(ComActActRegistDO::getActivityId, activityId).eq(ComActActRegistDO::getUserId, userId)
                    .eq(ComActActRegistDO::getCodeId, comActActRegistVO.getCodeId()));
            if (comActActActRegistDO == null) {
                return R.fail("未签到无法签退");
            }
            if (comActActActRegistDO.getEndTime() != null) {
                return R.fail("无法重复签退");
            }
            int retrieveIntegral = 0;
            comActActRegistDO.setId(comActActActRegistDO.getId());
            comActActRegistDO.setEndTime(nowDate);
            comActActRegistDO.setAward(retrieveIntegral);
            int result = comActActRegistDAO.updateById(comActActRegistDO);
            if (result > 0) {
                if (isHave) {
//                    AddComActIntegralUserDTO addComActIntegralUserDTO = new AddComActIntegralUserDTO();
//                    addComActIntegralUserDTO.setUserId(userId);
//                    addComActIntegralUserDTO.setIntegralType(integralType);
//                    addComActIntegralUserDTO.setIntegral(retrieveIntegral);
//                    addComActIntegralUserDTO.setSignIdentity(comActActSignDO.getSignIdentity());
//                    addComActIntegralUserDTO.setCommunityId(comActActivityDO.getCommunityId());
//                    addComActIntegralUserDTO.setServiceId(activityId);
//                    addComActIntegralUserDTO.setRemark(remark);
//                    comActIntegralUserTradeService.addIntegralTradeAdmin(addComActIntegralUserDTO);

                    //查询个人金汇币总额
                    JinhuiCoinGeneralTable jinhuiCoinGeneralTable=jinhuiCoinGeneralTableService.getDetails(userId+"");
                    if(jinhuiCoinGeneralTable!=null)
                    {
                        if (!StringUtils.isEmpty(jinhuiCoinGeneralTable.getGoldCoin()))
                        {
                            JinhuiCoinGeneralTableVO jinhuiVO=new JinhuiCoinGeneralTableVO();
                            jinhuiVO.setId(jinhuiCoinGeneralTable.getId());

                            int allGold=Integer.valueOf(jinhuiCoinGeneralTable.getGoldCoin());
                            allGold=allGold+rewardIntegral;
                            jinhuiVO.setGoldCoin(allGold+"");
                            jinhuiCoinGeneralTableService.editData(jinhuiVO);
                        }
                    }

                    JinhuiGoldCoinRecordVO jVo=new JinhuiGoldCoinRecordVO();
                    jVo.setCommunityId(comActActivityDO.getCommunityId()+"");
                    jVo.setTitle("志愿者活动奖励");
                    jVo.setUserId(userId+"");
                    jVo.setRemark("志愿者活动奖励");
                    jVo.setType("1");
                    jVo.setGoldCoin(rewardIntegral+"");
                    jinhuiGoldCoinRecordService.addData(jVo);
                    return R.ok();
                } else {
                    return R.ok();
                }
            }
        } else {
            int signDayCount = comActActRegistDAO.selectCount(new QueryWrapper<ComActActRegistDO>().lambda()
                    .eq(ComActActRegistDO::getActivityId, activityId).eq(ComActActRegistDO::getUserId, userId)
                    .eq(ComActActRegistDO::getCodeId, comActActRegistVO.getCodeId()));
            int signAllCount = comActActRegistDAO.selectCount(new QueryWrapper<ComActActRegistDO>().lambda()
                    .eq(ComActActRegistDO::getActivityId, activityId).eq(ComActActRegistDO::getUserId, userId));
            if (signDayCount > 0) {
                return R.fail("请扫描新的签到码");
            }
            if (isHave) {
                int limit = comActActivityDO.getLimit().intValue();
                if (limit != -1 && signAllCount >= limit) {
                    return R.fail("签到次数上限");
                }
            }
            comActActRegistDO.setActivityId(activityId);
            comActActRegistDO.setStartTime(new Date());
            comActActRegistDO.setType(comActActivityDO.getType());
            comActActRegistDO.setUserId(userId);
            comActActRegistDO.setSignIdentity(comActActSignDO.getSignIdentity());
            comActActRegistDO.setCreateAt(nowDate);
            comActActRegistDO.setCodeId(comActActRegistVO.getCodeId());
            comActActRegistDO.setAward(0);
            comActActRegistDO.setPosition(comActActRegistVO.getPosition());
            comActActRegistDO.setCheckUnitId(comActActSignDO.getCheckUnitId());
            comActActRegistDO.setTimes(signAllCount + 1);
            int result = comActActRegistDAO.insert(comActActRegistDO);
            if (result > 0) {
                return R.ok();
            }
        }
        return R.fail("网络错误，请重试");
    }


}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/service/impl/JinhuiCoinGeneralTableServiceImpl.java

New file
@@ -0,0 +1,64 @@
package com.panzhihua.service_jinhui_community.service.impl;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.VolunteerTypeVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiCoinGeneralTableVO;
import com.panzhihua.service_jinhui_community.dao.JinhuiCoinGeneralTableDao;
import com.panzhihua.service_jinhui_community.entity.JinhuiCoinGeneralTable;
import com.panzhihua.service_jinhui_community.service.JinhuiCoinGeneralTableService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;


@Slf4j
@Service
public class JinhuiCoinGeneralTableServiceImpl extends ServiceImpl<JinhuiCoinGeneralTableDao,
        JinhuiCoinGeneralTable> implements JinhuiCoinGeneralTableService
{

    @Override
    public R getList(int pageNum,int pageSize,String type)
    {
        Page page = new Page<>(pageNum,pageSize);
        return R.ok(baseMapper.getList(page,type));
    }

    @Override
    public JinhuiCoinGeneralTable getDetails(String userId) {
        return baseMapper.getDetails(userId);
    }


    @Override
    public R addData(JinhuiCoinGeneralTableVO volunteerTypeVO)
    {
        int num= baseMapper.addData(volunteerTypeVO);
        if(num>0)
        {
            return R.ok();
        }
        return R.fail("添加失败");
    }

    @Override
    public R editData(JinhuiCoinGeneralTableVO volunteerTypeVO) {
        int num= baseMapper.editData(volunteerTypeVO);
        if(num>0)
        {
            return R.ok();
        }
        return R.fail("添加失败");
    }

    @Override
    public R expurgateData(String id) {
        int num= baseMapper.expurgateData(id);
        if(num>0)
        {
            return R.ok();
        }
        return R.fail("添加失败");
    }
}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/java/com/panzhihua/service_jinhui_community/service/impl/JinhuiGoldCoinRecordServiceImpl.java

New file
@@ -0,0 +1,67 @@
package com.panzhihua.service_jinhui_community.service.impl;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.jinhui.JinhuiCoinGeneralTableVO;
import com.panzhihua.common.model.vos.jinhui.JinhuiGoldCoinRecordVO;
import com.panzhihua.service_jinhui_community.dao.JinhuiCoinGeneralTableDao;
import com.panzhihua.service_jinhui_community.dao.JinhuiGoldCoinRecordDao;
import com.panzhihua.service_jinhui_community.entity.JinhuiCoinGeneralTable;
import com.panzhihua.service_jinhui_community.entity.JinhuiGoldCoinRecord;
import com.panzhihua.service_jinhui_community.service.JinhuiCoinGeneralTableService;
import com.panzhihua.service_jinhui_community.service.JinhuiGoldCoinRecordService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;


@Slf4j
@Service
public class JinhuiGoldCoinRecordServiceImpl extends ServiceImpl<JinhuiGoldCoinRecordDao,
        JinhuiGoldCoinRecord> implements JinhuiGoldCoinRecordService
{

    @Override
    public R getList(int pageNum,int pageSize,String type)
    {
        Page page = new Page<>(pageNum,pageSize);
        return R.ok(baseMapper.getList(page,type));
    }

    @Override
    public JinhuiGoldCoinRecord getDetails(String userId) {
        return baseMapper.getDetails(userId);
    }


    @Override
    public R addData(JinhuiGoldCoinRecordVO volunteerTypeVO)
    {
        int num= baseMapper.addData(volunteerTypeVO);
        if(num>0)
        {
            return R.ok();
        }
        return R.fail("添加失败");
    }

    @Override
    public R editData(JinhuiGoldCoinRecordVO volunteerTypeVO) {
        int num= baseMapper.editData(volunteerTypeVO);
        if(num>0)
        {
            return R.ok();
        }
        return R.fail("添加失败");
    }

    @Override
    public R expurgateData(String id) {
        int num= baseMapper.expurgateData(id);
        if(num>0)
        {
            return R.ok();
        }
        return R.fail("添加失败");
    }
}

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/resources/bootstrap.yml

New file
@@ -0,0 +1,43 @@
spring:
  application:
    name: huacheng-jinhui-community
  cloud:
    config:
      discovery:
        enabled: true
        service-id: huacheng-config  # 注册中心的服务名
      profile: ${ENV:dev}  # 指定配置文件的环境
      uri: http://${CONFIG_URL:localhost}:6193/
  profiles:
    active: ${ENV:dev}
  servlet:
    multipart:
      max-file-size: 10MB
      max-request-size: 10MB


eureka:
  client:
    service-url:
      defaultZone: http://${EUREKA_URL:localhost}:8192/eureka

#实体加密、解密、字段脱敏拦截设置
domain:
  decrypt: true
  encrypt: true
  aesKey: Ryo7M3n8loC5
  sensitive: true

management:
  endpoints:
    web:
      exposure:
        include: '*'

  endpoint:
    health:
      show-details: always

  metrics:
    tags:
      application: huacheng-jinhui-community

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/resources/logback-spring.xml

New file
@@ -0,0 +1,78 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false">
    <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-->
    <springProfile name="dev">
        <property name="LOG_HOME" value="F:\log"/>
    </springProfile>
       <springProfile name="test">
        <property name="LOG_HOME" value="/mnt/data/gocd/log" />
    </springProfile>
<property name="LOG_HOME" value="/mnt/data/gocd/log" />
    <!-- 控制台输出 -->
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->
            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
        </encoder>
    </appender>
    <!-- 按照每天生成日志文件 -->
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <!--日志文件输出的文件名-->
            <FileNamePattern>${LOG_HOME}/huachengservice_community.log.%d{yyyy-MM-dd}.log</FileNamePattern>
            <!--日志文件保留天数-->
            <MaxHistory>30</MaxHistory>
        </rollingPolicy>
        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->
            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>
        </encoder>
        <!--日志文件最大的大小-->
        <triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">
            <MaxFileSize>10MB</MaxFileSize>
        </triggeringPolicy>
    </appender>

    <!--myibatis log configure-->
    <logger name="com.apache.ibatis" level="TRACE"/>
    <logger name="java.sql.Connection" level="DEBUG"/>
    <logger name="java.sql.Statement" level="DEBUG"/>
    <logger name="java.sql.PreparedStatement" level="DEBUG"/>
    <logger name="com.panzhihua.service_community" level="DEBUG"/>

    <!-- 日志输出级别 -->
    <root level="DEBUG">
        <appender-ref ref="STDOUT" />
    </root>
    <root level="INFO">
        <appender-ref ref="STDOUT" />
        <appender-ref ref="FILE" />
    </root>

    <!--慢接口和方法日志记录到不同的文件-->
    <appender name="slowClassAndMethodAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <File>${LOG_HOME}/slow_service_community.log</File>
        <append>true</append>
        <filter class="ch.qos.logback.classic.filter.LevelFilter">
            <level>INFO</level>
            <onMatch>ACCEPT</onMatch>
            <onMismatch>DENY</onMismatch>
        </filter>
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <fileNamePattern>${LOG_HOME}/slow_service_community.%d.%i.log</fileNamePattern>
            <maxHistory>10</maxHistory>
            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
                <maxFileSize>10MB</maxFileSize>
            </timeBasedFileNamingAndTriggeringPolicy>
        </rollingPolicy>
        <encoder>
            <pattern>%d{yyyy/MM/dd HH:mm:ss.SSS} %-5level [%thread] [%c{0}:%L] : %msg%n</pattern>
            <charset>UTF-8</charset>
        </encoder>
    </appender>

    <!--这是我们定义的慢接口和方法日志传入的名称-->
    <logger name="slowClassAndMethodLog" additivity="false" level="INFO">
        <appender-ref ref="slowClassAndMethodAppender"/>
    </logger>
</configuration>

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/resources/mapper/JinhuiCoinGeneralTableMapper.xml

New file
@@ -0,0 +1,100 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.panzhihua.service_jinhui_community.dao.JinhuiCoinGeneralTableDao">

    <resultMap type="com.panzhihua.service_jinhui_community.entity.JinhuiCoinGeneralTable" id="JinhuiCoinGeneralTableMap">
        <result property="id" column="id" />
        <result property="userId" column="user_id" />
        <result property="goldCoin" column="gold_coin" />
        <result property="creationTime" column="creation_time" />
        <result property="updateTime" column="update_time" />
        <result property="communityId" column="community_id" />
    </resultMap>

    <!-- 分页查询 -->
    <select id="getList" resultMap="JinhuiCoinGeneralTableMap">
        select
            id,
            user_id,
            gold_coin,
            creation_time,
            update_time,
            community_id
        from jinhui_coin_general_table
        order by creation_time desc
    </select>


    <select id="getDetails" resultMap="JinhuiCoinGeneralTableMap">
        select
            id,
            user_id,
            gold_coin,
            creation_time,
            update_time,
            community_id
        from jinhui_coin_general_table
        where
            user_id=#{userId}
    </select>

    <insert id="addData">
        insert into jinhui_coin_general_table
        <trim prefix="(" suffix=")" suffixOverrides=",">
            <if test="item.id != null" >
                id,
            </if>
            <if test="item.userId != null and item.userId != '' ">
                user_id,
            </if>
            <if test="item.goldCoin != null and item.goldCoin != '' ">
                gold_coin,
            </if>
            <if test="item.communityId != null and item.communityId != '' ">
                community_id,
            </if>
            creation_time
        </trim>
        values
        <trim prefix="("  suffix=")" suffixOverrides=",">
            <if test="item.id != null" >
                #{item.id},
            </if>
            <if test="item.userId != null and item.userId != '' ">
                #{item.goldCoin},
            </if>
            <if test="item.goldCoin != null and item.goldCoin != '' ">
                #{item.goldCoin},
            </if>
            <if test="item.communityId != null and item.communityId != '' ">
                #{item.communityId},
            </if>
            sysdate()
        </trim>
    </insert>

    <update id="editData">
        update jinhui_coin_general_table
        <set>
            <if test="item.id != null" >
                id=#{item.id},
            </if>
            <if test="item.userId != null and item.userId != '' ">
                user_id=#{item.goldCoin},
            </if>
            <if test="item.goldCoin != null and item.goldCoin != '' ">
                gold_coin=#{item.goldCoin},
            </if>
            <if test="item.communityId != null and item.communityId != '' ">
                community_id=#{item.communityId},
            </if>
            update_time=sysdate()
        </set>
        where id = #{item.id}
    </update>

    <delete id="expurgateData" parameterType="String">
        delete from jinhui_coin_general_table where id=#{id}
    </delete>

</mapper>

 springcloud_k8s_panzhihuazhihuishequ/service_jinhui_commynty/src/main/resources/mapper/JinhuiGoldCoinRecordMapper.xml

New file
@@ -0,0 +1,136 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.panzhihua.service_jinhui_community.dao.JinhuiGoldCoinRecordDao">

    <resultMap type="com.panzhihua.service_jinhui_community.entity.JinhuiGoldCoinRecord" id="itemMap">
        <result property="id" column="id" />
        <result property="userId" column="user_id" />
        <result property="goldCoin" column="gold_coin" />
        <result property="creationTime" column="creation_time" />
        <result property="updateTime" column="update_time" />
        <result property="communityId" column="community_id" />
        <result property="title" column="title" />
        <result property="remark" column="remark" />
        <result property="type" column="type" />
    </resultMap>

    <!-- 分页查询 -->
    <select id="getList" resultMap="itemMap">
        select
            id,
            user_id,
            gold_coin,
            creation_time,
            update_time,
            community_id,
            title,
            remark,
            type
        from jinhui_gold_coin_record
        order by creation_time desc
    </select>


    <select id="getDetails" resultMap="itemMap">
        select
            id,
            user_id,
            gold_coin,
            creation_time,
            update_time,
            community_id,
            title,
            remark,
            type
        from jinhui_gold_coin_record
        where
            user_id=#{userId}
    </select>

    <insert id="addData">
        insert into jinhui_gold_coin_record
        <trim prefix="(" suffix=")" suffixOverrides=",">
            <if test="item.id != null" >
                id,
            </if>
            <if test="item.userId != null and item.userId != '' ">
                user_id,
            </if>
            <if test="item.goldCoin != null and item.goldCoin != '' ">
                gold_coin,
            </if>
            <if test="item.communityId != null and item.communityId != '' ">
                community_id,
            </if>
            <if test="item.title != null and item.title != '' ">
                title,
            </if>
            <if test="item.remark != null and item.remark != '' ">
                remark,
            </if>
            <if test="item.type != null and item.type != '' ">
                type,
            </if>
            creation_time
        </trim>
        values
        <trim prefix="("  suffix=")" suffixOverrides=",">
            <if test="item.id != null" >
                #{item.id},
            </if>
            <if test="item.userId != null and item.userId != '' ">
                #{item.goldCoin},
            </if>
            <if test="item.goldCoin != null and item.goldCoin != '' ">
                #{item.goldCoin},
            </if>
            <if test="item.communityId != null and item.communityId != '' ">
                #{item.communityId},
            </if>
            <if test="item.title != null and item.title != '' ">
                #{item.title},
            </if>
            <if test="item.remark != null and item.remark != '' ">
                #{item.remark},
            </if>
            <if test="item.type != null and item.type != '' ">
                #{item.type},
            </if>
            sysdate()
        </trim>
    </insert>

    <update id="editData">
        update jinhui_gold_coin_record
        <set>
            <if test="item.id != null" >
                id=#{item.id},
            </if>
            <if test="item.userId != null and item.userId != '' ">
                user_id=#{item.goldCoin},
            </if>
            <if test="item.goldCoin != null and item.goldCoin != '' ">
                gold_coin=#{item.goldCoin},
            </if>
            <if test="item.communityId != null and item.communityId != '' ">
                community_id=#{item.communityId},
            </if>
            <if test="item.title != null and item.title != '' ">
                title=#{item.title},
            </if>
            <if test="item.remark != null and item.remark != '' ">
                remark=#{item.remark},
            </if>
            <if test="item.type != null and item.type != '' ">
                type=#{item.type},
            </if>
            update_time=sysdate()
        </set>
        where id = #{item.id}
    </update>

    <delete id="expurgateData" parameterType="String">
        delete from jinhui_gold_coin_record where id=#{id}
    </delete>

</mapper>