lidongdong
2023-01-30 63c985f072826e7c82f51b0f415454a066fd8c56
Merge remote-tracking branch 'origin/haucheng_panzhihua' into haucheng_panzhihua
40个文件已修改
413 ■■■■ 已修改文件
flower_city/src/main/java/com/dg/core/db/gen/mapper/SysUserMapper.java 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
flower_city/src/main/java/com/dg/core/service/ISysUserService.java 5 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
flower_city/src/main/java/com/dg/core/service/impl/GuideRepairOrderServiceImpl.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
flower_city/src/main/java/com/dg/core/service/impl/SysUserServiceImpl.java 13 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
flower_city/src/main/java/com/dg/core/util/SmsUtil.java 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
flower_city/src/main/resources/application.properties 38 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
flower_city/src/main/resources/mapper/SysUserMapper.xml 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommonApi.java 23 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/ShopFlowerApi.java 17 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/WxCallbackApi.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/config/MinioUtil.java 42 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/community/AddComActDynTypeDTO.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/community/ComActColumnVO.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/api/ComActReserveApi.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/api/CommunityPartyBuildingApi.java 21 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/api/CommunityPartyBuildingWestApi.java 33 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/config/MinioUtil.java 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/grid_app/src/main/java/com/panzhihua/grid_app/api/CommonApi.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/BcRegionApi.java 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/BcRegionDao.java 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActDAO.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComActColumn.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComActSocialProject.java 3 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/model/dos/ComActMessageDO.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/BcRegionService.java 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/ComMngProvinceService.java 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/BcRegionServiceImpl.java 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerGoodsServiceImpl.java 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/RentingHourseRegisterServiceImpl.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/BcRegionMapper.xml 17 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActEasyPhotoDOMapper.xml 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActEasyPhotoFeedbackDOMapper.xml 22 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActEasyPhotoHandlerMapper.xml 13 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComEventMapper.xml 35 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComMngPopulationDOMapper.xml 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComPropertyMapper.xml 21 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComShopFlowerOrderDeliveryMapper.xml 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/dao/ComPbMemberDAO.java 9 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_property/src/main/resources/mapper/ComPropertyAlarmMapper.xml 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
flower_city/src/main/java/com/dg/core/db/gen/mapper/SysUserMapper.java
@@ -88,4 +88,9 @@
     * @return 结果
     */
    List<SysUser>  queryList(@Param("userType") Integer userType,@Param("keyWord") String keyWord);
    /**
     * 修改group  长度
     */
    void setGroup();
}
flower_city/src/main/java/com/dg/core/service/ISysUserService.java
@@ -87,5 +87,8 @@
     */
    List<SysUser> queryList(Integer userType,String keyWor);
    /**
     * 修改group  长度
     */
    void setGroup();
}
flower_city/src/main/java/com/dg/core/service/impl/GuideRepairOrderServiceImpl.java
@@ -416,9 +416,9 @@
            if (sysUsers != null && sysUsers.size() > 0) {
                for (SysUser sysUser : sysUsers) {
//            transactionEventMapper.selectOne(new QueryWrapper<TransactionEvent>().lambda().eq(TransactionEvent::getId, guideRepairOrder.getMatterId()));
//            SysUser sysUser = sysUserMapper.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId, guideRepairOrder.getGuideUserId()));
            SysUser sysUserGuideUser = sysUserMapper.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getUserId, guideRepairOrder.getGuideUserId()));
                    if (sysUser != null) {
                        smsUtil.sendSmsOvertimeNew(sysUser.getPhonenumber(), sysUser.getUserName());
                        smsUtil.sendSmsOvertimeNew(sysUser.getPhonenumber(), sysUserGuideUser.getUserName());
                        wxUtil.sendGuideRepairOrderOvertime(sysUser.getOpenid(), accessToken, "86JgWHhR8b1XxD72WYqMnndyfkiMtSSoCk9NFMwLEZ8", sysUser);
                        guideRepairOrder.setIsPush(1);
                        guideRepairOrder.setIsTimeout("2");
flower_city/src/main/java/com/dg/core/service/impl/SysUserServiceImpl.java
@@ -49,18 +49,21 @@
    @Override
    public SysUser getUserByAccount(String account) {
        baseMapper.setGroup();
        SysUser sysUsers = baseMapper.getUserByAccount(account);
        return sysUsers;
    }
    @Override
    public ResultData smsSend(SysUser user){
        baseMapper.setGroup();
        return smsUtil.sendSmsNew(user.getPhonenumber());
    }
    @Override
    public ResultData loginByAccount(String phonenumber, String code){
        baseMapper.setGroup();
        String code1 = redisTemplate.opsForValue().get(phonenumber) + "";
        SysUser sysUser = baseMapper.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getPhonenumber, phonenumber));
