mirror of
https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git
synced 2026-04-22 03:55:17 +08:00
546 lines
20 KiB
Java
546 lines
20 KiB
Java
package com.jsowell.pile.service;
|
||
|
||
import com.alibaba.fastjson2.JSON;
|
||
import com.alibaba.fastjson2.JSONArray;
|
||
import com.alibaba.fastjson2.JSONObject;
|
||
import com.google.common.collect.Lists;
|
||
import com.jsowell.common.enums.sim.SimCardStatusCorrespondEnum;
|
||
import com.jsowell.common.enums.sim.SimSupplierEnum;
|
||
import com.jsowell.common.enums.ykc.ReturnCodeEnum;
|
||
import com.jsowell.common.exception.BusinessException;
|
||
import com.jsowell.common.util.DateUtils;
|
||
import com.jsowell.common.util.StringUtils;
|
||
import com.jsowell.common.util.http.HttpUtils;
|
||
import com.jsowell.common.util.id.IdUtils;
|
||
import com.jsowell.common.util.sim.SimCardUtils;
|
||
import com.jsowell.common.util.sim.XunZhongSimUtils;
|
||
import com.jsowell.pile.domain.PileSimInfo;
|
||
import com.jsowell.pile.vo.web.*;
|
||
import org.apache.commons.collections4.CollectionUtils;
|
||
import org.slf4j.Logger;
|
||
import org.slf4j.LoggerFactory;
|
||
import org.springframework.beans.factory.annotation.Autowired;
|
||
import org.springframework.beans.factory.annotation.Value;
|
||
import org.springframework.stereotype.Service;
|
||
|
||
import java.math.BigDecimal;
|
||
import java.util.ArrayList;
|
||
import java.util.Hashtable;
|
||
import java.util.List;
|
||
import java.util.stream.Collectors;
|
||
|
||
|
||
/**
|
||
* Sim卡Service
|
||
*
|
||
* @author JS-ZZA
|
||
* @date 2022/12/3 15:35
|
||
*/
|
||
@Service
|
||
public class SimCardService {
|
||
|
||
@Autowired
|
||
private PileSimInfoService pileSimInfoService;
|
||
|
||
protected final Logger logger = LoggerFactory.getLogger(SimCardService.class);
|
||
|
||
@Value("${xunzhong.apiId}")
|
||
private String API_ID;
|
||
|
||
@Value("${xunzhong.sim.getSimCardDetailURL}")
|
||
private String getSimCardDetailURL;
|
||
|
||
@Value("${xunzhong.trafficPool.poolListURL}")
|
||
private String poolListURL;
|
||
|
||
@Value("${xunzhong.sim.renewURL}")
|
||
private String renewURL;
|
||
|
||
@Value("${wulian.appId}")
|
||
private String appId;
|
||
|
||
@Value("${wulian.appSecret}")
|
||
private String appSecret;
|
||
|
||
@Value("${wulian.getWay}")
|
||
private String wuLianGetWay;
|
||
|
||
@Value("${wulian.name.getSimInfo}")
|
||
private String getSimInfoName;
|
||
|
||
@Value("${wulian.name.WuLianSimRenew}")
|
||
private String WuLianSimRenew;
|
||
|
||
/**
|
||
* 不知道iccid属于哪家供应商，就用这个方法查
|
||
*
|
||
* @param iccids
|
||
* @return
|
||
*/
|
||
public List<SimCardVO> searchByLoop(List<String> iccids) {
|
||
List<SimCardVO> resultList = Lists.newArrayList();
|
||
// 查XunZhong
|
||
List<SimCardVO> xunZhongList = XunZhongGetSimInfoByIccIds(iccids);
|
||
if (CollectionUtils.isNotEmpty(xunZhongList)) {
|
||
resultList.addAll(xunZhongList);
|
||
}
|
||
// 查WuLian平台
|
||
List<SimCardVO> wuLianSimData = WuLianGetSimInfoByIccIds(iccids);
|
||
if (CollectionUtils.isNotEmpty(wuLianSimData)) {
|
||
resultList.addAll(xunZhongList);
|
||
}
|
||
// 第三个供应商
|
||
|
||
logger.info("查询iccid:{}, 详情信息:{}", iccids, JSON.toJSONString(resultList));
|
||
return resultList;
|
||
}
|
||
|
||
/**
|
||
* 通过iccId去两个官方平台查询流量卡具体数据
|
||
*
|
||
* @param iccId
|
||
* @return
|
||
*/
|
||
SimCardVO searchOfficialWebsiteSimInfo(String iccId) {
|
||
SimCardVO vo = new SimCardVO();
|
||
List<String> iccIds = Lists.newArrayList(iccId);
|
||
// 查XunZhong
|
||
List<SimCardVO> simCardVOS = XunZhongGetSimInfoByIccIds(iccIds);
|
||
if (CollectionUtils.isNotEmpty(simCardVOS)) {
|
||
vo = simCardVOS.get(0);
|
||
} else {
|
||
// 查WuLian平台
|
||
List<SimCardVO> wuLianSimData = WuLianGetSimInfoByIccIds(iccIds);
|
||
if (CollectionUtils.isEmpty(wuLianSimData)) {
|
||
return vo;
|
||
}
|
||
vo = wuLianSimData.get(0);
|
||
}
|
||
return vo;
|
||
}
|
||
|
||
/**
|
||
* 通过iccId查询数据（2024.11.1 后管用）
|
||
*
|
||
* @param iccId
|
||
* @return
|
||
*/
|
||
public SimCardVO getSimCardInfoByIccId(String iccId) {
|
||
PileSimInfo pileSimInfo = pileSimInfoService.getBasicInfoByIccId(iccId);
|
||
// 调用官方数据接口查询最新sim卡数据
|
||
SimCardVO simCardVO = searchOfficialWebsiteSimInfo(iccId);
|
||
if (simCardVO == null) {
|
||
throw new BusinessException(ReturnCodeEnum.CODE_SELECT_INFO_IS_NULL);
|
||
}
|
||
if (pileSimInfo == null) {
|
||
// 数据库中没有此卡数据，进行新增
|
||
pileSimInfo = PileSimInfo.builder()
|
||
.name(simCardVO.getName())
|
||
.iccid(simCardVO.getIccId())
|
||
.status(simCardVO.getSimCardStatus())
|
||
.simSupplier(simCardVO.getSimCardFactory())
|
||
.totalData(String.valueOf(simCardVO.getPackageCapacity()))
|
||
.surplusData(String.valueOf(simCardVO.getResidualFlowRate()))
|
||
.expireTime(DateUtils.parseDate(simCardVO.getExpiredTime()))
|
||
.operator(simCardVO.getSimCardOperator())
|
||
|
||
.build();
|
||
pileSimInfoService.insertPileSimInfo(pileSimInfo);
|
||
} else {
|
||
// 将查到的流量套餐等最新数据更新到数据库
|
||
pileSimInfo.setName(simCardVO.getName());
|
||
pileSimInfo.setIccid(simCardVO.getIccId());
|
||
pileSimInfo.setStatus(simCardVO.getSimCardStatus());
|
||
pileSimInfo.setSimSupplier(simCardVO.getSimCardFactory());
|
||
pileSimInfo.setTotalData(String.valueOf(simCardVO.getPackageCapacity()));
|
||
pileSimInfo.setSurplusData(String.valueOf(simCardVO.getResidualFlowRate()));
|
||
pileSimInfo.setExpireTime(DateUtils.parseDate(simCardVO.getExpiredTime()));
|
||
pileSimInfo.setOperator(simCardVO.getSimCardOperator());
|
||
|
||
pileSimInfoService.updatePileSimInfo(pileSimInfo);
|
||
}
|
||
|
||
return simCardVO;
|
||
}
|
||
|
||
|
||
/**
|
||
* 批量续费（后管调用此方法）
|
||
*
|
||
* @param iccIds 卡号
|
||
* @param cycleNumber 续费周期
|
||
*/
|
||
public List<SimRenewResultVO> renewSimByLoop(List<String> iccIds, int cycleNumber) {
|
||
if (CollectionUtils.isEmpty(iccIds)) {
|
||
return Lists.newArrayList();
|
||
}
|
||
// 将集合中为空和0的过滤
|
||
iccIds = iccIds.stream()
|
||
.filter(StringUtils::isNotEmpty)
|
||
.filter(x -> !StringUtils.equals(x, "0"))
|
||
.collect(Collectors.toList());
|
||
|
||
ArrayList<SimRenewResultVO> list = new ArrayList<>();
|
||
for (String iccId : iccIds) {
|
||
// 查出此卡属于哪家公司(拿到code)
|
||
SimCardVO simCardVO = searchByLoop(Lists.newArrayList(iccId)).get(0);
|
||
String simSupplierCode = simCardVO.getSimCardFactory();
|
||
|
||
// 根据不同的公司执行不同的续费方法
|
||
SimRenewResultVO simRenewResultVO = renewSimBySupplier(simSupplierCode, iccId, cycleNumber);
|
||
list.add(simRenewResultVO);
|
||
}
|
||
return list;
|
||
}
|
||
|
||
|
||
/**
|
||
* 根据不同的公司执行不同的续费方法
|
||
*
|
||
* @param code 👇👇👇👇👇👇👇
|
||
* @param iccId 卡号
|
||
* @param cycleNumber 续费周期
|
||
* @see SimSupplierEnum
|
||
*/
|
||
private SimRenewResultVO renewSimBySupplier(String code, String iccId, int cycleNumber) {
|
||
SimRenewResultVO vo = new SimRenewResultVO();
|
||
vo.setIccId(iccId);
|
||
vo.setCycleNumber(cycleNumber);
|
||
|
||
if (StringUtils.equals(code, SimSupplierEnum.XUN_ZHONG.getCode())) {
|
||
// 讯众
|
||
try {
|
||
vo.setSimSuppler(SimSupplierEnum.XUN_ZHONG.getName());
|
||
XunZhongSimRenewal(Lists.newArrayList(iccId), cycleNumber);
|
||
vo.setResult(true);
|
||
} catch (BusinessException e) {
|
||
vo.setResult(false);
|
||
vo.setReason(e.getMessage());
|
||
}
|
||
}
|
||
// 物联平台
|
||
if (StringUtils.equals(code, SimSupplierEnum.WU_LIAN_INTERNET.getCode())) {
|
||
try {
|
||
vo.setSimSuppler(SimSupplierEnum.WU_LIAN_INTERNET.getName());
|
||
WuLianSimRenew(Lists.newArrayList(iccId), cycleNumber);
|
||
vo.setResult(true);
|
||
} catch (BusinessException e) {
|
||
vo.setResult(false);
|
||
vo.setReason(e.getMessage());
|
||
}
|
||
}
|
||
return vo;
|
||
}
|
||
|
||
|
||
/**
|
||
* 讯众 内部接口
|
||
* 通过iccIds查询讯众Sim卡信息
|
||
*
|
||
* @param iccIds
|
||
*/
|
||
public List<SimCardVO> XunZhongGetSimInfoByIccIds(List<String> iccIds) {
|
||
List<SimCardVO> resultList = new ArrayList<>();
|
||
|
||
List<XunZhongSimData> dataList = getSimCardDetail(iccIds);
|
||
SimCardVO simCard = null;
|
||
for (XunZhongSimData zhongSimData : dataList) {
|
||
// sim卡套餐
|
||
XunZhongSimData.Products products = null;
|
||
if (CollectionUtils.isNotEmpty(zhongSimData.getCurrent_products())) {
|
||
products = zhongSimData.getCurrent_products().get(0);
|
||
} else {
|
||
if (CollectionUtils.isNotEmpty(zhongSimData.getFuture_products())) {
|
||
products = zhongSimData.getFuture_products().get(0);
|
||
}
|
||
}
|
||
if (products == null) {
|
||
logger.info("iccid:{}, 没有套餐", zhongSimData.getIccid());
|
||
continue;
|
||
}
|
||
// set
|
||
simCard = new SimCardVO();
|
||
simCard.setIccId(zhongSimData.getIccid()); // 卡号
|
||
simCard.setSimCardFactory(SimSupplierEnum.XUN_ZHONG.getCode()); // 1-讯众物联
|
||
simCard.setSimCardOperator(zhongSimData.getCarrier_type()); // 运营商类型
|
||
simCard.setSimCardStatus(zhongSimData.getNet_status()); // 联网状态
|
||
simCard.setName(products.getName()); // 套餐名称
|
||
simCard.setExpiredTime(products.getExpiration_time()); // 过期时间
|
||
|
||
BigDecimal packageCapacity = products.getPackage_capacity(); // 套餐总量（mb）
|
||
simCard.setPackageCapacity(packageCapacity);
|
||
|
||
if (products.getCurrent_cycle_usage() != null) {
|
||
BigDecimal current_cycle_usage = products.getCurrent_cycle_usage(); // 当前已用（kb）
|
||
String currentCycleUsage = SimCardUtils.kb2MbOrGb(current_cycle_usage.intValue());
|
||
BigDecimal currentCycleUsageData = new BigDecimal(currentCycleUsage);
|
||
simCard.setUsedFlowRate(currentCycleUsageData);
|
||
BigDecimal residualData = packageCapacity.subtract(currentCycleUsageData); // 套餐剩余
|
||
simCard.setResidualFlowRate(residualData.setScale(2, BigDecimal.ROUND_HALF_UP));
|
||
}
|
||
|
||
resultList.add(simCard);
|
||
}
|
||
return resultList;
|
||
}
|
||
|
||
public static void main(String[] args) {
|
||
// List<String> iccIds = Lists.newArrayList();
|
||
// iccIds.add("123");
|
||
// iccIds.add(null);
|
||
// iccIds.add("0");
|
||
// iccIds.add("asdf");
|
||
// iccIds.add(null);
|
||
// iccIds.add("0");
|
||
// iccIds.add(null);
|
||
// iccIds.add("0");
|
||
// iccIds.add("9461351351");
|
||
// iccIds = iccIds.stream()
|
||
// .filter(StringUtils::isNotEmpty)
|
||
// .filter(x -> !StringUtils.equals(x, "0"))
|
||
// .collect(Collectors.toList());
|
||
// String iccId = StringUtils.join(iccIds, ",");
|
||
// System.out.println(iccId);
|
||
|
||
|
||
String packName = "移动 500M/月";
|
||
System.out.println(StringUtils.contains(packName, "移动"));
|
||
// StringUtils.containsAny()
|
||
}
|
||
|
||
|
||
/**
|
||
* 讯众官方接口
|
||
* 获取sim卡详细信息
|
||
*
|
||
* @param iccIds Sim卡集合
|
||
* @return
|
||
*/
|
||
public List<XunZhongSimData> getSimCardDetail(List<String> iccIds) {
|
||
String iccId = list2Str(iccIds);
|
||
|
||
String timestamp = String.valueOf(System.currentTimeMillis() / 1000);
|
||
|
||
Hashtable<String, Object> params = new Hashtable<>();
|
||
params.put("api_id", API_ID);
|
||
params.put("timestamp", timestamp);
|
||
params.put("iccids", iccId);
|
||
|
||
String signStr = XunZhongSimUtils.getSignStr(params);
|
||
|
||
params.put("sign", signStr);
|
||
|
||
String postResult = XunZhongSimUtils.sendPost(getSimCardDetailURL, params);
|
||
logger.info("【====讯众物联====】查询Sim卡信息, param:{}, result:{}", params, postResult);
|
||
JSONObject jsonObject = JSONObject.parseObject(postResult);
|
||
if (StringUtils.equals(jsonObject.getString("code"), "0")) {
|
||
String result = jsonObject.getString("result");
|
||
return JSON.parseArray(result, XunZhongSimData.class);
|
||
}
|
||
return Lists.newArrayList();
|
||
}
|
||
|
||
/**
|
||
* 讯众官方接口
|
||
* 获取流量池信息
|
||
*
|
||
* @return
|
||
*/
|
||
public String getTrafficPoolInfo() {
|
||
String timestamp = String.valueOf(System.currentTimeMillis() / 1000);
|
||
|
||
Hashtable<String, Object> params = new Hashtable<>();
|
||
params.put("api_id", API_ID);
|
||
params.put("timestamp", timestamp);
|
||
|
||
String signStr = XunZhongSimUtils.getSignStr(params);
|
||
params.put("sign", signStr);
|
||
|
||
String postResult = XunZhongSimUtils.sendPost(poolListURL, params);
|
||
logger.info("【====讯众物联====】获取流量池信息, result:{}", postResult);
|
||
return postResult;
|
||
}
|
||
|
||
|
||
/**
|
||
* 讯众官方接口
|
||
* sim卡续期
|
||
*
|
||
* @param iccIds 需要续期的sim卡
|
||
* @param cycleNumber 续费周期（0-999），0表示无限周期
|
||
* @return
|
||
*/
|
||
public void XunZhongSimRenewal(List<String> iccIds, int cycleNumber) {
|
||
if (CollectionUtils.isEmpty(iccIds)) {
|
||
throw new BusinessException(ReturnCodeEnum.CODE_PARAM_NOT_NULL_ERROR);
|
||
}
|
||
String iccId = list2Str(iccIds);
|
||
|
||
String timestamp = String.valueOf(System.currentTimeMillis() / 1000);
|
||
|
||
Hashtable<String, Object> params = new Hashtable<>();
|
||
params.put("api_id", API_ID);
|
||
params.put("timestamp", timestamp);
|
||
params.put("iccids", iccId);
|
||
params.put("cycle_number", cycleNumber);
|
||
|
||
String signStr = XunZhongSimUtils.getSignStr(params);
|
||
|
||
params.put("sign", signStr);
|
||
|
||
String postResult = XunZhongSimUtils.sendPost(renewURL, params);
|
||
logger.info("【====讯众物联====】sim卡续费业务, result:{}", postResult);
|
||
JSONObject jsonResult = JSONObject.parseObject(postResult);
|
||
String code = jsonResult.getString("code");
|
||
if (!StringUtils.equals("0", code)) {
|
||
String message = jsonResult.getString("message");
|
||
throw new BusinessException(code, message);
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* 物联平台官方接口
|
||
*
|
||
* 查询卡信息
|
||
*
|
||
* @param iccIds 卡号集合
|
||
* @return 卡信息集合
|
||
*/
|
||
public List<WuLianSimData> WuLianGetSimInfo(List<String> iccIds) {
|
||
ArrayList<WuLianSimData> list = new ArrayList<>();
|
||
|
||
if (CollectionUtils.isEmpty(iccIds)) {
|
||
return list;
|
||
}
|
||
for (String iccId : iccIds) {
|
||
JSONObject param = new JSONObject();
|
||
param.put("appid", appId);
|
||
param.put("appsecret", appSecret);
|
||
param.put("name", getSimInfoName);
|
||
param.put("iccid", iccId);
|
||
|
||
String result = HttpUtils.sendPostContentType(wuLianGetWay, param.toJSONString(), "application/json");
|
||
logger.info("【====物联网智能云平台====】查询Sim卡信息, result: {}", result);
|
||
|
||
JSONObject jsonObject = JSONObject.parseObject(result);
|
||
JSONArray dataArray = (JSONArray) jsonObject.get("data");
|
||
|
||
if (CollectionUtils.isNotEmpty(dataArray)) {
|
||
JSONObject data = dataArray.getJSONObject(0);
|
||
WuLianSimData wuLianSimData = JSONObject.parseObject(data.toJSONString(), WuLianSimData.class);
|
||
|
||
list.add(wuLianSimData);
|
||
}
|
||
}
|
||
return list;
|
||
}
|
||
|
||
|
||
/**
|
||
* 物联平台 内部接口
|
||
* 通过iccIds查询物联平台Sim卡信息
|
||
*
|
||
* @param iccIds
|
||
* @return
|
||
*/
|
||
public List<SimCardVO> WuLianGetSimInfoByIccIds(List<String> iccIds) {
|
||
List<SimCardVO> resultList = new ArrayList<>();
|
||
|
||
List<WuLianSimData> list = WuLianGetSimInfo(iccIds);
|
||
SimCardVO vo = null;
|
||
|
||
for (WuLianSimData wuLianSimData : list) {
|
||
String WuLianCardStatus = wuLianSimData.getCardStatus();
|
||
|
||
// 卡状态不一致，需做对应
|
||
String dataBaseCardStatus = SimCardStatusCorrespondEnum.getDataBaseCardStatus(WuLianCardStatus);
|
||
|
||
BigDecimal packageCanUsage = new BigDecimal(wuLianSimData.getPackageCanUsage()); // 可用流量(MB)
|
||
BigDecimal packageHasUsage = new BigDecimal(wuLianSimData.getPackageHasUsage()); // 已用流量(MB)
|
||
BigDecimal residualFlowRate = packageCanUsage.subtract(packageHasUsage); // 剩余
|
||
|
||
// 运营商
|
||
String packageName = wuLianSimData.getPackageName();
|
||
String operator = "";
|
||
if (StringUtils.contains(packageName, "移动")) {
|
||
operator = "china_mobile";
|
||
} else if (StringUtils.contains(packageName, "电信")) {
|
||
operator = "china_telecom";
|
||
} else if (StringUtils.contains(packageName, "联通")) {
|
||
operator = "china_unicom";
|
||
}
|
||
|
||
//将信息封装到SimCardVO
|
||
vo = new SimCardVO();
|
||
vo.setIccId(wuLianSimData.getIccId());
|
||
vo.setSimCardFactory(SimSupplierEnum.WU_LIAN_INTERNET.getCode()); // 2-物联网智能云平台
|
||
vo.setSimCardOperator(operator); // 运营商
|
||
vo.setSimCardStatus(dataBaseCardStatus); // 卡状态
|
||
vo.setName(packageName); // 套餐名称
|
||
vo.setExpiredTime(wuLianSimData.getCardEndTime()); // 卡到期时间
|
||
vo.setPackageCapacity(packageCanUsage); // 套餐容量
|
||
vo.setUsedFlowRate(packageHasUsage); // 已用流量
|
||
vo.setResidualFlowRate(residualFlowRate); // 剩余流量
|
||
|
||
|
||
resultList.add(vo);
|
||
|
||
}
|
||
return resultList;
|
||
|
||
}
|
||
|
||
|
||
/**
|
||
* 物联平台续费接口
|
||
*
|
||
* @param iccIds
|
||
* @param cycleNumber
|
||
* @return
|
||
*/
|
||
public void WuLianSimRenew(List<String> iccIds, int cycleNumber) {
|
||
List<WuLianSimRenewVO> resultList = new ArrayList<>();
|
||
if (CollectionUtils.isEmpty(iccIds)) {
|
||
return;
|
||
}
|
||
// 先查出卡的信息
|
||
List<WuLianSimData> wuLianSimData = WuLianGetSimInfo(iccIds);
|
||
for (WuLianSimData data : wuLianSimData) {
|
||
JSONObject param = new JSONObject();
|
||
param.put("appid", appId);
|
||
param.put("appsecret", appSecret);
|
||
param.put("name", WuLianSimRenew);
|
||
param.put("msisdn", data.getMsisdn());
|
||
param.put("packageId", data.getPackageId()); // 套餐id
|
||
param.put("outOrderNo", IdUtils.generateTransactionCode(data.getMsisdn())); // 外部业务订单号
|
||
param.put("period", cycleNumber); // 续费周期
|
||
|
||
String result = HttpUtils.sendPostContentType(wuLianGetWay, param.toJSONString(), "application/json");
|
||
logger.info("【====物联网智能云平台====】Sim卡续费, result: {}", result);
|
||
JSONObject resultJson = JSONObject.parseObject(result);
|
||
String resultCode = resultJson.getString("code");
|
||
WuLianSimRenewVO vo = null;
|
||
if (!StringUtils.equals("0", resultCode)) {
|
||
throw new BusinessException(resultCode, resultJson.getString("msg"));
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 将list数组转化为逗号分隔的字符串
|
||
*
|
||
* @param iccIds
|
||
* @return
|
||
*/
|
||
private String list2Str(List<String> iccIds) {
|
||
iccIds = iccIds.stream()
|
||
.filter(StringUtils::isNotEmpty)
|
||
.filter(x -> !StringUtils.equals(x, "0"))
|
||
.collect(Collectors.toList());
|
||
// 数组转成逗号分割的字符串
|
||
String iccId = StringUtils.join(iccIds, ",");
|
||
return iccId;
|
||
}
|
||
}
|