联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
java110
2022-04-14 51aa6b4f8a3d199b3e5f93f7b5513a040aecfc10 
 service-job/src/main/java/com/java110/job/adapt/payment/notice/MachinePaymentNoticeAdapt.java


@@ -50,12 +50,16 @@


import com.java110.utils.util.DateUtil;


import com.java110.utils.util.StringUtil;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import com.java110.core.log.LoggerFactory;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.http.ResponseEntity;


import org.springframework.stereotype.Component;


import org.springframework.web.client.RestTemplate;




import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.util.Calendar;


import java.util.Date;


import java.util.List;


import java.util.Map;




@@ -138,12 +142,26 @@


                businessPayFeeDetails = (JSONArray) bObj;


            }


        } else {


            return;


            if (data instanceof JSONObject) {


                businessPayFeeDetails = new JSONArray();


                businessPayFeeDetails.add(data);


            }


        }


        for (int bPayFeeDetailIndex = 0; bPayFeeDetailIndex < businessPayFeeDetails.size(); bPayFeeDetailIndex++) {


            JSONObject businessPayFeeDetail = businessPayFeeDetails.getJSONObject(bPayFeeDetailIndex);


            doSendPayFeeDetail(business, businessPayFeeDetail);


        }


    }




    private String subDay(String date) throws ParseException {


        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");


        Date dt = sdf.parse(date);


        Calendar rightNow = Calendar.getInstance();


        rightNow.setTime(dt);


        rightNow.add(Calendar.DAY_OF_MONTH, -1);


        Date dt1 = rightNow.getTime();


        String reStr = sdf.format(dt1);


        return reStr;


    }




    private void doSendPayFeeDetail(Business business, JSONObject businessPayFeeDetail) {


@@ -166,28 +184,58 @@


        String startTime = DateUtil.dateTimeToDate(payFeeDetailPo.getStartTime());


        //获取用户缴费到期时间


        String endTime = DateUtil.dateTimeToDate(payFeeDetailPo.getEndTime());


        try {


            endTime = subDay(endTime);


        } catch (ParseException e) {


            e.printStackTrace();


        }


        //获取用户缴费金额


        String receivedAmount = payFeeDetailPo.getReceivedAmount();


        //获取费用类型


        String feeTypeCd = feeDtos.get(0).getFeeTypeCd();


        //获取付费对象类型


        String payerObjType = feeDtos.get(0).getPayerObjType();


        //获取状态


        String state = payFeeDetailPo.getState();


        //车牌号


        String carNum = "";


        //停车场


        String num = "";


        //车位


        String spaceNum = "";


        if (!StringUtil.isEmpty(payerObjType) && payerObjType.equals("6666")) {


            String[] split = payerObjName.split("-");


            //获取车牌


            carNum = split[0];


            //获取停车场


            num = split[1];


            //获取车位


            spaceNum = split[2];


        }


        //获取社区名称


        String name = communityDtos.get(0).getName();


        JSONObject paramIn = new JSONObject();


        paramIn.put("payFeeRoom", name + payerObjName);


        paramIn.put("payFeeRoom", name + "-" + payerObjName);


        paramIn.put("feeTypeCdName", feeTypeCdName);


        paramIn.put("payFeeTime", startTime + "至" + endTime);


        paramIn.put("receivedAmount", receivedAmount);


        paramIn.put("startTime", startTime);


        paramIn.put("endTime", endTime);


        paramIn.put("payerObjType", payerObjType);


        paramIn.put("carNum", carNum);


        paramIn.put("num", num);


        paramIn.put("spaceNum", spaceNum);


        paramIn.put("state", state);


        //给业主推送消息


        sendMessage(paramIn, communityDtos.get(0), payFeeDetailPo);


        if (feeTypeCd.equals("888800010012")) {


        if (!StringUtil.isEmpty(state) && !state.equals("1300") && feeTypeCd.equals("888800010012")) {


            //给处理报修完结单的维修师傅推送消息


            sendMsg(paramIn, communityDtos.get(0), payFeeDetailPo);


        }


        //给员工推送消息


        publishMsg(paramIn, communityDtos.get(0), payFeeDetailPo);




        if (!StringUtil.isEmpty(state) && !state.equals("1300")) {


            //给员工推送消息


            publishMsg(paramIn, communityDtos.get(0), payFeeDetailPo);


        }


    }




    /**


@@ -240,35 +288,45 @@


            sendTemplate = sendMsgUrl;


        }


        String url = sendTemplate + accessToken;


        for (UserDto userDto : userDtos) {


            //根据 userId 查询到openId


            try {


                StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto();


                staffAppAuthDto.setStaffId(userDto.getUserId());


                staffAppAuthDto.setAppType("WECHAT");


                List<StaffAppAuthDto> staffAppAuthDtos = staffAppAuthInnerServiceSMO.queryStaffAppAuths(staffAppAuthDto);


                if(staffAppAuthDtos == null || staffAppAuthDtos.size()<1){


                    continue;


        //获取付费对象类型


        String payerObjType = paramIn.getString("payerObjType");


        if (userDtos != null && userDtos.size() > 0) {


            for (UserDto userDto : userDtos) {


                //根据 userId 查询到openId


                try {


                    StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto();


                    staffAppAuthDto.setStaffId(userDto.getUserId());


                    staffAppAuthDto.setAppType("WECHAT");


                    List<StaffAppAuthDto> staffAppAuthDtos = staffAppAuthInnerServiceSMO.queryStaffAppAuths(staffAppAuthDto);


                    if (staffAppAuthDtos == null || staffAppAuthDtos.size() < 1) {


                        continue;


                    }


                    String openId = staffAppAuthDtos.get(0).getOpenId();


                    Data data = new Data();


                    PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage();


                    templateMessage.setTemplate_id(templateId);


                    templateMessage.setTouser(openId);


                    data.setFirst(new Content("本次缴费已到账"));


                    if (payerObjType.equals("3333")) {  //房屋


                        data.setKeyword1(new Content(paramIn.getString("payFeeRoom")));


                        data.setKeyword2(new Content(paramIn.getString("feeTypeCdName")));


                    } else {  //车辆


                        data.setKeyword1(new Content(communityDto.getName() + "-" + paramIn.getString("num") + "-" + paramIn.getString("spaceNum")));


                        data.setKeyword2(new Content(paramIn.getString("feeTypeCdName") + "-" + paramIn.getString("carNum")));


                    }


                    data.setKeyword3(new Content(paramIn.getString("payFeeTime")));


                    data.setKeyword4(new Content(paramIn.getString("receivedAmount") + "元"));


                    data.setRemark(new Content("感谢您的使用,如有疑问请联系相关物业人员"));


                    templateMessage.setData(data);


                    //获取员工公众号地址


                    String wechatUrl = MappingCache.getValue("STAFF_WECHAT_URL");


                    templateMessage.setUrl(wechatUrl);


                    logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage));


                    ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class);


                    logger.info("微信模板返回内容:{}", responseEntity);


                } catch (Exception e) {


                    logger.error("发送缴费信息失败", e);


                }


                String openId = staffAppAuthDtos.get(0).getOpenId();


                Data data = new Data();


                PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage();


                templateMessage.setTemplate_id(templateId);


                templateMessage.setTouser(openId);


                data.setFirst(new Content("本次缴费已到账"));


                data.setKeyword1(new Content(paramIn.getString("payFeeRoom")));


                data.setKeyword2(new Content(paramIn.getString("feeTypeCdName")));


                data.setKeyword3(new Content(paramIn.getString("payFeeTime")));


                data.setKeyword4(new Content(paramIn.getString("receivedAmount") + "元"));


                data.setRemark(new Content("感谢您的使用,如有疑问请联系相关物业人员"));


                templateMessage.setData(data);


                String wechatUrl = MappingCache.getValue("OWNER_WECHAT_URL");


                templateMessage.setUrl(wechatUrl);


                logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage));


                ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class);


                logger.info("微信模板返回内容:{}", responseEntity);


            } catch (Exception e) {


                logger.error("发送缴费信息失败", e);


            }


        }


    }


@@ -338,7 +396,8 @@


            data.setKeyword4(new Content(paramIn.getString("receivedAmount") + "元"));


            data.setRemark(new Content("请与客服管家核实费用"));


            templateMessage.setData(data);


            String wechatUrl = MappingCache.getValue("OWNER_WECHAT_URL");


            //获取员工公众号地址


            String wechatUrl = MappingCache.getValue("STAFF_WECHAT_URL");


            templateMessage.setUrl(wechatUrl);


            logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage));


            ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class);


@@ -387,7 +446,7 @@


        feeDto.setCommunityId(payFeeDetailPo.getCommunityId());


        List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);


        Assert.listOnlyOne(feeDtos, "费用不存在");


        //支付房间id


        //支付房间id(支付车辆id)


        String payerObjId = feeDtos.get(0).getPayerObjId();


        //支付类型(房屋、车辆)


        String payerObjType = feeDtos.get(0).getPayerObjType();


@@ -401,8 +460,9 @@


            ownerId = ownerRoomRelDtos.get(0).getOwnerId();


        } else if (payerObjType.equals("6666")) {


            OwnerCarDto ownerCarDto = new OwnerCarDto();


            ownerCarDto.setPsId(payerObjId);


            ownerCarDto.setCarId(payerObjId);


            List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMO.queryOwnerCars(ownerCarDto);


            Assert.listOnlyOne(ownerCarDtos, "查询车辆所属业主信息错误！");


            //取得业主id


            ownerId = ownerCarDtos.get(0).getOwnerId();


        }


@@ -412,6 +472,7 @@


        ownerDto.setOwnerTypeCd("1001");


        //查询业主


        List<OwnerDto> ownerDtos = ownerInnerServiceSMO.queryOwners(ownerDto);


        Assert.listOnlyOne(ownerDtos, "查询业主信息错误！");


        //获得成员id


        String memberId = ownerDtos.get(0).getMemberId();


        OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();


@@ -426,13 +487,30 @@


            PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage();


            templateMessage.setTemplate_id(templateId);


            templateMessage.setTouser(openId);


            data.setFirst(new Content("本次缴费已到账"));


            data.setKeyword1(new Content(paramIn.getString("payFeeRoom")));


            data.setKeyword2(new Content(paramIn.getString("feeTypeCdName")));


            if (!StringUtil.isEmpty(paramIn.getString("state")) && paramIn.getString("state").equals("1300")) {


                data.setFirst(new Content("本次退费已到账"));


            } else {


                data.setFirst(new Content("本次缴费已到账"));


            }


            if (payerObjType.equals("3333")) {  //房屋


                data.setKeyword1(new Content(paramIn.getString("payFeeRoom")));


                data.setKeyword2(new Content(paramIn.getString("feeTypeCdName")));


            } else {  //车辆


                data.setKeyword1(new Content(communityDto.getName() + "-" + paramIn.getString("num") + "-" + paramIn.getString("spaceNum")));


                data.setKeyword2(new Content(paramIn.getString("feeTypeCdName") + "-" + paramIn.getString("carNum")));


            }


            data.setKeyword3(new Content(paramIn.getString("payFeeTime")));


            data.setKeyword4(new Content(paramIn.getString("receivedAmount") + "元"));


            if (!StringUtil.isEmpty(paramIn.getString("state")) && paramIn.getString("state").equals("1300")) {


                //获取退费金额


                double receivedAmount = Double.parseDouble(paramIn.getString("receivedAmount"));


                double money = receivedAmount * (-1.00);


                data.setKeyword4(new Content("退费" + money + "元"));


            } else {


                data.setKeyword4(new Content(paramIn.getString("receivedAmount") + "元"));


            }


            data.setRemark(new Content("感谢您的使用,如有疑问请联系相关物业人员"));


            templateMessage.setData(data);


            //获取业主公众号地址


            String wechatUrl = MappingCache.getValue("OWNER_WECHAT_URL");


            templateMessage.setUrl(wechatUrl);


            logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage));