Ver código fonte

国家局上传接口

gaodd 1 ano atrás
pai
commit
b175fa7997

+ 0 - 1
src/main/java/com/chinaitop/depot/system/mapper/OrgInfoMapper.java

@@ -36,5 +36,4 @@ public interface OrgInfoMapper {
36 36
     
37 37
     List<OrgInfo> getAllDepotInfo();
38 38
 
39
-	Map<String, Object> getKqGjjDate(Integer orgId);
40 39
 }

+ 0 - 30
src/main/java/com/chinaitop/depot/system/mapper/OrgInfoMapper.xml

@@ -1088,34 +1088,4 @@
1088 1088
     where org_class_id = 5318
1089 1089
   </select>
1090 1090
   
1091
-  
1092
-  <select id="getKqGjjDate" parameterType="java.lang.Integer" resultType="java.util.Map">
1093
-	select 
1094
-	a.org_id id, 
1095
-	a.kqbm kqdm, 
1096
-	a.tykqbm tykqbm, 
1097
-	dw.dwdm dwdm,
1098
-	a.org_name kqmc    ,
1099
-	e2.enumname || e3.enumname || e4.enumname || a.registered_address zcdz    ,
1100
-	e5.gbcode xzqhdm  ,
1101
-	a.depot_property kqcq,
1102
-	a.effective_capacity yxcr,
1103
-	a.yxgr, 
1104
-	a.depot_area zdmj, 
1105
-	a.house_number cfs,
1106
-	a.tank_number ygs, 
1107
-	a.longitude jd      ,
1108
-	a.latitude wd      ,
1109
-	'1' As kqzt,          
1110
-	DATE_FORMAT(a.updatetime, '%Y-%m-%d %H:%i:%s') zhgxsj  
1111
-	from org_info a 
1112
-	left join org_info b on b.org_id=a.parent_id
1113
-	left join basic_enum e1 on e1.enumid=a.depot_class
1114
-	left join basic_enum e2 on e2.enumid=a.zc_province
1115
-	left join basic_enum e3 on e3.enumid=a.zc_city
1116
-	left join basic_enum e4 on e4.enumid=a.zc_county
1117
-	left join basic_enum e5 on e5.enumid=a.area_code
1118
-	left join province_all.biz_unit_info dw on dw.id = a.unit_info_id
1119
-	where a.org_class_id=5318 and a.org_id = #{orgId}
1120
-  </select>
1121 1091
 </mapper>

+ 0 - 1
src/main/java/com/chinaitop/depot/system/mapper/UserInfoMapper.java

@@ -68,5 +68,4 @@ public interface UserInfoMapper {
68 68
 
69 69
 	List<Map<Object, Object>> sptgetUserInfo(Map<Object, Object> map);
70 70
 
71
-	Map<String, Object> getRyGjjDate(Integer id);
72 71
 }

+ 0 - 40
src/main/java/com/chinaitop/depot/system/mapper/UserInfoMapper.xml

@@ -790,44 +790,4 @@
790 790
 	order by ui.real_name asc
791 791
   </select>
792 792
   
793
-  
794
-  <select id="getRyGjjDate" parameterType="java.lang.Integer" resultType="java.util.Map">
795
-  		select 
796
-		a.user_id id,
797
-		substr(b.kqbm, 1, 18) dwdm,  
798
-		b.kqbm kqdm,
799
-		dw.tydwbm tydwbm, 
800
-		b.tykqbm tykqbm, 
801
-		b.org_name dwmc,
802
-		a.bmmc lsbm,
803
-		e1.gbcode xzqhdm,
804
-		a.real_name xm,
805
-		case a.sex when '5288' then '1' when '5289' then '2' else '1' end xb,
806
-		UPPER(a.sfzhm) sfzhm,
807
-		DATE_FORMAT(a.rzrq, '%Y-%m-%d')  rzrq,
808
-		a.gwxz gwxz,
809
-		a.zgzt zgzt,
810
-		DATE_FORMAT(a.lzrq, '%Y-%m-%d') lzrq,
811
-		a.telphone zjdh,
812
-		a.mobile yddh,
813
-		a.email dzyx,
814
-		e2.gbcode mz,
815
-		e3.gbcode zzmm,
816
-		e4.gbcode rylb,
817
-		a.zy zy,
818
-		DATE_FORMAT(a.qdzgzchzyzgsj, '%Y-%m-%d') qdzgzchzyzgsj,
819
-		e5.gbcode xl,
820
-		a.zw zw,
821
-		DATE_FORMAT(a.updatetime, '%Y-%m-%d %H:%i:%s') zhgxsj
822
-		from user_info a 
823
-		left join org_info b on b.org_id=a.org_id
824
-		left join basic_enum e1 on e1.enumid=b.area_code
825
-		left join basic_enum e2 on e2.enumid=a.mz
826
-		left join basic_enum e3 on e3.enumid=a.zzmm
827
-		left join basic_enum e4 on e4.enumid=a.rylb
828
-		left join basic_enum e5 on e5.enumid=a.xl
829
-		left join basic_enum e6 on e6.enumid=a.sex
830
-		left join province_all.biz_unit_info dw on dw.id = b.unit_info_id
831
-		where length(a.real_name) &lt;12 and b.org_class_id=5318 and a.user_id = #{id}
832
-  </select>
833 793
 </mapper>

+ 9 - 20
src/main/java/com/chinaitop/depot/system/service/impl/OrgInfoServiceImpl.java

