From 029de836702607a95ccb0a69a74efcea52ddc451 Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期四, 25 九月 2025 19:35:38 +0800
Subject: [PATCH] 上海对农数据接口调整2
---
src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1311.java | 161 +++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 161 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1311.java b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1311.java
new file mode 100644
index 0000000..c05fc95
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1311.java
@@ -0,0 +1,161 @@
+package com.fzzy.async.fzzy61.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1102;
+import com.fzzy.api.entity.ApiInfoData;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1102Rep;
+import com.fzzy.api.view.repository.ApiInfoDataRep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy61.entity.Fz61SecCamera;
+import com.fzzy.async.fzzy61.repository.Fzzy61Sync1311Rep;
+import com.fzzy.push.sh2023.SH2023Constant;
+import com.fzzy.push.sh2023.dto.SH2023Api1311;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 瑙嗛鐩戞帶
+ *
+ * @Author:YAN
+ */
+@Component
+@Slf4j
+public class Fzzy61Sync1311 {
+ @Autowired
+ private ApiLogRep apiLogRep;
+ @Autowired
+ private Api1102Rep api1102Rep;
+ @Autowired
+ private Fzzy61Sync1311Rep fzzy61Sync1311Rep;
+ @Autowired
+ private ApiInfoDataRep apiInfoDataRep;
+
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+ log.info("-------------1311鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+ //鍚屾鏁版嵁
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(SH2023Constant.SH_2023_API_CODE_1311);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz61SecCamera> list = fzzy61Sync1311Rep.findDateByDeptId(deptId);
+ if (list.isEmpty() || null == list) {
+ log.debug("-------------娌℃湁鑾峰彇鍒拌棰戠洃鎺т俊鎭�------------------");
+ return;
+ }
+ Api1102 api1102 = api1102Rep.findById(kqdm).get();
+ SH2023Api1311 sh2023Api1311;
+ SH2023Api1311 sh1311;
+ List<ApiInfoData> apiInfoDataList;
+ for (Fz61SecCamera sysData : list) {
+ sh2023Api1311 = new SH2023Api1311();
+ sh2023Api1311.setSpjksbid(sysData.getId());
+ sh2023Api1311.setTdbh(sysData.getChanNum());
+ sh2023Api1311.setJksbmc(sysData.getName());
+ sh2023Api1311.setKqdm(kqdm);
+
+ //鐩戞帶鍘傚晢
+ sh2023Api1311.setJkcs(getBrandId(sysData.getBrand()));
+
+ sh2023Api1311.setJkxh(sysData.getSn());
+
+ sh2023Api1311.setSpjklx(StringUtils.isEmpty(sysData.getSpjklx()) ? "3" : sysData.getSpjklx());
+ sh2023Api1311.setSblxbm("1");
+
+ sh2023Api1311.setAzwz(sysData.getName());
+ sh2023Api1311.setAzwzlx(StringUtils.isEmpty(sysData.getSpdwlx()) ? "7" : sysData.getSpdwlx());
+ if (sh2023Api1311.getAzwzlx().length() == 1) {
+ sh2023Api1311.setAzwzlx("0" + sh2023Api1311.getAzwzlx());
+ }
+ if ("12".equals(sh2023Api1311.getAzwzlx()) || "13".equals(sh2023Api1311.getAzwzlx())
+ || "14".equals(sh2023Api1311.getAzwzlx()) || "15".equals(sh2023Api1311.getAzwzlx())) {
+ sh2023Api1311.setAzwzlx("99");
+ }
+ if ("16".equals(sh2023Api1311.getAzwzlx())) {
+ sh2023Api1311.setAzwzlx("12");
+ }
+ sh2023Api1311.setSfazbgd("Y");
+
+ if (StringUtils.isEmpty(sysData.getType())) {
+ sysData.setType("01");
+ }
+ if (sysData.getType().equals("02")) {
+ sh2023Api1311.setJkjlxbm("2");
+ }
+ if (sysData.getType().equals("01")) {
+ sh2023Api1311.setJkjlxbm("1");
+ }
+ sh2023Api1311.setJktyzw(12);
+ sh2023Api1311.setSbipdz(sysData.getIp());
+ sh2023Api1311.setSbdkh(sysData.getControlPort());
+ sh2023Api1311.setSbdlmc(sysData.getLoginId());
+ sh2023Api1311.setSbdlmm(sysData.getPwd());
+ sh2023Api1311.setBz(sysData.getRemark());
+ sh2023Api1311.setZhgxsj(sysData.getUpdateTime() == null ? new Date() : sysData.getUpdateTime());
+
+ //鎸佷箙鍖栦繚瀛橈紝鍗曠嫭瀛樺叆闈炲浗鏍囨帴鍙ｈ〃
+ ApiInfoData infoData = new ApiInfoData();
+ infoData.setId(sh2023Api1311.getSpjksbid());
+ infoData.setKqdm(kqdm);
+ infoData.setInteType(Constant.API_CATEGORY_13);
+ infoData.setInteId(SH2023Constant.SH_2023_API_CODE_1311);
+ infoData.setUpdateTime(sh2023Api1311.getZhgxsj());
+ infoData.setDataId(sh2023Api1311.getSpjksbid());
+ infoData.setRemarks("瑙嗛鐩戞帶淇℃伅");
+ //璁剧疆鎿嶄綔鏍囧織
+ apiInfoDataList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_1311, infoData.getDataId(), kqdm);
+ if (null == apiInfoDataList || apiInfoDataList.isEmpty()) {
+ sh2023Api1311.setCzbz(Constant.CZBZ_I);
+ infoData.setCzbz(Constant.CZBZ_I);
+ } else {
+ sh2023Api1311.setCzbz(apiInfoDataList.get(0).getCzbz());
+ infoData.setCzbz(apiInfoDataList.get(0).getCzbz());
+ sh1311 = JSONObject.parseObject(apiInfoDataList.get(0).getData(), SH2023Api1311.class);
+ if (null != sh1311 && StringUtils.isNotEmpty(sh1311.getAjdm())) {
+ sh2023Api1311.setAjdm(sh1311.getAjdm());
+ }
+ if (null != sh1311 && StringUtils.isNotEmpty(sh1311.getHwdm())) {
+ sh2023Api1311.setHwdm(sh1311.getHwdm());
+ }
+ }
+
+ infoData.setData(JSON.toJSONString(sh2023Api1311));
+ apiInfoDataRep.save(infoData);
+ log.info("1311---瑙嗛鐩戞帶-鍚屾鏁版嵁锛歿}", sh2023Api1311);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e.toString());
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+
+ private String getBrandId(String brandName) {
+ if (StringUtils.isEmpty(brandName)) {
+ return "9";
+ }
+ if (brandName.contains("娴峰悍")) {
+ return "1";
+ }
+ if (brandName.contains("澶у崕")) {
+ return "2";
+ }
+ if (brandName.contains("瀹囪")) {
+ return "3";
+ }
+ return "9";
+ }
+}
--
Gitblit v1.9.3