上传文件

mhotel/src/com/happy/action/appAction.java

@@ -0,0 +1,465 @@
+package com.happy.action;
+
+import com.google.gson.Gson;
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.reflect.TypeToken;
+import com.happy.Model.*;
+import com.happy.Model.app.News;
+import com.happy.Model.weixin.*;
+import com.happy.Until.*;
+import com.happy.common.http.Get_airticle;
+import com.happy.common.http.HttpsClient;
+import com.happy.common.http.Message2;
+import com.happy.common.http.Message3;
+import com.happy.common.model.airticle.Content;
+import com.happy.common.model.airticle.Item_content;
+import com.happy.common.model.airticle.News_content;
+import com.happy.common.util.WechatUtil;
+import com.happy.common.wx.WxUtil;
+import com.happy.service.*;
+import com.opensymphony.xwork2.ActionSupport;
+import org.apache.struts2.ServletActionContext;
+import org.apache.struts2.interceptor.ServletRequestAware;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.HttpSession;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+public class appAction extends ActionSupport implements ServletRequestAware {
+
+    private HttpServletRequest request;
+    public HttpServletResponse response;
+
+    @Resource
+    public UserService userService;
+    @Resource
+    public BookService bookService;
+    @Resource
+    public HouseService houseService;
+    @Resource
+    public ConfigService configService;
+    @Resource
+    public AppService appService;
+
+    public String wxcode;
+    public String state;
+    public String code;
+    public String order_num;
+    public String card_number;
+    public String phone;
+    public String admin_name;
+    public String password;
+    public String openid;
+    public int page; // 当前页
+    public int rows;// 每页显示的行数rows
+
+    public HttpServletRequest getRequest() {
+        return request;
+    }
+
+    public void setRequest(HttpServletRequest request) {
+        this.request = request;
+    }
+
+    public void setServletRequest(HttpServletRequest request) {
+        this.request = request;
+    }
+
+    public HttpServletResponse getResponse() {
+        return response;
+    }
+
+    public void setResponse(HttpServletResponse response) {
+        this.response = response;
+    }
+
+    public String getState() {
+        return state;
+    }
+
+    public void setState(String state) {
+        this.state = state;
+    }
+
+    public String getWxcode() {
+        return wxcode;
+    }
+
+    public void setWxcode(String wxcode) {
+        this.wxcode = wxcode;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getOrder_num() {
+        return order_num;
+    }
+
+    public void setOrder_num(String order_num) {
+        this.order_num = order_num;
+    }
+
+    public String getCard_number() {
+        return card_number;
+    }
+
+    public void setCard_number(String card_number) {
+        this.card_number = card_number;
+    }
+
+    public String getPhone() {
+        return phone;
+    }
+
+    public void setPhone(String phone) {
+        this.phone = phone;
+    }
+
+    public String getAdmin_name() {
+        return admin_name;
+    }
+
+    public void setAdmin_name(String admin_name) {
+        this.admin_name = admin_name;
+    }
+
+    public String getPassword() {
+        return password;
+    }
+
+    public void setPassword(String password) {
+        this.password = password;
+    }
+
+    public String getOpenid() {
+        return openid;
+    }
+
+    public void setOpenid(String openid) {
+        this.openid = openid;
+    }
+
+    public int getPage() {
+        return page;
+    }
+
+    public void setPage(int page) {
+        this.page = page;
+    }
+
+    public int getRows() {
+        return rows;
+    }
+
+    public void setRows(int rows) {
+        this.rows = rows;
+    }
+
+    public String test() throws Exception {
+        JSONObject resultJson = new JSONObject();
+        String msg = Message2.send(openid,"20231011163520","总统套房",
+                "2023-10-11","测试","测试","");
+        resultJson.put("message", "返回成功");
+        resultJson.put("code", 200);
+        resultJson.put("data",msg);
+        ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+        return null;
+    }
+
+    // 查询是否绑定
+    public String getUser(){
+        JSONObject resultJson = new JSONObject();
+        if (code==null){
+            resultJson.put("message", "code不能为空");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        JSONObject jsonObject = appService.getGCodeInfo(code);
+        Admin admin = appService.queryByOpenid(jsonObject.get("openid").toString());
+        if (admin==null){
+            resultJson.put("message", "未绑定信息");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        resultJson.put("message", "返回成功");
+        resultJson.put("code", 200);
+        resultJson.put("data", admin);
+        ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+        return null;
+    }
+
+    // 开始绑定
+    public String code() throws IOException {
+        JSONObject resultJson = new JSONObject();
+        if (code==null || admin_name==null || password==null){
+            resultJson.put("message", "参数不能为空");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        Admin login = appService.login(admin_name,password);
+        if (login==null){
+            resultJson.put("message", "账户或密码错误");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        JSONObject jsonObject = appService.getGCodeInfo(code);
+        Admin admin = appService.queryByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
+        if (admin!=null){
+            resultJson.put("message", "该账户已绑定，请勿重复绑定");
+            resultJson.put("code", 205);
+            resultJson.put("data",admin);
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        int m = appService.updateOpenid(jsonObject.get("openid").toString(),admin_name);
+        if (m>0){
+            admin = appService.queryByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
+            resultJson.put("message", "绑定成功");
+            resultJson.put("code", 200);
+            resultJson.put("data",admin);
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        return null;
+    }
+
+    // 解绑
+    public String uncode(){
+        JSONObject resultJson = new JSONObject();
+        if (code==null || admin_name==null || password==null){
+            resultJson.put("message", "参数不能为空");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        Admin login = appService.login(admin_name,password);
+        if (login==null){
+            resultJson.put("message", "账户或密码错误");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        JSONObject jsonObject = appService.getGCodeInfo(code);
+        Admin admin = appService.queryByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
+        if (admin==null){
+            resultJson.put("message", "输入信息与当前绑定账户不匹配");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        int m = appService.updateOpenidNull(jsonObject.get("openid").toString());
+        if (m>0){
+            resultJson.put("message", "解绑成功");
+            resultJson.put("code", 200);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        resultJson.put("message", "解绑失败");
+        resultJson.put("code", 205);
+        resultJson.put("data","");
+        ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+        return null;
+    }
+
+    /******************************商户绑定*******************************/
+    public String get_user_ma(){
+        JSONObject resultJson = new JSONObject();
+        if (code==null){
+            resultJson.put("message", "参数不能为空");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        JSONObject jsonObject = appService.getGCodeInfo(code);
+        AdminManager admin = appService.queryMaByOpenid(jsonObject.get("openid").toString());
+        if (admin==null){
+            resultJson.put("message", "未绑定信息");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        resultJson.put("message", "返回成功");
+        resultJson.put("code", 200);
+        resultJson.put("data", admin);
+        ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+        return null;
+    }
+
+    public String manage_code(){
+        JSONObject resultJson = new JSONObject();
+        if (code==null || admin_name==null || password==null){
+            resultJson.put("message", "参数不能为空");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        AdminManager login = appService.login_ma(admin_name,password);
+        if (login==null){
+            resultJson.put("message", "账户或密码错误");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        if (login.getLevel().equals("1")){
+            resultJson.put("message", "管理员无权限绑定");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        JSONObject jsonObject = appService.getGCodeInfo(code);
+        AdminManager admin = appService.queryMaByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
+        if (admin!=null){
+            resultJson.put("message",  "该账户已绑定，请勿重复绑定");
+            resultJson.put("code", 205);
+            resultJson.put("data",admin);
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+
+        int m = appService.updateMaOpenid(jsonObject.get("openid").toString(),admin_name);
+        if (m>0){
+            admin = appService.queryMaByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
+            resultJson.put("message", "绑定成功");
+            resultJson.put("code", 200);
+            resultJson.put("data",admin);
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        return null;
+    }
+
+    public String uncode_ma(){
+        JSONObject resultJson = new JSONObject();
+        if (code==null || admin_name==null || password==null){
+            resultJson.put("message", "参数不能为空");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        AdminManager login = appService.login_ma(admin_name,password);
+        if (login==null){
+            resultJson.put("message", "账户或密码错误");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        JSONObject jsonObject = appService.getGCodeInfo(code);
+        AdminManager admin = appService.queryMaByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
+        if (admin==null){
+            resultJson.put("message", "输入信息与当前绑定账户不匹配");
+            resultJson.put("code", 205);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        int m = appService.updateMaOpenidNull(jsonObject.get("openid").toString());
+        if (m>0){
+            resultJson.put("message", "解绑成功");
+            resultJson.put("code", 200);
+            resultJson.put("data","");
+            ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+            return null;
+        }
+        resultJson.put("message", "解绑失败");
+        resultJson.put("code", 205);
+        resultJson.put("data","");
+        ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
+        return null;
+    }
+
+    /**=============================新闻资讯==============================**/
+    public String autoInsertNews() throws Exception {
+        int total = Get_airticle.getTotal();
+        int rows = 10;
+        int page = total % rows == 0 ? (total / rows)
+                : (total / rows) + 1;
+        for (int k = 0; k < page; k++) {
+            List<Item_content> litem = appService.getNews(k,rows);
+            for (int i = 0; i < litem.size(); i++) {
+                Item_content ic = litem.get(i);
+                Content content = ic.getContent();
+                List<News_content> news_item = content.getNews_item();
+                for (int j = 0; j < news_item.size(); j++) {
+                    News news = appService.queryByTit(news_item.get(j).getTitle());
+                    if (news==null){
+                        System.out.println("插入标题："+news_item.get(j).getTitle());
+                        News nw = new News();
+                        nw.setTitle(news_item.get(j).getTitle());
+                        nw.setAuthor(news_item.get(j).getAuthor());
+                        nw.setContent(news_item.get(j).getContent());
+                        nw.setDigest(news_item.get(j).getDigest());
+                        nw.setContent_source_url(news_item.get(j).getContent_source_url());
+                        nw.setUpdate_time(TimeExchange.getTime());
+                        appService.insertNews(nw);
+                    }
+                }
+            }
+        }
+        return null;
+    }
+
+    public String newlist() {
+        JSONObject resultJson = new JSONObject();
+        int total = appService.queryNewTotal("");// 查询表中的总记录数
+        List<News> listPage = appService.queryNewPage(page, rows,"");// 查询分页
+
+        if (listPage == null) {
+            resultJson.put("rows", "");
+            resultJson.put("total", 0);
+        } else {
+            resultJson.put("code", 200);
+            resultJson.put("rows", listPage);
+            // int total = listAll.size();
+            resultJson.put("total", total);// 总记录数
+            int totalPage = total % rows == 0 ? (total / rows)
+                    : (total / rows) + 1;// 总页数
+            resultJson.put("totalPage", totalPage);
+            resultJson.put("currentPage", page);// 当前页
+            resultJson.put("numPerPage", rows);// 每页数
+            resultJson.put("nextPage", totalPage - page == 0 ? page : page + 1);// 下一页
+            resultJson.put("previousPage", page - 0 == 1 ? page : page - 1);// 上一页
+            resultJson.put("hasPreviousPage", true);// 有上一页
+            resultJson.put("hasNextPage", true);// 有下一页
+            resultJson.put("firstPage", true);// 首页
+            resultJson.put("lastPage", true);// 尾页
+        }
+        ResponseUtil.writeJson(ServletActionContext.getResponse(),
+                resultJson.toString());
+        return null;
+    }
+
+}