fanxw 8 months ago
parent
commit
cc379564dd

+ 1 - 0
src/main/java/com/chinaitop/depot/business/controller/ReceiveNoticeController.java

@@ -196,6 +196,7 @@ public class ReceiveNoticeController {
196
 	public void updateNoticeReceiveAuditState(String cblx, String ysid, String hzsj) {
196
 	public void updateNoticeReceiveAuditState(String cblx, String ysid, String hzsj) {
197
 		try {
197
 		try {
198
 			String param = "cblx="+cblx+"&ysid="+ysid+"&hzsj="+hzsj;
198
 			String param = "cblx="+cblx+"&ysid="+ysid+"&hzsj="+hzsj;
199
+			logger.error("市平台通知性质转变单审批完该结束了,推送信息是:"+param);
199
 			systemOutsideDataService.addlogger("update_rkxzzbd_zt_and_hzsj", param, null);
200
 			systemOutsideDataService.addlogger("update_rkxzzbd_zt_and_hzsj", param, null);
200
 			receiveNoticeService.updateNoticeReceiveAuditState(cblx, ysid, hzsj);
201
 			receiveNoticeService.updateNoticeReceiveAuditState(cblx, ysid, hzsj);
201
 		} catch (Exception e) {
202
 		} catch (Exception e) {

+ 1 - 1
src/main/java/com/chinaitop/depot/business/controller/audit/BusinessProSheetAuditController.java

@@ -179,7 +179,7 @@ public class BusinessProSheetAuditController {
179
         BusinessNoticeReceive receiveNotice;
179
         BusinessNoticeReceive receiveNotice;
180
 		try {
180
 		try {
181
 			receiveNotice = (BusinessNoticeReceive)mapper.readValue(receiveNoticeJson, BusinessNoticeReceive.class);
181
 			receiveNotice = (BusinessNoticeReceive)mapper.readValue(receiveNoticeJson, BusinessNoticeReceive.class);
182
-			 receiveNoticeService.audit(receiveNotice, userId,  realName,orgName,content);
182
+			receiveNoticeService.audit(receiveNotice, userId,  realName,orgName,content);
183
 		} catch (IOException e) {
183
 		} catch (IOException e) {
184
 			// TODO Auto-generated catch block
184
 			// TODO Auto-generated catch block
185
 			e.printStackTrace();
185
 			e.printStackTrace();

+ 8 - 66
src/main/java/com/chinaitop/depot/business/mapper/BusinessNoticeReceiveMapper.java

@@ -8,93 +8,35 @@ import java.util.Map;
8
 import org.apache.ibatis.annotations.Param;
8
 import org.apache.ibatis.annotations.Param;
9
 
9
 
10
 public interface BusinessNoticeReceiveMapper {
10
 public interface BusinessNoticeReceiveMapper {
11
-    /**
12
-     * This method was generated by MyBatis Generator.
13
-     * This method corresponds to the database table business_notice_receive
14
-     *
15
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
16
-     */
11
+
17
     int countByExample(BusinessNoticeReceiveExample example);
12
     int countByExample(BusinessNoticeReceiveExample example);
18
 
13
 
19
-    /**
20
-     * This method was generated by MyBatis Generator.
21
-     * This method corresponds to the database table business_notice_receive
22
-     *
23
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
24
-     */
25
     int deleteByExample(BusinessNoticeReceiveExample example);
14
     int deleteByExample(BusinessNoticeReceiveExample example);
26
 
15
 
27
-    /**
28
-     * This method was generated by MyBatis Generator.
29
-     * This method corresponds to the database table business_notice_receive
30
-     *
31
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
32
-     */
33
     int deleteByPrimaryKey(Integer id);
16
     int deleteByPrimaryKey(Integer id);
34
 
17
 
35
-    /**
36
-     * This method was generated by MyBatis Generator.
37
-     * This method corresponds to the database table business_notice_receive
38
-     *
39
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
40
-     */
41
     int insert(BusinessNoticeReceive record);
18
     int insert(BusinessNoticeReceive record);
42
 
19
 
43
-    /**
44
-     * This method was generated by MyBatis Generator.
45
-     * This method corresponds to the database table business_notice_receive
46
-     *
47
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
48
-     */
49
     int insertSelective(BusinessNoticeReceive record);
20
     int insertSelective(BusinessNoticeReceive record);
50
 
21
 
51
-    /**
52
-     * This method was generated by MyBatis Generator.
53
-     * This method corresponds to the database table business_notice_receive
54
-     *
55
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
56
-     */
57
     List<BusinessNoticeReceive> selectByExample(BusinessNoticeReceiveExample example);
22
     List<BusinessNoticeReceive> selectByExample(BusinessNoticeReceiveExample example);
58
 
23
 
59
-    /**
60
-     * This method was generated by MyBatis Generator.
61
-     * This method corresponds to the database table business_notice_receive
62
-     *
63
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
64
-     */
65
     BusinessNoticeReceive selectByPrimaryKey(Integer id);
24
     BusinessNoticeReceive selectByPrimaryKey(Integer id);
66
 
25
 
67
-    /**
68
-     * This method was generated by MyBatis Generator.
69
-     * This method corresponds to the database table business_notice_receive
70
-     *
71
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
72
-     */
73
     int updateByExampleSelective(@Param("record") BusinessNoticeReceive record, @Param("example") BusinessNoticeReceiveExample example);
26
     int updateByExampleSelective(@Param("record") BusinessNoticeReceive record, @Param("example") BusinessNoticeReceiveExample example);
74
 
27
 
75
-    /**
76
-     * This method was generated by MyBatis Generator.
77
-     * This method corresponds to the database table business_notice_receive
78
-     *
79
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
80
-     */
81
     int updateByExample(@Param("record") BusinessNoticeReceive record, @Param("example") BusinessNoticeReceiveExample example);
28
     int updateByExample(@Param("record") BusinessNoticeReceive record, @Param("example") BusinessNoticeReceiveExample example);
82
 
29
 
83
-    /**
84
-     * This method was generated by MyBatis Generator.
85
-     * This method corresponds to the database table business_notice_receive
86
-     *
87
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
88
-     */
89
     int updateByPrimaryKeySelective(BusinessNoticeReceive record);
30
     int updateByPrimaryKeySelective(BusinessNoticeReceive record);
90
 
31
 
91
-    /**
92
-     * This method was generated by MyBatis Generator.
93
-     * This method corresponds to the database table business_notice_receive
94
-     *
95
-     * @mbggenerated Wed Jul 08 09:57:43 CST 2020
96
-     */
97
     int updateByPrimaryKey(BusinessNoticeReceive record);
32
     int updateByPrimaryKey(BusinessNoticeReceive record);
98
 
33
 
99
 	List<Map<String, String>> getUserRole(Integer userId);
34
 	List<Map<String, String>> getUserRole(Integer userId);
35
+
36
+	/**
37
+	 * 查询一条第三方接口配置数据
38
+	 * @param param
39
+	 * @return
40
+	 */
41
+	Map<String, Object> getSysCodeUrl(Map<String, Object> param);
100
 }
42
 }

+ 4 - 0
src/main/java/com/chinaitop/depot/business/mapper/BusinessNoticeReceiveMapper.xml

@@ -782,4 +782,8 @@
782
 					user_id = #{userId,jdbcType=INTEGER}
782
 					user_id = #{userId,jdbcType=INTEGER}
783
 			)
783
 			)
784
   </select>
784
   </select>
785
+  
786
+  <select id="getSysCodeUrl" parameterType="java.util.HashMap" resultType="java.util.HashMap">
787
+  	select * from sys_code WHERE org_id=#{orgId,jdbcType=INTEGER} and s_code=#{sCode,jdbcType=VARCHAR}
788
+  </select>
785
 </mapper>
789
 </mapper>

+ 1 - 2
src/main/java/com/chinaitop/depot/business/service/FeignBasicService.java

@@ -12,7 +12,6 @@ import com.chinaitop.depot.utils.HelloServiceHystrix;
12
 @FeignClient(name = "depot-basic", fallback = HelloServiceHystrix.class)
12
 @FeignClient(name = "depot-basic", fallback = HelloServiceHystrix.class)
13
 public interface FeignBasicService {
13
 public interface FeignBasicService {
14
 
14
 
15
-
16
     @RequestMapping(value = "/Warehouse/getWareDataByHwbm", method = RequestMethod.GET)
15
     @RequestMapping(value = "/Warehouse/getWareDataByHwbm", method = RequestMethod.GET)
17
     Map<String, Object> getWareDataByHwbm(@RequestParam(value = "hwbm") String hwbm);
16
     Map<String, Object> getWareDataByHwbm(@RequestParam(value = "hwbm") String hwbm);
18
 
17
 
@@ -31,7 +30,7 @@ public interface FeignBasicService {
31
 
30
 
32
     @RequestMapping(value = "/Warehouse/getHouseIdBySptDataID", method = RequestMethod.GET)
31
     @RequestMapping(value = "/Warehouse/getHouseIdBySptDataID", method = RequestMethod.GET)
33
     String getHouseIdBySptDataID(@RequestParam(value = "sptDataId") String sptDataId);
32
     String getHouseIdBySptDataID(@RequestParam(value = "sptDataId") String sptDataId);
34
-    
33
+
35
     @RequestMapping(value = "/Tank/getTankIdBySptDataID", method = RequestMethod.GET)
34
     @RequestMapping(value = "/Tank/getTankIdBySptDataID", method = RequestMethod.GET)
36
     String getTankIdBySptDataID(@RequestParam(value = "sptDataId") String sptDataId);
35
     String getTankIdBySptDataID(@RequestParam(value = "sptDataId") String sptDataId);
37
 
36
 

+ 43 - 12
src/main/java/com/chinaitop/depot/business/service/impl/ReceiveNoticeServiceImpl.java

@@ -525,7 +525,7 @@ public class ReceiveNoticeServiceImpl implements ReceiveNoticeService {
525
         		receiveNotice.setLdshr(userId+"");
525
         		receiveNotice.setLdshr(userId+"");
526
         		businessApproval.setTaskName("库领导审批");//任务名称
526
         		businessApproval.setTaskName("库领导审批");//任务名称
527
         	}
527
         	}
528
-        	
528
+
529
         	//修改本条数据
529
         	//修改本条数据
530
         	businessNoticeReceiveMapper.updateByPrimaryKeySelective(receiveNotice);
530
         	businessNoticeReceiveMapper.updateByPrimaryKeySelective(receiveNotice);
531
 
531
 
@@ -533,14 +533,38 @@ public class ReceiveNoticeServiceImpl implements ReceiveNoticeService {
533
         //增加审批表数据
533
         //增加审批表数据
534
     	businessApprovalService.add(businessApproval);
534
     	businessApprovalService.add(businessApproval);
535
 
535
 
536
-    	System.out.println("5".equals(receiveNotice.getAuditState().toString()));
537
-    	System.out.println("1".equals(receiveNotice.getIsNotice().toString()));
538
-    	System.out.println("0".equals(receiveNotice.getIsSheet().toString()));
539
-    	System.out.println("1".equals(receiveNotice.getCrktype()));
540
     	//必须是入库,库级和市级都审批完成,并且不是通知单,只是性质转变单
536
     	//必须是入库,库级和市级都审批完成,并且不是通知单,只是性质转变单
541
     	if ("5".equals(receiveNotice.getAuditState().toString()) && "1".equals(receiveNotice.getIsNotice().toString()) && "0".equals(receiveNotice.getIsSheet().toString()) && "1".equals(receiveNotice.getCrktype())) {
537
     	if ("5".equals(receiveNotice.getAuditState().toString()) && "1".equals(receiveNotice.getIsNotice().toString()) && "0".equals(receiveNotice.getIsSheet().toString()) && "1".equals(receiveNotice.getCrktype())) {
542
 			//转储成功后把信息给市平台
538
 			//转储成功后把信息给市平台
543
-			retSptMeagess(receiveNotice);
539
+			//retSptMeagess(receiveNotice);
540
+    		try {
541
+    			Map<String, Object> sysCodeMap = new HashMap<>();
542
+    			sysCodeMap.put("orgId", 10);
543
+    			sysCodeMap.put("sCode", "xzzzxxts");
544
+    			Map<String, Object> resultMap = businessNoticeReceiveMapper.getSysCodeUrl(sysCodeMap);
545
+    			String path = "";
546
+    			if (null != resultMap) {
547
+    				path = resultMap.get("s_val").toString();
548
+    			}
549
+    			if (null != receiveNotice.getCblx() && null != receiveNotice.getYsid()) {
550
+
551
+    				//组装请求参数
552
+    				Map<String, String> params = new HashMap<>();
553
+    				params.put("crklx", receiveNotice.getCblx());
554
+    				params.put("ysid", receiveNotice.getYsid());
555
+
556
+    				logger.info("给给市平台发送性质转变成功通知信息:"+params.toString());
557
+    				logger.info("给给市平台发送性质转变成功通知信息地址是:"+path);
558
+
559
+    				//给市平台发送请求
560
+    				String result = HTTPUtils.doPost(path, params);
561
+
562
+    				//保存推送合同引用状态的消息和返回结果
563
+    				systemOutsideDataService.addlogger("xzzzxx_result", params.toString(), result);
564
+    			}
565
+    		} catch (Exception e) {
566
+    			e.printStackTrace();
567
+    		}
544
     	}
568
     	}
545
 	}
569
 	}
546
 
570
 
@@ -560,21 +584,28 @@ public class ReceiveNoticeServiceImpl implements ReceiveNoticeService {
560
 		String result = "";
584
 		String result = "";
561
 
585
 
562
 		//获取请求的URL地址
586
 		//获取请求的URL地址
563
-		String path;
564
 		try {
587
 		try {
565
-			path = sysCodeService.getSVal(10, "xzzzxxts");
588
+			Map<String, Object> sysCodeMap = new HashMap<>();
589
+			sysCodeMap.put("orgId", 10);
590
+			sysCodeMap.put("sCode", "xzzzxxts");
591
+			Map<String, Object> resultMap = businessNoticeReceiveMapper.getSysCodeUrl(sysCodeMap);
592
+			String path = "";
593
+			if (null != resultMap) {
594
+				path = resultMap.get("s_val").toString();
595
+			}
566
 			if (null != receiveNotice.getCblx() && null != receiveNotice.getYsid()) {
596
 			if (null != receiveNotice.getCblx() && null != receiveNotice.getYsid()) {
567
-				
597
+
568
 				//组装请求参数
598
 				//组装请求参数
569
 				Map<String, String> params = new HashMap<>();
599
 				Map<String, String> params = new HashMap<>();
570
 				params.put("crklx", receiveNotice.getCblx());
600
 				params.put("crklx", receiveNotice.getCblx());
571
 				params.put("ysid", receiveNotice.getYsid());
601
 				params.put("ysid", receiveNotice.getYsid());
572
-				
602
+
573
 				logger.info("给给市平台发送性质转变成功通知信息:"+params.toString());
603
 				logger.info("给给市平台发送性质转变成功通知信息:"+params.toString());
574
-				
604
+				logger.info("给给市平台发送性质转变成功通知信息地址是:"+path);
605
+
575
 				//给市平台发送请求
606
 				//给市平台发送请求
576
 				result = HTTPUtils.doPost(path, params);
607
 				result = HTTPUtils.doPost(path, params);
577
-				
608
+
578
 				//保存推送合同引用状态的消息和返回结果
609
 				//保存推送合同引用状态的消息和返回结果
579
 				systemOutsideDataService.addlogger("xzzzxx_result", params.toString(), result);
610
 				systemOutsideDataService.addlogger("xzzzxx_result", params.toString(), result);
580
 			}
611
 			}

+ 1 - 0
src/main/java/com/chinaitop/depot/system/service/impl/SysCodeServiceImpl.java

@@ -41,6 +41,7 @@ public class SysCodeServiceImpl implements SysCodeService {
41
 			SysCode sysCode = querySysCode(orgId, sCode);
41
 			SysCode sysCode = querySysCode(orgId, sCode);
42
 			if (null != sysCode) {
42
 			if (null != sysCode) {
43
 				val = sysCode.getsVal();
43
 				val = sysCode.getsVal();
44
+				System.out.println("配置数据是:"+val);
44
 			} else {
45
 			} else {
45
 				val = "无此配置";
46
 				val = "无此配置";
46
 				System.out.println("没有检测到配置URL");
47
 				System.out.println("没有检测到配置URL");