1.添加关注 取消关注 接口

2.用户关注列表接口
3.详情返回是否关注商品
4.定时任务开拍半小时喝10分钟进行提醒

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/base/enums/WxMsgEnum.java

@@ -0,0 +1,39 @@
+package com.ydw.yunbuyer.web.pm.base.enums;
+
+public enum WxMsgEnum {
+    AUCTION_START_REMINDER("拍卖开始提醒","https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=ACCESS_TOKEN","lAd9AXOhtfFHaSgzd6BMZibSieaYjFb9cu2_1MKUvNY");
+
+    private String explain;
+    private String wx_connect_url;
+    private String template_id;
+
+    WxMsgEnum( String explain ,String wx_connect_url, String template_id) {
+        this.explain = explain;
+        this.wx_connect_url = wx_connect_url;
+        this.template_id = template_id;
+    }
+
+    public String getWx_connect_url() {
+        return wx_connect_url;
+    }
+
+    public void setWx_connect_url(String wx_connect_url) {
+        this.wx_connect_url = wx_connect_url;
+    }
+
+    public String getTemplate_id() {
+        return template_id;
+    }
+
+    public void setTemplate_id(String template_id) {
+        this.template_id = template_id;
+    }
+
+    public String getExplain() {
+        return explain;
+    }
+
+    public void setExplain(String explain) {
+        this.explain = explain;
+    }
+}

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/controller/api/TokenPersonController.java

