添加定时任务

watero-rst-web/src/main/java/com/iamberry/rst/controllers/mq/MQTask.java

@@ -74,6 +74,11 @@ public class MQTask implements InitializingBean {
 	private CustomerInfoMapper customerInfoMapper;
 	@Autowired
 	private SysConfigService sysConfigService;
+	@Autowired
+	private CustomerCommonService customerCommonService;
+	@Autowired
+	private KuaiDi100 kuaidi100;
+
 
 
 
@@ -417,4 +422,32 @@ public class MQTask implements InitializingBean {
 		map.put("district",districtList.get(0).getDistrict());
 		return map;
 	}
+
+
+	/**客诉系统  自动追踪发货信息**/
+//	@Scheduled(cron = "0 0/30 * * * ?")//每30分钟执行一次
+		@Scheduled(cron = "0 0/3 * * * ?")//每三分钟执行一次
+	public void syncSendBackCustomer()throws Exception{
+		CustomerCommon customerCommon = new CustomerCommon();
+		customerCommon.setRelationBackStatus(2);
+		List<CustomerCommon> customerCommonList = customerCommonService.listCustomerCommon(customerCommon);
+		for(int i=0;i<customerCommonList.size();i++){
+			CustomerCommon cc = customerCommonList.get(i);
+			if(!StringUtils.isEmpty(cc.getRelationBackLogisticsCompany()) && StringUtils.isEmpty(cc.getRelationBackLogisticsNo())){
+				JSONObject rst = kuaidi100.getExpressInfo(cc.getRelationBackLogisticsCompany(),cc.getRelationBackLogisticsNo());
+				if(rst.has("state") && rst.getInt("state") == 3){
+				}
+			}
+		}
+
+	}
+
+
+	public static void main(String[] args) {
+		KuaiDi100 kuaiDi100 = new KuaiDi100();
+		JSONObject rst = kuaiDi100.getExpressInfo("sto","3347947142695");
+
+	}
+
+
 }