opensource/iotlink
3
0
Fork 0
mirror of https://gitee.com/sdyunze/iotlink.git synced 2026-09-01 04:48:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

确实代码补提

Browse Source
This commit is contained in:
山东云则
2024-12-24 16:15:01 +08:00
parent 45b73529ba
commit 281a9bc245
19 changed files with 387 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
yunze-apiCommon/src/main/java/com/yunze/apiCommon/upstreamAPI/DianXinCMP/Inquire/Query_DX.java
+32 -16
View File
@@ -817,20 +817,36 @@ public class Query_DX extends DX_CMP_Api {
}
/**
* APN批量停复机
* @param
* @return
*/
public String FunctionApnCardStop(String access_number,String orderTypeId,String acctCd) {
Map<String,Object> rMap = new HashMap<>();
//拼接接口地址
String api_url = server_Ip + "/m2m_ec/query.do";
String method = "disabledNumber";
//拼接请求参数
Map<String, Object> params = new HashMap<>();
params.put("user_id", user_id);
params.put("method", method);
params.put("access_number", access_number);
params.put("orderTypeId", orderTypeId);
params.put("acctCd", acctCd);
String[] arr = {access_number,user_id,password,method,acctCd,orderTypeId}; //加密数组，数组所需参数根据对应的接口文档
DesUtils des = new DesUtils(); //DES加密工具类实例化
String passWord = des.strEnc(password, key1, key2, key3); //密码加密
String sign = des.strEnc(DesUtils.naturalOrdering(arr), key1, key2, key3); //生成sign加密值
params.put("sign", sign);
params.put("passWord", passWord);
//请求体封装
String res = UrlUtil.getUrl(api_url, params);
try {
rMap = XmlUtil.xmlToMap(res);
} catch (Exception e) {
System.out.println(Config_name + " 返回数据错误！" + res);
}
return rMap.toString();
}
}
yunze-apiCommon/src/main/java/com/yunze/apiCommon/upstreamAPI/DianXinCMP5G/Inquire/Query_DX5G.java
+26
View File
@@ -2,6 +2,7 @@ package com.yunze.apiCommon.upstreamAPI.DianXinCMP5G.Inquire;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.yunze.apiCommon.upstreamAPI.DianXinCMP5G.DianXin_DCP5G_Api;
import com.yunze.apiCommon.upstreamAPI.DianXinCMP5G.change.ServiceAccept_DX5G;
import com.yunze.apiCommon.utils.HttpUtil;
@@ -9,6 +10,7 @@ import com.yunze.apiCommon.utils.UrlUtil;
import com.yunze.apiCommon.utils.XmlUtil;
import lombok.extern.slf4j.Slf4j;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.logging.Logger;
@@ -400,4 +402,28 @@ public class Query_DX5G extends DianXin_DCP5G_Api {
}
return rMap;
}
/**
* 2.3.2. CTIOT_5GCMP_LC002-停机保号相关
* */
public String FunctionApnCardStop(String access_number,String orderTypeId){
Map<String, Object> rMap = null;
String res = null;
//拼接接口地址
String Config_name = "/5gcmp/openapi/v1/common/disabledNumberService";
String api_url = server_Ip + Config_name;
Map<String, Object> params = new HashMap<>();
params.put("access_number", access_number);
params.put("orderTypeId", orderTypeId);
//生成sign加密值
getSign(params);
String param_url = UrlUtil.getUrl(api_url, params, true);
res = HttpUtil.get(param_url, headers);
try {
rMap = XmlUtil.xmlToMap(res);
} catch (Exception e) {
System.out.println(Config_name + " 返回数据错误！" + res);
}
return rMap.toString();
}
}
yunze-apiCommon/src/main/java/com/yunze/apiCommon/upstreamAPI/YiDongEC/Inquire/Query_YD.java
+11
View File
@@ -804,4 +804,15 @@ public class Query_YD extends YD_EC_Api {
}
public String FunctionApnCardStop(String msisdn, String operType) {
String functionNm = "/change/sim-status";
JSONObject json = new JSONObject();
json.put("transid", appId + new SimpleDateFormat("YYYYMMDDHHMMSS").format(new Date()));
json.put("token", token);
json.put("msisdn", msisdn);
json.put("operType", operType);
String url = server_Ip + functionNm;
String Str = send(url, json);
return repeat(Str, json, url);
}
}
yunze-common/src/main/java/com/yunze/common/mapper/mysql/YzAgentPackageMapper.java
+2
View File
@@ -88,4 +88,6 @@ public interface YzAgentPackageMapper {
* 导出
*/
public List<Map<String, Object>> exportallorders(Map map);
String findAgentId(Object appId);
}
yunze-common/src/main/java/com/yunze/common/mapper/mysql/YzCardMapper.java
+13
View File
@@ -1,6 +1,8 @@
package com.yunze.common.mapper.mysql;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map;
@@ -652,6 +654,17 @@ public interface YzCardMapper
void updNewUsed(Map<String, Object> putMap);
Map<String, Object> selectApiParams(@Param("msisdn") String msisdn);
Map<String, Object> queryCardPackage(@Param("iccid") String iccid);
Map<String, Object> selectCardInfoList(@Param("iccid") String iccid);
Map<String, Object> selectCardDetail(@Param("iccid") String iccid);
Map<String, Object> getOneCardInfo(@Param("iccid") String iccid);
Map<String, Object> queryDueExpireDateXQ(@Param("iccid") String iccid);
}
yunze-common/src/main/java/com/yunze/common/mapper/mysql/YzCardPacketMapper.java
+6
View File
@@ -1,6 +1,8 @@
package com.yunze.common.mapper.mysql;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map;
@@ -148,4 +150,8 @@ public interface YzCardPacketMapper {
*/
public List<Map<String,Object>> exportPacket(Map<String, Object> map);
Map<String, Object> getPacketInfo(@Param("packetId") String packetId);
Map<String, Object> getOnePacketInfo(@Param("packageId") String packageId,@Param("packetId") String packetId);
}
yunze-common/src/main/java/com/yunze/common/mapper/mysql/YzOrderMapper.java
+7
View File
@@ -1,5 +1,8 @@
package com.yunze.common.mapper.mysql;
import org.apache.ibatis.annotations.Param;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -251,5 +254,9 @@ public interface YzOrderMapper {
public List<Map<String, Object>> findIccidOrderApi(Map<String, Object> map);
String selectOrderNo(@Param("iccid") String iccid);
void insertOrder(HashMap<String, Object> insertMap);
}
yunze-common/src/main/java/com/yunze/common/mapper/mysql/card/YzApplicationforRenewalMapper.java
+1
View File
@@ -21,5 +21,6 @@ public interface YzApplicationforRenewalMapper {
public int del(Map map);
void insertRenewal(Map<String, Object> packetObj);
}
yunze-common/src/main/java/com/yunze/common/mapper/mysql/card/YzApplicationforRenewalPrimaryIccidMapper.java
+3
View File
@@ -1,5 +1,7 @@
package com.yunze.common.mapper.mysql.card;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map;
@@ -23,4 +25,5 @@ public interface YzApplicationforRenewalPrimaryIccidMapper {
public Integer findCount(Map map);
void insertIccid(@Param("iccid") String iccid, @Param("id")String id);
}
yunze-common/src/main/java/com/yunze/common/mapper/mysql/card/YzApplicationforRenewalPrimaryMapper.java
+2
View File
@@ -1,5 +1,6 @@
package com.yunze.common.mapper.mysql.card;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -43,4 +44,5 @@ public interface YzApplicationforRenewalPrimaryMapper {
public List<Map <String,Object>> findAppOrderGr(Map map);
void insertPrimaryInfo(HashMap<Object, Object> hashMap);
}
yunze-common/src/main/java/com/yunze/common/mapper/mysql/card/YzApplicationforRenewalPrimaryOrdNoMapper.java
+2
View File
@@ -1,5 +1,6 @@
package com.yunze.common.mapper.mysql.card;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -29,4 +30,5 @@ public interface YzApplicationforRenewalPrimaryOrdNoMapper {
public List<Map <String,Object>> findOrder(Map map);
void insertOrderNo(HashMap<String, Object> orderMap);
}
yunze-common/src/main/resources/mapper/mysql/yunze/YzAgentPackagetMapper.xml
+8
View File
@@ -212,6 +212,14 @@
<include refid="selwhere"/>
GROUP BY a.id
</select>
<select id="findAgentId" resultType="java.lang.String">
SELECT
agent_id AS appId
FROM
yz_agent_account
WHERE
app_id = #{appId}
</select>
</mapper>
yunze-common/src/main/resources/mapper/mysql/yunze/YzCardMapper.xml
+100
View File
@@ -2445,5 +2445,105 @@
WHERE
t1.channel_id = "75"
</select>
<select id="selectApiParams" resultType="java.util.Map">
SELECT cd_code,
cd_username,
cd_pwd,
cd_key
FROM yz_card_info t1
LEFT JOIN yz_card_route t2 ON t1.channel_id = t2.cd_id
WHERE msisdn = #{msisdn}
</select>
<select id="queryCardPackage" resultType="java.util.Map">
SELECT t1.iccid,
t1.msisdn,
t1.imsi,
t4.validate_type as validateType,
t2.package_id as packageId,
t3.packet_id as packetId,
CONCAT(ROUND(t3.error_flow), 'M', t3.packet_valid_name, '/', t3.packet_valid_time,
t3.packet_valid_name) AS packetName
FROM yz_card_info t1
LEFT JOIN yz_card_packet t2 ON t1.package_id = t2.package_id
LEFT JOIN yz_card_packet t3 ON t2.package_id = t3.package_id
LEFT JOIN (SELECT *
FROM yz_card_flow
WHERE iccid = #{iccid}
GROUP BY iccid
ORDER BY create_time DESC) t4 ON t3.packet_id = t4.packet_id
WHERE t1.iccid = #{iccid}
AND t1.status_ShowId != 7
AND t1.agent_id != 664
GROUP BY t1.iccid
</select>
<select id="selectCardInfoList" resultType="java.util.Map">
SELECT iccid,
msisdn,
imsi,
imei,
activate_date as activateDate,
DATE_FORMAT(due_expire_time, "%Y-%m-%d") AS dueExpireTime,
status_ShowId as status,
remarks
FROM yz_card_info
WHERE iccid = #{iccid}
AND status_ShowId != 7
AND agent_id != 664
</select>
<select id="selectCardDetail" resultType="java.util.Map">
SELECT a.iccid,
a.msisdn,
a.imsi,
a.status_ShowId AS 'status',
a.activate_date as activateDate,
c.package_name as packageName,
a.used as useFlow,
a.remaining,
DATE_FORMAT(d.start_time, "%Y-%m-%d") AS startTime,
DATE_FORMAT(d.end_time, "%Y-%m-%d") AS endTime
FROM yz_card_info a
LEFT JOIN yz_card_route b ON a.channel_id = b.cd_id
LEFT JOIN yz_card_package c ON a.package_id = c.package_id
LEFT JOIN (SELECT *
FROM yz_card_flow
WHERE iccid = #{iccid}
GROUP BY iccid
ORDER BY create_time DESC) d ON c.package_id = d.package_id
WHERE a.iccid = #{iccid}
AND status_ShowId != 7
AND agent_id != 664
</select>
<select id="queryDueExpireDateXQ" resultType="java.util.Map">
SELECT
t1.iccid,
t1.status_ShowId AS status,
t1.used,
t5.error_flow AS totalFlow,
DATE_FORMAT( t1.activate_date, "%Y-%m-%d %H:%i:%S" ) AS activateDate,
CONCAT( ROUND( t5.error_flow ), 'M', '/', t5.packet_valid_name, '*12月' ) AS packetName,
DATE_FORMAT( DATE_SUB( t1.due_expire_time_xq, INTERVAL 12 MONTH ), "%Y-%m-%d %H:%i:%S" ) as startTime,
DATE_FORMAT( t1.due_expire_time_xq, "%Y-%m-%d" ) AS dueExpireTimeXq
FROM
yz_card_info t1
LEFT JOIN yz_card_packet t2 ON t1.package_id = t2.package_id
LEFT JOIN (
SELECT
t3.*
FROM
yz_card_packet t3
LEFT JOIN yz_card_flow t4 ON t4.packet_id = t3.packet_id
WHERE
t4.iccid = #{iccid}
ORDER BY
t4.start_time DESC
LIMIT 1
) t5 ON t2.package_id = t5.package_id
WHERE
t1.iccid = #{iccid}
AND t1.status_ShowId != 7
AND t1.agent_id != 664
GROUP BY
t1.iccid
</select>
</mapper>
yunze-common/src/main/resources/mapper/mysql/yunze/YzCardPacketMapper.xml
+16 -1
View File
@@ -615,7 +615,22 @@
<include refid="selwhere"/>
GROUP BY b.id
</select>
<select id="getPacketInfo" resultType="java.util.Map">
SELECT
t1.packet_cost,
t1.packet_id,
t1.package_id,
t1.packet_flow,
t1.packet_price,
CONCAT(ROUND(t1.error_flow), 'M', t1.packet_valid_name, '/', t1.packet_valid_time,
t1.packet_valid_name) AS packetName
FROM
yz_card_packet t1
LEFT JOIN yz_order t2 ON t1.packet_id = t2.packet_id
WHERE
t2.packet_id = #{packetId}
LIMIT 1
</select>
</mapper>
yunze-common/src/main/resources/mapper/mysql/yunze/YzOrderMapper.xml
+70 -5
View File
@@ -538,6 +538,65 @@
now(),0, <![CDATA[ #{info} ]]>,1
)
</insert>
<insert id="insertOrder" parameterType="java.util.HashMap" >
insert into
yz_order
(
ord_no,ord_type,ord_name,iccid,wx_ord_no,
status,price,account,packet_id,pay_type,
cre_type,is_profit,add_package,show_status,open_id,agent_id,
profit_type,create_time,validate_type,info,add_parameter,del_flag,is_profit_sharing,is_audit,callback_address,
is_dd_status,
is_openNet_status,
is_boot_status
)
value
(#{ord_no},#{ord_type},#{ord_name},#{iccid},#{wx_ord_no},
#{status},#{price},#{account},#{packet_id},#{pay_type},
#{cre_type},#{is_profit},#{add_package},#{show_status},#{open_id},#{agent_id},
#{profit_type},now(),#{validate_type},#{info}, #{add_parameter},0,0
<choose>
<when test="is_audit!=null">
,#{is_audit}
</when>
<otherwise>
,1
</otherwise>
</choose>
<choose>
<when test="callback_address!=null">
,#{callback_address}
</when>
<otherwise>
,""
</otherwise>
</choose>
<choose>
<when test="is_dd_status!=null">
,#{is_dd_status}
</when>
<otherwise>
,0
</otherwise>
</choose>
<choose>
<when test="is_openNet_status!=null">
,#{is_openNet_status}
</when>
<otherwise>
,0
</otherwise>
</choose>
<choose>
<when test="is_boot_status!=null">
,#{is_boot_status}
</when>
<otherwise>
,0
</otherwise>
</choose>
)
</insert>
<select id="exportallorders" parameterType="java.util.HashMap" resultType="java.util.HashMap">
SELECT
@@ -985,11 +1044,17 @@
</where>
GROUP BY iccid
</select>
<select id="selectOrderNo" resultType="java.lang.String">
SELECT
ord_no
FROM
yz_order
WHERE
iccid = #{iccid}
ORDER BY
create_time DESC
LIMIT 1
</select>
</mapper>
yunze-common/src/main/resources/mapper/mysql/yunze/card/YzApplicationforRenewalMapper.xml
+37
View File
@@ -71,6 +71,43 @@
#{packet_id}
)
</insert>
<insert id="insertRenewal" parameterType="java.util.HashMap" keyProperty="id" useGeneratedKeys="true">
insert into
yz_applicationfor_renewal
(
p_id,
dept_id,
create_time,
update_time,
packet_info,
card_count,
packet_wx_name,
packet_price,
packet_flow,
packet_cost,
packet_valid_time,
packet_valid_name,
generate_tariff_orders,
packet_id
)
values
(
#{p_id},
#{dept_id},
now(),
now(),
#{packet_info},
#{card_count},
#{packet_wx_name},
#{packet_price},
#{packet_flow},
#{packet_cost},
#{packet_valid_time},
#{packet_valid_name},
0,
#{packet_id}
)
</insert>
<update id="upd" parameterType="java.util.HashMap" >
update
yunze-common/src/main/resources/mapper/mysql/yunze/card/YzApplicationforRenewalPrimaryIccidMapper.xml
+12
View File
@@ -47,6 +47,18 @@
)
</foreach>
</insert>
<insert id="insertIccid">
insert into yz_applicationfor_renewal_iccid
(
iccid,
b_id
)
values (
#{iccid},
#{b_id}
)
</insert>
<delete id="del" parameterType="java.util.HashMap" >
delete from yz_applicationfor_renewal_iccid
yunze-common/src/main/resources/mapper/mysql/yunze/card/YzApplicationforRenewalPrimaryMapper.xml
+26
View File
@@ -108,6 +108,32 @@
#{amount}
)
</insert>
<insert id="insertPrimaryInfo" parameterType="java.util.HashMap" keyProperty="id" useGeneratedKeys="true">
insert into yz_applicationfor_renewal_primary
(dept_id,
create_time,
`status`,
info,
annotation,
feedback,
user_id,
update_time,
is_send,
card_sumCount,
amount)
values (#{dept_id},
now(),
0,
#{info},
#{annotation},
#{feedback},
#{user_id},
now(),
1,
#{card_sumCount},
#{amount})
</insert>
<update id="upd" parameterType="java.util.HashMap" >
update
yunze-common/src/main/resources/mapper/mysql/yunze/card/YzApplicationforRenewalPrimaryOrdNoMapper.xml
+13
View File
@@ -65,6 +65,19 @@
)
</foreach>
</insert>
<insert id="insertOrderNo">
insert into
yz_applicationfor_renewal_ordno
(
p_id,
ord_no
)
values
(
#{p_id},
#{ord_no}
)
</insert>
<delete id="del" parameterType="java.util.HashMap" >
delete from yz_applicationfor_renewal_ordno