@@ -0,0 +1,34 @@
+package com.ydw.yunbuyer.web.pm.controller.api;
+
+import com.ydw.yunbuyer.web.pm.base.ProjBaseAction;
+import com.ydw.yunbuyer.web.pm.web.WebMsgTools;
+import io.swagger.annotations.Api;
+import org.springframework.context.annotation.Scope;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.io.IOException;
+
+@Api(tags = "Token获取")
+@RestController
+@Scope("prototype")
+@RequestMapping("/api/token")
+public class TokenPersonController extends ProjBaseAction {
+
+	/**
+	 *
+	 * 获取token
+	 * @return
+	 */
+	@RequestMapping("/get_token")
+	public String get_token() {
+		String token = null;
+		try {
+			token = WebMsgTools.get_access_Token();
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+		result.put("token", token);
+		return result.toJSONString();
+	}
+}

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/controller_wxapp/ScheduledController.java

@@ -1,10 +1,15 @@
 package com.ydw.yunbuyer.web.pm.controller_wxapp;
 
-import java.util.List;
-import java.util.Map;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+import com.ydw.yunbuyer.web.pm.entity.t_pm_item_follow;
+import com.ydw.yunbuyer.web.pm.service.WxFollowService;
+import com.ydw.yunbuyer.web.pm.web.WebMsgTools;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
 import org.tmsps.ne4spring.utils.ChkUtil;
 import com.ydw.yunbuyer.api.user.api.PersionApi;
 import com.ydw.yunbuyer.api.user.entity.Persion;
@@ -25,6 +30,10 @@ import com.ydw.yunbuyer.web.pm.service.WxPmService;
 @Component
 public class ScheduledController {
 
+	private static long SAME_DAY_END = 0L;//当天结束日期
+	private static SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm"); //格式化
+	private static Map<String,List<Map<String, Object>>> SAME_DAY_MAP = new HashMap<>();//缓存数据
+
 	@Autowired
 	private PmItemService pmItemService;
 
@@ -35,6 +44,9 @@ public class ScheduledController {
 	private ShopService shopService;
 
 	@Autowired
+	private WxFollowService wxFollowService;
+
+	@Autowired
 	PersionApi persionApi;
 
 	@Scheduled(cron = "*/1 * * * * ?")
@@ -71,4 +83,89 @@ public class ScheduledController {
 			}
 		}
 	}
+
+
+	/**
+	 * 1.获取当前时间
+	 * 2.通过比较结束时间判断是否需要刷新缓存数据
+	 *   缓存数据
+	 * 3.查询数据
+	 * 	 3.1 当前时间加30分钟查询数据
+	 * 	 3.2 当前时间加10分钟查询数据
+	 * 4.发送消息
+	 */
+	@Scheduled(cron = "0 0/1 * * * ?")
+	public void auto_wx_msg() {
+		//1.获取当前时间
+		long nowTime = System.currentTimeMillis();
+		//2.通过比较结束时间判断是否需要刷新缓存数据
+		if (nowTime>SAME_DAY_END){
+			SAME_DAY_END = getEndTime();//更新时间
+			SAME_DAY_MAP = new HashMap<>();//更新数据
+			addSameDayMap(nowTime);
+		}
+		if (CollectionUtils.isEmpty(SAME_DAY_MAP)){
+			return;
+		}
+		//3.查询数据 1.当前时间加30分钟查询数据 2.当前时间加10分钟查询数据
+		String key1 = formatter.format(nowTime+1800000);
+		sendMsg(SAME_DAY_MAP.get(key1));
+		String key2 = formatter.format(nowTime+600000);
+		sendMsg(SAME_DAY_MAP.get(key2));
+	}
+
+	//出现当天新增的情况需要初始化数据
+	public static void initSameDayEnd(long time_opening){
+		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd"); //格式化
+		String nowTime = format.format(System.currentTimeMillis());
+		String timeOpening = format.format(time_opening);
+		if (nowTime.equals(timeOpening)){
+			SAME_DAY_END = 0L;
+		}
+	}
+
+	private void addSameDayMap(long nowTime) {
+		long queryTime = SAME_DAY_END+1800000;
+		List<Map<String, Object>> mapList = wxFollowService.auto_wx_msg(nowTime,queryTime);
+		for (Map<String, Object> map:mapList) {
+			String time_opening = formatter.format(map.get("time_opening"));
+			List<Map<String, Object>> maps = SAME_DAY_MAP.get(time_opening);
+			if (CollectionUtils.isEmpty(maps)){
+				List<Map<String, Object>> list = new ArrayList<>();
+				list.add(map);
+				SAME_DAY_MAP.put(time_opening,list);
+			}else{
+				List<Map<String, Object>> maps1 = SAME_DAY_MAP.get(time_opening);
+				maps1.add(map);
+				SAME_DAY_MAP.put(time_opening,maps1);
+			}
+		}
+	}
+
+	private void sendMsg(List<Map<String, Object>> list) {
+		if (CollectionUtils.isEmpty(list)){
+			return;
+		}
+		for (Map<String, Object> map:list) {
+			String open_id = String.valueOf(map.get("open_id"));
+			String pm_item_name = String.valueOf(map.get("pm_item_name"));
+			String time_opening = String.valueOf(map.get("time_opening"));
+			WebMsgTools.sendAuctionStartReminderMessage(open_id,pm_item_name,time_opening);
+		}
+	}
+
+	private static long getEndTime() {
+		Calendar todayEnd = Calendar.getInstance();
+		todayEnd.set(Calendar.SECOND, 59);
+		todayEnd.set(Calendar.MINUTE, 59);
+		todayEnd.set(Calendar.HOUR_OF_DAY, 23);
+		todayEnd.set(Calendar.MILLISECOND, 999);
+		return todayEnd.getTimeInMillis();
+	}
+
+	public static void main(String[] args) {
+		System.out.println(System.currentTimeMillis());
+		System.out.println(getEndTime());
+
+	}
 }

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/controller_wxapp/WxFollowController.java

