设备信息

src/main/java/com/chinaitop/depot/device/mapper/DSbxxsjyMapper.java

@@ -5,6 +5,7 @@ import com.chinaitop.depot.device.model.DSbxxsjyExample;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
+import java.util.Map;
 
 public interface DSbxxsjyMapper {
     int countByExample(DSbxxsjyExample example);
@@ -20,4 +21,6 @@ public interface DSbxxsjyMapper {
     int updateByExampleSelective(@Param("record") DSbxxsjy record, @Param("example") DSbxxsjyExample example);
 
     int updateByExample(@Param("record") DSbxxsjy record, @Param("example") DSbxxsjyExample example);
+
+	Map<String, Object> getSbGjjDate(String sbbh);
 }

src/main/java/com/chinaitop/depot/device/mapper/DSbxxsjyMapper.xml

@@ -151,7 +151,7 @@
       <include refid="Example_Where_Clause" />
     </if>
   </delete>
-  <insert id="insert" parameterType="com.chinaitop.depot.device.model.DSbxxsjy" >
+  <insert id="insert" parameterType="com.chinaitop.depot.device.model.DSbxxsjy">
     insert into d_sbxxsjy (sbbh, sbyqmc, kddm, 
       sbggxh, sbms, sbzt, 
       sbfl, sccj, cgjg, sbglz, 
@@ -836,4 +836,28 @@
       <include refid="Update_By_Example_Where_Clause" />
     </if>
   </update>
+  
+  <select id="getSbGjjDate" parameterType="java.lang.String" resultType="java.util.Map">
+  	select  
+	a.sbbh id,
+	b.kqbm kqdm,
+	b.tykqbm tykqbm,
+	b.credit_code dwdm,
+	b.org_name kqmc,
+	a.sbbh sbbh,
+	a.sbyqmc sbyqmc,
+	a.sbbm sbyqdm,
+	a.sbggxh sbggxh,
+	a.sccj sccj,
+	DATE_FORMAT(a.scrq, '%Y-%m-%d') scrq,
+	a.remark sbms,
+	a.status sbzt,
+	DATE_FORMAT(a.jdsj, '%Y-%m-%d') jdsj,
+	a.jddw jddw,
+	DATE_FORMAT(a.create_date, '%Y-%m-%d %H:%i:%s') zhgxsj 
+	from d_sbxxsjy a 
+	left join org_info b on b.org_id=a.szdwdm
+	where 1=1 
+	and a.ssfl='1' and a.sbbh = #{sbbh};
+  </select>
 </mapper>

src/main/java/com/chinaitop/depot/device/service/impl/DSblxxjyServiceImpl.java

@@ -4,10 +4,18 @@ import com.chinaitop.depot.device.mapper.DSbxxsjyMapper;
 import com.chinaitop.depot.device.model.DSbxxsjy;
 import com.chinaitop.depot.device.model.DSbxxsjyExample;
 import com.chinaitop.depot.device.service.DSblxxjyService;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Service;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.client.RestTemplate;
 
 import javax.annotation.Resource;
 import java.util.List;
+import java.util.Map;
 
 /**
  * @author qingsong.han
@@ -18,6 +26,14 @@ import java.util.List;
 public class DSblxxjyServiceImpl implements DSblxxjyService {
     @Resource
     private DSbxxsjyMapper sbxxsjyMapper;
+    
+    @Resource
+    private RestTemplate restTemplate;
+
+    @Bean
+    public RestTemplate restTemplate() {
+        return new RestTemplate();
+    }
 
     @Override
     public List<DSbxxsjy> getList(DSbxxsjyExample example) {
@@ -27,6 +43,8 @@ public class DSblxxjyServiceImpl implements DSblxxjyService {
     @Override
     public void save(DSbxxsjy dSbxxsjy) {
         sbxxsjyMapper.insert(dSbxxsjy);
+        this.gjjjk(dSbxxsjy.getSbbh(),"","i");
+        
     }
 
     @Override
@@ -35,6 +53,8 @@ public class DSblxxjyServiceImpl implements DSblxxjyService {
         DSbxxsjyExample.Criteria criteria = example.createCriteria();
         criteria.andSbbhEqualTo(dSbxxsjy.getSbbh());
         sbxxsjyMapper.updateByExampleSelective(dSbxxsjy,example);
+        
+        this.gjjjk(dSbxxsjy.getSbbh(),"","u");
     }
 
     @Override
@@ -44,5 +64,42 @@ public class DSblxxjyServiceImpl implements DSblxxjyService {
         criteria.andSbbhEqualTo(sbbh);
         criteria.andSzdwdmEqualTo(s);
         sbxxsjyMapper.deleteByExample(example);
+        
+        this.gjjjk(sbbh,s,"d");
+        
+    }
+    
+    
+    /**
+	 * 国家局数据
+	 */
+    public void gjjjk(String sbbh, String orgId,String czbz) {
+        
+		Map<String, Object>  gjjMap = sbxxsjyMapper.getSbGjjDate(sbbh);
+		gjjMap.put("czbz",czbz);
+		gjjMap.put("is_upload", 0);
+		String tableName = "ODS_UP_SBXXJK";
+		
+		/**
+         * restTemplate调用
+         */
+        String url = "http://localhost:9022/recPublish/sendMessage";//
+        // 发送post请求，并打印结果，以String类型接收响应结果JSON字符串
+        MultiValueMap<String, Object> sendMap = new LinkedMultiValueMap<>();
+		//Map<String, Object>  sendMap = new HashMap<String, Object>();
+        ObjectMapper objectMapper = new ObjectMapper();
+        String jsonMap;
+        try {
+			 jsonMap = objectMapper.writeValueAsString(gjjMap);
+			 sendMap.add("gjjMapJson",jsonMap);
+		} catch (JsonProcessingException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		sendMap.add("tableName", tableName);
+		//sendMap.add("orgId",111);
+
+       String result = (String) restTemplate.postForObject(url, sendMap, String.class);
     }
+    
 }