1

陈杰
1 parent a191d3cf
Showing 12 changed files with 300 additions and 4 deletions Show diff stats
src/main/java/com/sincere/wechatbusiness/controller/ChannelController.java
src/main/java/com/sincere/wechatbusiness/controller/CodeController.java
src/main/java/com/sincere/wechatbusiness/controller/TestController.java
src/main/java/com/sincere/wechatbusiness/controller/TokenController.java
src/main/java/com/sincere/wechatbusiness/mapper/ChannelMapper.java
src/main/java/com/sincere/wechatbusiness/mapper/ChannelProductMapper.java
src/main/java/com/sincere/wechatbusiness/model/ChannelProduct.java
src/main/java/com/sincere/wechatbusiness/service/ChannelProductService.java
src/main/java/com/sincere/wechatbusiness/service/impl/ChannelProductServiceImpl.java
src/main/resources/mapper/BannerMapper.xml
src/main/resources/mapper/ChannelMapper.xml
src/main/resources/mapper/ChannelProductMapper.xml
@@ -432,6 +432,14 @@ public class ChannelController {
         return result;
     }
+    @RequestMapping(value = "openAddress",method = RequestMethod.GET)
+    @ApiOperation(value = "开启配送，或者关闭配送")
+    public BaseDto openAddress(int id){
+        ChannelProduct channelProduct = channelProductService.getDetail(id);
+        channelProductService.updateProductOpenAddress(channelProduct.getOpenAddress()==1?0:1,id);
+        return new BaseDto();
+    }
+
     @RequestMapping(value = "GetDiscountPackage",method = RequestMethod.GET)
     @ApiOperation(value = "获取商品详情")
     public BaseDto<DiscountPackage> GetDiscountPackage(int id){
@@ -589,6 +597,7 @@ public class ChannelController {
         object.put("score_id",0);
         object.put("channelId",order.getChannelId());
         object.put("agentId",order.getAgentId());
+        object.put("address",order.getAddress());
         JSONObject jsonObject = HttpClientUtils.httpPostJson(domain+"/University/GetAddOrderDetail",object.toJSONString());
         String data = jsonObject.getString("data");
         result.setData(JSON.parseObject(data,new TypeReference<List<Order>>(){}));
@@ -0,0 +1,58 @@
+//package com.sincere.wechatbusiness.controller;
+//
+//import com.alibaba.fastjson.JSONObject;
+//import com.sincere.wechatbusiness.utils.HttpClientUtils;
+//import org.springframework.web.bind.annotation.RestController;
+//
+//import java.io.*;
+//import java.net.HttpURLConnection;
+//import java.net.URL;
+//
+//@RestController
+//public class CodeController {
+//
+//    private static String appId = "wxd055a716238e1bd7";
+//    private static String secret = "c6912d34732b65116b8b4e9d5f8a81a5";
+//
+//    public static void main(String[] args){
+//        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="+appId+"&secret="+secret;
+//        JSONObject object = HttpClientUtils.httpGet(url) ;
+//        String token = object.get("access_token").toString();
+//        try {
+//            URL imgUrl = new URL("https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token="+token);
+//            HttpURLConnection httpURLConnection = (HttpURLConnection) imgUrl.openConnection();
+//            httpURLConnection.setRequestMethod("POST");// 提交模式
+//            // conn.setConnectTimeout(10000);//连接超时 单位毫秒
+//            // conn.setReadTimeout(2000);//读取超时 单位毫秒
+//            // 发送POST请求必须设置如下两行
+//            httpURLConnection.setDoOutput(true);
+//            httpURLConnection.setDoInput(true);
+//            // 获取URLConnection对象对应的输出流
+//            PrintWriter printWriter = new PrintWriter(httpURLConnection.getOutputStream());
+//            // 发送请求参数
+//            JSONObject paramJson = new JSONObject();
+//            paramJson.put("scene", "channel=2");
+//            paramJson.put("page", "pages/index/index");
+//            paramJson.put("width", 430);
+//            paramJson.put("auto_color", true);
+//            printWriter.write(paramJson.toString());
+//            // flush输出流的缓冲
+//            printWriter.flush();
+//            //开始获取数据
+//            BufferedInputStream bis = new BufferedInputStream(httpURLConnection.getInputStream());
+//            OutputStream os = new FileOutputStream(new File("C:\\Users\\chen\\Desktop\\abc.png"));
+//            int len;
+//            byte[] arr = new byte[1024];
+//            while ((len = bis.read(arr)) != -1)
+//            {
+//                os.write(arr, 0, len);
+//                os.flush();
+//            }
+//            os.close();
+//        }
+//        catch (Exception e)
+//        {
+//            e.printStackTrace();
+//        }
+//    }
+//}
@@ -0,0 +1,107 @@
+//package com.sincere.wechatbusiness.controller;
+//
+//import com.sincere.wechatbusiness.dto.BaseDto;
+//import com.sincere.wechatbusiness.mapper.ChannelMapper;
+//import com.sincere.wechatbusiness.model.Banner;
+//import com.sincere.wechatbusiness.model.BannerNext;
+//import com.sincere.wechatbusiness.model.ChannelProduct;
+//import com.sincere.wechatbusiness.service.BannerService;
+//import com.sincere.wechatbusiness.service.ChannelProductService;
+//import com.sincere.wechatbusiness.service.ChannelService;
+//import org.apache.commons.lang3.StringUtils;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.web.bind.annotation.RequestMapping;
+//import org.springframework.web.bind.annotation.RequestMethod;
+//import org.springframework.web.bind.annotation.RestController;
+//
+//import java.io.BufferedReader;
+//import java.io.FileReader;
+//import java.io.IOException;
+//import java.util.List;
+//
+//@RestController
+//public class TestController {
+//
+//    @Autowired
+//    ChannelService channelService ;
+//
+//    @Autowired
+//    ChannelProductService channelProductService ;
+//
+//    @Autowired
+//    BannerService bannerService ;
+//
+//    @Autowired
+//    ChannelMapper channelMapper ;
+//
+//
+//    public static void  main(String[] args){
+//        try {
+//            FileReader fr = new FileReader("C:\\Users\\chen\\Desktop\\name.txt");
+//            BufferedReader bf = new BufferedReader(fr);
+//            String str;
+//            // 按行读取字符串
+//            while ((str = bf.readLine()) != null) {
+//                String[] message = str.split("=");
+//                System.out.println(message[0]+"="+ message[1] +"="+ java.net.URLEncoder.encode(message[2], "UTF-8"));
+//            }
+//            bf.close();
+//            fr.close();
+//        } catch (IOException e) {
+//            e.printStackTrace();
+//        }
+//    }
+//
+//    @RequestMapping(value = "copy",method = RequestMethod.GET)
+//    public BaseDto copyChannel(){
+//        int sourceId = 1025 ;
+//        ChannelProduct channelProduct = channelProductService.getList(sourceId).get(0);
+//        List<Banner> banners = bannerService.getList(sourceId);
+//        List<BannerNext> bannerNexts = bannerService.getBannerNextList(sourceId);
+//
+//        try {
+//            FileReader fr = new FileReader("C:\\Users\\chen\\Desktop\\name.txt");
+//            BufferedReader bf = new BufferedReader(fr);
+//            String str;
+//            // 按行读取字符串
+//            while ((str = bf.readLine()) != null) {
+//                int channelId =  0;
+//                try{
+//                     channelId = channelMapper.getByName(str.trim() + "团购").getId();
+//                }catch (Exception e){
+//                    System.out.println(str);
+//                    e.printStackTrace();
+//                }
+//                int channelProductId = 0 ;
+//                List<ChannelProduct> products = channelProductService.getList(channelId);
+//                for(ChannelProduct product : products){
+//                    channelProductId = product.getId();
+//                    product.setTitle(channelProduct.getTitle());
+//                    product.setCaption(channelProduct.getCaption());
+//                    product.setChannelPrice(channelProduct.getChannelPrice());
+//                    channelProductService.update(product);
+//                }
+//
+//                bannerService.deleteChannelBanner(channelId);
+//                bannerService.deleteChannelBannerNext(channelId);
+//                for(Banner banner : banners){
+//                    banner.setChannelId(channelId);
+//                    if(StringUtils.isNotBlank(banner.getLinkUrl())){
+//                        banner.setLinkUrl("http://market.myjxt.com/wap/index.html#/CommodityDetail?id="+channelProductId+"&productId=1");
+//                    }
+//                    bannerService.copy(banner);
+//                }
+//                for(BannerNext bannerNext : bannerNexts){
+//                    bannerNext.setChannelId(channelId);
+//                    bannerService.copyBannerNext(bannerNext);
+//                }
+//            }
+//            bf.close();
+//            fr.close();
+//        } catch (IOException e) {
+//            e.printStackTrace();
+//        }
+//
+//        return new BaseDto();
+//    }
+//}
@@ -0,0 +1,91 @@
+package com.sincere.wechatbusiness.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.sincere.wechatbusiness.model.AccessToken;
+import com.sincere.wechatbusiness.model.Token;
+import com.sincere.wechatbusiness.service.ChannelService;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.HttpURLConnection;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.Calendar;
+import java.util.Date;
+
+@RestController
+public class TokenController {
+
+    @Autowired
+    ChannelService channelService ;
+
+    @ApiOperation(value = "获取分享token")
+    @RequestMapping(value = "getToken",method = RequestMethod.GET)
+    public String getToken(){
+        AccessToken accessToken=channelService.getAccessToken();
+        Token token=new Token();
+        if(accessToken!=null) {
+            Calendar dateOne=Calendar.getInstance();
+            Calendar dateTwo=Calendar.getInstance();
+            dateOne.setTime(new Date());
+            dateTwo.setTime(accessToken.getCreateTime());
+            long timeOne=dateOne.getTimeInMillis();
+            long timeTwo=dateTwo.getTimeInMillis();
+            long minute=(timeOne-timeTwo)/(1000*60);
+
+            if(minute<60) token.setAccess_token(accessToken.getAccessToken());
+            else{
+                token=getAccessToken("wx6078ff3f67524996","8a0465b8ad0f000f568f48853e2818c8");
+                accessToken.setAccessToken(token.getAccess_token());
+                channelService.insertAccessToken(accessToken);
+            }
+        }
+        else {
+            token=getAccessToken("wx6078ff3f67524996","8a0465b8ad0f000f568f48853e2818c8");
+            accessToken=new AccessToken();
+            accessToken.setAccessToken(token.getAccess_token());
+            channelService.insertAccessToken(accessToken);
+        }
+        return accessToken.getAccessToken() ;
+    }
+
+    public Token getAccessToken(String appID, String appScret) {
+        Token token = new Token();
+        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appID + "&secret="
+                + appScret;
+        try {
+            URL getUrl=new URL(url);
+            HttpURLConnection http=(HttpURLConnection)getUrl.openConnection();
+            http.setRequestMethod("GET");
+            http.setRequestProperty("Content-Type",
+                    "application/x-www-form-urlencoded");
+            http.setDoOutput(true);
+            http.setDoInput(true);
+
+
+            http.connect();
+            InputStream is = http.getInputStream();
+            int size = is.available();
+            byte[] b = new byte[size];
+            is.read(b);
+
+            String message = new String(b, "UTF-8");
+            JSONObject json = JSONObject.parseObject(message);
+
+
+            token.setAccess_token(json.getString("access_token"));
+            token.setExpires_in(new Integer(json.getString("expires_in")));
+        } catch (MalformedURLException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return token;
+    }
+
+}
@@ -8,6 +8,8 @@ import java.util.List;
 public interface ChannelMapper {
+    Channel getByName(String name);
+
     List<Channel> getListByTemplate(int templateId);
     List<Channel> getList(Channel channel);
 package com.sincere.wechatbusiness.mapper;
 import com.sincere.wechatbusiness.model.ChannelProduct;
+import org.apache.ibatis.annotations.Param;
 import java.util.List;
@@ -16,4 +17,6 @@ public interface ChannelProductMapper {
     ChannelProduct getDetail(int id);
     int updateChannelProductMsg(ChannelProduct channelProduct);
+
+    int updateProductOpenAddress(@Param("openAddress") int openAddress , @Param("id") int id);
 }
@@ -32,6 +32,16 @@ public class ChannelProduct {
     private String channelRequire ;
     private String channelExplain ;
+    private int openAddress ;
+
+    public int getOpenAddress() {
+        return openAddress;
+    }
+
+    public void setOpenAddress(int openAddress) {
+        this.openAddress = openAddress;
+    }
+
     public String getChannelTitle() {
         return channelTitle;
     }
 package com.sincere.wechatbusiness.service;
 import com.sincere.wechatbusiness.model.ChannelProduct;
+import org.apache.ibatis.annotations.Param;
 import java.util.List;
@@ -16,4 +17,6 @@ public interface ChannelProductService {
     ChannelProduct getDetail(int id);
     int updateChannelProductMsg(ChannelProduct channelProduct);
+
+    int updateProductOpenAddress(int openAddress ,int id);
 }
@@ -32,4 +32,9 @@ public class ChannelProductServiceImpl implements ChannelProductService {
     public int updateChannelProductMsg(ChannelProduct channelProduct) {
         return channelProductMapper.updateChannelProductMsg(channelProduct);
     }
+
+    @Override
+    public int updateProductOpenAddress(int openAddress, int id) {
+        return channelProductMapper.updateProductOpenAddress(openAddress,id);
+    }
 }
@@ -43,7 +43,7 @@
         update banner set state=0 where id = #{id}
     </update>
-    <update id="deleteChannelBanner" parameterType="java.lang.Integer">
-        update banner set state=0 where channelId = #{channelId}
-    </update>
+    <delete id="deleteChannelBanner" parameterType="java.lang.Integer">
+        delete banner where channelId = #{channelId}
+    </delete>
 </mapper>
 \ No newline at end of file
@@ -16,6 +16,10 @@
         <result column="city_code" jdbcType="VARCHAR" property="cityCode" />
     </resultMap>
+    <select id="getByName" parameterType="java.lang.String" resultMap="ChannelMap">
+        select * from channel where name = #{name} and state = 1
+    </select>
+
     <resultMap id="AreaMap" type="com.sincere.wechatbusiness.model.Area">
         <result column="value" jdbcType="VARCHAR" property="value" />
         <result column="label" jdbcType="VARCHAR" property="label" />
@@ -19,7 +19,7 @@
         <result column="channel_require" jdbcType="VARCHAR" property="channelRequire" />
         <result column="channel_explain" jdbcType="VARCHAR" property="channelExplain" />
         <result column="title" jdbcType="VARCHAR" property="title" />
-
+        <result column="open_address" jdbcType="INTEGER" property="openAddress"/>
     </resultMap>
     <select id="getList" parameterType="java.lang.Integer" resultMap="ChannelProductMap">
@@ -61,6 +61,10 @@
         where id = #{id}
     </update>
+    <update id="updateProductOpenAddress">
+        update channel_product set open_address=#{openAddress} where id=#{id}
+    </update>
+
     <update id="deleteChannelProduct" parameterType="java.lang.Integer">
         update channel_product set state=0 where channelId=#{id}
     </update>
@@ -0,0 +1,58 @@		@@ -0,0 +1,58 @@
	1	+//package com.sincere.wechatbusiness.controller;
	2	+//
	3	+//import com.alibaba.fastjson.JSONObject;
	4	+//import com.sincere.wechatbusiness.utils.HttpClientUtils;
	5	+//import org.springframework.web.bind.annotation.RestController;
	6	+//
	7	+//import java.io.*;
	8	+//import java.net.HttpURLConnection;
	9	+//import java.net.URL;
	10	+//
	11	+//@RestController
	12	+//public class CodeController {
	13	+//
	14	+// private static String appId = "wxd055a716238e1bd7";
	15	+// private static String secret = "c6912d34732b65116b8b4e9d5f8a81a5";
	16	+//
	17	+// public static void main(String[] args){
	18	+// String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid="+appId+"&secret="+secret;
	19	+// JSONObject object = HttpClientUtils.httpGet(url) ;
	20	+// String token = object.get("access_token").toString();
	21	+// try {
	22	+// URL imgUrl = new URL("https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token="+token);
	23	+// HttpURLConnection httpURLConnection = (HttpURLConnection) imgUrl.openConnection();
	24	+// httpURLConnection.setRequestMethod("POST");// 提交模式
	25	+// // conn.setConnectTimeout(10000);//连接超时单位毫秒
	26	+// // conn.setReadTimeout(2000);//读取超时单位毫秒
	27	+// // 发送POST请求必须设置如下两行
	28	+// httpURLConnection.setDoOutput(true);
	29	+// httpURLConnection.setDoInput(true);
	30	+// // 获取URLConnection对象对应的输出流
	31	+// PrintWriter printWriter = new PrintWriter(httpURLConnection.getOutputStream());
	32	+// // 发送请求参数
	33	+// JSONObject paramJson = new JSONObject();
	34	+// paramJson.put("scene", "channel=2");
	35	+// paramJson.put("page", "pages/index/index");
	36	+// paramJson.put("width", 430);
	37	+// paramJson.put("auto_color", true);
	38	+// printWriter.write(paramJson.toString());
	39	+// // flush输出流的缓冲
	40	+// printWriter.flush();
	41	+// //开始获取数据
	42	+// BufferedInputStream bis = new BufferedInputStream(httpURLConnection.getInputStream());
	43	+// OutputStream os = new FileOutputStream(new File("C:\\Users\\chen\\Desktop\\abc.png"));
	44	+// int len;
	45	+// byte[] arr = new byte[1024];
	46	+// while ((len = bis.read(arr)) != -1)
	47	+// {
	48	+// os.write(arr, 0, len);
	49	+// os.flush();
	50	+// }
	51	+// os.close();
	52	+// }
	53	+// catch (Exception e)
	54	+// {
	55	+// e.printStackTrace();
	56	+// }
	57	+// }
	58	+//}
@@ -0,0 +1,107 @@		@@ -0,0 +1,107 @@
	1	+//package com.sincere.wechatbusiness.controller;
	2	+//
	3	+//import com.sincere.wechatbusiness.dto.BaseDto;
	4	+//import com.sincere.wechatbusiness.mapper.ChannelMapper;
	5	+//import com.sincere.wechatbusiness.model.Banner;
	6	+//import com.sincere.wechatbusiness.model.BannerNext;
	7	+//import com.sincere.wechatbusiness.model.ChannelProduct;
	8	+//import com.sincere.wechatbusiness.service.BannerService;
	9	+//import com.sincere.wechatbusiness.service.ChannelProductService;
	10	+//import com.sincere.wechatbusiness.service.ChannelService;
	11	+//import org.apache.commons.lang3.StringUtils;
	12	+//import org.springframework.beans.factory.annotation.Autowired;
	13	+//import org.springframework.web.bind.annotation.RequestMapping;
	14	+//import org.springframework.web.bind.annotation.RequestMethod;
	15	+//import org.springframework.web.bind.annotation.RestController;
	16	+//
	17	+//import java.io.BufferedReader;
	18	+//import java.io.FileReader;
	19	+//import java.io.IOException;
	20	+//import java.util.List;
	21	+//
	22	+//@RestController
	23	+//public class TestController {
	24	+//
	25	+// @Autowired
	26	+// ChannelService channelService ;
	27	+//
	28	+// @Autowired
	29	+// ChannelProductService channelProductService ;
	30	+//
	31	+// @Autowired
	32	+// BannerService bannerService ;
	33	+//
	34	+// @Autowired
	35	+// ChannelMapper channelMapper ;
	36	+//
	37	+//
	38	+// public static void main(String[] args){
	39	+// try {
	40	+// FileReader fr = new FileReader("C:\\Users\\chen\\Desktop\\name.txt");
	41	+// BufferedReader bf = new BufferedReader(fr);
	42	+// String str;
	43	+// // 按行读取字符串
	44	+// while ((str = bf.readLine()) != null) {
	45	+// String[] message = str.split("=");
	46	+// System.out.println(message[0]+"="+ message[1] +"="+ java.net.URLEncoder.encode(message[2], "UTF-8"));
	47	+// }
	48	+// bf.close();
	49	+// fr.close();
	50	+// } catch (IOException e) {
	51	+// e.printStackTrace();
	52	+// }
	53	+// }
	54	+//
	55	+// @RequestMapping(value = "copy",method = RequestMethod.GET)
	56	+// public BaseDto copyChannel(){
	57	+// int sourceId = 1025 ;
	58	+// ChannelProduct channelProduct = channelProductService.getList(sourceId).get(0);
	59	+// List<Banner> banners = bannerService.getList(sourceId);
	60	+// List<BannerNext> bannerNexts = bannerService.getBannerNextList(sourceId);
	61	+//
	62	+// try {
	63	+// FileReader fr = new FileReader("C:\\Users\\chen\\Desktop\\name.txt");
	64	+// BufferedReader bf = new BufferedReader(fr);
	65	+// String str;
	66	+// // 按行读取字符串
	67	+// while ((str = bf.readLine()) != null) {
	68	+// int channelId = 0;
	69	+// try{
	70	+// channelId = channelMapper.getByName(str.trim() + "团购").getId();
	71	+// }catch (Exception e){
	72	+// System.out.println(str);
	73	+// e.printStackTrace();
	74	+// }
	75	+// int channelProductId = 0 ;
	76	+// List<ChannelProduct> products = channelProductService.getList(channelId);
	77	+// for(ChannelProduct product : products){
	78	+// channelProductId = product.getId();
	79	+// product.setTitle(channelProduct.getTitle());
	80	+// product.setCaption(channelProduct.getCaption());
	81	+// product.setChannelPrice(channelProduct.getChannelPrice());
	82	+// channelProductService.update(product);
	83	+// }
	84	+//
	85	+// bannerService.deleteChannelBanner(channelId);
	86	+// bannerService.deleteChannelBannerNext(channelId);
	87	+// for(Banner banner : banners){
	88	+// banner.setChannelId(channelId);
	89	+// if(StringUtils.isNotBlank(banner.getLinkUrl())){
	90	+// banner.setLinkUrl("http://market.myjxt.com/wap/index.html#/CommodityDetail?id="+channelProductId+"&productId=1");
	91	+// }
	92	+// bannerService.copy(banner);
	93	+// }
	94	+// for(BannerNext bannerNext : bannerNexts){
	95	+// bannerNext.setChannelId(channelId);
	96	+// bannerService.copyBannerNext(bannerNext);
	97	+// }
	98	+// }
	99	+// bf.close();
	100	+// fr.close();
	101	+// } catch (IOException e) {
	102	+// e.printStackTrace();
	103	+// }
	104	+//
	105	+// return new BaseDto();
	106	+// }
	107	+//}
@@ -0,0 +1,91 @@		@@ -0,0 +1,91 @@
	1	+package com.sincere.wechatbusiness.controller;
	2	+
	3	+import com.alibaba.fastjson.JSONObject;
	4	+import com.sincere.wechatbusiness.model.AccessToken;
	5	+import com.sincere.wechatbusiness.model.Token;
	6	+import com.sincere.wechatbusiness.service.ChannelService;
	7	+import io.swagger.annotations.ApiOperation;
	8	+import org.springframework.beans.factory.annotation.Autowired;
	9	+import org.springframework.web.bind.annotation.RequestMapping;
	10	+import org.springframework.web.bind.annotation.RequestMethod;
	11	+import org.springframework.web.bind.annotation.RestController;
	12	+
	13	+import java.io.IOException;
	14	+import java.io.InputStream;
	15	+import java.net.HttpURLConnection;
	16	+import java.net.MalformedURLException;
	17	+import java.net.URL;
	18	+import java.util.Calendar;
	19	+import java.util.Date;
	20	+
	21	+@RestController
	22	+public class TokenController {
	23	+
	24	+ @Autowired
	25	+ ChannelService channelService ;
	26	+
	27	+ @ApiOperation(value = "获取分享token")
	28	+ @RequestMapping(value = "getToken",method = RequestMethod.GET)
	29	+ public String getToken(){
	30	+ AccessToken accessToken=channelService.getAccessToken();
	31	+ Token token=new Token();
	32	+ if(accessToken!=null) {
	33	+ Calendar dateOne=Calendar.getInstance();
	34	+ Calendar dateTwo=Calendar.getInstance();
	35	+ dateOne.setTime(new Date());
	36	+ dateTwo.setTime(accessToken.getCreateTime());
	37	+ long timeOne=dateOne.getTimeInMillis();
	38	+ long timeTwo=dateTwo.getTimeInMillis();
	39	+ long minute=(timeOne-timeTwo)/(1000*60);
	40	+
	41	+ if(minute<60) token.setAccess_token(accessToken.getAccessToken());
	42	+ else{
	43	+ token=getAccessToken("wx6078ff3f67524996","8a0465b8ad0f000f568f48853e2818c8");
	44	+ accessToken.setAccessToken(token.getAccess_token());
	45	+ channelService.insertAccessToken(accessToken);
	46	+ }
	47	+ }
	48	+ else {
	49	+ token=getAccessToken("wx6078ff3f67524996","8a0465b8ad0f000f568f48853e2818c8");
	50	+ accessToken=new AccessToken();
	51	+ accessToken.setAccessToken(token.getAccess_token());
	52	+ channelService.insertAccessToken(accessToken);
	53	+ }
	54	+ return accessToken.getAccessToken() ;
	55	+ }
	56	+
	57	+ public Token getAccessToken(String appID, String appScret) {
	58	+ Token token = new Token();
	59	+ String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appID + "&secret="
	60	+ + appScret;
	61	+ try {
	62	+ URL getUrl=new URL(url);
	63	+ HttpURLConnection http=(HttpURLConnection)getUrl.openConnection();
	64	+ http.setRequestMethod("GET");
	65	+ http.setRequestProperty("Content-Type",
	66	+ "application/x-www-form-urlencoded");
	67	+ http.setDoOutput(true);
	68	+ http.setDoInput(true);
	69	+
	70	+
	71	+ http.connect();
	72	+ InputStream is = http.getInputStream();
	73	+ int size = is.available();
	74	+ byte[] b = new byte[size];
	75	+ is.read(b);
	76	+
	77	+ String message = new String(b, "UTF-8");
	78	+ JSONObject json = JSONObject.parseObject(message);
	79	+
	80	+
	81	+ token.setAccess_token(json.getString("access_token"));
	82	+ token.setExpires_in(new Integer(json.getString("expires_in")));
	83	+ } catch (MalformedURLException e) {
	84	+ e.printStackTrace();
	85	+ } catch (IOException e) {
	86	+ e.printStackTrace();
	87	+ }
	88	+ return token;
	89	+ }
	90	+
	91	+}
	@@ -8,6 +8,8 @@ import java.util.List;		@@ -8,6 +8,8 @@ import java.util.List;
8		8
9	public interface ChannelMapper {	9	public interface ChannelMapper {
10		10
		11	+ Channel getByName(String name);
		12	+
11	List<Channel> getListByTemplate(int templateId);	13	List<Channel> getListByTemplate(int templateId);
12		14
13	List<Channel> getList(Channel channel);	15	List<Channel> getList(Channel channel);
	@@ -32,6 +32,16 @@ public class ChannelProduct {		@@ -32,6 +32,16 @@ public class ChannelProduct {
32	private String channelRequire ;	32	private String channelRequire ;
33	private String channelExplain ;	33	private String channelExplain ;
34		34
		35	+ private int openAddress ;
		36	+
		37	+ public int getOpenAddress() {
		38	+ return openAddress;
		39	+ }
		40	+
		41	+ public void setOpenAddress(int openAddress) {
		42	+ this.openAddress = openAddress;
		43	+ }
		44	+
35	public String getChannelTitle() {	45	public String getChannelTitle() {
36	return channelTitle;	46	return channelTitle;
37	}	47	}
	@@ -32,4 +32,9 @@ public class ChannelProductServiceImpl implements ChannelProductService {		@@ -32,4 +32,9 @@ public class ChannelProductServiceImpl implements ChannelProductService {
32	public int updateChannelProductMsg(ChannelProduct channelProduct) {	32	public int updateChannelProductMsg(ChannelProduct channelProduct) {
33	return channelProductMapper.updateChannelProductMsg(channelProduct);	33	return channelProductMapper.updateChannelProductMsg(channelProduct);
34	}	34	}
		35	+
		36	+ @Override
		37	+ public int updateProductOpenAddress(int openAddress, int id) {
		38	+ return channelProductMapper.updateProductOpenAddress(openAddress,id);
		39	+ }
35	}	40	}