ffpark_back.git

package com.boying.controller.phone;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.boying.common.BaseController;
import com.boying.common.SystemConfigProperties;
import com.boying.common.util.HttpUtil;
import com.boying.entity.*;
import com.boying.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.util.DigestUtils;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
 
import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import javax.servlet.http.HttpServletRequest;
 
import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.UnsupportedEncodingException;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import static com.boying.common.util.MyX509TrustManager.httpsRequest;
 
@RestController
@RequestMapping("ffPay")
public class FFPayController extends BaseController {
 
    @Autowired
    private TicketService ticketService;
    @Autowired
    private SystemConfigProperties systemConfigProperties;
    @Autowired
    private OutParkService outParkService;
    @Autowired
    private OrderRecordService orderRecordService;
    @Autowired
    private ParkService parkService;
    @Autowired
    private BarrierService barrierService;
    @Autowired
    private EnterParkService enterParkService;
    @Autowired
    private TicketBlackService ticketBlackService;
    @Autowired
    private WhiteListService whiteListService;
 
    static String payKey = "df937eda27cb4a59a12347966678e232";
    static String paySecret = "9e3b2f387b5b4232a9c782affc9c36ed";
    static String payerTypeCode = "1304062100000001";
    static String payerTypeCode2 = "1304062100000002";
    static String ip = "https://pay.hebcz.cn";
    static String ip2 = "http://nontax.hebcz.cn";
 
 
    //生成电子缴款码
    @PostMapping("zhiFa")
    public Object zhiFa(Long id){
        Ticket ticket = (Ticket) ticketService.findById(id);
        if(ticket.getPayStatus()==1){
            return error("此罚单已支付");
        }
        if(ticket.getStatus()==3){
            return error("此罚单已撤销");
        }
 
//        StringBuffer sbf = new StringBuffer();
////        StringBuffer s = new StringBuffer();
////        if(ticket.getMoney()==0){
////            s.append("amt=0.01");
////        }else{
////            DecimalFormat df = new DecimalFormat("#.00");
////            s.append("amt="+df.format(ticket.getMoney()));
////        }
////        s.append("&notifyUrl="+systemConfigProperties.getIp()+"ffPay/result");//回调的url
////        s.append("&payKey="+payKey);//财政给的
////        s.append("&payerName="+ticket.getCarNo());
////        s.append("&payerNum="+ ticket.getCode());//订单号
////        s.append("&payerTypeCode="+payerTypeCode);////财政给的
////        s.append("&reserve1=");
////        s.append("&reserve2=");
////        s.append("&reserve3=");
////        s.append("&returnUrl=");
////        sbf.append(s.toString());
////        s.append("&paySecret="+paySecret);////财政给的
////
////        String encode = DigestUtils.md5DigestAsHex(s.toString().getBytes());
////        sbf.append("&sign="+encode);
////        sbf.append("&signType=MD5");
////        System.out.println(sbf.toString());
////        String s1 = httpsRequest(ip+"/pay/inpay","POST",sbf.toString());
        StringBuffer sbf = new StringBuffer();
        StringBuffer s = new StringBuffer();
        if(ticket.getMoney()==0){
            s.append("amt=0.01");
        }else{
            DecimalFormat df = new DecimalFormat("#0.00");
            s.append("amt="+df.format(ticket.getMoney()).toString());
        }
        s.append("&notifyUrl="+systemConfigProperties.getIp()+"ffPay/result");
        s.append("&payKey=df937eda27cb4a59a12347966678e232");
        s.append("&payerName="+ticket.getCarNo());
        s.append("&payerNum="+ticket.getCode());
        s.append("&payerTypeCode=1304062100000001");
        s.append("&reserve1=");
        s.append("&reserve2=");
        s.append("&reserve3=");
        s.append("&returnUrl=");
        sbf.append(s.toString());
        s.append("&paySecret=9e3b2f387b5b4232a9c782affc9c36ed");
 
        String encode = null;
        try {
            encode = DigestUtils.md5DigestAsHex(s.toString().getBytes("UTF-8"));
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        sbf.append("&sign="+encode);
        sbf.append("&signType=MD5");
        System.out.println(sbf.toString());
        String s1 = httpsRequest(ip + "/pay/inpay", "POST", sbf.toString());
        System.out.println(s1);
        if(s1.equals("error")){
            return error("生成电子缴款码失败，请联系管理员");
        }
        JSONObject jsonObject = JSON.parseObject(s1);
        String payCode = "";
        if(jsonObject.get("payCode")==null){
            String eInfo = jsonObject.get("errorInfo").toString();
            if(eInfo.equals("此订单已过期")){
                ticket.setCode(System.currentTimeMillis()+"");
                String payCode2 = zhiFa2(ticket);
                ticket.setPayCode(payCode2);
                ticketService.save(ticket);
                addOrderRecord2(ticket);
                return success("生成执法电子缴款码","https://hbfs.govpay.ccb.com/online/fssm?fee=130000000001&PyfScnCgycd=01&pyfTpcd=3&BNo="+payCode);
            }
            return error(jsonObject.get("errorInfo").toString());
        }
        payCode = jsonObject.get("payCode").toString();
        ticket.setPayCode(payCode);
        ticketService.save(ticket);
 
        addOrderRecord2(ticket);
        return success("生成执法电子缴款码","https://hbfs.govpay.ccb.com/online/fssm?fee=130000000001&PyfScnCgycd=01&pyfTpcd=3&BNo="+payCode);
    }
 
    public String zhiFa2(Ticket ticket){
        StringBuffer sbf = new StringBuffer();
        StringBuffer s = new StringBuffer();
        if(ticket.getMoney()==0){
            s.append("amt=0.01");
        }else{
            DecimalFormat df = new DecimalFormat("#0.00");
            s.append("amt="+df.format(ticket.getMoney()).toString());
        }
        s.append("&notifyUrl="+systemConfigProperties.getIp()+"ffPay/result");
        s.append("&payKey=df937eda27cb4a59a12347966678e232");
        s.append("&payerName="+ticket.getCarNo());
        s.append("&payerNum="+ticket.getCode());
        s.append("&payerTypeCode=1304062100000001");
        s.append("&reserve1=");
        s.append("&reserve2=");
        s.append("&reserve3=");
        s.append("&returnUrl=");
        sbf.append(s.toString());
        s.append("&paySecret=9e3b2f387b5b4232a9c782affc9c36ed");
 
        String encode = null;
        try {
            encode = DigestUtils.md5DigestAsHex(s.toString().getBytes("UTF-8"));
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        sbf.append("&sign="+encode);
        sbf.append("&signType=MD5");
        String s1 = httpsRequest(ip + "/pay/inpay", "POST", sbf.toString());
        JSONObject jsonObject = JSON.parseObject(s1);
        String payCode = jsonObject.get("payCode").toString();
        return payCode;
    }
 
 
    //支付接口通知
    @PostMapping("result")
    public String result(HttpServletRequest request,String payKey,String payerTypeCode,String payerNum,String payCode,Double amt,String status,String errorInfo,String sign,String signType) throws Exception{
        System.out.println(payCode+"-------"+status);
        String s = "payCode===="+payCode+",\n";
        try {
            s += "开始走回调接口------>";
            writeTxt(s);
            updateOrderRecord(payCode,status);
        }catch (Exception e){
            s += "更新订单记录出异常------>";
            writeTxt(s);
        }
        return "success";
    }
 
    //更新订单记录
    public void updateOrderRecord(String payCode,String status){
        String s = "更新订单记录：payCode===="+payCode+",status==="+status+",\n";
        Specification<OrderRecord> specification = new Specification<OrderRecord>() {
            @Override
            public Predicate toPredicate(Root<OrderRecord> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
                List<Predicate> list = new ArrayList<Predicate>();
                list.add(cb.equal(root.get("payCode").as(String.class), payCode));
                Predicate[] arr = new Predicate[list.size()];
                cq.where(list.toArray(arr));
                return null;
            }
        };
        List<OrderRecord> all = orderRecordService.findAll(specification);
        s += "查询到订单记录为："+all.size()+"条，\n";
        if(all.size()==1){
            OrderRecord orderRecord = all.get(0);
            s += "查询到订单为："+orderRecord.getId()+"，\n";
            if(status.equals("01")){
                orderRecord.setStatus(0);
            }
            if(status.equals("03")){
                orderRecord.setStatus(1);
            }
            if(status.equals("04")||status.equals("05")||status.equals("06")){
                orderRecord.setStatus(2);
            }
            orderRecordService.save(orderRecord);
            if(orderRecord.getType()==0){
                updateTicket(orderRecord.getQueryId(),status);
            }else{
                s += "修改出场表："+orderRecord.getQueryId()+"，status==="+status+",\n";
                writeTxt(s);
                updateOutPark(orderRecord.getQueryId(),status);
            }
        }
        writeTxt(s);
    }
 
    //更新罚单的状态
    public void updateTicket(Long ticketId,String status){
        Ticket ticket = (Ticket) ticketService.findById(ticketId);
        if(ticket!=null){
            if(status.equals("01")){
                ticket.setPayStatus(0);
            }
            if(status.equals("03")){
                ticket.setPayStatus(1);
                dealCar(ticket.getCarNo());
            }
            if(status.equals("04")||status.equals("05")||status.equals("06")){
                ticket.setPayStatus(2);
            }
            ticketService.save(ticket);
        }
    }
 
    //更新缴费状态
    private void dealCar(String carNo){
        Specification<Ticket> specification2 = new Specification<Ticket>() {
            @Override
            public Predicate toPredicate(Root<Ticket> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
                List<Predicate> list = new ArrayList<Predicate>();
                list.add(cb.equal(root.get("carNo").as(String.class), carNo));
                list.add(cb.notEqual(root.get("payStatus"), 1));
                Predicate[] arr = new Predicate[list.size()];
                cq.where(list.toArray(arr));
                return null;
            }
        };
        List<Ticket> tickets = ticketService.findAll(specification2);
        if(tickets.size()==0){
            //更新缴费状态
            Specification<TicketBlack> specification = new Specification<TicketBlack>() {
                @Override
                public Predicate toPredicate(Root<TicketBlack> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
                    List<Predicate> list = new ArrayList<Predicate>();
                    list.add(cb.equal(root.get("carNo").as(String.class), carNo));
                    Predicate[] arr = new Predicate[list.size()];
                    cq.where(list.toArray(arr));
                    return null;
                }
            };
            List<TicketBlack> all = ticketBlackService.findAll(specification);
            for(TicketBlack ticketBlack:all){
                ticketBlack.setStatus(1);
                ticketBlack.setBlackType(0);
                ticketBlackService.save(ticketBlack);
            }
        }
    }
    //抬杆
//    public void updateOutPark(Long outParkId,String status){
//        OutPark outPark = (OutPark) outParkService.findById(outParkId);
//        if(outPark!=null){
//            if(status.equals("03")){
//                outPark.setStatus(1);
//                outParkService.save(outPark);
//                Barrier b= (Barrier) barrierService.findById(outPark.getBarrierId());
//                //调用抬杆接口 返回值：{"result":"true","msg":"操作完成"}
//                String res = HttpUtil.get(systemConfigProperties.getIp3()+"?barrierCode="+b.getCode());
//                JSONObject jsonObject = JSON.parseObject(res);
//                if(jsonObject.get("result").equals("true")){
//                    System.out.println("抬杆成功");
//
//                    deleteEnterPark(outPark.getCarNo());
//                }else{
//                    System.out.println("抬杆接口返回失败");
//                }
//            }
//        }
//    }
 
    public void updateOutPark(Long outParkId,String status){
        String s = "开始修改出场表-----》,\n";
        s+= "outparkId==="+outParkId+",status==="+status+",\n";
        writeTxt(s);
        OutPark outPark = (OutPark) outParkService.findById(outParkId);
        if(outPark!=null){
            s += "找到出场数据："+outPark.getId()+",\n";
            writeTxt(s);
            if(status.equals("03")){
                s += "出场数据修改----》";
                writeTxt(s);
                outPark.setStatus(1);
                outParkService.save(outPark);
            }
        }
        s += "未找到出场数据-----》";
        writeTxt(s);
    }
 
    //删除进停车场的数据
    public void deleteEnterPark(String carNo){
        Specification<EnterPark> specification = new Specification<EnterPark>() {
            @Override
            public Predicate toPredicate(Root<EnterPark> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
                List<Predicate> list = new ArrayList<Predicate>();
                list.add(cb.equal(root.get("carNo").as(String.class), carNo));
                Predicate[] arr = new Predicate[list.size()];
                cq.where(list.toArray(arr));
                return null;
            }
        };
        List<EnterPark> all = enterParkService.findAll(specification);
        for(EnterPark ep:all){
            enterParkService.delete(ep.getId());
        }
    }
 
    //生成电子缴款码
    @PostMapping("park")
    public Object park(Long id){
        String logs = "开始缴费流程------》";
        logs += "出场id为："+id+",\n";
        OutPark outPark = (OutPark) outParkService.findById(id);
        if(outPark.getPrice()==0){
            updateOutPark(outPark.getId(),"03");
            logs += "支付金额为0,\n";
            writeTxt(logs);
            return error("本次停车无需支付费用");
        }
 
        //判断是否在白名单
        Specification<WhiteList> specification = new Specification<WhiteList>() {
            @Override
            public Predicate toPredicate(Root<WhiteList> root, CriteriaQuery<?> cq, CriteriaBuilder cb) {
                List<Predicate> list = new ArrayList<Predicate>();
                list.add(cb.equal(root.get("carNo").as(String.class), outPark.getCarNo()));
                Predicate[] arr = new Predicate[list.size()];
                cq.where(list.toArray(arr));
                return null;
            }
        };
        List<WhiteList> all = whiteListService.findAll(specification);
        for(WhiteList w : all){
            if(w.getType()==0){
                logs+=outPark.getCarNo()+"在白名单,\n";
                updateOutPark(outPark.getId(),"03");
                writeTxt(logs);
                return error("本次停车无需支付费用!");
            }else{
                if(w.getParkId()!=null){
                    if(w.getEndTime()!=null){
                        if(w.getParkId()==outPark.getParkId()&&new Date().getTime()<w.getEndTime().getTime()){
                            logs+=outPark.getCarNo()+"在特殊规则白名单,\n";
                            updateOutPark(outPark.getId(),"03");
                            writeTxt(logs);
                            return error("本次停车无需支付费用!");
                        }
                    }
                }
            }
        }
 
        StringBuffer sbf = new StringBuffer();
        StringBuffer s = new StringBuffer();
        DecimalFormat df = new DecimalFormat("#0.00");
        s.append("amt="+df.format(outPark.getPrice()).toString());
        s.append("&notifyUrl="+systemConfigProperties.getIp()+"ffPay/result");//回调的url
        s.append("&payKey=df937eda27cb4a59a12347966678e232");//财政给的
        s.append("&payerName="+outPark.getCarNo());
        s.append("&payerNum="+ outPark.getCode());//订单号
        s.append("&payerTypeCode=1304062100000001");////财政给的
        s.append("&reserve1=");
        s.append("&reserve2=");
        s.append("&reserve3=");
        s.append("&returnUrl=");
        sbf.append(s.toString());
        s.append("&paySecret=9e3b2f387b5b4232a9c782affc9c36ed");////财政给的
 
        String encode = null;
        try {
            encode = DigestUtils.md5DigestAsHex(s.toString().getBytes("UTF-8"));
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
        sbf.append("&sign="+encode);
        sbf.append("&signType=MD5");
        String s1 = httpsRequest(ip+"/pay/inpay","POST",sbf.toString());
        if(s1.equals("error")){
            logs += "生成执法电子缴款码失败，请联系管理员,\n";
            writeTxt(logs);
            return error("生成执法电子缴款码失败，请联系管理员");
        }
        JSONObject jsonObject = JSON.parseObject(s1);
        if(jsonObject.get("payCode")==null){
            String eInfo = jsonObject.get("errorInfo").toString();
            if(eInfo.equals("此订单已过期")){
                outPark.setCode(System.currentTimeMillis()+"");
                outParkService.save(outPark);
                logs += "此订单已过期,\n";
                writeTxt(logs);
                return park(id);
            }else{
                logs += "此订单有异常错误,\n";
                writeTxt(logs);
                return error(eInfo);
            }
        }else{
            String payCode = jsonObject.get("payCode").toString();
            logs += "payCode: "+payCode+",\n";
            outPark.setPayCode(payCode);
            outParkService.save(outPark);
            writeTxt(logs);
            addOrderRecord(outPark);
            return success("生成停车电子缴款码","https://hbfs.govpay.ccb.com/online/fssm?fee=130000000001&PyfScnCgycd=01&pyfTpcd=3&BNo="+payCode);
        }
    }
 
 
    //插入停车订单记录
    public void addOrderRecord(OutPark outPark){
        Park park = (Park) parkService.findById(outPark.getParkId());
        OrderRecord orderRecord = new OrderRecord();
        orderRecord.setAddress(park.getName());
        orderRecord.setCarNo(outPark.getCarNo());
        orderRecord.setCode(outPark.getCode());
        orderRecord.setMoney(outPark.getPrice());
        orderRecord.setQueryId(outPark.getId());
        orderRecord.setType(1);
        orderRecord.setPayCode(outPark.getPayCode());
        orderRecordService.save(orderRecord);
    }
 
    //插入执法订单记录
    public void addOrderRecord2(Ticket ticket){
        OrderRecord orderRecord = new OrderRecord();
        orderRecord.setAddress(ticket.getAddress());
        orderRecord.setCarNo(ticket.getCarNo());
        orderRecord.setCode(ticket.getCode());
        orderRecord.setMoney(ticket.getMoney());
        orderRecord.setQueryId(ticket.getId());
        orderRecord.setType(0);
        orderRecord.setPayCode(ticket.getPayCode());
        orderRecordService.save(orderRecord);
    }
 
 
    private void writeTxt( String txt)
    {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
        try
        {
            FileWriter f = new FileWriter(systemConfigProperties.getLogPath()+"支付日志"+sdf.format(new Date())+".txt",true);
            BufferedWriter bw=new BufferedWriter(f);
            bw.write(txt);
            bw.newLine();
            bw.close();
        }
        catch(Exception e)
        {
            System.out.println("打印错误");
        }
    }
 
 
 
 
}