package com.java110.job.adapt.payment.notice;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.serializer.SerializerFeature;
|
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.core.smo.IComputeFeeSMO;
|
import com.java110.dto.privilege.BasePrivilegeDto;
|
import com.java110.dto.community.CommunityDto;
|
import com.java110.dto.fee.FeeDetailDto;
|
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.wechat.SmallWeChatDto;
|
import com.java110.dto.wechat.SmallWechatAttrDto;
|
import com.java110.dto.user.StaffAppAuthDto;
|
import com.java110.dto.user.UserDto;
|
import com.java110.dto.system.Business;
|
import com.java110.dto.wechat.Content;
|
import com.java110.dto.wechat.Data;
|
import com.java110.dto.wechat.PropertyFeeTemplateMessage;
|
import com.java110.intf.community.ICommunityInnerServiceSMO;
|
import com.java110.intf.fee.IFeeDetailInnerServiceSMO;
|
import com.java110.intf.fee.IFeeInnerServiceSMO;
|
import com.java110.intf.order.IPrivilegeInnerServiceSMO;
|
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.intf.user.IStaffAppAuthInnerServiceSMO;
|
import com.java110.job.adapt.DatabusAdaptImpl;
|
import com.java110.job.msgNotify.MsgNotifyFactory;
|
import com.java110.po.fee.PayFeeDetailPo;
|
import com.java110.utils.cache.MappingCache;
|
import com.java110.utils.cache.UrlCache;
|
import com.java110.utils.constant.MappingConstant;
|
import com.java110.utils.constant.WechatConstant;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.BeanConvertUtil;
|
import com.java110.utils.util.DateUtil;
|
import com.java110.utils.util.StringUtil;
|
import org.slf4j.Logger;
|
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;
|
|
/**
|
* 缴费通知适配器
|
*
|
* @author fqz
|
* @date 2020-12-11 18:54
|
*/
|
@Component(value = "machinePaymentNoticeAdapt")
|
public class MachinePaymentNoticeAdapt extends DatabusAdaptImpl {
|
|
private static Logger logger = LoggerFactory.getLogger(MachinePaymentNoticeAdapt.class);
|
|
@Autowired
|
private ICommunityInnerServiceSMO communityInnerServiceSMO;
|
|
@Autowired
|
private ISmallWeChatInnerServiceSMO smallWeChatInnerServiceSMOImpl;
|
|
@Autowired
|
private ISmallWechatAttrInnerServiceSMO smallWechatAttrInnerServiceSMOImpl;
|
|
@Autowired
|
private IPrivilegeInnerServiceSMO privilegeInnerServiceSMO;
|
|
@Autowired
|
private RestTemplate outRestTemplate;
|
|
@Autowired
|
private IStaffAppAuthInnerServiceSMO staffAppAuthInnerServiceSMO;
|
|
@Autowired
|
private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
|
|
@Autowired
|
private IFeeDetailInnerServiceSMO feeDetailInnerServiceSMOImpl;
|
|
@Autowired
|
private IComputeFeeSMO computeFeeSMOImpl;
|
|
@Autowired
|
private IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMO;
|
|
@Autowired
|
private IOwnerCarInnerServiceSMO ownerCarInnerServiceSMO;
|
|
@Autowired
|
private IOwnerInnerServiceSMO ownerInnerServiceSMO;
|
|
@Autowired
|
private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMO;
|
|
//模板信息推送地址
|
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
|
public void execute(Business business, List<Business> businesses) {
|
JSONObject data = business.getData();
|
JSONArray businessPayFeeDetails = null;
|
if (data == null) {
|
FeeDetailDto feeDetailDto = new FeeDetailDto();
|
feeDetailDto.setbId(business.getbId());
|
List<FeeDetailDto> feeDetailDtos = feeDetailInnerServiceSMOImpl.queryFeeDetails(feeDetailDto);
|
Assert.listOnlyOne(feeDetailDtos, "未查询到缴费记录");
|
businessPayFeeDetails = JSONArray.parseArray(JSONArray.toJSONString(feeDetailDtos, SerializerFeature.WriteDateUseDateFormat));
|
} else if (data.containsKey(PayFeeDetailPo.class.getSimpleName())) {
|
Object bObj = data.get(PayFeeDetailPo.class.getSimpleName());
|
if (bObj instanceof JSONObject) {
|
businessPayFeeDetails = new JSONArray();
|
businessPayFeeDetails.add(bObj);
|
} else if (bObj instanceof Map) {
|
businessPayFeeDetails = new JSONArray();
|
businessPayFeeDetails.add(JSONObject.parseObject(JSONObject.toJSONString(bObj)));
|
} else if (bObj instanceof List) {
|
businessPayFeeDetails = JSONArray.parseArray(JSONObject.toJSONString(bObj));
|
} else {
|
businessPayFeeDetails = (JSONArray) bObj;
|
}
|
} else {
|
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) {
|
//查询缴费明细
|
PayFeeDetailPo payFeeDetailPo = BeanConvertUtil.covertBean(businessPayFeeDetail, PayFeeDetailPo.class);
|
//查询小区信息
|
CommunityDto communityDto = new CommunityDto();
|
communityDto.setCommunityId(payFeeDetailPo.getCommunityId());
|
List<CommunityDto> communityDtos = communityInnerServiceSMO.queryCommunitys(communityDto);
|
FeeDto feeDto = new FeeDto();
|
feeDto.setFeeId(payFeeDetailPo.getFeeId());
|
feeDto.setCommunityId(payFeeDetailPo.getCommunityId());
|
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
Assert.listOnlyOne(feeDtos, "未查询到费用信息");
|
//获取费用类型
|
String feeTypeCdName = feeDtos.get(0).getFeeTypeCdName();
|
//获取缴费用户楼栋单元房间号
|
String payerObjName = computeFeeSMOImpl.getFeeObjName(feeDtos.get(0));
|
//获得用户缴费开始时间
|
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("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 (!StringUtil.isEmpty(state) && !state.equals("1300") && feeTypeCd.equals("888800010012")) {
|
//给处理报修完结单的维修师傅推送消息
|
sendMsg(paramIn, communityDtos.get(0), payFeeDetailPo);
|
}
|
if (!StringUtil.isEmpty(state) && !state.equals("1300")) {
|
//给员工推送消息
|
publishMsg(paramIn, communityDtos.get(0), payFeeDetailPo);
|
}
|
}
|
|
/**
|
* 给员工推送信息
|
*
|
* @param paramIn
|
* @param communityDto
|
* @param payFeeDetailPo
|
*/
|
private void publishMsg(JSONObject paramIn, CommunityDto communityDto, PayFeeDetailPo payFeeDetailPo) {
|
|
FeeDto feeDto = new FeeDto();
|
feeDto.setFeeId(payFeeDetailPo.getFeeId());
|
feeDto.setCommunityId(payFeeDetailPo.getCommunityId());
|
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
Assert.listOnlyOne(feeDtos, "费用不存在");
|
// 根据特定权限查询 有该权限的 员工
|
BasePrivilegeDto basePrivilegeDto = new BasePrivilegeDto();
|
basePrivilegeDto.setResource("/wechatNotification");
|
basePrivilegeDto.setStoreId(feeDtos.get(0).getIncomeObjId());
|
List<UserDto> userDtos = privilegeInnerServiceSMO.queryPrivilegeUsers(basePrivilegeDto);
|
String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN, "STAFF_WECHAT_URL");
|
|
//获取付费对象类型
|
String payerObjType = paramIn.getString("payerObjType");
|
if (userDtos == null || userDtos.size() < 1) {
|
return;
|
}
|
for (UserDto userDto : userDtos) {
|
//根据 userId 查询到openId
|
try {
|
JSONObject content = new JSONObject();
|
content.put("payFeeRoom", paramIn.getString("payFeeRoom"));
|
content.put("feeTypeCdName", paramIn.getString("feeTypeCdName"));
|
content.put("payFeeTime", paramIn.getString("payFeeTime"));
|
content.put("receivedAmount", paramIn.getString("receivedAmount") + "元");
|
content.put("url", wechatUrl);
|
MsgNotifyFactory.sendPayFeeMsg(payFeeDetailPo.getCommunityId(), userDto.getUserId(), content, MsgNotifyFactory.ROLE_STAFF);
|
} catch (Exception e) {
|
logger.error("发送缴费信息失败", e);
|
}
|
}
|
}
|
|
/**
|
* 给完结订单的维修师傅推送信息
|
*
|
* @param paramIn
|
* @param communityDto
|
* @param payFeeDetailPo
|
*/
|
private void sendMsg(JSONObject paramIn, CommunityDto communityDto, PayFeeDetailPo payFeeDetailPo) {
|
FeeDto feeDto = new FeeDto();
|
feeDto.setFeeId(payFeeDetailPo.getFeeId());
|
feeDto.setCommunityId(payFeeDetailPo.getCommunityId());
|
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
Assert.listOnlyOne(feeDtos, "费用不存在");
|
//获取创建用户,即处理结单的维修维修师傅
|
String userId = feeDtos.get(0).getUserId();
|
//根据 userId 查询到openId
|
try {
|
JSONObject content = new JSONObject();
|
content.put("payFeeRoom", paramIn.getString("payFeeRoom"));
|
content.put("feeTypeCdName", paramIn.getString("feeTypeCdName"));
|
content.put("payFeeTime", paramIn.getString("payFeeTime"));
|
content.put("receivedAmount", paramIn.getString("receivedAmount") + "元");
|
content.put("url", paramIn.getString("wechatUrl"));
|
MsgNotifyFactory.sendPayFeeMsg(payFeeDetailPo.getCommunityId(), userId, content, MsgNotifyFactory.ROLE_STAFF);
|
|
} catch (Exception e) {
|
logger.error("发送缴费信息失败", e);
|
}
|
}
|
|
/**
|
* 给业主推送消息
|
*
|
* @param paramIn
|
* @param communityDto
|
* @param payFeeDetailPo
|
*/
|
private void sendMessage(JSONObject paramIn, CommunityDto communityDto, PayFeeDetailPo payFeeDetailPo) {
|
//查询公众号配置
|
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;
|
}
|
|
|
FeeDto feeDto = new FeeDto();
|
feeDto.setFeeId(payFeeDetailPo.getFeeId());
|
feeDto.setCommunityId(payFeeDetailPo.getCommunityId());
|
List<FeeDto> feeDtos = feeInnerServiceSMOImpl.queryFees(feeDto);
|
Assert.listOnlyOne(feeDtos, "费用不存在");
|
//支付房间id(支付车辆id)
|
String payerObjId = feeDtos.get(0).getPayerObjId();
|
//支付类型(房屋、车辆)
|
String payerObjType = feeDtos.get(0).getPayerObjType();
|
String ownerId = "";
|
//3333 房屋缴费 6666 是车位缴费
|
if (payerObjType.equals("3333")) {
|
OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
|
ownerRoomRelDto.setRoomId(payerObjId);
|
List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMO.queryOwnerRoomRels(ownerRoomRelDto);
|
if (ownerRoomRelDtos == null || ownerRoomRelDtos.size() != 1) {
|
return;
|
}
|
//取得业主id
|
ownerId = ownerRoomRelDtos.get(0).getOwnerId();
|
} else if (payerObjType.equals("6666")) {
|
OwnerCarDto ownerCarDto = new OwnerCarDto();
|
ownerCarDto.setCarId(payerObjId);
|
List<OwnerCarDto> ownerCarDtos = ownerCarInnerServiceSMO.queryOwnerCars(ownerCarDto);
|
if (ownerCarDtos == null || ownerCarDtos.size() != 1) {
|
return;
|
}
|
//取得业主id
|
ownerId = ownerCarDtos.get(0).getOwnerId();
|
}
|
OwnerDto ownerDto = new OwnerDto();
|
ownerDto.setOwnerId(ownerId);
|
//1001 业主本人 1002 家庭成员
|
ownerDto.setOwnerTypeCd("1001");
|
//查询业主
|
List<OwnerDto> ownerDtos = ownerInnerServiceSMO.queryOwners(ownerDto);
|
Assert.listOnlyOne(ownerDtos, "查询业主信息错误！");
|
//获得成员id
|
String memberId = ownerDtos.get(0).getMemberId();
|
OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
|
ownerAppUserDto.setMemberId(memberId);
|
ownerAppUserDto.setAppType("WECHAT");
|
List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMO.queryOwnerAppUsers(ownerAppUserDto);
|
if (ownerAppUserDtos == null || ownerAppUserDtos.size() < 1) {
|
return;
|
}
|
JSONObject content = new JSONObject();
|
if (payerObjType.equals(FeeDto.PAYER_OBJ_TYPE_ROOM)) { //房屋
|
content.put("payFeeRoom", paramIn.getString("payFeeRoom"));
|
content.put("feeTypeCdName", paramIn.getString("feeTypeCdName"));
|
} else { //车辆
|
content.put("payFeeRoom", communityDto.getName() + "-" + paramIn.getString("num") + "-" + paramIn.getString("spaceNum"));
|
content.put("feeTypeCdName", paramIn.getString("feeTypeCdName") + "-" + paramIn.getString("carNum"));
|
}
|
content.put("payFeeTime", paramIn.getString("payFeeTime"));
|
|
//todo 退费
|
if (FeeDetailDto.STATE_RETURN_ORDER.equals(paramIn.getString("state"))) {
|
//获取退费金额
|
double receivedAmount = Double.parseDouble(paramIn.getString("receivedAmount"));
|
double money = receivedAmount * (-1.00);
|
content.put("receivedAmount", money + "元");
|
} else {
|
content.put("receivedAmount", paramIn.getString("receivedAmount") + "元");
|
}
|
//获取业主公众号地址
|
String wechatUrl = UrlCache.getOwnerUrl();
|
if (!StringUtil.isEmpty(wechatUrl) && wechatUrl.contains("?")) {
|
wechatUrl += ("&wAppId=" + smallWeChatDtos.get(0).getAppId());
|
} else {
|
wechatUrl += ("?wAppId=" + smallWeChatDtos.get(0).getAppId());
|
}
|
content.put("url", wechatUrl);
|
MsgNotifyFactory.sendPayFeeMsg(payFeeDetailPo.getCommunityId(), ownerAppUserDtos.get(0).getUserId(), content, MsgNotifyFactory.ROLE_OWNER);
|
|
}
|
}
|