@@ -0,0 +1,88 @@
+package com.ydw.yunbuyer.web.pm.controller_wxapp;
+
+import com.alibaba.fastjson.JSONObject;
+import com.ydw.yunbuyer.common.utils.date.CreatedTools;
+import com.ydw.yunbuyer.web.pm.base.ProjBaseAction;
+import com.ydw.yunbuyer.web.pm.entity.t_pm_item;
+import com.ydw.yunbuyer.web.pm.entity.t_pm_item_follow;
+import com.ydw.yunbuyer.web.pm.service.PmItemService;
+import com.ydw.yunbuyer.web.pm.service.WxFollowService;
+import com.ydw.yunbuyer.web.pm.web.SessionWxService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Scope;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+import java.util.Map;
+
+@Api(tags = "关注管理")
+@RestController
+@Scope("prototype")
+@RequestMapping("/wx/follow")
+public class WxFollowController extends ProjBaseAction {
+    @Autowired
+    private SessionWxService sessionWxService;
+    @Autowired
+    private WxFollowService wxFollowService;
+    @Autowired
+    private PmItemService pmItemService;
+
+    @ApiOperation("关注和取消")
+    @RequestMapping("/edit_pm_follow")
+    public String edit_pm_follow(String pm_item_id){
+        if (StringUtils.isBlank(pm_item_id)){
+            result.put("statuz",false);
+            result.put("message", "输入标的物id为空");
+            return result.toJSONString();
+        }
+        t_pm_item t_pm_item = pmItemService.get(pm_item_id);
+        if (t_pm_item == null ){
+            result.put("statuz",false);
+            result.put("message", "标的物不存在");
+            return result.toJSONString();
+        }
+        if (t_pm_item.getTime_opening() <0 ){
+            result.put("statuz",false);
+            result.put("message", "标的物开拍时间没设置");
+            return result.toJSONString();
+        }
+        JSONObject person = sessionWxService.getCurrentLoginPersion();
+        String person_id = person.getString("kid");//用户id
+        String open_id = person.getString("openid");//用户openid
+        t_pm_item_follow pm_item_follow = wxFollowService.getPersonidAndPmid(person_id,pm_item_id);
+        if (pm_item_follow == null){
+            t_pm_item_follow addParam = new t_pm_item_follow();
+            addParam.setPerson_id(person_id);
+            addParam.setOpen_id(open_id);
+            addParam.setPm_item_id(pm_item_id);
+            addParam.setPm_item_name(t_pm_item.getItem_name());
+            addParam.setStatus(0);
+            addParam.setTime_opening(t_pm_item.getTime_opening());
+            wxFollowService.add(addParam);
+        }else{
+            int status = pm_item_follow.getStatus() == 0? -100 : 0; //转换关注状态
+            pm_item_follow.setStatus(status);
+            pm_item_follow.setEditd(CreatedTools.getCreated());
+            pm_item_follow.setEdit_count(pm_item_follow.getEdit_count()+1);
+            wxFollowService.update(pm_item_follow);
+        }
+        result.put("statuz",true);
+        result.put("message", "操作成功");
+        return result.toJSONString();
+    }
+
+    @ApiOperation("查询用户关注的标的物")
+    @RequestMapping("/list_person_pm_follow")
+    public String list_person_pm_follow() {
+        JSONObject person = sessionWxService.getCurrentLoginPersion();
+        String person_id = person.getString("kid");//用户id
+        List<Map<String, Object>> list = wxFollowService.list_person_pm_follow(person_id);
+        result.put("data", list);
+        return result.toJSONString();
+    }
+
+}

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/controller_wxapp/WxItemController.java

@@ -61,6 +61,7 @@ public class WxItemController extends ProjBaseAction {
 		project_item.setBidding_linkman(bidding_linkman);
 		project_item.setBidding_contact(bidding_contact);
 		wxItemService.add(project_item);
+		ScheduledController.initSameDayEnd(project_item.getTime_opening());//新增是判断是否需要刷新定时缓存
 		return result.toJSONString();
 	}
 

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/controller_wxapp/WxPmApiController.java

@@ -1,16 +1,16 @@
 package com.ydw.yunbuyer.web.pm.controller_wxapp;
 
+import com.alibaba.fastjson.JSONObject;
 import com.ydw.yunbuyer.api.user.api.PersionApi;
 import com.ydw.yunbuyer.api.user.entity.Persion;
 import com.ydw.yunbuyer.common.utils.ChkTools;
 import com.ydw.yunbuyer.web.pm.base.ProjBaseAction;
 import com.ydw.yunbuyer.web.pm.entity.t_pm_item;