@@ -137,6 +140,7 @@
    @Override
    public List<SysUser> selectListByDepartmentId(String departmentId, String classifyId) {
        baseMapper.setGroup();
        List<String> departmentIds=new ArrayList<>();
        departmentIds.add(departmentId);
        List<OrganizationChartEntity> organizationChartEntities = organizationChartMapper.selectList(new QueryWrapper<OrganizationChartEntity>().lambda()
@@ -159,6 +163,7 @@
    @Override
    public ResultData loginByPhonenumber(String phonenumber)
    {
        baseMapper.setGroup();
        SysUser sysUser = baseMapper.selectOne(new QueryWrapper<SysUser>().lambda().eq(SysUser::getPhonenumber, phonenumber));
        if (sysUser==null){
            //查询花城e+是否存在此用户
@@ -239,7 +244,13 @@
    @Override
    public List<SysUser> queryList(Integer userType,String keyWord) {
        baseMapper.setGroup();
        return baseMapper.queryList(userType,keyWord);
    }
    @Override
    public void setGroup() {
        baseMapper.setGroup();
    }
    public  List<String> getDepartmentIds(  List<OrganizationChartEntity> organizationChartEntities,List<String> departmentIds){
@@ -256,11 +267,13 @@
    @Override
    public List<SysUser> selectConfigList(IPage<SysUser> page, Integer state,String userType,String userName,List<String> ids,String isDivisionHead) {
        baseMapper.setGroup();
        return baseMapper.selectConfigList(page, state,userType,userName,ids,isDivisionHead);
    }
    @Override
    public SysUser selectData(String userId,String phonenumber,String loginName) {
        baseMapper.setGroup();
        return baseMapper.selectData(userId,phonenumber,loginName);
    }
flower_city/src/main/java/com/dg/core/util/SmsUtil.java
@@ -24,6 +24,7 @@
import javax.annotation.Resource;
import java.io.IOException;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
@@ -377,7 +378,7 @@
        String url =
                "https://dxsdk.028lk.com:8082/Api/SendSms?"+"LoginName="+LoginName+"&Pwd="+Pwd+"&FeeType="+FeeType+"&Mobile="+tel+"&Content=";
        Random rd = new Random();
        String content="您在"+ LocalDateTime.now() +"新的导办工单,请"+name+"尽快处理。";
        String content="您在"+ LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) +"收到新的导办工单,请"+name+"尽快处理。";
        url=url+content;
        OkHttpClient client = new OkHttpClient();
        Response response;
flower_city/src/main/resources/application.properties
@@ -1,9 +1,11 @@
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.username=root
spring.datasource.password=nahanMysqlPwd&&RemoteRemote2019nahan
#spring.datasource.username=root
#spring.datasource.password=nahanMysqlPwd&&RemoteRemote2019nahan
spring.datasource.username=remote
spring.datasource.password=Panzhihua!@#admin123#@!
#spring.datasource.url=jdbc:mysql://10.8.0.74:3306/huacheng_smart_life?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&allowMultiQueries=true&serverTimezone=GMT%2B8
spring.datasource.url=jdbc:mysql://182.151.2.19:3306/huacheng_smart_life?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8
#spring.datasource.url=jdbc:mysql://182.151.2.19:3306/huacheng_smart_life?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8
spring.datasource.url=jdbc:mysql://118.121.197.120:3306/huacheng_smart_life?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
server.port=8187
#server.port=8088
@@ -11,10 +13,15 @@
swagger.enabled=true
swagger.pathMapping=/
#Redis
spring.redis.host=127.0.0.1
#spring.redis.host=127.0.0.1
#spring.redis.port=6379
#spring.redis.database=2
#spring.redis.password=nahanRedisPwsIsVerySimple&&
spring.redis.host=192.168.1.52
spring.redis.port=6379
spring.redis.database=2
spring.redis.password=nahanRedisPwsIsVerySimple&&
spring.redis.password=ODEGi3MXRBNQ8pH2
@@ -33,12 +40,17 @@
#ftp.username=root
#ftp.password=6-gj!bx@TNb!Dwpjd]1h1Kvqmc
#ftp.host=182.151.31.48
#ftp.port=22
#ftp.url=https://test.panzhihua.nhys.cdnhxx.com/
ftp.username=root
ftp.password=6-gj!bx@TNb!Dwpjd]1h1Kvqmc
ftp.host=182.151.31.48
ftp.password= @!nY0[-zxO
ftp.host= 182.151.24.68
ftp.port=22
ftp.url=https://test.panzhihua.nhys.cdnhxx.com/
ftp.url= https://www.psciio.com
flower_city/src/main/resources/mapper/SysUserMapper.xml
@@ -354,4 +354,9 @@
        delete from automessage_sys_user where user_id= #{id}
    </delete>
    <select id="setGroup">
        SET SESSION group_concat_max_len=10240
    </select>
</mapper>
springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/CommonApi.java
@@ -11,8 +11,8 @@
import com.panzhihua.applets.config.MinioUtil;
import com.panzhihua.applets.umf.UmfPayUtil;
import com.panzhihua.common.controller.BaseController;
import com.panzhihua.common.utlis.DateUtils;
import com.panzhihua.common.utlis.MimeTypeUtils;
import com.panzhihua.common.model.vos.community.Base64File;
import com.panzhihua.common.utlis.*;
import net.coobird.thumbnailator.Thumbnails;
import org.apache.commons.io.FilenameUtils;
import org.apache.commons.lang3.RandomUtils;
@@ -31,8 +31,6 @@
import com.panzhihua.common.model.vos.community.WeatherVO;
import com.panzhihua.common.model.vos.user.UserPhoneVO;
import com.panzhihua.common.service.community.CommunityService;
import com.panzhihua.common.utlis.HttpUtils;
import com.panzhihua.common.utlis.SFTPUtil;
import cn.binarywang.wx.miniapp.api.WxMaSecCheckService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
@@ -164,6 +162,23 @@
        }
    }
    @ApiOperation(value = "文件流上传接口")
    @PostMapping(value = "/uploadImagesInputStream")
    public R uploadImagesInputStream(@RequestBody Base64File file, HttpServletRequest request) {
        if(StringUtils.isEmpty(file.getFile())){
            return R.fail("文件不能为Null");
        }
        try {
            String name = UUID.randomUUID().toString().replaceAll("-", "") + ".jpg";
            InputStream is = minioUtil.base64StrToInputStream(file.getFile().replace("data:image/png;base64,","").replace("data:image/jpg;base64,","").replace("data:image/jpeg;base64,",""));
            String imageUrl = minioUtil.uploadInputStream(is, name);
            return R.ok(imageUrl);
        } catch (Exception e) {
            log.error("上传照片失败【{}】", e.getMessage());
            return R.fail();
        }
    }
    @ApiOperation(value = "新上传照片压缩接口")
    @PostMapping(value = "/uploadimagescompress", consumes = "multipart/*", headers = "content-type=multipart/form-date")
    public R uploadImagesComPress(@RequestParam MultipartFile file, HttpServletRequest request) {
springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/ShopFlowerApi.java
@@ -429,12 +429,21 @@
    @PostMapping("pageRefundOrder")
    @ApiOperation(value = "退款订单分页查询 用户", response = ComShopFlowerRefundOrderVO.class)
    public R pageRefundOrder(@RequestBody PageComOrderRefundDTO pageComOrderRefundDTO) {
        LoginUserInfoVO loginUserInfo = this.getLoginUserInfo();
        if (null != loginUserInfo.getBackstageType() && 5 == loginUserInfo.getBackstageType()){
            pageComOrderRefundDTO.setStoreId(loginUserInfo.getStoreIdId());
        }else {
            pageComOrderRefundDTO.setUserId(this.getUserId());
        return communityService.pageRefundOrder(pageComOrderRefundDTO);
        }
    /**
     * 商家 分页查询退款订单
     *
     * @param pageComOrderRefundDTO
     * @return
     */
    @PostMapping("pageRefundOrderStore")
    @ApiOperation(value = "退款订单分页查询 商家", response = ComShopFlowerRefundOrderVO.class)
    public R pageRefundOrderStore(@RequestBody PageComOrderRefundDTO pageComOrderRefundDTO) {
        LoginUserInfoVO loginUserInfo = this.getLoginUserInfo();
        pageComOrderRefundDTO.setStoreId(loginUserInfo.getStoreIdId());
        return communityService.pageRefundOrder(pageComOrderRefundDTO);
    }
springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/WxCallbackApi.java
@@ -143,7 +143,7 @@
            //调用uu洗车支付成功回调
            Map map=new HashMap();
            map.put("orderId",respMap.get("order_id"));
            HttpClientUtil.sendPostByJson("https://api.uucsh.cn/notify/wx/pzh-pay",JSONObject.toJSONString(map),1,"appid","10000");;
            HttpClientUtil.sendPostByJson("https://uu-api.imashuo.com/notify/wx/pzh-pay",JSONObject.toJSONString(map),1,"appid","10000");;
        }
        //调用SDK生成返回联动平台字符串,加到CONTENT中
        String resMetaData = service.responseUMFMap(respMap);
springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/config/MinioUtil.java
@@ -4,6 +4,7 @@
import io.minio.MinioClient;
import io.minio.ObjectStat;
import org.apache.commons.io.IOUtils;
import org.bouncycastle.util.encoders.Base64;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
@@ -61,6 +62,36 @@
                String fileName = s.append(name).toString();
                String contentType = file.getContentType();
                minioClient.putObject(minioProperties.getBucket(), fileName, input, contentType);
                StringBuilder fileUrl = new StringBuilder(minioProperties.getUrl());
                String url = fileUrl.append(fileName).toString();
                return url;
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return null;
    }
    /**
     * 文件上传
     *
     * @param input
     *            要上传的文件
     * @return
     */
    public String uploadInputStream(InputStream input, String name) {
        if (null != input) {
            try {
                UUID uuid = UUID.randomUUID();
                StringBuilder s = new StringBuilder();
                s.append(DateUtils.getCurrentDateyymd()).append("/");
                MinioClient minioClient = new MinioClient(minioProperties.getHost(), minioProperties.getAccessKey(),
                        minioProperties.getSecretKey());
                if (!minioClient.bucketExists(minioProperties.getBucket())) {
                    minioClient.makeBucket(minioProperties.getBucket());
                }
                String fileName = s.append(name).toString();
                minioClient.putObject(minioProperties.getBucket(), fileName, input, "application/octet-stream");
                StringBuilder fileUrl = new StringBuilder(minioProperties.getUrl());
                String url = fileUrl.append(fileName).toString();
                return url;
@@ -210,4 +241,15 @@
        }
    }
    public InputStream base64StrToInputStream(String base64string) {
        ByteArrayInputStream stream = null;
        try {
            byte[] bytes = Base64.decode(base64string);
            stream = new ByteArrayInputStream(bytes);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return stream;
    }
}
springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/community/AddComActDynTypeDTO.java
@@ -14,7 +14,7 @@
    @ApiModelProperty("分类名称")
    @NotBlank(message = "分类名称不能为空")
    @Length(min = 1, max = 5, message = "分类名称不可超过5个字")
    @Length(min = 1, max = 6, message = "分类名称不可超过6个字")
    private String name;
    @ApiModelProperty("分类字体颜色")
springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/community/ComActColumnVO.java
@@ -57,7 +57,7 @@
    /**
     * 分类类型 1服务类型分类 2技能分类 3通知公告 4项目分类
     */
    @ApiModelProperty(value = "分类类型 1服务类型分类 2技能分类 3通知公告 4项目分类")
    @ApiModelProperty(value = "分类类型 1服务范围分类 2技能分类 3通知公告 4项目分类")
    private Integer type;
    @JsonSerialize(using = ToStringSerializer.class)
springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/api/ComActReserveApi.java
@@ -1059,7 +1059,7 @@
    @ApiOperation(value = "查询西区社区列表")
    @GetMapping("/westList/noToken")
    public R getWestCommunityLists() {
        return communityService.getWestCommunityLists(null);
        return communityService.getWestCommunityLists("");
    }
    @ApiOperation(value = "删除预约登记记录")
springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/api/CommunityPartyBuildingApi.java
@@ -954,6 +954,27 @@
    }
    @ApiOperation(value = "新批量上传照片")
    @PostMapping(value = "/uploadimagess", consumes = "multipart/*", headers = "content-type=multipart/form-date")
    public R uploadImagess(@RequestParam MultipartFile[] files, HttpServletRequest request) {
        List<UploadFilesVO> urlList = new ArrayList<>();
        for (MultipartFile file : files) {
            try {
                assertAllowed(file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION);
                String extension = FilenameUtils.getExtension(file.getOriginalFilename());
                String name = UUID.randomUUID().toString().replaceAll("-", "") + "." + extension;
                String imageUrl = minioUtil.upload(file, name);
                UploadFilesVO fileVO = new UploadFilesVO();
                fileVO.setUrl(imageUrl);
                return R.ok(imageUrl);
            } catch (Exception e) {
                log.error("上传照片失败【{}】", e.getMessage());
                return R.fail();
            }
        }
        return R.ok(urlList);
    }
    @ApiOperation(value = "党员数据统计-分页查询党员数据",response = ComDataStatisticsMemberVo.class)
    @PostMapping("/dataStatistics/member/page")
    public R pageDataStatisticsMember(@RequestBody PageComDataStatisticsMemberDto statisticsMemberDto) {
springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/api/CommunityPartyBuildingWestApi.java
@@ -219,6 +219,7 @@
    @ApiOperation(value = "上传照片")
    @PostMapping(value = "uploadimage", consumes = "multipart/*", headers = "content-type=multipart/form-date")
    public R uploadImage(@RequestParam MultipartFile file, HttpServletRequest request) {
/*
        String name = file.getOriginalFilename();
        List<String> formateList = Arrays.asList("avi", "flv", "mpg", "mpeg", "mpe", "m1v", "m2v", "mpv2", "mp2v",
                "dat", "ts", "tp", "tpr", "pva", "pss", "mp4", "m4v", "m4p", "m4b", "3gp", "3gpp", "3g2", "3gp2", "ogg",
@@ -236,6 +237,17 @@
            sftp.uploadMore(FtpConstants.FTPFILEPATH_IDCARD, name, is);
            sftp.logout();
            return R.ok(url + "/idcard/" + name);
        } catch (Exception e) {
            log.error("上传照片失败【{}】", e.getMessage());
            return R.fail();
        }
*/
        try {
            assertAllowed(file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION);
            String extension = FilenameUtils.getExtension(file.getOriginalFilename());
            String name = UUID.randomUUID().toString().replaceAll("-", "") + "." + extension;
            String imageUrl = minioUtil.upload(file, name);
            return R.ok(imageUrl);
        } catch (Exception e) {
            log.error("上传照片失败【{}】", e.getMessage());
            return R.fail();
@@ -882,6 +894,27 @@
        return R.ok(urlList);
    }
    @ApiOperation(value = "新批量上传照片")
    @PostMapping(value = "/uploadimagess", consumes = "multipart/*", headers = "content-type=multipart/form-date")
    public R uploadImagess(@RequestParam MultipartFile[] files, HttpServletRequest request) {
        List<UploadFilesVO> urlList = new ArrayList<>();
        for (MultipartFile file : files) {
            try {
                assertAllowed(file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION);
                String extension = FilenameUtils.getExtension(file.getOriginalFilename());
                String name = UUID.randomUUID().toString().replaceAll("-", "") + "." + extension;
                String imageUrl = minioUtil.upload(file, name);
                UploadFilesVO fileVO = new UploadFilesVO();
                fileVO.setUrl(imageUrl);
                return R.ok(imageUrl);
            } catch (Exception e) {
                log.error("上传照片失败【{}】", e.getMessage());
                return R.fail();
            }
        }
        return R.ok(urlList);
    }
    @ApiOperation(value = "党员数据统计-分页查询党员数据",response = ComDataStatisticsMemberVo.class)
    @PostMapping("/dataStatistics/member/page")
springcloud_k8s_panzhihuazhihuishequ/community_backstage/src/main/java/com/panzhihua/community_backstage/config/MinioUtil.java
@@ -55,7 +55,8 @@
            try {
                UUID uuid = UUID.randomUUID();
                StringBuilder s = new StringBuilder();
                s.append(uuid.toString().replace("-", "")).append("/");
//                s.append(uuid.toString().replace("-", "")).append("/");
                s.append(DateUtils.getCurrentDateyymd()).append("-original").append("/");
                log.info("开始连接minio服务器" + DateUtils.getCurrentDateStr_MS());
                MinioClient minioClient = new MinioClient(minioProperties.getHost(), minioProperties.getAccessKey(),
                    minioProperties.getSecretKey());
springcloud_k8s_panzhihuazhihuishequ/grid_app/src/main/java/com/panzhihua/grid_app/api/CommonApi.java
@@ -12,6 +12,7 @@
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import com.panzhihua.common.utlis.MimeTypeUtils;
import com.panzhihua.grid_app.config.MinioUtil;
import org.apache.commons.io.FilenameUtils;
import org.springframework.beans.factory.annotation.Value;
@@ -26,6 +27,8 @@
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import static com.panzhihua.common.utlis.FileTypeUploadUtils.assertAllowed;
/**
 * @program: springcloud_k8s_panzhihuazhihuishequ
@@ -117,6 +120,7 @@
    @PostMapping(value = "/uploadimages", consumes = "multipart/*", headers = "content-type=multipart/form-date")
    public R uploadImages(@RequestParam MultipartFile file, HttpServletRequest request) {
        try {
            assertAllowed(file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION);
            String extension = FilenameUtils.getExtension(file.getOriginalFilename());
            String name = UUID.randomUUID().toString().replaceAll("-", "") + "." + extension;
            String imageUrl = minioUtil.upload(file, name);
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/BcRegionApi.java
@@ -41,6 +41,16 @@
    @PostMapping("queryAll")
    public R selectAll(@RequestParam("province") String province, @RequestParam("city") String city, @RequestParam("county")String country,@RequestParam("town")String town) {
        return this.bcRegionService.pageList(province,city,country,town);
    }
        /**
     * 关键字查询
     *
     * @param province 查询实体
     * @return 所有数据
     */
    @PostMapping("selectCommunityCodeByName")
    public R selectCommunityCodeByName( @RequestParam("city") String city, @RequestParam("county")String country,@RequestParam("town")String town,@RequestParam("villagetr") String villagetr) {
        return this.bcRegionService.selectCommunityCodeByName(city,country,town,villagetr);
    }
    @GetMapping("levelList")
    public R levelList(@RequestParam("level")Integer level,@RequestParam("code")String code){
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/BcRegionDao.java
@@ -29,6 +29,16 @@
     */
    String selectByName(@Param("province") String province,@Param("city") String city,@Param("county")String country,@Param("town")String town);
    /**
     * 通过名称查询社区编码
     * @param city
     * @param country
     * @param town
     * @param villagetr
     * @return
     */
    String selectCommunityCodeByName(@Param("city") String city,@Param("county")String country,@Param("town")String town,@Param("villagetr") String villagetr);
    List<ProvinceCityReturnVO> selectFirst();
    List<ProvinceCityReturnVO> selectSecond(String name);
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActDAO.java
@@ -97,7 +97,7 @@
    @Select("<script> select community_id,name,lng,lat from com_act  where state = 0 <if test='areaCode !=null and areaCode !=&quot;&quot;'> and area_code = #{areaCode} </if> </script>")
    List<EventGridCommunityAdminVO> getWestCommunityLists(@Param("areaCode") String areCode);
    @Select("select account,plaintext_password as password from com_act where community_id = ${communityId}")
    @Select("select account,plaintext_password as password from com_act where community_id = #{communityId}")
    ComActPasswordVo getCommunityPassword(@Param("communityId") Long communityId);
    @Select("select name from com_pb_check_unit where id=#{id}")
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComActColumn.java
@@ -72,7 +72,7 @@
    /**
     * 分类类型 1服务类型分类 2技能分类3公告分类
     */
    @ApiModelProperty(value = "分类类型 1服务类型分类 2技能分类3公告分类")
    @ApiModelProperty(value = "分类类型 1服务范围分类 2技能分类 3通知公告 4项目分类")
    private Integer type;
    /**
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/entity/ComActSocialProject.java
@@ -14,9 +14,6 @@
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.util.Date;
/**
 * 三社联动项目表(ComActSocialProject)表实体类
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/model/dos/ComActMessageDO.java
@@ -73,7 +73,7 @@
    private Long communityId;
    /**
     * 留言对象 1 社区团队 2 社区党委
     * 留言对象 1 社区团队 2 社区党委 3人大代表
     */
    private Long type;
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/BcRegionService.java
@@ -21,6 +21,8 @@
     */
    R pageList(String province, String city, String country,String town);
    R selectCommunityCodeByName( String city, String country,String town,String villagetr);
    /**
     * 四级联动列表
     * @return
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/ComMngProvinceService.java
@@ -36,6 +36,7 @@
     * 获取省下的所有区域 tree结构
     * 
     * @param provinceAdcode
     * @param areaCode
     * @return
     */
    R getCityTreeByProvinceCode(Integer provinceAdcode, String areaCode);
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/BcRegionServiceImpl.java
@@ -35,6 +35,11 @@
    }
    @Override
    public R selectCommunityCodeByName( String city, String country,String town,String villagetr) {
        return R.ok(this.baseMapper.selectCommunityCodeByName(city,country,town,villagetr));
    }
    @Override
    public R levelList(Integer level,String code) {
        if(level==1){
            List<ProvinceCityReturnVO> firstLevel=this.baseMapper.selectFirst();
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComShopFlowerGoodsServiceImpl.java
@@ -199,9 +199,9 @@
        if (goodsDO == null || goodsDO.getDeleteStatus().equals(ComShopFlowerGoodsDO.deleteStatus.yes)) {
            return R.fail(403, "商品不存在");
        }
        if (!goodsDO.getStatus().equals(ComShopFlowerGoodsDO.status.sell)) {
            return R.fail(405, "商品已下架");
        }
//        if (!goodsDO.getStatus().equals(ComShopFlowerGoodsDO.status.sell)) {
//            return R.fail(405, "商品已下架");
//        }
        // 根据商品id查询商品规格信息
        List<ComShopFlowerGoodsAttrVO> goodsAttrList = new ArrayList<>();
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/RentingHourseRegisterServiceImpl.java
@@ -94,7 +94,7 @@
        houseRegister.setCreateAt(nowDate);
        houseRegister.setUpdateAt(nowDate);
        try {
            WxMaQrcodeService qrCodeService = wxMaConfiguration.getMaService().getQrcodeService();
            WxMaQrcodeService qrCodeService = wxMaConfiguration.getMaService(registerDTO.getAreaCode()).getQrcodeService();
            byte[] bytes = qrCodeService.createWxaCodeUnlimitBytes("id=" + houseRegister.getId() + "&type=6",
                    minAppJumpPage, 30, true, null, false);
            String authCode = String.format("data:image/png;base64,%s", Base64.encode(bytes));
@@ -444,7 +444,7 @@
        if (!list.isEmpty()) {
            list.stream().forEach(houseRegister -> {
                try {
                    WxMaQrcodeService qrCodeService = wxMaConfiguration.getMaService().getQrcodeService();
                    WxMaQrcodeService qrCodeService = wxMaConfiguration.getMaService(areaCode).getQrcodeService();
                    byte[] bytes = qrCodeService.createWxaCodeUnlimitBytes("id=" + houseRegister.getId() + "&type=6",
                            minAppJumpPage, 30, true, null, false);
                    String authCode = String.format("data:image/png;base64,%s", Base64.encode(bytes));
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/BcRegionMapper.xml
@@ -35,6 +35,23 @@
        limit 1
    </select>
    <select id="selectCommunityCodeByName" resultType="string">
        SELECT distinct code FROM area_index_2022 where 1=1
        <if test="city !=null and city!=''">
            and city =#{city}
        </if>
        <if test="county !=null and county!=''">
            and county like concat(#{county},'%')
        </if>
        <if test="town !=null and town!=''">
            and town = #{town}
        </if>
        <if test="villagetr !=null and villagetr!=''">
            and villagetr like concat(#{villagetr},'%')
        </if>
        limit 1
    </select>
    <select id="selectFirst" resultType="com.panzhihua.common.model.vos.community.ProvinceCityReturnVO">
        select distinct  name,code from area_code_2022 where level=1
    </select>
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActEasyPhotoDOMapper.xml
@@ -499,8 +499,8 @@
        u.`name` sponsor_name,
        u.`nick_name` userNickName,
        u.phone sponsor_phone,
        count( DISTINCT pu.id ) giveThumbsUpNum,
        count( DISTINCT c.id ) commentNum,
        (SELECT  count(pu.id) FROM com_act_easy_photo_user pu WHERE pu.easy_photo_id = p.id) giveThumbsUpNum,
        (SELECT  count(c.id) FROM com_act_easy_photo_comment c WHERE c.easy_photo_id =p.id) commentNum,
        u.image_url,
        p.happen_addr,
        p.addr_remark,
@@ -524,9 +524,7 @@
        FROM
        com_act_easy_photo p
        JOIN sys_user u ON p.sponsor_id = u.user_id
        LEFT JOIN com_act_easy_photo_user pu ON p.id = pu.easy_photo_id
        LEFT JOIN sys_user su ON p.handler_id = su.user_id
        LEFT JOIN com_act_easy_photo_comment c ON p.id = c.easy_photo_id
        LEFT JOIN com_act_easy_photo_classify class ON p.classify_id = class.id
        LEFT JOIN (SELECT * FROM com_act_easy_photo_feedback WHERE `type` = 2) f ON p.id = f.easy_id
        <where> p.del_tag = 0
@@ -540,7 +538,7 @@
            AND p.sponsor_id = #{comActEasyPhotoVO.sponsorId}
        </if>
        <if test='comActEasyPhotoVO.sponsorId == null or comActEasyPhotoVO.sponsorId==0'>
            AND p.`status` in (2,5)
            AND p.`status` in (2,4,5)
            <if test="comActEasyPhotoVO.isFeedBackForDpc == null or comActEasyPhotoVO.isDpcMember == 0">
                AND p.is_publicity = 1
            </if>
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActEasyPhotoFeedbackDOMapper.xml
@@ -6,6 +6,7 @@
    <resultMap id="BaseResultMap" type="com.panzhihua.service_community.model.dos.ComActEasyPhotoFeedbackDO">
        <id column="id" property="id" />
        <result column="easy_id" property="easyId" />
        <result column="type" property="type" />
        <result column="feedback_content" property="feedbackContent" />
        <result column="feedback_img" property="feedbackImg" />
        <result column="create_at" property="createAt" />
@@ -31,7 +32,26 @@
            com_act_easy_photo_feedback AS caepf
            LEFT JOIN sys_user AS su ON su.user_id = caepf.create_by
        WHERE
            caepf.easy_id = #{easyId}
            caepf.easy_id = #{easyId} AND caepf.type = 1
        ORDER BY caepf.create_at desc
    </select>
    <select id="getPhotoFeedbackListForDpc"
            resultType="com.panzhihua.common.model.vos.community.ComActEasyPhotoFeedbackVO">
        SELECT
            caepf.id,
            caepf.easy_id,
            caepf.feedback_content,
            caepf.feedback_img,
            caepf.create_at,
            caepf.create_by,
            dpc.`name` as createByName,
            dpc.photo as createByImage
        FROM
            com_act_easy_photo_feedback AS caepf
            LEFT JOIN sys_user AS su ON su.user_id = caepf.create_by
            LEFT JOIN com_act_dpc dpc ON su.phone = dpc.phone
        WHERE
            caepf.easy_id = #{easyId} AND caepf.type = 2
        ORDER BY caepf.create_at desc
    </select>
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActEasyPhotoHandlerMapper.xml
@@ -12,11 +12,8 @@
    </resultMap>
    <!--查询单个-->
    <select id="queryById" resultMap="ComActEasyPhotoHandlerMap">
        select
          id, community_id, user_id, service_id, type, service_type
        from com_act_easy_photo_handler
        where id = #{id}
    <select id="queryById" resultType="com.panzhihua.common.model.vos.common.ComActEasyPhotoHandlerVo">
        select t.*,t1.name as senderName from com_act_easy_photo_handler t left join sys_user t1 on t.sender_id = t1.user_id where t.id = #{id}
    </select>
    <!--查询指定行数据-->
@@ -47,7 +44,7 @@
                and t.status = #{dto.status}
            </if>
        </where>
        order by create_at desc
        order by t.create_time desc
    </select>
    <!--查询所有数据-->
@@ -77,6 +74,10 @@
        </where>
        order by create_at desc
    </select>
    <select id="selectHandleRecord"
            resultType="com.panzhihua.common.model.vos.common.ComActEasyPhotoHandlerVo">
        SELECT * FROM com_act_easy_photo_handler WHERE service_id = #{serviceId} AND service_type = #{serviceType}
    </select>
</mapper>
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComEventMapper.xml
@@ -101,18 +101,19 @@
                </foreach>
            </if>
            <if test="comEvent.level != null and comEvent.level != ''">
                <if test="comEvent.searchId != null and comEvent.searchId != ''">
                    <if test="comEvent.level == 1">
                        AND type=4
                    AND type=4 OR current_process_type=4
                    </if>
                <if test="comEvent.searchId != null and comEvent.searchId != ''">
                    <if test="comEvent.level == 2">
                        AND center_id=#{comEvent.searchId} AND current_process_type=1
                        AND center_id=#{comEvent.searchId} AND current_process_type in(1,5)
                    </if>
                    <if test="comEvent.level == 3">
                        AND request_user_community in (select community_id from com_act where street_id=#{comEvent.searchId}) AND current_process_type=3
                        AND request_user_community in (select community_id from com_act where street_id=#{comEvent.searchId})
                        AND current_process_type in (3,5)
                    </if>
                    <if test="comEvent.level == 4">
                        AND request_user_community=#{comEvent.searchId} AND current_process_type=2
                        AND request_user_community=#{comEvent.searchId} AND current_process_type in (2,5)
                    </if>
                </if>
            </if>
@@ -208,19 +209,26 @@
            </foreach>
        </if>
        <if test="comEvent.level != null and comEvent.level != ''">
                <if test="comEvent.level == 1">
                    AND current_process_type=4
                </if>
                <if test="comEvent.searchId != null and comEvent.searchId != ''">
            <if test="comEvent.level == 2">
                AND center_id=#{comEvent.searchId} AND current_process_type=1
                        AND center_id=#{comEvent.searchId} AND current_process_type in(1,5)
            </if>
            <if test="comEvent.level == 3">
                AND request_user_community in(select community_id from com_act where street_id = #{comEvent.searchId}) AND current_process_type=3
                        AND request_user_community in (select community_id from com_act where street_id=#{comEvent.searchId})
                        AND current_process_type in (3,5)
            </if>
            <if test="comEvent.level == 4">
                AND request_user_community=#{comEvent.searchId} AND current_process_type=2
                        AND request_user_community=#{comEvent.searchId} AND current_process_type in (2,5)
                    </if>
            </if>
        </if>
    </where>
        group by event_process_status
    </select>
    <select id="caculateSum" resultType="int">
        select count(id) as  sum
@@ -252,18 +260,19 @@
                </foreach>
            </if>
            <if test="comEvent.level != null and comEvent.level != ''">
                <if test="comEvent.searchId != null and comEvent.searchId != ''">
                    <if test="comEvent.level == 1">
                        AND type=4
                    AND current_process_type=4
                    </if>
                <if test="comEvent.searchId != null and comEvent.searchId != ''">
                    <if test="comEvent.level == 2">
                        AND center_id=#{comEvent.searchId} AND current_process_type=1
                        AND center_id=#{comEvent.searchId} AND current_process_type in(1,5)
                    </if>
                    <if test="comEvent.level == 3">
                        AND request_user_community in (select community_id from com_act where street_id=#{comEvent.searchId}) AND current_process_type=3
                        AND request_user_community in (select community_id from com_act where street_id=#{comEvent.searchId})
                        AND current_process_type in (3,5)
                    </if>
                    <if test="comEvent.level == 4">
                        AND request_user_community=#{comEvent.searchId} AND current_process_type=2
                        AND request_user_community=#{comEvent.searchId} AND current_process_type in (2,5)
                    </if>
                </if>
            </if>
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComMngPopulationDOMapper.xml
@@ -1126,7 +1126,8 @@
               IFNULL((select count(user_id) from sys_user where community_id = ${communityId} and type=1),0) as user,
                        IFNULL((select count(id) from com_pb_member where community_id = ${communityId} and audit_result =1 ),0) as partyMember,
                        IFNULL((select count(id) from com_mng_volunteer_mng where community_id = ${communityId} and state=2 ),0) as volunteer,
                        IFNULL((select count(id) from com_pb_org where community_id = ${communityId} and parent_id = 0),0) as partyOrg
            IFNULL((select count(id) from com_pb_org where community_id = ${communityId} and parent_id = 0),0) as partyOrg,
            IFNULL((select count(id) from com_act_dpc where community_id = ${communityId} AND is_del = 0),0) as dpcNum
        from com_mng_population_community_tags AS cmpct
        where cmpct.community_id = ${communityId}
    </select>
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComPropertyMapper.xml
@@ -124,9 +124,9 @@
        (SELECT COUNT(t1.id) FROM com_property_alarm t1 LEFT JOIN com_property_equipment t2 ON t1.serial_no = t2.serial_no
        WHERE t2.community_id = #{communityId} AND t1.`status` = 1 AND t1.`type` = 2) AS completeAbnormalTotal,
        (SELECT COUNT(t1.id) FROM com_property_alarm t1 LEFT JOIN com_property_equipment t2 ON t1.serial_no = t2.serial_no
        WHERE t2.community_id = #{communityId} AND t1.`status` = 0 AND t1.`type` = 1) AS pendingServiceTotal,
        WHERE t2.community_id = #{communityId} AND t1.`status` = 0 AND t1.`type` = 1 and t1.serial_no not like '70%') AS pendingServiceTotal,
        (SELECT COUNT(t1.id) FROM com_property_alarm t1 LEFT JOIN com_property_equipment t2 ON t1.serial_no = t2.serial_no
        WHERE t2.community_id = #{communityId} AND t1.`status` = 1 AND t1.`type` = 1) AS completeServiceTotal
        WHERE t2.community_id = #{communityId} AND t1.`status` = 1 AND t1.`type` = 1 and t1.serial_no not like '70%') AS completeServiceTotal
    </select>
    <select id="retrieveAbnormalAddPolylineData"
            resultType="com.panzhihua.common.model.vos.community.StatisticsCommVO">
@@ -134,7 +134,7 @@
            SELECT DATE_FORMAT( t.create_time, '%Y-%m' ) AS filed, COUNT(1) AS num
            FROM com_property_alarm t
            LEFT JOIN com_property_equipment t1 ON t.serial_no = t1.serial_no
            WHERE t1.community_id = #{communityId} AND t.`type` = 2 AND DATE_FORMAT( t.create_time, '%Y-%m' ) &gt; DATE_FORMAT(date_sub(curdate(), interval 12 month),'%Y-%m'
            WHERE t1.community_id = #{communityId} AND t1.`type` = 2 AND DATE_FORMAT( t.create_time, '%Y-%m' ) &gt; DATE_FORMAT(date_sub(curdate(), interval 12 month),'%Y-%m'
            ) GROUP BY filed
            UNION ALL SELECT * FROM
            (
@@ -158,7 +158,7 @@
        SELECT COUNT( 1 ) AS num
        FROM com_property_alarm t
        LEFT JOIN com_property_equipment t1 ON t.serial_no = t1.serial_no
        WHERE t1.community_id = #{communityId} AND t.`type` = 2 AND DATE_FORMAT( t.create_time, '%Y-%m' ) &lt;= #{date}
        WHERE t1.community_id = #{communityId} AND t1.`type` = 2 AND DATE_FORMAT( t.create_time, '%Y-%m' ) &lt;= #{date}
    </select>
    <select id="retrieveServiceAddPolylineData"
            resultType="com.panzhihua.common.model.vos.community.StatisticsCommVO">
@@ -166,7 +166,7 @@
            SELECT DATE_FORMAT( t.create_time, '%Y-%m' ) AS filed, COUNT(1) AS num
            FROM com_property_alarm t
            LEFT JOIN com_property_equipment t1 ON t.serial_no = t1.serial_no
            WHERE t1.community_id = #{communityId} AND t.`type` = 1 AND DATE_FORMAT( t.create_time, '%Y-%m' ) &gt; DATE_FORMAT(date_sub(curdate(), interval 12 month),'%Y-%m'
            WHERE t1.community_id = #{communityId} AND t1.`type` = 1 AND DATE_FORMAT( t.create_time, '%Y-%m' ) &gt; DATE_FORMAT(date_sub(curdate(), interval 12 month),'%Y-%m'
            ) GROUP BY filed
            UNION ALL SELECT * FROM
            (
@@ -190,7 +190,7 @@
        SELECT COUNT( 1 ) AS num
        FROM com_property_alarm t
        LEFT JOIN com_property_equipment t1 ON t.serial_no = t1.serial_no
        WHERE t1.community_id = #{communityId} AND t.`type` = 1 AND DATE_FORMAT( t.create_time, '%Y-%m' ) &lt;= #{date}
        WHERE t1.community_id = #{communityId} AND t1.`type` = 1 AND DATE_FORMAT( t.create_time, '%Y-%m' ) &lt;= #{date}
    </select>
    <select id="getAbnormalList" resultType="com.panzhihua.common.model.vos.property.ComPropertyAlarmVO">
        SELECT
@@ -198,12 +198,11 @@
        t.create_time,
        t1.phone,
        t1.username AS NAME,
        t3.address AS position
        t1.position
        FROM
        com_property_alarm t
        LEFT JOIN com_property_equipment t1 ON t.serial_no = t1.serial_no
        LEFT JOIN com_mng_population_house t3 ON t1.village_id = t3.id
        WHERE t1.community_id = #{communityId} AND t.`type` = #{type} AND t.`status` = #{status}
        WHERE t1.community_id = #{communityId} AND t.`type` = #{type} AND t.`status` = #{status} and t.serial_no not like '70%'
        ORDER BY t.create_time DESC
    </select>
    <select id="getAlarmPointMapData"
@@ -222,7 +221,7 @@
            SELECT DISTINCT(t1.serial_no)
            FROM com_property_alarm t1
            LEFT JOIN com_property_equipment t2 ON t1.serial_no = t2.serial_no
            WHERE t2.community_id = #{communityId} AND t1.`status` = 0
            WHERE t2.community_id = #{communityId} AND t1.`status` = 0 and t1.serial_no not like '70%'
        )
        UNION ALL
        SELECT
@@ -240,7 +239,7 @@
            FROM com_property_alarm t1
            LEFT JOIN com_property_equipment t2 ON t1.serial_no = t2.serial_no
            WHERE t2.community_id = #{communityId} AND t1.`status` = 0
        )
        ) and serial_no not like '70%'
    </select>
    <select id="noticeList" resultType="com.panzhihua.common.model.vos.community.ComActAnnouncementVO">
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComShopFlowerOrderDeliveryMapper.xml
@@ -29,7 +29,7 @@
    <select id="pageDelivery" resultType="com.panzhihua.common.model.vos.shop.ComShopFlowerOrderDeliveryVO">
        select * from com_shop_flower_order_delivery where 1=1
        <if test="pageComFlowerOrderDeliveryDTO.deliveryNo != null and pageComFlowerOrderDeliveryDTO.deliveryNo != ''">
            and delivery_no like concat(#{pageComFlowerOrderDeliveryDTO.deliveryNo}, '%' )
            and delivery_no like concat( '%',#{pageComFlowerOrderDeliveryDTO.deliveryNo}, '%' )
        </if>
        <if test="pageComFlowerOrderDeliveryDTO.deliveryStatus != null">
            and delivery_status = #{pageComFlowerOrderDeliveryDTO.deliveryStatus}
springcloud_k8s_panzhihuazhihuishequ/service_partybuilding/src/main/java/com/panzhihua/service_dangjian/dao/ComPbMemberDAO.java
@@ -109,9 +109,10 @@
    /**
     * 根据id查询党员信息
     * @param id    主键id
     * @param areaCode
     * @return  党员信息
     */
    PartyBuildingMemberVO queryById(@Param("id") Long id);
    PartyBuildingMemberVO queryById(@Param("id") Long id, @Param("areaCode") String areaCode);
    /**
     * 分页查询党员数据统计
@@ -142,19 +143,21 @@
     * @param orgIds    党组织id集合
     * @param startTime 查询开始时间
     * @param endTime   查询结束时间
     * @param areaCode
     * @return  社区党组织左下统计数据
     */
    ComDataStatisticsOrgVo getOrgDataStatisticsLeftDown(@Param("communityId") Long communityId,@Param("orgIds") List<Long> orgIds
            ,@Param("startTime") String startTime,@Param("endTime") String endTime);
            , @Param("startTime") String startTime, @Param("endTime") String endTime, @Param("areaCode") String areaCode);
    /**
     * 分页查询社区党组织下党员
     * @param page   分页参数
     * @param communityId   社区id
     * @param orgIds    党组织id集合
     * @param areaCode
     * @return  党员列表
     */
    IPage<PartyBuildingMemberVO> getOrgDataStatisticsMember(Page page,@Param("communityId") Long communityId,@Param("orgIds") List<Long> orgIds);
    IPage<PartyBuildingMemberVO> getOrgDataStatisticsMember(@Param("page") Page page, @Param("communityId") Long communityId, @Param("orgIds") List<Long> orgIds, @Param("areaCode") String areaCode);
    /**
     * 查询社区党组织下某个时间段统计数据
springcloud_k8s_panzhihuazhihuishequ/service_property/src/main/resources/mapper/ComPropertyAlarmMapper.xml
@@ -18,13 +18,15 @@
    </resultMap>
    <select id="selectList" resultType="com.panzhihua.common.model.vos.property.ComPropertyAlarmVO">
        select t.id,t.serial_no,t.type,t.create_time,t1.phone,t1.username as name,t.status,t.solve_id,t.solve_time,t.solve_content,t.community_id,t.solve_url,t3.address as position,t1.longitude,t1.latitude,t2.name as solveName,t4.username as receiveName from com_property_alarm t
        select t.id,t.serial_no,t.type,t.create_time,t1.phone,t1.username as name,t.status,
            t.solve_id,t.solve_time,t.solve_content,t.community_id,t.solve_url,t1.position,
            t1.longitude,t1.latitude,t2.name as solveName,t4.username as receiveName
        from com_property_alarm t
        left join com_property_equipment t1 on t.serial_no = t1.serial_no
        left join com_mng_population_house t3 on t1.village_id=t3.id
        left join sys_user t2 on t.solve_id = user_id
        left join com_property_equipment t4 on t.receive_no = t4.serial_no
        <where>
            1=1
            1=1 and t.serial_no not like '70%'
            <if test="commonPage.paramId !=null">
                and t1.community_id = ${commonPage.paramId}
            </if>
@@ -35,7 +37,7 @@
                and t.status =#{commonPage.status}
            </if>
            <if test="commonPage.address !=null and commonPage.address !=''">
                and t3.address like concat(#{commonPage.address},'%')
                and t1.position like concat(#{commonPage.address},'%')
            </if>
            <if test="commonPage.username !=null and commonPage.username !=''">
                and t1.username like concat(#{commonPage.username},'%')
springcloud_k8s_panzhihuazhihuishequ/service_user/src/main/java/com/panzhihua/service_user/service/impl/UserServiceImpl.java
@@ -3416,7 +3416,7 @@
        }
        Map<String, String> headerMap = new HashMap<>();
        headerMap.put("appid", appId);
        String resultJson = HttpClientUtil.get("https://api.uucsh.cn/member/wx/get-access?province=" + uuLoginVO.getProvince() + "&city=" + uuLoginVO.getCity() + "&area=" + uuLoginVO.getArea() + "&appid=" + appId + "&timestamp=" + uuLoginVO.getTimestamp() + "&sign=" + uuLoginVO.getSign() + "&mobile=" + uuLoginVO.getMobile() + "&couponId=" + uuLoginVO.getCouponId(), headerMap, null);
        String resultJson = HttpClientUtil.get("https://uu-api.imashuo.com/member/wx/get-access?province=" + uuLoginVO.getProvince() + "&city=" + uuLoginVO.getCity() + "&area=" + uuLoginVO.getArea() + "&appid=" + appId + "&timestamp=" + uuLoginVO.getTimestamp() + "&sign=" + uuLoginVO.getSign() + "&mobile=" + uuLoginVO.getMobile() + "&couponId=" + uuLoginVO.getCouponId(), headerMap, null);
        JSONObject result = JSON.parseObject(resultJson);
        if (result.get("status").equals(1)) {
            return R.ok(result.get("data"));