java110-bean/src/main/java/com/java110/dto/fee/FeeDto.java
@@ -1,8 +1,6 @@ package com.java110.dto.fee; import com.java110.dto.PageDto; import com.java110.dto.RoomDto; import com.java110.dto.owner.OwnerCarDto; import java.io.Serializable; import java.util.Date; @@ -116,7 +114,11 @@ private List<FeeAttrDto> feeAttrDtos; //当前时间 private Date nowDate; //查询出的数量 private int count; public String getAmount() { @@ -207,7 +209,6 @@ public void setEndTime(Date endTime) { this.endTime = endTime; } public Date getArrearsEndTime() { return arrearsEndTime; @@ -553,5 +554,19 @@ this.ownerId = ownerId; } public Date getNowDate() { return nowDate; } public void setNowDate(Date nowDate) { this.nowDate = nowDate; } public int getCount() { return count; } public void setCount(int count) { this.count = count; } } java110-bean/src/main/java/com/java110/dto/repair/RepairDto.java
@@ -81,6 +81,7 @@ private String returnVisitFlag; private String startRuId; private String preRuId; private String ruId; public String getRepairName() { @@ -331,4 +332,12 @@ public void setbId(String bId) { this.bId = bId; } public String getRuId() { return ruId; } public void setRuId(String ruId) { this.ruId = ruId; } } java110-db/src/main/resources/mapper/community/CommunityServiceDaoImplMapper.xml
@@ -478,7 +478,7 @@ <if test="memberId !=null and memberId !=''"> ,s_community_member cm </if> where 1 =1 where t.status_cd = '0' and t.city_code = ca.area_code and ca.status_cd = '0' <if test="address !=null and address != ''"> @@ -535,7 +535,6 @@ <if test="page != -1 and page != null "> limit #{page}, #{row} </if> </select>
@@ -295,7 +295,7 @@ d.name stateName, rs.repair_type_name repairTypeName,rs.repair_way repairWay, t.repair_obj_type,t.repair_obj_id,t.repair_obj_name,t.repair_obj_type repairObjType,t.repair_obj_id repairObjId,t.repair_obj_name repairObjName, sru.ru_id startRuId,ru.ru_id ruId sru.ru_id startRuId,ru.ru_id ruId,ru.pre_ru_id preRuId from r_repair_pool t left join t_dict d on t.state = d.status_cd and d.table_name = 'r_repair_pool' and d.table_columns = 'state' left join r_repair_setting rs on rs.repair_type = t.repair_type and rs.status_cd = '0' java110-db/src/main/resources/mapper/fee/FeeServiceDaoImplMapper.xml
@@ -190,6 +190,9 @@ <if test="arrearsEndTime != null"> and t.end_time < #{arrearsEndTime} </if> <if test="nowDate != null"> and t.end_time > #{nowDate} </if> <if test="communityId !=null and communityId != ''"> and t.community_id= #{communityId} and pfc.community_id in (#{communityId},'9999') service-api/src/main/java/com/java110/api/listener/ownerRepair/GrabbingRepairListener.java
@@ -12,7 +12,6 @@ import com.java110.intf.community.IRepairInnerServiceSMO; import com.java110.intf.community.IRepairTypeUserInnerServiceSMO; import com.java110.intf.community.IRepairUserInnerServiceSMO; import com.java110.intf.fee.IFeeConfigInnerServiceSMO; import com.java110.po.owner.RepairUserPo; import com.java110.utils.constant.BusinessTypeConstant; import com.java110.utils.constant.ServiceCodeRepairDispatchStepConstant; @@ -49,9 +48,6 @@ @Autowired private IRepairTypeUserInnerServiceSMO repairTypeUserInnerServiceSMOImpl; @Autowired private IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl; @Override protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) { //Assert.hasKeyAndValue(reqJson, "xxx", "xxx"); @@ -82,36 +78,54 @@ @Override protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) { //获取报修id String repairId = reqJson.getString("repairId"); RepairDto repairDto = new RepairDto(); repairDto.setRepairId(repairId); List<RepairDto> repairDtos = repairInnerServiceSMOImpl.queryRepairs(repairDto); if (repairDtos == null || repairDtos.size() < 1) { ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "数据错误！"); context.setResponseEntity(responseEntity); } else { //获取状态 String state = repairDtos.get(0).getState(); if (state.equals("1000")) { //1000表示未派单 RepairUserDto repairUserDto = new RepairUserDto(); repairUserDto.setRepairId(repairId); repairUserDto.setCommunityId(reqJson.getString("communityId")); repairUserDto.setRepairEvent(RepairUserDto.REPAIR_EVENT_START_USER); List<RepairUserDto> repairUserDtos = repairUserInnerServiceSMOImpl.queryRepairUsers(repairUserDto); Assert.listOnlyOne(repairUserDtos, "未找到开始节点或找到多条"); RepairUserDto repairUserDto = new RepairUserDto(); repairUserDto.setRepairId(reqJson.getString("repairId")); repairUserDto.setCommunityId(reqJson.getString("communityId")); repairUserDto.setRepairEvent(RepairUserDto.REPAIR_EVENT_START_USER); List<RepairUserDto> repairUserDtos = repairUserInnerServiceSMOImpl.queryRepairUsers(repairUserDto); Assert.listOnlyOne(repairUserDtos, "未找到开始节点或找到多条"); String userId = reqJson.getString("userId"); String userName = reqJson.getString("userName"); RepairUserPo repairUserPo = new RepairUserPo(); repairUserPo.setRuId("-1"); repairUserPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); repairUserPo.setState(RepairUserDto.STATE_DOING); repairUserPo.setRepairId(reqJson.getString("repairId")); repairUserPo.setStaffId(userId); repairUserPo.setStaffName(userName); repairUserPo.setPreStaffId(repairUserDtos.get(0).getStaffId()); repairUserPo.setPreStaffName(repairUserDtos.get(0).getStaffName()); repairUserPo.setPreRuId(repairUserDtos.get(0).getRuId()); repairUserPo.setRepairEvent(RepairUserDto.REPAIR_EVENT_AUDIT_USER); repairUserPo.setContext(""); repairUserPo.setCommunityId(reqJson.getString("communityId")); super.insert(context, repairUserPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_REPAIR_USER); ownerRepairBMOImpl.modifyBusinessRepairDispatch(reqJson, context, RepairDto.STATE_TAKING); String userId = reqJson.getString("userId"); String userName = reqJson.getString("userName"); RepairUserPo repairUserPo = new RepairUserPo(); repairUserPo.setRuId("-1"); repairUserPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); repairUserPo.setState(RepairUserDto.STATE_DOING); repairUserPo.setRepairId(reqJson.getString("repairId")); repairUserPo.setStaffId(userId); repairUserPo.setStaffName(userName); repairUserPo.setPreStaffId(repairUserDtos.get(0).getStaffId()); repairUserPo.setPreStaffName(repairUserDtos.get(0).getStaffName()); repairUserPo.setPreRuId(repairUserDtos.get(0).getRuId()); repairUserPo.setRepairEvent(RepairUserDto.REPAIR_EVENT_AUDIT_USER); repairUserPo.setContext(""); repairUserPo.setCommunityId(reqJson.getString("communityId")); super.insert(context, repairUserPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_REPAIR_USER); ownerRepairBMOImpl.modifyBusinessRepairDispatch(reqJson, context, RepairDto.STATE_TAKING); ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_OK, ResultVo.MSG_OK); ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_OK, ResultVo.MSG_OK); context.setResponseEntity(responseEntity); context.setResponseEntity(responseEntity); } else if (state.equals("1100")) { //1100表示接单 ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "该订单处于接单状态，无法进行抢单！"); context.setResponseEntity(responseEntity); } else { ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "状态异常！"); context.setResponseEntity(responseEntity); } } }
@@ -41,15 +41,14 @@ @Java110Listener("repairDispatchListener") public class RepairDispatchListener extends AbstractServiceApiPlusListener { //派单 public static final String ACTION_DISPATCH = "DISPATCH"; //转单 public static final String ACTION_TRANSFER = "TRANSFER"; //退单 public static final String ACTION_BACK = "BACK"; private static Logger logger = LoggerFactory.getLogger(RepairDispatchListener.class); @@ -98,13 +97,7 @@ case ACTION_BACK: backRepair(context, reqJson); break; } ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_OK, ResultVo.MSG_OK); context.setResponseEntity(responseEntity); } private void backRepair(DataFlowContext context, JSONObject reqJson) { @@ -146,6 +139,10 @@ super.delete(context, feeAttrPo, BusinessTypeConstant.BUSINESS_TYPE_DELETE_FEE_INFO); } ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_OK, ResultVo.MSG_OK); context.setResponseEntity(responseEntity); } @@ -246,6 +243,9 @@ super.insert(context, repairUserPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_REPAIR_USER); ownerRepairBMOImpl.modifyBusinessRepairDispatch(reqJson, context, RepairDto.STATE_TRANSFER); ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_OK, ResultVo.MSG_OK); context.setResponseEntity(responseEntity); } /** @@ -255,43 +255,65 @@ * @param reqJson */ private void dispacthRepair(DataFlowContext context, JSONObject reqJson) { String userId = reqJson.getString("userId"); String userName = reqJson.getString("userName"); //获取报修id String repairId = reqJson.getString("repairId"); RepairDto repairDto = new RepairDto(); repairDto.setRepairId(repairId); List<RepairDto> repairDtos = repairInnerServiceSMOImpl.queryRepairs(repairDto); if (repairDtos == null || repairDtos.size() < 1) { ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "数据错误！"); context.setResponseEntity(responseEntity); } else { //获取状态 String state = repairDtos.get(0).getState(); if (state.equals("1000")) { //1000表示未派单 String userId = reqJson.getString("userId"); String userName = reqJson.getString("userName"); String ruId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ruId); // 自己的单子状态修改为转单 RepairUserPo repairUserPo = new RepairUserPo(); repairUserPo.setRuId(ruId); repairUserPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); repairUserPo.setEndTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); repairUserPo.setState(RepairUserDto.STATE_TRANSFER); repairUserPo.setRepairId(reqJson.getString("repairId")); repairUserPo.setStaffId(userId); repairUserPo.setStaffName(userName); freshPreStaff(reqJson, repairUserPo); repairUserPo.setRepairEvent(RepairUserDto.REPAIR_EVENT_AUDIT_USER); repairUserPo.setContext(reqJson.getString("context")); repairUserPo.setCommunityId(reqJson.getString("communityId")); super.insert(context, repairUserPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_REPAIR_USER); //处理人信息 repairUserPo = new RepairUserPo(); repairUserPo.setRuId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ruId)); Calendar calendar = Calendar.getInstance(); calendar.setTime(new Date()); calendar.add(Calendar.SECOND, 30); repairUserPo.setStartTime(DateUtil.getFormatTimeString(calendar.getTime(), DateUtil.DATE_FORMATE_STRING_A)); repairUserPo.setState(RepairUserDto.STATE_DOING); repairUserPo.setRepairId(reqJson.getString("repairId")); repairUserPo.setStaffId(reqJson.getString("staffId")); repairUserPo.setStaffName(reqJson.getString("staffName")); repairUserPo.setPreStaffId(userId); repairUserPo.setPreStaffName(userName); repairUserPo.setPreRuId(ruId); repairUserPo.setRepairEvent(RepairUserDto.REPAIR_EVENT_AUDIT_USER); repairUserPo.setContext(""); repairUserPo.setCommunityId(reqJson.getString("communityId")); super.insert(context, repairUserPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_REPAIR_USER); ownerRepairBMOImpl.modifyBusinessRepairDispatch(reqJson, context, RepairDto.STATE_TAKING); String ruId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ruId); // 自己的单子状态修改为转单 RepairUserPo repairUserPo = new RepairUserPo(); repairUserPo.setRuId(ruId); repairUserPo.setStartTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); repairUserPo.setEndTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A)); repairUserPo.setState(RepairUserDto.STATE_TRANSFER); repairUserPo.setRepairId(reqJson.getString("repairId")); repairUserPo.setStaffId(userId); repairUserPo.setStaffName(userName); freshPreStaff(reqJson, repairUserPo); repairUserPo.setRepairEvent(RepairUserDto.REPAIR_EVENT_AUDIT_USER); repairUserPo.setContext(reqJson.getString("context")); repairUserPo.setCommunityId(reqJson.getString("communityId")); super.insert(context, repairUserPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_REPAIR_USER); //处理人信息 repairUserPo = new RepairUserPo(); repairUserPo.setRuId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ruId)); Calendar calendar = Calendar.getInstance(); calendar.setTime(new Date()); calendar.add(Calendar.SECOND, 30); repairUserPo.setStartTime(DateUtil.getFormatTimeString(calendar.getTime(), DateUtil.DATE_FORMATE_STRING_A)); repairUserPo.setState(RepairUserDto.STATE_DOING); repairUserPo.setRepairId(reqJson.getString("repairId")); repairUserPo.setStaffId(reqJson.getString("staffId")); repairUserPo.setStaffName(reqJson.getString("staffName")); repairUserPo.setPreStaffId(userId); repairUserPo.setPreStaffName(userName); repairUserPo.setPreRuId(ruId); repairUserPo.setRepairEvent(RepairUserDto.REPAIR_EVENT_AUDIT_USER); repairUserPo.setContext(""); repairUserPo.setCommunityId(reqJson.getString("communityId")); super.insert(context, repairUserPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_REPAIR_USER); ownerRepairBMOImpl.modifyBusinessRepairDispatch(reqJson, context, RepairDto.STATE_TAKING); ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_OK, ResultVo.MSG_OK); context.setResponseEntity(responseEntity); } else if (state.equals("1100")) { //1100表示接单 ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "该订单处于接单状态，无法进行派单！"); context.setResponseEntity(responseEntity); } else { ResponseEntity<String> responseEntity = ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "状态异常！"); context.setResponseEntity(responseEntity); } } } /** service-fee/src/main/java/com/java110/fee/api/PayFeeConfigDiscountApi.java
@@ -48,8 +48,9 @@ PayFeeConfigDiscountPo payFeeConfigDiscountPo = BeanConvertUtil.covertBean(reqJson, PayFeeConfigDiscountPo.class); String paymaxEndTime = reqJson.getString("payMaxEndTime"); if(StringUtil.isEmpty(paymaxEndTime)){ payFeeConfigDiscountPo.setPayMaxEndTime(null); if (StringUtil.isEmpty(paymaxEndTime)) { //如果优惠最大时间为空，就默认为2037-12-31 00:00:00 payFeeConfigDiscountPo.setPayMaxEndTime("2037-12-31 00:00:00"); } return savePayFeeConfigDiscountBMOImpl.save(payFeeConfigDiscountPo); } service-job/src/main/java/com/java110/job/task/fee/FeeDueReminderTemplate.java
New file @@ -0,0 +1,369 @@ package com.java110.job.task.fee; import com.alibaba.fastjson.JSON; import com.aliyuncs.CommonRequest; import com.aliyuncs.CommonResponse; import com.aliyuncs.DefaultAcsClient; import com.aliyuncs.IAcsClient; import com.aliyuncs.exceptions.ClientException; import com.aliyuncs.exceptions.ServerException; import com.aliyuncs.http.MethodType; import com.aliyuncs.profile.DefaultProfile; import com.java110.core.factory.WechatFactory; import com.java110.dto.RoomDto; import com.java110.dto.community.CommunityDto; import com.java110.dto.fee.FeeDto; import com.java110.dto.owner.OwnerAppUserDto; import com.java110.dto.owner.OwnerCarDto; import com.java110.dto.owner.OwnerDto; import com.java110.dto.owner.OwnerRoomRelDto; import com.java110.dto.parking.ParkingSpaceDto; import com.java110.dto.smallWeChat.SmallWeChatDto; import com.java110.dto.smallWechatAttr.SmallWechatAttrDto; import com.java110.dto.task.TaskDto; import com.java110.entity.wechat.Content; import com.java110.entity.wechat.Data; import com.java110.entity.wechat.PropertyFeeTemplateMessage; import com.java110.intf.community.ICommunityInnerServiceSMO; import com.java110.intf.community.IParkingSpaceInnerServiceSMO; import com.java110.intf.community.IRoomInnerServiceSMO; import com.java110.intf.fee.IFeeInnerServiceSMO; import com.java110.intf.store.ISmallWeChatInnerServiceSMO; import com.java110.intf.store.ISmallWechatAttrInnerServiceSMO; import com.java110.intf.user.IOwnerAppUserInnerServiceSMO; import com.java110.intf.user.IOwnerCarInnerServiceSMO; import com.java110.intf.user.IOwnerInnerServiceSMO; import com.java110.intf.user.IOwnerRoomRelInnerServiceSMO; import com.java110.job.quartz.TaskSystemQuartz; import com.java110.utils.cache.MappingCache; import com.java110.utils.util.StringUtil; import org.slf4j.Logger; import org.slf4j.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.SimpleDateFormat; import java.util.Arrays; import java.util.Calendar; import java.util.Date; import java.util.List; /** * @author fqz * @Description 费用到期提醒 * @date 2021-01-22 08:40 */ @Component public class FeeDueReminderTemplate extends TaskSystemQuartz { private static Logger logger = LoggerFactory.getLogger(FeeDueReminderTemplate.class); @Autowired private ISmallWeChatInnerServiceSMO smallWeChatInnerServiceSMOImpl; @Autowired private ISmallWechatAttrInnerServiceSMO smallWechatAttrInnerServiceSMOImpl; @Autowired private IFeeInnerServiceSMO feeInnerServiceSMO; @Autowired private IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMO; @Autowired private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMO; @Autowired private IOwnerInnerServiceSMO ownerInnerServiceSMO; @Autowired private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMO; @Autowired private RestTemplate outRestTemplate; @Autowired private IRoomInnerServiceSMO roomInnerServiceSMO; @Autowired private IParkingSpaceInnerServiceSMO parkingSpaceInnerServiceSMO; @Autowired private ICommunityInnerServiceSMO communityInnerServiceSMO; //域 public static final String DOMAIN_COMMON = "DOMAIN.COMMON"; //键(黑名单) public static final String BLACKLIST = "blacklist"; //键(费用提前到期提醒天数) public static final String FEE_REMINDER_DAYS = "feeDueReminderDays"; //模板信息推送地址 private static String sendMsgUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="; //短信模板域 public final static String ALI_SMS_DOMAIN = "ALI_SMS"; @Override protected void process(TaskDto taskDto) { logger.debug("开始执行微信模板信息推送" + taskDto.toString()); // 获取小区 List<CommunityDto> communityDtos = getAllCommunity(); //取出开关映射的备注值 String remark = MappingCache.getRemark(DOMAIN_COMMON, BLACKLIST); String[] split = remark.split(","); //将数组转成list集合 List<String> remarkList = Arrays.asList(split); for (CommunityDto communityDto : communityDtos) { if (remarkList.contains(communityDto.getCommunityId())) { continue; } else { try { publishMsg(taskDto, communityDto); } catch (Exception e) { logger.error("推送消息失败", e); } } } } private void publishMsg(TaskDto taskDto, CommunityDto communityDto) { //查询公众号配置 SmallWeChatDto smallWeChatDto = new SmallWeChatDto(); smallWeChatDto.setWeChatType("1100"); smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY); smallWeChatDto.setObjId(communityDto.getCommunityId()); List<SmallWeChatDto> smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto); if (smallWeChatDto == null || smallWeChatDtos.size() <= 0) { logger.info("未配置微信公众号信息,定时任务执行结束"); return; } SmallWeChatDto weChatDto = smallWeChatDtos.get(0); SmallWechatAttrDto smallWechatAttrDto = new SmallWechatAttrDto(); smallWechatAttrDto.setCommunityId(communityDto.getCommunityId()); smallWechatAttrDto.setWechatId(weChatDto.getWeChatId()); smallWechatAttrDto.setSpecCd(SmallWechatAttrDto.SPEC_CD_WECHAT_EXPIRE_TEMPLATE); List<SmallWechatAttrDto> smallWechatAttrDtos = smallWechatAttrInnerServiceSMOImpl.querySmallWechatAttrs(smallWechatAttrDto); if (smallWechatAttrDtos == null || smallWechatAttrDtos.size() <= 0) { logger.info("未配置微信公众号消息模板"); return; } String templateId = smallWechatAttrDtos.get(0).getValue(); String accessToken = WechatFactory.getAccessToken(weChatDto.getAppId(), weChatDto.getAppSecret()); if (StringUtil.isEmpty(accessToken)) { logger.info("推送微信模板,获取accessToken失败:{}", accessToken); return; } FeeDto feeDto = new FeeDto(); //小区id feeDto.setCommunityId(communityDto.getCommunityId()); //有效数据 feeDto.setStatusCd("0"); //收费中状态 feeDto.setState("2008001"); //获取当前时间 Date date = new Date(); feeDto.setNowDate(date); int page; int row = 50; int count = feeInnerServiceSMO.queryFeesCount(feeDto); if (count < 0) { return; } double num = (double) count / (double) row; double ceil = Math.ceil(num); int size = (int) ceil; for (int i = 0; i < size; i++) { page = i + 1; feeDto.setPage(page); feeDto.setRow(row); List<FeeDto> feeDtos = feeInnerServiceSMO.queryFees(feeDto); //取出开关映射的值(提前提醒天数) String day = MappingCache.getValue(DOMAIN_COMMON, FEE_REMINDER_DAYS); if (StringUtil.isEmpty(day)) { return; } for (FeeDto tmpFeeDto : feeDtos) { //费用到期时间 Date endTime = tmpFeeDto.getEndTime(); Calendar cal = Calendar.getInstance(); cal.setTime(date); long time1 = cal.getTimeInMillis(); cal.setTime(endTime); long time2 = cal.getTimeInMillis(); double between_days = (double) (time2 - time1) / (double) (1000 * 3600 * 24); double days = Math.ceil(between_days); int feeDay = (int) days; int msgTime = Integer.parseInt(day); int smallTime = 0; if (msgTime > 1) { smallTime = msgTime - 1; } if (feeDay <= msgTime && feeDay > smallTime) { try { doSentWechat(tmpFeeDto, templateId, accessToken); } catch (Exception e) { logger.error("通知异常", e); } } else { continue; } } } } private void doSentWechat(FeeDto feeDto, String templateId, String accessToken) { //获取付费对象类型(3333表示房屋；6666表示车辆) String payerObjType = feeDto.getPayerObjType(); CommunityDto communityDto = new CommunityDto(); communityDto.setStatusCd("0"); communityDto.setCommunityId(feeDto.getCommunityId()); List<CommunityDto> communityDtos = communityInnerServiceSMO.queryCommunitys(communityDto); //获取小区名 String communityName = communityDtos.get(0).getName(); String ownerId = ""; String location = ""; String feeName = ""; String msgLocation = ""; if (payerObjType.equals("3333")) { //房屋 //付款方id(即房屋id) String payerObjId = feeDto.getPayerObjId(); RoomDto roomDto = new RoomDto(); roomDto.setStatusCd("0"); roomDto.setCommunityId(feeDto.getCommunityId()); roomDto.setRoomId(payerObjId); //查询房屋信息 List<RoomDto> roomDtos = roomInnerServiceSMO.queryRooms(roomDto); //房屋号 String roomNum = roomDtos.get(0).getRoomNum(); //单元 String unitNum = roomDtos.get(0).getUnitNum(); //楼栋 String floorNum = roomDtos.get(0).getFloorNum(); //位置 location = floorNum + "栋" + unitNum + "单元" + roomNum + "室"; msgLocation = floorNum + "-" + unitNum + "-" + roomNum; feeName = "物业费"; OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto(); //有效数据 ownerRoomRelDto.setStatusCd("0"); ownerRoomRelDto.setRoomId(payerObjId); //查询房屋业主关系表 List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMO.queryOwnerRoomRels(ownerRoomRelDto); //获取业主id ownerId = ownerRoomRelDtos.get(0).getOwnerId(); } else if (payerObjType.equals("6666")) { //车辆 //付款方id(即车辆id) String payerObjId = feeDto.getPayerObjId(); OwnerCarDto ownerCarDto = new OwnerCarDto(); //有效数据 ownerCarDto.setStatusCd("0"); //车辆id ownerCarDto.setCarId(payerObjId); //查询业主车辆表 List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMO.queryOwnerCars(ownerCarDto); //车位id String psId = ownerCarDtos.get(0).getPsId(); ParkingSpaceDto parkingSpaceDto = new ParkingSpaceDto(); parkingSpaceDto.setStatusCd("0"); parkingSpaceDto.setPsId(psId); parkingSpaceDto.setCommunityId(feeDto.getCommunityId()); List<ParkingSpaceDto> parkingSpaceDtos = parkingSpaceInnerServiceSMO.queryParkingSpaces(parkingSpaceDto); //获取车位编号 String num = parkingSpaceDtos.get(0).getNum(); //获取停车场编号 String areaNum = parkingSpaceDtos.get(0).getAreaNum(); location = areaNum + "号停车场" + num + "号车位"; msgLocation = areaNum + "-" + num; feeName = "车位费"; ownerId = ownerCarDtos.get(0).getOwnerId(); } //获取到期时间 Date endTime = feeDto.getEndTime(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String finishTime = format.format(endTime); OwnerDto ownerDto = new OwnerDto(); //有效数据 ownerDto.setStatusCd("0"); //业主id ownerDto.setOwnerId(ownerId); //1001 业主本人 1002 家庭成员 ownerDto.setOwnerTypeCd("1001"); //查询业主信息表 List<OwnerDto> ownerDtos = ownerInnerServiceSMO.queryOwners(ownerDto); if (ownerDtos == null || ownerDtos.size() < 1) { return; } //获取业主姓名 String name = ownerDtos.get(0).getName(); //获取成员id String memberId = ownerDtos.get(0).getMemberId(); OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto(); //有效数据 ownerAppUserDto.setStatusCd("0"); //成员id ownerAppUserDto.setMemberId(memberId); //绑定业主手机端类型 ownerAppUserDto.setAppType("WECHAT"); //查询绑定业主 List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMO.queryOwnerAppUsers(ownerAppUserDto); //用户绑定推送微信公众号信息 if (ownerAppUserDtos.size() > 0) { //获取openId String openId = ownerAppUserDtos.get(0).getOpenId(); String url = sendMsgUrl + accessToken; Data data = new Data(); PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage(); templateMessage.setTemplate_id(templateId); templateMessage.setTouser(openId); data.setFirst(new Content("尊敬的业主" + name + "，您的" + feeName + "即将到期，详细信息如下：")); data.setKeyword1(new Content(name)); data.setKeyword2(new Content(communityName + location)); data.setKeyword3(new Content(finishTime)); 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); } else { //用户没绑定就发送短信 //获取用户手机号 String link = ownerDtos.get(0).getLink(); DefaultProfile profile = DefaultProfile.getProfile(MappingCache.getValue(ALI_SMS_DOMAIN, "region"), MappingCache.getValue(ALI_SMS_DOMAIN, "accessKeyId"), MappingCache.getValue(ALI_SMS_DOMAIN, "accessSecret")); IAcsClient client = new DefaultAcsClient(profile); CommonRequest request = new CommonRequest(); request.setSysMethod(MethodType.POST); request.setSysDomain("dysmsapi.aliyuncs.com"); request.setSysVersion("2017-05-25"); request.setSysAction("SendSms"); request.putQueryParameter("RegionId", MappingCache.getValue(ALI_SMS_DOMAIN, "region")); request.putQueryParameter("PhoneNumbers", link); request.putQueryParameter("SignName", MappingCache.getValue(ALI_SMS_DOMAIN, "signName")); //获取模板编码(SMS_210079733为缴费成功提示模板编码) String feeDueReminderCode = MappingCache.getValue(ALI_SMS_DOMAIN, "FEE_DUE_REMINDER_CODE"); String substring = ""; if (!StringUtil.isEmpty(feeDueReminderCode)) { substring = feeDueReminderCode.substring(0, 4); } if (substring.equals("SMS_")) { request.putQueryParameter("TemplateCode", feeDueReminderCode); } request.putQueryParameter("TemplateParam", "{\"user\":" + "\"" + name + "\"" + "," + "\"community\":" + "\"" + communityName + "\"" + "," + "\"house\":" + "\"" + msgLocation + "\"" + "," + "\"feeType\":" + "\"" + feeName + "\"" + "," + "\"time\":" + "\"" + finishTime + "\"" + "}"); try { CommonResponse response = client.getCommonResponse(request); logger.debug("发送短信：{}", response.getData()); } catch (ServerException e) { e.printStackTrace(); } catch (ClientException e) { e.printStackTrace(); } } } }
