From 47662397ea230dfc5925b6b21a150f8a6d9432d9 Mon Sep 17 00:00:00 2001 From: czt <czt18638530771@163.com> Date: 星期三, 24 四月 2024 20:14:29 +0800 Subject: [PATCH] 陕西省平台提交1-搭建指令接收及数据上传架构 --- src/main/java/com/fzzy/order/ordersx2023/OrderSxService.java | 22 src/main/java/com/fzzy/push/sx2023/SX2023OrderServiceImpl.java | 203 ++++++ src/main/java/com/fzzy/push/sx2023/data/SXFinanceDto.java | 52 + src/main/java/com/fzzy/push/sx2023/SX2023HttpClientUtil.java | 80 ++ src/main/java/com/fzzy/order/ordersx2023/package-info.java | 7 src/main/java/com/fzzy/push/sx2023/data/SX2023RespDto.java | 47 + src/main/java/com/fzzy/order/ordersx2023/data/OrderSxConstant.java | 15 src/main/java/com/fzzy/push/sx2023/data/SX2023Dto.java | 24 src/main/java/com/fzzy/push/sx2023/SX2023Constant.java | 164 +++++ src/main/java/com/fzzy/order/ordersx2023/OrderSxManager.java | 66 ++ src/main/java/com/fzzy/api/utils/SXAESUtils.java | 56 + src/main/java/com/fzzy/push/sx2023/data/SX2023Api1101.java | 132 ++++ src/main/java/com/fzzy/push/sx2023/data/SX2023ReqDto.java | 53 + src/main/java/com/fzzy/order/ordersx2023/data/OrderSxReq.java | 48 + src/main/java/com/fzzy/order/ordersx2023/OrderSxController.java | 61 ++ src/main/java/com/fzzy/order/ordersx2023/data/OrderSxResp.java | 24 src/main/java/com/fzzy/push/sx2023/SX2023ApiRemoteService.java | 688 ++++++++++++++++++++++ 17 files changed, 1,742 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/fzzy/api/utils/SXAESUtils.java b/src/main/java/com/fzzy/api/utils/SXAESUtils.java new file mode 100644 index 0000000..0a5ec67 --- /dev/null +++ b/src/main/java/com/fzzy/api/utils/SXAESUtils.java @@ -0,0 +1,56 @@ +package com.fzzy.api.utils; + +import javax.crypto.Cipher; +import javax.crypto.SecretKey; +import javax.crypto.spec.IvParameterSpec; +import javax.crypto.spec.SecretKeySpec; +import java.nio.charset.StandardCharsets; +import java.util.Base64; + +/** + * @Description 闄曡タ鐪佸钩鍙版暟鎹姞瀵嗗強瑙e瘑 + * @Author CZT + * @Date 2024/4/23 18:02 + */ +public class SXAESUtils { + + public static final String AES_KEY = "shanxihlhtaeskey"; + private static final String AES_ALGORITHM = "AES/CBC/PKCS5Padding"; + private static final String AES_KEY_ALGORITHM = "AES"; + + + /** + * 鐢ˋES鍔犲瘑, 鍔犲瘑绠楁硶涓� AES/CBC/PKCS5Padding + * + * @param key + * @param data + * @return + * @throws Exception + */ + public static String encryptByAES(String key, String data) throws Exception { + Cipher cipher = Cipher.getInstance(AES_ALGORITHM); + cipher.init(Cipher.ENCRYPT_MODE, + new SecretKeySpec(key.getBytes(StandardCharsets.UTF_8), AES_KEY_ALGORITHM), + new IvParameterSpec(key.getBytes(StandardCharsets.UTF_8))); + byte[] out = cipher.doFinal(data.getBytes(StandardCharsets.UTF_8)); + return Base64.getEncoder().encodeToString(out); + } + + /** + * 鐢ˋES瑙e瘑, 瑙e瘑绠楁硶涓� AES/CBC/PKCS5Padding + * + * @param key + * @param dataBase64 + * @return + * @throws Exception + */ + public static String decryptByAES(String key, String dataBase64) throws Exception { + Cipher cipher = Cipher.getInstance(AES_ALGORITHM); + cipher.init(Cipher.DECRYPT_MODE, new SecretKeySpec(key.getBytes(StandardCharsets.UTF_8), + AES_KEY_ALGORITHM), new + IvParameterSpec(key.getBytes(StandardCharsets.UTF_8))); + byte[] out = + cipher.doFinal(Base64.getDecoder().decode(dataBase64)); + return new String(out, StandardCharsets.UTF_8); + } +} diff --git a/src/main/java/com/fzzy/order/ordersx2023/OrderSxController.java b/src/main/java/com/fzzy/order/ordersx2023/OrderSxController.java new file mode 100644 index 0000000..f1d852e --- /dev/null +++ b/src/main/java/com/fzzy/order/ordersx2023/OrderSxController.java @@ -0,0 +1,61 @@ +package com.fzzy.order.ordersx2023; + +import com.fzzy.order.ordersx2023.data.OrderSxConstant; +import com.fzzy.order.ordersx2023.data.OrderSxReq; +import com.fzzy.order.ordersx2023.data.OrderSxResp; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.ResponseBody; + +/** + * @Description 闄曡タ鐪佸钩鍙版寚浠ゆ帴鏀舵湇鍔� + * @Author CZT + * @Date 2024/4/23 11:11 + */ +@Slf4j +@Controller +@RequestMapping("Acquisition") +public class OrderSxController { + + @Autowired + private OrderSxManager orderSxManager; + /** + * 鐧诲綍鍏ュ彛 + * @param req + * @return + */ + @SuppressWarnings("unchecked") + @ResponseBody + @RequestMapping("/") + public OrderSxResp order(@RequestBody OrderSxReq req){ + log.debug("闄曡タ鐪佸钩鍙帮細鎺ユ敹鐨勬寚浠や俊鎭�={}", req); + //鍒ゆ柇鍙傛暟 + if(null == req){ + //瑙f瀽澶辫触 + log.error("闄曡タ鐪佸钩鍙帮細鎸囦护瑙f瀽澶辫触锛屾敹鍒扮殑鎸囦护淇℃伅涓虹┖锛�"); + return new OrderSxResp(OrderSxConstant.ORDER_SX_CODE_400); + } + + //蹇冭烦鎸囦护锛岀洿鎺ヨ繑鍥� + if(OrderSxConstant.ORDER_SX_TYPE_0.equals(req.getType())){ + log.info("闄曡タ鐪佸钩鍙帮細鏀跺埌蹇冭烦鎸囦护锛屾寚浠や俊鎭�={}", req); + return new OrderSxResp(OrderSxConstant.ORDER_SX_CODE_200); + } + + try { + + //寮傛鎵ц + orderSxManager.execute(req); + + return new OrderSxResp(OrderSxConstant.ORDER_SX_CODE_200); + + } catch (Exception e) { + log.error("闄曡タ鐪佸钩鍙帮細鎸囦护瑙f瀽澶辫触锛屾寚浠や俊鎭�={}", req); + return new OrderSxResp(OrderSxConstant.ORDER_SX_CODE_400); + } + + } +} diff --git a/src/main/java/com/fzzy/order/ordersx2023/OrderSxManager.java b/src/main/java/com/fzzy/order/ordersx2023/OrderSxManager.java new file mode 100644 index 0000000..6d21709 --- /dev/null +++ b/src/main/java/com/fzzy/order/ordersx2023/OrderSxManager.java @@ -0,0 +1,66 @@ +package com.fzzy.order.ordersx2023; + +import com.fzzy.api.entity.ApiConfs; +import com.fzzy.api.view.pr.ApiConfsPR; +import com.fzzy.order.ordersx2023.data.OrderSxReq; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.BeansException; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.ApplicationContext; +import org.springframework.context.ApplicationContextAware; +import org.springframework.scheduling.annotation.Async; +import org.springframework.stereotype.Component; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @Description 鎸囦护涓嬪彂鍏ュ彛 + * @Author CZT + * @Date 2024/4/23 11:36 + */ +@Slf4j +@Component(OrderSxManager.BEAN_ID) +public class OrderSxManager implements ApplicationContextAware { + public static final String BEAN_ID = "order.orderSxManager"; + + private static Map<String, OrderSxService> serviceMap; + + @Autowired + private ApiConfsPR apiConfsPR; + + @Override + public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { + Map<String, OrderSxService> map = applicationContext.getBeansOfType(OrderSxService.class); + serviceMap = new HashMap<>(); + for (String key : map.keySet()) { + serviceMap.put(map.get(key).getProtocol(), map.get(key)); + } + } + + @Async + public void execute(OrderSxReq req){ + + try{ + //鑾峰彇閰嶇疆淇℃伅 + List<ApiConfs> apiConfList = apiConfsPR.listAll(); + if(null == apiConfList || apiConfList.isEmpty()){ + log.error("闄曡タ鐪佸钩鍙帮細鏀跺埌鎸囦护锛屾湭鑾峰彇鍒板簱鍖洪厤缃俊鎭紝涓嶆墽琛岋紒"); + return; + } + //鏍规嵁閰嶇疆淇℃伅鎵ц + OrderSxService service; + for (ApiConfs conf : apiConfList) { + service = serviceMap.get(conf.getPushProtocol()); + if(null == service){ + log.error("闄曡タ鐪佸钩鍙帮細鏀跺埌鎸囦护锛屾湭鑾峰彇鍒板崗璁紝涓嶆墽琛岋紒"); + continue; + } + service.execute(req, conf); + } + } catch (Exception e) { + log.error("闄曡タ鐪佸钩鍙帮細鎸囦护鎵ц澶辫触锛岄敊璇�={}", e.getLocalizedMessage()); + } + } +} diff --git a/src/main/java/com/fzzy/order/ordersx2023/OrderSxService.java b/src/main/java/com/fzzy/order/ordersx2023/OrderSxService.java new file mode 100644 index 0000000..744909d --- /dev/null +++ b/src/main/java/com/fzzy/order/ordersx2023/OrderSxService.java @@ -0,0 +1,22 @@ +package com.fzzy.order.ordersx2023; + +import com.fzzy.api.entity.ApiConfs; +import com.fzzy.order.ordersx2023.data.OrderSxReq; + +import java.text.ParseException; + +/** + * @Description 鏍规嵁鍗忚瀹炵幇涓嶅悓瑙f瀽 + * @Author CZT + * @Date 2024/4/23 11:33 + */ +public interface OrderSxService { + + /** + * 鑾峰彇鍗忚缂栫爜 + * @return + */ + public String getProtocol(); + + public void execute(OrderSxReq req, ApiConfs apiConfs) throws ParseException; +} diff --git a/src/main/java/com/fzzy/order/ordersx2023/data/OrderSxConstant.java b/src/main/java/com/fzzy/order/ordersx2023/data/OrderSxConstant.java new file mode 100644 index 0000000..4f01510 --- /dev/null +++ b/src/main/java/com/fzzy/order/ordersx2023/data/OrderSxConstant.java @@ -0,0 +1,15 @@ +package com.fzzy.order.ordersx2023.data; + +/** + * @Description 闄曡タ鎸囦护鏈嶅姟甯哥敤甯搁噺 + * @Author CZT + * @Date 2024/4/23 11:24 + */ +public class OrderSxConstant { + + public static String ORDER_SX_TYPE_0 = "0"; //蹇冭烦鎸囦护 + public static String ORDER_SX_TYPE_1 = "1"; //鏁版嵁涓婃姤鎸囦护 + public static String ORDER_SX_CODE_200 = "200"; //鎸囦护瑙f瀽鎴愬姛 + public static String ORDER_SX_CODE_400 = "400"; //鎸囦护瑙f瀽澶辫触 + +} diff --git a/src/main/java/com/fzzy/order/ordersx2023/data/OrderSxReq.java b/src/main/java/com/fzzy/order/ordersx2023/data/OrderSxReq.java new file mode 100644 index 0000000..90191de --- /dev/null +++ b/src/main/java/com/fzzy/order/ordersx2023/data/OrderSxReq.java @@ -0,0 +1,48 @@ +package com.fzzy.order.ordersx2023.data; + +import lombok.Data; + +import java.io.Serializable; + +/** + * @Description 鎸囦护鎺ユ敹灏佽 + * @Author CZT + * @Date 2024/4/23 11:19 + */ +@Data +public class OrderSxReq implements Serializable { + /** + * 鎸囦护ID + */ + private String Orderid; + + /** + * 鎸囦护鍐呭锛氬績璺虫寚浠ゆ椂锛屽唴瀹逛负绌� + */ + private String Data; + + /** + * 鎸囦护绫诲瀷锛�0-蹇冭烦锛�1-鏁版嵁 + */ + private String Type; + + /** + * 寮�濮嬫椂闂� + */ + private String StartTime; + + /** + * 鎴鏃堕棿 + */ + private String EndTime; + + /** + * 鍗曚綅浠g爜锛�18浣嶇粺涓�淇$敤鐮� + */ + private String Dwdm; + + /** + * 鎿嶄綔鏍囧織锛歛:鏈笂浼犲拰宸蹭笂浼犵殑鏁版嵁锛堝寘鎷暟鎹睜涓搷浣滄爣蹇椾负d鐨勬暟鎹級 c:鏈笂浼犲拰宸蹭笂浼犵殑鏁版嵁锛堜笉鍖呮嫭鏁版嵁姹犱腑鎿嶄綔鏍囧織涓篸鐨勬暟鎹級 n:鏈笂浼犺繃鐨勬暟鎹� + */ + private String czbz; +} diff --git a/src/main/java/com/fzzy/order/ordersx2023/data/OrderSxResp.java b/src/main/java/com/fzzy/order/ordersx2023/data/OrderSxResp.java new file mode 100644 index 0000000..27b9ff9 --- /dev/null +++ b/src/main/java/com/fzzy/order/ordersx2023/data/OrderSxResp.java @@ -0,0 +1,24 @@ +package com.fzzy.order.ordersx2023.data; + +import java.io.Serializable; + +/** + * @Description 鎸囦护鍥炲灏佽 + * @Author CZT + * @Date 2024/4/23 11:16 + */ +public class OrderSxResp implements Serializable { + /** + * + */ + private static final long serialVersionUID = -6714158228489303453L; + + private String code; + public OrderSxResp() { + } + + public OrderSxResp(String code) { + this.code = code; + + } +} diff --git a/src/main/java/com/fzzy/order/ordersx2023/package-info.java b/src/main/java/com/fzzy/order/ordersx2023/package-info.java new file mode 100644 index 0000000..08c1d2b --- /dev/null +++ b/src/main/java/com/fzzy/order/ordersx2023/package-info.java @@ -0,0 +1,7 @@ + +/** + * @Description 闄曡タ鐪佸钩鍙版寚浠ゅ寘 + * @Author CZT + * @Date 2024/4/22 19:45 + */ +package com.fzzy.order.ordersx2023; \ No newline at end of file diff --git a/src/main/java/com/fzzy/push/sx2023/SX2023ApiRemoteService.java b/src/main/java/com/fzzy/push/sx2023/SX2023ApiRemoteService.java new file mode 100644 index 0000000..ca9813a --- /dev/null +++ b/src/main/java/com/fzzy/push/sx2023/SX2023ApiRemoteService.java @@ -0,0 +1,688 @@ +package com.fzzy.push.sx2023; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.fzzy.api.Constant; +import com.fzzy.api.data.ApiParam; +import com.fzzy.api.data.PushProtocol; +import com.fzzy.api.dto.ResponseDto; +import com.fzzy.api.entity.*; +import com.fzzy.api.service.ApiCommonService; +import com.fzzy.api.service.ApiRemoteService; +import com.fzzy.api.service.ApiTriggerService; +import com.fzzy.api.utils.*; +import com.fzzy.api.view.repository.ApiLogRep; +import com.fzzy.push.sx2023.data.*; +import lombok.Data; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang.time.DateFormatUtils; +import org.apache.commons.lang.time.DateUtils; +import org.springframework.beans.BeanUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.lang.reflect.Field; +import java.util.*; + +/** + * @Description 闄曡タ鐪佸钩鍙�2023鐗�-涓婁紶鏁版嵁鏈嶅姟绫� + * @Author CZT + * @Date 2024/4/23 12:07 + */ +@Slf4j +@Data +@Service +public class SX2023ApiRemoteService implements ApiRemoteService { + + @Autowired + private RedisUtil redisUtil; + @Autowired + private ApiCommonService apiCommonService; + @Autowired + private ApiTriggerService apiTriggerService; + @Autowired + private ApiLogRep apiLogRep; + + @Override + public String getProtocol() { + return PushProtocol.SB_SX_2023.getCode(); + } + + @Override + public ResponseDto pushData(ApiParam param, Object data) { + return pushData(param, null, data); + } + + @Override + public ResponseDto pushData(ApiParam param, ApiConfs conf, Object data) { + String inteId = param.getInteId(); + String kqdm = param.getKqdm(); + + try { + if (null == conf) { + conf = apiCommonService.getConf(kqdm); + } + + //娣诲姞鏃ュ織 + ApiLog apiLog = new ApiLog(); + apiLog.setId(ContextUtil.getUUID()); + apiLog.setInteId(inteId); + if (StringUtils.isEmpty(inteId)) { + ResponseDto responseDto = new ResponseDto(99, "娌℃湁鑾峰彇鍒版帴鍙�"); + apiLog.setStatus(99); + apiLog.setResult("娌℃湁鑾峰彇鍒版帴鍙�"); + apiLogRep.save(apiLog); + return responseDto; + } + + if (conf == null) { + ResponseDto responseDto = new ResponseDto(99, "娌℃湁鑾峰彇鍒颁笂浼犻厤缃�"); + apiLog.setStatus(99); + apiLog.setResult("娌℃湁鑾峰彇鍒颁笂浼犻厤缃�"); + apiLogRep.save(apiLog); + return responseDto; + } + + List<Map<String, Object>> listData = getListData(param.getInteId(), data, conf); + log.info("鎺ュ彛鏁版嵁淇℃伅=" + listData); + apiLog.setData(listData.toString()); + apiLog.setKqdm(kqdm); + apiLog.setUploadTime(new Date()); + + //鑾峰彇鎸囦护id + String key = RedisConst.buildKey(RedisConst.KYE_ORDER, conf.getKqdm()); + String orderId = (String) redisUtil.get(key); + if (StringUtils.isEmpty(orderId)) { + log.error("鎸囦护id澶辨晥"); + ResponseDto responseDto = new ResponseDto(99, "鎸囦护id澶辨晥"); + apiLog.setStatus(99); + apiLog.setResult("鎸囦护id澶辨晥"); + apiLogRep.save(apiLog); + return responseDto; + } + + //灏佽鎺ㄩ�佹暟鎹� + SX2023ReqDto reqData = new SX2023ReqDto(); + //鎶ユ枃鏍囪瘑 + reqData.setID(orderId); + //鐗堟湰鍙� + reqData.setVER("1.0"); + //鍗曚綅缂栫爜锛�11浣� + reqData.setOrgNo(conf.getUserName()); + //鍗曚綅鍚嶇О + reqData.setOrgName(conf.getKqmc()); + //鍙戣捣鏃堕棿 + reqData.setSendTime(new Date()); + //18浣嶅崟浣嶄唬鐮� + reqData.setDwdm(conf.getKqdm().substring(0, 18)); + //鍔犲瘑鏁版嵁涓讳綋 + reqData.setBody(SXAESUtils.encryptByAES(conf.getPublicKey(), JSON.toJSONString(listData))); + log.debug("涓婃姤鏁版嵁淇℃伅=" + JSON.toJSONString(reqData)); + String resp = SX2023HttpClientUtil.postPushData(conf.getApiUrl(), JSON.toJSONString(reqData)); + if (StringUtils.isEmpty(resp)) { + log.error("鏁版嵁涓婁紶闄曡タ鐪佸钩鍙板け璐ワ紝鏁版嵁={}", reqData); + ResponseDto responseDto = new ResponseDto(99, "鏁版嵁涓婁紶闄曡タ鐪佸钩鍙板け璐�"); + apiLog.setStatus(99); + apiLog.setResult("鏁版嵁涓婁紶闄曡タ鐪佸钩鍙板け璐�"); + apiLogRep.save(apiLog); + return responseDto; + } + resp = SXAESUtils.decryptByAES(conf.getPassword(), resp); + SX2023RespDto sx2023RespDto = JSONObject.parseObject(JSONObject.toJSONString(resp), SX2023RespDto.class); + + if (null == sx2023RespDto || null == sx2023RespDto.getMsgBody()) { + log.error("鏁版嵁涓婁紶闄曡タ鐪佸钩鍙板け璐ワ紝鏁版嵁={}", reqData); + ResponseDto responseDto = new ResponseDto(99, "鏁版嵁涓婁紶闄曡タ鐪佸钩鍙板け璐�"); + apiLog.setStatus(99); + apiLog.setResult("鏁版嵁涓婁紶闄曡タ鐪佸钩鍙板け璐�"); + apiLogRep.save(apiLog); + return responseDto; + } + + SX2023Dto result = JSONObject.parseObject(JSONObject.toJSONString(sx2023RespDto.getMsgBody()), SX2023Dto.class); + apiLog.setStatus(result.getCode().equals("200") ? 0 : Integer.valueOf(result.getCode())); + apiLog.setResult(result.getVER()); + apiLogRep.save(apiLog); + ResponseDto resd = new ResponseDto(); + resd.setSuccess(result.getCode().equals("200") ? 0 : Integer.valueOf(result.getCode())); + resd.setMsg(result.getVER()); + + return resd; + } catch (Exception e) { + log.error(e.getMessage(), e); + return new ResponseDto(99, e.getMessage()); + } + } + + /** + * 鎷夊彇鏁版嵁鎺ュ彛-褰撳墠鍗忚鏆傛棤瀹炵幇 + * @param param 鍙傛暟 + * @param conf 閰嶇疆锛屽彲浠ヤ负绌� + * @return + */ + @Override + public ResponseDto pullData(ApiParam param, ApiConfs conf) { + log.error("闄曡タ鐪佸钩鍙版殏鏃犳暟鎹叡浜帴鍙o紝鏃犳硶鎷夊彇鏁版嵁锛�"); + return null; + } + + /** + * 鎺ュ彛鏁版嵁灏佽 + * @param inteId + * @param data + * @param conf + * @return + */ + private List<Map<String, Object>> getListData(String inteId, Object data, ApiConfs conf) { + List<Map<String, Object>> result = new ArrayList<>(); + Map<String, Object> map = new HashMap<>(); + String inteIdUrl = getInteId(inteId); + //鑻ヤ负璐㈠姟1501銆�1502銆�1503鎺ュ彛锛屽垯鎺ュ彛缂栫爜濉啓1114 + if (Constant.API_CODE_1114_1501.equals(inteId) + || Constant.API_CODE_1114_1502.equals(inteId) + || Constant.API_CODE_1114_1503.equals(inteId)) { + List<SXFinanceDto> list = getFinanceData(inteId, data); + map.put(inteIdUrl, list); + } else { + List<Object> list = new ArrayList<>(); + Object object = getApiData(inteId, data, conf); + //闄ゅ簱瀛樻帴鍙e锛屽叾浠栨帴鍙d笂浼犲墠鏇存柊鏈�鍚庢洿鏂版椂闂� + if (!Constant.API_CODE_1208.equals(inteId)) { + setZhgxsjValue(data); + } + list.add(object); + map.put(inteIdUrl, list); + } + result.add(map); + return result; + } + + /** + * 甯歌鎺ュ彛鏁版嵁灏佽 + * @param inteId + * @param data + * @return + */ + private Object getApiData(String inteId, Object data, ApiConfs conf) { + if (Constant.API_CODE_1101.equals(inteId)) { + SX2023Api1101 apiData = new SX2023Api1101(); + BeanUtils.copyProperties(data, apiData); + //璁剧疆鍗曚綅缂栫爜锛�11浣�(浠庨厤缃俊鎭幏鍙�) + apiData.setDWBM(conf.getUserName()); + return apiData; + } + if (Constant.API_CODE_1102.equals(inteId)) { + + return null; + } + if (Constant.API_CODE_1103.equals(inteId)) { + + return null; + } + if (Constant.API_CODE_1104.equals(inteId)) { + + return null; + } + if (Constant.API_CODE_1105.equals(inteId)) { + + return null; + } + if (Constant.API_CODE_1106.equals(inteId)) { + + return null; + } + if (Constant.API_CODE_1107.equals(inteId)) { + + return null; + } + if (Constant.API_CODE_1108.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1109.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1110.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1111.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1112.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1113.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1201.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1202.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1203.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1204.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1205.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1206.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1207.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1208.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1209.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1210.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1211.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1212.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1301.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1302.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1303.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1304.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1305.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1306.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1307.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1308.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1309.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1310.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1401.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1403.equals(inteId)) { + return null; + } + if (Constant.API_CODE_1404.equals(inteId)) { + return null; + } + return data; + } + + /** + * 鏈�鍚庢洿鏂版椂闂达紝璧嬪�间负褰撳墠鏃堕棿 + * @param object + * @return + */ + private Object setZhgxsjValue(Object object) { + // 浣跨敤鍙嶅皠鑾峰彇灞炴�у垪琛� vo涓哄疄浣撳璞″悕 + try { + Field zhgxsj = object.getClass().getDeclaredField("zhgxsj"); + zhgxsj.setAccessible(true); + zhgxsj.set(object, DateUtils.addSeconds(new Date(), -10)); + } catch (Exception e) { + e.printStackTrace(); + } + return object; + } + + /** + * 鑾峰彇璐㈠姟灏佽鏁版嵁 + * @param inteId + * @param data + * @return + */ + private List<SXFinanceDto> getFinanceData(String inteId, Object data) { + //璐㈠姟鎶ヨ〃鏁版嵁灏佽 + if (Constant.API_CODE_1114_1501.equals(inteId)) { + return copyApi1501((Api1501) data); + } else if (Constant.API_CODE_1114_1502.equals(inteId)) { + return copyApi1502((Api1502) data); + } else { + return copyApi1503((Api1503) data); + } + } + + /** + * 灏佽1501-璧勪骇璐熷�烘暟鎹� + * @param api1503 + * @return + */ + private List<SXFinanceDto> copyApi1503(Api1503 api1503) { + List<SXFinanceDto> list = new ArrayList<>(); + SXFinanceDto SXFinanceDto = new SXFinanceDto(); + SXFinanceDto.setDWDM(api1503.getDwdm()); + SXFinanceDto.setKQDM(api1503.getKqdm()); + SXFinanceDto.setBBSJ(DateFormatUtils.format(api1503.getBbsj(), "yyyyMMdd")); + SXFinanceDto.setBBM("03"); + SXFinanceDto.setCZBZ(api1503.getCzbz()); + SXFinanceDto.setZHGXSJ(DateFormatUtils.format(DateUtils.addSeconds(new Date(), -10), "yyyy-MM-dd HH:mm:ss")); + + paddingData(SXFinanceDto, list, "0", "椤圭洰//t", "鏈湡閲戦//t", "鏈勾绱//t"); + paddingData(SXFinanceDto, list, "1", "涓�銆佽惀涓氭敹鍏�", api1503.getYyzsrbqye() + "", api1503.getYyzsrbnlj() + ""); + paddingData(SXFinanceDto, list, "2", "鍑忥細钀ヤ笟鎴愭湰", api1503.getYycbbqye() + "", api1503.getYycbbnlj() + ""); + paddingData(SXFinanceDto, list, "3", "绋庨噾鍙婇檮鍔�", api1503.getSjjfjbqye() + "", api1503.getSjjfjbnlj() + ""); + paddingData(SXFinanceDto, list, "4", "閿�鍞垂鐢�", api1503.getXsfybqye() + "", api1503.getXsfybnlj() + ""); + paddingData(SXFinanceDto, list, "5", "绠$悊璐圭敤", api1503.getGlfybqye() + "", api1503.getGlfybnlj() + ""); + paddingData(SXFinanceDto, list, "6", "鐮斿彂璐圭敤", api1503.getYffybqye() + "", api1503.getYffybnlj() + ""); + paddingData(SXFinanceDto, list, "7", "璐㈠姟璐圭敤", api1503.getCwfybqye() + "", api1503.getCwfybnlj() + ""); + paddingData(SXFinanceDto, list, "8", "鍏朵腑锛氬埄鎭垂鐢�", api1503.getLxfybqye() + "", api1503.getLxfybnlj() + ""); + paddingData(SXFinanceDto, list, "9", "鍒╂伅鏀跺叆", api1503.getLxsrbqye() + "", api1503.getLxsrbnlj() + ""); + paddingData(SXFinanceDto, list, "10", "鍔狅細鍏朵粬鏀剁泭", api1503.getQtsybqye() + "", api1503.getQtsybnlj() + ""); + paddingData(SXFinanceDto, list, "11", "鎶曡祫鏀剁泭锛堟崯澶变互鈥�-鈥濆彿濉垪锛�", api1503.getTzsybqye() + "", api1503.getTzsybnlj() + ""); + paddingData(SXFinanceDto, list, "12", "鍏朵腑锛氬鑱旇惀浼佷笟鍜屽悎钀ヤ紒涓氱殑鎶曡祫鏀剁泭", api1503.getLyqytzsybqye() + "", api1503.getLyqytzsybnlj() + ""); + paddingData(SXFinanceDto, list, "13", "鍏厑浠峰�煎彉鍔ㄦ敹鐩婏紙鎹熷け浠モ��-鈥濆彿濉垪锛�", api1503.getGyjzbdsybqye() + "", api1503.getGyjzbdsybnlj() + ""); + paddingData(SXFinanceDto, list, "14", "璧勪骇鍑忓�兼崯澶憋紙鎹熷け浠モ��-鈥濆彿濉垪锛�", api1503.getZcjzssbqye() + "", api1503.getZcjzssbnlj() + ""); + paddingData(SXFinanceDto, list, "15", "璧勪骇澶勭疆鏀剁泭锛堟崯澶变互鈥�-鈥濆彿濉垪锛�", api1503.getZcczsybqye() + "", api1503.getZcczsybnlj() + ""); + paddingData(SXFinanceDto, list, "16", "浜屻�佽惀涓氬埄娑︼紙浜忔崯浠モ��-鈥濆彿濉垪锛�", api1503.getYylrbqye() + "", api1503.getYylrbnlj() + ""); + paddingData(SXFinanceDto, list, "17", "鍔狅細钀ヤ笟澶栨敹鍏�", api1503.getYywsrbqye() + "", api1503.getYywsrbnlj() + ""); + paddingData(SXFinanceDto, list, "18", "鍑忥細钀ヤ笟澶栨敮鍑�", api1503.getYywzcbqye() + "", api1503.getYywzcbnlj() + ""); + paddingData(SXFinanceDto, list, "19", "涓夈�佸埄娑︽�婚锛堜簭鎹熸�婚浠モ��-鈥濆彿濉垪锛�", api1503.getLrzebqye() + "", api1503.getLrzebnlj() + ""); + paddingData(SXFinanceDto, list, "20", "鍑忥細鎵�寰楃◣璐圭敤", api1503.getSdsfybqye() + "", api1503.getSdsfybnlj() + ""); + paddingData(SXFinanceDto, list, "21", "鍥涖�佸噣鍒╂鼎锛堝噣浜忔崯浠モ��-鈥濆彿濉垪锛�", api1503.getJlrbqye() + "", api1503.getJlrbnlj() + ""); + paddingData(SXFinanceDto, list, "22", "锛堜竴锛夋寔缁粡钀ュ噣鍒╂鼎锛堝噣浜忔崯浠モ��-鈥濆彿濉垪锛�", api1503.getCxjyjlrbqye() + "", api1503.getCxjyjlrbnlj() + ""); + paddingData(SXFinanceDto, list, "23", "锛堜簩锛夌粓姝㈢粡钀ュ噣鍒╂鼎锛堝噣浜忔崯浠モ��-鈥濆彿濉垪锛�", api1503.getZzjyjlrbqye() + "", api1503.getZzjyjlrbnlj() + ""); + paddingData(SXFinanceDto, list, "24", "浜斻�佸叾浠栫患鍚堟敹鐩婄殑绋庡悗鍑�棰�", api1503.getQtzhsyjebqye() + "", api1503.getQtzhsyjebnlj() + ""); + paddingData(SXFinanceDto, list, "25", "锛堜竴锛変笉鑳介噸鍒嗙被杩涙崯鐩婄殑鍏朵粬缁煎悎鏀剁泭", api1503.getBnflzhsybqye() + "", api1503.getBnflzhsybnlj() + ""); + paddingData(SXFinanceDto, list, "26", "1锛庨噸鏂拌閲忚瀹氬彈鐩婅鍒掑彉鍔ㄩ", api1503.getCxjlbdebqye() + "", api1503.getCxjlbdebnlj() + ""); + paddingData(SXFinanceDto, list, "27", "锛堜簩锛夊皢閲嶅垎绫昏繘鎹熺泭鐨勫叾浠栫患鍚堟敹鐩�", "0", "0"); + paddingData(SXFinanceDto, list, "28", "1锛庢潈鐩婃硶涓嬪彲杞崯鐩婄殑鍏朵粬缁煎悎鏀剁泭", api1503.getQyfkzsybqye() + "", api1503.getQyfkzsybnlj() + ""); + paddingData(SXFinanceDto, list, "29", "2锛庡彲渚涘嚭鍞噾铻嶈祫浜у叕鍏佷环鍊煎彉鍔ㄦ崯鐩�", api1503.getKgcszcbdsybqye() + "", api1503.getKgcszcbdsybnlj() + ""); + paddingData(SXFinanceDto, list, "30", "3锛庢寔鏈夎嚦鍒版湡鎶曡祫閲嶅垎绫讳负鍙緵鍑哄敭閲戣瀺璧勪骇鎹熺泭", api1503.getCydqtzzcsybqye() + "", api1503.getKgcszcbdsybnlj() + ""); + paddingData(SXFinanceDto, list, "31", "4锛庣幇閲戞祦閲忓鏈熸崯鐩婄殑鏈夋晥閮ㄥ垎", api1503.getZjllsybqye() + "", api1503.getZjllsybnlj() + ""); + paddingData(SXFinanceDto, list, "32", "5锛庡甯佽储鍔℃姤琛ㄦ姌绠楀樊棰�", api1503.getWbcwbbcebqye() + "", api1503.getWbcwbbcebnlj() + ""); + paddingData(SXFinanceDto, list, "33", "鍏�佺患鍚堟敹鐩婃�婚", api1503.getZhsyzebqye() + "", api1503.getZhsyzebnlj() + ""); + paddingData(SXFinanceDto, list, "34", "涓冦�佹瘡鑲℃敹鐩婏細", api1503.getMgsybqye() + "", api1503.getMgsybnlj() + ""); + paddingData(SXFinanceDto, list, "35", "锛堜竴锛夊熀鏈瘡鑲℃敹鐩�", api1503.getJbmgsybqye() + "", api1503.getJbmgsybnlj() + ""); + paddingData(SXFinanceDto, list, "36", "锛堜簩锛夌█閲婃瘡鑲℃敹鐩�", api1503.getXsmgsybqye() + "", api1503.getXsmgsybnlj() + ""); + + return list; + } + + /** + * 灏佽1502-鐜伴噾娴佹暟鎹� + * @param api1502 + * @return + */ + private List<SXFinanceDto> copyApi1502(Api1502 api1502) { + List<SXFinanceDto> list = new ArrayList<>(); + SXFinanceDto SXFinanceDto = new SXFinanceDto(); + SXFinanceDto.setDWDM(api1502.getDwdm()); + SXFinanceDto.setKQDM(api1502.getKqdm()); + SXFinanceDto.setBBSJ(DateFormatUtils.format(api1502.getBbsj(), "yyyyMMdd")); + SXFinanceDto.setBBM("02"); + SXFinanceDto.setCZBZ(api1502.getCzbz()); + SXFinanceDto.setZHGXSJ(DateFormatUtils.format(DateUtils.addSeconds(new Date(), -10), "yyyy-MM-dd HH:mm:ss")); + + paddingData(SXFinanceDto, list, "0", "椤圭洰//t", "鏈湀鏁�//t", "鏈勾绱鏁�//t"); + paddingData(SXFinanceDto, list, "1", "涓�銆佺粡钀ユ椿鍔ㄤ骇鐢熺殑鐜伴噾娴侀噺锛�", api1502.getJyhdxjllbys() + "", api1502.getJyhdxjllbnljs() + ""); + paddingData(SXFinanceDto, list, "2", "閿�鍞晢鍝併�佹彁渚涘姵鍔℃敹鍒扮殑鐜伴噾", api1502.getXssplwxjbys() + "", api1502.getXssplwxjbnljs() + ""); + paddingData(SXFinanceDto, list, "3", "鏀跺埌鐨勭◣璐硅繑杩�", api1502.getSffhbys() + "", api1502.getSffhbnljs() + ""); + paddingData(SXFinanceDto, list, "4", "鏀跺埌鍏朵粬涓庣粡钀ユ椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getQtjyhdxjbys() + "", api1502.getQtjyhdxjbnljs() + ""); + paddingData(SXFinanceDto, list, "5", "缁忚惀娲诲姩鐜伴噾娴佸叆灏忚", api1502.getJyhdxjlrbys() + "", api1502.getJyhdxjlrbnljs() + ""); + paddingData(SXFinanceDto, list, "6", "璐拱鍟嗗搧銆佹帴鍙楀姵鍔℃敮浠樼殑鐜伴噾", api1502.getGmsplwzfbys() + "", api1502.getGmsplwzfbnljs() + ""); + paddingData(SXFinanceDto, list, "7", "鏀粯缁欒亴宸ヤ互鍙婁负鑱屽伐鏀粯鐨勭幇閲�", api1502.getZfzgxjbys() + "", api1502.getZfzgxjbnljs() + ""); + paddingData(SXFinanceDto, list, "8", "鏀粯鐨勫悇椤圭◣璐�", api1502.getZfxxsfbys() + "", api1502.getZfxxsfbnljs() + ""); + paddingData(SXFinanceDto, list, "9", "鏀粯鍏朵粬涓庣粡钀ユ椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getZfqtjyhdxjbys() + "", api1502.getZfqtjyhdxjbnljs() + ""); + paddingData(SXFinanceDto, list, "10", "缁忚惀娲诲姩鐜伴噾娴佸嚭灏忚", api1502.getJyhdxjlcbys() + "", api1502.getJyhdxjlcbnljs() + ""); + paddingData(SXFinanceDto, list, "11", "缁忚惀娲诲姩浜х敓鐨勭幇閲戞祦閲忓噣棰�", api1502.getJyhdxjlljebys() + "", api1502.getJyhdxjlljebnljs() + ""); + paddingData(SXFinanceDto, list, "12", "浜屻�佹姇璧勬椿鍔ㄤ骇鐢熺殑鐜伴噾娴侀噺锛�", api1502.getTzhdxjllbys() + "", api1502.getTzhdxjllbnljs() + ""); + paddingData(SXFinanceDto, list, "13", "鏀跺洖鎶曡祫鏀跺埌鐨勭幇閲�", api1502.getShtzxjbys() + "", api1502.getShtzxjbnljs() + ""); + paddingData(SXFinanceDto, list, "14", "鍙栧緱鎶曡祫鏀剁泭鏀跺埌鐨勭幇閲�", api1502.getQdtzsyxjbys() + "", api1502.getQdtzsyxjbnljs() + ""); + paddingData(SXFinanceDto, list, "15", "澶勭疆鍥哄畾璧勪骇銆佹棤褰㈣祫浜у拰鍏朵粬闀挎湡璧勪骇鏀跺洖鐨勭幇閲戝噣棰�", api1502.getCzgdzcdxjjebys() + "", api1502.getCzgdzcdxjjebnljs() + ""); + paddingData(SXFinanceDto, list, "16", "澶勭疆瀛愬叕鍙稿強鍏朵粬钀ヤ笟鍗曚綅鏀跺埌鐨勭幇閲戝噣棰�", api1502.getCzqtdwxjjebys() + "", api1502.getCzqtdwxjjebnljs() + ""); + paddingData(SXFinanceDto, list, "17", "鏀跺埌鍏朵粬涓庢姇璧勬椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getSdqttzxjbys() + "", api1502.getSdqttzxjbnljs() + ""); + paddingData(SXFinanceDto, list, "18", "鎶曡祫娲诲姩鐜伴噾娴佸叆灏忚", api1502.getTzhdxjlrbys() + "", api1502.getTzhdxjlrbnljs() + ""); + paddingData(SXFinanceDto, list, "19", "璐缓鍥哄畾璧勪骇銆佹棤褰㈣祫浜у拰鍏朵粬闀挎湡璧勪骇鏀粯鐨勭幇閲�", api1502.getGjgdzcdxjbys() + "", api1502.getGjgdzcdxjbnljs() + ""); + paddingData(SXFinanceDto, list, "20", "鎶曡祫鏀粯鐨勭幇閲�", api1502.getTzzfxjbys() + "", api1502.getTzzfxjbnljs() + ""); + paddingData(SXFinanceDto, list, "21", "鍙栧緱瀛愬叕鍙稿強鍏朵粬钀ヤ笟鍗曚綅鏀粯鐨勭幇閲戝噣棰�", api1502.getQdzgsdzfxjjebys() + "", api1502.getQdzgsdzfxjjebnljs() + ""); + paddingData(SXFinanceDto, list, "22", "鏀粯鍏朵粬涓庢姇璧勬椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getZfqttzxjbys() + "", api1502.getZfqttzxjbnljs() + ""); + paddingData(SXFinanceDto, list, "23", "鎶曡祫娲诲姩鐜伴噾娴佸嚭灏忚", api1502.getTzhdxjlcbys() + "", api1502.getTzhdxjlcbnljs() + ""); + paddingData(SXFinanceDto, list, "24", "鎶曡祫娲诲姩浜х敓鐨勭幇閲戞祦閲忓噣棰�", api1502.getTzhdcsxjlljebys() + "", api1502.getTzhdcsxjlljebnljs() + ""); + paddingData(SXFinanceDto, list, "25", "涓夈�佺璧勬椿鍔ㄤ骇鐢熺殑鐜伴噾娴侀噺锛�", api1502.getCchdxjllbys() + "", api1502.getCchdxjllbnljs() + ""); + paddingData(SXFinanceDto, list, "26", "鍚告敹鎶曡祫鏀跺埌鐨勭幇閲�", api1502.getXstzxjbys() + "", api1502.getXstzxjbnljs() + ""); + paddingData(SXFinanceDto, list, "27", "鍙栧緱鍊熸鏀跺埌鐨勭幇閲�", api1502.getQdjkxjbys() + "", api1502.getQdjkxjbnljs() + ""); + paddingData(SXFinanceDto, list, "28", "鏀跺埌鍏朵粬涓庣璧勬椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getSdqtczxjbys() + "", api1502.getSdqttzxjbnljs() + ""); + paddingData(SXFinanceDto, list, "29", "绛硅祫娲诲姩鐜伴噾娴佸叆灏忚", api1502.getCzhdxjlrbys() + "", api1502.getCzhdxjlrbnljs() + ""); + paddingData(SXFinanceDto, list, "30", "鍋胯繕鍊哄姟鏀粯鐨勭幇閲�", api1502.getChzwzfxjbys() + "", api1502.getChzwzfxjbnljs() + ""); + paddingData(SXFinanceDto, list, "31", "鍒嗛厤鑲″埄銆佸埄娑︽垨鍋夸粯鍒╂伅鏀粯鐨勭幇閲�", api1502.getFpgldxjbys() + "", api1502.getFpgldxjbnljs() + ""); + paddingData(SXFinanceDto, list, "32", "鏀粯鍏朵粬涓庣璧勬椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getZfqtdxjbys() + "", api1502.getZfqtdxjbnljs() + ""); + paddingData(SXFinanceDto, list, "33", "绛硅祫娲诲姩鐜伴噾娴佸嚭灏忚", api1502.getCzhdxjlcbys() + "", api1502.getCzhdxjlcbnljs() + ""); + paddingData(SXFinanceDto, list, "34", "绛硅祫娲诲姩浜х敓鐨勭幇閲戞祦閲忓噣棰�", api1502.getCchdxjlljebys() + "", api1502.getCchdxjlljebnljs() + ""); + paddingData(SXFinanceDto, list, "35", "鍥涖�佹眹鐜囧彉鍔ㄥ鐜伴噾鍙婄幇閲戠瓑浠风墿鐨勫奖鍝�", api1502.getHlbdxjyxbys() + "", api1502.getHlbdxjyxbnljs() + ""); + paddingData(SXFinanceDto, list, "36", "浜斻�佺幇閲戝強鐜伴噾绛変环鐗╁噣澧炲姞棰�", api1502.getXjdjwjzebys() + "", api1502.getXjdjwjzebnljs() + ""); + paddingData(SXFinanceDto, list, "37", "鍔狅細鏈熷垵鐜伴噾鍙婄幇閲戠瓑浠风墿浣欓", api1502.getQcxjdjwyebys() + "", api1502.getQcxjdjwyebnljs() + ""); + paddingData(SXFinanceDto, list, "38", "鍏�佹湡鏈幇閲戝強鐜伴噾绛変环鐗╀綑棰�", api1502.getQmxjdjwyebys() + "", api1502.getQmxjdjwyebnljs() + ""); + + return list; + } + + /** + * 灏佽1503-鍒╂鼎琛ㄦ暟鎹� + * @param api1501 + * @return + */ + private List<SXFinanceDto> copyApi1501(Api1501 api1501) { + List<SXFinanceDto> list = new ArrayList<>(); + SXFinanceDto SXFinanceDto = new SXFinanceDto(); + SXFinanceDto.setDWDM(api1501.getDwdm()); + SXFinanceDto.setKQDM(api1501.getKqdm()); + SXFinanceDto.setBBSJ(DateFormatUtils.format(api1501.getBbsj(), "yyyyMMdd")); + SXFinanceDto.setBBM("01"); + SXFinanceDto.setCZBZ(api1501.getCzbz()); + SXFinanceDto.setZHGXSJ(DateFormatUtils.format(DateUtils.addSeconds(new Date(), -10), "yyyy-MM-dd HH:mm:ss")); + + paddingData(SXFinanceDto, list, "0", "璧勪骇//t", "鏈熸湯浣欓//t", "骞村垵浣欓//t"); + paddingData(SXFinanceDto, list, "1", "娴佸姩璧勪骇锛�", api1501.getLdzchjqmye() + "", api1501.getLdzchjncye() + ""); + paddingData(SXFinanceDto, list, "2", "璐у竵璧勯噾", api1501.getHbjjqmye() + "", api1501.getHbjjncye() + ""); + paddingData(SXFinanceDto, list, "3", "浜ゆ槗鎬ч噾铻嶈祫浜�", api1501.getJyxjrzcqmye() + "", api1501.getJyxjrzcncye() + ""); + paddingData(SXFinanceDto, list, "4", "琛嶇敓閲戣瀺璧勪骇", api1501.getYsjrzcqmye() + "", api1501.getYsjrzcncye() + ""); + paddingData(SXFinanceDto, list, "5", "搴旀敹绁ㄦ嵁", api1501.getYspjqmye() + "", api1501.getYspjncye() + ""); + paddingData(SXFinanceDto, list, "6", "搴旀敹璐︽", api1501.getYszkqmye() + "", api1501.getYszkncye() + ""); + paddingData(SXFinanceDto, list, "7", "棰勪粯娆鹃」", api1501.getYuskxqmye() + "", api1501.getYuskxncye() + ""); + paddingData(SXFinanceDto, list, "8", "鍏朵粬搴旀敹娆�", api1501.getQtyszkqmye() + "", api1501.getQtyszkncye() + ""); + paddingData(SXFinanceDto, list, "9", "瀛樿揣", api1501.getChqmye() + "", api1501.getChncye() + ""); + paddingData(SXFinanceDto, list, "10", "鍚堝悓璧勪骇", api1501.getHtzcqmye() + "", api1501.getHtzcncye() + ""); + paddingData(SXFinanceDto, list, "11", "鎸佹湁寰呭敭璧勪骇", api1501.getCydszcqmye() + "", api1501.getCydszcncye() + ""); + paddingData(SXFinanceDto, list, "12", "涓�骞村唴鍒版湡鐨勯潪娴佸姩璧勪骇", api1501.getYnndqfldzcqmye() + "", api1501.getYnndqfldzcncye() + ""); + paddingData(SXFinanceDto, list, "13", "鍏朵粬娴佸姩璧勪骇", api1501.getQtldzcqmye() + "", api1501.getQtldzcncye() + ""); + paddingData(SXFinanceDto, list, "14", "娴佸姩璧勪骇鍚堣", api1501.getLdzchjqmye() + "", api1501.getLdzchjncye() + ""); + paddingData(SXFinanceDto, list, "15", "闈炴祦鍔ㄨ祫浜э細", api1501.getFldzcqmye() + "", api1501.getFldzcncye() + ""); + paddingData(SXFinanceDto, list, "16", "鍊哄埜鎶曡祫", api1501.getZjtzqmye() + "", api1501.getZjtzncye() + ""); + paddingData(SXFinanceDto, list, "17", "鍏朵粬鍊哄埜鎶曡祫", api1501.getQtzqtzqmye() + "", api1501.getQtzqtzncye() + ""); + paddingData(SXFinanceDto, list, "18", "闀挎湡搴旀敹娆�", api1501.getCqyskqmye() + "", api1501.getCqyskncye() + ""); + paddingData(SXFinanceDto, list, "19", "闀挎湡鑲℃潈鎶曡祫", api1501.getCqgqtzqmye() + "", api1501.getCqgqtzncye() + ""); + paddingData(SXFinanceDto, list, "20", "鍏朵粬鏉冪泭宸ュ叿鎶曡祫", api1501.getQtqygjtzqmye() + "", api1501.getQtqygjtzncye() + ""); + paddingData(SXFinanceDto, list, "21", "鍏朵粬闈炴祦鍔ㄩ噾铻嶈祫浜�", api1501.getQtfldjrzcqmye() + "", api1501.getQtfldjrzcncye() + ""); + paddingData(SXFinanceDto, list, "22", "鎶曡祫鎬ф埧鍦颁骇", api1501.getTzxfdcqmye() + "", api1501.getTzxfdcncye() + ""); + paddingData(SXFinanceDto, list, "23", "鍥哄畾璧勪骇", api1501.getGdzcqmye() + "", api1501.getGdzcncye() + ""); + paddingData(SXFinanceDto, list, "24", "鍦ㄥ缓宸ョ▼", api1501.getZjgcqmye() + "", api1501.getZjgcncye() + ""); + paddingData(SXFinanceDto, list, "25", "鐢熶骇鎬х敓鐗╄祫浜�", api1501.getScxswzcqmye() + "", api1501.getScxswzcncye() + ""); + paddingData(SXFinanceDto, list, "26", "娌规皵璧勪骇", api1501.getYqzcqmye() + "", api1501.getYqzcncye() + ""); + paddingData(SXFinanceDto, list, "27", "鏃犲舰璧勪骇", api1501.getWxzcqmye() + "", api1501.getWxzcncye() + ""); + paddingData(SXFinanceDto, list, "28", "寮�鍙戞敮鍑�", api1501.getKfzcqmye() + "", api1501.getKfzcncye() + ""); + paddingData(SXFinanceDto, list, "29", "鍟嗚獕", api1501.getSyqmye() + "", api1501.getSyncye() + ""); + paddingData(SXFinanceDto, list, "30", "闀挎湡寰呮憡璐圭敤", api1501.getCqdtfyqmye() + "", api1501.getCqdtfyncye() + ""); + paddingData(SXFinanceDto, list, "31", "閫掑欢鎵�寰楃◣璧勪骇", api1501.getDysdszcqmye() + "", api1501.getDysdszcncye() + ""); + paddingData(SXFinanceDto, list, "32", "鍏朵粬闈炴祦鍔ㄨ祫浜�", api1501.getQtfldzcqmye() + "", api1501.getQtfldzcncye() + ""); + paddingData(SXFinanceDto, list, "33", "闈炴祦鍔ㄨ祫浜у悎璁�", api1501.getFldzcqmye() + "", api1501.getFldzcncye() + ""); + paddingData(SXFinanceDto, list, "34", "璧勪骇鎬昏", api1501.getZczjqmye() + "", api1501.getZczjncye() + ""); + paddingData(SXFinanceDto, list, "35", "璐熷�哄拰鎵�鏈夎�呮潈鐩婏紙鎴栬偂涓滄潈鐩婏級//t", "鏈熸湯浣欓//t", "骞村垵浣欓//t"); + paddingData(SXFinanceDto, list, "36", "娴佸姩璐熷�猴細", api1501.getLdfzhjqmye() + "", api1501.getLdfzhjncye() + ""); + paddingData(SXFinanceDto, list, "37", "鐭湡鍊熸", api1501.getDqjkqmye() + "", api1501.getLdzchjncye() + ""); + paddingData(SXFinanceDto, list, "38", "浜ゆ槗鎬ч噾铻嶈礋鍊�", api1501.getJyxjrfzqmye() + "", api1501.getJyxjrfzncye() + ""); + paddingData(SXFinanceDto, list, "39", "琛嶇敓閲戣瀺璐熷��", api1501.getYsjrfzqmye() + "", api1501.getYsjrfzncye() + ""); + paddingData(SXFinanceDto, list, "40", "搴斾粯绁ㄦ嵁", api1501.getLdfzyspjqmye() + "", api1501.getLdfzyspjncye() + ""); + paddingData(SXFinanceDto, list, "41", "搴斾粯璐︽", api1501.getLdfzyszkqmye() + "", api1501.getLdfzyszkncye() + ""); + paddingData(SXFinanceDto, list, "42", "棰勬敹娆鹃」", api1501.getLdfzyuskxqmye() + "", api1501.getLdfzyszkncye() + ""); + paddingData(SXFinanceDto, list, "43", "鍚堝悓璐熷��", api1501.getHtfzqmye() + "", api1501.getHtfzncye() + ""); + paddingData(SXFinanceDto, list, "44", "搴斾粯鑱屽伐钖叕", api1501.getYfzgxcqmye() + "", api1501.getYfzgxcncye() + ""); + paddingData(SXFinanceDto, list, "45", "搴斾氦绋庤垂", api1501.getYjsfqmye() + "", api1501.getYjsfncye() + ""); + paddingData(SXFinanceDto, list, "46", "鍏朵粬搴斾粯娆�", api1501.getQtyfkqmye() + "", api1501.getQtyfkncye() + ""); + paddingData(SXFinanceDto, list, "47", "鎸佹湁寰呭敭璐熷��", api1501.getCydsfzqmye() + "", api1501.getCydsfzncye() + ""); + paddingData(SXFinanceDto, list, "48", "涓�骞村唴鍒版湡鐨勯潪娴佸姩璐熷��", api1501.getYnddqfldfzqmye() + "", api1501.getYnddqfldfzncye() + ""); + paddingData(SXFinanceDto, list, "49", "鍏朵粬娴佸姩璐熷��", api1501.getQtldfzqmye() + "", api1501.getQtldfzncye() + ""); + paddingData(SXFinanceDto, list, "50", "娴佸姩璐熷�哄悎璁�", api1501.getLdfzhjqmye() + "", api1501.getLdfzhjncye() + ""); + paddingData(SXFinanceDto, list, "51", "闈炴祦鍔ㄨ礋鍊猴細", api1501.getFldfzhjqmye() + "", api1501.getFldfzhjncye() + ""); + paddingData(SXFinanceDto, list, "52", "闀挎湡鍊熸", api1501.getCqjkqmye() + "", api1501.getCqjkncye() + ""); + paddingData(SXFinanceDto, list, "53", "搴斾粯鍊哄埜", api1501.getYfzqqmye() + "", api1501.getYfzqncye() + ""); + paddingData(SXFinanceDto, list, "54", "鍏朵腑锛氫紭鍏堣偂", api1501.getYfzqyxgqmye() + "", api1501.getYfzqyxgncye() + ""); + paddingData(SXFinanceDto, list, "55", "姘哥画鍊�", api1501.getYfzqyxzqmye() + "", api1501.getYfzqyxzncye() + ""); + paddingData(SXFinanceDto, list, "56", "闀挎湡搴斾粯娆�", api1501.getCqyfkqmye() + "", api1501.getCqyfkncye() + ""); + paddingData(SXFinanceDto, list, "57", "棰勮璐熷��", api1501.getYjsfqmye() + "", api1501.getYjsfncye() + ""); + paddingData(SXFinanceDto, list, "58", "閫掑欢鏀剁泭", api1501.getDysyqmye() + "", api1501.getDysyncye() + ""); + paddingData(SXFinanceDto, list, "59", "閫掑欢鎵�寰楃◣璐熷��", api1501.getDysdsfzqmye() + "", api1501.getDysdsfzncye() + ""); + paddingData(SXFinanceDto, list, "60", "鍏朵粬闈炴祦鍔ㄨ礋鍊�", api1501.getQtfldfzqmye() + "", api1501.getQtfldfzncye() + ""); + paddingData(SXFinanceDto, list, "61", "闈炴祦鍔ㄨ礋鍊哄悎璁�", api1501.getFldfzhjqmye() + "", api1501.getFldfzhjncye() + ""); + paddingData(SXFinanceDto, list, "62", "璐熷�哄悎璁�", api1501.getFzhjqmye() + "", api1501.getFzhjncye() + ""); + paddingData(SXFinanceDto, list, "63", "鎵�鏈夎�呮潈鐩婏紙鎴栬偂涓滄潈鐩婏級锛�", api1501.getSyzqyqmye() + "", api1501.getSyzqyncye() + ""); + paddingData(SXFinanceDto, list, "64", "瀹炴敹璧勬湰锛堟垨鑲℃湰锛�", api1501.getSszbqmye() + "", api1501.getSszbncye() + ""); + paddingData(SXFinanceDto, list, "65", "鍏朵粬鏉冪泭宸ュ叿", api1501.getQtqygjqmye() + "", api1501.getQtqygjncye() + ""); + paddingData(SXFinanceDto, list, "66", "鍏朵腑锛氫紭鍏堣偂", api1501.getQtqygjyxgqmye() + "", api1501.getQtqygjyxgncye() + ""); + paddingData(SXFinanceDto, list, "67", "姘哥画鍊�", api1501.getQtqygjyxzqmye() + "", api1501.getQtqygjyxzncye() + ""); + paddingData(SXFinanceDto, list, "68", "璧勬湰鍏Н", api1501.getZbgjqmye() + "", api1501.getZbgjncye() + ""); + paddingData(SXFinanceDto, list, "69", "鍑忥細搴撳瓨鑲�", api1501.getJkcgqmye() + "", api1501.getJkcgncye() + ""); + paddingData(SXFinanceDto, list, "70", "鍏朵粬缁煎悎鏀剁泭", api1501.getQtzhsyqmye() + "", api1501.getQtzhsyncye() + ""); + paddingData(SXFinanceDto, list, "71", "涓撻」鍌ㄥ", api1501.getZxcbqmye() + "", api1501.getZxcbncye() + ""); + paddingData(SXFinanceDto, list, "72", "鐩堜綑鍏Н", api1501.getYygjqmye() + "", api1501.getYygjncye() + ""); + paddingData(SXFinanceDto, list, "73", "鏈垎閰嶅埄娑�", api1501.getWfplrqmye() + "", api1501.getWfplrncye() + ""); + paddingData(SXFinanceDto, list, "74", "鎵�鏈夎�呮潈鐩婏紙鎴栬偂涓滄潈鐩婏級鍚堣", api1501.getSyzqyqmye() + "", api1501.getSyzqyncye() + ""); + paddingData(SXFinanceDto, list, "75", "璐熷�哄拰鎵�鏈夎�呮潈鐩婏紙鎴栬偂涓滄潈鐩婏級鎬昏", api1501.getFzhsyzqyqmye() + "", api1501.getFzhsyzqyncye() + ""); + return list; + } + + /** + * 璐㈠姟鏁版嵁灏佽 + * @param common + * @param list + * @param zbxh + * @param zbmc + * @param zbz1 + * @param zbz2 + */ + private void paddingData(SXFinanceDto common, List<SXFinanceDto> list, String zbxh, String zbmc, String zbz1, String zbz2) { + SXFinanceDto SXFinanceDto = new SXFinanceDto(); + BeanUtils.copyProperties(common, SXFinanceDto); + SXFinanceDto.setZBXH(zbxh); + SXFinanceDto.setZBMC(zbmc); + SXFinanceDto.setZBZ1(zbz1); + SXFinanceDto.setZBZ2(zbz2); + list.add(SXFinanceDto); + } + + /** + * 鏍规嵁鎺ュ彛缂栫爜鑾峰彇瀵瑰簲鐨勬帴鍙f暟鎹簱琛ㄥ悕 + * @param inteId + * @return + */ + private String getInteId(String inteId) { + switch (inteId) { + case "1101": + return SX2023Constant.SX_2023_API_ODS_UP_DWXXJK; + case "1102": + return SX2023Constant.SX_2023_API_ODS_UP_KQXXJK; + case "1103": + return SX2023Constant.SX_2023_API_ODS_UP_CFXXJK; + case "1104": + return SX2023Constant.SX_2023_API_ODS_UP_AJXXJK; + case "1105": + return SX2023Constant.SX_2023_API_ODS_UP_HWXXJK; + case "1106": + return SX2023Constant.SX_2023_API_ODS_UP_YGXXJK; + case "1107": + return SX2023Constant.SX_2023_API_ODS_UP_SBXXJK; + case "1108": + return SX2023Constant.SX_2023_API_ODS_UP_YJXXJK; + case "1109": + return SX2023Constant.SX_2023_API_ODS_UP_WJXXJK; + case "1110": + return SX2023Constant.SX_2023_API_ODS_UP_KQTCFDWBZSJXXJK; + case "1111": + return SX2023Constant.SX_2023_API_ODS_UP_KQTSPJKSBDWBZSJXXJK; + case "1112": + return SX2023Constant.SX_2023_API_ODS_UP_RYXXJK; + case "1201": + return SX2023Constant.SX_2023_API_ODS_UP_HTXXJK; + case "1202": + return SX2023Constant.SX_2023_API_ODS_UP_LSRKXXJK; + case "1203": + return SX2023Constant.SX_2023_API_ODS_UP_LSRKJYXXJK; + case "1204": + return SX2023Constant.SX_2023_API_ODS_UP_LSRKJSXXJK; + case "1205": + return SX2023Constant.SX_2023_API_ODS_UP_LSCKXXJK; + case "1206": + return SX2023Constant.SX_2023_API_ODS_UP_LSCKJSXXJK; + case "1207": + return SX2023Constant.SX_2023_API_ODS_UP_DCXXJK; + case "1208": + return SX2023Constant.SX_2023_API_ODS_UP_LSKCXXJK; + case "1209": + return SX2023Constant.SX_2023_API_ODS_UP_SYDXXJK; + case "1210": + return SX2023Constant.SX_2023_API_ODS_UP_LSXZZBDXXJK; + case "1211": + return SX2023Constant.SX_2023_API_ODS_UP_ZMKCXXJK; + case "1212": + return SX2023Constant.SX_2023_API_ODS_UP_KHXXJK; + case "1301": + return SX2023Constant.SX_2023_API_ODS_UP_AQGLXXJK; + case "1302": + return SX2023Constant.SX_2023_API_ODS_UP_WSDJCXXJK; + case "1303": + return SX2023Constant.SX_2023_API_ODS_UP_CHJCXXJK; + case "1304": + return SX2023Constant.SX_2023_API_ODS_UP_QTJCXXJK; + case "1305": + return SX2023Constant.SX_2023_API_ODS_UP_TFZYXXJK; + case "1306": + return SX2023Constant.SX_2023_API_ODS_UP_XZZYXXJK; + case "1307": + return SX2023Constant.SX_2023_API_ODS_UP_CNSPTXXXJK; + case "1308": + return SX2023Constant.SX_2023_API_ODS_UP_SPJKYCSJGJJBXXJK; + case "1309": + return SX2023Constant.SX_2023_API_ODS_UP_WGYJXXJK; + case "1310": + return SX2023Constant.SX_2023_API_ODS_UP_ZJXXJK; + case "1401": + return SX2023Constant.SX_2023_API_ODS_UP_CBGMXXJK; + case "1403": + return SX2023Constant.SX_2023_API_ODS_UP_LHJHXXJK; + case "1404": + return SX2023Constant.SX_2023_API_ODS_UP_LHJHMXXXJK; + case "1501": + return SX2023Constant.SX_2023_API_ODS_UP_CWBBXXJK; + case "1502": + return SX2023Constant.SX_2023_API_ODS_UP_CWBBXXJK; + case "1503": + return SX2023Constant.SX_2023_API_ODS_UP_CWBBXXJK; + default: + return inteId; + } + } + +} diff --git a/src/main/java/com/fzzy/push/sx2023/SX2023Constant.java b/src/main/java/com/fzzy/push/sx2023/SX2023Constant.java new file mode 100644 index 0000000..3a56f5f --- /dev/null +++ b/src/main/java/com/fzzy/push/sx2023/SX2023Constant.java @@ -0,0 +1,164 @@ +package com.fzzy.push.sx2023; + +/** + * @Description 闄曡タ鐪佸钩鍙板父閲忕被 + * @Author CZT + * @Date 2024/4/23 14:05 + */ +public class SX2023Constant { + + /** + * ODS_UP_DWXXJK 鍗曚綅淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_DWXXJK = "ODS_UP_DWXXJK"; + /** + * ODS_UP_KQXXJK 搴撳尯淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_KQXXJK = "ODS_UP_KQXXJK"; + /** + * ODS_UP_CFXXJK 浠撴埧淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_CFXXJK = "ODS_UP_CFXXJK"; + /** + * ODS_UP_AJXXJK 寤掗棿淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_AJXXJK = "ODS_UP_AJXXJK"; + /** + * ODS_UP_HWXXJK 璐т綅淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_HWXXJK = "ODS_UP_HWXXJK"; + /** + * ODS_UP_YGXXJK 娌圭綈淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_YGXXJK = "ODS_UP_YGXXJK"; + /** + * ODS_UP_SBXXJK 璁惧淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_SBXXJK = "ODS_UP_SBXXJK"; + /** + * ODS_UP_YJXXJK 鑽墏淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_YJXXJK = "ODS_UP_YJXXJK"; + /** + * ODS_UP_WJXXJK 鏂囦欢淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_WJXXJK = "ODS_UP_WJXXJK"; + /** + * ODS_UP_KQTCFDWBZSJXXJK 搴撳尯鍥句粨鎴跨偣浣嶆爣娉ㄦ暟鎹帴鍙� + */ + public static String SX_2023_API_ODS_UP_KQTCFDWBZSJXXJK = "ODS_UP_KQTCFDWBZSJXXJK"; + /** + * ODS_UP_KQTSPJKSBDWBZSJXXJK 搴撳尯鍥捐棰戠洃鎺ц澶囩偣浣嶆爣娉ㄦ暟鎹帴鍙� + */ + public static String SX_2023_API_ODS_UP_KQTSPJKSBDWBZSJXXJK = "ODS_UP_KQTSPJKSBDWBZSJXXJK"; + /** + * ODS_UP_RYXXJK 浜哄憳淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_RYXXJK = "ODS_UP_RYXXJK"; + /** + * ODS_UP_CWBBXXJK 璐㈠姟鎶ヨ〃鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_CWBBXXJK = "ODS_UP_CWBBXXJK"; + + /** + * ODS_UP_HTXXJK 鍚堝悓淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_HTXXJK = "ODS_UP_HTXXJK"; + /** + * ODS_UP_LSRKXXJK 绮鍏ュ簱淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_LSRKXXJK = "ODS_UP_LSRKXXJK"; + /** + * ODS_UP_LSRKJYXXJK 绮鍏ュ簱妫�楠屼俊鎭暟鎹帴鍙� + */ + public static String SX_2023_API_ODS_UP_LSRKJYXXJK = "ODS_UP_LSRKJYXXJK"; + /** + * ODS_UP_LSRKJSXXJK 绮鍏ュ簱缁撶畻淇℃伅鏁版嵁鍙� + */ + public static String SX_2023_API_ODS_UP_LSRKJSXXJK = "ODS_UP_LSRKJSXXJK"; + /** + * ODS_UP_LSCKXXJK 绮鍑哄簱淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_LSCKXXJK = "ODS_UP_LSCKXXJK"; + /** + * ODS_UP_LSCKJSXXJK 绮鍑哄簱缁撶畻淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_LSCKJSXXJK = "ODS_UP_LSCKJSXXJK"; + /** + * ODS_UP_DCXXJK 鍊掍粨鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_DCXXJK = "ODS_UP_DCXXJK"; + /** + * ODS_UP_LSKCXXJK 绮搴撳瓨鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_LSKCXXJK = "ODS_UP_LSKCXXJK"; + /** + * ODS_UP_SYDXXJK 鎹熸孩鍗曟暟鎹帴鍙� + */ + public static String SX_2023_API_ODS_UP_SYDXXJK = "ODS_UP_SYDXXJK"; + /** + * ODS_UP_LSXZZBDXXJK 绮鎬ц川杞彉鍗曟暟鎹帴鍙� + */ + public static String SX_2023_API_ODS_UP_LSXZZBDXXJK = "ODS_UP_LSXZZBDXXJK"; + /** + * ODS_UP_ZMKCXXJK 璐﹂潰搴撳瓨鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_ZMKCXXJK = "ODS_UP_ZMKCXXJK"; + /** + * ODS_UP_KHXXJK 瀹㈡埛淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_KHXXJK = "ODS_UP_KHXXJK"; + + /** + * ODS_UP_AQGLXXJK 瀹夊叏绠$悊鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_AQGLXXJK = "ODS_UP_AQGLXXJK"; + /** + * ODS_UP_WSDJCXXJK 娓╂箍搴︽娴嬫暟鎹帴鍙� + */ + public static String SX_2023_API_ODS_UP_WSDJCXXJK = "ODS_UP_WSDJCXXJK"; + /** + * ODS_UP_CHJCXXJK 瀹宠櫕妫�娴嬫暟鎹帴鍙� + */ + public static String SX_2023_API_ODS_UP_CHJCXXJK = "ODS_UP_CHJCXXJK"; + /** + * ODS_UP_QTJCXXJK 姘斾綋妫�娴嬫暟鎹帴鍙� + */ + public static String SX_2023_API_ODS_UP_QTJCXXJK = "ODS_UP_QTJCXXJK"; + /** + * ODS_UP_TFZYXXJK 閫氶浣滀笟鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_TFZYXXJK = "ODS_UP_TFZYXXJK"; + /** + * ODS_UP_XZZYXXJK 鐔忚捀浣滀笟鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_XZZYXXJK = "ODS_UP_XZZYXXJK"; + /** + * ODS_UP_CNSPTXXXJK 浠撳唴瑙嗛鍥惧儚鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_CNSPTXXXJK = "ODS_UP_CNSPTXXXJK"; + /** + * ODS_UP_SPJKYCSJGJJBXXJK 瑙嗛鐩戞帶寮傚父浜嬩欢鍛婅鍩烘湰淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_SPJKYCSJGJJBXXJK = "ODS_UP_SPJKYCSJGJJBXXJK"; + /** + * ODS_UP_WGYJXXJK 杩濊棰勮淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_WGYJXXJK = "ODS_UP_WGYJXXJK"; + /** + * ODS_UP_ZJXXJK 璐ㄦ鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_ZJXXJK = "ODS_UP_ZJXXJK"; + /** + * ODS_UP_CBGMXXJK 鍌ㄥ瑙勬ā鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_CBGMXXJK = "ODS_UP_CBGMXXJK"; + /** + * ODS_UP_LHJHXXJK 杞崲璁″垝淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_LHJHXXJK = "ODS_UP_LHJHXXJK"; + /** + * ODS_UP_LHJHMXXXJK 杞崲璁″垝鏄庣粏淇℃伅鏁版嵁鎺ュ彛 + */ + public static String SX_2023_API_ODS_UP_LHJHMXXXJK = "ODS_UP_LHJHMXXXJK"; +} diff --git a/src/main/java/com/fzzy/push/sx2023/SX2023HttpClientUtil.java b/src/main/java/com/fzzy/push/sx2023/SX2023HttpClientUtil.java new file mode 100644 index 0000000..22020f8 --- /dev/null +++ b/src/main/java/com/fzzy/push/sx2023/SX2023HttpClientUtil.java @@ -0,0 +1,80 @@ +package com.fzzy.push.sx2023; + +import com.fzzy.push.sx2023.data.SX2023RespDto; +import lombok.extern.slf4j.Slf4j; + +import java.io.BufferedReader; +import java.io.InputStreamReader; +import java.io.OutputStream; +import java.net.HttpURLConnection; +import java.net.URL; + +/** + * @Description 闄曡タ鐪佸钩鍙�2023鐗�-鏁版嵁涓婁紶鏈嶅姟 + * @Author CZT + * @Date 2024/4/23 15:11 + */ +@Slf4j +public class SX2023HttpClientUtil { + + public static String postPushData(String url, String reqData) throws Exception { + log.debug("---------鎺ュ彛璇锋眰鍦板潃锛�" + url + "----------鍙傛暟锛�" + reqData + "---------"); + BufferedReader in = null; + URL urls = new URL(url); + HttpURLConnection connection = null; + OutputStream outputStream = null; + String rs = ""; + SX2023RespDto responseDto; + try { + + connection = (HttpURLConnection) urls.openConnection(); + connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); + connection.setDoOutput(true); + connection.setDoInput(true); + connection.setRequestProperty("Accept-Language", "zh-CN,zh;q=0.8"); + connection.setRequestProperty("Accept", "*/*"); + connection.setRequestProperty("Range", "bytes=" + ""); + connection.setConnectTimeout(20000); + connection.setReadTimeout(30000); + connection.setRequestMethod("POST"); + + outputStream = connection.getOutputStream(); + + outputStream.write(reqData.getBytes("UTF-8")); + try { + connection.connect(); + if (connection.getResponseCode() == 200) { + in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); + String line = ""; + while ((line = in.readLine()) != null) { + rs += line; + } + } else { + log.error("http鐘舵�侊細" + connection.getResponseCode()); + log.error("http娑堟伅锛�" + connection.getResponseMessage()); + } + + } catch (Exception e) { + System.out.println("鍙戠敓寮傚父"); + log.error(e.getMessage(), e); + rs = null; + return rs; + } + log.info("---------鎺ュ彛杩斿洖锛�" + rs + "---------"); + return rs; + } finally { + try { + outputStream.close(); + if (in != null) { + in.close(); + } + } catch (Exception e) { + } + outputStream = null; + if (connection != null) + connection.disconnect(); + connection = null; + } + } + +} diff --git a/src/main/java/com/fzzy/push/sx2023/SX2023OrderServiceImpl.java b/src/main/java/com/fzzy/push/sx2023/SX2023OrderServiceImpl.java new file mode 100644 index 0000000..40d25f1 --- /dev/null +++ b/src/main/java/com/fzzy/push/sx2023/SX2023OrderServiceImpl.java @@ -0,0 +1,203 @@ +package com.fzzy.push.sx2023; + +import com.fzzy.api.data.ApiParam; +import com.fzzy.api.data.PushProtocol; +import com.fzzy.api.entity.ApiConfs; +import com.fzzy.api.utils.RedisConst; +import com.fzzy.api.utils.RedisUtil; +import com.fzzy.order.ordersx2023.OrderSxService; +import com.fzzy.order.ordersx2023.data.OrderSxConstant; +import com.fzzy.order.ordersx2023.data.OrderSxReq; +import com.fzzy.push.impl.*; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; +import org.apache.commons.lang.time.DateUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.text.ParseException; + +/** + * @Description 闄曡タ鐪佸钩鍙�2023鐗�-鎸囦护瑙f瀽 + * @Author CZT + * @Date 2024/4/23 11:48 + */ +@Slf4j +@Service +public class SX2023OrderServiceImpl implements OrderSxService { + + @Autowired + private RedisUtil redisUtil; + @Autowired + private SX2023ApiRemoteService apiRemoteService; + @Autowired + private ComPushService11 pushService11; + @Autowired + private ComPushService12 pushService12; + @Autowired + private ComPushService13 pushService13; + @Autowired + private ComPushService14 pushService14; + + @Override + public String getProtocol() { + return PushProtocol.SB_SX_2023.getCode(); + } + + @Override + public void execute(OrderSxReq req, ApiConfs apiConfs) throws ParseException { + // 鑻ユ寚浠ょ被鍨嬩笉涓�1锛屽垯杩斿洖 + if (!OrderSxConstant.ORDER_SX_TYPE_1.equals(req.getType())) { + log.error("闄曡タ鐪佸钩鍙帮細鏀跺埌鎸囦护锛屾寚浠ょ被鍨嬩笉涓�1锛屼笉鎵ц鏁版嵁涓婃姤锛侊紝鎸囦护绫诲瀷={}", req.getType()); + return; + } + String datas = req.getData(); + if (StringUtils.isEmpty(datas)) { + log.error("闄曡タ鐪佸钩鍙帮細鏀跺埌鎸囦护锛屾寚浠ゅ唴瀹逛负绌猴紝涓嶆墽琛屾暟鎹笂鎶ワ紒"); + return; + } + + //鎸囦护瀛樺叆缂撳瓨锛屾椂鏁�24灏忔椂 + String key = RedisConst.buildKey(RedisConst.KYE_ORDER, apiConfs.getKqdm()); + redisUtil.set(key, req, 59 * 60 * 24); + + ApiParam param = new ApiParam(); + param.setPushProtocol(apiConfs.getPushProtocol()); + param.setKqdm(apiConfs.getKqdm()); + param.setStart(DateUtils.parseDate(req.getStartTime(), new String[]{"yyyy-MM-dd HH:mm:ss"})); + param.setEnd(DateUtils.parseDate(req.getEndTime(), new String[]{"yyyy-MM-dd HH:mm:ss"})); + param.setDeptId(apiConfs.getDeptId()); + + log.info("鎺ユ敹鐨勬寚浠や腑鎺ュ彛鍐呭涓�={}", datas); + String[] interfaces = datas.split(","); + for (String inteId : interfaces) { + log.info("鎵ц鎺ュ彛={}鐨勬暟鎹笂鎶�", inteId); + getDataToPush(param, inteId); + } + } + + + private void getDataToPush(ApiParam param, String inteId) { + + switch (inteId) { + case "ODS_UP_DWXXJK": + pushService11.pushData1101(apiRemoteService, param); + break; + case "ODS_UP_KQXXJK": + pushService11.pushData1102(apiRemoteService, param); + break; + case "ODS_UP_CFXXJK": + pushService11.pushData1103(apiRemoteService, param); + break; + case "ODS_UP_AJXXJK": + pushService11.pushData1104(apiRemoteService, param); + break; + case "ODS_UP_HWXXJK": + pushService11.pushData1105(apiRemoteService, param); + break; + case "ODS_UP_YGXXJK": + pushService11.pushData1106(apiRemoteService, param); + break; + case "ODS_UP_SBXXJK": + pushService11.pushData1107(apiRemoteService, param); + break; + case "ODS_UP_YJXXJK": + pushService11.pushData1108(apiRemoteService, param); + break; + case "ODS_UP_WJXXJK": + pushService12.pushData1109(apiRemoteService, param); + break; + case "ODS_UP_KQTCFDWBZSJXXJK": + pushService11.pushData1110(apiRemoteService, param); + break; + case "ODS_UP_KQTSPJKSBDWBZSJXXJK": + pushService11.pushData1111(apiRemoteService, param); + break; + case "ODS_UP_RYXXJK": + pushService11.pushData1112(apiRemoteService, param); + break; + case "ODS_UP_CWBBXXJK": + pushService11.pushData1114(apiRemoteService, param); + break; + case "ODS_UP_HTXXJK": + pushService12.pushData1201(apiRemoteService, param); + break; + case "ODS_UP_LSRKXXJK": + pushService12.pushData1202(apiRemoteService, param); + break; + case "ODS_UP_LSRKJYXXJK": + pushService12.pushData1203(apiRemoteService, param); + break; + case "ODS_UP_LSRKJSXXJK": + pushService12.pushData1204(apiRemoteService, param); + break; + case "ODS_UP_LSCKXXJK": + pushService12.pushData1205(apiRemoteService, param); + break; + case "ODS_UP_LSCKJSXXJK": + pushService12.pushData1206(apiRemoteService, param); + break; + case "ODS_UP_DCXXJK": + pushService12.pushData1207(apiRemoteService, param); + break; + case "ODS_UP_LSKCXXJK": + pushService12.pushData1208(apiRemoteService, param); + break; + case "ODS_UP_SYDXXJK": + pushService12.pushData1209(apiRemoteService, param); + break; + case "ODS_UP_LSXZZBDXXJK": + pushService12.pushData1210(apiRemoteService, param); + break; + case "ODS_UP_ZMKCXXJK": + pushService12.pushData1211(apiRemoteService, param); + break; + case "ODS_UP_KHXXJK": + pushService12.pushData1212(apiRemoteService, param); + break; + case "ODS_UP_AQGLXXJK": + pushService13.pushData1301(apiRemoteService, param); + break; + case "ODS_UP_WSDJCXXJK": + pushService13.pushData1302(apiRemoteService, param); + break; + case "ODS_UP_CHJCXXJK": + pushService13.pushData1303(apiRemoteService, param); + break; + case "ODS_UP_QTJCXXJK": + pushService13.pushData1304(apiRemoteService, param); + break; + case "ODS_UP_TFZYXXJK": + pushService13.pushData1305(apiRemoteService, param); + break; + case "ODS_UP_XZZYXXJK": + pushService13.pushData1306(apiRemoteService, param); + break; + case "ODS_UP_CNSPTXXXJK": + pushService13.pushData1307(apiRemoteService, param); + break; + case "ODS_UP_SPJKYCSJGJJBXXJK": + pushService13.pushData1308(apiRemoteService, param); + break; + case "ODS_UP_WGYJXXJK": + pushService13.pushData1309(apiRemoteService, param); + break; + case "ODS_UP_ZJXXJK": + pushService13.pushData1310(apiRemoteService, param); + break; + case "ODS_UP_CBGMXXJK": + pushService14.pushData1401(apiRemoteService, param); + break; + case "ODS_UP_LHJHXXJK": + pushService14.pushData1403(apiRemoteService, param); + break; + case "ODS_UP_LHJHMXXXJK": + pushService14.pushData1404(apiRemoteService, param); + break; + default: + log.error("-----闄曡タ鐪佸钩鍙帮細鏈尮閰嶅埌鎺ュ彛缂栫爜锛屼笉鎺ㄩ��-----"); + break; + } + + } +} diff --git a/src/main/java/com/fzzy/push/sx2023/data/SX2023Api1101.java b/src/main/java/com/fzzy/push/sx2023/data/SX2023Api1101.java new file mode 100644 index 0000000..82c7535 --- /dev/null +++ b/src/main/java/com/fzzy/push/sx2023/data/SX2023Api1101.java @@ -0,0 +1,132 @@ +package com.fzzy.push.sx2023.data; + +import com.alibaba.fastjson.annotation.JSONField; +import com.bstek.dorado.annotation.PropertyDef; +import com.fasterxml.jackson.annotation.JsonProperty; +import lombok.Data; +import java.io.Serializable; +import java.util.Date; + +/** + * @Description 鍗曚綅淇℃伅 + * @Author CZT + * @Date 2024/4/24 9:12 + */ +@Data +public class SX2023Api1101 implements Serializable { + + @PropertyDef(label = "鍗曚綅缂栫爜--11浣�") + private String DWBM; + + + @PropertyDef(label = "鍗曚綅浠g爜") + @JsonProperty("DWDM") + private String dwdm; + + @PropertyDef(label = "鍗曚綅鍚嶇О") + @JsonProperty("DWMC") + private String dwmc; + + @PropertyDef(label = "鍗曚綅绫诲瀷") + @JsonProperty("DWLX") + private String dwlx; + + @PropertyDef(label = "娉ㄥ唽鏃ユ湡") + @JSONField(format = "yyyy-MM-dd") + @JsonProperty("ZCRQ") + private Date zcrq; + + @PropertyDef(label = "娉ㄥ唽璧勬湰") + @JsonProperty("ZCZB") + private Double zczb; + + @PropertyDef(label = "璧勪骇鎬婚") + @JsonProperty("ZCZE") + private Double zcze; + + @PropertyDef(label = "娉曞畾浠h〃浜�") + @JsonProperty("FDDBR") + private String fddbr; + + @PropertyDef(label = "娉曚汉韬唤璇佸彿") + @JsonProperty("FRSFZH") + private String frsfzh; + + @PropertyDef(label = "娉曚汉鑱旂郴鏂瑰紡") + @JsonProperty("FRLXFS") + private String frlxfs; + + @PropertyDef(label = "浼佷笟鑱旂郴浜�") + @JsonProperty("QYLXR") + private String qylxr; + + @PropertyDef(label = "鍔炲叕鐢佃瘽") + @JsonProperty("BGDH") + private String bgdh; + + @PropertyDef(label = "娉ㄥ唽鍦板潃") + @JsonProperty("ZCDZ") + private String zcdz; + + @PropertyDef(label = "鐢靛瓙閭") + @JsonProperty("DZYX") + private String dzyx; + + @PropertyDef(label = "浼佷笟瀹樻柟缃戠珯鍦板潃") + @JsonProperty("QYGFWZDZ") + private String qygfwzdz; + + @PropertyDef(label = "浼犵湡鍙风爜") + @JsonProperty("CZHM") + private String czhm; + + @PropertyDef(label = "閭斂缂栫爜") + @JsonProperty("YZBM") + private String yzbm; + + @PropertyDef(label = "琛屾斂鍖哄垝浠g爜") + @JsonProperty("XZQHDM") + private String xzqhdm; + + @PropertyDef(label = "涓婄骇鍗曚綅鍚嶇О") + @JsonProperty("SJDWMC") + private String sjdwmc; + + @PropertyDef(label = "涓婄骇鍗曚綅浠g爜") + @JsonProperty("SJDWDM") + private String sjdwdm; + + @PropertyDef(label = "搴撳尯鏁�") + @JsonProperty("KQS") + private Integer kqs; + + @PropertyDef(label = "浠撴埧鏁�") + @JsonProperty("CFS") + private Integer cfs; + + @PropertyDef(label = "娌圭綈鏁�") + @JsonProperty("YGS") + private Integer ygs; + + @PropertyDef(label = "缁忓害") + @JsonProperty("JD") + private Double jd; + + @PropertyDef(label = "绾害") + @JsonProperty("WD") + private Double wd; + + @PropertyDef(label = "鍗曚綅鐘舵��") + @JsonProperty("DWZT") + private String dwzt; + + @PropertyDef(label = "鎿嶄綔鏍囧織") + @JsonProperty("CZBZ") + private String czbz; + + @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�") + @JSONField(format = "yyyy-MM-dd HH:mm:ss") + @JsonProperty("ZHGXSJ") + private Date zhgxsj; + +} diff --git a/src/main/java/com/fzzy/push/sx2023/data/SX2023Dto.java b/src/main/java/com/fzzy/push/sx2023/data/SX2023Dto.java new file mode 100644 index 0000000..44361e7 --- /dev/null +++ b/src/main/java/com/fzzy/push/sx2023/data/SX2023Dto.java @@ -0,0 +1,24 @@ +package com.fzzy.push.sx2023.data; + +import lombok.Data; + +import java.io.Serializable; + +/** + * @Description 闄曡タ鐪佸钩鍙�2023鐗�-鍝嶅簲鐮佹暟鎹皝瑁� + * @Author CZT + * @Date 2024/4/23 16:21 + */ +@Data +public class SX2023Dto implements Serializable { + + /** + * 鍝嶅簲鐮� + */ + private String Code; + + /** + * 鐩稿簲淇℃伅 + */ + private String VER; +} diff --git a/src/main/java/com/fzzy/push/sx2023/data/SX2023ReqDto.java b/src/main/java/com/fzzy/push/sx2023/data/SX2023ReqDto.java new file mode 100644 index 0000000..2d8be75 --- /dev/null +++ b/src/main/java/com/fzzy/push/sx2023/data/SX2023ReqDto.java @@ -0,0 +1,53 @@ +package com.fzzy.push.sx2023.data; + +import com.alibaba.fastjson.annotation.JSONField; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + * @Description 闄曡タ鐪佸钩鍙�2023鐗�-鎺ㄩ�佹暟鎹皝瑁� + * @Author CZT + * @Date 2024/4/23 15:02 + */ +@Data +public class SX2023ReqDto implements Serializable { + + /** + * 鎶ユ枃鏍囪瘑 + */ + private String ID; + + /** + * 鐗堟湰鍙� + */ + private String VER; + + /** + * 鍗曚綅缂栫爜锛�11浣� + */ + private String OrgNo; + + /** + * 鍗曚綅鍚嶇О + */ + private String OrgName; + + /** + * 鍙戣捣鏃堕棿 + */ + @JSONField(format = "yyyy-MM-dd HH:mm:ss") + private Date SendTime; + + /** + * 鍗曚綅浠g爜 + */ + private String dwdm; + + /** + * 鏁版嵁涓讳綋鍐呭锛氬姞瀵� + */ + private String Body; + +} diff --git a/src/main/java/com/fzzy/push/sx2023/data/SX2023RespDto.java b/src/main/java/com/fzzy/push/sx2023/data/SX2023RespDto.java new file mode 100644 index 0000000..6128db8 --- /dev/null +++ b/src/main/java/com/fzzy/push/sx2023/data/SX2023RespDto.java @@ -0,0 +1,47 @@ +package com.fzzy.push.sx2023.data; + +import com.alibaba.fastjson.annotation.JSONField; +import lombok.Data; + +import java.io.Serializable; +import java.util.Date; + +/** + * @Description 闄曡タ鐪佸钩鍙�2023鐗�-鐩稿簲鏁版嵁灏佽 + * @Author CZT + * @Date 2024/4/23 15:07 + */ +@Data +public class SX2023RespDto<T> implements Serializable { + + /** + * 鎶ユ枃鏍囪瘑ID + */ + private String ID; + /** + * 鎶ユ枃鐗堟湰鍙� + */ + private String VER; + /** + * 鍙戣捣鏃堕棿 + */ + @JSONField(format = "yyyy-MM-dd HH:mm:ss") + private Date SendTime; + /** + * 璇锋眰鍛戒护褰卞搷鐨勮鏁� + */ + private String ROWS; + /** + * 鎵ц娑堟伅鐨勫唴瀹� + */ + private T MsgBody; + + public SX2023RespDto() { + } + + public SX2023RespDto(String ID, String VER) { + this.ID = ID; + this.VER = VER; + } + +} diff --git a/src/main/java/com/fzzy/push/sx2023/data/SXFinanceDto.java b/src/main/java/com/fzzy/push/sx2023/data/SXFinanceDto.java new file mode 100644 index 0000000..2690031 --- /dev/null +++ b/src/main/java/com/fzzy/push/sx2023/data/SXFinanceDto.java @@ -0,0 +1,52 @@ +package com.fzzy.push.sx2023.data; + +import com.bstek.dorado.annotation.PropertyDef; +import lombok.Data; + +/** + * @Description 鎶ヨ〃鏁版嵁灏佽 + * @Author CZT + * @Date 2024/4/23 17:30 + */ +@Data +public class SXFinanceDto { + + @PropertyDef(label = "鍗曚綅浠g爜") + private String DWDM; + + @PropertyDef(label = "搴撳尯浠g爜") + private String KQDM; + + @PropertyDef(label = "鎶ヨ〃鏈熷彿") + private String BBSJ; + + @PropertyDef(label = "鎶ヨ〃鍚�") + private String BBM; + + @PropertyDef(label = "鎸囨爣搴忓彿") + private String ZBXH; + + @PropertyDef(label = "鎸囨爣鍚嶇О") + private String ZBMC; + + @PropertyDef(label = "鎸囨爣鍊� 1") + private String ZBZ1; + + @PropertyDef(label = "鎸囨爣鍊� 2") + private String ZBZ2; + + @PropertyDef(label = "鎿嶄綔鏍囧織") + private String CZBZ; + + @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�") + private String ZHGXSJ; + + public SXFinanceDto() { + } + + public SXFinanceDto(String zbmc, String zbz1, String zbz2){ + this.ZBMC = zbmc; + this.ZBZ1 = zbz1; + this.ZBZ2 = zbz2; + } +} -- Gitblit v1.9.3