huahuibao/biz/message/classes/InformAdminClass.php

<?php

namespace biz\message\classes;

use biz\admin\classes\AdminClass;
use biz\admin\services\ShopAdminService;
use biz\user\classes\UserClass;
use common\components\httpUtil;
use common\components\wxUtil;
use common\services\xhTMessageService;
use Yii;
use biz\base\classes\BaseClass;

class InformAdminClass extends BaseClass
{
	
	public static $baseFile = '\biz\message\models\InformAdmin';
	
	//增加通知员工 shish
	public static function addInform($params, $shopAdmin, $type, $TMList)
	{
		//没有关注公众号暂时不进行通知
		$subscribe = isset($shopAdmin['adminBaseInfo']['subscribe']) ? $shopAdmin['adminBaseInfo']['subscribe'] : 0;
		if ($subscribe == 0) {
			return false;
		}
		//没有小程序id暂时不进行通知，目前只有小程序商家版，没有h5
		$miniOpenId = isset($shopAdmin['adminBaseInfo']['miniOpenId']) ? $shopAdmin['adminBaseInfo']['miniOpenId'] : '';
		if (empty($miniOpenId)) {
			return false;
		}
		switch ($type) {
			case 'goodsSold':
				//宝贝售出
				$respond = self::goodsSoldInform($params, $shopAdmin, $TMList);
				break;
			case 'income':
				//收入提醒
				$respond = self::incomeInform($params, $shopAdmin, $TMList);
				break;
			case 'send':
				$respond = self::sendInform($params, $shopAdmin, $TMList);
				break;
			default:
		}
		$shopAdminId = $shopAdmin['id'];
		$shopId = $shopAdmin['shopId'];
		$mobile = isset($shopAdmin['adminBaseInfo']['mobile']) ? $shopAdmin['adminBaseInfo']['mobile'] : '';
		//通知管理员的都是平台通知
		$isOpen = 1;
		$data = [
			'messageType' => 'inform',
			'informWay' => 'miniProgram',
			'userType' => 'admin',
			'mobile' => $mobile,
			'shopAdminId' => $shopAdminId,
			'userId' => 0,
			'shopId' => $shopId,
			'isOpen' => $isOpen,
		];
		$data = array_merge($data, $respond);
		$producer = Yii::$app->rabbitmq->getProducer('informProducer');
		$msg = serialize($data);
		Yii::info('消息通知：' . $msg);
		$producer->publish($msg, 'informExchange', 'informRoute');
		
	}
	
	//宝贝售出提醒 shish 2020.5.31
	public static function goodsSoldInform($params, $admin, $TMList)
	{
		$totalFee = isset($params['totalFee']) ? $params['totalFee'] : 0;
		$orderId = isset($params['orderId']) ? $params['orderId'] : '';
		$orderSn = isset($params['orderSn']) ? $params['orderSn'] : '';
		$orderName = '商品';
		$userName = '石头';
		$data['briefContent'] = "客户" . $userName . "付款" . $totalFee . '元';
		//收入提醒
		$openId = isset($admin['adminBaseInfo']['openId']) ? $admin['adminBaseInfo']['openId'] : '';
		$miniOpenId = isset($admin['adminBaseInfo']['miniOpenId']) ? $admin['adminBaseInfo']['miniOpenId'] : '';
		$shortTempId = 'OPENTM207422813';
		$tempId = isset($TMList[$shortTempId]) ? $TMList[$shortTempId] : '';
		$tMessage = [
			"touser" => $openId,
			"template_id" => $tempId,
			"url" => Yii::$app->params['adminUrl'] . '/order/detail',
			"data" => [
				"first" => ["value" => '您有新的收入！', "color" => "#173177"],
				"keyword1" => ["value" => (string)$orderSn, "color" => "#173177"],
				"keyword2" => ["value" => $orderName, "color" => "#173177"],
				"keyword3" => ["value" => number_format($totalFee, 2) . '元', "color" => "#173177"],
				"keyword4" => ["value" => number_format($totalFee, 2) . '元', "color" => "#173177"],
				"keyword5" => ["value" => $userName, "color" => "#173177"],
				"remark" => ["value" => '点此查看详细', "color" => "#173177"]
			]
		];
		if (!empty($miniOpenId)) {
			$tMessage['miniprogram']['appid'] = $params['miniAppId'];
			$tMessage['miniprogram']['pagepath'] = 'admin/order/detail?id=' . $orderId;
		}
		$data['tMessage'] = json_encode($tMessage);
		$msg = "客户" . $userName . "付款" . $totalFee . '元';
		$data['content'] = $msg;
		return $data;
	}
	