@@ -221,33 +221,22 @@ public class OrgInfoServiceImpl implements OrgInfoService {
221 221
    	 * 国家局数据
222 222
    	 */
223 223
        public void gjjjk(Integer id, Integer orgId,String czbz) {
224
-           
225
-    	Map<String, Object>  gjjMap = OrgInfoMapper.getKqGjjDate(orgId);
226
-   		gjjMap.put("czbz", czbz);
227
-   		gjjMap.put("is_upload", 0);
228
-   		String tableName = "ODS_UP_KQXXJK";
229
-   		
224
+         
225
+    	  String tableName = "ODS_UP_KQXXJK";
230 226
    		/**
231 227
             * restTemplate调用
232 228
             */
233 229
            //String url = "http://localhost:9022/recPublish/sendMessage";//
234
-           // 发送post请求,并打印结果,以String类型接收响应结果JSON字符串
230
+           //发送post请求,并打印结果,以String类型接收响应结果JSON字符串
231
+   		
235 232
            MultiValueMap<String, Object> sendMap = new LinkedMultiValueMap<>();
236
-   		//Map<String, Object>  sendMap = new HashMap<String, Object>();
237
-           ObjectMapper objectMapper = new ObjectMapper();
238
-           String jsonMap;
239
-           try {
240
-   			 jsonMap = objectMapper.writeValueAsString(gjjMap);
241
-   			 sendMap.add("gjjMapJson",jsonMap);
242
-   		} catch (JsonProcessingException e) {
243
-   			// TODO Auto-generated catch block
244
-   			e.printStackTrace();
245
-   		}
246 233
    		sendMap.add("tableName", tableName);
234
+   		sendMap.add("czbz", czbz);
235
+   		sendMap.add("ywId", id);
247 236
    		sendMap.add("orgId", orgId);
248 237
 
249
-   		System.out.println(jsgjjsjUrl);
250
-   		
251
-          restTemplate.postForObject(jsgjjsjUrl, sendMap, String.class);
238
+        restTemplate.postForObject(jsgjjsjUrl, sendMap, String.class);
239
+           
240
+    	
252 241
        }
253 242
 }

+ 13 - 26
src/main/java/com/chinaitop/depot/system/service/impl/UserInfoServiceImpl.java

@@ -12,7 +12,6 @@ import javax.annotation.Resource;
12 12
 
13 13
 import org.apache.commons.lang3.StringUtils;
14 14
 import org.springframework.beans.factory.annotation.Value;
15
-import org.springframework.context.annotation.Bean;
16 15
 import org.springframework.stereotype.Service;
17 16
 import org.springframework.transaction.annotation.Transactional;
18 17
 import org.springframework.util.LinkedMultiValueMap;
@@ -33,7 +32,6 @@ import com.chinaitop.depot.utils.NetStateUtil;
33 32
 import com.chinaitop.depot.utils.SHA1Util;
34 33
 import com.chinaitop.depot.webservice.ExchangeServer;
35 34
 import com.chinaitop.depot.webservice.IExchangeService;
36
-import com.fasterxml.jackson.core.JsonProcessingException;
37 35
 import com.fasterxml.jackson.databind.ObjectMapper;
38 36
 
39 37
 @Service
@@ -368,31 +366,20 @@ public class UserInfoServiceImpl implements UserInfoService {
368 366
    	 */
369 367
        public void gjjjk(Integer id, Integer orgId,String czbz) {
370 368
            
371
-   		Map<String, Object>  gjjMap = UserInfoMapper.getRyGjjDate(id);
372
-   		gjjMap.put("czbz",czbz);
373
-   		gjjMap.put("is_upload", 0);
374
-   		String tableName = "ODS_UP_RYXXJK";
375
-   		
376
-   		/**
377
-            * restTemplate调用
378
-            */
379
-           //String url = "http://localhost:9022/recPublish/sendMessage";//
380
-           // 发送post请求,并打印结果,以String类型接收响应结果JSON字符串
381
-           MultiValueMap<String, Object> sendMap = new LinkedMultiValueMap<>();
382
-   		//Map<String, Object>  sendMap = new HashMap<String, Object>();
383
-           ObjectMapper objectMapper = new ObjectMapper();
384
-           String jsonMap;
385
-           try {
386
-   			 jsonMap = objectMapper.writeValueAsString(gjjMap);
387
-   			 sendMap.add("gjjMapJson",jsonMap);
388
-   		} catch (JsonProcessingException e) {
389
-   			// TODO Auto-generated catch block
390
-   			e.printStackTrace();
391
-   		}
392
-   		sendMap.add("tableName", tableName);
393
-   		sendMap.add("orgId",orgId);
369
+         String tableName = "ODS_UP_RYXXJK";
370
+  		/**
371
+           * restTemplate调用
372
+           */
373
+          //String url = "http://localhost:9022/recPublish/sendMessage";//
374
+          //发送post请求,并打印结果,以String类型接收响应结果JSON字符串
375
+  		
376
+          MultiValueMap<String, Object> sendMap = new LinkedMultiValueMap<>();
377
+  		sendMap.add("tableName", tableName);
378
+  		sendMap.add("czbz", czbz);
379
+  		sendMap.add("ywId", id);
380
+  		sendMap.add("orgId", orgId);
394 381
 
395 382
           restTemplate.postForObject(jsgjjsjUrl, sendMap, String.class);
396
-       }
383
+     }
397 384
 
398 385
 }