+import com.ydw.yunbuyer.web.pm.entity.t_pm_item_follow;
 import com.ydw.yunbuyer.web.pm.entity.t_pm_item_submit_offer;
 import com.ydw.yunbuyer.web.pm.entity.t_shop;
-import com.ydw.yunbuyer.web.pm.service.PmItemService;
-import com.ydw.yunbuyer.web.pm.service.ShopService;
-import com.ydw.yunbuyer.web.pm.service.SlideShowService;
-import com.ydw.yunbuyer.web.pm.service.WxPmService;
+import com.ydw.yunbuyer.web.pm.service.*;
+import com.ydw.yunbuyer.web.pm.web.SessionWxService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -52,6 +52,11 @@ public class WxPmApiController extends ProjBaseAction {
 	@Autowired
 	private ShopService shopService;
 
+	@Autowired
+	private SessionWxService sessionWxService;
+	@Autowired
+	private WxFollowService wxFollowService;
+
 	@RequestMapping("/list_item")
 	public String list_item() {
 		List<Map<String, Object>> list = pmItemService.list_all_open();
@@ -109,11 +114,19 @@ public class WxPmApiController extends ProjBaseAction {
 		}
 		// 竞价记录
 		List<Map<String, Object>> list1 = wxPmService.bidding_record(kid);
+
+		// 是否关注查询
+		JSONObject person = sessionWxService.getCurrentLoginPersion();
+		String person_id = person.getString("kid");//用户id
+		t_pm_item_follow pm_follow = wxFollowService.getPersonidAndPmid(person_id, kid);
+		Boolean follow = pm_follow == null?false:pm_follow.getStatus()==0; //true 关注 false 没关注
+
 		result.put("nowtime", System.currentTimeMillis());
 		result.put("imgarray", imgsrclist);
 		result.put("data", list);
 		result.put("record", list1);
 		result.put("statuz", true);
+		result.put("follow", follow); //true 关注 false 没关注
 		return result.toJSONString();
 	}
 

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/dao/WxFollowDao.java

@@ -0,0 +1,15 @@
+package com.ydw.yunbuyer.web.pm.dao;
+
+import com.ydw.yunbuyer.web.pm.entity.t_pm_item_follow;
+
+import java.util.List;
+import java.util.Map;
+
+public interface WxFollowDao extends BaseDao<t_pm_item_follow> {
+
+    t_pm_item_follow getPersonidAndPmid(String person_id, String pm_item_id);
+
+    List<Map<String, Object>> list_person_pm_follow(String person_id);
+
+    List<Map<String, Object>> auto_wx_msg(long nowTime, long queryTime);
+}

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/daoImpl/WxFollowDaoImpl.java

@@ -0,0 +1,41 @@
+package com.ydw.yunbuyer.web.pm.daoImpl;
+
+import com.ydw.yunbuyer.web.pm.base.BaseMySQLService;
+import com.ydw.yunbuyer.web.pm.dao.WxFollowDao;
+import com.ydw.yunbuyer.web.pm.entity.t_pm_item_follow;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Map;
+
+@Repository
+public class WxFollowDaoImpl extends BaseDaoImpl<t_pm_item_follow> implements WxFollowDao {
+
+    @Autowired
+    private BaseMySQLService bs;
+
+    @Override
+    public t_pm_item_follow getPersonidAndPmid(String person_id, String pm_item_id) {
+        String sql = "select * from t_pm_item_follow where person_id = '"+person_id+"' and pm_item_id ='"+pm_item_id+"' ";
+        t_pm_item_follow t = bs.findObj(sql,t_pm_item_follow.class);
+        return t;
+    }
+
+    @Override
+    public List<Map<String, Object>> list_person_pm_follow(String person_id) {
+        String sql = " select pi.* from t_pm_item_follow t  "
+            +" left join t_pm_item pi on pi.kid = t.pm_item_id "
+            +" where t.status = 0 and t.person_id = '"+person_id+"' "
+            +" ORDER BY t.created desc  ";
+        List<Map<String, Object>> list = bs.findList(sql);
+        return list;
+    }
+
+    @Override
+    public List<Map<String, Object>> auto_wx_msg(long nowTime, long queryTime) {
+        String sql = " select open_id,pm_item_name,time_opening from t_pm_item_follow where time_opening > "+nowTime+" and time_opening < "+queryTime;
+        List<Map<String, Object>> list = bs.findList(sql);
+        return list;
+    }
+}

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/entity/WxMsgVo.java

@@ -0,0 +1,50 @@
+package com.ydw.yunbuyer.web.pm.entity;
+
+import java.util.Map;
+
+public class WxMsgVo {
+    private String touser;//用户openid
+    private String template_id;//模版id
+    private String page;//默认跳到小程序首页
+    private String form_id;//收集到的用户formid
+    private String emphasis_keyword = "";//放大那个推送字段
+    private Map<String, TemplateData> data;//推送文字
+	public String getTouser() {
+		return touser;
+	}
+	public void setTouser(String touser) {
+		this.touser = touser;
+	}
+	public String getTemplate_id() {
+		return template_id;
+	}
+	public void setTemplate_id(String template_id) {
+		this.template_id = template_id;
+	}
+	public String getPage() {
+		return page;
+	}
+	public void setPage(String page) {
+		this.page = page;
+	}
+	public String getForm_id() {
+		return form_id;
+	}
+	public void setForm_id(String form_id) {
+		this.form_id = form_id;
+	}
+	public String getEmphasis_keyword() {
+		return emphasis_keyword;
+	}
+	public void setEmphasis_keyword(String emphasis_keyword) {
+		this.emphasis_keyword = emphasis_keyword;
+	}
+	public Map<String, TemplateData> getData() {
+		return data;
+	}
+	public void setData(Map<String, TemplateData> data) {
+		this.data = data;
+	}
+    
+    
+}

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/entity/t_pm_item_follow.java

@@ -0,0 +1,98 @@
+package com.ydw.yunbuyer.web.pm.entity;
+
+import com.ydw.yunbuyer.common.utils.date.CreatedTools;
+import org.tmsps.ne4spring.annotation.Table;
+import org.tmsps.ne4spring.orm.model.DataModel;
+
+
+/**
+ * 标段（包）
+ */
+
+@Table
+public class t_pm_item_follow extends DataModel {
+
+	/** 表字段 **/
+	private String person_id; //用户id
+	private String open_id; //用户openid
+	private String pm_item_id; //标的物id
+	private String pm_item_name; //标的物名称
+	private long time_opening; //开始时间
+	private int status;	//状态：0.关注 -100.取消关注(假删除)
+	private int edit_count; //修改次数
+	private long created = CreatedTools.getCreated(); //创建时间
+	private long editd = CreatedTools.getCreated(); //修改时间
+
+	public String getPerson_id() {
+		return person_id;
+	}
+
+	public void setPerson_id(String person_id) {
+		this.person_id = person_id;
+	}
+
+	public String getPm_item_id() {
+		return pm_item_id;
+	}
+
+	public void setPm_item_id(String pm_item_id) {
+		this.pm_item_id = pm_item_id;
+	}
+
+	public int getStatus() {
+		return status;
+	}
+
+	@Override
+	public void setStatus(int status) {
+		this.status = status;
+	}
+
+	public int getEdit_count() {
+		return edit_count;
+	}
+
+	public void setEdit_count(int edit_count) {
+		this.edit_count = edit_count;
+	}
+
+	public long getCreated() {
+		return created;
+	}
+
+	public void setCreated(long created) {
+		this.created = created;
+	}
+
+	public long getEditd() {
+		return editd;
+	}
+
+	public void setEditd(long editd) {
+		this.editd = editd;
+	}
+
+	public long getTime_opening() {
+		return time_opening;
+	}
+
+	public void setTime_opening(long time_opening) {
+		this.time_opening = time_opening;
+	}
+
+	public String getOpen_id() {
+		return open_id;
+	}
+
+	public void setOpen_id(String open_id) {
+		this.open_id = open_id;
+	}
+
+	public String getPm_item_name() {
+		return pm_item_name;
+	}
+
+	public void setPm_item_name(String pm_item_name) {
+		this.pm_item_name = pm_item_name;
+	}
+}

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/service/WxFollowService.java

@@ -0,0 +1,17 @@
+package com.ydw.yunbuyer.web.pm.service;
+
+
+import com.ydw.yunbuyer.web.pm.entity.t_pm_item_follow;
+
+import java.util.List;
+import java.util.Map;
+
+public interface WxFollowService extends BaseService<t_pm_item_follow> {
+
+    t_pm_item_follow getPersonidAndPmid(String person_id, String pm_item_id);
+
+    List<Map<String, Object>> list_person_pm_follow(String person_id);
+
+    List<Map<String, Object>> auto_wx_msg(long nowTime, long queryTime);
+
+}

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/serviceImpl/WxFollowServiceImpl.java

@@ -0,0 +1,31 @@
+package com.ydw.yunbuyer.web.pm.serviceImpl;
+
+import com.ydw.yunbuyer.web.pm.dao.WxFollowDao;
+import com.ydw.yunbuyer.web.pm.entity.t_pm_item_follow;
+import com.ydw.yunbuyer.web.pm.service.WxFollowService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class WxFollowServiceImpl  extends BaseServiceImpl<t_pm_item_follow> implements WxFollowService {
+    @Autowired
+    private WxFollowDao wxFollowDao;
+
+    @Override
+    public t_pm_item_follow getPersonidAndPmid(String person_id, String pm_item_id) {
+        return wxFollowDao.getPersonidAndPmid(person_id,pm_item_id);
+    }
+
+    @Override
+    public List<Map<String, Object>> list_person_pm_follow(String person_id) {
+        return wxFollowDao.list_person_pm_follow(person_id);
+    }
+
+    @Override
+    public List<Map<String, Object>> auto_wx_msg(long nowTime, long queryTime) {
+        return wxFollowDao.auto_wx_msg(nowTime,queryTime);
+    }
+}

krock-pm/krock-web-pm/src/main/java/com/ydw/yunbuyer/web/pm/web/WebMsgTools.java

@@ -0,0 +1,166 @@
+package com.ydw.yunbuyer.web.pm.web;
+
+import com.alibaba.fastjson.JSONObject;
+import com.ydw.yunbuyer.web.pm.entity.TemplateData;
+import com.ydw.yunbuyer.web.pm.entity.WxMssVo;
+import org.apache.http.client.ClientProtocolException;
+import org.tmsps.ne4spring.utils.JsonUtil;
+
+import java.io.BufferedReader;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.URLConnection;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Random;
+
+public class WebMsgTools {
+	private static String subscribeMessageUrl = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=ACCESS_TOKEN";
+
+	/**
+	 *  拍卖开始提醒
+	 * @return
+	 */
+	public static String sendAuctionStartReminderMessage(String openId,String thing,String date){
+		String url = null;
+		try {
+			url = subscribeMessageUrl.replace("ACCESS_TOKEN",get_access_Token());
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+		WxMssVo wxMssVo = new WxMssVo();
+		wxMssVo.setTouser(openId);
+		wxMssVo.setTemplate_id("lAd9AXOhtfFHaSgzd6BMZibSieaYjFb9cu2_1MKUvNY");
+		Map<String, TemplateData> m = new HashMap<>();
+		TemplateData thing1 = new TemplateData();
+		thing1.setValue(thing);
+		m.put("thing1",thing1);
+
+		TemplateData date3 = new TemplateData();
+		date3.setValue(date);
+		m.put("date2",date3);
+
+		wxMssVo.setData(m);
+		String response = sendPost(url, wxMssVo);
+		System.out.println(response);
+		return response;
+	}
+
+	/**
+	 *  拍卖成功通知
+	 * @return
+	 */
+	public static String sendAuctionSuccessNoticeMessage(String openId,String thing,String amount,String date,String number) throws IOException {
+		String url = subscribeMessageUrl.replace("ACCESS_TOKEN",get_access_Token());
+		WxMssVo wxMssVo = new WxMssVo();
+		wxMssVo.setTouser(openId);
+		wxMssVo.setTemplate_id("W0zx3nSHECvFmrkYRGZpnUnsTlTGOaK2b3LbTDeB4cA");
+		Map<String, TemplateData> m = new HashMap<>();
+		TemplateData thing1 = new TemplateData();
+		thing1.setValue(thing);
+		m.put("thing1",thing1);
+
+		TemplateData amount2 = new TemplateData();
+		amount2.setValue(amount);
+		m.put("amount2",amount2);
+
+		TemplateData date3 = new TemplateData();
+		date3.setValue(date);
+		m.put("date3",date3);
+
+		TemplateData number9 = new TemplateData();
+		number9.setValue(number);
+		m.put("number9",number9);
+
+		wxMssVo.setData(m);
+		String response = sendPost(url, wxMssVo);
+		System.out.println(response);
+		return response;
+	}
+
+	public static String get_access_Token() throws ClientProtocolException, IOException {
+		String appid = WebTools.getAppId();
+		String appsecret = WebTools.getAppSecret();
+		String getOpenIdUrl = "https://api.weixin.qq.com/cgi-bin/token?appid=APPID&secret=APPSECRET&grant_type=authorization_code";
+		// 获取返回的code
+		String requestUrl = getOpenIdUrl.replace("authorization_code", "client_credential").replace("APPID", appid)
+				.replace("APPSECRET", appsecret);
+		String response = WebTools.sendGetReq(requestUrl);
+		System.out.println(response);
+		JSONObject jsonobj = JsonUtil.jsonStrToJsonObject(response);
+		String access_token = jsonobj.getString("access_token");
+		return access_token;
+	}
+
+	public static String sendPost(String url, WxMssVo wxMssVo) {
+		String result = "";
+		BufferedReader in = null;
+		try {
+			String urlNameString = url;
+			URL realUrl = new URL(urlNameString);
+			// 打开和URL之间的连接
+			URLConnection urlconnection = realUrl.openConnection();
+			urlconnection.setDoOutput(true);
+			// 设置通用的请求属性
+			HttpURLConnection connection = (HttpURLConnection) urlconnection;
+			connection.setRequestProperty("accept", "*/*");
+			connection.setRequestProperty("connection", "Keep-Alive");
+			connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
+			connection.setRequestProperty("Charset", "UTF-8");
+			connection.setRequestMethod("POST");
+			connection.setDoOutput(true);
+			DataOutputStream dos = new DataOutputStream(connection.getOutputStream());
+			dos.write(JsonUtil.toJson(wxMssVo).getBytes());
+			dos.flush();
+			dos.close();
+			// 建立实际的连接
+			connection.connect();
+			// 获取所有响应头字段
+			java.util.Map<String, List<String>> map = connection.getHeaderFields();
+			// 遍历所有的响应头字段
+			for (String key : map.keySet()) {
+				System.out.println(key + "--->" + map.get(key));
+			}
+			// 定义 BufferedReader输入流来读取URL的响应
+			in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
+			String line;
+			while ((line = in.readLine()) != null) {
+				result += line;
+			}
+		} catch (Exception e) {
+			System.out.println("发送GET请求出现异常！" + e);
+			e.printStackTrace();
+		} // 使用finally块来关闭输入流
+		finally {
+			try {
+				if (in != null) {
+					in.close();
+				}
+			} catch (Exception e2) {
+				e2.printStackTrace();
+			}
+		}
+		return result;
+	}
+
+	public static void main(String[] args) throws IOException {
+//		sendAuctionStartReminderMessage("oIQgR5QOJmf3gMCA2z8HyU9TaI5Q","cs","2022年01月05日");
+//		sendAuctionSuccessNoticeMessage("oIQgR5QOJmf3gMCA2z8HyU9TaI5Q","拍品名称","100","2022年01月05日","1");
+		int i = -1;
+		i >>>= 10;
+		System.out.println(i);
+		long l = -1;
+		l >>>= 10;
+		System.out.println(l);
+		short s = 1;
+		s >>= 10;
+		System.out.println(s);
+		byte b = 1;
+		b >>= 10;
+		System.out.println(b);
+	}
+}