	//送到通知 shish 2020.1.31
	public static function sendInform($params, $admin, $TMList)
	{
		$totalFee = 199;
		$userName = '石头';
		$orderId = $params['orderId'];
		$data['briefContent'] = "客户" . $userName . "付款" . $totalFee . '元';
		$openId = isset($admin['openId']) && !empty($admin['openId']) ? $admin['openId'] : '';
		$miniOpenId = isset($admin['miniOpenId']) && !empty($admin['miniOpenId']) ? $admin['miniOpenId'] : '';
		$shortTempId = 'OPENTM201205968';
		$tempId = isset($TMList[$shortTempId]) ? $TMList[$shortTempId] : '';
		$tMessage = [
			"touser" => $openId,
			"template_id" => $tempId,
			"url" => Yii::$app->params['frontUrl'] . "/center/order-detail?id=1225&account=12362",
			"data" => [
				"first" => ["value" => '客户订单已送达', "color" => "#173177"],
				"keyword1" => ["value" => (string)1525, "color" => "#173177"],
				"keyword2" => ["value" => '石头', "color" => "#173177"],
				"keyword3" => ["value" => '已送达', "color" => "#173177"],
				"remark" => ["value" => '。。。。。。。', "color" => "#173177"]
			]
		];
		if (!empty($miniOpenId)) {
			$tMessage['miniprogram']['appid'] = $params['miniAppId'];
			$tMessage['miniprogram']['pagepath'] = 'admin/order/detail?id=' . $orderId;
		}
		$data['tMessage'] = json_encode($tMessage);
		$msg = "客户" . $userName . "付款" . $totalFee . '元';
		$data['content'] = $msg;
		return $data;
	}
	
	//收入提醒 shish 2020.5.31
	public static function incomeInform($params, $admin, $TMList)
	{
		$order = $params['order'];
		$totalFee = isset($order['totalFee']) ? $order['totalFee'] : 0;
		$orderId = isset($order['orderId']) ? $order['orderId'] : '';
		$orderSn = isset($order['orderSn']) ? $order['orderSn'] : '';
		$payTime = isset($order['payTime']) && !empty($order['payTime']) ? date("Y-m-d H:i", $order['payTime']) : '未知';
		$store = isset($order['store']) ? $order['store'] : 0;
		$sourceTypeId = $order['sourceType'];
		if ($store == 1) {
			$incomeStyle = '门店收入';
		} else {
			$sourceTypeList = [0 => '微信', 1 => '支付宝', 2 => '小程序', 3 => '朋友圈', 4 => '美团', 5 => '系统'];
			$incomeStyle = isset($sourceTypeList[$sourceTypeId]) ? $sourceTypeList[$sourceTypeId] . '收入' : '未知';
		}
		$data = [];
		$data['briefContent'] = "客户付款" . $totalFee . '元';
		$openId = isset($admin['adminBaseInfo']['openId']) ? $admin['adminBaseInfo']['openId'] : '';
		$miniOpenId = isset($admin['adminBaseInfo']['miniOpenId']) ? $admin['adminBaseInfo']['miniOpenId'] : '';
		$shortTempId = 'OPENTM207422813';
		$tempId = isset($TMList[$shortTempId]) ? $TMList[$shortTempId] : '';
		$tMessage = [
			"touser" => $openId,
			"template_id" => $tempId,
			"url" => Yii::$app->params['adminUrl'] . '/order/detail',
			"data" => [
				"first" => ["value" => '您有新的收入~', "color" => "#173177"],
				"keyword1" => ["value" => number_format($totalFee, 2) . '元', "color" => "#173177"],
				"keyword2" => ["value" => $incomeStyle, "color" => "#173177"],
				"keyword3" => ["value" => $payTime, "color" => "#173177"],
				"remark" => ["value" => '点此查看、发货', "color" => "#173177"]
			]
		];
		if (!empty($miniOpenId)) {
			$tMessage['miniprogram']['appid'] = $params['miniAppId'];
			$tMessage['miniprogram']['pagepath'] = 'admin/order/detail?id=' . $orderId;
		}
		$data['tMessage'] = json_encode($tMessage);
		$msg = "客户" . $userName . "付款" . $totalFee . '元';
		$data['content'] = $msg;
		return $data;
	}
	
	//添加通知内容 shish 2020.1.8
	public static function addData($data)
	{
		self::add($data);
	}
	
	//订单完成通知店长 shish 2020.3.19
	public static function sendComplete($order, $merchant)
	{
		$merchantId = $merchant['id'];
		$orderId = $order['id'];
		$shopId = $order['shopId'];
		$adminList = ShopAdminService::getNoticeAdminList($shopId);
		$tm = xhTMessageService::getList($merchantId);
		$shortTempId = 'OPENTM201205968';//订单送达通知
		$tempId = $tm[$shortTempId];
		if (!empty($adminList)) {
			foreach ($adminList as $admin) {
				if (isset($admin['subscribe']) && $admin['subscribe'] == 1) {
					$openId = $admin['openId'];
					$miniOpenId = $admin['miniOpenId'];
					$url = Yii::$app->params['shopDomain'] . "/#/admin/order/detail?id=" . $order['id'];
					$url = httpUtil::becomeHttps($url);
					$data = [
						"touser" => $openId,
						"template_id" => $tempId,
						"url" => $url,
						"data" => [
							"first" => ["value" => '客户订单已送达', "color" => "#173177"],
							"keyword1" => ["value" => (string)$order['orderSn'], "color" => "#173177"],
							"keyword2" => ["value" => $order['bookName'], "color" => "#173177"],
							"keyword3" => ["value" => '已送达', "color" => "#173177"],
							"remark" => ["value" => '', "color" => "#173177"]
						]
					];
					if (!empty($miniOpenId)) {
						$data['miniprogram']['appid'] = $merchant['miniAppId'];
						$data['miniprogram']['pagepath'] = 'admin/order/detail?id=' . $orderId;
					}
					wxUtil::sendTaskInform($data, $merchant);
				}
			}
		}
	}
	
}